短信验证码

yn-bftl-byx / thirdparty

Browse code 短信验证码 master
1 parent e2ea954 commit 1b7103519d8409478f76f34e04ea23492b53c02a Jing authored on 29 Sep 2024

Patch

Showing 3 changed files

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.bean.BeanUtil; 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.base.entity.BankLineNumber; 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.service.ByxTradeWayService; import com.yn.bftl.thirdparty.common.vo.BaseResponseVO; 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.ChinaumsAddBankCardDTO; 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.BankLineNumberRepository; 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.ByxQueryBindBankRow; import org.apache.commons.collections.CollectionUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.validation.Valid; 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 { private static final Logger log = LoggerFactory.getLogger(BankCardServiceImpl.class); @Resource private ChinaumsBankCardRepository chinaumsBankCardRepository; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private ChinaumsUtil chinaumsUtil; @Resource private ByxChinaumsUtil byxChinaumsUtil; @Resource private SequenceUtil sequenceUtil; @Resource private BankLineNumberRepository bankLineNumberRepository; @Resource private ByxTradeWayService byxTradeWayService; @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 (ByxQueryBindBankRow byxQueryBindBankRow :chinaumsQueryBindBankCardVO.getRowList()){ bankAcctNoList.add(byxQueryBindBankRow.getBankAcctNo()); } } return bankAcctNoList; } @Override @Transactional(rollbackFor = Exception.class) public void addBankCard(@Valid 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); } 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"); } // 根据bankCode 查询对应的银行信息 BankLineNumber bankLineNumber = bankLineNumberRepository.findFirstByBankCode(chinaumsAddBankCardDTO.getBankCode()); // 赋值银行卡 ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard(); if (chinaumsAddBankCardDTO.getId() != null) { chinaumsBankCard = chinaumsBankCardRepository.findById(chinaumsAddBankCardDTO.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(chinaumsAddBankCardDTO.getBankAcctNo()))){ throw new YnceErrorException(YnceError.YNCE_218029); } chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo); chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode()); chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo()); chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber()); // chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo()); chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType()); chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId()); if(ObjectUtil.isNotEmpty(bankLineNumber)){ chinaumsBankCard.setBankName(bankLineNumber.getBankName()); chinaumsBankCard.setBankCode(bankLineNumber.getBankCode()); // chinaumsBankCard.setBankBranchCode(bankLineNumber.getDrecCode()); } } BeanUtils.copyProperties(byxChinaumsAcctBindBankCardDTO, chinaumsBankCard); // byxChinaumsAcctBindBankCardDTO.setCusId(chinaumsAuthInfo.getCusId()); // byxChinaumsAcctBindBankCardDTO.setMchId(chinaumsAuthInfo.getMchId()); byxChinaumsAcctBindBankCardDTO.setElecBankNo(chinaumsAuthInfo.getElecBankNo()); byxChinaumsAcctBindBankCardDTO.setIdCard(chinaumsAuthInfo.getIdCardNumber()); byxChinaumsAcctBindBankCardDTO.setWalletId(company.getWalletId()); byxChinaumsAcctBindBankCardDTO.setBankAcctName(chinaumsAuthInfo.getSettleAcctBankName()); byxChinaumsAcctBindBankCardDTO.setBankNo(bankLineNumber.getThreeDigitBranchCode()); try { if(ObjectUtil.isEmpty(byxChinaumsAcctBindBankCardDTO.getBankAcctNo())){ // 银行账户 byxChinaumsAcctBindBankCardDTO.setBankAcctNo(chinaumsBankCard.getBankAcctNo()); } if(ObjectUtil.isEmpty(byxChinaumsAcctBindBankCardDTO.getMobileNo())){ // 手机号 byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsBankCard.getMobileNumber()); } } catch (Exception exception) { throw new YnceErrorException(YnceError.YNCE_218014); } byxTradeWayService.setCert(byxChinaumsAcctBindBankCardDTO, company.getWalletId()); // log.info("{}",(JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO)); BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class); // 绑定后根据返回的状态码更新状态 if(Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.getRspCode())){ chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED); chinaumsAuthInfo.setBankCardNo(byxChinaumsAcctBindBankCardDTO.getBankAcctNo()); chinaumsAuthInfo.setBindAcctName(byxChinaumsAcctBindBankCardDTO.getBankAcctName()); chinaumsAuthInfoRepository.save(chinaumsAuthInfo); } else { chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED); chinaumsBankCard.setAcctValidationFailureMsg(baseResponseVO.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()); byxTradeWayService.setCert(byxChinaumsAcctBindBankCardDTO, byxChinaumsAcctBindBankCardDTO.getWalletId()); byxTradeWayService.setTradeWayInCert(byxChinaumsAcctBindBankCardDTO, byxChinaumsAcctBindBankCardDTO.getWalletId()); BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class); if (Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.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 cn.hutool.core.bean.BeanUtil; 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.base.entity.BankLineNumber; 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.service.ByxTradeWayService; import com.yn.bftl.thirdparty.common.vo.BaseResponseVO; 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.ChinaumsAddBankCardDTO; 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.BankLineNumberRepository; 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.ByxQueryBindBankRow; import org.apache.commons.collections.CollectionUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.validation.Valid; 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 { private static final Logger log = LoggerFactory.getLogger(BankCardServiceImpl.class); @Resource private ChinaumsBankCardRepository chinaumsBankCardRepository; @Resource private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository; @Resource private ChinaumsUtil chinaumsUtil; @Resource private ByxChinaumsUtil byxChinaumsUtil; @Resource private SequenceUtil sequenceUtil; @Resource private BankLineNumberRepository bankLineNumberRepository; @Resource private ByxTradeWayService byxTradeWayService; @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 (ByxQueryBindBankRow byxQueryBindBankRow :chinaumsQueryBindBankCardVO.getRowList()){ bankAcctNoList.add(byxQueryBindBankRow.getBankAcctNo()); } } return bankAcctNoList; } @Override @Transactional(rollbackFor = Exception.class) public void addBankCard(@Valid 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); } 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"); } // 根据bankCode 查询对应的银行信息 BankLineNumber bankLineNumber = bankLineNumberRepository.findFirstByBankCode(chinaumsAddBankCardDTO.getBankCode()); // 赋值银行卡 ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard(); if (chinaumsAddBankCardDTO.getId() != null) { chinaumsBankCard = chinaumsBankCardRepository.findById(chinaumsAddBankCardDTO.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(chinaumsAddBankCardDTO.getBankAcctNo()))){ throw new YnceErrorException(YnceError.YNCE_218029); } chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo); chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode()); chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo()); chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber()); // chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo()); chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType()); chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId()); if(ObjectUtil.isNotEmpty(bankLineNumber)){ chinaumsBankCard.setBankName(bankLineNumber.getBankName()); chinaumsBankCard.setBankCode(bankLineNumber.getBankCode()); // chinaumsBankCard.setBankBranchCode(bankLineNumber.getDrecCode()); } } BeanUtils.copyProperties(byxChinaumsAcctBindBankCardDTO, chinaumsBankCard); // byxChinaumsAcctBindBankCardDTO.setCusId(chinaumsAuthInfo.getCusId()); // byxChinaumsAcctBindBankCardDTO.setMchId(chinaumsAuthInfo.getMchId()); byxChinaumsAcctBindBankCardDTO.setElecBankNo(chinaumsAuthInfo.getElecBankNo()); byxChinaumsAcctBindBankCardDTO.setIdCard(chinaumsAuthInfo.getIdCardNumber()); byxChinaumsAcctBindBankCardDTO.setWalletId(company.getWalletId()); byxChinaumsAcctBindBankCardDTO.setBankAcctName(chinaumsAuthInfo.getSettleAcctBankName()); byxChinaumsAcctBindBankCardDTO.setBankNo(bankLineNumber.getThreeDigitBranchCode()); try { if(ObjectUtil.isEmpty(byxChinaumsAcctBindBankCardDTO.getBankAcctNo())){ // 银行账户 byxChinaumsAcctBindBankCardDTO.setBankAcctNo(chinaumsBankCard.getBankAcctNo()); } if(ObjectUtil.isEmpty(byxChinaumsAcctBindBankCardDTO.getMobileNo())){ // 手机号 byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsBankCard.getMobileNumber()); } } catch (Exception exception) { throw new YnceErrorException(YnceError.YNCE_218014); } byxTradeWayService.setCert(byxChinaumsAcctBindBankCardDTO, company.getWalletId()); log.info("{}",(JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO)); BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class); // 绑定后根据返回的状态码更新状态 if(Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.getRspCode())){ chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED); chinaumsAuthInfo.setBankCardNo(byxChinaumsAcctBindBankCardDTO.getBankAcctNo()); chinaumsAuthInfo.setBindAcctName(byxChinaumsAcctBindBankCardDTO.getBankAcctName()); chinaumsAuthInfoRepository.save(chinaumsAuthInfo); } else { chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED); chinaumsBankCard.setAcctValidationFailureMsg(baseResponseVO.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()); byxTradeWayService.setTradeWayInCert(byxChinaumsAcctBindBankCardDTO, byxChinaumsAcctBindBankCardDTO.getWalletId()); BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class); if (Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.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); } }

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.bean.BeanUtil;
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.base.entity.BankLineNumber;
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.service.ByxTradeWayService;
import com.yn.bftl.thirdparty.common.vo.BaseResponseVO;
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.ChinaumsAddBankCardDTO;
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.BankLineNumberRepository;
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.ByxQueryBindBankRow;
import org.apache.commons.collections.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import javax.validation.Valid;
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 {

private static final Logger log = LoggerFactory.getLogger(BankCardServiceImpl.class);
    @Resource
    private ChinaumsBankCardRepository chinaumsBankCardRepository;
    @Resource
    private ChinaumsAuthInfoRepository chinaumsAuthInfoRepository;
    @Resource
    private ChinaumsUtil chinaumsUtil;
    @Resource
    private ByxChinaumsUtil byxChinaumsUtil;
    @Resource
    private SequenceUtil sequenceUtil;
    @Resource
    private BankLineNumberRepository bankLineNumberRepository;

@Resource
    private ByxTradeWayService byxTradeWayService;

@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 (ByxQueryBindBankRow byxQueryBindBankRow :chinaumsQueryBindBankCardVO.getRowList()){
                bankAcctNoList.add(byxQueryBindBankRow.getBankAcctNo());
            }
        }
        return bankAcctNoList;
    }

