wlzboy
2025-12-06 847a7773ef1a8ad418c6934d35b5f205a97c04d0
ruoyi-admin/src/main/java/com/ruoyi/web/controller/task/SysTaskController.java
@@ -1,7 +1,11 @@
package com.ruoyi.web.controller.task;
import java.util.List;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import com.ruoyi.system.service.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
@@ -16,6 +20,8 @@
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.core.domain.entity.SysDept;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.system.domain.SysTask;
import com.ruoyi.system.domain.SysTaskLog;
@@ -25,10 +31,9 @@
import com.ruoyi.system.domain.vo.TaskUpdateVO;
import com.ruoyi.system.domain.vo.TaskStatisticsVO;
import com.ruoyi.system.domain.enums.TaskStatus;
import com.ruoyi.system.service.ISysTaskService;
import com.ruoyi.system.service.IVehicleInfoService;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.utils.StringUtils;
/**
 * 任务管理Controller
@@ -45,6 +50,17 @@
    
    @Autowired
    private IVehicleInfoService vehicleInfoService;
    @Autowired
    private ISysUserService userService;
    @Autowired
    private ISysDeptService deptService;
    @Autowired
    @Qualifier("tiandituMapService")
    private IMapService mapService;
    /**
     * 查询任务管理列表(后台管理端)
@@ -60,21 +76,52 @@
    /**
     * 查询任务列表(APP端)
     * 仅显示当前用户相关的任务:
     * 1. 当前用户所在机构的任务
     * 2. 当前用户创建的任务
     * 3. 分配给当前用户的任务
     * 根据用户权限返回不同范围的任务:
     * 1. 有查看所有咨询单权限(canViewAllConsult='1'):返回该用户管理所有分公司下的所有任务单
     * 2. 无权限(canViewAllConsult='0'):只返回分配给该用户的单或该用户创建的单
     */
    @GetMapping("/list")
    public TableDataInfo appList(TaskQueryVO queryVO) {
        // 在后端自动获取当前用户信息,实现综合查询
        // 获取当前用户信息
        Long currentUserId = getUserId();
        Long currentDeptId = getDeptId();
        SysUser currentUser = userService.selectUserById(currentUserId);
        
        // APP端强制使用当前登录用户信息进行过滤
        queryVO.setDeptId(currentDeptId);
        queryVO.setCreatorId(currentUserId);
        queryVO.setAssigneeId(currentUserId);
        if (currentUser == null) {
            return getDataTable(new java.util.ArrayList<>());
        }
        // 判断用户是否有查看所有咨询单的权限
        String canViewAllConsult = currentUser.getCanViewAllConsult();
        if ("1".equals(canViewAllConsult)) {
            // 有权限:返回该用户管理所有分公司下的所有任务单
            // 1. 获取用户管理的分公司列表
            List<SysDept> branchCompanies = deptService.computeBranchCompaniesForUser(currentUser);
            if (branchCompanies != null && !branchCompanies.isEmpty()) {
                // 2. 提取所有分公司ID
                List<Long> deptIds = new java.util.ArrayList<>();
                for (SysDept dept : branchCompanies) {
                    deptIds.add(dept.getDeptId());
                }
                // 3. 设置查询条件为分公司ID列表(SQL会自动包含所有子部门)
                queryVO.setDeptIds(deptIds);
                // 清空创建人和执行人过滤条件,返回这些分公司下的所有任务
                queryVO.setCreatorId(null);
                queryVO.setAssigneeId(null);
            } else {
                // 如果没有找到分公司,返回空列表
                return getDataTable(new java.util.ArrayList<>());
            }
        } else {
            // 无权限:只返回分配给该用户的单或该用户创建的单
            // 清空deptId和deptIds,使用creatorId和assigneeId进行OR查询
            queryVO.setDeptId(null);
            queryVO.setDeptIds(null);
            queryVO.setCreatorId(currentUserId);
            queryVO.setAssigneeId(currentUserId);
        }
        
        startPage();
        List<SysTask> list = sysTaskService.selectSysTaskList(queryVO);
@@ -214,6 +261,8 @@
        
        // 如果包含GPS位置信息,使用带位置的方法
        if (request.getLatitude() != null && request.getLongitude() != null) {
           String address= mapService.reverseGeocoding(request.getLongitude(), request.getLatitude());
           request.setLocationAddress(address);
            SysTaskLog locationLog = new SysTaskLog();
            locationLog.setLatitude(request.getLatitude());
            locationLog.setLongitude(request.getLongitude());
@@ -225,10 +274,10 @@
            locationLog.setAltitude(request.getAltitude());
            locationLog.setSpeed(request.getSpeed());
            locationLog.setHeading(request.getHeading());
            return toAjax(sysTaskService.changeTaskStatusWithLocation(taskId, newStatus, request.getRemark(), locationLog));
        }
        return toAjax(sysTaskService.changeTaskStatus(taskId, newStatus, request.getRemark()));
    }
@@ -290,6 +339,20 @@
    }
    /**
     * 检查任务是否可以出发(APP端)
     * 检查:
     * 1. 车辆是否有未完成的任务
     * 2. 执行人员是否有未完成的任务
     *
     * @param taskId 任务ID
     * @return 校验结果
     */
    @GetMapping("/{taskId}/check-depart")
    public AjaxResult checkTaskCanDepart(@PathVariable Long taskId) {
        return sysTaskService.checkTaskCanDepart(taskId);
    }
    /**
     * 分配任务请求对象
     */
    public static class AssignTaskRequest {