银联银行卡-列表、绑定、删除；发送验证码

yn-bftl-byx / thirdparty

Browse code 银联银行卡-列表、绑定、删除；发送验证码 master
1 parent 824ebd1 commit a392bc91901049a7d81d2dde7ccf4806d82edfeb Jing authored on 28 Aug

Patch

Showing 13 changed files

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/common/constants/Constant.java 0 → 100644
package com.yn.bftl.thirdparty.common.constants; /** * @program: yn-byx-thirdparty * @description: 公用常量类 * @author: Jing * @create: 2024-08-27 16:59 / public class Constant { / * 成功/处理完成 */ public static final String RETURN_SUCCESS_CODE = "00000"; }

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/common/dto/BaseResponseDTO.java 0 → 100644
package com.yn.bftl.thirdparty.common.dto; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import lombok.EqualsAndHashCode; @Data public class BaseResponseDTO { @ApiModelProperty(value = "应答码") private String rspCode; @ApiModelProperty(value = "应答描述") private String rspResult; }

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/common/enums/SmsTmpltCode.java 0 → 100644
package com.yn.bftl.thirdparty.common.enums; import lombok.AllArgsConstructor; /** * 下发短信的模板编码 * * @author Jing * @date 2024.08.28 */ @AllArgsConstructor public enum SmsTmpltCode { COMMON("COMMON", "一般验证码"), REGIST("REGIST", "开户"), ACTIVATE("ACTIVATE", "激活"), TRADE("TRADE", "交易"); private final String value; private final String name; public String getValue() { return this.value; } public String getName() { return this.name; } }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/common/enums/SmsTmpltCode.java 0 → 100644

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/controller/member/BankCardMemberController.java
package com.yn.bftl.thirdparty.modules.chinaums.controller.member; import cn.hutool.core.bean.BeanUtil; import com.yn.bftl.common.common.exception.YnceError; import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo; import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard; import com.yn.bftl.common.modules.company.enums.ApplicationStatus; import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsAcctBindBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.enums.OprtTypeEnum; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository; import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.apache.commons.lang3.StringUtils; 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.validation.Valid; import javax.validation.constraints.NotNull; import java.util.List; /** * 银联银行卡控制层 * * @author huabiao * @create 2023/2/15 14:57 / @Api(value = "BankCardMemberController", tags = "用户端-银联银行卡") @RestController @RequestMapping("/member/chinaums/bank_card") public class BankCardMemberController { @Resource private BankCardService bankCardService; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private ChinaumsBankCardRepository chinaumsBankCardRepository; @ApiOperation(value = "银联银行卡-列表") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", name = "status", value = "银行卡状态", required = true, dataType = "ChinaumsBankCardStatus", dataTypeClass = ChinaumsBankCardStatus.class), }) @RequestMapping(value = "/list", method = RequestMethod.GET) public List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status) { return bankCardService.bankCardList(status); } @ApiOperation(value = "银联银行卡-绑定") @RequestMapping(value = "/add", method = RequestMethod.POST) public void addBankCard(@Valid @RequestBody ChinaumsAddBankCardDTO chinaumsAddBankCardDTO) { if (chinaumsAddBankCardDTO.getBankAcctType().equals("1")) { // 校验手机号 if (StringUtils.isBlank(chinaumsAddBankCardDTO.getMobileNumber())) { throw new YnceErrorException(YnceError.YNCE_218021); } // 校验验证码 if (StringUtils.isBlank(chinaumsAddBankCardDTO.getSmsCode())) { throw new YnceErrorException(YnceError.YNCE_218022); } } ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO = new ByxChinaumsAcctBindBankCardDTO(); BeanUtil.copyProperties(chinaumsAddBankCardDTO, byxChinaumsAcctBindBankCardDTO); byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsAddBankCardDTO.getMobileNumber()); byxChinaumsAcctBindBankCardDTO.setBankNo(chinaumsAddBankCardDTO.getBankBranchCode()); byxChinaumsAcctBindBankCardDTO.setSmsAuthCode(chinaumsAddBankCardDTO.getSmsCode()); byxChinaumsAcctBindBankCardDTO.setOprtType(OprtTypeEnum.BINDING.getValue()); if("2".equals(chinaumsAddBankCardDTO.getBankAcctType()) ){ byxChinaumsAcctBindBankCardDTO.setBankAcctType("0"); } bankCardService.addBankCard(byxChinaumsAcctBindBankCardDTO); } @ApiOperation(value = "银联银行卡-删除") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", name = "id", value = "银行卡ID", required = true, dataType = "Long", dataTypeClass = Long.class), }) @RequestMapping(value = "/delete", method = RequestMethod.DELETE) public Boolean deleteBankCard(@NotNull Long id) { return bankCardService.deleteBankCard(id); } @ApiOperation(value = "银联银行卡-打款金额验证") @RequestMapping(value = "/amount_validate", method = RequestMethod.POST) public Boolean amountValidate(@Valid @RequestBody BankCardAmountValidateDTO bankCardAmountValidateDTO) { return bankCardService.amountValidate(bankCardAmountValidateDTO); } @ApiOperation(value = "银联银行卡-详情") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", name = "id", value = "银行卡ID", required = true, dataType = "Long", dataTypeClass = Long.class), }) @RequestMapping(value = "/one", method = RequestMethod.GET) public ChinaumsBankCardDetailVO getBankCardDetail(@NotNull Long id) { return bankCardService.getBankCardDetail(id); } @ApiOperation(value = "银联银行卡-处理") @RequestMapping(value = "/handle", method = RequestMethod.POST) public void handleChinaumsBankCard() { // 获取所有银联认证信息 List<ChinaumsAuthInfo> chinaumsAuthInfoList = chinaumsAuthInfoRepository.findAll(); for (ChinaumsAuthInfo chinaumsAuthInfo : chinaumsAuthInfoList) { // 审核通过的需要将银行卡信息保存到银联认证信息中 if (chinaumsAuthInfo.getApplicationStatus().equals(ApplicationStatus.SUCCEEDED)) { ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard(); chinaumsBankCard.setBankCode(chinaumsAuthInfo.getSettleAcctBankCode()); chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode()); chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo()); if (StringUtils.isNotBlank(chinaumsAuthInfo.getCusApplicationId())) { chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber()); } else { chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getLegalPersonMobileNumber()); } chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo); chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo()); chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType()); chinaumsBankCard.setBankName(chinaumsAuthInfo.getSettleAcctBankName()); chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId()); chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED); chinaumsBankCardRepository.save(chinaumsBankCard); } } } } package com.yn.bftl.thirdparty.modules.chinaums.controller.member; import com.yn.bftl.common.common.exception.YnceError; import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo; import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard; import com.yn.bftl.common.modules.company.enums.ApplicationStatus; import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository; import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.apache.commons.lang3.StringUtils; 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.validation.Valid; import javax.validation.constraints.NotNull; import java.util.List; / * 银联银行卡控制层 * * @author huabiao * @create 2023/2/15 14:57 **/ @Api(value = "BankCardMemberController", tags = "用户端-银联银行卡") @RestController @RequestMapping("/member/chinaums/bank_card") public class BankCardMemberController { @Resource private BankCardService bankCardService; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private ChinaumsBankCardRepository chinaumsBankCardRepository; @ApiOperation(value = "银联银行卡-列表") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", name = "status", value = "银行卡状态", required = true, dataType = "ChinaumsBankCardStatus", dataTypeClass = ChinaumsBankCardStatus.class), }) @RequestMapping(value = "/list", method = RequestMethod.GET) public List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status) { return bankCardService.bankCardList(status); } @ApiOperation(value = "银联银行卡-绑定") @RequestMapping(value = "/add", method = RequestMethod.POST) public void addBankCard(@Valid @RequestBody ChinaumsAddBankCardDTO chinaumsAddBankCardDTO) { if (chinaumsAddBankCardDTO.getBankAcctType().equals("1")) { // 校验手机号 if (StringUtils.isBlank(chinaumsAddBankCardDTO.getMobileNumber())) { throw new YnceErrorException(YnceError.YNCE_218021); } // 校验验证码 if (StringUtils.isBlank(chinaumsAddBankCardDTO.getSmsCode())) { throw new YnceErrorException(YnceError.YNCE_218022); } } bankCardService.addBankCard(chinaumsAddBankCardDTO); } @ApiOperation(value = "银联银行卡-删除") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", name = "id", value = "银行卡ID", required = true, dataType = "Long", dataTypeClass = Long.class), }) @RequestMapping(value = "/delete", method = RequestMethod.DELETE) public Boolean deleteBankCard(@NotNull Long id) { return bankCardService.deleteBankCard(id); } @ApiOperation(value = "银联银行卡-打款金额验证") @RequestMapping(value = "/amount_validate", method = RequestMethod.POST) public Boolean amountValidate(@Valid @RequestBody BankCardAmountValidateDTO bankCardAmountValidateDTO) { return bankCardService.amountValidate(bankCardAmountValidateDTO); } @ApiOperation(value = "银联银行卡-详情") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", name = "id", value = "银行卡ID", required = true, dataType = "Long", dataTypeClass = Long.class), }) @RequestMapping(value = "/one", method = RequestMethod.GET) public ChinaumsBankCardDetailVO getBankCardDetail(@NotNull Long id) { return bankCardService.getBankCardDetail(id); } @ApiOperation(value = "银联银行卡-处理") @RequestMapping(value = "/handle", method = RequestMethod.POST) public void handleChinaumsBankCard() { // 获取所有银联认证信息 List<ChinaumsAuthInfo> chinaumsAuthInfoList = chinaumsAuthInfoRepository.findAll(); for (ChinaumsAuthInfo chinaumsAuthInfo : chinaumsAuthInfoList) { // 审核通过的需要将银行卡信息保存到银联认证信息中 if (chinaumsAuthInfo.getApplicationStatus().equals(ApplicationStatus.SUCCEEDED)) { ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard(); chinaumsBankCard.setBankCode(chinaumsAuthInfo.getSettleAcctBankCode()); chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode()); chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo()); if (StringUtils.isNotBlank(chinaumsAuthInfo.getCusApplicationId())) { chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber()); } else { chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getLegalPersonMobileNumber()); } chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo); chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo()); chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType()); chinaumsBankCard.setBankName(chinaumsAuthInfo.getSettleAcctBankName()); chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId()); chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED); chinaumsBankCardRepository.save(chinaumsBankCard); } } } }

Ignore Space Show notes View

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

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

import cn.hutool.core.bean.BeanUtil;
import com.yn.bftl.common.common.exception.YnceError;
import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo;
import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard;
import com.yn.bftl.common.modules.company.enums.ApplicationStatus;
import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsAcctBindBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.enums.OprtTypeEnum;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository;
import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
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.validation.Valid;
import javax.validation.constraints.NotNull;
import java.util.List;

/**
 * 银联银行卡控制层
 *
 * @author huabiao
 * @create 2023/2/15  14:57
 **/
@Api(value = "BankCardMemberController", tags = "用户端-银联银行卡")
@RestController
@RequestMapping("/member/chinaums/bank_card")
public class BankCardMemberController {

@Resource
    private BankCardService bankCardService;
    @Resource
    private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository;
    @Resource
    private ChinaumsBankCardRepository chinaumsBankCardRepository;

@ApiOperation(value = "银联银行卡-列表")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "status", value = "银行卡状态", required = true, dataType = "ChinaumsBankCardStatus", dataTypeClass = ChinaumsBankCardStatus.class),
    })
    @RequestMapping(value = "/list", method = RequestMethod.GET)
    public List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status) {
        return bankCardService.bankCardList(status);
    }

@ApiOperation(value = "银联银行卡-绑定")
    @RequestMapping(value = "/add", method = RequestMethod.POST)
    public void addBankCard(@Valid @RequestBody ChinaumsAddBankCardDTO chinaumsAddBankCardDTO) {
        if (chinaumsAddBankCardDTO.getBankAcctType().equals("1")) {
            // 校验手机号
            if (StringUtils.isBlank(chinaumsAddBankCardDTO.getMobileNumber())) {
                throw new YnceErrorException(YnceError.YNCE_218021);
            }
            // 校验验证码
            if (StringUtils.isBlank(chinaumsAddBankCardDTO.getSmsCode())) {
                throw new YnceErrorException(YnceError.YNCE_218022);
            }
        }
        ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO = new ByxChinaumsAcctBindBankCardDTO();
        BeanUtil.copyProperties(chinaumsAddBankCardDTO, byxChinaumsAcctBindBankCardDTO);
        byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsAddBankCardDTO.getMobileNumber());
        byxChinaumsAcctBindBankCardDTO.setBankNo(chinaumsAddBankCardDTO.getBankBranchCode());
        byxChinaumsAcctBindBankCardDTO.setSmsAuthCode(chinaumsAddBankCardDTO.getSmsCode());
        byxChinaumsAcctBindBankCardDTO.setOprtType(OprtTypeEnum.BINDING.getValue());
        if("2".equals(chinaumsAddBankCardDTO.getBankAcctType()) ){
            byxChinaumsAcctBindBankCardDTO.setBankAcctType("0");
        }
        bankCardService.addBankCard(byxChinaumsAcctBindBankCardDTO);
    }