@Override
    @Transactional(rollbackFor = Exception.class)
    public void addBankCard(@Valid 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);
        }

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");
        }
        // 根据bankCode 查询对应的银行信息
        BankLineNumber bankLineNumber = bankLineNumberRepository.findFirstByBankCode(chinaumsAddBankCardDTO.getBankCode());
        // 赋值银行卡
        ChinaumsBankCard chinaumsBankCard = new ChinaumsBankCard();
        if (chinaumsAddBankCardDTO.getId() != null) {
            chinaumsBankCard = chinaumsBankCardRepository.findById(chinaumsAddBankCardDTO.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(chinaumsAddBankCardDTO.getBankAcctNo()))){
                throw new YnceErrorException(YnceError.YNCE_218029);
            }
            chinaumsBankCard.setChinaumsAuthInfo(chinaumsAuthInfo);
            chinaumsBankCard.setBankBranchCode(chinaumsAuthInfo.getSettleAcctBankBranchCode());
            chinaumsBankCard.setBankAcctNo(chinaumsAuthInfo.getSettleAcctBankAcctNo());
            chinaumsBankCard.setMobileNumber(chinaumsAuthInfo.getMobileNumber());
//            chinaumsBankCard.setOutRequestNo(chinaumsAuthInfo.getOutRequestNo());
            chinaumsBankCard.setBankAcctType(chinaumsAuthInfo.getSettleAcctType());
            chinaumsBankCard.setSettleAcctId(chinaumsAuthInfo.getSettleAcctId());

