package com.java110.job.task.visiterToMachine;

import com.java110.core.log.LoggerFactory;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.task.TaskDto;
import com.java110.dto.visit.VisitDto;
import com.java110.intf.community.IVisitInnerServiceSMO;
import com.java110.job.quartz.TaskSystemQuartz;
import com.java110.po.owner.VisitPo;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

/**
 * 预约状态修改定时任务
 *
 * @author fqz
 * @date 2022-04-20
 */
@Component
public class EditRecordStateTemplate extends TaskSystemQuartz {

    @Autowired
    private IVisitInnerServiceSMO visitInnerServiceSMOImpl;

    private static Logger logger = LoggerFactory.getLogger(EditRecordStateTemplate.class);

    @Override
    protected void process(TaskDto taskDto) throws Exception {
        logger.debug("开始执行微信模板信息推送" + taskDto.toString());
        // 获取小区
        List<CommunityDto> communityDtos = getAllCommunity();
        for (CommunityDto communityDto : communityDtos) {
            doEditRecordState(taskDto, communityDto);
        }
    }

    private void doEditRecordState(TaskDto taskDto, CommunityDto communityDto) throws ParseException {
        //查询访客记录信息
        VisitDto visitDto = new VisitDto();
        visitDto.setCommunityId(communityDto.getCommunityId());
        List<VisitDto> visitDtos = visitInnerServiceSMOImpl.queryVisits(visitDto);
        if (visitDtos == null || visitDtos.size() < 1) {
            return;
        }
        for (VisitDto visit : visitDtos) {
            //获取访客离开时间
            String departureTime = visit.getDepartureTime();
            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            Date finishTime = format.parse(departureTime);
            Date date = new Date();
            if (finishTime.getTime() <= date.getTime()) { //如果访客离开时间小于当前时间，这条访客记录就失效
                VisitPo visitPo = new VisitPo();
                visitPo.setvId(visit.getvId());
                visitPo.setRecordState("1"); //预约状态 0表示有效 1表示无效
                visitInnerServiceSMOImpl.updateVisit(visitPo);
            }
        }
    }

}