Prechádzať zdrojové kódy

添加一个推送消息接口

lighter 2 rokov pred
rodič
commit
f03ff30463

+ 8 - 1
src/main/java/thyyxxk/wxservice_server/controller/WxApiController.java

@@ -1,5 +1,6 @@
 package thyyxxk.wxservice_server.controller;
 
+import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
@@ -73,7 +74,13 @@ public class WxApiController {
 
     @PostMapping("/pushMessage")
     public void pushMessage(@RequestBody @Validated PushMessageParam param) {
-        pushWxMessageService.pushMessage(param);
+        pushWxMessageService.pushMessage2(param);
+    }
+
+    @PostMapping("/pushMessage2")
+    public String pushMessage2(@RequestBody JSONObject param) {
+        boolean result = pushWxMessageService.pushMessage2(param);
+        return result ? "SUCCESS" : "FAIL";
     }
 
     @PostMapping("/getWxPayQrcode")

+ 1 - 1
src/main/java/thyyxxk/wxservice_server/scheduled/QuestionnaireAfterVisit.java

@@ -56,7 +56,7 @@ public class QuestionnaireAfterVisit {
                 "\"template_id\":\"G4YAN56RmDjEPpNyP5fpCdr5TghyqspDeWlWaD5Eg2o\"," +
                 "\"url\":\"" + url + "\"}";
         JSONObject message = JSONObject.parseObject(msgContent);
-        if (messageService.pushMessage(message)) {
+        if (messageService.pushMessage2(message)) {
             dao.updateQuestionnaireTime(visit.getPatientId());
         }
     }

+ 1 - 1
src/main/java/thyyxxk/wxservice_server/service/CovidVaccinateAppointmentService.java

@@ -135,7 +135,7 @@ public class CovidVaccinateAppointmentService {
             pojo.setCardNo(param.getPatientId());
             pojo.setCardNoPatientId(true);
             pojo.setMsgContext(JSONObject.parseObject(msgContent));
-            pushWxMessageService.pushMessage(pojo);
+            pushWxMessageService.pushMessage2(pojo);
         }
         log.info("预约新冠疫苗接种:{}", JSONObject.toJSONStringWithDateFormat(param, "yyyy-MM-dd HH:mm:ss"));
         return ResultVoUtil.success("您已成功预约新冠疫苗接种服务。请于【" + dateFormatted + "】" +

+ 1 - 1
src/main/java/thyyxxk/wxservice_server/service/IdCardAnalyzeService.java

@@ -181,7 +181,7 @@ public class IdCardAnalyzeService {
         PushMessageParam pojo = new PushMessageParam();
         pojo.setCardNo(temp.getIcCardNo());
         pojo.setMsgContext(JSONObject.parseObject(msgContent));
-        pushWxMessageService.pushMessage(pojo);
+        pushWxMessageService.pushMessage2(pojo);
         return ResultVoUtil.success(map);
     }
 }

+ 2 - 2
src/main/java/thyyxxk/wxservice_server/service/PatientCardsService.java

@@ -119,7 +119,7 @@ public class PatientCardsService {
         PushMessageParam pojo = new PushMessageParam();
         pojo.setCardNo(param.getIcCardNo());
         pojo.setMsgContext(JSONObject.parseObject(msgContent));
-        pushWxMessageService.pushMessage(pojo);
+        pushWxMessageService.pushMessage2(pojo);
         return map;
     }
 
@@ -174,7 +174,7 @@ public class PatientCardsService {
                     "\"url\":\"\"}";
         }
         pojo.setMsgContext(JSONObject.parseObject(msgContent));
-        pushWxMessageService.pushMessage(pojo);
+        pushWxMessageService.pushMessage2(pojo);
         return ResultVoUtil.success("变更就诊卡成功。");
     }
 }

+ 2 - 2
src/main/java/thyyxxk/wxservice_server/service/PushWxMessageService.java

@@ -27,7 +27,7 @@ public class PushWxMessageService {
         this.dao = dao;
     }
 
-    public void pushMessage(PushMessageParam param) {
+    public void pushMessage2(PushMessageParam param) {
         if (StringUtil.isBlank(param.getCardNo())) {
             return;
         }
@@ -48,7 +48,7 @@ public class PushWxMessageService {
         }
     }
 
-    public boolean pushMessage(JSONObject msgContent) {
+    public boolean pushMessage2(JSONObject msgContent) {
         RestTemplate template = new RestTemplate();
         String wxUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" +
                 PropertiesUtil.getLocalProperty("access_token");

+ 1 - 1
src/main/java/thyyxxk/wxservice_server/service/SavePayResultService.java

@@ -256,7 +256,7 @@ public class SavePayResultService {
         PushMessageParam pojo = new PushMessageParam();
         pojo.setCardNo(yjjDao.selectCardNoByPatientId(order.getPatientId()));
         pojo.setMsgContext(JSONObject.parseObject(msgContent));
-        pushWxMessageService.pushMessage(pojo);
+        pushWxMessageService.pushMessage2(pojo);
         dao.updateSuccessHisStatus(order.getTradeNo());
         return ResultVoUtil.success("保存住院预交金信息成功。");
     }