Explorar o código

配分事项表同步功能添加岗位、区域、通道

wangxx hai 1 semana
pai
achega
729120dc3f

+ 32 - 16
airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerSyncServiceImpl.java

@@ -212,7 +212,8 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
212
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectedName(),
212
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectedName(),
213
                     null, row.getRecordDate(),
213
                     null, row.getRecordDate(),
214
                     row.getLocation(), sv, ZERO,
214
                     row.getLocation(), sv, ZERO,
215
-                    row.getProblemDesc(), src, row.getEvidenceFile());
215
+                    row.getProblemDesc(), src, row.getEvidenceFile(),
216
+                    row.getChannelId(),row.getChannelNo(),row.getAreaId(),row.getPositionId(),row.getPosition());
216
             scoreEventMapper.insert(e);
217
             scoreEventMapper.insert(e);
217
             ins++;
218
             ins++;
218
         }
219
         }
@@ -252,8 +253,9 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
252
             ScoreIndicator lv3 = getIndicator(l3Id);
253
             ScoreIndicator lv3 = getIndicator(l3Id);
253
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectorName(),
254
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectorName(),
254
                     row.getTeamName(), row.getRecordDate(),
255
                     row.getTeamName(), row.getRecordDate(),
255
-                    row.getChannelNo(), sv, ZERO,
256
-                    row.getItemName(), src, row.getEvidenceFile());
256
+                    row.getLocation(), sv, ZERO,
257
+                    row.getItemName(), src, row.getEvidenceFile(),
258
+                    row.getChannelId(),row.getChannelNo(),row.getAreaId(),row.getPositionId(),row.getPosition());
257
             scoreEventMapper.insert(e);
259
             scoreEventMapper.insert(e);
258
             ins++;
260
             ins++;
259
         }
261
         }
@@ -287,8 +289,9 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
287
             ScoreIndicator lv3 = getIndicator(l3Id);
289
             ScoreIndicator lv3 = getIndicator(l3Id);
288
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getTestedName(),
290
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getTestedName(),
289
                     row.getTeamName(), row.getRecordDate(),
291
                     row.getTeamName(), row.getRecordDate(),
290
-                    null, NEG_HALF, ZERO,
291
-                    row.getTestItem(), src, row.getEvidenceFile());
292
+                    row.getRegion(), NEG_HALF, ZERO,
293
+                    row.getTestItem(), src, row.getEvidenceFile(),
294
+                    row.getChannelId(),row.getChannel(),row.getAreaId(),row.getPositionId(),row.getTestType());
292
             scoreEventMapper.insert(e);
295
             scoreEventMapper.insert(e);
293
             ins++;
296
             ins++;
294
         }
297
         }
@@ -322,8 +325,9 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
322
             ScoreIndicator lv3 = getIndicator(l3Id);
325
             ScoreIndicator lv3 = getIndicator(l3Id);
323
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getResponsibleName(),
326
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getResponsibleName(),
324
                     row.getTeamName(), row.getRecordDate(),
327
                     row.getTeamName(), row.getRecordDate(),
325
-                    null, sv, ZERO,
326
-                    row.getEventDesc(), src, row.getEvidenceFile());
328
+                    row.getArea(), sv, ZERO,
329
+                    row.getEventDesc(), src, row.getEvidenceFile(),
330
+                    row.getChannelId(),row.getChannelNo(),row.getAreaId(),row.getPositionId(),row.getPosition());
327
             scoreEventMapper.insert(e);
331
             scoreEventMapper.insert(e);
328
             ins++;
332
             ins++;
329
         }
333
         }
@@ -354,8 +358,9 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
354
             ScoreIndicator lv3 = getIndicator(l3Id);
358
             ScoreIndicator lv3 = getIndicator(l3Id);
355
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectorName(),
359
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectorName(),
356
                     row.getTeamName(), row.getRecordDate(),
360
                     row.getTeamName(), row.getRecordDate(),
357
-                    null, sv, ZERO,
358
-                    row.getItemName(), src, row.getEvidenceFile());
361
+                    row.getWorkArea(), sv, ZERO,
362
+                    row.getItemName(), src, row.getEvidenceFile(),
363
+                    null,null,row.getAreaId(),row.getPositionId(),row.getPosition());
359
             scoreEventMapper.insert(e);
364
             scoreEventMapper.insert(e);
360
             ins++;
365
             ins++;
361
         }
366
         }
@@ -391,7 +396,8 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
391
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
396
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
392
                     row.getTeamName(), row.getApproveDate() != null ? new java.util.Date(row.getApproveDate().getTime()) : null,
397
                     row.getTeamName(), row.getApproveDate() != null ? new java.util.Date(row.getApproveDate().getTime()) : null,
393
                     null, sv, ZERO,
398
                     null, sv, ZERO,
394
-                    row.getRewardReason(), src, null);
399
+                    row.getRewardReason(), src, null,
400
+                    null,null,null,null,null);
395
             scoreEventMapper.insert(e);
