梅州完整性增量

docus-active-query-service_1.3
lzy 3 years ago
parent 1fedb12f4f
commit 124e76474c

@ -51,10 +51,10 @@
//---------- //----------
//0 1 //0 1
"syncFlag":"0", "syncFlag":"0",
"pageSize":"1000", "pageSize":"5",
// //
"newSyncTime":"", "newSyncTime":"",
// //
"syncTableName":"CIS_EMR_DOCUMENT", "syncTableName":"CIS_EMR_DOCUMENT",
"syncTableNamespaces":"CDR" "syncTableNamespaces":"DOCUS"
} }

@ -63,7 +63,7 @@ public class MzSyncService implements IMzSyncService {
List<MzSync> mzSyncs; List<MzSync> mzSyncs;
for (int i = 0; ; i++) { for (int i = 0; ; i++) {
front = i * pageSize; front = i * pageSize;
later = front + pageSize; later = pageSize;
jzhs = afCollectAddMapper.listJzhAndAdd(front, later, newSyncTime); jzhs = afCollectAddMapper.listJzhAndAdd(front, later, newSyncTime);
if (null == jzhs || jzhs.size() == 0) { if (null == jzhs || jzhs.size() == 0) {
break; break;
@ -95,7 +95,7 @@ public class MzSyncService implements IMzSyncService {
List<MzSync> mzSyncs; List<MzSync> mzSyncs;
for (int i = 0; ; i++) { for (int i = 0; ; i++) {
front = i * pageSize; front = i * pageSize;
later = front + pageSize; later = pageSize;
jzhs = afCollectAddMapper.listJzh(front, later); jzhs = afCollectAddMapper.listJzh(front, later);
if (null == jzhs || jzhs.size() == 0) { if (null == jzhs || jzhs.size() == 0) {
break; break;
@ -113,7 +113,6 @@ public class MzSyncService implements IMzSyncService {
} }
/** /**
* *
* *

Loading…
Cancel
Save