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.DAOHelper;
import com.fgkj.dao.impl.BattInfImpl;
import com.fgkj.dao.impl.Batt_maint_infImpl;
import com.fgkj.dao.impl.Batt_maint_processImpl;
import com.fgkj.db.DBUtil;
import com.fgkj.db.IDatabaseName;
import com.fgkj.dto.AllModel;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.Batt_Maint_Dealarm;
import com.fgkj.dto.Batt_User_Permit;
import com.fgkj.dto.Batt_maint_inf;
import com.fgkj.dto.Batt_maint_process;
import com.fgkj.dto.Batt_maintenance_inf;
import com.fgkj.dto.Batttestdata_inf;
import com.fgkj.dto.Page;
import com.fgkj.dto.ServiceModel;
import com.fgkj.dto.User_inf;

public class Batt_maint_infService {
	private ServiceModel model;
	private BaseDAO dao;
	private BaseDAO daoAgain;
	private BaseDAO daoProcess;
	private User_infService uservice;
	private Batt_maint_processService pservice;
	
	public Batt_maint_infService() {
		model=new ServiceModel();
		dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATT_MAINT_INF);
		daoAgain = BaseDAOFactory.getBaseDAO(BaseDAO.BATT_MAINT_INFAGAIN);
		daoProcess=BaseDAOFactory.getBaseDAO(BaseDAO.BATT_MAINT_PROCESS);
		uservice=new User_infService();
		pservice=new Batt_maint_processService();
	}
	
	
	//2.1电池故障维护记录查询
	public ServiceModel serchMaint(Object obj){
		Batt_Maint_Dealarm bmd = (Batt_Maint_Dealarm) obj;
		User_inf uinf=new User_inf();
		Batt_maint_process pinf=new Batt_maint_process();
		List<Batt_Maint_Dealarm> list =dao.serchByCondition(bmd);
		for(int i=0;i<list.size();i++){
			
			Batt_maint_inf mainf=list.get(i).getMainf();
			if(list.get(i).getMainf().getUsr_id()!=null){
				uinf.setUId(list.get(i).getMainf().getUsr_id());
				mainf.setUname(((List<User_inf>) uservice.serchuName(uinf).getData()).get(0).getUName());
			//	System.out.println(mainf.getUname());
				
				}
				
				if(list.get(i).getMainf().getCopy_uids()!=null&&list.get(i).getMainf().getCopy_uids().length()>0){
					//System.out.println(list.get(i).getMainf().getCopy_uids());
					String[] names=list.get(i).getMainf().getCopy_uids().split(",");
					String copyname=new String();
					for (String string : names) {
						uinf.setUId(Integer.parseInt(string));
						copyname+=((List<User_inf>) uservice.serchuName(uinf).getData()).get(0).getUName()+",";
					}
					
					copyname=copyname.substring(0, copyname.length()-1);
					mainf.setCopy_name(copyname);
					//System.out.println(mainf.getCopy_name());
				}
				
				if(list.get(i).getMainf().getAppoint_uid()!=null){
				uinf.setUId(list.get(i).getMainf().getAppoint_uid());
				mainf.setAppoint_name(((List<User_inf>) uservice.serchuName(uinf).getData()).get(0).getUName());
			//	System.out.println(mainf.getAppoint_name());
				}
			list.get(i).setMainf(mainf);
			//System.out.println(list.size());
		}
		if(list!=null&&list.size()>0){
			model.setCode(1);
			model.setData(list);
			model.setMsg("查询成功!");
		}else{
			model.setCode(0);
			model.setMsg("查询失败!");
		}
		return model;
	}
	
	// 2.2电池故障处理统计查询
	/*
	 * maint_result存放统计方式 
	 * fault_caption存放维护区 
	 * master_check存放包机人 
	 * remark存放品牌
	 */
	public List serchByCondition(Object obj) {
		//System.out.println(obj+"&&&&&&&&&&&&");
		Batt_User_Permit bup = (Batt_User_Permit) obj;
		BattInf binf=bup.getBinf();
		List<Batt_maint_inf> list = daoAgain.serchByCondition(binf);
		List<BattInf> listb=(new BattInfImpl()).searchAll();
		// 总电池数
		int allBatt=listb.size();
		// 超时次数
		List<ServiceModel> listmodel=new ArrayList<ServiceModel>();
		
		//System.out.println(list.get(1));
		if (list != null && list.size() > 0) {
			for (int i = 0; i < list.size(); i++) {
				//System.out.println(list.size()+"lll");
				int overTime = 0;
				// 未完成次数
				int lastNum = 0;
				// 时间段
				String perid_Time = "";
				
				//System.out.println(i);
				Date maint_time_limit = list.get(i).getMaint_time_limit();
				Date maint_done_time = list.get(i).getMaint_done_time();
				// System.out.println(maint_time_limit);
				// System.out.println(maint_done_time.getTime());
				// System.out.println(maint_time_limit.getTime());

				// 获取具体年份，月份和该月的总天数
				int year = maint_time_limit.getYear() + 1900;
				int month = maint_time_limit.getMonth() + 1;
				// int day=ActionUtil.getDaysByYearMonth(year, month);
				// System.out.println(day);

				// 获取统计方式
				String method = list.get(i).getMaint_result();

				if (method.equals("1")) {// 按月份
					perid_Time = ActionUtil.getFirstDayOfMonth(year, month - 1);
					perid_Time += " ";
					perid_Time += ActionUtil.getLastDayOfMonth(year, month - 1);
					// System.out.println(perid_Time);
				} else if (method.equals("2")) {// 按季度
					if (month < 3) {
						month = 1;
					} else {
						if (month % 3 == 0) {
							month = month / 3;
						} else {
							month = month / 3 + 1;
						}
					}
				//	System.out.println(month);

					perid_Time = ActionUtil.getFirstDayOfMonth(year,(month - 1) * 3);
					perid_Time += " ";
					perid_Time += ActionUtil.getLastDayOfMonth(year,month * 3 - 1);
					// System.out.println(perid_Time);
				} else if (method.equals("3")) {// 按年份
					perid_Time = ActionUtil.getFirstDayOfMonth(year, 0);
					perid_Time += " ";
					perid_Time += ActionUtil.getLastDayOfMonth(year, 11);
					// System.out.println(perid_Time);
				}
				if (maint_done_time.getTime() > maint_time_limit.getTime()) {
					overTime++;
				}
				if (list.get(i).getMaint_done() == 0) {
					lastNum++;
				}
				model = new ServiceModel();
				model.setCode(1);
				model.setMsgN(perid_Time); // 时间段
				model.setSum(list.size()); // 故障次数
				Float percentBatt=0f;
				if(allBatt!=0){
					percentBatt= (float) (list.size()/ allBatt);
				}
				//System.out.println(list.size());
				//System.out.println(allBatt);
				//System.out.println(percentBatt);
				model.setLowCH(percentBatt);//电池故障率
				
				model.setNewsum(lastNum); // 未完成次数
				Float percent = (float) (overTime / list.size());
				model.setLowCA(percent); // 超时率
				model.setMsg(list.get(i).getFault_caption());//维护区
				model.setMsgO(list.get(i).getMaster_check());    //责任人
				model.setMsgV(list.get(i).getRemark());//电池品牌
				listmodel.add(model);
			}
		} else {	
			model.setCode(0);
			model.setMsgN("0");
			listmodel.add(model);
		}
		ServiceModel lastModel=new ServiceModel();
		lastModel.setMsgN("0");
		lastModel.setCode(model.getCode());
		lastModel.setMsg(model.getMsg());
		lastModel.setLowCH(model.getLowCH());
		lastModel.setLowCA(model.getLowCA());
		lastModel.setMsgO(model.getMsgO());
		lastModel.setMsgV(model.getMsgV());
		listmodel.add(lastModel);//补全最后一次时间改变
	//	System.out.println(listmodel.size());
		int num=0;//存放下发作业数
		String time="";
		ServiceModel sumModel=null;
		List<ServiceModel> last=new ArrayList<ServiceModel>();
		for (int i=0;i<listmodel.size();i++) {
			//System.out.println(listmodel.get(i));
			  if(listmodel.get(i).getMsgN().equals(time)){
				   num++;
			   }else{
				   if(i!=0){
						sumModel=new ServiceModel();
						sumModel.setSum(num+1);// 故障次数
						sumModel.setNewsum(listmodel.get(i).getNewsum());// 未完成次数
						sumModel.setCode(listmodel.get(i).getCode());
						sumModel.setLowCH(listmodel.get(i).getLowCH());//故障率
						sumModel.setLowCA(listmodel.get(i).getLowCA());// 超时率
						sumModel.setMsgN(time);//时间段
						sumModel.setMsgV(listmodel.get(i).getMsgV());//电池平拍
						sumModel.setMsgO(listmodel.get(i).getMsgO()); //责任人
						sumModel.setMsg(listmodel.get(i).getMsg());//维护区
						last.add(sumModel);		
				   }
				num=0;		          
				time=listmodel.get(i).getMsgN();
		    }
			    
		} 
//		for (ServiceModel s : last) {
//			System.out.println(s);
//		}
		
		
		List<ServiceModel> listd=new ArrayList();
		for(int i=(bup.getPage().getPageCurr()-1)*bup.getPage().getPageSize();i<bup.getPage().getPageSize()*bup.getPage().getPageCurr()&&i<last.size();i++){
			last.get(i).setLowRA((float)last.size());
			listd.add(last.get(i));
		}
		return listd;

	}

	public ServiceModel add(Object obj) {
		Boolean bl=dao.add(obj);
		if(bl){
			model.setCode(1);
			model.setMsg("添加成功!");
		}
		else{
			model.setMsg("添加失败!");
		}
		return model;
		
	}
	//2.1 电池维护记录查询(编辑记录)
	public ServiceModel update(Object obj1,Object obj2) {
		Batt_maint_inf mainf=(Batt_maint_inf) obj1;
		Boolean bl = dao.update(mainf);
		//System.out.println(bl);
		List<Batt_maint_process> process = (List<Batt_maint_process>)obj2;
		ArrayList<String> sql_str = new ArrayList<String>();//存放所有的sql语句
		if (bl) {
			for(int i=0;i<process.size();i++){
				Batt_maint_process bprocess=process.get(i);
				bprocess.setBatt_maint_rec_id(mainf.getNum());
				sql_str.add(((Batt_maint_processImpl)daoProcess).addPro(bprocess));
				//System.out.println("sql_str:"+sql_str);
				
			}
			Boolean blP= DAOHelper.makeManualCommit(DBUtil.getConn(),sql_str);
			if(blP){
				model.setCode(1);
				model.setMsg("修改成功!");
			}	
			else {
				model.setCode(0);
				model.setMsg("修改失败!");
			}
				
		} else {
			model.setMsg("修改失败!");
		}
		return model;
	}

	//2.1 电池维护记录查询（删除记录）
	public ServiceModel delete(Object obj) {
		Batt_maint_inf mainf=(Batt_maint_inf) obj;
		Batt_maint_process bprocess=new Batt_maint_process();
		bprocess.setBatt_maint_rec_id(mainf.getNum());				//通过Batt_maint_rec_id属性删除
		Boolean bl = dao.del(mainf);
		if (bl) {
			Boolean blp=daoProcess.del(bprocess);
			if(blp){
				model.setCode(1);
				model.setMsg("删除成功!");
			}else{
				model.setCode(0);
				model.setMsg("删除失败!");
			}
			
		} else {
			model.setCode(0);
			model.setMsg("删除失败!");
		}
		return model;
	}


	//1.1,1.2根据battgroupid查时间
	public ServiceModel serchByInfo(Object obj) {
		model=new ServiceModel();
		Batt_maint_inf mainf =(Batt_maint_inf) obj;
		List<Batt_maint_inf> list = dao.serchByInfo(mainf);
		/*for (Batt_maint_inf u : list) {
			System.out.println(u);
		}*/

		if (list != null && list.size() > 0) {
			model.setCode(1);
			model.setData(list);
			model.setSum(list.size());
		}
		return model;
	}

	//0.3查询所有的维护记录（只传page对象）
	public ServiceModel search(){
		//Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
		List<Batt_Maint_Dealarm> list=((Batt_maint_infImpl)dao).search();
		if(list!=null&&list.size()>0){
			model.setCode(1);
			model.setData(list);
		}else{
			model.setCode(0);
			model.setMsg("查询失败!");
		}
		return model;
	}

	//0.4电池组故障率
	public ServiceModel searchAll() {
		List<Batt_maint_inf> list = dao.searchAll();
		List<BattInf> listb=new BattInfImpl().searchAll();
		if(list!=null && listb!=null){
			model.setCode(1);
			model.setNewsum(list.size());
			model.setSum(listb.size());
		}
		//System.out.println(model);
		return model;
	}

	//0.4/0.8电池组故障率/维护率(最新)
	public ServiceModel searchByStationName(Object obj) {
		Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
		BattInf binf=bmd.getBinf();
		Batt_maint_inf mainf=bmd.getMainf();
		List<Batt_maint_inf> list = ((Batt_maint_infImpl)dao).searchByStationName(bmd);		//故障数
		mainf.setMaint_done(1);
		List<Batt_maint_inf> listD = ((Batt_maint_infImpl)dao).searchByStationName(bmd);	//故障维护数
		
		List<BattInf> listB=new BattInfImpl().search(binf);//
		model.setCode(listD.size());	  ////故障维护数
		model.setNewsum(listB.size());    //电池组数
		model.setSum(list.size());		  //故障数	
		//System.out.println(model);
		return model;
	}
	
	//根据电池组id查询电池的故障记录
	public ServiceModel searchByBattgroupId(Object obj) {
		model=new ServiceModel();
		List<Batt_maint_inf> list = ((Batt_maint_infImpl)dao).searchByBattgroupId(obj);
		User_inf uinf=new User_inf();		
		if(list!=null && list.size()>0){
			for (int i = 0; i < list.size(); i++) {
				uinf.setUId(list.get(i).getUsr_id());
				List<User_inf> users=(List<User_inf>) uservice.serchuName(uinf).getData();
				//System.out.println(users);
				if(users.size()>0){
					list.get(i).setUname(users.get(0).getUName());
				}
				//System.out.println(list.get(i));
			}
			model.setCode(1);
			model.setData(list);
			model.setMsg("查询成功");
		}else{
			model.setMsg("查询失败");
		}
		return model;
	}

	public static void main(String[] args) throws ParseException {
		Batt_maint_infService us = new Batt_maint_infService();

		BattInf binf = new BattInf();
		/*
		 * 维护区：stationname1 包机人：stationname 电池品牌：battproducer 统计方式：devicename
		 * 统计开始时间：battproductdate 统计结束时间：battproductdata1
		 */
		binf.setStationName("");
		binf.setStationName1("");
		binf.setBattGroupName("");
		binf.setBattGroupName1("");
		binf.setBattProducer("");
		binf.setBattGroupId(0);

		binf.setDeviceName("2");
		binf.setMonCapStd(0f);
		binf.setMonVolStd(0f);
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		Date date1 = sdf.parse("2000-01-01");
		Date date2 = sdf.parse("2016-12-30");
		binf.setBattProductDate(ActionUtil.getSimpDate(date1));
		binf.setBattProductDate1(ActionUtil.getSimpDate(date2));
		binf.setBattInUseDate(ActionUtil.getSimpDate(date1));
		binf.setBattInUseDate1(ActionUtil.getSimpDate(date2));

		/*
		 * binf.getStationName1(), binf.getStationName(),
		 * binf.getBattGroupName(), binf.getBattProducer(),
		 * binf.getBattGroupName1(), binf.getBattProductDate(),
		 * binf.getBattProductDate1(), binf.getBattInUseDate(),
		 * binf.getBattInUseDate1(),uinf.getuName()
		 */

		Batt_maint_inf mainf = new Batt_maint_inf();
		mainf.setRemark("100");
		mainf.setMaint_done_time(ActionUtil.getSimpDate(date1));
		mainf.setMaint_done_time1(ActionUtil.getSimpDate(date2));
		mainf.setMaint_done(100);

		Batttestdata_inf tdata = new Batttestdata_inf();
		tdata.setTest_type(0);
		tdata.setTest_starttype(0);
		tdata.setRecord_time(ActionUtil.getSimpDate(date1));
		tdata.setRecord_time1(ActionUtil.getSimpDate(date2));

		User_inf uinf = new User_inf();
		uinf.setUName("0");

		Page p = new Page();
		p.setPageCurr(1);
		p.setPageSize(1);

		Batt_User_Permit bup=new Batt_User_Permit();
		bup.setBinf(binf);
		bup.setPage(p);
		bup.setUinf(uinf);
		
		Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
		bmd.setBinf(binf);
		bmd.setMainf(mainf);
		bmd.setTdata(tdata);
		bmd.setPage(p);
		bmd.setUinf(uinf);
		
		
		//us.searchByStationName(bmd);
	   // us.serchMaint(bmd);
		//us.serchByCondition(bup);
		//us.search();
		//us.searchAll();
		mainf.setBattGroupId(1000001);
		us.searchByBattgroupId(mainf);
	}	
}