From a40e6a45b2207a9b172b7687ce6e4fe7da8b9ac6 Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期二, 03 十二月 2024 16:46:49 +0800
Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/funingyunwei

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwPatrolTaskRecordServiceImpl.java |   47 ++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 42 insertions(+), 5 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwPatrolTaskRecordServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwPatrolTaskRecordServiceImpl.java
index 2c6f8d7..6fb3725 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwPatrolTaskRecordServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwPatrolTaskRecordServiceImpl.java
@@ -9,8 +9,7 @@
 import com.doumee.core.utils.Constants;
 import com.doumee.core.utils.DateUtil;
 import com.doumee.core.utils.Utils;
-import com.doumee.dao.business.YwContractRevenueMapper;
-import com.doumee.dao.business.YwPatrolTaskRecordMapper;
+import com.doumee.dao.business.*;
 import com.doumee.dao.business.model.*;
 import com.doumee.dao.system.MultifileMapper;
 import com.doumee.dao.system.model.Multifile;
@@ -45,9 +44,17 @@
     @Autowired
     private MultifileMapper multifileMapper;
 
+    @Autowired
+    private YwDeviceMapper ywDeviceMapper;
+
+    @Autowired
+    private YwPatrolPointMapper ywPatrolPointMapper;
 
     @Autowired
     private SystemDictDataBiz systemDictDataBiz;
+
+    @Autowired
+    private YwPatrolTaskMapper ywPatrolTaskMapper;
 
 
 
@@ -117,9 +124,12 @@
         queryWrapper.selectAll(YwPatrolTaskRecord.class)
                 .selectAs(YwPatrolPoint::getName,YwPatrolTaskRecord::getPointName)
                 .selectAs(YwPatrolPoint::getContent,YwPatrolTaskRecord::getContent)
+                .selectAs(SystemUser::getRealname,YwPatrolTaskRecord::getRealname)
                 .leftJoin(YwPatrolPoint.class,YwPatrolPoint::getId,YwPatrolTaskRecord::getPointId)
                 .leftJoin(SystemUser.class,SystemUser::getId,YwPatrolTaskRecord::getDealUserId)
                 .eq(YwPatrolScheme::getIsdeleted, Constants.ZERO)
+                .eq(Objects.nonNull(model) && Objects.nonNull(model.getTaskId()),YwPatrolTaskRecord::getTaskId, model.getTaskId())
+                .eq(Objects.nonNull(model) && Objects.nonNull(model.getDealUserId()),YwPatrolTaskRecord::getDealUserId, model.getDealUserId())
                 .like(StringUtils.isNotBlank(model.getPointName()),YwPatrolPoint::getName,model.getPointName())
                 .eq(Objects.nonNull(model) && Objects.nonNull(model.getStatus()) , YwPatrolTaskRecord::getStatus,model.getStatus())
                 .orderByDesc(YwPatrolScheme::getCreateDate)
@@ -140,7 +150,7 @@
     public void patrolData(YwPatrolTaskRecord ywPatrolTaskRecord) {
         if(Objects.isNull(ywPatrolTaskRecord)
         || Objects.isNull(ywPatrolTaskRecord.getId())
-        || Objects.isNull(ywPatrolTaskRecord.getDealStatus())){
+        ){
             throw new BusinessException(ResponseStatus.BAD_REQUEST);
         }
         LoginUserInfo loginUserInfo = ywPatrolTaskRecord.getLoginUserInfo();
@@ -151,9 +161,23 @@
         if(!Constants.equalsInteger(model.getStatus(),Constants.ZERO)){
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏁版嵁鐘舵�佸凡娴佽浆");
         }
-
+        YwPatrolPoint ywPatrolPoint = ywPatrolPointMapper.selectById(model.getPointId());
+        if(Objects.isNull(ywPatrolPoint)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
+        YwDevice ywDevice = ywDeviceMapper.selectById(ywPatrolPoint.getDeviceId());
+        if(Objects.isNull(ywDevice)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
+        YwPatrolTask ywPatrolTask = ywPatrolTaskMapper.selectById(model.getTaskId());
+        if(Objects.isNull(ywPatrolTask)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
+        if(ywPatrolTask.getStartDate().getTime()>System.currentTimeMillis()){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈埌宸℃鏃堕棿鏃犳硶杩涜璇ユ搷浣�");
+        }
         ywPatrolTaskRecordMapper.update(null,new UpdateWrapper<YwPatrolTaskRecord>().lambda()
-                .set(YwPatrolTaskRecord::getDealStatus,ywPatrolTaskRecord.getDealStatus())
+                .set(YwPatrolTaskRecord::getDealStatus,ywDevice.getStatus())
                 .set(YwPatrolTaskRecord::getEditor,loginUserInfo.getId())
                 .set(YwPatrolTaskRecord::getEditDate, DateUtil.getCurrDateTime())
                 .set(YwPatrolTaskRecord::getDealDate, DateUtil.getCurrDateTime())
@@ -162,6 +186,19 @@
                 .set(YwPatrolTaskRecord::getDealInfo, ywPatrolTaskRecord.getDealInfo())
                 .eq(YwPatrolTaskRecord::getId,ywPatrolTaskRecord.getId()));
 
+        if(ywPatrolTaskRecordMapper.selectCount(new QueryWrapper<YwPatrolTaskRecord>().lambda()
+                .eq(YwPatrolTaskRecord::getTaskId,ywPatrolTask.getId())
+                .ne(YwPatrolTaskRecord::getId,ywPatrolTaskRecord.getId()))==Constants.ZERO){
+            ywPatrolTask.setStatus(Constants.THREE);
+        }else{
+            ywPatrolTask.setStatus(Constants.ONE);
+        }
+        //鏌ヨ鏄惁瀛樺湪鍏朵粬鏈�
+       ywPatrolTaskMapper.update(null,new UpdateWrapper<YwPatrolTask>().lambda().eq(YwPatrolTask::getId,ywPatrolTask.getId())
+               .set(YwPatrolTask::getStatus,ywPatrolTask.getStatus())
+               .set(YwPatrolTask::getEditDate,DateUtil.getCurrDateTime())
+               .set(YwPatrolTask::getEditor,loginUserInfo.getId())
+       );
         //闄勪欢鏁版嵁
         if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywPatrolTaskRecord.getMultifileList())){
             for (Multifile multifile:ywPatrolTaskRecord.getMultifileList()) {

--
Gitblit v1.9.3