package com.fgkj.services;

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

import com.fgkj.actions.ActionUtil;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.dao.BattCapFactory;
import com.fgkj.dao.impl.Batt_param_lowImpl;
import com.fgkj.dao.impl.Battalarm_dataDAOImpl;
import com.fgkj.dao.impl.Batttestdata_infDAOImpl;
import com.fgkj.dao.impl.BatttestdatastopDAOImpl;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.Batt_Maint_Dealarm;
import com.fgkj.dto.Batt_param_low;
import com.fgkj.dto.Batttestdata_inf;
import com.fgkj.dto.Batttestdatastop;
import com.fgkj.dto.ServiceModel;
import com.mysql.fabric.xmlrpc.base.Array;

public class BatttestdatastopService {
	private ServiceModel model;
	private BaseDAO dao;
	private BaseDAO daoA;
	private BaseDAO daoT;
	
	public BatttestdatastopService() {
		model = new ServiceModel();
		dao = BaseDAOFactory.getBaseDAO(BaseDAO.BATTTESTDATASTOP);
		daoA = BaseDAOFactory.getBaseDAO(BaseDAO.BATTALARM_DATA);
		daoT = BaseDAOFactory.getBaseDAO(BaseDAO.BATTTESTDATA_INF);
	}
	
	public ServiceModel serchByCondition(Object obj){
		Batttestdatastop btds=(Batttestdatastop)obj;
		if(btds.getBattGroupId()!=null && btds.getTest_record_count()!=null){
			List list=dao.serchByCondition(obj);
			if(list !=null && list.size()>0){
				model.setCode(1);
				model.setData(list);
			}
		}
		return model;
	}
	
	//1查询最新落后单体
	public ServiceModel serchByLowNew(Object obj){
	    	 Batttestdatastop bstop=(Batttestdatastop) obj;
	    	//System.out.println("bstop:   "+bstop);
	 		List<Batttestdatastop> listLow=((BatttestdatastopDAOImpl)dao).serchByLowNew(bstop);
	 		List<Batttestdatastop> listType=((BatttestdatastopDAOImpl)dao).serchByType(bstop);
	 			 		
	 		if(listType!=null&& listType.size()>0){
	 			model.setNewsum(1);
	 		}else{
	 			model.setNewsum(0);
	 		}
	 		if(listLow!=null && listLow.size()>0){
	 			model.setCode(1);
	 			model.setData(listLow);
	 			model.setSum(listLow.size());//最新落后单体数
	 			//落后最新单体编号
	 			String numStrN="";
	 			for(int i=0;i<listLow.size();i++){
	 				numStrN+=",";
	 				numStrN+=listLow.get(i).getMon_num().toString();
	 				
	 			}
	 			numStrN=numStrN.substring(1, numStrN.length());
	 			//System.out.println(numStr);
	 			model.setMsgN(numStrN);
	 			//
	 			//落后最新单体编号
	 			String numStrV="";
	 			for(int i=0;i<listLow.size();i++){
	 				numStrV+=",";
	 				numStrV+=listLow.get(i).getMon_vol().toString();
	 				
	 			}
	 			numStrV=numStrV.substring(1, numStrV.length());
	 			//System.out.println(numStr);
	 			model.setMsgV(numStrV);
	 		}else {
	 			model.setCode(0);	 			
	 			model.setSum(0);
	 			model.setMsgN("");
			}	
	    	
	 		//System.out.println(model);
	 		return model;
	 	} 

	//1.2得到落后的信息
    public ServiceModel serchByLow(Object obj){
       Batttestdatastop bstop=(Batttestdatastop) obj;
       model=new ServiceModel();  
       //根据落后的数据（数量，编号，电压）
		List<Batttestdatastop> listLow=((BatttestdatastopDAOImpl)dao).serchByLow(bstop);
		//截止平均电压值
		List<Batttestdatastop> list=((BatttestdatastopDAOImpl)dao).serch(bstop);
		if(listLow!=null && listLow.size()>0){
			//落后单体编号
			String numStrN="";
			//落后单体电压
			String numStrV="";
			for(int i=0;i<listLow.size();i++){
				numStrN+=",";
				numStrN+=listLow.get(i).getMon_num().toString();
				numStrV+=",";
				Float mon_vol=(float)Math.round(listLow.get(i).getMon_vol()*1000)/1000;
				numStrV+=mon_vol.toString();
				
			}
			numStrN=numStrN.substring(1, numStrN.length());
			numStrV=numStrV.substring(1, numStrV.length());
			
			model.setCode(1);
			model.setMsgN(numStrN);//落后单体编号
			model.setMsgV(numStrV);//落户单体电压编号
			if(list!=null&&list.size()>0){
			   Float mon_avg=(float)Math.round(list.get(list.size()-1).getMon_avg()*1000)/1000;
 			   model.setLowRH(mon_avg);//平均截至电压
 			}
			model.setSum(listLow.size());//落后单体数
			model.setNewsum(listLow.get(listLow.size()-1).getBattGroupId());
		}else {	
			model.setCode(0);	
			//model.setSum(0);
			if(list!=null&&list.size()>0){
				 Float mon_avg=(float)Math.round(list.get(list.size()-1).getMon_avg()*1000)/1000;
	 			 model.setLowRH(mon_avg);//平均截至电压
  			}
		}	
		//System.out.println(model.getNewsum()+"    "+model.getLowRH());
		return model;
	} 
    
