同步mysql增加mapper

liquidnet-bus-service/liquidnet-service-sweet/docu/db_sweet_integral_activity_20211020.sql

-create database if not exists ln_scene character set utf8mb4 collate utf8mb4_unicode_ci;
--- >>------------------------------------------------------------------------------------
-use ln_scene;
-
 -- 积分活动表
 drop TABLE if exists `sweet_integral_activity`;
 CREATE TABLE `sweet_integral_activity`

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/syncRedis/RedisDataController.java

@@ -93,10 +93,17 @@ public class RedisDataController {
         return ResponseDto.success(result);
     }
 
-    @PostMapping("sweet/cityVote")
-    @ApiOperation("sweet-cityVote数据迁移")
-    public ResponseDto<Boolean> cityVote() {
-        Boolean result = redisDataService.cityVote();
+    @PostMapping("sweet/cityVote3")
+    @ApiOperation("sweet-cityVote3数据迁移")
+    public ResponseDto<Boolean> cityVote3() {
+        Boolean result = redisDataService.cityVote3();
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("sweet/cityVote4")
+    @ApiOperation("sweet-cityVote4数据迁移")
+    public ResponseDto<Boolean> cityVote4() {
+        Boolean result = redisDataService.cityVote4();
         return ResponseDto.success(result);
     }
 

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/syncRedis/RedisDataServiceImpl.java

@@ -214,9 +214,8 @@ public class RedisDataServiceImpl {
         }
     }
 
-    public Boolean cityVote() {
+    public Boolean cityVote3() {
         try {
-//        RedisTemplate<String, Object> redis = redisUtil.getRedisTemplateByDb(15);
             Jedis redis = getRedis();
 
             String redisKey = "sweet:cityVote3:cityCode*";
@@ -240,4 +239,30 @@ public class RedisDataServiceImpl {
             return false;
         }
     }
+
+    public Boolean cityVote4() {
+        try {
+            Jedis redis = getRedis();
+
+            String redisKey = "sweet:cityVote4:cityCode*";
+
+            Set<String> keys = redis.keys(redisKey);
+            for (String key : keys) {
+                String value = redis.get(key);
+                redisUtil.set(key, value);
+            }
+
+            String redisKey2 = "sweet:cityVote4:user*";
+            Set<String> keys2 = redis.keys(redisKey2);
+            for (String key : keys2) {
+                String value = redis.get(key);
+                redisUtil.set(key, value);
+            }
+
+            return true;
+        } catch (Exception e) {
+            log.error("sweetUnionIdStrError", e);
+            return false;
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/syncRedis/UserDataServiceImpl.java

@@ -12,6 +12,8 @@ import com.liquidnet.service.feign.adam.api.FeignAdamBaseClient;
 import com.liquidnet.service.sweet.config.WechatMpConfigure;
 import com.liquidnet.service.sweet.entity.SweetAppletUser;
 import com.liquidnet.service.sweet.mapper.SweetAppletUserMapper;
+import com.liquidnet.service.sweet.mapper.SweetAppletUsersMapper;
+import com.liquidnet.service.sweet.mapper.SweetWechatUsersMapper;
 import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
 import com.liquidnet.service.sweet.vo.SweetAppletUsersVo;
@@ -44,6 +46,12 @@ public class UserDataServiceImpl {
     @Autowired
     private FeignAdamBaseClient feignAdamBaseClient;
 
+    @Autowired
+    private SweetAppletUsersMapper appletUsersMapper;
+
+    @Autowired
+    SweetWechatUsersMapper sweetWechatUsersMapper;
+
     public void userInfo(Integer type) throws WxErrorException {
         WxMpService wxMpService = wechatMpConfigure.getWxMpService(type);
 
@@ -95,6 +103,24 @@ public class UserDataServiceImpl {
                         });
                         queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                                 SqlMapping.gets(sqls, sqlsDataA));
+
+                        /*SweetWechatUsers sweetWechatUsers1 = new SweetWechatUsers();
+                        sweetWechatUsers1.setWechatUserId(sweetWechatUsersVo.getWechatUserId());
+                        sweetWechatUsers1.setType(type);
+                        sweetWechatUsers1.setOpenId(sweetWechatUsersVo.getOpenId());
+                        sweetWechatUsers1.setUnionId(sweetWechatUsersVo.getUnionId());
+                        sweetWechatUsers1.setNickname(sweetWechatUsersVo.getNickname());
+                        sweetWechatUsers1.setSexDesc(sweetWechatUsersVo.getSexDesc());
+                        sweetWechatUsers1.setSex(sweetWechatUsersVo.getSex());
+                        sweetWechatUsers1.setHeadImgUrl(sweetWechatUsersVo.getHeadImgUrl());
+                        sweetWechatUsers1.setLanguage(sweetWechatUsersVo.getLanguage());
+                        sweetWechatUsers1.setCountry(sweetWechatUsersVo.getCountry());
+                        sweetWechatUsers1.setProvince(sweetWechatUsersVo.getProvince());
+                        sweetWechatUsers1.setCity(sweetWechatUsersVo.getCity());
+                        sweetWechatUsers1.setSubscribeTime(sweetWechatUsersVo.getSubscribeTime());
+                        sweetWechatUsers1.setSubscribeScene(sweetWechatUsersVo.getSubscribeScene());
+                        sweetWechatUsersMapper.insert(sweetWechatUsers1);*/
+
                         // 入缓存
                         redisUtils.setSweetWechatUsers(sweetWechatUsersVo);
                     }
@@ -142,6 +168,24 @@ public class UserDataServiceImpl {
             });
             queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                     SqlMapping.gets(sqls, sqlsDataA));
+
+            /*SweetWechatUsers sweetWechatUsers1 = new SweetWechatUsers();
+            sweetWechatUsers1.setWechatUserId(sweetWechatUsersVo.getWechatUserId());
+            sweetWechatUsers1.setType(type);
+            sweetWechatUsers1.setOpenId(sweetWechatUsersVo.getOpenId());
+            sweetWechatUsers1.setUnionId(sweetWechatUsersVo.getUnionId());
+            sweetWechatUsers1.setNickname(sweetWechatUsersVo.getNickname());
+            sweetWechatUsers1.setSexDesc(sweetWechatUsersVo.getSexDesc());
+            sweetWechatUsers1.setSex(sweetWechatUsersVo.getSex());
+            sweetWechatUsers1.setHeadImgUrl(sweetWechatUsersVo.getHeadImgUrl());
+            sweetWechatUsers1.setLanguage(sweetWechatUsersVo.getLanguage());
+            sweetWechatUsers1.setCountry(sweetWechatUsersVo.getCountry());
+            sweetWechatUsers1.setProvince(sweetWechatUsersVo.getProvince());
+            sweetWechatUsers1.setCity(sweetWechatUsersVo.getCity());
+            sweetWechatUsers1.setSubscribeTime(sweetWechatUsersVo.getSubscribeTime());
+            sweetWechatUsers1.setSubscribeScene(sweetWechatUsersVo.getSubscribeScene());
+            sweetWechatUsersMapper.insert(sweetWechatUsers1);*/
+
             // 入缓存
             redisUtils.setSweetWechatUsers(sweetWechatUsersVo);
         }
@@ -172,6 +216,17 @@ public class UserDataServiceImpl {
                     queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
                             SqlMapping.gets(sqlsA, sqlsDataA));
 
+                    /*SweetAppletUsers sweetAppletUsers1 = new SweetAppletUsers();
+                    sweetAppletUsers1.setAppletUserId(info.getUserId());
+                    sweetAppletUsers1.setUserId(userId);
+                    sweetAppletUsers1.setOpenId(info.getOpenId());
+                    sweetAppletUsers1.setUnionId(info.getUnionId());
+                    sweetAppletUsers1.setPhoneNumber(info.getGetPhoneNumber());
+                    sweetAppletUsers1.setPurePhoneNumber(info.getGetPurePhoneNumber());
+                    sweetAppletUsers1.setCountryCode(info.getGetCountryCode());
+                    sweetAppletUsers1.setType(info.getType());
+                    appletUsersMapper.insert(sweetAppletUsers1);*/
+
                     SweetAppletUsersVo sweetAppletUsersVo = SweetAppletUsersVo.getNew();
                     sweetAppletUsersVo.setAppletUserId(info.getUserId());
                     sweetAppletUsersVo.setUserId(userId);