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

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

import com.shlanbao.tzsc.utils.tools.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.shlanbao.tzsc.base.dao.EqmFixRecDaoI;
import com.shlanbao.tzsc.base.mapping.EqmFixRec;
import com.shlanbao.tzsc.base.mapping.MdEquipment;
import com.shlanbao.tzsc.base.mapping.MdShift;
import com.shlanbao.tzsc.base.mapping.SysUser;
import com.shlanbao.tzsc.base.model.DataGrid;
import com.shlanbao.tzsc.base.model.PageParams;
import com.shlanbao.tzsc.base.model.SessionInfo;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.pms.equ.fix.beans.EqmFixRecBean;
import com.shlanbao.tzsc.pms.equ.fix.service.EqmFixRecServiceI;

@Service
public class EqmFixRecServiceImpl extends BaseService implements EqmFixRecServiceI{
	@Autowired
	protected EqmFixRecDaoI eqmFixDao;

	@Override
	public void addFixRec(EqmFixRecBean eqmFixRecBean) throws Exception {
		if(StringUtil.notNull(eqmFixRecBean.getId())){
			String hql = "from EqmFixRec  where id = ? ";
			List<Object> params = new ArrayList<Object>();
			params.add(eqmFixRecBean.getId());
			EqmFixRec fixRec = eqmFixDao.unique(EqmFixRec.class, hql, params);
			if(null!=fixRec){
				fixRec.setEqp_id(new MdEquipment(eqmFixRecBean.getEquipId()));//设备
				fixRec.setShift_id(new MdShift(eqmFixRecBean.getShiftId()));//班次
				//fixRec.setFixtype(eqmFixRecBean.getFixtype());//维修类型
				fixRec.setMaintaiin_type(new Long(eqmFixRecBean.getFixtype()).intValue());
				fixRec.setRemark(eqmFixRecBean.getRemark());//备注	
				if(null!=eqmFixRecBean.getAppointUsrId()&&!"".equals(eqmFixRecBean.getAppointUsrId())){
					fixRec.setMaintaiin_id(eqmFixRecBean.getAppointUsrId());//维修人
					fixRec.setStatus(2);//状态 新增是 0 或 空  , 运行是 1 ,完成 2 
					fixRec.setCreate_user_time(new Date());//创建时间
				}
			}
		}else{
			//新增
			EqmFixRec fixRec = BeanConvertor.copyProperties(eqmFixRecBean, EqmFixRec.class ) ;
			fixRec.setAsk_date(new Date());//请求时间
			fixRec.setEqp_id(new MdEquipment(eqmFixRecBean.getEquipId()));//设备
			SessionInfo sessionInfo = (SessionInfo) WebContextUtil.getObjectFromSession();//设置请求用户
			fixRec.setAsk_userId(sessionInfo.getUser().getId());
			
			fixRec.setShift_id(new MdShift(eqmFixRecBean.getShiftId()));//班次
			//fixRec.setShift_id(eqmFixRecBean.getShiftId());
			//fixRec.setId(null);
			fixRec.setStatus(0);//状态 新增是 0 或 空  , 运行是 1 ,完成 2 
			if(null!=eqmFixRecBean.getAppointUsrId()&&!"".equals(eqmFixRecBean.getAppointUsrId())){
				fixRec.setMaintaiin_id(eqmFixRecBean.getAppointUsrId());
				fixRec.setMaintaiin_time(new Date());
			}
			eqmFixDao.save(fixRec);
		}
		//eqmFixDao.saveOrUpdate(fixRec);
	}

	@Override
	