@ApiOperation(value = "银联银行卡-删除")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "id", value = "银行卡ID", required = true, dataType = "Long", dataTypeClass = Long.class),
    })
    @RequestMapping(value = "/delete", method = RequestMethod.DELETE)
    public Boolean deleteBankCard(@NotNull Long id) {
        return bankCardService.deleteBankCard(id);
    }

@ApiOperation(value = "银联银行卡-打款金额验证")
    @RequestMapping(value = "/amount_validate", method = RequestMethod.POST)
    public Boolean amountValidate(@Valid @RequestBody BankCardAmountValidateDTO bankCardAmountValidateDTO) {
        return bankCardService.amountValidate(bankCardAmountValidateDTO);
    }

@ApiOperation(value = "银联银行卡-详情")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "id", value = "银行卡ID", required = true, dataType = "Long", dataTypeClass = Long.class),
    })
    @RequestMapping(value = "/one", method = RequestMethod.GET)
    public ChinaumsBankCardDetailVO getBankCardDetail(@NotNull Long id) {
        return bankCardService.getBankCardDetail(id);
    }

@ApiOperation(value = "银联银行卡-处理")
    @RequestMapping(value = "/handle", method = RequestMethod.POST)
    public void handleChinaumsBankCard() {
        // 获取所有银联认证信息
        List<ChinaumsAuthInfo> chinaumsAuthInfoList = chinaumsAuthInfoRepository.findAll();
        for (ChinaumsAuthInfo chinaumsAuthInfo : chinaumsAuthInfoList) {
            // 审核通过的需要将银行卡信息保存到银联认证信息中
            if (chinaumsAuthInfo.getApplicationStatus().equals(ApplicationStatus.SUCCEEDED)) {
                ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard();
                chinaumsBankCard.setBankCode(chinaumsAuthInfo.getSettleAcctBankCode());
                chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode());
                chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo());
                if (StringUtils.isNotBlank(chinaumsAuthInfo.getCusApplicationId())) {
                    chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber());
                } else {
                    chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getLegalPersonMobileNumber());
                }
                chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo);
                chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo());
                chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType());
                chinaumsBankCard.setBankName(chinaumsAuthInfo.getSettleAcctBankName());
                chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId());
                chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED);
                chinaumsBankCardRepository.save(chinaumsBankCard);
            }
        }
    }
}

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

import com.yn.bftl.common.common.exception.YnceError;
import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo;
import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard;
import com.yn.bftl.common.modules.company.enums.ApplicationStatus;
import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository;
import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
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.validation.Valid;
import javax.validation.constraints.NotNull;
import java.util.List;

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/dto/byx/ByxChinaumsAcctBindBankCardDTO.java 0 → 100644
package com.yn.bftl.thirdparty.modules.chinaums.dto.byx; import com.yn.bftl.thirdparty.common.dto.BaseSecretDTO; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import lombok.EqualsAndHashCode; import javax.validation.constraints.NotBlank; /** * 银联增加银行卡DTO * * @author huabiao * @create 2023/2/15 15:08 **/ @Data @EqualsAndHashCode(callSuper = false) @ApiModel(value = "ByxChinaumsAddBankCardDTO", description = "银联增加银行卡DTO") public class ByxChinaumsAcctBindBankCardDTO extends BaseSecretDTO { @ApiModelProperty(value = "id") private Long id; @ApiModelProperty(value = "平台订单号", hidden = true) private String outRequestNo; @ApiModelProperty(value = "个人用户ID", hidden = true) private String cusId; @ApiModelProperty(value = "二级商户ID", hidden = true) private String mchId; @ApiModelProperty(value = "银行账户类型：1(\"对私银行卡\"),0(\"对公银行账户\")", required = true) @NotBlank private String bankAcctType; @ApiModelProperty(value = "开户银行名称", required = true) @NotBlank private String bankName; @ApiModelProperty(value = "开户银行编码", required = true) @NotBlank private String bankCode; @ApiModelProperty(value = "银行账户户名", required = true) @NotBlank private String bankAcctName; @ApiModelProperty(value = "开户银行联行号", required = true) @NotBlank private String bankNo; @ApiModelProperty(value = "银行账号") @NotBlank private String bankAcctNo; @ApiModelProperty(value = "职业", hidden = true) private String profession; @ApiModelProperty(value = "需要绑定的卡在银行的预留手机号(绑定时必填)") private String mobileNo; @ApiModelProperty(value = "短信验证码(如需额外验证，可调用发送短信验证码接口)") private String smsAuthCode; @ApiModelProperty(value = "电子账户 ID") private String walletId; @ApiModelProperty(value = "操作方式(1：绑定 2：绑定并设置为默认卡 3：解绑 4：设置默认卡)", hidden = true) private String oprtType; @ApiModelProperty(value = "证件编号") private String idCard; @ApiModelProperty(value = "电子联行号") private String elecBankNo; }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/dto/byx/ByxChinaumsAcctBindBankCardDTO.java 0 → 100644

package com.yn.bftl.thirdparty.modules.chinaums.dto.byx;

import com.yn.bftl.thirdparty.common.dto.BaseSecretDTO;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;

import javax.validation.constraints.NotBlank;

/**
 * 银联增加银行卡DTO
 *
 * @author huabiao
 * @create 2023/2/15  15:08
 **/
@Data
@EqualsAndHashCode(callSuper = false)
@ApiModel(value = "ByxChinaumsAddBankCardDTO", description = "银联增加银行卡DTO")
public class ByxChinaumsAcctBindBankCardDTO extends BaseSecretDTO {

@ApiModelProperty(value = "id")
    private Long id;

@ApiModelProperty(value = "平台订单号", hidden = true)
    private String outRequestNo;

@ApiModelProperty(value = "个人用户ID", hidden = true)
    private String cusId;

@ApiModelProperty(value = "二级商户ID", hidden = true)
    private String mchId;

@ApiModelProperty(value = "银行账户类型：1(\"对私银行卡\"),0(\"对公银行账户\")", required = true)
    @NotBlank
    private String bankAcctType;

@ApiModelProperty(value = "开户银行名称", required = true)
    @NotBlank
    private String bankName;

@ApiModelProperty(value = "开户银行编码", required = true)
    @NotBlank
    private String bankCode;

@ApiModelProperty(value = "银行账户户名", required = true)
    @NotBlank
    private String bankAcctName;

@ApiModelProperty(value = "开户银行联行号", required = true)
    @NotBlank
    private String bankNo;

@ApiModelProperty(value = "银行账号")
    @NotBlank
    private String bankAcctNo;

@ApiModelProperty(value = "职业", hidden = true)
    private String profession;

@ApiModelProperty(value = "需要绑定的卡在银行的预留手机号(绑定时必填)")
    private String mobileNo;

@ApiModelProperty(value = "短信验证码(如需额外验证，可调用发送短信验证码接口)")
    private String smsAuthCode;

@ApiModelProperty(value = "电子账户 ID")
    private String walletId;

@ApiModelProperty(value = "操作方式(1：绑定 2：绑定并设置为默认卡 3：解绑 4：设置默认卡)", hidden = true)
    private String oprtType;

@ApiModelProperty(value = "证件编号")
    private String idCard;

@ApiModelProperty(value = "电子联行号")
    private String elecBankNo;
}

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/dto/byx/ByxChinaumsQueryBindBankCardDTO.java 0 → 100644
package com.yn.bftl.thirdparty.modules.chinaums.dto.byx; import com.yn.bftl.thirdparty.common.dto.BaseSecretDTO; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import lombok.EqualsAndHashCode; import javax.validation.constraints.NotBlank; /** * 银联增加银行卡DTO * * @author huabiao * @create 2023/2/15 15:08 **/ @Data @EqualsAndHashCode(callSuper = false) @ApiModel(value = "ByxChinaumsQueryBindBankCardDTO", description = "查询账户银行卡DTO") public class ByxChinaumsQueryBindBankCardDTO extends BaseSecretDTO { @ApiModelProperty(value = "银行账户") @NotBlank private String bankAcctNo; @ApiModelProperty(value = "查询类型 0：绑定的银行卡 1：签约的银行卡", hidden = true) private String signBindType = "0"; @ApiModelProperty(value = "电子账户 ID") private String walletId; @ApiModelProperty(value = "签约商户号") private String signMerNo; }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/dto/byx/ByxChinaumsQueryBindBankCardDTO.java 0 → 100644

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/enums/OprtTypeEnum.java 0 → 100644
package com.yn.bftl.thirdparty.modules.chinaums.enums; import lombok.AllArgsConstructor; /** * @program: yn-byx-thirdparty * @description: 账户绑定/解绑/设置默认银行卡接口操作方式 1：绑定 2：绑定并设置为默认卡 3：解绑 4：设置默认卡 * @author: Jing * @create: 2024-08-27 17:04 **/ @AllArgsConstructor public enum OprtTypeEnum { BINDING("1", "绑定"), BIND_AND_SET_AS_DEFAULT_CARD("2", "绑定并设置为默认卡"), UNBIND("3", "解绑"), SET_DEFAULT_CARD("4", "设置默认卡"); private final String value; private final String name; public String getValue() { return this.value; } public String getName() { return this.name; } }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/enums/OprtTypeEnum.java 0 → 100644

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/service/BankCardService.java
package com.yn.bftl.thirdparty.modules.chinaums.service; import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus; import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsAcctBindBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO; import java.util.List; /** * 银联银行卡服务 * * @author huabiao * @create 2023/2/15 14:59 / public interface BankCardService { / * 银联银行卡-列表 * * @param status 银行卡状态 * @return * @description * @author yuweibin / List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status); /* * 银联银行卡-添加 * * @param byxChinaumsAcctBindBankCardDTO 银联添加银行卡DTO * @author huabiao * @create 2023/2/15 15:58 / void addBankCard(ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO); /* * 银联银行卡-删除 * * @param id 银行卡ID * @return true：删除成功；false：删除失败 * @author huabiao * @create 2023/2/20 10:29L / Boolean deleteBankCard(Long id); /* * 银联银行卡-打款验证 * * @param bankCardAmountValidateDTO 银行卡金额验证DTO * @return true：验证成功；false：验证失败 * @author huabiao * @create 2023/2/21 17:24 / Boolean amountValidate(BankCardAmountValidateDTO bankCardAmountValidateDTO); /* * 银联银行卡-详情 * * @param id 银联银行卡ID * @return 银联银行卡 * @author huabiao * @create 2023/2/22 19:41 / ChinaumsBankCardDetailVO getBankCardDetail(Long id); } package com.yn.bftl.thirdparty.modules.chinaums.service; import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus; import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO; import java.util.List; /* * 银联银行卡服务 * * @author huabiao * @create 2023/2/15 14:59 / public interface BankCardService { / * 银联银行卡-列表 * * @param status 银行卡状态 * @return * @description * @author yuweibin / List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status); /* * 银联银行卡-添加 * * @param chinaumsAddBankCardDTO 银联添加银行卡DTO * @author huabiao * @create 2023/2/15 15:58 / void addBankCard(ChinaumsAddBankCardDTO chinaumsAddBankCardDTO); /* * 银联银行卡-删除 * * @param id 银行卡ID * @return true：删除成功；false：删除失败 * @author huabiao * @create 2023/2/20 10:29L / Boolean deleteBankCard(Long id); /* * 银联银行卡-打款验证 * * @param bankCardAmountValidateDTO 银行卡金额验证DTO * @return true：验证成功；false：验证失败 * @author huabiao * @create 2023/2/21 17:24 / Boolean amountValidate(BankCardAmountValidateDTO bankCardAmountValidateDTO); /* * 银联银行卡-详情 * * @param id 银联银行卡ID * @return 银联银行卡 * @author huabiao * @create 2023/2/22 19:41 */ ChinaumsBankCardDetailVO getBankCardDetail(Long id); }

Ignore Space Show notes View

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

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

import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus;
import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsAcctBindBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO;

import java.util.List;

/**
 * 银联银行卡服务
 *
 * @author huabiao
 * @create 2023/2/15  14:59
 **/
public interface BankCardService {

/**
     * 银联银行卡-列表
     *
     * @param status 银行卡状态
     * @return
     * @description
     * @author yuweibin
     */
    List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status);

/**
     * 银联银行卡-添加
     *
     * @param byxChinaumsAcctBindBankCardDTO 银联添加银行卡DTO
     * @author huabiao
     * @create 2023/2/15  15:58
     */
    void addBankCard(ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO);

/**
     * 银联银行卡-删除
     *
     * @param id 银行卡ID
     * @return true：删除成功；false：删除失败
     * @author huabiao
     * @create 2023/2/20  10:29L
     */
    Boolean deleteBankCard(Long id);

/**
     * 银联银行卡-打款验证
     *
     * @param bankCardAmountValidateDTO 银行卡金额验证DTO
     * @return true：验证成功；false：验证失败
     * @author huabiao
     * @create 2023/2/21  17:24
     */
    Boolean amountValidate(BankCardAmountValidateDTO bankCardAmountValidateDTO);

