package com.shlanbao.tzsc.pms.sch.workorder.service.impl;

import java.util.ArrayList;
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.model.DataGrid;
import com.shlanbao.tzsc.base.model.PageParams;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.pms.sch.workorder.beans.FaultWkBean;
import com.shlanbao.tzsc.pms.sch.workorder.service.FaultWkServiceI;
import com.shlanbao.tzsc.utils.tools.MathUtil;
import com.shlanbao.tzsc.utils.tools.StringUtil;
/**
 *
* @ClassName: FaultWkServiceI
* @Description: 设备运行故障信息
* @author luo
* @date 2015年10月10日 上午10:05:39
*
 */
@Service
public class FaultWkServiceImpl extends BaseService implements FaultWkServiceI{
	@Autowired
	private BaseDaoI<Object> baseDao;

	@Override
	public DataGrid queryFaultWkGrid(FaultWkBean bean,PageParams pageParams) {
		String sql=getFaultWkSql(bean,"");
		List<FaultWkBean> faultWkList=new ArrayList<FaultWkBean>();
		List<?> faultWkObj = baseDao.queryBySql(sql);
		for(int i=(pageParams.getPage()-1)*pageParams.getRows();i<pageParams.getPage()*pageParams.getRows()&&i<faultWkObj.size();i++){
			Object o=faultWkObj.get(i);
			//设备名称，工单code,生产日期，班组名称，班次名称，生产牌号，故障名称，故障发生时长，故障发生次数，生产时长
			Object[] arr=(Object[]) o;
			FaultWkBean b=new FaultWkBean();
			b.setEqp_name(StringUtil.convertObjToString(arr[0]));
			b.setWk_code(StringUtil.convertObjToString(arr[1]));
			b.setDate(StringUtil.convertObjToString(arr[2]));
			b.setTeam_name(StringUtil.convertObjToString(arr[3]));
			b.setShift_name(StringUtil.convertObjToString(arr[4]));
			b.setMat_name(StringUtil.convertObjToString(arr[5]));
			b.setFault_name(StringUtil.convertObjToString(arr[6]));
			String time=StringUtil.convertObjToString(arr[7]);
			if(StringUtil.isDouble(time)){
				double tim=MathUtil.roundHalfUp(Double.parseDouble(time), 2);
				b.setTime(String.valueOf(tim));
			}else{
				b.setTime(StringUtil.convertObjToString(arr[7]));
			}

			b.setTimes(StringUtil.convertObjToString(arr[8]));
			b.setRuntime(StringUtil.convertObjToString(arr[9]));
			faultWkList.add(b);
		}
		return new DataGrid(faultWkList,Long.parseLong(faultWkObj.size()+""));
	}
	@Override
	public List<FaultWkBean> exportFaultWkList(FaultWkBean bean,String param){
		String sql=getFaultWkSql(bean,param);
		List<FaultWkBean> faultWkList=new ArrayList<FaultWkBean>();
		List<?> faultWkObj = baseDao.queryBySql(sql);
		for(Object o:faultWkObj){
			//设备名称，工单code,生产日期，班组名称，班次名称，生产牌号，故障名称，故障发生时长，故障发生次数，生产时长
			Object[] arr=(Object[]) o;
			FaultWkBean b=new FaultWkBean();
			if(!"time".equals(param) && !"times".equals(param)){//统计信息只有三个字段
				b.setEqp_name(StringUtil.convertObjToString(arr[0]));
				b.setWk_code(StringUtil.convertObjToString(arr[1]));
				b.setDate(StringUtil.convertObjToString(arr[2]));
				b.setTeam_name(StringUtil.convertObjToString(arr[3]));
				b.setShift_name(StringUtil.convertObjToString(arr[4]));
				b.setMat_name(StringUtil.convertObjToString(arr[5]));
				b.setFault_name(StringUtil.convertObjToString(arr[6]));
				b.setTime(StringUtil.convertObjToString(arr[7]));
				b.setTimes(StringUtil.convertObjToString(arr[8]));
				b.setRuntime(StringUtil.convertObjToString(arr[9]));
			}else{
				b.setTime(StringUtil.convertObjToString(arr[0]));
				b.setTimes(StringUtil.convertObjToString(arr[1]));
				b.setFault_name(StringUtil.convertObjToString(arr[2]));
			}
			faultWkList.add(b);
		}
		return faultWkList;
	}


