From 5701eb6693c654d53f1bba460eb3a417d495b344 Mon Sep 17 00:00:00 2001 From: zhang <zc857179121@qq.com> Date: 星期三, 11 六月 2025 17:31:53 +0800 Subject: [PATCH] bug修复;下发任务给rcs携带货架码 --- src/main/java/com/zy/asrs/controller/OpenController.java | 730 +++++++++++++++++++++++++++++++++++++++++-------------- 1 files changed, 543 insertions(+), 187 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java index 19883d4..d99a3b3 100644 --- a/src/main/java/com/zy/asrs/controller/OpenController.java +++ b/src/main/java/com/zy/asrs/controller/OpenController.java @@ -1,187 +1,543 @@ -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.service.OpenService; -import com.zy.common.model.DetlDto; -import com.zy.common.web.BaseController; -import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.*; - -import java.util.ArrayList; -import java.util.Date; -import java.util.List; - -/** - * Created by vincent on 2022/4/8 - */ -@Slf4j -@RestController -@RequestMapping("open/asrs") -public class OpenController extends BaseController { - - private static final boolean auth = true; - public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{ - add("ea1f0459efc02a79f046f982767939ae"); - }}; - - @Autowired - private OpenService openService; - - - - /****************************************************************************/ - /********************************* 鎵撳寘涓婄嚎 **********************************/ - /****************************************************************************/ - - - @PostMapping("/order/pakin/new/package/v1") - @AppAuth(memo = "鎵撳寘涓婄嚎鎺ュ彛") - 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/default/v1") - public synchronized R pakinOrderCreate(@RequestHeader(required = false) String appkey, - @RequestBody OpenOrderPakinParam param) { - auth(appkey, param); - if (Cools.isEmpty(param)) { - return R.parse(BaseRes.PARAM); - } - if (Cools.isEmpty(param.getOrderNo())) { - return R.error("鍗曟嵁缂栧彿[orderNo]涓嶈兘涓虹┖"); - } - if (Cools.isEmpty(param.getOrderType())) { - return R.error("鍗曟嵁绫诲瀷[orderType]涓嶈兘涓虹┖"); - } - if (Cools.isEmpty(param.getOrderDetails())) { - return R.error("鍗曟嵁鏄庣粏[orderDetails]涓嶈兘涓虹┖"); - } - openService.pakinOrderCreate(param); - return R.ok(); - } - - /** - * 鍏ュ簱鍗曞洖鍐� - */ - @PostMapping("/order/pakin/complete/default/v1") - public synchronized R orderPakinComplete(@RequestHeader(required = false) String appkey, - @RequestBody(required = false) OpenOrderCompleteParam param) { - auth(appkey, param); - return R.ok().add(openService.pakinOrderComplete(param)); - } - - /** - * 娣诲姞鍑哄簱鍗� - */ - @PostMapping("/order/pakout/new/default/v1") - public synchronized R pakoutOrderCreate(@RequestHeader(required = false) String appkey, - @RequestBody OpenOrderPakoutParam param) { - auth(appkey, param); - if (Cools.isEmpty(param)) { - return R.parse(BaseRes.PARAM); - } - if (Cools.isEmpty(param.getOrderNo())) { - return R.error("鍗曟嵁缂栧彿[orderNo]涓嶈兘涓虹┖"); - } - if (Cools.isEmpty(param.getOrderType())) { - return R.error("鍗曟嵁绫诲瀷[orderType]涓嶈兘涓虹┖"); - } - if (Cools.isEmpty(param.getOrderDetails())) { - return R.error("鍗曟嵁鏄庣粏[orderDetails]涓嶈兘涓虹┖"); - } - openService.pakoutOrderCreate(param); - return R.ok(); - } - - /** - * 鍑哄簱鍗曞洖鍐� - */ - @PostMapping("/order/pakout/complete/default/v1") - public synchronized R orderPakoutComplete(@RequestHeader(required = false) String appkey, - @RequestBody(required = false) OpenOrderCompleteParam param) { - auth(appkey, param); - return R.ok().add(openService.pakoutOrderComplete(param)); - } - - - /** - * 搴撳瓨缁熻 - */ - @RequestMapping("/stock/default/v1") - public R queryStock(@RequestHeader(required = false) String appkey) { - auth(appkey, null); - 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)); - if (!auth) { - return; - } - if (Cools.isEmpty(appkey)) { - throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�"); - } - if (!APP_KEY_LIST.contains(appkey)) { - throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�"); - } - } - - 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)); - } - -} +//package com.zy.asrs.controller; +// +//import com.alibaba.fastjson.JSON; +//import com.core.annotations.AppAuth; +//import com.core.common.BaseRes; +//import com.core.common.Cools; +//import com.core.common.R; +//import com.core.exception.CoolException; +//import com.zy.asrs.entity.param.CheckParam; +//import com.zy.asrs.entity.param.MatSyncParam; +//import com.zy.asrs.entity.param.OrderProdSyncParam; +//import com.zy.asrs.entity.param.OrderSyncParam; +//import com.zy.asrs.service.ApiLogService; +//import com.zy.asrs.service.OpenService; +//import com.zy.common.utils.Synchro; +//import com.zy.common.web.BaseController; +//import lombok.extern.slf4j.Slf4j; +//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.List; +//import java.util.Map; +// +///** +// * Created by vincent on 2022/4/8 +// */ +//@Slf4j +//@RestController +//@RequestMapping("open/asrs") +//public class OpenController extends BaseController { +// +// private static final boolean auth = true; +// public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{ +// add("ea1f0459efc02a79f046f982767939ae"); +// }}; +// +// +// @Autowired +// private OpenService openService; +// +// +// @Autowired +// private ApiLogService apiLogService; +// +// +// /** +// * 搴撳瓨缁熻 +// */ +// @RequestMapping("/stock/default/v1") +// public R queryStock(@RequestHeader(required = false) String appkey, +// HttpServletRequest request) { +// auth(appkey, null, request); +// return R.ok().add(openService.queryStock()); +// } +// +// /** +// * 鍟嗗搧淇℃伅鍚屾鎺ュ彛 +// */ +// @PostMapping("/mat/v1") +// @AppAuth(memo = "鐗╂枡鍚屾鎺ュ彛") +// public synchronized R syncMatInfoErp(@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("鏇存柊鎴愬姛"); +// +// } +// +// +// 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; +// } +// if (Cools.isEmpty(appkey)) { +// throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�"); +// } +// if (!APP_KEY_LIST.contains(appkey)) { +// throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�"); +// } +// } +// +// +// /* +// 鐩樼偣鎺ュ彛 +// */ +// @PostMapping("/check/default/v1") +// @AppAuth(memo = "搴撳瓨鐩樼偣") +// public synchronized R checkLoc(@RequestHeader(required = false) String appkey, +// @RequestBody CheckParam param, +// HttpServletRequest request) { +// auth(appkey, param, request); +// if (Cools.isEmpty(param)) { +// return R.parse(BaseRes.PARAM); +// } +// +// openService.checkAndAdjustLocDetl(param); +// +// return R.ok("搴撳瓨璋冩暣鎴愬姛"); +// +// } +// +// @PostMapping("/order/pakin/default/v1") +// @AppAuth(memo = "鐢熸垚鍏ュ簱鍗曟嵁") +// public synchronized R orderPakin(@RequestHeader(required = false) String appkey, +// @RequestBody Map<String, Object> map, +// HttpServletRequest request) { +// //log.info("鐢熸垚鍏ュ簱鍗曟嵁,{}", JSON.toJSONString(map)); +// OrderProdSyncParam param = JSON.parseObject(JSON.toJSONString(map), OrderProdSyncParam.class); +// auth(appkey, param, request); +// if (Cools.isEmpty(param)) { +// return R.parse(BaseRes.PARAM); +// } +// if (Cools.isEmpty(param.getOrderNo()) && Cools.isEmpty(param.getCPOID())) { +// return R.parse(BaseRes.PARAM); +// } +// String docName = param.get鎿嶄綔鍗曟嵁(); +// if (Cools.isEmpty(docName)) { +// docName = param.getOrderType(); +// } +// switch (docName) { +// case "Purchase": +// mappingPakOutOrderParam(param, true, "閾跺骇閲囪喘鍏ュ簱鍗�"); +// break; +// case "MO": +// mappingPakInOrderParam(param, true, "閾跺骇濮斿鐢熶骇璁㈠崟"); +// mappingOrderParam(param, false, "閾跺骇鏈寘瑁呮垚鍝佸嚭搴撳崟"); +// mappingOrderParamDB40(param, false, "鍗婃垚鍝佽皟鎷ㄥ崟"); +// //mappingOrderParam40(param, false, "鍗婃垚鍝佸嚭搴撳崟"); +// if (!Cools.isEmpty(param.getChildren())) { +// mappingOrderParamChild(param, false, "閾跺骇濮斿鏉愭枡鍑哄簱鍗�"); +// } +// break; +// case "OM": +// mappingPakInOrderParam(param, true, "閾跺骇鐢熶骇璁㈠崟"); +// mappingOrderParam(param, false, "閾跺骇濮斿鏈寘瑁呮垚鍝佸嚭搴撳崟"); +// if (!Cools.isEmpty(param.getChildren())) { +// mappingOrderParamChild(param, false, "閾跺骇鐢熶骇鏉愭枡鍑哄簱鍗�"); +// } +// break; +// case "閲囪喘鍏ュ簱鍗曢��璐�": +// mappingPakOutOrderParam(param, false, "閾跺骇閲囪喘鍏ュ簱鍗曢��璐�"); +// break; +// case "濮斿鍏ュ簱鍗曢��璐�": +// mappingPakOutOrderParam(param, false, "閾跺骇濮斿鍏ュ簱鍗曢��璐�"); +// break; +// case "鍏朵粬鍑哄簱鍗�": +// mappingPakOutOrderParam(param, false, "鍏朵粬鍑哄簱鍗�"); +// break; +// case "鍏朵粬鍏ュ簱鍗�": +// mappingPakOutOrderParam(param, true, "鍏朵粬鍏ュ簱鍗�"); +// break; +// case "濮斿鏉愭枡鍑哄簱閫�鏂�": +// mappingPakOutOrderParam(param, true, "閾跺骇濮斿鏉愭枡鍑哄簱閫�鏂�"); +// break; +// case "鐢熶骇鏉愭枡鍑哄簱閫�鏂�": +// mappingPakOutOrderParam(param, true, "閾跺骇鐢熶骇鏉愭枡鍑哄簱閫�鏂�"); +// break; +// case "濮斿鏉愭枡鍑哄簱琛ユ枡": +// mappingPakOutOrderParam(param, false, "閾跺骇濮斿鏉愭枡鍑哄簱琛ユ枡"); +// break; +// case "鐢熶骇鏉愭枡鍑哄簱琛ユ枡": +// mappingPakOutOrderParam(param, false, "閾跺骇鐢熶骇鏉愭枡鍑哄簱琛ユ枡"); +// break; +// +// case "鍗婃垚鍝佸叆搴撳崟": +// mappingPakOutOrderParam(param, true, "鍗婃垚鍝佸叆搴撳崟"); +// break; +// case "鎴愬搧鍏ュ簱鍗�": +// mappingPakOutOrderParam(param, true, "鎴愬搧鍏ュ簱鍗�"); +// break; +// default: +// log.info("鏈煡鐨勫崟鎹被鍨�:{}", param); +// mappingPakOutOrderParam(param, param.getPakin() == 1 ? true : false, param.get鎿嶄綔鍗曟嵁()); +// break; +// } +// +// return R.ok("鍗曟嵁鎺ュ彈鎴愬姛"); +// +// } +// +// +// @PostMapping("/order/pakout/default/v1") +// @AppAuth(memo = "鍚屾宸ュ崟鍗曟嵁") +// public synchronized R orderPakout(@RequestHeader(required = false) String appkey, +// @RequestBody Map<String, Object> map) { +// //log.info("鍚屾宸ュ崟鍗曟嵁,{}", JSON.toJSONString(map)); +// OrderProdSyncParam param = JSON.parseObject(JSON.toJSONString(map), OrderProdSyncParam.class); +// auth(appkey, param, request); +// if (Cools.isEmpty(param)) { +// return R.parse(BaseRes.PARAM); +// } +// if (Cools.isEmpty(param.getOrderNo()) && Cools.isEmpty(param.getCPOID())) { +// return R.parse(BaseRes.PARAM); +// } +// String docName = param.get鎿嶄綔鍗曟嵁(); +// switch (docName) { +// case "Purchase": +// mappingPakOutOrderParam(param, true, "閾跺骇閲囪喘鍏ュ簱鍗�"); +// break; +// case "MO": +// mappingPakInOrderParam(param, true, "閾跺骇鐢熶骇璁㈠崟"); +// mappingOrderParam(param, false, "閾跺骇鏈寘瑁呮垚鍝佸嚭搴撳崟"); +// mappingOrderParamDB40(param, false, "鍗婃垚鍝佽皟鎷ㄥ崟"); +// //mappingOrderParam40(param, false, "鍗婃垚鍝佸嚭搴撳崟"); +// if (!Cools.isEmpty(param.getChildren())) { +// mappingOrderParamChild(param, false, "閾跺骇鐢熶骇鏉愭枡鍑哄簱鍗�"); +// } +// break; +// case "OM": +// mappingPakInOrderParam(param, true, "閾跺骇濮斿鐢熶骇璁㈠崟"); +// mappingOrderParam(param, false, "閾跺骇濮斿鏈寘瑁呮垚鍝佸嚭搴撳崟"); +// if (!Cools.isEmpty(param.getChildren())) { +// mappingOrderParamChild(param, false, "閾跺骇濮斿鏉愭枡鍑哄簱鍗�"); +// } +// break; +// case "閲囪喘鍏ュ簱鍗曢��璐�": +// mappingPakOutOrderParam(param, false, "閾跺骇閲囪喘鍏ュ簱鍗曢��璐�"); +// break; +// case "濮斿鍏ュ簱鍗曢��璐�": +// mappingPakOutOrderParam(param, false, "閾跺骇濮斿鍏ュ簱鍗曢��璐�"); +// break; +// case "鍏朵粬鍑哄簱鍗�": +// mappingPakOutOrderParam(param, false, "鍏朵粬鍑哄簱鍗�"); +// break; +// case "鍏朵粬鍏ュ簱鍗�": +// mappingPakOutOrderParam(param, true, "鍏朵粬鍏ュ簱鍗�"); +// break; +// case "濮斿鏉愭枡鍑哄簱閫�鏂�": +// mappingPakOutOrderParam(param, true, "閾跺骇濮斿鏉愭枡鍑哄簱閫�鏂�"); +// break; +// case "鐢熶骇鏉愭枡鍑哄簱閫�鏂�": +// mappingPakOutOrderParam(param, true, "閾跺骇鐢熶骇鏉愭枡鍑哄簱閫�鏂�"); +// break; +// case "濮斿鏉愭枡鍑哄簱琛ユ枡": +// mappingPakOutOrderParam(param, false, "閾跺骇濮斿鏉愭枡鍑哄簱琛ユ枡"); +// break; +// case "鐢熶骇鏉愭枡鍑哄簱琛ユ枡": +// mappingPakOutOrderParam(param, false, "閾跺骇鐢熶骇鏉愭枡鍑哄簱琛ユ枡"); +// break; +// case "鍗婃垚鍝佸叆搴撳崟": +// mappingPakOutOrderParam(param, true, "鍗婃垚鍝佸叆搴撳崟"); +// break; +// case "鎴愬搧鍏ュ簱鍗�": +// mappingPakOutOrderParam(param, true, "鎴愬搧鍏ュ簱鍗�"); +// break; +// default: +// log.info("鏈煡鐨勫崟鎹被鍨�:{}", param); +// mappingPakOutOrderParam(param, param.getPakin() == 1 ? true : false, param.get鎿嶄綔鍗曟嵁()); +// break; +// } +// return R.ok("鍗曟嵁鎺ュ彈鎴愬姛"); +// +// } +// +// @PostMapping("/order/pak/default/v1") +// @AppAuth(memo = "鐢熸垚鍏ュ簱鍗曟嵁") +// public synchronized R orderPakin2(@RequestHeader(required = false) String appkey, +// @RequestBody Map<String, Object> map, +// HttpServletRequest request) { +// //log.info("鐢熸垚鍏ュ簱鍗曟嵁,{}", JSON.toJSONString(map)); +// OrderProdSyncParam param = JSON.parseObject(JSON.toJSONString(map), OrderProdSyncParam.class); +// auth(appkey, param, request); +// if (Cools.isEmpty(param)) { +// return R.parse(BaseRes.PARAM); +// } +// if (Cools.isEmpty(param.getOrderNo()) && Cools.isEmpty(param.getCPOID())) { +// return R.parse(BaseRes.PARAM); +// } +// String docName = param.getOrderType(); +// if (Cools.isEmpty(docName)) { +// return R.parse(BaseRes.PARAM); +// } +// switch (docName) { +// case "閾跺骇鐢熶骇棰嗘枡鐢宠鍗�": +// mappingPakOutOrderParam(param, false, "閾跺骇鐢熶骇棰嗘枡鐢宠鍗�"); +// break; +// case "閾跺骇鐢熶骇閫�鏂欑敵璇峰崟": +// mappingPakOutOrderParam(param, true, "閾跺骇鐢熶骇閫�鏂欑敵璇峰崟"); +// break; +// case "閾跺骇鐢熶骇琛ユ枡鐢宠鍗�": +// mappingPakOutOrderParam(param, false, "閾跺骇鐢熶骇琛ユ枡鐢宠鍗�"); +// break; +// case "閾跺骇鐢熶骇鍏ュ簱鐢宠鍗�": +// mappingPakOutOrderParam(param, true, "閾跺骇鐢熶骇鍏ュ簱鐢宠鍗�"); +// break; +// default: +// log.info("鏈煡鐨勫崟鎹被鍨�:{}", param); +// mappingPakOutOrderParam(param, param.getPakin() == 1 ? true : false, docName); +// // return R.error("鍗曟嵁鎺ュ彈澶辫触:鏈煡鐨勫崟鎹被鍨�"); +// break; +// } +// +// return R.ok("鍗曟嵁鎺ュ彈鎴愬姛"); +// +// } +// +// +// @PostMapping("/order/delete/default/v1") +// @AppAuth(memo = "鍗曟嵁鍒犻櫎瀹℃牳") +// public synchronized R orderDelete(@RequestHeader(required = false) String appkey, +// @RequestBody(required = false) Map<String, Object> param, +// HttpServletRequest request) { +// log.info("鍗曟嵁鍒犻櫎瀹℃牳,{}", JSON.toJSONString(param)); +// auth(appkey, param, request); +// if (Cools.isEmpty(param)) { +// return R.parse(BaseRes.PARAM); +// } +// +// boolean success = openService.orderDelete(param.get("id").toString()); +// +// if (success) { +// return R.ok("鍗曟嵁鍒犻櫎鎴愬姛"); +// } else { +// return R.error("鍗曟嵁姝e湪鎵ц锛屽垹闄ゅけ璐�"); +// } +// +// } +// +// private void mappingPakInOrderParam(OrderProdSyncParam param, boolean pakin, String docName) { +// //鐢熸垚鍗曟嵁涓讳綋 +// OrderSyncParam orderSyncParam = new OrderSyncParam(); +// Synchro.Copy(param, orderSyncParam); +// +// if (Cools.isEmpty(orderSyncParam.getCPOID())) { +// orderSyncParam.setCPOID(param.getOrderNoT()); +// } +// if (Cools.isEmpty(orderSyncParam.getDdate())) { +// orderSyncParam.setDdate(param.getOrderTime()); +// } +// +// if (!Cools.isEmpty(param.getCInvCode()) && param.getCInvCode().startsWith("60")) { +// return; +// } +// +// //鐢熸垚鍗曟嵁鏄庣粏 +// OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl(); +// Synchro.Copy(param, orderDetl); +// //orderDetl.setcInvCode(param.getCInvCode()); +// //orderDetl.setiQuantity(param.getIQuantity()); +// orderDetl.setCDefine22(param.getIvouchrowno()); +// //orderDetl.setbFree1(param.getBFree1()); +// orderDetl.setId(param.getId()); +// orderDetl.setIvouchrowno(param.getIvouchrowno()); +// orderDetl.setINum(param.getINum()); +// orderDetl.setIinvexchrate(param.getIinvexchrate()); +// +// //娣诲姞鍗曟嵁鏄庣粏鍒板崟鎹富浣� +// List<OrderSyncParam.OrderDetl> orderDetls = new ArrayList<>(); +// orderDetls.add(orderDetl); +// +// orderSyncParam.setChildren(orderDetls); +// +//// String docName = param.getIQuantity() > 0 ? "閾跺骇浜у搧鐢熶骇鍏ュ簱鍗�" : "鍏ュ簱閫�鍥炲崟"; +//// boolean pakin = param.getIQuantity() > 0 ? true : false; +// +// openService.syncOrder(orderSyncParam, pakin, docName); +// +// //return orderSyncParam; +// } +// +// +// private void mappingPakOutOrderParam(OrderProdSyncParam param, boolean pakin, String docName) { +// OrderSyncParam orderSyncParam = new OrderSyncParam(); +// +// List<OrderProdSyncParam.ChildInfo> child = param.getChildren(); +// Synchro.Copy(param, orderSyncParam); +// if (Cools.isEmpty(orderSyncParam.getCPOID())) { +// orderSyncParam.setCPOID(param.getOrderNoT()); +// orderSyncParam.setDdate(param.getOrderTime()); +// } +// +// //鐢熸垚鍗曟嵁鏄庣粏 +// List<OrderSyncParam.OrderDetl> orderDetls = new ArrayList<>(); +// +// for (OrderProdSyncParam.ChildInfo childInfo : child) { +// OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl(); +// Synchro.Copy(childInfo, orderDetl); +// //orderDetl.setcInvCode(childInfo.getCInvCode()); +// //orderDetl.setiQuantity(childInfo.getIQuantity()); +// orderDetl.setCsocode(param.getCsocode()); +// //orderDetl.setbFree1(childInfo.getBFree1()); +// orderDetl.setId(Cools.isEmpty(childInfo.getIPOsID()) ? childInfo.getId() : childInfo.getIPOsID()); +// orderDetl.setIvouchrowno(childInfo.getIvouchrowno()); +// if (!Cools.isEmpty(childInfo.getCFree1())) { +// orderDetl.setBFree1(childInfo.getCFree1()); +// } +// orderDetls.add(orderDetl); +// } +// orderSyncParam.setChildren(orderDetls); +// +// openService.syncOrder(orderSyncParam, pakin, docName); +// +// //return orderSyncParam; +// } +// +// private void mappingOrderParamChild(OrderProdSyncParam param, boolean pakin, String docName) { +// OrderSyncParam orderSyncParam = new OrderSyncParam(); +// +// List<OrderProdSyncParam.ChildInfo> child = param.getChildren(); +// Synchro.Copy(param, orderSyncParam); +// orderSyncParam.set鎿嶄綔绯荤粺鍙�(param.get鎿嶄綔绯荤粺鍙�()); +// orderSyncParam.setCPOID(child.get(0).getOrderNoT()); +// orderSyncParam.setDdate(param.getOrderTime()); +// +// //鐢熸垚鍗曟嵁鏄庣粏 +// List<OrderSyncParam.OrderDetl> orderDetls = new ArrayList<>(); +// +// for (OrderProdSyncParam.ChildInfo childInfo : child) { +// OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl(); +// Synchro.Copy(childInfo, orderDetl); +// orderDetl.setCDefine22(param.getIvouchrowno()); +// orderDetl.setCsocode(param.getCsocode()); +// orderDetl.setId(childInfo.getIds()); +// //orderDetl.setIvouchrowno(childInfo.getIvouchrowno()); +// if (!Cools.isEmpty(childInfo.getCFree1())) { +// orderDetl.setBFree1(childInfo.getCFree1()); +// } +// orderDetls.add(orderDetl); +// } +// orderSyncParam.setChildren(orderDetls); +// +// openService.syncOrder(orderSyncParam, pakin, docName); +// +// //return orderSyncParam; +// } +// +// +// private void mappingOrderParam(OrderProdSyncParam param, boolean pakin, String docName) { +// //鐢熸垚鍗曟嵁涓讳綋 +// OrderSyncParam orderSyncParam = new OrderSyncParam(); +// Synchro.Copy(param, orderSyncParam); +// +// if (Cools.isEmpty(orderSyncParam.getCPOID())) { +// orderSyncParam.setCPOID(param.getOrderNoT()); +// } +// if (Cools.isEmpty(orderSyncParam.getDdate())) { +// orderSyncParam.setDdate(param.getOrderTime()); +// } +// orderSyncParam.setCPOID("C" + orderSyncParam.getCPOID()); +// //鐢熸垚鍗曟嵁鏄庣粏 +// OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl(); +// Synchro.Copy(param, orderDetl); +// +// if (!param.getCInvCode().startsWith("50")) { +// return; +// } +// //orderDetl.setcInvCode(param.getCInvCode()); +// //orderDetl.setiQuantity(param.getIQuantity()); +// orderDetl.setCDefine22(param.getIvouchrowno()); +// //orderDetl.setbFree1(param.getBFree1()); +// orderDetl.setId(param.getId()); +// orderDetl.setIvouchrowno(param.getIvouchrowno()); +// orderDetl.setINum(param.getINum()); +// orderDetl.setIinvexchrate(param.getIinvexchrate()); +// +// //娣诲姞鍗曟嵁鏄庣粏鍒板崟鎹富浣� +// List<OrderSyncParam.OrderDetl> orderDetls = new ArrayList<>(); +// orderDetls.add(orderDetl); +// +// orderSyncParam.setChildren(orderDetls); +// +//// String docName = param.getIQuantity() > 0 ? "閾跺骇浜у搧鐢熶骇鍏ュ簱鍗�" : "鍏ュ簱閫�鍥炲崟"; +//// boolean pakin = param.getIQuantity() > 0 ? true : false; +// +// openService.syncOrder(orderSyncParam, pakin, docName); +// +// //return orderSyncParam; +// } +// +// private void mappingOrderParamDB40(OrderProdSyncParam param, boolean pakin, String docName) { +// //鐢熸垚鍗曟嵁涓讳綋 +// OrderSyncParam orderSyncParam = new OrderSyncParam(); +// Synchro.Copy(param, orderSyncParam); +// +// if (Cools.isEmpty(orderSyncParam.getCPOID())) { +// orderSyncParam.setCPOID(param.getOrderNoT()); +// } +// if (Cools.isEmpty(orderSyncParam.getDdate())) { +// orderSyncParam.setDdate(param.getOrderTime()); +// } +// orderSyncParam.setCPOID("DC" + orderSyncParam.getCPOID()); +// //鐢熸垚鍗曟嵁鏄庣粏 +// OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl(); +// Synchro.Copy(param, orderDetl); +// +// if (!(param.getCInvCode().startsWith("401") || param.getCInvCode().startsWith("402"))) { +// return; +// } +// //orderDetl.setcInvCode(param.getCInvCode()); +// //orderDetl.setiQuantity(param.getIQuantity()); +// orderDetl.setCDefine22(param.getIvouchrowno()); +// //orderDetl.setbFree1(param.getBFree1()); +// orderDetl.setId(param.getId()); +// orderDetl.setIvouchrowno(param.getIvouchrowno()); +// orderDetl.setINum(param.getINum()); +// orderDetl.setIinvexchrate(param.getIinvexchrate()); +// +// //娣诲姞鍗曟嵁鏄庣粏鍒板崟鎹富浣� +// List<OrderSyncParam.OrderDetl> orderDetls = new ArrayList<>(); +// orderDetls.add(orderDetl); +// +// orderSyncParam.setChildren(orderDetls); +// +//// String docName = param.getIQuantity() > 0 ? "閾跺骇浜у搧鐢熶骇鍏ュ簱鍗�" : "鍏ュ簱閫�鍥炲崟"; +//// boolean pakin = param.getIQuantity() > 0 ? true : false; +// +// openService.syncOrder(orderSyncParam, pakin, docName); +// +// //return orderSyncParam; +// } +// +// +// +//// @PostMapping("/order/add") +//// public R re(@RequestHeader(required = false) String appkey, +//// HttpServletRequest request) throws IOException { +//// List<ApiLog> apiLogs = apiLogService.selectList(new EntityWrapper<ApiLog>().eq("url", "/phyzwms/open/asrs/order/pakin/default/v1").eq("response", "{\"msg\":\"鏈嶅姟鍣ㄩ敊璇痋",\"code\":500}").ge("create_time", "2025-01-06 00:00:00")); +//// for (ApiLog apiLog : apiLogs) { +//// Map<String, Object> param = new HashMap<>(); +//// ObjectMapper mapper = new ObjectMapper(); +//// if (!Cools.isEmpty(apiLog.getRequest())) { +//// param = mapper.readValue(apiLog.getRequest(), Map.class); +//// try { +//// orderPakin(appkey, param, request); +//// } catch (Exception e) { +//// +//// } +//// } +//// } +//// return R.ok(); +//// +//// } +// +//} -- Gitblit v1.9.1