From 7b5c93919a56a78d3f56cd536160771f737157cd Mon Sep 17 00:00:00 2001
From: Xiajijian <1176061145@qq.com>
Date: Thu, 05 Feb 2026 09:34:04 +0800
Subject: [PATCH] 1. 优化代码细节。

---
 ard-route/src/main/java/com/ard/route/service/impl/ArdRouteMissionServiceImpl.java |   44 ++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 42 insertions(+), 2 deletions(-)

diff --git a/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteMissionServiceImpl.java b/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteMissionServiceImpl.java
index ea5facc..e23626c 100644
--- a/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteMissionServiceImpl.java
+++ b/ard-route/src/main/java/com/ard/route/service/impl/ArdRouteMissionServiceImpl.java
@@ -1,17 +1,23 @@
 package com.ard.route.service.impl;
 
 import java.util.List;
+
+import com.alibaba.fastjson2.JSON;
+import com.ard.common.core.domain.entity.SysUser;
 import com.ard.common.utils.DateUtils;
+import com.ard.common.utils.SecurityUtils;
 import com.ard.common.utils.uuid.IdUtils;
 import com.ard.route.domain.route.ArdRouteMission;
 import com.ard.route.domain.route.ArdRoutePoint;
 import com.ard.route.mapper.ArdRoutePointMapper;
+import com.ard.route.websocket.utils.MiWebSocketUtils;
+import com.ard.system.mapper.SysUserMapper;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.ard.route.mapper.ArdRouteMissionMapper;
 import com.ard.route.service.IArdRouteMissionService;
 
-import static com.ard.common.utils.SecurityUtils.getUsername;
 
 /**
  * 航线任务Service业务层处理
@@ -20,6 +26,7 @@
  * @date 2026-01-20
  */
 @Service
+@Slf4j
 public class ArdRouteMissionServiceImpl implements IArdRouteMissionService {
 
     @Autowired
@@ -27,6 +34,9 @@
 
     @Autowired
     private ArdRoutePointMapper ardRoutePointMapper;
+
+    @Autowired
+    private SysUserMapper sysUserMapper;
 
     /**
      * 查询航线任务
@@ -70,8 +80,16 @@
     public int insertArdRouteMission(ArdRouteMission ardRouteMission) {
         ardRouteMission.setId(IdUtils.simpleUUID());
         ardRouteMission.setExecuteStatus("0");
+        ardRouteMission.setIsRead("0");
         ardRouteMission.setCreateTime(DateUtils.getNowDate());
+        ardRouteMission.setIssuerName(getUserName(ardRouteMission.getIssuerId()));
         dataProcessingRoutePoint(ardRouteMission.getMissionDetailList(),ardRouteMission.getId());
+        try {
+            log.debug("给用户{}定时推送,航线任务信息", ardRouteMission.getIssuerName());
+            MiWebSocketUtils.sendMessage(ardRouteMission.getIssuerId(),JSON.toJSONString(ardRouteMission));
+        } catch (Exception e) {
+            log.error("Error sending message to session {}", ardRouteMission.getIssuerName(), e);
+        }
         return ardRouteMissionMapper.insertArdRouteMission(ardRouteMission);
     }
 
@@ -84,11 +102,18 @@
     @Override
     public int updateArdRouteMission(ArdRouteMission ardRouteMission) {
         ardRouteMission.setUpdateTime(DateUtils.getNowDate());
+        ardRouteMission.setIssuerName(getUserName(ardRouteMission.getIssuerId()));
         // 删除航线任务航点
         ardRoutePointMapper.deleteArdRoutePointByMissionId(ardRouteMission.getId());
         // 重新插入航线任务航点
         dataProcessingRoutePoint(ardRouteMission.getMissionDetailList(),ardRouteMission.getId());
         return ardRouteMissionMapper.updateArdRouteMission(ardRouteMission);
+    }
+
+    // 获取用户名称
+    private String getUserName(Long userId) {
+        SysUser sysUser = sysUserMapper.selectUserById(userId);
+        return sysUser.getUserName();
     }
 
     /**
@@ -109,6 +134,8 @@
      */
     @Override
     public int deleteArdRouteMissionByIds(String[] ids) {
+        // 删除航线任务航点
+        ardRoutePointMapper.deleteArdRoutePointByMissionId(ids[0]);
         return ardRouteMissionMapper.deleteArdRouteMissionByIds(ids);
     }
 
@@ -120,6 +147,7 @@
      */
     @Override
     public int deleteArdRouteMissionById(String id) {
+        ardRoutePointMapper.deleteArdRoutePointByMissionId(id);
         return ardRouteMissionMapper.deleteArdRouteMissionById(id);
     }
 
@@ -135,10 +163,22 @@
         ArdRouteMission ardRouteMission = new ArdRouteMission();
         ardRouteMission.setId(id);
         ardRouteMission.setExecuteStatus(status);
-        ardRouteMission.setExecuteBy(getUsername());
+        ardRouteMission.setExecuteName(SecurityUtils.getUsername());
         ardRouteMission.setExecuteTime(DateUtils.getNowDate());
         ardRouteMission.setUpdateTime(DateUtils.getNowDate());
         return ardRouteMissionMapper.updateArdRouteMission(ardRouteMission);
     }
 
+    /**
+     * 批量修改航线任务已读状态
+     *
+     * @param ids 主键集合
+     * @param isRead 已读状态
+     * @return 结果
+     */
+    @Override
+    public int updateIsRead(String[] ids, String isRead) {
+        return ardRouteMissionMapper.updateIsRead(ids,isRead);
+    }
+
 }

--
Gitblit v1.9.3