platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/BusinessCustomerServiceImpl.java
@@ -11,6 +11,7 @@
import com.by4cloud.platformx.business.mapper.BusinessCustomerMapper;
import com.by4cloud.platformx.business.service.BusinessCustomerService;
import com.by4cloud.platformx.business.vo.BankNameVo;
import com.by4cloud.platformx.business.vo.BusinessCustomerMainVo;
import com.by4cloud.platformx.business.vo.CustBankVo;
import com.by4cloud.platformx.business.vo.CustInfoVo;
import com.by4cloud.platformx.common.core.util.R;
@@ -35,11 +36,15 @@
   private final BipBanklViewMapper bipBanklViewMapper;
   @Override
   public R syncMainBusCus() {
      List<BusinessCustomer> bcList = baseMapper.selectList(Wrappers.<BusinessCustomer>lambdaQuery().isNull(BusinessCustomer::getCreditCode)
            .or().isNull(BusinessCustomer::getLegalPerson).or().isNull(BusinessCustomer::getLegalPerson)
            .or().isNull(BusinessCustomer::getBankName).or().isNull(BusinessCustomer::getBankAccount)
            .or().isNull(BusinessCustomer::getRegisterName));
   public R syncMainBusCus(String compId) {
      List<BusinessCustomer> bcList = baseMapper.selectList(Wrappers.<BusinessCustomer>lambdaQuery()
            .eq(StrUtil.isNotEmpty(compId),BusinessCustomer::getCompId,compId)
            .and(wrapper -> wrapper.isNull(BusinessCustomer::getCreditCode)
            .or().isNull(BusinessCustomer::getLegalPerson)
            .or().isNull(BusinessCustomer::getBankName)
            .or().isNull(BusinessCustomer::getBankAccount)
            .or().isNull(BusinessCustomer::getRegisterName))
      );
      if (ArrayUtil.isNotEmpty(bcList.toArray())){
         for (BusinessCustomer bc:bcList
             ) {
@@ -48,21 +53,21 @@
            if (ObjUtil.isNotNull(custInfo)){
               bc.setCreditCode(custInfo.getCertificateId());
               bc.setRegisterName(custInfo.getCustName());
               bc.setLegalPerson(custInfo.getLegalGerson());
               bc.setLegalPerson(custInfo.getLegalPerson());
               bc.setAddress(custInfo.getRegistrationAddress());
               baseMapper.updateById(bc);
               log.info("{}同步名称、法人、地址、信用码信息成功",bc.getCompanyName());
            }
            CustBankVo bankVo = bipViewMapper.selectBankByCustName(bc.getCompanyName());
            if (ObjUtil.isNotNull(bankVo)){
            List<CustBankVo> bankVoList = bipViewMapper.selectBankByCustName(bc.getCompanyName());
            if (ArrayUtil.isNotEmpty(bankVoList.toArray())){
               if (StrUtil.isEmpty(bc.getBankAccount())){
                  bc.setBankAccount(bankVo.getBankAccount());
                  bc.setBankAccount(bankVoList.get(0).getBankAccount());
                  baseMapper.updateById(bc);
                  log.info("{}同步银行卡号信息成功",bc.getCompanyName());
               }
               BankNameVo bankNameVo = bipBanklViewMapper.selectBankByCode(bankVo.getBankName());
               if (ObjUtil.isNotNull(bankVo)){
                  bc.setBankName(bankNameVo.getBankNameName());
               List<BankNameVo> bankNameVoList = bipBanklViewMapper.selectBankByCode(bankVoList.get(0).getBankName());
               if (ArrayUtil.isNotEmpty(bankNameVoList.toArray())){
                  bc.setBankName(bankNameVoList.get(0).getBankNameName());
                  baseMapper.updateById(bc);
                  log.info("{}同步银行名称信息成功",bc.getCompanyName());
               }
@@ -72,4 +77,32 @@
      }
      return R.ok();
   }
   @Override
   public BusinessCustomerMainVo queryMainBC(String companyName) {
      BusinessCustomerMainVo bc = new BusinessCustomerMainVo();
      bc.setCompanyName(companyName);
      log.info("主数据查询{}信息",companyName);
      CustInfoVo custInfo = bipViewMapper.selectBaseInfoByCustName(companyName);
      if (ObjUtil.isNotNull(custInfo)){
         bc.setCreditCode(custInfo.getCertificateId());
         bc.setRegisterName(custInfo.getCustName());
         bc.setLegalPerson(custInfo.getLegalPerson());
         bc.setAddress(custInfo.getRegistrationAddress());
         log.info("{}主数据查询名称、法人、地址、信用码信息成功",companyName);
      }
      List<CustBankVo> bankVoList = bipViewMapper.selectBankByCustName(bc.getCompanyName());
      if (ArrayUtil.isNotEmpty(bankVoList.toArray())){
         if (StrUtil.isEmpty(bc.getBankAccount())){
            bc.setBankAccount(bankVoList.get(0).getBankAccount());
            log.info("{}主数据查询银行卡号信息成功",companyName);
         }
         List<BankNameVo> bankNameVoList = bipBanklViewMapper.selectBankByCode(bankVoList.get(0).getBankName());
         if (ArrayUtil.isNotEmpty(bankNameVoList.toArray())){
            bc.setBankName(bankNameVoList.get(0).getBankNameName());
            log.info("{}主数据查询银行名称信息成功",companyName);
         }
      }
      return bc;
   }
}