package com.qianwen.smartman.modules.mdc.service;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Service;

import com.baomidou.dynamic.datasource.annotation.DS;
import com.qianwen.smartman.modules.mdc.dto.ProcessParameterVO;

@DS("iotdb")
@Service
public class ProcessParameterHelperService {
    private static final Logger log = LoggerFactory.getLogger(ProcessParameterHelperService.class);
    
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
	@DS("iotdb")
	public ProcessParameterVO queryLastParameterLessThenTime(long workstationId,String item,Long time) {
		
		ProcessParameterVO vo = null;
		String sql ="select max_time(n) as ts,last_value(n) as n,last_value(v) as v,last_value(workstation_id) as workstationId from root.f2.process_param_"+workstationId+"_"+item+" where time<"+time+" limit 1 align by device";
		List<ProcessParameterVO> list =  jdbcTemplate.query(sql, new RowMapper<ProcessParameterVO>() {

			@Override
			public ProcessParameterVO mapRow(ResultSet rs, int rowNum) throws SQLException {
				ProcessParameterVO p = new ProcessParameterVO();
				Long time = rs.getLong("ts");
				p.setRealTime(time);
				p.setCollectItem(rs.getString("n"));
				p.setValueCollect(rs.getString("v"));
				
				return p;
			}
			
		});
		if(!list.isEmpty()) {
			vo = list.get(0);
		}
		return vo;
	}
	
	/**
	 * 获取工位最新参数值(采集时间应大于指定时间)
	 * @param workstationId
	 * @param item  参数名称,如DeviceStatus/Output
	 * @param time 指定的时间
	 * @return
	 */
	@DS("iotdb")
	public ProcessParameterVO getLastParameterGreaterThenTime(long workstationId,String item,Long time) {
		
		
		ProcessParameterVO vo = null;
		String sql ="select max_time(n) as ts,last_value(n) as n,last_value(v) as v,last_value(workstation_id) as workstationId from root.f2.process_param_"+workstationId+"_"+item+" where time>"+time+" limit 1 align by device";
		List<ProcessParameterVO> list =  jdbcTemplate.query(sql, new RowMapper<ProcessParameterVO>() {

			@Override
			public ProcessParameterVO mapRow(ResultSet rs, int rowNum) throws SQLException {
				ProcessParameterVO p = new ProcessParameterVO();
				p.setRealTime(rs.getLong("ts"));
				p.setCollectItem(rs.getString("n"));
				p.setValueCollect(rs.getString("v"));
				
				return p;
			}
			
		});
		if(!list.isEmpty()) {
			vo = list.get(0);
		}
		return vo;
		
		
	}

}