//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.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.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")
|
//public class XcxPayController {
|
//
|
// @Autowired
|
// MallOrderInfoMapper mallOrderInfoMapper;
|
// @Autowired
|
// MallMoneyFlowMapper mallMoneyFlowMapper;
|
// @Autowired
|
// MallMemberWalletMapper mallMemberWalletMapper;
|
// @Autowired
|
// MallMemberMapper mallMemberMapper;
|
// @Autowired
|
// DataDictionaryCustomMapper dataDictionaryCustomMapper;
|
// @Autowired
|
// IMallMoneyFlowService mallMoneyFlowService;
|
// @Autowired
|
// RedisUtils redisUtils;
|
// @Autowired
|
// private IApiMallMemberWalletService memberWalletService;
|
// @Autowired
|
// private IApiMallMemberService mallMemberService;
|
// @Autowired
|
// private MallAgentRecordMapper mallAgentRecordMapper;
|
// @Autowired
|
// private AgentProducer agentProducer;
|
//
|
// @Autowired
|
// private IXcxPayService iXcxPayService;
|
//
|
// @Autowired
|
// private 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;
|
//
|
// }
|
//
|
// private void sendResultBack(HttpServletResponse response, String resXml) throws IOException {
|
// log.info("返回微信数据={}", resXml);
|
// ServletOutputStream out = response.getOutputStream();
|
// out.write(resXml.getBytes());
|
// out.flush();
|
// out.close();
|
// }
|
//
|
//}
|
