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

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

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

import com.shlanbao.tzsc.base.dao.EqmFixRecDaoI;
import com.shlanbao.tzsc.base.dao.EqmTroubleDaoI;
import com.shlanbao.tzsc.base.dao.EqmTroubleReDaoI;
import com.shlanbao.tzsc.base.interceptor.WorkOrderStatChangeInterceptor;
import com.shlanbao.tzsc.base.mapping.EqmFixRec;
import com.shlanbao.tzsc.base.mapping.EqmTrouble;
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.trouble.beans.EqmTroubleBean;
import com.shlanbao.tzsc.pms.equ.trouble.beans.EqmTroubleInfoBean;
import com.shlanbao.tzsc.pms.equ.trouble.beans.TroubleBean;
import com.shlanbao.tzsc.pms.equ.trouble.service.TroubleServiceI;
import com.shlanbao.tzsc.utils.tools.StringUtil;

@Service
public class TroubleServiceImpl  extends BaseService implements TroubleServiceI {

	@Autowired
	private EqmTroubleDaoI troubleDao;
	@Autowired
	private EqmTroubleReDaoI eqmtroubleDaoI;
	@Autowired
	private EqmFixRecDaoI eqmFixRecDao;
	
	@Override
	public DataGrid queryTrouble(TroubleBean bean, PageParams pageParams) throws Exception {
		StringBuffer sqlBuffer=new StringBuffer();
		sqlBuffer.append("from EqmTrouble t where 1=1 ");  
		
		if(StringUtil.notNull(bean.getStartDate())){
			sqlBuffer.append("and to_char(t.create_time,'yyyy-MM-dd')>='"+bean.getStartDate()+"' "); 
		}
		if(StringUtil.notNull(bean.getEndDate())){
			sqlBuffer.append("and to_char(t.create_time,'yyyy-MM-dd')<='"+bean.getEndDate()+"' "); 
		}
		if(StringUtil.notNull(bean.getEqu_id())){
			sqlBuffer.append("and t.EQU_ID='"+bean.getEqu_id()+"' ");
		}
		if(StringUtil.notNull(bean.getShift_id())){
			sqlBuffer.append("and t.SHIFT_ID='"+bean.getShift_id()+"' ");
		}
		sqlBuffer.append("order by t.create_time desc ");
		List<EqmTrouble> lists=troubleDao.query(sqlBuffer.toString());
		long total=troubleDao.queryTotal("select count(*) "+sqlBuffer.toString());
		return new DataGrid(lists,total);
	}

	@Override
	public DataGrid queryTrouble(EqmTroubleBean eqmtroubleBean, PageParams pageParams) throws Exception {
		/*StringBuilder hql=new StringBuilder();
		hql.append(" from EqmTrouble t where 1=1 and t.del='0' ");
		if(StringUtil.notNull(eqmtroubleBean.getMdWorkshopId()) )
			hql.append(" and t.mdEquipment.mdWorkshop.id='"+eqmtroubleBean.getMdWorkshopId()+"' ");
		if(StringUtil.notNull(eqmtroubleBean.getMdEqpCategoryId()))
			hql.append(" and t.mdEquipment.mdEqpType.mdEqpCategory.id='"+eqmtroubleBean.getMdEqpCategoryId()+"' ");
		if(StringUtil.notNull(eqmtroubleBean.getMdEqpTypeId()))
			hql.append(" and t.mdEquipment.mdEqpType.id='"+eqmtroubleBean.getMdEqpTypeId()+"' ");
		if(StringUtil.notNull(eqmtroubleBean.getMdEquipmentId()))
			hql.append(" and t.mdEquipment.id='"+eqmtroubleBean.getMdEquipmentId()+"' ");
		if(StringUtil.notNull(eqmtroubleBean.getMdShiftId()))
			hql.append(" and t.mdShift.id='"+eqmtroubleBean.getMdShiftId()+"' ");
		hql.append(StringUtil.fmtDateBetweenParams("t.fault_date", eqmtroubleBean.getRuntime(), eqmtroubleBean.getEndtime()));	
		List<EqmTrouble> troubles=eqmtroubleDaoI.queryByPage(hql.toString(), pageParams);
		List<EqmTroubleBean> eqmTroubleBeans=new ArrayList<EqmTroubleBean>();
		for (EqmTrouble eqmTrouble : troubles) {
			EqmTroubleBean bean=BeanConvertor.copyProperties(eqmTrouble, EqmTroubleBean.class);
			if(eqmTrouble.getMdShift()!=null){
				bean.setMdShiftId(eqmTrouble.getMdShift().getId());
				bean.setMdShiftName(eqmTrouble.getMdShift().getName());
			}
			if(eqmTrouble.getMdEquipment()!=null){
				bean.setMdEquipmentId(eqmTrouble.getMdEquipment().getId());
				bean.setMdEquipmentName(eqmTrouble.getMdEquipment().getEquipmentName());
			}
			bean.setFaultDate(DateUtil.formatDateToString(eqmTrouble.getFault_date(),"yyyy-MM-dd"));
			eqmTroubleBeans.add(bean);
		}
		long total=eqmtroubleDaoI.queryTotal("select count(*) "+hql.toString());
		return new DataGrid(eqmTroubleBeans, total);*/
		return null;
	}
	
