~liusuyi/ruoyi-api.git

			@@ -1,19 +1,23 @@
			package com.ruoyi.sy.controller;

			import java.io.UnsupportedEncodingException;
			import java.net.URLEncoder;
			import java.text.SimpleDateFormat;
			import java.util.*;
			import javax.annotation.PostConstruct;
			import javax.annotation.Resource;
			import javax.servlet.http.HttpServletRequest;
			import javax.servlet.http.HttpServletResponse;

			import com.alibaba.fastjson2.JSON;
			import com.ruoyi.common.core.domain.entity.SysUser;
			import com.ruoyi.common.utils.SecurityUtils;
			import com.ruoyi.common.utils.uuid.IdUtils;
			import com.ruoyi.sy.domain.ArdSyUser;
			import com.ruoyi.sy.gps31.PositionContainer;
			import com.ruoyi.sy.gps31.PushClientImplAlarm;
			import com.ruoyi.sy.gps31.PushClientImplPosition;
			import com.ruoyi.sy.service.IArdSyUserService;
			import com.ruoyi.system.domain.SysConfig;
			import com.ruoyi.common.core.domain.entity.SysConfig;
			import com.ruoyi.system.service.ISysConfigService;
			import com.ruoyi.system.service.ISysDeptService;
			import com.ruoyi.system.service.ISysUserService;
			@@ -33,8 +37,6 @@
			import com.ruoyi.sy.service.IArdSyCarService;
			import com.ruoyi.common.utils.poi.ExcelUtil;
			import com.ruoyi.common.core.page.TableDataInfo;
			import org.springframework.web.context.request.RequestContextHolder;
			import org.springframework.web.context.request.ServletRequestAttributes;
			import org.springframework.web.multipart.MultipartFile;

			/**
			@@ -89,6 +91,10 @@
			String ip = syURL.split(":")[1].replace("//", "");
			List<ArdSyUser> ardSyUserList = iArdSyUserService.selectSyUser();
			//车辆实时位置线程
			if(ardSyUserList.size()==0)
			{
			return;
			}
			PushClientImplPosition pushClientImplPosition = new PushClientImplPosition(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
			Thread pushClientImplPositionThread = new Thread(pushClientImplPosition);
			pushClientImplPositionThread.start();
			@@ -102,7 +108,6 @@
			}
			};
			carPositionTimer.scheduleAtFixedRate(carPositionTask,date,3*1000);//启用

			//车辆实时位置线程
			PushClientImplAlarm pushClientImplAlarm = new PushClientImplAlarm(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
			Thread pushClientImplAlarmThread = new Thread(pushClientImplAlarm);
			@@ -210,7 +215,7 @@
			/**
			* 获取未挂接权限的三一车辆
			*/
			@PreAuthorize("@ss.hasPermi('sy:syCar:getArdSyCarNoRight')")
			// @PreAuthorize("@ss.hasPermi('sy:syCar:getArdSyCarNoRight')")
			@PostMapping("/getArdSyCarNoRight")
			@ApiOperation("获取未挂接权限的三一车辆")
			public Map<String,Object> getArdSyCarNoRight(){
			@@ -228,7 +233,7 @@
			/**
			* 获取全部的三一车辆
			*/
			@PreAuthorize("@ss.hasPermi('sy:syCar:getArdSyCarAll')")
			// @PreAuthorize("@ss.hasPermi('sy:syCar:getArdSyCarAll')")
			@PostMapping("/getArdSyCarAll")
			@ApiOperation("获取全部的三一车辆")
			public Map<String,Object> getArdSyCarAll(){
			@@ -246,7 +251,7 @@
			/**
			* 获取全部车辆模型
			*/
			@PreAuthorize("@ss.hasPermi('sy:syCar:getAllCarModel')")
			// @PreAuthorize("@ss.hasPermi('sy:syCar:getAllCarModel')")
			@PostMapping("/getAllCarModel")
			@ApiOperation("获取全部车辆模型")
			public Map<String,Object> getAllCarModel(){
			@@ -280,7 +285,11 @@
			String usersId = SecurityUtils.getUserId();
			ArdSyUser ardSyUser = iArdSyUserService.userById(usersId);
			String syURL = sysConfigService.getSYURL();
			return ardSyCarService.allListByUser(ardSyUser,syURL,usersId);
			//根据userId查询部门Id
			SysUser sysUser = sysUserService.selectUserById(usersId);
			//根据当前deptId或者当前及所属下级的所有deptId
			List<Long> deptList = sysDeptService.deptIdBySub(sysUser.getDeptId());
			return ardSyCarService.allListByUser(ardSyUser,syURL,usersId,deptList);
			}

			@PreAuthorize("@ss.hasPermi('sy:syCar:carList')")
			@@ -295,6 +304,9 @@
			if(ardSyUser!=null) {
			//查询出31的车辆数据
			List<Map<String,String>> list = ardSyCarService.getCarList(ardSyUser,syURL,usersId,teamId);
			if(list.isEmpty()){
			return Results.succeed(new ArrayList());
			}
			//根据userId查询部门Id
			SysUser sysUser = sysUserService.selectUserById(usersId);
			//根据当前deptId或者当前及所属下级的所有deptId
			@@ -306,7 +318,7 @@
			}
			}

			@PreAuthorize("@ss.hasPermi('sy:syCar:carListById')")
			// @PreAuthorize("@ss.hasPermi('sy:syCar:carListById')")
			@PostMapping("/carListById/{id}")
			@ApiOperation("根据车辆ID获取车辆列表")
			public Results carListById(@PathVariable String id){
			@@ -326,9 +338,136 @@
			@PreAuthorize("@ss.hasPermi('sy:syCar:getArdSyUserByUsersId')")
			@PostMapping("getArdSyUserByUsersId")
			@ApiOperation("获取三一平台对应用户名密码")
			public Results getArdSyUserByUsersId(@RequestBody Map<String,String> map) {
			public Results getArdSyUserByUsersId() {
			String usersId = SecurityUtils.getUserId();
			ArdSyUser ardSyUser = iArdSyUserService.userById(usersId);
			return Results.succeed(ardSyUser);
			Map<String,Object> map = new HashMap<>();
			if(ardSyUser==null){
			return Results.succeed();
			}else {
			map.put("userId",ardSyUser.getUserId());
			map.put("password",ardSyUser.getPassword());
			map.put("passwords",DigestUtils.md5Hex(ardSyUser.getPassword()));
			}
			return Results.succeed(map);
			}

			@PreAuthorize("@ss.hasPermi('sy:syCar:getSDKCarPositionByRight')")
			@PostMapping("getSDKCarPositionByRight")
			@ApiOperation("获取部门权限下所有车辆位置")
			public Results getSDKCarPositionByRight(){
			String usersId = SecurityUtils.getUserId();
			//根据userId查询部门Id
			SysUser sysUser = sysUserService.selectUserById(usersId);
			Map<String, Map<String,Map<String,Object>>> deptPositionMap = PositionContainer.getDeptPositionMap();
			if(deptPositionMap.isEmpty()){
			return Results.succeed();
			}else {
			// return Results.succeed(deptPositionMap.get(sysUser.getDeptId().toString()).get(map.get("carId")));
			return Results.succeed(deptPositionMap.get(sysUser.getDeptId().toString()));
			}
			}

			@PreAuthorize("@ss.hasPermi('sy:syCar:getCarNearPositionByCarId')")
			@PostMapping("getCarNearPositionByCarId")
			@ApiOperation("获取单个车辆位置")
			public Results getCarNearPositionByCarId(@RequestBody Map<String,String> map){
			String usersId = SecurityUtils.getUserId();
			ArdSyUser ardSyUser = iArdSyUserService.userById(usersId);
			String carId = map.get("carId");
			String syURL = sysConfigService.getSYURL();
			return Results.succeed(ardSyCarService.getCarGPSBycarId(usersId,carId,syURL,ardSyUser));
			}

			@PreAuthorize("@ss.hasPermi('sy:syCar:chaseCarByCarId')")
			@PostMapping("chaseCarByCarId")
			@ApiOperation("根据车辆主键追踪车辆")
			public Results chaseCarByCarId(@RequestBody Map<String,String> map){
			String usersId = SecurityUtils.getUserId();
			String carId = map.get("carId");
			String cycle = map.get("cycle");
			return ardSyCarService.chaseCarByCarId(usersId,carId,cycle);
			}

			@PreAuthorize("@ss.hasPermi('sy:syCar:getExistTraceByCarIdAndMonth')")
			@PostMapping("getExistTraceByCarIdAndMonth")
			@ApiOperation("根据车辆主键及月份查询轨迹存在")
			public Results getExistTraceByCarIdAndMonth(@RequestBody Map<String,String> map){
			String userId = SecurityUtils.getUserId();
			String carId = map.get("carId");
			String time = map.get("time");
			return ardSyCarService.getExistTraceByCarIdAndMonth(userId,carId,time);
			}

			@GetMapping("getCarPicture")
			@ApiOperation("清淤获取照片")
			public AjaxResult getCarNearPositionByCarId(String carId) throws UnsupportedEncodingException {
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
			Date currentTime = new Date();
			long tenSeconds = 1000L;
			Date beforeTenSeconds = new Date(currentTime.getTime() - tenSeconds);
			String startTime = sdf.format(beforeTenSeconds);
			String usersId = SecurityUtils.getUserId();
			ArdSyUser ardSyUser = iArdSyUserService.userById(usersId);
			String syURL = sysConfigService.getSYURL();
			String sessionId = ardSyCarService.getSessionId(syURL,ardSyUser);
			System.out.println("sessionId:"+sessionId);
			//获取摄像通道信息
			Map<String, Object> result = ardSyCarService.getCarPicture(carId,syURL,sessionId);
			String vs = "";
			try {
			//提取通道信息
			Map<String,Object> map = ((List<Map<String,Object>>)result.get("list")).get(0);
			Map<String, Object> videos = (Map<String, Object>) JSON.parse((String) map.get("videos"));
			System.out.println("通道："+videos);
			vs = (String) videos.get("vs");
			} catch (Exception e) {
			return AjaxResult.error("该车辆没有摄像通道无照片数据！");
			}
			//筛选通道信息
			String[] vsArray = vs.split(",");
			List<String> channelList = new ArrayList<>();
			for (int i = 0; i < vsArray.length; i++) {
			channelList.add(vsArray[i].substring(0,1));
			}
			//拍照
			Map<String,Object> sendCmdMap = ardSyCarService.sendCmd(ardSyUser.getUserId(),syURL,sessionId,carId,channelList);
			System.out.println("拍照："+sendCmdMap);
			//获取照片
			Map<String,Object> photoMap = ardSyCarService.getPhoto(syURL,carId,sessionId,startTime);
			System.out.println("获取照片："+photoMap);
			return AjaxResult.success(photoMap);
			}

			@GetMapping("getVideo")
			@ApiOperation("清淤获取视频")
			public AjaxResult getVideo(String carId){
			String usersId = SecurityUtils.getUserId();
			ArdSyUser ardSyUser = iArdSyUserService.userById(usersId);
			String syURL = sysConfigService.getSYURL();
			Map<String,Object> video = ardSyCarService.getVideo(syURL,carId,ardSyUser);
			return AjaxResult.success(video);
			}

			@GetMapping("getThreeOne")
			@ApiOperation("获取三一视频地址")
			public AjaxResult getThreeOne() {
			return AjaxResult.success("获取地址成功！",sysConfigService.selectConfigByKey("threeOneVideo"));
			}

			@PreAuthorize("@ss.hasPermi('sy:syCar:getAlarmHPfmCountDetail')")
			@PostMapping("getAlarmHPfmCountDetail")
			@ApiOperation("根据车辆和时间段查询报警历史记录详情")
			public AjaxResult getAlarmHPfmCountDetail(@RequestBody Map<String,String> map){
			String usersId = SecurityUtils.getUserId();
			ArdSyUser ardSyUser = iArdSyUserService.userById(usersId);
			String carId = map.get("carId");
			String startTime = map.get("startTime");
			String endTime = map.get("endTime");
			String syURL = sysConfigService.getSYURL();
			String sessionId = ardSyCarService.getSessionId(syURL,ardSyUser);
			Map<String, Object> mapDetail = ardSyCarService.getAlarmHPfmCountDetail(sessionId,usersId,carId,startTime,endTime,syURL);
			return AjaxResult.success(mapDetail);
			}

			}