package com.shlanbao.tzsc.pms.equ.runtime.service.impl;

import java.util.ArrayList;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.shlanbao.tzsc.base.dao.BaseDaoI;
import com.shlanbao.tzsc.base.mapping.SchStatOutput;
import com.shlanbao.tzsc.base.model.DataGrid;
import com.shlanbao.tzsc.base.model.PageParams;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.pms.equ.effective.beans.EffectiveGraphBean;
import com.shlanbao.tzsc.pms.equ.runtime.beans.EqpRunTimeBean;
import com.shlanbao.tzsc.pms.equ.runtime.service.EqpRunTimeServiceI;
import com.shlanbao.tzsc.utils.tools.DateUtil;
import com.shlanbao.tzsc.utils.tools.MathUtil;
import com.shlanbao.tzsc.utils.tools.StringUtil;
/**
 * 
 * @ClassName: EqpRunTimeServiceImpl 
 * @Description: 设备运行统计service实现类 
 * @author luo
 * @date 2015年3月5日 下午3:44:56 
 *
 */
@Service
public class EqpRunTimeServiceImpl extends BaseService implements EqpRunTimeServiceI{

	@Autowired
	private BaseDaoI<Object> baseDao;
	
	/*@Autowired
	private BaseDaoI<SchStatOutput> baseDaoI;*/
	/**
	 * 设备运行统计查询方法
	 */
	@Override
	public DataGrid queryEqpRunTimeByBean(EqpRunTimeBean bean, PageParams pageParams) {
		String hql = "from SchStatOutput o where 1=1 and o.del=0 ";
		StringBuffer params = new StringBuffer();
		if(StringUtil.notNull(bean.getEqpName())){
			params.append(" and o.schWorkorder.mdEquipment.equipmentName like '%"+ bean.getEqpName() +"%'");
		}
		if(StringUtil.notNull(bean.getEqpType())){
			params.append(" and o.schWorkorder.mdEquipment.mdEqpType.id ='"+ bean.getEqpType() +"'");
		}
		if(StringUtil.notNull(bean.getTeamName())){
			params.append(" and o.schWorkorder.mdTeam.id='"+ bean.getTeamName() +"'");
		}
		if(StringUtil.notNull(bean.getShiftName())){
			params.append(" and o.schWorkorder.mdShift.id='"+ bean.getShiftName() +"'");
		}
		if(bean.getRunDate()!=null&&StringUtil.notNull(bean.getRunDate().toString().trim())){ 
			params.append(" and CONVERT(varchar(100),o.schWorkorder.date, 23)>='"+ bean.getRunDate() +"'");
		}
		if(bean.getRunDate2()!=null&&StringUtil.notNull(bean.getRunDate2().toString().trim())){
			params.append(" and CONVERT(varchar(100),o.schWorkorder.date, 23)<='"+ bean.getRunDate2() +"'");
		}
		String param = params.toString();
		/*hql = hql.concat(StringUtil.fmtDateBetweenParams("o.schWorkorder.stim", bean.getRunDate(), bean.getRunDate2()));*/
		List<Object> eqmTrouble = baseDao.queryByPage(hql.concat(param).concat(" order by o.schWorkorder.date, o.schWorkorder.mdEquipment.equipmentName, o.schWorkorder.mdShift.id"), pageParams);
		List<EqpRunTimeBean> list = new ArrayList<EqpRunTimeBean>();
		for(Object o : eqmTrouble){
			SchStatOutput et = (SchStatOutput) o;
			EqpRunTimeBean tb = new EqpRunTimeBean();
			tb.setEqpName(et.getSchWorkorder().getMdEquipment().getEquipmentName());
			tb.setEqpType(et.getSchWorkorder().getMdEquipment().getMdEqpType().getName());
			tb.setShiftName(et.getSchWorkorder().getMdShift().getName());
			tb.setTeamName(et.getSchWorkorder().getMdTeam().getName());
			tb.setRunTime(et.getRunTime());
			tb.setTime(DateUtil.formatDateToString(et.getSchWorkorder().getDate(),"yyyy-MM-dd"));
			list.add(tb);
		}
		hql = "select count(*) from SchStatOutput o where 1=1 and o.del=0 ";
		long total = baseDao.queryTotal(hql.concat(param));
		return new DataGrid(list,total);
	}
	
