package cc.mrbird.febs.pay.controller;
|
|
import cc.mrbird.febs.common.entity.FebsResponse;
|
import cc.mrbird.febs.common.enumerates.*;
|
import cc.mrbird.febs.common.properties.XcxProperties;
|
import cc.mrbird.febs.common.utils.RedisUtils;
|
import cc.mrbird.febs.common.utils.SpringContextHolder;
|
import cc.mrbird.febs.mall.dto.RechargeWalletMessageSendDto;
|
import cc.mrbird.febs.mall.entity.*;
|
import cc.mrbird.febs.mall.mapper.*;
|
import cc.mrbird.febs.mall.service.IApiMallMemberService;
|
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
|
import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
|
import cc.mrbird.febs.pay.model.NotifyData;
|
import cc.mrbird.febs.pay.service.IXcxPayService;
|
import cc.mrbird.febs.pay.service.WxFaPiaoService;
|
import cc.mrbird.febs.pay.util.Signature;
|
import cc.mrbird.febs.pay.util.Util;
|
import cc.mrbird.febs.pay.util.WechatConfigure;
|
import cc.mrbird.febs.rabbit.producter.AgentProducer;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import com.wechat.pay.contrib.apache.httpclient.notification.NotificationRequest;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.annotation.Resource;
|
import javax.servlet.ServletOutputStream;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.nio.charset.StandardCharsets;
|
import java.security.InvalidKeyException;
|
import java.security.NoSuchAlgorithmException;
|
import java.security.SignatureException;
|
import java.text.ParseException;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Slf4j
|
@RestController
|
@RequestMapping(value = "/api/xcxPay")
|
@RequiredArgsConstructor
|
public class XcxPayController {
|
|
private final HappyActivityOrderMapper happyActivityOrderMapper;
|
private final MallOrderInfoMapper mallOrderInfoMapper;
|
private final MallMoneyFlowMapper mallMoneyFlowMapper;
|
private final MallMemberWalletMapper mallMemberWalletMapper;
|
private final MallMemberMapper mallMemberMapper;
|
private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
|
private final IMallMoneyFlowService mallMoneyFlowService;
|
private final RedisUtils redisUtils;
|
private final IApiMallMemberWalletService memberWalletService;
|
private final IApiMallMemberService mallMemberService;
|
private final MallAgentRecordMapper mallAgentRecordMapper;
|
private final AgentProducer agentProducer;
|
private final IXcxPayService iXcxPayService;
|
private final WxFaPiaoService wxFaPiaoService;
|
private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class);
|
/**
|
* 微信充值回调接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RequestMapping(value = "/rechargeCallBack")
|
public void rechargeCallBack(HttpServletResponse response, HttpServletRequest request) throws IOException {
|
log.info("微信充值回调start....");
|
|
// 获取输入参数
|
String inputLine;
|
StringBuffer notityXml = new StringBuffer();
|
String resXml = "";
|
|
// String attrStr = "{'rechargeNo':"+rechargeNo+",'memberId':"+mallMember.getId()+"}";
|
String attrStr = "";
|
|
FebsResponse threadResult = new FebsResponse();
|
try {
|
while ((inputLine = request.getReader().readLine()) != null) {
|
notityXml.append(inputLine);
|
}
|
request.getReader().close();
|
log.info("notityXml ---- :{} ", notityXml);
|
|
|
// XMl转对象
|
Object bb = Util.getObjectFromXML(notityXml.toString(), NotifyData.class);
|
NotifyData data = new NotifyData();
|
BeanUtils.copyProperties(bb,data);
|
log.info("----return_code = {}", data.getReturn_code());
|
// 返回状态码 SUCCESS/FAIL
|
if (WechatConfigure.CODE_SUCCESS.equals(data.getReturn_code())) {
|
attrStr = data.getAttach();
|
JSONObject jsonObject = JSONUtil.parseObj(attrStr);
|
String rechargeNo = (String) jsonObject.get("rechargeNo");
|
Integer type = (Integer) jsonObject.get("type");
|
Long memberId = Long.parseLong(jsonObject.get("memberId").toString());
|
Long agentApplyId = Long.parseLong(jsonObject.get("agentApplyId").toString());
|
// 检验订单状态
|
MallMoneyFlow mallMoneyFlow = mallMoneyFlowMapper.selectOneByOrderNoAndMemberId(rechargeNo,memberId);
|
// 校验签名
|
// String paySecret = WechatConfigure.WECHARPAY_SECRET;
|
String paySecret = xcxProperties.getWecharpaySecret();
|
if (Signature.checkIsSignValidFromResponseString(notityXml.toString(),paySecret)) {
|
// 校验业务结果
|
if (WechatConfigure.CODE_SUCCESS.equals(data.getResult_code())) {
|
// 返回SUCCESS报文
|
resXml = WechatConfigure.RESULT_XML_SUCCESS;
|
// 支付费用
|
Double total_fee = Double.parseDouble(data.getTotal_fee());
|
// 商户订单号
|
String payNum = data.getOut_trade_no();
|
|
log.info("支付回调关键信息---total_fee:{},payNum:{},rechargeNo:{}", total_fee, payNum, rechargeNo);
|
// 订单ID
|
BigDecimal payMoney = new BigDecimal(total_fee).divide(new BigDecimal(100), 2,
|
RoundingMode.HALF_UP);
|
|
if (ObjectUtil.isNotEmpty(mallMoneyFlow)) {
|
log.debug("检查支付金额payMoney={},mallMoneyFlow.getPayMoney()={}", payMoney, mallMoneyFlow.getAmount());
|
//合伙人申请的充值，要更新会员状态为FIRST_LEVEL
|
if(2 == type){
|
log.info("微信充值回调" + agentApplyId);
|
MallAgentRecord mallAgentRecord = mallAgentRecordMapper.selectById(agentApplyId);
|
mallMemberService.updateMemberAgent(agentApplyId,mallAgentRecord.getAgentLevel());
|
}
|
memberWalletService.addBalance(payMoney,memberId);
|
mallMoneyFlow.setStatus(2);
|
mallMoneyFlowMapper.updateById(mallMoneyFlow);
|
|
/**
|
* 充值赠送金额
|
*/
|
DataDictionaryCustom giveStateDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
|
DataDictionaryEnum.GIVE_STATE.getType(),
|
DataDictionaryEnum.GIVE_STATE.getCode());
|
|
DataDictionaryCustom giveAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
|
DataDictionaryEnum.GIVE_AMOUNT.getType(),
|
DataDictionaryEnum.GIVE_AMOUNT.getCode());
|
|
DataDictionaryCustom chargeAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
|
DataDictionaryEnum.CHARGE_AMOUNT.getType(),
|
DataDictionaryEnum.CHARGE_AMOUNT.getCode());
|
/**
|
* 普通充值
|
* 开启了充值赠送
|
* 系统设置的赠送金额和充值金额不为空
|
* 充值金额大于等于系统设置的充值金额
|
*/
|
if(1 == type
|
&& ObjectUtil.isNotEmpty(giveStateDic)
|
&& "1".equals(giveStateDic.getValue())
|
&& ObjectUtil.isNotEmpty(giveAmountDic)
|
&& ObjectUtil.isNotEmpty(chargeAmountDic)){
|
BigDecimal giveAmount = ObjectUtil.isEmpty(giveAmountDic.getValue()) ?
|
BigDecimal.ZERO :
|
new BigDecimal(giveAmountDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN);
|
BigDecimal chargeAmount = ObjectUtil.isEmpty(chargeAmountDic.getValue()) ?
|
BigDecimal.ZERO :
|
new BigDecimal(chargeAmountDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN);
|
if(payMoney.compareTo(chargeAmount) >= 0){
|
mallMoneyFlowService.addMoneyFlow(
|
memberId,
|
giveAmount,
|
MoneyFlowTypeEnum.RECHARGE_SEND.getValue(),
|
rechargeNo+"ZS",
|
FlowTypeEnum.BALANCE.getValue(),
|
"充值赠送金额",
|
2);
|
|
memberWalletService.addBalance(giveAmount,memberId);
|
}
|
}
|
|
RechargeWalletMessageSendDto rechargeWalletMessageSendDto = new RechargeWalletMessageSendDto();
|
rechargeWalletMessageSendDto.setRechargeNo(rechargeNo);
|
rechargeWalletMessageSendDto.setRechargeAmount(payMoney.toString());
|
|
MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
|
rechargeWalletMessageSendDto.setBalance(mallMemberWallet.getBalance().toString());
|
rechargeWalletMessageSendDto.setCreateTime(DateUtil.now());
|
rechargeWalletMessageSendDto.setOpenId(mallMemberMapper.selectById(memberId).getOpenId());
|
DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WX_TEMPLATE_ID_TWO.getType(), DataDictionaryEnum.WX_TEMPLATE_ID_TWO.getCode());
|
rechargeWalletMessageSendDto.setTemplateId(dataDictionaryCustom.getValue());
|
iXcxPayService.rechargeWalletMessageSend(rechargeWalletMessageSendDto);
|
threadResult.success().message("充值成功");
|
} else {
|
log.info("充值失败", attrStr);
|
}
|
} else {
|
log.info("微信标识业务是失败");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:001）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "微信标识业务是失败");
|
}
|
} else {
|
log.info("无效签名");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:002）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "微信标识业务是失败");
|
}
|
} else {
|
log.info("通信标识失败");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:003）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "通信标识失败");
|
}
|
} catch (Exception e) {
|
log.error("支付回调签名错误", e);
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:004）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "支付回调签名错误");
|
} finally {
|
// 通知线程消息
|
// PayThreadPool.notifyThread(Integer.valueOf(orderId), threadResult);
|
sendResultBack(response, resXml);
|
}
|
return;
|
|
}
|
|
// public static void main(String[] args) {
|
// String attach="{'rechargeNo':CZ_2022083117160259880,'memberId':47}";
|
// JSONObject jsonObject = JSONUtil.parseObj(attach);
|
// String rechargeNo = (String) jsonObject.get("rechargeNo");
|
// Long memberId = Long.parseLong(jsonObject.get("memberId").toString());
|
// System.out.println(memberId);
|
// System.out.println(rechargeNo);
|
// }
|
/**
|
* 微信电子发票回调接口
|
* POST方式回调
|
* @return
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RequestMapping(value = "/fapiaoCallBack")
|
public Map<String, Object> fapiaoCallBack(HttpServletRequest request, @RequestBody Map<String, Object> requestBody) {
|
return wxFaPiaoService.fapiaoCallBack(request,requestBody);
|
|
}
|
|
/**
|
* 微信支付回调接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RequestMapping(value = "/wxpayCallback")
|
public void payCallBack(HttpServletResponse response, HttpServletRequest request) throws IOException {
|
log.info("微信支付回调start....");
|
|
// 获取输入参数
|
String inputLine;
|
StringBuffer notityXml = new StringBuffer();
|
String resXml = "";
|
String orderId = "";
|
|
FebsResponse threadResult = new FebsResponse();
|
try {
|
while ((inputLine = request.getReader().readLine()) != null) {
|
notityXml.append(inputLine);
|
}
|
request.getReader().close();
|
log.info("notityXml ---- :{} ", notityXml);
|
|
|
// XMl转对象
|
Object bb = Util.getObjectFromXML(notityXml.toString(), NotifyData.class);
|
NotifyData data = new NotifyData();
|
BeanUtils.copyProperties(bb,data);
|
log.info("----return_code = {}", data.getReturn_code());
|
|
// 返回状态码 SUCCESS/FAIL
|
if (WechatConfigure.CODE_SUCCESS.equals(data.getReturn_code())) {
|
|
orderId = data.getAttach();
|
// 检验订单状态
|
MallOrderInfo order = mallOrderInfoMapper.selectById(Long.valueOf(orderId));
|
|
// 校验签名
|
// String paySecret = WechatConfigure.WECHARPAY_SECRET;
|
String paySecret = xcxProperties.getWecharpaySecret();
|
if (Signature.checkIsSignValidFromResponseString(notityXml.toString(),paySecret)) {
|
// 校验业务结果
|
if (WechatConfigure.CODE_SUCCESS.equals(data.getResult_code())) {
|
// 返回SUCCESS报文
|
resXml = WechatConfigure.RESULT_XML_SUCCESS;
|
// 支付费用
|
Double total_fee = Double.parseDouble(data.getTotal_fee());
|
//微信支付订单号
|
String transaction_id = data.getTransaction_id();
|
// 商户订单号
|
String payNum = data.getOut_trade_no();
|
|
log.info("支付回调关键信息---total_fee:{},payNum:{},orderId:{}", total_fee, payNum, orderId);
|
// 订单ID
|
BigDecimal payMoney = new BigDecimal(total_fee).divide(new BigDecimal(100), 2,
|
RoundingMode.HALF_UP);
|
|
|
if (order != null && OrderStatusEnum.WAIT_PAY.getValue() == order.getStatus()) {
|
log.debug("检查支付金额payMoney={},order.getPayMoney()={}", payMoney, order.getAmount());
|
order.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
|
order.setPayResult("1");
|
order.setPayTime(new Date());
|
order.setDeliveryState(OrderDeliveryStateEnum.DELIVERY_WAIT.getValue());
|
order.setPayOrderNo(transaction_id);
|
mallOrderInfoMapper.updateById(order);
|
|
agentProducer.sendOrderCoupon(order.getId());
|
// agentProducer.sendGetScoreMsg(order.getId());
|
|
mallMoneyFlowService.addMoneyFlow(
|
order.getMemberId(),
|
order.getAmount().negate(),
|
MoneyFlowTypeEnum.WECHAT_PAY.getValue(),
|
order.getOrderNo(),
|
FlowTypeEnum.WECHAT.getValue(),
|
"微信支付",
|
2);
|
threadResult.success().message("支付成功");
|
} else {
|
log.info("订单状态不为待付款，order status=", order.getStatus());
|
}
|
} else {
|
log.info("微信标识业务是失败");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:001）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "微信标识业务是失败");
|
}
|
} else {
|
log.info("无效签名");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:002）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "微信标识业务是失败");
|
}
|
} else {
|
log.info("通信标识失败");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:003）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "通信标识失败");
|
}
|
} catch (Exception e) {
|
log.error("支付回调签名错误", e);
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:004）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "支付回调签名错误");
|
} finally {
|
// 通知线程消息
|
// PayThreadPool.notifyThread(Integer.valueOf(orderId), threadResult);
|
sendResultBack(response, resXml);
|
}
|
return;
|
|
}
|
|
/**
|
* 活动门票支付回调接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RequestMapping(value = "/activityOrderCallback")
|
public void activityOrderCallback(HttpServletResponse response, HttpServletRequest request) throws IOException {
|
log.info("活动门票支付回调start....");
|
|
// 获取输入参数
|
String inputLine;
|
StringBuffer notityXml = new StringBuffer();
|
String resXml = "";
|
String orderId = "";
|
|
FebsResponse threadResult = new FebsResponse();
|
try {
|
while ((inputLine = request.getReader().readLine()) != null) {
|
notityXml.append(inputLine);
|
}
|
request.getReader().close();
|
log.info("notityXml ---- :{} ", notityXml);
|
|
|
// XMl转对象
|
Object bb = Util.getObjectFromXML(notityXml.toString(), NotifyData.class);
|
NotifyData data = new NotifyData();
|
BeanUtils.copyProperties(bb,data);
|
log.info("----return_code = {}", data.getReturn_code());
|
|
// 返回状态码 SUCCESS/FAIL
|
if (WechatConfigure.CODE_SUCCESS.equals(data.getReturn_code())) {
|
|
orderId = data.getAttach();
|
// 检验订单状态
|
HappyActivityOrder happyActivityOrder = happyActivityOrderMapper.selectById(Long.valueOf(orderId));
|
|
// 校验签名
|
String paySecret = xcxProperties.getWecharpaySecret();
|
if (Signature.checkIsSignValidFromResponseString(notityXml.toString(),paySecret)) {
|
// 校验业务结果
|
if (WechatConfigure.CODE_SUCCESS.equals(data.getResult_code())) {
|
// 返回SUCCESS报文
|
resXml = WechatConfigure.RESULT_XML_SUCCESS;
|
// 支付费用
|
Double total_fee = Double.parseDouble(data.getTotal_fee());
|
//微信支付订单号
|
String transaction_id = data.getTransaction_id();
|
// 商户订单号
|
String payNum = data.getOut_trade_no();
|
|
log.info("支付回调关键信息---total_fee:{},payNum:{},orderId:{}", total_fee, payNum, orderId);
|
// 订单ID
|
BigDecimal payMoney = new BigDecimal(total_fee).divide(new BigDecimal(100), 2,
|
RoundingMode.HALF_UP);
|
|
|
if (happyActivityOrder != null && StateUpDownEnum.PAY_STATE_NOT_PAY.getCode() == happyActivityOrder.getPayState()) {
|
log.debug("检查支付金额payMoney={},order.getPayMoney()={}", payMoney, happyActivityOrder.getAmount());
|
happyActivityOrder.setState(StateUpDownEnum.ORDER_STATE_WAIT_USE.getCode());
|
happyActivityOrder.setPayState(StateUpDownEnum.PAY_STATE_PAY_SUCCESS.getCode());
|
happyActivityOrder.setUpdatedTime(new Date());
|
happyActivityOrder.setPayOrderNo(payNum);
|
happyActivityOrder.setWxOrderNo(transaction_id);
|
happyActivityOrderMapper.updateById(happyActivityOrder);
|
|
mallMoneyFlowService.addMoneyFlow(
|
happyActivityOrder.getMemberId(),
|
happyActivityOrder.getAmount().negate(),
|
MoneyFlowTypeEnum.WECHAT_PAY.getValue(),
|
happyActivityOrder.getOrderNo(),
|
FlowTypeEnum.WECHAT.getValue(),
|
"微信支付",
|
2);
|
threadResult.success().message("支付成功");
|
} else {
|
log.info("订单状态不为待付款，happyActivityOrder state=", happyActivityOrder.getPayState());
|
}
|
} else {
|
log.info("微信标识业务是失败");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:001）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "微信标识业务是失败");
|
}
|
} else {
|
log.info("无效签名");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:002）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "微信标识业务是失败");
|
}
|
} else {
|
log.info("通信标识失败");
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:003）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "通信标识失败");
|
}
|
} catch (Exception e) {
|
log.error("支付回调签名错误", e);
|
threadResult.fail().message("查询支付信息失败，请联系客服或者刷新支付信息（错误码:004）");
|
// resXml = AppConstance.RESULT_XML_FAIL.replace(ERRORMSG, "支付回调签名错误");
|
} finally {
|
// 通知线程消息
|
// PayThreadPool.notifyThread(Integer.valueOf(orderId), threadResult);
|
sendResultBack(response, resXml);
|
}
|
return;
|
|
}
|
|
private void sendResultBack(HttpServletResponse response, String resXml) throws IOException {
|
log.info("返回微信数据={}", resXml);
|
ServletOutputStream out = response.getOutputStream();
|
out.write(resXml.getBytes());
|
out.flush();
|
out.close();
|
}
|
|
}
|
