From b46065a201c09ce69f111806f2bda4a5f476bc4e Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期六, 18 十月 2025 17:20:22 +0800
Subject: [PATCH] fix:用户同步,机构同步

---
 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskServiceImpl.java |  244 ++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 231 insertions(+), 13 deletions(-)

diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskServiceImpl.java
index 386cf99..baaece3 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysTaskServiceImpl.java
@@ -1,5 +1,6 @@
 package com.ruoyi.system.service.impl;
 
+import java.math.BigDecimal;
 import java.util.Date;
 import java.util.List;
 import java.util.ArrayList;
@@ -21,6 +22,8 @@
 import com.ruoyi.system.domain.SysTaskVehicle;
 import com.ruoyi.system.domain.SysTaskAttachment;
 import com.ruoyi.system.domain.SysTaskLog;
+import com.ruoyi.system.domain.SysTaskEmergency;
+import com.ruoyi.system.domain.SysTaskWelfare;
 import com.ruoyi.system.domain.vo.TaskQueryVO;
 import com.ruoyi.system.domain.vo.TaskCreateVO;
 import com.ruoyi.system.domain.vo.TaskUpdateVO;
@@ -30,6 +33,8 @@
 import com.ruoyi.system.mapper.SysTaskVehicleMapper;
 import com.ruoyi.system.mapper.SysTaskAttachmentMapper;
 import com.ruoyi.system.mapper.SysTaskLogMapper;
+import com.ruoyi.system.mapper.SysTaskEmergencyMapper;
+import com.ruoyi.system.mapper.SysTaskWelfareMapper;
 import com.ruoyi.system.mapper.VehicleInfoMapper;
 import com.ruoyi.system.domain.VehicleInfo;
 import com.ruoyi.system.service.ISysTaskService;
@@ -56,6 +61,12 @@
     private SysTaskLogMapper sysTaskLogMapper;
     
     @Autowired
