|
@@ -1,8 +1,6 @@
|
|
|
package com.warewms.job.task;
|
|
|
|
|
|
-import com.jfinal.plugin.activerecord.Db;
|
|
|
-import com.warewms.common.annotation.JFinalTx;
|
|
|
-import com.warewms.common.utils.HttpRequest;
|
|
|
+import com.warewms.service.HeXunDataService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
@@ -19,92 +17,35 @@ import org.springframework.stereotype.Component;
|
|
|
@Component("wareWmsTask")
|
|
|
public class WareWmsTask {
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private HeXunDataService heXunDataService;
|
|
|
|
|
|
-//
|
|
|
-// /**
|
|
|
-// * 检验WMS企业信息证照信息是否过期
|
|
|
-// */
|
|
|
-// public void checkEnterpriseDateValidation() {
|
|
|
-// try {
|
|
|
-// HttpRequest.postData("kayeeApiConfig.getUrl()");
|
|
|
-// } catch (Exception e) {
|
|
|
-// e.printStackTrace();
|
|
|
-// }
|
|
|
-// }
|
|
|
-//
|
|
|
-// /**
|
|
|
-// * 刷新提醒数据
|
|
|
-// */
|
|
|
-// public void requestRemind() {
|
|
|
-// try {
|
|
|
-// HttpRequest.postData("http://47.100.226.205:8080/remindController.do?remind");
|
|
|
-// } catch (Exception e) {
|
|
|
-// e.printStackTrace();
|
|
|
-// }
|
|
|
-// }
|
|
|
-//
|
|
|
-// /**
|
|
|
-// * 统计用户绩效
|
|
|
-// */
|
|
|
-// public void requestUserStatisticsPerformance() {
|
|
|
-// try {
|
|
|
-// HttpRequest.postData("http://47.100.226.205:8080/userStatisticsPerformanceController.do?performanceStatistics");
|
|
|
-// } catch (Exception e) {
|
|
|
-// e.printStackTrace();
|
|
|
-// }
|
|
|
-// }
|
|
|
-//
|
|
|
/**
|
|
|
- * 清除定时任务日志
|
|
|
+ * 定时回传报警信息
|
|
|
*/
|
|
|
public void exec(){
|
|
|
- log.info("Schedule...................");
|
|
|
+
|
|
|
+ log.info("------------------回传报警信息------------------");
|
|
|
+ heXunDataService.uploadAlarmData();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 定时回传检测点信息
|
|
|
+ */
|
|
|
+ public void uploadPointData() {
|
|
|
+
|
|
|
+ log.info("------------------回传检测点信息------------------");
|
|
|
+ heXunDataService.uploadPointOneData();
|
|
|
+ heXunDataService.uploadPointTwoData();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 定时回传机器人信息
|
|
|
+ */
|
|
|
+ public void uploadRobotData() {
|
|
|
+
|
|
|
+ log.info("------------------回传机器人信息------------------");
|
|
|
+ heXunDataService.uploadRobotOneData();
|
|
|
+ heXunDataService.uploadRobotTwoData();
|
|
|
}
|
|
|
-//
|
|
|
-// /**
|
|
|
-// * 初始化库位状态
|
|
|
-// */
|
|
|
-// public void initLocationStatus(){
|
|
|
-//
|
|
|
-// log.info("开始初始化库位状态------------->>>>");
|
|
|
-// String sql = Db.getSql("location.initLocationStatus");
|
|
|
-// Db.update(sql);
|
|
|
-// log.info("初始化库位状态完成-------------<<<<");
|
|
|
-// }
|
|
|
-//
|
|
|
-// /**
|
|
|
-// * 库存备份、库存量监测
|
|
|
-// */
|
|
|
-// public void invBackup() {
|
|
|
-//
|
|
|
-// log.info("↓↓↓↓↓↓↓↓↓↓↓↓↓库存备份、库存量监测↓↓↓↓↓↓↓↓↓↓↓↓↓");
|
|
|
-// try {
|
|
|
-//
|
|
|
-// invLotBackupService.backup();
|
|
|
-// invLotLocIdBackupService.backup();
|
|
|
-//
|
|
|
-// commonService.inventoryDetection();
|
|
|
-// } catch (Exception e) {
|
|
|
-//
|
|
|
-// e.printStackTrace();
|
|
|
-// }
|
|
|
-// }
|
|
|
-//
|
|
|
-// /**
|
|
|
-// * !!!!!!数据归档 !!!!!!
|
|
|
-// * 不了解业务请不要随意动
|
|
|
-// */
|
|
|
-// @JFinalTx
|
|
|
-// public void dataArchive() {
|
|
|
-//
|
|
|
-// log.info("↓↓↓↓↓↓↓↓↓↓↓↓↓归档↓↓↓↓↓↓↓↓↓↓↓↓↓");
|
|
|
-// try {
|
|
|
-//
|
|
|
-// commonService.dataArchive();
|
|
|
-// } catch (Exception e) {
|
|
|
-//
|
|
|
-// log.error("数据定时归档操作失败:》》》》》》》》》》》》》》》》》》》》》》》》" + e.getMessage());
|
|
|
-// throw new RuntimeException(e);
|
|
|
-// }
|
|
|
-// }
|
|
|
}
|