dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/controller/InspectionAppointmentController.java

@@ -60,6 +60,7 @@ public class InspectionAppointmentController extends BaseController
     /**
      * 获取【请填写功能名称】详细信息
      */
+    @PreAuthorize("@ss.hasPermi('system:appointment:query')")
     @GetMapping(value = "/{id}")
     public CommonResult getInfo(@PathVariable("id") Long id)
     {
@@ -79,6 +80,7 @@ public class InspectionAppointmentController extends BaseController
     /**
      * 修改【请填写功能名称】
      */
+    @PreAuthorize("@ss.hasPermi('system:appointment:edit')")
     @PutMapping
     public CommonResult edit(@RequestBody InspectionAppointment inspectionAppointment)
     {

dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/entity/InspectionInfo.java

@@ -96,10 +96,6 @@ public class InspectionInfo extends TenantBaseDO
     private String customerSource;
     /** 引车员id*/
     private Long leadManId;
-    /** 接车员id*/
-    private Long meetManId;
-    /** 是否接车*/
-    private String isMeetCar;
     @TableField(exist = false)
     private String lastTitle;
 
@@ -175,6 +171,4 @@ public class InspectionInfo extends TenantBaseDO
     private Integer additionalRecording;
     @TableField(exist = false)
     private String orderId;
-    @TableField(exist = false)
-    private Long appointmentId;
 }

dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/AppInspectionPartnerServiceImpl.java

@@ -202,13 +202,15 @@ public class AppInspectionPartnerServiceImpl extends ServiceImpl<AppInspectionPa
                 throw new Exception("信息有误");
             }
         } else {
-            LambdaQueryWrapper<ShopMallPartners> queryWrapper = new LambdaQueryWrapper<>();
+            LambdaQueryWrapper<PartnerWorker> queryWrapperWork = new LambdaQueryWrapper<>();
-            queryWrapper.orderByAsc(ShopMallPartners::getPartnerId).eq(ShopMallPartners::getType, "jc").eq(ShopMallPartners::getIsBanned, "0").last("limit 1");
+            queryWrapperWork.eq(PartnerWorker::getUserId, user.getId());
-            partner = this.getOne(queryWrapper);
+            queryWrapperWork.orderByAsc(PartnerWorker::getPartnerId);
-            if (ObjectUtil.isEmpty(partner)) {
+            queryWrapperWork.last("limit 1");
+            PartnerWorker worker = partnerWorkerService.getOne(queryWrapperWork);
+            if (ObjectUtil.isEmpty(worker)) {
                 throw new Exception("信息有误");
             }
-            partner.setPartnerId(partner.getPartnerId());
+            partner.setPartnerId(worker.getPartnerId());
         }
         return partner;
     }

dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/InspectionEquInfoServiceImpl.java

@@ -63,14 +63,21 @@ public class InspectionEquInfoServiceImpl extends ServiceImpl<InspectionEquInfoM
     public InspectionEquInfo selectInspectionEquInfoById(Long id) {
         InspectionEquInfo inspectionEquInfo = baseMapper.selectInspectionEquInfoById(id);
 
-        //查询文件表文件夹id是否存在
+        //查询文件附件
         if (ObjectUtil.isNotEmpty(inspectionEquInfo.getFolderId())) {
-            InspectionFile folder = inspectionFileService.getOne(Wrappers.<InspectionFile>lambdaQuery().eq(InspectionFile::getId, inspectionEquInfo.getFolderId()));
+            List<InspectionFile> fileList = inspectionFileService.list(Wrappers.<InspectionFile>lambdaQuery()
-            if (ObjectUtil.isNull(folder)) {
+                    .eq(InspectionFile::getFatherId, inspectionEquInfo.getFolderId()));
-                inspectionEquInfo.setFolderId(null);
-            }
-        }
 
+            List<FileDO> copyFileList = new ArrayList<>();
+            for (InspectionFile inspectionFile : fileList) {
+                FileDO fileDO = new FileDO();
+                //把文件名后缀截取掉
+                fileDO.setUrl(inspectionFile.getFilePath());
+                fileDO.setName(inspectionFile.getFileName());
+                copyFileList.add(fileDO);
+            }
+            inspectionEquInfo.setFileList(copyFileList);
+        }
         return inspectionEquInfo;
     }
 

dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/InspectionInfoServiceImpl.java

@@ -42,10 +42,8 @@ import cn.iocoder.yudao.module.system.dal.mysql.permission.RoleMapper;
 import cn.iocoder.yudao.module.system.service.permission.RoleService;
 import cn.iocoder.yudao.module.system.service.user.AdminUserService;
 import cn.iocoder.yudao.util.SendSmsUtil;
-import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import cn.iocoder.yudao.util.StringUtils;
@@ -122,8 +120,6 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
     private DlInspectionProjectService projectService;
     @Autowired
     private FileService fileService;
