package com.shlanbao.tzsc.pms.msg.cons.service.impl;

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.MsgConWarnDaoI;
import com.shlanbao.tzsc.base.mapping.MsgConWarn;
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.msg.cons.beans.MsgConWarnBean;
import com.shlanbao.tzsc.pms.msg.cons.service.MsgConWarnServiceI;
import com.shlanbao.tzsc.utils.tools.DateUtil;
import com.shlanbao.tzsc.utils.tools.StringUtil;

@Service
public class MsgConWarnServiceImpl extends BaseService implements MsgConWarnServiceI{
	@Autowired
	protected MsgConWarnDaoI msgConWarnDao;
	@Override
	public void addMsgConWarn(MsgConWarn msgConWarn) throws Exception {
		MsgConWarn msgCon = null;
		if(StringUtil.notNull(msgConWarn.getId())){
			msgCon = msgConWarnDao.findById(MsgConWarn.class, msgConWarn.getId());
			beanConvertor.copyProperties(msgConWarn, msgCon);
		}else{
			msgCon = msgConWarn;
			msgCon.setDel(0L);
			msgCon.setSts(0L);
			msgCon.setTime(new Date());
			msgCon.setId(null);
		}
		msgConWarnDao.saveOrUpdate(msgCon);
	}
	//query
	@Override
	public DataGrid queryMsgConWarn(MsgConWarnBean msgConWarn, PageParams pageParams,Date startTime,Date endTime)throws Exception {

		String hql = "from MsgConWarn o where 1=1 and o.del=0";
		String params = "";
		if(StringUtil.notNull(msgConWarn.getEquipName()))
			params += " and o.schWorkorder.mdEquipment.equipmentName  like '%"+msgConWarn.getEquipName()+"%'";
		if(StringUtil.notNull(msgConWarn.getWorkShopId()))
			params += " and o.schWorkorder.mdEquipment.mdWorkshop.id ='"+msgConWarn.getWorkShopId()+"'";

		params+=StringUtil.fmtDateHHmmssBetweenParams("o.time", msgConWarn.getTime(), msgConWarn.getTime2());
		List<MsgConWarn> msgConWarns = msgConWarnDao.queryByPage(hql.concat(params), pageParams);
		String sqlhql = "select count(*) " + hql;
		long total = msgConWarnDao.queryTotal(sqlhql.concat(params));
		return new DataGrid(convertToBeans(msgConWarns), total);
}

	@Override
	public List<MsgConWarnBean> getMsgConWarns(long sts) throws Exception {
		return convertToBeans(msgConWarnDao.query("from MsgConWarn o where 1=1 and o.del=0 and o.sts=" + sts));
	}

	@Override
	public MsgConWarn getMsgConWarnById(String id) throws Exception {
		return msgConWarnDao.findById(MsgConWarn.class, id);
	}

	@Override
	public MsgConWarnBean getMsgConWarnBeanById(String id) throws Exception {
		MsgConWarn msgConWarn = getMsgConWarnById(id);
		MsgConWarnBean bean = beanConvertor.copyProperties(msgConWarn, MsgConWarnBean.class);
		if(msgConWarn.getSchWorkorder() != null){
			bean.setWorkId(msgConWarn.getSchWorkorder().getId());
			bean.setWorkCode(msgConWarn.getSchWorkorder().getCode());
			bean.setWorkShopId(msgConWarn.getSchWorkorder().getMdEquipment().getMdWorkshop().getId());
			bean.setWorkShopName(msgConWarn.getSchWorkorder().getMdEquipment().getMdWorkshop().getName());
			bean.setEquipId(msgConWarn.getSchWorkorder().getMdEquipment().getId());
			bean.setEquipName(msgConWarn.getSchWorkorder().getMdEquipment().getEquipmentName());
		}
		return bean;
	}

	@Override
	public void deleteMsgConWarnById(String id) throws Exception {
		getMsgConWarnById(id).setDel(1L);
	}

	@Override
	public void batchdeleteMsgConWarn(String ids) {
		String[] split = ids.split(",");
		for (int i = 0; i < split.length; i++) {
			try {
				getMsgConWarnById(split[i]).setDel(1L);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

	}

	private List<MsgConWarnBean> convertToBeans(List<MsgConWarn> msgConWarns)throws Exception{
		List<MsgConWarnBean> beans = new ArrayList<MsgConWarnBean>();
		for (MsgConWarn msgConWarn : msgConWarns) {
			MsgConWarnBean bean = beanConvertor.copyProperties(msgConWarn, MsgConWarnBean.class);
			String sql = "select name from md_mat where id = ?";
			List<?> objs = msgConWarnDao.queryBySql(sql,msgConWarn.getItem());
			if (objs!=null && objs.size()>0){
                bean.setItem(objs.get(0).toString());
            }
			if(msgConWarn.getSchWorkorder() != null){
				bean.setWorkId(msgConWarn.getSchWorkorder().getId());
				bean.setWorkCode(msgConWarn.getSchWorkorder().getCode());
				bean.setWorkShopId(msgConWarn.getSchWorkorder().getMdEquipment().getMdWorkshop().getId());
				bean.setWorkShopName(msgConWarn.getSchWorkorder().getMdEquipment().getMdWorkshop().getName());
				bean.setEquipId(msgConWarn.getSchWorkorder().getMdEquipment().getId());
				bean.setEquipName(msgConWarn.getSchWorkorder().getMdEquipment().getEquipmentName());
			}
			beans.add(bean);
		}
		return beans;
	}

}