Merge branch 'jxl_sync_redis' into dev_surplus_redis

liquidnet-bus-service/liquidnet-service-sweet/pom.xml

@@ -59,6 +59,12 @@
             <version>1.0-SNAPSHOT</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.liquidnet</groupId>
+            <artifactId>liquidnet-service-adam-api</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

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

+package com.liquidnet.service.sweet.controller.syncRedis;
+
+import com.liquidnet.service.base.ResponseDto;
+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;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+
+@Api(tags = "redis数据迁移-jxl")
+@RestController
+@RequestMapping("sync")
+public class JxlDataController {
+
+    @Autowired
+    private JxlDataImpl jxlData;
+
+    /**
+     * basicServices
+     * @return
+     */
+    @PostMapping("basicServices/versions")
+    @ApiOperation("basicServices版本控制数据迁移")
+    public ResponseDto<Boolean> basicServicesVersions() {
+        Boolean result = jxlData.basicServicesVersions();
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("basicServices/upush")
+    @ApiOperation("basicServices推送数据迁移-可不迁暂时无数据")
+    public ResponseDto<Boolean> basicServicesUpush() {
+        Boolean result = jxlData.basicServicesUpush();
+        return ResponseDto.success(result);
+    }
+
+    /**
+     * sweet
+     * @return
+     */
+    @PostMapping("sweet/accessToken")
+    @ApiOperation("sweet-AccessToken数据迁移-可不迁可自动生成")
+    public ResponseDto<Boolean> sweetAccessToken() {
+        Boolean result = jxlData.sweetAccessToken();
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("sweet/answer")
+    @ApiOperation("sweet-answer数据迁移")
+    public ResponseDto<Boolean> sweetAnswer() {
+        Boolean result = jxlData.sweetAnswer();
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("sweet/wechatUser/openId")
+    @ApiOperation("sweet-wechatUser-openId数据迁移")
+    public ResponseDto<Boolean> sweetOpenId() {
+        Boolean result = jxlData.sweetOpenId();
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("sweet/wechatUser/unionId")
+    @ApiOperation("sweet-wechatUser-unionId数据迁移-这里也会同步unionIdStr会抛异常过滤掉")
+    public ResponseDto<Boolean> sweetUnionId() {
+        Boolean result = jxlData.sweetUnionId();
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("sweet/wechatUser/unionIdStr")
+    @ApiOperation("sweet-wechatUser-unionIdStr数据迁移")
+    public ResponseDto<Boolean> sweetUnionIdStr() {
+        Boolean result = jxlData.sweetUnionIdStr();
+        return ResponseDto.success(result);
+    }
+
+    /**
+     * kylin
+     * @return
+     */
+    @PostMapping("kylin/banner")
+    @ApiOperation("kylin-banner数据迁移")
+    public ResponseDto<Boolean> kylinBanner() {
+        Boolean result = jxlData.kylinBanner();
+        return ResponseDto.success(result);
+    }
+
+    /*kylin:order:ExpressStatus:id:138291855523471362201224 // 无数据暂时 一条是测试
+    // 下面会自动降级mongo
+    kylin:order:refund:orderId:1000651
+    kylin:order:refund:orderRefundsId:1381407542789734445377
+    kylin:performances:exclusive
+    kylin:performances:notice
+    kylin:performances:recommend
+    kylin:performances:systemRecommend
+    kylin:performances:cityName:七台河
+    kylin:performances:id:103866917946163208505924
+    kylin:performances:roadShowId:14301561753157632035424*/
+
+}

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

+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.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.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.Set;
+
+@Service
+@Slf4j
+public class JxlDataImpl {
+
+    @Autowired
+    private RedisUtil redisUtil;
+
+    public Boolean basicServicesVersions() {
+        RedisTemplate<String, Object> redisTemplateByDb = redisUtil.getRedisTemplateByDb(15);
+
+        String appAndroid = KylinRedisConst.ZHENGZAI_APP_VERSIONS_ANDROID;
+        String appIos = KylinRedisConst.ZHENGZAI_APP_VERSIONS_IOS;
+        String checkAndroid = KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_ANDROID;
+        String checkIos = KylinRedisConst.ZHENGZAI_APP_VERSIONS_CHECK_IOS;
+
+        ZhengzaiAppVersionsVo appAndroidValue = (ZhengzaiAppVersionsVo) redisTemplateByDb.opsForValue().get(appAndroid);
+        redisUtil.set(appAndroid, appAndroidValue);
+        ZhengzaiAppVersionsVo appIosValue = (ZhengzaiAppVersionsVo) redisTemplateByDb.opsForValue().get(appIos);
+        redisUtil.set(appIos, appIosValue);
+        ZhengzaiAppVersionsVo checkAndroidValue = (ZhengzaiAppVersionsVo) redisTemplateByDb.opsForValue().get(checkAndroid);
+        redisUtil.set(checkAndroid, checkAndroidValue);
+        ZhengzaiAppVersionsVo checkIosValue = (ZhengzaiAppVersionsVo) redisTemplateByDb.opsForValue().get(checkIos);
+        redisUtil.set(checkIos, checkIosValue);
+
+        return true;
+    }
+
+    public Boolean basicServicesUpush() {
+        RedisTemplate<String, Object> redisTemplateByDb = redisUtil.getRedisTemplateByDb(15);
+
+        String pushAndroid = KylinRedisConst.ADMIN_UPUSH_LIST_IOS;
+        String pushIos = KylinRedisConst.ADMIN_UPUSH_LIST_ANDROID;
+
+        LinkedList<AdminUpushVo> pushAndroidList = (LinkedList<AdminUpushVo>) redisTemplateByDb.opsForValue().get(pushAndroid);
+        redisUtil.set(pushAndroid, pushAndroidList);
+        LinkedList<AdminUpushVo> pushIosList = (LinkedList<AdminUpushVo>) redisTemplateByDb.opsForValue().get(pushIos);
+        redisUtil.set(pushIos, pushIosList);
+
+        return true;
+    }
+
+    public Boolean sweetAccessToken() {
+//        sweet:accessToken:applet:zhengzai:access_token:wx4732efeaa2b08086
+//        sweet:accessToken:applet:strawberry:access_token:wx08b852ade69f8019
+        return true;
+    }
+
+    public Boolean sweetAnswer() {
+        RedisTemplate<String, Object> redisTemplateByDb = redisUtil.getRedisTemplateByDb(15);
+
+        String redisKey = "sweet:answer:phone*";
+
+        Set<String> keys = redisTemplateByDb.keys(redisKey);
+        for (String key : keys) {
+            SweetAnswerVo answer = (SweetAnswerVo) redisTemplateByDb.opsForValue().get(key);
+            redisUtil.set(key, answer);
+        }
+
+        return true;
+    }
+
+    public Boolean sweetOpenId() {
+        RedisTemplate<String, Object> redisTemplateByDb = redisUtil.getRedisTemplateByDb(15);
+
+        String redisKey = "sweet:wechatUser:openId*";
+
+        Set<String> keys = redisTemplateByDb.keys(redisKey);
+        for (String key : keys) {
+            String value = (String) redisTemplateByDb.opsForValue().get(key);
+            redisUtil.set(key, value);
+        }
+
+        return true;
+    }
+
+    public Boolean sweetUnionId() {
+        RedisTemplate<String, Object> redisTemplateByDb = redisUtil.getRedisTemplateByDb(15);
+
+        String redisKey = "sweet:wechatUser:unionId*";
+
+        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;
+    }
+
+    public Boolean sweetUnionIdStr() {
+        RedisTemplate<String, Object> redisTemplateByDb = redisUtil.getRedisTemplateByDb(15);
+
+        String redisKey = "sweet:wechatUser:unionIdStr*";
+
+        Set<String> keys = redisTemplateByDb.keys(redisKey);
+        for (String key : keys) {
+            String value = (String) redisTemplateByDb.opsForValue().get(key);
+            redisUtil.set(key, value);
+        }
+
+        return true;
+    }
+
+    public Boolean kylinBanner() {
+        RedisTemplate<String, Object> redisTemplateByDb = redisUtil.getRedisTemplateByDb(15);
+
+        String bannerKey = KylinRedisConst.ADMIN_BANNER_LIST;
+
+        ArrayList<KylinBanners> bannerList = (ArrayList<KylinBanners>) redisTemplateByDb.opsForValue().get(bannerKey);
+        redisUtil.set(bannerKey, bannerList);
+
+        return true;
+    }
+}