/**
     * 银联银行卡-详情
     *
     * @param id 银联银行卡ID
     * @return 银联银行卡
     * @author huabiao
     * @create 2023/2/22  19:41
     */
    ChinaumsBankCardDetailVO getBankCardDetail(Long id);
}

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

import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus;
import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO;

import java.util.List;

/**
 * 银联银行卡服务
 *
 * @author huabiao
 * @create 2023/2/15  14:59
 **/
public interface BankCardService {

/**
     * 银联银行卡-添加
     *
     * @param chinaumsAddBankCardDTO 银联添加银行卡DTO
     * @author huabiao
     * @create 2023/2/15  15:58
     */
    void addBankCard(ChinaumsAddBankCardDTO chinaumsAddBankCardDTO);

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/service/ToolService.java
package com.yn.bftl.thirdparty.modules.chinaums.service; import com.alibaba.fastjson.JSONObject; import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsPostDTO; import com.yn.bftl.thirdparty.modules.chinaums.vo.BankLineNumberVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsImageVO; import org.springframework.data.domain.Page; import org.springframework.data.domain.Pageable; import org.springframework.web.multipart.MultipartFile; import java.math.BigDecimal; import java.time.LocalDate; /** * 银联工具服务 * * @author huabiao * @create 2022/12/6 18:25 / public interface ToolService { / * 银联-图片上传 * * @param file :文件 * @param type * @return 银联图片VO * @author huabiao * @create 2022/12/6 9:57 / ChinaumsImageVO uploadImage(MultipartFile file, String type); /* * 银行-列表查询 * * @param keyword:关键字 * @return 银行列表 * @author huabiao * @create 2022/12/6 18:44 / Page<BankLineNumberVO> getBankList(String keyword, Pageable pageable); /* * 打款金额验证 * * @param amount:打款金额 * @return TRUE:正确,FALSE:不正确 * @description * @author huabiao * @create 2022/12/7 11:34 / Boolean amountValidate(BigDecimal amount); /* * 银联-发送验证码 * * @param mobile :手机号 * @author huabiao * @create 2022/12/7 13:45 / void smsCodes(String mobile); /* * 获取平台对账单下载接口 * * @param billDate * @return / String tradeBills(LocalDate billDate); /* * 重置支付密码-发送验证码 * * @author huabiao * @create 2023/3/2 16:04 / void smsCodesForResetPassword(); /* * 银联调用 * * @param chinaumsPostDTO 请求参数 * @author huabiao * @create 2023/4/3 16:06 / JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO); } package com.yn.bftl.thirdparty.modules.chinaums.service; import com.alibaba.fastjson.JSONObject; import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsPostDTO; import com.yn.bftl.thirdparty.modules.chinaums.vo.BankLineNumberVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsImageVO; import org.springframework.data.domain.Page; import org.springframework.data.domain.Pageable; import org.springframework.web.multipart.MultipartFile; import java.math.BigDecimal; import java.time.LocalDate; /* * 银联工具服务 * * @author huabiao * @create 2022/12/6 18:25 / public interface ToolService { / * 银联-图片上传 * * @param file :文件 * @param type * @return 银联图片VO * @author huabiao * @create 2022/12/6 9:57 / ChinaumsImageVO uploadImage(MultipartFile file, String type); /* * 银行-列表查询 * * @param keyword:关键字 * @return 银行列表 * @author huabiao * @create 2022/12/6 18:44 / Page<BankLineNumberVO> getBankList(String keyword, Pageable pageable); /* * 打款金额验证 * * @param amount:打款金额 * @return TRUE:正确,FALSE:不正确 * @description * @author huabiao * @create 2022/12/7 11:34 / Boolean amountValidate(BigDecimal amount); /* * 银联-发送验证码 * * @param mobile:手机号 * @author huabiao * @create 2022/12/7 13:45 / void smsCodes(String mobile); /* * 获取平台对账单下载接口 * * @param billDate * @return / String tradeBills(LocalDate billDate); /* * 重置支付密码-发送验证码 * * @author huabiao * @create 2023/3/2 16:04 / void smsCodesForResetPassword(); /* * 银联调用 * * @param chinaumsPostDTO 请求参数 * @author huabiao * @create 2023/4/3 16:06 */ JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO); }

Ignore Space Show notes View

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

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

import com.alibaba.fastjson.JSONObject;
import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsPostDTO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.BankLineNumberVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsImageVO;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.web.multipart.MultipartFile;

import java.math.BigDecimal;
import java.time.LocalDate;

/**
 * 银联工具服务
 *
 * @author huabiao
 * @create 2022/12/6  18:25
 **/
public interface ToolService {

/**
     * 银联-图片上传
     *
     * @param file :文件
     * @param type
     * @return 银联图片VO
     * @author huabiao
     * @create 2022/12/6  9:57
     */
    ChinaumsImageVO uploadImage(MultipartFile file, String type);

/**
     * 银行-列表查询
     *
     * @param keyword:关键字
     * @return 银行列表
     * @author huabiao
     * @create 2022/12/6  18:44
     */
    Page<BankLineNumberVO> getBankList(String keyword, Pageable pageable);

/**
     * 打款金额验证
     *
     * @param amount:打款金额
     * @return TRUE:正确,FALSE:不正确
     * @description
     * @author huabiao
     * @create 2022/12/7  11:34
     */
    Boolean amountValidate(BigDecimal amount);

/**
     * 银联-发送验证码
     *
     * @param mobile :手机号
     * @author huabiao
     * @create 2022/12/7  13:45
     */
    void smsCodes(String mobile);

/**
     * 获取平台对账单下载接口
     *
     * @param billDate
     * @return
     */
    String tradeBills(LocalDate billDate);

/**
     * 重置支付密码-发送验证码
     *
     * @author huabiao
     * @create 2023/3/2  16:04
     */
    void smsCodesForResetPassword();

/**
     * 银联调用
     *
     * @param chinaumsPostDTO 请求参数
     * @author huabiao
     * @create 2023/4/3  16:06
     */
    JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO);
}

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

import java.math.BigDecimal;
import java.time.LocalDate;

/**
 * 银联工具服务
 *
 * @author huabiao
 * @create 2022/12/6  18:25
 **/