+    private SysTaskEmergencyMapper sysTaskEmergencyMapper;
+    
+    @Autowired
+    private SysTaskWelfareMapper sysTaskWelfareMapper;
+    
+    @Autowired
     private VehicleInfoMapper vehicleInfoMapper;
 
     /**
@@ -66,7 +77,20 @@
      */
     @Override
     public SysTask selectSysTaskByTaskId(Long taskId) {
-        return sysTaskMapper.selectSysTaskByTaskId(taskId);
+        SysTask task = sysTaskMapper.selectSysTaskByTaskId(taskId);
+        if (task != null) {
+            // 鍔犺浇鎬ユ晳杞繍鎵╁睍淇℃伅
+            if ("EMERGENCY_TRANSFER".equals(task.getTaskType())) {
+                SysTaskEmergency emergencyInfo = sysTaskEmergencyMapper.selectSysTaskEmergencyByTaskId(taskId);
+                task.setEmergencyInfo(emergencyInfo);
+            }
+            // 鍔犺浇绂忕杞︽墿灞曚俊鎭�
+            else if ("WELFARE".equals(task.getTaskType())) {
+                SysTaskWelfare welfareInfo = sysTaskWelfareMapper.selectSysTaskWelfareByTaskId(taskId);
+                task.setWelfareInfo(welfareInfo);
+            }
+        }
+        return task;
     }
 
     /**
@@ -94,12 +118,6 @@
         task.setTaskType(createVO.getTaskType());
         task.setTaskStatus(TaskStatus.PENDING.getCode());
         task.setTaskDescription(createVO.getTaskDescription());
-        task.setDepartureAddress(createVO.getDepartureAddress());
-        task.setDestinationAddress(createVO.getDestinationAddress());
-        task.setDepartureLongitude(createVO.getDepartureLongitude());
-        task.setDepartureLatitude(createVO.getDepartureLatitude());
-        task.setDestinationLongitude(createVO.getDestinationLongitude());
-        task.setDestinationLatitude(createVO.getDestinationLatitude());
         task.setPlannedStartTime(createVO.getPlannedStartTime());
         task.setPlannedEndTime(createVO.getPlannedEndTime());
         task.setAssigneeId(createVO.getAssigneeId());
@@ -112,8 +130,51 @@
         task.setRemark(createVO.getRemark());
         task.setDelFlag("0");
         
-        // 璁$畻棰勮鍏噷鏁�
-        calculateEstimatedDistance(task);
+        // 璁剧疆閫氱敤鍦板潃鍜屽潗鏍囦俊鎭�
+        if (createVO.getDepartureAddress() != null) {
+            task.setDepartureAddress(createVO.getDepartureAddress());
+        }
+        if (createVO.getDestinationAddress() != null) {
+            task.setDestinationAddress(createVO.getDestinationAddress());
+        }
+        if (createVO.getDepartureLongitude() != null) {
+            task.setDepartureLongitude(createVO.getDepartureLongitude());
+        }
+        if (createVO.getDepartureLatitude() != null) {
+            task.setDepartureLatitude(createVO.getDepartureLatitude());
+        }
+        if (createVO.getDestinationLongitude() != null) {
+            task.setDestinationLongitude(createVO.getDestinationLongitude());
+        }
+        if (createVO.getDestinationLatitude() != null) {
+            task.setDestinationLatitude(createVO.getDestinationLatitude());
+        }
+        if (createVO.getEstimatedDistance() != null) {
+            task.setEstimatedDistance(createVO.getEstimatedDistance());
+        }
+        
+        // 璁剧疆鎬ユ晳杞繍鐗瑰畾淇℃伅
+        if (createVO.getTransferTime() != null) {
+            task.setPlannedStartTime(createVO.getTransferTime());
+        }
+        if (createVO.getTransferDistance() != null) {
+            task.setEstimatedDistance(createVO.getTransferDistance());
+        }
+        
+        // 璁剧疆绂忕杞︾壒瀹氫俊鎭�
+        if (createVO.getServiceTime() != null) {
+            task.setPlannedStartTime(createVO.getServiceTime());
+        }
+        if (createVO.getStartAddress() != null) {
+            task.setDepartureAddress(createVO.getStartAddress());
+        }
+        if (createVO.getEndAddress() != null) {
+            task.setDestinationAddress(createVO.getEndAddress());
+        }
+        // 璁剧疆绂忕杞﹀叕閲屾暟
+        if (createVO.getDistance() != null) {
+            task.setEstimatedDistance(createVO.getDistance());
+        }
         
         int result = sysTaskMapper.insertSysTask(task);
         
@@ -133,6 +194,16 @@
                 
                 sysTaskVehicleMapper.insertSysTaskVehicle(taskVehicle);
             }
+        }
+        
+        // 淇濆瓨鎬ユ晳杞繍鎵╁睍淇℃伅
+        if (result > 0 && "EMERGENCY_TRANSFER".equals(createVO.getTaskType())) {
+            saveEmergencyInfo(task.getTaskId(), createVO);
+        }
+        
+        // 淇濆瓨绂忕杞︽墿灞曚俊鎭�
+        if (result > 0 && "WELFARE".equals(createVO.getTaskType())) {
+            saveWelfareInfo(task.getTaskId(), createVO);
         }
         
         // 璁板綍鎿嶄綔鏃ュ織
@@ -248,6 +319,21 @@
     @Override
     @Transactional
     public int changeTaskStatus(Long taskId, TaskStatus newStatus, String remark) {
+        return changeTaskStatusWithLocation(taskId, newStatus, remark, null);
+    }
+
+    /**
+     * 鍙樻洿浠诲姟鐘舵�侊紙鍚獹PS浣嶇疆淇℃伅锛�
+     * 
+     * @param taskId 浠诲姟ID
+     * @param newStatus 鏂扮姸鎬�
+     * @param remark 澶囨敞
+     * @param locationLog GPS浣嶇疆淇℃伅鏃ュ織瀵硅薄
+     * @return 缁撴灉
+     */
+    @Override
+    @Transactional
+    public int changeTaskStatusWithLocation(Long taskId, TaskStatus newStatus, String remark, SysTaskLog locationLog) {
         SysTask oldTask = sysTaskMapper.selectSysTaskByTaskId(taskId);
         if (oldTask == null) {
             throw new RuntimeException("浠诲姟涓嶅瓨鍦�");
@@ -266,20 +352,26 @@
         task.setUpdateTime(DateUtils.getNowDate());
         
         // 鏍规嵁鐘舵�佽缃浉搴旂殑鏃堕棿
-        if (newStatus == TaskStatus.IN_PROGRESS && oldTask.getActualStartTime() == null) {
+        if (newStatus == TaskStatus.DEPARTING && oldTask.getActualStartTime() == null) {
+            // 鍑哄彂涓細璁剧疆瀹為檯寮�濮嬫椂闂�
+            task.setActualStartTime(DateUtils.getNowDate());
+        } else if (newStatus == TaskStatus.IN_PROGRESS && oldTask.getActualStartTime() == null) {
+            // 鍏煎鏃ф暟鎹細浠诲姟涓姸鎬佷篃璁剧疆瀹為檯寮�濮嬫椂闂�
             task.setActualStartTime(DateUtils.getNowDate());
         } else if (newStatus == TaskStatus.COMPLETED) {
+            // 宸插畬鎴愶細璁剧疆瀹為檯缁撴潫鏃堕棿
             task.setActualEndTime(DateUtils.getNowDate());
         }
         
         int result = sysTaskMapper.updateTaskStatus(task);
         
-        // 璁板綍鎿嶄綔鏃ュ織
+        // 璁板綍鎿嶄綔鏃ュ織锛堝惈GPS浣嶇疆淇℃伅锛�
         if (result > 0) {
             recordTaskLog(taskId, "STATUS_CHANGE", "鐘舵�佸彉鏇�", 
                          "鐘舵�侊細" + oldTaskStatus.getInfo(), 
                          "鐘舵�侊細" + newStatus.getInfo() + "锛屽娉細" + remark, 
-                         SecurityUtils.getUserId(), SecurityUtils.getUsername());
+                         SecurityUtils.getUserId(), SecurityUtils.getUsername(),
+                         locationLog);
         }
         
         return result;
@@ -557,6 +649,16 @@
             task.setAttachments(sysTaskAttachmentMapper.selectSysTaskAttachmentByTaskId(taskId));
             // 鏌ヨ鎿嶄綔鏃ュ織
             task.setOperationLogs(sysTaskLogMapper.selectSysTaskLogByTaskId(taskId));
+            // 鍔犺浇鎬ユ晳杞繍鎵╁睍淇℃伅
+            if ("EMERGENCY_TRANSFER".equals(task.getTaskType())) {
+                SysTaskEmergency emergencyInfo = sysTaskEmergencyMapper.selectSysTaskEmergencyByTaskId(taskId);
+                task.setEmergencyInfo(emergencyInfo);
+            }
+            // 鍔犺浇绂忕杞︽墿灞曚俊鎭�
+            else if ("WELFARE".equals(task.getTaskType())) {
+                SysTaskWelfare welfareInfo = sysTaskWelfareMapper.selectSysTaskWelfareByTaskId(taskId);
+                task.setWelfareInfo(welfareInfo);
+            }
         }
         return task;
     }