if(ObjectUtil.isNotEmpty(bankLineNumber)){
                chinaumsBankCard.setBankName(bankLineNumber.getBankName());
                chinaumsBankCard.setBankCode(bankLineNumber.getBankCode());
//                chinaumsBankCard.setBankBranchCode(bankLineNumber.getDrecCode());
            }
        }
        BeanUtils.copyProperties(byxChinaumsAcctBindBankCardDTO, chinaumsBankCard);
//        byxChinaumsAcctBindBankCardDTO.setCusId(chinaumsAuthInfo.getCusId());
//        byxChinaumsAcctBindBankCardDTO.setMchId(chinaumsAuthInfo.getMchId());
        byxChinaumsAcctBindBankCardDTO.setElecBankNo(chinaumsAuthInfo.getElecBankNo());
        byxChinaumsAcctBindBankCardDTO.setIdCard(chinaumsAuthInfo.getIdCardNumber());
        byxChinaumsAcctBindBankCardDTO.setWalletId(company.getWalletId());
        byxChinaumsAcctBindBankCardDTO.setBankAcctName(chinaumsAuthInfo.getSettleAcctBankName());
        byxChinaumsAcctBindBankCardDTO.setBankNo(bankLineNumber.getThreeDigitBranchCode());

try {
            if(ObjectUtil.isEmpty(byxChinaumsAcctBindBankCardDTO.getBankAcctNo())){
                // 银行账户
                byxChinaumsAcctBindBankCardDTO.setBankAcctNo(chinaumsBankCard.getBankAcctNo());
            }

if(ObjectUtil.isEmpty(byxChinaumsAcctBindBankCardDTO.getMobileNo())){
                // 手机号
                byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsBankCard.getMobileNumber());
            }
        } catch (Exception exception) {
            throw new YnceErrorException(YnceError.YNCE_218014);
        }
        byxTradeWayService.setCert(byxChinaumsAcctBindBankCardDTO, company.getWalletId());
//        log.info("{}",(JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO));
        BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class);
        // 绑定后根据返回的状态码更新状态
        if(Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.getRspCode())){
            chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED);

