| | |
| | | package com.by4cloud.platformx.business.service.impl; |
| | | |
| | | import cn.hutool.core.util.ArrayUtil; |
| | | import cn.hutool.core.util.ObjUtil; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.by4cloud.platformx.business.entity.BusinessCustomer; |
| | | import com.by4cloud.platformx.business.mapper.BipBanklViewMapper; |
| | | import com.by4cloud.platformx.business.mapper.BipViewMapper; |
| | | 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.CustBankVo; |
| | | import com.by4cloud.platformx.business.vo.CustInfoVo; |
| | | import com.by4cloud.platformx.common.core.util.R; |
| | | import lombok.RequiredArgsConstructor; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * 客商信息 |
| | | * |
| | | * @author platformx |
| | | * @date 2026-05-07 10:13:22 |
| | | */ |
| | | @Slf4j |
| | | @RequiredArgsConstructor |
| | | @Service |
| | | public class BusinessCustomerServiceImpl extends ServiceImpl<BusinessCustomerMapper, BusinessCustomer> implements BusinessCustomerService { |
| | | |
| | | private final BipViewMapper bipViewMapper; |
| | | 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)); |
| | | if (ArrayUtil.isNotEmpty(bcList.toArray())){ |
| | | for (BusinessCustomer bc:bcList |
| | | ) { |
| | | log.info("开始同步{}信息",bc.getCompanyName()); |
| | | CustInfoVo custInfo = bipViewMapper.selectBaseInfoByCustName(bc.getCompanyName()); |
| | | if (ObjUtil.isNotNull(custInfo)){ |
| | | bc.setCreditCode(custInfo.getCertificateId()); |
| | | bc.setRegisterName(custInfo.getCustName()); |
| | | bc.setLegalPerson(custInfo.getLegalGerson()); |
| | | bc.setAddress(custInfo.getRegistrationAddress()); |
| | | baseMapper.updateById(bc); |
| | | log.info("{}同步名称、法人、地址、信用码信息成功",bc.getCompanyName()); |
| | | } |
| | | CustBankVo bankVo = bipViewMapper.selectBankByCustName(bc.getCompanyName()); |
| | | if (ObjUtil.isNotNull(bankVo)){ |
| | | if (StrUtil.isEmpty(bc.getBankAccount())){ |
| | | bc.setBankAccount(bankVo.getBankAccount()); |
| | | baseMapper.updateById(bc); |
| | | log.info("{}同步银行卡号信息成功",bc.getCompanyName()); |
| | | } |
| | | BankNameVo bankNameVo = bipBanklViewMapper.selectBankByCode(bankVo.getBankName()); |
| | | if (ObjUtil.isNotNull(bankVo)){ |
| | | bc.setBankName(bankNameVo.getBankNameName()); |
| | | baseMapper.updateById(bc); |
| | | log.info("{}同步银行名称信息成功",bc.getCompanyName()); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | return R.ok(); |
| | | } |
| | | } |