package com.shlanbao.tzsc.data.runtime.handler;

import java.util.ArrayList;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Queue;

import org.apache.log4j.Logger;

import com.lanbao.dac.data.CommonData;
import com.shlanbao.tzsc.utils.tools.MathUtil;
import com.shlanbao.tzsc.utils.tools.StringUtil;
/**
 * 设备故障停机时间和次数统计
 * @author luo
 *
 */
public class FaultDataCalc extends Thread{
	private static FaultDataCalc fauleData;
	//private static Hashtable<String,String> gd_Compile;
	//保存当前设备运行的班次，来源于DAC采集数据
	private Hashtable<Integer,String> currentEqpShift=new Hashtable<Integer,String>();;
	private Queue<Map<String, CommonData>> queue = new LinkedList<Map<String, CommonData>>(); 
	private Logger log = Logger.getLogger(this.getClass());
	//实例化
	public static FaultDataCalc getInstance() {
		if (fauleData == null) {
			fauleData = new FaultDataCalc();
			/*try{
				//如果初始化错误，则new一个对象
				gd_Compile=ConfigUtil.readTxtFile();
			}catch(Exception e){
				gd_Compile=new Hashtable<String,String>();
			}*/
		}
		return fauleData;
	}
	
	public Hashtable<Integer, String> getCurrentEqpShift() {
		return currentEqpShift;
	}

	public void setCurrentEqpShift(Hashtable<Integer, String> currentEqpShift) {
		this.currentEqpShift = currentEqpShift;
	}
	
	public Queue<Map<String, CommonData>> getQueue() {
		return queue;
	}

	public void setQueue(Queue<Map<String, CommonData>> queue) {
		this.queue = queue;
	}

	@Override
	public void run(){
		while(queue.peek()!=null){
			Map<String, CommonData> dataMap=queue.poll();
			if(dataMap!=null && dataMap.size()>0){
				setFauleData(dataMap);
			}
		}
	}
	
	//汇总故障数据
	public void setFauleData(Map<String, CommonData> dataMap){
		int equipmentID=0;
		try{
			equipmentID = Integer.valueOf(dataMap.get("EquipmentID").getVal());//设备
			String type = dataMap.get("TYPE").getVal().toString();
			String shiftId = dataMap.get("SHIFTINFO").getVal().toString();
			if(equipmentID<1||type.equals("null")||shiftId.equals("null")){
				log.info("设备Code："+equipmentID+",设备类型："+type+",班次:"+shiftId);
			}else if(type.toUpperCase().equals("ZJ17")){
				//设备类型判断必须要与DAC一致
				//String[] fauleDetail=new String[3];
				StringBuffer[] fauleDetail = new StringBuffer[3];
				//卷烟机 
				//卷烟机85-114点位为故障点位，其中3个为一组。例如85：故障名称，86：停机时长(停机时长格式为01:50，需转换成Integer)，87：停机次数
				for(int i=85;i<115;i=i+3){
					for(int j=0;j<3;j++){
						if(fauleDetail[j]!=null){
							fauleDetail[j].setLength(0);
						}else{
							fauleDetail[j] = new StringBuffer();
						}
						CommonData data=dataMap.get(String.valueOf(i+j));
						if(data!=null){
							String val=data.getVal();
							if(val!=null&&StringUtil.notNull(val)&&!val.equals("null")){
								fauleDetail[j].append(val.trim());
							}else{
								break;
							}
						}
					}
					if(fauleDetail[0]==null||fauleDetail[1]==null||fauleDetail[2]==null||fauleDetail[0].equals("0")){
						continue;
					}
					try{
						String[] time=fauleDetail[1].toString().split(":");
						if(time.length==2){
							fauleDetail[1].setLength(0);
							fauleDetail[1].append(String.valueOf((Integer.parseInt(time[1])+Integer.parseInt(time[0])*60)));
							setFaultByEqpId(String.valueOf(equipmentID), fauleDetail[0].toString(), fauleDetail[2].toString(), fauleDetail[1].toString(),shiftId.trim());
						}
					}catch(Exception ex){
						log.info("设备Code："+equipmentID+",故障名称："+fauleDetail[0]+",故障时间:"+fauleDetail[1]+",故障次数:"+fauleDetail[2]);
					}
				}
			}else if(type.toUpperCase().equals("ZB25")){
				//ZB25包装机 故障内容保存在8号点位表中
				CommonData data=dataMap.get("8");
				if(data!=null&&data.getVal()!=null&&StringUtil.notNull(data.getVal().trim())&&!data.getVal().trim().equals("null")){
					String faultString=data.getVal().trim();
					String[] fault=null;
					if(faultString.indexOf("&")>0){
						fault=data.getVal().split("&");
					}else{
						fault=new String[]{faultString};
					}
					for(String temp:fault){
						String[] fauleDetail=temp.split(":");
						if(fauleDetail.length!=3){
							continue;
						}
						String name=StringUtil.notNull(fauleDetail[0])?fauleDetail[0].trim():"";
						//由于包装机上传的停机时长单位是秒，所以包装机需要除以60
						double faultTime=MathUtil.roundHalfUp(Double.parseDouble(fauleDetail[1].trim())/60.00,2);
						setFaultByEqpId(String.valueOf(equipmentID), name, fauleDetail[2].trim(), String.valueOf(faultTime),shiftId.trim());
					}
				}
			}else if(type.toUpperCase().equals("ZJ19")){
				//待开发...
				log.info("ZJ19故障信息（没有点表）未开发");
			}else if(type.toUpperCase().equals("ZB45")){
				//待开发...
				log.info("ZB45故障信息（没有点表）未开发");
			}else if(type.toUpperCase().equals("PROTOS 70")){
				//待开发...
				log.info("PROTOS 70故障信息（没有点表）未开发");
			}
			currentEqpShift.put(equipmentID, shiftId);
		}catch(Exception ex){
			log.error("设备ID："+equipmentID+"故障统计出错",ex);
		}
	}
	/**
	 * 跟新设备故障
	 * @param eid 设备ID
	 * @param faultName 故障名称
	 * @param fauleNumber 故障发生次数
	 * @param fauleTime 故障发生时长
	 * @param shiftId 班次ID
	 */
	public void setFaultByEqpId(String eid,String faultName,String fauleNumber,String fauleTime,String shiftId){
		if(StringUtil.notNull(eid)&&StringUtil.notNull(faultName)&&StringUtil.notNull(fauleNumber)&&StringUtil.notNull(fauleTime)&&StringUtil.notNull(shiftId)){
			//后去当前设备的班次
			String oldShift=currentEqpShift.get(eid);
			//如果当前设备在一个班次上运行，并且当前运行的班次和DAC传过来的班次不一致，则清空当前设备的故障信息
			if(StringUtil.notNull(oldShift)&&!oldShift.equals(shiftId)){
				//保存换班前的数据，然后remove
				this.removeFaultListByEid(eid);
			}
			Hashtable<String,Hashtable<String,Double[]>> ht=NeedData.getInstance().getFaultHt();
			Hashtable<String,Double[]> eqpHt=ht.get(eid);
			if(eqpHt==null){
				eqpHt=new Hashtable<String,Double[]>();
			}
			Double[] faultNum=eqpHt.get(faultName);
			if(faultNum==null){
				faultNum=new Double[2];
			}
			if(StringUtil.isDouble(fauleNumber)&&StringUtil.isDouble(fauleTime)){
				faultNum[0]=Double.valueOf(fauleNumber);
				faultNum[1]=Double.valueOf(fauleTime);
				eqpHt.put(faultName, faultNum);
				ht.put(eid, eqpHt);
				NeedData.getInstance().setFaultHt(ht);
			}else{
				log.error("设备ID："+eid+"设备停机时间("+fauleTime+"),或停机次数("+fauleNumber+"),数据错误");
			}
		}
	}
	
