From af212f68a20cfd2549a37093a7850b5a99f1a2ea Mon Sep 17 00:00:00 2001 From: ZY <zc857179121@qq.com> Date: 星期六, 21 九月 2024 09:39:19 +0800 Subject: [PATCH] 逻辑调整 --- src/main/java/com/zy/asrs/controller/OpenController.java | 164 +++++++++++++++++++++++++++++++----------------------- 1 files changed, 93 insertions(+), 71 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java index 01996c4..8ebafbe 100644 --- a/src/main/java/com/zy/asrs/controller/OpenController.java +++ b/src/main/java/com/zy/asrs/controller/OpenController.java @@ -1,11 +1,10 @@ package com.zy.asrs.controller; import com.alibaba.fastjson.JSON; +import com.core.annotations.AppAuth; import com.core.common.*; import com.core.exception.CoolException; -import com.zy.asrs.entity.param.OpenOrderCompleteParam; -import com.zy.asrs.entity.param.OpenOrderPakinParam; -import com.zy.asrs.entity.param.OpenOrderPakoutParam; +import com.zy.asrs.entity.param.*; import com.zy.asrs.service.OpenService; import com.zy.common.model.DetlDto; import com.zy.common.web.BaseController; @@ -13,6 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; +import javax.servlet.http.HttpServletRequest; import java.util.ArrayList; import java.util.Date; import java.util.List; @@ -33,33 +33,44 @@ @Autowired private OpenService openService; - + @PostMapping("/order/matSync/default/v1") + @AppAuth(memo = "鍟嗗搧淇℃伅鍚屾鎺ュ彛") + public synchronized R syncMatInfo(@RequestHeader(required = false) String appkey, + @RequestBody(required = false) MatSyncParam param, + HttpServletRequest request){ + auth(appkey, param, request); + if (Cools.isEmpty(param)) { + return R.parse(BaseRes.PARAM); + } + openService.syncMat(param); + return R.ok(); + } /****************************************************************************/ /********************************* 鎵撳寘涓婄嚎 **********************************/ /****************************************************************************/ - - @PostMapping("/order/pakin/new/package/v1") - public synchronized R pakinOrderPackage(@RequestHeader(required = false) String appkey, - @RequestParam(required = false) String barcode) { - auth(appkey, barcode); - if (Cools.isEmpty(barcode)) { - return R.parse(BaseRes.PARAM); - } - openService.packageUp(barcode); - return R.ok(); - } - - +// @PostMapping("/order/pakin/new/package/v1") +// @AppAuth(memo = "鎵撳寘涓婄嚎鎺ュ彛") +// public synchronized R pakinOrderPackage(@RequestHeader(required = false) String appkey, +// @RequestBody(required = false) PackParam param, +// HttpServletRequest request) { +// auth(appkey, param, request); +// if (Cools.isEmpty(param)) { +// return R.parse(BaseRes.PARAM); +// } +// openService.packageUp(param); +// return R.ok(); +// } /** * 娣诲姞鍏ュ簱鍗� */ - @PostMapping("/order/pakin/new/default/v1") + @PostMapping("/order/pakin/default/v1") public synchronized R pakinOrderCreate(@RequestHeader(required = false) String appkey, - @RequestBody OpenOrderPakinParam param) { - auth(appkey, param); + @RequestBody OpenOrderPakinParam param, + HttpServletRequest request) { + auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } @@ -72,7 +83,7 @@ if (Cools.isEmpty(param.getOrderDetails())) { return R.error("鍗曟嵁鏄庣粏[orderDetails]涓嶈兘涓虹┖"); } - openService.pakinOrderCreate(param); + //openService.pakinOrderCreate(param); return R.ok(); } @@ -81,20 +92,29 @@ */ @PostMapping("/order/pakin/complete/default/v1") public synchronized R orderPakinComplete(@RequestHeader(required = false) String appkey, - @RequestBody(required = false) OpenOrderCompleteParam param) { - auth(appkey, param); + @RequestBody(required = false) OpenOrderCompleteParam param, + HttpServletRequest request) { + auth(appkey, param, request); return R.ok().add(openService.pakinOrderComplete(param)); } /** * 娣诲姞鍑哄簱鍗� */ - @PostMapping("/order/pakout/new/default/v1") + @PostMapping("/order/pakout/default/v1") + @AppAuth(memo = "娣诲姞璁㈠崟鍑哄簱") public synchronized R pakoutOrderCreate(@RequestHeader(required = false) String appkey, - @RequestBody OpenOrderPakoutParam param) { - auth(appkey, param); + @RequestBody OpenOrderPakoutParam param, + HttpServletRequest request) { + auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); + } + if (Cools.isEmpty(param.getLgort())) { + return R.error("鍗曟嵁缂栧彿[lgort]涓嶈兘涓虹┖"); + } + if (!param.getLgort().equals("5006")) { + return R.ok(); } if (Cools.isEmpty(param.getOrderNo())) { return R.error("鍗曟嵁缂栧彿[orderNo]涓嶈兘涓虹┖"); @@ -114,8 +134,9 @@ */ @PostMapping("/order/pakout/complete/default/v1") public synchronized R orderPakoutComplete(@RequestHeader(required = false) String appkey, - @RequestBody(required = false) OpenOrderCompleteParam param) { - auth(appkey, param); + @RequestBody(required = false) OpenOrderCompleteParam param, + HttpServletRequest request) { + auth(appkey, param, request); return R.ok().add(openService.pakoutOrderComplete(param)); } @@ -124,14 +145,15 @@ * 搴撳瓨缁熻 */ @RequestMapping("/stock/default/v1") - public R queryStock(@RequestHeader(required = false) String appkey) { - auth(appkey, null); + public R queryStock(@RequestHeader(required = false) String appkey, + HttpServletRequest request) { + auth(appkey, null, request); return R.ok().add(openService.queryStock()); } - - private void auth(String appkey, Object obj) { - log.info("{}鎺ュ彛琚闂紒appkey:{},璇锋眰鏁版嵁锛歿}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj)); + private void auth(String appkey, Object obj, HttpServletRequest request) { + log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj)); + request.setAttribute("cache", obj); if (!auth) { return; } @@ -143,43 +165,43 @@ } } - public static void main(String[] args) { - // 1 - System.out.println("======================================"); - OpenOrderPakinParam param = new OpenOrderPakinParam(); - param.setOrderNo(String.valueOf(new SnowflakeIdWorker().nextId())); - param.setOrderType("鎵撳寘涓婄嚎鍗�"); - param.setOrderTime(DateUtils.convert(new Date())); - List<DetlDto> orderDetails = new ArrayList<>(); - param.setOrderDetails(orderDetails); - for (int i = 0; i < 3; i++) { - DetlDto detlDto = new DetlDto(); - switch (i) { - case 0: - detlDto.setMatnr("MDH020030530"); - detlDto.setBatch("500"); - detlDto.setAnfme(18.0); - break; - case 1: - detlDto.setMatnr("MDH020016416"); - detlDto.setBatch("500"); - detlDto.setAnfme(32.0); - break; - case 2: - detlDto.setMatnr("LSH90152025"); - detlDto.setAnfme(50.0); - break; - default: - break; - } - orderDetails.add(detlDto); - } - System.out.println(JSON.toJSONString(param)); - // 2 - System.out.println("======================================"); - OpenOrderCompleteParam param1 = new OpenOrderCompleteParam(); - param1.setOrderNo("963001846497017856"); - System.out.println(JSON.toJSONString(param1)); - } +// public static void main(String[] args) { +// // 1 +// System.out.println("======================================"); +// OpenOrderPakinParam param = new OpenOrderPakinParam(); +// param.setOrderNo(String.valueOf(new SnowflakeIdWorker().nextId())); +// param.setOrderType("鎵撳寘涓婄嚎鍗�"); +// param.setOrderTime(DateUtils.convert(new Date())); +// List<DetlDto> orderDetails = new ArrayList<>(); +// param.setOrderDetails(orderDetails); +// for (int i = 0; i < 3; i++) { +// DetlDto detlDto = new DetlDto(locDto); +// switch (i) { +// case 0: +// detlDto.setMatnr("MDH020030530"); +// detlDto.setBatch("500"); +// detlDto.setAnfme(18.0); +// break; +// case 1: +// detlDto.setMatnr("MDH020016416"); +// detlDto.setBatch("500"); +// detlDto.setAnfme(32.0); +// break; +// case 2: +// detlDto.setMatnr("LSH90152025"); +// detlDto.setAnfme(50.0); +// break; +// default: +// break; +// } +// orderDetails.add(detlDto); +// } +// System.out.println(JSON.toJSONString(param)); +// // 2 +// System.out.println("======================================"); +// OpenOrderCompleteParam param1 = new OpenOrderCompleteParam(); +// param1.setOrderNo("963001846497017856"); +// System.out.println(JSON.toJSONString(param1)); +// } } -- Gitblit v1.9.1