From 53d014edd19f57125c355abe71ec5b478500e610 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期二, 05 八月 2025 09:57:40 +0800
Subject: [PATCH] 保洁巡检所有代码

---
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TInspectorController.java |  367 ++++++++++++++++++++++++++++++++++------------------
 1 files changed, 238 insertions(+), 129 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TInspectorController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TInspectorController.java
index 2fb437b..d344b02 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TInspectorController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TInspectorController.java
@@ -5,6 +5,7 @@
 import cn.afterturn.easypoi.excel.entity.ExportParams;
 import com.ruoyi.common.annotation.Log;
 import com.ruoyi.common.basic.PageInfo;
+import com.ruoyi.common.core.domain.BaseModel;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.enums.BusinessType;
@@ -18,8 +19,7 @@
 import com.ruoyi.system.query.TaskListQuery;
 import com.ruoyi.system.service.*;
 import com.ruoyi.system.utils.TemplateMessageSendUtil;
-import com.ruoyi.system.vo.system.InspectorListVO;
-import com.ruoyi.system.vo.system.TaskListVO;
+import com.ruoyi.system.vo.system.*;
 import com.ruoyi.web.controller.tool.EmailUtils;
 import com.ruoyi.web.controller.tool.MsgUtils;
 import io.swagger.annotations.Api;
@@ -54,6 +54,8 @@
     @Resource
     private TLocationService locationService;
     @Resource
+    private TLocationTypeService locationTypeService;
+    @Resource
     private TProjectDeptService projectDeptService;
 
     @Resource
@@ -68,7 +70,10 @@
     @Resource
     private TInspectorService inspectorService;
     @Resource
+    private TInspectorDetailService inspectorDetailService;
+    @Resource
     private TTaskCleanService taskCleanerService;
