From 82bcd0328dddbaad65933e2fada22bc68e82b3d5 Mon Sep 17 00:00:00 2001 From: whycq <913841844@qq.com> Date: 星期六, 26 八月 2023 10:07:46 +0800 Subject: [PATCH] # 导入订单增加单据类型 --- src/main/java/com/zy/asrs/controller/OrderController.java | 110 ++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 108 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/OrderController.java b/src/main/java/com/zy/asrs/controller/OrderController.java index 9617c76..1cf392f 100644 --- a/src/main/java/com/zy/asrs/controller/OrderController.java +++ b/src/main/java/com/zy/asrs/controller/OrderController.java @@ -1,5 +1,6 @@ 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; @@ -12,6 +13,7 @@ import com.zy.asrs.entity.result.WrkTraceVo; import com.zy.asrs.service.*; import com.zy.common.model.DetlDto; +import com.zy.common.model.OrderDto; import com.zy.common.web.BaseController; import lombok.extern.slf4j.Slf4j; import org.apache.poi.hssf.usermodel.HSSFWorkbook; @@ -50,6 +52,8 @@ private WrkMastLogService wrkMastLogService; @Autowired private LocDetlService locDetlService; + @Autowired + private MatService matService; @RequestMapping(value = "/order/nav/list/auth") @ManagerAuth @@ -99,7 +103,9 @@ @RequestMapping(value = "/order/detl/all/auth") @ManagerAuth public R head(@RequestParam Long orderId){ - return R.ok().add(orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_id", orderId))); + List<OrderDetl> orderDetls = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_id", orderId)); + orderDetls.removeIf(next -> next.getQty() > 0); + return R.ok().add(orderDetls); } @RequestMapping(value = "/order/form/add/auth") @@ -265,6 +271,15 @@ List<WrkTraceVo> wrkTraceVos = new ArrayList<>(); List<WrkDetl> wrkDetls = wrkDetlService.selectAndLogByOrderNoGroupByMatnrOfSum(order.getOrderNo()); for (WrkDetl wrkDetl : wrkDetls) { + if (isJSON(wrkDetl.getOrderNo())) { + List<OrderDto> orderDtoList = JSON.parseArray(wrkDetl.getOrderNo(), OrderDto.class); + for (OrderDto one : orderDtoList) { + if (one.getOrderNo().equals(order.getOrderNo())) { + wrkDetl.setAnfme(one.getAnfme()); + break; + } + } + } WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", wrkDetl.getWrkNo()).eq("io_time", wrkDetl.getIoTime())); if (wrkMast == null) { WrkMastLog wrkMastLog = wrkMastLogService.selectOne(new EntityWrapper<WrkMastLog>().eq("wrk_no", wrkDetl.getWrkNo()).eq("io_time", wrkDetl.getIoTime())); @@ -439,9 +454,100 @@ Row row = sheet.getRow(i); // 璁㈠崟缂栧彿 String uuid = dataFormatter.formatCellValue(row.getCell(0)); + // 鍟嗗搧鍚嶇О + String maktx = dataFormatter.formatCellValue(row.getCell(1)); + // 鍟嗗搧缂栫爜 + String matnr = dataFormatter.formatCellValue(row.getCell(2)); + // 鏁伴噺 + Double anfme = Double.parseDouble(dataFormatter.formatCellValue(row.getCell(3))); + // 涓嬪崟鏃堕棿 + String timeStr = dataFormatter.formatCellValue(row.getCell(4)); + // 鍗曟嵁绫诲瀷 + Long orderType = Long.parseLong(dataFormatter.formatCellValue(row.getCell(5))); + Date time = null; + try { + time = DateUtils.convert(timeStr, DateUtils.yyyyMMddHHmmss_F); + } catch (Exception e) { + throw new CoolException("绗�" + i + "琛屼笅鐨勯偅鏃堕棿瑙f瀽澶辫触锛岃閲嶆柊瀵煎叆锛�"); + } + // 鍟嗗搧绯诲垪 + String tagName = dataFormatter.formatCellValue(row.getCell(5)); + // 瑙勬牸 + String specs = dataFormatter.formatCellValue(row.getCell(6)); + + Mat mat = matService.selectByMatnr(matnr); + if (null == mat) { + throw new CoolException(matnr + "鍟嗗搧缂栫爜鐨勫晢鍝佷笉瀛樺湪锛岃閲嶆柊瀵煎叆锛�"); + } + + Order order = orderService.selectByNo(uuid); + if (null == order) { + order = new Order( + String.valueOf(snowflakeIdWorker.nextId()), // 缂栧彿[闈炵┖] + uuid, // 璁㈠崟缂栧彿 + timeStr, // 鍗曟嵁鏃ユ湡 + orderType, // 鍗曟嵁绫诲瀷 + null, // 椤圭洰缂栧彿 + null, // + null, // 璋冩嫧椤圭洰缂栧彿 + null, // 鍒濆绁ㄦ嵁鍙� + null, // 绁ㄦ嵁鍙� + null, // 瀹㈡埛缂栧彿 + null, // 瀹㈡埛 + null, // 鑱旂郴鏂瑰紡 + null, // 鎿嶄綔浜哄憳 + null, // 鍚堣閲戦 + null, // 浼樻儬鐜� + null, // 浼樻儬閲戦 + null, // 閿�鍞垨閲囪喘璐圭敤鍚堣 + null, // 瀹炰粯閲戦 + null, // 浠樻绫诲瀷 + null, // 涓氬姟鍛� + null, // 缁撶畻澶╂暟 + null, // 閭垂鏀粯绫诲瀷 + null, // 閭垂 + null, // 浠樻鏃堕棿 + null, // 鍙戣揣鏃堕棿 + null, // 鐗╂祦鍚嶇О + null, // 鐗╂祦鍗曞彿 + 1L, // 璁㈠崟鐘舵�� + 1, // 鐘舵�� + userId, // 娣诲姞浜哄憳 + now, // 娣诲姞鏃堕棿 + userId, // 淇敼浜哄憳 + now, // 淇敼鏃堕棿 + null // 澶囨敞 + ); + if (!orderService.insert(order)) { + throw new CoolException("鐢熸垚鍗曟嵁涓绘。澶辫触锛岃閲嶆柊瀵煎叆锛�"); + } + } + + OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), matnr, null); + if (orderDetl == null) { + orderDetl = new OrderDetl(); + orderDetl.sync(mat); + orderDetl.setBatch(null); + orderDetl.setAnfme(anfme); + orderDetl.setOrderId(order.getId()); + orderDetl.setOrderNo(order.getOrderNo()); + orderDetl.setCreateBy(userId); + orderDetl.setCreateTime(now); + orderDetl.setUpdateBy(userId); + orderDetl.setUpdateTime(now); + orderDetl.setStatus(1); + orderDetl.setQty(0.0D); + if (!orderDetlService.insert(orderDetl)) { + throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃閲嶆柊瀵煎叆锛�"); + } + } else { + if(!orderDetlService.increaseAnfme(order.getId(), matnr, null, anfme)) { + throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃閲嶆柊瀵煎叆锛�"); + } + } } - return R.ok(); + return R.ok("瀵煎叆鎴愬姛"); } } -- Gitblit v1.9.1