From f6261adaab448e52a83e3615242dab1ad33023ec Mon Sep 17 00:00:00 2001
From: zhou zhou <3272660260@qq.com>
Date: 星期五, 20 三月 2026 10:55:47 +0800
Subject: [PATCH] #需求第六条
---
src/main/java/com/zy/asrs/task/WorkMastScheduler.java | 53 ++++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 42 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
index 0d39e15..5113cf1 100644
--- a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
@@ -1,17 +1,24 @@
package com.zy.asrs.task;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.core.common.Cools;
+import com.core.exception.CoolException;
+import com.zy.asrs.entity.Mat;
+import com.zy.asrs.entity.Tag;
import com.zy.asrs.entity.Task;
import com.zy.asrs.entity.WrkMast;
-import com.zy.asrs.service.TaskService;
-import com.zy.asrs.service.WrkMastService;
+import com.zy.asrs.service.*;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.WorkMastHandler;
+import com.zy.common.utils.NodeUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
+import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
@@ -29,6 +36,13 @@
private WorkMastHandler workMastHandler;
@Autowired
private TaskService taskService;
+ @Resource
+ private MesService mesService;
+ @Autowired
+ private MatService matService;
+ @Autowired
+ private TagService tagService;
+ // TODO锛歳eporterTask()
@Scheduled(cron = "0/3 * * * * ? ")
private void execute(){
@@ -56,16 +70,33 @@
return;
}
for (Task wrkMast : wrkMasts) {
- ReturnT<String> returnT = workMastHandler.AgvStart(wrkMast);
- if (!returnT.isSuccess()) {
- wrkMast.setUpdMk("X");
- wrkMast.setErrorMemo(returnT.getMsg());
- wrkMast.setErrorTime(new Date());
- if (!taskService.updateById(wrkMast)) {
- log.error("宸ヤ綔妗workNo={}]鏍囪寰呭鐞嗗け璐�", wrkMast.getWrkNo());
- }
- }
+ workMastHandler.AgvStart(wrkMast);
}
}
+ @Scheduled(cron = "0/3 * * * * ? ")
+ private void autoSyncMatGroup(){
+ Page<Mat> page = new Page<>(1, 20);
+ //寤虹珛鎴愬搧鍜屽浠秚ag鍚庢妸14锛�15鏇挎崲涓哄疄闄卛d
+ page = matService.selectPage(page, new EntityWrapper<Mat>().notIn("tag_id", 14,15));
+ List<Mat> matList = page.getRecords();
+ for (Mat mat : matList) {
+ String groupName = null;
+ if (mat.getMatnr().startsWith("T_") || mat.getMatnr().startsWith("X_")) {
+ groupName = "鎴愬搧";
+ }else {
+ groupName = "閰嶄欢";
+ }
+ Tag secTag = tagService.selectByName(groupName, 3);
+ if (Cools.isEmpty(secTag)) {
+ continue;
+ }
+ mat.setTagId(secTag.getId());
+ matService.updateById(mat);
+
+ }
+
+ }
+
+
}
--
Gitblit v1.9.1