From 7d8cb5591159f5a863438bf513413e227fcba16c Mon Sep 17 00:00:00 2001 From: ludj Date: Mon, 17 Apr 2023 11:18:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E4=BB=BB=E5=8A=A1=E4=BA=8B?= =?UTF-8?q?=E5=8A=A1=E6=B3=A8=E8=A7=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lms/nladmin-system/pom.xml | 33 ++++++++++--------- .../acs/service/impl/AcsToWmsServiceImpl.java | 10 +++--- .../sch/task/call/empty/HLCallEmptyTask.java | 12 +++---- .../sch/task/call/empty/YZCallEmptyTask.java | 14 ++++---- .../call/material/FJCallMaterialTask.java | 14 ++++---- .../call/material/SZCallMaterialTask.java | 16 ++++----- .../sch/task/send/empty/FJSendEmptyTask.java | 14 ++++---- .../send/material/HLSendMaterialTask.java | 11 +++---- .../send/material/SZSendMaterialTask.java | 14 ++++---- .../send/material/YZSendMaterialTask.java | 14 ++++---- .../main/resources/config/application-dev.yml | 4 +-- .../src/views/wms/sch/point/index.vue | 4 +-- 12 files changed, 79 insertions(+), 81 deletions(-) diff --git a/lms/nladmin-system/pom.xml b/lms/nladmin-system/pom.xml index e29aa9f..2d202b6 100644 --- a/lms/nladmin-system/pom.xml +++ b/lms/nladmin-system/pom.xml @@ -19,7 +19,6 @@ 1.8 1.16 2.9.2 - 1.2.70 1.1.22 2.5.0 1.3.1.Final @@ -67,6 +66,12 @@ org.reflections reflections 0.9.10 + + + guava + com.google.guava + + @@ -132,6 +137,10 @@ io.swagger swagger-models + + mapstruct + org.mapstruct + @@ -186,6 +195,12 @@ com.alibaba easyexcel 2.1.6 + + + asm + org.ow2.asm + + org.apache.poi @@ -207,14 +222,6 @@ xercesImpl 2.12.0 - - - - com.alibaba - fastjson - ${fastjson.version} - - org.mapstruct @@ -269,7 +276,7 @@ org.aspectj aspectjweaver - 1.9.2 + 1.9.6 @@ -278,12 +285,6 @@ spring-boot-starter-aop - - - com.google.guava - guava - 29.0-jre - org.springframework.boot diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java index f3ccb7d..d610de1 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java @@ -22,7 +22,6 @@ import org.nl.wms.sch.manage.*; import org.nl.wms.sch.task.call.empty.HLCallEmptyTask; import org.nl.wms.sch.task.call.empty.YZCallEmptyTask; import org.nl.wms.sch.task.call.material.FJCallMaterialTask; -import org.nl.wms.sch.task.call.material.SZCallMaterialTask; import org.nl.wms.sch.task.send.empty.FJSendEmptyTask; import org.nl.wms.sch.task.send.material.HLSendMaterialTask; import org.nl.wms.sch.task.send.material.SZSendMaterialTask; @@ -184,6 +183,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { @Transactional(rollbackFor = Exception.class) public JSONObject apply(JSONObject param) { String point_code = param.getString("device_code"); + String type = param.getString("type"); + if (StrUtil.isBlank(type)) { + throw new BadRequestException("任务类型不能为空!"); + } if (StrUtil.isBlank(point_code)) { throw new BadRequestException("点位不能为空!"); } @@ -204,11 +207,6 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { } TaskUtils.isLocked(point); - String type = param.getString("type"); - if (StrUtil.isBlank(type)) { - throw new BadRequestException("任务类型不能为空!"); - } - Region region = Region.get(point.getString("region_code")); JSONObject method_param = new JSONObject(); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/HLCallEmptyTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/HLCallEmptyTask.java index 292c4d1..ad58e0c 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/HLCallEmptyTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/HLCallEmptyTask.java @@ -37,7 +37,7 @@ public class HLCallEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -67,7 +67,7 @@ public class HLCallEmptyTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findStartPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -102,7 +102,7 @@ public class HLCallEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -112,7 +112,7 @@ public class HLCallEmptyTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -122,7 +122,7 @@ public class HLCallEmptyTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -160,7 +160,7 @@ public class HLCallEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/YZCallEmptyTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/YZCallEmptyTask.java index c98cd77..201e9e5 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/YZCallEmptyTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/empty/YZCallEmptyTask.java @@ -24,7 +24,7 @@ import org.springframework.transaction.annotation.Transactional; @Component public class YZCallEmptyTask extends AbstractAcsTask { - @Transactional(rollbackFor = Exception.class) + @Override public void updateTaskStatus(JSONObject task, String status) { if (TaskStatus.EXECUTING.value().equals(status)) { @@ -38,7 +38,7 @@ public class YZCallEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -73,7 +73,7 @@ public class YZCallEmptyTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findStartPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -112,7 +112,7 @@ public class YZCallEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -122,7 +122,7 @@ public class YZCallEmptyTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -132,7 +132,7 @@ public class YZCallEmptyTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -170,7 +170,7 @@ public class YZCallEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/FJCallMaterialTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/FJCallMaterialTask.java index 17c15c5..51e57fa 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/FJCallMaterialTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/FJCallMaterialTask.java @@ -22,7 +22,7 @@ import org.springframework.transaction.annotation.Transactional; @Component public class FJCallMaterialTask extends AbstractAcsTask { - @Transactional(rollbackFor = Exception.class) + @Override public void updateTaskStatus(JSONObject task, String status) { if (TaskStatus.EXECUTING.value().equals(status)) { @@ -36,7 +36,7 @@ public class FJCallMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -67,7 +67,7 @@ public class FJCallMaterialTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findStartPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -100,7 +100,7 @@ public class FJCallMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -110,7 +110,7 @@ public class FJCallMaterialTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -120,7 +120,7 @@ public class FJCallMaterialTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -158,7 +158,7 @@ public class FJCallMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/SZCallMaterialTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/SZCallMaterialTask.java index add73f9..7ba465a 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/SZCallMaterialTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/call/material/SZCallMaterialTask.java @@ -21,7 +21,7 @@ import org.springframework.transaction.annotation.Transactional; @Component public class SZCallMaterialTask extends AbstractAcsTask { - @Transactional(rollbackFor = Exception.class) + @Override public void autoCreate() { JSONArray points = WQL.getWO("CALL_MATERIAL_TASK").addParam("flag", "2").process().getResultJSONArray(0); @@ -39,7 +39,7 @@ public class SZCallMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void updateTaskStatus(JSONObject task, String status) { if (TaskStatus.EXECUTING.value().equals(status)) { @@ -53,7 +53,7 @@ public class SZCallMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -83,7 +83,7 @@ public class SZCallMaterialTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findStartPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -117,7 +117,7 @@ public class SZCallMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -127,7 +127,7 @@ public class SZCallMaterialTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -137,7 +137,7 @@ public class SZCallMaterialTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -175,7 +175,7 @@ public class SZCallMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/empty/FJSendEmptyTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/empty/FJSendEmptyTask.java index e440d65..4cb31f0 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/empty/FJSendEmptyTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/empty/FJSendEmptyTask.java @@ -21,7 +21,7 @@ import org.springframework.transaction.annotation.Transactional; @Component public class FJSendEmptyTask extends AbstractAcsTask { - @Transactional(rollbackFor = Exception.class) + @Override public void updateTaskStatus(JSONObject task, String status) { if (TaskStatus.EXECUTING.value().equals(status)) { @@ -35,7 +35,7 @@ public class FJSendEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -66,7 +66,7 @@ public class FJSendEmptyTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findNextPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -97,7 +97,7 @@ public class FJSendEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -107,7 +107,7 @@ public class FJSendEmptyTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -117,7 +117,7 @@ public class FJSendEmptyTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -154,7 +154,7 @@ public class FJSendEmptyTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/HLSendMaterialTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/HLSendMaterialTask.java index c32a3d0..94401cc 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/HLSendMaterialTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/HLSendMaterialTask.java @@ -39,7 +39,6 @@ public class HLSendMaterialTask extends AbstractAcsTask { } @Override - @Transactional public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -74,7 +73,7 @@ public class HLSendMaterialTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findNextPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -105,7 +104,7 @@ public class HLSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -115,7 +114,7 @@ public class HLSendMaterialTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -125,7 +124,7 @@ public class HLSendMaterialTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -162,7 +161,7 @@ public class HLSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/SZSendMaterialTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/SZSendMaterialTask.java index 508de79..ab0bc1f 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/SZSendMaterialTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/SZSendMaterialTask.java @@ -21,7 +21,7 @@ import org.springframework.transaction.annotation.Transactional; @Component public class SZSendMaterialTask extends AbstractAcsTask { - @Transactional(rollbackFor = Exception.class) + @Override public void updateTaskStatus(JSONObject task, String status) { if (TaskStatus.EXECUTING.value().equals(status)) { @@ -35,7 +35,7 @@ public class SZSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -66,7 +66,7 @@ public class SZSendMaterialTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findNextPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -97,7 +97,7 @@ public class SZSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -107,7 +107,7 @@ public class SZSendMaterialTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -117,7 +117,7 @@ public class SZSendMaterialTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -154,7 +154,7 @@ public class SZSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/YZSendMaterialTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/YZSendMaterialTask.java index 01ac027..a201c09 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/YZSendMaterialTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/task/send/material/YZSendMaterialTask.java @@ -22,7 +22,7 @@ import org.springframework.transaction.annotation.Transactional; @Component public class YZSendMaterialTask extends AbstractAcsTask { - @Transactional(rollbackFor = Exception.class) + @Override public void updateTaskStatus(JSONObject task, String status) { if (TaskStatus.EXECUTING.value().equals(status)) { @@ -36,7 +36,7 @@ public class YZSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public String createTask(JSONObject form) { JSONObject point = form.getJSONObject("point"); @@ -68,7 +68,7 @@ public class YZSendMaterialTask extends AbstractAcsTask { return task.getString("task_id"); } - @Transactional(rollbackFor = Exception.class) + @Override public void findNextPoint() { WQLObject task_table = WQLObject.getWQLObject("sch_base_task"); @@ -102,7 +102,7 @@ public class YZSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + @Override public void forceFinish(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -112,7 +112,7 @@ public class YZSendMaterialTask extends AbstractAcsTask { this.finishTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + @Override public void cancel(String task_id) { JSONObject task = WQLObject.getWQLObject("sch_base_task").query("task_id = " + task_id).uniqueResult(0); @@ -122,7 +122,7 @@ public class YZSendMaterialTask extends AbstractAcsTask { this.cancelTask(task, OperationType.MANUAL); } - @Transactional(rollbackFor = Exception.class) + public void cancelTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.CANCELLED.value()); @@ -159,7 +159,7 @@ public class YZSendMaterialTask extends AbstractAcsTask { } } - @Transactional(rollbackFor = Exception.class) + public void finishTask(JSONObject task, OperationType operation_type) { if (task.getIntValue("task_status") < Integer.parseInt(TaskStatus.FINISHED.value())) { task.put("task_status", TaskStatus.FINISHED.value()); diff --git a/lms/nladmin-system/src/main/resources/config/application-dev.yml b/lms/nladmin-system/src/main/resources/config/application-dev.yml index 84e511a..5ac9770 100644 --- a/lms/nladmin-system/src/main/resources/config/application-dev.yml +++ b/lms/nladmin-system/src/main/resources/config/application-dev.yml @@ -6,9 +6,9 @@ spring: druid: db-type: com.alibaba.druid.pool.DruidDataSource driverClassName: net.sf.log4jdbc.sql.jdbcapi.DriverSpy - url: jdbc:log4jdbc:mysql://${DB_HOST:127.0.0.1}:${DB_PORT:3306}/${DB_NAME:lnsh_lms3}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useOldAliasMetadataBehavior=true + url: jdbc:log4jdbc:mysql://${DB_HOST:47.111.78.178}:${DB_PORT:3306}/${DB_NAME:lnsh_lms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useOldAliasMetadataBehavior=true username: ${DB_USER:root} - password: ${DB_PWD:123456} + password: ${DB_PWD:P@ssw0rd} # 初始连接数 initial-size: 5 # 最小连接数 diff --git a/lms/nladmin-ui/src/views/wms/sch/point/index.vue b/lms/nladmin-ui/src/views/wms/sch/point/index.vue index 33d283e..c85f396 100644 --- a/lms/nladmin-ui/src/views/wms/sch/point/index.vue +++ b/lms/nladmin-ui/src/views/wms/sch/point/index.vue @@ -258,7 +258,7 @@ - +