package com.shlanbao.tzsc.base.interceptor;

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

import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;

import com.shlanbao.tzsc.base.dao.SchCalendarDaoI;
import com.shlanbao.tzsc.base.dao.SchStatOutputDaoI;
import com.shlanbao.tzsc.base.dao.SysMessageQueueDaoI;
import com.shlanbao.tzsc.base.mapping.SchStatOutput;
import com.shlanbao.tzsc.base.mapping.SysMessageQueue;
import com.shlanbao.tzsc.data.webservice.client.SendMessageClient;
import com.shlanbao.tzsc.pms.sch.stat.beans.InputBean;
import com.shlanbao.tzsc.pms.sch.stat.beans.OutputBean;
import com.shlanbao.tzsc.utils.tools.ApplicationContextUtil;
import com.shlanbao.tzsc.utils.tools.StringUtil;

/**
 * 工单产耗信息反馈
 * @author shisihai
 *
 */
public class WorkOrderFeedbackInterceptor {

	
	/**
	 * 
	 *说明：工单产耗信息反馈
	 * @param idOrIds
	 * @param feedbackUser
	 * @return
	 * shisihai  
	 * 20162016年2月22日上午9:06:15
	 */
	public  Integer sendWorkOrderDetails(String idOrIds,String feedbackUser){
		SchCalendarDaoI dao=ApplicationContextUtil.getBean(SchCalendarDaoI.class);
		SendMessageClient sendMessageClient=new SendMessageClient();
		for(String id : StringUtil.splitToStringList(idOrIds, ",")){
			//1.根据产出id查询出所需数据
			String sql=getFeedbackSql(id);
			//1.2封装数据
			List<?> ls=dao.queryBySql(sql);
			Map<String,Object> map=packData(ls,"1");//默认是换班类型的反馈
			//2.生成xml字符串数据文件,单个工单信息xml字符串  	
			String xmlStr=createXMLStr(map);
			//调用mes接收工单信息反馈的方法，将xml字符串传过去
			//*********************
			//sendMessageClient.SendMessageToMes("SDCSFinishedEntryInfo", xmlStr);
			if(!xmlStr.equals("")){
					addLog("工单反馈outid："+id,1);
					this.editOutputIsFeedback(id, feedbackUser);//修改状态				
			}else{
				addLog("工单反馈outid："+id,0);
				return 0;
			}
		}
		return 1;
	}

	
	
	/**
	 *说明：修改生产实绩反馈状态
	 * @param id
	 * @param feedbackUser
	 * shisihai  
	 * 20162016年2月22日上午9:03:11
	 */
	private void editOutputIsFeedback(String id,String feedbackUser){
		SchStatOutputDaoI schStatOutputDao=ApplicationContextUtil.getBean(SchStatOutputDaoI.class);
		SchStatOutput output = schStatOutputDao.findById(SchStatOutput.class, id);
		output.setIsFeedback(1L);
		output.setFeedbackTime(new Date());
		output.setFeedbackUser(feedbackUser);
		
	}
	
	
	
