PublicDealFreeBerths.java
6.32 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
package com.zteits.job.task.getfreeberths;
import com.alibaba.fastjson.JSON;
import com.clouds.common.cache.park.ParkFreeBerthsCacheUtil;
import com.xiaoleilu.hutool.util.CollectionUtil;
import com.zteits.clouds.api.apibase.constants.DataStatusEnum;
import com.zteits.clouds.api.apibase.constants.SourceTypeEnum;
import com.zteits.clouds.api.dto.order.parkorder.param.pushfreeberths.PushFreeBerthsChangeRequest;
import com.zteits.clouds.api.dto.rocketmq.datacollection.freeberths.FreeBerthsChangeMsgVO;
import com.zteits.job.dao.park.ParkFreeBerthDao;
import com.zteits.job.dao.park.ParkingLotDao;
import com.zteits.job.domain.ParkingLot;
import com.zteits.job.domain.ParkingLotExample;
import com.zteits.job.task.getfreeberths.base.ThirdFreeBerthServiceRoute;
import com.zteits.job.task.getfreeberths.param.GetRealFreeBerthsDO;
import com.zteits.job.task.getfreeberths.param.IarinParkInfo;
import com.zteits.job.task.getfreeberths.param.UpdateFreeByIrainRes;
import com.zteits.job.util.HttpClientTutorial;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import java.io.IOException;
import java.time.Duration;
import java.time.LocalTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/**
* 调用道闸接口，获取真实的空闲车位数
* .<br/>
* <p>
* Copyright: Copyright (c) 2017 zteits
*
* @ClassName: GetRealFreeBerthsJob
* @Description:
* @version: v1.0.0
* @author: zhaowg
* @date: 2018年5月11日 下午5:47:42
* Modification History:
* Date Author Version Description
* ---------------------------------------------------------*
* 2018年5月11日 zhaowg v1.0.0 创建
*/
@Component
public class PublicDealFreeBerths {
private static final Logger logger = LoggerFactory.getLogger(PublicDealFreeBerths.class);
@Autowired
private ParkingLotDao parkingLotDao;
@Autowired
private ParkFreeBerthDao parkFreeBerthDao;
@Autowired
private Map<String, CallThirdQueryFreeBerthService> thirdBerthServiceMap;
@Async("myTaskAsyncPool")
public void dealFreeBerths(ParkingLot parkingLotDTO) {
if (99 == parkingLotDTO.getSourceType().intValue()) {
return;
}
logger.info("开始查询停车场" + parkingLotDTO.getPlName() + "[" + parkingLotDTO.getPlNo() + "]");
String plNo = parkingLotDTO.getPlNo();
GetRealFreeBerthsDO getRealFreeBerthsDO = queryFreeBerths(parkingLotDTO);
if (getRealFreeBerthsDO == null) {
return;
}
//调用接口返回的真实空闲车位数，可能为负数或者超过总车位数
Integer realFreeBerths = StringUtils.isBlank(getRealFreeBerthsDO.getFreeParkingSpace()) ? 0 : Integer.valueOf(getRealFreeBerthsDO.getFreeParkingSpace());
//修改后的空闲车位数，最小0，最大不超过总车位数
Integer freeBerths = realFreeBerths;
//判断数据有效性
if (freeBerths < 0) {
logger.info("返回的空闲车位数小于0，修改为0");
freeBerths = 0;
} else if (freeBerths > parkingLotDTO.getPlBerthNum()) {
logger.info("返回的空闲车位数大于总车位数" + parkingLotDTO.getPlBerthNum() + "，修改为总车位数");
freeBerths = parkingLotDTO.getPlBerthNum();
}
//判断缓存中空闲车位数是否发生变化了
FreeBerthsChangeMsgVO freeBerthsChangeMsgVO = ParkFreeBerthsCacheUtil.getFreeBerthsObjectByPlNo(plNo);
if (freeBerthsChangeMsgVO == null) {
return;
}
if (freeBerthsChangeMsgVO.getRealFreeBerths() != realFreeBerths) {
logger.info(plNo + "-原来真实空闲车位数：" + freeBerthsChangeMsgVO.getRealFreeBerths() + "，新真实空闲车位数：" + realFreeBerths + ",新空闲车位数：" + freeBerths);
//更新缓存
freeBerthsChangeMsgVO = ParkFreeBerthsCacheUtil.setFreeBerthsByPlNo(plNo, freeBerths, realFreeBerths);
}
if (SourceTypeEnum.NAN_ZHE.getValue().equals(parkingLotDTO.getSourceType())) {
//南泽的总车位数不正确
return;
}
//判断总车位数是否一致
Integer plBerthNum = StringUtils.isBlank(getRealFreeBerthsDO.getTotalParkingSpace()) ? 0 : Integer.valueOf(getRealFreeBerthsDO.getTotalParkingSpace());
if (!plBerthNum.equals(parkingLotDTO.getPlBerthNum())
&& plBerthNum.intValue() > 0) {
logger.debug(parkingLotDTO.getPlName() + ",总车位数:" + parkingLotDTO.getPlBerthNum() + "与接口返回的不一致，更新总车位数为" + plBerthNum);
parkingLotDao.updateTotalBerths(plNo, plBerthNum);
}
List<FreeBerthsChangeMsgVO> msgVOList = new ArrayList<>();
msgVOList.add(freeBerthsChangeMsgVO);
PushFreeBerthsChangeRequest pushFreeBerthsChangeRequest = new PushFreeBerthsChangeRequest();
pushFreeBerthsChangeRequest.setBerthsChangeMsgVOs(msgVOList);
pushFreeBerthsChangeRequest.setSysCode("XXL-JOB");
//更新空闲车位数
parkFreeBerthDao.updateFreeBerthsByPlNo(pushFreeBerthsChangeRequest);
}
/**
* 调用第三方接口查询空闲车位数
*
* @throws IOException 2018年5月11日 zhaowg
*/
private GetRealFreeBerthsDO queryFreeBerths(ParkingLot parkingLot) {
try {
/**根据数据来源路由具体的通知服务*/
CallThirdQueryFreeBerthService queryThirdBerthInfoService = ThirdFreeBerthServiceRoute
.selectThirdBerthService(SourceTypeEnum.getEnumByValue(parkingLot.getSourceType()), thirdBerthServiceMap);
/**根据数据来源类型，查询第三方空闲车位数*/
return queryThirdBerthInfoService.queryFreeBerths(parkingLot);
} catch (Exception e) {
logger.error("处理错误", e);
}
return null;
}
}