diff --git a/src/main/java/com/glxp/api/service/sync/HeartService.java b/src/main/java/com/glxp/api/service/sync/HeartService.java index bec00be74..7177b91db 100644 --- a/src/main/java/com/glxp/api/service/sync/HeartService.java +++ b/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 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)