	public EqmFixRecBean getFixRecById(String id) throws Exception {
		EqmFixRec fixRec=  eqmFixDao.findById(EqmFixRec.class,id);
		EqmFixRecBean recBean=BeanConvertor.copyProperties(fixRec, EqmFixRecBean.class);
		MdEquipment mdEquipment=fixRec.getEqp_id();
		recBean.setEquipId(mdEquipment.getId());
		recBean.setEquipName(mdEquipment.getEquipmentName());
		MdShift shift=fixRec.getShift_id();
		recBean.setShiftId(shift.getId());
		recBean.setShiftName(shift.getName());
		if(null!=fixRec.getMaintaiin_id()){
//			recBean.setAppointUsrId(fixRec.getAppointUsr().getId());
//			recBean.setAppointUsrName(fixRec.getAppointUsr().getName());
			recBean.setAppointUsrId(fixRec.getMaintaiin_id());
			recBean.setAppointUsrName(fixRec.getMaintaiin_name());
		}
		 return recBean;
	}
/**
 * 备件跟换记录查询
 * 2015-09-30
 * shisihai
 */
	@Override
	public DataGrid queryFixRec(EqmFixRecBean eqmFixRecBean, PageParams pageParams)throws Exception {
		int page=pageParams.getPage();
		int row=pageParams.getRows();
		Integer leng=0;
		StringBuffer count=this.getSql(eqmFixRecBean, 0);
		List<?> l=eqmFixDao.queryBySql(count.toString());
		if(l!=null && l.size()>0){
			leng=Integer.parseInt( l.get(0).toString()) ;
		}
		StringBuffer sb=this.getSql(eqmFixRecBean, 1);
		sb.append(" and t.rownumberf > " +(page-1)*row);
		sb.append(" and t.rownumberf <= " +page*row);
		List<Object[]> ls=(List<Object[]>) eqmFixDao.queryBySql(sb.toString());
		List<EqmFixRecBean> beans=new ArrayList<EqmFixRecBean>();
		EqmFixRecBean bean =null;
		for (Object[] o : ls) {
			try {
				bean=new EqmFixRecBean();
				if(o[1]!=null){
					bean.setId(o[1].toString());
				}
				if(o[2]!=null||o[10]!=null){
					bean.setEquipName(o[2]==null?o[10].toString():o[2].toString());
				}
				if(o[3]!=null||o[11]!=null){
					bean.setShiftName(o[3]==null?o[11].toString():o[3].toString());
				}
				if(o[4]!=null){
					bean.setBjName(o[4].toString());
				}
				if(o[5]!=null){
					bean.setBjCode(o[5].toString());
				}
				if(o[6]!=null){
					bean.setBjNum(o[6].toString());
				}
				if(o[7]!=null){
					bean.setFixtim(o[7].toString());
				}
				if(o[8]!=null){
					bean.setGhName(o[8].toString());
				}
				if(o[9]!=null){
					bean.setFixtype(Long.parseLong(o[9].toString()));//更换备件的来源 1-点检   2-维修呼叫   3-轮保   4-备品备件 5、检修
				}
				beans.add(bean);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		
		return new DataGrid(beans, (long)leng);
	}

	@LogAnno(operateType = "删除备品备件更换记录")
	@Override
	public void deleteFixRec(String id) throws Exception {
		List list = new ArrayList<>();
		list.add(id);
		eqmFixDao.updateBySql("delete from EQP_SPARE_PARTS where id = ?",list);
	}
	@LogAnno(operateType = "批量删除备品备件更换记录")
	@Override
	public void batchDeleteFixRec(String ids) {
		String[] split = ids.split(",");
        try {
			for (int i = 0; i < split.length; i++) {
				List list = new ArrayList<>();
				list.add(split[i]);
				eqmFixDao.updateBySql("delete from EQP_SPARE_PARTS where id = ?",list);
			}
		}catch (Exception e){
        	e.printStackTrace();
		}
	}

	/**
 * 
 * @param eqmFixRecBean
 * @param type 1 查信息  其余查条数
 * @return
 */
	private StringBuffer getSql(EqmFixRecBean eqmFixRecBean,int type){
		StringBuffer sb=null;
		if(type==1){
			sb=new StringBuffer(" SELECT * from ");
		}else{
			 sb=new StringBuffer(" select count(0) from ");
		}
		sb.append("(select rownum as rownumberf, a.id,d.equipment_name,e.name,"
				+" a.SPARE_PARTS_NAME,a.SPARE_PARTS_CODE,a.SPARE_PARTS_NUM,"
				+" a.REPAIR_DATE,a.MAINTAIIN_NAME,b.type,b.eqp_name,b.shift_name"
				+" from EQP_SPARE_PARTS a "
				+" LEFT JOIN EQM_WHEEL_COVEL_PLAN b ON A .EWCP_ID = b.ID"
				+" left join EQP_REQUEST_RECORD f on a.eqp_rr_id = f.id "
				+" LEFT JOIN MD_EQUIPMENT D ON f.eqp_id = D.ID"
				+" LEFT JOIN MD_SHIFT E ON f.shift = E.ID where 1=1 ");
		
		
	
		if(StringUtil.notNull(eqmFixRecBean.getReqtim())){
			sb.append(" and to_char(a.REPAIR_DATE,'yyyy-MM-dd') >='" +eqmFixRecBean.getReqtim()+ "'");
		}
		//完成时间2
		if(StringUtil.notNull(eqmFixRecBean.getRestim())){
			sb.append(" and to_char(a.REPAIR_DATE,'yyyy-MM-dd') <= '" +eqmFixRecBean.getRestim()+ "'");
		}
		
		//设备id
		if(StringUtil.notNull(eqmFixRecBean.getEquipId())){
			sb.append( " and d.id= '" +eqmFixRecBean.getEquipId()+ "'");
		}
		//班次
		if(StringUtil.notNull(eqmFixRecBean.getShiftId())){
			sb.append(" and e.id='" +eqmFixRecBean.getShiftId()+ "'");
		}
		/*//维修类型 0  电器和 机械 1
		if(eqmFixRecBean.getFixtype()!=null){
			sb.append( " and b.TYPE=" +eqmFixRecBean.getFixtype());
		}*/
		sb.append(" order by a.REPAIR_DATE ) t where 1=1 ");
		return sb;
	}
	
}