|
|
|
@ -17,14 +17,37 @@ |
|
|
|
|
|
|
|
package com.epmet.service.impl; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
import com.epmet.commons.tools.exception.ValidateException; |
|
|
|
import com.epmet.commons.tools.utils.HttpClientManager; |
|
|
|
import com.epmet.commons.tools.validator.ValidatorUtils; |
|
|
|
import com.epmet.constant.WxmpMessageConstant; |
|
|
|
import com.epmet.dao.WxmpResiUserSubscribeDao; |
|
|
|
import com.epmet.dao.WxmpTemplateMsgSubscribeStatusDao; |
|
|
|
import com.epmet.dao.WxmpWorkUserSubscribeDao; |
|
|
|
import com.epmet.dto.form.StaffBasicInfoFormDTO; |
|
|
|
import com.epmet.dto.form.UserBasicInfoFormDTO; |
|
|
|
import com.epmet.dto.form.WxSubscribeMessageFormDTO; |
|
|
|
import com.epmet.entity.WxmpMsgSendRecordEntity; |
|
|
|
import com.epmet.entity.WxmpTemplateMsgSubscribeStatusEntity; |
|
|
|
import com.epmet.exception.WxSubscribeException; |
|
|
|
import com.epmet.feign.EpmetUserOpenFeignClient; |
|
|
|
import com.epmet.redis.WxmpMessageRedis; |
|
|
|
import com.epmet.service.WxmpMessageService; |
|
|
|
import com.epmet.service.WxmpMsgSendRecordService; |
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.slf4j.Logger; |
|
|
|
import org.slf4j.LoggerFactory; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
|
import java.util.HashMap; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Map; |
|
|
|
|
|
|
|
/** |
|
|
|
* 微信消息订阅Service |
|
|
|
* |
|
|
|
@ -38,6 +61,21 @@ public class WxmpMessageServiceImpl implements WxmpMessageService { |
|
|
|
@Autowired |
|
|
|
private WxmpTemplateMsgSubscribeStatusDao msgSubscribeStatusDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private EpmetUserOpenFeignClient epmetUserOpenFeignClient; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpMessageRedis wxmpMessageRedis; |
|
|
|
|
|
|
|
@Resource |
|
|
|
private WxmpResiUserSubscribeDao wxmpResiUserSubscribeDao; |
|
|
|
|
|
|
|
@Resource |
|
|
|
private WxmpWorkUserSubscribeDao wxmpWorkUserSubscribeDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private WxmpMsgSendRecordService wxmpMsgSendRecordService; |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 保存系统授权信息 |
|
|
|
* @return void |
|
|
|
@ -62,4 +100,172 @@ public class WxmpMessageServiceImpl implements WxmpMessageService { |
|
|
|
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 { |
|
|
|
ValidatorUtils.validateEntity(msg); |
|
|
|
|
|
|
|
String userId = msg.getUserId(); |
|
|
|
String clientType = msg.getClientType(); |
|
|
|
String customerId = msg.getCustomerId(); |
|
|
|
String templateId = msg.getTemplateId(); |
|
|
|
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); |
|
|
|
} |
|
|
|
|
|
|
|
//判断用户是否有次数
|
|
|
|
Integer count = null; |
|
|
|
if (WxmpMessageConstant.RESI.equals(clientType)) { |
|
|
|
count = wxmpResiUserSubscribeDao.getResiSubscribeInfo(openId, customerId, templateId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
count = wxmpWorkUserSubscribeDao.getWorkSubscribeInfo(openId, customerId, templateId); |
|
|
|
} |
|
|
|
if (count == null) { |
|
|
|
//用户未订阅
|
|
|
|
throw new WxSubscribeException("用户未订阅",openId); |
|
|
|
} |
|
|
|
if (count == 0) { |
|
|
|
throw new WxSubscribeException("用户可用额度不足",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())); |
|
|
|
data.put(WxmpMessageConstant.MESSAGE_CONTENT, new JSONObject().put("value", msg.getMessageContent())); |
|
|
|
data.put(WxmpMessageConstant.MESSAGE_TIME, new JSONObject().put("value", msg.getMessageTime())); |
|
|
|
jsonObject.put(WxmpMessageConstant.DATA, data); |
|
|
|
//选填项
|
|
|
|
if (StringUtils.isNotBlank(msg.getPage())) { |
|
|
|
jsonObject.put(WxmpMessageConstant.PAGE, msg.getPage()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(msg.getMiniprogramState())) { |
|
|
|
jsonObject.put(WxmpMessageConstant.MINIPROGRAM_STATE, msg.getMiniprogramState()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(msg.getLang())) { |
|
|
|
jsonObject.put(WxmpMessageConstant.LANG, msg.getLang()); |
|
|
|
} |
|
|
|
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, customerId, templateId, 1); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
decrease = wxmpWorkUserSubscribeDao.decreaseWorkSubscribeCount(openId, customerId, templateId, 1); |
|
|
|
} |
|
|
|
if (decrease == 0) { |
|
|
|
logger.error("消息{}发送成功但订阅条数-1失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
//存表
|
|
|
|
int saveRes = wxmpMsgSendRecordService.saveRecord(initRecord(msg,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, customerId, templateId); |
|
|
|
} else if (WxmpMessageConstant.WORK.equals(clientType)) { |
|
|
|
clear = wxmpWorkUserSubscribeDao.clearWorkSubscribeCount(openId, customerId, templateId); |
|
|
|
} |
|
|
|
if (clear == 0) { |
|
|
|
logger.error("消息{}发送失败且清空订阅条数失败", JSON.toJSONString(msg)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
//抛出错误
|
|
|
|
throw new WxSubscribeException(String.valueOf(resultMap.get(WxmpMessageConstant.ERR_MSG)),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).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 openId, String status){ |
|
|
|
WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = new WxmpMsgSendRecordEntity(); |
|
|
|
wxmpMsgSendRecordEntity.setCustomerId(msg.getCustomerId()); |
|
|
|
wxmpMsgSendRecordEntity.setClientType(msg.getClientType()); |
|
|
|
wxmpMsgSendRecordEntity.setTemplateId(msg.getTemplateId()); |
|
|
|
wxmpMsgSendRecordEntity.setUserId(msg.getUserId()); |
|
|
|
wxmpMsgSendRecordEntity.setWxOpenId(openId); |
|
|
|
wxmpMsgSendRecordEntity.setBehaviorType(msg.getBehaviorType()); |
|
|
|
wxmpMsgSendRecordEntity.setTitle("您有一条" + msg.getBehaviorType()); |
|
|
|
wxmpMsgSendRecordEntity.setMessageContent(msg.getMessageContent()); |
|
|
|
wxmpMsgSendRecordEntity.setMessageTime(msg.getMessageTime()); |
|
|
|
wxmpMsgSendRecordEntity.setResult(status); |
|
|
|
return wxmpMsgSendRecordEntity; |
|
|
|
} |
|
|
|
} |
|
|
|
|
liushaowen
5 years ago