From 1717a12c83db01e3b31ea9ed913e5bacaf9edbf3 Mon Sep 17 00:00:00 2001
From: hdy <1105738590@qq.com>
Date: 星期六, 29 三月 2025 14:24:06 +0800
Subject: [PATCH] 修改
---
billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java | 125 ++++++++++++++++++++++++++++++++++++++++-
1 files changed, 122 insertions(+), 3 deletions(-)
diff --git a/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java b/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java
index 8a06eab..445a12c 100644
--- a/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java
+++ b/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java
@@ -1,8 +1,21 @@
package com.billion.main.da.service.impl;
+import java.text.SimpleDateFormat;
+import java.util.Arrays;
import java.util.List;
+import java.util.Objects;
+import cn.hutool.http.HttpRequest;
+import cn.hutool.http.HttpResponse;
+import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.billion.main.bs.domain.BsBomChildInfo;
+import com.billion.main.bs.service.IBsBomChildInfoService;
+import com.billion.main.constant.Constants;
+import com.billion.main.da.domain.CollectMT;
+import com.billion.main.om.domain.OmOrderScheduling;
+import com.billion.main.om.service.IOmOrderSchedulingService;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.billion.main.da.mapper.DaMaterialCollectionMapper;
@@ -15,12 +28,16 @@
* @author Billion-Yi
* @date 2024-11-22
*/
+@Slf4j
@Service
public class DaMaterialCollectionServiceImpl extends ServiceImpl<DaMaterialCollectionMapper, DaMaterialCollection> implements IDaMaterialCollectionService
{
@Autowired
private DaMaterialCollectionMapper daMaterialCollectionMapper;
-
+ @Autowired
+ public IBsBomChildInfoService bsBomChildInfoService;
+ @Autowired
+ public IOmOrderSchedulingService omOrderSchedulingService;
/**
* 鏌ヨ鐗╂枡閲囬泦
*
@@ -54,8 +71,109 @@
@Override
public void insertDaMaterialCollection(DaMaterialCollection daMaterialCollection)
{
- this.save(daMaterialCollection);
+ String url = "http://172.40.161.71:8890/Interaction/CollectMT";
+ CollectMT collectMT = new CollectMT();
+ DaMaterialCollection daMaterialCollection1 = new DaMaterialCollection();
+ BsBomChildInfo bsBomChildInfo = new BsBomChildInfo();
+ OmOrderScheduling omOrderScheduling = new OmOrderScheduling();
+
+ daMaterialCollection1.setSfcCode(daMaterialCollection.getSfcCode());
+ daMaterialCollection1.setLocationCode(daMaterialCollection.getLocationCode());
+ daMaterialCollection1.setParamValue(daMaterialCollection.getParamValue());
+ daMaterialCollection1.setCollectTime(daMaterialCollection.getCollectTime());
+
+ omOrderScheduling.setSfcCode(daMaterialCollection.getSfcCode());
+ if( Constants.PLC1.contains(daMaterialCollection.getLocationCode()) ||
+ Constants.C005.equals(daMaterialCollection.getLocationCode()) ||
+ Constants.C060.equals(daMaterialCollection.getLocationCode()) )
+ {omOrderScheduling.setRemarks("Head");}
+ else if(
+ Constants.PLC2.contains(daMaterialCollection.getLocationCode()) ||
+ Constants.OP005.equals(daMaterialCollection.getLocationCode()) ||
+ Constants.OP310.equals(daMaterialCollection.getLocationCode()))
+ {omOrderScheduling.setRemarks("Body");}
+ else if(Constants.P010.equals(daMaterialCollection.getLocationCode()))
+ {omOrderScheduling.setRemarks("Pre");}
+ List<OmOrderScheduling> omOrderSchedulingList = omOrderSchedulingService.selectOmOrderSchedulingList(omOrderScheduling);
+ String OrderNumber = omOrderSchedulingList.get(0).getWorkOrderNo();
+
+ bsBomChildInfo.setLocationCode(daMaterialCollection.getLocationCode());
+ bsBomChildInfo.setBomCode(OrderNumber);
+ String[] parts = daMaterialCollection.getParamValue().split("#");
+ String targetValue = parts[1]; // 鍙栫浜屼釜鍏冪礌锛堢储寮�1锛�
+ bsBomChildInfo.setMaterialCode(targetValue);
+ List<BsBomChildInfo> bsBomChildInfoList = bsBomChildInfoService.selectBsBomChildInfoList(bsBomChildInfo);
+ String MaterialCode = bsBomChildInfoList.get(0).getMaterialCode();
+ String MaterialName = bsBomChildInfoList.get(0).getMaterialName();
+ daMaterialCollection1.setMaterialCode(MaterialCode);
+ daMaterialCollection1.setMaterialName(MaterialName);
+
+ this.save(daMaterialCollection1);
+ collectMT.setMaterial1(MaterialName);
+ collectMT.setOrderNumber(OrderNumber);
+ collectMT.setEngineNumber(daMaterialCollection.getSfcCode());
+ collectMT.setStationName(daMaterialCollection.getLocationCode());
+ collectMT.setPartsNumber(daMaterialCollection.getParamValue());
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ collectMT.setInsertTime(sdf.format(daMaterialCollection.getCollectTime()));
+ try {
+ HttpResponse response = HttpRequest.post(url).body(JSONUtil.toJsonStr(collectMT)).execute();
+ log.info("鎺ㄩ�佹垚鍔燂紝鍝嶅簲鎶ユ枃: {}", response);
+ } catch (Exception e) {
+ // 璁板綍鏃ュ織
+ log.error("鎺ㄩ�佸け璐�");
+ }
+// this.save(daMaterialCollection);
}
+
+
+ @Override
+ public void plusSave(DaMaterialCollection daMaterialCollection) {
+ String url = "http://172.40.161.71:8890/Interaction/CollectMT";
+ CollectMT collectMT = new CollectMT();
+ DaMaterialCollection daMaterialCollection1 = new DaMaterialCollection();
+ BsBomChildInfo bsBomChildInfo = new BsBomChildInfo();
+ OmOrderScheduling omOrderScheduling = new OmOrderScheduling();
+ daMaterialCollection1.setSfcCode(daMaterialCollection.getSfcCode());
+ daMaterialCollection1.setLocationCode(daMaterialCollection.getLocationCode());
+ daMaterialCollection1.setParamValue(daMaterialCollection.getParamValue());
+ daMaterialCollection1.setCollectTime(daMaterialCollection.getCollectTime());
+ omOrderScheduling.setSfcCode(daMaterialCollection.getSfcCode());
+ omOrderScheduling.setSfcCode(daMaterialCollection.getSfcCode());
+ if( Constants.PLC1.contains(daMaterialCollection.getLocationCode()) ||
+ Constants.C005.equals(daMaterialCollection.getLocationCode()) ||
+ Constants.C060.equals(daMaterialCollection.getLocationCode()) )
+ {omOrderScheduling.setRemarks("Head");}
+ else if(
+ Constants.PLC2.contains(daMaterialCollection.getLocationCode()) ||
+ Constants.OP005.equals(daMaterialCollection.getLocationCode()) ||
+ Constants.OP310.equals(daMaterialCollection.getLocationCode()))
+ {omOrderScheduling.setRemarks("Body");}
+ else if(Constants.P010.equals(daMaterialCollection.getLocationCode()))
+ {omOrderScheduling.setRemarks("Pre");}
+ List<OmOrderScheduling> omOrderSchedulingList = omOrderSchedulingService.selectOmOrderSchedulingList(omOrderScheduling);
+ String OrderNumber = omOrderSchedulingList.get(0).getWorkOrderNo();
+ String[] parts = daMaterialCollection.getParamValue().split("#");
+ String targetValue = parts[1]; // 鍙栫浜屼釜鍏冪礌锛堢储寮�1锛�
+ daMaterialCollection1.setMaterialCode(targetValue);
+ daMaterialCollection1.setMaterialName(daMaterialCollection.getParamName());
+ this.save(daMaterialCollection1);
+ collectMT.setMaterial1(daMaterialCollection.getMaterialName());
+ collectMT.setOrderNumber(OrderNumber);
+ collectMT.setEngineNumber(daMaterialCollection.getSfcCode());
+ collectMT.setStationName(daMaterialCollection.getLocationCode());
+ collectMT.setPartsNumber(daMaterialCollection.getParamValue());
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ collectMT.setInsertTime(sdf.format(daMaterialCollection.getCollectTime()));
+ try {
+ HttpResponse response = HttpRequest.post(url).body(JSONUtil.toJsonStr(collectMT)).execute();
+ log.info("鎺ㄩ�佹垚鍔燂紝鍝嶅簲鎶ユ枃: {}", response);
+ } catch (Exception e) {
+ // 璁板綍鏃ュ織
+ log.error("鎺ㄩ�佸け璐�");
+ }
+ }
+
/**
* 淇敼鐗╂枡閲囬泦
@@ -92,4 +210,5 @@
{
return daMaterialCollectionMapper.deleteDaMaterialCollectionById(id);
}
-}
+
+}
\ No newline at end of file
--
Gitblit v1.9.3