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

@@ -97,5 +97,12 @@ public class InspectionInfoController extends BaseController
         return toAjax(inspectionInfoService.deleteInspectionInfoByIds(id));
     }
 
-
+    /**
+     * 根据当前登陆人获取可以选择的工单
+     * @return
+     */
+    @GetMapping("geStelectInspection")
+    public CommonResult geStelectInspection(){
+        return success(inspectionInfoService.geStelectInspection());
+    }
 }

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

@@ -75,4 +75,9 @@ public interface IInspectionInfoService  extends IService<InspectionInfo>
 
     Map<String,Object> workOrderData(Long partnerId, String carNum, String goodsTitle, String customerSource, String payType, String startTime, Long roleId, String endTime);
 
+    /**
+     * 根据当前登陆人获取可以选择的工单
+     * @return
+     */
+    List<InspectionInfo> geStelectInspection();
 }

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

@@ -2,9 +2,13 @@ package cn.iocoder.yudao.module.inspection.service.impl;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
+
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.iocoder.yudao.framework.security.core.LoginUser;
@@ -17,7 +21,9 @@ import cn.iocoder.yudao.module.partner.service.IPartnerWorkerService;
 import cn.iocoder.yudao.module.payment.service.IOrderInfoDetailService;
 import cn.iocoder.yudao.module.payment.service.OrderInfoService;
 import cn.iocoder.yudao.module.system.controller.admin.user.vo.user.UserSaveReqVO;
+import cn.iocoder.yudao.module.system.dal.dataobject.permission.UserRoleDO;
 import cn.iocoder.yudao.module.system.dal.dataobject.user.AdminUserDO;
+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.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -49,8 +55,7 @@ import javax.annotation.Resource;
  * @date 2023-08-13
  */
 @Service
