From 9a8395f4b6e0779762311e04d9594df4e99fc488 Mon Sep 17 00:00:00 2001 From: liyongde <1419499670@qq.com> Date: Tue, 6 Aug 2024 16:13:20 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=88=9D=E6=AD=A5=E7=BB=B4=E6=8A=A4?= =?UTF-8?q?=E4=B8=BB=E4=BD=93=E6=A1=86=E6=9E=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/resources/config/application.yml | 20 ----- .../wms/ext/acs/service/AcsToWmsService.java | 2 +- .../wms/ext/acs/service/WmsToAcsService.java | 3 +- .../acs/service/impl/AcsToWmsServiceImpl.java | 76 +++++++++++++++++- .../acs/service/impl/WmsToAcsServiceImpl.java | 14 ++-- .../controller/SchBaseTaskController.java | 3 +- .../nl/wms/sch/task_manage/AbstractTask.java | 62 ++++---------- .../nl/wms/sch/task_manage/AcsTaskDto.java | 2 +- .../nl/wms/sch/task_manage/task/AcsUtil.java | 75 ++++++++++++++++- .../second_floor_area/CallEmpReelTask.java | 2 +- .../task/second_floor_area/CoolCutTask.java | 2 +- .../task/second_floor_area/InCoolIvtTask.java | 6 +- .../task/second_floor_area/InHotTask.java | 2 +- .../task/second_floor_area/OutHotTask.java | 8 +- .../src/main/resources/config/application.yml | 2 +- .../nladmin-ui/src/assets/images/longdian.png | Bin 0 -> 3923 bytes lms2/nladmin-ui/src/i18n/langs/en.js | 2 +- lms2/nladmin-ui/src/i18n/langs/in.js | 2 +- lms2/nladmin-ui/src/i18n/langs/zh-CN.js | 2 +- .../src/layout/components/Sidebar/Logo.vue | 12 +-- 20 files changed, 191 insertions(+), 106 deletions(-) create mode 100644 lms2/nladmin-ui/src/assets/images/longdian.png diff --git a/lms/nladmin-system/src/main/resources/config/application.yml b/lms/nladmin-system/src/main/resources/config/application.yml index 35aabb3f1..6ba9455c6 100644 --- a/lms/nladmin-system/src/main/resources/config/application.yml +++ b/lms/nladmin-system/src/main/resources/config/application.yml @@ -161,26 +161,6 @@ mybatis-plus: db-config: id-type: INPUT banner: false -jetcache: - statIntervalMinutes: 15 - areaInCacheName: false - local: - default: - type: linkedhashmap - keyConvertor: fastjson - remote: - default: - type: redis - keyConvertor: fastjson2 - broadcastChannel: projectA - valueEncoder: java - valueDecoder: java - poolConfig: - minIdle: 5 - maxIdle: 20 - maxTotal: 50 - host: 127.0.0.1 - port: 6379 lucene: index: path: D:\log\lms\ld\index diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/AcsToWmsService.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/AcsToWmsService.java index 09b3a04ca..8af2f9909 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/AcsToWmsService.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/AcsToWmsService.java @@ -15,7 +15,7 @@ public interface AcsToWmsService { * @return Map */ - Map receiveTaskStatusAcs(String string); + Map receiveTaskStatusAcs(String string) throws InterruptedException; /** diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java index c212fd4b0..e7448e353 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java @@ -4,6 +4,7 @@ import org.nl.wms.ext.acs.service.dto.to.wms.AcsResponse; import org.nl.wms.sch.task_manage.AcsTaskDto; import java.util.List; +import java.util.Map; /** * @Author: lyd @@ -18,6 +19,6 @@ public interface WmsToAcsService { * @param list: 任务链表 * @return */ - AcsResponse renotifyAcs(List list); + Map issueTaskToAcs(List list); } diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java index 0a7c8b064..9907152e6 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java @@ -1,20 +1,88 @@ package org.nl.wms.ext.acs.service.impl; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; -import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.nl.common.exception.BadRequestException; import org.nl.wms.ext.acs.service.AcsToWmsService; +import org.nl.wms.sch.task.service.ISchBaseTaskService; +import org.nl.wms.sch.task.service.dao.SchBaseTask; +import org.nl.wms.sch.task_manage.AbstractTask; +import org.nl.wms.sch.task_manage.task.TaskFactory; +import org.nl.wms.sch.task_manage.task.core.TaskStatus; +import org.redisson.api.RLock; +import org.redisson.api.RedissonClient; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.HttpStatus; import org.springframework.stereotype.Service; import java.util.Map; +import java.util.concurrent.TimeUnit; @Service -@RequiredArgsConstructor @Slf4j public class AcsToWmsServiceImpl implements AcsToWmsService { + + @Autowired + private RedissonClient redissonClient; + @Autowired + private ISchBaseTaskService taskService; + @Autowired + private TaskFactory taskFactory; @Override - public Map receiveTaskStatusAcs(String string) { - return null; + public Map receiveTaskStatusAcs(String string) throws InterruptedException { + log.info("acs向lms反馈任务状态，请求参数：--------------------------------------" + string); + JSONArray array = JSONArray.parseArray(string); + //返回处理失败的任务 + JSONArray errArr = new JSONArray(); + for (int i = 0; i < array.size(); i++) { + JSONObject row = array.getJSONObject(i); + String taskId = row.getString("task_id"); + RLock lock = redissonClient.getLock(taskId); + boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS); + try { + if (tryLock) { + SchBaseTask task = taskService.getById(taskId); + row.put("task_code", task.getTask_code()); + //1:执行中,2:完成 ,3:acs取消 + String acsTaskStatus = row.getString("task_status"); + String message = ""; + TaskStatus status = null; + if ("1".equals(acsTaskStatus)) { + status = TaskStatus.EXECUTING; + } + if ("2".equals(acsTaskStatus)) { + status = TaskStatus.FINISHED; + } + if ("3".equals(acsTaskStatus)) { + status = TaskStatus.CANCELED; + } + // 任务处理类 + try { + AbstractTask task1 = taskFactory.getTask(task.getConfig_code()); + task1.updateTaskStatus(row, status); + } catch (Exception e) { + e.printStackTrace(); + message = e.getMessage(); + throw new BadRequestException(message); + } + } else { + throw new BadRequestException("任务标识为：" + taskId + "的任务正在操作中！"); + } + } finally { + if (tryLock) { + lock.unlock(); + } + } + + } + JSONObject result = new JSONObject(); + result.put("status", HttpStatus.OK.value()); + result.put("message", "任务状态反馈成功!"); + result.put("data", new JSONObject()); + result.put("errArr", errArr); + log.info("acs向lms反馈任务状态，返回参数：--------------------------------------" + result.toString()); + return result; } @Override diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java index e6a8c9759..2b8246a2a 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java @@ -1,5 +1,7 @@ package org.nl.wms.ext.acs.service.impl; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; import lombok.extern.slf4j.Slf4j; import org.nl.wms.ext.acs.service.WmsToAcsService; import org.nl.wms.ext.acs.service.dto.to.acs.IssueAcsRequest; @@ -12,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; +import java.util.Map; /** * @Author: lyd @@ -25,12 +28,13 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { private ISysInteractRecordService interactRecordService; @Override - public AcsResponse renotifyAcs(List list) { + public Map issueTaskToAcs(List list) { String api = "api/wms/task"; - AcsResponse resultForAcs = AcsUtil.notifyAcs2(api, IssueAcsRequest.buildRequestObj("下发任务", list)); - // 记录日志 - interactRecordService.saveRecord("下发任务", list, resultForAcs, GeneralDefinition.LMS_ACS); - return resultForAcs; + JSONArray jsonArray = new JSONArray(); + for (AcsTaskDto dto : list) { + jsonArray.add(JSONObject.toJSONString(dto)); + } + return AcsUtil.notifyAcs(api, jsonArray); } } diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskController.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskController.java index 6b8220f74..0e781c1e0 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskController.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/controller/SchBaseTaskController.java @@ -70,8 +70,7 @@ public class SchBaseTaskController { } @PutMapping("/operation") - @Log("任务操作") - + @Log("PC操作任务") public ResponseEntity update(@RequestBody Map map) { schBaseTaskService.operation(map); return new ResponseEntity<>(HttpStatus.NO_CONTENT); diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AbstractTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AbstractTask.java index 45472a6b5..57cf9eff7 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AbstractTask.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AbstractTask.java @@ -1,11 +1,8 @@ package org.nl.wms.sch.task_manage; -import cn.hutool.core.date.DateUtil; import cn.hutool.core.lang.Assert; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.ObjectUtil; -import cn.hutool.http.HttpStatus; -import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import lombok.SneakyThrows; @@ -48,10 +45,19 @@ public abstract class AbstractTask { @Autowired private WmsToAcsService wmsToAcsService; + /** + * 不走任务配置的创建任务类, 不会被定时任务扫描自动创建 + * @param form 创建任务需要的参数 + * @return 返回任务标识 + */ + public String createTask(JSONObject form) { + return null; + } + /** * 任务创建 * 根据配置生成任务，如并发控制等 - * + * 这里会定时任务执行，例如：一条任务状态是[起点确认]的任务会在这个方法，由子类来定时扫描去执行对应的逻辑 * @throws BadRequestException / */ public abstract void create() throws BadRequestException; @@ -59,20 +65,19 @@ public abstract class AbstractTask { /** * 任务创建 * 只会创建完整的任务，创建失败则抛出异常 - * + * 这个定时任务不会扫描到，只做一次性创建，失败则报错 * @param task / */ public void createCompletion(SchBaseTask task) { } - /** * @return WCS的任务集合 * @discription 重新下发给wcs任务 * @author ldjun * @created 2020年6月12日 下午5:52:28 */ - protected AcsResponse renotifyAcs(SchBaseTask task) { + protected AcsResponse immediateNotifyAcs(SchBaseTask task) { Assert.notNull(task); List taskList = new ArrayList<>(); taskList.add(task); @@ -94,7 +99,7 @@ public abstract class AbstractTask { List list = new ArrayList<>(); for (SchBaseTask task : taskList) { AcsTaskDto taskDto = new AcsTaskDto(); - taskDto.setExt_task_uuid(task.getTask_id()); + taskDto.setExt_task_id(task.getTask_id()); taskDto.setTask_code(task.getTask_code()); taskDto.setRoute_plan_code("normal"); taskDto.setStart_device_code(task.getPoint_code1()); @@ -108,35 +113,7 @@ public abstract class AbstractTask { this.deliveryBeforeProcessing(task, taskDto); list.add(taskDto); } - try { - // 创建下发对象 - resultForAcs = wmsToAcsService.renotifyAcs(list); - } catch (Exception e) { - log.error("任务下发异常: {}", e.getMessage()); - resultForAcs.setResponseDate(DateUtil.now()); - resultForAcs.setCode(HttpStatus.HTTP_BAD_REQUEST); - resultForAcs.setMessage(e.getMessage()); - } - // 如果下发完毕，就修改状态 - if (resultForAcs.getCode() == HttpStatus.HTTP_OK) { - // 解析 - JSONArray errArr = resultForAcs.getErrArr(); - for (SchBaseTask schBaseTask : taskList) { - schBaseTask.setTask_status(TaskStatus.ISSUE.getCode()); - // 判断是否是出错的任务 - for (int i = 0; ObjectUtil.isNotEmpty(errArr) && i < errArr.size(); i++) { - JSONObject errObj = errArr.getJSONObject(i); - String taskCode = errObj.getString("task_code"); - if (taskCode.equals(schBaseTask.getTask_code())) { - // 出错的任务就设置出错信息为备注，不是出错就设置下发 - schBaseTask.setTask_status(TaskStatus.START_AND_POINT.getCode()); - schBaseTask.setRemark(errObj.getString("message")); - break; - } - } - } - taskService.updateBatchById(taskList); - } + wmsToAcsService.issueTaskToAcs(list); return resultForAcs; } @@ -244,7 +221,7 @@ public abstract class AbstractTask { public abstract void cancel(String task_code); /** - * 申请任务 + * 申请任务 - 暂时不用 *

创建task的总入口，会根据自定义的子类去执行创建方法。

* @param param 请求任务的参数（可以是只确定了单个点，也可以是4个点都确定了） * @throws BadRequestException 如果创建失败 @@ -286,18 +263,14 @@ public abstract class AbstractTask { task.setTask_id(IdUtil.getSnowflake(1, 1).nextIdStr()); task.setTask_code(IdUtil.getSnowflake(1, 1).nextIdStr()); task.setConfig_code(configCode); - // todo task.setCreate_mode(ObjectUtil.isNotEmpty(param.getString("create_mode")) ? param.getString("create_mode") : GeneralDefinition.ACS_CREATION); task.setVehicle_code(vehicleCode); task.setVehicle_qty(param.getInteger("vehicle_qty")); task.setVehicle_type(vehicleType); - task.setTask_status(TaskStatus.APPLY.getCode()); + task.setTask_status(TaskStatus.CREATED.getCode()); // 设置起/终点 - task.setPoint_code1(param.getString("point_code1")); - task.setPoint_code2(param.getString("point_code2")); - task.setPoint_code3(param.getString("point_code3")); - task.setPoint_code4(param.getString("point_code4")); + bean.setTaskPoint(taskConfig, task, applyPointCode); // 将所有参数存到表中，后续需要可以提取 task.setRequest_param(JSONObject.toJSONString(param)); // 设置创建人信息 @@ -314,5 +287,4 @@ public abstract class AbstractTask { bean.create(); } } - } diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AcsTaskDto.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AcsTaskDto.java index f9cd2f71a..81af250e4 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AcsTaskDto.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/AcsTaskDto.java @@ -23,7 +23,7 @@ public class AcsTaskDto { /** * 任务标识 */ - private String ext_task_uuid; + private String ext_task_id; /** * 任务编号 diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/AcsUtil.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/AcsUtil.java index a3427f73f..5115f5ac5 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/AcsUtil.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/AcsUtil.java @@ -4,14 +4,22 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.http.HttpRequest; import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import lombok.extern.slf4j.Slf4j; +import org.nl.common.exception.BadRequestException; import org.nl.config.SpringContextHolder; import org.nl.system.service.param.dao.Param; import org.nl.system.service.param.impl.SysParamServiceImpl; import org.nl.wms.ext.acs.service.dto.ResultForAcs; import org.nl.wms.ext.acs.service.dto.to.wms.AcsResponse; +import org.nl.wms.sch.task.service.ISchBaseTaskService; +import org.nl.wms.sch.task.service.dao.SchBaseTask; import org.nl.wms.sch.task_manage.GeneralDefinition; +import org.nl.wms.sch.task_manage.task.core.TaskStatus; +import org.nl.wms.util.URLEnum; +import org.springframework.http.HttpStatus; import java.util.List; @@ -25,6 +33,69 @@ import java.util.List; */ @Slf4j public class AcsUtil { + public static JSONObject notifyAcs(String api, JSONArray list) { + log.info("下发ACS参数----------------------------------------+" + api + ",---" + list.toString()); + //判断是否连接ACS系统 + String isConnect = SpringContextHolder.getBean(SysParamServiceImpl.class).findByCode("is_connect_acs").getValue(); + JSONObject result = new JSONObject(); + if (StrUtil.equals("0", isConnect)) { + result.put("status", HttpStatus.OK.value()); + result.put("message", "下发成功，但未连接ACS!"); + result.put("data", new JSONObject()); + return result; + } + for (int j = 0; j < list.size(); j++) { + JSONObject jo = list.getJSONObject(j); + String product_area = jo.getString("product_area"); + if (StrUtil.isEmpty(product_area)) { + throw new BadRequestException("区域不能为空!下发信息：" + jo.toString()); + } + String acs_url = URLEnum.find(product_area); + if (StrUtil.isEmpty(acs_url)) { + log.info(product_area); + throw new BadRequestException("未查询到区域对应的acs地址！"); + } + String url = acs_url + api; + try { + JSONArray rows = new JSONArray(); + rows.add(jo); + String resultMsg = HttpRequest.post(url) + .body(String.valueOf(rows)) + .execute().body(); + result = JSONObject.parseObject(resultMsg); + log.info("下发acs任务成功，返回参数----------------------------------------+" + api + ",---" + result.toString()); + } catch (Exception e) { + //acs抛异常这里 + String msg = e.getMessage(); + //ConnectException: Connection refused: connect + //网络不通 + result.put("status", HttpStatus.BAD_REQUEST); + result.put("message", "网络不通,操作失败!"); + result.put("data", new JSONObject()); + log.error("ACS出现异常: {}", e); + log.info("下发ACS任务失败，原因是：----------------------------------------+"+ msg); + } + if (!StrUtil.equals(result.getString("status"), "200")) { + log.info("下发acs任务失败，原因是：----------------------------------------+"+ result.getString("message")); + throw new BadRequestException(result.getString("message")); + } else { + //如果向ACS下发任务，变更任务状态为下发 + if ("api/wms/task".equals(api)) { + for (int i = 0; i < list.size(); i++) { + JSONObject task_jo = list.getJSONObject(i); + ISchBaseTaskService bean = SpringContextHolder.getBean(ISchBaseTaskService.class); + bean.update(new LambdaUpdateWrapper() + .set(SchBaseTask::getTask_status, TaskStatus.ISSUE.getCode()) + .eq(SchBaseTask::getTask_id, task_jo.getString("ext_task_id"))); + } + } + } + + } + log.info("下发acs任务，结果是：----------------------------------------+"+ result); + return result; + } + /** * 原生默认请求方法： 默认执行的参数都是jsonArray * @param api @@ -32,7 +103,7 @@ public class AcsUtil { * @return * @param */ - public static ResultForAcs notifyAcs(String api, List list) { + public static ResultForAcs notifyAcs2(String api, List list) { SysParamServiceImpl sysParamService = SpringContextHolder.getBean(SysParamServiceImpl.class); // list转JSONArray String s = JSON.toJSONString(list); @@ -77,7 +148,7 @@ public class AcsUtil { * @return * @param */ - public static AcsResponse notifyAcs2(String api, T object) { + public static AcsResponse notifyAcs3(String api, T object) { SysParamServiceImpl sysParamService = SpringContextHolder.getBean(SysParamServiceImpl.class); //判断是否连接ACS系统 Param isConnectAcs = sysParamService.findByCode(GeneralDefinition.IS_CONNECT_ACS); diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CallEmpReelTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CallEmpReelTask.java index a6f02369c..5e4110e36 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CallEmpReelTask.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CallEmpReelTask.java @@ -175,7 +175,7 @@ public class CallEmpReelTask extends AbstractTask { taskService.save(task); // 如果需要立即下发 if (BooleanUtil.toBoolean(task.getIs_send())) { - this.renotifyAcs(task); + this.immediateNotifyAcs(task); } } diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CoolCutTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CoolCutTask.java index 75248a791..2f029d6e7 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CoolCutTask.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/CoolCutTask.java @@ -154,7 +154,7 @@ public class CoolCutTask extends AbstractTask { taskService.save(task); //如果目标点位没有空位先创建不下发 if (isSend) { - this.renotifyAcs(task); + this.immediateNotifyAcs(task); } } diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InCoolIvtTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InCoolIvtTask.java index 3f3f895de..6402d5713 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InCoolIvtTask.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InCoolIvtTask.java @@ -18,12 +18,9 @@ import org.nl.common.exception.BadRequestException; import org.nl.config.SpringContextHolder; import org.nl.system.service.dict.ISysDictService; import org.nl.system.service.dict.dao.Dict; -import org.nl.system.service.dict.dao.mapper.SysDictMapper; import org.nl.system.service.param.impl.SysParamServiceImpl; -import org.nl.wms.basedata.material.service.ImdMeMaterialbaseService; import org.nl.wms.pdm.bi.dao.PdmBiRawfoilworkorder; import org.nl.wms.pdm.bi.service.IpdmBiRawfoilworkorderService; -import org.nl.wms.pdm.bi.service.IpdmBiSlittingproductionplanService; import org.nl.wms.pdm.ivt.dao.StIvtCoolpointivt; import org.nl.wms.pdm.ivt.service.*; import org.nl.wms.sch.point.service.ISchBasePointService; @@ -40,7 +37,6 @@ import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; -import java.util.HashMap; import java.util.Map; @@ -150,7 +146,7 @@ public class InCoolIvtTask extends AbstractTask { taskService.save(task); //如果目标点位没有空位先创建不下发 if (isSend) { - this.renotifyAcs(task); + this.immediateNotifyAcs(task); } } diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InHotTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InHotTask.java index 966703342..1aafdd63c 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InHotTask.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/InHotTask.java @@ -178,7 +178,7 @@ public class InHotTask extends AbstractTask { taskService.save(task); //如果目标点位没有空位先创建不下发 if (isSend) { - this.renotifyAcs(task); + this.immediateNotifyAcs(task); } } diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/OutHotTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/OutHotTask.java index a832b81c1..da21bc8b1 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/OutHotTask.java +++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/second_floor_area/OutHotTask.java @@ -14,14 +14,8 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import lombok.extern.slf4j.Slf4j; import org.nl.common.exception.BadRequestException; import org.nl.common.utils.SecurityUtils; -import org.nl.config.SpringContextHolder; import org.nl.system.service.dict.ISysDictService; import org.nl.system.service.dict.dao.Dict; -import org.nl.system.service.dict.dao.mapper.SysDictMapper; -import org.nl.wms.basedata.material.service.ImdMeMaterialbaseService; -import org.nl.wms.pdm.bi.service.IpdmBiRawfoilworkorderService; -import org.nl.wms.pdm.bi.service.IpdmBiSlittingproductionplanService; -import org.nl.wms.pdm.ivt.dao.StIvtCoolpointivt; import org.nl.wms.pdm.ivt.dao.StIvtHotpointivt; import org.nl.wms.pdm.ivt.dao.StIvtHotregioniomst; import org.nl.wms.pdm.ivt.service.*; @@ -146,7 +140,7 @@ public class OutHotTask extends AbstractTask { taskService.save(task); //如果目标点位没有空位先创建不下发 if (isSend) { - this.renotifyAcs(task); + this.immediateNotifyAcs(task); } } diff --git a/lms2/nladmin-system/nlsso-server/src/main/resources/config/application.yml b/lms2/nladmin-system/nlsso-server/src/main/resources/config/application.yml index 40f1d7ed1..3da52d086 100644 --- a/lms2/nladmin-system/nlsso-server/src/main/resources/config/application.yml +++ b/lms2/nladmin-system/nlsso-server/src/main/resources/config/application.yml @@ -53,7 +53,7 @@ spring: login-username: admin login-password: admin dynamic: - primary: dm + primary: mysql datasource: mysql: driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy diff --git a/lms2/nladmin-ui/src/assets/images/longdian.png b/lms2/nladmin-ui/src/assets/images/longdian.png new file mode 100644 index 0000000000000000000000000000000000000000..611094eb2cf418f1ef7cbc2ecc12ac0d5cdbfb82 GIT binary patch literal 3923 zcmV-Z53KNsP)*bTtkVyb^0fJXsb1mM$1Y!Z}99JST36MzF!6y7ir zl0B5y2dkvNO?}EpSl0ts3*c7(o3?NRbpcQxz=M&P!a9ZqlhOh+7=8)hegJ)oq0UzU zI0C>v+k$|YDQ%S+EfLBm2=`$+c5Trv0O|m!r{7utaz)iOb5++2yGpc3{eV0KgCcmjQUz;o1zqhX6j&?D}GcB{l|dyM%B;B)0fa zN1V?E&;md=^?_`lqxeF9SI~D_4B&^9{EdoL!l*jQADI|aNVfLsoJaCVlIM`TmE>5G zQ%No)`CCFx#e-=ihmmZU<#sji_`7Pn$cw8$a-8!v`GNd#sEWg5WHI%Nok-U9!umMn z&LderkS`O;5zkji9z}Ad_r<>;xpOkUk$@6F)twhuNAg9I7m@5ha!-=Glk80LI+8Dt z{BjEmKwNAf`Ohr2=Ma_qE6K)zctZtBGd&O&m#%Q$uX!=_2ea<|ndBsOS`&7&%3Bgh zzd1BdeA|;en&dMi-yzwL#XanFv09ON8?WE}hpecZ#BDv$kE|d!ZoCct()Jvn5Jf4L%H|kC` zeM_TSwE|FCac2T(1mGF~>i|3q;DZQn91dy^aym=a4X#$};RH|X6LJ8iH^>PaYlrgWuv|3Gr7W-N;W%>bG5-o@c%-lvtq zZ&%n`-uJycz#|Urr~Ef4?MP`OlnNZ1S0rF7&^}V3#*VAj99`N2hA#Dv6D@W7oF#wJPuva9-=HW*G%S9{nYpfM3rM|6^nf5oS z4v;!jMN@w*+0C11iryoIMJ+CR%hD7V_e!1IFOYs7fahdsniYwSht2>_m+A9fsZa*L z0C*q33l5jI&fi8|>;vG=G|T%tfcE;kjK0Ic0N#)q_ll!NZZ3?4>Iwi2^j*#SohOUq zo&Zh)&`WK&TR0U`Y|&9YlM`!_4K z_Aopu0$8NMs-@yhJD)Fe?0o>HM7YJrA_@9C`ewHPn4y8n40`WsFg#yE6hU$Bq??hc ztEg=xHZ|tTu5b1izEQ)jR);kU_$9?v@f0wF$|>roEt4lL0<$-9TqHC(_R~l0qy_6) z08Y>VQIIreYTTinWrHyqRSl+VrZxN@)!xV?hubRcDgB;CS(7z;d?8-_G>Z(?qInpA z;hGV6=XHKNW3ehnI?-2D@ zUc<8s$r^z)20a7eMJN)G0kt7{bxe!XYFQD?hZrC`c!NNh&jmh=i_H-bvwt$5Rc<4IaM*+9#OGC~gVxN{8-s zI94NBM|sOS;cG~KqJc7#GHl;jti^ggFWy?smXSO?kpF)a35ZE8)k$YWny=_fen4^* z$qTeuQ!@ttnh{P>3<=~*MaPl++~M@9Gm;n+;KeEOC!eqYSQlC9sLjJJ0bXedNFz;Mp_$@$ndlxOc_GQeVhTfu z%yjruq=ceKM?e~TZWtDe6+g)d`b_>jd&m#`f zF^tiULa7_+zEArI_x~ePb+EEHY;<^S)C>_yZ)vhRcqq=L-VR@@!X4z57ebQ&FK9hC zHI0F>MUrphW0N|)MIv9V`xO7N{P31(?blZE)f9iK^Zs{hk7|=w=6fW&g$l{lEHK4M zyil7(CrEb>ljV!s$H3D-j(L;ZTSv3DU=*t`3hg^r0uk$Y(oA ztw5YlgEb)hA~nOp2+Yg!W^lj7_W>T31}IINKpeCNJKGzO*2*u-;%&Y6U)6z6kfEl! zoC-Th6$%+4^2FnHl7AxkgjB6f&Y)6B{(Lt5ObJn23EgP5!<)7pEOR6E-AG<5owGoT zsjl7va7$3O1;iJC|9J7eBHYs#kbV&kg{n$A>V{7v#Ak%UkJXwkl-4Ed)c9H;E<^`7 zb$(3ikzr1{mg);P2E3>(9q71nysWU+S_3@c4YpJ#?5=d~PWM>>-f`(k@o3{L!k^KO z`D|w$*HqrnF0KufVZL2$^T%!yg!5$f@?DX)G!^#@@~#)ZZ-je19p0r$5e}JKU@TdK zLT^2H&{{9m%y6Pphq%5>O&z{-q%p*;=Ox~Ie1RsnVGb9vRe`CZ?#y#xH?(t7de zF4f<3`jw7F>oW0aB-a)jUO_6gS@V?l%QF8|-O2*tQ?>;p-^=?`z#6i|OLJ_1Pa@hQ zQoGD-_kM@9I80&I`qDR$-lfrAUD7p{bW%Pu6SR|RQ$wAovG%9BYtL$abt~I%G7q6-#0L|s@Zt+{--BQ8q zpkJ?DZtEMhL4Ip-PI5lrxvHe{+4@Dlt0OV#;U%ShOGgasodqX*eq{#x$|GQ|Tx%w% zJ&g;@sd9xf-}Tp$cpfAU%A}DtGyt@afE=iXt?R|dJ<>bWalkX^4&eDns`N2gIm+o+ zuf_3lySXYR#~U;BOB*KtrAy@I5~rWc(Q)1TA~DHf-!B_y{EctdlgD-ZdJ`unmrN7Jgrfm-b@{s&)T#sBU5EFG?-N(vENEGIBf$N;mOninC z;X@rP@*U;Y$hqz!dDZ4f02U~16+JK2hkq#n|2QyhGf|z+3@EMT?YvHogmpCde6PVK z9ZzK!c82$7;!Ln!v)5_~>Rk?x_G%B?E*}GUQ+`<%Rn<>+(ahJgB&|Ix#aV--ySGr! zGcOL8snEwqI@=!N;nF}S----37k5x0*>y}d+at2r*5+ay4}&69HVaZ)8n8^dWoNm| z|3h`Q$4l30mT42imHZxg*g~VwKJq%=fy~fLs%bW{KETVYqh?1!Q=qh}Sec?gy5@z_ zLwo5g#0?UnWN4^!&W9?^V>+|F1Dl6w&S9+*hwWts@o~3CnVHh(QwhguT7+8R=)a8# zN3}Ez6WbNGR{=p_0UScEZt@r{GwN45277xTZ8p(FDqmhPmjjt{7pY9>ou{k(;zk+W z{L(W?IXS9J>qyKNKxtL6mPbOe4|5XjHtm~0*J55EUADNXQ?d?Q+xwi40E*S;a?@1CsVG;`>KTBVpj>H=|4|<`6}v!=pkzJKg{)|RX}>` zg(^g1!YD6W_n2U8QMA_eokuBjzSOWSc@?MKG+PsiDV)h3*N2>{J&`wc4A=;74VgN> z(>e2-wNZA8I%Fkvj)Nr#dyDTz=l4YAw^x|v=yHuJDsP-FL4XV&6IF+`QeOwAajC<( zGR4=Es(ZEiWxi&YzS{77FF{>i&|n7LfpsN-5o(Li9RV34dPf&?%hXVs;T%$O9jMSbw9H{49J@?nM zbzZb*90ut*SI^d2vzeZ)o4s)lv1RTl7ni;|ZRnb1Pu8>b;hUAF+18%nxI}I#=3LR= zoH|i%@ix5)J68^(-*{yWluy=ea>BIX)*Wb&6GrDu5ae!TebB61{LqrP1}WoB`Po9E z+XicE$N77yPzFzFx*fEYZcVSK-{w*a8fo(ij>=_s@U80MtDW`qYv0>$$Su^bHLd3A z*Dlhns$*}jtff(Qux6%jy>e{&-SwOLLg=C}?ljM6U3Z5rPZ%qY0juWSq~B@^%h%OM z3p`%8O5Iy36Z{N?+nLz@uK{+Wc%GBDymQ-*{pK}FqKdUqx_8YicFqdURO;dwP08)F zLp)BZL8iOH*}`&lkc(x8t}0!-kJdtUom)woNp%>lvNtHN6@*oKww>g0>GAnerRqo( z`BCwkoU4=!OukX-ct)s9M>4vSDgDb;~grptX>xyRlH(8}QAV$lP*b)-vW+6{Ch4Grhg_-N2}$ h_6k(