package com.shlanbao.tzsc.pms.qm.check.service.impl;

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

import com.shlanbao.tzsc.base.model.SessionInfo;
import com.shlanbao.tzsc.utils.tools.DateUtil;
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.QmExcheckAddDaoI;
import com.shlanbao.tzsc.base.mapping.QmExcheckAdd;
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.qm.check.beans.QmExcheckAddBean;
import com.shlanbao.tzsc.pms.qm.check.service.QmExcheckAddService;
import com.shlanbao.tzsc.pms.sch.workorder.beans.WorkOrderBean;
import com.shlanbao.tzsc.utils.tools.StringUtil;

import javax.servlet.http.HttpServletRequest;

@Service
public class QmExcheckAddServiceImpl extends BaseService implements QmExcheckAddService {
	@Autowired
	private QmExcheckAddDaoI qmexcheckaddimpl;
	@Autowired
	private HttpServletRequest request;

	@Override
	public DataGrid getAllQmExchecks(WorkOrderBean orderbean, PageParams pageParams) throws Exception {
		List<QmExcheckAddBean> exchecks=new ArrayList<QmExcheckAddBean>();
		try{
			List<?> data=new ArrayList<>();
			data=getQmExchecks(orderbean,"count",pageParams);
			Long count=0L;
			if(data!=null && data.size()>0){
				count=StringUtil.converObj2Long(data.get(0));
				if(count>0){
					List<?> rows=getQmExchecks(orderbean,"",pageParams);
					if(rows!=null && rows.size()>0){
						QmExcheckAddBean qmcheckbean=null;
						for(int i=0;i<rows.size();i++){
							Object[] temp=(Object[])rows.get(i);
							qmcheckbean=new QmExcheckAddBean();
							qmcheckbean.setId(StringUtil.convertObjToString(temp[1]));
							qmcheckbean.setMatname(StringUtil.convertObjToString(temp[2]));
							qmcheckbean.setCheckbatch(StringUtil.convertObjToString(temp[3]));//检验批次
							qmcheckbean.setTimestamp_(StringUtil.convertObjToString(temp[4]));//取样时间
							qmcheckbean.setSubBatchCode(StringUtil.convertObjToString(temp[5]));//取样批次
							qmcheckbean.setSamplenum(StringUtil.convert2Integer(temp[6]));
							qmcheckbean.setWat(StringUtil.converObj2Double(temp[8]));
							qmcheckbean.setQmexcheckaddid(StringUtil.convertObjToString(temp[9]));
							String team=StringUtil.convertObjToString(temp[7]);
							if("1".equals(team)){
								team= "甲";
							}else if("2".equals(team)){
								team= "乙";
							}else if("3".equals(team)){
								team= "丙";
							}else{
								team="-";
							}
							String equipmentName=StringUtil.convertObjToString(temp[3]);
							if(equipmentName.indexOf("K03")>=0){
								equipmentName="3#成型机";
							}else if(equipmentName.indexOf("K02")>=0){
								equipmentName="2#成型机";
							}else if(equipmentName.indexOf("K01")>=0){
								equipmentName="1#成型机";
							}
							qmcheckbean.setTeam(team);
							qmcheckbean.setEqpuipmentname(equipmentName);
							qmcheckbean.setStatus(StringUtil.convertObjToString(temp[10]));
							qmcheckbean.setCreateUserName(StringUtil.convertObjToString(temp[11]));
							qmcheckbean.setCreateUserTime(DateUtil.formatStringToDate(StringUtil.convertObjToString(temp[12]),"yyyy-MM-dd HH:mm:ss"));
							qmcheckbean.setUpdateUserName(StringUtil.convertObjToString(temp[13]));
							qmcheckbean.setUpdateUserTime(DateUtil.formatStringToDate(StringUtil.convertObjToString(temp[14]),"yyyy-MM-dd HH:mm:ss"));
							exchecks.add(qmcheckbean);
						}
					}
				}
			}
			return new DataGrid(exchecks,count);
		}catch(Exception e){
			log.error("查询所有成型成品含水率记录异常");
		}
		return new DataGrid(exchecks,0L);
	}

