diff --git a/pom.xml b/pom.xml index c7269bb24..9f93f7ccc 100644 --- a/pom.xml +++ b/pom.xml @@ -9,7 +9,7 @@ 4.0.0 manage - 1.4.31 + 1.4.32 UTF-8 1.8.0 diff --git a/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/AppActService.java b/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/AppActService.java index 0c19c46fa..2788d7340 100644 --- a/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/AppActService.java +++ b/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/AppActService.java @@ -26,4 +26,6 @@ public interface AppActService { void published(JSONObject manager,String act_id,boolean is_valid); void sendAnnualBillMessage(JSONObject params); + + void sendTESTAnnualBillMessage(JSONObject params); } diff --git a/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/impls/AppActServiceImp.java b/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/impls/AppActServiceImp.java index 5bd61fb08..d042b7d33 100644 --- a/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/impls/AppActServiceImp.java +++ b/src/main/java/au/com/royalpay/payment/manage/activities/app_index/core/impls/AppActServiceImp.java @@ -137,7 +137,6 @@ public class AppActServiceImp implements AppActService { @Override public void sendAnnualBillMessage(JSONObject params) { - logger.debug("sendAnnualMessage Begin"); List tokens = clientDeviceTokenMapper.listAllTokens(params); for (JSONObject devToken : tokens) { @@ -183,6 +182,48 @@ public class AppActServiceImp implements AppActService { } } + @Override + public void sendTESTAnnualBillMessage(JSONObject params) { + logger.debug("sendAnnualMessage Begin"); + JSONObject devToken = clientDeviceTokenMapper.findByDevId("cf90a252-1121-4bfd-a201-fb573b44ac11"); + Runnable task = () -> { + String token = devToken.getString("token"); + JSONObject log = saveAppMessageLog(devToken.getString("dev_id"), + devToken.getIntValue("client_id"), + "annual_bill" + devToken.getString("client_type"), + token, + "年度账单" + ); + try { + JSONObject type = new JSONObject(); + type.put("send_type", "annual_bill"); + type.put("id", devToken.getString("dev_token_id")); + AppMsgSender sender = senderMap.get((devToken.getString("client_type"))); + if (StringUtils.isBlank(token) || sender == null) { + return; + } + JSONObject managerMsg = new JSONObject(); + managerMsg.put("title", LocaleSupport.localeMessage("app.message.title.annual_bill")); + managerMsg.put("body", LocaleSupport.localeMessage("app.message.body.annual_bill")); + managerMsg.put("type", type); + JSONObject messageData = new JSONObject(); + messageData.put("url", PlatformEnvironment.getEnv().concatUrl("/annual_bill.html")); + System.out.println(PlatformEnvironment.getEnv().concatUrl("/annual_bill.html")); + managerMsg.put("data", messageData); + managerMsg.put("msgType", "annual_bill"); + AppMessage appMessage = new AppManagerMessageBuilder(managerMsg).buildMessage(); + sender.sendMessage(appMessage, devToken); + log.put("status", 2); + appMessageLogMapper.update(log); + } catch (Exception e) { + logger.error("出错了:" + e.getMessage()); + appMessageLogMapper.updateStatus(log.getString("send_id"), 1, e.getMessage()); + throw new ServerErrorException("Send App" + devToken.getString("client_type") + "Filed" + ",token" + token, e); + } + }; + sendingAppleMsgPool.execute(task); + } + private JSONObject saveAppMessageLog(String dev_id, int client_id, String messageType, String dev_token, String remark) { JSONObject log = new JSONObject(); log.put("dev_id", dev_id); diff --git a/src/main/java/au/com/royalpay/payment/manage/activities/app_index/web/AppActController.java b/src/main/java/au/com/royalpay/payment/manage/activities/app_index/web/AppActController.java index c104c4694..e42411c2f 100644 --- a/src/main/java/au/com/royalpay/payment/manage/activities/app_index/web/AppActController.java +++ b/src/main/java/au/com/royalpay/payment/manage/activities/app_index/web/AppActController.java @@ -7,10 +7,8 @@ import au.com.royalpay.payment.manage.permission.manager.ManagerMapping; import au.com.royalpay.payment.tools.CommonConsts; import au.com.royalpay.payment.tools.permission.enums.ManagerRole; import au.com.royalpay.payment.tools.utils.PageListUtils; - import com.alibaba.fastjson.JSONObject; import com.github.miemiedev.mybatis.paginator.domain.PageList; - import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -50,13 +48,13 @@ public class AppActController { public String testSendAnnualBillMessage() { JSONObject params = new JSONObject(); params.put("client_id", 9); - appActService.sendAnnualBillMessage(params); + appActService.sendTESTAnnualBillMessage(params); return "success"; } - @GetMapping(value = "/annual/bill/all") - public String sendAnnualBillMessage() { - appActService.sendAnnualBillMessage(null); - return "success"; - } +// @GetMapping(value = "/annual/bill/all") +// public String sendAnnualBillMessage() { +// appActService.sendAnnualBillMessage(null); +// return "success"; +// } }