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

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

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

import com.shlanbao.tzsc.base.dao.BaseDaoI;
import com.shlanbao.tzsc.base.dao.EqmLubricantDaoI;
import com.shlanbao.tzsc.base.mapping.EqmLubricant;
import com.shlanbao.tzsc.base.mapping.EqmLubricantPlan;
import com.shlanbao.tzsc.base.mapping.EqpLubricantRecord;
import com.shlanbao.tzsc.base.mapping.MdEqpCategory;
import com.shlanbao.tzsc.base.mapping.MdEqpType;
import com.shlanbao.tzsc.base.mapping.MdEquipment;
import com.shlanbao.tzsc.base.mapping.SchStatInput;
import com.shlanbao.tzsc.base.mapping.SysEqpCategory;
import com.shlanbao.tzsc.base.mapping.SysEqpType;
import com.shlanbao.tzsc.base.mapping.SysRole;
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.service.BaseService;
import com.shlanbao.tzsc.pms.equ.fix.beans.EqmFixRecBean;
import com.shlanbao.tzsc.pms.equ.lubricate.beans.EqmLubricantBean;
import com.shlanbao.tzsc.pms.equ.lubricate.service.EqmLubricantServiceI;
import com.shlanbao.tzsc.pms.sch.stat.beans.InputBean;
import com.shlanbao.tzsc.pms.sys.datadict.beans.SysEqpTypeBean;
import com.shlanbao.tzsc.utils.tools.BeanConvertor;
import com.shlanbao.tzsc.utils.tools.DateUtil;
import com.shlanbao.tzsc.utils.tools.StringUtil;
@Service
public class EqmLubricantServiceImpl extends BaseService implements EqmLubricantServiceI {
	@Autowired
	private EqmLubricantDaoI lubricantDao;
	@Autowired
	private BaseDaoI<Object> baseDao;
	//新增
	@LogAnno(operateType = "新增设备润滑数据明细")
	@Override
	public boolean addBean(EqmLubricant bean) {
		lubricantDao.save(bean);
		return true;
	}
	
	//根据Id获取对象
	@Override
	public EqmLubricant getBeanById(String id){
		return lubricantDao.findById(EqmLubricant.class, id);
	}
	//根据Id获取对象
	@Override
	public EqmLubricantBean getBeanByIds(String id) throws Exception{
		
		EqmLubricant qmLubricant=lubricantDao.findById(EqmLubricant.class, id);
		EqmLubricantBean bean=BeanConvertor.copyProperties(qmLubricant, EqmLubricantBean.class);
		bean.setCategoryId(qmLubricant.getSysEqpCategory().getId());
		bean.setCategoryName(qmLubricant.getSysEqpCategory().getName());
		return bean;
	}
	//修改
	@LogAnno(operateType = "修改设备润滑数据明细")
	@Override
	public boolean updateBean(EqmLubricantBean bean) {
		EqmLubricant o = lubricantDao.findById(EqmLubricant.class, bean.getId());
		o.setNum(bean.getNum());
		o.setEquLocation(bean.getEquLocation());
		o.setEnable(bean.getEnable());
		o.setLubPosition(bean.getLubPosition());
		o.setFixedPoints(bean.getFixedPoints());
		o.setLubOil(bean.getLubOil());
		o.setLubMethod(bean.getLubMethod());
		o.setChangeOilDosage(bean.getChangeOilDosage());
		o.setChangeOilCycle(bean.getChangeOilCycle());
		o.setSpePerson(bean.getSpePerson());
		o.setRoleId(bean.getRoleId());
		o.setQuaQuantity(bean.getQuaQuantity());
		o.setQuaUnit(bean.getQuaUnit());
		o.setDes(bean.getDes());
		o.setRoleId(bean.getRoleId());
		o.setLastUpdateName(bean.getLastUpdateName());
		o.setLastUpdateTime(bean.getLastUpdateTime());
		o.setShiftId(bean.getShiftId());
		return lubricantDao.saveOrUpdate(o);
	}

