From 03805f3cfd53cbb2f94e4b67bba4728ca22dfc80 Mon Sep 17 00:00:00 2001 From: jiaosong <jiaosong6760@dingtalk.com> Date: 星期五, 03 十一月 2023 15:36:21 +0800 Subject: [PATCH] # log日志 --- server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java | 82 ++++++++++++++++++++++++++++------------ 1 files changed, 57 insertions(+), 25 deletions(-) diff --git a/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java b/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java index 4c42c9b..72ee3f6 100644 --- a/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java +++ b/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java @@ -5,24 +5,24 @@ import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.utils.ID; -import com.doumee.dao.business.ActionLogMapper; +import com.doumee.dao.business.RefundMapper; +import com.doumee.dao.business.TransactionsMapper; +import com.doumee.dao.business.model.Refund; +import com.doumee.dao.business.model.Transactions; +import com.doumee.dao.business.web.request.RefundDTO; +import com.doumee.service.business.RefundService; import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest; -import com.github.binarywang.wxpay.bean.request.WxPayDownloadBillRequest; import com.github.binarywang.wxpay.bean.request.WxPayRefundRequest; -import com.github.binarywang.wxpay.bean.result.WxPayBillResult; import com.github.binarywang.wxpay.bean.result.WxPayRefundResult; import com.github.binarywang.wxpay.exception.WxPayException; import lombok.extern.slf4j.Slf4j; +import org.checkerframework.checker.units.qual.A; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; -import org.yaml.snakeyaml.scanner.Constant; import java.math.BigDecimal; -import java.security.KeyFactory; -import java.security.Signature; -import java.security.spec.PKCS8EncodedKeySpec; -import java.util.Base64; +import java.util.Date; /** * 寰俊灏忕▼搴�-鍏叡鏂规硶 @@ -31,32 +31,65 @@ @Slf4j public class WxMiniUtilService { + @Autowired + private RefundMapper refundMapper; @Autowired - private SystemDictDataBiz systemDictDataBiz; + private TransactionsMapper transactionsMapper; - /** - * 璁㈠崟寰俊閫�娆� - * orderNo:鍟嗘埛璁㈠崟鍙� - * totalPrice锛氳鍗曟�婚噾棰� - * refundPrice锛涢��娆鹃噾棰� - */ - @Transactional(rollbackFor = Exception.class) - public static String wxRefund(String orderNo, BigDecimal totalPrice, BigDecimal refundPrice) { + + @Transactional(rollbackFor = {BusinessException.class,Exception.class}) + public Refund wxRefund(RefundDTO refundDTO) { try { // 鍙戦�侀��娆捐姹� String refNum = ID.nextGUID(); WxPayRefundRequest request = new WxPayRefundRequest(); - request.setOutTradeNo(orderNo); + request.setOutTradeNo(refundDTO.getOrderId()); request.setOutRefundNo(refNum); - // request.setTotalFee(2); - // request.setRefundFee(1); - request.setTotalFee(BaseWxPayRequest.yuanToFen(totalPrice.toString())); - request.setRefundFee(BaseWxPayRequest.yuanToFen(refundPrice.toString())); + request.setTotalFee(refundDTO.getTotalAmount().intValue()); + request.setRefundFee(refundDTO.getRefundAmount().intValue()); + System.out.println("瀹為檯鎬婚噾棰�" + refundDTO.getTotalAmount()); + System.out.println("瀹為檯閫�娆鹃噾棰�" + refundDTO.getRefundAmount()); +// request.setTotalFee(1); +// request.setRefundFee(1); WxPayRefundResult response = WxMiniConfig.wxPayService.refund(request); if ("SUCCESS".equals(response.getReturnCode()) && "SUCCESS".equals(response.getResultCode())) { - return refNum; - } else { + //瀛樺偍閫�娆捐褰� 涓� 娴佹按璁板綍 + Refund refund = new Refund(); + refund.setId(Constants.getUUID()); + refund.setCreateDate(new Date()); + refund.setMemberId(refundDTO.getMemberId()); + refund.setMoney(refundDTO.getRefundAmount()); + refund.setOnlineOrderid(refNum); + refund.setPayWay(Constants.ZERO); + refund.setStatus(Constants.TWO); + refund.setDoneDate(new Date()); + refund.setCreator(refundDTO.getCreator()); + refund.setType(refundDTO.getType()); + refund.setObjId(refundDTO.getOrderId()); + refund.setReason(refundDTO.getReason()); + refund.setCanBalance(refundDTO.getCanBalance()); + refundMapper.insert(refund); + //瀛樺偍浜ゆ槗娴佹按琛� + Transactions transactions = new Transactions(); + transactions.setId(Constants.getUUID()); + transactions.setMemberId(refundDTO.getMemberId()); + transactions.setCreateDate(new Date()); + transactions.setIsdeleted(Constants.ZERO); + transactions.setOrderId(refundDTO.getOrderId()); + transactions.setMoney(refundDTO.getRefundAmount()); + transactions.setType(refundDTO.getType()==Constants.TRANSACTIONS_TYPE.REFUND.getKey()?Constants.TRANSACTIONS_TYPE.PLATFORMREFUND.getKey():Constants.REFUND_TYPE.BACK.getKey()); + transactions.setPreOrderid(refundDTO.getOrderId()); + transactions.setOnlineOrderid(refNum); + transactions.setDoneDate(new Date()); + transactions.setTitle(Constants.TRANSACTIONS_TYPE.get(transactions.getType()).getName()); + transactions.setContent(Constants.TRANSACTIONS_TYPE.get(transactions.getType()).getInfo()); + transactions.setBalance(BigDecimal.ZERO); + transactions.setObjId(refund.getId()); + transactions.setObjType(Constants.ONE); + transactionsMapper.insert(transactions); + return refund; + } else{ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),response.getErrCode() + response.getErrCodeDes()); } } catch (WxPayException e) { @@ -64,6 +97,5 @@ } throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閫�娆惧彂鐢熷紓甯歌鑱旂郴绠$悊鍛�"); } - } -- Gitblit v1.9.3