    //3.得到测试信息
    public ServiceModel serchByMonNum(Object obj){
	    model=new ServiceModel();
		List<Batttestdatastop> list=((BatttestdatastopDAOImpl)dao).serchByMonNum(obj);
		//System.out.println(((Batttestdatastop)obj).getBattGroupId());
		/*List<Batttestdatastop> listType=((BatttestdatastopDAOImpl)dao).serchByType(obj);
		if(listType!=null&& listType.size()>0){
			model.setNewsum(1);
		}else{
			model.setNewsum(0);
		}*/
		
		if(list!=null && list.size()>0){
			model.setCode(1);
			model.setData(list);//根据battgroupid和mon_num的值查出电池单体信息
		}else{
			model.setCode(0);
		}
	//	for(Batttestdatastop b:list){
	//		System.out.println(b);
	//	}
	//	System.out.println(list);
		return model;
	}
	
    //1.4得到历史最高电容/平均电容/最低电容/最新测试电容
    public ServiceModel serchByCap(Object obj) {
		model=new ServiceModel();
		List<Batttestdatastop> list=((BatttestdatastopDAOImpl)dao).serchByCap(obj);
		if(list!=null&&list.size()>0){
			model.setCode(0);
			model.setData(list);
		}else{
			model.setCode(0);
			model.setMsg("查询失败！");
		}
		return model;
	}

    //7.1电池放电落后单体筛选，并将电容告警的电池组加到告警表中
    public ServiceModel serchBadBatt(Object obj){
	   	List<Batt_Maint_Dealarm> list=((Batttestdata_infDAOImpl)daoT).serchBadBatt(obj);
	   	//System.out.println("list.size(): "+list.size());
	   	
	   	float param=0;//容量有效参数
	   	double STDAH=0;//标存容量
	   	Batt_param_low capLow=new Batt_param_low();
	   	capLow.setLow_type(BattCapFactory.CapType_type);;
	   	capLow.setLow_nametype(BattCapFactory.CapType_name);
	   	capLow.setLow_method(BattCapFactory.CapType_method);
	   	List<Batt_param_low> listC=(new Batt_param_lowImpl().serchByLow(capLow));
	   	//System.out.println("listC："+listC.size());
	   	if(listC!=null&&listC.size()>0){
	   		param=listC.get(listC.size()-1).getLow_value();
	   	}
		int flag=0;//该次放电是否有效判断
		List<Batt_Maint_Dealarm> listE=new ArrayList();//存放放电有效的测试
	   	if(list!=null&&list.size()>0){
	   		for(int i=0;i<list.size();i++){
	   			STDAH=list.get(i).getBinf().getMonCapStd();
	   			float testCap=list.get(i).getTdata().getTest_cap();//此次放电量统计
	   			//System.out.println(list.get(i).getTdata().getBattGroupId()+"  "+list.get(i).getTdata().getTest_record_count()+"   "+testCap+"  "+param+"  "+STDAH);
	   			flag=BattCapFactory.Judge(testCap, param, STDAH);
	   		    if(flag==1){
	   		    	if(listE.size()>0){
	   		    		int tdata_battgroupid=list.get(i).getTdata().getBattGroupId();
	   		    		int e_battgroupid=listE.get(listE.size()-1).getTdata().getBattGroupId();
	   		    		if(tdata_battgroupid!=e_battgroupid){
	   		    			listE.add(list.get(i));
	   		    		}else{
	   		    			continue;
	   		    		}
	   		    	}else{
	   		    		listE.add(list.get(i));
	   		    	}
	   		    	flag=0;
	   		    }
	   		}
	   	}
   	
   		List listAll=new ArrayList();//存放最后查询出来的所有落后电池组的落后单体
   		for (int j = 0; j < listE.size(); j++) {
   			List<Batt_Maint_Dealarm> listB= ((BatttestdatastopDAOImpl)dao).serchBadBatt((listE).get(j));
   			System.out.println(listE.get(j).getTdata().getBattGroupId()+" "+listB.size());
		   
		    //将容量落后的信息插入到告警表中
		   Boolean bl=((Battalarm_dataDAOImpl)daoA).addPro(listB);
		   // System.out.println(bl);
		    if(listB!=null&&listB.size()>0){
		       listAll.add(listB);
		    }
   		}
	   	if(listAll!=null&&listAll.size()>0){
	   		model.setData(listAll);
	   		model.setCode(1);
	   		model.setMsg("查询成功!");
	   	}else{
	   		model.setCode(0);
	   		model.setMsg("查询失败!");
	   	}
   		System.out.println(listAll.size());
		return model;
	}

	
	public static void main(String[] args) throws ParseException {
//		Batttestdatastop btds=new Batttestdatastop();
//		btds.setBattGroupId(1002563);
//		//btds.setTest_record_count(1);
//		btds.setMon_num(0);
		BatttestdatastopService bs=new BatttestdatastopService();
//		bs.serchByMonNum(btds);
		
		
		
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		Date date1 = sdf.parse("2000-01-01");
		Date date2 = sdf.parse("2020-01-01");
		Batt_Maint_Dealarm bmd=new Batt_Maint_Dealarm();
		BattInf binf=new BattInf();
		Batttestdata_inf tdata=new Batttestdata_inf();

	    binf.setBattInUseDate(ActionUtil.getSimpDate(date1));
	    binf.setBattInUseDate1(ActionUtil.getSimpDate(date2));
	    binf.setStationName1("");
        binf.setStationName("");
        binf.setBattProducer("");
        binf.setBattGroupId(0);
        bmd.setBinf(binf);
        tdata.setTest_starttime(ActionUtil.getSimpDate(date1));
        tdata.setTest_starttime_ex(ActionUtil.getSimpDate(date2));
        bmd.setTdata(tdata);
        bs.serchBadBatt(bmd);
		
		//System.out.println(new BatttestdatastopService().serchByCondition(btds));;
	}
}