v12

src/main/java/com/hikcreate/drv_photo_pic/impl/SqlHelp.java

@@ -57,8 +57,7 @@ public class SqlHelp {
             }
             }
             if(colValue[0] == null){
             if(colValue[0] == null){
                flag1=true;
                flag1=true;
-            } else if (colValue[0] != null && (gxsj.substring(0, 19).compareTo(colValue[1].substring(0, 19)) < 0 ||
-                    gxsj.substring(0, 19).compareTo(colValue[1].substring(0, 19)) == 0)) {
+            } else if (colValue[0] != null && (gxsj.substring(0, 19).compareTo(colValue[1].substring(0, 19)) < 0 )) {
                 flag1 = false;
                 flag1 = false;
             }else {
             }else {
                 logger.info(gxsj+"---------------"+colValue[1]);
                 logger.info(gxsj+"---------------"+colValue[1]);
@@ -71,7 +70,7 @@ public class SqlHelp {
         }
         }
     }
     }
 
 
-    public static byte[] blobToByteZp(BLOB zp) {
+    public synchronized static byte[] blobToByteZp(BLOB zp) {
         try {
         try {
             long length = zp.length();
             long length = zp.length();
             byte[] bytes = new byte[(int) length];
             byte[] bytes = new byte[(int) length];

src/main/java/com/hikcreate/drv_photo_pic/impl/VehicleImpl.java

@@ -144,7 +144,6 @@ public class VehicleImpl implements Vehicle {
             while (resultSet.next()) {
             while (resultSet.next()) {
                 saveToHbase(resultSet, fileService);
                 saveToHbase(resultSet, fileService);
             }
             }
-
         }catch (Exception e) {
         }catch (Exception e) {
             e.printStackTrace();
             e.printStackTrace();
         } finally {
         } finally {
@@ -179,7 +178,7 @@ public class VehicleImpl implements Vehicle {
      * @param resultSet
      * @param resultSet
      * @param fileService
      * @param fileService
      */
      */
-    private void saveToHbase(ResultSet resultSet, FileService fileService) {
+    private synchronized void saveToHbase(ResultSet resultSet, FileService fileService) {
         try {
         try {
             xh = resultSet.getString("XH");
             xh = resultSet.getString("XH");
             hphm = resultSet.getString("HPHM");
             hphm = resultSet.getString("HPHM");

src/main/java/com/hikcreate/schedul/PicSchedule.java

@@ -47,7 +47,7 @@ public class PicSchedule {
     /**
     /**
      * 每天早上9点同步机动车的增量数据
      * 每天早上9点同步机动车的增量数据
      */
      */
-//    @Scheduled(cron = "0 0 9 * * *")
+    @Scheduled(cron = "0 0 9 * * *")
     public void  getIncrementVehPic(){
     public void  getIncrementVehPic(){
         vehicle.getIncrementVehPic();
         vehicle.getIncrementVehPic();
     }
     }