package com.doumee.service.business.impl.hksync;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.doumee.config.DataSyncConfig;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.haikang.model.HKConstants;
|
import com.doumee.core.haikang.model.param.BaseListPageResponse;
|
import com.doumee.core.haikang.model.param.BaseResponse;
|
import com.doumee.core.haikang.model.param.request.*;
|
import com.doumee.core.haikang.model.param.respose.AppointmentInfoResponse;
|
import com.doumee.core.haikang.model.param.respose.ParkCrossRecordInfoResponse;
|
import com.doumee.core.haikang.model.param.respose.ParkListResponse;
|
import com.doumee.core.haikang.service.HKService;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.DESUtil;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.CarEventMapper;
|
import com.doumee.dao.business.ParksMapper;
|
import com.doumee.dao.business.join.ParkBookJoinMapper;
|
import com.doumee.dao.business.model.*;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 海康停车库同步Service实现
|
* @author 江蹄蹄
|
* @date 2023/11/30 15:33
|
*/
|
@Service
|
public class HkSyncParkServiceImpl extends HkSyncBaseServiceImpl {
|
|
@Autowired
|
private DataSyncConfig dataSyncConfig;
|
@Autowired
|
private ParksMapper parksMapper;
|
@Autowired
|
private ParkBookJoinMapper parkBookMapper;
|
@Autowired
|
private CarEventMapper carEventMapper;
|
@Override
|
public void syncParkBookData() {
|
if(Constants.DEALING_HK_PARKBOOK){
|
return ;
|
}
|
Constants.DEALING_HK_PARKBOOK =true;
|
try {
|
//查询所有需要同步的数据
|
List<ParkBook> list =getDealList ();
|
if(list ==null || list.size()==0){
|
return;
|
}
|
Date date = new Date();
|
//处理所有需要包期的车辆数据记录
|
for(ParkBook c : list) {
|
dealParkBookBiz(c,date);
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}finally {
|
Constants.DEALING_HK_PARKBOOK =false;
|
}
|
|
}
|
|
private void dealParkBookBiz(ParkBook c,Date date) {
|
try {
|
if(Constants.equalsObject(c.getIsdeleted(),Constants.ONE)) {
|
//如果取消预约，则进行取消包期
|
if(StringUtils.isNotBlank(c.getParkHkId())
|
&& StringUtils.isNotBlank(c.getCarCode())){
|
boolean result = cancelParkBookHk(c);
|
c.setHkStatus(result?Constants.ONE:Constants.TWO);
|
c.setRemark(result?"取消包期成功":"取消包期失败");
|
}else{
|
c.setHkStatus(Constants.TWO);//下发失败
|
c.setRemark("取消包期失败");
|
}
|
c.setHkDate(date);
|
}else{
|
//如果是新增包期，数据不合法，直接提示下发失败
|
if(StringUtils.isNotBlank(c.getParkHkId())
|
&& StringUtils.isNotBlank(c.getCarCode())){
|
boolean result = addParkBookHk(c);
|
c.setHkStatus(result?Constants.ONE:Constants.TWO);
|
c.setRemark(result?"包期成功":"包期失败");
|
}else{
|
c.setHkStatus(Constants.TWO);
|
c.setRemark("包期失败~");
|
}
|
}
|
c.setHkDate(date);
|
parkBookMapper.updateById(c);
|
}catch (Exception e){
|
|
}
|
|
}
|
|
@Override
|
public void syncParkBookBySingleModel(ParkBook c) {
|
if(Constants.equalsObject(c.getIsdeleted(),Constants.ONE)){
|
//如果取消预约，则进行取消包期
|
if(StringUtils.isNotBlank(c.getParkHkId())
|
&& StringUtils.isNotBlank(c.getCarCode())){
|
boolean result = cancelParkBookHk(c);
|
c.setHkStatus(result?Constants.ONE:Constants.TWO);
|
c.setRemark(result?"取消包期成功":"取消包期失败");
|
}else{
|
c.setHkStatus(Constants.TWO);//下发失败
|
c.setRemark("取消包期失败");
|
}
|
c.setHkDate(new Date());
|
parkBookMapper.updateById(c);
|
}else {
|
//处理所有需要包期的车辆数据记录
|
//数据不合法，直接提示下发失败
|
if (StringUtils.isNotBlank(c.getParkHkId())
|
&& StringUtils.isNotBlank(c.getCarCode())) {
|
boolean result = addParkBookHk(c);
|
c.setHkStatus(result ? Constants.ONE : Constants.TWO);
|
c.setRemark(result ? "包期成功" : "包期失败");
|
} else {
|
c.setHkStatus(Constants.TWO);
|
c.setRemark("包期失败~");
|
}
|
c.setHkDate(new Date());
|
parkBookMapper.updateById(c);
|
}
|
}
|
private boolean addParkBookHk(ParkBook c) {
|
CarChargeAddRequest param = new CarChargeAddRequest();
|
param.setPlateNo(c.getCarCode());
|
param.setParkSyscode(c.getParkHkId());
|
param.setStartTime(Objects.isNull(c.getStartTime())?DateUtil.getDate(new Date(),"yyyy-MM-dd"):DateUtil.getShortTimeToNull(c.getStartTime()));
|
param.setEndTime(Objects.isNull(c.getEndTime())?"2999-12-31":DateUtil.getShortTimeToNull(c.getEndTime()));
|
BaseResponse response = HKService.carChargeAddtion(param);
|
if(response!=null
|
&& StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)){
|
return true;
|
}else{
|
return false;
|
}
|
}
|
private boolean cancelParkBookHk(ParkBook c) {
|
CarChargeDelRequest param = new CarChargeDelRequest();
|
param.setPlateNo(c.getCarCode());
|
param.setParkSyscode(c.getParkHkId());
|
BaseResponse response = HKService.carChargeDeletion(param);
|
if(response!=null
|
&& StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)){
|
return true;
|
}else{
|
return false;
|
}
|
}
|
|
private List<ParkBook> getDealList() {
|
MPJLambdaWrapper<ParkBook> queryWrapper = new MPJLambdaWrapper<>();
|
queryWrapper.selectAll(ParkBook.class);
|
queryWrapper.selectAs(Parks::getHkId,ParkBook::getParkHkId);
|
queryWrapper.leftJoin(Parks.class,Parks::getId,ParkBook::getParkId);
|
queryWrapper.selectAs(Device::getHkId,Empower::getDeviceIndexCode);
|
List<ParkBook> list = parkBookMapper.selectJoinList(ParkBook.class,queryWrapper.eq(ParkBook::getHkStatus,Constants.ZERO).orderByAsc(ParkBook::getId));
|
return list;
|
}
|
private void getDataChangeList(List<Parks> allList, List<ParkListResponse> allHkList, List<Parks> addList, List<Parks> editList,List<Parks> deleteList, Date date) {
|
if(allHkList!=null && allHkList.size()>0){
|
for(ParkListResponse device : allHkList){
|
Parks model = getExistedData(device,allList);
|
if(model !=null){
|
//如果已存在，则更新数据
|
model = initModelByHkData(model,device,date);
|
editList.add(model);
|
}else{
|
//如果不存在，则新增数据
|
model = new Parks();
|
model = initModelByHkData(model,device,date);
|
addList.add(model);
|
}
|
}
|
}
|
//判断获取删除的门禁设备，逻辑删除
|
getDeleteList(allList,allHkList,deleteList,date);
|
}
|
/**
|
* 同步海康停车库数据
|
* @param param
|
* @return
|
*/
|
@Override
|
// @Async
|
public String syncHkParks(ParkListRequest param){
|
if(Constants.DEALING_HK_SYNCPRIVILEGE){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "同步任务正在执行哦，请稍后查看结果！") ;
|
}
|
Constants.DEALING_HK_SYNCPRIVILEGE =true;
|
try {
|
List<Parks> deleteList = new ArrayList<>();
|
List<Parks> addList = new ArrayList<>();
|
List<Parks> editList = new ArrayList<>();
|
Date date = new Date();
|
//查询全部当前数据
|
List<Parks> allList = parksMapper.selectList(null);
|
//分页遍历循环查询所有门禁设备数据
|
param = new ParkListRequest();
|
BaseResponse<List<ParkListResponse>> response = HKService.parkList(param);
|
if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~");
|
}
|
List<ParkListResponse> allHkList = response.getData();
|
// 获取增删改数据集合
|
getDataChangeList(allList,allHkList,addList,editList,deleteList,date);
|
if(deleteList.size()>0){
|
//逻辑删除
|
for(Parks d : deleteList){
|
parksMapper.updateById(d);
|
}
|
}
|
if(addList.size()>0){
|
parksMapper.insertBatchSomeColumn(addList);
|
}
|
if(editList.size()>0){
|
for(Parks d : editList){
|
parksMapper.updateById(d);
|
}
|
}
|
return "同步数据：新增【"+addList.size()+"】条，更新【"+editList.size()+"】条，删除【"+deleteList.size()+"】条";
|
}catch (Exception e){
|
e.printStackTrace();
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "同步失败！");
|
}finally {
|
Constants.DEALING_HK_SYNCPRIVILEGE =false;
|
}
|
}
|
|
/**
|
* 初始化海康入库数据
|
* @param model
|
* @param device
|
* @param date
|
* @return
|
*/
|
private Parks initModelByHkData(Parks model, ParkListResponse device,Date date) {
|
model.setIsdeleted(Constants.ZERO);
|
model.setName(device.getParkName());
|
model.setHkDate(date);
|
model.setCreateDate(DateUtil.getISO8601DateByStr(device.getCreateTime()));
|
model.setEditDate(DateUtil.getISO8601DateByStr(device.getUpdateTime()));
|
model.setHkId(device.getParkIndexCode());
|
model.setHkStatus(Constants.ONE);
|
model.setStatus(Constants.ONE);
|
return model;
|
}
|
|
private Parks getExistedData(ParkListResponse data, List<Parks> allList) {
|
if(allList.size()>0){
|
for(Parks r : allList){
|
if(StringUtils.equals(r.getHkId(), data.getParkIndexCode())){
|
//表示未删除
|
return r;
|
}
|
}
|
}
|
return null;
|
}
|
|
private void getDeleteList(List<Parks> allList, List<ParkListResponse> allHkList,List<Parks> deleteList ,Date date) {
|
if(allList!=null && allList.size()>0){
|
for(Parks data : allList){
|
if(isDeletedDevice(data,allHkList)){
|
data.setIsdeleted(Constants.ONE);
|
data.setEditDate(date);
|
deleteList.add(data);
|
}
|
}
|
}
|
}
|
|
private boolean isDeletedDevice(Parks device, List<ParkListResponse> allHkList) {
|
if(allHkList.size()>0){
|
for(ParkListResponse r : allHkList){
|
if(StringUtils.equals(device.getHkId(), r.getParkIndexCode())){
|
//表示未删除
|
return false;
|
}
|
}
|
}
|
return true;
|
|
}
|
|
|
|
@Override
|
@Transactional
|
public void syncParkRecords(Date date){
|
try {
|
if( Constants.formatIntegerNum(dataSyncConfig.getVisitorDataOrigin()) != DataSyncConfig.origin.hk){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，当前不支持海康数据同步操作~");
|
}
|
ParkCrossRecordListRequest param = new ParkCrossRecordListRequest();
|
//（全量同步）
|
boolean hasNext = true;
|
int curTotal = 0;
|
int curPage = 1;
|
//查询今天的
|
Date start = Utils.Date.getStart(date);
|
Date end = new Date();
|
if(DateUtil.daysBetweenDates(end,start) >1){
|
end = Utils.Date.getEnd(date);
|
}
|
param.setStartTime(DateUtil.getISO8601Timestamp2( start));
|
param.setEndTime(DateUtil.getISO8601Timestamp2( end));
|
|
List<CarEvent> allHkList = new ArrayList<>();
|
while (hasNext){
|
//分页遍历循环查询所有门禁设备数据
|
param.setPageNo(curPage);
|
param.setPageSize(100);
|
BaseResponse<BaseListPageResponse<ParkCrossRecordInfoResponse>> response = HKService.parkCrossRecords(param);
|
if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) ){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "对不起，海康同步数据失败~");
|
}
|
if(response.getData() == null || response.getData().getTotal() ==0){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未同步到任何信息！");
|
}
|
BaseListPageResponse<ParkCrossRecordInfoResponse> r = response.getData();
|
curTotal += 100;
|
if(curTotal >= r.getTotal()){
|
hasNext = false;
|
}
|
if(r.getList() == null || r.getList().size()==0){
|
hasNext =false;
|
}else{
|
allHkList.addAll(getNewCarEventModelBYList(r.getList()));
|
}
|
curPage++;
|
}
|
if(allHkList .size() == 0){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未同步到任何信息！");
|
}
|
//清空原有当天的数据
|
carEventMapper.delete(new UpdateWrapper<CarEvent>().lambda()
|
.ge(CarEvent::getCreateDate,start)
|
.le(CarEvent::getCreateDate,end));
|
if(allHkList.size()>0){
|
int sublistSize = 500;
|
|
int startIndex = 0;
|
int endIndex = sublistSize;
|
|
while (startIndex < allHkList.size()) {
|
if (endIndex > allHkList.size()) {
|
endIndex = allHkList.size();
|
}
|
|
List<CarEvent> sublist = allHkList.subList(startIndex, endIndex);
|
if(sublist.size()>0){
|
carEventMapper.insertBatchSomeColumn(sublist);//插入新数据
|
}
|
startIndex = endIndex;
|
endIndex += sublistSize;
|
}
|
}
|
|
}catch (BusinessException e){
|
throw e;
|
}
|
}
|
|
private List<CarEvent> getNewCarEventModelBYList(List<ParkCrossRecordInfoResponse> list ) {
|
List<CarEvent> newList = new ArrayList<>();
|
if(list == null || list.size()==0){
|
return newList;
|
}
|
for(ParkCrossRecordInfoResponse model :list){
|
if( model.getReleaseResult() ==null || !( model.getReleaseResult() == 1|| model.getReleaseResult() == 2 )){
|
continue;
|
}
|
CarEvent c = new CarEvent();
|
c.setHappenTime(model.getCrossTime());
|
c.setCreateDate(DateUtil.getISO8601DateByStr2(model.getCrossTime()));
|
c.setSvrIndex(model.getAswSyscode());
|
c.setVehiclePicUrl(model.getVehiclePicUri());
|
c.setPlatePicUrl(model.getPlateNoPicUri());
|
c.setVehicleType(model.getVehicleType());
|
c.setPlateColor(model.getPlateColor());
|
c.setPlateType(model.getPlateType());
|
c.setCardNo(model.getCardNo());
|
c.setReleaseReason(model.getReleaseReason());
|
c.setPlateNos(model.getPlateNo());
|
c.setReleaseResult(model.getReleaseResult());
|
c.setInoutType(model.getVehicleOut());
|
c.setParkIndex(model.getParkSyscode());
|
c.setParkName(model.getParkName());
|
c.setEventId(model.getCrossRecordSyscode());
|
c.setGateIndex(model.getEntranceSyscode());
|
c.setGateName(model.getEntranceName());
|
c.setIsdeleted(Constants.ZERO);
|
if(model.getVehicleOut() !=null &&model.getVehicleOut() == 0 ){
|
c.setEventType(HKConstants.EventTypes.PARK_PASS_IN.getKey());
|
}else {
|
c.setEventType(HKConstants.EventTypes.PARK_PASS_OUT.getKey());
|
}
|
newList.add(c);
|
}
|
return newList;
|
}
|
|
|
}
|
