diff --git a/src/com/engine/salary/timer/SyncCBSAccountDetailsJob.java b/src/com/engine/salary/timer/SyncCBSAccountDetailsJob.java index c13733c..e487961 100644 --- a/src/com/engine/salary/timer/SyncCBSAccountDetailsJob.java +++ b/src/com/engine/salary/timer/SyncCBSAccountDetailsJob.java @@ -223,6 +223,7 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob { }}; String hkr = ""; + String je = ""; for (EBS2ECConfig.Table.Field field : table.getFields()) { //数据库字段 String fieldName = field.getKey(); @@ -235,6 +236,11 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob { if ("hkr".equals(fieldName)) { hkr = value; } + + //金额 + if ("je".equals(fieldName)) { + je = value; + } } //业务逻辑字段,收款类型,默认是银行存款 @@ -260,6 +266,12 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob { fields.add("sfxtzdrl"); values.add(1); + //是否系统自动认领=1 ,已认领金额(yrlje)=金额(je),未认领金额(wrlje)=0 + fields.add("yrlje"); + values.add(String.format("'%s'", je)); + fields.add("wrlje"); + values.add(String.format("'%s'", 0)); + //办事处 fields.add("szbm"); values.add(String.format("'%s'", "1412")); @@ -290,6 +302,12 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob { fields.add("sfxtzdrl"); values.add(1); + //是否系统自动认领=1 ,已认领金额(yrlje)=金额(je),未认领金额(wrlje)=0 + fields.add("yrlje"); + values.add(String.format("'%s'", je)); + fields.add("wrlje"); + values.add(String.format("'%s'", 0)); + //办事处 fields.add("szbm"); List bmbmList = Arrays.stream(bmbms.split(",")).map(departmentMap::get).filter(StrUtil::isNotBlank).collect(Collectors.toList()); @@ -303,6 +321,16 @@ public class SyncCBSAccountDetailsJob extends BaseCronJob { //未认领 fields.add("zt"); values.add(0); + + //是否系统认领 + fields.add("sfxtzdrl"); + values.add(0); + + //是否系统自动认领(sfxtzdrl)=0,已认领金额(yrlje)=0 ,未认领金额(wrlje)=金额(je) + fields.add("yrlje"); + values.add(String.format("'%s'", 0)); + fields.add("wrlje"); + values.add(String.format("'%s'", je)); } String sql = String.format("insert into %s (%s) values (%s)", tableName, String.join(",", fields), values.stream().map(Object::toString).collect(Collectors.joining(","))); diff --git a/src/com/engine/salary/timer/SyncCBSPayDetailsJob.java b/src/com/engine/salary/timer/SyncCBSPayDetailsJob.java index 8369d34..d17ceeb 100644 --- a/src/com/engine/salary/timer/SyncCBSPayDetailsJob.java +++ b/src/com/engine/salary/timer/SyncCBSPayDetailsJob.java @@ -281,6 +281,7 @@ public class SyncCBSPayDetailsJob extends BaseCronJob { }}; String hkr = ""; + String je = ""; for (EBS2ECConfig.Table.Field field : table.getFields()) { //数据库字段 String fieldName = field.getKey(); @@ -293,6 +294,11 @@ public class SyncCBSPayDetailsJob extends BaseCronJob { if ("hkr".equals(fieldName)) { hkr = value; } + + //金额 + if ("je".equals(fieldName)) { + je = value; + } } //业务逻辑字段,收款类型 @@ -326,6 +332,12 @@ public class SyncCBSPayDetailsJob extends BaseCronJob { fields.add("sfxtzdrl"); values.add(1); + //是否系统自动认领=1 ,已认领金额(yrlje)=金额(je),未认领金额(wrlje)=0 + fields.add("yrlje"); + values.add(String.format("'%s'", je)); + fields.add("wrlje"); + values.add(String.format("'%s'", 0)); + //办事处 fields.add("szbm"); List bmbmList = Arrays.stream(bmbms.split(",")).map(departmentMap::get).filter(StrUtil::isNotBlank).collect(Collectors.toList()); @@ -334,6 +346,16 @@ public class SyncCBSPayDetailsJob extends BaseCronJob { //未认领 fields.add("zt"); values.add(0); + + //是否系统认领 + fields.add("sfxtzdrl"); + values.add(0); + + //是否系统自动认领(sfxtzdrl)=0,已认领金额(yrlje)=0 ,未认领金额(wrlje)=金额(je) + fields.add("yrlje"); + values.add(String.format("'%s'", 0)); + fields.add("wrlje"); + values.add(String.format("'%s'", je)); } } else { //未认领