소스 검색

ledger_complaint表字段添加、相关代码修改、导入逻辑修改

wangxx 3 주 전
부모
커밋
4d9deb3c64

+ 1 - 9
airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerChannelPassRate.java

@@ -59,13 +59,11 @@ public class LedgerChannelPassRate extends BaseEntity {
59 59
     @Excel(name = "同步标志(0=未同步;1=已同步)")
60 60
     private String syncFlag;
61 61
 
62
-    // ID字段
62
+   // ID字段
63 63
     private Long responsibleId;
64 64
     private Long deptId;
65 65
     private Long teamId;
66 66
     private Long groupId;
67
-    private Long positionId;
68
-    private Long areaId;
69 67
     private String groupName;
70 68
 
71 69
     public Long getId() { return id; }
@@ -119,12 +117,6 @@ public class LedgerChannelPassRate extends BaseEntity {
119 117
     public Long getGroupId() { return groupId; }
120 118
     public void setGroupId(Long groupId) { this.groupId = groupId; }
121 119
 
122
-    public Long getPositionId() { return positionId; }
123
-    public void setPositionId(Long positionId) { this.positionId = positionId; }
124
-
125
-    public Long getAreaId() { return areaId; }
126
-    public void setAreaId(Long areaId) { this.areaId = areaId; }
127
-
128 120
     public String getDeptName() { return deptName; }
129 121
     public void setDeptName(String deptName) { this.deptName = deptName; }
130 122
 

+ 53 - 1
airport-ledger/src/main/java/com/sundot/airport/ledger/domain/LedgerComplaint.java

@@ -45,6 +45,21 @@ public class LedgerComplaint extends BaseEntity {
45 45
     @Excel(name = "投诉内容")
46 46
     private String complaintDesc;
47 47
 
48
+    @Excel(name = "旅客诉求")
49
+    private String passengerDemand;
50
+
51
+    @Excel(name = "渠道来源")
52
+    private String channelSource;
53
+
54
+    @Excel(name = "是否有责")
55
+    private String isResponsible;
56
+
57
+    @Excel(name = "责任队长")
58
+    private String responsibleCaptain;
59
+
60
+    @Excel(name = "队室内勤")
61
+    private String teamInternalDuty;
62
+
48 63
     @Excel(name = "处理结果")
49 64
     private String resultHandling;
50 65
 
@@ -65,6 +80,13 @@ public class LedgerComplaint extends BaseEntity {
65 80
     @Excel(name = "同步标志(0=未同步;1=已同步)")
66 81
     private String syncFlag;
67 82
 
83
+    // ID字段
84
+    private Long responsibleId;
85
+    private Long deptId;
86
+    private Long teamId;
87
+    private Long groupId;
88
+    private String groupName;
89
+
68 90
     public Long getId() { return id; }
69 91
     public void setId(Long id) { this.id = id; }
70 92
 
@@ -92,6 +114,21 @@ public class LedgerComplaint extends BaseEntity {
92 114
     public String getComplaintDesc() { return complaintDesc; }
93 115
     public void setComplaintDesc(String complaintDesc) { this.complaintDesc = complaintDesc; }
94 116
 
117
+    public String getPassengerDemand() { return passengerDemand; }
118
+    public void setPassengerDemand(String passengerDemand) { this.passengerDemand = passengerDemand; }
119
+
120
+    public String getChannelSource() { return channelSource; }
121
+    public void setChannelSource(String channelSource) { this.channelSource = channelSource; }
122
+
123
+    public String getIsResponsible() { return isResponsible; }
124
+    public void setIsResponsible(String isResponsible) { this.isResponsible = isResponsible; }
125
+
126
+    public String getResponsibleCaptain() { return responsibleCaptain; }
127
+    public void setResponsibleCaptain(String responsibleCaptain) { this.responsibleCaptain = responsibleCaptain; }
128
+
129
+    public String getTeamInternalDuty() { return teamInternalDuty; }
130
+    public void setTeamInternalDuty(String teamInternalDuty) { this.teamInternalDuty = teamInternalDuty; }
131
+
95 132
     public String getResultHandling() { return resultHandling; }
96 133
     public void setResultHandling(String resultHandling) { this.resultHandling = resultHandling; }
97 134
 
@@ -112,4 +149,19 @@ public class LedgerComplaint extends BaseEntity {
112 149
 
113 150
     public String getSyncFlag() { return syncFlag; }
114 151
     public void setSyncFlag(String syncFlag) { this.syncFlag = syncFlag; }
115
-}
152
+
153
+    public Long getResponsibleId() { return responsibleId; }
154
+    public void setResponsibleId(Long responsibleId) { this.responsibleId = responsibleId; }
155
+
156
+    public Long getDeptId() { return deptId; }
157
+    public void setDeptId(Long deptId) { this.deptId = deptId; }
158
+
159
+    public Long getTeamId() { return teamId; }
160
+    public void setTeamId(Long teamId) { this.teamId = teamId; }
161
+
162
+    public Long getGroupId() { return groupId; }
163
+    public void setGroupId(Long groupId) { this.groupId = groupId; }
164
+
165
+    public String getGroupName() { return groupName; }
166
+    public void setGroupName(String groupName) { this.groupName = groupName; }
167
+}

+ 32 - 10
airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerCombinedImportServiceImpl.java

@@ -390,21 +390,43 @@ public class LedgerCombinedImportServiceImpl implements ILedgerCombinedImportSer
390 390
     /** 5. 投诉情况 → ledger_complaint
391 391
      * R2: 时间(0) 航班号(1) 旅客姓名(2) 班组(3) 责任人(4)
392 392
      *     投诉情况(5) 旅客诉求(6) 类别(7) 渠道来源(8) 是否有责(9)
393
-     *     处理进度(10)
393
+     *     处理进度(10) 责任队长(11) 队室内勤(12)
394 394
      */
395 395
     private int doComplaint(Sheet sheet, String batchNo, String username) {
396 396
         List<LedgerComplaint> list = new ArrayList<>();
397 397
         for (Object[] c : dataRows(sheet, 2)) {
398 398
             LedgerComplaint o = new LedgerComplaint();
399
-            o.setRecordDate(date(c, 0));
400
-            o.setFlightNo(str(c, 1));
401
-            o.setPassengerName(str(c, 2));
402
-            o.setTeamName(str(c, 3));
403
-            o.setResponsibleName(str(c, 4));
404
-            o.setComplaintDesc(str(c, 5));
405
-            o.setComplaintType(str(c, 7));
406
-            o.setResultHandling(str(c, 10));
407
-            o.setRemark(str(c, 8));
399
+            
400
+            // 按导入顺序映射字段
401
+            o.setRecordDate(date(c, 0));           // 时间
402
+            o.setFlightNo(str(c, 1));              // 航班号
403
+            o.setPassengerName(str(c, 2));         // 旅客姓名
404
+            o.setTeamName(str(c, 3));              // 班组
405
+            String responsibleName = str(c, 4);    // 责任人
406
+            o.setResponsibleName(responsibleName);
407
+            o.setComplaintDesc(str(c, 5));         // 投诉情况
408
+            o.setPassengerDemand(str(c, 6));       // 旅客诉求
409
+            o.setComplaintType(str(c, 7));         // 类别
410
+            o.setChannelSource(str(c, 8));         // 渠道来源
411
+            o.setIsResponsible(str(c, 9));         // 是否有责
412
+            o.setResultHandling(str(c, 10));       // 处理进度
413
+            o.setResponsibleCaptain(str(c, 11));   // 责任队长
414
+            o.setTeamInternalDuty(str(c, 12));     // 队室内勤
415
+            
416
+            // 根据责任人名称查找组织信息和ID
417
+            if (responsibleName != null && !responsibleName.trim().isEmpty()) {
418
+                Map<String, Object> orgInfo = resolveOrgInfoByNameWithCache(responsibleName);
419
+                if (!orgInfo.isEmpty()) {
420
+                    o.setResponsibleId((Long) orgInfo.get("userId"));
421
+                    o.setDeptId((Long) orgInfo.get("deptId"));
422
+                    o.setDeptName((String) orgInfo.get("deptName"));
423
+                    o.setTeamId((Long) orgInfo.get("teamId"));
424
+                    o.setTeamName((String) orgInfo.get("teamName"));
425
+                    o.setGroupId((Long) orgInfo.get("groupId"));
426
+                    o.setGroupName((String) orgInfo.get("groupName"));
427
+                }
428
+            }
429
+            
408 430
             o.setImportBatch(batchNo);
409 431
             o.setSourceType("1");
410 432
             o.setCreateBy(username);