	private String getFaultWkSql(FaultWkBean bean ,String param){
		StringBuffer sqlBuffer=new StringBuffer();
		if("time".equals(param) || "times".equals(param)){//统计图查询
			sqlBuffer.append("  SELECT * from (select sum(o.TIME) time,sum(o.TIMES) times, o.faultName from ( ");
		}
		//设备名称，工单code,生产日期，班组名称，班次名称，生产牌号，故障名称，故障发生时长，故障发生次数，生产时长
		sqlBuffer.append(" SELECT 	e.EQUIPMENT_NAME, wo.CODE,  to_char(wo.date_,'yyyy-MM-dd') as date_, ");
		sqlBuffer.append(" team.NAME AS teamName, shift.NAME AS shiftName, mat.NAME AS matName, ");
		sqlBuffer.append(" fault.NAME AS faultName, fault. TIME, fault.TIMES, sso.RUN_TIME ");
		/*sqlBuffer.append(" FROM SCH_WORKORDER wo ");
		sqlBuffer.append("sso.RUN_TIME   ");*/
		sqlBuffer.append("from SCH_WORKORDER wo left join SCH_STAT_OUTPUT sso on wo.ID=sso.OID  ");
		sqlBuffer.append("left join SCH_STAT_FAULT fault on sso.ID=fault.OID ");
		sqlBuffer.append("left join MD_EQUIPMENT e on wo.EQP=e.ID   ");
		sqlBuffer.append("left join MD_EQP_TYPE etype on e.EQP_TYPE_ID=etype.ID ");
		sqlBuffer.append("left join MD_EQP_CATEGORY cate on cate.ID=etype.CID ");
		sqlBuffer.append("left join MD_TEAM team on wo.TEAM=team.ID  ");
		sqlBuffer.append("left join MD_SHIFT shift on wo.SHIFT=shift.ID   ");
		sqlBuffer.append("left join MD_MAT mat on wo.MAT=mat.ID  ");
		sqlBuffer.append("where fault.NAME is not null and fault.status = 0  ");
		if(StringUtil.notNull(bean.getWorkShop_id())){
			sqlBuffer.append("and e.WORK_SHOP='"+bean.getWorkShop_id()+"' ");
		}
		if(StringUtil.notNull(bean.getEqp_type_cate_id())){
			sqlBuffer.append("and cate.code='"+bean.getEqp_type_cate_id()+"' ");
		}
		if(StringUtil.notNull(bean.getStartDate())){
			sqlBuffer.append("and to_char(wo.DATE_,'yyyy-MM-dd')>='"+bean.getStartDate()+"' ");
		}
		if(StringUtil.notNull(bean.getEndDate())){
			sqlBuffer.append("and to_char(wo.DATE_,'yyyy-MM-dd')<='"+bean.getEndDate()+"' ");
		}
		if(StringUtil.notNull(bean.getEqp_type_id())){
			sqlBuffer.append("and e.EQP_TYPE_ID='"+bean.getEqp_type_id()+"' ");
		}
		if(StringUtil.notNull(bean.getEqp_id())){
			sqlBuffer.append("and wo.EQP='"+bean.getEqp_id()+"' ");
		}
		if(StringUtil.notNull(bean.getShift_id())){
			sqlBuffer.append("and wo.SHIFT='"+bean.getShift_id()+"' ");
		}
		sqlBuffer.append(" ORDER BY wo.CODE,to_char(wo.date_,'yyyy-MM-dd'),fault.TIME DESC ");
		if("time".equals(param)){
			sqlBuffer.append(" )o GROUP BY o.faultName ) ORDER BY time desc ");
		}
		if("times".equals(param)){
			sqlBuffer.append(" )o GROUP BY o.faultName ) ORDER BY times desc ");
		}
		return sqlBuffer.toString();
	}
}