-    @Autowired
-    private IInspectionAppointmentService inspectionAppointmentService;
 
     /**
      * 查询【请填写功能名称】
@@ -209,20 +205,6 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
         //赊账的情况
         orderInfo.setOrderStatus("0");
         orderInfoService.save(orderInfo);
-        //判断有没有传预约信息
-        if (ObjectUtil.isNotNull(inspectionInfo.getAppointmentId())) {
-            //修改预约信息表的orderId
-            InspectionAppointment appointment = new InspectionAppointment();
-            appointment.setOrderId(orderInfo.getId());
-            inspectionAppointmentService.update(Wrappers.<InspectionAppointment>lambdaUpdate()
-                    .eq(InspectionAppointment::getId, inspectionInfo.getAppointmentId())
-                    .set(InspectionAppointment::getOrderId, orderInfo.getId()));
-
-            //修改订单的核销时间
-            orderInfoService.update(Wrappers.<OrderInfo>lambdaUpdate()
-                    .eq(OrderInfo::getId, orderInfo.getId())
-                    .set(OrderInfo::getValidationTime, new Date()));
-        }
         inspectionInfo.setInspectionOrderId(orderInfo.getId());
         inspectionInfo.setPartnerId(partners.getPartnerId());
         inspectionInfo.setWorkerName(workerUser.getNickname());
@@ -743,23 +725,24 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
             List<UserRoleDO> byUserId = roleService.getByUserId(loginUser.getId());
             inspectionInfo.setLeadManId(loginUser.getId());
             List<Long> roleIds = byUserId.stream().map(UserRoleDO::getRoleId).collect(Collectors.toList());
-
             if (!"1".equals(inspectionInfo.getStatus())) {
+                // 进行中 已完成
                 inspectionInfo.setDealUserId(loginUser.getId());
             }
 
-            Map<String, Long> result = new ConcurrentHashMap<>(); // 线程安全
+            Map<String, Long> result = new ConcurrentHashMap<>(); // 使用ConcurrentHashMap以确保线程安全
 
-            // 这里 `5` 而不是 `6`，因为 i 从 `0` 开始
+            // 定义一个数组来保存所有的CompletableFuture
             CompletableFuture<Void>[] futures = new CompletableFuture[6];
 
-            for (int i = 0; i < 6; i++) { // 改为 `0~4`
+            for (int i = 1; i < 6; i++) {
-                final String status = String.valueOf(i + 1);
+                final String status = String.valueOf(i);
 
-                // 深拷贝对象，防止多线程修改冲突
+                // 复制一份inspectionInfo对象，避免多线程修改同一个对象导致的问题
-                InspectionInfo infoCopy = JSON.parseObject(JSON.toJSONString(inspectionInfo), InspectionInfo.class);
+                InspectionInfo infoCopy = BeanUtil.toBean(inspectionInfo, InspectionInfo.class);
                 infoCopy.setStatus(status);
 
+                // 为每个任务创建一个新的Page对象
                 Page<InspectionInfo> page = new Page<>(1, 10);
 
                 futures[i] = CompletableFuture.runAsync(() -> {
@@ -776,15 +759,8 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
         } catch (Exception e) {
             throw new RuntimeException("Failed to execute tasks in parallel", e);
         } finally {
+            // 关闭线程池
             executor.shutdown();
-            try {
-                if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
-                    executor.shutdownNow();
-                }
-            } catch (InterruptedException e) {
-                executor.shutdownNow();
-            }
         }
     }
-
 }

dl-module-inspection/src/main/resources/mapper/inspection/InspectionAppointmentMapper.xml

@@ -33,10 +33,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </select>
 
     <select id="selectInspectionAppointmentById" parameterType="Long" resultMap="InspectionAppointmentResult">
-        select ia.*,su.nickname as buyName, su.mobile as buyPhoneNum
+        <include refid="selectInspectionAppointmentVo"/>
-        from inspection_appointment ia
+        where id = #{id}
-        left join system_users su on su.id = ia.user_id
-        where ia.id = #{id}
     </select>
 
     <insert id="insertInspectionAppointment" parameterType="cn.iocoder.yudao.module.inspection.entity.InspectionAppointment">

dl-module-inspection/src/main/resources/mapper/inspection/InspectionInfoMapper.xml

@@ -355,12 +355,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
                 AND iwn.deal_user_id = #{inspectionInfo.dealUserId}
                 ORDER BY iwn.update_time DESC
             </if>
-            <!-- 待接车 -->
-            <if test="inspectionInfo.status == 6">
-                AND ii.is_meet_car = '0'
-                AND ii.meet_man_id = #{inspectionInfo.dealUserId}
-                ORDER BY iwn.update_time DESC
-            </if>
         </where>
         ) AS subquery
         WHERE rn = 1;