From 9eccd1928920bd29e208ee1b248cf82698c135c3 Mon Sep 17 00:00:00 2001 From: LSH <brook_w@163.com> Date: 星期六, 13 八月 2022 10:39:37 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/MobileController.java | 85 +++++++++++++++++++----------------------- 1 files changed, 38 insertions(+), 47 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java index 0aa03bc..7508ecd 100644 --- a/src/main/java/com/zy/asrs/controller/MobileController.java +++ b/src/main/java/com/zy/asrs/controller/MobileController.java @@ -1,10 +1,13 @@ package com.zy.asrs.controller; +import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.baomidou.mybatisplus.mapper.Wrapper; import com.core.annotations.ManagerAuth; import com.core.common.BaseRes; import com.core.common.Cools; +import com.core.common.DateUtils; import com.core.common.R; import com.core.exception.CoolException; import com.zy.asrs.entity.*; @@ -12,12 +15,16 @@ import com.zy.asrs.entity.param.MobileAdjustParam; import com.zy.asrs.entity.result.MobileAdjustResult; import com.zy.asrs.service.*; +import com.zy.asrs.task.handler.WorkLogHandler; +import com.zy.common.constant.MesConstant; import com.zy.common.model.LocDto; import com.zy.common.model.TaskDto; import com.zy.common.model.WrkDto; +import com.zy.common.utils.HttpHandler; import com.zy.common.web.BaseController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; +import org.springframework.transaction.interceptor.TransactionAspectSupport; import org.springframework.web.bind.annotation.*; import java.util.*; @@ -50,6 +57,16 @@ private BasDevpService basDevpService; @Autowired private PackService packService; + + + // 鍟嗗搧涓婃灦 + @RequestMapping("/mat/onSale/auth") + //@ManagerAuth + public R matOnSale(@RequestBody CombParam combParam){ + mobileService.onSale(combParam); + return R.ok("涓婃灦鎴愬姛"); + } + // 鍟嗗搧涓嬫灦 // 缁勬墭 ---------------------------------------------------------------------------------------------------- @@ -298,61 +315,35 @@ } @PostMapping("/order/out/pakout/auth") -// @ManagerAuth(memo = "鏍规嵁璁㈠崟鍑哄簱") + @ManagerAuth(memo = "璁㈠崟鍑哄簱") public synchronized R pakoutByOrder(@RequestBody JSONObject param) { if(!param.containsKey("staNo") || !param.containsKey("orderNo")){ return R.parse(BaseRes.PARAM); } - Integer staNo = param.containsKey("staNo") ? Integer.parseInt(param.get("staNo").toString()) : 0; - String orderNo = param.containsKey("orderNo") ? param.get("orderNo").toString() : ""; + mobileService.pakoutByOrder(param,getUserId()); + return R.ok("鍑哄簱鎴愬姛"); + } - BasDevp sta = basDevpService.checkSiteStatus(staNo); - //鏍规嵁璁㈠崟鍙风敓鎴愬嚭搴撲换鍔″伐浣滄。,寰呭疄鐜� - List<OrderDetl> orderDetls = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no", orderNo)); - for(OrderDetl orderDetl : orderDetls){ - //鏌ヨ鎵�鏈夊簱浣嶇姸鎬佷负F鐨勫簱浣嶄俊鎭� - List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(),orderDetl.getBatch(),orderDetl.getOrderNo(),null); - if (locDetls.size() == 0) { - throw new CoolException("搴撳瓨涓病鏈夎鐗╂枡"); - } + + /*...........................璧e窞鏂板..............浠ヤ笅.............璧e窞鏂板...........................*/ + @PostMapping("/test/startUp/auth") +// @ManagerAuth(memo = "鐢宠PACK娴嬭瘯") + public synchronized R startUpTestPACK(@RequestBody TestMast testMast) { + if (Cools.isEmpty(testMast)) { + return R.parse(BaseRes.PARAM); } + //鎻愪氦娴嬭瘯绯荤粺 + mobileService.startUpTestPACK(testMast); - -// if (Cools.isEmpty(locDtos)) { -// return R.parse(BaseRes.PARAM); -// } -// boolean lack = true; -// for (LocDto locDto : locDtos) { -// if (!locDto.isLack()) { -// lack = false; -// break; -// } -// } -// if (lack) { -// return R.error("搴撳瓨涓嶈冻"); -// } -// -// Thread.sleep(1000L); -// -// List<TaskDto> taskDtos = new ArrayList<>(); -// // 鏍规嵁 锛堝簱浣� & 鍑哄簱绔欙級 鍒嗙粍锛� 鐞嗘兂鐘舵�侊細涓�缁勪负涓�娆″嚭搴撲换鍔� -// for (LocDto locDto : locDtos) { -// if (locDto.isLack()) { continue; } -// TaskDto taskDto = new TaskDto(locDto.getLocNo(), locDto.getStaNo(), locDto); -// if (TaskDto.has(taskDtos, taskDto)) { -// TaskDto dto = TaskDto.find(taskDtos, taskDto); -// assert dto != null; -// dto.getLocDtos().addAll(taskDto.getLocDtos()); -// } else { -// taskDtos.add(taskDto); -// } -// } -// // ----------------------------------------------------------------------------------------------- -// for (TaskDto taskDto : taskDtos) { -// BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo()); -// workService.stockOut(staNo, taskDto, getUserId()); -// } return R.ok(); } + @PostMapping("/test/suspend/auth") + @ManagerAuth(memo = "鏆傚仠娴嬭瘯") + public synchronized R suspendTestPACK() { + mobileService.suspendTestPACK(); + return R.ok(); + } + /*...........................璧e窞鏂板..............浠ヤ笂.............璧e窞鏂板...........................*/ + } -- Gitblit v1.9.1