	//查询
	@Override
	public DataGrid searchBean(EqmLubricantBean seachBean,PageParams pageParams) {
		StringBuffer hql=new StringBuffer();
		hql.append("select o.id,o.name,");
		hql.append("o.eqp_type.id,");
		hql.append("o.eqp_type.name,");
		hql.append("o.create_usr.id ,");
		hql.append("o.create_usr.name ,");
		hql.append("o.cycle,");//周期
		hql.append("o.last_time,");
		hql.append("o.next_time,");
		hql.append("o.create_time,");
		hql.append("o.rule_id,");
		hql.append("o.rule_name,");
		hql.append("o.status, ");
		hql.append("o.eqp_category.id ");
		hql.append("from EqmLubricant o where 1=1 ");
		if(StringUtil.notNull(seachBean.getId())){
			hql.append("and o.id='"+seachBean.getId()+"' ");
		}
		
		/*if(StringUtil.notNull(seachBean.getEqp_typeId())){
			hql.append("and o.eqp_type.id='"+seachBean.getEqp_typeId()+"' ");
		}
		
		if(seachBean.getStatus()>-1){
			hql.append("and o.status='"+seachBean.getStatus()+"' ");
		}*/
		long total=baseDao.query(hql.toString()).size();
		//hql.append("order by o.date_p,o.shift.code ");
		List<Object> list=baseDao.queryByPage(hql.toString(), pageParams);
		List<EqmLubricantBean> returnList=new ArrayList<EqmLubricantBean>();
		for(Object o:list){
			Object[] temp=(Object[]) o;
			EqmLubricantBean b=new EqmLubricantBean();
			b.setId(temp[0].toString());
			/*b.setName(temp[1].toString());
			b.setEqp_typeId(temp[2].toString());
			b.setEqp_typeName(temp[3].toString());
			b.setCreate_uId(temp[4].toString());
			b.setCreate_uName(temp[5].toString());
			b.setCycle(Integer.parseInt(temp[6].toString()));
			if(temp[7]!=null)b.setLast_time(temp[7].toString());
			if(temp[8]!=null)b.setNext_time(temp[8].toString());
			if(temp[9]!=null)b.setCreate_time(temp[9].toString());
			b.setRuleId(temp[10].toString());
			if(temp[11]!=null)
				b.setRuleName(temp[11].toString());
			b.setStatus(Integer.parseInt(temp[12].toString()));
			b.setEqp_category(temp[13].toString());
			returnList.add(b);*/
		}
		return new DataGrid(returnList,total);
	}
	//生产润滑计划
	public void createLubricantPlan(String lubriId,String eqpId){
		EqmLubricant  lubri=getBeanById(lubriId);
		EqmLubricantPlan plan=new EqmLubricantPlan();
		plan.setDate_p(new Date());
		plan.setEqp(new MdEquipment(eqpId));
		/*plan.setLub_id(lubri.getRule_id());*/
		plan.setStatus(0);
		
	}
	@Override
	public List<?> getListBySql(String sql){
		return baseDao.queryBySql(sql);
	}

