|
|
|
@ -8,6 +8,7 @@ import com.glxp.api.entity.system.SyncDataSetEntity;
|
|
|
|
|
import com.glxp.api.req.system.ScheduledRequest;
|
|
|
|
|
import com.glxp.api.service.sync.HeartService;
|
|
|
|
|
import com.glxp.api.util.RedisUtil;
|
|
|
|
|
import org.apache.commons.lang3.exception.ExceptionUtils;
|
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
|
@ -81,7 +82,9 @@ public class SyncHeartTask implements SchedulingConfigurer {
|
|
|
|
|
redisUtil.set("SPS_SYNC_UPLOAD_DATA", curTime1);
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
logger.error(ExceptionUtils.getStackTrace(e));
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -100,6 +103,7 @@ public class SyncHeartTask implements SchedulingConfigurer {
|
|
|
|
|
redisUtil.set("SPS_SYNC_UPLOAD_ORDER", curTime2);
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
logger.error(ExceptionUtils.getStackTrace(e));
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -117,11 +121,13 @@ public class SyncHeartTask implements SchedulingConfigurer {
|
|
|
|
|
heartService.dlAllOrder();
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
logger.error(ExceptionUtils.getStackTrace(e));
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
heartService.dlAllDiProducts();
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
logger.error(ExceptionUtils.getStackTrace(e));
|
|
|
|
|
}
|
|
|
|
|
Arrays.stream(BasicExportTypeEnum.values()).forEach(i -> {
|
|
|
|
|
heartService.pullData(i);
|
|
|
|
|