From a7ad35b3e20867204cda9faa7bdf8a686264e906 Mon Sep 17 00:00:00 2001
From: shiyunteng <shiyunteng@example.com>
Date: 星期四, 27 三月 2025 17:17:43 +0800
Subject: [PATCH] 合同及明细业务调整

---
 platformx-device-biz/src/main/java/com/by4cloud/platformx/device/service/impl/ReceivingNoteServiceImpl.java |   49 ++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 36 insertions(+), 13 deletions(-)

diff --git a/platformx-device-biz/src/main/java/com/by4cloud/platformx/device/service/impl/ReceivingNoteServiceImpl.java b/platformx-device-biz/src/main/java/com/by4cloud/platformx/device/service/impl/ReceivingNoteServiceImpl.java
index e4d4310..a8673d5 100644
--- a/platformx-device-biz/src/main/java/com/by4cloud/platformx/device/service/impl/ReceivingNoteServiceImpl.java
+++ b/platformx-device-biz/src/main/java/com/by4cloud/platformx/device/service/impl/ReceivingNoteServiceImpl.java
@@ -5,12 +5,8 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.by4cloud.platformx.device.dto.ReceivingNoteQueryDTO;
-import com.by4cloud.platformx.device.entity.DeviceInventory;
-import com.by4cloud.platformx.device.entity.ReceivingNote;
-import com.by4cloud.platformx.device.entity.ReceivingNoteItem;
-import com.by4cloud.platformx.device.mapper.DeviceInventoryMapper;
-import com.by4cloud.platformx.device.mapper.ReceivingNoteItemMapper;
-import com.by4cloud.platformx.device.mapper.ReceivingNoteMapper;
+import com.by4cloud.platformx.device.entity.*;
+import com.by4cloud.platformx.device.mapper.*;
 import com.by4cloud.platformx.device.service.ReceivingNoteService;
 import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Service;
@@ -30,6 +26,9 @@
 
 	private final ReceivingNoteItemMapper itemMapper;
 	private final DeviceInventoryMapper inventoryMapper;
+	private final InventoryFlowWaterMapper inventoryFlowWaterMapper;
+	private final DeviceMapper deviceMapper;
+	private final ContractMapper contractMapper;
 
 	@Override
 	public IPage pageNew(Page page, ReceivingNoteQueryDTO queryDTO) {
@@ -48,13 +47,37 @@
 				if (item.getSerialNos()!=null&&item.getSerialNos().size()>0){
 					for (String serialNo:item.getSerialNos()
 						 ) {
-						DeviceInventory inventory = new DeviceInventory();
-						inventory.setDeviceId(item.getDeviceId());
-						inventory.setDeviceNumber(item.getDeviceCode());
-						inventory.setName(item.getDeviceName());
-						inventory.setSerialNo(serialNo);
-						inventory.setSource(1);
-						inventoryMapper.insert(inventory);
+						Device device = deviceMapper.selectById(item.getDeviceId());
+						Contract contract = contractMapper.selectById(entity.getContractId());
+						if (device!=null) {
+							DeviceInventory inventory = new DeviceInventory();
+							inventory.setDeviceId(item.getDeviceId());
+							inventory.setDeviceNumber(item.getDeviceCode());
+							inventory.setName(device.getName());
+							inventory.setSerialNo(serialNo);
+							if (contract!=null&&(contract.getType()==1||contract.getType()==2)){
+								inventory.setSource(1);
+								inventory.setInventoryStatus(1);
+							}
+							if (contract!=null&&contract.getType()==0){
+								inventory.setSource(1);
+								inventory.setInventoryStatus(2);
+							}
+							inventoryMapper.insert(inventory);
+							//璁惧搴撳瓨娴佹按鍚屾鏂板
+							InventoryFlowWater flowWater = new InventoryFlowWater();
+							flowWater.setDeviceId(item.getDeviceId());
+							flowWater.setSerialNo(serialNo);
+							flowWater.setInventoryId(inventory.getId());
+							flowWater.setClassId(device.getClassId());
+							if (contract!=null&&(contract.getType()==1||contract.getType()==2)){
+								flowWater.setOperateType(2);
+							}
+							if (contract!=null&&contract.getType()==0){
+								flowWater.setOperateType(1);
+							}
+							inventoryFlowWaterMapper.insert(flowWater);
+						}
 					}
 
 				}

--
Gitblit v1.9.1