diff --git a/src/main/java/com/docus/bgts/service/MzSyncService.java b/src/main/java/com/docus/bgts/service/MzSyncService.java index 7f0b804..7d1a769 100644 --- a/src/main/java/com/docus/bgts/service/MzSyncService.java +++ b/src/main/java/com/docus/bgts/service/MzSyncService.java @@ -65,7 +65,7 @@ public class MzSyncService implements IMzSyncService { front = i * pageSize; later = pageSize; jzhs = afCollectAddMapper.listJzhAndAdd(front, later, newSyncTime); - if (null == jzhs || jzhs.size() == 0) { + if (jzhs.size() == 0) { break; } else { mzSyncs = mzSyncMapper.listMzSync(jzhs, front, later, tableName, tableNamespaces); @@ -98,7 +98,7 @@ public class MzSyncService implements IMzSyncService { front = i * pageSize; later = pageSize; jzhs = afCollectAddMapper.listJzh(front, later); - if (null == jzhs || jzhs.size() == 0) { + if (jzhs.size() == 0) { break; } else { mzSyncs = mzSyncMapper.listMzSync(jzhs, front, later, tableName, tableNamespaces); @@ -119,9 +119,9 @@ public class MzSyncService implements IMzSyncService { * * @param mzSyncs */ - private void integralityBySyncs(List mzSyncs) { + private void integralityBySyncs(List mzSyncs ,List) { StringBuilder sql; - if (null != mzSyncs && mzSyncs.size() != 0) { + if (mzSyncs.size() != 0) { List maps = afCollectAddMapper.integrality(mzSyncs); System.out.println(maps); sql = new StringBuilder(); @@ -133,6 +133,7 @@ public class MzSyncService implements IMzSyncService { sql.append(" where jzh="); sql.append("'"); sql.append(map.get("jzh")); + sql.append("jzh"); sql.append("'"); sql.append(";"); } diff --git a/src/main/resources/mapper/dboracle/MzSyncMapper.xml b/src/main/resources/mapper/dboracle/MzSyncMapper.xml index a70a335..9b1fe4d 100644 --- a/src/main/resources/mapper/dboracle/MzSyncMapper.xml +++ b/src/main/resources/mapper/dboracle/MzSyncMapper.xml @@ -11,11 +11,11 @@ (SELECT a.DOCUMENT_TITLE as file_title, a.UNIQUE_ID as serialnum, - a.VISITING_SERIAL_NUMBER as jzh, + + #{jzh} as jzh, ROWID "NAVICAT_ROWID" FROM "${tableNamespace}"."${tableName}" a where VISITING_SERIAL_NUMBER in - #{jzh} ) "NAVICAT_TABLE"