修改 入场须知

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

@@ -39,4 +39,11 @@ public class DataController {
         return ResponseDto.success(result);
     }
 
+    @PostMapping("childAccount")
+    @ApiOperation("验票子账号数据迁移")
+    public ResponseDto<Boolean> childAccount() {
+        Boolean result = data.childAccount();
+        return ResponseDto.success(result);
+    }
+
 }

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

+package com.liquidnet.service.platform.service.impl.kylin;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.service.kylin.entity.KylinCheckUser;
+import com.liquidnet.service.kylin.entity.KylinCheckUserPerformances;
+import com.liquidnet.service.kylin.mapper.KylinCheckUserMapper;
+import com.liquidnet.service.kylin.mapper.KylinCheckUserPerformancesMapper;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 巡演 服务实现类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-11
+ */
+@Service
+public class DMCheckUserPerformanceServiceImpl extends ServiceImpl<KylinCheckUserPerformancesMapper, KylinCheckUserPerformances> {
+
+}

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

+package com.liquidnet.service.platform.service.impl.kylin;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.service.kylin.entity.KylinCheckUser;
+import com.liquidnet.service.kylin.entity.KylinRoadShows;
+import com.liquidnet.service.kylin.mapper.KylinCheckUserMapper;
+import com.liquidnet.service.kylin.mapper.KylinRoadShowsMapper;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 巡演 服务实现类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-11
+ */
+@Service
+public class DMCheckUserServiceImpl extends ServiceImpl<KylinCheckUserMapper, KylinCheckUser> {
+
+}

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

@@ -3,8 +3,12 @@ package com.liquidnet.service.platform.service.impl.kylin;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
+import com.liquidnet.service.kylin.dto.param.CheckPerformanceRelationParam;
 import com.liquidnet.service.kylin.dto.param.PerformancePartnerVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCheckUserPerformanceVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCheckUserVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketPartnerVo;