chinaumsAuthInfo.setBankCardNo(byxChinaumsAcctBindBankCardDTO.getBankAcctNo());
            chinaumsAuthInfo.setBindAcctName(byxChinaumsAcctBindBankCardDTO.getBankAcctName());
            chinaumsAuthInfoRepository.save(chinaumsAuthInfo);
        }
        else {
            chinaumsBankCard.setStatus(ChinaumsBankCardStatus.FAILED);
            chinaumsBankCard.setAcctValidationFailureMsg(baseResponseVO.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());

byxTradeWayService.setCert(byxChinaumsAcctBindBankCardDTO, byxChinaumsAcctBindBankCardDTO.getWalletId());
        byxTradeWayService.setTradeWayInCert(byxChinaumsAcctBindBankCardDTO, byxChinaumsAcctBindBankCardDTO.getWalletId());
        BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class);
        if (Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.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 javax.annotation.Resource;
import javax.validation.Valid;
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 ByxTradeWayService byxTradeWayService;

if(ObjectUtil.isEmpty(byxChinaumsAcctBindBankCardDTO.getMobileNo())){
                // 手机号
                byxChinaumsAcctBindBankCardDTO.setMobileNo(chinaumsBankCard.getMobileNumber());
            }
        } catch (Exception exception) {
            throw new YnceErrorException(YnceError.YNCE_218014);
        }
        byxTradeWayService.setCert(byxChinaumsAcctBindBankCardDTO, company.getWalletId());
        log.info("{}",(JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO));
        BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class);
        // 绑定后根据返回的状态码更新状态
        if(Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.getRspCode())){
            chinaumsBankCard.setStatus(ChinaumsBankCardStatus.SUCCEEDED);

byxTradeWayService.setTradeWayInCert(byxChinaumsAcctBindBankCardDTO, byxChinaumsAcctBindBankCardDTO.getWalletId());
        BaseResponseVO baseResponseVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_UPAPI_ACCT_BIND_BANK_CARD, (JSONObject) JSONObject.toJSON(byxChinaumsAcctBindBankCardDTO), BaseResponseVO.class);
        if (Constant.RETURN_SUCCESS_CODE.equals(baseResponseVO.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;
        }
    }

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 cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.CharsetUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.poi.excel.ExcelUtil; import cn.hutool.poi.excel.ExcelWriter; import cn.hutool.poi.excel.StyleSet; 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.constants.Constant; 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.ByxChinaumsQueryBillInfoDTO; 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.AuthService; 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 com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxChinaumsQueryBillInfoVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxQueryBillInfoRow; import org.apache.commons.codec.binary.Base64; import org.apache.commons.lang3.StringUtils; import org.apache.poi.ss.usermodel.CellStyle; import org.apache.poi.ss.usermodel.Font; import org.apache.poi.ss.usermodel.HorizontalAlignment; import org.apache.poi.ss.usermodel.VerticalAlignment; import org.apache.poi.ss.util.CellRangeAddress; import org.apache.poi.ss.util.CellReference; 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 javax.servlet.ServletOutputStream; import java.io.IOException; import java.math.BigDecimal; import java.time.LocalDate; 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; @Resource private AuthService authService; @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,5); } @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(); ChinaumsAuthInfo chinaumsAuthInfo = authService.getCurrentAuthInfo(); DateTime dateTime =ObjectUtil.isEmpty(billDate)?DateTime.now(): new DateTime(billDate); ByxChinaumsQueryBillInfoDTO billInfoDTO = new ByxChinaumsQueryBillInfoDTO(); billInfoDTO.setStartDate(DateUtil.beginOfDay(dateTime).toString()); billInfoDTO.setEndDate(DateUtil.endOfDay(dateTime).toString()); billInfoDTO.setWalletId(chinaumsAuthInfo.getBalanceAcctId()); ByxChinaumsQueryBillInfoVO byxChinaumsQueryBillInfoVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_TRADE_BILLS, (JSONObject) JSONObject.toJSON(billInfoDTO), ByxChinaumsQueryBillInfoVO.class); if(Constant.RETURN_SUCCESS_CODE.equals(byxChinaumsQueryBillInfoVO.getRspCode())){ // todo 生成excel并返回下载url export(byxChinaumsQueryBillInfoVO.getTransList()); } return ""; } @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), JSONObject.class); } private void export(List<ByxQueryBillInfoRow> transList){ // 1.获取ExcelWriter对象 ExcelWriter writer = ExcelUtil.getBigWriter(); // 2.写出表头 // 自定义标题别名 writer.addHeaderAlias("name", "姓名"); writer.addHeaderAlias("age", "年龄"); writer.addHeaderAlias("hobby", "爱好"); // ... // 3.定义表头单元格样式(可选) StyleSet style = writer.getStyleSet(); CellStyle headCellStyle = style.getHeadCellStyle(); // 自动换行 headCellStyle.setWrapText(true); // 水平居中 headCellStyle.setAlignment(HorizontalAlignment.CENTER); // 上下居中 headCellStyle.setVerticalAlignment(VerticalAlignment.CENTER); // 设置表头字体大小 Font headFont = writer.createFont(); headFont.setFontName("宋体"); headFont.setFontHeightInPoints((short) 15); // 设置字体大小为15磅 headCellStyle.setFont(headFont); // 4.定义内容单元格样式(可选) CellStyle cellStyle = style.getCellStyle(); cellStyle.setAlignment(HorizontalAlignment.LEFT); // 设置字体大小 Font font = writer.createFont(); font.setFontName("宋体"); cellStyle.setFont(font); // 5.其他设置(可选) // 只写出设置别名的属性 writer.setOnlyAlias(true); // 冻结行 writer.setFreezePane(1); // 6.写入数据设置列宽 writer.write(transList); writer.autoSizeColumnAll(); // 7.开启筛选(可选) // 这里数值为列数 String rangeString = CellReference.convertNumToColString(3) + "1"; CellRangeAddress filterRange = CellRangeAddress.valueOf("A1:" + rangeString); writer.getSheet().setAutoFilter(filterRange); // 8.导出 // response.setCharacterEncoding(CharsetUtil.UTF_8); // response.setHeader("Content-Disposition","attachment;filename=test.xlsx"); // response.setContentType("application/vnd.ms-excel;" + CharsetUtil.UTF_8); // try (ServletOutputStream outputStream = response.getOutputStream()) { // writer.flush(outputStream); // writer.close(); // } catch (Exception e) { // log.warn("批量导出出错：{}", e.getMessage()); // } } } package com.yn.bftl.thirdparty.modules.chinaums.service.impl; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.CharsetUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.poi.excel.ExcelUtil; import cn.hutool.poi.excel.ExcelWriter; import cn.hutool.poi.excel.StyleSet; 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.constants.Constant; 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.ByxChinaumsQueryBillInfoDTO; 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.AuthService; 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 com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxChinaumsQueryBillInfoVO; import com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxQueryBillInfoRow; import org.apache.commons.codec.binary.Base64; import org.apache.commons.lang3.StringUtils; import org.apache.poi.ss.usermodel.CellStyle; import org.apache.poi.ss.usermodel.Font; import org.apache.poi.ss.usermodel.HorizontalAlignment; import org.apache.poi.ss.usermodel.VerticalAlignment; import org.apache.poi.ss.util.CellRangeAddress; import org.apache.poi.ss.util.CellReference; 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 javax.servlet.ServletOutputStream; import java.io.IOException; import java.math.BigDecimal; import java.time.LocalDate; 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; @Resource private AuthService authService; @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(); ChinaumsAuthInfo chinaumsAuthInfo = authService.getCurrentAuthInfo(); DateTime dateTime =ObjectUtil.isEmpty(billDate)?DateTime.now(): new DateTime(billDate); ByxChinaumsQueryBillInfoDTO billInfoDTO = new ByxChinaumsQueryBillInfoDTO(); billInfoDTO.setStartDate(DateUtil.beginOfDay(dateTime).toString()); billInfoDTO.setEndDate(DateUtil.endOfDay(dateTime).toString()); billInfoDTO.setWalletId(chinaumsAuthInfo.getBalanceAcctId()); ByxChinaumsQueryBillInfoVO byxChinaumsQueryBillInfoVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_TRADE_BILLS, (JSONObject) JSONObject.toJSON(billInfoDTO), ByxChinaumsQueryBillInfoVO.class); if(Constant.RETURN_SUCCESS_CODE.equals(byxChinaumsQueryBillInfoVO.getRspCode())){ // todo 生成excel并返回下载url export(byxChinaumsQueryBillInfoVO.getTransList()); } return ""; } @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); } private void export(List<ByxQueryBillInfoRow> transList){ // 1.获取ExcelWriter对象 ExcelWriter writer = ExcelUtil.getBigWriter(); // 2.写出表头 // 自定义标题别名 writer.addHeaderAlias("name", "姓名"); writer.addHeaderAlias("age", "年龄"); writer.addHeaderAlias("hobby", "爱好"); // ... // 3.定义表头单元格样式(可选) StyleSet style = writer.getStyleSet(); CellStyle headCellStyle = style.getHeadCellStyle(); // 自动换行 headCellStyle.setWrapText(true); // 水平居中 headCellStyle.setAlignment(HorizontalAlignment.CENTER); // 上下居中 headCellStyle.setVerticalAlignment(VerticalAlignment.CENTER); // 设置表头字体大小 Font headFont = writer.createFont(); headFont.setFontName("宋体"); headFont.setFontHeightInPoints((short) 15); // 设置字体大小为15磅 headCellStyle.setFont(headFont); // 4.定义内容单元格样式(可选) CellStyle cellStyle = style.getCellStyle(); cellStyle.setAlignment(HorizontalAlignment.LEFT); // 设置字体大小 Font font = writer.createFont(); font.setFontName("宋体"); cellStyle.setFont(font); // 5.其他设置(可选) // 只写出设置别名的属性 writer.setOnlyAlias(true); // 冻结行 writer.setFreezePane(1); // 6.写入数据设置列宽 writer.write(transList); writer.autoSizeColumnAll(); // 7.开启筛选(可选) // 这里数值为列数 String rangeString = CellReference.convertNumToColString(3) + "1"; CellRangeAddress filterRange = CellRangeAddress.valueOf("A1:" + rangeString); writer.getSheet().setAutoFilter(filterRange); // 8.导出 // response.setCharacterEncoding(CharsetUtil.UTF_8); // response.setHeader("Content-Disposition","attachment;filename=test.xlsx"); // response.setContentType("application/vnd.ms-excel;" + CharsetUtil.UTF_8); // try (ServletOutputStream outputStream = response.getOutputStream()) { // writer.flush(outputStream); // writer.close(); // } catch (Exception e) { // log.warn("批量导出出错：{}", e.getMessage()); // } } }

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 cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.CharsetUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.poi.excel.ExcelUtil;
import cn.hutool.poi.excel.ExcelWriter;
import cn.hutool.poi.excel.StyleSet;
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.constants.Constant;
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.ByxChinaumsQueryBillInfoDTO;
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.AuthService;
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 com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxChinaumsQueryBillInfoVO;
import com.yn.bftl.thirdparty.modules.chinaums.vo.byx.ByxQueryBillInfoRow;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.ss.usermodel.CellStyle;
import org.apache.poi.ss.usermodel.Font;
import org.apache.poi.ss.usermodel.HorizontalAlignment;
import org.apache.poi.ss.usermodel.VerticalAlignment;
import org.apache.poi.ss.util.CellRangeAddress;
import org.apache.poi.ss.util.CellReference;
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 javax.servlet.ServletOutputStream;
import java.io.IOException;
import java.math.BigDecimal;
import java.time.LocalDate;
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;
    @Resource
    private AuthService authService;

@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,5);
    }