@@ -586,7 +688,29 @@
      */
     private void recordTaskLog(Long taskId, String operationType, String operationDesc, 
                               String oldValue, String newValue, Long operatorId, String operatorName) {
-        SysTaskLog log = new SysTaskLog();
+        recordTaskLog(taskId, operationType, operationDesc, oldValue, newValue, 
+                     operatorId, operatorName, null);
+    }
+
+    /**
+     * 璁板綍浠诲姟鎿嶄綔鏃ュ織锛堝惈GPS浣嶇疆淇℃伅锛�
+     * 
+     * @param taskId 浠诲姟ID
+     * @param operationType 鎿嶄綔绫诲瀷
+     * @param operationDesc 鎿嶄綔鎻忚堪
+     * @param oldValue 鎿嶄綔鍓嶅��
+     * @param newValue 鎿嶄綔鍚庡��
+     * @param operatorId 鎿嶄綔浜篒D
+     * @param operatorName 鎿嶄綔浜哄鍚�
+     * @param log GPS浣嶇疆淇℃伅鏃ュ織瀵硅薄锛堝彲涓簄ull锛�
+     */
+    private void recordTaskLog(Long taskId, String operationType, String operationDesc, 
+                              String oldValue, String newValue, Long operatorId, String operatorName,
+                              SysTaskLog log) {
+        if (log == null) {
+            log = new SysTaskLog();
+        }
+        
         log.setTaskId(taskId);
         log.setOperationType(operationType);
         log.setOperationDesc(operationDesc);
@@ -664,4 +788,98 @@
             task.setEstimatedDistance(java.math.BigDecimal.ZERO);
         }
     }