public interface ToolService {

/**
     * 银联-发送验证码
     *
     * @param mobile:手机号
     * @author huabiao
     * @create 2022/12/7  13:45
     */
    void smsCodes(String mobile);

/**
     * 获取平台对账单下载接口
     *
     * @param billDate
     * @return
     */
    String tradeBills(LocalDate billDate);

/**
     * 重置支付密码-发送验证码
     *
     * @author huabiao
     * @create 2023/3/2  16:04
     */
    void smsCodesForResetPassword();

/**
     * 银联调用
     *
     * @param chinaumsPostDTO 请求参数
     * @author huabiao
     * @create 2023/4/3  16:06
     */
    JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO);
}

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/service/impl/BankCardServiceImpl.java
package com.yn.bftl.thirdparty.modules.chinaums.service.impl; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; import com.yn.bftl.common.common.exception.YnceError; import com.yn.bftl.common.common.util.ByxRouteUtil; import com.yn.bftl.common.common.util.RouteUtil; import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo; import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard; import com.yn.bftl.common.modules.company.entity.Company; import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus; import com.yn.bftl.thirdparty.common.constants.Constant; import com.yn.bftl.thirdparty.common.dto.BaseResponseDTO; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.service.BaseMemberService; import com.yn.bftl.thirdparty.common.util.SequenceUtil; import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsAcctBindBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsQueryBindBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate; import com.yn.bftl.thirdparty.modules.chinaums.enums.OprtTypeEnum; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository; import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService; import com.yn.bftl.thirdparty.modules.chinaums.util.ByxChinaumsUtil; import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.chinaums.ChinaumsAddBankCardVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxChinaumsQueryBindBankCardVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.byx.QueryBindBankRow; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.validation.constraints.NotNull; import java.math.BigDecimal; import java.util.ArrayList; import java.util.List; /** * 银行卡服务实现类 * * @author huabiao * @create 2023/2/15 14:59 / @Service public class BankCardServiceImpl extends BaseMemberService implements BankCardService { @Resource private ChinaumsBankCardRepository chinaumsBankCardRepository; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private ChinaumsUtil chinaumsUtil; @Resource private ByxChinaumsUtil byxChinaumsUtil; @Resource private SequenceUtil sequenceUtil; @Override public List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status) { List<ChinaumsBankCardVO> chinaumsBankCardVOList = new ArrayList<>(); Company company = getUser().getCompany(); if (company != null && company.getChinaumsAuthInfo() != null) { ChinaumsAuthInfo chinaumsAuthInfo = company.getChinaumsAuthInfo(); if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard())) { // List<Long> chinaumsBankCardIdList = chinaumsAuthInfo.getChinaumsBankCard().stream().filter(chinaumsBankCard -> chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.PROCESSING)).map(ChinaumsBankCard::getId).collect(Collectors.toList()); // if (CollectionUtils.isNotEmpty(chinaumsBankCardIdList)) { // for (Long chinaumsBankCardId : chinaumsBankCardIdList) { // handleBankCardStatus(chinaumsBankCardRepository.findById(chinaumsBankCardId).orElse(null)); // } // } // 获取银联的已绑定银行卡列表 List<String> bankAcctNoList = queryBindBankCard(chinaumsAuthInfo.getBalanceAcctId()); for (ChinaumsBankCard chinaumsBankCard : chinaumsAuthInfo.getChinaumsBankCard()) { // 不在银联接口返回的银行卡不显示 if ((status == null \|\| chinaumsBankCard.getStatus().equals(status) && bankAcctNoList.contains(chinaumsBankCard.getBankAcctNo()))) { ChinaumsBankCardVO chinaumsBankCardVO = new ChinaumsBankCardVO(); chinaumsBankCardVO.setId(chinaumsBankCard.getId()); chinaumsBankCardVO.setBankName(chinaumsBankCard.getBankName()); chinaumsBankCardVO.setBankAcctNo(chinaumsBankCard.getBankAcctNo()); chinaumsBankCardVO.setStatus(chinaumsBankCard.getStatus()); chinaumsBankCardVO.setFailureMsg(chinaumsBankCard.getAcctValidationFailureMsg()); chinaumsBankCardVOList.add(chinaumsBankCardVO); } } } } return chinaumsBankCardVOList; } / * 查询账户银行卡列表 * @param balanceAcctId * @return / private List<String> queryBindBankCard(String balanceAcctId) { List<String> bankAcctNoList = new ArrayList<>(); if (ObjectUtil.isEmpty(balanceAcctId)) { return bankAcctNoList; } ByxChinaumsQueryBindBankCardDTO byxChinaumsQueryBindBankCardDTO = new ByxChinaumsQueryBindBankCardDTO(); byxChinaumsQueryBindBankCardDTO.setWalletId(balanceAcctId); ByxChinaumsQueryBindBankCardVO chinaumsQueryBindBankCardVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS_BY_ACCT_NO, (JSONObject) JSONObject.toJSON(byxChinaumsQueryBindBankCardDTO), ByxChinaumsQueryBindBankCardVO.class); if(ObjectUtil.isNotNull(chinaumsQueryBindBankCardVO)&&ObjectUtil.isNotEmpty(chinaumsQueryBindBankCardVO.getRowList())){ for (QueryBindBankRow queryBindBankRow:chinaumsQueryBindBankCardVO.getRowList()){ bankAcctNoList.add(queryBindBankRow.getBankAcctNo()); } } return bankAcctNoList; } @Override @Transactional(rollbackFor = Exception.class) public void addBankCard(ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO) { Company company = getUser().getCompany(); if (company == null) { throw new YnceErrorException(YnceError.YNCE_201009); } ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(company.getId()); if (chinaumsAuthInfo == null) { throw new YnceErrorException(YnceError.YNCE_218009); } if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().size() >= 10) { throw new YnceErrorException(YnceError.YNCE_218027); } // 赋值银行卡 ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard(); if (byxChinaumsAcctBindBankCardDTO.getId() != null) { chinaumsBankCard = chinaumsBankCardRepository.findById(byxChinaumsAcctBindBankCardDTO.getId()).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } // byxChinaumsAcctBindBankCardDTO.setOutRequestNo(chinaumsBankCard.getOutRequestNo()); } else { // 判断该银行卡号是否存在当前用户列表中 if(CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().stream().anyMatch(filterChinaumsBankCard -> filterChinaumsBankCard.getBankAcctNo().equals(byxChinaumsAcctBindBankCardDTO.getBankAcctNo()))){ throw new YnceErrorException(YnceError.YNCE_218029); } chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo); chinaumsBankCard.setBankCode(chinaumsAuthInfo.getSettleAcctBankCode()); chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode()); chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo()); chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber()); chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo); chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo()); chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType()); chinaumsBankCard.setBankName(chinaumsAuthInfo.getSettleAcctBankName()); chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId()); // byxChinaumsAcctBindBankCardDTO.setOutRequestNo(sequenceUtil.getNextSequenceNumber("YHK")); // byxChinaumsAcctBindBankCardDTO.setProfession("40100"); } BeanUtils.copyProperties(byxChinaumsAcctBindBankCardDTO, chinaumsBankCard); byxChinaumsAcctBindBankCardDTO.setCusId(chinaumsAuthInfo.getCusId()); byxChinaumsAcctBindBankCardDTO.setMchId(chinaumsAuthInfo.getMchId()); try { // 银行账户 byxChinaumsAcctBindBankCardDTO.setBankAcctNo(chinaumsBankCard.getBankAcctNo()); // 手机号 byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsBankCard.getMobileNumber()); } catch (Exception exception) { throw new YnceErrorException(YnceError.YNCE_218014); } BaseResponseDTO baseResponseDTO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseDTO.class); // 绑定后根据返回的状态码更新状态 if(Constant.RETURN_SUCCESS_CODE.equals(baseResponseDTO.getRspCode())){ chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED); chinaumsAuthInfo.setBankCardNo(byxChinaumsAcctBindBankCardDTO.getBankAcctNo()); chinaumsAuthInfo.setBindAcctName(byxChinaumsAcctBindBankCardDTO.getBankAcctName()); chinaumsAuthInfoRepository.save(chinaumsAuthInfo); } else { chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED); chinaumsBankCard.setAcctValidationFailureMsg(baseResponseDTO.getRspResult()); } chinaumsBankCardRepository.save(chinaumsBankCard); // chinaumsBankCard.setOutRequestNo(chinaumsAddBankCardVO.getOutRequestNo()); // chinaumsBankCard.setSettleAcctId(chinaumsAddBankCardVO.getSettleAcctId()); // handleBankCardStatus(chinaumsBankCard); } @Override @Transactional(rollbackFor = Exception.class) public Boolean deleteBankCard(@NotNull Long id) { ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(id).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } List<ChinaumsBankCardVO> chinaumsBankCardVOList = this.bankCardList(null); if (CollectionUtils.isNotEmpty(chinaumsBankCardVOList) && chinaumsBankCardVOList.stream().filter(chinaumsBankCardVO -> chinaumsBankCardVO.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)).count() == 1) { throw new YnceErrorException(YnceError.YNCE_218024); } if (!chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)) { throw new YnceErrorException(YnceError.YNCE_218025); } if(chinaumsBankCard.getBankAcctNo().equals(chinaumsBankCard.getChinaumsAuthInfo().getSettleAcctBankAcctNo())){ throw new YnceErrorException(YnceError.YNCE_218025.getStatus(),YnceError.YNCE_218025.getMsg() + "认证绑定的卡不允许解绑"); } // ChinaumsDeleteBankCardDTO chinaumsDeleteBankCardDTO = ChinaumsDeleteBankCardDTO.builder().settleAcctId(chinaumsBankCard.getSettleAcctId()).build(); ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO = new ByxChinaumsAcctBindBankCardDTO(); byxChinaumsAcctBindBankCardDTO.setWalletId(chinaumsBankCard.getChinaumsAuthInfo().getBalanceAcctId()); byxChinaumsAcctBindBankCardDTO.setOprtType(OprtTypeEnum.UNBIND.getValue()); BaseResponseDTO baseResponseDTO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseDTO.class); if (Constant.RETURN_SUCCESS_CODE.equals(baseResponseDTO.getRspCode()) ) { List<ChinaumsBankCard> chinaumsBankCardList = chinaumsBankCard.getChinaumsAuthInfo().getChinaumsBankCard(); chinaumsBankCardList.removeIf(deleteChinaumsBankCard -> deleteChinaumsBankCard.getId().equals(id)); chinaumsBankCard.setChinaumsAuthInfo(null); chinaumsBankCardRepository.delete(chinaumsBankCard); return true; } else { return false; } } @Override @Transactional(rollbackFor = Exception.class) public Boolean amountValidate(BankCardAmountValidateDTO bankCardAmountValidateDTO) { ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(bankCardAmountValidateDTO.getId()).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } if (chinaumsBankCard.getBankAcctType().equals("1")) { throw new YnceErrorException(YnceError.YNCE_218026); } ChinaumsAmountValidate chinaumsAmountValidate = ChinaumsAmountValidate .builder() .settleAcctId(chinaumsBankCard.getSettleAcctId()) .payAmount(bankCardAmountValidateDTO.getAmount().multiply(new BigDecimal(100)).intValue()) .build(); chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_ACCTS_VALIDATE, (JSONObject) JSONObject.toJSON(chinaumsAmountValidate), null); return true; } @Override public ChinaumsBankCardDetailVO getBankCardDetail(Long id) { ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(id).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } ChinaumsBankCardDetailVO chinaumsBankCardDetailVO = new ChinaumsBankCardDetailVO(); BeanUtils.copyProperties(chinaumsBankCard, chinaumsBankCardDetailVO); return chinaumsBankCardDetailVO; } /* * 处理银联银行卡状态 * * @param chinaumsBankCard 银联银行卡 * @author huabiao * @create 2023/2/20 16:12 / private void handleBankCardStatus(ChinaumsBankCard chinaumsBankCard) { if (chinaumsBankCard == null) { return; } JSONObject jsonObject = new JSONObject(); jsonObject.put("settleAcctId", chinaumsBankCard.getSettleAcctId()); ChinaumsAddBankCardVO chinaumsAddBankCardVO = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS_BY_ACCT_NO, (JSONObject) JSONObject.toJSON(jsonObject), ChinaumsAddBankCardVO.class); // 查询完状态后需要将银联银行卡信息中的状态更新 switch (chinaumsAddBankCardVO.getVerifyStatus()) { case "processing": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.PROCESSING); break; case "needless": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.NEEDLESS); break; case "blocked": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.BLOCKED); break; case "succeeded": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED); break; case "failed": chinaumsBankCard.setAcctValidationFailureMsg(chinaumsAddBankCardVO.getAcctValidationFailureMsg()); chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED); break; } chinaumsBankCardRepository.save(chinaumsBankCard); } } package com.yn.bftl.thirdparty.modules.chinaums.service.impl; import com.alibaba.fastjson.JSONObject; import com.yn.bftl.common.common.exception.YnceError; import com.yn.bftl.common.common.util.RSAEncryptorUtil; import com.yn.bftl.common.common.util.RouteUtil; import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo; import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard; import com.yn.bftl.common.modules.company.entity.Company; import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.service.BaseMemberService; import com.yn.bftl.thirdparty.common.util.SequenceUtil; import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsDeleteBankCardDTO; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository; import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService; import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.chinaums.ChinaumsAddBankCardVO; import org.apache.commons.collections.CollectionUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.validation.constraints.NotNull; import java.math.BigDecimal; import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; /* * 银行卡服务实现类 * * @author huabiao * @create 2023/2/15 14:59 / @Service public class BankCardServiceImpl extends BaseMemberService implements BankCardService { @Resource private ChinaumsBankCardRepository chinaumsBankCardRepository; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private ChinaumsUtil chinaumsUtil; @Resource private SequenceUtil sequenceUtil; @Override public List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status) { List<ChinaumsBankCardVO> chinaumsBankCardVOList = new ArrayList<>(); Company company = getUser().getCompany(); if (company != null && company.getChinaumsAuthInfo() != null) { ChinaumsAuthInfo chinaumsAuthInfo = company.getChinaumsAuthInfo(); if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard())) { List<Long> chinaumsBankCardIdList = chinaumsAuthInfo.getChinaumsBankCard().stream().filter(chinaumsBankCard -> chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.PROCESSING)).map(ChinaumsBankCard::getId).collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(chinaumsBankCardIdList)) { for (Long chinaumsBankCardId : chinaumsBankCardIdList) { handleBankCardStatus(chinaumsBankCardRepository.findById(chinaumsBankCardId).orElse(null)); } } for (ChinaumsBankCard chinaumsBankCard : chinaumsAuthInfo.getChinaumsBankCard()) { if (status == null \|\| chinaumsBankCard.getStatus().equals(status)) { ChinaumsBankCardVO chinaumsBankCardVO = new ChinaumsBankCardVO(); chinaumsBankCardVO.setId(chinaumsBankCard.getId()); chinaumsBankCardVO.setBankName(chinaumsBankCard.getBankName()); chinaumsBankCardVO.setBankAcctNo(chinaumsBankCard.getBankAcctNo()); chinaumsBankCardVO.setStatus(chinaumsBankCard.getStatus()); chinaumsBankCardVO.setFailureMsg(chinaumsBankCard.getAcctValidationFailureMsg()); chinaumsBankCardVOList.add(chinaumsBankCardVO); } } } } return chinaumsBankCardVOList; } @Override @Transactional(rollbackFor = Exception.class) public void addBankCard(ChinaumsAddBankCardDTO chinaumsAddBankCardDTO) { Company company = getUser().getCompany(); if (company == null) { throw new YnceErrorException(YnceError.YNCE_201009); } ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(company.getId()); if (chinaumsAuthInfo == null) { throw new YnceErrorException(YnceError.YNCE_218009); } if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().size() >= 10) { throw new YnceErrorException(YnceError.YNCE_218027); } // 赋值银行卡 ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard(); if (chinaumsAddBankCardDTO.getId() != null) { chinaumsBankCard = chinaumsBankCardRepository.findById(chinaumsAddBankCardDTO.getId()).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } chinaumsAddBankCardDTO.setOutRequestNo(chinaumsBankCard.getOutRequestNo()); } else { // 判断该银行卡号是否存在当前用户列表中 if(CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().stream().filter(filterChinaumsBankCard -> filterChinaumsBankCard.getBankAcctNo().equals(chinaumsAddBankCardDTO.getBankAcctNo())).findFirst().isPresent()){ throw new YnceErrorException(YnceError.YNCE_218029); } chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo); chinaumsAddBankCardDTO.setOutRequestNo(sequenceUtil.getNextSequenceNumber("YHK")); chinaumsAddBankCardDTO.setProfession("40100"); } BeanUtils.copyProperties(chinaumsAddBankCardDTO, chinaumsBankCard); chinaumsAddBankCardDTO.setCusId(chinaumsAuthInfo.getCusId()); chinaumsAddBankCardDTO.setMchId(chinaumsAuthInfo.getMchId()); // 对敏感信息加密处理 String publicKey = chinaumsUtil.getPublicKey(); try { // 银行账户 chinaumsAddBankCardDTO.setBankAcctNo(RSAEncryptorUtil.encryptByPublicKey(chinaumsBankCard.getBankAcctNo(), publicKey)); // 手机号 chinaumsAddBankCardDTO.setMobileNumber(RSAEncryptorUtil.encryptByPublicKey(chinaumsBankCard.getMobileNumber(), publicKey)); } catch (Exception exception) { throw new YnceErrorException(YnceError.YNCE_218014); } ChinaumsAddBankCardVO chinaumsAddBankCardVO = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS, (JSONObject) JSONObject.toJSON(chinaumsAddBankCardDTO), ChinaumsAddBankCardVO.class); chinaumsBankCard.setOutRequestNo(chinaumsAddBankCardVO.getOutRequestNo()); chinaumsBankCard.setSettleAcctId(chinaumsAddBankCardVO.getSettleAcctId()); handleBankCardStatus(chinaumsBankCard); } @Override @Transactional(rollbackFor = Exception.class) public Boolean deleteBankCard(@NotNull Long id) { ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(id).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } List<ChinaumsBankCardVO> chinaumsBankCardVOList = this.bankCardList(null); if (CollectionUtils.isNotEmpty(chinaumsBankCardVOList) && chinaumsBankCardVOList.stream().filter(chinaumsBankCardVO -> chinaumsBankCardVO.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)).count() == 1) { throw new YnceErrorException(YnceError.YNCE_218024); } if (!chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)) { throw new YnceErrorException(YnceError.YNCE_218025); } if(chinaumsBankCard.getBankAcctNo().equals(chinaumsBankCard.getChinaumsAuthInfo().getSettleAcctBankAcctNo())){ throw new YnceErrorException(YnceError.YNCE_218025.getStatus(),YnceError.YNCE_218025.getMsg() + "认证绑定的卡不允许解绑"); } ChinaumsDeleteBankCardDTO chinaumsDeleteBankCardDTO = ChinaumsDeleteBankCardDTO.builder().settleAcctId(chinaumsBankCard.getSettleAcctId()).build(); JSONObject jsonObject = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS_DEL, (JSONObject) JSONObject.toJSON(chinaumsDeleteBankCardDTO), JSONObject.class); if (jsonObject.get("isDeleted").toString().equals("true")) { List<ChinaumsBankCard> chinaumsBankCardList = chinaumsBankCard.getChinaumsAuthInfo().getChinaumsBankCard(); chinaumsBankCardList.removeIf(deleteChinaumsBankCard -> deleteChinaumsBankCard.getId().equals(id)); chinaumsBankCard.setChinaumsAuthInfo(null); chinaumsBankCardRepository.delete(chinaumsBankCard); return true; } else { return false; } } @Override @Transactional(rollbackFor = Exception.class) public Boolean amountValidate(BankCardAmountValidateDTO bankCardAmountValidateDTO) { ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(bankCardAmountValidateDTO.getId()).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } if (chinaumsBankCard.getBankAcctType().equals("1")) { throw new YnceErrorException(YnceError.YNCE_218026); } ChinaumsAmountValidate chinaumsAmountValidate = ChinaumsAmountValidate .builder() .settleAcctId(chinaumsBankCard.getSettleAcctId()) .payAmount(bankCardAmountValidateDTO.getAmount().multiply(new BigDecimal(100)).intValue()) .build(); chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_ACCTS_VALIDATE, (JSONObject) JSONObject.toJSON(chinaumsAmountValidate), null); return true; } @Override public ChinaumsBankCardDetailVO getBankCardDetail(Long id) { ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(id).orElse(null); if (chinaumsBankCard == null) { throw new YnceErrorException(YnceError.YNCE_218023); } ChinaumsBankCardDetailVO chinaumsBankCardDetailVO = new ChinaumsBankCardDetailVO(); BeanUtils.copyProperties(chinaumsBankCard, chinaumsBankCardDetailVO); return chinaumsBankCardDetailVO; } / * 处理银联银行卡状态 * * @param chinaumsBankCard 银联银行卡 * @author huabiao * @create 2023/2/20 16:12 */ private void handleBankCardStatus(ChinaumsBankCard chinaumsBankCard) { if (chinaumsBankCard == null) { return; } JSONObject jsonObject = new JSONObject(); jsonObject.put("settleAcctId", chinaumsBankCard.getSettleAcctId()); ChinaumsAddBankCardVO chinaumsAddBankCardVO = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS_BY_ACCT_NO, (JSONObject) JSONObject.toJSON(jsonObject), ChinaumsAddBankCardVO.class); // 查询完状态后需要将银联银行卡信息中的状态更新 switch (chinaumsAddBankCardVO.getVerifyStatus()) { case "processing": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.PROCESSING); break; case "needless": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.NEEDLESS); break; case "blocked": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.BLOCKED); break; case "succeeded": chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED); break; case "failed": chinaumsBankCard.setAcctValidationFailureMsg(chinaumsAddBankCardVO.getAcctValidationFailureMsg()); chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED); break; } chinaumsBankCardRepository.save(chinaumsBankCard); } }

