修复bug

yn-bftl-byx / thirdparty

Browse code 修复bug master
1 parent 4cc9a8f commit 260b813d400e19e9ad89b4bd47540475baeac9e8 steven authored on 23 Sep

Patch

Showing 3 changed files

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/controller/ChinaumsCallBackController.java
package com.yn.bftl.thirdparty.modules.chinaums.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.yn.bftl.thirdparty.modules.chinaums.dto.MchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxMchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.service.ChinaumsCallBackService; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsCallBackVO; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.data.redis.connection.util.ByteArrayWrapper; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import javax.servlet.ServletInputStream; import javax.servlet.http.HttpServletRequest; import javax.validation.Valid; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.nio.charset.StandardCharsets; /** * @Author：Vance * @Description：回调controller * @Date：2022/12/8 15:05 / @Slf4j @Api(value = "ChinaumsCallBackController", tags = "公共端-银联回调") @RestController @RequestMapping("/chinaums/call_back") @Validated public class ChinaumsCallBackController { @Resource private ChinaumsCallBackService chinaumsCallBackService; @ApiOperation(value = "回调") @RequestMapping(value = "/byx/result", method = RequestMethod.POST) public ChinaumsCallBackVO callbackForByx(HttpServletRequest request) { log.info("comming"); String requestBody = ""; try { // 获取ServletInputStream ServletInputStream inputStream = request.getInputStream(); // 创建一个BufferedReader来读取输入流，这里使用InputStreamReader将字节流转换为字符流 // 假设请求体是UTF-8编码的，你可以根据实际情况调整编码 BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8)); StringBuilder stringBuilder = new StringBuilder(); String line; // 逐行读取输入流直到结束 while ((line = reader.readLine()) != null) { stringBuilder.append(line); } reader.close(); inputStream.close(); // 此时stringBuilder中包含了请求体的全部内容 requestBody = stringBuilder.toString(); } catch (IOException e) { log.error(e.getMessage()); throw new RuntimeException(e); } ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = JSON.parseObject(requestBody, ByxMchApplicationsNoticeDTO.class); // ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = byteToObject(data); validateParams(byxMchApplicationsNoticeDTO); byxMchApplicationsNoticeDTO.setMsgBodyObject(JSON.parseObject(byxMchApplicationsNoticeDTO.getMsgBody(), JSONObject.class)); // log.info("回调通知，数据：" + JSON.toJSONString(byxMchApplicationsNoticeDTO)); return chinaumsCallBackService.callbackForByx(byxMchApplicationsNoticeDTO); } private static void validateParams(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) { if (byxMchApplicationsNoticeDTO == null) { log.error("byxMchApplicationsNoticeDTO is null."); throw new RuntimeException("参数不正确"); } if (StringUtils.isEmpty(byxMchApplicationsNoticeDTO.getMsgType())) { log.error("getMsgType is null."); throw new RuntimeException("参数不正确"); } if (StringUtils.isEmpty(byxMchApplicationsNoticeDTO.getMsgBody())) { log.error("getMsgBody is null."); throw new RuntimeException("参数不正确"); } } private static ByxMchApplicationsNoticeDTO byteToObject(byte[] data) { if (data == null) { log.error("回调参数异常"); throw new RuntimeException("回调参数异常"); } ObjectMapper mapper = new ObjectMapper(); ByteArrayWrapper wrapper = new ByteArrayWrapper(data); String json = ""; try { json = mapper.writeValueAsString(wrapper); } catch (JsonProcessingException e) { log.error(e.getMessage()); throw new RuntimeException(e); } ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = JSON.parseObject(json, ByxMchApplicationsNoticeDTO.class); return byxMchApplicationsNoticeDTO; } @ApiOperation(value = "回调") @RequestMapping(value = "/result", method = RequestMethod.POST) public ChinaumsCallBackVO mchApplicationsResult(@Valid @RequestBody MchApplicationsNoticeDTO mchApplicationsNoticeDTO) { return chinaumsCallBackService.mchApplicationsResult(mchApplicationsNoticeDTO); } } package com.yn.bftl.thirdparty.modules.chinaums.controller; import com.alibaba.fastjson.JSON; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.yn.bftl.thirdparty.modules.chinaums.dto.MchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxMchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.service.ChinaumsCallBackService; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsCallBackVO; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.data.redis.connection.util.ByteArrayWrapper; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import javax.servlet.ServletInputStream; import javax.servlet.http.HttpServletRequest; import javax.validation.Valid; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.nio.charset.StandardCharsets; /* * @Author：Vance * @Description：回调controller * @Date：2022/12/8 15:05 */ @Slf4j @Api(value = "ChinaumsCallBackController", tags = "公共端-银联回调") @RestController @RequestMapping("/chinaums/call_back") @Validated public class ChinaumsCallBackController { @Resource private ChinaumsCallBackService chinaumsCallBackService; @ApiOperation(value = "回调") @RequestMapping(value = "/byx/result", method = RequestMethod.POST) public ChinaumsCallBackVO callbackForByx(HttpServletRequest request) { log.info("comming"); String requestBody = ""; try { // 获取ServletInputStream ServletInputStream inputStream = request.getInputStream(); // 创建一个BufferedReader来读取输入流，这里使用InputStreamReader将字节流转换为字符流 // 假设请求体是UTF-8编码的，你可以根据实际情况调整编码 BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8)); StringBuilder stringBuilder = new StringBuilder(); String line; // 逐行读取输入流直到结束 while ((line = reader.readLine()) != null) { stringBuilder.append(line); } reader.close(); inputStream.close(); // 此时stringBuilder中包含了请求体的全部内容 requestBody = stringBuilder.toString(); } catch (IOException e) { log.error(e.getMessage()); throw new RuntimeException(e); } log.info("=========================转换后的参数json:" + requestBody); log.info("========================结束"); ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = JSON.parseObject(requestBody, ByxMchApplicationsNoticeDTO.class); // ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = byteToObject(data); validateParams(byxMchApplicationsNoticeDTO); log.info("回调通知，数据：" + JSON.toJSONString(byxMchApplicationsNoticeDTO)); return chinaumsCallBackService.callbackForByx(byxMchApplicationsNoticeDTO); } private static void validateParams(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) { if (byxMchApplicationsNoticeDTO == null) { log.error("byxMchApplicationsNoticeDTO is null."); throw new RuntimeException("参数不正确"); } if (StringUtils.isEmpty(byxMchApplicationsNoticeDTO.getMsgType())) { log.error("getMsgType is null."); throw new RuntimeException("参数不正确"); } if (byxMchApplicationsNoticeDTO.getMsgBody() == null) { log.error("getMsgBody is null."); throw new RuntimeException("参数不正确"); } } private static ByxMchApplicationsNoticeDTO byteToObject(byte[] data) { if (data == null) { log.error("回调参数异常"); throw new RuntimeException("回调参数异常"); } ObjectMapper mapper = new ObjectMapper(); ByteArrayWrapper wrapper = new ByteArrayWrapper(data); String json = ""; try { json = mapper.writeValueAsString(wrapper); } catch (JsonProcessingException e) { log.error(e.getMessage()); throw new RuntimeException(e); } ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = JSON.parseObject(json, ByxMchApplicationsNoticeDTO.class); return byxMchApplicationsNoticeDTO; } @ApiOperation(value = "回调") @RequestMapping(value = "/result", method = RequestMethod.POST) public ChinaumsCallBackVO mchApplicationsResult(@Valid @RequestBody MchApplicationsNoticeDTO mchApplicationsNoticeDTO) { return chinaumsCallBackService.mchApplicationsResult(mchApplicationsNoticeDTO); } }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/controller/ChinaumsCallBackController.java

package com.yn.bftl.thirdparty.modules.chinaums.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yn.bftl.thirdparty.modules.chinaums.dto.MchApplicationsNoticeDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxMchApplicationsNoticeDTO;
import com.yn.bftl.thirdparty.modules.chinaums.service.ChinaumsCallBackService;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsCallBackVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.data.redis.connection.util.ByteArrayWrapper;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.validation.Valid;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;

/**
 * @Author：Vance
 * @Description：回调controller
 * @Date：2022/12/8 15:05
 */
@Slf4j
@Api(value = "ChinaumsCallBackController", tags = "公共端-银联回调")
@RestController
@RequestMapping("/chinaums/call_back")
@Validated
public class ChinaumsCallBackController {

@Resource
    private ChinaumsCallBackService chinaumsCallBackService;

@ApiOperation(value = "回调")
    @RequestMapping(value = "/byx/result", method = RequestMethod.POST)
    public ChinaumsCallBackVO callbackForByx(HttpServletRequest request) {
        log.info("comming");
        String requestBody = "";
        try {
            // 获取ServletInputStream
            ServletInputStream inputStream = request.getInputStream();

// 创建一个BufferedReader来读取输入流，这里使用InputStreamReader将字节流转换为字符流
            // 假设请求体是UTF-8编码的，你可以根据实际情况调整编码
            BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8));

StringBuilder stringBuilder = new StringBuilder();
            String line;

// 逐行读取输入流直到结束
            while ((line = reader.readLine()) != null) {
                stringBuilder.append(line);
            }
            reader.close();
            inputStream.close();

// 此时stringBuilder中包含了请求体的全部内容
            requestBody = stringBuilder.toString();

} catch (IOException e) {
            log.error(e.getMessage());
            throw new RuntimeException(e);
        }
        ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = JSON.parseObject(requestBody, ByxMchApplicationsNoticeDTO.class);
//        ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = byteToObject(data);
        validateParams(byxMchApplicationsNoticeDTO);
        byxMchApplicationsNoticeDTO.setMsgBodyObject(JSON.parseObject(byxMchApplicationsNoticeDTO.getMsgBody(), JSONObject.class));
//        log.info("回调通知，数据：" + JSON.toJSONString(byxMchApplicationsNoticeDTO));
        return chinaumsCallBackService.callbackForByx(byxMchApplicationsNoticeDTO);
    }

private static void validateParams(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) {
        if (byxMchApplicationsNoticeDTO == null) {
            log.error("byxMchApplicationsNoticeDTO is null.");
            throw new RuntimeException("参数不正确");
        }
        if (StringUtils.isEmpty(byxMchApplicationsNoticeDTO.getMsgType())) {
            log.error("getMsgType is null.");
            throw new RuntimeException("参数不正确");
        }
        if (StringUtils.isEmpty(byxMchApplicationsNoticeDTO.getMsgBody())) {
            log.error("getMsgBody is null.");
            throw new RuntimeException("参数不正确");
        }
    }

private static ByxMchApplicationsNoticeDTO byteToObject(byte[] data) {
        if (data == null) {
            log.error("回调参数异常");
            throw new RuntimeException("回调参数异常");
        }
        ObjectMapper mapper = new ObjectMapper();
        ByteArrayWrapper wrapper = new ByteArrayWrapper(data);
        String json = "";
        try {
            json = mapper.writeValueAsString(wrapper);
        } catch (JsonProcessingException e) {
            log.error(e.getMessage());
            throw new RuntimeException(e);
        }
        ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = JSON.parseObject(json, ByxMchApplicationsNoticeDTO.class);
        return byxMchApplicationsNoticeDTO;
    }

@ApiOperation(value = "回调")
    @RequestMapping(value = "/result", method = RequestMethod.POST)
    public ChinaumsCallBackVO mchApplicationsResult(@Valid @RequestBody MchApplicationsNoticeDTO mchApplicationsNoticeDTO) {
        return chinaumsCallBackService.mchApplicationsResult(mchApplicationsNoticeDTO);
    }
}

package com.yn.bftl.thirdparty.modules.chinaums.controller;

import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yn.bftl.thirdparty.modules.chinaums.dto.MchApplicationsNoticeDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxMchApplicationsNoticeDTO;
import com.yn.bftl.thirdparty.modules.chinaums.service.ChinaumsCallBackService;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsCallBackVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.data.redis.connection.util.ByteArrayWrapper;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@Resource
    private ChinaumsCallBackService chinaumsCallBackService;

StringBuilder stringBuilder = new StringBuilder();
            String line;

// 此时stringBuilder中包含了请求体的全部内容
            requestBody = stringBuilder.toString();

} catch (IOException e) {
            log.error(e.getMessage());
            throw new RuntimeException(e);
        }
        log.info("=========================转换后的参数json:" + requestBody);
        log.info("========================结束");
        ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = JSON.parseObject(requestBody, ByxMchApplicationsNoticeDTO.class);
