由内向外同步

src/main/java/com/glxp/api/service/sync/HeartService.java

@@ -498,7 +498,7 @@ public class HeartService {
                             , map.get("oldDate"), now)
             );
             if (CollectionUtil.isNotEmpty(busTypeChangeList)) {
-                if(dataResponse==null){
+                if (dataResponse == null) {
                     dataResponse = new SpsSyncBusResponse();
                 }
                 dataResponse.setBusTypeChangeEntities(busTypeChangeList);
@@ -519,7 +519,7 @@ public class HeartService {
                             , map.get("oldDate"), now)
             );
             if (CollectionUtil.isNotEmpty(thrBusTypeOriginEntities)) {
-                if(dataResponse==null){
+                if (dataResponse == null) {
                     dataResponse = new SpsSyncBusResponse();
                 }
                 dataResponse.setThrBusTypeOriginEntities(thrBusTypeOriginEntities);
@@ -539,7 +539,7 @@ public class HeartService {
      * @return
      */
     private boolean needExec(int... set) {
-        return Arrays.stream(set).filter(i->i==1).findAny().isPresent();
+        return Arrays.stream(set).filter(i -> i == 1).findAny().isPresent();
     }
 
     public void uploadData(BasicExportTypeEnum exportType, String taskId, Function<HeartService, Object> dataMethod) {
@@ -562,8 +562,12 @@ public class HeartService {
                 .updateTime(new Date())
                 .receiveStatus(status)
                 .scheduleType(BasicProcessStatus.SCHEDULE_NORMAL)
+                .remark(baseResponse.getMessage())
                 .build();
         this.insertExportStatus(exportStatus);
+        if (baseResponse.getCode() != 20000) {
+            throw new RuntimeException(baseResponse.getMessage());
+        }
     }
 
     @Transactional(propagation = Propagation.REQUIRES_NEW)