From 406115ad731db54e50132ece77d09fbf1fc44212 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 16 十二月 2024 09:14:23 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java | 191 +++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 183 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index 7c6f793..9a28eec 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -26,6 +26,8 @@
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
import java.util.*;
/**
@@ -75,7 +77,9 @@
@Autowired
private ManLocDetlMapper manLocDetlMapper;
@Resource
- private InventoryCheckOrderDetlService inventoryCheckOrderDetlService;
+ private InventoryCheckOrderService checkOrderService;
+ @Resource
+ private InventoryCheckOrderDetlService checkOrderDetlService;
@Resource
private BasDevpMapper basDevpMapper;
@@ -264,11 +268,15 @@
if(param.getCombMats().size()>1){
throw new CoolException("璇锋彁鍙栦竴涓晢鍝侊紝鎴栬�呭埛鏂伴噸鏂扮粍鎵橈紒");
}
- // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁
-// if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>().
-// eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) {
-// throw new CoolException(param.getBarcode() + "鏁版嵁姝ｅ湪杩涜鍏ュ簱");
-// }
+ param.getCombMats().forEach(elem -> {
+ // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁
+ if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>().
+ eq("zpallet", param.getBarcode())
+ .eq("io_status", "N")
+ .eq("matnr",elem.getMatnr()).eq("batch",elem.getBatch())) > 0) {
+ throw new CoolException(param.getBarcode() + "宸叉湁鐩稿悓鏁版嵁");
+ }
+ });
if(param.getBarcode().length()!=9){
throw new CoolException("鏉＄爜闀垮害涓嶆槸9浣�===>>" + param.getBarcode());
@@ -289,6 +297,15 @@
// 鐢熸垚鍏ュ簱閫氱煡妗�
List<DetlDto> detlDtos = new ArrayList<>();
param.getCombMats().forEach(elem -> {
+
+ // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁
+ if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>().
+ eq("zpallet", param.getBarcode())
+ .eq("io_status", "N")
+ .eq("matnr",elem.getMatnr()).eq("batch",elem.getBatch())) > 0) {
+ throw new CoolException(param.getBarcode() + "宸叉湁鐩稿悓鏁版嵁");
+ }
+
DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme());
if (DetlDto.has(detlDtos, detlDto)) {
DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch());
@@ -884,7 +901,7 @@
throw new CoolException("鐩樼偣鍒楄〃鍙傛暟涓虹┖");
}
for (InventoryCheckOrderDetl orderDetl: param.getParam()){
- InventoryCheckOrderDetl inventoryCheckOrderDetl = inventoryCheckOrderDetlService.selectOne(new EntityWrapper<InventoryCheckOrderDetl>()
+ InventoryCheckOrderDetl inventoryCheckOrderDetl = checkOrderDetlService.selectOne(new EntityWrapper<InventoryCheckOrderDetl>()
.eq("order_no", orderDetl.getOrderNo())
.eq("matnr", orderDetl.getMatnr())
.eq("batch", orderDetl.getBatch()));
@@ -896,7 +913,7 @@
}
inventoryCheckOrderDetl.setCheckAnfme(orderDetl.getCheckAnfme());
inventoryCheckOrderDetl.setStatus("2");
- if (!inventoryCheckOrderDetlService.updateById(inventoryCheckOrderDetl)){
+ if (!checkOrderDetlService.updateById(inventoryCheckOrderDetl)){
throw new CoolException("淇濆瓨鐩樼偣淇℃伅澶辫触!");
}
@@ -908,6 +925,164 @@
@Override
@Transactional
+ public void inventoryUpload(String orderId) {
+ if (Cools.isEmpty(orderId)){
+ throw new CoolException("鐩樼偣鍗昳d涓虹┖");
+ }
+ InventoryCheckOrder inventoryCheckOrder = checkOrderService.selectById(orderId);
+ if (Cools.isEmpty(inventoryCheckOrder)){
+ throw new CoolException("鏈壘鍒扮洏鐐瑰崟");
+ }
+ if (inventoryCheckOrder.getStatus().equals("2")){
+ throw new CoolException("鐩樼偣鍗曞凡鎻愪氦");
+ }
+ int count = checkOrderDetlService.selectCount(new EntityWrapper<InventoryCheckOrderDetl>()
+ .eq("order_no", inventoryCheckOrder.getOrderNo()).isNull("check_anfme"));
+ if (count>0){
+ throw new CoolException("鏈夋湭瀹屾垚鐨勭洏鐐逛换鍔�");
+ }
+
+ List<InventoryCheckOrderDetl> checkOrderProfitDetls = checkOrderDetlService.selectList(new EntityWrapper<InventoryCheckOrderDetl>()
+ .eq("order_no", inventoryCheckOrder.getOrderNo())
+ .addFilter("anfme < check_anfme"));
+ if (!checkOrderProfitDetls.isEmpty()){
+ //鑾峰彇鐩樼泩鍗昿aram
+ InventoryErpParam erpProfitParam = getErpProfitParam(inventoryCheckOrder, checkOrderProfitDetls);
+ uploadErp(erpProfitParam);
+ }
+
+ List<InventoryCheckOrderDetl> checkOrderDeficitDetls = checkOrderDetlService.selectList(new EntityWrapper<InventoryCheckOrderDetl>()
+ .eq("order_no", inventoryCheckOrder.getOrderNo())
+ .addFilter("anfme > check_anfme"));
+
+ if (!checkOrderDeficitDetls.isEmpty()){
+ //鑾峰彇鐩樹簭鍗昿aram
+ InventoryErpParam erpDeficitParam = getErpDeficitParam(inventoryCheckOrder, checkOrderDeficitDetls);
+ uploadErp(erpDeficitParam);
+ }
+
+ inventoryCheckOrder.setStatus("2");
+ if (!checkOrderService.updateById(inventoryCheckOrder)){
+ throw new CoolException("鐘舵�佹洿鏂板け璐�");
+ }
+
+
+
+
+ }
+
+ public void uploadErp(InventoryErpParam param){
+ String response = "";
+ boolean success = false;
+ try {
+ HashMap<String, Object> headers = new HashMap<>();
+ headers.put("Content-Type", "application/json");
+ response = new HttpHandler.Builder()
+ .setHeaders(headers)
+ .setUri("10.0.100.160:30108")
+ .setPath("web/apps/gongqi.df.dataTrans/DTInterFace/doJobWithupdateBody")
+ .setJson(JSON.toJSONString(param))
+ .build()
+ .doPost();
+ JSONObject jsonObject = JSON.parseObject(response);
+ if (jsonObject.getInteger("errcode").equals(0)) {
+ success = true;
+ } else if (jsonObject.getInteger("errcode").equals(1)) {
+ log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(param), response);
+ throw new CoolException(jsonObject.getString("msg"));
+ } else {
+ log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(param), response);
+ throw new CoolException("涓婃姤mes绯荤粺澶辫触");
+ }
+ } catch (Exception e) {
+ log.error("fail", e);
+ throw new CoolException(e.getMessage());
+ } finally {
+ try {
+ // 淇濆瓨鎺ュ彛鏃ュ織
+ apiLogService.save(
+ "鐩樼偣鍗曚笂鎶�",
+ MesConstant.URL + MesConstant.PACK_DOWN_URL,
+ null,
+ "127.0.0.1",
+ JSON.toJSONString(param),
+ response,
+ success
+ );
+ } catch (Exception e) { log.error("", e); }
+ }
+ }
+
+ public InventoryErpParam getErpProfitParam(InventoryCheckOrder inventoryCheckOrder,List<InventoryCheckOrderDetl> checkOrderProfitDetls) {
+ Date date = new Date();
+ InventoryErpParam erpProfitParam = new InventoryErpParam();
+ InventoryErpParam.DataJson dataJson = new InventoryErpParam.DataJson();
+ dataJson.setFlowCode("LIKUwms12GOTmes");
+ dataJson.setTableCode("DTInventInTable_pdd");
+ dataJson.setLogName("鐩樼泩鍗�-鍏ュ簱鍗�");
+ erpProfitParam.setDataJson(dataJson);
+ List<InventoryErpParam.UpdateJson> updateJsonList = new ArrayList<>();
+ InventoryErpParam.UpdateJson updateJson = new InventoryErpParam.UpdateJson();
+ updateJson.setOrderNo(inventoryCheckOrder.getOrderNo());
+ updateJson.setDate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(date));
+ List<InventoryErpParam.MatDetails> matDetails = new ArrayList<>();
+ for (InventoryCheckOrderDetl checkOrderProfitDetl: checkOrderProfitDetls){
+ InventoryErpParam.MatDetails matDetail = new InventoryErpParam.MatDetails();
+
+ Mat mat = matService.selectByMatnr(checkOrderProfitDetl.getMatnr());
+
+ matDetail.setMatnr(checkOrderProfitDetl.getMatnr());
+ matDetail.setBatch(checkOrderProfitDetl.getBatch());
+ matDetail.setSpecs(mat.getSpecs());
+ Double anfme = new BigDecimal(checkOrderProfitDetl.getCheckAnfme()).subtract(new BigDecimal(checkOrderProfitDetl.getAnfme())).doubleValue();
+ matDetail.setAnfme(anfme);
+ matDetail.setLocNo(checkOrderProfitDetl.getLocNo());
+ matDetail.setWarehouse(checkOrderProfitDetl.getArea());
+ matDetail.setSeq(updateJson.getMatDetails() == null?1:updateJson.getMatDetails().size()+1);
+ matDetails.add(matDetail);
+ }
+ updateJson.setMatDetails(matDetails);
+ updateJsonList.add(updateJson);
+ erpProfitParam.setUpdateJson(updateJsonList);
+ return erpProfitParam;
+ }
+
+ public InventoryErpParam getErpDeficitParam(InventoryCheckOrder inventoryCheckOrder,List<InventoryCheckOrderDetl> checkOrderDeficitDetls) {
+ Date date = new Date();
+ InventoryErpParam erpDeficitParam = new InventoryErpParam();
+ InventoryErpParam.DataJson dataJson = new InventoryErpParam.DataJson();
+ dataJson.setFlowCode("LIKUwms12GOTmes");
+ dataJson.setTableCode("DTInventOutTable_pdd");
+ dataJson.setLogName("鐩樹簭鍗�-鍑哄簱鍗�");
+ erpDeficitParam.setDataJson(dataJson);
+ List<InventoryErpParam.UpdateJson> updateJsonList2 = new ArrayList<>();
+ InventoryErpParam.UpdateJson updateJson2 = new InventoryErpParam.UpdateJson();
+ updateJson2.setOrderNo(inventoryCheckOrder.getOrderNo());
+ updateJson2.setDate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(date));
+ List<InventoryErpParam.MatDetails> matDetails = new ArrayList<>();
+ for (InventoryCheckOrderDetl checkOrderDeficitDetl: checkOrderDeficitDetls){
+ InventoryErpParam.MatDetails matDetail = new InventoryErpParam.MatDetails();
+
+ Mat mat = matService.selectByMatnr(checkOrderDeficitDetl.getMatnr());
+
+ matDetail.setMatnr(checkOrderDeficitDetl.getMatnr());
+ matDetail.setBatch(checkOrderDeficitDetl.getBatch());
+ matDetail.setSpecs(mat.getSpecs());
+ Double anfme = new BigDecimal(checkOrderDeficitDetl.getAnfme()).subtract(new BigDecimal(checkOrderDeficitDetl.getCheckAnfme())).doubleValue();
+ matDetail.setAnfme(anfme);
+ matDetail.setLocNo(checkOrderDeficitDetl.getLocNo());
+ matDetail.setWarehouse(checkOrderDeficitDetl.getArea());
+ matDetail.setSeq(updateJson2.getMatDetails() == null?1:updateJson2.getMatDetails().size()+1);
+ matDetails.add(matDetail);
+ }
+ updateJson2.setMatDetails(matDetails);
+ updateJsonList2.add(updateJson2);
+ erpDeficitParam.setUpdateJson(updateJsonList2);
+ return erpDeficitParam;
+ }
+
+ @Override
+ @Transactional
public void stockOut(OrderDetl orderDetl, BasDevp staNo, LocDetl locDetl,
Double curOutQty, Integer ioType, Long userId, Date now) {
// 鑾峰彇搴撲綅
--
Gitblit v1.9.1