	//查询运行效率图表数据源
	public EffectiveGraphBean queryEqpRunTimeChart(EqpRunTimeBean bean, PageParams pageParams){
		
		String hql = "select o.schWorkorder.date"
				+ ",o.schWorkorder.mdEquipment.equipmentName"
				+ ",o.schWorkorder.mdShift.name"
			//	+ ",o.schWorkorder.mdEquipment.mdEqpType.code"
				+ ",o.schWorkorder.mdTeam.name"
				+ ",o.runTime  from SchStatOutput o where 1=1 and o.del=0 ";
		StringBuffer params = new StringBuffer();
		if(StringUtil.notNull(bean.getEqpName())){
			params.append(" and o.schWorkorder.mdEquipment.equipmentName like '%"+ bean.getEqpName() +"%'");
		}
		if(StringUtil.notNull(bean.getEqpType())){
			params.append(" and o.schWorkorder.mdEquipment.mdEqpType.id='"+ bean.getEqpType() +"'");
		}
		if(StringUtil.notNull(bean.getTeamName())){
			params.append(" and o.schWorkorder.mdTeam.id='"+ bean.getTeamName() +"'");
		}
		if(StringUtil.notNull(bean.getShiftName())){
			params.append(" and o.schWorkorder.mdShift.id='"+ bean.getShiftName() +"'");
		}
		if(bean.getRunDate()!=null&&StringUtil.notNull(bean.getRunDate().toString().trim())){ 
			params.append(" and CONVERT(varchar(100),o.schWorkorder.date, 23)>='"+ bean.getRunDate() +"'");
		}
		if(bean.getRunDate2()!=null&&StringUtil.notNull(bean.getRunDate2().toString().trim())){
			params.append(" and CONVERT(varchar(100),o.schWorkorder.date, 23)<='"+ bean.getRunDate2() +"'");
		}
		String param = params.toString();
		
		List<Object> list = baseDao.queryByPage(hql.concat(param).concat(" order by o.schWorkorder.date, o.schWorkorder.mdEquipment.equipmentName, o.schWorkorder.mdShift.id"), pageParams);
		Hashtable<String,String> ht1=new Hashtable<String,String>();
		Hashtable<String,String> ht2=new Hashtable<String,String>();
		Hashtable<String,Object[]> ht3=new Hashtable<String,Object[]>();
		int xlength=0;
		int ylength=0;
		List<String> sortList=new ArrayList<String>();
		for(Object o:list){
			Object[] temp=(Object[])o;
			String date=temp[0].toString();
			date=date.substring(5,10);
			//获取日期+设备名称
			if(ht1.get(temp[1].toString()+date)==null){
				//DateUtil.formatDateToString((Date)temp[0],"yyyy-MM-dd");
				ht1.put(temp[1].toString()+date, temp[1].toString()+date);
				sortList.add(temp[1].toString()+date);
				xlength++;
			}
			//获取班次名称
			if(ht2.get(temp[2].toString())==null){
				ht2.put(temp[2].toString(), temp[2].toString());
				ylength++;
			}
			//
			if(ht3.get(temp[1].toString()+date+temp[2].toString())==null){
				ht3.put(temp[1].toString()+date+temp[2].toString(), temp);
			}
			
		}
		//Iterator<String> i1=ht1.keySet().iterator();
		Iterator<String> i2=ht2.keySet().iterator();
		//X轴值类型
		String[] xValue=new String[xlength];
		//Y轴值类型
		String[] yvalueType=new String[ylength];
		//Y轴值
		double[][] yValue=new double[ylength][xlength];
		int i=0;
		int j;
		//循环设备
		for(int index=0;index<sortList.size();index++){
			String key=sortList.get(index);
			xValue[i]=ht1.get(key);
			j=0;
			i2=ht2.keySet().iterator();
			//循环班组信息
			while(i2.hasNext()){
				String i2Key=i2.next();
				yvalueType[j]=i2Key;
				Object o=ht3.get(ht1.get(key)+ht2.get(i2Key));
				if(o!=null){
					Object[] temp=(Object[])o;
					yValue[j][i]=Double.parseDouble(temp[4].toString());
				}else{
					yValue[j][i]=0.0;
				}
				j++;
			}
			i++;
		}
		EffectiveGraphBean beans=new EffectiveGraphBean();
		beans.setXvalue(xValue);
		beans.setYvalue(yValue);
		beans.setYvalueType(yvalueType);
		return beans;
	} 

}