	/**
	 * 张璐
	 * 设备信息表查询--测试用
	 * @return
	 */
	@Override
	public List<EqmTroubleInfoBean> queryTroubleInfo(EqmTroubleInfoBean troubleBean){
		/*StringBuffer sb=new StringBuffer();
		sb.append("SELECT et.id,et.md_eqp_type_id,et.trouble_part_description,et.part_code_description,et.trouble_phenomenon_description,et.trouble_reason_description,et.trouble_code,et.trouble_phenomenon,et.trouble_reason from EQM_TROUBLE_INFO et where 1=1 ");
		if(StringUtil.notNull(troubleBean.getTroubleName())){
			sb.append(" and et.trouble_reason_description='"+troubleBean.getTroubleName()+"'");
		}
		List<?> list = eqmtroubleDaoI.queryBySql(sb.toString());
		List<EqmTroubleInfoBean> listBean = new ArrayList<EqmTroubleInfoBean>();
		if(list.size()>0){
			for(Object b:list){
				Object[]temp = (Object[]) b;
				EqmTroubleInfoBean bean = new EqmTroubleInfoBean();
				bean.setId(temp[0].toString());
				if(null!=temp[1]){
					bean.setEqp_DES(temp[1].toString());
				}
				bean.setTrouble_part_description(temp[2].toString());
				bean.setPart_code_description(temp[3].toString());
				bean.setTrouble_phenomenon_description(temp[4].toString());
				bean.setTrouble_reason_description(temp[5].toString());
				bean.setTrouble_code(temp[6].toString());
				bean.setTrouble_phenomenon((int) temp[7]);
				bean.setTrouble_reason(temp[8].toString());
				listBean.add(bean);
			}
		}
		return listBean;*/
		
		StringBuffer sb=new StringBuffer(1000);
		sb.append("SELECT id,code,description,type,parent_id from EQM_TROUBLE_INFO  where 1=1 ");
		if(StringUtil.notNull(troubleBean.getParent_id())){
			sb.append(" and parent_id='"+troubleBean.getParent_id()+"'");
		}
		sb.append(" ORDER BY type");
		
		List<?> list = eqmtroubleDaoI.queryBySql(sb.toString());
		List<EqmTroubleInfoBean> listBean = new ArrayList<EqmTroubleInfoBean>();
		if(list.size()>0){
			for(Object b:list){
				Object[]temp = (Object[]) b;
				EqmTroubleInfoBean bean = new EqmTroubleInfoBean();
				bean.setId(temp[0].toString());
				bean.setCode(temp[1].toString());
				bean.setDescription(temp[2].toString());
				bean.setType(temp[3].toString());
				if(temp[4]!=null){
					bean.setParent_id(temp[4].toString());
				}
				listBean.add(bean);
			}
		}
		return listBean;
	}
	
	/**张璐2015-10-30
	 * 用于添加新的故障信息
	 * @param des--故障描述
	 * @param fiveCode--本级代码
	 * @param pid--父节点
	 */
	@Override
	public void addNewTrouble(String des,String fiveCode,String pid,String id){
		StringBuffer sb=new StringBuffer(1000);
		sb.append("INSERT into EQM_TROUBLE_INFO VALUES('"+id+"','"+fiveCode+"','"+des+"',5,'"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"','"+pid+"')");
		eqmtroubleDaoI.updateBySql(sb.toString(), null);
	}
	
	/**
	 * 删除新添加的故障
	 * 张璐
	 */
	@Override
	public void deleteNewTrouble(String id){
		StringBuffer sb=new StringBuffer(1000);
		sb.append("DELETE from EQM_TROUBLE_INFO where id='"+id+"' ");
		eqmtroubleDaoI.updateBySql(sb.toString(), null);
	}

	@Override
	public void dasSendTrouble(String ids) {
		ids=ids.replaceAll(",", "','");
		StringBuffer hqlbuffer=new StringBuffer(1000);
		hqlbuffer.append("from EqmTrouble where 1=1 and status=1 and id in ('"+ids+"')");
		List<EqmTrouble> eqmtlist=troubleDao.query(hqlbuffer.toString());//通过ids查询维修记录表
		hqlbuffer.setLength(0);
		hqlbuffer.append("from EqmFixRec where 1=1 and eqmtrouble_id in ('"+ids+"') ");//通过ids查询备品备件更换记录表
		List<EqmFixRec> eqmfrlist=eqmFixRecDao.query(hqlbuffer.toString());
		//调用封装XML方法
		try {
			WorkOrderStatChangeInterceptor.getInstance().dasSendEquipmentRepairRecord(eqmtlist,eqmfrlist);
		} catch (Exception e) {
			log.info("设备维修记录反馈异常!");
			e.printStackTrace();
		}
	}

	
}