feats: add wx subcribe message

src/main/java/com/huiju/estateagents/service/impl/MiniAppServiceImpl.java

 
     @Override
     public void sendNoticeMessage(TaPerson toUser, String link, String name, String phone, String content, LocalDateTime dt) {
-        List<WxMaTemplateData> data = new ArrayList<>();
-        data.add(new WxMaTemplateData("keyword1", name, "#fffff"));
-        data.add(new WxMaTemplateData("keyword2", phone, "#fffff"));
-        data.add(new WxMaTemplateData("keyword3", content, "#fffff"));
-        data.add(new WxMaTemplateData("keyword4", DateUtils.cutSecond(dt), "#fffff"));
-
-        sendMessage(CommConstant.MINIAPP_TPL_NOTICE, toUser, link, data);
+        List<String> data = new ArrayList<String>(){{
+            add(name);
+            add(phone);
+            add(content);
+            add(DateUtils.cutSecond(dt));
+        }};
+
+        ResponseBean res = sendSubscribeMessage(CommConstant.MINIAPP_TPL_NOTICE, toUser, link, data);
+        if (res.getCode() != ResponseBean.CODE_SUCCESS) {
+            // TODO
+            // 使用短信发送
+        }
     }
     
     @Override
     public void sendHelpMessage(TaPerson toUser, String link, String result, String activityName, LocalDateTime dt) {
-        List<WxMaTemplateData> data = new ArrayList<>();
-        data.add(new WxMaTemplateData("keyword1", result, "#fffff"));
-        data.add(new WxMaTemplateData("keyword2", activityName, "#fffff"));
-        data.add(new WxMaTemplateData("keyword3", DateUtils.cutSecond(dt), "#fffff"));
-        
-        sendMessage(CommConstant.MINIAPP_TPL_HELP, toUser, link, data);
+//        List<WxMaSubscribeData> data = new ArrayList<>();
+//        data.add(new WxMaSubscribeData("keyword1", result, "#fffff"));
+//        data.add(new WxMaSubscribeData("keyword2", activityName, "#fffff"));
+//        data.add(new WxMaSubscribeData("keyword3", DateUtils.cutSecond(dt), "#fffff"));
+
+        // WARN: break change
+        List<String> data = new ArrayList<String>(){{
+            add(activityName);
+            add(result);
+            add(DateUtils.cutSecond(dt));
+        }};
+
+        ResponseBean res = sendSubscribeMessage(CommConstant.MINIAPP_TPL_HELP, toUser, link, data);
+        if (res.getCode() != ResponseBean.CODE_SUCCESS) {
+            // TODO
+            // 使用短信发送
+        }
     }
     
     @Override
     public void sendGroupMessage(TaPerson toUser, String link, String result, String activityName, LocalDateTime dt) {
-        List<WxMaTemplateData> data = new ArrayList<>();
-        data.add(new WxMaTemplateData("keyword1", result, "#fffff"));
-        data.add(new WxMaTemplateData("keyword2", activityName, "#fffff"));
-        data.add(new WxMaTemplateData("keyword3", DateUtils.cutSecond(dt), "#fffff"));
-        
-        sendMessage(CommConstant.MINIAPP_TPL_GROUP, toUser, link, data);
+//        List<WxMaSubscribeData> data = new ArrayList<>();
+//        data.add(new WxMaSubscribeData("keyword1", result, "#fffff"));
+//        data.add(new WxMaSubscribeData("keyword2", activityName, "#fffff"));
+//        data.add(new WxMaSubscribeData("keyword3", DateUtils.cutSecond(dt), "#fffff"));
+
+        // WARN: break change
+        List<String> data = new ArrayList<String>(){{
+            add(activityName);
+            add(result);
+            add(DateUtils.cutSecond(dt));
+        }};
+
+
+        ResponseBean res = sendSubscribeMessage(CommConstant.MINIAPP_TPL_GROUP, toUser, link, data);
+        if (res.getCode() != ResponseBean.CODE_SUCCESS) {
+            // TODO
+            // 使用短信发送
+        }
     }
 
     @Override
     public void sendMainBizMessage(TaPerson toUser, String link, String custName, String phone, String sex, String fromName, String bizType, String content) {
-        List<WxMaTemplateData> data = new ArrayList<>();
-        data.add(new WxMaTemplateData("keyword1", custName, "#fffff"));
-        data.add(new WxMaTemplateData("keyword2", StringUtils.ifNull(phone, "未知"), "#fffff"));
-        data.add(new WxMaTemplateData("keyword3",StringUtils.ifNull(sex, "未知"), "#fffff"));
-        data.add(new WxMaTemplateData("keyword4", fromName, "#fffff"));
-        data.add(new WxMaTemplateData("keyword5", bizType, "#fffff"));
-        data.add(new WxMaTemplateData("keyword6", content, "#fffff"));
-
-        sendMessage("mainbiz", toUser, link, data);
+        List<String> data = new ArrayList<String>(){{
+            add(custName);
+            add(StringUtils.ifNull(phone, "未知"));
+            add(StringUtils.ifNull(sex, "未知"));
+            add(fromName);
+            add(bizType);
+            add(content);
+        }};
+
+        ResponseBean res = sendSubscribeMessage("mainbiz", toUser, link, data);
+        if (res.getCode() != ResponseBean.CODE_SUCCESS) {
+            // TODO
+            // 使用短信发送
+        }
     }
 
     @Override
     public void sendNewCustomerMessage(TaPerson toUser, String link, String custName, String phone, String sex, String fromName) {
-        List<WxMaTemplateData> data = new ArrayList<>();
-        data.add(new WxMaTemplateData("keyword1", custName, "#fffff"));
-        data.add(new WxMaTemplateData("keyword2", StringUtils.ifNull(phone, "未知"), "#fffff"));
-        data.add(new WxMaTemplateData("keyword3",StringUtils.ifNull(sex, "未知"), "#fffff"));
-        data.add(new WxMaTemplateData("keyword4", fromName, "#fffff"));
-
-        sendMessage("newCustomer", toUser, link, data);
+        List<String> data = new ArrayList<String>(){{
+            add(custName);
+            add(StringUtils.ifNull(phone, "未知"));
+            add(StringUtils.ifNull(sex, "未知"));
+            add(fromName);
+        }};
+
+        ResponseBean res = sendSubscribeMessage("newCustomer", toUser, link, data);
+        if (res.getCode() != ResponseBean.CODE_SUCCESS) {
+            // TODO
+            // 使用短信发送
+        }
     }
 
     @Override
         return taMiniappList;
     }
 