Ignore Space Show notes View

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

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

import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSONObject;
import com.yn.bftl.common.common.exception.YnceError;
import com.yn.bftl.common.common.util.ByxRouteUtil;
import com.yn.bftl.common.common.util.RouteUtil;
import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo;
import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard;
import com.yn.bftl.common.modules.company.entity.Company;
import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus;
import com.yn.bftl.thirdparty.common.constants.Constant;
import com.yn.bftl.thirdparty.common.dto.BaseResponseDTO;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.service.BaseMemberService;
import com.yn.bftl.thirdparty.common.util.SequenceUtil;
import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsAcctBindBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxChinaumsQueryBindBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate;
import com.yn.bftl.thirdparty.modules.chinaums.enums.OprtTypeEnum;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository;
import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService;
import com.yn.bftl.thirdparty.modules.chinaums.util.ByxChinaumsUtil;
import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.chinaums.ChinaumsAddBankCardVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxChinaumsQueryBindBankCardVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.byx.QueryBindBankRow;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import javax.validation.constraints.NotNull;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;

/**
 * 银行卡服务实现类
 *
 * @author huabiao
 * @create 2023/2/15  14:59
 **/
@Service
public class BankCardServiceImpl extends BaseMemberService implements BankCardService {

@Resource
    private ChinaumsBankCardRepository chinaumsBankCardRepository;
    @Resource
    private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository;
    @Resource
    private ChinaumsUtil chinaumsUtil;
    @Resource
    private ByxChinaumsUtil byxChinaumsUtil;
    @Resource
    private SequenceUtil sequenceUtil;

@Override
    public List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status) {
        List<ChinaumsBankCardVO> chinaumsBankCardVOList = new ArrayList<>();
        Company company = getUser().getCompany();
        if (company != null && company.getChinaumsAuthInfo() != null) {
            ChinaumsAuthInfo chinaumsAuthInfo = company.getChinaumsAuthInfo();
            if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard())) {
//                List<Long> chinaumsBankCardIdList = chinaumsAuthInfo.getChinaumsBankCard().stream().filter(chinaumsBankCard -> chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.PROCESSING)).map(ChinaumsBankCard::getId).collect(Collectors.toList());
//                if (CollectionUtils.isNotEmpty(chinaumsBankCardIdList)) {
//                    for (Long chinaumsBankCardId : chinaumsBankCardIdList) {
//                        handleBankCardStatus(chinaumsBankCardRepository.findById(chinaumsBankCardId).orElse(null));
//                    }
//                }
                // 获取银联的已绑定银行卡列表
                List<String> bankAcctNoList = queryBindBankCard(chinaumsAuthInfo.getBalanceAcctId());
                for (ChinaumsBankCard chinaumsBankCard : chinaumsAuthInfo.getChinaumsBankCard()) {
                    // 不在银联接口返回的银行卡不显示
                    if ((status == null || chinaumsBankCard.getStatus().equals(status) && bankAcctNoList.contains(chinaumsBankCard.getBankAcctNo()))) {
                        ChinaumsBankCardVO chinaumsBankCardVO = new ChinaumsBankCardVO();
                        chinaumsBankCardVO.setId(chinaumsBankCard.getId());
                        chinaumsBankCardVO.setBankName(chinaumsBankCard.getBankName());
                        chinaumsBankCardVO.setBankAcctNo(chinaumsBankCard.getBankAcctNo());
                        chinaumsBankCardVO.setStatus(chinaumsBankCard.getStatus());
                        chinaumsBankCardVO.setFailureMsg(chinaumsBankCard.getAcctValidationFailureMsg());
                        chinaumsBankCardVOList.add(chinaumsBankCardVO);
                    }
                }
            }
        }
        return chinaumsBankCardVOList;
    }

/**
     * 查询账户银行卡列表
     * @param balanceAcctId
     * @return
     */
    private List<String> queryBindBankCard(String balanceAcctId) {
        List<String> bankAcctNoList = new ArrayList<>();
        if (ObjectUtil.isEmpty(balanceAcctId)) {
            return bankAcctNoList;
        }
        ByxChinaumsQueryBindBankCardDTO byxChinaumsQueryBindBankCardDTO = new ByxChinaumsQueryBindBankCardDTO();
        byxChinaumsQueryBindBankCardDTO.setWalletId(balanceAcctId);

ByxChinaumsQueryBindBankCardVO chinaumsQueryBindBankCardVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS_BY_ACCT_NO, (JSONObject) JSONObject.toJSON(byxChinaumsQueryBindBankCardDTO), ByxChinaumsQueryBindBankCardVO.class);

if(ObjectUtil.isNotNull(chinaumsQueryBindBankCardVO)&&ObjectUtil.isNotEmpty(chinaumsQueryBindBankCardVO.getRowList())){
            for (QueryBindBankRow queryBindBankRow:chinaumsQueryBindBankCardVO.getRowList()){
                bankAcctNoList.add(queryBindBankRow.getBankAcctNo());
            }
        }
        return bankAcctNoList;
    }

@Override
    @Transactional(rollbackFor = Exception.class)
    public void addBankCard(ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO) {
        Company company = getUser().getCompany();
        if (company == null) {
            throw new YnceErrorException(YnceError.YNCE_201009);
        }
        ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(company.getId());
        if (chinaumsAuthInfo == null) {
            throw new YnceErrorException(YnceError.YNCE_218009);
        }
        if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().size() >= 10) {
            throw new YnceErrorException(YnceError.YNCE_218027);
        }
        // 赋值银行卡
        ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard();
        if (byxChinaumsAcctBindBankCardDTO.getId() != null) {
            chinaumsBankCard = chinaumsBankCardRepository.findById(byxChinaumsAcctBindBankCardDTO.getId()).orElse(null);
            if (chinaumsBankCard == null) {
                throw new YnceErrorException(YnceError.YNCE_218023);
            }
//            byxChinaumsAcctBindBankCardDTO.setOutRequestNo(chinaumsBankCard.getOutRequestNo());
        } else {
            // 判断该银行卡号是否存在当前用户列表中
            if(CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().stream().anyMatch(filterChinaumsBankCard -> filterChinaumsBankCard.getBankAcctNo().equals(byxChinaumsAcctBindBankCardDTO.getBankAcctNo()))){
                throw new YnceErrorException(YnceError.YNCE_218029);
            }
            chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo);
            chinaumsBankCard.setBankCode(chinaumsAuthInfo.getSettleAcctBankCode());
            chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode());
            chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo());
            chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber());
            chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo);
            chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo());
            chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType());
            chinaumsBankCard.setBankName(chinaumsAuthInfo.getSettleAcctBankName());
            chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId());
//            byxChinaumsAcctBindBankCardDTO.setOutRequestNo(sequenceUtil.getNextSequenceNumber("YHK"));
//            byxChinaumsAcctBindBankCardDTO.setProfession("40100");
        }
        BeanUtils.copyProperties(byxChinaumsAcctBindBankCardDTO, chinaumsBankCard);
        byxChinaumsAcctBindBankCardDTO.setCusId(chinaumsAuthInfo.getCusId());
        byxChinaumsAcctBindBankCardDTO.setMchId(chinaumsAuthInfo.getMchId());

try {
            // 银行账户
            byxChinaumsAcctBindBankCardDTO.setBankAcctNo(chinaumsBankCard.getBankAcctNo());
            // 手机号
            byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsBankCard.getMobileNumber());
        } catch (Exception exception) {
            throw new YnceErrorException(YnceError.YNCE_218014);
        }
        BaseResponseDTO baseResponseDTO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseDTO.class);
        // 绑定后根据返回的状态码更新状态
        if(Constant.RETURN_SUCCESS_CODE.equals(baseResponseDTO.getRspCode())){
            chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED);

chinaumsAuthInfo.setBankCardNo(byxChinaumsAcctBindBankCardDTO.getBankAcctNo());
            chinaumsAuthInfo.setBindAcctName(byxChinaumsAcctBindBankCardDTO.getBankAcctName());
            chinaumsAuthInfoRepository.save(chinaumsAuthInfo);
        }
        else {
            chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED);
            chinaumsBankCard.setAcctValidationFailureMsg(baseResponseDTO.getRspResult());
        }
        chinaumsBankCardRepository.save(chinaumsBankCard);
//        chinaumsBankCard.setOutRequestNo(chinaumsAddBankCardVO.getOutRequestNo());
//        chinaumsBankCard.setSettleAcctId(chinaumsAddBankCardVO.getSettleAcctId());
//        handleBankCardStatus(chinaumsBankCard);
    }

@Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean deleteBankCard(@NotNull Long id) {
        ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(id).orElse(null);
        if (chinaumsBankCard == null) {
            throw new YnceErrorException(YnceError.YNCE_218023);
        }
        List<ChinaumsBankCardVO> chinaumsBankCardVOList = this.bankCardList(null);
        if (CollectionUtils.isNotEmpty(chinaumsBankCardVOList) && chinaumsBankCardVOList.stream().filter(chinaumsBankCardVO -> chinaumsBankCardVO.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)).count() == 1) {
            throw new YnceErrorException(YnceError.YNCE_218024);
        }
        if (!chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)) {
            throw new YnceErrorException(YnceError.YNCE_218025);
        }
        if(chinaumsBankCard.getBankAcctNo().equals(chinaumsBankCard.getChinaumsAuthInfo().getSettleAcctBankAcctNo())){
            throw new YnceErrorException(YnceError.YNCE_218025.getStatus(),YnceError.YNCE_218025.getMsg() + "认证绑定的卡不允许解绑");
        }
//        ChinaumsDeleteBankCardDTO chinaumsDeleteBankCardDTO = ChinaumsDeleteBankCardDTO.builder().settleAcctId(chinaumsBankCard.getSettleAcctId()).build();
        ByxChinaumsAcctBindBankCardDTO byxChinaumsAcctBindBankCardDTO = new ByxChinaumsAcctBindBankCardDTO();
        byxChinaumsAcctBindBankCardDTO.setWalletId(chinaumsBankCard.getChinaumsAuthInfo().getBalanceAcctId());
        byxChinaumsAcctBindBankCardDTO.setOprtType(OprtTypeEnum.UNBIND.getValue());

BaseResponseDTO baseResponseDTO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseDTO.class);
        if (Constant.RETURN_SUCCESS_CODE.equals(baseResponseDTO.getRspCode()) ) {
            List<ChinaumsBankCard> chinaumsBankCardList = chinaumsBankCard.getChinaumsAuthInfo().getChinaumsBankCard();
            chinaumsBankCardList.removeIf(deleteChinaumsBankCard -> deleteChinaumsBankCard.getId().equals(id));
            chinaumsBankCard.setChinaumsAuthInfo(null);
            chinaumsBankCardRepository.delete(chinaumsBankCard);
            return true;
        } else {
            return false;
        }
    }

@Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean amountValidate(BankCardAmountValidateDTO bankCardAmountValidateDTO) {
        ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(bankCardAmountValidateDTO.getId()).orElse(null);
        if (chinaumsBankCard == null) {
            throw new YnceErrorException(YnceError.YNCE_218023);
        }
        if (chinaumsBankCard.getBankAcctType().equals("1")) {
            throw new YnceErrorException(YnceError.YNCE_218026);
        }
        ChinaumsAmountValidate chinaumsAmountValidate = ChinaumsAmountValidate
                .builder()
                .settleAcctId(chinaumsBankCard.getSettleAcctId())
                .payAmount(bankCardAmountValidateDTO.getAmount().multiply(new BigDecimal(100)).intValue())
                .build();
        chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_ACCTS_VALIDATE, (JSONObject) JSONObject.toJSON(chinaumsAmountValidate), null);
        return true;
    }

@Override
    public ChinaumsBankCardDetailVO getBankCardDetail(Long id) {
        ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(id).orElse(null);
        if (chinaumsBankCard == null) {
            throw new YnceErrorException(YnceError.YNCE_218023);
        }
        ChinaumsBankCardDetailVO chinaumsBankCardDetailVO = new ChinaumsBankCardDetailVO();
        BeanUtils.copyProperties(chinaumsBankCard, chinaumsBankCardDetailVO);
        return chinaumsBankCardDetailVO;
    }

/**
     * 处理银联银行卡状态
     *
     * @param chinaumsBankCard 银联银行卡
     * @author huabiao
     * @create 2023/2/20  16:12
     */
    private void handleBankCardStatus(ChinaumsBankCard chinaumsBankCard) {
        if (chinaumsBankCard == null) {
            return;
        }
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("settleAcctId", chinaumsBankCard.getSettleAcctId());
        ChinaumsAddBankCardVO chinaumsAddBankCardVO = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS_BY_ACCT_NO, (JSONObject) JSONObject.toJSON(jsonObject), ChinaumsAddBankCardVO.class);
        // 查询完状态后需要将银联银行卡信息中的状态更新
        switch (chinaumsAddBankCardVO.getVerifyStatus()) {
            case "processing":
                chinaumsBankCard.setStatus(ChinaumsBankCardStatus.PROCESSING);
                break;
            case "needless":
                chinaumsBankCard.setStatus(ChinaumsBankCardStatus.NEEDLESS);
                break;
            case "blocked":
                chinaumsBankCard.setStatus(ChinaumsBankCardStatus.BLOCKED);
                break;
            case "succeeded":
                chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED);
                break;
            case "failed":
                chinaumsBankCard.setAcctValidationFailureMsg(chinaumsAddBankCardVO.getAcctValidationFailureMsg());
                chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED);
                break;
        }
        chinaumsBankCardRepository.save(chinaumsBankCard);
    }
}

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

import com.alibaba.fastjson.JSONObject;
import com.yn.bftl.common.common.exception.YnceError;
import com.yn.bftl.common.common.util.RSAEncryptorUtil;
import com.yn.bftl.common.common.util.RouteUtil;
import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo;
import com.yn.bftl.common.modules.company.entity.ChinaumsBankCard;
import com.yn.bftl.common.modules.company.entity.Company;
import com.yn.bftl.common.modules.company.enums.ChinaumsBankCardStatus;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.service.BaseMemberService;
import com.yn.bftl.thirdparty.common.util.SequenceUtil;
import com.yn.bftl.thirdparty.modules.chinaums.dto.BankCardAmountValidateDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAddBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsDeleteBankCardDTO;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsBankCardRepository;
import com.yn.bftl.thirdparty.modules.chinaums.service.BankCardService;
import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardDetailVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsBankCardVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.chinaums.ChinaumsAddBankCardVO;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import javax.validation.constraints.NotNull;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 银行卡服务实现类
 *
 * @author huabiao
 * @create 2023/2/15  14:59
 **/
@Service
public class BankCardServiceImpl extends BaseMemberService implements BankCardService {

@Override
    public List<ChinaumsBankCardVO> bankCardList(ChinaumsBankCardStatus status) {
        List<ChinaumsBankCardVO> chinaumsBankCardVOList = new ArrayList<>();
        Company company = getUser().getCompany();
        if (company != null && company.getChinaumsAuthInfo() != null) {
            ChinaumsAuthInfo chinaumsAuthInfo = company.getChinaumsAuthInfo();
            if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard())) {
                List<Long> chinaumsBankCardIdList = chinaumsAuthInfo.getChinaumsBankCard().stream().filter(chinaumsBankCard -> chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.PROCESSING)).map(ChinaumsBankCard::getId).collect(Collectors.toList());
                if (CollectionUtils.isNotEmpty(chinaumsBankCardIdList)) {
                    for (Long chinaumsBankCardId : chinaumsBankCardIdList) {
                        handleBankCardStatus(chinaumsBankCardRepository.findById(chinaumsBankCardId).orElse(null));
                    }
                }
                for (ChinaumsBankCard chinaumsBankCard : chinaumsAuthInfo.getChinaumsBankCard()) {
                    if (status == null || chinaumsBankCard.getStatus().equals(status)) {
                        ChinaumsBankCardVO chinaumsBankCardVO = new ChinaumsBankCardVO();
                        chinaumsBankCardVO.setId(chinaumsBankCard.getId());
                        chinaumsBankCardVO.setBankName(chinaumsBankCard.getBankName());
                        chinaumsBankCardVO.setBankAcctNo(chinaumsBankCard.getBankAcctNo());
                        chinaumsBankCardVO.setStatus(chinaumsBankCard.getStatus());
                        chinaumsBankCardVO.setFailureMsg(chinaumsBankCard.getAcctValidationFailureMsg());
                        chinaumsBankCardVOList.add(chinaumsBankCardVO);
                    }
                }
            }
        }
        return chinaumsBankCardVOList;
    }

@Override
    @Transactional(rollbackFor = Exception.class)
    public void addBankCard(ChinaumsAddBankCardDTO chinaumsAddBankCardDTO) {
        Company company = getUser().getCompany();
        if (company == null) {
            throw new YnceErrorException(YnceError.YNCE_201009);
        }
        ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(company.getId());
        if (chinaumsAuthInfo == null) {
            throw new YnceErrorException(YnceError.YNCE_218009);
        }
        if (CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().size() >= 10) {
            throw new YnceErrorException(YnceError.YNCE_218027);
        }
        // 赋值银行卡
        ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard();
        if (chinaumsAddBankCardDTO.getId() != null) {
            chinaumsBankCard = chinaumsBankCardRepository.findById(chinaumsAddBankCardDTO.getId()).orElse(null);
            if (chinaumsBankCard == null) {
                throw new YnceErrorException(YnceError.YNCE_218023);
            }
            chinaumsAddBankCardDTO.setOutRequestNo(chinaumsBankCard.getOutRequestNo());
        } else {
            // 判断该银行卡号是否存在当前用户列表中
            if(CollectionUtils.isNotEmpty(chinaumsAuthInfo.getChinaumsBankCard()) && chinaumsAuthInfo.getChinaumsBankCard().stream().filter(filterChinaumsBankCard -> filterChinaumsBankCard.getBankAcctNo().equals(chinaumsAddBankCardDTO.getBankAcctNo())).findFirst().isPresent()){
                throw new YnceErrorException(YnceError.YNCE_218029);
            }
            chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo);
            chinaumsAddBankCardDTO.setOutRequestNo(sequenceUtil.getNextSequenceNumber("YHK"));
            chinaumsAddBankCardDTO.setProfession("40100");
        }
        BeanUtils.copyProperties(chinaumsAddBankCardDTO, chinaumsBankCard);
        chinaumsAddBankCardDTO.setCusId(chinaumsAuthInfo.getCusId());
        chinaumsAddBankCardDTO.setMchId(chinaumsAuthInfo.getMchId());
        // 对敏感信息加密处理
        String publicKey = chinaumsUtil.getPublicKey();
        try {
            // 银行账户
            chinaumsAddBankCardDTO.setBankAcctNo(RSAEncryptorUtil.encryptByPublicKey(chinaumsBankCard.getBankAcctNo(), publicKey));
            // 手机号
            chinaumsAddBankCardDTO.setMobileNumber(RSAEncryptorUtil.encryptByPublicKey(chinaumsBankCard.getMobileNumber(), publicKey));
        } catch (Exception exception) {
            throw new YnceErrorException(YnceError.YNCE_218014);
        }
        ChinaumsAddBankCardVO chinaumsAddBankCardVO = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS, (JSONObject) JSONObject.toJSON(chinaumsAddBankCardDTO), ChinaumsAddBankCardVO.class);
        chinaumsBankCard.setOutRequestNo(chinaumsAddBankCardVO.getOutRequestNo());
        chinaumsBankCard.setSettleAcctId(chinaumsAddBankCardVO.getSettleAcctId());
        handleBankCardStatus(chinaumsBankCard);
    }

@Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean deleteBankCard(@NotNull Long id) {
        ChinaumsBankCard chinaumsBankCard = chinaumsBankCardRepository.findById(id).orElse(null);
        if (chinaumsBankCard == null) {
            throw new YnceErrorException(YnceError.YNCE_218023);
        }
        List<ChinaumsBankCardVO> chinaumsBankCardVOList = this.bankCardList(null);
        if (CollectionUtils.isNotEmpty(chinaumsBankCardVOList) && chinaumsBankCardVOList.stream().filter(chinaumsBankCardVO -> chinaumsBankCardVO.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)).count() == 1) {
            throw new YnceErrorException(YnceError.YNCE_218024);
        }
        if (!chinaumsBankCard.getStatus().equals(ChinaumsBankCardStatus.SUCCEEDED)) {
            throw new YnceErrorException(YnceError.YNCE_218025);
        }
        if(chinaumsBankCard.getBankAcctNo().equals(chinaumsBankCard.getChinaumsAuthInfo().getSettleAcctBankAcctNo())){
            throw new YnceErrorException(YnceError.YNCE_218025.getStatus(),YnceError.YNCE_218025.getMsg() + "认证绑定的卡不允许解绑");
        }
        ChinaumsDeleteBankCardDTO chinaumsDeleteBankCardDTO = ChinaumsDeleteBankCardDTO.builder().settleAcctId(chinaumsBankCard.getSettleAcctId()).build();
        JSONObject jsonObject = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_SETTLE_ACCTS_DEL, (JSONObject) JSONObject.toJSON(chinaumsDeleteBankCardDTO), JSONObject.class);
        if (jsonObject.get("isDeleted").toString().equals("true")) {
            List<ChinaumsBankCard> chinaumsBankCardList = chinaumsBankCard.getChinaumsAuthInfo().getChinaumsBankCard();
            chinaumsBankCardList.removeIf(deleteChinaumsBankCard -> deleteChinaumsBankCard.getId().equals(id));
            chinaumsBankCard.setChinaumsAuthInfo(null);
            chinaumsBankCardRepository.delete(chinaumsBankCard);
            return true;
        } else {
            return false;
        }
    }

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/service/impl/ToolServiceImpl.java
package com.yn.bftl.thirdparty.modules.chinaums.service.impl; import com.alibaba.fastjson.JSONObject; import com.yn.bftl.common.common.exception.YnceError; import com.yn.bftl.common.common.util.ByxRouteUtil; import com.yn.bftl.common.common.util.RouteUtil; import com.yn.bftl.common.modules.base.entity.BankLineNumber; import com.yn.bftl.common.modules.base.vo.MetaFileVO; import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo; import com.yn.bftl.common.modules.company.entity.Company; import com.yn.bftl.common.modules.meta.entity.MetaFile; import com.yn.bftl.thirdparty.common.enums.SmsTmpltCode; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.service.BaseMemberService; import com.yn.bftl.thirdparty.modules.baiduai.service.ClassCardService; import com.yn.bftl.thirdparty.modules.baiduai.vo.BusinessLicenseInfoVO; import com.yn.bftl.thirdparty.modules.baiduai.vo.IdcardInfoVO; import com.yn.bftl.thirdparty.modules.business.service.MetaFileService; import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsPostDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsUploadImagesDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxSmsSendDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate; import com.yn.bftl.thirdparty.modules.chinaums.repository.BankLineNumberRepository; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository; import com.yn.bftl.thirdparty.modules.chinaums.service.ToolService; import com.yn.bftl.thirdparty.modules.chinaums.util.ByxChinaumsUtil; import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil; import com.yn.bftl.thirdparty.modules.chinaums.vo.BankLineNumberVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsImageVO; import io.lettuce.core.StrAlgoArgs; import org.apache.commons.codec.binary.Base64; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.Pageable; import org.springframework.data.jpa.domain.Specification; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import javax.persistence.criteria.CriteriaBuilder; import javax.persistence.criteria.CriteriaQuery; import javax.persistence.criteria.Predicate; import javax.persistence.criteria.Root; import java.io.IOException; import java.math.BigDecimal; import java.time.LocalDate; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.List; import java.util.Map; /** * 银联工具服务实现 * * @author huabiao * @create 2022/12/6 18:48 / @Service public class ToolServiceImpl extends BaseMemberService implements ToolService { @Resource private BankLineNumberRepository bankLineNumberRepository; @Resource private ChinaumsUtil chinaumsUtil; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private MetaFileService metaFileService; @Resource private ClassCardService classCardService; @Resource private ByxChinaumsUtil byxChinaumsUtil; @Override public ChinaumsImageVO uploadImage(MultipartFile file, String type) { ChinaumsImageVO chinaumsImageVO = new ChinaumsImageVO(); if (StringUtils.isNotBlank(type)) { switch (type) { case "front": case "back": IdcardInfoVO idcardInfoVO = classCardService.idcard(file, type); chinaumsImageVO.setIdcardInfoVO(idcardInfoVO); break; case "business_license": BusinessLicenseInfoVO businessLicenseInfoVO = classCardService.businessLicense(file, true, false); chinaumsImageVO.setBusinessLicenseInfoVO(businessLicenseInfoVO); break; default: } } // 上传图片到银联 String contentType = file.getContentType(); String base64EncoderImg; try { // 图片转base64 byte[] imageBytes; imageBytes = file.getBytes(); Base64 base64Encoder = new Base64(); base64EncoderImg = Base64.encodeBase64String(imageBytes); } catch (IOException ioException) { throw new YnceErrorException("图片转换异常"); } ChinaumsUploadImagesDTO chinaumsUploadImagesDTO = ChinaumsUploadImagesDTO.builder() .file(base64EncoderImg) .filename(file.getOriginalFilename()) .mimeType(contentType) .build(); Map jsonObject = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_IMAGES, (JSONObject) JSONObject.toJSON(chinaumsUploadImagesDTO), Map.class); // 保存图片到服务器 MetaFile metaFile = metaFileService.fileUpload(file); // 获取VO数据 MetaFileVO metaFileVO = metaFileService.getMetaFileVO(metaFile); BeanUtils.copyProperties(metaFileVO, chinaumsImageVO); chinaumsImageVO.setMediaId(jsonObject.get("mediaId").toString()); return chinaumsImageVO; } @Override public Page<BankLineNumberVO> getBankList(String keyword, Pageable pageable) { Specification<BankLineNumber> specification = new Specification<BankLineNumber>() { @Override public Predicate toPredicate(Root<BankLineNumber> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) { List<Predicate> predicates = new ArrayList<>(); if (StringUtils.isNotBlank(keyword)) { // 如果包含空格则切分关键字 if (keyword.contains(" ")) { String[] keywordList = keyword.split(" "); for (String s : keywordList) { predicates.add(criteriaBuilder.like(root.get("bankName"), "%" + s + "%")); } } else { predicates.add(criteriaBuilder.like(root.get("bankName"), "%" + keyword + "%")); } } query.where(predicates.toArray(new Predicate[predicates.size()])); query.orderBy(criteriaBuilder.desc(root.get("createdOn"))); return query.getRestriction(); } }; Page<BankLineNumber> bankLineNumberPage = bankLineNumberRepository.findAll(specification, pageable); List<BankLineNumberVO> bankLineNumberVOList = new ArrayList<>(); for (BankLineNumber bankLineNumber : bankLineNumberPage.getContent()) { BankLineNumberVO bankLineNumberVO = new BankLineNumberVO(); BeanUtils.copyProperties(bankLineNumber, bankLineNumberVO); bankLineNumberVOList.add(bankLineNumberVO); } PageImpl<BankLineNumberVO> bankLineNumberVOPage = new PageImpl(bankLineNumberVOList, pageable, bankLineNumberPage.getTotalElements()); return bankLineNumberVOPage; } @Override public Boolean amountValidate(BigDecimal amount) { Company company = getUser().getCompany(); ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(company.getId()); if (chinaumsAuthInfo == null) { throw new YnceErrorException(YnceError.YNCE_218009); } ChinaumsAmountValidate chinaumsAmountValidate = ChinaumsAmountValidate .builder() .settleAcctId(chinaumsAuthInfo.getSettleAcctId()) .payAmount(amount.multiply(new BigDecimal(100)).intValue()) .build(); chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_ACCTS_VALIDATE, (JSONObject) JSONObject.toJSON(chinaumsAmountValidate), null); return true; } @Override public void smsCodes(String mobile) { smsCodes(mobile, SmsTmpltCode.COMMON); } @Override public String tradeBills(LocalDate billDate) { JSONObject jsonObject = new JSONObject(); jsonObject.put("billDate", billDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); Map result = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_TRADE_BILLS, jsonObject, Map.class); return result.get("downloadUrl").toString(); // byxChinaumsUtil.execute(ByxRouteUtil.) } @Override public void smsCodesForResetPassword() { JSONObject jsonObject = new JSONObject(); ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(getUser().getCompany().getId()); if (chinaumsAuthInfo == null) { throw new YnceErrorException(YnceError.YNCE_218009); } jsonObject.put("balanceAcctId", chinaumsAuthInfo.getBalanceAcctId()); chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_ACCT_PASSWORD_SMS_CODES, jsonObject, null); } @Override public JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO) { return chinaumsUtil.execute(chinaumsPostDTO.getUrl(), chinaumsPostDTO.getJsonObject(), JSONObject.class); } private void smsCodes(String mobile,SmsTmpltCode smsTmpltCode) { smsCodes(mobile, smsTmpltCode, null); } private void smsCodes(String mobile,SmsTmpltCode smsTmpltCode,Integer smsBizType) { // JSONObject jsonObject = new JSONObject(); // jsonObject.put("mobileNumber", mobile); // chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_SMS_CODES, jsonObject, null); ByxSmsSendDTO byxSmsSendDTO = new ByxSmsSendDTO(); byxSmsSendDTO.setMobileNo(mobile); byxSmsSendDTO.setSmsTmpltCode(smsTmpltCode.getValue()); byxSmsSendDTO.setSmsBizType(smsBizType); byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_SMS_CODES, (JSONObject) JSONObject.toJSON(byxSmsSendDTO), null); } } package com.yn.bftl.thirdparty.modules.chinaums.service.impl; import com.alibaba.fastjson.JSONObject; import com.yn.bftl.common.common.exception.YnceError; import com.yn.bftl.common.common.util.RouteUtil; import com.yn.bftl.common.modules.base.entity.BankLineNumber; import com.yn.bftl.common.modules.base.vo.MetaFileVO; import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo; import com.yn.bftl.common.modules.company.entity.Company; import com.yn.bftl.common.modules.meta.entity.MetaFile; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.service.BaseMemberService; import com.yn.bftl.thirdparty.modules.baiduai.service.ClassCardService; import com.yn.bftl.thirdparty.modules.baiduai.vo.BusinessLicenseInfoVO; import com.yn.bftl.thirdparty.modules.baiduai.vo.IdcardInfoVO; import com.yn.bftl.thirdparty.modules.business.service.MetaFileService; import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsPostDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsUploadImagesDTO; import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate; import com.yn.bftl.thirdparty.modules.chinaums.repository.BankLineNumberRepository; import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository; import com.yn.bftl.thirdparty.modules.chinaums.service.ToolService; import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil; import com.yn.bftl.thirdparty.modules.chinaums.vo.BankLineNumberVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsImageVO; import org.apache.commons.codec.binary.Base64; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.Pageable; import org.springframework.data.jpa.domain.Specification; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import javax.persistence.criteria.CriteriaBuilder; import javax.persistence.criteria.CriteriaQuery; import javax.persistence.criteria.Predicate; import javax.persistence.criteria.Root; import java.io.IOException; import java.math.BigDecimal; import java.time.LocalDate; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.List; import java.util.Map; / * 银联工具服务实现 * * @author huabiao * @create 2022/12/6 18:48 **/ @Service public class ToolServiceImpl extends BaseMemberService implements ToolService { @Resource private BankLineNumberRepository bankLineNumberRepository; @Resource private ChinaumsUtil chinaumsUtil; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private MetaFileService metaFileService; @Resource private ClassCardService classCardService; @Override public ChinaumsImageVO uploadImage(MultipartFile file, String type) { ChinaumsImageVO chinaumsImageVO = new ChinaumsImageVO(); if (StringUtils.isNotBlank(type)) { switch (type) { case "front": case "back": IdcardInfoVO idcardInfoVO = classCardService.idcard(file, type); chinaumsImageVO.setIdcardInfoVO(idcardInfoVO); break; case "business_license": BusinessLicenseInfoVO businessLicenseInfoVO = classCardService.businessLicense(file, true, false); chinaumsImageVO.setBusinessLicenseInfoVO(businessLicenseInfoVO); break; default: } } // 上传图片到银联 String contentType = file.getContentType(); String base64EncoderImg; try { // 图片转base64 byte[] imageBytes; imageBytes = file.getBytes(); Base64 base64Encoder = new Base64(); base64EncoderImg = Base64.encodeBase64String(imageBytes); } catch (IOException ioException) { throw new YnceErrorException("图片转换异常"); } ChinaumsUploadImagesDTO chinaumsUploadImagesDTO = ChinaumsUploadImagesDTO.builder() .file(base64EncoderImg) .filename(file.getOriginalFilename()) .mimeType(contentType) .build(); Map jsonObject = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_IMAGES, (JSONObject) JSONObject.toJSON(chinaumsUploadImagesDTO), Map.class); // 保存图片到服务器 MetaFile metaFile = metaFileService.fileUpload(file); // 获取VO数据 MetaFileVO metaFileVO = metaFileService.getMetaFileVO(metaFile); BeanUtils.copyProperties(metaFileVO, chinaumsImageVO); chinaumsImageVO.setMediaId(jsonObject.get("mediaId").toString()); return chinaumsImageVO; } @Override public Page<BankLineNumberVO> getBankList(String keyword, Pageable pageable) { Specification<BankLineNumber> specification = new Specification<BankLineNumber>() { @Override public Predicate toPredicate(Root<BankLineNumber> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) { List<Predicate> predicates = new ArrayList<>(); if (StringUtils.isNotBlank(keyword)) { // 如果包含空格则切分关键字 if (keyword.contains(" ")) { String[] keywordList = keyword.split(" "); for (String s : keywordList) { predicates.add(criteriaBuilder.like(root.get("bankName"), "%" + s + "%")); } } else { predicates.add(criteriaBuilder.like(root.get("bankName"), "%" + keyword + "%")); } } query.where(predicates.toArray(new Predicate[predicates.size()])); query.orderBy(criteriaBuilder.desc(root.get("createdOn"))); return query.getRestriction(); } }; Page<BankLineNumber> bankLineNumberPage = bankLineNumberRepository.findAll(specification, pageable); List<BankLineNumberVO> bankLineNumberVOList = new ArrayList<>(); for (BankLineNumber bankLineNumber : bankLineNumberPage.getContent()) { BankLineNumberVO bankLineNumberVO = new BankLineNumberVO(); BeanUtils.copyProperties(bankLineNumber, bankLineNumberVO); bankLineNumberVOList.add(bankLineNumberVO); } PageImpl<BankLineNumberVO> bankLineNumberVOPage = new PageImpl(bankLineNumberVOList, pageable, bankLineNumberPage.getTotalElements()); return bankLineNumberVOPage; } @Override public Boolean amountValidate(BigDecimal amount) { Company company = getUser().getCompany(); ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(company.getId()); if (chinaumsAuthInfo == null) { throw new YnceErrorException(YnceError.YNCE_218009); } ChinaumsAmountValidate chinaumsAmountValidate = ChinaumsAmountValidate .builder() .settleAcctId(chinaumsAuthInfo.getSettleAcctId()) .payAmount(amount.multiply(new BigDecimal(100)).intValue()) .build(); chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_ACCTS_VALIDATE, (JSONObject) JSONObject.toJSON(chinaumsAmountValidate), null); return true; } @Override public void smsCodes(String mobile) { JSONObject jsonObject = new JSONObject(); jsonObject.put("mobileNumber", mobile); chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_SMS_CODES, jsonObject, null); } @Override public String tradeBills(LocalDate billDate) { JSONObject jsonObject = new JSONObject(); jsonObject.put("billDate", billDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); Map result = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_TRADE_BILLS, jsonObject, Map.class); return result.get("downloadUrl").toString(); } @Override public void smsCodesForResetPassword() { JSONObject jsonObject = new JSONObject(); ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(getUser().getCompany().getId()); if (chinaumsAuthInfo == null) { throw new YnceErrorException(YnceError.YNCE_218009); } jsonObject.put("balanceAcctId", chinaumsAuthInfo.getBalanceAcctId()); chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_ACCT_PASSWORD_SMS_CODES, jsonObject, null); } @Override public JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO) { return chinaumsUtil.execute(chinaumsPostDTO.getUrl(), chinaumsPostDTO.getJsonObject(), JSONObject.class); } }

Ignore Space Show notes View

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

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

import com.alibaba.fastjson.JSONObject;
import com.yn.bftl.common.common.exception.YnceError;
import com.yn.bftl.common.common.util.ByxRouteUtil;
import com.yn.bftl.common.common.util.RouteUtil;
import com.yn.bftl.common.modules.base.entity.BankLineNumber;
import com.yn.bftl.common.modules.base.vo.MetaFileVO;
import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo;
import com.yn.bftl.common.modules.company.entity.Company;
import com.yn.bftl.common.modules.meta.entity.MetaFile;
import com.yn.bftl.thirdparty.common.enums.SmsTmpltCode;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.service.BaseMemberService;
import com.yn.bftl.thirdparty.modules.baiduai.service.ClassCardService;
import com.yn.bftl.thirdparty.modules.baiduai.vo.BusinessLicenseInfoVO;
import com.yn.bftl.thirdparty.modules.baiduai.vo.IdcardInfoVO;
import com.yn.bftl.thirdparty.modules.business.service.MetaFileService;
import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsPostDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsUploadImagesDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.byx.ByxSmsSendDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate;
import com.yn.bftl.thirdparty.modules.chinaums.repository.BankLineNumberRepository;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository;
import com.yn.bftl.thirdparty.modules.chinaums.service.ToolService;
import com.yn.bftl.thirdparty.modules.chinaums.util.ByxChinaumsUtil;
import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil;
import com.yn.bftl.thirdparty.modules.chinaums.vo.BankLineNumberVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsImageVO;
import io.lettuce.core.StrAlgoArgs;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import java.io.IOException;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * 银联工具服务实现
 *
 * @author huabiao
 * @create 2022/12/6  18:48
 **/
@Service
public class ToolServiceImpl extends BaseMemberService implements ToolService {

@Resource
    private BankLineNumberRepository bankLineNumberRepository;
    @Resource
    private ChinaumsUtil chinaumsUtil;
    @Resource
    private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository;
    @Resource
    private MetaFileService metaFileService;
    @Resource
    private ClassCardService classCardService;
    @Resource
    private ByxChinaumsUtil byxChinaumsUtil;

@Override
    public ChinaumsImageVO uploadImage(MultipartFile file, String type) {
        ChinaumsImageVO chinaumsImageVO = new ChinaumsImageVO();
        if (StringUtils.isNotBlank(type)) {
            switch (type) {
                case "front":
                case "back":
                    IdcardInfoVO idcardInfoVO = classCardService.idcard(file, type);
                    chinaumsImageVO.setIdcardInfoVO(idcardInfoVO);
                    break;
                case "business_license":
                    BusinessLicenseInfoVO businessLicenseInfoVO = classCardService.businessLicense(file, true, false);
                    chinaumsImageVO.setBusinessLicenseInfoVO(businessLicenseInfoVO);
                    break;
                default:
            }
        }

// 上传图片到银联
        String contentType = file.getContentType();
        String base64EncoderImg;
        try {
            // 图片转base64
            byte[] imageBytes;
            imageBytes = file.getBytes();
            Base64 base64Encoder = new Base64();
            base64EncoderImg = Base64.encodeBase64String(imageBytes);
        } catch (IOException ioException) {
            throw new YnceErrorException("图片转换异常");
        }
        ChinaumsUploadImagesDTO chinaumsUploadImagesDTO = ChinaumsUploadImagesDTO.builder()
                .file(base64EncoderImg)
                .filename(file.getOriginalFilename())
                .mimeType(contentType)
                .build();
        Map jsonObject = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_IMAGES, (JSONObject) JSONObject.toJSON(chinaumsUploadImagesDTO), Map.class);
        // 保存图片到服务器
        MetaFile metaFile = metaFileService.fileUpload(file);
        // 获取VO数据
        MetaFileVO metaFileVO = metaFileService.getMetaFileVO(metaFile);
        BeanUtils.copyProperties(metaFileVO, chinaumsImageVO);
        chinaumsImageVO.setMediaId(jsonObject.get("mediaId").toString());
        return chinaumsImageVO;
    }

@Override
    public Page<BankLineNumberVO> getBankList(String keyword, Pageable pageable) {
        Specification<BankLineNumber> specification = new Specification<BankLineNumber>() {
            @Override
            public Predicate toPredicate(Root<BankLineNumber> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
                List<Predicate> predicates = new ArrayList<>();
                if (StringUtils.isNotBlank(keyword)) {
                    // 如果包含空格则切分关键字
                    if (keyword.contains(" ")) {
                        String[] keywordList = keyword.split(" ");
                        for (String s : keywordList) {
                            predicates.add(criteriaBuilder.like(root.get("bankName"), "%" + s + "%"));
                        }
                    } else {
                        predicates.add(criteriaBuilder.like(root.get("bankName"), "%" + keyword + "%"));
                    }

}
                query.where(predicates.toArray(new Predicate[predicates.size()]));
                query.orderBy(criteriaBuilder.desc(root.get("createdOn")));
                return query.getRestriction();
            }
        };
        Page<BankLineNumber> bankLineNumberPage = bankLineNumberRepository.findAll(specification, pageable);
        List<BankLineNumberVO> bankLineNumberVOList = new ArrayList<>();
        for (BankLineNumber bankLineNumber : bankLineNumberPage.getContent()) {
            BankLineNumberVO bankLineNumberVO = new BankLineNumberVO();
            BeanUtils.copyProperties(bankLineNumber, bankLineNumberVO);
            bankLineNumberVOList.add(bankLineNumberVO);
        }
        PageImpl<BankLineNumberVO> bankLineNumberVOPage = new PageImpl(bankLineNumberVOList, pageable, bankLineNumberPage.getTotalElements());
        return bankLineNumberVOPage;
    }

@Override
    public Boolean amountValidate(BigDecimal amount) {
        Company company = getUser().getCompany();
        ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(company.getId());
        if (chinaumsAuthInfo == null) {
            throw new YnceErrorException(YnceError.YNCE_218009);
        }
        ChinaumsAmountValidate chinaumsAmountValidate = ChinaumsAmountValidate
                .builder()
                .settleAcctId(chinaumsAuthInfo.getSettleAcctId())
                .payAmount(amount.multiply(new BigDecimal(100)).intValue())
                .build();
        chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_ACCTS_VALIDATE, (JSONObject) JSONObject.toJSON(chinaumsAmountValidate), null);
        return true;
    }

@Override
    public void smsCodes(String mobile) {
        smsCodes(mobile, SmsTmpltCode.COMMON);
    }

@Override
    public String tradeBills(LocalDate billDate) {
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("billDate", billDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
        Map result = chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_TRADE_BILLS, jsonObject, Map.class);
        return result.get("downloadUrl").toString();
//        byxChinaumsUtil.execute(ByxRouteUtil.)
    }

@Override
    public void smsCodesForResetPassword() {
        JSONObject jsonObject = new JSONObject();
        ChinaumsAuthInfo chinaumsAuthInfo = chinaumsAuthInfoRepository.findFirstByCompanyId(getUser().getCompany().getId());
        if (chinaumsAuthInfo == null) {
            throw new YnceErrorException(YnceError.YNCE_218009);
        }
        jsonObject.put("balanceAcctId", chinaumsAuthInfo.getBalanceAcctId());
        chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_UPAPI_ACCT_PASSWORD_SMS_CODES, jsonObject, null);
    }

