公众号提现以及飞手认证公众号提醒修改BUG

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/WxController.java

@@ -111,4 +111,10 @@ public class WxController extends BaseController {
     public ResultBody moveSubUserUnionIdToTest() {
         return wxService.moveSubUserUnionIdToTest();
     }
+    @ApiOperation(value = "同步微信公众号用户数据")
+    @ApiResponses({@ApiResponse(code = 200, message = "OK", response = ResultBody.class)})
+    @GetMapping("moveSubUser")
+    public ResultBody moveSubUser() {
+        return wxService.moveSubUser();
+    }
 }

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

@@ -109,6 +109,8 @@ public interface WxService {
 
     ResultBody moveSubUserUnionIdToTest();
 
+    ResultBody moveSubUser();
+
     ResultBody getUserPortrait();
     
 }

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

@@ -316,12 +316,14 @@ public class PilotCertificationServiceImpl implements PilotCertificationService
             String unionId = userAccountDO.getUnionId();
             // 查询对应的openId(touser)
             String touser = userSubInfoDao.getUserOpenidByUnionId(unionId);
+            if(touser != null){
                 JSONObject jsonObject = spellMsg("飞手执照及能力认证","审核通过");
                 ws.setTouser(touser);
                 ws.setTemplateId("9qvgBhfW9yoQJY91iMfhrog8y5eZUPSbo9PLvQzS_vk");
                 ws.setDataObject(jsonObject);
                 wxService.sendSubTemplateMsg(ws);
             }
+        }
 
         PilotCertificationLogDO pilotCertificationLog = new PilotCertificationLogDO(userAccountDO.getId(), userLoginInfoFromRedis.getUserAccountId(), CertificationMessage.match(param.getAuditStatus()));
         certificationDao.insertPilotLog(pilotCertificationLog);

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

@@ -389,7 +389,7 @@ public class WxServiceImpl implements WxService {
     @Override
     public ResultBody moveSubUserUnionIdToTest() {
         String accessToken = this.getSubStableAccessToken();
-        String url = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=" + accessToken + "&next_openid=" + "oB6kk6obNektxM62mjj9PJHPtcME";
+        String url = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=" + accessToken;
         String jsonStr = HttpsRequestUtil.httpsGet(url, null);
         log.info("all users：{}", jsonStr);
         JSONObject obj = JSONObject.parseObject(jsonStr);
@@ -397,7 +397,7 @@ public class WxServiceImpl implements WxService {
         int count = 0;
         for (String openid : lists) {
             UserSubInfoDO userSubInfo = userSubInfoDao.getUserSubInfo(openid);
-            if (userSubInfo != null) {
+            if (userSubInfo != null && userSubInfo.getUnionId() == null ) {
                 String InfoUrl = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=" + accessToken + "&openid=" + openid
                         + "&lang=zh_CN";
                 String jsonStr1 = HttpsRequestUtil.httpsGet(InfoUrl, null);
@@ -410,7 +410,35 @@ public class WxServiceImpl implements WxService {
         log.info("User count: {}", count);
         return ResultBody.success();
     }
-
+    @Override
+    public ResultBody moveSubUser() {
+        String accessToken = this.getSubStableAccessToken();
+        String url = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=" + accessToken;
+        String jsonStr = HttpsRequestUtil.httpsGet(url, null);
+        log.info("all users：{}", jsonStr);
+        JSONObject obj = JSONObject.parseObject(jsonStr);
+        List<String> lists = JSONArray.parseArray(obj.getJSONObject("data").get("openid").toString(), String.class);
+        int count = 0;
+        for (String openid : lists) {
+            Integer integer = userSubInfoDao.countUserSubInfo(openid);
+            if (integer == 0) {
+                count++;
+                UserSubInfoDO sub = new UserSubInfoDO();
+                sub.setOpenId(openid);
+                sub.setRegStatus(1);
+                sub.setDeleted(0);
+                sub.setCreateTime(new Date());
+                String InfoUrl = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=" + accessToken + "&openid=" + openid
+                        + "&lang=zh_CN";
+                String jsonStr1 = HttpsRequestUtil.httpsGet(InfoUrl, null);
+                JSONObject obj1 = JSONObject.parseObject(jsonStr1);
+                sub.setUnionId(obj1.getString("unionid"));
+                userSubInfoDao.insertUserSubInfo(sub);
+            }
+        }
+        log.info("User count: {}", count);
+        return ResultBody.success();
+    }
 
     @Override
     public ResultBody getUserPortrait() {

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

@@ -255,12 +255,15 @@ public class WithdrawalServiceImpl implements WithdrawalService {
         WxMsgVO ws = new WxMsgVO();
         String unionId = userServiceDao.getUserAccountById(applyInfo.getUserAccountId()).getUnionId();
         // 查询对应的openId(touser)
-        String touser = userSubInfoDao.getUserSubInfoByUnionId(unionId).getOpenId();
+        UserSubInfoDO info = userSubInfoDao.getUserSubInfoByUnionId(unionId);
+        if(info != null && info.getOpenId() != null){
+            String touser = info.getOpenId();
             JSONObject jsonObject = spellMsg(applyInfo.getEmpName(), applyInfo.getPayAmount(), applyInfo.getPayAccount());
             ws.setTouser(touser);
             ws.setTemplateId("y6PHvZownxqR5hf4dSXaa2Lp1jeq3ccytd6G-kUQla4");
             ws.setDataObject(jsonObject);
             wxService.sendSubTemplateMsg(ws);
+        }
         return ResultBody.success();
     }