createVote 获取openid

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

@@ -16,7 +16,9 @@ import com.liquidnet.service.sweet.service.ISweetCityVoteService;
 import com.liquidnet.service.sweet.utils.ObjectUtil;
 import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.RedisDataUtils;
+import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
 import com.liquidnet.service.sweet.vo.SweetCItyVoteStatVo;
+import com.liquidnet.service.sweet.vo.SweetWechatUsersVo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -41,6 +43,8 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
     @Autowired
     private RedisDataUtils redisDataUtils;
     @Autowired
+    private WechatUsersRedisUtils usersRedisUtils;
+    @Autowired
     QueueUtils queueUtils;
     @Autowired
     private SweetCityVoteStatMapper sweetCityVoteStatMapper;
@@ -78,8 +82,12 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
         SweetCityVote aNew = SweetCityVote.getNew();
         aNew.setVoteId(IDGenerator.nextSnowId());
         aNew.setPhone(param.getPhone());
-        String sweetWechatOpenId = redisDataUtils.getSweetWechatOpenId(param.getUnionId());
+        SweetWechatUsersVo sweetWechatUsers = usersRedisUtils.getSweetWechatUsers(param.getUnionId(), 2);
+        String sweetWechatOpenId = "";
+        if (null != sweetWechatUsers) {
+            sweetWechatOpenId = sweetWechatUsers.getOpenId();
             aNew.setOpenId(sweetWechatOpenId);
+        }
         aNew.setUnionId(param.getUnionId());
         aNew.setCityCode(param.getCityCode());
         aNew.setCityName(param.getCityName());