数据迁移提交

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/DataController.java

@@ -41,6 +41,13 @@ public class DataController {
         return ResponseDto.success();
     }
 
+    @PostMapping("checkTicket")
+    @ApiOperation("验票账号相关迁移")
+    public ResponseDto<Boolean> checkTicket() {
+        data.checkTicket();
+        return ResponseDto.success();
+    }
+
 //    @PostMapping("initScore")
 //    @ApiOperation("积分数据迁移")
 //    public ResponseDto<Boolean> initScore(@RequestParam("page") int page, @RequestParam("size") int size) {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java

@@ -69,7 +69,6 @@ public class DataImpl {
     DMTAuthorizationRecordsService dmtAuthorizationRecordsService;
 
 
-
     private static final String SQL_URL = "jdbc:mysql://39.107.71.112:3308/dev_ln_scene";
     private static final String SQL_USER = "testmall";
     private static final String SQL_PWD = "zhengzai!mYT";
@@ -209,8 +208,8 @@ public class DataImpl {
                 //OTHER
                 judgeFields(fields.getFieldId(), fields.getUid(), appliesVo, vo);
                 //场地权限
-                if(!fields.getUid().equals("")){
-                    initPermission("field",null,row.getString("performance_id"),fields.getUid(),null,null,null);
+                if (!fields.getUid().equals("")) {
+                    initPermission("field", null, row.getString("performance_id"), fields.getUid(), null, null, null);
                 }
             }
             row.close();
@@ -223,7 +222,7 @@ public class DataImpl {
     //演出所属账号修改
     public void account() {
         try {
-            String sql = "select merchant_id, mm.mobile\n" +
+            String sql = "select merchant_id, mm.mobile,  kp.performances_id\n" +
                     "from kylin_performances kp\n" +
                     "         inner join kylin_performance_relations kpr on kpr.performance_id = kp.performances_id\n" +
                     "         left join " + PHP_DB + ".merchants mm on mm.id = kpr.merchant_id\n" +
@@ -269,6 +268,7 @@ public class DataImpl {
                         partnerVoQuery.getQueryObject(),
                         objectPartnerVo
                 );
+                initPermission("sponsor", uid, row.getString("performances_id"), null, null, null, null);
             }
             row.close();
             preparedStatement.close();
@@ -370,6 +370,35 @@ public class DataImpl {
 
     //相关权限迁移
     public void checkTicket() {
+        try {
+            String sql = "select kcup.performance_id,kcu.mobile,kpr.merchant_id\n" +
+                    "from kylin_check_user_performances kcup\n" +
+                    "         inner join kylin_check_user kcu on kcu.check_user_id = kcup.check_user_id\n" +
+                    "         inner join kylin_performance_relations kpr on kpr.performance_id = kcup.performance_id\n" +
+                    "order by kcup.performance_id";
+            Connection connection = DriverManager.getConnection(SQL_URL, SQL_USER, SQL_PWD);
+            //查询数据
+            PreparedStatement preparedStatement = connection.prepareStatement(sql);
+            ResultSetImpl row = (ResultSetImpl) preparedStatement.executeQuery();
+            while (row.next()) {
+                String mobile = row.getString("mobile");
+                String merchantId = row.getString("merchant_id");
+                String performanceId = row.getString("performance_id");
+                if (mobile == null) {
+                    continue;
+                }
+                MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+                params.add("mobile", mobile);
+                MultiValueMap<String, String> headers = CollectionUtil.linkedMultiValueMapStringString();
+                headers.add("Accept", "application/json;charset=UTF-8");
+                String returnData = HttpUtil.post(adamUrl.concat("/adam/rsc/reg/mobile"), params, headers);
+                AdamUserInfoVo adamUserInfoVo = JsonUtils.fromJson(returnData, new TypeReference<ResponseDto<AdamUserInfoVo>>() {
+                }).getData();
+                initPermission("check", merchantId, performanceId, null, adamUserInfoVo.getNickname(), adamUserInfoVo.getUid(), adamUserInfoVo.getMobile());
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 
 
@@ -441,8 +470,8 @@ public class DataImpl {
                 records.setUid(checkId);
                 records.setMobile(checkMobile);
                 records.setName(checkName);
-                records.setCuid(fieldOwnId);
-                records.setCuidRole(MerchantAuthorizationConst.PerformanceRole.FIELDER.getRole());
+                records.setCuid(cuid);
+                records.setCuidRole(MerchantAuthorizationConst.PerformanceRole.CREATOR.getRole());
                 records.setCreatedAt(now);
                 break;
         }
@@ -457,11 +486,11 @@ public class DataImpl {
         MerchantAuthorizationPermissionParam paramRead = MerchantAuthorizationPermissionParam.getNew();
         paramRead.setPermissionId(MerchantAuthorizationConst.PerformancePermission.READ.getId());
         MerchantAuthorizationPermissionParam paramEdit = MerchantAuthorizationPermissionParam.getNew();
-        paramRead.setPermissionId(MerchantAuthorizationConst.PerformancePermission.EDIT.getId());
+        paramEdit.setPermissionId(MerchantAuthorizationConst.PerformancePermission.EDIT.getId());
         MerchantAuthorizationPermissionParam paramLine = MerchantAuthorizationPermissionParam.getNew();
-        paramRead.setPermissionId(MerchantAuthorizationConst.PerformancePermission.LINE.getId());
+        paramLine.setPermissionId(MerchantAuthorizationConst.PerformancePermission.LINE.getId());
         MerchantAuthorizationPermissionParam paramAudit = MerchantAuthorizationPermissionParam.getNew();
-        paramRead.setPermissionId(MerchantAuthorizationConst.PerformancePermission.AUDIT.getId());
+        paramAudit.setPermissionId(MerchantAuthorizationConst.PerformancePermission.AUDIT.getId());
 
         switch (type) {
             case "sponsor":
@@ -470,7 +499,7 @@ public class DataImpl {
                 checkPermissionParam.add(paramRead);
                 checkPermissionParam.add(paramEdit);
                 checkPermissionParam.add(paramLine);
-                checkPermissionParam.add(paramAudit);
+//                checkPermissionParam.add(paramAudit);
                 checkPermissionParam.add(paramSales);
                 break;
             case "field":
@@ -512,7 +541,7 @@ public class DataImpl {
         // mongo
         mongoTemplate.insert(authorizationRecordsVo, MerchantAuthorizationRecordsVo.class.getSimpleName());
         // updated uid
-        getAndSyncAuthorizationPerformanceVo(performanceId,authorizationRecordsVo.getUid());
+        getAndSyncAuthorizationPerformanceVo(performanceId, authorizationRecordsVo.getUid());
     }
 
     public MerchantAuthorizationPerformanceVo getAndSyncAuthorizationPerformanceVo(String performanceId, String uid) {
@@ -521,11 +550,11 @@ public class DataImpl {
         List<MerchantAuthorizationRecordsVo> authorizationRecordsVos = mongoTemplate.find(recordsQuery, MerchantAuthorizationRecordsVo.class, MerchantAuthorizationRecordsVo.class.getSimpleName());
         List<String> uidRoles = new ArrayList<>();
         List<String> permissionIds = new ArrayList<>();
-        for (MerchantAuthorizationRecordsVo authorizationRecordsVo: authorizationRecordsVos) {
+        for (MerchantAuthorizationRecordsVo authorizationRecordsVo : authorizationRecordsVos) {
             if (!uidRoles.contains(authorizationRecordsVo.getUidRole())) {
                 uidRoles.add(authorizationRecordsVo.getUidRole());
             }
-            for (MerchantAuthorizationPermissionsVo authorizationPermissionsVo: authorizationRecordsVo.getPermissionsVos()) {
+            for (MerchantAuthorizationPermissionsVo authorizationPermissionsVo : authorizationRecordsVo.getPermissionsVos()) {
                 if (!permissionIds.contains(authorizationPermissionsVo.getPermissionId())) {
                     permissionIds.add(authorizationPermissionsVo.getPermissionId());
                 }
@@ -537,7 +566,7 @@ public class DataImpl {
         vo.setUidRoles(uidRoles);
         vo.setPermissionIds(permissionIds);
         Query query = Query.query(Criteria.where("performanceId").is(performanceId).and("uid").is(uid));
-        Document document = (Document)mongoConverter.convertToMongoType(vo);
+        Document document = (Document) mongoConverter.convertToMongoType(vo);
         Update update = Update.fromDocument(document);
         mongoTemplate.upsert(query, update, MerchantAuthorizationPerformanceVo.class, MerchantAuthorizationPerformanceVo.class.getSimpleName());
         return vo;