时区保险

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/service/TableSyncExService.java

@@ -98,6 +98,18 @@ public class TableSyncExService extends TableSyncServiceImpl {
 
 
                 Timestamp lastTimestamp=DataObject.getTimestampValue(sync.getEtlTimestamp(),DataObject.getBeginDate());
+
+
+                {
+                    Calendar c = Calendar.getInstance();
+                    c.setTime(lastTimestamp);
+                    c.add(Calendar.HOUR, -8);
+                    lastTimestamp=new java.sql.Timestamp(c.getTime().getTime());
+                }
+
+
+
+
                 QueryFilter filter=QueryFilter.createQuery();
                 if(sourceModel.getLastModifyField()!=null)
                     filter.ge(sourceModel.getLastModifyField().getColumnName(),lastTimestamp);
@@ -194,5 +206,6 @@ public class TableSyncExService extends TableSyncServiceImpl {
             DynamicDataSourceContextHolder.poll();
         }
     }
+
 }