	/**
	 *说明：接口日志
	 * @param des
	 * @param flag 1成功  0失败
	 * shisihai  
	 * 20152015年12月28日下午4:56:58
	 */
	private void addLog(String des,Integer flag) {
		SysMessageQueueDaoI sysMessageQueueDaoI=ApplicationContextUtil.getBean(SysMessageQueueDaoI.class);
		SysMessageQueue log=new SysMessageQueue();
		log.setSysReceive(2L);//接受方
		log.setSysSend(1L);//发送方
		log.setDel(0L);
		log.setMsgType(1L);
		log.setDes(des);//描述
		log.setFlag(flag);
		log.setDate(new Date());
		try {
			sysMessageQueueDaoI.saveAndReturn(log);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	/**
	 *说明：生成工单产耗详细xml，反馈给mes
	 * @param map
	 * @return
	 * shisihai  
	 * 20152015年12月28日下午2:20:21
	 */
	@SuppressWarnings("unchecked")
	private String createXMLStr(Map<String, Object> map) {
		OutputBean out=(OutputBean) map.get("out");
		List<InputBean> inputs=(List<InputBean>) map.get("input");
		try {
			Document doc=DocumentHelper.createDocument();
			Element root=doc.addElement("EntryShiftORFinished");//根节点
			Element entryBasicInfo=root.addElement("EntryBasicInfo");
			if (out!=null) {
				//订单号
				entryBasicInfo.addElement("OrderID").setText(out.getOrderNum());
				//工单号
				entryBasicInfo.addElement("EntryID").setText(out.getWorkorderCode());
				//生产日期
				entryBasicInfo.addElement("ProduceDate").setText(out.getDate());
				//牌号编码
				entryBasicInfo.addElement("OutMaterialID").setText(out.getMatId());
				//批次作业号
				entryBasicInfo.addElement("LotID").setText(out.getBth());
				//产量信息
				Element outMaterialQuantity = entryBasicInfo.addElement("OutMaterialQuantity");
				//实际产量
				outMaterialQuantity.addElement("RealOutMaterialQuantity")
						.setText(StringUtil.convertObjToString(out.getQty()));
				//修改产量
				outMaterialQuantity.addElement("ChangeMaterialQuantity")
						.setText(StringUtil.convertObjToString(out.getChangeQty()));
				//修改产量标识
				outMaterialQuantity.addElement("ChangeIdentifer").setText(out.getChangeFlag());
				//单位
				entryBasicInfo.addElement("UOM").setText(out.getUnitName());
				//设备编码
				entryBasicInfo.addElement("DeviceID").setText(out.getEqpCode());
				//批次作业顺序号
				entryBasicInfo.addElement("SequenceNumber").setText(out.getSequenceNumber());
				//计划开始时间
				entryBasicInfo.addElement("PlanningStartTime").setText(out.getPstim());
				//计划结束时间
				entryBasicInfo.addElement("PlanningFinishedTime").setText(out.getPetim());
				//实际开始时间
				entryBasicInfo.addElement("ActualStartTime").setText(out.getStim());
				//实际结束时间
				entryBasicInfo.addElement("ActualFinishedTime").setText(out.getEtim());
				//外联设备相关信息
				Element destination = entryBasicInfo.addElement("Destination");
				destination.addElement("DestinationID");
				destination.addElement("DestinationType");
				Element sourceDevice = entryBasicInfo.addElement("SourceDevice");
				for (int i = 0; i < 2; i++) {
					Element item = sourceDevice.addElement("Item");
					item.addElement("SouceDeviceID");
					item.addElement("SouceDeviceType");
				}
				//工单类型编号
				entryBasicInfo.addElement("EntryType").setText(out.getOrderType());
				//班次
				entryBasicInfo.addElement("ShiftID").setText(out.getShift());
				//班组
				entryBasicInfo.addElement("TeamID").setText(out.getTeam());
				//结果类型
				entryBasicInfo.addElement("Result").setText(out.getResult());
				//删除标志
				entryBasicInfo.addElement("DeleteFlag").setText(StringUtil.convertObjToString(out.getDel()));
			}
			if (inputs!=null) {
				//辅料消耗信息
				Element materialInfo = root.addElement("MaterialInfo");
				for (InputBean input : inputs) {
					Element item = materialInfo.addElement("Item");
					//辅料类型
					item.addElement("MaterialClass").setText(input.getMatType());
					//辅料编码
					item.addElement("MaterialID").setText(input.getMatCode());
					//物料批次号
					item.addElement("LotID").setText(input.getBth());
					//消耗
					item.addElement("Quantity").setText(StringUtil.convertObjToString(input.getQty()));
					//单位
					item.addElement("UOM").setText(input.getUnit());
				} 
			}
			StringBuffer xmlStr=new StringBuffer(doc.asXML());
//			Document document = DocumentHelper.parseText(xmlStr.toString());  
//			System.err.println(document.asXML());
			return xmlStr.toString();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return	"";
	}
	
	/**
	 * 
	 *说明：查询工单产耗信息
	 * @param id
	 * @return
	 * shisihai  
	 * 20162016年2月22日上午10:52:04
	 */
	private String getFeedbackSql(String id){
		StringBuffer sb=new StringBuffer();
		sb.append("SELECT ");
		sb.append(" swo.erp_code AS mod_id,swo.code AS orderCode,to_char(swo.DATE_,'yyyy-mm-dd') as sdate,swo.MAT,swo.BTH,");
		sb.append(" nvl(sso.QTY, 0) as qty,nvl(sso.DACQTY, 0) as dacQty,(SELECT mes_code as mes_code from MD_UNIT mdu where sso.UNIT=mdu.id) as unit,");
		sb.append(" (SELECT	MES_EQPCODE FROM MD_EQUIPMENT WHERE id = swo.EQP) AS eqpCode,");
		sb.append(" RUN_SEQ as sequenceNumber,");
		sb.append(" to_char(swo.STIM,'yyyy-mm-dd hh24:mi:ss') as stim,to_char(swo.ETIM,'yyyy-mm-dd hh24:mi:ss') as etim,to_char(swo.REAL_STIM,'yyyy-mm-dd hh24:mi:ss') as rstim,to_char(swo.REAL_ETIM,'yyyy-mm-dd hh24:mi:ss') as retim,");
		sb.append(" swo.TYPE,swo.SHIFT,swo.TEAM,");
		sb.append(" swo.sts,tab.*");
		sb.append(" FROM SCH_STAT_OUTPUT sso LEFT JOIN SCH_WORKORDER swo ON sso.OID = swo.id");
		sb.append(" LEFT JOIN ( SELECT (SELECT TID FROM MD_MAT WHERE mat = id ) AS flClass,(SELECT code FROM MD_MAT WHERE mat = id ) AS flCode,");
		sb.append(" '物料批次' AS wuBth,");
		sb.append(" QTY AS flQty,(SELECT mes_code as mes_code FROM MD_UNIT WHERE UNIT = id) AS flunName,OUT_ID FROM SCH_STAT_INPUT ) tab ON tab.OUT_ID = sso.ID");
		sb.append(" WHERE sso.id ='"+id+"'");
		return sb.toString();
	}
	
	
	
	/**
	 * 
	 *说明：封装工单详细反馈数据
	 * @param ls
	 * @param FeedbackType 反馈类型 0-结束工单  1-换班
	 * @return
	 * shisihai  
	 * 20152015年12月28日下午1:51:22
	 */
	private Map<String, Object> packData(List<?> ls,String FeedbackType) {
		Map<String,Object> map=new HashMap<String,Object>();
		List<InputBean> inputs=new ArrayList<InputBean>();
		InputBean input=null;
		OutputBean out=null;
		if(ls!=null && ls.size()>0){
			Object[] obj=null;
			for (int i = 0; i < ls.size(); i++) {
				obj=(Object[]) ls.get(i);
				if(i==0){
					out=new OutputBean();
					//ERP订单号
					out.setOrderNum(StringUtil.convertObjToString(obj[0]));
					//工单号
					out.setWorkorderCode(StringUtil.convertObjToString(obj[1]));
					//工单日期
					out.setDate(StringUtil.convertObjToString(obj[2]));
					//牌号编码
					out.setMatId(StringUtil.convertObjToString(obj[3]));
					//作业批次号
					out.setBth(StringUtil.convertObjToString(obj[4]));
					//实际产量
					out.setQty(this.convDouble(obj[5]));
					//修改产量
					out.setChangeQty(this.convDouble(obj[5])-this.convDouble(obj[6]));
					//修改标志
					out.setChangeFlag("");
					//单位
					out.setUnitName(StringUtil.convertObjToString(obj[7]));
					//设备code
					out.setEqpCode(StringUtil.convertObjToString(obj[8]));
					//批次作业顺序号
					out.setSequenceNumber(StringUtil.convertObjToString(obj[9]));
					//计划开始
					out.setPstim(StringUtil.convertObjToString(obj[10]));
					//计划结束
					out.setPetim(StringUtil.convertObjToString(obj[11]));
					//实际开始
					out.setStim(StringUtil.convertObjToString(obj[12]));
					//实际结束
					out.setEtim(StringUtil.convertObjToString(obj[13]));
					//工单类型编号
					out.setOrderType(StringUtil.convertObjToString(obj[14]));
					//班次
					out.setShift(StringUtil.convertObjToString(obj[15]));
					//班组
					out.setTeam(StringUtil.convertObjToString(obj[16]));
					//结果
					out.setResult("");
					//删除状态
					out.setDel(0L);
					//工单状态
					out.setOrderStat(StringUtil.convertObjToString(obj[17]));
					map.put("out", out);
				}
				input=new InputBean();
				//辅料类型
				input.setMatType(StringUtil.convertObjToString(obj[18]));
				//辅料code
				input.setMatCode(StringUtil.convertObjToString(obj[19]));
				//物料批次
				input.setBth(StringUtil.convertObjToString(obj[20]));
				//消耗量
				input.setQty(convDouble(obj[21]));
				//单位
				input.setUnit(StringUtil.convertObjToString(obj[22]));
				inputs.add(input);
			}
		}
		map.put("input", inputs);
		return map;
	}
	
	/**
	 * Obje 转Double
	 * TODO
	 * @param o
	 * @return
	 * TRAVLER
	 * 2015年12月2日下午4:30:32
	 */
	private Double convDouble(Object o){
		Double d=0.0;
		if(o!=null&&StringUtil.isDouble(o.toString())){
			d=Double.valueOf(o.toString());
		}
		return d;
	}
	
}