	@LogAnno(operateType = "添加成型机成品含水率检测记录")
	@Override
	public boolean addQmExcheck(QmExcheckAddBean qmExcheckAddbean) throws Exception {
		boolean flag=false;
		//增加创建人与创建时间信息
		SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
		String createUserName = sessionInfo.getUser().getName();
		String updateUserName = createUserName;
		if(qmExcheckAddbean.getQmexcheckaddid()!=null && !"".equals(qmExcheckAddbean.getQmexcheckaddid())){
			String sql = "update qm_cxcheck_add set wat = ?,UPDATE_USER_NAME = ?,UPDATE_USER_TIME = ? where id in(select a.id from QM_CXCHECK_ADD a join QM_ONLINECHECK b on a.qmocid = b.id join QM_ONLINECHECK c on b.team = c.team and b.materialcode = c.materialcode " +
		" and substr(b.ordernumber,0,6) = substr(c.ordernumber,0,6) where c.id = ?) ";
			List<Object> param = new ArrayList<>();
			param.add(qmExcheckAddbean.getWat());
			param.add(updateUserName);
			param.add(new Date());
			param.add(qmExcheckAddbean.getId());
			qmexcheckaddimpl.updateBySql(sql, param);
		
			flag=true;
		}else{
			String sql = "select b.id from  QM_ONLINECHECK b  join QM_ONLINECHECK c on b.team = c.team and b.materialcode = c.materialcode " + 
					" and substr(b.ordernumber,0,6) = substr(c.ordernumber,0,6) where c.id = ? ";
			List<Object> param = new ArrayList<>();
			param.add(qmExcheckAddbean.getId());
			List<?> list = qmexcheckaddimpl.queryBySql(sql, param);
			QmExcheckAdd qmCheckAdd = null;
			if (list != null && list.size()>0) {
				for (Object object : list) {
					qmCheckAdd=new QmExcheckAdd();
					qmCheckAdd.setQmocid(object.toString());
					qmCheckAdd.setWat(qmExcheckAddbean.getWat());
					qmCheckAdd.setChkDate(new Date());
					qmCheckAdd.setStatus("0");
					qmCheckAdd.setCreateUserName(createUserName);
					qmCheckAdd.setCreateUserTime(new Date());
					qmCheckAdd.setUpdateUserName(updateUserName);
					qmCheckAdd.setUpdateUserTime(qmCheckAdd.getCreateUserTime());
					qmexcheckaddimpl.save(qmCheckAdd);
				}
			}
			
			flag=true;
		}
		return flag;
	}

	@Override
	public QmExcheckAddBean deleteQmExcheckByid(String id) throws Exception {
		return null;
	}

	@Override
	public List<?> getQmExchecks(WorkOrderBean orderbean, String params, PageParams pageParams) throws Exception {
		int sRow=(pageParams.getPage()-1)*pageParams.getRows();
		int eRow=pageParams.getPage()*pageParams.getRows();
		try{
			StringBuffer sb=new StringBuffer();
			if("count".equals(params)){
				sb.append("select count(*) from (");
			}else{
				sb.append("select * from(");
			}
			sb.append("select ROWNUM as rnum,a.ID,(select name from MD_MAT where code=a.materialcode and TID in (1,14) and rownum=1) as matname,a.QCBATCHS,a.TIMESTAMP_,a.SUBBATCHCODE,a.SAMPLENUMBER,a.TEAM,b.WAT,b.ID as qmcheckaddid,b.status,b.CREATE_USER_NAME,b.CREATE_USER_TIME,b.UPDATE_USER_NAME,b.UPDATE_USER_TIME "
					+ "from QM_ONLINECHECK a left join QM_CXCHECK_ADD b on a.ID=b.QMOCID where 1=1");
			if(StringUtil.notNull(orderbean.getTeamId())){
				sb.append(" and a.TEAM='"+orderbean.getTeamId()+"'");
			}
			if(StringUtil.notNull(orderbean.getDate())){
				sb.append(" and to_char(a.TIMESTAMP_,'yyyy-MM-dd')>='"+orderbean.getDate()+"'");
			}
			if(StringUtil.notNull(orderbean.getEtim())){
				sb.append(" and to_char(a.TIMESTAMP_,'yyyy-MM-dd')<='"+orderbean.getEtim()+"'");
			}
			if(StringUtil.notNull(orderbean.getCode())){
				sb.append(" and a.ORDERNUMBER like '%"+orderbean.getCode()+"%'");
			}
			if("count".equals(params)){
				sb.append(" and a.INSPECTIONTYPE="+orderbean.getInspectionType()+" order by a.TIMESTAMP_ desc ");
				sb.append(" )");
			}else{
				sb.append(" and a.INSPECTIONTYPE="+orderbean.getInspectionType()+" order by a.TIMESTAMP_ desc");
				sb.append(" ) t where t.rnum>"+sRow+" and t.rnum<="+eRow);
			}
			String sql=sb.toString();
			List<?> list=qmexcheckaddimpl.queryBySql(sql);
			return list;
		}catch(Exception e){
			e.printStackTrace();
		}
		return null;
	}

}