fix:验票账号关联演出数据更新调整;

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/DataMigrationProcessorService.java

@@ -31,6 +31,8 @@ public abstract class DataMigrationProcessorService {
     @Autowired
     public MongoTemplate mongoTemplate;
     @Autowired
+    public AdamRdmService adamRdmService;
+    @Autowired
     public AdamUserMapper userMapper;
 
     protected abstract void dataProcessing(Integer dg, Integer lS, String incrDt, String flg, String flu);

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/processor/DMThirdPartsProcessor.java

 package com.liquidnet.service.adam.service.processor;
 
+import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.service.adam.dto.vo.AdamThirdPartInfoVo;
 import com.liquidnet.service.adam.entity.AdamThirdParty;
 import com.liquidnet.service.adam.service.DataMigrationProcessorService;
@@ -17,6 +18,7 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -50,6 +52,7 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
         }
         sql += " order by id limit ?,?";
 
+        LocalDateTime currentYear = DateUtil.Formatter.yyyyMMddHHmmss.parse("2021-01-01 00:00:00");
         Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
@@ -84,7 +87,8 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
                         thirdParty.setNickname(row.getString(4));
                         thirdParty.setPlatform(row.getString(5));
                         thirdParty.setState(1);
-                        thirdParty.setCreatedAt(row.getLocalDateTime(6));
+                        LocalDateTime createdAt = row.getLocalDateTime(6);
+                        thirdParty.setCreatedAt(createdAt);
                         thirdParty.setUpdatedAt(row.getLocalDateTime(7));
 
                         AdamThirdPartInfoVo vo = AdamThirdPartInfoVo.getNew();
@@ -99,6 +103,10 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
 
                         thirdPartyList.add(thirdParty);
                         vos.add(vo);
+
+                        if (currentYear.isBefore(createdAt)) {
+                            adamRdmService.setUidByPlatformOpenId(thirdParty.getPlatform(), thirdParty.getOpenId(), uid);
+                        }
                     }
                     if (thirdPartyList.size() == 500) {
                         tl += thirdPartyList.size();

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/processor/DMUserInformationProcessor.java

@@ -23,6 +23,7 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -68,6 +69,7 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
         }
         sql += " order by uid limit ?,?";
 
+        LocalDateTime currentYear = DateUtil.Formatter.yyyyMMddHHmmss.parse("2021-01-01 00:00:00");
         Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
@@ -99,9 +101,11 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
                     if (!reUidList.contains(uid)) {
                         AdamUser user = new AdamUser();
                         user.setUid(uid);
-                        user.setMobile(row.getString(2));
-                        user.setCreatedAt(row.getLocalDateTime(10));
-                        user.setUpdatedAt(row.getLocalDateTime(11));
+                        String mobile = row.getString(2);
+                        user.setMobile(mobile);
+                        LocalDateTime createdAt = row.getLocalDateTime(10), updatedAt = row.getLocalDateTime(11);
+                        user.setCreatedAt(createdAt);
+                        user.setUpdatedAt(updatedAt);
                         user.setState(1);
 
                         AdamUserInfo userInfo = new AdamUserInfo();
@@ -136,6 +140,11 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
                         userList.add(user);
                         userInfoList.add(userInfo);
                         vos.add(vo);
+
+                        if (StringUtils.length(mobile) == 11 &&
+                                (currentYear.isBefore(createdAt) || currentYear.isBefore(updatedAt))) {
+                            adamRdmService.setUidByMobile(mobile, uid);
+                        }
                     }
                     if (userList.size() == 500) {
                         tl += userList.size();

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/partner/KylinCheckUserPerformancesPartnerServiceImpl.java

@@ -77,7 +77,6 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
     @Override
     public ResponseDto<String> setPerformance(CheckUserParam param) {
         try {
-            List<CheckPerformanceRelationParam> performanceList = new ArrayList<>();
             for (CheckPerformanceRelationParam item : param.getCheckPerformanceRelationParamList()) {
                 KylinCheckUserPerformances checkUserPerformances = new KylinCheckUserPerformances();
                 checkUserPerformances.setCheckUserId(param.getCheckUserId());
@@ -87,14 +86,22 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
                 checkUserPerformances.setCreatedAt(LocalDateTime.now());
                 checkUserPerformances.setStatus(1);
                 checkUserPerformancesMapper.insert(checkUserPerformances);
-                performanceList.add(item);
             }
+            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(param.getCheckUserId())), KylinCheckUserPerformanceVo.class, KylinCheckUserPerformanceVo.class.getSimpleName());
+
             KylinCheckUserPerformanceVo userPerformanceVo = new KylinCheckUserPerformanceVo();
+            List<CheckPerformanceRelationParam> performanceRelationParamsList = new ArrayList<>();
+            List<KylinCheckUserPerformances> data = checkUserPerformancesMapper.selectList(new UpdateWrapper<KylinCheckUserPerformances>().eq("check_user_id", param.getCheckUserId()));
+            for (KylinCheckUserPerformances item : data) {
+                CheckPerformanceRelationParam performanceRelationParam = new CheckPerformanceRelationParam();
+                performanceRelationParam.setCanDownTime(item.getCanDownTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+                performanceRelationParam.setPerformanceId(item.getCheckUserPerformanceId());
+                performanceRelationParamsList.add(performanceRelationParam);
+            }
             userPerformanceVo.setCheckUserId(param.getCheckUserId());
-            userPerformanceVo.setRelationParams(performanceList);
-            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(param.getCheckUserId())), KylinCheckUserPerformanceVo.class, KylinCheckUserPerformanceVo.class.getSimpleName());
-            mongoTemplate.insert(userPerformanceVo, KylinCheckUserPerformanceVo.class.getSimpleName());
+            userPerformanceVo.setRelationParams(performanceRelationParamsList);
 
+            mongoTemplate.insert(userPerformanceVo, KylinCheckUserPerformanceVo.class.getSimpleName());
             dataUtils.delCheckUserRelationRedis(param.getCheckUserId());
             return ResponseDto.success("添加成功");
         } catch (Exception e) {