@Override
    public JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO) {
        return chinaumsUtil.execute(chinaumsPostDTO.getUrl(), chinaumsPostDTO.getJsonObject(), JSONObject.class);
    }

private void smsCodes(String mobile,SmsTmpltCode smsTmpltCode) {
        smsCodes(mobile, smsTmpltCode, null);
    }

private void smsCodes(String mobile,SmsTmpltCode smsTmpltCode,Integer smsBizType) {
//        JSONObject jsonObject = new JSONObject();
//        jsonObject.put("mobileNumber", mobile);
//        chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_SMS_CODES, jsonObject, null);
        ByxSmsSendDTO byxSmsSendDTO = new ByxSmsSendDTO();
        byxSmsSendDTO.setMobileNo(mobile);
        byxSmsSendDTO.setSmsTmpltCode(smsTmpltCode.getValue());
        byxSmsSendDTO.setSmsBizType(smsBizType);
        byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_SMS_CODES, (JSONObject) JSONObject.toJSON(byxSmsSendDTO), null);
    }
}

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

import com.alibaba.fastjson.JSONObject;
import com.yn.bftl.common.common.exception.YnceError;
import com.yn.bftl.common.common.util.RouteUtil;
import com.yn.bftl.common.modules.base.entity.BankLineNumber;
import com.yn.bftl.common.modules.base.vo.MetaFileVO;
import com.yn.bftl.common.modules.company.entity.ChinaumsAuthInfo;
import com.yn.bftl.common.modules.company.entity.Company;
import com.yn.bftl.common.modules.meta.entity.MetaFile;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.service.BaseMemberService;
import com.yn.bftl.thirdparty.modules.baiduai.service.ClassCardService;
import com.yn.bftl.thirdparty.modules.baiduai.vo.BusinessLicenseInfoVO;
import com.yn.bftl.thirdparty.modules.baiduai.vo.IdcardInfoVO;
import com.yn.bftl.thirdparty.modules.business.service.MetaFileService;
import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsPostDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.ChinaumsUploadImagesDTO;
import com.yn.bftl.thirdparty.modules.chinaums.dto.chinaums.ChinaumsAmountValidate;
import com.yn.bftl.thirdparty.modules.chinaums.repository.BankLineNumberRepository;
import com.yn.bftl.thirdparty.modules.chinaums.repository.ChinaumsAuthInfoRepository;
import com.yn.bftl.thirdparty.modules.chinaums.service.ToolService;
import com.yn.bftl.thirdparty.modules.chinaums.util.ChinaumsUtil;
import com.yn.bftl.thirdparty.modules.chinaums.vo.BankLineNumberVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.ChinaumsImageVO;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

/**
 * 银联工具服务实现
 *
 * @author huabiao
 * @create 2022/12/6  18:48
 **/
@Service
public class ToolServiceImpl extends BaseMemberService implements ToolService {

@Override
    public void smsCodes(String mobile) {
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("mobileNumber", mobile);
        chinaumsUtil.execute(RouteUtil.ROUTE_WALLET_SMS_CODES, jsonObject, null);
    }

@Override
    public JSONObject postTool(ChinaumsPostDTO chinaumsPostDTO) {
        return chinaumsUtil.execute(chinaumsPostDTO.getUrl(), chinaumsPostDTO.getJsonObject(), JSONObject.class);
    }
}

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/vo/byx/ByxChinaumsQueryBindBankCardVO.java 0 → 100644
package com.yn.bftl.thirdparty.modules.chinaums.vo.byx; import com.yn.bftl.thirdparty.common.dto.BaseResponseDTO; import io.swagger.annotations.ApiModel; import lombok.Data; import lombok.EqualsAndHashCode; import java.util.List; /** * 银联添加银行卡VO * * @author huabiao * @create 2023/2/20 15:39 / @Data @EqualsAndHashCode(callSuper = false) @ApiModel(value = "ChinaumsQueryBindBankCardVO", description = "查询账户银行卡vo") public class ByxChinaumsQueryBindBankCardVO extends BaseResponseDTO { / * 电子账户 ID / private String walletId; /* * 电子账户名称 */ private List<QueryBindBankRow> rowList; }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/vo/byx/ByxChinaumsQueryBindBankCardVO.java 0 → 100644

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/chinaums/vo/byx/QueryBindBankRow.java 0 → 100644
package com.yn.bftl.thirdparty.modules.chinaums.vo.byx; import io.swagger.annotations.ApiModel; import lombok.Data; import lombok.EqualsAndHashCode; /** * @program: yn-byx-thirdparty * @description: * @author: Jing * @create: 2024-08-23 17:50 / @Data @EqualsAndHashCode(callSuper = false) @ApiModel(value = "QueryBindBankRow", description = "查询账户银行卡-循环域vo") public class QueryBindBankRow { / * 银行账户 / private String bankAcctNo; /* * 银行账户名称 / private String bankAcctName; /* * 是否默认卡 / private String isDefault; /* * 开户行号 / private String bankNo; /* * 银行名称 / private String bankName; /* * 电子联行号 / private String elecBankNo; /* * 银行账户类型 / private String bankAcctType; /* * 是否信用卡 / private String creditMark; /* * 电子协议编号 / private String protocolNo; /* * 签约商户号 / private String signMerNo; /* * 业务类型 / private String businessCode; /* * 是否签约类型 / private String signBindType; /* * 是否需要重新签约 */ private String isNeedReSign; }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/chinaums/vo/byx/QueryBindBankRow.java 0 → 100644

package com.yn.bftl.thirdparty.modules.chinaums.vo.byx;

import io.swagger.annotations.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;

/**
 * @program: yn-byx-thirdparty
 * @description:
 * @author: Jing
 * @create: 2024-08-23 17:50
 **/
@Data
@EqualsAndHashCode(callSuper = false)
@ApiModel(value = "QueryBindBankRow", description = "查询账户银行卡-循环域vo")
public class QueryBindBankRow {

/**
     *  银行账户
     */
    private String bankAcctNo;
    /**
     *  银行账户名称
     */
    private String bankAcctName;
    /**
     *  是否默认卡
     */
    private String isDefault;
    /**
     *  开户行号
     */
    private String bankNo;

/**
     * 银行名称
     */
    private String bankName;

/**
     * 电子联行号
     */
    private String elecBankNo;

/**
     * 银行账户类型
     */
    private String bankAcctType;

/**
     * 是否信用卡
     */
    private String creditMark;
    /**
     * 电子协议编号
     */
    private String protocolNo;

/**
     * 签约商户号
     */
    private String signMerNo;

/**
     * 业务类型
     */
    private String businessCode;

/**
     * 是否签约类型
     */
    private String signBindType;

/**
     * 是否需要重新签约
     */
    private String isNeedReSign;
}

Show line notes below