From 7c7ce7bef175b9b0c10edf15ed4e96d5d446a845 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期一, 26 二月 2024 18:26:56 +0800
Subject: [PATCH] 优化投诉单功能
---
service-job/src/main/java/com/java110/job/msgNotify/wechat/WechatMsgNotifyImpl.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 51 insertions(+), 0 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/msgNotify/wechat/WechatMsgNotifyImpl.java b/service-job/src/main/java/com/java110/job/msgNotify/wechat/WechatMsgNotifyImpl.java
index 07cacc4..502c407 100644
--- a/service-job/src/main/java/com/java110/job/msgNotify/wechat/WechatMsgNotifyImpl.java
+++ b/service-job/src/main/java/com/java110/job/msgNotify/wechat/WechatMsgNotifyImpl.java
@@ -19,6 +19,7 @@
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.ListUtil;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
@@ -612,4 +613,54 @@
JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
return new ResultVo(paramOut.getIntValue("errcode"), paramOut.getString("errmsg"));
}
+
+ /**
+ * 鎶曡瘔閫氱煡鍛樺伐
+ *
+ * @param communityId 灏忓尯
+ * @param userId 鐢ㄦ埛
+ * @param content {
+ * complainName
+ * }
+ * @return
+ */
+ @Override
+ public ResultVo sendComplaintMsg(String communityId, String userId, JSONObject content) {
+ String accessToken = wechatTemplateImpl.getAccessToken(communityId);
+
+ StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();
+ staffAppAuthDto.setStaffId(userId);
+ staffAppAuthDto.setAppType("WECHAT");
+ List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMOImpl.queryStaffAppAuths(staffAppAuthDto);
+ if (ListUtil.isNull(staffAppAuthDtos)) {
+ throw new IllegalArgumentException("鍛樺伐鏈璇侊紝娌℃湁鑾峰彇鍒板井淇penId");
+ }
+ String openId = staffAppAuthDtos.get(0).getOpenId();
+ Mapping mapping = MappingCache.getMapping(MappingConstant.WECHAT_DOMAIN, SPEC_CD_WECHAT_PROCESS_TEMPLATE);
+
+ if (mapping == null) {
+ throw new IllegalArgumentException("寮�鍙戣�呰处鎴风紪鐮佹槧灏勬湭閰嶇疆鍩熶负=" + MappingConstant.WECHAT_DOMAIN + ",閿负=" + SPEC_CD_WECHAT_PROCESS_TEMPLATE);
+ }
+ String templateId = wechatTemplateImpl.getTemplateId(communityId, mapping.getValue(), mapping.getName(), templateKeys.get(SPEC_CD_WECHAT_PROCESS_TEMPLATE));
+
+ String url = sendMsgUrl + accessToken;
+
+ JSONObject data = new JSONObject();
+ PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();
+ templateMessage.setTemplate_id(templateId);
+ templateMessage.setTouser(openId);
+ data.put("thing2", new Content("鎶曡瘔鍗曞鐞嗘祦绋�"));
+ data.put("time10", new Content(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B)));
+ data.put("thing9", new Content(content.getString("complaintName")));
+ templateMessage.setData(data);
+ //鑾峰彇鍛樺伐鍏紬鍙峰湴鍧�
+ String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN, "STAFF_WECHAT_URL");
+ templateMessage.setUrl(wechatUrl);
+ logger.info("鍙戦�佹ā鏉挎秷鎭唴瀹�:{}", JSON.toJSONString(templateMessage));
+ ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);
+ logger.info("寰俊妯℃澘杩斿洖鍐呭:{}", responseEntity);
+
+ JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
+ return new ResultVo(paramOut.getIntValue("errcode"), paramOut.getString("errmsg"));
+ }
}
--
Gitblit v1.8.0