From 62903a6bcced0b44f4d9a4ca4bfab2f30ecdec25 Mon Sep 17 00:00:00 2001 From: pang.jiabao <pang_jiabao@163.com> Date: 星期五, 01 十一月 2024 11:40:52 +0800 Subject: [PATCH] 入库呼叫agv取货修改 --- src/main/java/com/zy/asrs/controller/WorkController.java | 144 +++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 137 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/WorkController.java b/src/main/java/com/zy/asrs/controller/WorkController.java index c76f3f7..1050097 100644 --- a/src/main/java/com/zy/asrs/controller/WorkController.java +++ b/src/main/java/com/zy/asrs/controller/WorkController.java @@ -1,19 +1,31 @@ package com.zy.asrs.controller; +import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.annotations.ManagerAuth; +import com.core.common.Cools; import com.core.common.R; +import com.zy.asrs.entity.BasDevp; +import com.zy.asrs.entity.StaDesc; +import com.zy.asrs.entity.WaitPakin; import com.zy.asrs.entity.param.EmptyPlateOutParam; import com.zy.asrs.entity.param.FullStoreParam; import com.zy.asrs.entity.param.LocDetlAdjustParam; import com.zy.asrs.entity.param.StockOutParam; import com.zy.asrs.service.BasDevpService; +import com.zy.asrs.service.StaDescService; import com.zy.asrs.service.WorkService; +import com.zy.common.model.StartupDto; import com.zy.common.web.BaseController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; /** * 宸ヤ綔娴佹帴鍙f帶鍒跺櫒 @@ -26,27 +38,110 @@ private WorkService workService; @Autowired private BasDevpService basDevpService; + @Autowired + private StaDescService staDescService; @RequestMapping("/available/put/site") - @ManagerAuth(memo = "鑾峰彇鍏ュ簱绔欑偣") + @ManagerAuth() public R availablePutSite(){ return R.ok().add(basDevpService.getAvailableInSite()); } @RequestMapping("/available/empty/put/site") - @ManagerAuth(memo = "鑾峰彇绌烘澘鍏ュ簱绔欑偣") + @ManagerAuth() public R availableEmptyPutSite(){ return R.ok().add(basDevpService.getAvailableEmptyInSite()); } @RequestMapping("/available/take/site") - @ManagerAuth(memo = "鑾峰彇鍑哄簱绔欑偣") + @ManagerAuth() public R availableTakeSite(){ - return R.ok().add(basDevpService.getAvailableOutSite()); + List<Map<String, Object>> result = new ArrayList<>(); + List<Integer> outSite = basDevpService.getAvailableOutSite(101); + for (Integer siteId : outSite) { + Map<String, Object> map = new HashMap<>(); + map.put("siteId", siteId); + map.put("desc", siteId + "锛堝叏鏉垮嚭搴撳彛锛�"); + result.add(map); + } + List<Integer> pickOutSite = basDevpService.getAvailableOutSite(103); + for (Integer siteId : pickOutSite) { + Map<String, Object> map = new HashMap<>(); + map.put("siteId", siteId); + map.put("desc", siteId + "锛堟嫞鏂欏嚭搴撳彛锛�"); + result.add(map); + } + return R.ok().add(result); + } + @RequestMapping("/crn/available/take/site") + @ManagerAuth() + public R crnAvailableTakeSite(){ + List<Map<String, Object>> result = new ArrayList<>(); + List<Integer> outSite = basDevpService.getCrnAvailableOutSite(101); + for (Integer siteId : outSite) { + Map<String, Object> map = new HashMap<>(); + map.put("siteId", siteId); + map.put("desc", siteId + "锛堝叏鏉垮嚭搴撳彛锛�"); + result.add(map); + } + List<Integer> pickOutSite = basDevpService.getCrnAvailableOutSite(103); + for (Integer siteId : pickOutSite) { + Map<String, Object> map = new HashMap<>(); + map.put("siteId", siteId); + map.put("desc", siteId + "锛堟嫞鏂欏嚭搴撳彛锛�"); + result.add(map); + } + return R.ok().add(result); + } + + @RequestMapping("/available/take/check/site") + @ManagerAuth() + public R availableTakeCheckSite(){ + return R.ok().add(basDevpService.getAvailableOutSite(107)); + } + + @RequestMapping("/available/take/check/site/crn") + @ManagerAuth() + public R availableTakeCheckSiteCrn(){ + EntityWrapper<StaDesc> staDescEntityWrapper = new EntityWrapper<>(); + staDescEntityWrapper.eq("type_no",107); + staDescEntityWrapper.setSqlSelect("DISTINCT stn_no as stnNo"); + staDescEntityWrapper.in("crn_no",1,2,3,4,5,6,7); + return R.ok().add(staDescService.selectList(staDescEntityWrapper)); + } + + @RequestMapping("/available/take/check/site/ctu") + @ManagerAuth() + public R availableTakeCheckSiteCtu(){ + return R.ok().add(basDevpService.getAvailableOutSite(107)); + } + + @RequestMapping("/available/take/check/site/shuttle") + @ManagerAuth() + public R availableTakeCheckSiteShuttle(){ + return R.ok().add(basDevpService.getAvailableOutSite(107)); + } + + @RequestMapping("/available/crn/empty/take/site") + @ManagerAuth() + public R availablecrnEmptyTakeSite(){ + return R.ok().add(basDevpService.getCrnAvailableEmptyOutSite()); + } + + @RequestMapping("/available/shuttle/empty/take/site") + @ManagerAuth() + public R availableshuttleEmptyTakeSite(){ + return R.ok().add(basDevpService.getShuttleAvailableEmptyOutSite()); + } + + @RequestMapping("/available/ctu/empty/take/site") + @ManagerAuth() + public R availablectuEmptyTakeSite(){ + return R.ok().add(basDevpService.getCtuAvailableEmptyOutSite()); } @RequestMapping("/available/empty/take/site") - @ManagerAuth(memo = "鑾峰彇绌烘澘鍑哄簱绔欑偣") + @ManagerAuth() public R availableEmptyTakeSite(){ return R.ok().add(basDevpService.getAvailableEmptyOutSite()); } @@ -54,11 +149,16 @@ @RequestMapping("/full/store/put/start") @ManagerAuth(memo = "鍏ㄦ澘鍏ュ簱") public R fullStorePutStart(@RequestBody FullStoreParam fullStoreParam) { - return R.ok("鍏ュ簱鍚姩鎴愬姛").add(workService.startupFullPutStore(fullStoreParam,getUserId())); + try { + String locNo = workService.startupFullPutStore(fullStoreParam, getUserId()); + return R.ok("鍏ュ簱鍚姩鎴愬姛").add(locNo); + } catch (Exception e){ + return R.error("鍏ュ簱鍚姩澶辫触==>"+e.getMessage()); + } } @RequestMapping("/plate/out/start") - @ManagerAuth(memo = "鍏ㄦ澘鍑哄簱") + @ManagerAuth(memo = "鍑哄簱浣滀笟") public R fullStoreTakeStart(@RequestBody StockOutParam param) { workService.startupFullTakeStore(param, getUserId()); return R.ok("鍑哄簱鍚姩鎴愬姛"); @@ -92,6 +192,19 @@ return R.ok("绉诲簱鍚姩鎴愬姛"); } + @RequestMapping("/mat/turn/over/out/start") + @ManagerAuth(memo = "鍝佸彿绉讳氦") + public R turnMatLocDetl(@RequestBody EmptyPlateOutParam param) { + if (Cools.isEmpty(param) || Cools.isEmpty(param.getLocDetls(),param.getMatId()) || Cools.isEmpty(param.getLocDetls().get(0)) || Cools.isEmpty(param.getLocDetls().get(0).getMatnr())){ + return R.error("鍙傛暟涓虹┖"); + } + if (param.getLocDetls().size()>1){ + return R.error("璇峰崟鏉℃暟鎹慨鏀癸紝璋ㄦ厧鎿嶄綔锛�"); + } + workService.turnMatLocDetl(param, getUserId()); + return R.ok("鍝佸彿绉讳氦鎴愬姛"); + } + @RequestMapping("/locDdetl/adjust/start") @ManagerAuth(memo = "搴撳瓨璋冩暣") public R locDetlAdjustStart(@RequestBody LocDetlAdjustParam param) { @@ -109,8 +222,25 @@ } else if (type == 2) { workService.cancelWrkMast(workNo, getUserId()); return R.ok("宸ヤ綔妗e凡鍙栨秷"); + } else if (type == 3) { + workService.pickWrkMast(workNo, getUserId()); + return R.ok("宸ヤ綔妗e凡鎷f枡"); } return R.ok(); } + @RequestMapping("/create/waitPain/wrkMast/start") + @ManagerAuth(memo = "鐢熸垚浠诲姟") + public R createWaitPainWrkMastStart(@RequestBody List<WaitPakin> list) { + StartupDto startupDto = workService.createWaitPainWrkMastStart(list, getUserId()); + return R.ok("浠诲姟鍙凤細" + startupDto.getWorkNo() + ";鐩爣搴撲綅锛�" + startupDto.getLocNo()); + } + + @RequestMapping("/deal/preHave/start") + @ManagerAuth(memo = "鍏堝叆鍝佸鐞�") + public R dealPreHave(@RequestParam Integer wrkNo) { + String locNo = workService.dealPreHaveStart(wrkNo, getUserId()); + return R.ok("浠诲姟閲嶆柊鍏ュ簱锛岀洰鏍囧簱浣嶏細" + locNo); + } + } -- Gitblit v1.9.1