+    @Deprecated
     private void sendMessage(String tplName, TaPerson toUser, String link, List<WxMaTemplateData> data) {
         String appid = toUser.getMiniappId();
         if (StringUtils.isEmpty(appid)) {
         }
     }
 
+    private ResponseBean sendSubscribeMessage(String tplName, TaPerson toUser, String link, List<String> data) {
+        String appid = toUser.getMiniappId();
+        if (StringUtils.isEmpty(appid)) {
+            log.error("人员 {} 无对应来源小程序信息", toUser);
+            return ResponseBean.error("消息接收人无 appid 信息", ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        TaMiniappTemplate tpl = getTplByType(tplName, toUser.getMiniappId());
+        if (null == tpl) {
+            log.error("模板 {} 不存在", tplName);
+            return ResponseBean.error("消息模板不存在", ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        List<WxMaSubscribeData> sendData = createMessageData(data, tpl.getFieldNum());
+
+        WxMaSubscribeMessage message = WxMaSubscribeMessage.builder()
+                .templateId(tpl.getTplId())
+                .data(sendData)
+                .page(StringUtils.ifNull(link, CommConstant.MINIAPP_INDEX))
+                .toUser(toUser.getMiniOpenid())
+                .build();
+
+        try {
+            WxMaService wxService = wxUtils.getMiniApp(appid);
+            wxService.getMsgService().sendSubscribeMsg(message);
+
+            return ResponseBean.success("消息发送成功");
+        } catch (WxErrorException e) {
+            e.printStackTrace();
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+    private List<WxMaSubscribeData> createMessageData(List<String> list, Integer count) {
+        List<WxMaSubscribeData> data = new ArrayList<>();
+        if (list == null || list.size() == 0 || count == null || count == 0) return data;
+
+        int length = count > list.size() ? list.size() : count;
+        for (int i = 0; i < length; i++) {
+            data.add(new WxMaSubscribeData("keyword"+ (i+1), list.get(i), "#fffff"));
+        }
+        return data;
+    }
+
     private TaMiniappTemplate getTplByType(String type, String appid) {
         TaMiniappTemplate tpl = taMiniappTemplateMapper.selectTplByType(type, appid);
         return tpl;