	//根据设备ID获取设备故障集合，String[] //0:机台ID，1:班次，2:故障描述,3:次数,4:故障发生总时长
	public List<String[]> getFaultList(String eid){
		if(NeedData.getInstance().getFaultHt()==null)
			return null;
		Hashtable<String,Double[]> ht=NeedData.getInstance().getFaultHt().get(eid);
		if(ht!=null){
			List<String[]> list=new ArrayList<String[]>();
			for(Iterator it=ht.keySet().iterator();it.hasNext();){ 
				//key 故障描述
                String key=(String)it.next();  
                //value 0:故障次数，1:故障发生时长
                Double[] value=ht.get(key); 
                //根据设备ID获取班次信息 
                String shiftId=currentEqpShift.get(Integer.parseInt(eid));
                if(StringUtil.notNull(shiftId)){
                	//0:机台ID，1:班次，2:故障描述,3:次数,4:故障发生总时长
                    String[] temp={eid,shiftId,key,String.valueOf(value[0]),String.valueOf(value[1])};
                    list.add(temp);
                }else{
                	log.equals("获取设备故障信息出错,原因:根据设备ID："+eid+",无法获取班次信息。");
                }
            }  
			return list;
		}else{
			return null;
		}
	}
	//获取所有设备故障集合 0:机台ID，1:故障描述,2:次数,3:故障发生总时长
	public List<String[]> getAllFaultList(){
		Hashtable<String,Hashtable<String,Double[]>> ht=NeedData.getInstance().getFaultHt();
		if(ht==null){
			return null;
		}else{
			List<String[]> list=new ArrayList<String[]>();
			for(Iterator its=ht.keySet().iterator();its.hasNext();){  
				//key 设备ID
                String key=(String)its.next();   
                Hashtable<String,Double[]> value=ht.get(key);   
                for(Iterator i=value.keySet().iterator();i.hasNext();){  
                	//key 故障描述
                    String keys=(String)i.next();   
                    //value 0:故障次数，1:故障发生时长
                    Double[] v=value.get(keys);   
                    //根据设备ID获取班次信息 
                    String shiftId=currentEqpShift.get(Integer.parseInt(key));
                    if(StringUtil.notNull(shiftId)){
                    	//0:机台ID，1:班次，2:故障描述,3:次数,4:故障发生总时长
                        String[] temp={key,shiftId,keys,String.valueOf(v[0]),String.valueOf(v[1])};
                        list.add(temp);
                    }else{
                    	log.equals("获取设备故障信息出错,原因:根据设备ID："+key+",无法获取班次信息。");
                    }
                }  
            }  
			return list;
		}
	}
	//初始化故障集合
	public void removeFaultList(){
		NeedData.getInstance().setFaultHt(null);
	}
	//清空某一个设备的故障集合
	public void removeFaultListByEid(String eid){
		NeedData.getInstance().getFaultHt().remove(eid);
		/*Hashtable<String,Hashtable<String,Double[]>> ht=NeedData.getInstance().getFaultHt();
		ht.remove(eid);
		NeedData.getInstance().setFaultHt(ht);*/
	}
	
}