sync redis to sweet

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/syncRedis/JxlDataController.java → liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/syncRedis/JxlDataController.java

-package com.liquidnet.service.platform.controller.syncRedis;
+package com.liquidnet.service.sweet.controller.syncRedis;
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.platform.service.syncRedis.JxlDataImpl;
+import com.liquidnet.service.sweet.service.impl.syncRedis.JxlDataImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -62,7 +62,7 @@ public class JxlDataController {
     }
 
     @PostMapping("sweet/wechatUser/unionId")
-    @ApiOperation("sweet-wechatUser-unionId数据迁移")
+    @ApiOperation("sweet-wechatUser-unionId数据迁移-这里也会同步unionIdStr会抛异常过滤掉")
     public ResponseDto<Boolean> sweetUnionId() {
         Boolean result = jxlData.sweetUnionId();
         return ResponseDto.success(result);

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/syncRedis/JxlDataImpl.java → liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/syncRedis/JxlDataImpl.java

-package com.liquidnet.service.platform.service.syncRedis;
+package com.liquidnet.service.sweet.service.impl.syncRedis;
 
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.service.adam.dto.vo.admin.AdminUpushVo;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dto.vo.admin.ZhengzaiAppVersionsVo;
 import com.liquidnet.service.kylin.entity.KylinBanners;
-import com.liquidnet.service.platform.utils.DataUtils;
 import com.liquidnet.service.sweet.entity.SweetWechatUser;
 import com.liquidnet.service.sweet.vo.SweetAnswerVo;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 
@@ -18,12 +17,9 @@ import java.util.LinkedList;
 import java.util.Set;
 
 @Service
+@Slf4j
 public class JxlDataImpl {
 
-    @Autowired
-    private MongoTemplate mongoTemplate;
-    @Autowired
-    private DataUtils dataUtils;
     @Autowired
     private RedisUtil redisUtil;
 
@@ -102,8 +98,12 @@ public class JxlDataImpl {
 
         Set<String> keys = redisTemplateByDb.keys(redisKey);
         for (String key : keys) {
+            try {
                 SweetWechatUser userInfo = (SweetWechatUser) redisTemplateByDb.opsForValue().get(key);
                 redisUtil.set(key, userInfo);
+            } catch (Exception e) {
+                log.error("同步wechatUser失败"+key, e);
+            }
         }
 
         return true;