package com.zteits.park.job;

import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.zteits.clouds.api.apibase.constants.DataStatusEnum;
import com.zteits.park.constant.EqpConstant;
import com.zteits.park.constant.ParkConstant;
import com.zteits.park.domain.TpPPda;
import com.zteits.park.domain.TpPPdaExample;
import com.zteits.park.mapper.TpPPdaMapper;
import com.zteits.park.service.employee.oper.EmployeeChargeOperInnerService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Calendar;
import java.util.Date;
import java.util.List;

/**
 * 修改PDA状态，在线，离线，同时签退收费员
 *
 * Copyright: Copyright (c) 2017  zteits
 *
 * @ClassName: EqpHeartBeatJob.java
 * @Description:
 * @version: v1.0.0
 * @author: zhaowg
 * @date: 2017年12月11日   上午10:12:45
 * Modification History:
 * Date             Author          Version            Description
 *---------------------------------------------------------*
 * 2017年12月11日      zhaowg              v1.0.0               创建
 */
@Component
public class PDAHeartBeatJob{
	private static final Logger logger = LoggerFactory.getLogger(PDAHeartBeatJob.class);
	@Autowired
	private EmployeeChargeOperInnerService employeeChargeOperInnerService;
	@Autowired
	private TpPPdaMapper tpPPdaMapper;
	@XxlJob("pdaHeartBeatJob")
	public ReturnT<String> execute(String... params) throws Exception {
		String param = XxlJobHelper.getJobParam();
		if (StringUtils.isNotEmpty(param) && params == null) {
			params = param.split(",");
		}

		try{
			log("开始查询需要更新的PDA记录,超过15分钟没有心跳且状态是在线的设备，系统判定为离线，执行签退操作");
			Calendar calendar = Calendar.getInstance();
	        calendar.add(Calendar.MINUTE, -15);
	        Date date = new Date(calendar.getTimeInMillis());
			TpPPdaExample example = new TpPPdaExample();
			example.createCriteria()
			.andDataStateEqualTo(DataStatusEnum.DATA_STATUS_VALID.value())
			.andOnlineFlgEqualTo(EqpConstant.IS_ONLINE.ON_LINE)
			.andPdaTypeEqualTo(ParkConstant.PdaType.CHARGER_PDA_TYPE)
			.andLatestUsedTimeLessThanOrEqualTo(date);
			List<TpPPda> tpPPdas = tpPPdaMapper.selectByExample(example);
			if(CollectionUtils.isEmpty(tpPPdas)){
				log("查询到记录条数为0条");
				return ReturnT.SUCCESS;
			}
			log("查询到记录条数为："+tpPPdas.size());
			for (TpPPda tpPPda : tpPPdas) {
				log("开始执行签退操作,设备号："+tpPPda.getPdaNo()+",收费员："+tpPPda.getChargerCode());
				try{
					employeeChargeOperInnerService.pdaSignOut(tpPPda.getChargerCode(), tpPPda.getPdaNo(),ParkConstant.SignRecord.SIGN_OUT_TYPE_3);
				}catch(Exception e){
					log("更新PDA在线离线状态异常："+e.getMessage());
				}
			}
		}catch(Exception e){
			log("更新PDA在线离线状态异常："+e.getMessage());
		}
		return ReturnT.SUCCESS;
	}
	private void log(String msg){
		XxlJobHelper.log(msg);
		logger.info(msg);
	}

}