package com.fzzy.async.fzzy30.impl; import com.fzzy.api.Constant; import com.fzzy.api.entity.Api1102; import com.fzzy.api.entity.Api1201; import com.fzzy.api.entity.ApiLog; import com.fzzy.api.service.ApiTriggerService; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.view.repository.Api1102Rep; import com.fzzy.api.view.repository.Api1201Rep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.async.fzzy30.entity.MContract; import com.fzzy.async.fzzy30.repository.FzzySync1201Rep; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.math.BigDecimal; import java.util.Date; import java.util.List; /** * 合同信息数据接口 */ @Slf4j @Component public class Fzzy30Sync1201 { @Autowired private FzzySync1201Rep fzzySync1201Rep; @Autowired private ApiTriggerService apiTriggerService; @Autowired private Api1201Rep api1201Rep; @Autowired private Api1102Rep api1102Rep; @Autowired private ApiLogRep apiLogRep; /** * 同步合同接口 * * @param deptId * @param start * @param end */ public void syncData(String kqdm, String deptId, Date start, Date end) { log.info("-------------1201接口数据开始同步------------------"); //同步数据,只记录失败的信息 ApiLog apiLog = new ApiLog(); apiLog.setType(ApiLog.TYPE_SYNC); apiLog.setKqdm(deptId); apiLog.setUploadTime(new Date()); apiLog.setInteId(Constant.API_CODE_1201); apiLog.setStatus(99); apiLog.setId(ContextUtil.getUUID()); try { List list = fzzySync1201Rep.listContract(deptId, start, end); if (null == list || list.isEmpty()) { log.info("-------------没有获取到合同信息------------------"); return; } //根据库区代码获取单位代码 Api1102 api1201 = api1102Rep.findById(kqdm).get(); Api1201 apiData; for (MContract sysData : list) { apiData = new Api1201(); //单位代码( 1101 接口的单位代 码) +自定义编码 apiData.setHth(api1201.getDwdm() + sysData.getId()); apiData.setHtmc(sysData.getName()); apiData.setDwdm(api1201.getDwdm()); //业务类型 String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_HT_YWLX, sysData.getType()); apiData.setYwlx(mappingCode); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_KHLX, sysData.getCustomerType()); apiData.setKhlx(mappingCode); apiData.setKhtyshxydm(sysData.getCustomerId()); apiData.setKhmc(sysData.getCustomerName()); apiData.setFddbr(sysData.getCustomerSignUser()); apiData.setQdrq(sysData.getSigningTime()); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety()); apiData.setLspzdm(mappingCode); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodVariety()); apiData.setLsxzdm(mappingCode); apiData.setHtdj(sysData.getPrice()); apiData.setYdgxlssl(sysData.getContactAmount()); apiData.setHtzje(new BigDecimal(sysData.getMoney())); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_JSYHTYZX, ""); apiData.setJsyhtyzx(mappingCode); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_BANK, sysData.getCustomerBank()); apiData.setKhfkhh(mappingCode); apiData.setKhfzh(sysData.getCustomerBankAccount()); apiData.setKhqyr(sysData.getCustomerSignUser()); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_BANK, sysData.getBank()); apiData.setBfkhh(mappingCode); apiData.setBfzh(sysData.getBankAccount()); apiData.setWcrq(sysData.getEndTime()); apiData.setCzbz(Constant.CZBZ_I); apiData.setZhgxsj(sysData.getCreateTime()); apiData.setSyncTime(new Date()); apiData.setBizId(sysData.getId()); apiLog.setDataId(apiData.getBizId()); //保存数据 api1201Rep.save(apiData); log.info("1201---同步数据:{}", apiData.toString()); } } catch (Exception e) { log.error("---合同同步执行失败----{}", e); apiLog.setResult("同步合同信息失败:" + e.getMessage()); apiLogRep.save(apiLog); } } }