清洗数据及企微主体表所在库切换

src/main/java/com/mokamrp/privates/mapper/CorpMapper.java

@@ -1,7 +1,7 @@
 package com.mokamrp.privates.mapper;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.mokamrp.privates.mapper.pojo.Corp;
 import org.apache.ibatis.annotations.Param;
@@ -18,6 +18,7 @@ import java.util.List;
  * @since 2021-04-19
  */
 @Component
+@DS("javadb")
 public interface CorpMapper extends BaseMapper<Corp> {
     public List<Corp> selectCorpList(Page<Corp> pageObj, @Param("userId") Integer userId, @Param("corpName") String corpName);
 }

src/main/resources/application-local.properties

@@ -15,6 +15,11 @@ spring.datasource.dynamic.datasource.db.driverClassName=com.mysql.cj.jdbc.Driver
 spring.datasource.dynamic.datasource.db.url=jdbc:mysql://172.18.71.27:3306/mochat?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8
 spring.datasource.dynamic.datasource.db.username=typer
 spring.datasource.dynamic.datasource.db.password=jch9sh_shl
+#企微主体
+spring.datasource.dynamic.datasource.javadb.driverClassName=com.mysql.cj.jdbc.Driver
+spring.datasource.dynamic.datasource.javadb.url=jdbc:mysql://172.18.71.27:3306/mochat_java?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8
+spring.datasource.dynamic.datasource.javadb.username=typer
+spring.datasource.dynamic.datasource.javadb.password=jch9sh_shl
 #大数据数据库
 spring.datasource.dynamic.datasource.datadb.driverClassName=com.mysql.cj.jdbc.Driver
 spring.datasource.dynamic.datasource.datadb.url=jdbc:mysql://rm-uf6uysb4ncki343q7go.mysql.rds.aliyuncs.com:3306/hera_data

src/main/resources/application-prod.properties

@@ -12,6 +12,11 @@ spring.datasource.dynamic.datasource.db.driverClassName=com.mysql.cj.jdbc.Driver
 spring.datasource.dynamic.datasource.db.url=jdbc:mysql://rm-uf6s9smcl373jjenc35930.mysql.rds.aliyuncs.com:3306/mochat?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8
 spring.datasource.dynamic.datasource.db.username=mochat
 spring.datasource.dynamic.datasource.db.password=MoChat666$%MOchaT
+#企微主体
+spring.datasource.dynamic.datasource.javadb.driverClassName=com.mysql.cj.jdbc.Driver
+spring.datasource.dynamic.datasource.javadb.url=jdbc:mysql://rm-uf6s9smcl373jjenc35930.mysql.rds.aliyuncs.com:3306/mochat_java?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8
+spring.datasource.dynamic.datasource.javadb.username=mochat
+spring.datasource.dynamic.datasource.javadb.password=MoChat666$%MOchaT
 #大数据数据库
 spring.datasource.dynamic.datasource.datadb.driverClassName=com.mysql.cj.jdbc.Driver
 spring.datasource.dynamic.datasource.datadb.url=jdbc:mysql://rm-uf6uysb4ncki343q735930.mysql.rds.aliyuncs.com:3306/hera_data

src/main/resources/application-test.properties

@@ -12,6 +12,11 @@ spring.datasource.dynamic.datasource.db.driverClassName=com.mysql.cj.jdbc.Driver
 spring.datasource.dynamic.datasource.db.url=jdbc:mysql://172.18.71.27:3306/mochat?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8
 spring.datasource.dynamic.datasource.db.username=typer
 spring.datasource.dynamic.datasource.db.password=jch9sh_shl
+#企微主体
+spring.datasource.dynamic.datasource.javadb.driverClassName=com.mysql.cj.jdbc.Driver
+spring.datasource.dynamic.datasource.javadb.url=jdbc:mysql://172.18.71.27:3306/mochat_java?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8
+spring.datasource.dynamic.datasource.javadb.username=typer
+spring.datasource.dynamic.datasource.javadb.password=jch9sh_shl
 #大数据数据库
 spring.datasource.dynamic.datasource.datadb.driverClassName=com.mysql.cj.jdbc.Driver
 spring.datasource.dynamic.datasource.datadb.url=jdbc:mysql://rm-uf6uysb4ncki343q7go.mysql.rds.aliyuncs.com:3306/hera_data

src/test/java/com/mokamrp/WebTest.java

@@ -3,8 +3,9 @@ package com.mokamrp;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.mokamrp.privates.PrivateServerStart;
-import com.mokamrp.privates.mapper.pojo.Corp;
+import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobilePool;
 import com.mokamrp.privates.service.CorpService;
+import com.mokamrp.privates.service.pangu.FosterwxMobilePoolService;
 import com.mokamrp.privates.service.pangu.FosterwxMobileService;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.Test;
@@ -23,19 +24,29 @@ public class WebTest {
     @Autowired
     private CorpService corpService;
 
+    @Autowired
+    private FosterwxMobilePoolService fosterwxMobilePoolService;
+
     @Test
     public void test1() {
         // 清洗数据
         fosterwxMobileService.list().forEach(fosterwxMobile -> {
-            if (corpService.count(new LambdaQueryWrapper<Corp>().eq(Corp::getName, fosterwxMobile.getWorkWxCorp())) > 1) {
-                log.warn("{}名字有两个主体", fosterwxMobile.getWorkWxCorp());
-            }
-            Corp corp = corpService.getOne(new LambdaQueryWrapper<Corp>().eq(Corp::getName, fosterwxMobile.getWorkWxCorp()).last("Limit 1"));
-            if (null != corp) {
-                fosterwxMobile.setWorkWxCorpId(corp.getId());
-                fosterwxMobile.setWxAppid(corp.getWxCorpid());
-                fosterwxMobileService.updateById(fosterwxMobile);
-            }
+            // if (corpService.count(new LambdaQueryWrapper<Corp>().eq(Corp::getName, fosterwxMobile.getWorkWxCorp())) > 1) {
+            //     log.warn("{}名字有两个主体", fosterwxMobile.getWorkWxCorp());
+            // }
+            // Corp corp = corpService.getOne(new LambdaQueryWrapper<Corp>().eq(Corp::getName, fosterwxMobile.getWorkWxCorp()).last("Limit 1"));
+            // if (null != corp) {
+            //     fosterwxMobile.setWorkWxCorpId(corp.getId());
+            //     fosterwxMobile.setWxAppid(corp.getWxCorpid());
+            //     fosterwxMobileService.updateById(fosterwxMobile);
+            // } else {
+            //     fosterwxMobile.setWorkWxCorpId(0);
+            //     fosterwxMobile.setWxAppid(null);
+            //     fosterwxMobileService.updateById(fosterwxMobile);
+            // }
+            fosterwxMobilePoolService.update(new FosterwxMobilePool() {{
+                setWxAppid(fosterwxMobile.getWxAppid());
+            }}, new LambdaQueryWrapper<FosterwxMobilePool>().eq(FosterwxMobilePool::getPoolIndex, fosterwxMobile.getMobileUnioCode()));
         });
     }
 }