package com.fgkj.services;

import java.util.ArrayList;
import java.util.List;

import com.fgkj.dao.AlarmDaoFactory;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.dao.ProcessServerDao;
import com.fgkj.dao.impl.Alarm_paramImpl;
import com.fgkj.dao.impl.BattInfImpl;
import com.fgkj.dao.impl.Dev_paramImpl;
import com.fgkj.dao.impl.Process_surveyImpl;
import com.fgkj.dto.Alarm_param;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.Dev_param;
import com.fgkj.dto.Process_survey;
import com.fgkj.dto.ServiceModel;
import com.mysql.fabric.xmlrpc.base.Array;

public class Dev_paramService {
	private ServiceModel model;
	private BaseDAO dao;
	public Dev_paramService() {
		super();
		this.model = new ServiceModel();
		this.dao = BaseDAOFactory.getBaseDAO(BaseDAO.DEV_PARAM);
	}
	 //给设备添加参数
	public ServiceModel add(Object obj){
		boolean bl=dao.add(obj);
		if(bl){
			model.setCode(1);
			model.setMsg("插入成功!");
		}else{
			model.setCode(0);
			model.setMsg("插入失败!");
		}		
		return model;
	}
	//查询所有设备的所有的告警参数
	public ServiceModel update(Object obj){
		Boolean bl=dao.update(obj);
		if(bl){
			//告警参数修改成功后重启服务
			int alarm_id=((Dev_param) obj).getAlm_id();
			Process_survey process=new Process_survey();
			//将电池告警的服务设为重启
			process.setProcessName(ProcessServerDao.BMS_FBSDEV_ALARM_BATT);
			Boolean b=(new Process_surveyImpl()).update(process);
			model.setCode(1);
			model.setMsg("修改成功!");
		}else{
			model.setCode(0);
			model.setMsg("修改失败!");
		}
		return model;
	}
	 //查询所有设备的所有的告警参数
	public ServiceModel searchAll(){
		List list=dao.searchAll();
		if(list!=null && list.size()>0){
			model.setCode(1);
			model.setData(list);
			model.setMsg("查询成功!");
		}else{
			model.setCode(0);
			model.setMsg("查询失败!");
		}		
		return model;
	}
	//根据设备id和告警类型查设备告警参数
	public ServiceModel serchByCondition(Object obj){
		List list=dao.serchByCondition(obj);
		if(list!=null && list.size()>0){
			model.setCode(1);
			model.setData(list);
			model.setMsg("查询成功!");
		}else{
			model.setCode(0);
			model.setMsg("查询失败!");
		}		
		return model;
	}
	//查询所有存在设备告警参数的机房
	public ServiceModel serchAllDevId(){
		List list=((Dev_paramImpl)dao).serchAllDevId();
		if(list!=null && list.size()>0){
			model.setCode(1);
			model.setData(list);
			model.setMsg("查询成功!");
		}else{
			model.setCode(0);
			model.setMsg("查询失败!");
		}		
		return model;
	}
	//根据设备id查询设备对应的告警参数种类
	public ServiceModel serchByInfo(Object obj){
		List list=dao.serchByInfo(obj);
		if(list!=null && list.size()>0){
			model.setCode(1);
			model.setData(list);
			model.setMsg("查询成功!");
		}else{
			model.setCode(0);
			model.setMsg("查询失败!");
		}		
		return model;
	}
	
	 //根据设备id查询设备所有的参数
	public ServiceModel serchParamById(Object obj){
		List list=((Dev_paramImpl)dao).serchParamById(obj);
		if(list!=null && list.size()>0){
			model.setCode(1);
			model.setData(list);
			model.setMsg("查询成功!");
		}else{
			model.setCode(0);
			model.setMsg("查询失败!");
		}		
		return model;
	}
	public static void main(String[] args) {
		Dev_paramService dservice=new Dev_paramService();
		BattInf binf=new BattInf();
		binf.setBattGroupId(1000021);
		int dev_id=(new BattInfImpl()).serchDev_id(binf);
		Alarm_param aparam=new Alarm_param();
		aparam.setAlm_id(1);
		List listP=(new Alarm_paramImpl()).serchByCondition(aparam);
		List list=new ArrayList();
		for (int i = 0; i < listP.size(); i++) {
			Alarm_param param=(Alarm_param) listP.get(i);
			Dev_param dparam=new Dev_param();
			dparam.setDev_id(dev_id);
			dparam.setAlm_id(param.getAlm_id());
			dparam.setAlm_name(param.getAlm_name());
			dparam.setAlm_high_coe(param.getAlm_high_coe());
			dparam.setAlm_low_coe(param.getAlm_low_coe());
			dparam.setAlm_high_level(param.getAlm_high_level());
			dparam.setAlm_low_level(param.getAlm_low_level());
			dparam.setAlm_high_en(param.getAlm_high_en());
			dparam.setAlm_low_en(param.getAlm_low_en());
			list.add(dparam);
		}
		ServiceModel model=dservice.add(list);
	}
}