소스 검색

提醒优化

DLC 11 달 전
부모
커밋
127b1c9044

+ 0 - 3
cx-aps/cx-aps-common/src/main/java/com/rongwei/bscommon/sys/service/impl/ApsProductionOrderServiceImpl.java

@@ -375,7 +375,6 @@ public class ApsProductionOrderServiceImpl extends ServiceImpl<ApsProductionOrde
      */
     @Override
     public void auxiliaryMaterial() {
-        log.info("辅料申购提醒开始");
         List<ApsProductionOrderDo> apsProductionOrderDos = this.baseMapper.getAuxiliaryMaterial();
         for (ApsProductionOrderDo apsProductionOrderDo : apsProductionOrderDos) {
             //系统通知(移动端和PC端个人工作台)
@@ -460,7 +459,6 @@ public class ApsProductionOrderServiceImpl extends ServiceImpl<ApsProductionOrde
      */
     @Override
     public void processDelay() {
-        log.info("作业延期提醒开始");
         List<ApsProductionOrderDo> apsProductionOrderDos = this.baseMapper.getProcessDelay();
         for (ApsProductionOrderDo apsProductionOrderDo : apsProductionOrderDos) {
             //系统通知(移动端和PC端个人工作台)
@@ -484,7 +482,6 @@ public class ApsProductionOrderServiceImpl extends ServiceImpl<ApsProductionOrde
      */
     @Override
     public void reportUnqualify() {
-        log.info("报工不合格提醒开始");
         List<ApsProductionOrderDo> apsProductionOrderDos = this.baseMapper.getReportUnqualify();
         if (apsProductionOrderDos.isEmpty()) {
             return;

+ 30 - 6
cx-aps/cx-aps-server/src/main/java/com/rongwei/bsserver/controller/ApsProductionOrderController.java

@@ -91,16 +91,32 @@ public class ApsProductionOrderController {
     辅料申购提醒
      */
     @PostMapping("/auxiliaryMaterial")
-    public void auxiliaryMaterial() {
-        apsProductionOrderService.auxiliaryMaterial();
+    public R auxiliaryMaterial() {
+        log.info("辅料申购提醒开始");
+        Thread thread = new Thread(new Runnable() {
+            @SneakyThrows
+            public void run() {
+                apsProductionOrderService.auxiliaryMaterial();
+            }
+        });
+        thread.start(); // 启动线程
+        return R.ok();
     }
 
     /*
     作业延期提醒
      */
     @PostMapping("/processDelay")
-    public void processDelay() {
-        apsProductionOrderService.processDelay();
+    public R processDelay() {
+        log.info("作业延期提醒开始");
+        Thread thread = new Thread(new Runnable() {
+            @SneakyThrows
+            public void run() {
+                apsProductionOrderService.processDelay();
+            }
+        });
+        thread.start(); // 启动线程
+        return R.ok();
     }
 
     /**
@@ -115,8 +131,16 @@ public class ApsProductionOrderController {
     报工不合格提醒
      */
     @PostMapping("/reportUnqualify")
-    public void reportUnqualify() {
-        apsProductionOrderService.reportUnqualify();
+    public R reportUnqualify() {
+        log.info("报工不合格提醒开始");
+        Thread thread = new Thread(new Runnable() {
+            @SneakyThrows
+            public void run() {
+                apsProductionOrderService.reportUnqualify();
+            }
+        });
+        thread.start(); // 启动线程
+        return R.ok();
     }