+
+    /**
+     * 淇濆瓨鎬ユ晳杞繍浠诲姟鎵╁睍淇℃伅
+     * 
+     * @param taskId 浠诲姟ID
+     * @param createVO 浠诲姟鍒涘缓瀵硅薄
+     */
+    private void saveEmergencyInfo(Long taskId, TaskCreateVO createVO) {
+        SysTaskEmergency emergencyInfo = new SysTaskEmergency();
+        emergencyInfo.setTaskId(taskId);
+        
+        // 璁剧疆鎮h�呬俊鎭�
+        if (createVO.getPatient() != null) {
+            emergencyInfo.setPatientContact(createVO.getPatient().getContact());
+            emergencyInfo.setPatientPhone(createVO.getPatient().getPhone());
+            emergencyInfo.setPatientName(createVO.getPatient().getName());
+            emergencyInfo.setPatientGender(createVO.getPatient().getGender());
+            emergencyInfo.setPatientIdCard(createVO.getPatient().getIdCard());
+            emergencyInfo.setPatientCondition(createVO.getPatient().getCondition());
+        }
+        
+        // 璁剧疆杞嚭鍖婚櫌淇℃伅
+        if (createVO.getHospitalOut() != null) {
+            emergencyInfo.setHospitalOutName(createVO.getHospitalOut().getName());
+            emergencyInfo.setHospitalOutDepartment(createVO.getHospitalOut().getDepartment());
+            emergencyInfo.setHospitalOutBedNumber(createVO.getHospitalOut().getBedNumber());
+            emergencyInfo.setHospitalOutAddress(createVO.getHospitalOut().getAddress());
+            emergencyInfo.setHospitalOutLongitude(createVO.getHospitalOut().getLongitude());
+            emergencyInfo.setHospitalOutLatitude(createVO.getHospitalOut().getLatitude());
+        }
+        
+        // 璁剧疆杞叆鍖婚櫌淇℃伅
+        if (createVO.getHospitalIn() != null) {
+            emergencyInfo.setHospitalInName(createVO.getHospitalIn().getName());
+            emergencyInfo.setHospitalInDepartment(createVO.getHospitalIn().getDepartment());
+            emergencyInfo.setHospitalInBedNumber(createVO.getHospitalIn().getBedNumber());
+            emergencyInfo.setHospitalInAddress(createVO.getHospitalIn().getAddress());
+            emergencyInfo.setHospitalInLongitude(createVO.getHospitalIn().getLongitude());
+            emergencyInfo.setHospitalInLatitude(createVO.getHospitalIn().getLatitude());
+        }
+        
+        // 璁剧疆璐圭敤淇℃伅
+        emergencyInfo.setTransferDistance(createVO.getTransferDistance());
+        emergencyInfo.setTransferPrice(createVO.getPrice());
+        
+        // 绯荤粺瀛楁
+        emergencyInfo.setCreateTime(DateUtils.getNowDate());
+        emergencyInfo.setUpdateTime(DateUtils.getNowDate());
+        emergencyInfo.setCreateBy(SecurityUtils.getUsername());
+        emergencyInfo.setUpdateBy(SecurityUtils.getUsername());
+        
+        sysTaskEmergencyMapper.insertSysTaskEmergency(emergencyInfo);
+    }
+
+    /**
+     * 淇濆瓨绂忕杞︿换鍔℃墿灞曚俊鎭�
+     * 
+     * @param taskId 浠诲姟ID
+     * @param createVO 浠诲姟鍒涘缓瀵硅薄
+     */
+    private void saveWelfareInfo(Long taskId, TaskCreateVO createVO) {
+        SysTaskWelfare welfareInfo = new SysTaskWelfare();
+        welfareInfo.setTaskId(taskId);
+        
+        // 璁剧疆涔樺淇℃伅
+        if (createVO.getPassenger() != null) {
+            welfareInfo.setPassengerContact(createVO.getPassenger().getContact());
+            welfareInfo.setPassengerPhone(createVO.getPassenger().getPhone());
+        }
+        
+        // 璁剧疆鍦板潃淇℃伅
+        welfareInfo.setPickupAddress(createVO.getStartAddress());
+        welfareInfo.setDestinationAddress(createVO.getEndAddress());
+        
+        // 璁剧疆GPS鍧愭爣
+        welfareInfo.setPickupLongitude(createVO.getDepartureLongitude());
+        welfareInfo.setPickupLatitude(createVO.getDepartureLatitude());
+        welfareInfo.setDestinationLongitude(createVO.getDestinationLongitude());
+        welfareInfo.setDestinationLatitude(createVO.getDestinationLatitude());
+        
+        // 璁剧疆璺濈鍜岃垂鐢�
+        // 浼樺厛浣跨敤绂忕杞︿笓鐢ㄧ殑distance瀛楁锛屽鏋滄病鏈夊垯浣跨敤閫氱敤鐨別stimatedDistance
+        BigDecimal serviceDistance = createVO.getDistance() != null ? createVO.getDistance() : createVO.getEstimatedDistance();
+        welfareInfo.setServiceDistance(serviceDistance);
+        welfareInfo.setServicePrice(createVO.getPrice());
+        
+        // 绯荤粺瀛楁
+        welfareInfo.setCreateTime(DateUtils.getNowDate());
+        welfareInfo.setUpdateTime(DateUtils.getNowDate());
+        welfareInfo.setCreateBy(SecurityUtils.getUsername());
+        welfareInfo.setUpdateBy(SecurityUtils.getUsername());
+        
+        sysTaskWelfareMapper.insertSysTaskWelfare(welfareInfo);
+    }
 }

--
Gitblit v1.9.1