+DM for adam;

liquidnet-bus-do/liquidnet-service-adam-do/src/main/java/com/liquidnet/service/adam/entity/AdamUserInfo.java

@@ -77,6 +77,18 @@ public class AdamUserInfo implements Serializable {
      */
     private String tagMe;
 
+    /**
+     * 旧数据迁移
+     * 融云token
+     */
+    private String rongCloudToken;
+
+    /**
+     * 旧数据迁移（stringid为上上版系统用户id，uid为上版系统用户id，旧数据迁移至当前版本延用原uid）
+     * 0-老融云token(用stringid生成),1重新生成过的token(用uid生成)
+     */
+    private Integer rongCloudTag;
+
     private String comment;
 
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/admin/AdamDMAdminController.java

+package com.liquidnet.service.adam.controller.admin;
+
+import com.liquidnet.service.adam.service.processor.DMUserInformationProcessor;
+import com.liquidnet.service.base.ResponseDto;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDateTime;
+
+@Api(tags = "DM")
+@Slf4j
+@Validated
+@RestController
+@RequestMapping("dm")
+public class AdamDMAdminController {
+    @Autowired
+    DMUserInformationProcessor dmUserInformationProcessor;
+
+    @ApiOperation(value = "user")
+    @GetMapping(value = {"user"})
+    public ResponseDto<Object> dataMigrationForUser(@RequestParam int alis, @RequestParam boolean flg) {
+        if (verify(alis)) dmUserInformationProcessor.handler(flg);
+        return ResponseDto.success();
+    }
+
+    @ApiOperation(value = "tpa")
+    @GetMapping(value = {"tpa"})
+    public ResponseDto<Object> dataMigrationForTpa(@RequestParam int alis, @RequestParam boolean flg) {
+        if (verify(alis)) dmUserInformationProcessor.handler(flg);
+        return ResponseDto.success();
+    }
+
+    @ApiOperation(value = "real")
+    @GetMapping(value = {"real"})
+    public ResponseDto<Object> dataMigrationForReal(@RequestParam int alis, @RequestParam boolean flg) {
+        if (verify(alis)) dmUserInformationProcessor.handler(flg);
+        return ResponseDto.success();
+    }
+
+    @ApiOperation(value = "vip")
+    @GetMapping(value = {"vip"})
+    public ResponseDto<Object> dataMigrationForVip(@RequestParam int alis, @RequestParam boolean flg) {
+        if (verify(alis)) dmUserInformationProcessor.handler(flg);
+        return ResponseDto.success();
+    }
+
+    @ApiOperation(value = "morder")
+    @GetMapping(value = {"morder"})
+    public ResponseDto<Object> dataMigrationForMOrder(@RequestParam int alis, @RequestParam boolean flg) {
+        if (verify(alis)) dmUserInformationProcessor.handler(flg);
+        return ResponseDto.success();
+    }
+
+    @ApiOperation(value = "enters")
+    @GetMapping(value = {"enters"})
+    public ResponseDto<Object> dataMigrationForEnters(@RequestParam int alis, @RequestParam boolean flg) {
+        if (verify(alis)) dmUserInformationProcessor.handler(flg);
+        return ResponseDto.success();
+    }
+
+    @ApiOperation(value = "addr")
+    @GetMapping(value = {"addr"})
+    public ResponseDto<Object> dataMigrationForAddr(@RequestParam int alis, @RequestParam boolean flg) {
+        if (verify(alis)) dmUserInformationProcessor.handler(flg);
+        return ResponseDto.success();
+    }
+
+    private boolean verify(int alis) {
+        LocalDateTime now = LocalDateTime.now();
+        int hour = now.getHour();
+        return alis == Integer.parseInt((hour > 12 ? hour - 12 : hour) + "" + now.getMinute());
+    }
+}

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

+package com.liquidnet.service.adam.service;
+
+import lombok.SneakyThrows;
+
+import java.sql.*;
+
+public abstract class DataMigrationProcessorService {
+    public Connection connection = null;
+    public PreparedStatement statement = null;
+    public ResultSet resultSet = null;
+
+    public void handler(boolean flg) {
+        preHandler();
+
+        try {
+            dataProcessing(flg);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        postHandler();
+    }
+
+    @SneakyThrows
+    private void preHandler() {
+        Class.forName("com.mysql.cj.jdbc.Driver");
+        connection = DriverManager.getConnection(
+                "jdbc:mysql://zhengzai.mysql.polardb.rds.aliyuncs.com:3306/passport",
+                "readonly", "ZWDsf8Fy");
+    }
+
+    protected abstract void dataProcessing(boolean flg);
+
+    private void postHandler() {
+        try {
+            assert resultSet != null;
+            resultSet.close();
+            statement.close();
+            connection.close();
+        } catch (SQLException throwables) {
+            throwables.printStackTrace();
+        }
+    }
+}