redis获取openid改成mysql

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/service/impl/sweet/SweetWechatTemplateMsgServiceImpl.java

@@ -6,8 +6,9 @@ import com.liquidnet.service.consumer.base.config.sweet.WechatMaConfigure;
 import com.liquidnet.service.consumer.base.config.sweet.WechatMpConfigure;
 import com.liquidnet.service.sweet.dto.param.SweetOpenSendMsgParam;
 import com.liquidnet.service.sweet.entity.SweetAppletUsers;
+import com.liquidnet.service.sweet.entity.SweetWechatUsers;
 import com.liquidnet.service.sweet.mapper.SweetAppletUsersMapper;
-import com.liquidnet.service.sweet.vo.SweetWechatUsersVo;
+import com.liquidnet.service.sweet.mapper.SweetWechatUsersMapper;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxErrorException;
 import me.chanjar.weixin.mp.api.WxMpService;
@@ -40,6 +41,8 @@ public class SweetWechatTemplateMsgServiceImpl {
 
     @Autowired
     private SweetAppletUsersMapper sweetAppletUserMapper;
+    @Autowired
+    private SweetWechatUsersMapper sweetWechatUsersMapper;
 
 //    @Autowired
 //    private RedisDataUtils redisDataUtils;
@@ -108,13 +111,17 @@ public class SweetWechatTemplateMsgServiceImpl {
             return "";
         } else {
             SweetAppletUsers sweetAppletUser = sweetAppletUsers.get(0);
-//            SweetWechatUsersVo sweetWechatUsers = redisDataUtils.getSweetWechatUsersOfUnionId(sweetAppletUser.getUnionId(), 1);
-//            if (null == sweetWechatUsers) {
-//                log.info("getOpenId没有此WechatUser用户：[phone={},unionId={}]", phone, sweetAppletUser.getUnionId());
+            SweetWechatUsers sweetWechatUsers = sweetWechatUsersMapper.selectOne(
+                    Wrappers.lambdaQuery(SweetWechatUsers.class).
+                            eq(SweetWechatUsers::getIsCancel, 1).eq(SweetWechatUsers::getType, sendTargetType)
+                            .eq(SweetWechatUsers::getUnionId, sweetAppletUser.getUnionId())
+            );
+            if (null == sweetWechatUsers) {
+                log.info("getOpenId没有此WechatUser用户：[phone={},unionId={}]", phone, sweetAppletUser.getUnionId());
                 return "";
-//            } else {
-//                return sweetWechatUsers.getOpenId();
-//            }
+            } else {
+                return sweetWechatUsers.getOpenId();
+            }
         }
     }