From 19c74dc7fc321baa85ab9fc7c9bb1244dcc2005a Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 23 九月 2024 13:00:22 +0800
Subject: [PATCH] #

---
 zy-acs-manager/src/main/java/com/zy/acs/manager/manager/controller/BusController.java |   49 ++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 36 insertions(+), 13 deletions(-)

diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/controller/BusController.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/controller/BusController.java
index 5d3f8b5..50856dd 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/controller/BusController.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/controller/BusController.java
@@ -4,13 +4,16 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.zy.acs.framework.common.Cools;
 import com.zy.acs.framework.common.R;
-import com.zy.acs.manager.common.utils.ExcelUtil;
 import com.zy.acs.manager.common.annotation.OperationLog;
-import com.zy.acs.manager.common.domain.BaseParam;
-import com.zy.acs.manager.common.domain.KeyValVo;
-import com.zy.acs.manager.common.domain.PageParam;
+import com.zy.acs.manager.common.domain.*;
+import com.zy.acs.manager.common.utils.ExcelUtil;
+import com.zy.acs.manager.core.service.MainService;
+import com.zy.acs.manager.manager.controller.param.BusCreateParam;
+import com.zy.acs.manager.manager.controller.param.OpenBusSubmitParam;
 import com.zy.acs.manager.manager.entity.Bus;
 import com.zy.acs.manager.manager.service.BusService;
+import com.zy.acs.manager.manager.service.LocService;
+import com.zy.acs.manager.manager.service.StaService;
 import com.zy.acs.manager.system.controller.BaseController;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -25,6 +28,12 @@
 
     @Autowired
     private BusService busService;
+    @Autowired
+    private MainService mainService;
+    @Autowired
+    private StaService staService;
+    @Autowired
+    private LocService locService;
 
     @PreAuthorize("hasAuthority('manager:bus:list')")
     @PostMapping("/bus/page")
@@ -55,14 +64,28 @@
     @PreAuthorize("hasAuthority('manager:bus:save')")
     @OperationLog("Create Bus")
     @PostMapping("/bus/save")
-    public R save(@RequestBody Bus bus) {
-        bus.setCreateBy(getLoginUserId());
-        bus.setCreateTime(new Date());
-        bus.setUpdateBy(getLoginUserId());
-        bus.setUpdateTime(new Date());
-        if (!busService.save(bus)) {
-            return R.error("Save Fail");
+    public R save(@RequestBody BusCreateParam param) {
+        OpenBusSubmitParam submitParam = new OpenBusSubmitParam();
+        submitParam.setBatch(param.getBusNo());
+        for (TaskIdByLongDto dto : param.getTaskList()) {
+            TaskDto taskDto = new TaskDto();
+            taskDto.setSeqNum(dto.getSeqNum());
+            taskDto.setPriority(dto.getPriority());
+            if (!Cools.isEmpty(dto.getOriSta())) {
+                taskDto.setOriSta(staService.getById(dto.getOriSta()).getStaNo());
+            }
+            if (!Cools.isEmpty(dto.getOriLoc())) {
+                taskDto.setOriLoc(locService.getById(dto.getOriLoc()).getLocNo());
+            }
+            if (!Cools.isEmpty(dto.getDestSta())) {
+                taskDto.setDestSta(staService.getById(dto.getDestSta()).getStaNo());
+            }
+            if (!Cools.isEmpty(dto.getDestLoc())) {
+                taskDto.setDestLoc(locService.getById(dto.getDestLoc()).getLocNo());
+            }
+            submitParam.getTaskList().add(taskDto);
         }
+        Bus bus = mainService.generateBusAndTask(submitParam, param.getMemo());
         return R.ok("Save Success").add(bus);
     }
 
@@ -94,10 +117,10 @@
         List<KeyValVo> vos = new ArrayList<>();
         LambdaQueryWrapper<Bus> wrapper = new LambdaQueryWrapper<>();
         if (!Cools.isEmpty(condition)) {
-            wrapper.like(Bus::getSeqNum, condition);
+            wrapper.like(Bus::getBusNo, condition);
         }
         busService.page(new Page<>(1, 30), wrapper).getRecords().forEach(
-                item -> vos.add(new KeyValVo(item.getId(), item.getSeqNum()))
+                item -> vos.add(new KeyValVo(item.getId(), item.getBusNo()))
         );
         return R.ok().add(vos);
     }

--
Gitblit v1.9.1