-public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,InspectionInfo> implements IInspectionInfoService
-{
+public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper, InspectionInfo> implements IInspectionInfoService {
     @Autowired
     private AdminUserService userService;
     @Autowired
@@ -72,8 +77,15 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
     private IDelOrderInfoService delInspectionOrderService;
     @Autowired
     private IDelInspectionInfoService delInspectionInfoService;
+    @Autowired
+    private IInspectionWorkNodeService workNodeService;
+    @Autowired
+    private InspectionStepInfoService inspectionStepInfoService;
     @Resource
     private CustomerMainService customerMainService;
+    @Autowired
+    private RoleService roleService;
+
     /**
      * 查询【请填写功能名称】
      *
@@ -81,8 +93,7 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
      * @return 【请填写功能名称】
      */
     @Override
-    public InspectionInfo selectInspectionInfoById(Long id)
-    {
+    public InspectionInfo selectInspectionInfoById(Long id) {
         return baseMapper.selectInspectionInfoById(id);
     }
 
@@ -93,8 +104,7 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
      * @return 【请填写功能名称】
      */
     @Override
-    public IPage<InspectionInfo> selectInspectionInfoList(Page<InspectionInfo> page, InspectionInfo inspectionInfo)
-    {
+    public IPage<InspectionInfo> selectInspectionInfoList(Page<InspectionInfo> page, InspectionInfo inspectionInfo) {
         return baseMapper.selectInspectionInfoList(page, inspectionInfo);
     }
 
@@ -109,15 +119,19 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
     public int insertInspectionInfo(InspectionInfo inspectionInfo) throws Exception {
         LoginUser loginUser = SecurityFrameworkUtils.getLoginUser();
         ShopMallPartners partners = appInspectionPartnerService.shopInfo();
-        LambdaQueryWrapper<PartnerWorker> workerQueryWrapper =new LambdaQueryWrapper<>();
-        workerQueryWrapper.eq(PartnerWorker::getUserId,loginUser.getId()).eq(PartnerWorker::getPartnerId,partners.getPartnerId());
-        PartnerWorker worker = workerService.getOne(workerQueryWrapper);
-        if (ObjectUtils.isNotEmpty(worker)){
-            inspectionInfo.setWorkId(worker.getId());
-        }else {
-            throw new Exception("请先将接待员加入员工");
+//        LambdaQueryWrapper<PartnerWorker> workerQueryWrapper =new LambdaQueryWrapper<>();
+//        workerQueryWrapper.eq(PartnerWorker::getUserId,loginUser.getId()).eq(PartnerWorker::getPartnerId,partners.getPartnerId());
+//        PartnerWorker worker = workerService.getOne(workerQueryWrapper);
+//        if (ObjectUtils.isNotEmpty(worker)){
+//            inspectionInfo.setWorkId(worker.getId());
+//        }else {
+//            throw new Exception("请先将接待员加入员工");
+//        }
+        if (ObjectUtils.isEmpty(inspectionInfo.getInspectionWorkNodes())) {
+            throw new RuntimeException("请选择检测项目");
         }
-        AdminUserDO workerUser =userService.getUser(worker.getUserId());
+        //当前登陆人 就是检测人
+        AdminUserDO workerUser = userService.getUser(loginUser.getId());
         String buyName = StringUtils.isNotEmpty(inspectionInfo.getBuyName()) ? inspectionInfo.getBuyName() : "未知客户";
         String buyPhone = StringUtils.isNotEmpty(inspectionInfo.getBuyPhone()) ? inspectionInfo.getBuyPhone() : StringUtils.isNotEmpty(inspectionInfo.getBuyName()) ? inspectionInfo.getBuyName() : "无";
         AdminUserDO user = userService.getUserByMobile(buyPhone);
@@ -213,7 +227,23 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
         }
         //追加订单明细记录
         orderInfoDetailService.save(new OrderInfoDetail(orderInfo.getId(), "线下订单创建", new Date(), 0L, "1"));
-        return baseMapper.insert(inspectionInfo);
+        //默认当前流程的顺序为1
+        inspectionInfo.setNowOrderNum(1);
+        //添加检测工单
+        baseMapper.insert(inspectionInfo);
+        //补充检测流程
+        List<InspectionWorkNode> inspectionWorkNodes = inspectionInfo.getInspectionWorkNodes();
+        //将检测工单流程补充检测工单id
+        inspectionWorkNodes.stream().forEach(inspectionWorkNode -> inspectionWorkNode.setInspectionInfoId(inspectionInfo.getId()));
+        workNodeService.saveBatch(inspectionWorkNodes);
+
+        //检测步骤表插入检测开始
+        InspectionStepInfo stepInfo = new InspectionStepInfo();
+        stepInfo.setInspectionInfoId(Integer.parseInt(String.valueOf(inspectionInfo.getId())));
+        stepInfo.setTitle("检测开始");
+        stepInfo.setContent("检测开始");
+        boolean save = inspectionStepInfoService.save(stepInfo);
+        return save ? 1 : 0;
     }
 
     @Override
@@ -284,8 +314,7 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public int deleteInspectionInfoByIds(Long id)
-    {
+    public int deleteInspectionInfoByIds(Long id) {
         InspectionInfo info = this.getById(id);
         baseMapper.deleteInspectionInfoById(id);
         OrderInfo orderInfo = orderInfoService.getById(info.getInspectionOrderId());
@@ -307,10 +336,10 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
      * @return 结果
      */
     @Override
-    public int deleteInspectionInfoById(Long id)
-    {
+    public int deleteInspectionInfoById(Long id) {
         return baseMapper.deleteInspectionInfoById(id);
     }
+
     @Override
     public List<InspectionInfo> workOrder(Long partnerId, String carNum, String goodsTitle, String customerSource, String payType, String startTime, Long roleId, String endTime) {
         return baseMapper.workOrder(partnerId, carNum, goodsTitle, customerSource, payType, startTime, roleId, endTime);
@@ -335,4 +364,51 @@ public class InspectionInfoServiceImpl extends ServiceImpl<InspectionInfoMapper,
     public Map<String, Object> workOrderData(Long partnerId, String carNum, String goodsTitle, String customerSource, String payType, String startTime, Long roleId, String endTime) {
         return baseMapper.workOrderData(partnerId, carNum, goodsTitle, customerSource, payType, startTime, roleId, endTime);
     }
+
+    /**
+     * 根据当前登陆人获取可以选择的工单
+     *
+     * @return
+     */
+    @Override
+    public List<InspectionInfo> geStelectInspection() {
+        //获取当前登录人
+        LoginUser loginUser = SecurityFrameworkUtils.getLoginUser();
+        //获取当前登陆人的角色
+        List<UserRoleDO> byUserId = roleService.getByUserId(loginUser.getId());
+        List<Long> roleIds = byUserId.stream().map(UserRoleDO::getRoleId).collect(Collectors.toList());
+        //查询所有工单为进行中的
+        List<InspectionInfo> inspectionInfos = baseMapper.selectList(new LambdaQueryWrapper<InspectionInfo>()
+                .eq(InspectionInfo::getStatus, 0));
+        //根据工单id查询工单流程节点
+        List<Long> infoIds = inspectionInfos.stream().map(inspectionInfo -> inspectionInfo.getId()).collect(Collectors.toList());
+        if (ObjectUtils.isNotEmpty(infoIds)) {
+            List<InspectionWorkNode> inspectionWorkNodes = workNodeService.list(new LambdaQueryWrapper<InspectionWorkNode>()
+                    .in(InspectionWorkNode::getInspectionInfoId, infoIds)
+                    .eq(InspectionWorkNode::getDealUserId, null));
+
+            //工单集合
+            List<InspectionInfo> inspectionInfoList = new ArrayList<>();
+
+            //根据工单id查询工单流程节点
+            Map<Long, List<InspectionWorkNode>> inspectionWorkNodeMap = inspectionWorkNodes.stream().collect(Collectors.groupingBy(InspectionWorkNode::getInspectionInfoId));
+            for (InspectionInfo inspectionInfo : inspectionInfos) {
+                List<InspectionWorkNode> inspectionWorkNodeList = inspectionWorkNodeMap.get(inspectionInfo.getId());
+                //遍历工单流程节点 流程为key
+                if (CollectionUtil.isNotEmpty(inspectionWorkNodeList)) {
+                    Map<Integer, InspectionWorkNode> inspectionWorkMap = inspectionWorkNodeList.stream().collect(Collectors.toMap(InspectionWorkNode::getOrderNum, item -> item));
+                    InspectionWorkNode inspectionWorkNode = inspectionWorkMap.get(inspectionInfo.getNowOrderNum());
+                    if (inspectionWorkNode != null){
+                        //判断当前项目 当前登录人员 是否可以处理
+                        if (roleIds.contains(inspectionWorkNode.getRoleId())){
+                            inspectionInfo.setWorkNodeId(inspectionWorkNode.getId());
+                            inspectionInfoList.add(inspectionInfo);
+                        }
+                    }
+                }
+            }
+            return inspectionInfoList;
+        }
+        return null;
+    }
 }

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

@@ -126,6 +126,7 @@ public class PartnerCustomerInfoServiceImpl extends ServiceImpl<PartnerCustomerI
      * @return 结果
      */
     @Override
+
     public int insertPartnerCustomerInfo(PartnerCustomerInfo partnerCustomerInfo) throws Exception {
         // 获取当前商户信息
         ShopMallPartners partners = partnerService.shopInfo();