	/**
	 * [功能说明]：通过ID，查询润滑详细
	 * @date 2017年8月30日11:28:42
	 * @author wanchanghuang
	 * */
	@Override
	public DataGrid queryEqmLubricationById(SysEqpCategory bean,
			PageParams pageParams) {
		List<EqmLubricantBean> beans = new ArrayList<EqmLubricantBean>();
		StringBuffer sb=new StringBuffer();
		long total=0;
		sb.append(" select a.ID,a.NUM,a.EQU_LOCATION,a.LUB_POSITION,a.FIXED_POINTS,a.LUB_OIL,a.LUB_METHOD,a.CHANGE_OILDOSAGE,a.CHANGE_OILCYCLE, ");
		sb.append(" a.SPE_PERSON,a.QUA_QUANTITY,a.QUA_UNIT,a.DES,a.CREATE_TIME,a.LAST_UPDATE_NAME,b.id as SYS_EC,a.role_id,a.ENABLE,a.SHIFT_ID,a.LAST_UPDATE_TIME from EQM_LUBRICATION a,SYS_EQP_CATEGORY b ");
		sb.append(" where b.maintainace_type='"+bean.getMaintainaceType()+"' and b.id='"+bean.getId()+"' and a.SYS_EC=b.id ");
		if(StringUtil.notEmpty(bean.getCode())&&!"4".equals(bean.getCode())){
			sb.append(" and a.SHIFT_ID ="+StringUtil.convert2Integer(bean.getCode())+"");
		}
		if (StringUtil.notEmpty(bean.getLubPosition())) {
			sb.append(" and a.lub_position like '%"+bean.getLubPosition()+"%'");
		}
		if (StringUtil.notEmpty(bean.getEquLocation())) {
			sb.append(" and a.equ_location like '%"+bean.getEquLocation()+"%'");
		}
		if(StringUtil.notNull(bean.getEqpType())){
			sb.append(" and b.name like '%"+bean.getEqpType()+"%'");
		}
		if(StringUtil.notNull(bean.getCycleType())){
			sb.append(" and b.cycle_type='"+bean.getCycleType()+"' ");
		}
		sb.append(" order by a.num asc ");
		List<?> list= lubricantDao.queryBySql(sb.toString());
		if(list!=null && list.size()>0){
			EqmLubricantBean eb=null;
			for(Object o:list){
				Object[] temp=(Object[]) o;
				eb=new EqmLubricantBean();
				eb.setId(StringUtil.convertObjToString(temp[0]));
				eb.setNum(StringUtil.convertObjToString(temp[1]));
				eb.setEquLocation(StringUtil.convertObjToString(temp[2]));
				eb.setLubPosition(StringUtil.convertObjToString(temp[3]));
				eb.setFixedPoints(StringUtil.convertObjToString(temp[4]));
				eb.setLubOil(StringUtil.convertObjToString(temp[5]));
				eb.setLubMethod(StringUtil.convertObjToString(temp[6]));
				eb.setChangeOilDosage(StringUtil.convertObjToString(temp[7]));
				eb.setChangeOilCycle(StringUtil.convertObjToString(temp[8]));
				eb.setSpePerson(StringUtil.convertObjToString(temp[9]));
				eb.setQuaQuantity(StringUtil.convertObjToString(temp[10]));
				eb.setQuaUnit(StringUtil.convertObjToString(temp[11]));
				eb.setDes(StringUtil.convertObjToString(temp[12]));
				eb.setCreateTime(DateUtil.formatStringToDate(temp[13].toString(), "yyyy-MM-dd HH:mm:ss"));
				eb.setLastUpdateName(StringUtil.convertObjToString(temp[14]));
				eb.setCategoryId(StringUtil.convertObjToString(temp[15]));
				eb.setRoleId(StringUtil.convertObjToString(temp[16]));
				eb.setEnable(StringUtil.convertObjToString(temp[17]));
				eb.setShiftId(StringUtil.convert2Integer(temp[18]));
				eb.setLastUpdateTime(temp[19]==null?null:DateUtil.formatStringToDate(temp[19].toString(), "yyyy-MM-dd HH:mm:ss"));
				beans.add(eb);
			}
		}
		return new DataGrid(beans, total);
	}

