From fd9c9297a8ae4710dab4fdcc21ad1eb96ca2c2e7 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 31 May 2021 19:26:10 +0800 Subject: [PATCH] tt --- .../main/java/com/iformall/utils/AppTest.java | 4 +- .../com/iformall/mapper/WxCUserMapper.java | 2 + .../impl/WxCreditHistoryServiceImpl.java | 38 +++++++++++-------- .../main/resources/mapper/WxCUserMapper.xml | 4 ++ 4 files changed, 30 insertions(+), 18 deletions(-) diff --git a/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java b/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java index 1aaee0bdb..fd2cfeb5d 100644 --- a/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java +++ b/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java @@ -53,8 +53,8 @@ public class AppTest { paramMap.put("userNumber","551612907794915328");//***会员Id paramMap.put("userPhone","18872592633");//会员手机号 paramMap.put("timeEnd","2021-05-31 11:43:00");//***付款时间(yyyy-MM-dd HH:mm:ss) - paramMap.put("amount","1100");//***付款金额(分) - paramMap.put("summary","我要加积分");//付款摘要 + paramMap.put("amount","2200");//***付款金额(分) + paramMap.put("summary","再来一单");//付款摘要 /** * 交易退款信息 参数 diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java index 23af87b8b..d31bdc4f7 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java @@ -40,4 +40,6 @@ public interface WxCUserMapper extends CommonMapper { void updateMsgCount(WxCUser user); void updateMsgCountDown(@Param("tenantId")String tenantId, @Param("openId")String openId); + + List findOpenIdList(@Param("userId")Long userId, @Param("tenantId")String tenantId); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java index 78ded57ea..7d0562447 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java @@ -319,22 +319,28 @@ public class WxCreditHistoryServiceImpl implements WxCreditHistoryService { temp.setType(EnumTemplateType.CREDIT_UPD_REMIND.getCode()); temp = wxTemplateMsgService.getByObj(temp); if(temp.getId() != null){ - WxMsg msg = new WxMsg(); - msg.updateTenantInfo(record); - msg.setWay(EnumSendWay.APPINFOR.getCode()); - msg.setIsright(EnumMsgSend.MSG_SEND_IMMEDIATELY.getCode()); - msg.setPhones(wxCUserBasicInfo.getPhone()); - msg.setModelId(temp.getId()); - Map map = new HashMap<>(); - map.put("character_string1",record.getCreditNum().toString()); - map.put("character_string2",record.getCreditAmount().toString()); - map.put("time4",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(record.getCreateDate())); - map.put("thing3",record.getChangePurpose()); - map.put("goToPage","pages/index/index?type=jf"); - msg.setMsg(JSONObject.toJSONString(map)); - msg.setName(EnumTemplateType.CREDIT_UPD_REMIND.name()); - msg.setSignature(EnumTemplateType.CREDIT_UPD_REMIND.name()); - wxMsgService.add(msg); + List openIds = wxCUserMapper.findOpenIdList(wxCUserBasicInfo.getId(),tenantId); + if(openIds != null && openIds.size() > 0){ + WxMsg msg = new WxMsg(); + msg.updateTenantInfo(record); + msg.setWay(EnumSendWay.APPINFOR.getCode()); + msg.setIsright(EnumMsgSend.MSG_SEND_IMMEDIATELY.getCode()); + msg.setStatus(EnumMsgStatus.MSG_STATUS_NOT_SEND.getCode()); + msg.setPhones(String.join(",", openIds)); + msg.setModelId(temp.getId()); + Map map = new HashMap<>(); + map.put("character_string1",record.getCreditNum().toString()); + map.put("character_string2",record.getCreditAmount().toString()); + map.put("time4",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(record.getCreateDate())); + map.put("thing3",EnumScoreType.getEnum(record.getCreditType()).getMessage()); + map.put("goToPage","pages/index/index?type=jf"); + msg.setMsg(JSONObject.toJSONString(map)); + msg.setName(EnumTemplateType.CREDIT_UPD_REMIND.name()); + msg.setSignature(EnumTemplateType.CREDIT_UPD_REMIND.name()); + wxMsgService.add(msg); + }else{ + logger.error("找不到微信用户"); + } } } catch (Exception e) { e.printStackTrace(); diff --git a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml index 091a26c95..6ac0a42e2 100644 --- a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml @@ -435,4 +435,8 @@ where user_id = #{userId} and tenant_id = #{tenantId} and id != #{id} + +