排名

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

@@ -42,6 +42,7 @@ public class SweetAppletSubMsgController {
     // 一次订阅 可以多次发 直到用户取消订阅 所以正规做法应该是记录订阅模版 不关联任何推送数据 等推送的时候查是否订阅某模版
     // 然后发送判断失败是用户取消了 删除订阅记录 或者看取消是否有回调 利用回调处理也可
     // 现在的理解有误 已写完 先用
+    // * 实际到了测试发现订阅一次只能发一条 再次发43101
     @PostMapping("create")
     @ApiOperation("添加订阅记录")
     @ApiImplicitParams({

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

@@ -126,8 +126,8 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
     public ResponseDto setStatList(Integer type) {
         List<SweetCityVoteStatDto> list = sweetCityVoteStatMapper.getStatList(type);
         List<SweetCItyVoteStatVo> sweetCityVoteStatList = redisDataUtils.getSweetCityVoteStatList(type);
+        ArrayList<SweetCItyVoteStatVo> newList = ObjectUtil.getSweetCItyVoteStatVoList();
         if (!CollectionUtils.isEmpty(list)) {
-            ArrayList<SweetCItyVoteStatVo> newList = ObjectUtil.getSweetCItyVoteStatVoList();
             Integer ranking = 0;
             Integer rankingUpOrDown = 2;
             for (SweetCityVoteStatDto cityVote : list) {
@@ -154,6 +154,8 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
             }
             // list.forEach(r -> newList.add(SweetCItyVoteStatVo.getNew().copy(r)));
             redisDataUtils.setSweetCityVoteStatList(newList, type);
+        } else {
+            redisDataUtils.setSweetCityVoteStatList(newList, type);
         }
         redisDataUtils.setSweetCityVoteStatUpdateTime(type);
         return ResponseDto.success();