+
     @ApiOperation(value = "督察记录分页列表")
     @PostMapping(value = "/pageList")
     public R<PageInfo<InspectorListVO>> pageList(@RequestBody InsepectorListQuery query) {
@@ -76,87 +81,79 @@
         List<TLocation> locationList = locationService.list();
         if (StringUtils.hasLength(query.getDeptName())) {
             List<TProjectDept> list = projectDeptService.lambdaQuery().like(TProjectDept::getProjectName, query.getDeptName()).list();
-            List<String> projectIds = list
+            List<String> listIds = projectDeptService.lambdaQuery().like(TProjectDept::getProjectName, query.getDeptName()).list()
                     .stream().map(TProjectDept::getId).collect(Collectors.toList());
-            List<String> deptIds = deptService.lambdaQuery().like(TDept::getDeptName, query.getDeptName()).list()
-                    .stream().map(TDept::getId).collect(Collectors.toList());
-            for (TProjectDept projectDept : list) {
-                if (projectDept.getParentId().equals("0")){
-                    List<TProjectDept> list1 = projectDeptService.lambdaQuery().eq(TProjectDept::getParentId, projectDept.getId()).list();
-                    List<String> collect = list1.stream().map(TProjectDept::getId).collect(Collectors.toList());
-                    projectIds.addAll(collect);
+            for (TProjectDept tProjectDept : list) {
+                if (tProjectDept.getParentId().equals("0")) {
+                    List<String> collect = projectDeptService.lambdaQuery().eq(TProjectDept::getParentId, tProjectDept.getId()).list()
+                            .stream().map(TProjectDept::getId).collect(Collectors.toList());
+                    listIds.addAll(collect);
+                    listIds.add(tProjectDept.getId());
                 }
             }
-            projectIds.addAll(deptIds);
-            if (projectIds.isEmpty()) {
+            List<String> deptIds = deptService.lambdaQuery().like(TDept::getDeptName, query.getDeptName()).list()
+                    .stream().map(TDept::getId).collect(Collectors.toList());
+            listIds.addAll(deptIds);
+            if (listIds.isEmpty()) {
                 return R.ok(new PageInfo<>());
             }
-            // 用户ids
-            List<Long> collect = sysUsers.stream().filter(e -> e.getDeptType() == 1 && projectIds.contains(e.getDeptId())).map(SysUser::getUserId)
-                    .collect(Collectors.toList());
-            List<Long> collect1 = sysUsers.stream().filter(e -> e.getDeptType() == 2 && deptIds.contains(e.getDeptId())).map(SysUser::getUserId)
-                    .collect(Collectors.toList());
-            collect.addAll(collect1);
-            if (collect.isEmpty()) {
-                return R.ok(new PageInfo<>());
-            }
+            List<Long> collect = sysUsers.stream().filter(e -> listIds.contains(e.getDeptId()))
+                    .map(SysUser::getUserId).collect(Collectors.toList());
             query.setPatrolInspectorIds(collect);
-
             if (StringUtils.hasLength(query.getPhonenumber())) {
                 List<Long> patrolInspectorIds = sysUsers.stream().filter(sysUser ->
-                        sysUser.getPhonenumber().equals(query.getPhonenumber())
-                                && projectIds.contains(sysUser.getDeptId())
+                        sysUser.getPhonenumber().contains(query.getPhonenumber())
+                                && listIds.contains(sysUser.getDeptId())
                 ).map(SysUser::getUserId).collect(Collectors.toList());
                 if (patrolInspectorIds.isEmpty()) {
                     return R.ok(new PageInfo<>());
-                } else {
-                    patrolInspectorIds = patrolInspectorIds.stream().filter(query.getPatrolInspectorIds()::contains).collect(Collectors.toList());
-                    query.setPatrolInspectorIds(patrolInspectorIds);
                 }
+                query.setPatrolInspectorIds(patrolInspectorIds);
             }
         }
-        if (StringUtils.hasLength(query.getPhonenumber())){
+        if (StringUtils.hasLength(query.getPhonenumber())) {
             List<Long> patrolInspectorIds = sysUsers.stream().filter(sysUser ->
                     sysUser.getPhonenumber().contains(query.getPhonenumber())
             ).map(SysUser::getUserId).collect(Collectors.toList());
-            if (query.getPatrolInspectorIds()!=null&&!query.getPatrolInspectorIds().isEmpty()){
+            query.setPatrolInspectorIds(patrolInspectorIds);
+            if (!query.getPatrolInspectorIds().isEmpty()) {
                 // 取交集
                 patrolInspectorIds = patrolInspectorIds.stream().filter(query.getPatrolInspectorIds()::contains).collect(Collectors.toList());
             }
-            if (patrolInspectorIds.isEmpty()){
+            query.setPatrolInspectorIds(patrolInspectorIds);
+            if (patrolInspectorIds.isEmpty()) {
                 return R.ok(new PageInfo<>());
             }
-            query.setPatrolInspectorIds(patrolInspectorIds);
-
         }
-
-        if (query.getLocationType()!=null){
+        if (query.getClearStatus() != null) {
+            List<String> collect = inspectorDetailService.lambdaQuery().eq(TInspectorDetail::getClearStatus, query.getClearStatus())
+                    .list().stream().distinct().map(TInspectorDetail::getInspectorId).collect(Collectors.toList());
+            query.setTaskIds(collect);
+            if (collect.isEmpty()) {
+                return R.ok(new PageInfo<>());
+            }
+        }
+        if (StringUtils.hasLength(query.getLocationType())) {
             List<String> collect = locationList.stream().filter(e -> e.getLocationType().equals(query.getLocationType())).map(TLocation::getId)
                     .collect(Collectors.toList());
-            if (collect.isEmpty()){
+            if (collect.isEmpty()) {
                 return R.ok(new PageInfo<>());
             }
             query.setLocationIds(collect);
         }
-        if (StringUtils.hasLength(query.getLocationName())){
+        if (StringUtils.hasLength(query.getLocationName())) {
             List<String> collect = locationList.stream().filter(e -> e.getLocationName().contains(query.getLocationName())).map(TLocation::getId)
                     .collect(Collectors.toList());
-            if (collect.isEmpty()){
-                query.setLocationIds(collect);
+            query.setLocationIds(collect);
+            if (collect.isEmpty()) {
                 return R.ok(new PageInfo<>());
-            }else{
-                if (query.getLocationIds()!=null){
-                    collect = collect.stream().filter(query.getLocationIds()::contains).collect(Collectors.toList());
-                    if (collect.isEmpty()){
-                        return R.ok(new PageInfo<>());
-                    }
+            } else {
+                collect = collect.stream().filter(query.getLocationIds()::contains).collect(Collectors.toList());
+                if (collect.isEmpty()) {
+                    return R.ok(new PageInfo<>());
                 }
                 query.setLocationIds(collect);
             }
-        }
-        if (StringUtils.hasLength(query.getEndTime())){
-            String replace = query.getEndTime().replace(" 00:00:00", " 23:59:59");
-            query.setEndTime(replace);
         }
         return R.ok(inspectorService.pageList(query));
     }
@@ -167,68 +164,68 @@
     public void exportExcel(@RequestBody InsepectorListQuery query) {
         List<SysUser> sysUsers = sysUserService.selectAllList();
         List<TLocation> locationList = locationService.list();
-        if (StringUtils.hasLength(query.getDeptName())){
+        if (StringUtils.hasLength(query.getDeptName())) {
             List<String> projectIds = projectDeptService.lambdaQuery().like(TProjectDept::getProjectName, query.getDeptName()).list()
                     .stream().map(TProjectDept::getId).collect(Collectors.toList());
             List<String> deptIds = deptService.lambdaQuery().like(TDept::getDeptName, query.getDeptName()).list()
                     .stream().map(TDept::getId).collect(Collectors.toList());
             projectIds.addAll(deptIds);
-            if (projectIds.isEmpty()){
-                projectIds.add("0")    ;
+            if (projectIds.isEmpty()) {
+                projectIds.add("0");
             }
-            if (StringUtils.hasLength(query.getPhonenumber())){
+            if (StringUtils.hasLength(query.getPhonenumber())) {
                 List<Long> patrolInspectorIds = sysUsers.stream().filter(sysUser ->
                         sysUser.getPhonenumber().equals(query.getPhonenumber())
                                 && projectIds.contains(sysUser.getDeptId())
                 ).map(SysUser::getUserId).collect(Collectors.toList());
-                if (patrolInspectorIds.isEmpty()){
-                    patrolInspectorIds.add(0L)    ;
+                if (patrolInspectorIds.isEmpty()) {
+                    patrolInspectorIds.add(0L);
                 }
                 query.setPatrolInspectorIds(patrolInspectorIds);
             }
         }
-        if (StringUtils.hasLength(query.getPhonenumber())){
+        if (StringUtils.hasLength(query.getPhonenumber())) {
             List<Long> patrolInspectorIds = sysUsers.stream().filter(sysUser ->
                     sysUser.getPhonenumber().equals(query.getPhonenumber())
             ).map(SysUser::getUserId).collect(Collectors.toList());
-            if (!query.getPatrolInspectorIds().isEmpty()){
+            if (!query.getPatrolInspectorIds().isEmpty()) {
                 // 取交集
                 patrolInspectorIds = patrolInspectorIds.stream().filter(query.getPatrolInspectorIds()::contains).collect(Collectors.toList());
             }
-            if (patrolInspectorIds.isEmpty()){
+            if (patrolInspectorIds.isEmpty()) {
                 patrolInspectorIds.add(0L);
             }
             query.setPatrolInspectorIds(patrolInspectorIds);
 
         }
-        if (query.getClearStatus()!=null){
-            List<String> collect = tTaskDetailService.lambdaQuery().eq(TTaskDetail::getClearStatus, query.getClearStatus())
-                    .list().stream().distinct().map(TTaskDetail::getTaskId).collect(Collectors.toList());
-            if (collect.isEmpty()){
+        if (query.getClearStatus() != null) {
+            List<String> collect = inspectorDetailService.lambdaQuery().eq(TInspectorDetail::getClearStatus, query.getClearStatus())
+                    .list().stream().distinct().map(TInspectorDetail::getInspectorId).collect(Collectors.toList());
+            if (collect.isEmpty()) {
                 collect.add("-1");
             }
             query.setTaskIds(collect);
 
         }
-        if (query.getLocationType()!=null){
+        if (query.getLocationType() != null) {
             List<String> collect = locationList.stream().filter(e -> e.getLocationType().equals(query.getLocationType())).map(TLocation::getId)
                     .collect(Collectors.toList());
-            if (collect.isEmpty()){
+            if (collect.isEmpty()) {
                 collect.add("-1");
 
             }
             query.setLocationIds(collect);
         }
-        if (StringUtils.hasLength(query.getLocationName())){
+        if (StringUtils.hasLength(query.getLocationName())) {
             List<String> collect = locationList.stream().filter(e -> e.getLocationName().contains(query.getLocationName())).map(TLocation::getId)
                     .collect(Collectors.toList());
-            if (collect.isEmpty()){
+            if (collect.isEmpty()) {
                 collect.add("-1");
 
                 query.setLocationIds(collect);
-            }else{
+            } else {
                 collect = collect.stream().filter(query.getLocationIds()::contains).collect(Collectors.toList());
-                if (collect.isEmpty()){
+                if (collect.isEmpty()) {
                     collect.add("-1");
                 }
                 query.setLocationIds(collect);
@@ -257,6 +254,64 @@
         }
 
     }
+
+    @ApiOperation(value = "督察详情任务")
+    @GetMapping(value = "/detail")
+    public R<InspectorDetailVO> detail(@RequestParam String id) {
+        TInspector inspector = inspectorService.getById(id);
+        List<TInspectorDetail> list = inspectorDetailService.lambdaQuery().eq(TInspectorDetail::getInspectorId, id)
+                .orderByDesc(BaseModel::getCreateTime).list();
+        InspectorDetailVO taskDetailVO = new InspectorDetailVO();
+        BeanUtils.copyProperties(inspector, taskDetailVO);
+        TLocation byId1 = locationService.getById(inspector.getLocationId());
+        TLocationType byId2 = locationTypeService.getById(byId1.getLocationType());
+        taskDetailVO.setLocationAddress(byId1.getLocationAddress());
+        taskDetailVO.setLocationIcon(byId2.getLocationIcon());
+        taskDetailVO.setLocationName(byId1.getLocationName());
+        taskDetailVO.setLocationTypeName(byId2.getLocationName());
+        TInspectorDetail tTaskDetail = list.stream().filter(e -> e.getHandleType() == 1).findFirst().orElse(null);
+        if (tTaskDetail != null && tTaskDetail.getUnqualified() != null) {
+            TDictData byId3 = dictDataService.getById(tTaskDetail.getUnqualified());
+            if (byId3 != null) {
+                tTaskDetail.setUnqualifiedName(byId3.getDataContent());
+            }
+        }
+        if (tTaskDetail != null) {
+            tTaskDetail.setFinishTime(tTaskDetail.getCreateTime());
+        }
+        taskDetailVO.setTaskDetail(tTaskDetail);
+        taskDetailVO.setRecords(list);
+        return R.ok(taskDetailVO);
+    }
+
+    @ApiOperation(value = "详情任务-操作记录-详情")
+    @GetMapping(value = "/detailRecord")
+    public R<InspectorRecordDetailVO> detailRecord(@RequestParam String id) {
+        InspectorRecordDetailVO taskDetailVO = new InspectorRecordDetailVO();
+        TInspectorDetail byId4 = inspectorDetailService.getById(id);
+        TInspector byId = inspectorService.getById(byId4.getInspectorId());
+        BeanUtils.copyProperties(byId, taskDetailVO);
+        TLocation byId1 = locationService.getById(byId.getLocationId());
+        TLocationType byId2 = locationTypeService.getById(byId1.getLocationType());
+        taskDetailVO.setLocationAddress(byId1.getLocationAddress());
+        taskDetailVO.setLocationIcon(byId2.getLocationIcon());
+        taskDetailVO.setLocationName(byId2.getLocationName());
+        if (byId4.getUnqualified() != null) {
+            TDictData byId3 = dictDataService.getById(byId4.getUnqualified());
+            if (byId3 != null) {
+                byId4.setUnqualifiedName(byId3.getDataContent());
+            }
+        }
+        if (byId4.getAuditPerson() != null) {
+            SysUser sysUser = sysUserService.selectUserById(Long.valueOf(byId4.getAuditPerson()));
+            if (sysUser != null) {
+                byId4.setAuditPersonName(sysUser.getUserName());
+            }
+        }
+        taskDetailVO.setTaskDetail(byId4);
+        return R.ok(taskDetailVO);
+    }
+
     @Log(title = "批量删除督察任务", businessType = BusinessType.DELETE)
     @ApiOperation(value = "批量删除督察任务")
     @DeleteMapping(value = "/deleteByIds")
@@ -265,6 +320,7 @@
         inspectorService.removeBatchByIds(Arrays.asList(split));
         return R.ok();
     }
+
     @Log(title = "删除督察任务", businessType = BusinessType.DELETE)
     @ApiOperation(value = "删除督察任务")
     @DeleteMapping(value = "/deleteById")
@@ -272,6 +328,7 @@
         inspectorService.removeById(id);
         return R.ok();
     }
+
     @Resource
     private TNoticeService noticeService;
     @Resource
@@ -282,79 +339,24 @@
     private MsgUtils msgUtils;
     @Resource
     private TemplateMessageSendUtil templateMessageSendUtil;
+
     @Log(title = "审核任务", businessType = BusinessType.UPDATE)
     @ApiOperation(value = "审核任务")
     @PostMapping(value = "/audit")
     public R<Boolean> audit(@RequestBody TInspectorAuditDTO dto) throws Exception {
-        TTaskAuditDTO tTaskAuditDTO = new TTaskAuditDTO();
-        BeanUtils.copyProperties(dto, tTaskAuditDTO);
-        TTask task = taskCleanerService.getById(dto.getTaskId());
-        TLocation location = locationService.getById(task.getLocationId());
-        TNotice tNotice = new TNotice();
-        TNoticeSet noticeSet = noticeSetService.lambdaQuery().eq(TNoticeSet::getType, 2).last("limit 1")
-                .one();
-        tNotice.setUserId(task.getPatrolInspector());
-        tNotice.setStatus(1);
-        tNotice.setDataId(task.getId());
-        tNotice.setNoticeSetType(noticeSet.getNoticeType());
-        TInspector byId = inspectorService.getById(dto.getId());
-        SysUser sysUser = sysUserService.selectUserById(Long.valueOf(task.getPatrolInspector()));
-        // 邮箱
-        TDictData email = dictDataService.lambdaQuery().eq(TDictData::getDataType,4).one();
-        // 授权码
-        TDictData code = dictDataService.lambdaQuery().eq(TDictData::getDataType,5).one();
-        if (dto.getAuditStatus()==1){
-            if (byId.getClearStatus()==2){
-                tTaskAuditDTO.setHandleType(3);
-                dto.setStatus(2);
-                // 增加消息
-                tNotice.setNoticeType(8);
-                tNotice.setNoticeContent("【"+location.getLocationName()+"】督察任务不合格,请重新上传!");
-                noticeService.save(tNotice);
-                switch (noticeSet.getNoticeType()) {
-                    case 1:
-                        msgUtils.sendMsg5(sysUser.getPhonenumber(), location.getLocationName());
-                        break;
-                    case 2:
-                        if (StringUtils.hasLength(email.getDataContent()) && StringUtils.hasLength(code.getDataContent())) {
-                            EmailUtils.sendEmail(sysUser.getEmail(), email.getDataContent(), code.getDataContent(), "【"+location.getLocationName()+"】任务督察不合格,请及时整改!");
-                        }
-                        break;
-                    case 3:
-                        if (StringUtils.hasLength(sysUser.getOpenId())){
-                            templateMessageSendUtil.wxTemplateProblemRectificationRequest(sysUser.getOpenId(),
-                                    location.getLocationName(),dto.getAuditRemark());
-                        }
-                        break;
-                }
-            }else{
-                if (dto.getAuditTime()!=null){
-                    dto.setStatus(3);
-                }else{
-                    dto.setStatus(4);
-                }
-            }
-        }
-        dto.setAuditTime(LocalDateTime.now());
-
-        dto.setAuditPerson(tokenService.getLoginUser().getUserId()+"");
-        inspectorService.updateById(dto);
-        return R.ok();
-
-
-//        TInspector byId = inspectorService.getById(dto.getId());
-//
 //        TTaskAuditDTO tTaskAuditDTO = new TTaskAuditDTO();
 //        BeanUtils.copyProperties(dto, tTaskAuditDTO);
-//        TLocation location = locationService.getById(byId.getLocationId());
+//        TTask task = taskCleanerService.getById(dto.getTaskId());
+//        TLocation location = locationService.getById(task.getLocationId());
 //        TNotice tNotice = new TNotice();
 //        TNoticeSet noticeSet = noticeSetService.lambdaQuery().eq(TNoticeSet::getType, 2).last("limit 1")
 //                .one();
-//        tNotice.setUserId(location.getLocationLeader());
+//        tNotice.setUserId(task.getPatrolInspector());
 //        tNotice.setStatus(1);
-//        tNotice.setDataId(byId.getId());
+//        tNotice.setDataId(task.getId());
 //        tNotice.setNoticeSetType(noticeSet.getNoticeType());
-//        SysUser sysUser = sysUserService.selectUserById(Long.valueOf(location.getLocationLeader()));
+//        TInspector byId = inspectorService.getById(dto.getId());
+//        SysUser sysUser = sysUserService.selectUserById(Long.valueOf(task.getPatrolInspector()));
 //        // 邮箱
 //        TDictData email = dictDataService.lambdaQuery().eq(TDictData::getDataType,4).one();
 //        // 授权码
@@ -377,6 +379,10 @@
 //                        }
 //                        break;
 //                    case 3:
+//                        if (StringUtils.hasLength(sysUser.getOpenId())){
+//                            templateMessageSendUtil.wxTemplateProblemRectificationRequest(sysUser.getOpenId(),
+//                                    location.getLocationName(),dto.getAuditRemark());
+//                        }
 //                        break;
 //                }
 //            }else{
@@ -388,9 +394,112 @@
 //            }
 //        }
 //        dto.setAuditTime(LocalDateTime.now());
+//
 //        dto.setAuditPerson(tokenService.getLoginUser().getUserId()+"");
 //        inspectorService.updateById(dto);
 //        return R.ok();
+
+
+        SysUser auditPerson = sysUserService.selectUserById(tokenService.getLoginUser().getUserId());
+
+        TInspector byId = inspectorService.getById(dto.getId());
+
+        TTaskAuditDTO tTaskAuditDTO = new TTaskAuditDTO();
+        BeanUtils.copyProperties(dto, tTaskAuditDTO);
+        TLocation location = locationService.getById(byId.getLocationId());
+        TNotice tNotice = new TNotice();
+        TNoticeSet noticeSet = noticeSetService.lambdaQuery().eq(TNoticeSet::getType, 2).last("limit 1")
+                .one();
+        tNotice.setUserId(location.getLocationLeader());
+        tNotice.setStatus(1);
+        tNotice.setDataId(byId.getId());
+        tNotice.setNoticeSetType(noticeSet.getNoticeType());
+        SysUser sysUser = sysUserService.selectUserById(Long.valueOf(location.getLocationLeader()));
+        // 邮箱
+        TDictData email = dictDataService.lambdaQuery().eq(TDictData::getDataType, 4).one();
+        // 授权码
+        TDictData code = dictDataService.lambdaQuery().eq(TDictData::getDataType, 5).one();
+        TInspectorDetail one = inspectorDetailService.lambdaQuery().eq(TInspectorDetail::getInspectorId, byId.getId())
+                .eq(TInspectorDetail::getHandleType, 1).orderByDesc(TInspectorDetail::getCreateTime)
+                .last("limit 1").one();
+        if (dto.getAuditStatus() == 1) {
+            TInspectorDetail tInspectorDetail = new TInspectorDetail();
+            tInspectorDetail.setInspectorId(byId.getId());
+            tInspectorDetail.setClearStatus(byId.getClearStatus());
+            tInspectorDetail.setUnqualified(byId.getUnqualified());
+            tInspectorDetail.setRemark(byId.getRemark());
+            tInspectorDetail.setPicture(byId.getPicture());
+            tInspectorDetail.setAudioUrl(byId.getAudioUrl());
+            tInspectorDetail.setHandleType(2);
+            tInspectorDetail.setAuditPerson(tokenService.getLoginUser().getUserId() + "");
+            tInspectorDetail.setAuditTime(LocalDateTime.now());
+            tInspectorDetail.setAuditRemark(dto.getAuditRemark());
+            tInspectorDetail.setAuditStatus(dto.getAuditStatus());
+            inspectorDetailService.save(tInspectorDetail);
+
+
+            Long count = inspectorDetailService.lambdaQuery().eq(TInspectorDetail::getInspectorId, byId.getId())
+                    .eq(TInspectorDetail::getHandleType, 1).count();
+
+            if (count>2){
+                dto.setStatus(3);
+            }else{
+                if (byId.getClearStatus() == 1) {
+                    dto.setStatus(4);
+                }else{
+                    dto.setStatus(3);
+                }
+            }
+        } else {
+            TInspectorDetail tInspectorDetail = new TInspectorDetail();
+            tInspectorDetail.setInspectorId(byId.getId());
+            tInspectorDetail.setClearStatus(dto.getClearStatus());
+            tInspectorDetail.setUnqualified(byId.getUnqualified());
+            tInspectorDetail.setRemark(dto.getAuditRemark());
+            tInspectorDetail.setPicture(byId.getPicture());
+            tInspectorDetail.setAudioUrl(byId.getAudioUrl());
+            tInspectorDetail.setHandleType(3);
+            tInspectorDetail.setAuditPerson(tokenService.getLoginUser().getUserId() + "");
+            tInspectorDetail.setAuditTime(LocalDateTime.now());
+            tInspectorDetail.setAuditRemark(dto.getAuditRemark());
+            tInspectorDetail.setAuditStatus(dto.getAuditStatus());
+            inspectorDetailService.save(tInspectorDetail);
+            tTaskAuditDTO.setHandleType(3);
+            dto.setStatus(2);
+            // 增加消息
+            tNotice.setNoticeType(8);
+            tNotice.setNoticeContent("【" + location.getLocationName() + "】督察任务不合格,请重新上传!");
+            noticeService.save(tNotice);
+            switch (noticeSet.getNoticeType()) {
+                case 1:
+                    msgUtils.sendMsg5(sysUser.getPhonenumber(), location.getLocationName());
+                    break;
+                case 2:
+                    if (StringUtils.hasLength(email.getDataContent()) && StringUtils.hasLength(code.getDataContent())
+                            &&StringUtils.hasLength(sysUser.getEmail())) {
+                        EmailUtils.sendEmail(sysUser.getEmail(), email.getDataContent(), code.getDataContent(), "【" + location.getLocationName() + "】任务督察不合格,请及时整改!");
+                    }
+                    break;
+                case 3:
+                    if (StringUtils.hasLength(sysUser.getOpenId())) {
+                        templateMessageSendUtil.wxTemplateTaskResultRequest(sysUser.getOpenId(),
+                                location.getLocationName(), "驳回", auditPerson.getNickName());
+                    }
+                    break;
+            }
+
+        }
+        dto.setAuditTime(LocalDateTime.now());
+        dto.setAuditPerson(tokenService.getLoginUser().getUserId() + "");
+        inspectorService.updateById(dto);
+        one.setAuditPerson(tokenService.getLoginUser().getUserId() + "");
+        one.setAuditTime(LocalDateTime.now());
+        one.setAuditRemark(dto.getAuditRemark());
+        one.setAuditStatus(dto.getAuditStatus());
+        inspectorDetailService.updateById(one);
+        return R.ok();
     }
+
+
 }
 

--
Gitblit v1.7.1