package com.qianwen.mdc.collect.service;

import java.util.Arrays;
import java.util.Date;
import java.util.Map;
import java.util.Set;

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.stereotype.Service;

import com.qianwen.mdc.collect.cache.WorkstationCache;
import com.qianwen.mdc.collect.dto.WorkstationDTO;
import com.qianwen.mdc.collect.entity.iotdb.DeviceState;
import com.qianwen.mdc.collect.entity.iotdb.ProcessParam;
import com.qianwen.mdc.collect.enums.FeedbackTimePointEnum;
import com.qianwen.mdc.collect.mapper.iotdb.ProcessParamMapper;
import com.qianwen.mdc.collect.vo.FactoryDataVO;

import cn.hutool.core.util.ObjectUtil;
/**
 * 设备离线处理服务,超过一定时间无采集数据判定为离线，插入离线状态数据
 */
@Service
public class DeviceOfflineCheckService{
    private static final Logger log = LoggerFactory.getLogger(DeviceOfflineCheckService.class);
    /**
     * 离线判定时长，默认5分钟
     */
    @Value("${offlineConfigDuration:3000000}")
    private long offlineConfigDuration;
    public static final String OFFLINE_VALUE = "4";//离线状态值
    @Autowired
	private ProcessParamService paramService;

    @Autowired
    private WorkstationCache workstationCache;
    @Autowired
    private ProcessParamMapper processParamMapper;
    
    @Autowired
	private FactoryDataService factoryDataService;
    /**
     * 保存状态固定点数据(state_{workstationId})
     * @param workstationIdList
     */
    public void checkOffline() {
    	//将数据按照工位id分组
    	Map<String, WorkstationDTO> workstationsMap = workstationCache.getWorkstations();
        if (ObjectUtil.isEmpty(workstationsMap)) {
        	log.info("缓存无设备数据，退出");
        	return;
        }
        	
        Set<String> workstationIds = workstationsMap.keySet();
        
        log.info("离线检查工位总数:{}",workstationsMap.size());
        
        for(String workstationId :workstationIds) {
        	log.info("开始检查工位{}的离线状态",workstationId);
        	Long wid = Long.parseLong(workstationId);
        	handleWorkstationOffline(wid);
        }
    
    }
    /**
     * 检查一个工位是否离线，离线则填充离线状态数据
     * @param workstationId
     */
    public void handleWorkstationOffline(long workstationId) {
    	ProcessParam lastParam = processParamMapper.lastParamByWorstationId(workstationId);
    	
    	long nowMills = System.currentTimeMillis();
    	long onlineRange = nowMills - offlineConfigDuration;
    	if(lastParam != null && lastParam.getTime()> onlineRange) {
    		//有数据，且在判定时间内-》在线
    		return;
    	}
    	//TODO 这里一直离线是什么数据
    	
    	//时间段内无参数，说明设备没采集数据判定为离线，插入状态，然后发送realTime消息给mdc
    	
    	ProcessParam statusParam = new ProcessParam();
    	statusParam.setTime(nowMills);
    	statusParam.setN("DeviceStatus");
    	statusParam.setV(OFFLINE_VALUE);
    	statusParam.setWorkstationId(workstationId);
    	if(lastParam == null || !lastParam.getN().equals("DeviceStatus")) {
    		//之前无任何采集的数据(或者上一条不是状态数据)，新加一条离线状态数据
	    	paramService.insertProcessParam(statusParam);
    	}
    	
    	//通知mdc更新实时状态
    	paramService.sendRealtimeDataMsg(statusParam);
    	
    }
    
}