公众号消息通知飞手执照及能力认证审核通过

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

@@ -11,6 +11,7 @@ import com.mmc.iuav.user.constant.WxConstant;
 import com.mmc.iuav.user.controller.userpoints.config.NumberOfUserPoints;
 import com.mmc.iuav.user.controller.userpoints.config.UserPointsEnum;
 import com.mmc.iuav.user.controller.wx.*;
+import com.mmc.iuav.user.dao.UserSubInfoDao;
 import com.mmc.iuav.user.dao.dronepilot.PilotCertificationDao;
 import com.mmc.iuav.user.dao.userpoints.UserPointsDao;
 import com.mmc.iuav.user.dao.userpoints.UserPointsDetailsDao;
@@ -24,9 +25,11 @@ import com.mmc.iuav.user.model.dto.dronepilot.*;
 import com.mmc.iuav.user.model.qo.dronepilot.*;
 import com.mmc.iuav.user.model.vo.CompanyInfoVO;
 import com.mmc.iuav.user.model.vo.PilotAuditSumVO;
+import com.mmc.iuav.user.model.vo.WxMsgVO;
 import com.mmc.iuav.user.model.vo.dronepilot.PilotAbilityVO;
 import com.mmc.iuav.user.model.vo.dronepilot.PilotCertificationVO;
 import com.mmc.iuav.user.model.vo.userpoints.UserPointsVO;
+import com.mmc.iuav.user.service.WxService;
 import com.mmc.iuav.user.service.dronepilot.PilotCertificationService;
 import com.mmc.iuav.user.util.SmsUtil;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -72,6 +75,13 @@ public class PilotCertificationServiceImpl implements PilotCertificationService
     @Value("${iuav.ims.uri}")
     private String imsApp;
 
+    @Autowired
+    private WxService wxService;
+
+    @Autowired
+    private UserSubInfoDao userSubInfoDao;
+
+
     @Override
     public ResultBody insertPilot(PilotCertificationVO certificationVO, LoginSuccessDTO userLoginInfoFromRedis) {
 
@@ -297,6 +307,17 @@ public class PilotCertificationServiceImpl implements PilotCertificationService
         if (param.getAuditStatus() == 1) {
             String pilotApplyPhone = certificationDao.getPilotApplyPhone(param.getId());
             SmsUtil.sendPassPilotApply(pilotApplyPhone);
+
+            // 审核通过，通过公众号发布消息通知
+            WxMsgVO ws = new WxMsgVO();
+            String unionId = userAccountDO.getUnionId();
+            // 查询对应的openId(touser)
+            String touser = userSubInfoDao.getUserSubInfoByUnionId(unionId).getOpenId();
+            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()));
@@ -642,4 +663,25 @@ public class PilotCertificationServiceImpl implements PilotCertificationService
         userIdList.add(userAccountId);
         return userIdList;
     }
+
+    public JSONObject spellMsg(String name, String result){
+        JSONObject data=new JSONObject();
+
+        //申请项目{{thing3.DATA}}
+        JSONObject thing3=new JSONObject();
+        thing3.put("value",name);
+        data.put("thing3",thing3);
+
+        //审核时间{{time6.DATA}}
+        JSONObject time6=new JSONObject();
+        time6.put("value",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+        data.put("time6",time6);
+
+        //审核结果{{thing5.DATA}}
+        JSONObject thing5=new JSONObject();
+        thing5.put("value",thing5);
+        data.put("thing5",result);
+
+        return data;
+    }
 }