@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();

ChinaumsAuthInfo chinaumsAuthInfo = authService.getCurrentAuthInfo();
        DateTime dateTime =ObjectUtil.isEmpty(billDate)?DateTime.now(): new DateTime(billDate);

ByxChinaumsQueryBillInfoDTO billInfoDTO = new ByxChinaumsQueryBillInfoDTO();
        billInfoDTO.setStartDate(DateUtil.beginOfDay(dateTime).toString());
        billInfoDTO.setEndDate(DateUtil.endOfDay(dateTime).toString());
        billInfoDTO.setWalletId(chinaumsAuthInfo.getBalanceAcctId());
        ByxChinaumsQueryBillInfoVO byxChinaumsQueryBillInfoVO = byxChinaumsUtil.execute(ByxRouteUtil.ROUTE_WALLET_TRADE_BILLS, (JSONObject) JSONObject.toJSON(billInfoDTO), ByxChinaumsQueryBillInfoVO.class);

if(Constant.RETURN_SUCCESS_CODE.equals(byxChinaumsQueryBillInfoVO.getRspCode())){
            // todo 生成excel并返回下载url
            export(byxChinaumsQueryBillInfoVO.getTransList());
        }

return "";
    }

@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), JSONObject.class);
    }

private void export(List<ByxQueryBillInfoRow> transList){
        // 1.获取ExcelWriter对象
        ExcelWriter writer = ExcelUtil.getBigWriter();
        // 2.写出表头
        // 自定义标题别名
        writer.addHeaderAlias("name", "姓名");
        writer.addHeaderAlias("age", "年龄");
        writer.addHeaderAlias("hobby", "爱好");
        // ...
        // 3.定义表头单元格样式(可选)
        StyleSet style = writer.getStyleSet();
        CellStyle headCellStyle = style.getHeadCellStyle();
        // 自动换行
        headCellStyle.setWrapText(true);
        // 水平居中
        headCellStyle.setAlignment(HorizontalAlignment.CENTER);
        // 上下居中
        headCellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
        // 设置表头字体大小
        Font headFont = writer.createFont();
        headFont.setFontName("宋体");
        headFont.setFontHeightInPoints((short) 15); // 设置字体大小为15磅
        headCellStyle.setFont(headFont);
        // 4.定义内容单元格样式(可选)
        CellStyle cellStyle = style.getCellStyle();
        cellStyle.setAlignment(HorizontalAlignment.LEFT);
        // 设置字体大小
        Font font = writer.createFont();
        font.setFontName("宋体");
        cellStyle.setFont(font);
        // 5.其他设置(可选)
        // 只写出设置别名的属性
        writer.setOnlyAlias(true);
        // 冻结行
        writer.setFreezePane(1);
        // 6.写入数据 设置列宽
        writer.write(transList);
        writer.autoSizeColumnAll();
        // 7.开启筛选(可选)
        // 这里数值为列数
        String rangeString = CellReference.convertNumToColString(3) + "1";
        CellRangeAddress filterRange = CellRangeAddress.valueOf("A1:" + rangeString);
        writer.getSheet().setAutoFilter(filterRange);
        // 8.导出
//        response.setCharacterEncoding(CharsetUtil.UTF_8);
//        response.setHeader("Content-Disposition","attachment;filename=test.xlsx");
//        response.setContentType("application/vnd.ms-excel;" + CharsetUtil.UTF_8);
//        try (ServletOutputStream outputStream = response.getOutputStream()) {
//            writer.flush(outputStream);
//            writer.close();
//        } catch (Exception e) {
//            log.warn("批量导出出错：{}", e.getMessage());
//        }
    }

}

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

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

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

