zhaowg / zteits-module

package com.zteits.job.task.getfreeberths;

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;

import com.alibaba.fastjson.JSON;
import com.clouds.common.cache.park.ParkingLotCacheUtil;
import com.zteits.clouds.api.apibase.constants.DataStatusEnum;
import com.zteits.job.task.getfreeberths.base.ThirdFreeBerthServiceRoute;
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.Scheduled;
import org.springframework.stereotype.Component;

import com.clouds.common.cache.park.ParkFreeBerthsCacheUtil;
import com.xiaoleilu.hutool.util.CollectionUtil;
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.param.GetRealFreeBerthsDO;
import org.springframework.util.CollectionUtils;

/**
 * 调用道闸接口，获取真实的空闲车位数
 * .<br/>
 *
 * 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 PublicGetRealFreeBerthsJob{
	private static final Logger logger = LoggerFactory.getLogger(PublicGetRealFreeBerthsJob.class);
	//艾润北京西城空闲车位接口地址
	@Value("${irain.bjxc.getfreeberthNum}")
	private String irainBjxcGetfreeberthNumUrl;
	@Autowired
	private ParkingLotDao parkingLotDao;
	@Autowired
	private ParkFreeBerthDao parkFreeBerthDao;
	@Autowired
    private Map<String,CallThirdQueryFreeBerthService> thirdBerthServiceMap;
	/**
	 * 间隔10秒执行一次
	 *
	 * 2018年5月4日 zhaowg
	 */
	@Scheduled(fixedDelay=10000)
	public void execute(){
		logger.info("查询道闸的停车场");
		//数据来源类型：1-艾润;2-路测;3-捷商;4-南泽 ;5-共享车位，6:青岛 7:红门道闸  99:北京诱导bjpgis
		List<Integer> sourceTypes = Stream.of(1,4,6,7,99).collect(Collectors.toList());
		ParkingLotExample example = new ParkingLotExample();
		example.createCriteria().andSourceTypeIn(sourceTypes).andDataStatusEqualTo(DataStatusEnum.DATA_STATUS_VALID.value());
		List<ParkingLot> parkingLots = parkingLotDao.selectByExample(example);
		if(CollectionUtil.isEmpty(parkingLots)){
			logger.info("没有满足条件的停车场");
			return;
		}

		//北京诱导bjpgis单独处理
		List<ParkingLot> bjpgisParks = parkingLots.stream().filter(item->item.getSourceType().intValue()==99).collect(Collectors.toList());
		this.dealFreeBerthsForBjpgis(bjpgisParks);

		//其他道闸诱导处理
		this.dealFreeBerths(parkingLots);
	}

	/**
	 * 北京诱导bjpgis单独处理
	 * @param bjpgisParks
	 */
	private void dealFreeBerthsForBjpgis(List<ParkingLot> bjpgisParks) {
		if(CollectionUtil.isEmpty(bjpgisParks)){
			return;
		}
		if(StringUtils.isBlank(irainBjxcGetfreeberthNumUrl)){
			logger.error("北京西城获取空闲车位地址为空");
			return;
		}
		LocalTime beginTime = LocalTime.now();
		logger.info("开始调用北京西城艾润空闲车位接口更新空闲车位数。"+beginTime);
		String response = HttpClientTutorial.httpGetRequest(irainBjxcGetfreeberthNumUrl);
		logger.info("响应信息为："+response);
		if(com.alibaba.dubbo.common.utils.StringUtils.isBlank(response)){
			return;
		}
		UpdateFreeByIrainRes byIrainRes= JSON.parseObject(response, UpdateFreeByIrainRes.class);
		if(byIrainRes==null){
			return;
		}
		if(!byIrainRes.getCode().equals("0") || CollectionUtils.isEmpty(byIrainRes.getList())){
			return;
		}
		Map<String,ParkingLot> map = bjpgisParks.stream().collect(Collectors.toMap(ParkingLot::getPlOutNo, Function.identity(),(key1,key2)->key1));
		List<FreeBerthsChangeMsgVO> berthsChangeMsgVOs = new ArrayList<>();
		for (IarinParkInfo iarinParkInfo : byIrainRes.getList()) {
			String plOutNo = "bjpgis_"+iarinParkInfo.getId();
			if(!map.containsKey(plOutNo)){
				continue;
			}
			String plNo = map.get(plOutNo).getPlNo();
			Integer freeBerths = iarinParkInfo.getRemaind();
			if(com.alibaba.dubbo.common.utils.StringUtils.isBlank(plNo)){
				continue;
			}
			//判断空闲车位数是否发生变化了
			Integer oldFreeBerths = ParkFreeBerthsCacheUtil.getFreeBerthsByPlNo(plNo);
			if(oldFreeBerths.intValue() == freeBerths.intValue()){
				logger.info(plNo+"-原来空闲车位数："+oldFreeBerths+"和新空闲车位数相等，无需处理");
				continue;
			}
			//发生空闲车位变化消息
			//更新缓存
			FreeBerthsChangeMsgVO berthsChangeMsgVO = ParkFreeBerthsCacheUtil.setFreeBerthsByPlNo(plNo, freeBerths,freeBerths);
			berthsChangeMsgVOs.add(berthsChangeMsgVO);
		}
		PushFreeBerthsChangeRequest freeBerthsChangeMsgVO = new PushFreeBerthsChangeRequest();
		freeBerthsChangeMsgVO.setBerthsChangeMsgVOs(berthsChangeMsgVOs );
		freeBerthsChangeMsgVO.setSysCode("DATA-COLLECT");
		//更新空闲车位数
		parkFreeBerthDao.updateFreeBerthsByPlNo(freeBerthsChangeMsgVO);
		LocalTime endTime = LocalTime.now();
		logger.info("调用北京西城艾润空闲车位接口结束，共耗时" + Duration.between(beginTime, endTime).getSeconds());

	}

	private void dealFreeBerths(List<ParkingLot> parkingLots) {
		List<FreeBerthsChangeMsgVO> berthsChangeMsgVOs = new ArrayList<>();
		for (ParkingLot parkingLotDTO : parkingLots) {
			if(99 == parkingLotDTO.getSourceType().intValue()){
				continue;
			}
			logger.info("开始查询停车场"+parkingLotDTO.getPlName()+"["+parkingLotDTO.getPlNo()+"]");
			String plNo = parkingLotDTO.getPlNo();
			GetRealFreeBerthsDO getRealFreeBerthsDO = queryFreeBerths(parkingLotDTO);
			if(getRealFreeBerthsDO == null){
				continue;
			}
			//调用接口返回的真实空闲车位数，可能为负数或者超过总车位数
			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){
				continue;
			}
			if(freeBerthsChangeMsgVO.getRealFreeBerths() != realFreeBerths){
				logger.info(plNo+"-原来真实空闲车位数："+freeBerthsChangeMsgVO.getRealFreeBerths()+"，新真实空闲车位数："+realFreeBerths+",新空闲车位数："+freeBerths);
				//更新缓存
				freeBerthsChangeMsgVO = ParkFreeBerthsCacheUtil.setFreeBerthsByPlNo(plNo, freeBerths,realFreeBerths);
			}
			berthsChangeMsgVOs.add(freeBerthsChangeMsgVO);

			if(SourceTypeEnum.NAN_ZHE.getValue().equals(parkingLotDTO.getSourceType())){
				//南泽的总车位数不正确
				continue;
			}
			//判断总车位数是否一致
			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);
			}
		}
		if(CollectionUtil.isEmpty(berthsChangeMsgVOs)){
			return;
		}
		PushFreeBerthsChangeRequest freeBerthsChangeMsgVO = new PushFreeBerthsChangeRequest();
		freeBerthsChangeMsgVO.setBerthsChangeMsgVOs(berthsChangeMsgVOs );
		freeBerthsChangeMsgVO.setSysCode("XXL-JOB");
		//更新空闲车位数
		parkFreeBerthDao.updateFreeBerthsByPlNo(freeBerthsChangeMsgVO);
	}

	/**
	 * 调用第三方接口查询空闲车位数
	 * @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;
	}

}