调整更新票据逻辑

master
钱涛 2 months ago
parent dfcb8f95f7
commit a5e30b3f37

@ -132,17 +132,17 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob {
requestParam.setEndDate(nowDate); requestParam.setEndDate(nowDate);
} }
requestParam.setLoanType(loanType); requestParam.setLoanType(loanType);
requestParam.setPaymentNatureList(paymentNatureList == null ? null :Arrays.stream(paymentNatureList.split(",")).collect(Collectors.toList())); requestParam.setPaymentNatureList(paymentNatureList == null ? null : Arrays.stream(paymentNatureList.split(",")).collect(Collectors.toList()));
requestParam.setDateType(dateType); requestParam.setDateType(dateType);
requestParam.setAccountNoList(accountNoList== null ? null :Arrays.stream(accountNoList.split(",")).collect(Collectors.toList())); requestParam.setAccountNoList(accountNoList == null ? null : Arrays.stream(accountNoList.split(",")).collect(Collectors.toList()));
requestParam.setBankTypeList(bankTypeList== null ? null :Arrays.stream(bankTypeList.split(",")).collect(Collectors.toList())); requestParam.setBankTypeList(bankTypeList == null ? null : Arrays.stream(bankTypeList.split(",")).collect(Collectors.toList()));
requestParam.setCurrencyList(currencyList== null ? null :Arrays.stream(currencyList.split(",")).collect(Collectors.toList())); requestParam.setCurrencyList(currencyList == null ? null : Arrays.stream(currencyList.split(",")).collect(Collectors.toList()));
requestParam.setDetailedSources(detailedSources); requestParam.setDetailedSources(detailedSources);
requestParam.setCurrentFlag(currentFlag); requestParam.setCurrentFlag(currentFlag);
requestParam.setAccountNatureList(accountNatureList== null ? null :Arrays.stream(accountNatureList.split(",")).collect(Collectors.toList())); requestParam.setAccountNatureList(accountNatureList == null ? null : Arrays.stream(accountNatureList.split(",")).collect(Collectors.toList()));
requestParam.setBankSerialNumber(bankSerialNumber); requestParam.setBankSerialNumber(bankSerialNumber);
requestParam.setTransactionSerialNumber(transactionSerialNumber); requestParam.setTransactionSerialNumber(transactionSerialNumber);
requestParam.setUnitCodeList(unitCodeList== null ? null :Arrays.stream(unitCodeList.split(",")).collect(Collectors.toList())); requestParam.setUnitCodeList(unitCodeList == null ? null : Arrays.stream(unitCodeList.split(",")).collect(Collectors.toList()));
requestParam.setErpSerialNumber(erpSerialNumber); requestParam.setErpSerialNumber(erpSerialNumber);
//查询前1000条数据 //查询前1000条数据
@ -217,7 +217,7 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob {
add(String.format("'%s'", currDate)); add(String.format("'%s'", currDate));
add(String.format("'%s'", currTime)); add(String.format("'%s'", currTime));
}}; }};
String hkr = ""; String hkr = "";
for (EBS2ECConfig.Table.Field field : table.getFields()) { for (EBS2ECConfig.Table.Field field : table.getFields()) {
//数据库字段 //数据库字段
@ -225,14 +225,14 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob {
fields.add(fieldName); fields.add(fieldName);
// 接口值 // 接口值
String value = detailMap.getOrDefault(field.getEbsKey(), ""); String value = detailMap.getOrDefault(field.getEbsKey(), "");
values.add(String.format("'%s'", detailMap.getOrDefault(field.getEbsKey(), ""))); values.add(String.format("'%s'", value));
//汇款人 //汇款人
if ("hkr".equals(fieldName)) { if ("hkr".equals(fieldName)) {
hkr = value; hkr = value;
} }
} }
//业务逻辑字段,收款类型,默认是银行存款 //业务逻辑字段,收款类型,默认是银行存款
fields.add("sklx"); fields.add("sklx");
values.add(0); values.add(0);
@ -244,7 +244,7 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob {
* *
*/ */
Integer departmentId = customerDepartmentMap.get(hkr); Integer departmentId = customerDepartmentMap.get(hkr);
if(departmentId!=null){ if (departmentId != null) {
//认领 //认领
fields.add("zt"); fields.add("zt");
values.add(1); values.add(1);
@ -255,8 +255,8 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob {
//办事处 //办事处
fields.add("szbm"); fields.add("szbm");
values.add(departmentId); values.add(String.format("'%s'", departmentId));
}else { } else {
//未认领 //未认领
fields.add("zt"); fields.add("zt");
values.add(0); values.add(0);

@ -167,13 +167,13 @@ public class SyncCBSBillPoolJob extends BaseCronJob {
} }
requestParam.setHoldAccountList(Arrays.stream(holdAccountList.split(",")).collect(Collectors.toList())); requestParam.setHoldAccountList(Arrays.stream(holdAccountList.split(",")).collect(Collectors.toList()));
if (StrUtil.isNotBlank(issueDateStart) && StrUtil.isNotBlank(issueDateEnd)) { if (StrUtil.isNotBlank(holdSignDateStart) && StrUtil.isNotBlank(holdSignDateEnd)) {
requestParam.setIssueDateStart(issueDateStart); requestParam.setHoldSignDateStart(holdSignDateStart);
requestParam.setIssueDateEnd(issueDateEnd); requestParam.setHoldSignDateEnd(holdSignDateEnd);
} else { } else {
String nowDate = LocalDate.now().toString(); String nowDate = LocalDate.now().toString();
requestParam.setIssueDateStart(nowDate); requestParam.setHoldSignDateStart(nowDate);
requestParam.setIssueDateEnd(nowDate); requestParam.setHoldSignDateEnd(nowDate);
} }
//系统票据类型 //系统票据类型
@ -184,8 +184,8 @@ public class SyncCBSBillPoolJob extends BaseCronJob {
requestParam.setBillType(billType); requestParam.setBillType(billType);
requestParam.setDraftSourceList(draftSourceList==null ? null :Arrays.stream(draftSourceList.split(",")).collect(Collectors.toList())); requestParam.setDraftSourceList(draftSourceList==null ? null :Arrays.stream(draftSourceList.split(",")).collect(Collectors.toList()));
requestParam.setHoldBankTypeList(holdBankTypeList==null ? null :Arrays.stream(holdBankTypeList.split(",")).collect(Collectors.toList())); requestParam.setHoldBankTypeList(holdBankTypeList==null ? null :Arrays.stream(holdBankTypeList.split(",")).collect(Collectors.toList()));
requestParam.setHoldSignDateStart(holdSignDateStart); requestParam.setIssueDateStart(issueDateStart);
requestParam.setHoldSignDateEnd(holdSignDateEnd); requestParam.setIssueDateEnd(issueDateEnd);
requestParam.setDraftNbr(draftNbr); requestParam.setDraftNbr(draftNbr);
requestParam.setBillNbr(billNbr); requestParam.setBillNbr(billNbr);
requestParam.setBillAmountStart(billAmountStart); requestParam.setBillAmountStart(billAmountStart);

@ -173,13 +173,13 @@ public class SyncCBSPayDetailsJob extends BaseCronJob {
} }
requestParam.setHoldAccountList(Arrays.stream(holdAccountList.split(",")).collect(Collectors.toList())); requestParam.setHoldAccountList(Arrays.stream(holdAccountList.split(",")).collect(Collectors.toList()));
if (StrUtil.isNotBlank(issueDateStart) && StrUtil.isNotBlank(issueDateEnd)) { if (StrUtil.isNotBlank(holdSignDateStart) && StrUtil.isNotBlank(holdSignDateEnd)) {
requestParam.setIssueDateStart(issueDateStart); requestParam.setHoldSignDateStart(holdSignDateStart);
requestParam.setIssueDateEnd(issueDateEnd); requestParam.setHoldSignDateEnd(holdSignDateEnd);
} else { } else {
String nowDate = LocalDate.now().toString(); String nowDate = LocalDate.now().toString();
requestParam.setIssueDateStart(nowDate); requestParam.setHoldSignDateStart(nowDate);
requestParam.setIssueDateEnd(nowDate); requestParam.setHoldSignDateEnd(nowDate);
} }
//系统票据类型 //系统票据类型
@ -190,8 +190,8 @@ public class SyncCBSPayDetailsJob extends BaseCronJob {
requestParam.setBillType(billType); requestParam.setBillType(billType);
requestParam.setDraftSourceList(draftSourceList==null ? null :Arrays.stream(draftSourceList.split(",")).collect(Collectors.toList())); requestParam.setDraftSourceList(draftSourceList==null ? null :Arrays.stream(draftSourceList.split(",")).collect(Collectors.toList()));
requestParam.setHoldBankTypeList(holdBankTypeList==null ? null :Arrays.stream(holdBankTypeList.split(",")).collect(Collectors.toList())); requestParam.setHoldBankTypeList(holdBankTypeList==null ? null :Arrays.stream(holdBankTypeList.split(",")).collect(Collectors.toList()));
requestParam.setHoldSignDateStart(holdSignDateStart); requestParam.setIssueDateStart(issueDateStart);
requestParam.setHoldSignDateEnd(holdSignDateEnd); requestParam.setIssueDateEnd(issueDateEnd);
requestParam.setDraftNbr(draftNbr); requestParam.setDraftNbr(draftNbr);
requestParam.setBillNbr(billNbr); requestParam.setBillNbr(billNbr);
requestParam.setBillAmountStart(billAmountStart); requestParam.setBillAmountStart(billAmountStart);
@ -314,7 +314,7 @@ public class SyncCBSPayDetailsJob extends BaseCronJob {
//办事处 //办事处
fields.add("szbm"); fields.add("szbm");
values.add(departmentId); values.add(String.format("'%s'", departmentId));
}else { }else {
//未认领 //未认领
fields.add("zt"); fields.add("zt");

Loading…
Cancel
Save