package com.tievd.jyz.handler;

import com.alibaba.fastjson.JSON;
import com.tievd.jyz.cache.AlgorithmCache;
import com.tievd.jyz.cache.DeviceCache;
import com.tievd.jyz.entity.Device;
import com.tievd.jyz.entity.PatrolConfig;
import com.tievd.jyz.entity.SysAlgorithmItem;
import com.tievd.jyz.mqtt.dto.MqttParamDTO;
import com.tievd.jyz.service.IPatrolConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.sql.Time;

/**
 * 事件接收处理类
 * @author timi
 */
@Slf4j
@Component
public class PatrolConfigHandler {

    @Autowired
    IPatrolConfigService patrolConfigService;

    
    public void configPatrol(MqttParamDTO<JSON> param){
        PatrolConfig patrolConfig = JSON.toJavaObject(param.getData(), PatrolConfig.class);
        String deviceSn = param.getSn();
        Device device = DeviceCache.getDeviceBySn(deviceSn);
        //1&00:00-23:59@2&00:00-23:59@3&00:00-23:59@4&00:00-23:59@5&00:00-23:59@6&00:00-23:59@0&00:00-23:59
        //时间段格式如上，当前设计每天时间段一致，故只取第一天时间进行合并
        String timePeriod = patrolConfig.getTimePeriod();
        Time start = null;
        Time end = null;
        try {
            timePeriod = timePeriod.substring(timePeriod.indexOf("1&") + 2, timePeriod.indexOf("@2&"));
            String[] periods = timePeriod.split("\\|");
            //合并时间段
            for (String period : periods) {
                String[] time = period.split("-");
                if (time.length < 2) continue;
                Time s = Time.valueOf(time[0] + ":00");
                Time e = Time.valueOf(time[1] + ":00");
                if (start == null || start.after(s)) start = s;
                if (end == null || end.before(e)) end = e;
            }
            if (start == null || end == null){
                log.info("巡查时间段数据异常");
                return;
            }
        } catch (Exception e) {
            log.info("======> 巡查配置时间段转换失败：{}", timePeriod);
            return;
        }
        patrolConfig.setTimeStart(start);
        patrolConfig.setTimeEnd(end);
        SysAlgorithmItem alg = AlgorithmCache.getAlgorithmMap(patrolConfig.getAlgorithmCode());
        patrolConfig.setAlgorithmName(alg.getAlgorithmName()).setOrgCode(device.getOrgCode()).generateId();
        
        patrolConfigService.saveOrUpdate(patrolConfig);
    }
    
    
    
}