package com.ruoyi.order.service.impl;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.ruoyi.account.api.feignClient.AppUserClient;
|
import com.ruoyi.account.api.model.TAppUser;
|
import com.ruoyi.chargingPile.api.model.Site;
|
import com.ruoyi.chargingPile.api.model.TChargingGun;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.order.api.model.TChargingOrder;
|
import com.ruoyi.order.api.model.TOrderEvaluate;
|
import com.ruoyi.order.service.WxSubscribeMessageService;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.LinkedHashMap;
|
import java.util.Map;
|
|
@Service
|
public class WxSubscribeMessageServiceImpl implements WxSubscribeMessageService {
|
|
private static final Logger log = LoggerFactory.getLogger(WxSubscribeMessageServiceImpl.class);
|
private static final String SEND_URL = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token={accessToken}";
|
|
@Resource
|
private AppUserClient appUserClient;
|
@Resource
|
private RestTemplate restTemplate;
|
|
@Override
|
public void sendChargeStart(TChargingOrder order, Site site, TChargingGun chargingGun) {
|
if (order == null) {
|
return;
|
}
|
Map<String, String> data = new LinkedHashMap<>();
|
data.put("thing16", limit(siteName(site), 20));
|
data.put("thing17", limit(gunCode(chargingGun), 20));
|
data.put("amount10", amount(order.getRechargeAmount()));
|
data.put("thing21", limit(defaultText(order.getPlateNum(), "未填写"), 20));
|
send(WxSubscribeTemplate.CHARGE_START, order.getAppUserId(), page(WxSubscribeTemplate.CHARGE_START, order), data);
|
}
|
|
@Override
|
public void sendChargeEnd(TChargingOrder order, Site site, TChargingGun chargingGun) {
|
if (order == null) {
|
return;
|
}
|
Map<String, String> data = new LinkedHashMap<>();
|
data.put("thing6", limit(siteName(site), 20));
|
data.put("character_string15", limit(gunCode(chargingGun), 32));
|
data.put("amount33", amount(order.getPaymentAmount() == null ? order.getOrderAmount() : order.getPaymentAmount()));
|
data.put("amount18", amount(order.getRefundAmount()));
|
data.put("thing3", limit(endReason(order.getEndMode()), 20));
|
send(WxSubscribeTemplate.CHARGE_END, order.getAppUserId(), page(WxSubscribeTemplate.CHARGE_END, order), data);
|
}
|
|
@Override
|
public void sendEvaluationReply(TOrderEvaluate orderEvaluate, TChargingOrder order, Site site) {
|
if (orderEvaluate == null) {
|
return;
|
}
|
Map<String, String> data = new LinkedHashMap<>();
|
data.put("thing1", limit(siteName(site), 20));
|
data.put("thing3", limit(defaultText(orderEvaluate.getEvaluationResponse(), "平台已回复您的评价"), 20));
|
send(WxSubscribeTemplate.SERVICE_EVALUATION, orderEvaluate.getAppUserId(), WxSubscribeTemplate.SERVICE_EVALUATION.getDefaultPage(), data);
|
}
|
|
@Override
|
public void sendPriceDrop(Long appUserId, Site site, BigDecimal price) {
|
Map<String, String> data = new LinkedHashMap<>();
|
data.put("thing1", limit(siteName(site), 20));
|
data.put("amount4", amount(price));
|
send(WxSubscribeTemplate.PRICE_DROP, appUserId, priceDropPage(site), data);
|
}
|
|
private void send(WxSubscribeTemplate template, Long appUserId, String page, Map<String, String> data) {
|
try {
|
if (appUserId == null) {
|
return;
|
}
|
R<TAppUser> userResult = appUserClient.getUserById(appUserId);
|
TAppUser appUser = userResult == null ? null : userResult.getData();
|
if (appUser == null || !StringUtils.hasText(appUser.getWxOpenid())) {
|
log.info("微信订阅消息未发送，用户openid为空，template={}, appUserId={}", template.name(), appUserId);
|
return;
|
}
|
R<String> tokenResult = appUserClient.getWXToken();
|
String accessToken = tokenResult == null ? null : tokenResult.getData();
|
if (!StringUtils.hasText(accessToken)) {
|
log.warn("微信订阅消息未发送，access_token为空，template={}, appUserId={}", template.name(), appUserId);
|
return;
|
}
|
JSONObject payload = buildPayload(appUser.getWxOpenid(), template, page, data);
|
JSONObject response = restTemplate.postForObject(SEND_URL, payload, JSONObject.class, accessToken);
|
if (response != null && response.getIntValue("errcode") != 0) {
|
log.warn("微信订阅消息发送失败，template={}, appUserId={}, response={}", template.name(), appUserId, response);
|
}
|
} catch (Exception e) {
|
log.warn("微信订阅消息发送异常，template={}, appUserId={}", template.name(), appUserId, e);
|
}
|
}
|
|
static JSONObject buildPayload(String openid, WxSubscribeTemplate template, String page, Map<String, String> data) {
|
JSONObject payload = new JSONObject();
|
payload.put("touser", openid);
|
payload.put("template_id", template.getTemplateId());
|
if (StringUtils.hasText(page)) {
|
payload.put("page", page);
|
}
|
JSONObject dataJson = new JSONObject();
|
for (Map.Entry<String, String> entry : data.entrySet()) {
|
JSONObject value = new JSONObject();
|
value.put("value", entry.getValue());
|
dataJson.put(entry.getKey(), value);
|
}
|
payload.put("data", dataJson);
|
return payload;
|
}
|
|
private static String page(WxSubscribeTemplate template, TChargingOrder order) {
|
if (order == null || order.getChargingGunId() == null) {
|
return template.getDefaultPage();
|
}
|
return template.getDefaultPage() + "?gunId=" + order.getChargingGunId();
|
}
|
|
private static String priceDropPage(Site site) {
|
if (site == null || site.getId() == null) {
|
return WxSubscribeTemplate.PRICE_DROP.getDefaultPage();
|
}
|
return WxSubscribeTemplate.PRICE_DROP.getDefaultPage() + "?id=" + site.getId();
|
}
|
|
private static String siteName(Site site) {
|
return site == null ? "充电站" : defaultText(site.getName(), "充电站");
|
}
|
|
private static String gunCode(TChargingGun chargingGun) {
|
if (chargingGun == null) {
|
return "充电桩";
|
}
|
if (StringUtils.hasText(chargingGun.getFullNumber())) {
|
return chargingGun.getFullNumber();
|
}
|
if (StringUtils.hasText(chargingGun.getCode())) {
|
return chargingGun.getCode();
|
}
|
return defaultText(chargingGun.getName(), "充电桩");
|
}
|
|
private static String amount(BigDecimal value) {
|
return (value == null ? BigDecimal.ZERO : value).setScale(2, RoundingMode.HALF_UP).toPlainString() + "元";
|
}
|
|
private static String endReason(Integer endMode) {
|
if (endMode == null) {
|
return "充电结束";
|
}
|
switch (endMode) {
|
case 0:
|
return "异常终止";
|
case 1:
|
return "主动终止";
|
case 2:
|
return "满电终止";
|
case 3:
|
return "费用不足终止";
|
default:
|
return "充电结束";
|
}
|
}
|
|
private static String defaultText(String value, String defaultValue) {
|
return StringUtils.hasText(value) ? value : defaultValue;
|
}
|
|
private static String limit(String value, int maxLength) {
|
if (value == null || value.length() <= maxLength) {
|
return value;
|
}
|
return value.substring(0, maxLength);
|
}
|
}
|
