package com.shlanbao.tzsc.pms.md.mat.service.impl;

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

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

import com.shlanbao.tzsc.base.dao.MdMatDaoI;
import com.shlanbao.tzsc.base.dao.MdMaterialLkDaoI;
import com.shlanbao.tzsc.base.mapping.MdMat;
import com.shlanbao.tzsc.base.mapping.MdMatType;
import com.shlanbao.tzsc.base.mapping.MdMaterialLk;
import com.shlanbao.tzsc.base.mapping.MdUnit;
import com.shlanbao.tzsc.base.mapping.SchWorkorder;
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.plugin.service.LoadComboboxServiceI;
import com.shlanbao.tzsc.pms.md.mat.beans.MatBean;
import com.shlanbao.tzsc.pms.md.mat.service.MatServiceI;
import com.shlanbao.tzsc.utils.params.ComboboxType;

import javax.servlet.http.HttpServletRequest;

@Service
public class MatServiceImpl extends BaseService implements MatServiceI{
	@Autowired
	private MdMatDaoI mdMatDao;
	@Autowired
	private MdMaterialLkDaoI mdMaterialLkDao;
	@Autowired
	private LoadComboboxServiceI loadComboboxService;
	@Autowired
	private HttpServletRequest request;

	@Override
	public List<MatBean> queryAllMatsForComboBox() throws Exception {
		String hql = "from MdMat o where o.mdMatType.code=?" ;
		//mdMatType.code=1 成品  2辅料
		return BeanConvertor.copyList(mdMatDao.query(hql,"1"), MatBean.class);
	}
	@LogAnno(operateType = "新增物料")
	@Override
	public void addMat(MatBean matBean) throws Exception {
		MdMat o = new MdMat();
		BeanConvertor.copyProperties(matBean, o);
		if(StringUtil.notNull(matBean.getUnit())){
			o.setMdUnit(new MdUnit(matBean.getUnit()));
		}
		if(StringUtil.notNull(matBean.getMatType())){
			o.setMdMatType(new MdMatType(matBean.getMatType()));
		}
		o.setLastUpdateTime(new Date());
		o.setDel("0");
		FillUserInfoUtil.fillCreateUserInfo(o,request);
		mdMatDao.save(o);
		loadComboboxService.initCombobox(ComboboxType.MATPROD);
	}
	@LogAnno(operateType = "编辑物料")
	@Override
	public void editMat(MatBean matBean) throws Exception {
		MdMat o = mdMatDao.findById(MdMat.class, matBean.getId());

		BeanConvertor.copyProperties(matBean, o);
		o.setLastUpdateTime(new Date());

		if(StringUtil.notNull(matBean.getUnit())){
			o.setMdUnit(new MdUnit(matBean.getUnit()));
		}

		if(StringUtil.notNull(matBean.getMatType())){
			o.setMdMatType(new MdMatType(matBean.getMatType()));
		}
		FillUserInfoUtil.fillUpdateUserInfo(o,request);
		loadComboboxService.initCombobox(ComboboxType.MATPROD);
	}
	@LogAnno(operateType = "删除物料")
	@Override
	public void deleteMat(String id) throws Exception {
		mdMatDao.updateByParams("update MdMat o set o.del='1' where o.id=?", id);
		loadComboboxService.initCombobox(ComboboxType.MATPROD);
	}
	@Override
	public DataGrid getAllMats(MatBean matBean,PageParams pageParams) throws Exception {

		String hql = "from MdMat o left join fetch o.mdMatType t left join fetch o.mdUnit u where o.del='0'";

		if(StringUtil.notNull(matBean.getMatType())){
			hql = hql.concat(" and o.mdMatType.id = "+matBean.getMatType());
		}

		if(matBean.getEnable() != null){
			hql = hql.concat(" and o.enable = "+matBean.getEnable());
		}

		if(StringUtil.notNull(matBean.getCode())){
			hql = hql.concat(" and o.code like '%"+matBean.getCode()+"%'");
		}

		if(StringUtil.notNull(matBean.getName())){
			hql = hql.concat(" and o.name like '%"+matBean.getName()+"%'");
		}
		List<MdMat> mdMats = mdMatDao.queryByPage(hql+" order by o.lastUpdateTime desc ", pageParams);

		List<MatBean> list = new ArrayList<MatBean>();

		for (MdMat mdMat : mdMats) {
			MatBean bean = BeanConvertor.copyProperties(mdMat, MatBean.class);
			if(mdMat.getMdUnit()!=null){
				bean.setUnit(mdMat.getMdUnit().getName());
				bean.setUnitId(mdMat.getMdUnit().getId());
			}
			if(mdMat.getMdMatType()!=null){
				bean.setMatType(mdMat.getMdMatType().getName());
			}
			FillUserInfoUtil.fillCreateAndUpdateUserInfo(mdMat,bean);
			list.add(bean);
		}

		hql= "select count(o) ".concat(hql.replace("fetch", ""));

		Long count = mdMatDao.queryTotal(hql);

		return new DataGrid(list, count);
	}
	@Override
	public MatBean getMatById(String id) throws Exception{

		MdMat mdMat = mdMatDao.findById(MdMat.class, id);

		MatBean bean = BeanConvertor.copyProperties(mdMat,MatBean.class);

		if(mdMat.getMdUnit()!=null){
			bean.setUnit(mdMat.getMdUnit().getId());
		}

		if(mdMat.getMdMatType()!=null){
			bean.setMatType(mdMat.getMdMatType().getId());
		}

		return bean;
	}
	@Override
	public List<MatBean> queryAllProdMat() throws Exception {
		List<MatBean> list = new ArrayList<MatBean>();
		String hql = "from MdMat o where o.del='0' and o.mdMatType.code='1'";
		List<MdMat> mats=mdMatDao.query(hql);
		if(mats!=null &&mats.size()>0){
			MatBean matBean=null;
			for (MdMat mdMat : mats) {
				matBean = new MatBean(mdMat.getId(), mdMat.getName());
				list.add(matBean);
			}
		}
		return list;
	}
	@Override
	public Map<String, String[]> getAllMatMap() {
		List<?> ls=mdMatDao.queryBySql("SELECT code,id,tid from md_mat where ENABLE=1 and del=0");
		Map<String,String[]> map=new HashMap<>();
		try {
			if(ls!=null && ls.size()>0){
				for (Object obj : ls) {//需要修改
					Object[] str=(Object[]) obj;
					if(StringUtil.notEmpty(str[0]) && StringUtil.notEmpty(str[1])){
						map.put(str[0].toString(), new String[]{str[1].toString(),str[2].toString()});
					}
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return map;
	}

	@Override
	public Map<String, String[]> getAllMatMapJB() {
		List<?> ls=mdMatDao.queryBySql("SELECT code,id,tid from md_mat where ENABLE=1 and del=0 and tid not in ('14') ");
		Map<String,String[]> map=new HashMap<>();
		try {
			if(ls!=null && ls.size()>0){
				for (Object obj : ls) {//需要修改
					Object[] str=(Object[]) obj;
					if(StringUtil.notEmpty(str[0]) && StringUtil.notEmpty(str[1])){
						map.put(str[0].toString(), new String[]{str[1].toString(),str[2].toString()});
					}
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return map;
	}

	/**得到所有牌号*/
	@Override
	public Map<String, String[]> getAllMatMapCx() {
		List<?> ls=mdMatDao.queryBySql("SELECT code,id,tid from md_mat where ENABLE=1 and del=0 and tid  in ('1','14') ");
		Map<String,String[]> map=new HashMap<>();
		try {
			if(ls!=null && ls.size()>0){
				for (Object obj : ls) {//需要修改
					Object[] str=(Object[]) obj;
					if(StringUtil.notEmpty(str[0]) && StringUtil.notEmpty(str[1])){
						map.put(str[0].toString(), new String[]{str[1].toString(),str[2].toString()});
					}
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return map;
	}

	/**
	 * 存放成型机牌号
	 *
	 * */
	@Override
	public Map<String, String[]> getAllMatMapFiller() {
		List<?> ls=mdMatDao.queryBySql("SELECT code,id,tid from md_mat where ENABLE=1 and del=0 and tid='14' ");
		Map<String,String[]> map=new HashMap<>();
		try {
			if(ls!=null && ls.size()>0){
				for (Object obj : ls) {//需要修改
					Object[] str=(Object[]) obj;
					if(StringUtil.notEmpty(str[0]) && StringUtil.notEmpty(str[1])){
						map.put(str[0].toString(), new String[]{str[1].toString(),str[2].toString()});
					}
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return map;
	}

	/**
	 * 功能说明：查询当天时间的工厂日历
	 *
	 * */
	@Override
	public Map<String, String[]> getAllSchCalendar(SchWorkorder schWorkorder) {
		try {
			String sql="select shift,etim,WORKSHOP from SCH_CALENDAR where  to_char(date_,'yyyy-MM-dd')='"+DateUtil.datetoStr(schWorkorder.getDate(), "yyyy-MM-dd") +"' and WORKSHOP=1 ";
			List<?> ls=mdMatDao.queryBySql(sql);
			Map<String,String[]> map=new HashMap<String, String[]>();
			if(ls!=null && ls.size()>0){
				for (Object obj : ls) {//需要修改
					Object[] str=(Object[]) obj;
					if(StringUtil.notEmpty(str[0]) && StringUtil.notEmpty(str[1])){
						map.put(str[0].toString(), new String[]{str[1].toString(),str[2].toString()});
					}
				}
			}
			return map;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
	@Override
	public List<MatBean> getMatFiller() {
		List<MatBean> list = new ArrayList<MatBean>();
		String hql = "from MdMat o where o.del='0' and o.mdMatType.code='14'";
		List<MdMat> mats=mdMatDao.query(hql);
		if(mats!=null &&mats.size()>0){
			MatBean matBean=null;
			for (MdMat mdMat : mats) {
				matBean = new MatBean(mdMat.getId(), mdMat.getName());
				list.add(matBean);
			}
		}
		return list;
	}
	@Override
	public List<MatBean> getFlFiller() {
		List<MatBean> list = new ArrayList<MatBean>();
		String hql = "from MdMat o where o.del='0' and o.mdMatType.code='4'";
		List<MdMat> mats=mdMatDao.query(hql);
		if(mats!=null &&mats.size()>0){
			MatBean matBean=null;
			for (MdMat mdMat : mats) {
				matBean = new MatBean(mdMat.getId(), mdMat.getName());
				list.add(matBean);
			}
		}
		return list;
	}

	/**
	 * [说明]:查询物料是否存在
	 * @author wanchanghuang
	 * @date 2019年5月7日10:46:36
	 * */
	@Override
	public long queryMdMatType(MdMat mdMat) {
		try {
			String hql = "from MdMat o where o.del='0' and o.code=?";
			List<MdMat> list=mdMatDao.query(hql, mdMat.getCode());
			if(list!=null) {
				return list.size();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return 0;
	}
	/**
	 * [说明]:插入对象
	 * @author wanchanghuang
	 * @date 2019年5月7日10:46:36
	 * */
	@Override
	public void saveMdMat(MdMat mdMat) {
		mdMatDao.save(mdMat);
	}
	/**
	 *  [说明]：物料锁定-修改
	 * @author wanchanghuang
	 * @create 2019年5月15日14:03:26
	 */
	@Override
	public void updateMdMaterail(MdMaterialLk wkorder) {
		String sql="update MD_MATERIAL_LK set type='"+wkorder.getType()+"' where material_code='"+wkorder.getMaterialCode()+"' and material_batch_code='"+wkorder.getMaterialBatchCode()+"' ";
		//mdMaterialLkDao.queryBySql(sql);
		mdMaterialLkDao.updateBySql(sql, null);
	}
	/**
	 *  [说明]：物料锁定-查询
	 * @author wanchanghuang
	 * @create 2019年5月15日14:03:26
	 */
	@Override
	public long queryMdMaterailAll(MdMaterialLk wkorder) {
		try {
			String hql = "from MdMaterialLk o where o.type='1' and o.materialCode=? and o.materialBatchCode=? ";
			List<MdMaterialLk> list=mdMaterialLkDao.query(hql, wkorder.getMaterialCode(),wkorder.getMaterialBatchCode());
			if(list!=null) {
				return list.size();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return 0;
	}
	/**
	 *  [说明]：物料锁定-添加
	 * @author wanchanghuang
	 * @create 2019年5月15日14:03:26
	 */
	@Override
	public void addMdMaterail(MdMaterialLk wkorder) {
		mdMaterialLkDao.save(wkorder);
	}

	@LogAnno(operateType = "批量删除物料")
	@Override
	public void batchDeleteMat(String ids) {
		String[] split = ids.split(",");
		for (int i = 0; i < split.length; i++) {
			mdMatDao.updateByParams("update MdMat o set o.del='1' where o.id=?", split[i]);
		}
		loadComboboxService.initCombobox(ComboboxType.MATPROD);
	}


	@Override
	public List<?> getProdByMonth(String month) {


		return mdMatDao.queryBySql("select b.CODE,b.NAME from SCH_WORKORDER a join md_mat b on a.mat = b.id where to_char(a.DATE_,'yyyy-mm') = ? and a.TYPE in (1,2) group by b.CODE,b.NAME ",month);
	}
}