公众号发送短信

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/impl/WxServiceImpl.java

@@ -9,6 +9,7 @@ import com.mmc.iuav.response.ResultEnum;
 import com.mmc.iuav.user.constant.UserSystemConstant;
 import com.mmc.iuav.user.constant.WxConstant;
 import com.mmc.iuav.user.controller.wx.HttpsOpenUtil;
+import com.mmc.iuav.user.dao.UserServiceDao;
 import com.mmc.iuav.user.dao.UserSubInfoDao;
 import com.mmc.iuav.user.entity.UserSubInfoDO;
 import com.mmc.iuav.user.model.vo.AppletMsgVO;
@@ -49,6 +50,9 @@ public class WxServiceImpl implements WxService {
     @Autowired
     private UserSubInfoDao userSubInfoDao;
 
+    @Autowired
+    private UserServiceDao userServiceDao;
+
     @Override
     public String appLogin(WxLoginVO wxLoginVO) {
         String url = WxConstant.CODE2_SESSION_URL + "?appid=" + userSystemConstant.getWxAppId() + "&secret=" +
@@ -250,6 +254,11 @@ public class WxServiceImpl implements WxService {
         String accessToken = null;
         try {
             accessToken = this.getSubStableAccessToken();
+            if (StringUtils.isBlank(ws.getTouser())) {
+                String unionId = userServiceDao.getUserAccountById(ws.getUserAccountId()).getUnionId();
+                String touser = userSubInfoDao.getUserSubInfoByUnionId(unionId).getOpenId();
+                ws.setTouser(touser);
+            }
             String url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken;
             String param = ws.buildTemplateMsg();
             String result = HttpHelper.httpPost(url, param);