	@Override
	public List<SysRole> getRoleAll() {
		try {
			String sql="select id,name from SYS_ROLE where del=0";
			List<?> list=baseDao.queryBySql(sql);
			List<SysRole> srlist=new ArrayList<SysRole>();
			if(list!=null && list.size()>0){
				SysRole sr=null;
				for(Object o:list){
					Object[] temp=(Object[]) o;
					sr=new SysRole();
					sr.setId(StringUtil.convertObjToString(temp[0]));
					sr.setName(StringUtil.convertObjToString(temp[1]));
					srlist.add(sr);
				}
			}
			return srlist;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
	@LogAnno(operateType = "删除设备润滑数据明细")
	@Override
	public void deleteLubrCycle(String id) {
		// sysEqpTypeDao.findById(SysEqpType.class, id).setDel("1");
		lubricantDao.deleteById(id, EqmLubricant.class);
		//.deleteById(id, SysEqpType.class);
				// comboboxServiceI.initCombobox(ComboboxType.EQPTYPE);
		
	}

	@Override
	public DataGrid queryLubricantRec(EqpLubricantRecord eqmFixRecBean, PageParams pageParams) {
		int page=pageParams.getPage();
		int row=pageParams.getRows();
		Integer leng=0;
		StringBuffer count=this.getSql(eqmFixRecBean, 0);
		List<?> l=lubricantDao.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[]>) lubricantDao.queryBySql(sb.toString());
		List<EqpLubricantRecord> beans=new ArrayList<EqpLubricantRecord>();
		EqpLubricantRecord bean =null;
		for (Object[] o : ls) {
			try {
				bean=new EqpLubricantRecord();
				if(o[1]!=null){
					bean.setId(o[1].toString());
				}
				if(o[2]!=null){
					bean.setGreaser(o[2].toString());
				}
				if(o[3]!=null){
					bean.setLubricantName(o[3].toString());
				}
				if(o[4]!=null){
					bean.setLubricantCode(o[4].toString());
				}
				if(o[5]!=null){
					bean.setLubricantCount(o[5].toString());
				}
				if(o[6]!=null){
					bean.setCreateTime_(o[6].toString());
				}
				if(o[7]!=null){
					bean.setLubricantTime_(o[7].toString());
				}
				if(o[8]!=null){
					bean.setEqp(o[8].toString());
				}
				if(o[9]!=null){
					bean.setShift(o[9].toString());
				}
				beans.add(bean);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		
		return new DataGrid(beans, (long)leng);
	}

	@Override
	public void batchDeleteLubrCycle(String ids) {
		String[] split = ids.split(",");
		try {
			for (int i = 0; i < split.length; i++) {
				lubricantDao.deleteById(split[i], EqmLubricant.class);
			}
		}catch (Exception e){
			e.printStackTrace();
		}

	}


	private StringBuffer getSql(EqpLubricantRecord 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,a.greaser,a.LUBRICANT_NAME,a.LUBRICANT_CODE,"
				+" a.LUBRICANT_COUNT,a.CREATE_TIME,a.LUBRICANT_TIME,b.EQP_NAME,"
				+" b.SHIFT_NAME from EQP_LUBRICANT_RECORD a join EQM_WHEEL_COVEL_PLAN b"
				+" on a.EWCP_ID = b.id where 1=1");
		
		
	
		if(StringUtil.notNull(eqmFixRecBean.getLubricantTime_())){
			sb.append(" and to_char(a.LUBRICANT_TIME,'yyyy-MM-dd') >='" +eqmFixRecBean.getLubricantTime_()+ "'");
		}
		//完成时间2
		if(StringUtil.notNull(eqmFixRecBean.getCreateTime_())){
			sb.append(" and to_char(a.LUBRICANT_TIME,'yyyy-MM-dd') <= '" +eqmFixRecBean.getCreateTime_()+ "'");
		}
		
		//设备id
		if(StringUtil.notNull(eqmFixRecBean.getEqp())){
			sb.append( " and b.EQP_ID= '" +eqmFixRecBean.getEqp()+ "'");
		}
		//班次
		if(StringUtil.notNull(eqmFixRecBean.getShift())){
			sb.append(" and b.SHIFT_ID='" +eqmFixRecBean.getShift()+ "'");
		}
		/*//维修类型 0  电器和 机械 1
		if(eqmFixRecBean.getFixtype()!=null){
			sb.append( " and b.TYPE=" +eqmFixRecBean.getFixtype());
		}*/
		sb.append(" order by a.LUBRICANT_TIME ) t where 1=1 ");
		return sb;
	}
	

}