From 00985eabb51145130d4fa253b153aaeeec3a957a Mon Sep 17 00:00:00 2001 From: whycq <913841844@qq.com> Date: 星期日, 24 三月 2024 20:22:05 +0800 Subject: [PATCH] # app version --- src/main/java/com/zy/asrs/controller/AgvMobileController.java | 90 +++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 87 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/AgvMobileController.java b/src/main/java/com/zy/asrs/controller/AgvMobileController.java index 27d587c..6987853 100644 --- a/src/main/java/com/zy/asrs/controller/AgvMobileController.java +++ b/src/main/java/com/zy/asrs/controller/AgvMobileController.java @@ -1,13 +1,24 @@ package com.zy.asrs.controller; import com.core.common.R; +import com.zy.asrs.entity.AgvBasDevp; +import com.zy.asrs.entity.param.AgvMobileStartParam; import com.zy.asrs.entity.param.CombParam; +import com.zy.asrs.service.AgvBasDevpService; import com.zy.asrs.service.AgvMobileService; +import com.zy.asrs.service.AgvWorkService; +import com.zy.asrs.service.OrderDetlService; import com.zy.common.web.BaseController; +import lombok.Synchronized; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.*; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import java.util.List; import java.util.Map; +import java.util.stream.Collectors; /** * 绉诲姩绔帴鍙f帶鍒跺櫒 @@ -19,13 +30,26 @@ @Autowired private AgvMobileService agvMobileService; + @Autowired + private AgvBasDevpService agvBasDevpService; + @Autowired + private AgvWorkService workService; + @Autowired + private OrderDetlService orderDetlService; + + /* + locno锛熺粍鎵�+缁戝畾鏆傚瓨浣� 锛� 缁勬墭 + */ @PostMapping("/comb/auth") public R comb(@RequestBody CombParam combParam){ - agvMobileService.comb(combParam, 1l); - return R.ok("缁勬墭鎴愬姛"); + String message = agvMobileService.comb(combParam, 1l); + return R.ok(message); } + /* + 缁戝畾鎵樼洏鏉$爜涓庢殏瀛樹綅 + */ @PostMapping("/combBinging/auth") public R combBinding(@RequestBody Map<String,Object> map){ String barcode = map.get("barcode").toString(); @@ -34,9 +58,69 @@ return R.ok("鎵樼洏缁戝畾绔欑偣鎴愬姛"); } + /* + 鑾峰彇褰撳墠宸茬粦瀹氱殑杩樻病鐢熸垚宸ヤ綔妗g殑鏆傚瓨浣� + */ + @PostMapping("/getBasDevp/auth") + public R getBasDevpByFloor(@RequestBody Map<String,Object> map){ + String floor = map.get("floor").toString(); + if("1".equals(floor) || "3".equals(floor)){ + return R.ok(agvMobileService.getAgvBasDevpByFloor(Integer.parseInt(floor))); + } + return R.error("鍙傛暟閿欒"); + } + /* + 鑾峰彇杈撻�佺嚎绔欑偣 + */ + @PostMapping("/getBasDevp/noCacheShelves/auth") + public R getBasDevpByNoCacheShelves(){ + return R.ok(agvBasDevpService.getBasDevpByNoCacheShelves()); + } + /* + 鍚姩鍏ュ簱锛岀敓鎴愬伐浣滄。 + */ + @PostMapping("/pakin/auth") + @Synchronized + public R pakin(@RequestBody Map<String,Object> map){ + List<String> devNos = (List<String>) map.get("devNo"); + List<AgvBasDevp> agvBasDevpList = devNos.stream().map(devNo -> { + return agvBasDevpService.selectById(devNo); + }).collect(Collectors.toList()); + workService.createWaitPainWrkMastStart(agvBasDevpList, getUserId(),false); + + return R.ok("鐢熸垚宸ヤ綔妗f垚鍔�"); + } + + /* + 鍏ュ簱 + */ + @PostMapping("/pakin/empty/auth") + @Synchronized + public R pakinEmpty(@RequestBody List<AgvMobileStartParam> params){ + + for (AgvMobileStartParam param : params){ + workService.emptyPlateIn(param.getDevNo(),param.getContainerCode(),param.getContainerType(), getUserId()); + } + + return R.ok(); + } + + /* + 绌烘澘鍑哄簱 + */ + @PostMapping("/pakout/empty/auth") + @Synchronized + public R pakoutEmpty(@RequestBody List<AgvMobileStartParam> params){ + + for (AgvMobileStartParam param : params){ + workService.emptyPlateOut(param.getDevNo(),param.getContainerType(), getUserId()); + } + + return R.ok(); + } } -- Gitblit v1.9.1