package com.nova.sankuai.service.impl;
|
|
import cn.hutool.core.util.BooleanUtil;
|
import cn.hutool.crypto.asymmetric.KeyType;
|
import cn.hutool.crypto.asymmetric.RSA;
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpResponse;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alipay.api.AlipayApiException;
|
import com.alipay.api.AlipayConstants;
|
import com.alipay.api.DefaultAlipayClient;
|
import com.alipay.api.request.AlipayTradeWapPayRequest;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.nova.sankuai.domain.dto.*;
|
import com.nova.sankuai.domain.entity.*;
|
import com.nova.sankuai.domain.vo.AlipayOrderInfoVO;
|
import com.nova.sankuai.infra.config.AlipayConfigProperties;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.mapper.*;
|
import com.nova.sankuai.infra.utils.MessageSendUtil;
|
import com.nova.sankuai.security.UserDetail;
|
import com.nova.sankuai.service.AlipayOrderInfoConverter;
|
import com.nova.sankuai.service.IAlipayPlatformService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.http.MediaType;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.nio.charset.StandardCharsets;
|
import java.security.MessageDigest;
|
import java.security.NoSuchAlgorithmException;
|
import java.text.DecimalFormat;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.util.*;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.locks.Lock;
|
import java.util.concurrent.locks.ReentrantLock;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Service
|
public class AlipayPlatformServiceImpl implements IAlipayPlatformService {
|
|
/*
|
* 参考文档：https://opendocs.alipay.com/open/203/105285
|
*/
|
|
private final SysAlipayAccountMapper alipayAccountMapper;
|
private final SysAlipayAccountUsageMapper alipayAccountUsageMapper;
|
private final AlipayExcessTextmsgReceiverMapper alipayExcessTextmsgReceiverMapper;
|
private final AlipayExcessTextmsgSendRecordMapper alipayExcessTextmsgSendRecordMapper;
|
private final AlipayChannelRecordMapper alipayChannelRecordMapper;
|
private final AlipayOrderInfoMapper alipayOrderInfoMapper;
|
private final AlipayRefundRecordMapper alipayRefundRecordMapper;
|
private final AlipayOrderInfoConverter converter;
|
private final AlipayConfigProperties alipayConf;
|
private final ObjectMapper objectMapper;
|
private final RSA rsa;
|
|
private final VipCardOrderMapper vipCardOrderMapper;
|
private final CustomerUserMapper userMapper;
|
|
private final Lock decisionLock = new ReentrantLock();
|
private final Lock alipayExcessRemindLock = new ReentrantLock();
|
private final Lock alipayExcessPreventionLock = new ReentrantLock();
|
|
private final ExecutorService exec = Executors.newFixedThreadPool(5);
|
|
private final MessageDigest digest;
|
|
private final MessageSendUtil messageSendUtil;
|
|
public AlipayPlatformServiceImpl(SysAlipayAccountMapper alipayAccountMapper,
|
SysAlipayAccountUsageMapper alipayAccountUsageMapper,
|
AlipayExcessTextmsgReceiverMapper alipayExcessTextmsgReceiverMapper,
|
AlipayExcessTextmsgSendRecordMapper alipayExcessTextmsgSendRecordMapper,
|
AlipayChannelRecordMapper alipayChannelRecordMapper,
|
AlipayOrderInfoMapper alipayOrderInfoMapper,
|
AlipayRefundRecordMapper alipayRefundRecordMapper,
|
AlipayOrderInfoConverter converter,
|
AlipayConfigProperties alipayConf,
|
ObjectMapper objectMapper,
|
MessageSendUtil messageSendUtil,
|
@Value("${loginrsa.key-pair.public}") String publicKey,
|
@Value("${loginrsa.key-pair.private}") String privateKey,
|
VipCardOrderMapper vipCardOrderMapper,
|
CustomerUserMapper userMapper) throws NoSuchAlgorithmException {
|
this.alipayAccountMapper = alipayAccountMapper;
|
this.alipayAccountUsageMapper = alipayAccountUsageMapper;
|
this.alipayExcessTextmsgReceiverMapper = alipayExcessTextmsgReceiverMapper;
|
this.alipayExcessTextmsgSendRecordMapper = alipayExcessTextmsgSendRecordMapper;
|
this.alipayChannelRecordMapper = alipayChannelRecordMapper;
|
this.alipayOrderInfoMapper = alipayOrderInfoMapper;
|
this.alipayRefundRecordMapper = alipayRefundRecordMapper;
|
this.converter = converter;
|
this.alipayConf = alipayConf;
|
this.vipCardOrderMapper = vipCardOrderMapper;
|
this.userMapper = userMapper;
|
this.rsa = new RSA(privateKey, publicKey);
|
this.messageSendUtil = messageSendUtil;
|
|
digest = MessageDigest.getInstance("MD5");
|
this.objectMapper = objectMapper;
|
}
|
|
@Override
|
public String orderCreate(AlipayOrderCreateDTO createDTO) {
|
String orderId = createDTO.getChannelId() + "_" + createDTO.getOrderId();
|
|
// 渠道编码检查
|
AlipayChannelRecord channel = checkChannelID(createDTO.getChannelId());
|
|
// 当日支付宝可交易金额是否超额
|
long usageId = accountDecision(orderId, createDTO.getTotalAmount());
|
SysAlipayAccount account = alipayAccountMapper.selectByUsageId(usageId);
|
|
try {
|
// 支付宝订单生成
|
String form = generateAlipayForm(account,
|
orderId, createDTO.getTotalAmount().toPlainString(),
|
createDTO.getOrderSubject(), createDTO.getReturnUrl(),
|
alipayConf.getPlatformNotifyUrl());
|
|
// 生成成功后记录订单信息
|
AlipayOrderInfo order = new AlipayOrderInfo();
|
order.setId(IdWorker.getId());
|
order.setChannelId(createDTO.getChannelId());
|
order.setOrderId(createDTO.getOrderId());
|
order.setOrderSubject(createDTO.getOrderSubject());
|
order.setOrderBody(createDTO.getOrderBody());
|
order.setGmtCreate(new Date());
|
order.setTotalAmount(createDTO.getTotalAmount());
|
order.setOrderStatus("WAIT_BUYER_PAY");
|
order.setAppId(account.getAppId());
|
order.setNotifyUrl(createDTO.getNotifyUrl() != null ? createDTO.getNotifyUrl() : "");
|
|
// 渠道当日是否限额
|
int insert = 0, syncLimit = 30, times = 0;
|
Date date = new Date();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
String from = sdf.format(date) + " 00:00:00";
|
String to = sdf.format(date) + " 23:59:59";
|
while (insert == 0) {
|
if (times >= syncLimit) {
|
throw new CommonException("订单生成错误! 并发异常");
|
}
|
times++;
|
sleepWhile();
|
int vers = checkChannelTradingLimit(channel, createDTO.getTotalAmount());
|
if (vers == -1) {
|
// 执行正常插入
|
order.setRecordVers(0);
|
insert = alipayOrderInfoMapper.insertSelective(order);
|
} else {
|
// 执行版本号插入
|
order.setRecordVers(vers);
|
insert = alipayOrderInfoMapper.insertSelectiveWithVers(order, from, to);
|
}
|
}
|
return form;
|
} catch (Exception e) {
|
// 订单生成失败
|
cancelAlipayOrder(orderId);
|
alipayAccountUsageMapper.deleteById(usageId);
|
throw new CommonException("支付宝订单生成失败!reason=" + e.getMessage());
|
}
|
}
|
|
private void cancelAlipayOrder(String outTradeNo) {
|
}
|
|
private void sleepWhile() {
|
try {
|
TimeUnit.MILLISECONDS.sleep(10L);
|
} catch (InterruptedException ignored) {
|
}
|
}
|
|
private int checkChannelTradingLimit(AlipayChannelRecord channel, BigDecimal amount) {
|
BigDecimal dailyLimit = channel.getDailyLimit();
|
Date date = new Date();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
String from = sdf.format(date) + " 00:00:00";
|
String to = sdf.format(date) + " 23:59:59";
|
int count = alipayOrderInfoMapper.checkTodayHasTradeOrder(channel.getChannelId(), from, to);
|
if (count == 0) {
|
// 当日还没有任何一笔交易
|
if (dailyLimit.subtract(amount).doubleValue() < 0) {
|
throw new CommonException("渠道交易超额");
|
}
|
return -1;
|
}
|
|
String channelId = channel.getChannelId();
|
AlipayChannelDailyLimitDTO limit = alipayOrderInfoMapper.checkChannelIdTradingLimit(channelId, from, to, dailyLimit);
|
if (limit == null) {
|
// 目标渠道当日达到限额
|
throw new CommonException("渠道已限额");
|
}
|
if (dailyLimit.subtract(limit.getTotal()).subtract(amount).doubleValue() < 0) {
|
throw new CommonException("渠道交易超额");
|
}
|
return limit.getVers();
|
}
|
|
@Override
|
public String generateAlipayForm(SysAlipayAccount account,
|
String orderId, String amount, String subject,
|
String returnURL, String notifyURL) throws AlipayApiException {
|
DefaultAlipayClient client = new DefaultAlipayClient(
|
alipayConf.getUrl(),
|
account.getAppId(),
|
account.getPrivateKey(),
|
"json",
|
AlipayConstants.CHARSET_UTF8,
|
account.getPublicKey(),
|
"RSA2");
|
AlipayTradeWapPayRequest alipayReq = new AlipayTradeWapPayRequest();
|
alipayReq.setReturnUrl(returnURL);
|
alipayReq.setNotifyUrl(notifyURL);
|
alipayReq.setBizContent(new JSONObject() {{
|
put("out_trade_no", orderId);
|
put("total_amount", amount);
|
put("subject", subject);
|
put("product_code", "QUICK_WAP_WAY");
|
}}.toJSONString());
|
return client.pageExecute(alipayReq).getBody();
|
}
|
|
private AlipayChannelRecord checkChannelID(String channelId) {
|
AlipayChannelRecord usingChannel = alipayChannelRecordMapper.selectByChannelIdAndStatus(channelId, "using");
|
if (usingChannel == null) {
|
throw new CommonException("渠道ID无效");
|
}
|
return usingChannel;
|
}
|
|
private final Map<String, LocalDate> msgSendFlag = new ConcurrentHashMap<>(4);
|
|
@Override
|
public long accountDecision(String orderId, BigDecimal amount) {
|
try {
|
if (!decisionLock.tryLock(10L, TimeUnit.SECONDS)) {
|
throw new RuntimeException("支付宝账户决定 - 获取锁超时");
|
}
|
LocalDate today = LocalDate.now();
|
|
SysAlipayAccountUsage usage = new SysAlipayAccountUsage();
|
usage.setId(IdWorker.getId());
|
usage.setOrderId(orderId);
|
usage.setCreateDate(today);
|
usage.setSingleAmount(amount);
|
usage.setStatus("init");
|
usage.setCreateDatetime(LocalDateTime.now());
|
int insert = alipayAccountUsageMapper.insertWithSelect(usage);
|
if (insert == 0) {
|
if (!today.equals(msgSendFlag.get("满额提醒"))) {
|
// 没提醒过，或已经是第二天
|
msgSendFlag.put("满额提醒", today);
|
log.info("alipay->进入满额提醒");
|
alipayExcessRemind();
|
}
|
throw new CommonException("所有支付宝账户已限额，请联系管理员");
|
} else {
|
// 如果没有超额，也可能是管理员手工重置了账户可用余额
|
msgSendFlag.remove("满额提醒");
|
alipayExcessPrevention();
|
return usage.getId();
|
}
|
} catch (InterruptedException e) {
|
throw new RuntimeException("支付宝账户决定 - 获取锁中断", e);
|
} finally {
|
decisionLock.unlock();
|
}
|
}
|
|
@Override
|
public void handleNotify(Map<String, String[]> map) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
try {
|
String outTradeNo = nil(map.get("out_trade_no"), it -> it[0]);
|
int splitIndex = outTradeNo.indexOf("_");
|
String channelId = outTradeNo.substring(0, splitIndex);
|
String orderId = outTradeNo.substring(splitIndex + 1);
|
|
AlipayOrderInfo order = new AlipayOrderInfo();
|
order.setAlipaySerial(nil(map.get("trade_no"), it -> it[0])); // 支付宝流水号 trade_no
|
order.setChannelId(channelId);
|
order.setOrderId(orderId);
|
order.setGmtPayment(nil(map.get("gmt_create"), it -> sdf.parse(it[0])));
|
order.setGmtRefund(nil(map.get("gmt_refund"), it -> sdf.parse(it[0])));
|
order.setGmtClose(nil(map.get("gmt_close"), it -> sdf.parse(it[0])));
|
order.setBuyerId(nil(map.get("buyer_id"), it -> it[0]));
|
order.setSellerId(nil(map.get("seller_id"), it -> it[0]));
|
order.setReceiptAmount(newBigDecimal(nil(map.get("receipt_amount"), it -> it[0])));
|
order.setPointAmount(newBigDecimal(nil(map.get("invoice_amount"), it -> it[0])));
|
order.setBuyerPayAmount(newBigDecimal(nil(map.get("buyer_pay_amount"), it -> it[0])));
|
order.setInvoiceAmount(newBigDecimal(nil(map.get("point_amount"), it -> it[0])));
|
order.setRefundFee(newBigDecimal(nil(map.get("refund_fee"), it -> it[0])));
|
order.setOrderStatus(nil(map.get("trade_status"), it -> it[0]));
|
|
if ("TRADE_CLOSED".equals(order.getOrderStatus())) {
|
// 关闭订单
|
alipayAccountUsageMapper.delete(Wrappers.<SysAlipayAccountUsage>lambdaUpdate()
|
.eq(SysAlipayAccountUsage::getOrderId, outTradeNo));
|
} else {
|
alipayAccountUsageMapper.updateStatus(outTradeNo);
|
}
|
|
alipayOrderInfoMapper.updateByOrderSelective(order);
|
|
AlipayOrderQueryDTO condition = new AlipayOrderQueryDTO();
|
condition.setChannelId(channelId);
|
condition.setOrderId(orderId);
|
AlipayOrderInfo orderResult = alipayOrderInfoMapper.selectByChannelIdAndOrderId(condition);
|
|
String notifyUrl = orderResult.getNotifyUrl();
|
if (StringUtils.isNotBlank(notifyUrl)) {
|
ArrayList<String> errors = new ArrayList<>();
|
for (String url : notifyUrl.split(",")) {
|
HttpResponse resp = HttpRequest.post(url)
|
.contentType(MediaType.APPLICATION_JSON_VALUE)
|
.body(toJsonString(sign(toJsonString(converter.toView(orderResult)))))
|
.execute();
|
if (!resp.isOk()) {
|
errors.add(String.format("[%s] resp is not ok: %s", url, resp));
|
} else if (!"ok".equals(resp.body())) {
|
errors.add(String.format("[%s] resp is not ok: %s", url, resp.body()));
|
}
|
}
|
if (errors.size() > 0) {
|
throw new CommonException("回调地址中存在返回错误：" + errors);
|
}
|
}
|
} catch (Exception e) {
|
log.error("AlipayPlatform回调异常! error = " + e.getMessage() + " map = " + JSON.toJSONString(map), e);
|
map.forEach((k, v) -> log.error("alipay callback param: k = " + k + ", v = " + Arrays.toString(v)));
|
throw new RuntimeException(e);
|
}
|
}
|
|
@FunctionalInterface
|
interface MyFunc<T, R> {
|
R apply(T in) throws Exception;
|
}
|
|
private <IN, OUT> OUT nil(IN in, MyFunc<IN, OUT> fun) throws Exception {
|
if (in == null) {
|
return null;
|
}
|
return fun.apply(in);
|
}
|
|
private BigDecimal newBigDecimal(String amount) {
|
if (amount == null) {
|
return null;
|
}
|
return new BigDecimal(amount);
|
}
|
|
@Override
|
public <T> T decode(String encodedString, Class<T> type) {
|
try {
|
if (BooleanUtil.isTrue(alipayConf.getPlatformEncryptFlag())) {
|
byte[] content = rsa.decrypt(Base64.getDecoder().decode(encodedString), KeyType.PrivateKey);
|
return objectMapper.readValue(new String(content), type);
|
}
|
return objectMapper.readValue(encodedString, type);
|
} catch (Exception e) {
|
throw new CommonException("解密失败", e);
|
}
|
}
|
|
@Override
|
public String encode(String inst) {
|
try {
|
if (BooleanUtil.isTrue(alipayConf.getPlatformEncryptFlag())) {
|
byte[] bytes = rsa.encrypt(inst.getBytes(StandardCharsets.UTF_8), KeyType.PrivateKey);
|
return Base64.getEncoder().encodeToString(bytes);
|
}
|
return inst;
|
} catch (Exception e) {
|
throw new RuntimeException("加密失败", e);
|
}
|
}
|
|
@Override
|
public AlipayOrderInfoVO orderQuery(AlipayOrderQueryDTO queryDTO) {
|
AlipayOrderInfo orderInst = alipayOrderInfoMapper.selectByChannelIdAndOrderId(queryDTO);
|
if (orderInst == null) {
|
throw new CommonException("订单查询失败! 订单[" + queryDTO.getOrderId() + "]不存在");
|
}
|
return converter.toView(orderInst);
|
}
|
|
@Override
|
public String toJsonString(Object obj) {
|
if (obj instanceof String) {
|
return ((String) obj);
|
}
|
try {
|
return objectMapper.writeValueAsString(obj);
|
} catch (JsonProcessingException e) {
|
String msg = "ObjectMapper 序列化出错: " + e.getMessage();
|
log.error(msg);
|
throw new CommonException(msg);
|
}
|
}
|
|
@Override
|
public Map<String, String> sign(String content) {
|
String sign = Base64.getEncoder().encodeToString(digest.digest(content.getBytes(StandardCharsets.UTF_8)));
|
Map<String, String> map = new HashMap<>();
|
map.put("sign", sign);
|
map.put("value", encode(content));
|
return map;
|
}
|
|
@Override
|
public void transferAccount(AlipayTransferAccountDTO param) {
|
|
}
|
|
@Override
|
public void refund(AlipayRefundDTO refundDTO) {
|
// 保存退款记录
|
AlipayRefundRecord record = converter.toEntity(refundDTO);
|
record.setRefundReqTime(new Date());
|
alipayRefundRecordMapper.insertSelective(record);
|
}
|
|
@Override
|
public IPage<AlipayRefundRecord> refundList(AlipayRefundQueryDTO queryDTO) {
|
Page<?> page = new Page<>(queryDTO.getPageNo(), queryDTO.getPageSize());
|
return alipayRefundRecordMapper.selectPage(page, queryDTO);
|
}
|
|
@Override
|
public void refundFinish(AlipayRefundFinishDTO finishDTO) {
|
AlipayRefundRecord condition = new AlipayRefundRecord();
|
condition.setId(finishDTO.getRefundId());
|
condition.setRefundStatus(finishDTO.getRefundStatus());
|
condition.setDealUserId(finishDTO.getDealUserId());
|
condition.setDealTime(finishDTO.getDealFinishTime());
|
condition.setDealDesc(finishDTO.getDealDesc());
|
alipayRefundRecordMapper.updateByPrimaryKeySelective(condition);
|
}
|
|
@Override
|
public BigDecimal refundAmountCalculate(UserDetail user) {
|
Date now = new Date();
|
List<Integer> prices = new ArrayList<>();
|
|
// 会员服务
|
if (userMapper.selectVipDateInTimeCount(user.getId(), now) > 0) {
|
prices.add(vipCardOrderMapper.findLatestEndOrderPriceByUserIdAndVipTypes(user.getId(), Collections.singletonList(0)));
|
}
|
// 审批加速包
|
if (userMapper.selectQueueVipCount(user.getId()) > 0) {
|
prices.add(vipCardOrderMapper.findLatestEndOrderPriceByUserIdAndVipTypes(user.getId(), Collections.singletonList(1)));
|
}
|
// 贷超会员
|
if (userMapper.selectLoanVipDateInTimeCount(user.getId(), now) > 0) {
|
prices.add(vipCardOrderMapper.findLatestEndOrderPriceByUserIdAndVipTypes(user.getId(), Collections.singletonList(2)));
|
}
|
BigDecimal unitPrice = new BigDecimal(prices.stream().filter(Objects::nonNull).reduce(0, (Integer::sum)));
|
return unitPrice.divide(BigDecimal.valueOf(100L), 2, RoundingMode.DOWN);
|
}
|
|
/**
|
* 满额提醒
|
*/
|
private void alipayExcessRemind() {
|
try {
|
LocalDate today = LocalDate.now();
|
LambdaQueryWrapper<AlipayExcessTextmsgSendRecord> query = Wrappers.<AlipayExcessTextmsgSendRecord>lambdaQuery()
|
.eq(AlipayExcessTextmsgSendRecord::getSendDate, today)
|
.eq(AlipayExcessTextmsgSendRecord::getSendType, 1);
|
Integer count = alipayExcessTextmsgSendRecordMapper.selectCount(query);
|
if (count == 0) {
|
log.info("alipay->今日未发送满额提醒");
|
try {
|
if (!alipayExcessRemindLock.tryLock(10L, TimeUnit.SECONDS)) {
|
throw new CommonException("支付宝限额提醒 - 获取锁超时");
|
}
|
count = alipayExcessTextmsgSendRecordMapper.selectCount(query);
|
if (count == 0) {
|
List<String> phones = alipayExcessTextmsgReceiverMapper.selectList(
|
Wrappers.<AlipayExcessTextmsgReceiver>lambdaQuery().eq(AlipayExcessTextmsgReceiver::getStatus, 1))
|
.stream()
|
.map(AlipayExcessTextmsgReceiver::getPhone)
|
.collect(Collectors.toList());
|
String content = "【三快分期】系统已达到支付限额，无法继续接受订单，请立即切换支付渠道";
|
phones.forEach(phone -> {
|
AlipayExcessTextmsgSendRecord record = new AlipayExcessTextmsgSendRecord();
|
record.setReceiverPhone(phone);
|
record.setTextContent(content);
|
record.setSendDate(today);
|
record.setSendDatetime(LocalDateTime.now());
|
record.setSendType(1);
|
alipayExcessTextmsgSendRecordMapper.insert(record);
|
messageSendUtil.sendMessage(phone, content);
|
log.info("alipay->号码{}已发送短信", phone);
|
});
|
}
|
} catch (InterruptedException e) {
|
throw new CommonException("支付宝限额提醒 - 获取锁中断", e);
|
} finally {
|
alipayExcessRemindLock.unlock();
|
}
|
}
|
} catch (RuntimeException e) {
|
log.info("alipay->满额提醒异常：{}:{}", e.getClass(), e.getMessage());
|
throw e;
|
}
|
}
|
|
/**
|
* 满额预警
|
*/
|
private void alipayExcessPrevention() {
|
String today = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
|
BigDecimal todayTotal = alipayAccountUsageMapper.selectSumAmountInDay(today);
|
BigDecimal total = alipayAccountMapper.selectTotalAmount();
|
|
BigDecimal divide = todayTotal.divide(total, 3, RoundingMode.HALF_UP);
|
if (divide.doubleValue() < 0.9) {
|
// 未达到预警阈值
|
msgSendFlag.remove("满额预警");
|
return;
|
}
|
|
LocalDate todayDate = LocalDate.now();
|
if (todayDate.equals(msgSendFlag.get("满额预警"))) {
|
return;
|
}
|
msgSendFlag.put("满额预警", todayDate);
|
|
LambdaQueryWrapper<AlipayExcessTextmsgSendRecord> query = Wrappers.<AlipayExcessTextmsgSendRecord>lambdaQuery()
|
.eq(AlipayExcessTextmsgSendRecord::getSendDate, todayDate)
|
.eq(AlipayExcessTextmsgSendRecord::getSendType, 2);
|
Integer count = alipayExcessTextmsgSendRecordMapper.selectCount(query);
|
if (count == 0) {
|
try {
|
if (!alipayExcessPreventionLock.tryLock(10L, TimeUnit.SECONDS)) {
|
throw new CommonException("支付宝限额提醒 - 获取锁超时");
|
}
|
count = alipayExcessTextmsgSendRecordMapper.selectCount(query);
|
if (count == 0) {
|
BigDecimal rest = total.subtract(todayTotal);
|
DecimalFormat decimalFormat = new DecimalFormat();
|
decimalFormat.applyPattern("0.00");
|
String content = String.format("【三快分期】系统支付限额即将达到上限，请注意切换支付渠道，已用%s，剩余%s",
|
decimalFormat.format(todayTotal.doubleValue()),
|
decimalFormat.format(rest.doubleValue()));
|
|
List<String> phones = alipayExcessTextmsgReceiverMapper.selectList(
|
Wrappers.<AlipayExcessTextmsgReceiver>lambdaQuery()
|
.eq(AlipayExcessTextmsgReceiver::getStatus, 1))
|
.stream()
|
.map(AlipayExcessTextmsgReceiver::getPhone)
|
.collect(Collectors.toList());
|
phones.forEach(phone -> {
|
AlipayExcessTextmsgSendRecord record = new AlipayExcessTextmsgSendRecord();
|
record.setReceiverPhone(phone);
|
record.setTextContent(content);
|
record.setSendDate(todayDate);
|
record.setSendDatetime(LocalDateTime.now());
|
record.setSendType(2);
|
alipayExcessTextmsgSendRecordMapper.insert(record);
|
});
|
// 避免网络原因造成占用锁过长时间
|
exec.execute(() -> phones.forEach(e -> messageSendUtil.sendMessage(e, content)));
|
}
|
} catch (InterruptedException e) {
|
throw new CommonException("支付宝限额提醒 - 获取锁中断", e);
|
} finally {
|
alipayExcessPreventionLock.unlock();
|
}
|
}
|
}
|
|
@Override
|
public <T> T decodeByPublicKey(String encodedString, Class<T> type) {
|
try {
|
if (BooleanUtil.isTrue(alipayConf.getPlatformEncryptFlag())) {
|
byte[] content = rsa.decrypt(Base64.getDecoder().decode(encodedString), KeyType.PublicKey);
|
return objectMapper.readValue(new String(content), type);
|
}
|
return objectMapper.readValue(encodedString, type);
|
} catch (Exception e) {
|
throw new CommonException("解密失败", e);
|
}
|
}
|
}
|
