From 4b9dc71d162f3fcd79bc88b170154b7516fc4962 Mon Sep 17 00:00:00 2001
From: chenhj <1263187585@qq.com>
Date: 星期四, 18 十二月 2025 13:37:14 +0800
Subject: [PATCH] 新增设备维修保养过程描述,上传对应附件

---
 src/main/java/com/ruoyi/device/service/impl/DeviceRepairServiceImpl.java |   60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 54 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/ruoyi/device/service/impl/DeviceRepairServiceImpl.java b/src/main/java/com/ruoyi/device/service/impl/DeviceRepairServiceImpl.java
index 707063b..e9fddfb 100644
--- a/src/main/java/com/ruoyi/device/service/impl/DeviceRepairServiceImpl.java
+++ b/src/main/java/com/ruoyi/device/service/impl/DeviceRepairServiceImpl.java
@@ -3,16 +3,26 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.basic.dto.StorageBlobDTO;
+import com.ruoyi.basic.pojo.StorageAttachment;
+import com.ruoyi.basic.service.StorageAttachmentService;
+import com.ruoyi.common.constant.StorageAttachmentConstants;
+import com.ruoyi.common.enums.StorageAttachmentRecordType;
 import com.ruoyi.common.utils.bean.BeanUtils;
 import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.device.dto.DeviceDefectRecordDto;
 import com.ruoyi.device.dto.DeviceRepairDto;
 import com.ruoyi.device.execl.DeviceRepairExeclDto;
 import com.ruoyi.device.mapper.DeviceRepairMapper;
+import com.ruoyi.device.pojo.DeviceLedger;
 import com.ruoyi.device.pojo.DeviceRepair;
+import com.ruoyi.device.service.DeviceDefectRecordService;
+import com.ruoyi.device.service.IDeviceLedgerService;
 import com.ruoyi.device.service.IDeviceRepairService;
 import com.ruoyi.framework.web.domain.AjaxResult;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -20,16 +30,21 @@
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.stream.Collectors;
 
 @Service
 @AllArgsConstructor
 @Slf4j
 public class DeviceRepairServiceImpl extends ServiceImpl<DeviceRepairMapper, DeviceRepair> implements IDeviceRepairService {
 
-
+    @Autowired
+    private DeviceDefectRecordService deviceDefectRecordService;
     @Autowired
     private DeviceRepairMapper deviceRepairMapper;
-
+    @Autowired
+    private IDeviceLedgerService deviceLedgerService;
+    @Autowired
+    private StorageAttachmentService storageAttachmentService;
     @Override
     public IPage<DeviceRepairDto> queryPage(Page page, DeviceRepairDto deviceRepairDto) {
 
@@ -37,17 +52,38 @@
     }
 
     @Override
-    public AjaxResult saveDeviceRepair(DeviceRepair deviceRepair) {
-        boolean save = this.save(deviceRepair);
-        if (save){
+    public AjaxResult saveDeviceRepair(DeviceRepairDto deviceRepair) {
+        DeviceLedger byId = deviceLedgerService.getById(deviceRepair.getDeviceLedgerId());
+        deviceRepair.setDeviceName(byId.getDeviceName());
+        deviceRepair.setDeviceModel(byId.getDeviceModel());
+        int save = deviceRepairMapper.insert(deviceRepair);
+        storageAttachmentService.saveStorageAttachmentByStorageBlob(deviceRepair.getFiles(),
+                deviceRepair.getId(), StorageAttachmentRecordType.DeviceRepairImage,
+                StorageAttachmentConstants.StorageAttachmentImage);
+        if (save == 1){
             return AjaxResult.success();
         }
         return AjaxResult.error();
     }
 
     @Override
-    public AjaxResult updateDeviceRepair(DeviceRepair deviceRepair) {
+    public AjaxResult updateDeviceRepair(DeviceRepairDto deviceRepair) {
         if (this.updateById(deviceRepair)) {
+            Long id = deviceRepair.getId();
+            //
+            DeviceDefectRecordDto deviceDefectRecordDto = new DeviceDefectRecordDto();
+            deviceDefectRecordDto.setDeviceLedgerId(id);
+            deviceDefectRecordDto.setStatus("涓ラ噸缂洪櫡");
+            List<DeviceDefectRecordDto> records = deviceDefectRecordService.listPage(new Page<>(1, -1), deviceDefectRecordDto).getRecords();
+            if (!records.isEmpty()){
+                records.forEach(deviceDefectRecord -> {
+                    deviceDefectRecord.setStatus("姝e父");
+                    deviceDefectRecordService.updateByDDR(deviceDefectRecord);
+                });
+            }
+            storageAttachmentService.saveStorageAttachmentByStorageBlob(deviceRepair.getFiles(),
+                    deviceRepair.getId(), StorageAttachmentRecordType.DeviceRepairImage,
+                    StorageAttachmentConstants.StorageAttachmentImage);
             return AjaxResult.success();
         }
         return AjaxResult.error();
@@ -87,4 +123,16 @@
 
     }
 
+    @Override
+    public DeviceRepairDto detailById(Long id) {
+        DeviceRepairDto deviceRepairDto = deviceRepairMapper.detailById(id);
+        List<StorageAttachment> storageAttachments = storageAttachmentService.selectStorageAttachments(id, StorageAttachmentRecordType.DeviceRepairImage,
+                StorageAttachmentConstants.StorageAttachmentImage);
+        if (CollectionUtils.isNotEmpty(storageAttachments)) {
+            List<StorageBlobDTO> storageBlobs = storageAttachments.stream().map(StorageAttachment::getStorageBlobDTO).collect(Collectors.toList());
+            deviceRepairDto.setFiles(storageBlobs);
+        }
+        return deviceRepairDto;
+    }
+
 }

--
Gitblit v1.9.3