From 7d81ce01560d384f15212edc40ebeaa9924913f9 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期日, 21 九月 2025 19:12:53 +0800
Subject: [PATCH] feat:新增评价功能

---
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/VehicleGpsController.java |  287 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 281 insertions(+), 6 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/VehicleGpsController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/VehicleGpsController.java
index f5116b2..5c3e134 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/VehicleGpsController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/VehicleGpsController.java
@@ -1,7 +1,11 @@
 package com.ruoyi.web.controller.system;
 
-import java.util.List;
+import java.util.*;
+import java.text.SimpleDateFormat;
+import java.text.ParseException;
 
+import com.ruoyi.system.domain.*;
+import com.ruoyi.system.service.*;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -18,8 +22,6 @@
 import com.ruoyi.common.core.controller.BaseController;
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.enums.BusinessType;
-import com.ruoyi.system.domain.VehicleGps;
-import com.ruoyi.system.service.IVehicleGpsService;
 import com.ruoyi.common.utils.poi.ExcelUtil;
 import com.ruoyi.common.core.page.TableDataInfo;
 
@@ -32,16 +34,123 @@
     @Autowired
     private IVehicleGpsService vehicleGpsService;
 
-    @Anonymous
-    /**
+    @Autowired
+    private ITbVehicleOrderService tbVehicleOrderService;
+
+    @Autowired
+    private IDispatchOrdService dispatchOrdService;
+
+    @Autowired
+    private ITbOrdersService tbOrdersService;
+
+    @Autowired
+    private IGpsCollectService gpsCollectService;
+
+    @Autowired
+    private IVehicleInfoService vehicleInfoService;
+
+    @Autowired
+    private ICmsGpsCollectService cmsGpsCollectService;
+
+   /**
      * 鏌ヨ杞﹁締GPS鍧愭爣鍒楄〃
-     */
+     */  
     @PreAuthorize("@ss.hasPermi('system:gps:list')")
     @GetMapping("/list")
     public TableDataInfo list(VehicleGps vehicleGps) {
+
         startPage();
+//        String vehicleNo=vehicleGps.getVehicleNo();
+//        String beginTime=vehicleGps.getBeginTime();
+//        String endTime=vehicleGps.getEndTime();
+//        return this.getAnonymousTracks(vehicleNo,beginTime,endTime);
+//
+//        // 璁剧疆鎸夋椂闂村�掑簭鎺掑簭
+        vehicleGps.setOrderByColumn("collect_time");
+        vehicleGps.setIsAsc("desc");
         List<VehicleGps> list = vehicleGpsService.selectVehicleGpsList(vehicleGps);
         return getDataTable(list);
+    }
+    @Anonymous(needSign=true)   
+    @GetMapping("/anonymousList")
+    public TableDataInfo anonymousList(VehicleGps vehicleGps) {
+
+        if(vehicleGps.getOrderId()==null)
+        {
+            return getDataTable(new ArrayList<>());
+        }
+
+        //鏌ヨ璁㈠崟
+        TbVehicleOrder tbVehicleOrder = tbVehicleOrderService.selectTbVehicleOrderById(vehicleGps.getOrderId());
+        if(tbVehicleOrder==null)
+        {
+            return getDataTable(new ArrayList<>());
+        }
+
+        if(!Objects.equals(tbVehicleOrder.getStatus(), "0"))
+        {
+            //闈�0琛ㄧず璁㈠崟瀹屾垚浜嗐��
+            try {
+                TbOrders tbOrders = tbOrdersService.selectTbOrdersByOrderID(vehicleGps.getOrderId());
+                if (tbOrders == null) {
+                    return getDataTable(new ArrayList<>());
+                }
+
+
+                DispatchOrd dispatchOrd = dispatchOrdService.selectDispatchOrdByServiceOrdIDDt(tbOrders.getServiceOrdID());
+                if (dispatchOrd == null) {
+                    return getDataTable(new ArrayList<>());
+                }
+
+                String vehicleNo = tbVehicleOrder.getVehicle();
+                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                String beginTime= sdf.format(dispatchOrd.getDispatchOrdStartDate());
+                String endTime=  sdf.format(dispatchOrd.getDispatchOrdUpdateTime());
+                //濡傛灉璁㈠崟娌″畬鎴愶紝 endTime涓哄綋鍓嶆椂闂达紱濡備綍璁㈠崟宸茬粡瀹屾垚浜嗭紝鐢ㄨ鍗曠殑缁撴潫鏃堕棿銆�
+
+                return this.getAnonymousTracks(vehicleNo,beginTime,endTime);
+//                Map<String, Object> params = new HashMap<>();
+//                params.put("beginTime", dispatchOrd.getDispatchOrdStartDate());
+//                params.put("endTime", dispatchOrd.getDispatchOrdUpdateTime());
+//
+//                vehicleGps.setVehicleNo(tbVehicleOrder.getVehicle());
+//                startPage();
+//                // 璁剧疆鎸夋椂闂村�掑簭鎺掑簭
+//                vehicleGps.setOrderByColumn("collect_time");
+//                vehicleGps.setIsAsc("desc");
+//                List<VehicleGps> list = vehicleGpsService.selectVehicleGpsList(vehicleGps);
+//                return getDataTable(list);
+            }
+            catch (Exception ex)
+            {
+                logger.error("宸插畬鎴愮殑璁㈠崟鏌ヨ鍦板浘寮傚父锛歿}",ex.getMessage());
+                return getDataTable(new ArrayList<>());
+            }
+        }else{
+            TbOrders tbOrders = tbOrdersService.selectTbOrdersByOrderID(vehicleGps.getOrderId());
+            if (tbOrders == null) {
+                return getDataTable(new ArrayList<>());
+            }
+            DispatchOrd dispatchOrd = dispatchOrdService.selectDispatchOrdByServiceOrdIDDt(tbOrders.getServiceOrdID());
+            if (dispatchOrd == null) {
+                return getDataTable(new ArrayList<>());
+            }
+            String vehicleNo = tbVehicleOrder.getVehicle();
+            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            String beginTime= sdf.format(dispatchOrd.getDispatchOrdStartDate());
+            String endTime=  sdf.format(new Date());
+
+            logger.info("鏌ヨ杞﹁締杞ㄨ抗锛氳溅杈嗗彿锛歿}, 寮�濮嬫椂闂达細{}, 缁撴潫鏃堕棿锛歿}", vehicleNo, beginTime, endTime);
+            return this.getAnonymousTracks(vehicleNo,beginTime,endTime);
+//
+//        vehicleGps.setVehicleNo(tbVehicleOrder.getVehicle());
+//        startPage();
+//        // 璁剧疆鎸夋椂闂村�掑簭鎺掑簭
+//        vehicleGps.setOrderByColumn("collect_time");
+//        vehicleGps.setIsAsc("desc");
+//        List<VehicleGps> list = vehicleGpsService.selectVehicleGpsList(vehicleGps);
+//        return getDataTable(list);
+        }
     }
 
     /**
@@ -51,6 +160,9 @@
     @Log(title = "杞﹁締GPS鍧愭爣", businessType = BusinessType.EXPORT)
     @GetMapping("/export")
     public AjaxResult export(VehicleGps vehicleGps) {
+        // 璁剧疆鎸夋椂闂村�掑簭鎺掑簭
+        vehicleGps.setOrderByColumn("collect_time");
+        vehicleGps.setIsAsc("desc");
         List<VehicleGps> list = vehicleGpsService.selectVehicleGpsList(vehicleGps);
         ExcelUtil<VehicleGps> util = new ExcelUtil<VehicleGps>(VehicleGps.class);
         return util.exportExcel(list, "杞﹁締GPS鍧愭爣鏁版嵁");
@@ -94,4 +206,167 @@
     public AjaxResult remove(@PathVariable Long[] gpsIds) {
         return toAjax(vehicleGpsService.deleteVehicleGpsByIds(gpsIds));
     }
+
+    /**
+     * 鏌ヨ杞﹁締鍘嗗彶杞ㄨ抗
+     */
+    @PreAuthorize("@ss.hasPermi('system:gps:query')")
+    @GetMapping("/tracks")
+    public TableDataInfo getTracks(String vehicleNo, String beginTime, String endTime) {
+        return getAnonymousTracks(vehicleNo, beginTime, endTime);
+    }
+
+   
+    /**
+     * 鍖垮悕鏌ヨ杞﹁締鍘嗗彶杞ㄨ抗
+     */
+    @Anonymous()
+    @GetMapping("/anonymousTracks")
+    public TableDataInfo getAnonymousTracks(String vehicleNo, String beginTime, String endTime) {
+        try {
+            // 閫氳繃杞︾墝鍙疯幏鍙栬澶嘔D
+            VehicleInfo vehicleInfo = vehicleInfoService.selectVehicleInfoByPlateNumber(vehicleNo);
+            if (vehicleInfo == null) {
+
+                // throw new Error("鏈壘鍒拌杞﹁締瀵瑰簲鐨凣PS璁惧");
+                return getDataTable(new ArrayList<>());
+            }
+
+            // 澶勭悊寮�濮嬫椂闂�
+                beginTime = beginTime.replace("T", " ");
+                if (beginTime.split(":").length == 2) { // 鍙湁灏忔椂鍜屽垎閽�
+                    beginTime += ":00";
+                }
+                
+                // 澶勭悊缁撴潫鏃堕棿
+//                endTime = endTime.replace("T", " ").replace(" ","%20");
+            endTime = endTime.replace("T", " ");
+                if (endTime.split(":").length == 2) { // 鍙湁灏忔椂鍜屽垎閽�
+                    endTime += ":59";
+                }
+
+            List<GpsTrackPoint> trackPoints = new ArrayList<>();
+
+            //濡傛灉骞冲彴鏄痗ms锛屽垯璋冪敤cms鐨勬帴鍙�
+            if(vehicleInfo.getPlatformCode().equals("CMS"))
+            {
+                
+                CmsTrackDetailResponse response = cmsGpsCollectService.queryTrackDetail(
+                    vehicleInfo.getDeviceId(),  // 璁惧鍙�
+                    beginTime,                  // 寮�濮嬫椂闂�
+                    endTime,                    // 缁撴潫鏃堕棿
+                    null,                       // 璺濈锛堝彲閫夛級
+                    null,                       // 鍋滆溅鏃堕暱锛堝彲閫夛級
+                    1,                          // 瑙f瀽鍦扮悊浣嶇疆
+                    null,                       // 褰撳墠椤电爜锛堝彲閫夛級
+                    null,                       // 姣忛〉璁板綍鏁帮紙鍙�夛級
+                    2                           // 鍦板浘绫诲瀷锛�2锛氱櫨搴﹀湴鍥撅級
+                );
+
+                if (response.getResult() != 0) {
+                    throw new Error("鏌ヨCMS杞ㄨ抗澶辫触");
+                }
+
+                // 杞崲CMS杞ㄨ抗鐐逛负缁熶竴鏍煎紡
+                if (response.getTracks() != null) {
+                    for (CmsTrackDetailResponse.CmsTrackPoint point : response.getTracks()) {
+                        GpsTrackPoint trackPoint = new GpsTrackPoint();
+                        trackPoint.setVehicleNo(point.getVid());
+                        trackPoint.setDeviceId(point.getId());
+                        
+                        //缁忓害绾害涓虹┖鏃讹紝璺宠繃
+                        if(point.getMlng()==null || point.getMlat()==null)
+                        {
+                            continue;
+                        }
+
+                        // 缁忓害锛屼娇鐢ㄤ笁鍏冭繍绠楃
+                        trackPoint.setLongitude(point.getMlng() != null ? Double.parseDouble(point.getMlng()) : 0.0);
+                        
+                        // 绾害锛屼娇鐢ㄤ笁鍏冭繍绠楃
+                        trackPoint.setLatitude(point.getMlat() != null ? Double.parseDouble(point.getMlat()) : 0.0);
+                        
+                        // 閫熷害锛岀洿鎺ヤ娇鐢╥nt杞琩ouble
+                        trackPoint.setSpeed(point.getSp() > 0 ? (double)point.getSp() : 0.0);
+                        
+                        // 鏂瑰悜锛屼娇鐢ㄤ笁鍏冭繍绠楃澶勭悊
+                        trackPoint.setCourse(point.getFt() > 0 ? point.getFt() : 0);
+                        
+                        // ACC鐘舵�侊紝浣跨敤涓夊厓杩愮畻绗﹀鐞�
+                        trackPoint.setAccStatus(point.getAc() > 0 ? point.getAc() : 0);
+                        
+                        // 鍦ㄧ嚎鐘舵�侊紝浣跨敤涓夊厓杩愮畻绗﹀鐞�
+                        trackPoint.setOnlineStatus(point.getNet() > 0 ? point.getNet() : 0);
+                        trackPoint.setAddress(point.getPs());
+                        
+                        // 涓婃姤鏃堕棿锛岀洿鎺ヤ娇鐢ㄥ瓧绗︿覆
+                        trackPoint.setReportTime(point.getGt() != null ? point.getGt() : new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+                        
+                        trackPoints.add(trackPoint);
+                    }
+                }
+            }
+            else {
+                
+                // 鏋勫缓鏌ヨ璇锋眰
+                GpsTrackQueryRequest request = new GpsTrackQueryRequest();
+                request.setDeviceid(vehicleInfo.getDeviceId());
+                request.setBegintime(beginTime);
+                request.setEndtime(endTime);
+                request.setTimezone(8); // 涓浗鏃跺尯
+
+                logger.info("鏌ヨ杞﹁締杞ㄨ抗锛氳溅杈嗗彿锛歿}, 璁惧ID锛歿}, 寮�濮嬫椂闂达細{}, 缁撴潫鏃堕棿锛歿}", vehicleNo, vehicleInfo.getDeviceId(), beginTime, endTime);
+                // 鏌ヨ杞ㄨ抗
+                GpsTrackQueryResponse response = gpsCollectService.queryTracks(request);
+                if (response.getStatus() != 0) {
+                    logger.error("鏌ヨ杞ㄨ抗澶辫触锛岀姸鎬佺爜锛歿}, 閿欒淇℃伅锛歿}", response.getStatus(), response.getCause());
+                    throw new Error("鏌ヨ杞ㄨ抗澶辫触锛�" + (response.getCause() != null ? response.getCause() : "鏈煡閿欒"));
+                }
+
+                // 杞崲GPS51杞ㄨ抗鐐逛负缁熶竴鏍煎紡
+                if (response.getRecords() != null) {
+                    for (GpsTrackPoint point : response.getRecords()) {
+                        GpsTrackPoint trackPoint = new GpsTrackPoint();
+                        trackPoint.setVehicleNo(vehicleNo);
+                        trackPoint.setDeviceId(vehicleInfo.getDeviceId());
+                        trackPoint.setLongitude(point.getLongitude());    // 缁忓害
+                        trackPoint.setLatitude(point.getLatitude());    // 绾害
+                        trackPoint.setSpeed(point.getSpeed());      // 閫熷害
+                        trackPoint.setCourse(point.getCourse());    // 鏂瑰悜
+                        trackPoint.setReportTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(point.getUpdatetime()))); // 涓婃姤鏃堕棿
+                        trackPoints.add(trackPoint);
+                    }
+                }
+            }
+            //杞崲鎴怢ist<VehicleGps> 
+            List<VehicleGps> vehicleGpsList = new ArrayList<>();
+            for(GpsTrackPoint trackPoint : trackPoints)
+            {
+                VehicleGps vehicleGps = new VehicleGps();
+                vehicleGps.setVehicleNo(trackPoint.getVehicleNo());
+                vehicleGps.setDeviceId(trackPoint.getDeviceId());
+                vehicleGps.setLongitude(trackPoint.getLongitude());
+                vehicleGps.setLatitude(trackPoint.getLatitude());
+                vehicleGps.setSpeed(trackPoint.getSpeed());
+                //鏂瑰悜
+                vehicleGps.setDirection(Double.valueOf(trackPoint.getCourse()));
+                //鍦板潃
+                vehicleGps.setAddress(trackPoint.getAddress());
+                vehicleGps.setCollectTime(trackPoint.getReportTime());
+                //GPS骞冲彴澶勭悊鏃堕棿
+                vehicleGps.setPlatformProcessTime(trackPoint.getReportTime());
+                vehicleGps.setDeviceReportTime(trackPoint.getReportTime());
+                vehicleGpsList.add(vehicleGps);
+            }
+            //鏃堕棿鍊掑簭鎺掑簭
+            vehicleGpsList.sort(Comparator.comparing(VehicleGps::getDeviceReportTime).reversed());
+            
+            //杩斿洖杞﹁締Gps鍒楄〃
+            return getDataTable(vehicleGpsList);
+            // return success(vehicleGpsList);
+        } catch (Exception e) {
+            logger.error("鏌ヨ杞﹁締杞ㄨ抗寮傚父", e);
+            throw new Error("鏌ヨ杞﹁締杞ㄨ抗澶辫触锛�" + e.getMessage());
+        }
+    }
 } 
\ No newline at end of file

--
Gitblit v1.9.1