|
|
|
@ -19,28 +19,32 @@ package com.epmet.service.impl; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
|
import com.epmet.commons.tools.constant.AppClientConstant; |
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
import com.epmet.commons.tools.enums.EnvEnum; |
|
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
|
import com.epmet.commons.tools.exception.ValidateException; |
|
|
|
import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
|
import com.epmet.commons.tools.utils.HttpClientManager; |
|
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
|
import com.epmet.commons.tools.validator.ValidatorUtils; |
|
|
|
import com.epmet.constant.WxMsgTemplateSubscribeStatus; |
|
|
|
import com.epmet.constant.WxmpMessageConstant; |
|
|
|
import com.epmet.dao.WxmpResiUserSubscribeDao; |
|
|
|
import com.epmet.dao.WxmpTemplateMsgSubscribeStatusDao; |
|
|
|
import com.epmet.dao.WxmpUserSubscribeRecordDao; |
|
|
|
import com.epmet.dao.WxmpWorkUserSubscribeDao; |
|
|
|
import com.epmet.dto.form.GetTemplateListFormDTO; |
|
|
|
import com.epmet.dto.form.StaffBasicInfoFormDTO; |
|
|
|
import com.epmet.dto.form.UserBasicInfoFormDTO; |
|
|
|
import com.epmet.dto.form.WxSubscribeMessageFormDTO; |
|
|
|
import com.epmet.dto.result.GetTemplateListResultDTO; |
|
|
|
import com.epmet.entity.WxmpMsgSendRecordEntity; |
|
|
|
import com.epmet.entity.WxmpTemplateMsgSubscribeStatusEntity; |
|
|
|
import com.epmet.dto.result.StaffBasicInfo; |
|
|
|
import com.epmet.dto.result.UserBasicInfo; |
|
|
|
import com.epmet.dto.result.WxMsgAuthInfoResultDTO; |
|
|
|
import com.epmet.entity.*; |
|
|
|
import com.epmet.exception.WxSubscribeException; |
|
|
|
import com.epmet.feign.EpmetUserOpenFeignClient; |
|
|
|
import com.epmet.redis.WxmpMessageRedis; |
|
|
|
import com.epmet.redis.WxmpMsgSendRecordRedis; |
|
|
|
import com.epmet.service.WxmpMessageService; |
|
|
|
import com.epmet.service.WxmpMsgSendRecordService; |
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
@ -50,7 +54,6 @@ import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
|
import java.text.ParseException; |
|
|
|
import java.text.SimpleDateFormat; |
|
|
|
import java.util.Date; |
|
|
|
import java.util.HashMap; |
|
|
|
@ -65,234 +68,244 @@ import java.util.Map; |
|
|
|
*/ |
|
|
|
@Service |
|
|
|
public class WxmpMessageServiceImpl implements WxmpMessageService { |
|
|
|
private Logger logger = LoggerFactory.getLogger(getClass()); |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpTemplateMsgSubscribeStatusDao msgSubscribeStatusDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private EpmetUserOpenFeignClient epmetUserOpenFeignClient; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpMessageRedis wxmpMessageRedis; |
|
|
|
|
|
|
|
@Resource |
|
|
|
private WxmpResiUserSubscribeDao wxmpResiUserSubscribeDao; |
|
|
|
|
|
|
|
@Resource |
|
|
|
private WxmpWorkUserSubscribeDao wxmpWorkUserSubscribeDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpMsgSendRecordService wxmpMsgSendRecordService; |
|
|
|
|
|
|
|
/** |
|
|
|
* @return void |
|
|
|
* @Description 保存系统授权信息 |
|
|
|
* @author wxz |
|
|
|
* @date 2020.10.21 17:29 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void saveSysAuthorizeInfo(String customerId, String clientType, String alwaysVisit, String subscribeStatus, String userId) { |
|
|
|
WxmpTemplateMsgSubscribeStatusEntity userSubscribeStatusEntity = msgSubscribeStatusDao.getUserSubscribeStatusEntity(userId, customerId, clientType); |
|
|
|
if (userSubscribeStatusEntity != null) { |
|
|
|
userSubscribeStatusEntity.setAlwaysVisit(alwaysVisit); |
|
|
|
userSubscribeStatusEntity.setSubscribeStatus(subscribeStatus); |
|
|
|
msgSubscribeStatusDao.updateById(userSubscribeStatusEntity); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
userSubscribeStatusEntity = new WxmpTemplateMsgSubscribeStatusEntity(); |
|
|
|
userSubscribeStatusEntity.setCustomerId(customerId); |
|
|
|
userSubscribeStatusEntity.setClientType(clientType); |
|
|
|
userSubscribeStatusEntity.setAlwaysVisit(alwaysVisit); |
|
|
|
userSubscribeStatusEntity.setSubscribeStatus(subscribeStatus); |
|
|
|
userSubscribeStatusEntity.setUserId(userId); |
|
|
|
msgSubscribeStatusDao.insert(userSubscribeStatusEntity); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @param msgList |
|
|
|
* @return void |
|
|
|
* @Description 发送订阅消息 |
|
|
|
* @Author liushaowen |
|
|
|
* @Date 2020/10/21 15:34 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void sendWxSubscribeMessage(List<WxSubscribeMessageFormDTO> msgList) { |
|
|
|
logger.info("待发送订阅消息数量:{}", msgList.size()); |
|
|
|
int succecssCount = 0; |
|
|
|
for (WxSubscribeMessageFormDTO msg : msgList) { |
|
|
|
try { |
|
|
|
String userId = msg.getUserId(); |
|
|
|
String clientType = msg.getClientType(); |
|
|
|
String customerId = msg.getCustomerId(); |
|
|
|
String templateId = null; |
|
|
|
String openId = null; |
|
|
|
//通过userId获取openId
|
|
|
|
try { |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
UserBasicInfoFormDTO userBasicInfoFormDTO = new UserBasicInfoFormDTO(); |
|
|
|
userBasicInfoFormDTO.setUserId(userId); |
|
|
|
openId = epmetUserOpenFeignClient.getUserBasicInfo(userBasicInfoFormDTO).getData().getOpenId(); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
StaffBasicInfoFormDTO staffBasicInfoFormDTO = new StaffBasicInfoFormDTO(); |
|
|
|
staffBasicInfoFormDTO.setStaffId(userId); |
|
|
|
openId = epmetUserOpenFeignClient.getStaffBasicInfo(staffBasicInfoFormDTO).getData().getOpenId(); |
|
|
|
} else { |
|
|
|
throw new WxSubscribeException("clientType有误", "", openId); |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
throw new WxSubscribeException("连接User服务失败", "", ""); |
|
|
|
} |
|
|
|
|
|
|
|
if (StringUtils.isBlank(openId)) { |
|
|
|
throw new WxSubscribeException("openId获取失败", "", ""); |
|
|
|
} |
|
|
|
|
|
|
|
//获取accessToken
|
|
|
|
StringBuilder key = new StringBuilder(msg.getCustomerId()).append(":").append(msg.getClientType()); |
|
|
|
Map<String, Object> authorizerRefreshToken = new HashMap<>(); |
|
|
|
try { |
|
|
|
authorizerRefreshToken = wxmpMessageRedis.getAuthorizerRefreshToken(key.toString()); |
|
|
|
} catch (Exception e) { |
|
|
|
throw new WxSubscribeException("连接缓存服务器失败", "", openId); |
|
|
|
} |
|
|
|
String accessToken = (String) authorizerRefreshToken.get(WxmpMessageConstant.AUTHORIZER_ACCESS_TOKEN); |
|
|
|
if (StringUtils.isBlank(accessToken)) { |
|
|
|
throw new WxSubscribeException("accessToken获取失败", "", openId); |
|
|
|
} |
|
|
|
|
|
|
|
//获取模板id
|
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
templateId = wxmpResiUserSubscribeDao.getResiSubscribeTemplateId(openId, templateId, customerId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
templateId = wxmpWorkUserSubscribeDao.getWorkSubscribeTemplateId(openId, templateId, customerId); |
|
|
|
} |
|
|
|
if (StringUtils.isBlank(templateId)) { |
|
|
|
throw new WxSubscribeException("获取模板id失败", "", openId); |
|
|
|
} |
|
|
|
|
|
|
|
//判断用户是否有次数
|
|
|
|
Integer count = null; |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
count = wxmpResiUserSubscribeDao.getResiSubscribeInfo(openId, templateId, customerId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
count = wxmpWorkUserSubscribeDao.getWorkSubscribeInfo(openId, templateId, customerId); |
|
|
|
} |
|
|
|
if (count == null) { |
|
|
|
//用户未订阅
|
|
|
|
throw new WxSubscribeException("用户未订阅", templateId, openId); |
|
|
|
} |
|
|
|
if (count == 0) { |
|
|
|
throw new WxSubscribeException("用户可用额度不足", templateId, openId); |
|
|
|
} |
|
|
|
|
|
|
|
//发送消息
|
|
|
|
JSONObject jsonObject = new JSONObject(); |
|
|
|
JSONObject data = new JSONObject(); |
|
|
|
//必填项
|
|
|
|
jsonObject.put(WxmpMessageConstant.ACCESS_TOKEN, accessToken); |
|
|
|
jsonObject.put(WxmpMessageConstant.TOUSER, openId); |
|
|
|
jsonObject.put(WxmpMessageConstant.TEMPLATE_ID, templateId); |
|
|
|
data.put(WxmpMessageConstant.TITLE, new JSONObject().put("value", ("您有一条" + msg.getBehaviorType()).substring(0, WxmpMessageConstant.TITLE_LIMIT))); |
|
|
|
data.put(WxmpMessageConstant.MESSAGE_CONTENT, new JSONObject().put("value", msg.getMessageContent().substring(0, WxmpMessageConstant.MESSAGE_CONTENT_LIMIT))); |
|
|
|
data.put(WxmpMessageConstant.MESSAGE_TIME, new JSONObject().put("value", new SimpleDateFormat("yyyy-MM-dd HH:mm").format(new Date()))); |
|
|
|
jsonObject.put(WxmpMessageConstant.DATA, data); |
|
|
|
EnvEnum envEnum = EnvEnum.getCurrentEnv(); |
|
|
|
//选填项
|
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
jsonObject.put(WxmpMessageConstant.PAGE, WxmpMessageConstant.PAGE_RESI); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
jsonObject.put(WxmpMessageConstant.PAGE, WxmpMessageConstant.PAGE_WORK); |
|
|
|
} |
|
|
|
//开发环境
|
|
|
|
if ("dev".equals(envEnum.getCode())) { |
|
|
|
jsonObject.put(WxmpMessageConstant.MINIPROGRAM_STATE, WxmpMessageConstant.STATE_DEV); |
|
|
|
} |
|
|
|
//测试环境
|
|
|
|
if ("test".equals(envEnum.getCode())) { |
|
|
|
jsonObject.put(WxmpMessageConstant.MINIPROGRAM_STATE, WxmpMessageConstant.STATE_TEST); |
|
|
|
} |
|
|
|
|
|
|
|
String resultStr = HttpClientManager.getInstance().sendPostByJSON(WxmpMessageConstant.SEND_MESSAGE + accessToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
|
Map<String, Object> resultMap = JSON.parseObject(resultStr, Map.class); |
|
|
|
Object errcode = resultMap.get(WxmpMessageConstant.ERR_CODE); |
|
|
|
if (errcode.equals(NumConstant.ZERO)) { |
|
|
|
//发送成功
|
|
|
|
|
|
|
|
//订阅条数-1
|
|
|
|
int decrease = 0; |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
decrease = wxmpResiUserSubscribeDao.decreaseResiSubscribeCount(openId, templateId, customerId, 1); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
decrease = wxmpWorkUserSubscribeDao.decreaseWorkSubscribeCount(openId, templateId, customerId, 1); |
|
|
|
} |
|
|
|
if (decrease == 0) { |
|
|
|
logger.error("消息{}发送成功但订阅条数-1失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
//存表
|
|
|
|
int saveRes = wxmpMsgSendRecordService.saveRecord(initRecord(msg, templateId, openId, WxmpMessageConstant.SUCCESS)); |
|
|
|
if (saveRes == 0) { |
|
|
|
logger.error("消息{}发送成功但存入记录表失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
} else { |
|
|
|
//发送失败
|
|
|
|
//用户拒绝，需清空订阅表条数，修改订阅状态
|
|
|
|
if (errcode.equals(WxmpMessageConstant.USER_REFUSED)) { |
|
|
|
int clear = 0; |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
clear = wxmpResiUserSubscribeDao.clearResiSubscribeCount(openId, templateId, customerId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
clear = wxmpWorkUserSubscribeDao.clearWorkSubscribeCount(openId, templateId, customerId); |
|
|
|
} |
|
|
|
if (clear == 0) { |
|
|
|
logger.error("消息{}发送失败且清空订阅条数失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
//抛出错误
|
|
|
|
throw new WxSubscribeException(String.valueOf(resultMap.get(WxmpMessageConstant.ERR_MSG)),templateId, openId); |
|
|
|
} |
|
|
|
|
|
|
|
succecssCount++; |
|
|
|
} catch (Exception e) { |
|
|
|
String errMsg = e.getMessage(); |
|
|
|
//ValidateException错误信息为getMsg
|
|
|
|
private Logger logger = LoggerFactory.getLogger(getClass()); |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpTemplateMsgSubscribeStatusDao msgSubscribeStatusDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private EpmetUserOpenFeignClient epmetUserOpenFeignClient; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpMessageRedis wxmpMessageRedis; |
|
|
|
|
|
|
|
@Resource |
|
|
|
private WxmpResiUserSubscribeDao wxmpResiUserSubscribeDao; |
|
|
|
|
|
|
|
@Resource |
|
|
|
private WxmpWorkUserSubscribeDao wxmpWorkUserSubscribeDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpMsgSendRecordService wxmpMsgSendRecordService; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpUserSubscribeRecordDao subscribeRecordDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpResiUserSubscribeDao resiUserSubscribeDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private EpmetUserOpenFeignClient userOpenFeignClient; |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 保存系统授权信息 |
|
|
|
* @return void |
|
|
|
* @author wxz |
|
|
|
* @date 2020.10.21 17:29 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void saveSysAuthorizeInfo(String customerId, String clientType, String alwaysVisit, String subscribeStatus, String userId, String templateId) { |
|
|
|
WxmpTemplateMsgSubscribeStatusEntity userSubscribeStatusEntity = msgSubscribeStatusDao.getUserSubscribeStatusEntity(userId, customerId, clientType, templateId); |
|
|
|
if (userSubscribeStatusEntity != null) { |
|
|
|
userSubscribeStatusEntity.setAlwaysVisit(alwaysVisit); |
|
|
|
userSubscribeStatusEntity.setSubscribeStatus(subscribeStatus); |
|
|
|
msgSubscribeStatusDao.updateById(userSubscribeStatusEntity); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
userSubscribeStatusEntity = new WxmpTemplateMsgSubscribeStatusEntity(); |
|
|
|
userSubscribeStatusEntity.setCustomerId(customerId); |
|
|
|
userSubscribeStatusEntity.setClientType(clientType); |
|
|
|
userSubscribeStatusEntity.setTemplateId(templateId); |
|
|
|
userSubscribeStatusEntity.setAlwaysVisit(alwaysVisit); |
|
|
|
userSubscribeStatusEntity.setSubscribeStatus(subscribeStatus); |
|
|
|
userSubscribeStatusEntity.setUserId(userId); |
|
|
|
msgSubscribeStatusDao.insert(userSubscribeStatusEntity); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @param msgList |
|
|
|
* @return void |
|
|
|
* @Description 发送订阅消息 |
|
|
|
* @Author liushaowen |
|
|
|
* @Date 2020/10/21 15:34 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void sendWxSubscribeMessage(List<WxSubscribeMessageFormDTO> msgList) { |
|
|
|
logger.info("待发送订阅消息数量:{}", msgList.size()); |
|
|
|
int succecssCount = 0; |
|
|
|
for (WxSubscribeMessageFormDTO msg : msgList) { |
|
|
|
try { |
|
|
|
String userId = msg.getUserId(); |
|
|
|
String clientType = msg.getClientType(); |
|
|
|
String customerId = msg.getCustomerId(); |
|
|
|
String templateId = null; |
|
|
|
String openId = null; |
|
|
|
//通过userId获取openId
|
|
|
|
try { |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
UserBasicInfoFormDTO userBasicInfoFormDTO = new UserBasicInfoFormDTO(); |
|
|
|
userBasicInfoFormDTO.setUserId(userId); |
|
|
|
openId = epmetUserOpenFeignClient.getUserBasicInfo(userBasicInfoFormDTO).getData().getOpenId(); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
StaffBasicInfoFormDTO staffBasicInfoFormDTO = new StaffBasicInfoFormDTO(); |
|
|
|
staffBasicInfoFormDTO.setStaffId(userId); |
|
|
|
openId = epmetUserOpenFeignClient.getStaffBasicInfo(staffBasicInfoFormDTO).getData().getOpenId(); |
|
|
|
} else { |
|
|
|
throw new WxSubscribeException("clientType有误", "", openId); |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
throw new WxSubscribeException("连接User服务失败", "", ""); |
|
|
|
} |
|
|
|
|
|
|
|
if (StringUtils.isBlank(openId)) { |
|
|
|
throw new WxSubscribeException("openId获取失败", "", ""); |
|
|
|
} |
|
|
|
|
|
|
|
//获取accessToken
|
|
|
|
StringBuilder key = new StringBuilder(msg.getCustomerId()).append(":").append(msg.getClientType()); |
|
|
|
Map<String, Object> authorizerRefreshToken = new HashMap<>(); |
|
|
|
try { |
|
|
|
authorizerRefreshToken = wxmpMessageRedis.getAuthorizerRefreshToken(key.toString()); |
|
|
|
} catch (Exception e) { |
|
|
|
throw new WxSubscribeException("连接缓存服务器失败", "", openId); |
|
|
|
} |
|
|
|
String accessToken = (String) authorizerRefreshToken.get(WxmpMessageConstant.AUTHORIZER_ACCESS_TOKEN); |
|
|
|
if (StringUtils.isBlank(accessToken)) { |
|
|
|
throw new WxSubscribeException("accessToken获取失败", "", openId); |
|
|
|
} |
|
|
|
|
|
|
|
//获取模板id
|
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
templateId = wxmpResiUserSubscribeDao.getResiSubscribeTemplateId(openId, templateId, customerId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
templateId = wxmpWorkUserSubscribeDao.getWorkSubscribeTemplateId(openId, templateId, customerId); |
|
|
|
} |
|
|
|
if (StringUtils.isBlank(templateId)) { |
|
|
|
throw new WxSubscribeException("获取模板id失败", "", openId); |
|
|
|
} |
|
|
|
|
|
|
|
//判断用户是否有次数
|
|
|
|
Integer count = null; |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
count = wxmpResiUserSubscribeDao.getResiSubscribeInfo(openId, templateId, customerId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
count = wxmpWorkUserSubscribeDao.getWorkSubscribeInfo(openId, templateId, customerId); |
|
|
|
} |
|
|
|
if (count == null) { |
|
|
|
//用户未订阅
|
|
|
|
throw new WxSubscribeException("用户未订阅", templateId, openId); |
|
|
|
} |
|
|
|
if (count == 0) { |
|
|
|
throw new WxSubscribeException("用户可用额度不足", templateId, openId); |
|
|
|
} |
|
|
|
|
|
|
|
//发送消息
|
|
|
|
JSONObject jsonObject = new JSONObject(); |
|
|
|
JSONObject data = new JSONObject(); |
|
|
|
//必填项
|
|
|
|
jsonObject.put(WxmpMessageConstant.ACCESS_TOKEN, accessToken); |
|
|
|
jsonObject.put(WxmpMessageConstant.TOUSER, openId); |
|
|
|
jsonObject.put(WxmpMessageConstant.TEMPLATE_ID, templateId); |
|
|
|
data.put(WxmpMessageConstant.TITLE, new JSONObject().put("value", ("您有一条" + msg.getBehaviorType()).substring(0, WxmpMessageConstant.TITLE_LIMIT))); |
|
|
|
data.put(WxmpMessageConstant.MESSAGE_CONTENT, new JSONObject().put("value", msg.getMessageContent().substring(0, WxmpMessageConstant.MESSAGE_CONTENT_LIMIT))); |
|
|
|
data.put(WxmpMessageConstant.MESSAGE_TIME, new JSONObject().put("value", new SimpleDateFormat("yyyy-MM-dd HH:mm").format(new Date()))); |
|
|
|
jsonObject.put(WxmpMessageConstant.DATA, data); |
|
|
|
EnvEnum envEnum = EnvEnum.getCurrentEnv(); |
|
|
|
//选填项
|
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
jsonObject.put(WxmpMessageConstant.PAGE, WxmpMessageConstant.PAGE_RESI); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
jsonObject.put(WxmpMessageConstant.PAGE, WxmpMessageConstant.PAGE_WORK); |
|
|
|
} |
|
|
|
//开发环境
|
|
|
|
if ("dev".equals(envEnum.getCode())) { |
|
|
|
jsonObject.put(WxmpMessageConstant.MINIPROGRAM_STATE, WxmpMessageConstant.STATE_DEV); |
|
|
|
} |
|
|
|
//测试环境
|
|
|
|
if ("test".equals(envEnum.getCode())) { |
|
|
|
jsonObject.put(WxmpMessageConstant.MINIPROGRAM_STATE, WxmpMessageConstant.STATE_TEST); |
|
|
|
} |
|
|
|
|
|
|
|
String resultStr = HttpClientManager.getInstance().sendPostByJSON(WxmpMessageConstant.SEND_MESSAGE + accessToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
|
Map<String, Object> resultMap = JSON.parseObject(resultStr, Map.class); |
|
|
|
Object errcode = resultMap.get(WxmpMessageConstant.ERR_CODE); |
|
|
|
if (errcode.equals(NumConstant.ZERO)) { |
|
|
|
//发送成功
|
|
|
|
|
|
|
|
//订阅条数-1
|
|
|
|
int decrease = 0; |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
decrease = wxmpResiUserSubscribeDao.decreaseResiSubscribeCount(openId, templateId, customerId, 1); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
decrease = wxmpWorkUserSubscribeDao.decreaseWorkSubscribeCount(openId, templateId, customerId, 1); |
|
|
|
} |
|
|
|
if (decrease == 0) { |
|
|
|
logger.error("消息{}发送成功但订阅条数-1失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
//存表
|
|
|
|
int saveRes = wxmpMsgSendRecordService.saveRecord(initRecord(msg, templateId, openId, WxmpMessageConstant.SUCCESS)); |
|
|
|
if (saveRes == 0) { |
|
|
|
logger.error("消息{}发送成功但存入记录表失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
} else { |
|
|
|
//发送失败
|
|
|
|
//用户拒绝，需清空订阅表条数，修改订阅状态
|
|
|
|
if (errcode.equals(WxmpMessageConstant.USER_REFUSED)) { |
|
|
|
int clear = 0; |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
clear = wxmpResiUserSubscribeDao.clearResiSubscribeCount(openId, templateId, customerId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
clear = wxmpWorkUserSubscribeDao.clearWorkSubscribeCount(openId, templateId, customerId); |
|
|
|
} |
|
|
|
if (clear == 0) { |
|
|
|
logger.error("消息{}发送失败且清空订阅条数失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
//抛出错误
|
|
|
|
throw new WxSubscribeException(String.valueOf(resultMap.get(WxmpMessageConstant.ERR_MSG)),templateId, openId); |
|
|
|
} |
|
|
|
|
|
|
|
succecssCount++; |
|
|
|
} catch (Exception e) { |
|
|
|
String errMsg = e.getMessage(); |
|
|
|
//ValidateException错误信息为getMsg
|
|
|
|
// if (StringUtils.isBlank(errMsg) && e instanceof ValidateException) {
|
|
|
|
// errMsg = ((ValidateException) e).getMsg();
|
|
|
|
// }
|
|
|
|
if (e instanceof WxSubscribeException) { |
|
|
|
//存表
|
|
|
|
WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = initRecord(msg, ((WxSubscribeException) e).getTemplateId(), ((WxSubscribeException) e).getOpenId(), WxmpMessageConstant.ERROR); |
|
|
|
wxmpMsgSendRecordEntity.setReason(errMsg); |
|
|
|
int saveRes = wxmpMsgSendRecordService.saveRecord(wxmpMsgSendRecordEntity); |
|
|
|
if (saveRes == 0) { |
|
|
|
logger.error("消息{}发送失败且存入记录表失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
logger.error("消息:{}发送失败,原因是:{}", JSON.toJSONString(msg), errMsg); |
|
|
|
continue; |
|
|
|
} |
|
|
|
} |
|
|
|
logger.info("{}条消息中的{}条发送成功", msgList.size(), succecssCount); |
|
|
|
} |
|
|
|
|
|
|
|
//初始化记录对象
|
|
|
|
private WxmpMsgSendRecordEntity initRecord(WxSubscribeMessageFormDTO msg, String templateId, String openId, String status) { |
|
|
|
WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = new WxmpMsgSendRecordEntity(); |
|
|
|
wxmpMsgSendRecordEntity.setCustomerId(msg.getCustomerId()); |
|
|
|
wxmpMsgSendRecordEntity.setClientType(msg.getClientType()); |
|
|
|
wxmpMsgSendRecordEntity.setTemplateId(templateId); |
|
|
|
wxmpMsgSendRecordEntity.setUserId(msg.getUserId()); |
|
|
|
wxmpMsgSendRecordEntity.setWxOpenId(openId); |
|
|
|
wxmpMsgSendRecordEntity.setBehaviorType(msg.getBehaviorType()); |
|
|
|
wxmpMsgSendRecordEntity.setTitle("您有一条" + msg.getBehaviorType()); |
|
|
|
wxmpMsgSendRecordEntity.setMessageContent(msg.getMessageContent()); |
|
|
|
wxmpMsgSendRecordEntity.setMessageTime(new Date()); |
|
|
|
wxmpMsgSendRecordEntity.setResult(status); |
|
|
|
return wxmpMsgSendRecordEntity; |
|
|
|
} |
|
|
|
if (e instanceof WxSubscribeException) { |
|
|
|
//存表
|
|
|
|
WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = initRecord(msg, ((WxSubscribeException) e).getTemplateId(), ((WxSubscribeException) e).getOpenId(), WxmpMessageConstant.ERROR); |
|
|
|
wxmpMsgSendRecordEntity.setReason(errMsg); |
|
|
|
int saveRes = wxmpMsgSendRecordService.saveRecord(wxmpMsgSendRecordEntity); |
|
|
|
if (saveRes == 0) { |
|
|
|
logger.error("消息{}发送失败且存入记录表失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
logger.error("消息:{}发送失败,原因是:{}", JSON.toJSONString(msg), errMsg); |
|
|
|
continue; |
|
|
|
} |
|
|
|
} |
|
|
|
logger.info("{}条消息中的{}条发送成功", msgList.size(), succecssCount); |
|
|
|
} |
|
|
|
|
|
|
|
//初始化记录对象
|
|
|
|
private WxmpMsgSendRecordEntity initRecord(WxSubscribeMessageFormDTO msg, String templateId, String openId, String status) { |
|
|
|
WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = new WxmpMsgSendRecordEntity(); |
|
|
|
wxmpMsgSendRecordEntity.setCustomerId(msg.getCustomerId()); |
|
|
|
wxmpMsgSendRecordEntity.setClientType(msg.getClientType()); |
|
|
|
wxmpMsgSendRecordEntity.setTemplateId(templateId); |
|
|
|
wxmpMsgSendRecordEntity.setUserId(msg.getUserId()); |
|
|
|
wxmpMsgSendRecordEntity.setWxOpenId(openId); |
|
|
|
wxmpMsgSendRecordEntity.setBehaviorType(msg.getBehaviorType()); |
|
|
|
wxmpMsgSendRecordEntity.setTitle("您有一条" + msg.getBehaviorType()); |
|
|
|
wxmpMsgSendRecordEntity.setMessageContent(msg.getMessageContent()); |
|
|
|
wxmpMsgSendRecordEntity.setMessageTime(new Date()); |
|
|
|
wxmpMsgSendRecordEntity.setResult(status); |
|
|
|
return wxmpMsgSendRecordEntity; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @return |
|
|
|
@ -319,4 +332,150 @@ public class WxmpMessageServiceImpl implements WxmpMessageService { |
|
|
|
return resultList; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public WxMsgAuthInfoResultDTO getAuthorizationInfo(String customerId, String clientType, String loginUserId, String templateId) { |
|
|
|
return msgSubscribeStatusDao.getUserSubscribeStatusDTO(loginUserId, customerId, clientType, templateId); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void saveWxSubscribe(String customerId, String clientType, String templateId, String wxAlwaysVisit, |
|
|
|
String wxSubscribeStatus, String behaviorType, String userId) { |
|
|
|
|
|
|
|
String openId; |
|
|
|
// 1. 用户订阅信息表新增或者更新
|
|
|
|
if (AppClientConstant.APP_GOV.equals(clientType)) { |
|
|
|
// 工作端
|
|
|
|
openId = getWorkOpenId(userId); |
|
|
|
saveWxWorkSubscribe(customerId, templateId, wxSubscribeStatus, userId, openId); |
|
|
|
} else { |
|
|
|
//居民端
|
|
|
|
openId = getResiOpenId(userId); |
|
|
|
saveWxResiSubscribe(customerId, templateId, wxSubscribeStatus, userId, openId); |
|
|
|
} |
|
|
|
|
|
|
|
// 2.保存行为记录
|
|
|
|
WxmpUserSubscribeRecordEntity record = new WxmpUserSubscribeRecordEntity(); |
|
|
|
record.setBehaviorType(behaviorType); |
|
|
|
record.setCustomerId(customerId); |
|
|
|
record.setTemplateId(templateId); |
|
|
|
record.setUserId(userId); |
|
|
|
record.setWxAlwaysVisit(wxAlwaysVisit); |
|
|
|
record.setWxOpenId(openId); |
|
|
|
record.setWxSubscribeStatus(wxSubscribeStatus); |
|
|
|
subscribeRecordDao.insert(record); |
|
|
|
|
|
|
|
// 3.更新用户模板订阅状态
|
|
|
|
WxmpTemplateMsgSubscribeStatusEntity subscribeStatusEntity = msgSubscribeStatusDao.getUserSubscribeStatusEntity(userId, customerId, clientType, templateId); |
|
|
|
if (subscribeStatusEntity == null) { |
|
|
|
subscribeStatusEntity = new WxmpTemplateMsgSubscribeStatusEntity(); |
|
|
|
subscribeStatusEntity.setUserId(userId); |
|
|
|
subscribeStatusEntity.setWxSubscribeStatus(wxSubscribeStatus); |
|
|
|
subscribeStatusEntity.setTemplateId(templateId); |
|
|
|
subscribeStatusEntity.setWxAlwaysVisit(wxAlwaysVisit); |
|
|
|
subscribeStatusEntity.setCustomerId(customerId); |
|
|
|
subscribeStatusEntity.setClientType(clientType); |
|
|
|
msgSubscribeStatusDao.insert(subscribeStatusEntity); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
subscribeStatusEntity.setWxAlwaysVisit(wxAlwaysVisit); |
|
|
|
subscribeStatusEntity.setWxSubscribeStatus(wxSubscribeStatus); |
|
|
|
|
|
|
|
msgSubscribeStatusDao.updateById(subscribeStatusEntity); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 保存居民端微信订阅信息 |
|
|
|
* @return void |
|
|
|
* @author wxz |
|
|
|
* @date 2020.10.22 09:56 |
|
|
|
*/ |
|
|
|
private void saveWxResiSubscribe(String customerId, String templateId, String wxSubscribeStatus, String userId, String openId) { |
|
|
|
|
|
|
|
WxmpResiUserSubscribeEntity wxResiSubscribe = resiUserSubscribeDao.getWxResiSubscribe(userId, customerId, templateId); |
|
|
|
if (wxResiSubscribe == null) { |
|
|
|
WxmpResiUserSubscribeEntity insert = new WxmpResiUserSubscribeEntity(); |
|
|
|
insert.setCount(WxMsgTemplateSubscribeStatus.SUBSCRIBE.equals(wxSubscribeStatus) ? 1 : 0); |
|
|
|
insert.setCustomerId(customerId); |
|
|
|
insert.setTemplateId(templateId); |
|
|
|
insert.setUserId(userId); |
|
|
|
insert.setWxOpenId(openId); |
|
|
|
insert.setWxSubscribeStatus(wxSubscribeStatus); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
if (WxMsgTemplateSubscribeStatus.SUBSCRIBE.equals(wxSubscribeStatus)) { |
|
|
|
resiUserSubscribeDao.incrSubscribeCount(1, userId, customerId, templateId, openId); |
|
|
|
} else { |
|
|
|
resiUserSubscribeDao.unSubscribe(userId, customerId, templateId, openId); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 保存工作端订阅信息 |
|
|
|
* @return void |
|
|
|
* @author wxz |
|
|
|
* @date 2020.10.22 14:21 |
|
|
|
*/ |
|
|
|
private void saveWxWorkSubscribe(String customerId, String templateId, String wxSubscribeStatus, String userId, String openId) { |
|
|
|
WxmpWorkUserSubscribeEntity wxWorkSubscribe = wxmpWorkUserSubscribeDao.getWxWorkSubscribe(userId, customerId, templateId); |
|
|
|
if (wxWorkSubscribe == null) { |
|
|
|
WxmpWorkUserSubscribeEntity insert = new WxmpWorkUserSubscribeEntity(); |
|
|
|
insert.setCount(WxMsgTemplateSubscribeStatus.SUBSCRIBE.equals(wxSubscribeStatus) ? 1 : 0); |
|
|
|
insert.setCustomerId(customerId); |
|
|
|
insert.setTemplateId(templateId); |
|
|
|
insert.setUserId(userId); |
|
|
|
insert.setWxOpenId(openId); |
|
|
|
insert.setWxSubscribeStatus(wxSubscribeStatus); |
|
|
|
wxmpWorkUserSubscribeDao.insert(insert); |
|
|
|
return ; |
|
|
|
} |
|
|
|
|
|
|
|
if (WxMsgTemplateSubscribeStatus.SUBSCRIBE.equals(wxSubscribeStatus)) { |
|
|
|
wxmpWorkUserSubscribeDao.incrSubscribeCount(1, userId, customerId, templateId, openId); |
|
|
|
} else { |
|
|
|
wxmpWorkUserSubscribeDao.unSubscribe(userId, customerId, templateId, openId); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 根据UserId查询居民OpenId |
|
|
|
* @return string |
|
|
|
* @author wxz |
|
|
|
* @date 2020.10.22 13:35 |
|
|
|
*/ |
|
|
|
public String getResiOpenId(String userId) { |
|
|
|
UserBasicInfoFormDTO bif = new UserBasicInfoFormDTO(); |
|
|
|
bif.setUserId(userId); |
|
|
|
Result<UserBasicInfo> result = userOpenFeignClient.getUserBasicInfo(bif); |
|
|
|
if (!result.success()) { |
|
|
|
throw new RenException(String.format("查询居民OpenId失败,userId:%s，错误信息:%s",userId , result.getInternalMsg())); |
|
|
|
} |
|
|
|
UserBasicInfo userBasicInfo = result.getData(); |
|
|
|
if (userBasicInfo == null) { |
|
|
|
throw new RenException(String.format("根据userId:%s,没有查询到居民OpenId",userId)); |
|
|
|
} |
|
|
|
return userBasicInfo.getOpenId(); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 查询工作人员openId |
|
|
|
* @return java.lang.String |
|
|
|
* @author wxz |
|
|
|
* @date 2020.10.22 14:46 |
|
|
|
*/ |
|
|
|
public String getWorkOpenId(String userId) { |
|
|
|
StaffBasicInfoFormDTO form = new StaffBasicInfoFormDTO(); |
|
|
|
form.setStaffId(userId); |
|
|
|
Result<StaffBasicInfo> result = userOpenFeignClient.getStaffBasicInfo(form); |
|
|
|
if (!result.success()) { |
|
|
|
throw new RenException(String.format("查询工作人员OpenId失败,userId:%s，错误信息:%s",userId , result.getInternalMsg())); |
|
|
|
} |
|
|
|
StaffBasicInfo staffBasicInfo = result.getData(); |
|
|
|
if (staffBasicInfo == null) { |
|
|
|
throw new RenException(String.format("根据userId:%s,没有查询到工作人员OpenId",userId)); |
|
|
|
} |
|
|
|
return staffBasicInfo.getOpenId(); |
|
|
|
} |
|
|
|
} |
wxz
5 years ago