ChinaumsAuthInfo chinaumsAuthInfo = authService.getCurrentAuthInfo();
        DateTime dateTime =ObjectUtil.isEmpty(billDate)?DateTime.now(): new DateTime(billDate);

return "";
    }

@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);
    }

}

Ignore Space Show notes View src/main/resources/application-dev.yml
server: port: 8002 spring: config: activate: on-profile: dev servlet: multipart: enabled: true max-file-size: 50MB max-request-size: 50MB datasource: driverClassName: com.mysql.cj.jdbc.Driver # url: jdbc:mysql://rm-wz9v86640axofea90.mysql.rds.aliyuncs.com:3306/app_huabiao_yn_bftl_develop_dev?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai # username: app_huabiao # password: Asdf123!@# url: jdbc:mysql://182.44.68.187:13306/baiyexing?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai username: baiyexing password: baiyexing@@1234 hikari: maximum-pool-size: 10 minimum-idle: 2 idle-timeout: 30000 max-lifetime: 3600000 # 设置最大生命周期为60分钟 connection-test-query: SELECT 1 # 连接有效性检查查询 jpa: hibernate: ddlAuto: none showSql: false properties: hibernate: session_factory: interceptor: com.yn.bftl.thirdparty.interceptor.AuditInterceptor redis: database: 14 host: 182.44.68.187 port: 16379 pool: max-active: 8 max-wait: 1 max-idle: 8 min-idle: 0 timeout: 20000 password: baiyexing@123456 # rabbitmq: # host: localhost # port: 5672 # username: bftl # password: YnceRabbitmq0319 # virtual-host: /bftl # data: # mongodb: # repositories: # type: none # elasticsearch: # repositories: # enabled: false file: basePath: /root/files urlPath: http://hypass.file.yn-ce.com:8088/bftl/ qiniu: accessKey: Vo_jAis-RYsjC7n9pGTtTh2Oa6wtkyq52aiLaiyg secretKey: jyYMQfpcA4naN-Pxsxr-UgBHubtr_nK-Y4HQzun0 bucketName: bftl domain: files: http://files.bftl.yn-ce.com video: http://video.bftl.yn-ce.com image: xxxx proxy: host: 10.27.182.59 port: 18889 server: port: 8002 spring: config: activate: on-profile: dev servlet: multipart: enabled: true max-file-size: 50MB max-request-size: 50MB datasource: driverClassName: com.mysql.cj.jdbc.Driver # url: jdbc:mysql://rm-wz9v86640axofea90.mysql.rds.aliyuncs.com:3306/app_huabiao_yn_bftl_develop_dev?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai # username: app_huabiao # password: Asdf123!@# url: jdbc:mysql://182.44.68.187:13306/baiyexing?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai username: baiyexing password: baiyexing@@1234 jpa: hibernate: ddlAuto: none showSql: false properties: hibernate: session_factory: interceptor: com.yn.bftl.thirdparty.interceptor.AuditInterceptor redis: database: 14 host: 182.44.68.187 port: 16379 pool: max-active: 8 max-wait: 1 max-idle: 8 min-idle: 0 timeout: 20000 password: baiyexing@123456 # rabbitmq: # host: localhost # port: 5672 # username: bftl # password: YnceRabbitmq0319 # virtual-host: /bftl # data: # mongodb: # repositories: # type: none # elasticsearch: # repositories: # enabled: false file: basePath: /root/files urlPath: http://hypass.file.yn-ce.com:8088/bftl/ qiniu: accessKey: Vo_jAis-RYsjC7n9pGTtTh2Oa6wtkyq52aiLaiyg secretKey: jyYMQfpcA4naN-Pxsxr-UgBHubtr_nK-Y4HQzun0 bucketName: bftl domain: files: http://files.bftl.yn-ce.com video: http://video.bftl.yn-ce.com image: xxxx proxy: host: 10.27.182.59 port: 18889