401
             scoreEventMapper.insert(e);
396
             ins++;
402
             ins++;
397
         }
403
         }
@@ -425,7 +431,8 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
425
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectedName(),
431
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectedName(),
426
                     row.getTeamName(), row.getRecordDate(),
432
                     row.getTeamName(), row.getRecordDate(),
427
                     row.getLocation(), sv, ZERO,
433
                     row.getLocation(), sv, ZERO,
428
-                    row.getProblemDesc(), src, row.getEvidenceFile());
434
+                    row.getProblemDesc(), src, row.getEvidenceFile(),
435
+                    row.getChannelId(),row.getChannelNo(),row.getAreaId(),row.getPositionId(),row.getPosition());
429
             scoreEventMapper.insert(e);
436
             scoreEventMapper.insert(e);
430
             ins++;
437
             ins++;
431
         }
438
         }
@@ -452,7 +459,8 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
452
             ScoreEvent e = buildEvent(dimId, lv2, null, row.getResponsibleName(),
459
             ScoreEvent e = buildEvent(dimId, lv2, null, row.getResponsibleName(),
453
                     row.getTeamName(), row.getRecordDate(),
460
                     row.getTeamName(), row.getRecordDate(),
454
                     null, sv, ZERO,
461
                     null, sv, ZERO,
455
-                    row.getComplaintDesc(), src, row.getEvidenceFile());
462
+                    row.getComplaintDesc(), src, row.getEvidenceFile(),
463
+                    null,null,null,null,null);
456
             scoreEventMapper.insert(e);
464
             scoreEventMapper.insert(e);
457
             ins++;
465
             ins++;
458
         }
466
         }
@@ -480,7 +488,8 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
480
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
488
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
481
                     row.getTeamName(), row.getScoreDate(),
489
                     row.getTeamName(), row.getScoreDate(),
482
                     null, sv, ZERO,
490
                     null, sv, ZERO,
483
-                    "航站楼加分", src, null);
491
+                    "航站楼加分", src, null,
492
+                    null,null,null,null,null);
484
             scoreEventMapper.insert(e);
493
             scoreEventMapper.insert(e);
485
             ins++;
494
             ins++;
486
         }
495
         }
@@ -515,7 +524,8 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
515
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
524
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
516
                     row.getTeamName(), null,
525
                     row.getTeamName(), null,
517
                     null, POS_FIVE, ZERO,
526
                     null, POS_FIVE, ZERO,
518
-                    row.getExamCategory() + " " + row.getExamPeriod(), src, null);
527
+                    row.getExamCategory() + " " + row.getExamPeriod(), src, null,
528
+                    null,null,null,null,null);
519
             scoreEventMapper.insert(e);
529
             scoreEventMapper.insert(e);
520
             ins++;
530
             ins++;
521
         }
531
         }
@@ -648,7 +658,8 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
648
     private ScoreEvent buildEvent(Long dimId, ScoreIndicator lv2, ScoreIndicator lv3,
658
     private ScoreEvent buildEvent(Long dimId, ScoreIndicator lv2, ScoreIndicator lv3,
649
                                   String personName, String teamName, java.util.Date eventDate,
659
                                   String personName, String teamName, java.util.Date eventDate,
650
                                   String location, BigDecimal sv, BigDecimal cascade,
660
                                   String location, BigDecimal sv, BigDecimal cascade,
651
-                                  String desc, String sourceLedger, String evidenceFile) {
661
+                                  String desc, String sourceLedger, String evidenceFile,
662
+                                  Long channelId,String channelNo,Long areaId,Long positionId,String position) {
652
         ScoreEvent e = new ScoreEvent();
663
         ScoreEvent e = new ScoreEvent();
653
         e.setDimensionId(dimId);
664
         e.setDimensionId(dimId);
654
         e.setDimensionName(dimId != null ? dimCache.entrySet().stream()
665
         e.setDimensionName(dimId != null ? dimCache.entrySet().stream()
@@ -690,7 +701,12 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
690
         e.setEvidenceFile(evidenceFile);
701
         e.setEvidenceFile(evidenceFile);
691
         e.setCreateBy("system");
702
         e.setCreateBy("system");
692
         e.setCreateTime(DateUtils.getNowDate());
703
         e.setCreateTime(DateUtils.getNowDate());
693
-        
704
+        e.setChannelId(channelId);
705
+        e.setChannelName(channelNo);
706
+        e.setRegionalName(location);
707
+        e.setRegionalId(areaId);
708
+        e.setPostId(positionId);
709
+        e.setPostName(position);
694
         // 通过人员名称解析组织信息(ID和名称)
710
         // 通过人员名称解析组织信息(ID和名称)
695
         if (StrUtil.isNotEmpty(e.getPersonName())) {
711
         if (StrUtil.isNotEmpty(e.getPersonName())) {
696
             Map<String, Object> orgInfo = resolveOrgInfoByName(e.getPersonName());
712
             Map<String, Object> orgInfo = resolveOrgInfoByName(e.getPersonName());