|
@@ -1,6 +1,7 @@
|
|
|
package com.ywt.outpatient.batch.jobhandler;
|
|
|
|
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
|
+import com.ywt.biz.common.constant.GlobalConstants;
|
|
|
import com.ywt.biz.common.util.Checker;
|
|
|
import com.ywt.biz.common.util.DateUtil;
|
|
|
import com.ywt.biz.common.util.serializers.JsonSerializer;
|
|
@@ -48,7 +49,7 @@ public class OutpatientJob {
|
|
|
@DubboReference
|
|
|
MedEquipService medEquipServiceBlockingStub;
|
|
|
|
|
|
- @DubboReference
|
|
|
+ @DubboReference(url = GlobalConstants.CENTRAL_CONTROL_SERVICE_NFYY_SERVICE_DUBBO_REFERENCE_URL, protocol = GlobalConstants.DUBBO_REFERENCE_PROTOCOL)
|
|
|
private TaiheService taiheServiceBlockingStub;
|
|
|
|
|
|
@Autowired
|
|
@@ -102,8 +103,15 @@ public class OutpatientJob {
|
|
|
} catch (Exception e) {
|
|
|
logger.error("invoiceNotifyReturnEquipJobHandler.execute(): {}", e.getMessage(), e);
|
|
|
}
|
|
|
+ }
|
|
|
|
|
|
- logger.info("In invoiceNotifyReturnEquipJobHandler -- two - executing its JOB at " + new Date());
|
|
|
+ /**
|
|
|
+ * 每5秒钟执行一次
|
|
|
+ * 推送最近30分钟失败的订单 体检订单
|
|
|
+ */
|
|
|
+ @XxlJob("checkUpOrderPushFailureJobHandler")
|
|
|
+ public void checkUpOrderPushFailureJobHandle() throws Exception {
|
|
|
+ logger.info("In CheckUpOrderPushFailureJob - executing its JOB at " + new Date());
|
|
|
try {
|
|
|
// 推送体检缴费订单信息给太和(推送失败的订单)
|
|
|
List<CheckUpOrder> checkUpOrderList = getPushFilureList();
|
|
@@ -134,10 +142,11 @@ public class OutpatientJob {
|
|
|
});
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
- logger.error("invoiceNotifyReturnEquipJobHandler.execute(): {}", e.getMessage(), e);
|
|
|
+ logger.error("CheckUpOrderPushFailureJob.execute(): {}", e.getMessage(), e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+
|
|
|
/**
|
|
|
* 每小时执行一次
|
|
|
* 0 0 1 * * ?
|