Ignore Space Show notes View

src/main/resources/application-dev.yml

server:
  port: 8002
spring:
  config:
    activate:
      on-profile: dev
  servlet:
    multipart:
      enabled: true
      max-file-size: 50MB
      max-request-size: 50MB
  datasource:
    driverClassName: com.mysql.cj.jdbc.Driver
#    url: jdbc:mysql://rm-wz9v86640axofea90.mysql.rds.aliyuncs.com:3306/app_huabiao_yn_bftl_develop_dev?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai
#    username: app_huabiao
#    password: Asdf123!@#
    url: jdbc:mysql://182.44.68.187:13306/baiyexing?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai
    username: baiyexing
    password: baiyexing@@1234
    hikari:
      maximum-pool-size: 10
      minimum-idle: 2
      idle-timeout: 30000
      max-lifetime: 3600000 # 设置最大生命周期为60分钟
      connection-test-query: SELECT 1 # 连接有效性检查查询
  jpa:
    hibernate:
      ddlAuto: none
    showSql: false
    properties:
      hibernate:
        session_factory:
          interceptor: com.yn.bftl.thirdparty.interceptor.AuditInterceptor
  redis:
    database: 14
    host: 182.44.68.187
    port: 16379
    pool:
      max-active: 8
      max-wait: 1
      max-idle: 8
      min-idle: 0
    timeout: 20000
    password: baiyexing@123456
