java/shehongcheliangjianguan.git

			@@ -7,6 +7,7 @@
			import com.ruoyi.dataInterchange.api.feignClient.PlaybackMsgClient;
			import com.ruoyi.dataInterchange.api.feignClient.RealVideoMsgClient;
			import com.ruoyi.dataInterchange.api.feignClient.UPExgMsgRealLocationClient;
			import com.ruoyi.dataInterchange.api.vo.GnssDataVo;
			import com.ruoyi.dataInterchange.api.vo.OrderTravelVo;
			import com.ruoyi.dataInterchange.api.vo.UPPlaybackMsgStartupAckVo;
			import com.ruoyi.dataInterchange.api.vo.UPRealvideoMsgStartupAckVo;
			@@ -19,18 +20,25 @@
			import com.ruoyi.system.service.ICarTypeService;
			import com.ruoyi.system.service.IDriverService;
			import com.ruoyi.system.service.IEnterpriseService;
			import com.ruoyi.system.util.JavaCVStreamUtil;
			import io.swagger.annotations.ApiImplicitParam;
			import io.swagger.annotations.ApiImplicitParams;
			import io.swagger.annotations.ApiOperation;
			import org.springframework.data.redis.core.RedisTemplate;
			import org.springframework.web.bind.annotation.GetMapping;
			import org.springframework.web.bind.annotation.PathVariable;
			import org.springframework.web.bind.annotation.RequestMapping;
			import org.springframework.web.bind.annotation.RestController;

			import javax.annotation.Resource;
			import java.math.BigDecimal;
			import java.time.LocalDateTime;
			import java.time.ZoneOffset;
			import java.util.List;
			import java.util.concurrent.ExecutorService;
			import java.util.concurrent.LinkedBlockingQueue;
			import java.util.concurrent.ThreadPoolExecutor;
			import java.util.concurrent.TimeUnit;

			/**
			* @author zhibing.pu
			@@ -40,27 +48,23 @@
			@RequestMapping("/car")
			public class CarController {

			private String outputUrl = "F:\\nginx 1.7.11.3 Gryphon\\html\\";
			@Resource
			private ICarService carService;

			@Resource
			private IDriverService driverService;

			@Resource
			private IEnterpriseService enterpriseService;

			@Resource
			private RealVideoMsgClient realVideoMsgClient;

			@Resource
			private PlaybackMsgClient playbackMsgClient;

			@Resource
			private UPExgMsgRealLocationClient upExgMsgRealLocationClient;

			@Resource
			private ICarTypeService carTypeService;

			@Resource
			private RedisTemplate redisTemplate;

			@GetMapping("/getCarList")
			@ApiOperation(value = "获取车辆列表", tags = {"车辆管理"})
			@@ -83,7 +87,11 @@
			Driver driver = driverService.getOne(new LambdaQueryWrapper<Driver>().eq(Driver::getVehicleNumber, car.getVehicleNumber()).eq(Driver::getStatus, 1));
			Enterprise enterprise = enterpriseService.getById(car.getEnterpriseId());
			car.setEnterpriseName(enterprise.getName());
			car.setDriverName(driver.getName());
			if (null != driver) {
			car.setDriverName(driver.getName());
			car.setDriverPhone(driver.getPhone());
			car.setDrivingLicenseNumber(driver.getDrivingLicenceFile());
			}
			return R.ok(car);
			}

			@@ -103,12 +111,37 @@
			if (200 == msgStartupAckVoR.getCode()) {
			UPRealvideoMsgStartupAckVo data = msgStartupAckVoR.getData();
			RealVideoResp resp = new RealVideoResp();
			resp.setServerIp(data.getServerIP());
			resp.setServerPort(data.getServerPort());
			String url = "rtmp://192.168.110.85:1935/flv-live/" + car.getVehicleNumber();
			//执行拉流和推流
			ExecutorService executorService = new ThreadPoolExecutor(1, 1,
			0L, TimeUnit.MILLISECONDS,
			new LinkedBlockingQueue<Runnable>());
			executorService.execute(new Runnable() {
			@Override
			public void run() {
			JavaCVStreamUtil.push_flv(data.getUrl(), url, id);
			}
			});
			resp.setUrl(url);
			return R.ok(resp);
			}

			return R.fail(msgStartupAckVoR.getMsg());
			}


			@GetMapping("/closeRealVideo/{id}")
			@ApiOperation(value = "关闭实时音视频", tags = {"车辆管理"})
			@ApiImplicitParams({
			@ApiImplicitParam(value = "车辆id", name = "id", required = true)
			})
			public R closeRealVideo(@PathVariable("id") Integer id){
			JavaCVStreamUtil.close(id);
			return R.ok();
			}





			@GetMapping("/getPlaybackVideo")
			@@ -124,8 +157,18 @@
			if (200 == startupAckVoR.getCode()) {
			UPPlaybackMsgStartupAckVo data = startupAckVoR.getData();
			RealVideoResp resp = new RealVideoResp();
			resp.setServerIp(data.getServerIP());
			resp.setServerPort(data.getServerPort());
			String url = "rtmp://192.168.110.85:1935/flv-live/" + car.getVehicleNumber();
			//执行拉流和推流
			ExecutorService executorService = new ThreadPoolExecutor(1, 1,
			0L, TimeUnit.MILLISECONDS,
			new LinkedBlockingQueue<Runnable>());
			executorService.execute(new Runnable() {
			@Override
			public void run() {
			JavaCVStreamUtil.push_flv(data.getUrl(), url, req.getId());
			}
			});
			resp.setUrl(url);
			return R.ok(resp);
			}
			return R.fail(startupAckVoR.getMsg());
			@@ -184,10 +227,10 @@
			@ApiOperation(value = "获取车辆状态汇总数据和公司总数等", tags = {"首页"})
			public R<CarStatusCount> getCarStatusCount() {
			List<Car> list = carService.list();
			long online = list.stream().filter(s -> s.getStatus() == 1).count();
			long offline = list.stream().filter(s -> s.getStatus() == 3).count();
			long breakdown = list.stream().filter(s -> s.getStatus() == 4).count();
			long abnormal = list.stream().filter(s -> s.getStatus() == 2).count();
			long online = list.isEmpty() ? 0 : list.stream().filter(s -> s.getStatus() == 1).count();
			long offline = list.isEmpty() ? 0 : list.stream().filter(s -> s.getStatus() == 3).count();
			long breakdown = list.isEmpty() ? 0 : list.stream().filter(s -> s.getStatus() == 4).count();
			long abnormal = list.isEmpty() ? 0 : list.stream().filter(s -> s.getStatus() == 2).count();
			CarStatusCount carStatusCount = new CarStatusCount();
			carStatusCount.setOffline(offline);
			carStatusCount.setOnline(online);
			@@ -201,4 +244,21 @@
			return R.ok(carStatusCount);
			}


			@GetMapping("/getMapCarList")
			@ApiOperation(value = "获取地图司机数据", tags = {"首页"})
			public R<List<Car>> getMapCarList() {
			List<Car> list = carService.list(new LambdaQueryWrapper<Car>().eq(Car::getStatus, 1));
			for (Car car : list) {
			Long s = (null == car.getDownlineTime() ? LocalDateTime.now() : car.getDownlineTime()).toEpochSecond(ZoneOffset.ofHours(8)) - car.getOnlineTime().toEpochSecond(ZoneOffset.ofHours(8));
			car.setDrivingTime(s / 60);
			GnssDataVo gnssDataVo = (GnssDataVo) redisTemplate.opsForValue().get("location:" + car.getVehicleNumber());
			if (null != gnssDataVo) {
			car.setLongitude(new BigDecimal(gnssDataVo.getLon()).divide(new BigDecimal(1000000)).toString());
			car.setLatitude(new BigDecimal(gnssDataVo.getLat()).divide(new BigDecimal(1000000)).toString());
			car.setSpeed(gnssDataVo.getVec1());
			}
			}
			return R.ok(list);
			}
			}