@@ -26,6 +30,7 @@ import java.sql.ResultSet;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.List;
 
 @Service
 public class DataImpl {
@@ -63,6 +68,11 @@ public class DataImpl {
     @Autowired
     private DMRoadShowsServiceImpl dmRoadShowsService;
 
+    @Autowired
+    private DMCheckUserServiceImpl dmCheckUserService;
+    @Autowired
+    private DMCheckUserPerformanceServiceImpl dmCheckUserPerformanceService;
+
     @Autowired
     private DataUtils dataUtils;
     @Autowired
@@ -791,7 +801,7 @@ public class DataImpl {
             //演出数据
             while (resultData.next()) {
                 KylinRoadShows roadShows = new KylinRoadShows();
-                roadShows.setRoadShowsId(resultData.getInt("id")+"");
+                roadShows.setRoadShowsId(resultData.getInt("id") + "");
                 roadShows.setTitle(resultData.getString("title"));
                 roadShows.setImgPoster(resultData.getString("img_poster"));
                 roadShows.setStatus(1);
@@ -818,4 +828,95 @@ public class DataImpl {
             }
         }
     }
+
+    public boolean childAccount() {
+        String driverClassName = "com.mysql.cj.jdbc.Driver";    //启动驱动
+        String url = "jdbc:mysql://pc-2ze6z2hxkug559q79.mysql.polardb.rds.aliyuncs.com:3306/mall";    //设置连接路径
+        String username = "readonly";    //数据库用户名
+        String password = "ZWDsf8Fy";    //数据库连接密码
+        Connection con = null;        //连接
+        PreparedStatement pstmt = null;    //使用预编译语句
+        ResultSet rs = null;    //获取的结果集
+
+        try {
+            ArrayList<KylinCheckUser> checkUserList = new ArrayList();
+            ArrayList<KylinCheckUserVo> checkUserVoArrayList = new ArrayList();
+
+            Class.forName(driverClassName); //执行驱动
+            con = DriverManager.getConnection(url, username, password); //获取连接
+            String sql = "select m.id,name,mobile,father_id,m.created_at,m.updated_at from merchants as m left join merchant_relation as mr on m.id = mr.child_id where is_own = 'no' and mobile not like '%&%'";
+            pstmt = con.prepareStatement(sql);
+            ResultSet resultData = pstmt.executeQuery();
+            //演出数据
+            while (resultData.next()) {
+                KylinCheckUser checkUser = new KylinCheckUser();
+                checkUser.setCheckUserId(resultData.getInt("id") + "");
+                checkUser.setMerchantId(resultData.getInt("father_id") + "");
+                checkUser.setMobile(resultData.getString("mobile"));
+                checkUser.setName(resultData.getString("name"));
+                checkUser.setPwd(StringUtil.right(checkUser.getMobile(), 8));
+                checkUser.setStatus(1);
+                checkUser.setCreatedAt(DateUtil.Formatter.yyyyMMddHHmmssS.parse(resultData.getTimestamp("created_at").toString()));
+                if (null != resultData.getTimestamp("updated_at")) {
+                    checkUser.setUpdatedAt(DateUtil.Formatter.yyyyMMddHHmmssS.parse(resultData.getTimestamp("updated_at").toString()));
+                }
+
+                KylinCheckUserVo checkUserVo = new KylinCheckUserVo();
+                checkUserVo.setCheckUserId(checkUser.getCheckUserId());
+                checkUserVo.setMerchantId(checkUser.getMerchantId());
+                checkUserVo.setMobile(checkUser.getMobile());
+                checkUserVo.setName(checkUser.getName());
+                checkUserVo.setPwd(checkUser.getMobile());
+                checkUserVo.setStatus("1");
+
+                checkUserList.add(checkUser);
+                checkUserVoArrayList.add(checkUserVo);
+
+                //关系
+                ArrayList<KylinCheckUserPerformances> checkUserPerformancesArrayList = new ArrayList();
+                List<CheckPerformanceRelationParam> voList = new ArrayList();
+                KylinCheckUserPerformanceVo checkUserPerformanceVo = new KylinCheckUserPerformanceVo();
+                checkUserPerformanceVo.setCheckUserId(checkUser.getCheckUserId());
+                String relationSql = "select * from performance_visit_children where performance_id > 5721 and merchant_id = = " + checkUser.getCheckUserId(); //设置的预编译语句格式
+                pstmt = con.prepareStatement(relationSql);
+                ResultSet relationData = pstmt.executeQuery();
+                while (relationData.next()) {
+                    KylinCheckUserPerformances checkUserPerformances = new KylinCheckUserPerformances();
+                    checkUserPerformances.setCheckUserId(resultData.getInt("merchant_id") + "");
+                    checkUserPerformances.setPerformanceId(resultData.getInt("performance_id") + "");
+                    checkUserPerformances.setCheckUserPerformanceId(resultData.getInt("id") + "");
+                    checkUserPerformances.setStatus(1);
+                    checkUserPerformances.setCreatedAt(DateUtil.Formatter.yyyyMMddHHmmssS.parse(resultData.getTimestamp("created_at").toString()));
+                    if (null != resultData.getTimestamp("updated_at")) {
+                        checkUserPerformances.setUpdatedAt(DateUtil.Formatter.yyyyMMddHHmmssS.parse(resultData.getTimestamp("updated_at").toString()));
+                    }
+                    checkUserPerformancesArrayList.add(checkUserPerformances);
+
+                    CheckPerformanceRelationParam voData = new CheckPerformanceRelationParam();
+                    voData.setPerformanceId(checkUserPerformances.getPerformanceId());
+                    voData.setCanDownTime(DateUtil.Formatter.yyyyMMddHHmmss.format(checkUserPerformances.getCreatedAt()));
+                    voList.add(voData);
+                }
+                checkUserPerformanceVo.setRelationParams(voList);
+
+                dmCheckUserPerformanceService.saveBatch(checkUserPerformancesArrayList);
+                mongoTemplate.insert(checkUserPerformanceVo, KylinCheckUserPerformances.class.getSimpleName());
+            }
+            dmCheckUserService.saveBatch(checkUserList);
+            mongoTemplate.insert(checkUserVoArrayList, KylinCheckUserVo.class.getSimpleName());
+
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new RuntimeException(e);
+        } finally {
+            //关闭资源,倒关
+            try {
+                if (rs != null) rs.close();
+                if (pstmt != null) pstmt.close();
+                if (con != null) con.close();  //必须要关
+            } catch (Exception e) {
+            }
+        }
+    }
 }