#  rabbitmq:
#    host: localhost
#    port: 5672
#    username: bftl
#    password: YnceRabbitmq0319
#    virtual-host: /bftl
#  data:
#    mongodb:
#      repositories:
#        type: none
#    elasticsearch:
#      repositories:
#        enabled: false
file:
  basePath: /root/files
  urlPath: http://hypass.file.yn-ce.com:8088/bftl/
qiniu:
  accessKey: Vo_jAis-RYsjC7n9pGTtTh2Oa6wtkyq52aiLaiyg
  secretKey: jyYMQfpcA4naN-Pxsxr-UgBHubtr_nK-Y4HQzun0
  bucketName: bftl
  domain:
    files: http://files.bftl.yn-ce.com
    video: http://video.bftl.yn-ce.com
    image: xxxx
proxy:
  host: 10.27.182.59
  port: 18889

server:
  port: 8002
spring:
  config:
    activate:
      on-profile: dev
  servlet:
    multipart:
      enabled: true
      max-file-size: 50MB
      max-request-size: 50MB
  datasource:
    driverClassName: com.mysql.cj.jdbc.Driver
#    url: jdbc:mysql://rm-wz9v86640axofea90.mysql.rds.aliyuncs.com:3306/app_huabiao_yn_bftl_develop_dev?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai
#    username: app_huabiao
#    password: Asdf123!@#
    url: jdbc:mysql://182.44.68.187:13306/baiyexing?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai
    username: baiyexing
    password: baiyexing@@1234
  jpa:
    hibernate:
      ddlAuto: none
    showSql: false
    properties:
      hibernate:
        session_factory:
          interceptor: com.yn.bftl.thirdparty.interceptor.AuditInterceptor
  redis:
    database: 14
    host: 182.44.68.187
    port: 16379
    pool:
      max-active: 8
      max-wait: 1
      max-idle: 8
      min-idle: 0
    timeout: 20000
    password: baiyexing@123456
#  rabbitmq:
#    host: localhost
#    port: 5672
#    username: bftl
#    password: YnceRabbitmq0319
#    virtual-host: /bftl
#  data:
#    mongodb:
#      repositories:
#        type: none
#    elasticsearch:
#      repositories:
#        enabled: false
file:
  basePath: /root/files
  urlPath: http://hypass.file.yn-ce.com:8088/bftl/
qiniu:
  accessKey: Vo_jAis-RYsjC7n9pGTtTh2Oa6wtkyq52aiLaiyg
  secretKey: jyYMQfpcA4naN-Pxsxr-UgBHubtr_nK-Y4HQzun0
  bucketName: bftl
  domain:
    files: http://files.bftl.yn-ce.com
    video: http://video.bftl.yn-ce.com
    image: xxxx
proxy:
  host: 10.27.182.59
  port: 18889

Show line notes below