suojin
/
yt-bus-live
22
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

code submit

Browse Source
master
liuqingkun 3 years ago
parent 98c0039f8e
commit 326751c1dd
2 changed files with 410 additions and 390 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      README.md
  2. 798
      src/main/java/org/springblade/modules/business/controller/CommonApiController.java

2
README.md
Unescape View File

@ -1 +1 @@
### 体检预约项目 ### 慢直播项目

798
src/main/java/org/springblade/modules/business/controller/CommonApiController.java
Unescape View File

@ -1,5 +1,6 @@
package org.springblade.modules.business.controller; package org.springblade.modules.business.controller;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
@ -15,6 +16,8 @@ import org.springblade.core.tenant.annotation.TenantDS;
import org.springblade.core.tool.api.R; import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.Func; import org.springblade.core.tool.utils.Func;
import org.springblade.modules.business.entity.BusLine; import org.springblade.modules.business.entity.BusLine;
import org.springblade.modules.business.entity.CarAdmin;
import org.springblade.modules.business.service.ICarAdminService;
import org.springblade.modules.business.service.ICarInfoService; import org.springblade.modules.business.service.ICarInfoService;
import org.springblade.modules.business.service.IStationHintService; import org.springblade.modules.business.service.IStationHintService;
import org.springblade.modules.business.service.impl.PublishService; import org.springblade.modules.business.service.impl.PublishService;
@ -49,403 +52,420 @@ import java.util.concurrent.TimeUnit;
@Api(value = "公共接口", tags = "公共接口") @Api(value = "公共接口", tags = "公共接口")
public class CommonApiController extends BladeController { public class CommonApiController extends BladeController {
private final ICarInfoService carInfoService; private final ICarInfoService carInfoService;
private final RedisTemplate redisTemplate; private final RedisTemplate redisTemplate;
private final PublishService publishService; private final PublishService publishService;
private final CarInfoTask carInfoTask; private final CarInfoTask carInfoTask;
private final IStationHintService stationHintService; private final IStationHintService stationHintService;
private final IProBusLineImgService proBusLineImgService;
private final IProBusLineImgService proBusLineImgService;
private final ICarAdminService carAdminService;
/** /**
* 设置车牌号 * 设置车牌号
* *
* @return * @return
*/ */
@GetMapping("set-car-stat") @GetMapping("set-push-car-and-stat")
public R setCarStat(@RequestParam String carNo, @RequestParam String carStat) { public R setPushCarAndStat(@RequestParam String clientId, @RequestParam String carStat) {
redisTemplate.opsForValue().set("set-current-Facility-stat" + carNo, carStat); CarAdmin carAdmin = carAdminService.getOne(Wrappers.<CarAdmin>lambdaQuery().eq(CarAdmin::getReceiverId, clientId));
publishService.publishToWeb(carNo, carStat); String carNo = Func.isEmpty(carAdmin) ? "" : carAdmin.getName();
return R.status(true);
} redisTemplate.opsForValue().set("car-current-number", carNo);
redisTemplate.opsForValue().set("set-current-Facility-stat" + carNo, carStat);
/** publishService.publishToWeb(carNo, carStat);
* 设置车牌号 return R.status(true);
* }
* @return
*/ /**
@GetMapping("set-car-stat-v2") * 设置车牌号
public R setCarStatV2(@RequestParam String carNo, @RequestParam String carStat) { *
redisTemplate.opsForValue().set("car-current-stat" + carNo, carStat); * @return
return R.status(true); */
} @GetMapping("set-car-stat")
public R setCarStat(@RequestParam String carNo, @RequestParam String carStat) {
/** redisTemplate.opsForValue().set("set-current-Facility-stat" + carNo, carStat);
* 设置车牌号 publishService.publishToWeb(carNo, carStat);
* return R.status(true);
* @return }
*/
@GetMapping("set-car-no") /**
public R setCarNo(String carNo) { * 设置车牌号
redisTemplate.opsForValue().set("car-current-number", carNo); *
return R.status(true); * @return
} */
@GetMapping("set-car-stat-v2")
/** public R setCarStatV2(@RequestParam String carNo, @RequestParam String carStat) {
* 获取车牌号 redisTemplate.opsForValue().set("car-current-stat" + carNo, carStat);
* @return return R.status(true);
*/ }
@GetMapping("get-car-no")
public R getCarNo() { /**
String carNo = (String) redisTemplate.opsForValue().get("car-current-number"); * 设置车牌号
if (Func.isBlank(carNo)) { *
carNo = "鲁F08953D"; * @return
} */
@GetMapping("set-car-no")
return R.data(carNo); public R setCarNo(String carNo) {
} redisTemplate.opsForValue().set("car-current-number", carNo);
return R.status(true);
/** }
* 获取车速
* /**
* @param carNo 车牌号 * 获取车牌号
* @return *
*/ * @return
@GetMapping("get-car-speed") */
public R getCarSpeed(@RequestParam String carNo) { @GetMapping("get-car-no")
CarInfoVO info = carInfoService.getCarInfo(carNo); public R getCarNo() {
carInfoTask.getCarSpeed(carNo); String carNo = (String) redisTemplate.opsForValue().get("car-current-number");
if (Func.isEmpty(info)) { if (Func.isBlank(carNo)) {
return R.fail("未获取到车辆信息, 请检查车是否已掉线"); carNo = "鲁F08953D";
} }
return R.data(info.getSpeed()); return R.data(carNo);
} }
/** /**
* 获取早晚高峰时间 * 获取车速
* *
* @return * @param carNo 车牌号
*/ * @return
@GetMapping("get-rush-hour") */
public R getRushHour() { @GetMapping("get-car-speed")
List<Map<String, String>> rushHourList = new ArrayList<>(); public R getCarSpeed(@RequestParam String carNo) {
Map<String, String> morning = new ArrayMap<>(); CarInfoVO info = carInfoService.getCarInfo(carNo);
morning.put("name", "早高峰"); carInfoTask.getCarSpeed(carNo);
morning.put("starttime", "7:30"); if (Func.isEmpty(info)) {
morning.put("endtime", "8:30"); return R.fail("未获取到车辆信息, 请检查车是否已掉线");
rushHourList.add(morning); }
Map<String, String> evening = new ArrayMap<>(); return R.data(info.getSpeed());
evening.put("name", "晚高峰"); }
evening.put("starttime", "17:30");
evening.put("endtime", "18:30"); /**
rushHourList.add(evening); * 获取早晚高峰时间
*
return R.data(rushHourList); * @return
} */
@GetMapping("get-rush-hour")
/** public R getRushHour() {
* 获取站点列表 List<Map<String, String>> rushHourList = new ArrayList<>();
*/ Map<String, String> morning = new ArrayMap<>();
@GetMapping("/get-site") morning.put("name", "早高峰");
public R getSiteList(@RequestParam String carNo) { morning.put("starttime", "7:30");
CarInfoVO info = carInfoService.getCarInfo(carNo); morning.put("endtime", "8:30");
if (Func.isEmpty(info)) { rushHourList.add(morning);
return R.fail("未获取到车辆信息, 请检查车是否已掉线");
} Map<String, String> evening = new ArrayMap<>();
List<SiteInfoVO> siteList = SiteListCache.getSiteList(info.getLinename(), info.getUpordown()); evening.put("name", "晚高峰");
int nextSiteIdx = Integer.parseInt(info.getInorder()); evening.put("starttime", "17:30");
if (BusinessConstant.CAR_STAT_IN.toString().equals(info.getNowstate())) { evening.put("endtime", "18:30");
nextSiteIdx -= 1; rushHourList.add(evening);
}
return R.data(rushHourList);
// 下一站 }
List<Map<String, String>> snameList = new ArrayList<>();
SiteInfoVO nextSite = nextSiteIdx < siteList.size() ? siteList.get(nextSiteIdx) : null; /**
SiteInfoVO nextSite2 = (nextSiteIdx + 1) < siteList.size() ? siteList.get((nextSiteIdx) + 1) : null; * 获取站点列表
SiteInfoVO nextSite3 = (nextSiteIdx + 2) < siteList.size() ? siteList.get(nextSiteIdx + 2) : null; */
// 上一站 @GetMapping("/get-site")
SiteInfoVO preSite = nextSiteIdx - 1 > 0 ? siteList.get(nextSiteIdx - 1) : null; public R getSiteList(@RequestParam String carNo) {
// 上两站 CarInfoVO info = carInfoService.getCarInfo(carNo);
SiteInfoVO preTwoSite = nextSiteIdx - 2 > 0 ? siteList.get(nextSiteIdx - 2) : null; if (Func.isEmpty(info)) {
// 上三站 return R.fail("未获取到车辆信息, 请检查车是否已掉线");
SiteInfoVO preThreeSite = nextSiteIdx - 3 > 0 ? siteList.get(nextSiteIdx - 3) : null; }
List<SiteInfoVO> siteList = SiteListCache.getSiteList(info.getLinename(), info.getUpordown());
Map<String, String> siteMsgMap; int nextSiteIdx = Integer.parseInt(info.getInorder());
if (Func.isNotEmpty(preThreeSite)) { if (BusinessConstant.CAR_STAT_IN.toString().equals(info.getNowstate())) {
siteMsgMap = new HashMap<>(); nextSiteIdx -= 1;
siteMsgMap.put("siteName", preThreeSite.getSname()); }
siteMsgMap.put("type", "before");
snameList.add(siteMsgMap); // 下一站
} List<Map<String, String>> snameList = new ArrayList<>();
if (Func.isNotEmpty(preTwoSite)) { SiteInfoVO nextSite = nextSiteIdx < siteList.size() ? siteList.get(nextSiteIdx) : null;
siteMsgMap = new HashMap<>(); SiteInfoVO nextSite2 = (nextSiteIdx + 1) < siteList.size() ? siteList.get((nextSiteIdx) + 1) : null;
siteMsgMap.put("siteName", preTwoSite.getSname()); SiteInfoVO nextSite3 = (nextSiteIdx + 2) < siteList.size() ? siteList.get(nextSiteIdx + 2) : null;
siteMsgMap.put("type", "before"); // 上一站
snameList.add(siteMsgMap); SiteInfoVO preSite = nextSiteIdx - 1 > 0 ? siteList.get(nextSiteIdx - 1) : null;
} // 上两站
if (Func.isNotEmpty(preSite)) { SiteInfoVO preTwoSite = nextSiteIdx - 2 > 0 ? siteList.get(nextSiteIdx - 2) : null;
siteMsgMap = new HashMap<>(); // 上三站
siteMsgMap.put("siteName", preSite.getSname()); SiteInfoVO preThreeSite = nextSiteIdx - 3 > 0 ? siteList.get(nextSiteIdx - 3) : null;
siteMsgMap.put("type", "before");
snameList.add(siteMsgMap); Map<String, String> siteMsgMap;
} if (Func.isNotEmpty(preThreeSite)) {
if (Func.isNotEmpty(nextSite)) { siteMsgMap = new HashMap<>();
siteMsgMap = new HashMap<>(); siteMsgMap.put("siteName", preThreeSite.getSname());
siteMsgMap.put("siteName", nextSite.getSname()); siteMsgMap.put("type", "before");
siteMsgMap.put("type", "after"); snameList.add(siteMsgMap);
snameList.add(siteMsgMap); }
} if (Func.isNotEmpty(preTwoSite)) {
if (Func.isNotEmpty(nextSite2)) { siteMsgMap = new HashMap<>();
siteMsgMap = new HashMap<>(); siteMsgMap.put("siteName", preTwoSite.getSname());
siteMsgMap.put("siteName", nextSite2.getSname()); siteMsgMap.put("type", "before");
siteMsgMap.put("type", "after"); snameList.add(siteMsgMap);
snameList.add(siteMsgMap); }
} if (Func.isNotEmpty(preSite)) {
siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", preSite.getSname());
siteMsgMap.put("type", "before");
snameList.add(siteMsgMap);
}
if (Func.isNotEmpty(nextSite)) {
siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", nextSite.getSname());
siteMsgMap.put("type", "after");
snameList.add(siteMsgMap);
}
if (Func.isNotEmpty(nextSite2)) {
siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", nextSite2.getSname());
siteMsgMap.put("type", "after");
snameList.add(siteMsgMap);
}
// if (Func.isNotEmpty(nextSite3)) { // if (Func.isNotEmpty(nextSite3)) {
// snameList.add(nextSite3.getSname()); // snameList.add(nextSite3.getSname());
// } // }
// 计算当前车辆与前一站和后一站的距离 // 计算当前车辆与前一站和后一站的距离
double pass = 0; double pass = 0;
if (Func.isNotEmpty(preSite)) { if (Func.isNotEmpty(preSite)) {
pass = CommonUtil.calculateDistance(Double.parseDouble(preSite.getJingdu()), Double.parseDouble(preSite.getWeidu()), pass = CommonUtil.calculateDistance(Double.parseDouble(preSite.getJingdu()), Double.parseDouble(preSite.getWeidu()),
Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu())); Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu()));
} }
double unpass = 0; double unpass = 0;
if (Func.isNotEmpty(nextSite)) { if (Func.isNotEmpty(nextSite)) {
unpass = CommonUtil.calculateDistance(Double.parseDouble(nextSite.getJingdu()), Double.parseDouble(nextSite.getWeidu()), unpass = CommonUtil.calculateDistance(Double.parseDouble(nextSite.getJingdu()), Double.parseDouble(nextSite.getWeidu()),
Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu())); Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu()));
} }
double runPercent = (pass + unpass) > 0 ? (pass / (pass + unpass)) * 100 : 0; double runPercent = (pass + unpass) > 0 ? (pass / (pass + unpass)) * 100 : 0;
DecimalFormat df1 = new DecimalFormat("#"); DecimalFormat df1 = new DecimalFormat("#");
// 先从缓存中获取上一次的运行百分比, 然后将本次的运行百分比更新到缓存中 // 先从缓存中获取上一次的运行百分比, 然后将本次的运行百分比更新到缓存中
String runPercentStr = df1.format(runPercent > 100 ? 100 : runPercent); String runPercentStr = df1.format(runPercent > 100 ? 100 : runPercent);
String prePercentStr = (String) redisTemplate.opsForValue().get("car-run-percent"); String prePercentStr = (String) redisTemplate.opsForValue().get("car-run-percent");
log.error("____________________________________________"); log.error("____________________________________________");
log.error("runPercentStr : " + runPercentStr); log.error("runPercentStr : " + runPercentStr);
log.error("prePercentStr : " + prePercentStr); log.error("prePercentStr : " + prePercentStr);
log.error("CarInfoVO: " + info.toString()); log.error("CarInfoVO: " + info.toString());
prePercentStr = Func.isBlank(prePercentStr) ? "0" : prePercentStr; prePercentStr = Func.isBlank(prePercentStr) ? "0" : prePercentStr;
redisTemplate.opsForValue().set("car-run-percent", runPercentStr, 30, TimeUnit.SECONDS); redisTemplate.opsForValue().set("car-run-percent", runPercentStr, 30, TimeUnit.SECONDS);
Map<String, Object> siteMap = new HashMap<>(); Map<String, Object> siteMap = new HashMap<>();
siteMap.put("startSite", siteList.get(0).getSname()); siteMap.put("startSite", siteList.get(0).getSname());
siteMap.put("endSite", siteList.get(siteList.size() - 1).getSname()); siteMap.put("endSite", siteList.get(siteList.size() - 1).getSname());
siteMap.put("siteList", snameList); siteMap.put("siteList", snameList);
siteMap.put("prePercent", prePercentStr); siteMap.put("prePercent", prePercentStr);
siteMap.put("runPercent", runPercentStr); siteMap.put("runPercent", runPercentStr);
if (Func.isEmpty(nextSite)) { if (Func.isEmpty(nextSite)) {
nextSite = preSite; nextSite = preSite;
} }
BusLine busLine = BusLineCache.getBusLine(info.getUpordown(), nextSite.getSname(), nextSite.getWeizhi()); BusLine busLine = BusLineCache.getBusLine(info.getUpordown(), nextSite.getSname(), nextSite.getWeizhi());
// 组织返回数据 // 组织返回数据
Map<String, Object> resultMap = new HashMap<>(); Map<String, Object> resultMap = new HashMap<>();
resultMap.put("siteData", siteMap); resultMap.put("siteData", siteMap);
resultMap.put("catStat", redisTemplate.opsForValue().get("car-current-stat" + carNo)); resultMap.put("catStat", redisTemplate.opsForValue().get("car-current-stat" + carNo));
if (Func.isEmpty(busLine)) { if (Func.isEmpty(busLine)) {
resultMap.put("siteTips", ""); resultMap.put("siteTips", "");
resultMap.put("articleData", ""); resultMap.put("articleData", "");
resultMap.put("activityData", ""); resultMap.put("activityData", "");
resultMap.put("scenicData", ""); resultMap.put("scenicData", "");
resultMap.put("imgData", ""); resultMap.put("imgData", "");
} else { } else {
resultMap.put("siteTips", busLine.getTips()); resultMap.put("siteTips", busLine.getTips());
resultMap.put("articleData", busLine.getActicle()); resultMap.put("articleData", busLine.getActicle());
resultMap.put("activityData", busLine.getActivity()); resultMap.put("activityData", busLine.getActivity());
resultMap.put("scenicData", busLine.getScenic()); resultMap.put("scenicData", busLine.getScenic());
resultMap.put("scenicData", busLine.getScenic()); resultMap.put("scenicData", busLine.getScenic());
// redis缓存控制显示景区图片还是地图图片, 每10s切换一次, 若无景区图片, 显示地图图片 // redis缓存控制显示景区图片还是地图图片, 每10s切换一次, 若无景区图片, 显示地图图片
if (Func.isBlank(busLine.getImgScenic())) { if (Func.isBlank(busLine.getImgScenic())) {
resultMap.put("imgData", busLine.getImgMap()); resultMap.put("imgData", busLine.getImgMap());
} else { } else {
// 图片类型 1: 地图, 2:景点 // 图片类型 1: 地图, 2:景点
Integer imgType = (Integer) redisTemplate.opsForValue().get("site-img-type"); Integer imgType = (Integer) redisTemplate.opsForValue().get("site-img-type");
if (Func.isEmpty(imgType)) { if (Func.isEmpty(imgType)) {
imgType = 2; imgType = 2;
redisTemplate.opsForValue().set("site-img-type", imgType, 30, TimeUnit.SECONDS); redisTemplate.opsForValue().set("site-img-type", imgType, 30, TimeUnit.SECONDS);
} }
// 上一次放入地图的时间 // 上一次放入地图的时间
Long prePutImgTime = (Long) redisTemplate.opsForValue().get("site-img-time"); Long prePutImgTime = (Long) redisTemplate.opsForValue().get("site-img-time");
if (Func.isEmpty(prePutImgTime)) { if (Func.isEmpty(prePutImgTime)) {
prePutImgTime = System.currentTimeMillis(); prePutImgTime = System.currentTimeMillis();
redisTemplate.opsForValue().set("site-img-time", prePutImgTime, 30, TimeUnit.DAYS); redisTemplate.opsForValue().set("site-img-time", prePutImgTime, 30, TimeUnit.DAYS);
} }
// 若距离上一次更新图片<10s, 不修改放入的地图类型 // 若距离上一次更新图片<10s, 不修改放入的地图类型
if (System.currentTimeMillis() - prePutImgTime < 10000) { if (System.currentTimeMillis() - prePutImgTime < 10000) {
if (1 == imgType) { if (1 == imgType) {
resultMap.put("imgData", busLine.getImgMap()); resultMap.put("imgData", busLine.getImgMap());
} else { } else {
resultMap.put("imgData", busLine.getImgScenic()); resultMap.put("imgData", busLine.getImgScenic());
} }
} else { } else {
// 否则, 修改返回的图片类型, 并更新缓存 // 否则, 修改返回的图片类型, 并更新缓存
if (1 == imgType) { if (1 == imgType) {
imgType = 2; imgType = 2;
resultMap.put("imgData", busLine.getImgScenic()); resultMap.put("imgData", busLine.getImgScenic());
} else { } else {
imgType = 1; imgType = 1;
resultMap.put("imgData", busLine.getImgMap()); resultMap.put("imgData", busLine.getImgMap());
} }
redisTemplate.opsForValue().set("site-img-type", imgType, 30, TimeUnit.SECONDS); redisTemplate.opsForValue().set("site-img-type", imgType, 30, TimeUnit.SECONDS);
} }
} }
} }
return R.data(resultMap); return R.data(resultMap);
} }
/** /**
* 获取所有实时的车辆信息 * 获取所有实时的车辆信息
* *
* @return * @return
*/ */
@ApiOperation(value = "获取所有实时的车辆信息", notes = "传入id和busLine") @ApiOperation(value = "获取所有实时的车辆信息", notes = "传入id和busLine")
@GetMapping("/get-all-car-info") @GetMapping("/get-all-car-info")
public R getAllCarInfo() { public R getAllCarInfo() {
return R.data(carInfoService.getAllCarInfo()); return R.data(carInfoService.getAllCarInfo());
} }
/** /**
* 获取实时车辆站点信息 * 获取实时车辆站点信息
*/ */
@GetMapping("/get-current-info") @GetMapping("/get-current-info")
public R getCurrentInfo(@RequestParam String carNo) { public R getCurrentInfo(@RequestParam String carNo) {
CarInfoVO info = carInfoService.getCarInfo(carNo); CarInfoVO info = carInfoService.getCarInfo(carNo);
if (Func.isEmpty(info)) { if (Func.isEmpty(info)) {
return R.fail("未获取到车辆信息, 请检查车是否已掉线"); return R.fail("未获取到车辆信息, 请检查车是否已掉线");
} }
List<SiteInfoVO> siteList = SiteListCache.getSiteList(info.getLinename(), info.getUpordown()); List<SiteInfoVO> siteList = SiteListCache.getSiteList(info.getLinename(), info.getUpordown());
int nextSiteIdx = Integer.parseInt(info.getInorder()); int nextSiteIdx = Integer.parseInt(info.getInorder());
if (BusinessConstant.CAR_STAT_IN.toString().equals(info.getNowstate())) { if (BusinessConstant.CAR_STAT_IN.toString().equals(info.getNowstate())) {
nextSiteIdx -= 1; nextSiteIdx -= 1;
} }
// 下一站 // 下一站
List<Map<String, String>> snameList = new ArrayList<>(); List<Map<String, String>> snameList = new ArrayList<>();
SiteInfoVO nextSite = nextSiteIdx < siteList.size() ? siteList.get(nextSiteIdx) : null; SiteInfoVO nextSite = nextSiteIdx < siteList.size() ? siteList.get(nextSiteIdx) : null;
SiteInfoVO nextSite2 = (nextSiteIdx + 1) < siteList.size() ? siteList.get((nextSiteIdx) + 1) : null; SiteInfoVO nextSite2 = (nextSiteIdx + 1) < siteList.size() ? siteList.get((nextSiteIdx) + 1) : null;
SiteInfoVO nextSite3 = (nextSiteIdx + 2) < siteList.size() ? siteList.get(nextSiteIdx + 2) : null; SiteInfoVO nextSite3 = (nextSiteIdx + 2) < siteList.size() ? siteList.get(nextSiteIdx + 2) : null;
// 上一站 // 上一站
SiteInfoVO preSite = nextSiteIdx - 1 > 0 ? siteList.get(nextSiteIdx - 1) : null; SiteInfoVO preSite = nextSiteIdx - 1 > 0 ? siteList.get(nextSiteIdx - 1) : null;
// 上两站 // 上两站
SiteInfoVO preTwoSite = nextSiteIdx - 2 > 0 ? siteList.get(nextSiteIdx - 2) : null; SiteInfoVO preTwoSite = nextSiteIdx - 2 > 0 ? siteList.get(nextSiteIdx - 2) : null;
// 上三站 // 上三站
SiteInfoVO preThreeSite = nextSiteIdx - 3 > 0 ? siteList.get(nextSiteIdx - 3) : null; SiteInfoVO preThreeSite = nextSiteIdx - 3 > 0 ? siteList.get(nextSiteIdx - 3) : null;
Map<String, String> siteMsgMap; Map<String, String> siteMsgMap;
if (Func.isNotEmpty(preThreeSite)) { if (Func.isNotEmpty(preThreeSite)) {
siteMsgMap = new HashMap<>(); siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", preThreeSite.getSname()); siteMsgMap.put("siteName", preThreeSite.getSname());
siteMsgMap.put("type", "before"); siteMsgMap.put("type", "before");
snameList.add(siteMsgMap); snameList.add(siteMsgMap);
} }
if (Func.isNotEmpty(preTwoSite)) { if (Func.isNotEmpty(preTwoSite)) {
siteMsgMap = new HashMap<>(); siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", preTwoSite.getSname()); siteMsgMap.put("siteName", preTwoSite.getSname());
siteMsgMap.put("type", "before"); siteMsgMap.put("type", "before");
snameList.add(siteMsgMap); snameList.add(siteMsgMap);
} }
if (Func.isNotEmpty(preSite)) { if (Func.isNotEmpty(preSite)) {
siteMsgMap = new HashMap<>(); siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", preSite.getSname()); siteMsgMap.put("siteName", preSite.getSname());
siteMsgMap.put("type", "before"); siteMsgMap.put("type", "before");
snameList.add(siteMsgMap); snameList.add(siteMsgMap);
} }
if (Func.isNotEmpty(nextSite)) { if (Func.isNotEmpty(nextSite)) {
siteMsgMap = new HashMap<>(); siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", nextSite.getSname()); siteMsgMap.put("siteName", nextSite.getSname());
siteMsgMap.put("type", "after"); siteMsgMap.put("type", "after");
snameList.add(siteMsgMap); snameList.add(siteMsgMap);
} }
if (Func.isNotEmpty(nextSite2)) { if (Func.isNotEmpty(nextSite2)) {
siteMsgMap = new HashMap<>(); siteMsgMap = new HashMap<>();
siteMsgMap.put("siteName", nextSite2.getSname()); siteMsgMap.put("siteName", nextSite2.getSname());
siteMsgMap.put("type", "after"); siteMsgMap.put("type", "after");
snameList.add(siteMsgMap); snameList.add(siteMsgMap);
} }
// if (Func.isNotEmpty(nextSite3)) { // if (Func.isNotEmpty(nextSite3)) {
// snameList.add(nextSite3.getSname()); // snameList.add(nextSite3.getSname());
// } // }
// 计算当前车辆与前一站和后一站的距离 // 计算当前车辆与前一站和后一站的距离
double pass = 0; double pass = 0;
if (Func.isNotEmpty(preSite)) { if (Func.isNotEmpty(preSite)) {
pass = CommonUtil.calculateDistance(Double.parseDouble(preSite.getJingdu()), Double.parseDouble(preSite.getWeidu()), pass = CommonUtil.calculateDistance(Double.parseDouble(preSite.getJingdu()), Double.parseDouble(preSite.getWeidu()),
Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu())); Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu()));
} }
double unpass = 0; double unpass = 0;
if (Func.isNotEmpty(nextSite)) { if (Func.isNotEmpty(nextSite)) {
unpass = CommonUtil.calculateDistance(Double.parseDouble(nextSite.getJingdu()), Double.parseDouble(nextSite.getWeidu()), unpass = CommonUtil.calculateDistance(Double.parseDouble(nextSite.getJingdu()), Double.parseDouble(nextSite.getWeidu()),
Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu())); Double.parseDouble(info.getJingdu()), Double.parseDouble(info.getWeidu()));
} }
double runPercent = (pass + unpass) > 0 ? (pass / (pass + unpass)) * 100 : 0; double runPercent = (pass + unpass) > 0 ? (pass / (pass + unpass)) * 100 : 0;
DecimalFormat df1 = new DecimalFormat("#"); DecimalFormat df1 = new DecimalFormat("#");
// 先从缓存中获取上一次的运行百分比, 然后将本次的运行百分比更新到缓存中 // 先从缓存中获取上一次的运行百分比, 然后将本次的运行百分比更新到缓存中
String runPercentStr = df1.format(runPercent > 100 ? 100 : runPercent); String runPercentStr = df1.format(runPercent > 100 ? 100 : runPercent);
String prePercentStr = (String) redisTemplate.opsForValue().get("car-run-percent-info"); String prePercentStr = (String) redisTemplate.opsForValue().get("car-run-percent-info");
log.error("____________________________________________"); log.error("____________________________________________");
log.error("runPercentStr : " + runPercentStr); log.error("runPercentStr : " + runPercentStr);
log.error("prePercentStr : " + prePercentStr); log.error("prePercentStr : " + prePercentStr);
log.error("CarInfoVO: " + info.toString()); log.error("CarInfoVO: " + info.toString());
prePercentStr = Func.isBlank(prePercentStr) ? "0" : prePercentStr; prePercentStr = Func.isBlank(prePercentStr) ? "0" : prePercentStr;
redisTemplate.opsForValue().set("car-run-percent-info", runPercentStr, 30, TimeUnit.SECONDS); redisTemplate.opsForValue().set("car-run-percent-info", runPercentStr, 30, TimeUnit.SECONDS);
Map<String, Object> siteMap = new HashMap<>(); Map<String, Object> siteMap = new HashMap<>();
siteMap.put("startSite", siteList.get(0).getSname()); siteMap.put("startSite", siteList.get(0).getSname());
siteMap.put("endSite", siteList.get(siteList.size() - 1).getSname()); siteMap.put("endSite", siteList.get(siteList.size() - 1).getSname());
siteMap.put("siteList", snameList); siteMap.put("siteList", snameList);
siteMap.put("prePercent", prePercentStr); siteMap.put("prePercent", prePercentStr);
siteMap.put("runPercent", runPercentStr); siteMap.put("runPercent", runPercentStr);
if (Func.isEmpty(nextSite)) { if (Func.isEmpty(nextSite)) {
nextSite = preSite; nextSite = preSite;
} }
BusLine busLine = BusLineCache.getBusLine(info.getUpordown(), nextSite.getSname(), nextSite.getWeizhi()); BusLine busLine = BusLineCache.getBusLine(info.getUpordown(), nextSite.getSname(), nextSite.getWeizhi());
// 组织返回数据 // 组织返回数据
Map<String, Object> resultMap = new HashMap<>(); Map<String, Object> resultMap = new HashMap<>();
resultMap.put("siteData", siteMap); resultMap.put("siteData", siteMap);
resultMap.put("catStat", redisTemplate.opsForValue().get("car-current-stat-info" + carNo)); resultMap.put("catStat", redisTemplate.opsForValue().get("car-current-stat-info" + carNo));
if (Func.isEmpty(busLine)) { if (Func.isEmpty(busLine)) {
resultMap.put("siteTips", ""); resultMap.put("siteTips", "");
resultMap.put("articleData", ""); resultMap.put("articleData", "");
resultMap.put("activityData", ""); resultMap.put("activityData", "");
resultMap.put("scenicData", ""); resultMap.put("scenicData", "");
resultMap.put("imgData", ""); resultMap.put("imgData", "");
resultMap.put("speed", ""); resultMap.put("speed", "");
} else { } else {
resultMap.put("siteTips", busLine.getTips()); resultMap.put("siteTips", busLine.getTips());
resultMap.put("articleData", busLine.getActicle()); resultMap.put("articleData", busLine.getActicle());
resultMap.put("activityData", busLine.getActivity()); resultMap.put("activityData", busLine.getActivity());
resultMap.put("scenicData", busLine.getScenic()); resultMap.put("scenicData", busLine.getScenic());
resultMap.put("speed",info.getSpeed()); resultMap.put("speed", info.getSpeed());
List<BusLine> busLineList = stationHintService.getBusLineByName(nextSite.getSname()); List<BusLine> busLineList = stationHintService.getBusLineByName(nextSite.getSname());
Long busLineId = busLineList.get(0).getId(); Long busLineId = busLineList.get(0).getId();
List<imgVo> imgList = proBusLineImgService.getImgByid(busLineId); List<imgVo> imgList = proBusLineImgService.getImgByid(busLineId);
redisTemplate.opsForValue().set("imgList-info", imgList); redisTemplate.opsForValue().set("imgList-info", imgList);
resultMap.put("imgData", imgList); resultMap.put("imgData", imgList);
} }
//定时任务缓存 //定时任务缓存
carInfoTask.setCarInfo(resultMap); carInfoTask.setCarInfo(resultMap);
return R.data(resultMap); return R.data(resultMap);
} }
} }

Write Preview
Loading…
Cancel
Save