//        ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO = byteToObject(data);
        validateParams(byxMchApplicationsNoticeDTO);
        log.info("回调通知，数据：" + JSON.toJSONString(byxMchApplicationsNoticeDTO));
        return chinaumsCallBackService.callbackForByx(byxMchApplicationsNoticeDTO);
    }

private static void validateParams(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) {
        if (byxMchApplicationsNoticeDTO == null) {
            log.error("byxMchApplicationsNoticeDTO is null.");
            throw new RuntimeException("参数不正确");
        }
        if (StringUtils.isEmpty(byxMchApplicationsNoticeDTO.getMsgType())) {
            log.error("getMsgType is null.");
            throw new RuntimeException("参数不正确");
        }
        if (byxMchApplicationsNoticeDTO.getMsgBody() == null) {
            log.error("getMsgBody is null.");
            throw new RuntimeException("参数不正确");
        }
    }

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/dto/byx/ByxMchApplicationsNoticeDTO.java
package com.yn.bftl.thirdparty.modules.chinaums.dto.byx; import com.alibaba.fastjson.JSONObject; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import lombok.EqualsAndHashCode; import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotNull; @Data @EqualsAndHashCode(callSuper = false) @ApiModel(value = "ByxMchApplicationsNoticeDTO", description = "商户开户通知DTO") public class ByxMchApplicationsNoticeDTO { @ApiModelProperty(value = "时间") private String msgTime; @ApiModelProperty(value = "消息类型", required = true) @NotBlank private String msgType; @NotNull @ApiModelProperty(value = "消息内容", required = true) private String msgBody; private JSONObject msgBodyObject; } package com.yn.bftl.thirdparty.modules.chinaums.dto.byx; import com.alibaba.fastjson.JSONObject; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import lombok.EqualsAndHashCode; import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotNull; @Data @EqualsAndHashCode(callSuper = false) @ApiModel(value = "ByxMchApplicationsNoticeDTO", description = "商户开户通知DTO") public class ByxMchApplicationsNoticeDTO { @ApiModelProperty(value = "时间") private String msgTime; @ApiModelProperty(value = "消息类型", required = true) @NotBlank private String msgType; @NotNull @ApiModelProperty(value = "消息内容", required = true) private JSONObject msgBody; }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/dto/byx/ByxMchApplicationsNoticeDTO.java

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/service/impl/ChinaumsCallBackServiceImpl.java
package com.yn.bftl.thirdparty.modules.chinaums.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alipay.api.internal.util.StringUtils; import com.yn.bftl.common.modules.account.dto.ExternalIncomeDTO; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.util.DateTimeUtils; import com.yn.bftl.thirdparty.modules.chinaums.dto.ByxChinaumsCallBackDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.MchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.TradeResultDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxMchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.service.AuthService; import com.yn.bftl.thirdparty.modules.chinaums.service.ChinaumsCallBackService; import com.yn.bftl.thirdparty.modules.chinaums.service.WalletService; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsCallBackVO; import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.io.; import java.time.Duration; import java.time.LocalDateTime; import java.util.concurrent.TimeUnit; /* * 银联回调服务实现 * * @author huabiao * @create 2022/12/8 19:19 */ @Slf4j @Service public class ChinaumsCallBackServiceImpl implements ChinaumsCallBackService { @Resource private AuthService authService; @Resource private WalletService walletService; @Resource private StringRedisTemplate stringRedisTemplate; @Override public ChinaumsCallBackVO callbackForByx(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) { log.info("银联回调 - {}", JSON.toJSONString(byxMchApplicationsNoticeDTO)); synchronized (this) { return handleCallBack(byxMchApplicationsNoticeDTO); } } private ChinaumsCallBackVO handleCallBack(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) { Boolean isSuccess = false; switch (byxMchApplicationsNoticeDTO.getMsgType()) { case "REG_STATUS_CHANGE": break; case "OPEN_C_ACCOUNT_RESULT_NOTIFY": break; // 商户开户成功通知 case "REG_OPEN_ACCT_SUCCESS": JSONObject dto = byxMchApplicationsNoticeDTO.getMsgBodyObject(); ByxChinaumsCallBackDTO byxChinaumsCallBackDTO = dto.toJavaObject(ByxChinaumsCallBackDTO.class); isSuccess = authService.handleMchCallBackSuccess(byxChinaumsCallBackDTO); break; case "MERGE_GUARANTEED_PAY": String mctOrderNo = byxMchApplicationsNoticeDTO.getMsgBodyObject().get("mctOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBodyObject().get("mctOrderNo").toString(); String guaranteedOrderNo = byxMchApplicationsNoticeDTO.getMsgBodyObject().get("guaranteedOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBodyObject().get("guaranteedOrderNo").toString(); String orderStatus = byxMchApplicationsNoticeDTO.getMsgBodyObject().get("orderStatus") == null ? null : byxMchApplicationsNoticeDTO.getMsgBodyObject().get("orderStatus").toString(); if (StringUtils.isEmpty(mctOrderNo)) { log.error("回调（MERGE_GUARANTEED_PAY）：商户订单号为空"); throw new YnceErrorException("商户订单号为空"); } TradeResultDTO tradeResultDTO = new TradeResultDTO(); tradeResultDTO.setOutOrderNo(mctOrderNo); tradeResultDTO.setTradeId(guaranteedOrderNo); tradeResultDTO.setStatus(orderStatus); isSuccess = walletService.payCallback(tradeResultDTO); break; // 交易结果 case "trade_result": log.info("交易结果通知交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBodyObject().get("tradeType")); isSuccess = walletService.tradeResult(byxMchApplicationsNoticeDTO.getMsgBodyObject().toJavaObject(TradeResultDTO.class)); break; // 转账入金 case "transfer_deposit": log.info("转账入金交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBodyObject().get("tradeType")); ExternalIncomeDTO externalIncomeDTO = byxMchApplicationsNoticeDTO.getMsgBodyObject().toJavaObject(ExternalIncomeDTO.class); // 加锁，避免并发请求 String lockKeyTradeId = externalIncomeDTO.getTradeId(); Boolean lockTradeId = stringRedisTemplate.opsForValue().setIfAbsent(lockKeyTradeId, lockKeyTradeId); // 拿不到锁直接返回 if (!lockTradeId) { throw new YnceErrorException("转账入金(充值)处理中，稍后重试"); } stringRedisTemplate.expire(lockKeyTradeId, 1, TimeUnit.MINUTES); try { isSuccess = walletService.transferDeposit(externalIncomeDTO); } finally { // 执行成功和失败都需要删除锁 stringRedisTemplate.delete(lockKeyTradeId); } break; default: isSuccess = true; } ChinaumsCallBackVO chinaumsCallBackVO = new ChinaumsCallBackVO(); if (isSuccess) { // 通知成功回复 JSONObject msgHead = new JSONObject(); msgHead.put("errCode", "0000"); msgHead.put("errInfo", "SUCCESS"); chinaumsCallBackVO.setMsgHead(msgHead); chinaumsCallBackVO.setMsgBody(new JSONObject()); } return chinaumsCallBackVO; } @Override public ChinaumsCallBackVO mchApplicationsResult(MchApplicationsNoticeDTO mchApplicationsNoticeDTO) { log.info("银联回调 - {}", JSON.toJSONString(mchApplicationsNoticeDTO)); // 加锁，避免并发请求 String lockKey = mchApplicationsNoticeDTO.getEventType() + mchApplicationsNoticeDTO.getEventId(); Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, lockKey); // 拿不到锁直接返回 if (!lock) { throw new YnceErrorException("该回调在处理中，稍后重试"); } stringRedisTemplate.expire(lockKey, 1, TimeUnit.MINUTES); try { Boolean isSuccess = false; switch (mchApplicationsNoticeDTO.getEventType()) { // 二级商户进件通知 // case "mch_application_finished": // Object mchApplicationId = mchApplicationsNoticeDTO.getEventData().get("mchApplicationId"); // if (mchApplicationId != null) { // // 判断时间是否超过30秒，若是则手动处理 // LocalDateTime succeededTime = DateTimeUtils.getLocalDateTimeByRFC3339(mchApplicationsNoticeDTO.getEventData().get("succeededAt").toString()); // Duration duration = Duration.between(succeededTime, LocalDateTime.now()); // if (duration.toMillis() < 30000) { // isSuccess = false; // }else { // isSuccess = authService.handleApplicationStatus("2", mchApplicationId.toString(), null); // } // } // break; // 交易结果 case "trade_result": log.info("交易结果通知交易类型为：{}", mchApplicationsNoticeDTO.getEventData().get("tradeType")); isSuccess = walletService.tradeResult(mchApplicationsNoticeDTO.getEventData().toJavaObject(TradeResultDTO.class)); break; // 平台监管账户(母账户)发生入金 case "root_transfer_deposit": log.info("平台监管账户(母账户)发生入金"); isSuccess = true; break; // 转账入金 case "transfer_deposit": log.info("转账入金交易类型为：{}", mchApplicationsNoticeDTO.getEventData().get("tradeType")); ExternalIncomeDTO externalIncomeDTO = mchApplicationsNoticeDTO.getEventData().toJavaObject(ExternalIncomeDTO.class); // 加锁，避免并发请求 String lockKeyTradeId = externalIncomeDTO.getTradeId(); Boolean lockTradeId = stringRedisTemplate.opsForValue().setIfAbsent(lockKeyTradeId, lockKeyTradeId); // 拿不到锁直接返回 if (!lockTradeId) { throw new YnceErrorException("转账入金(充值)处理中，稍后重试"); } stringRedisTemplate.expire(lockKeyTradeId, 1, TimeUnit.MINUTES); try { isSuccess = walletService.transferDeposit(externalIncomeDTO); } finally { // 执行成功和失败都需要删除锁 stringRedisTemplate.delete(lockKeyTradeId); } break; // 打款金额验证 case "settle_acct_pay_amount_validation": log.info("打款金额验证"); isSuccess = authService.accountValidation(mchApplicationsNoticeDTO.getEventData().get("outRequestNo").toString()); break; default: isSuccess = true; } ChinaumsCallBackVO chinaumsCallBackVO = new ChinaumsCallBackVO(); if (isSuccess) { // 通知成功回复 JSONObject msgHead = new JSONObject(); msgHead.put("errCode", "0000"); msgHead.put("errInfo", "SUCCESS"); chinaumsCallBackVO.setMsgHead(msgHead); chinaumsCallBackVO.setMsgBody(new JSONObject()); } return chinaumsCallBackVO; } finally { // 执行成功和失败都需要删除锁 stringRedisTemplate.delete(lockKey); } } public static void main(String[] args) { String content = "{\"msgBody\":{\"registerNo\":\"c2814b8bd2c840668098bb9d90510003\"},\"msgType\":\"REG_OPEN_ACCT_SUCCESS\"}"; // 要保存的字符串 // String content = "Hello, World!"; // 指定文件路径 String filePath = "D:\\output"; // 将字符串转换为字节数组 byte[] contentBytes = content.getBytes(); // 使用try-with-resources语句自动关闭资源 try (Writer writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(filePath), "UTF-8"))) { writer.write(content); } catch (IOException e) { e.printStackTrace(); System.out.println("保存文件时发生错误"); } } // public static void main(String[] args) { // ByxMchApplicationsNoticeDTO dto = new ByxMchApplicationsNoticeDTO(); // dto.setMsgType("REG_OPEN_ACCT_SUCCESS"); // JSONObject jsonObject = new JSONObject(); // jsonObject.put("registerNo", "c2814b8bd2c840668098bb9d90510003"); // dto.setMsgBody(jsonObject); // System.out.println(JSON.toJSONString(dto)); // } } package com.yn.bftl.thirdparty.modules.chinaums.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alipay.api.internal.util.StringUtils; import com.yn.bftl.common.modules.account.dto.ExternalIncomeDTO; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.util.DateTimeUtils; import com.yn.bftl.thirdparty.modules.chinaums.dto.ByxChinaumsCallBackDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.MchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.TradeResultDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxMchApplicationsNoticeDTO; import com.yn.bftl.thirdparty.modules.chinaums.service.AuthService; import com.yn.bftl.thirdparty.modules.chinaums.service.ChinaumsCallBackService; import com.yn.bftl.thirdparty.modules.chinaums.service.WalletService; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsCallBackVO; import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.io.; import java.time.Duration; import java.time.LocalDateTime; import java.util.concurrent.TimeUnit; /** * 银联回调服务实现 * * @author huabiao * @create 2022/12/8 19:19 **/ @Slf4j @Service public class ChinaumsCallBackServiceImpl implements ChinaumsCallBackService { @Resource private AuthService authService; @Resource private WalletService walletService; @Resource private StringRedisTemplate stringRedisTemplate; @Override public ChinaumsCallBackVO callbackForByx(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) { log.info("银联回调 - {}", JSON.toJSONString(byxMchApplicationsNoticeDTO)); synchronized (this) { return handleCallBack(byxMchApplicationsNoticeDTO); } } private ChinaumsCallBackVO handleCallBack(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) { Boolean isSuccess = false; switch (byxMchApplicationsNoticeDTO.getMsgType()) { case "REG_STATUS_CHANGE": break; case "OPEN_C_ACCOUNT_RESULT_NOTIFY": break; // 商户开户成功通知 case "REG_OPEN_ACCT_SUCCESS": JSONObject dto = byxMchApplicationsNoticeDTO.getMsgBody(); ByxChinaumsCallBackDTO byxChinaumsCallBackDTO = dto.toJavaObject(ByxChinaumsCallBackDTO.class); isSuccess = authService.handleMchCallBackSuccess(byxChinaumsCallBackDTO); break; case "MERGE_GUARANTEED_PAY": String mctOrderNo = byxMchApplicationsNoticeDTO.getMsgBody().get("mctOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBody().get("mctOrderNo").toString(); String guaranteedOrderNo = byxMchApplicationsNoticeDTO.getMsgBody().get("guaranteedOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBody().get("guaranteedOrderNo").toString(); String orderStatus = byxMchApplicationsNoticeDTO.getMsgBody().get("orderStatus") == null ? null : byxMchApplicationsNoticeDTO.getMsgBody().get("orderStatus").toString(); if (StringUtils.isEmpty(mctOrderNo)) { log.error("回调（MERGE_GUARANTEED_PAY）：商户订单号为空"); throw new YnceErrorException("商户订单号为空"); } TradeResultDTO tradeResultDTO = new TradeResultDTO(); tradeResultDTO.setOutOrderNo(mctOrderNo); tradeResultDTO.setTradeId(guaranteedOrderNo); tradeResultDTO.setStatus(orderStatus); isSuccess = walletService.payCallback(tradeResultDTO); break; // 交易结果 case "trade_result": log.info("交易结果通知交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBody().get("tradeType")); isSuccess = walletService.tradeResult(byxMchApplicationsNoticeDTO.getMsgBody().toJavaObject(TradeResultDTO.class)); break; // 转账入金 case "transfer_deposit": log.info("转账入金交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBody().get("tradeType")); ExternalIncomeDTO externalIncomeDTO = byxMchApplicationsNoticeDTO.getMsgBody().toJavaObject(ExternalIncomeDTO.class); // 加锁，避免并发请求 String lockKeyTradeId = externalIncomeDTO.getTradeId(); Boolean lockTradeId = stringRedisTemplate.opsForValue().setIfAbsent(lockKeyTradeId, lockKeyTradeId); // 拿不到锁直接返回 if (!lockTradeId) { throw new YnceErrorException("转账入金(充值)处理中，稍后重试"); } stringRedisTemplate.expire(lockKeyTradeId, 1, TimeUnit.MINUTES); try { isSuccess = walletService.transferDeposit(externalIncomeDTO); } finally { // 执行成功和失败都需要删除锁 stringRedisTemplate.delete(lockKeyTradeId); } break; default: isSuccess = true; } ChinaumsCallBackVO chinaumsCallBackVO = new ChinaumsCallBackVO(); if (isSuccess) { // 通知成功回复 JSONObject msgHead = new JSONObject(); msgHead.put("errCode", "0000"); msgHead.put("errInfo", "SUCCESS"); chinaumsCallBackVO.setMsgHead(msgHead); chinaumsCallBackVO.setMsgBody(new JSONObject()); } return chinaumsCallBackVO; } @Override public ChinaumsCallBackVO mchApplicationsResult(MchApplicationsNoticeDTO mchApplicationsNoticeDTO) { log.info("银联回调 - {}", JSON.toJSONString(mchApplicationsNoticeDTO)); // 加锁，避免并发请求 String lockKey = mchApplicationsNoticeDTO.getEventType() + mchApplicationsNoticeDTO.getEventId(); Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, lockKey); // 拿不到锁直接返回 if (!lock) { throw new YnceErrorException("该回调在处理中，稍后重试"); } stringRedisTemplate.expire(lockKey, 1, TimeUnit.MINUTES); try { Boolean isSuccess = false; switch (mchApplicationsNoticeDTO.getEventType()) { // 二级商户进件通知 // case "mch_application_finished": // Object mchApplicationId = mchApplicationsNoticeDTO.getEventData().get("mchApplicationId"); // if (mchApplicationId != null) { // // 判断时间是否超过30秒，若是则手动处理 // LocalDateTime succeededTime = DateTimeUtils.getLocalDateTimeByRFC3339(mchApplicationsNoticeDTO.getEventData().get("succeededAt").toString()); // Duration duration = Duration.between(succeededTime, LocalDateTime.now()); // if (duration.toMillis() < 30000) { // isSuccess = false; // }else { // isSuccess = authService.handleApplicationStatus("2", mchApplicationId.toString(), null); // } // } // break; // 交易结果 case "trade_result": log.info("交易结果通知交易类型为：{}", mchApplicationsNoticeDTO.getEventData().get("tradeType")); isSuccess = walletService.tradeResult(mchApplicationsNoticeDTO.getEventData().toJavaObject(TradeResultDTO.class)); break; // 平台监管账户(母账户)发生入金 case "root_transfer_deposit": log.info("平台监管账户(母账户)发生入金"); isSuccess = true; break; // 转账入金 case "transfer_deposit": log.info("转账入金交易类型为：{}", mchApplicationsNoticeDTO.getEventData().get("tradeType")); ExternalIncomeDTO externalIncomeDTO = mchApplicationsNoticeDTO.getEventData().toJavaObject(ExternalIncomeDTO.class); // 加锁，避免并发请求 String lockKeyTradeId = externalIncomeDTO.getTradeId(); Boolean lockTradeId = stringRedisTemplate.opsForValue().setIfAbsent(lockKeyTradeId, lockKeyTradeId); // 拿不到锁直接返回 if (!lockTradeId) { throw new YnceErrorException("转账入金(充值)处理中，稍后重试"); } stringRedisTemplate.expire(lockKeyTradeId, 1, TimeUnit.MINUTES); try { isSuccess = walletService.transferDeposit(externalIncomeDTO); } finally { // 执行成功和失败都需要删除锁 stringRedisTemplate.delete(lockKeyTradeId); } break; // 打款金额验证 case "settle_acct_pay_amount_validation": log.info("打款金额验证"); isSuccess = authService.accountValidation(mchApplicationsNoticeDTO.getEventData().get("outRequestNo").toString()); break; default: isSuccess = true; } ChinaumsCallBackVO chinaumsCallBackVO = new ChinaumsCallBackVO(); if (isSuccess) { // 通知成功回复 JSONObject msgHead = new JSONObject(); msgHead.put("errCode", "0000"); msgHead.put("errInfo", "SUCCESS"); chinaumsCallBackVO.setMsgHead(msgHead); chinaumsCallBackVO.setMsgBody(new JSONObject()); } return chinaumsCallBackVO; } finally { // 执行成功和失败都需要删除锁 stringRedisTemplate.delete(lockKey); } } public static void main(String[] args) { String content = "{\"msgBody\":{\"registerNo\":\"c2814b8bd2c840668098bb9d90510003\"},\"msgType\":\"REG_OPEN_ACCT_SUCCESS\"}"; // 要保存的字符串 // String content = "Hello, World!"; // 指定文件路径 String filePath = "D:\\output"; // 将字符串转换为字节数组 byte[] contentBytes = content.getBytes(); // 使用try-with-resources语句自动关闭资源 try (Writer writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(filePath), "UTF-8"))) { writer.write(content); } catch (IOException e) { e.printStackTrace(); System.out.println("保存文件时发生错误"); } } // public static void main(String[] args) { // ByxMchApplicationsNoticeDTO dto = new ByxMchApplicationsNoticeDTO(); // dto.setMsgType("REG_OPEN_ACCT_SUCCESS"); // JSONObject jsonObject = new JSONObject(); // jsonObject.put("registerNo", "c2814b8bd2c840668098bb9d90510003"); // dto.setMsgBody(jsonObject); // System.out.println(JSON.toJSONString(dto)); // } }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/service/impl/ChinaumsCallBackServiceImpl.java

package com.yn.bftl.thirdparty.modules.chinaums.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alipay.api.internal.util.StringUtils;
import com.yn.bftl.common.modules.account.dto.ExternalIncomeDTO;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.util.DateTimeUtils;
import com.yn.bftl.thirdparty.modules.chinaums.dto.ByxChinaumsCallBackDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.MchApplicationsNoticeDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.TradeResultDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxMchApplicationsNoticeDTO;
import com.yn.bftl.thirdparty.modules.chinaums.service.AuthService;
import com.yn.bftl.thirdparty.modules.chinaums.service.ChinaumsCallBackService;
import com.yn.bftl.thirdparty.modules.chinaums.service.WalletService;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsCallBackVO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.io.*;
import java.time.Duration;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;

/**
 * 银联回调服务实现
 *
 * @author huabiao
 * @create 2022/12/8  19:19
 **/
@Slf4j
@Service
public class ChinaumsCallBackServiceImpl implements ChinaumsCallBackService {

@Resource
    private AuthService authService;
    @Resource
    private WalletService walletService;
    @Resource
    private StringRedisTemplate stringRedisTemplate;

@Override
    public ChinaumsCallBackVO callbackForByx(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) {
        log.info("银联回调 - {}", JSON.toJSONString(byxMchApplicationsNoticeDTO));
        synchronized (this) {
            return handleCallBack(byxMchApplicationsNoticeDTO);
        }
    }

private ChinaumsCallBackVO handleCallBack(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) {
        Boolean isSuccess = false;
        switch (byxMchApplicationsNoticeDTO.getMsgType()) {
            case "REG_STATUS_CHANGE":
                break;
            case "OPEN_C_ACCOUNT_RESULT_NOTIFY":
                break;
            // 商户开户成功通知
            case "REG_OPEN_ACCT_SUCCESS":
                JSONObject dto = byxMchApplicationsNoticeDTO.getMsgBodyObject();
                ByxChinaumsCallBackDTO byxChinaumsCallBackDTO = dto.toJavaObject(ByxChinaumsCallBackDTO.class);
                isSuccess = authService.handleMchCallBackSuccess(byxChinaumsCallBackDTO);
                break;
            case "MERGE_GUARANTEED_PAY":
                String mctOrderNo = byxMchApplicationsNoticeDTO.getMsgBodyObject().get("mctOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBodyObject().get("mctOrderNo").toString();
                String guaranteedOrderNo = byxMchApplicationsNoticeDTO.getMsgBodyObject().get("guaranteedOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBodyObject().get("guaranteedOrderNo").toString();
                String orderStatus = byxMchApplicationsNoticeDTO.getMsgBodyObject().get("orderStatus") == null ? null : byxMchApplicationsNoticeDTO.getMsgBodyObject().get("orderStatus").toString();
                if (StringUtils.isEmpty(mctOrderNo)) {
                    log.error("回调（MERGE_GUARANTEED_PAY）：商户订单号为空");
                    throw new YnceErrorException("商户订单号为空");
                }
                TradeResultDTO tradeResultDTO = new TradeResultDTO();
                tradeResultDTO.setOutOrderNo(mctOrderNo);
                tradeResultDTO.setTradeId(guaranteedOrderNo);
                tradeResultDTO.setStatus(orderStatus);
                isSuccess = walletService.payCallback(tradeResultDTO);
                break;
            // 交易结果
            case "trade_result":
                log.info("交易结果通知 交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBodyObject().get("tradeType"));
                isSuccess = walletService.tradeResult(byxMchApplicationsNoticeDTO.getMsgBodyObject().toJavaObject(TradeResultDTO.class));
                break;
            // 转账入金
            case "transfer_deposit":
                log.info("转账入金 交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBodyObject().get("tradeType"));
                ExternalIncomeDTO externalIncomeDTO = byxMchApplicationsNoticeDTO.getMsgBodyObject().toJavaObject(ExternalIncomeDTO.class);
                // 加锁，避免并发请求
                String lockKeyTradeId = externalIncomeDTO.getTradeId();
                Boolean lockTradeId = stringRedisTemplate.opsForValue().setIfAbsent(lockKeyTradeId, lockKeyTradeId);
                // 拿不到锁直接返回
                if (!lockTradeId) {
                    throw new YnceErrorException("转账入金(充值)处理中，稍后重试");
                }
                stringRedisTemplate.expire(lockKeyTradeId, 1, TimeUnit.MINUTES);
                try {
                    isSuccess = walletService.transferDeposit(externalIncomeDTO);
                } finally {
                    // 执行成功和失败都需要删除锁
                    stringRedisTemplate.delete(lockKeyTradeId);
                }
                break;
            default:
                isSuccess = true;
        }
        ChinaumsCallBackVO chinaumsCallBackVO = new ChinaumsCallBackVO();
        if (isSuccess) {
            // 通知成功回复
            JSONObject msgHead = new JSONObject();
            msgHead.put("errCode", "0000");
            msgHead.put("errInfo", "SUCCESS");
            chinaumsCallBackVO.setMsgHead(msgHead);
            chinaumsCallBackVO.setMsgBody(new JSONObject());
        }
        return chinaumsCallBackVO;
    }

@Override
    public ChinaumsCallBackVO mchApplicationsResult(MchApplicationsNoticeDTO mchApplicationsNoticeDTO) {
        log.info("银联回调 - {}", JSON.toJSONString(mchApplicationsNoticeDTO));
        // 加锁，避免并发请求
        String lockKey = mchApplicationsNoticeDTO.getEventType() + mchApplicationsNoticeDTO.getEventId();
        Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, lockKey);
        // 拿不到锁直接返回
        if (!lock) {
            throw new YnceErrorException("该回调在处理中，稍后重试");
        }
        stringRedisTemplate.expire(lockKey, 1, TimeUnit.MINUTES);
        try {
            Boolean isSuccess = false;
            switch (mchApplicationsNoticeDTO.getEventType()) {
                // 二级商户进件通知
//                case "mch_application_finished":
//                    Object mchApplicationId = mchApplicationsNoticeDTO.getEventData().get("mchApplicationId");
//                    if (mchApplicationId != null) {
//                        // 判断时间是否超过30秒，若是则手动处理
//                        LocalDateTime succeededTime = DateTimeUtils.getLocalDateTimeByRFC3339(mchApplicationsNoticeDTO.getEventData().get("succeededAt").toString());
//                        Duration duration = Duration.between(succeededTime, LocalDateTime.now());
//                        if (duration.toMillis() < 30000) {
//                            isSuccess = false;
//                        }else {
//                            isSuccess = authService.handleApplicationStatus("2", mchApplicationId.toString(), null);
//                        }
//                    }
//                    break;
                // 交易结果
                case "trade_result":
                    log.info("交易结果通知 交易类型为：{}", mchApplicationsNoticeDTO.getEventData().get("tradeType"));
                    isSuccess = walletService.tradeResult(mchApplicationsNoticeDTO.getEventData().toJavaObject(TradeResultDTO.class));
                    break;
                // 平台监管账户(母账户)发生入金
                case "root_transfer_deposit":
                    log.info("平台监管账户(母账户)发生入金");
                    isSuccess = true;
                    break;
                // 转账入金
                case "transfer_deposit":
                    log.info("转账入金 交易类型为：{}", mchApplicationsNoticeDTO.getEventData().get("tradeType"));
                    ExternalIncomeDTO externalIncomeDTO = mchApplicationsNoticeDTO.getEventData().toJavaObject(ExternalIncomeDTO.class);
                    // 加锁，避免并发请求
                    String lockKeyTradeId = externalIncomeDTO.getTradeId();
                    Boolean lockTradeId = stringRedisTemplate.opsForValue().setIfAbsent(lockKeyTradeId, lockKeyTradeId);
                    // 拿不到锁直接返回
                    if (!lockTradeId) {
                        throw new YnceErrorException("转账入金(充值)处理中，稍后重试");
                    }
                    stringRedisTemplate.expire(lockKeyTradeId, 1, TimeUnit.MINUTES);
                    try {
                        isSuccess = walletService.transferDeposit(externalIncomeDTO);
                    } finally {
                        // 执行成功和失败都需要删除锁
                        stringRedisTemplate.delete(lockKeyTradeId);
                    }
                    break;
                // 打款金额验证
                case "settle_acct_pay_amount_validation":
                    log.info("打款金额验证");
                    isSuccess = authService.accountValidation(mchApplicationsNoticeDTO.getEventData().get("outRequestNo").toString());
                    break;
                default:
                    isSuccess = true;
            }
            ChinaumsCallBackVO chinaumsCallBackVO = new ChinaumsCallBackVO();
            if (isSuccess) {
                // 通知成功回复
                JSONObject msgHead = new JSONObject();
                msgHead.put("errCode", "0000");
                msgHead.put("errInfo", "SUCCESS");
                chinaumsCallBackVO.setMsgHead(msgHead);
                chinaumsCallBackVO.setMsgBody(new JSONObject());
            }
            return chinaumsCallBackVO;
        }  finally {
            // 执行成功和失败都需要删除锁
            stringRedisTemplate.delete(lockKey);
        }
    }

public static void main(String[] args) {
        String content = "{\"msgBody\":{\"registerNo\":\"c2814b8bd2c840668098bb9d90510003\"},\"msgType\":\"REG_OPEN_ACCT_SUCCESS\"}";
        // 要保存的字符串
//        String content = "Hello, World!";

// 指定文件路径
        String filePath = "D:\\output";

// 将字符串转换为字节数组
        byte[] contentBytes = content.getBytes();

// 使用try-with-resources语句自动关闭资源
        try (Writer writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(filePath), "UTF-8"))) {
            writer.write(content);
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("保存文件时发生错误");
        }

}

//    public static void main(String[] args) {
//        ByxMchApplicationsNoticeDTO  dto = new ByxMchApplicationsNoticeDTO();
//        dto.setMsgType("REG_OPEN_ACCT_SUCCESS");
//        JSONObject jsonObject = new JSONObject();
//        jsonObject.put("registerNo", "c2814b8bd2c840668098bb9d90510003");
//        dto.setMsgBody(jsonObject);
//        System.out.println(JSON.toJSONString(dto));
//    }
}

package com.yn.bftl.thirdparty.modules.chinaums.service.impl;

import javax.annotation.Resource;
import java.io.*;
import java.time.Duration;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;

/**
 * 银联回调服务实现
 *
 * @author huabiao
 * @create 2022/12/8  19:19
 **/
@Slf4j
@Service
public class ChinaumsCallBackServiceImpl implements ChinaumsCallBackService {

@Resource
    private AuthService authService;
    @Resource
    private WalletService walletService;
    @Resource
    private StringRedisTemplate stringRedisTemplate;

private ChinaumsCallBackVO handleCallBack(ByxMchApplicationsNoticeDTO byxMchApplicationsNoticeDTO) {
        Boolean isSuccess = false;
        switch (byxMchApplicationsNoticeDTO.getMsgType()) {
            case "REG_STATUS_CHANGE":
                break;
            case "OPEN_C_ACCOUNT_RESULT_NOTIFY":
                break;
            // 商户开户成功通知
            case "REG_OPEN_ACCT_SUCCESS":
                JSONObject dto = byxMchApplicationsNoticeDTO.getMsgBody();
                ByxChinaumsCallBackDTO byxChinaumsCallBackDTO = dto.toJavaObject(ByxChinaumsCallBackDTO.class);
                isSuccess = authService.handleMchCallBackSuccess(byxChinaumsCallBackDTO);
                break;
            case "MERGE_GUARANTEED_PAY":
                String mctOrderNo = byxMchApplicationsNoticeDTO.getMsgBody().get("mctOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBody().get("mctOrderNo").toString();
                String guaranteedOrderNo = byxMchApplicationsNoticeDTO.getMsgBody().get("guaranteedOrderNo") == null ? null : byxMchApplicationsNoticeDTO.getMsgBody().get("guaranteedOrderNo").toString();
                String orderStatus = byxMchApplicationsNoticeDTO.getMsgBody().get("orderStatus") == null ? null : byxMchApplicationsNoticeDTO.getMsgBody().get("orderStatus").toString();
                if (StringUtils.isEmpty(mctOrderNo)) {
                    log.error("回调（MERGE_GUARANTEED_PAY）：商户订单号为空");
                    throw new YnceErrorException("商户订单号为空");
                }
                TradeResultDTO tradeResultDTO = new TradeResultDTO();
                tradeResultDTO.setOutOrderNo(mctOrderNo);
                tradeResultDTO.setTradeId(guaranteedOrderNo);
                tradeResultDTO.setStatus(orderStatus);
                isSuccess = walletService.payCallback(tradeResultDTO);
                break;
            // 交易结果
            case "trade_result":
                log.info("交易结果通知 交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBody().get("tradeType"));
                isSuccess = walletService.tradeResult(byxMchApplicationsNoticeDTO.getMsgBody().toJavaObject(TradeResultDTO.class));
                break;
            // 转账入金
            case "transfer_deposit":
                log.info("转账入金 交易类型为：{}", byxMchApplicationsNoticeDTO.getMsgBody().get("tradeType"));
                ExternalIncomeDTO externalIncomeDTO = byxMchApplicationsNoticeDTO.getMsgBody().toJavaObject(ExternalIncomeDTO.class);
                // 加锁，避免并发请求
                String lockKeyTradeId = externalIncomeDTO.getTradeId();
                Boolean lockTradeId = stringRedisTemplate.opsForValue().setIfAbsent(lockKeyTradeId, lockKeyTradeId);
                // 拿不到锁直接返回
                if (!lockTradeId) {
                    throw new YnceErrorException("转账入金(充值)处理中，稍后重试");
                }
                stringRedisTemplate.expire(lockKeyTradeId, 1, TimeUnit.MINUTES);
                try {
                    isSuccess = walletService.transferDeposit(externalIncomeDTO);
                } finally {
                    // 执行成功和失败都需要删除锁
                    stringRedisTemplate.delete(lockKeyTradeId);
                }
                break;
            default:
                isSuccess = true;
        }
        ChinaumsCallBackVO chinaumsCallBackVO = new ChinaumsCallBackVO();
        if (isSuccess) {
            // 通知成功回复
            JSONObject msgHead = new JSONObject();
            msgHead.put("errCode", "0000");
            msgHead.put("errInfo", "SUCCESS");
            chinaumsCallBackVO.setMsgHead(msgHead);
            chinaumsCallBackVO.setMsgBody(new JSONObject());
        }
        return chinaumsCallBackVO;
    }

// 指定文件路径
        String filePath = "D:\\output";

// 将字符串转换为字节数组
        byte[] contentBytes = content.getBytes();

}

Show line notes below