diff --git a/nms_sync/.gitignore b/nms_sync/.gitignore new file mode 100644 index 0000000..ae3c172 --- /dev/null +++ b/nms_sync/.gitignore @@ -0,0 +1 @@ +/bin/ diff --git a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$2$1.class b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$2$1.class index 9ac1c4b..2a27db2 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$2$1.class and b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$2$1.class differ diff --git a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3$1.class b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3$1.class index a5d2e01..fed7e3b 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3$1.class and b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3$1.class differ diff --git a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3.class b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3.class index 98d4465..6a77e70 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3.class and b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread$3.class differ diff --git a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread.class b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread.class index 3c0ad03..85aa516 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread.class and b/nms_sync/bin/com/nms/thread/SyncSlaveToMasterThread.class differ diff --git a/nms_sync/bin/com/nms/thread/SyncThread$2$1.class b/nms_sync/bin/com/nms/thread/SyncThread$2$1.class index 159b103..1f63c5f 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncThread$2$1.class and b/nms_sync/bin/com/nms/thread/SyncThread$2$1.class differ diff --git a/nms_sync/bin/com/nms/thread/SyncThread$3$1.class b/nms_sync/bin/com/nms/thread/SyncThread$3$1.class index 2fe9630..67fe42e 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncThread$3$1.class and b/nms_sync/bin/com/nms/thread/SyncThread$3$1.class differ diff --git a/nms_sync/bin/com/nms/thread/SyncThread$3.class b/nms_sync/bin/com/nms/thread/SyncThread$3.class index 231cef1..4f124eb 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncThread$3.class and b/nms_sync/bin/com/nms/thread/SyncThread$3.class differ diff --git a/nms_sync/bin/com/nms/thread/SyncThread.class b/nms_sync/bin/com/nms/thread/SyncThread.class index c4a2a47..37c01f9 100644 Binary files a/nms_sync/bin/com/nms/thread/SyncThread.class and b/nms_sync/bin/com/nms/thread/SyncThread.class differ diff --git a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java index 18f1b31..fcf5f5d 100644 --- a/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java +++ b/nms_sync/src/com/nms/thread/SyncSlaveToMasterThread.java @@ -108,6 +108,9 @@ public class SyncSlaveToMasterThread implements Runnable{ for(Record insertData:insertDatas){ Record seqData = Db.use("masterDataSource").findFirst("select nextval('seq_"+record.getStr("table_name")+"') seqId from dual"); insertData.set(record.getStr("id_name"), seqData.getLong("seqId")); + if(record.getStr("table_name").equals("event_record_library")) { + insertData.set("sync_status",1); + } } Db.use("masterDataSource").batchSave(record.getStr("table_name"), insertDatas, record.getInt("batch_size")); // 同步完成后 取出最后一条数据的id 更新到table_sync_info表中 用作下次使用 diff --git a/nms_sync/src/com/nms/thread/SyncThread.java b/nms_sync/src/com/nms/thread/SyncThread.java index db99c15..378ed13 100644 --- a/nms_sync/src/com/nms/thread/SyncThread.java +++ b/nms_sync/src/com/nms/thread/SyncThread.java @@ -118,6 +118,9 @@ public class SyncThread implements Runnable { for(Record insertData:insertDatas){ Record seqData = Db.use(url).findFirst("select nextval('seq_"+record.getStr("table_name")+"') seqId from dual"); insertData.set(record.getStr("id_name"), seqData.getLong("seqId")); + if(record.getStr("table_name").equals("event_record_library")) { + insertData.set("sync_status",1); + } } Db.use(url).batchSave(record.getStr("table_name"), insertDatas, record.getInt("batch_size")); // 同步完成后 取出最后一条数据的id 更新到table_sync_info表中 用作下次使用