uas-eis/src/main/java/com/uas/eis/serviceImpl/MESHelperServiceImpl.java

package com.uas.eis.serviceImpl;

import com.uas.eis.core.config.SpObserver;
import com.uas.eis.dao.BaseDao;
import com.uas.eis.dao.SqlRowList;
import com.uas.eis.entity.ErrorMessage;
import com.uas.eis.entity.HelperType;
import com.uas.eis.exception.ApiSystemException;
import com.uas.eis.sdk.entity.ApiResult;
import com.uas.eis.service.MESDataService;
import com.uas.eis.service.MESHelperService;
import com.uas.eis.utils.*;
import flexjson.JSON;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import net.sf.json.JsonConfig;
import org.apache.commons.lang.StringUtils;
import org.dom4j.DocumentException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.jackson.JsonObjectDeserializer;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestBody;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.SAXException;
import sun.awt.TimedWindowEvent;

import java.io.IOException;
import java.sql.Timestamp;
import java.util.*;

import org.dom4j.DocumentHelper;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;

import org.xml.sax.InputSource;
import java.io.StringReader;

@Service
public class MESHelperServiceImpl implements MESHelperService {

	@Autowired
	private BaseDao baseDao;

	@Value("${spring.datasource.username}")
	private String username;

	@Override
	public Map<Object,Object> TestInsertLog(String data){
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		baseDao.execute("insert into EISDATA(ed_id,ed_data,ed_indate)values(EISDATA_seq.nextval,?,sysdate)",data);
		rmap.put("result","OK");
		rmap.put("message", "OK,写入数据成功");
		return rmap;
	}

	@Override
	public Map<Object,Object> Radium(String data) {
		Map<String, Object> map=null;
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String oErrMessage="";
		String UserName="";
		try{
			map =BaseUtil.convertJsonToMap(data);
		}catch (Exception e){
			System.out.printf(e.getMessage()) ;
		}
		if(map.get("SN")==null){
			rmap.put("code",-1);
			rmap.put("message","SN号不能为空");
			return rmap;
		}
		if(map.get("MO")==null){
			rmap.put("code",-1);
			rmap.put("message","工单号不能为空");
			return rmap;
		}
		if(map.get("SpecificationName")==null){
			rmap.put("code",-1);
			rmap.put("message","工序不能为空");
			return rmap;
		}
		if(map.get("UserName")==null){
			rmap.put("code",-1);
			rmap.put("message","用户不能为空");
			return rmap;
		}
		String specificationName=map.get("SpecificationName").toString();
		String MO=map.get("MO").toString();

		Map<Object,Object> map1=BaseUtil.parseFormStoreToMap(map.get("SN").toString());
		for (Map.Entry<Object, Object> entry : map1.entrySet()) {
			Object key = entry.getKey();
			Object value = entry.getValue();
			SqlRowList rs=baseDao.queryForRowSet("select 1 from makesnlist where msl_sncode='"+value.toString().toUpperCase()+"'" +
					" and msl_makecode='"+MO+"' and msl_Radium=-1");
			if(rs.next()){
				oErrMessage+="序列号"+value.toString().toUpperCase()+"已镭雕,";

			}else {
				baseDao.execute("update makesnlist set msl_Radium=-1 where msl_sncode='"+value.toString().toUpperCase()+"' and " +
						"msl_makecode='"+MO+"'");
			}
			//启用过站
			if(baseDao.getFieldDataByCondition("configs","data","caller='MESSetting' and code='Radium'").toString().equals("1")){
				oErrMessage+=GoMo(value.toString().toUpperCase(),MO, specificationName);
				if(oErrMessage.equals("null")){
					oErrMessage="";
				}else{
					rmap.put("code",-1);
					rmap.put("message",oErrMessage);
					return rmap;
				}
				oErrMessage+=CheckRoutePassed(value.toString().toUpperCase(),specificationName);
				if(oErrMessage.equals("null")){
					oErrMessage="";
				}else{
					rmap.put("code",-1);
					rmap.put("message",oErrMessage);
					return rmap;
				}
				oErrMessage+=SetPcbaData(value.toString().toUpperCase(),specificationName,UserName,"OK");
				if(oErrMessage.equals("null")){
					oErrMessage="";
				}else{
					rmap.put("code",-1);
					rmap.put("message",oErrMessage);
					return rmap;
				}
			}
		}
		if(oErrMessage.equals("")||oErrMessage==null){
			rmap.put("code",0);
			rmap.put("message","镭射识别绑定成功");
			return rmap;
		}else{
			rmap.put("code",-1);
			rmap.put("message",oErrMessage);
			return rmap;
		}
	}

	@Override
	public Map<Object,Object> SPI(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		try {
			JSONObject object = JSONObject.fromObject(data);

			if (!object.containsKey("SPIRecord") || object.get("SPIRecord") == null) {
				rmap.put("code", "-1");
				rmap.put("result","NG");
				rmap.put("message", "NG,参数缺少必要节点: SPIRecord");
				return rmap;
			}
			JSONObject record = JSONObject.fromObject(object.get("SPIRecord"));
			String Username   = record.optString("Username", "");
			String Shiftname  = record.optString("Shiftname", "");
			String MachineNO  = record.optString("MachineNO", "");
			String LineNO     = record.optString("LineNO", "");
			String procedure  = record.optString("procedure", "");
			String Moname     = record.optString("Moname", "");
			String Lotsn      = record.optString("Lotsn", "");
			String Side       = record.optString("Side", "");
			String Result     = record.optString("Result", "");
			String Defect     = record.optString("Defect", "");
			String elementQTY = record.optString("elementQTY", "");
			String TestQTY    = record.optString("TestQTY", "");
			String Time       = record.optString("Time", "");

			String AreaCPK		= record.optString("AreaCPK", "");
			String HeightCPK	= record.optString("HeightCPK", "");
			String VolumeCPK	= record.optString("VolumeCPK", "");
			String Track = "";
			int lastIndex = MachineNO.lastIndexOf("-");
			if (lastIndex > -1) {
				Track = MachineNO.substring(lastIndex + 1);
				MachineNO = MachineNO.substring(0, lastIndex);

				StringBuilder un = new StringBuilder(Username);
				Username = Track.contains("2") ? un.insert(4, Track).toString() : Username;
			}

			if (Time.contains("T")) {
				Time = Time.substring(0, 19).replaceAll("T", " ");
			}

			if(Lotsn == null || Lotsn.isEmpty()){
				rmap.put("code","0");
				rmap.put("result","OK");
				rmap.put("ServerMessage","OK,空序列号Mes跳过处理");
				return rmap;
			}

			SqlRowList rs=baseDao.queryForRowSet("SELECT devicetestinfo_seq.NEXTVAL seq FROM dual");
			Map<Object, Object> paramsMap = new HashMap<Object, Object>();
			if(rs.next()){
				paramsMap.put("DTI_ID",rs.getString("seq"));
				paramsMap.put("DTI_SNCODE",Lotsn);
				paramsMap.put("DTI_USERNAME",Username);
				paramsMap.put("DTI_MACHINE",MachineNO);
				paramsMap.put("DTI_LINECODE",LineNO);
				paramsMap.put("DTI_RESULT",Result);

				paramsMap.put("DTI_MAKECODE",Moname);
				paramsMap.put("DTI_SHIFTNAME",Shiftname);
				paramsMap.put("DTI_PROGRAM",procedure);
				paramsMap.put("DTI_DEFECT",Defect);
				paramsMap.put("DTI_TESTQTY",TestQTY);

				paramsMap.put("DTI_MACHINETYPE","SPI");
				paramsMap.put("DTI_TYPE","SPI");

				paramsMap.put("DTI_TIME",Time);
				paramsMap.put("DTI_SOURCECONTENT","");
				paramsMap.put("dti_elementQTY",elementQTY);
				paramsMap.put("dti_side",Side);

				paramsMap.put("DTI_AREACPK",AreaCPK);
				paramsMap.put("DTI_HEIGHTCPK",HeightCPK);
				paramsMap.put("DTI_VOLUMECPK",VolumeCPK);
				paramsMap.put("DTI_TRACK",Track);
				baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap,"devicetestinfo"));
			}
			String oErrMessage=null;
			List<String> list = new ArrayList<String>();
			list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
					String.valueOf(Moname),
					String.valueOf(Username),
					String.valueOf(Lotsn),
					String.valueOf("")
			}, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
			oErrMessage=list.get(2);
			if(oErrMessage != null){
				rmap.put("code", "-1");
				rmap.put("result","NG");
				rmap.put("message", "NG,过站核对失败,"+oErrMessage );
				return rmap;
			}
			String wo = list.get(0);
			Map<Object, Object> stepMap = SetStepFinish(wo, Username, Lotsn, "", "OK", Username, "");
			if(stepMap.get("oErrMessage") != null){
				rmap.put("code", "-1");
				rmap.put("result","NG");
				rmap.put("message", "NG,处理过站失败," + stepMap.get("oErrMessage") );
				return rmap;
			}
			rmap.put("code","0");
			rmap.put("result","OK");
			rmap.put("ServerMessage","OK,过站处理成功,SPI测试数据上传成功");

		} catch (Exception e) {
			rmap.put("code", "-1");
			rmap.put("result","NG");
			rmap.put("message", "NG,SPI接口异常: "+e.getMessage());
		}
		return rmap;
	}

	@Override
	public Map<Object, Object> AOI(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		try {
			JSONObject object = JSONObject.fromObject(data);

			if (!object.containsKey("AOIRecord") || object.get("AOIRecord") == null) {
				rmap.put("code", "-1");
				rmap.put("result", "NG");
				rmap.put("message", "NG,参数缺少必要节点: AOIRecord");
				return rmap;
			}

			JSONObject record = JSONObject.fromObject(object.get("AOIRecord"));
			String Username   = record.optString("Username", "");
			String Shiftname  = record.optString("Shiftname", "");
			String MachineNO  = record.optString("MachineNO", "");
			String LineNO     = record.optString("LineNO", "");
			String procedure  = record.optString("procedure", "");
			String Moname     = record.optString("Moname", "");
			String Lotsn      = record.optString("Lotsn", "");
			String Side       = record.optString("Side", "");
			String Result     = record.optString("Result", "");
			String Defect     = record.optString("Defect", "");
			String elementQTY = record.optString("elementQTY", "");
			String TestQTY    = record.optString("TestQTY", "");
			String Type       = record.optString("Type", "AOI");
			String Time       = record.optString("Time", "");
			String Track = "";
			int lastIndex = MachineNO.lastIndexOf("-");
			if (lastIndex > -1) {
				Track = MachineNO.substring(lastIndex + 1);
				MachineNO = MachineNO.substring(0, lastIndex);

				StringBuilder un = new StringBuilder(Username);
				Username = Track.contains("2") ? un.insert(4, Track).toString() : Username;
			}

			if (Time.contains("T")) {
				Time = Time.substring(0, 19).replaceAll("T", " ");
			}

			if(Lotsn == null || Lotsn.isEmpty()){
				SqlRowList mhc = baseDao.queryForRowSet("SELECT * FROM(SELECT mhc_id, mhc_indate, trunc((sysdate - mhc_indate) * 1440) minute " +
						"FROM makehourcount WHERE mhc_macode = '"+Moname+"' AND mhc_linecode = '"+LineNO+"' AND mhc_sourcecode = '"+Username+"' " +
						"ORDER BY mhc_indate DESC) WHERE ROWNUM = 1");

				SqlRowList sc = baseDao.queryForRowSet("select sc_stepcode,sc_stepname from Source where sc_code = '"+Username+"'");
				String sc_stepcode="";
				if(sc.next()){
					sc_stepcode = sc.getString("sc_stepcode");
				}

				if(mhc.next()){
					if(mhc.getInt("minute") > 10){
						baseDao.execute("insert into makehourcount(mhc_id, mhc_macode, mhc_indate, mhc_type, mhc_sourcecode, " +
								"mhc_inman, mhc_qty, mhc_linecode, mhc_pcbcount, mhc_stepcode)" +
								"values(makehourcount_seq.nextval,'"+Moname+"',sysdate,'','"+Username+"'," +
								"'"+Username+"',1,'"+LineNO+"',1,'"+sc_stepcode+"')");
					}else {
						baseDao.updateByCondition("makehourcount", "MHC_QTY = MHC_QTY+1", "mhc_id='" + mhc.getString("mhc_id") + "'");
					}
				}
				if(mhc.size() == 0){
					baseDao.execute("insert into makehourcount(mhc_id, mhc_macode, mhc_indate, mhc_type, mhc_sourcecode, " +
							"mhc_inman, mhc_qty, mhc_linecode, mhc_pcbcount, mhc_stepcode)" +
							"values(makehourcount_seq.nextval,'"+Moname+"',sysdate,'','"+Username+"'," +
							"'"+Username+"',1,'"+LineNO+"',1,'"+sc_stepcode+"')");
				}

				rmap.put("code","0");
				rmap.put("result","OK");
				rmap.put("ServerMessage","OK,空序列号Mes跳过处理");
				return rmap;
			}

			SqlRowList rs = baseDao.queryForRowSet("SELECT devicetestinfo_seq.NEXTVAL seq FROM dual");
			Map<Object, Object> paramsMap = new HashMap<Object, Object>();
			if (rs.next()) {
				paramsMap.put("DTI_ID", rs.getString("seq"));
				paramsMap.put("DTI_SNCODE", Lotsn);
				paramsMap.put("DTI_USERNAME", Username);
				paramsMap.put("DTI_MACHINE", MachineNO);
				paramsMap.put("DTI_LINECODE", LineNO);
				paramsMap.put("DTI_RESULT", Result);

				paramsMap.put("DTI_MAKECODE", Moname);
				paramsMap.put("DTI_SHIFTNAME", Shiftname);
				paramsMap.put("DTI_PROGRAM", procedure);
				paramsMap.put("DTI_DEFECT", Defect);
				paramsMap.put("DTI_TESTQTY", TestQTY);

				paramsMap.put("DTI_MACHINETYPE", Type);
				paramsMap.put("DTI_TYPE", "AOI");

				paramsMap.put("DTI_TIME", Time);
				paramsMap.put("DTI_SOURCECONTENT", "");
				paramsMap.put("dti_elementQTY", elementQTY);
				paramsMap.put("dti_side", Side);
				paramsMap.put("DTI_TRACK",Track);
				baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap, "devicetestinfo"));
			}

			String oErrMessage=null;
			List<String> list = new ArrayList<String>();
			list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
					String.valueOf(Moname),
					String.valueOf(Username),
					String.valueOf(Lotsn),
					String.valueOf("")
			}, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
			oErrMessage=list.get(2);
			if(oErrMessage != null){
				rmap.put("code", "-1");
				rmap.put("result","NG");
				rmap.put("message", "NG,过站核对失败,"+oErrMessage );
				return rmap;
			}

			String[] items = Defect.split(",");
			String errCode = "";
			for (String item : items) {
				SqlRowList rs1 = baseDao.queryForRowSet("SELECT bc_code FROM BADCODE where bc_name = '"+ item +"'");
				if(rs1.next()){
					if(errCode == null || errCode.isEmpty()){
						errCode = rs1.getString("bc_code");
					}else{
						errCode = errCode + "," +rs1.getString("bc_code");
					}
				}
			}
			String newRes = "PASS".equals(Result) ? "OK":"NG";
			String wo = list.get(0);
			Map<Object, Object> stepMap = SetStepFinish(wo, Username, Lotsn, "", newRes, Username, errCode);
			if(stepMap.get("oErrMessage") != null){
				rmap.put("code", "-1");
				rmap.put("result","NG");
				rmap.put("message", "NG,处理过站失败," + stepMap.get("oErrMessage") );
				return rmap;
			}

			rmap.put("code","0");
			rmap.put("result","OK");
			rmap.put("ServerMessage", "OK,过站处理成功,AOI测试数据上传成功");
		} catch (Exception e) {
			rmap.put("code", "-1");
			rmap.put("result", "NG");
			rmap.put("message", "NG,AOI接口异常:" + e.getMessage());
		}
		return rmap;
	}

	@Override
	public Map<Object,Object> ReflowOvenCheck(String data){
		Map<Object,Object> rmap = new HashMap<Object,Object>();

		JSONObject object = JSONObject.fromObject(data);
		String SN   			= object.optString("SN", "");
		String TERMINAL_NAME	= object.optString("TERMINAL_NAME", "");
		String EMP_NO   	  	= object.optString("EMP_NO", "");
		try{
			List<String> list = new ArrayList<String>();
			list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
					String.valueOf(""),
					String.valueOf(TERMINAL_NAME),
					String.valueOf(SN),
					String.valueOf(EMP_NO)
			}, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
			String oErrMessage=list.get(2);
			String wo=list.get(0);
			if(oErrMessage != null){
				rmap.put("SN", SN);
				rmap.put("Status", false);
				rmap.put("Message", "NG," + oErrMessage);
				return rmap;
			}

			Map<Object, Object> stepMap = SetStepFinish(wo, EMP_NO, SN, "", "OK", EMP_NO, "");
			if(stepMap.get("oErrMessage") != null){
				rmap.put("SN", SN);
				rmap.put("Status", false);
				rmap.put("Message", "NG,处理过站失败," + stepMap.get("oErrMessage") );
				return rmap;
			}
			rmap.put("SN", SN);
			rmap.put("Status", true);
			rmap.put("Message", "OK,过站处理成功");
		}catch (Exception ex){
			rmap.put("SN", SN);
			rmap.put("Status", false);
			rmap.put("Message", "NG," + ex.getMessage());
		}
		return rmap;
	}

	@Override
	public Map<Object,Object> ReflowOven(String data){
		Map<Object,Object> rmap = new HashMap<Object,Object>();
		try{
			JSONObject object = JSONObject.fromObject(data);

			Map<Object, Object> paramsMap = new HashMap<Object, Object>();
			SqlRowList rs = baseDao.queryForRowSet("SELECT hlh_seq.NEXTVAL seq FROM dual");
			if (rs.next()) {
				paramsMap.put("HLH_ID", rs.getString("seq"));
			}
//			paramsMap.put("HLH_INDATE", "sysdate");
			// 基本信息
			paramsMap.put("WorkMode", object.optString("WorkMode", ""));
			paramsMap.put("ProjectName", object.optString("ProjectName", ""));
			paramsMap.put("TrackLength", object.optString("TrackLength", ""));
			// 冷区温度
			paramsMap.put("CZoneT1_RV", object.optString("CZoneT1_RV", ""));
			paramsMap.put("CZoneT2_RV", object.optString("CZoneT2_RV", ""));
			paramsMap.put("CZoneT3_RV", object.optString("CZoneT3_RV", ""));
			paramsMap.put("CZoneT4_RV", object.optString("CZoneT4_RV", ""));
			paramsMap.put("CZoneT5_RV", object.optString("CZoneT5_RV", ""));
			paramsMap.put("CZoneT1_SV", object.optString("CZoneT1_SV", ""));
			paramsMap.put("CZoneT2_SV", object.optString("CZoneT2_SV", ""));
			paramsMap.put("CZoneT3_SV", object.optString("CZoneT3_SV", ""));
			paramsMap.put("CZoneT4_SV", object.optString("CZoneT4_SV", ""));
			paramsMap.put("CZoneT5_SV", object.optString("CZoneT5_SV", ""));
			// 风机转速
			paramsMap.put("MotorRev1_RV", object.optString("MotorRev1_RV", ""));
			paramsMap.put("MotorRev2_RV", object.optString("MotorRev2_RV", ""));
			paramsMap.put("MotorRev3_RV", object.optString("MotorRev3_RV", ""));
			paramsMap.put("MotorRev4_RV", object.optString("MotorRev4_RV", ""));
			paramsMap.put("MotorRev5_RV", object.optString("MotorRev5_RV", ""));
			paramsMap.put("MotorRev1_SV", object.optString("MotorRev1_SV", ""));
			paramsMap.put("MotorRev2_SV", object.optString("MotorRev2_SV", ""));
			paramsMap.put("MotorRev3_SV", object.optString("MotorRev3_SV", ""));
			paramsMap.put("MotorRev4_SV", object.optString("MotorRev4_SV", ""));
			paramsMap.put("MotorRev5_SV", object.optString("MotorRev5_SV", ""));
			// 链速
			paramsMap.put("Speeds1_RV", object.optString("Speeds1_RV", ""));
			paramsMap.put("Speeds2_RV", object.optString("Speeds2_RV", ""));
			paramsMap.put("Speeds1_SV", object.optString("Speeds1_SV", ""));
			paramsMap.put("Speeds2_SV", object.optString("Speeds2_SV", ""));
			// 氧气浓度
			paramsMap.put("O21_RV", object.optString("O21_RV", ""));
			paramsMap.put("O21_SV", object.optString("O21_SV", ""));
			// 指示灯状态
			paramsMap.put("bLight_red", object.optString("bLight_red", ""));
			paramsMap.put("bLight_yellow", object.optString("bLight_yellow", ""));
			paramsMap.put("bLight_green", object.optString("bLight_green", ""));
			// 上温区当前温度
			paramsMap.put("T1_RV", object.optString("T1_RV", ""));
			paramsMap.put("T2_RV", object.optString("T2_RV", ""));
			paramsMap.put("T3_RV", object.optString("T3_RV", ""));
			paramsMap.put("T4_RV", object.optString("T4_RV", ""));
			paramsMap.put("T5_RV", object.optString("T5_RV", ""));
			paramsMap.put("T6_RV", object.optString("T6_RV", ""));
			paramsMap.put("T7_RV", object.optString("T7_RV", ""));
			paramsMap.put("T8_RV", object.optString("T8_RV", ""));
			paramsMap.put("T9_RV", object.optString("T9_RV", ""));
			paramsMap.put("T10_RV", object.optString("T10_RV", ""));
			paramsMap.put("T11_RV", object.optString("T11_RV", ""));
			paramsMap.put("T12_RV", object.optString("T12_RV", ""));
			paramsMap.put("T13_RV", object.optString("T13_RV", ""));
			// 上温区设定温度
			paramsMap.put("T1_SV", object.optString("T1_SV", ""));
			paramsMap.put("T2_SV", object.optString("T2_SV", ""));
			paramsMap.put("T3_SV", object.optString("T3_SV", ""));
			paramsMap.put("T4_SV", object.optString("T4_SV", ""));
			paramsMap.put("T5_SV", object.optString("T5_SV", ""));
			paramsMap.put("T6_SV", object.optString("T6_SV", ""));
			paramsMap.put("T7_SV", object.optString("T7_SV", ""));
			paramsMap.put("T8_SV", object.optString("T8_SV", ""));
			paramsMap.put("T9_SV", object.optString("T9_SV", ""));
			paramsMap.put("T10_SV", object.optString("T10_SV", ""));
			paramsMap.put("T11_SV", object.optString("T11_SV", ""));
			paramsMap.put("T12_SV", object.optString("T12_SV", ""));
			paramsMap.put("T13_SV", object.optString("T13_SV", ""));
			// 下温区当前温度
			paramsMap.put("B1_RV", object.optString("B1_RV", ""));
			paramsMap.put("B2_RV", object.optString("B2_RV", ""));
			paramsMap.put("B3_RV", object.optString("B3_RV", ""));
			paramsMap.put("B4_RV", object.optString("B4_RV", ""));
			paramsMap.put("B5_RV", object.optString("B5_RV", ""));
			paramsMap.put("B6_RV", object.optString("B6_RV", ""));
			paramsMap.put("B7_RV", object.optString("B7_RV", ""));
			paramsMap.put("B8_RV", object.optString("B8_RV", ""));
			paramsMap.put("B9_RV", object.optString("B9_RV", ""));
			paramsMap.put("B10_RV", object.optString("B10_RV", ""));
			paramsMap.put("B11_RV", object.optString("B11_RV", ""));
			paramsMap.put("B12_RV", object.optString("B12_RV", ""));
			paramsMap.put("B13_RV", object.optString("B13_RV", ""));
			// 下温区设定温度
			paramsMap.put("B1_SV", object.optString("B1_SV", ""));
			paramsMap.put("B2_SV", object.optString("B2_SV", ""));
			paramsMap.put("B3_SV", object.optString("B3_SV", ""));
			paramsMap.put("B4_SV", object.optString("B4_SV", ""));
			paramsMap.put("B5_SV", object.optString("B5_SV", ""));
			paramsMap.put("B6_SV", object.optString("B6_SV", ""));
			paramsMap.put("B7_SV", object.optString("B7_SV", ""));
			paramsMap.put("B8_SV", object.optString("B8_SV", ""));
			paramsMap.put("B9_SV", object.optString("B9_SV", ""));
			paramsMap.put("B10_SV", object.optString("B10_SV", ""));
			paramsMap.put("B11_SV", object.optString("B11_SV", ""));
			paramsMap.put("B12_SV", object.optString("B12_SV", ""));
			paramsMap.put("B13_SV", object.optString("B13_SV", ""));

			baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap, "HLH"));

			rmap.put("Status", true);
			rmap.put("Message", "Success");
		}catch (Exception ex){
			rmap.put("Status", false);
			rmap.put("Message", "Fail," + ex.getMessage());
		}
		return rmap;
	}
	@Override
	public Map<Object, Object> PrintCheck(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		JSONObject object = JSONObject.fromObject(data);
		JSONObject obj1=object.getJSONObject("Header");
		JSONObject obj2=object.getJSONObject("Body");
		if(obj1!=null){
			String Command=obj1.get("Command").toString();
			String SessionID=obj1.get("SessionID").toString();
			String TimeStamp=obj1.get("TimeStamp").toString();
			String Direction=obj1.get("Direction").toString();
			String Vendor=obj1.get("Vendor").toString();
			String Line=obj1.get("Line").toString();
			String MachineSN=obj1.get("MachineSN").toString();
			String MachineType=obj1.get("MachineType").toString();
			String FrontSqueegeeSN="";
			String RearSqueegeeSN="";
			String StencilSN="";
			String PasteSN="";
			if(obj2!=null){
				FrontSqueegeeSN=obj2.get("FrontSqueegeeSN").toString();
				RearSqueegeeSN=obj2.get("RearSqueegeeSN").toString();
				StencilSN=obj2.get("StencilSN").toString();
				PasteSN=obj2.get("PasteSN").toString();
			}
			int code = 200;
			String returnmessage = "";
			if(!baseDao.checkIf("Stencil","nvl(st_usestatus,'') = '出库' and st_code = '"+FrontSqueegeeSN+"'"))
			{
				code = 222;
				returnmessage = returnmessage + "刮刀:"+FrontSqueegeeSN+"未领用出库,校验失败.\n";
			}
			if(!baseDao.checkIf("Stencil","nvl(st_usestatus,'') = '出库' and st_code = '"+RearSqueegeeSN+"'"))
			{
				code = 222;
				returnmessage = returnmessage + "刮刀:"+RearSqueegeeSN+"未领用出库,校验失败.\n";
			}
			if(!baseDao.checkIf("Stencil","nvl(st_usestatus,'') = '出库' and st_code = '"+StencilSN+"'"))
			{
				code = 222;
				returnmessage = returnmessage + "钢网:"+StencilSN+"未清洗出库,校验失败.\n";
			}
			/*if(!baseDao.checkIf("SPMBARCODE","nvl(SPB_STATUS,'') = '已开封' and SPB_BARCODE = '"+PasteSN+"'"))
			{
				code = 222;
				returnmessage = returnmessage + "锡膏:"+PasteSN+"未领用,校验失败.\n";
			}*/

			if(returnmessage == null || returnmessage.isEmpty()){
				SqlRowList startLine=baseDao.queryForRowSet("SELECT su_linecode, su_usemacode, su_useprodcode FROM( SELECT * FROM stenciluse WHERE su_stcode = ? AND su_status = '领用' ORDER BY su_usedate DESC) WHERE ROWNUM = 1", StencilSN);
				String wo = "";
				String partNo = "";
				String suLine = "";
				if(startLine.next()){
					wo = startLine.getString("su_usemacode");
					partNo = startLine.getString("su_useprodcode");
					suLine = startLine.getString("su_linecode");

					SqlRowList rs=baseDao.queryForRowSet("SELECT st_id FROM stencil WHERE st_kind = '钢网' AND st_code = ?", StencilSN);
					if(rs.next()){
						baseDao.execute("insert into stenciluse(su_id, su_useman, su_stcode, su_stid, su_status, su_linecode, su_usemacode,su_useprodcode)" +
								"values(stenciluse_seq.nextval,'"+MachineSN+"','"+StencilSN+"','"+rs.getString("st_id")+"','上线','"+suLine+"','"+wo+"','"+partNo+"')");

						baseDao.updateByCondition("stencil", "st_line = '"+suLine+"'", "st_code='" + StencilSN + "'");
					}

					SqlRowList rs1=baseDao.queryForRowSet("SELECT st_id FROM stencil WHERE st_kind = '刮刀' AND st_code = ?", FrontSqueegeeSN);
					if(rs1.next()){
						baseDao.execute("insert into stenciluse(su_id, su_useman, su_stcode, su_stid, su_status, su_linecode,su_usemacode,su_useprodcode)" +
								"values(stenciluse_seq.nextval,'"+MachineSN+"','"+FrontSqueegeeSN+"','"+rs1.getString("st_id")+"','上线','"+suLine+"','"+wo+"','"+partNo+"')");

						baseDao.updateByCondition("stencil", "st_line = '"+suLine+"'", "st_code='" + StencilSN + "'");
					}

					SqlRowList rs2=baseDao.queryForRowSet("SELECT st_id FROM stencil WHERE st_kind = '刮刀' AND st_code = ?", RearSqueegeeSN);
					if(rs2.next()){
						baseDao.execute("insert into stenciluse(su_id, su_useman, su_stcode, su_stid, su_status, su_linecode,su_usemacode,su_useprodcode)" +
								"values(stenciluse_seq.nextval,'"+MachineSN+"','"+RearSqueegeeSN+"','"+rs2.getString("st_id")+"','上线','"+suLine+"','"+wo+"','"+partNo+"')");

						baseDao.updateByCondition("stencil", "st_line = '"+suLine+"'", "st_code='" + StencilSN + "'");
					}

					baseDao.updateByCondition("spmbarcode", "spb_status = '上线',spb_update_time = sysdate,spb_use_count = spb_use_count,SPB_LINECODE = '"+suLine+"'", "spb_barcode='" + PasteSN + "'");
					SqlRowList rs3 = baseDao.queryForRowSet("SELECT spmlog_seq.NEXTVAL seq FROM dual");
					Map<Object, Object> paramsMap = new HashMap<Object, Object>();
					if (rs3.next()) {
						paramsMap.put("spl_id", rs3.getString("seq"));
						paramsMap.put("spl_operation", "上线");
						paramsMap.put("spl_operator", MachineSN);
						paramsMap.put("spl_barcode", PasteSN);
//						paramsMap.put("spl_user_count", "spl_user_count");
						paramsMap.put("spl_linecode", suLine);
						paramsMap.put("spl_equipment", MachineType);
						paramsMap.put("spl_sysname", MachineSN);
						paramsMap.put("spl_makecode", wo);
						baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap,"spmlog"));
					}
				}
			}

			Map<Object, Object> rmap1 = new HashMap<Object, Object>();
			rmap1.put("Command","MaterialVerify");
			rmap1.put("SessionID",SessionID);
			rmap1.put("TimeStamp",TimeStamp);
			rmap1.put("Direction","Response");
			rmap.put("Header",rmap1);

			Map<Object, Object> rmap2 = new HashMap<Object, Object>();
			rmap2.put("Code",code);
			rmap2.put("Message",returnmessage);
			rmap.put("Body",rmap2);
		}
		return rmap;
	}

	@Override
	public String  UploadSteel(String SteelMeshCode,String scraperCode, String SteelMeshCount, String scraperCount, String datatime) {
		String err = CheckSteel(SteelMeshCode);
		//判断钢网编号
		if(SteelMeshCode!=null&&!"".equals(SteelMeshCode)){
			baseDao.execute("insert into devicetestinfo(DTI_ID, DTI_SNCODE,DTI_TESTQTY, DTI_MACHINETYPE, DTI_TYPE, DTI_TIME, DTI_SOURCECONTENT)values(devicetestinfo_seq.nextval,'"+scraperCode+"','"+scraperCount+"','钢网','钢网',to_date('"+datatime+"','yyyy-mm-dd hh24:mi:ss'),'')");
			baseDao.execute("update stencil set  st_usecount=nvl(st_usecount,0)+"+scraperCount +" where st_code='"+SteelMeshCode+"'");
		}
		//判断刮刀编号
		if(scraperCode!=null&&!"".equals(scraperCode)){
			baseDao.execute("insert into devicetestinfo(DTI_ID, DTI_SNCODE,DTI_TESTQTY, DTI_MACHINETYPE, DTI_TYPE, DTI_TIME, DTI_SOURCECONTENT)values(devicetestinfo_seq.nextval,'"+scraperCode+"','"+scraperCount+"','刮刀','刮刀',to_date('"+datatime+"','yyyy-mm-dd hh24:mi:ss'),'')");
			baseDao.execute("update stencil set  st_usecount=nvl(st_usecount,0)+"+scraperCount +" where st_code='"+scraperCode+"'");
		}
		return err;
	}

	@Override
	public String CheckSteel(String SteelMeshCode) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		SqlRowList rs=baseDao.queryForRowSet("select st_kind,nvl(st_usecount,0)st_usecount,nvl(st_maxusecount,0)st_maxusecount from stencil where st_code='"+SteelMeshCode+"'");
		if(rs.next()){
			String st_usecount=rs.getString("st_usecount");
			String st_maxusecount=rs.getString("st_maxusecount");
			String st_kind=rs.getString("st_kind");
			if(Integer.parseInt(st_usecount)>=Integer.parseInt(st_maxusecount)){
				return rs.getString("st_kind")+"已使用"+st_usecount+",超出最大使用次数"+st_maxusecount;
			}
		}else{
			return "编号不存在";
		}
		return "";
	}

	@Override
	public Map<Object,Object> SetupResultDataInterface(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();

		JSONObject object = JSONObject.fromObject(data);
		Object object1 = object.get("data");
		JSONObject obj = JSONObject.fromObject(object1);
		JSONObject SetupResultDetail=obj.getJSONObject("SetupResultDetail");
		if(SetupResultDetail!=null){
			String ActionType=SetupResultDetail.get("ActionType").toString();
			String MessageSendTime=Time(SetupResultDetail.getString("MessageSendTime"));
			String LineName=SetupResultDetail.get("LineName").toString();
			String SetupName=SetupResultDetail.get("SetupName").toString();
			String MachineName=SetupResultDetail.get("MachineName").toString();
			String OrderNumber=SetupResultDetail.get("OrderNumber").toString();
			String DockingStationID=SetupResultDetail.get("DockingStationID").toString();
			String Operator=SetupResultDetail.get("Operator").toString();
			String TableLocation=SetupResultDetail.get("TableLocation").toString();
			String TableId=SetupResultDetail.get("TableId").toString();
			String Track=SetupResultDetail.get("Track").toString();
			String FeederTypeName=SetupResultDetail.get("FeederTypeName").toString();
			String FeederID=SetupResultDetail.get("FeederID").toString();
			JSONObject PackagingUnitDetail=SetupResultDetail.getJSONObject("PackagingUnit");
			if(PackagingUnitDetail!=null){
				String PUID=PackagingUnitDetail.getString("PUID");
				String ComponentBarcode=PackagingUnitDetail.getString("ComponentBarcode");
				String ComponentBarcodeFragment=PackagingUnitDetail.getString("ComponentBarcodeFragment");
				String OriginalQuantity=PackagingUnitDetail.getString("OriginalQuantity");
				String Quantity=PackagingUnitDetail.getString("Quantity");
				String CreateDate=Time(PackagingUnitDetail.getString("CreateDate"));
				String DateCode=PackagingUnitDetail.getString("DateCode");
				String BatchId=PackagingUnitDetail.getString("BatchId");
				String MsdLevel=PackagingUnitDetail.getString("MsdLevel");
				JSONObject LockInfoList=null;
				try{
					LockInfoList=PackagingUnitDetail.getJSONObject("LockInfoList");
				}catch (Exception e){

				}
				JSONObject SplicedPackagingUnitList=null;
				try{
					SplicedPackagingUnitList=PackagingUnitDetail.getJSONObject("SplicedPackagingUnitList");
				}catch (Exception e){

				}
				String smt_line="";
				if(LineName.equals("Line1")){
					smt_line="贴片L1线";
				}
				if(LineName.equals("Line2")){
					smt_line="贴片L2线";
				}
				if(LineName.equals("Line3")||LineName.equals("L3")){
					smt_line="贴片L3线";
				}
				if(LineName.equals("Line4")||LineName.equals("L4")){
					smt_line="贴片L4线";
				}
				if(LineName.equals("Line5")){
					smt_line="贴片L5线";
				}
				if(LineName.equals("Line6")){
					smt_line="贴片L6线";
				}
				Object makecode=baseDao.getFieldDataByCondition("Line","li_makecode","li_code='"+smt_line+"'");
				int sr_id=baseDao.getSeqId("SETUPRESULTDETAIL_seq");
				baseDao.execute("insert into SETUPRESULTDETAIL(sr_id,ACTIONTYPE,LINENAME,SetupName,ORDERNUMBER,MACHINENAME," +
						"TABLEID,DOCKINGSTATIONID,OPERATOR,TableLocation,FeederTypeName,FeederID,MessageSendTime)values('"+sr_id+"'," +
						"'"+ActionType+"','"+LineName+"','"+SetupName+"','"+OrderNumber+"','"+MachineName+"','"+TableId+"','"+DockingStationID+"'," +
						"'"+Operator+"','"+TableLocation+"','"+FeederTypeName+"','"+FeederID+"',to_date('"+MessageSendTime+"','yyyy-mm-dd hh24:mi:ss'))");
				int pu_id=baseDao.getSeqId("PACKAGINGUNIT_seq");
				baseDao.execute("insert into PACKAGINGUNIT(PU_ID,PUID,PU_SRID,ComponentBarcodeFragment,ComponentBarcode,OriginalQuantity,Quantity,CreateDate," +
						"DateCode,BatchId,MsdLevel,makecode)values('"+pu_id+"','"+PUID+"','"+sr_id+"','"+ComponentBarcodeFragment+"','"+ComponentBarcode+"','"+OriginalQuantity+"','"+Quantity+"',to_date('"+CreateDate+"','yyyy-mm-dd hh24:mi:ss')," +
						"'"+DateCode+"','"+BatchId+"','"+MsdLevel+"','"+makecode+"')");
				if(LockInfoList!=null){
					JSONArray LockInfoItem=LockInfoList.getJSONArray("LockInfoItem");
					for(int i=0;i<LockInfoItem.size();i++){
						JSONObject map=LockInfoItem.getJSONObject(i);
						String Date=Time(map.getString("Date"));
						String Message=map.getString("Message");
						String Reason=map.getString("Reason");
						String Source=map.getString("Source");
						baseDao.execute("insert into LOCKINFOLIST(LF_ID,lf_puid,INDATE,MESSAGE,REASON,SOURCE)" +
								"values(LOCKINFOLIST_seq.nextval,'"+pu_id+"',to_date('"+Date+"','yyyy-mm-dd hh24:mi:ss'),'"+Message+"'," +
								"'"+Reason+"','"+Source+"')");
					}
				}
				if(SplicedPackagingUnitList!=null){
					JSONArray SplicedPackagingUnitItem=SplicedPackagingUnitList.getJSONArray("SplicedPackagingUnitItem");
					for(int i=0;i<SplicedPackagingUnitItem.size();i++){
						JSONObject map=SplicedPackagingUnitItem.getJSONObject(i);
						String UID1=map.getString("PUID");
						String ComponentBarcode1=map.getString("ComponentBarcode");
						String ComponentName=map.getString("ComponentName");
						String OriginalQuantity1=map.getString("OriginalQuantity");
						String Quantity1=map.getString("Quantity");
						String ManufacturePartNumber=map.getString("ManufacturePartNumber");
						String Manufacturer=map.getString("Manufacturer");
						String Supplier=map.getString("Supplier");
						baseDao.execute("insert into SPLICEDPACKAGING (SP_ID,SP_PUID,PUID,COMPONENTBARCODE,ORIGINALQUANTITY,QUANTITY)" +
								"values(SPLICEDPACKAGING_seq.nextval,'"+pu_id+"','"+UID1+"','"+ComponentBarcode1+"','"+OriginalQuantity1+"','"+Quantity1+"')");
					}
				}
			}
			rmap.put("code","0");
			rmap.put("result","OK");
			rmap.put("ServerMessage","MES:贴片机数据记录成功");
		}
		return rmap;
	}

	@Override
	public Map<Object,Object> StateEventDetail(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		JSONObject object = JSONObject.fromObject(data);
		Object object1 = object.get("data");
		JSONObject obj = JSONObject.fromObject(object1);
		JSONObject StateEventDetail=obj.getJSONObject("StateEventDetail");
		if(StateEventDetail!=null){
			int st_id=baseDao.getSeqId("StateEventDetail_seq");
			String MessageSendTime=Time(StateEventDetail.getString("MessageSendTime"));
			String CompletionStatusType=StateEventDetail.getString("CompletionStatusType");
			String LineFullPath=StateEventDetail.getString("LineFullPath");
			String LineName=StateEventDetail.getString("LineName");
			String MachineFullPath=StateEventDetail.getString("MachineFullPath");
			String MachineName=StateEventDetail.getString("MachineName");
			String JobFullPath=StateEventDetail.getString("JobFullPath");
			String JobName=StateEventDetail.getString("JobName");
			String RecipeFullPath=StateEventDetail.getString("RecipeFullPath");
			String RecipeName=StateEventDetail.getString("RecipeName");
			String SetupFullPath=StateEventDetail.getString("SetupFullPath");
			String SetupName=StateEventDetail.getString("SetupName");
			String BoardFullPath=StateEventDetail.getString("BoardFullPath");
			String BoardName=StateEventDetail.getString("BoardName");
			String OrderNumber=StateEventDetail.getString("OrderNumber");
			String ConveyorMode=StateEventDetail.getString("ConveyorMode");
			String DownloadMode=StateEventDetail.getString("DownloadMode");
			String FactoryLayoutPath=StateEventDetail.getString("FactoryLayoutPath");
			String MachineId=StateEventDetail.getString("MachineId");
			String MachineType=StateEventDetail.getString("MachineType");
			String TypeName=StateEventDetail.getString("TypeName");
			String ProcessingAreaCount=StateEventDetail.getString("ProcessingAreaCount");
			String StationSoftwareVersion=StateEventDetail.getString("StationSoftwareVersion");
			String MonitoringServiceVersion=StateEventDetail.getString("MonitoringServiceVersion");
			String ComputerAddress=StateEventDetail.getString("ComputerAddress");
			baseDao.execute("insert into StateEventDetail(ST_ID, MESSAGESENDTIME, COMPLETIONSTATUSTYPE, LINEFULLPATH, LINENAME, MACHINEFULLPATH, MACHINENAME, JOBFULLPATH, JOBNAME, RECIPEFULLPATH, RECIPENAME, SETUPFULLPATH, SETUPNAME, BOARDFULLPATH, BOARDNAME, ORDERNUMBER, CONVEYORMODE, DOWNLOADMODE, FACTORYLAYOUTPATH, MACHINEID, MACHINETYPE, TYPENAME, PROCESSINGAREACOUNT, STATIONSOFTWAREVERSION, MONITORINGSERVICEVERSION, COMPUTERADDRESS)" +
					"values("+st_id+", to_date('"+MessageSendTime+"','yyyy-mm-dd hh24:mi:ss'), '"+CompletionStatusType+"', '"+LineFullPath+"', '"+LineName+"', '"+MachineFullPath+"', '"+MachineName+"', '"+JobFullPath+"', '"+JobName+"', '"+RecipeFullPath+"', '"+RecipeName+"', '"+SetupFullPath+"', '"+SetupName+"', '"+BoardFullPath+"', '"+BoardName+"', '"+OrderNumber+"', '"+ConveyorMode+"', '"+DownloadMode+"', '"+FactoryLayoutPath+"', '"+MachineId+"', '"+MachineType+"', '"+TypeName+"', '"+ProcessingAreaCount+"', '"+StationSoftwareVersion+"', '"+MonitoringServiceVersion+"', '"+ComputerAddress+"')");
			JSONArray ProcessingAreaStateList=StateEventDetail.getJSONArray("ProcessingAreaStateList");
			for (int i=0;i<ProcessingAreaStateList.size();i++){
				JSONObject map1=ProcessingAreaStateList.getJSONObject(i);
				String ProcessingArea=map1.getString("ProcessingArea");
				String Conveyor=map1.getString("Conveyor");
				String CurrentStateBegin=map1.getString("CurrentStateBegin");
				String CurrentStateCode=map1.getString("CurrentStateCode");
				String CurrentStateDescription=map1.getString("CurrentStateDescription");
				String PreviousStateCode=map1.getString("PreviousStateCode");
				String PreviousStateDescription=map1.getString("PreviousStateDescription");
				baseDao.execute("insert into ProcessingAreaStateList(RAS_ID, RAS_STID, PROCESSINGAREA, CONVEYOR, CURRENTSTATEBEGIN, CURRENTSTATECODE, CURRENTSTATEDESCRIPTION, PREVIOUSSTATECODE, PREVIOUSSTATEDESCRIPTION)" +
						"values(ProcessingAreaStateList_seq.nextval,'"+st_id+"','"+ProcessingArea+"','"+Conveyor+"','"+CurrentStateBegin+"'," +
						"'"+CurrentStateCode+"','"+CurrentStateDescription+"','"+PreviousStateCode+"','"+PreviousStateDescription+"')");
			}
		}
		rmap.put("code","0");
		rmap.put("result","OK");
		rmap.put("ServerMessage","MES:贴片机数据记录成功");
		return rmap;
	}

	@Override
	public Map<Object,Object> SendPlaceData(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		JSONObject object = JSONObject.fromObject(data);
		Object object1 = object.get("data");
		JSONObject obj = JSONObject.fromObject(object1);
		JSONObject PlacedDataDetail=obj.getJSONObject("PlacedDataDetail");
		if(PlacedDataDetail!=null){
			int pd_id=baseDao.getSeqId("PlacedDataDetail_seq");
			String MESSAGESENDTIME=Time(PlacedDataDetail.getString("MessageSendTime"));
			String COMPLETIONSTATUSTYPE=PlacedDataDetail.getString("CompletionStatusType");
			String LINEFULLPATH=PlacedDataDetail.getString("LineFullPath");
			String MACHINEFULLPATH=PlacedDataDetail.getString("MachineFullPath");
			String RECIPEFULLPATH=PlacedDataDetail.getString("RecipeFullPath");
			String RECIPENAME=PlacedDataDetail.getString("RecipeName");
			String SETUPFULLPATH=PlacedDataDetail.getString("SetupName");
			String BOARDFULLPATH=PlacedDataDetail.getString("BoardFullPath");
			String FACTORYLAYOUTPATH=PlacedDataDetail.getString("FactoryLayoutPath");
			String MACHINEID=PlacedDataDetail.getString("MachineId");
			String MACHINETYPE=PlacedDataDetail.getString("MachineType");
			String STATIONSOFTWAREVERSION=PlacedDataDetail.getString("StationSoftwareVersion");
			String MONITORINGSERVICEVERSION=PlacedDataDetail.getString("MonitoringServiceVersion");
			String COMPUTERADDRESS=PlacedDataDetail.getString("ComputerAddress");
			baseDao.execute("insert into PlacedDataDetail(pd_id,MessageSendTime,CompletionStatusType,LineFullPath,MachineFullPath,RecipeFullPath," +
					"RecipeName,SETUPFULLPATH,BoardFullPath,FactoryLayoutPath,MachineId,MachineType,StationSoftwareVersion,MonitoringServiceVersion," +
					"ComputerAddress)values('"+pd_id+"',to_date('"+MESSAGESENDTIME+"','yyyy-mm-dd hh24:mi:ss'),'"+COMPLETIONSTATUSTYPE+"'," +
					"'"+LINEFULLPATH+"','"+MACHINEFULLPATH+"','"+RECIPEFULLPATH+"','"+RECIPENAME+"','"+SETUPFULLPATH+"','"+BOARDFULLPATH+"'," +
					"'"+FACTORYLAYOUTPATH+"','"+MACHINEID+"','"+MACHINETYPE+"','"+STATIONSOFTWAREVERSION+"','"+MONITORINGSERVICEVERSION+"','"+COMPUTERADDRESS+"')");
			JSONArray PanelList=PlacedDataDetail.getJSONArray("PlacedComponentList");
			for (int i=0;i<PanelList.size();i++){
				JSONObject map1=PanelList.getJSONObject(i);
				String TABLELOCATION =map1.getString("TableLocation");
				String TRACK=map1.getString("Track");
				String DIVISION=map1.getString("Division");
				String COMPONENTFULLPATH=map1.getString("ComponentFullPath");
				String COMPONENTNAME=map1.getString("ComponentName");
				String COMPONENTSHAPEFULLPATH=map1.getString("ComponentShapeFullPath");
				String FEEDERCATEGORY=map1.getString("FeederCategory");
				String FEEDERTYPENAME=map1.getString("FeederTypeName");
				String FEEDERID=map1.getString("FeederID");
				String ACCESSTOTAL=map1.getString("AccessTotal");
				String PlacedComponents=map1.getString("PlacedComponents");
				String REJECTQTY=map1.getString("RejectQty");
				String REJECTIDENT=map1.getString("RejectIdent");
				String REJECTVACUUM=map1.getString("RejectVacuum");
				String TRACKEMPTY=map1.getString("TrackEmpty");
				String IDENTERRROR=map1.getString("IdentErrror");
				String MATERIALDEFECT=map1.getString("MaterialDefect");
				String ABSENCEAFTERPICK=map1.getString("AbsenceAfterPick");
				String ABSENCEBEFOREPLACEMENT=map1.getString("AbsenceBeforePlacement");
				String TREATMENTERROR=map1.getString("TreatmentError");
				baseDao.execute("insert into PlacedComponentList(pc_id,pc_pdid,TABLELOCATION,TRACK,DIVISION,COMPONENTFULLPATH," +
						"COMPONENTNAME,COMPONENTSHAPEFULLPATH,FEEDERCATEGORY,FEEDERTYPENAME,FEEDERID,ACCESSTOTAL,PlacedComponents," +
						"REJECTQTY,REJECTIDENT,REJECTVACUUM,TRACKEMPTY,IDENTERRROR,MATERIALDEFECT,ABSENCEAFTERPICK,ABSENCEBEFOREPLACEMENT,TREATMENTERROR)" +
						"values(PlacedComponentList_seq.nextval,'"+pd_id+"','"+TABLELOCATION+"','"+TRACK+"','"+DIVISION+"','"+COMPONENTFULLPATH+"'" +
						",'"+COMPONENTNAME+"','"+COMPONENTSHAPEFULLPATH+"','"+FEEDERCATEGORY+"','"+FEEDERTYPENAME+"','"+FEEDERID+"'," +
						"'"+ACCESSTOTAL+"','"+PlacedComponents+"','"+REJECTQTY+"','"+REJECTIDENT+"','"+REJECTVACUUM+"','"+TRACKEMPTY+"'," +
						"'"+IDENTERRROR+"','"+MATERIALDEFECT+"','"+ABSENCEAFTERPICK+"','"+ABSENCEBEFOREPLACEMENT+"','"+TREATMENTERROR+"')");
			}
			JSONArray PickupErrorList=PlacedDataDetail.getJSONArray("PickupErrorList");
			for (int i=0;i<PickupErrorList.size();i++){
				JSONObject map1=PickupErrorList.getJSONObject(i);
				String GANTRY=map1.getString("Gantry");
				String HEAD=map1.getString("Head");
				String SEGMENT1=map1.getString("Segment");
				String NOZZLE=map1.getString("Nozzle");
				String TABLELOCATION=map1.getString("TableLocation");
				String TRACK=map1.getString("Track");
				String DIVISION=map1.getString("Division");
				String TOWER=map1.getString("Tower");
				String LEVEL1=map1.getString("Level");
				String COMPONENTFULLPATH=map1.getString("ComponentFullPath");
				String COMPONENTNAME=map1.getString("ComponentName");
				String COMPONENTSHAPEFULLPATH=map1.getString("ComponentShapeFullPath");
				String COMPONENTSHAPENAME=map1.getString("ComponentShapeName");
				String FEEDERCATEGORY=map1.getString("FeederCategory");
				String FEEDERTYPENAME=map1.getString("FeederTypeName");
				String FEEDERID=map1.getString("FeederID");
				String ERRORTYPE=map1.getString("ErrorType");
				String ERRORDESCRIPTION=map1.getString("ErrorDescription");
				baseDao.execute("insert into PickupErrorList(pe_id,pe_pdid,Gantry,Head,SEGMENT1,NOZZLE,TABLELOCATION,TRACK,DIVISION,TOWER" +
						",LEVEL1,COMPONENTFULLPATH,COMPONENTNAME,COMPONENTSHAPEFULLPATH,COMPONENTSHAPENAME,FEEDERCATEGORY,FEEDERTYPENAME," +
						"FEEDERID,ERRORTYPE,ERRORDESCRIPTION)values(PickupErrorList_seq.nextval,'"+pd_id+"','"+GANTRY+"','"+HEAD+"','"+SEGMENT1+"','"+NOZZLE+"'," +
						"'"+TABLELOCATION+"','"+TRACK+"','"+DIVISION+"','"+TOWER+"','"+LEVEL1+"','"+COMPONENTFULLPATH+"','"+COMPONENTNAME+"'," +
						"'"+COMPONENTSHAPEFULLPATH+"','"+COMPONENTSHAPENAME+"','"+FEEDERCATEGORY+"','"+FEEDERTYPENAME+"','"+FEEDERID+"','"+ERRORTYPE+"'," +
						"'"+ERRORDESCRIPTION+"')");
			}
		}
		rmap.put("code","0");
		rmap.put("result","OK");
		rmap.put("ServerMessage","MES:贴片机数据记录成功");
		return  rmap;
	}

	@Override
	public Map<Object,Object> TraceabilityDataInterface(String data) {
		Integer td_id=baseDao.getSeqId("TRACEDATA_seq");
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		JSONObject object = JSONObject.fromObject(data);
		Object object1 = object.get("data");
		JSONObject obj = JSONObject.fromObject(object1);
		JSONObject TraceabilityDataDetail=obj.getJSONObject("TraceabilityDataDetail");
		if(TraceabilityDataDetail!=null){
			String DateBegin=Time(TraceabilityDataDetail.get("DateBegin").toString());
			String DateCompleted=Time(TraceabilityDataDetail.get("DateCompleted").toString());
			String LineName=TraceabilityDataDetail.get("LineName").toString();
			String MachineName=TraceabilityDataDetail.get("MachineName").toString();
			String BoardName=TraceabilityDataDetail.get("BoardName").toString();
			String MachineID=TraceabilityDataDetail.get("MachineID").toString();
			String BoardSide=TraceabilityDataDetail.get("BoardSide").toString();
			String OrderNumber=TraceabilityDataDetail.get("OrderNumber").toString();
			String PCBBarcode=TraceabilityDataDetail.get("PCBBarcode").toString();
			baseDao.execute("insert into TRACEDATA(TD_ID,DateBegin,DateCompleted,LineName,MachineName,BoardName,MachineID,BoardSide,OrderNumber,PCBBarcode,TD_INDATE)" +
					"values("+td_id+",to_date('"+DateBegin+"','yyyy-mm-dd hh24:mi:ss'),to_date('"+DateCompleted+"','yyyy-mm-dd hh24:mi:ss')," +
					"'"+LineName+"','"+MachineName+"','"+BoardName+"','"+MachineID+"','"+BoardSide+"','"+OrderNumber+"','"+PCBBarcode+"',sysdate)");

			JSONObject MaterialTraceabilityDetail=null;
			try{
				MaterialTraceabilityDetail=TraceabilityDataDetail.getJSONObject("MaterialTraceabilityDetail");
			}catch (Exception e){

			}
			JSONObject MaterialConsumptionDetail=null;
			try{
				MaterialConsumptionDetail=TraceabilityDataDetail.getJSONObject("MaterialConsumptionDetail");
			}catch (Exception e){

			}
			//上料信息
			if(MaterialTraceabilityDetail!=null){
				JSONArray PanelList=MaterialTraceabilityDetail.getJSONArray("PanelList");
				for (int i=0;i<PanelList.size();i++){
					JSONObject map=PanelList.getJSONObject(i);
					String PanelName=map.get("PanelName").toString();
					JSONArray PackagingUnitRefList=map.getJSONArray("PackagingUnitRefList");
					System.out.println(PackagingUnitRefList.size());
					if(PackagingUnitRefList!=null){
						for (int j=0;j<PackagingUnitRefList.size();j++){
							String PlaceRefID="";
							JSONObject map1=PackagingUnitRefList.getJSONObject(j);
							String PUID=map1.getString("PUID");
							String TableLocation=map1.getString("TableLocation");
							String Track=map1.getString("Track");
							String ComponentBarcode=map1.getString("ComponentBarcode");
							String OriginalQuantity=map1.getString("OriginalQuantity");
							String Quantity=map1.getString("Quantity");
							String CreateDate=Time(map1.getString("CreateDate"));
							String DateCode=map1.getString("DateCode");
							String Batch2=map1.getString("Batch2");
							String MsdLevel=map1.getString("MsdLevel");
							String VerifiedDate=Time(map1.getString("VerifiedDate"));
							String Operator=map1.getString("Operator");
							JSONArray PlaceRefList=map1.getJSONArray("PlaceRefList");
							if(PlaceRefList!=null){
								for (int k=0;k<PlaceRefList.size();k++){
									JSONObject map2=PlaceRefList.getJSONObject(k);
									PlaceRefID+=map2.getString("PlaceRefID")+",";
								}
							}
							baseDao.execute("insert into MATERIALTRACE(MT_ID,MT_TDID,PANELNAME,PUID,PlaceRefList,TableLocation,Track,ComponentBarcode,OriginalQuantity,Quantity,CreateDate,DateCode,Batch2,MsdLevel,VerifiedDate,Operator)" +
									"values(MATERIALTRACE_seq.nextval,'"+td_id+"','"+PanelName+"','"+PUID+"','"+PlaceRefID+"','"+TableLocation+"','"+Track+"','"+ComponentBarcode+"','"+OriginalQuantity+"','"+Quantity+"',to_date('"+CreateDate+"','yyyy-mm-dd hh24:mi:ss'),'"+DateCode+"','"+Batch2+"'," +
									"'"+MsdLevel+"',to_date('"+CreateDate+"','yyyy-mm-dd hh24:mi:ss'),'"+Operator+"')");
						}
					}
				}
			}
			//扣料信息
			if(MaterialConsumptionDetail!=null){
				JSONArray ConsumedPackagingUnitList=MaterialConsumptionDetail.getJSONArray("ConsumedPackagingUnitList");
				for (int i=0;i<ConsumedPackagingUnitList.size();i++){
					JSONObject map1=ConsumedPackagingUnitList.getJSONObject(i);
					String PUID=map1.getString("PUID");
					String AccessTotal=map1.getString("AccessTotal");
					String RejectIdent=map1.getString("RejectIdent");
					String RejectVacuum=map1.getString("RejectVacuum");
					String TrackEmpty=map1.getString("TrackEmpty");
					baseDao.execute("insert into CONSUMEDPACKAGING(cp_id,cp_tdid,puid,AccessTotal,RejectIdent,RejectVacuum" +
							",TrackEmpty) values(CONSUMEDPACKAGING_seq.nextval,'"+td_id+"','"+PUID+"','"+AccessTotal+"','"+RejectIdent+"','"+RejectVacuum+"'," +
							"'"+TrackEmpty+"')");
				}
			}
			rmap.put("code","0");
			rmap.put("result","OK");
			rmap.put("ServerMessage","MES:贴片机数据记录成功");
		}
		return rmap;
	}

	public Map<Object,Object> XrayTestDataSave(String data){
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		Map<String, Object> map=null;
		JSONObject object = JSONObject.fromObject(data);
		Object object1 = object.get("data");
		JSONObject obj = JSONObject.fromObject(object1);
		JSONArray object2=obj.getJSONArray("NonconformData");

		Object Barcode=obj.get("Barcode");
		Object EquipmentEncode=obj.get("EquipmentEncode");
		Object ModelType=obj.get("ModelType");
		Object CheckNumber=obj.get("CheckNumber");
		Object NcmNumber=obj.get("NcmNumber");
		Object NonconformNumber=obj.get("NonconformNumber");
		Object CheckDate=obj.get("CheckDate");
		Object ShiftName=obj.get("ShiftName");
		Object LineBody=obj.get("LineBody");
		Object Inspector=obj.get("Inspector");
		int XT_ID = baseDao.getSeqId("xraytest_seq");
		baseDao.execute("insert into xraytest(XT_ID, BARCODE, EQUIPMENTENCODE, MODELTYPE, CHECKNUMBER, NCMNUMBER, NONCONFORMNUMBER, CHECKDATE, SHIFTNAME, LINEBODY, INSPECTOR)" +
				"values("+XT_ID+",'"+Barcode+"','"+EquipmentEncode+"','"+ModelType+"','"+CheckNumber+"','"+NcmNumber+"','"+NonconformNumber+"',to_date('"+CheckDate+"','yyyy-mm-dd hh24:mi:ss')" +
				",'"+ShiftName+"','"+LineBody+"','"+Inspector+"')");
		for (int i=0;i<object2.size();i++){
			JSONObject map1=object2.getJSONObject(i);
			String NonconformANo=map1.getString("NonconformANo");
			String NonconformDescription=map1.getString("NonconformDescription");
			baseDao.execute("insert into XrayTestdetail(xtd_xtid,xtd_id,NONCONFORMANO, NONCONFORMDESCRIPTION)" +
					"values("+XT_ID+",XrayTestdetail_seq.nextval,'"+NonconformANo+"','"+NonconformDescription+"')");
		}
		rmap.put("code","0");
		rmap.put("result","OK");
		rmap.put("ServerMessage","MES:检查数据上传成功！");
		return rmap;
	}

	public String Time(String time){
		return time.replaceAll("T"," ").substring(0,19);
	}

	@Override
	public Map<Object,Object> Weigh(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String oErrMessage="";
		String lotSN="";
		String specificationName="";
		String weight="";
		String moName="";
		String workcenterName="";
		Map<String, Object> map=null;
		try{
			map =BaseUtil.convertJsonToMap(data);
		}catch (Exception e){
			System.out.printf(e.getMessage()) ;
		}
		if(map.get("lotSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		if(map.get("lotSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		if(map.get("specificationName")==null){
			oErrMessage = "工序不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		if(map.get("weight")==null){
			oErrMessage = "重量不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		lotSN=map.get("lotSN").toString();
		SqlRowList rs=baseDao.queryForRowSet("select ms_sncode from  makeserial where ms_imei1='"+lotSN+"' or ms_imei2='"+lotSN+"' or ms_imei3='"+lotSN+"' or ms_imei4='"+lotSN+"'");
		if(rs.next()){
			lotSN=rs.getString("ms_sncode");
		}else{
			 rs=baseDao.queryForRowSet("select mil_sncode from  makeimeilist where mil_imei1='"+lotSN+"' or mil_imei2='"+lotSN+"' or mil_imei3='"+lotSN+"' or mil_imei4='"+lotSN+"'");
			if(rs.next()){
				lotSN=rs.getString("mil_sncode");
			}
		}
		specificationName=map.get("specificationName").toString();
		weight=map.get("weight").toString().replaceAll("KG","");
		oErrMessage=CheckRoutePassed(lotSN,specificationName);
		if(oErrMessage!=null){
			rmap.put("code",-1);
			rmap.put("message",oErrMessage);
			Map<String, String> rmap1 = new HashMap<String, String>();
			rmap1.put("minWeight","");
			rmap1.put("maxWeightc","");
			rmap1.put("machineModel","");
			rmap.put("dataInfo",rmap1);
			return rmap;
		}
		Object[] obj = baseDao.getFieldsDataByCondition("makeserial left join product on pr_code=ms_prodcode","pr_colorboxminw,pr_colorboxmaxw","ms_id =(select max(ms_id) from makeserial where ms_sncode='"+lotSN+"')");
		if(obj[0]!=null&&obj[1]!=null){
			//不在设置的重量范围内
			if(Double.parseDouble(weight)<Double.parseDouble(obj[0].toString())||Double.parseDouble(weight)>Double.parseDouble(obj[1].toString())){
				rmap.put("code",-1);
				rmap.put("message","SN["+lotSN+"]重量为"+weight+",不符合重量范围"+obj[0]+"-"+obj[1]);
				Map<String, String> rmap1 = new HashMap<String, String>();
				rmap1.put("minWeight",obj[0].toString());
				rmap1.put("maxWeight",obj[1].toString());
				rmap1.put("machineModel","");
				rmap.put("dataInfo",rmap1);
				return rmap;
			}
			Object oErr=SetPcbaData(lotSN,specificationName,specificationName,"OK");
			if(oErr==null){
				rmap.put("code",0);
				rmap.put("message","SN["+lotSN+"]重量为"+weight+",符合重量范围"+obj[0]+"-"+obj[1]+",称重通过");
				Object ms_id=baseDao.getFieldDataByCondition("makeserial","max(ms_id)","ms_sncode='"+lotSN+"'");
				baseDao.execute("update makeserial set ms_grossw ='"+weight+"' where ms_id="+ms_id);
			}else{
				rmap.put("code",-1);
				rmap.put("message",oErr);
			}
			Map<String, String> rmap1 = new HashMap<String, String>();
			rmap1.put("minWeight",obj[0].toString());
			rmap1.put("maxWeight",obj[1].toString());
			rmap1.put("machineModel","");
			rmap.put("dataInfo",rmap1);
			return rmap;
		}
		return rmap;
	}

	@Override
	public Map<Object,Object> UploadReelInfo(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String oErrMessage="";
		String ReelId="";
		String Quantity="";
		Map<String, Object> map=null;
		try{
			map =BaseUtil.convertJsonToMap(data);
		}catch (Exception e){
			System.out.printf(e.getMessage()) ;
		}
		if(map.get("ReelId")==null){
			rmap.put("Status","NG");
			rmap.put("Meassage","料盘ID不能为空");
			return rmap;
		}
		if(map.get("Quantity")==null){
			rmap.put("Status","NG");
			rmap.put("Meassage","数量不能为空");
			return rmap;
		}
		ReelId=map.get("ReelId").toString();
		Quantity=map.get("Quantity").toString();
		SqlRowList rs=baseDao.queryForRowSet("select bar_id,bar_prodcode,bar_remain,pr_spec,to_char(nvl(bar_madedate,sysdate),'yyyy-mm-dd')bar_madedate,bar_vendcode,bar_vendbarcode,pr_detail,bar_ordercode from barcode left join product on bar_prodcode = pr_code where bar_code=?",ReelId);
		if(rs.next()){
			/*baseDao.execute("update barcode@ERP_JMDZ_HF set bar_remain=?,bar_status = 2 where bar_id=?",Quantity,rs.getString("bar_id"));
			baseDao.execute("insert into barcodechange@ERP_JMDZ_HF(BC_ID,BC_INDATE, BC_REASON, BC_QTY, BC_BARCODE,  BC_PRODCODE, BC_NEWQTY)" +
					"values(barcodechange_seq.nextval@ERP_JMDZ_HF,sysdate,'点料机更新条码数量',?,?,?,?)",rs.getString("bar_remain"),ReelId,rs.getString("bar_prodcode"),Quantity);*/
			baseDao.execute("update barcode set bar_remain=?,bar_status = 1,bar_outno = '' where bar_code=?",Quantity,ReelId);
			baseDao.execute("insert into barcodechange(BC_ID,BC_INDATE, BC_REASON, BC_QTY, BC_BARCODE,  BC_PRODCODE, BC_NEWQTY)" +
					"values(barcodechange_seq.nextval,sysdate,'点料机更新条码数量',?,?,?,?)",rs.getString("bar_remain"),ReelId,rs.getString("bar_prodcode"),Quantity);
			rmap.put("Status","OK");
			rmap.put("Meassage","通过");
			rmap.put("PN",rs.getString("bar_prodcode"));
			rmap.put("MPN",rs.getString("pr_spec"));
			rmap.put("DataCode",rs.getString("bar_madedate"));

			rmap.put("VENDCODE",rs.getString("bar_vendcode") != null ? rs.getString("bar_vendcode") : "");
			rmap.put("VENDBARCODE",rs.getString("bar_vendbarcode") != null ? rs.getString("bar_vendbarcode") : "");
			rmap.put("PRDETAIL",rs.getString("pr_detail") != null ? rs.getString("bar_vendbarcode") : "");
			rmap.put("ORDERCODE",rs.getString("bar_ordercode") != null ? rs.getString("bar_ordercode") : "");
		}else {
			rmap.put("Status","NG");
			rmap.put("Meassage","条码不存在");
			return rmap;
		}
		return rmap;
	}

	@Override
	public Map<Object,Object> SendSolderExecuteNode(String data) {
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String SolderCode="",ScanTime ="",Station ="",Node ="";
		String SysName = "",UserName ="";
		Map<String, Object> map=null;
		try{
			map =BaseUtil.convertJsonToMap(data);
		}catch (Exception e){
			System.out.printf(e.getMessage()) ;
		}
		if(map.get("SolderCode")==null){
			rmap.put("Result","NG");
			rmap.put("Meassage","锡膏条码不能为空");
			return rmap;
		}
		if(map.get("ScanTime")==null){
			rmap.put("Result","NG");
			rmap.put("Meassage","扫描时间不能为空");
			return rmap;
		}
		if(map.get("Station")==null){
			rmap.put("Result","NG");
			rmap.put("Meassage","设备编码不能为空");
			return rmap;
		}
		if(map.get("Node")==null){
			rmap.put("Result","NG");
			rmap.put("Meassage","当前节点状态不能为空");
			return rmap;
		}

		SolderCode=map.get("SolderCode").toString();
		ScanTime=Time(map.get("ScanTime").toString());
		Station=map.get("Station").toString();
		Node=map.get("Node").toString();

		UserName=map.get("UserName").toString();
		SysName=map.get("SysName").toString();

		//SqlRowList rs=baseDao.queryForRowSet("select bar_id,bar_prodcode,bar_remain,pr_spec,to_char(nvl(bar_madedate,sysdate),'yyyy-mm-dd')bar_madedate from barcode@ERP_JMDZ_HF left join product on bar_prodcode = pr_code where bar_code=?",SolderCode);
		SqlRowList rs=baseDao.queryForRowSet("SELECT spb_id,nvl(spb_use_count,1) spb_use_count FROM spmbarcode WHERE spb_barcode = ?",SolderCode);
		if(rs.next()){
			String curCount = rs.getString("spb_use_count");
			if(Node.contains("回温开始")){
				int spb_use_count = Integer.parseInt(curCount) + 1;
				baseDao.updateByCondition("spmbarcode", "spb_status = '"+Node+"',spb_update_time = to_date('"+ScanTime+"','yyyy-mm-dd hh24:mi:ss'),spb_use_count = '"+ spb_use_count +"'", "spb_barcode='" + SolderCode + "'");

				baseDao.execute("INSERT INTO spmlog ( spl_id, spl_date, spl_operation, spl_operator, spl_barcode, spl_user_count, spl_equipment,spl_sysname) VALUES ( spmlog_seq.NEXTVAL, TO_DATE(?, 'yyyy-mm-dd hh24:mi:ss'), ?, ?, ?, ?, ?,?)",ScanTime,Node,UserName,SolderCode,spb_use_count,Station,SysName);
				rmap.put("Result","OK");
				rmap.put("Meassage", Node +": 记录成功");
			}else{
				baseDao.updateByCondition("spmbarcode", "spb_status = '"+Node+"',spb_update_time = to_date('"+ScanTime+"','yyyy-mm-dd hh24:mi:ss'),spb_use_count = '"+ curCount +"'", "spb_barcode='" + SolderCode + "'");

				baseDao.execute("INSERT INTO spmlog (spl_id, spl_date, spl_operation, spl_operator, spl_barcode, spl_user_count, spl_equipment,spl_sysname) VALUES ( spmlog_seq.NEXTVAL, TO_DATE(?, 'yyyy-mm-dd hh24:mi:ss'), ?, ?, ?, ?, ?,?)",ScanTime,Node,UserName,SolderCode,curCount,Station,SysName);
				if(Node.contains("领用")){
					baseDao.updateByCondition("spmbarcode", "spb_status = '已开封',spb_update_time = sysdate,spb_use_count = '"+ curCount +"'", "spb_barcode='" + SolderCode + "'");
					baseDao.execute("INSERT INTO spmlog ( spl_id, spl_date, spl_operation, spl_operator, spl_barcode, spl_user_count, spl_equipment,spl_sysname) VALUES ( spmlog_seq.NEXTVAL, TO_DATE(?, 'yyyy-mm-dd hh24:mi:ss'), ?, ?, ?, ?, ?,?)",ScanTime,"已开封",UserName,SolderCode,curCount,Station,SysName);
				}
				rmap.put("Result","OK");
				rmap.put("Meassage",Node +": 记录成功");
			}

		}else {
			rmap.put("Result","NG");
			rmap.put("Meassage","锡膏条码不存在,请先录入锡膏");
			return rmap;
		}
		return rmap;
	}

	@Override
	public Map<Object,Object> StencilInspect(String data){
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		JSONObject jsonObj = JSONObject.fromObject(data);
		String DeviceCode   = jsonObj.optString("DeviceCode", "");
		String MeshCode   = jsonObj.optString("MeshCode", "");
		String InspectTime   = jsonObj.optString("InspectTime", "");
		String InspectMode   = jsonObj.optString("Inspector", "");
		String WorkOrderNo   = jsonObj.optString("WorkOrderNo", "");

		String wo = WorkOrderNo.contains("/") ? WorkOrderNo.split("/")[0] : WorkOrderNo;
		String line = WorkOrderNo.contains("/") ? WorkOrderNo.split("/")[1] : "";

		if(MeshCode ==null){
			rmap.put("Result","NG");
			rmap.put("Meassage","钢网/刮刀编号不能为空");
			return rmap;
		}
		Map<Object, Object> paramsMap = new HashMap<Object, Object>();
		Map<Object, Object> paramsMap1 = new HashMap<Object, Object>();
		try{
			SqlRowList rs=baseDao.queryForRowSet("SELECT st_id,st_line,st_usestatus,st_kind,nvl(st_cleannums, 0) st_cleannums FROM stencil WHERE st_code = ?",MeshCode);
			if(rs.next()){
				String cleannums = rs.getString("st_cleannums");
				String usestatus = rs.getString("st_usestatus");
				String stKind = rs.getString("st_kind");
				SqlRowList rs1=baseDao.queryForRowSet("SELECT stenciluse_seq.NEXTVAL seq FROM dual");
				if(rs1.next()){
					paramsMap.put("su_id",rs1.getString("seq"));
					paramsMap.put("su_stid",rs.getString("st_id"));
					paramsMap.put("su_stcode",MeshCode);
					paramsMap.put("su_linecode",rs.getString("st_line"));
					paramsMap.put("su_usemacode",wo);
					paramsMap.put("su_usedate",InspectTime.replace("/", "-"));
					if(usestatus.contains("在库")){
						paramsMap.put("su_status","领用");
						if(jsonObj.optString("InspectResult", "").contains("NG")){
							rmap.put("Result", "NG");
							rmap.put("Meassage", stKind+"状态: 检测结果" + jsonObj.optString("InspectResult", "") + "不可领用");
							return rmap;
						}
						if(jsonObj.optString("TestResult", "").contains("NG")){
							rmap.put("Result", "NG");
							rmap.put("Meassage", stKind+"状态: 刮刀检测结果" + jsonObj.optString("TestResult", "") + "不可领用");
							return rmap;
						}

						if(line == null && line.isEmpty()){
							rmap.put("Result", "NG");
							rmap.put("Meassage", "领用操作须在工单后加线体名称,如XXX/SMTA");
							return rmap;
						}
						paramsMap.put("su_linecode", line);
						baseDao.updateByCondition("stencil", "st_line = '"+line+"'", "st_code='" + MeshCode + "'");
					}else if(usestatus.contains("出库")){
						paramsMap.put("su_status","归还");
						baseDao.updateByCondition("stencil", "st_line = ''", "st_code='" + MeshCode + "'");
					}

					paramsMap1.put("std_class",InspectMode);
					paramsMap1.put("STD_SUBCLASS1",rs1.getString("seq"));
					paramsMap1.put("STD_SUBCLASS2",stKind);
					paramsMap1.put("STD_DATE",InspectTime.replace("/", "-"));
					paramsMap1.put("STD_VALUE1",DeviceCode);
					paramsMap1.put("STD_VALUE2",jsonObj.optString("action", ""));
					paramsMap1.put("STD_VALUE3",jsonObj.optString("Inspector", ""));

					if(stKind.contains("钢网")){
						paramsMap.put("su_ensiona",jsonObj.optString("Tension1", ""));
						paramsMap.put("su_ensionb",jsonObj.optString("Tension2", ""));
						paramsMap.put("su_ensionc",jsonObj.optString("Tension3", ""));
						paramsMap.put("su_ensiond",jsonObj.optString("Tension4", ""));
						paramsMap.put("su_ensione",jsonObj.optString("Tension5", ""));

						String ensiona = jsonObj.optString("Tension1", "");
						String ensionb = jsonObj.optString("Tension2", "");
						String ensionc = jsonObj.optString("Tension3", "");
						String ensiond = jsonObj.optString("Tension4", "");
						String ensione = jsonObj.optString("Tension5", "");
						baseDao.updateByCondition("stencil", "ST_ENSIONA = '"+ensiona+"',ST_ENSIONB = '"+ensionb+"'," +
								"ST_ENSIONC = '"+ensionc+"',ST_ENSIOND = '"+ensiond+"',ST_ENSIONE = '"+ensione+"'"
								, "st_code='" + MeshCode + "'");

						paramsMap1.put("STD_VALUE4",jsonObj.optString("HoleResult", ""));
						paramsMap1.put("STD_VALUE5",jsonObj.optString("TensionResult", ""));
						paramsMap1.put("STD_VALUE6",jsonObj.optString("InspectResult", ""));
						paramsMap1.put("STD_VALUE7",jsonObj.optString("InspectState", ""));
						paramsMap1.put("STD_VALUE8",jsonObj.optString("SizeErrNum", ""));

						paramsMap1.put("STD_VALUE9",jsonObj.optString("LocationErrNum", ""));
						paramsMap1.put("STD_VALUE10",jsonObj.optString("SurplusNum", ""));
						paramsMap1.put("STD_VALUE11",jsonObj.optString("InsufficientNum", ""));
						paramsMap1.put("STD_VALUE12",jsonObj.optString("AreaErrNum", ""));
						paramsMap1.put("STD_VALUE13",jsonObj.optString("ForeignMatterNum", ""));

						paramsMap1.put("STD_VALUE14",jsonObj.optString("PlugHoleNum", ""));
						paramsMap1.put("STD_VALUE15",jsonObj.optString("OtherErrNum", ""));
						paramsMap1.put("STD_VALUE16",jsonObj.optString("ErrCount", ""));
						paramsMap1.put("STD_VALUE17",jsonObj.optString("HoleCount", ""));
					}else if(stKind.contains("刮刀")){
						paramsMap1.put("STD_VALUE4",jsonObj.optString("TestResult", ""));
						paramsMap1.put("STD_VALUE5",jsonObj.optString("ScrapSegma", ""));
						paramsMap1.put("STD_VALUE6",jsonObj.optString("NlightWay", ""));
						paramsMap1.put("STD_VALUE7",jsonObj.optString("Startpt", ""));
						paramsMap1.put("STD_VALUE8",jsonObj.optString("Stoppt", ""));

						paramsMap1.put("STD_VALUE9",jsonObj.optString("Gaprange", ""));
						paramsMap1.put("STD_VALUE10",jsonObj.optString("MaxGap", ""));
						paramsMap1.put("STD_VALUE11",jsonObj.optString("MinGap", ""));
						paramsMap1.put("STD_VALUE12",jsonObj.optString("ChkSide", ""));
					}
					if(InspectMode.contains("清洗")){
						paramsMap.put("su_cleannums",Integer.parseInt(cleannums) + 1);
						baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap,"stenciluse"));
					}else{
						paramsMap.put("su_cleannums",cleannums);
						baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap,"stenciluse"));
					}
					if(usestatus.contains("在库") ){
						baseDao.updateByCondition("stencil", "st_usestatus = '出库'", "st_code='" + MeshCode + "'");
					}else if(usestatus.contains("出库")){
						baseDao.updateByCondition("stencil", "st_usestatus = '在库'", "st_code='" + MeshCode + "'");
					}
					baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap1,"steptestdetail"));
					rmap.put("Result","OK");
					rmap.put("Meassage",InspectMode +": 记录成功");
				}
			}
		}catch (Exception e){
			rmap.put("Result", "NG");
			rmap.put("Meassage", "系统异常: " + e.getMessage());
		}
		return rmap;
	}

	@Override
	public Map<Object,Object> FirstInspect(String data){
		Map<String, Object> map=null;
		try{
			map =BaseUtil.convertJsonToMap(data);
		}catch (Exception e){
			System.out.printf(e.getMessage()) ;
		}

		baseDao.execute("insert into "+username+".EISDATA(ed_id,ed_data,ed_indate)values("+username+".EISDATA_seq.nextval,?,sysdate)",data);
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		rmap.put("Result", "OK");
		rmap.put("Meassage", "成功");

		return rmap;
	}

	@Override
	public Map<Object,Object> DLLMain(String accessKey, String requestId, String data) {
		String AE_MASTER = "N_MES";
		SpObserver.putSp(AE_MASTER);
		Map<Object, Object> map = BaseUtil.parseFormStoreToMap(data);
		//解析map
		if(!StringUtil.hasText(map.get("type"))){
			throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPENULL,requestId));
		}
		if(!StringUtil.hasText(map.get("detail"))){
			throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_DATAILLEGAL,requestId));
		}
		String type = map.get("type").toString();
		JSONObject json = JSONObject.fromObject(map.get("detail"));
		HelperType helperType = HelperType.getTypeByCode(type);
		if(null == helperType){
			throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPEILLEGAL,requestId));
		}
		baseDao.execute("insert into EISDATA(ed_id,ed_data,ed_indate)values(EISDATA_seq.nextval,?,sysdate)",data);
		int err = 0;
		//返回值
		Map<Object, Object> remap = new HashMap<Object, Object>();
		switch(helperType){
			case CheckRoutePassed:
				remap = CheckRoutePassed(json);
				break;
			case CheckUserAndResourcePassed:
				remap = CheckUserAndResourcePassed(json);
				break;
			case GetAddressRangeByMO:
				remap = GetAddressRangeByMO(json);
				break;
			case GetMEIOrNetCodeRange:
				remap = GetMEIOrNetCodeRange(json);
				break;
			case GetRcardMOInfo:
				remap = GetRcardMOInfo(json);
				break;
			case GetMobileAllInfo:
				remap = GetMobileAllInfo(json);
				break;
			case SetAddressInfo:
				remap = SetAddressInfo(json);
				break;
			case GetMaster:
				remap = GetMaster(json);
				break;
			case SetMobileData:
				remap = SetMobileData(json);
				break;
			case SetIMEIInfo:
				remap = SetIMEIInfo(json);
				break;
			case SetTestDetail:
				remap = SetTestDetail(json);
				break;
			case SetPcbaData:
				remap = SetPcbaData(json);
				break;
			case GetInfoByMaterial:
				remap = GetInfoByMaterial(json);
				break;
			case GoMo:
				remap = GoMo(json);
				break;
			case GetMakeInfoBySN:
				remap = GetMakeInfoBySN(json);
				break;
			default:
				err = -1;
				break;
		}
		if(err == -1){
			throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPEILLEGAL,requestId));
		}
		SpObserver.putSp(username);
		return remap;
	}

	private Map<Object,Object> GoMo(JSONObject map){
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String iSN=null;
		String iResCode=null;
		String iMo=null;
		String oErrMessage=null;
		if(map.get("iMo")==null){
			oErrMessage = "工单号不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		if(map.get("iResCode")==null){
			oErrMessage = "岗位资源不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		iSN=map.get("iSN").toString();
		iResCode=map.get("iResCode").toString();
		iMo=map.get("iMo").toString();
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
				String.valueOf(iMo),
				String.valueOf(iResCode),
				String.valueOf(iSN),
				String.valueOf("")
		}, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
		oErrMessage=list.get(2);

		SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=(  select max(ms_id) from makeserial where ms_sncode  in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' '  union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
		String ms_status = "";
		String ms_stepcode = "";
		String ms_nextstepcode = "";
		if(rs.next()){
			ms_status= rs.getString("ms_status");
			ms_stepcode=rs.getString("ms_stepcode");
			ms_nextstepcode=rs.getString("ms_nextstepcode");
		}
		String stepcode = GetStepCodeBySource(iResCode);
		if ( oErrMessage == null || (ms_status == "3" && ms_stepcode == stepcode))
		{
			if (ms_status == "3")
			{
				oErrMessage =  null;
			}
		}
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private String GoMo(String iSN,String iMo,String iResCode){
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String oErrMessage=null;
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
				String.valueOf(iMo),
				String.valueOf(iResCode),
				String.valueOf(iSN),
				String.valueOf("")
		}, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
		oErrMessage=list.get(2);

		SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=(  select max(ms_id) from makeserial where ms_sncode  in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' '  union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
		String ms_status = "";
		String ms_stepcode = "";
		String ms_nextstepcode = "";
		if(rs.next()){
			ms_status= rs.getString("ms_status");
			ms_stepcode=rs.getString("ms_stepcode");
			ms_nextstepcode=rs.getString("ms_nextstepcode");
		}
		String stepcode = GetStepCodeBySource(iResCode);
		if ( oErrMessage == null || (ms_status == "3" && ms_stepcode == stepcode))
		{
			if (ms_status == "3")
			{
				oErrMessage =  null;
			}
		}
		return oErrMessage;
	}

	private Map<Object,Object> GetInfoByMaterial(JSONObject map){
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String iPCBA=null;
		String oErrMessage=null;
		if(map.get("iPCBA")==null){
			oErrMessage = "主板SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		iPCBA=map.get("iPCBA").toString();
		SqlRowList rs=baseDao.queryForRowSet("select nvl(max(ms_id),0)ms_id from CRAFTMATERIAL left join makeserial on ms_firstsn=cm_firstsn  where cm_barcode='"+iPCBA+"' and nvl(cm_status,0)<>-1 order by cm_id desc");
		if(rs.next()){
			if(!rs.getString("ms_id").equals("0")){
				rs=baseDao.queryForRowSet("select ma_bios,ma_ec,ms_sncode,ma_hardware from makeserial left join make on ms_makecode=ma_code where ms_id='"+rs.getString("ms_id")+"'");
				if (rs.next()){
					rmap.put("oSN",rs.getString("ms_sncode"));
					rmap.put("oBIOS",rs.getString("ma_bios"));
					rmap.put("oEC",rs.getString("ma_ec"));
					rmap.put("oHardWare",rs.getString("ma_hardware"));
				}
			}else{
				oErrMessage = "主板SN未查询到关联信息";
				rmap.put("oErrMessage",oErrMessage);
				return rmap;
			}
		}
		return rmap;
	}

	private Map<Object,Object> CheckRoutePassed(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String iSN=map.get("iSN").toString();
		String iResCode=map.get("iResCode").toString();
		String oErrMessage="";
		if (iSN ==null)
		{
			oErrMessage = "SN不能为空";
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
				String.valueOf(""),
				String.valueOf(iResCode),
				String.valueOf(iSN),
				String.valueOf("")
		}, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
		oErrMessage=list.get(2);
		if(oErrMessage!=null){
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=(  select max(ms_id) from makeserial where ms_sncode  in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' '  union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
		String ms_status = "";
		String ms_stepcode = "";
		String ms_nextstepcode = "";
		if(rs.next()){
			ms_status= rs.getString("ms_status");
			ms_stepcode=rs.getString("ms_stepcode");
			ms_nextstepcode=rs.getString("ms_nextstepcode");
		}
		String stepcode = GetStepCodeBySource(iResCode);
		if (ms_nextstepcode != "" && !ms_nextstepcode.equals(stepcode))
		{
			oErrMessage = "当前序列号下一工序" + ms_nextstepcode;
		}
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private String CheckRoutePassed(String iSN,String iResCode){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage;
		if (iSN ==null)
		{
			oErrMessage = "SN不能为空";
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
				String.valueOf(""),
				String.valueOf(iResCode),
				String.valueOf(iSN),
				String.valueOf("")
		}, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
		oErrMessage=list.get(2);
		if(oErrMessage!=null){
			return oErrMessage;
		}
		SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=(  select max(ms_id) from makeserial where ms_sncode  in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' '  union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
		String ms_status = "";
		String ms_stepcode = "";
		String ms_nextstepcode = "";
		if(rs.next()){
			ms_status= rs.getString("ms_status");
			ms_stepcode=rs.getString("ms_stepcode");
			ms_nextstepcode=rs.getString("ms_nextstepcode");
		}
		String stepcode = GetStepCodeBySource(iResCode);
		if (ms_nextstepcode != "" && !ms_nextstepcode.equals(stepcode))
		{
			oErrMessage = "当前序列号"+iSN+"下一工序" + ms_nextstepcode;
		}
		return oErrMessage;
	}

	private Map<Object,Object> CheckUserAndResourcePassed(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage = null;
		if (map.get("iUserCode") == null || map.get("iResCode") == null || map.get("iPassWord") == null)
		{
			oErrMessage = "用户名,密码,岗位资源必须填写";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		String iUserCode=map.get("iUserCode").toString();
		String iPassWord=map.get("iPassWord").toString();
		String iResCode=map.get("iResCode").toString();
		if (CheckUserLogin(iUserCode, iPassWord))
		{
			String SQL = "select em_code,em_type,em_name from employee where em_code=? ";
			SqlRowList rs = baseDao.queryForRowSet(SQL,  iUserCode);
			if (rs.next())
			{
				String em_name = rs.getString("em_name");
				String em_type = rs.getString("em_type");
				if (iResCode ==null)
				{
					oErrMessage = "岗位资源不允许为空";
					rmap.put("oErrMessage",oErrMessage);
					return rmap;
				}
				if (em_type.equals("admin"))
				{
					if (!baseDao.checkIf("Source", "sc_code='" + iResCode + "' and sc_statuscode='AUDITED'"))
					{
						oErrMessage = "岗位资源编号错误或者未审核！";
					}
				}
				else
				{
					SqlRowList rs1=baseDao.queryForRowSet("select ur_resourcecode from cs$empgroup left join cs$userresource on ur_groupcode=eg_groupcode left join source on ur_resourcecode=sc_code where eg_emcode = '"+ iUserCode + "' and sc_statuscode='AUDITED'");
					//如果存在该编号
					if (rs1.next())
					{
						//判断如果多个岗位资源存在，用户输入的只要在其中就行
						while (rs.next())
						{
							if (!rs.getString("ur_resourcecode").equals("iResCode")){
								oErrMessage = "用户不处于当前资源所属分组!";
							}else
							{
								oErrMessage=null;
								continue;
							}
						}
					}
					else
						oErrMessage = "岗位资源编号错误或者未审核！";
				}
			}
			else
				oErrMessage = "用户不存在!";
		}else{
			oErrMessage = "用户名密码不正确!";
		}
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}
	private Map<Object,Object> GetAddressRangeByMO(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String iSN="";
		String oErrMessage = null;
		String oWIFI = "";
		String oBT = "";
		String oNetCard = "";
		String oCode1 = "";
		String oCode2 = "";
		String oCode3 = "";
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		iSN=map.get("iSN").toString();
		//判断工单是否归属
		JSONObject map3=new JSONObject();
		map3.put("iSN",iSN);
		Map<Object, Object> map2=GetRcardMOInfo(map3);
		if(map2.get("oErrMessage")!=null){
			oErrMessage=map2.get("oErrMessage").toString();
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_GETADDRESSBYMAKECODE_FIMEI", new Object[]{
				String.valueOf(iSN),
				String.valueOf(map2.get("oMoCode").toString()),
		}, new Integer[]{1,2}, new Integer[]{3,4,5,6,7,8,9});
		oWIFI = list.get(0);
		oBT =  list.get(1);
		oNetCard =  list.get(2);
		oCode1 =  list.get(3);
		oCode2 = list.get(4);
		oCode3 =  list.get(5);
		oErrMessage= list.get(6);
		if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
			rmap.put("oWIFI",oWIFI);
			rmap.put("oBT",oBT);
			rmap.put("oNetCard",oNetCard);
			rmap.put("oCode1",oCode1);
			rmap.put("oCode2",oCode2);
			rmap.put("oCode3",oCode3);
			rmap.put("oErrMessage",oErrMessage);
		}
		else
			rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private Map<Object,Object> GetMEIOrNetCodeRange(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String iSN="";
		String oErrMessage = null;
		String oIMEI1 = "";
		String oIMEI2 = "";
		String oIMEI3 = "";
		String oIMEI4 = "";
		String oMEID = "";
		String oNetCode = "";
		String oPSN = "";
		String oID1 = "";
		String oID2 = "";
		String oID3 = "";
		String oID4 = "";
		String oID5 = "";
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		if(map.get("iIMEI1")!=null){
			oIMEI1=map.get("iIMEI1").toString();
		}
		if(map.get("iNetCode")!=null){
			oNetCode=map.get("iNetCode").toString();
		}
		iSN=map.get("iSN").toString();
		Object MAC_IMEI=baseDao.getFieldDataByCondition("makeaddresslist", "mal_imei", "mal_sncode='" + iSN + "'");
		if(MAC_IMEI!=null){
			oIMEI1=MAC_IMEI.toString();
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_GETIMEIORNETCODERANGE_FIMEI", new Object[]{
				String.valueOf(iSN),
				String.valueOf(""),
				String.valueOf(oIMEI1),
				String.valueOf(oNetCode),
		}, new Integer[]{1,2,3,4}, new Integer[]{5,6,7,8,9,10,11,12,13,14,15});
		oIMEI1 = list.get(0);
		oIMEI2 =  list.get(1);
		oIMEI3 =  list.get(2);
		oIMEI4 =  list.get(3);
		oMEID =  list.get(4);
		oNetCode = list.get(5);
		oPSN =  list.get(6);
		oID1 =  list.get(7);
		oID2 =  list.get(8);
		oID3 =  list.get(9);
		oErrMessage= list.get(10);
		if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
			rmap.put("oIMEI1",oIMEI1);
			rmap.put("oIMEI2",oIMEI2);
			rmap.put("oIMEI3",oIMEI3);
			rmap.put("oIMEI4",oIMEI4);
			rmap.put("oMEID",oMEID);
			rmap.put("oNetCode",oNetCode);
			rmap.put("oPSN",oPSN);
			rmap.put("oID1",oID1);
			rmap.put("oID2",oID2);
			rmap.put("oID3",oID3);
			rmap.put("oErrMessage",oErrMessage);
		}
		else
			rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private Map<Object,Object> GetRcardMOInfo(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		//取MakeProcess表中的执行记录ID最大的一个工单的号码
		String oErrMessage = null;
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		String iSN=map.get("iSN").toString();
		StringBuffer sql=new StringBuffer();
		sql.append("select max(ms_id)ms_id from makeserial where ms_sncode in (select '" + iSN + "' from dual union select sn from ");
		sql.append("makesnrelation where beforesn='" + iSN + "' and sn<>' '  union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' ')");
		SqlRowList rs = baseDao.queryForRowSet(sql.toString());
		String ms_id="";
		if(rs.next()){
			if(rs.getString("ms_id")==null){
				oErrMessage = "序列号:" + iSN + " 未归属工单";
				rmap.put("oErrMessage",oErrMessage);
				return rmap;
			}
			else{
				ms_id= rs.getString("ms_id");
			}
		}
		Object oMoCode = baseDao.getFieldDataByCondition("MakeSerial", "ms_makecode", "ms_id='" + ms_id + "'");
		if (oMoCode != null){
			rmap.put("oMoCode",oMoCode);
			oErrMessage= null;
		}
		else
		{
			oErrMessage = "序列号:" + iSN + " 未归属工单";
		}
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}



	private Map<Object,Object> GetMobileAllInfo(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String iSN="";
		String oErrMessage = null;
		String oIMEI1 = "";
		String oIMEI2 = "";
		String oIMEI3 = "";
		String oIMEI4 = "";
		String oMEID = "";
		String oNetCode = "";
		String oNetCard = "";
		String oPSN = "";
		String oID1 = "";
		String oID2 = "";
		String oID3 = "";
		String oID4 = "";
		String oID5 = "";
		String oWIFI = "";
		String oBT = "";
		String oCode1 = "";
		String oCode2 = "";
		String oCode3 = "";
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		iSN=map.get("iSN").toString();
		Object ms_id =baseDao.getFieldDataByCondition("makeserial", "max(ms_id)", "ms_sncode='" + iSN + "'");
		if(ms_id!=null)
		{
			SqlRowList rs=baseDao.queryForRowSet("select ms_imei4,ms_id, ms_mac, ms_bt, ms_meid, ms_netcode, ms_psn, ms_imei1, ms_imei2, ms_imei3, ms_othcode1, ms_othcode2, ms_othcode3, ms_othid1, ms_othid2, ms_othid3,ms_netcard from MakeSerial where ms_id="+ms_id.toString());
			if(rs.next()){
				oWIFI = rs.getString("ms_mac");
				oBT = rs.getString("ms_bt");
				oPSN = rs.getString("ms_psn");
				oNetCode = rs.getString("ms_netcode");
				oNetCard = rs.getString("ms_netcard");
				oMEID = rs.getString("ms_meid");
				oIMEI1 = rs.getString("ms_imei1");
				oIMEI2 = rs.getString("ms_imei2");
				oIMEI3 = rs.getString("ms_imei3");
				oIMEI4 = rs.getString("ms_imei4");
				oCode1 = rs.getString("ms_othcode1");
				oCode2 = rs.getString("ms_othcode2");
				oCode3 = rs.getString("ms_othcode3");
				oID1 = rs.getString("ms_othid1");
				oID2 = rs.getString("ms_othid2");
				oID3 = rs.getString("ms_othid3");

			}
		}else
		{
			oErrMessage = "序列号" + iSN + "不存在";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
			rmap.put("oIMEI1",oIMEI1);
			rmap.put("oIMEI2",oIMEI2);
			rmap.put("oIMEI3",oIMEI3);
			rmap.put("oIMEI4",oIMEI4);
			rmap.put("oMEID",oMEID);
			rmap.put("oNetCode",oNetCode);
			rmap.put("oNetCard",oNetCard);
			rmap.put("oPSN",oPSN);
			rmap.put("oID1",oID1);
			rmap.put("oID2",oID2);
			rmap.put("oID3",oID3);
			rmap.put("oID4",oID4);
			rmap.put("oID5",oID5);
			rmap.put("oWIFI",oWIFI);
			rmap.put("oBT",oBT);
			rmap.put("oCode1",oCode1);
			rmap.put("oCode2",oCode2);
			rmap.put("oCode3",oCode3);
			rmap.put("oErrMessage","");
		}
		else
			rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private Map<Object,Object> SetAddressInfo(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage = null;
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		String iSN=map.get("iSN").toString();
		String iWIFI = null;
		String iBT = null;
		String iCode1 = null;
		String iCode2 = null;
		String iCode3 = null;
		String iNetCard=null;
		if(map.get("iWIFI")!=null){
			iWIFI=map.get("iWIFI").toString();
		}
		if(map.get("iMAC")!=null){
			iWIFI=map.get("iMAC").toString();
		}
		if(map.get("iBT")!=null){
			iBT=map.get("iBT").toString();
		}
		if(map.get("iCode1")!=null){
			iCode1=map.get("iCode1").toString();
		}
		if(map.get("iNetCard")!=null){
			iNetCard=map.get("iNetCard").toString();
		}
		if(map.get("iCode2")!=null){
			iCode2=map.get("iCode2").toString();
		}
		if(map.get("iCode3")!=null){
			iCode3=map.get("iCode3").toString();
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_SETADDRESSINFO_FIMEI", new Object[]{
				String.valueOf(iSN),
				String.valueOf(iWIFI),
				String.valueOf(iBT),
				String.valueOf(iNetCard),
				String.valueOf(iCode1),
				String.valueOf(iCode2),
				String.valueOf(iCode3)
		}, new Integer[]{1, 2, 3, 4, 5, 6,7}, new Integer[]{8});
		oErrMessage = list.get(0);
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private Map<Object,Object> GetMaster(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		SqlRowList rs=baseDao.queryForRowSet("select ma_user from mes.master");
		while(rs.next())
		{
			rmap.put(rs.getString("ma_user"),rs.getString("ma_user"));
		}
		return rmap;
	}

	private Map<Object,Object> SetMobileData(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage = null;
		if(map.get("iSN")==null||map.get("iTSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		String iSN=map.get("iSN").toString();
		String iTSN=map.get("iTSN").toString();
		String iSourceCode = null;
		String iOperater = null;
		String iResult = null;
		String flag = null;
		String iErrCode = null;
		if(map.get("iSourceCode")!=null){
			iSourceCode=map.get("iSourceCode").toString();
		}
		if(map.get("iOperater")!=null){
			iOperater=map.get("iOperater").toString();
		}
		if(map.get("iResult")!=null){
			iResult=map.get("iResult").toString();
		}
		if(map.get("flag")!=null){
			flag=map.get("flag").toString();
		}
		if(map.get("iErrCode")!=null){
			iErrCode=map.get("iErrCode").toString();
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_DLLSNCHANGE", new Object[]{
				String.valueOf(iTSN),
				String.valueOf(iSN),
				String.valueOf(iSourceCode),
				String.valueOf(iOperater),
				String.valueOf(iResult),
				String.valueOf(iErrCode),
		}, new Integer[]{1, 2, 3, 4, 5, 6}, new Integer[]{7});
		oErrMessage = list.get(0);
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}
	private Map<Object,Object> SetIMEIInfo(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage = null;
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		String iSN=map.get("iSN").toString();
		String iIMEI1=null;
		String iIMEI2 = null;
		String iIMEI3 = null;
		String iIMEI4 = null;
		String iMEID = null;
		String iPSN = null;
		String iNET = null;
		String iID1 = null;
		String iID2 = null;
		String iID3 = null;
		if(map.get("iPSN")!=null){
			iPSN=map.get("iPSN").toString();
		}
		if(map.get("iIMEI1")!=null){
			iIMEI1=map.get("iIMEI1").toString();
		}
		if(map.get("iIMEI2")!=null){
			iIMEI2=map.get("iIMEI2").toString();
		}
		if(map.get("iIMEI3")!=null){
			iIMEI3=map.get("iIMEI3").toString();
		}
		if(map.get("iIMEI4")!=null){
			iIMEI4=map.get("iIMEI4").toString();
		}
		if(map.get("iMEID")!=null){
			iMEID=map.get("iMEID").toString();
		}
		if(map.get("iNET")!=null){
			iNET=map.get("iNET").toString();
		}
		if(map.get("iID1")!=null){
			iID1=map.get("iID1").toString();
		}
		if(map.get("iID2")!=null){
			iID2=map.get("iID2").toString();
		}
		if(map.get("iID3")!=null){
			iID3=map.get("iID3").toString();
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_SETIMEIINFO_FIMEI", new Object[]{
				String.valueOf(iSN),
				String.valueOf(iIMEI1),
				String.valueOf(iIMEI2),
				String.valueOf(iIMEI3),
				String.valueOf(iIMEI4),
				String.valueOf(iMEID),
				String.valueOf(iNET),
				String.valueOf(iPSN),
				String.valueOf(iID1),
				String.valueOf(iID2),
				String.valueOf(iID3),
		}, new Integer[]{1, 2, 3, 4, 5, 6,7,8,9,10,11}, new Integer[]{12});
		oErrMessage = list.get(0);
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}
	private Map<Object,Object> SetTestDetail(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage=null;
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		String iSN=map.get("iSN").toString();
		String iTestResult= "";
		String iResCode= "";
		String iClassName="";
		String iTestDetail= "";
		if(map.get("iTestResult")!=null){
			iTestResult=map.get("iTestResult").toString();
		}
		if(map.get("iClassName")!=null){
			iClassName=map.get("iClassName").toString();
		}
		if(map.get("iResCode")!=null){
			iResCode=map.get("iResCode").toString();
		}
		if(map.get("iTestDetail")!=null){
			iTestDetail=map.get("iTestDetail").toString();
		}
		JSONObject map3=new JSONObject();
		map3.put("iSN",iSN);
		Map<Object, Object> map2=GetRcardMOInfo(map3);
		String omakeCode = "";
		StringBuffer sql=new StringBuffer();
		String[] name=iClassName.split("\\|");
		String[] result=iTestResult.split("\\|");
		String[] value=iTestDetail.split("\\|");
		if(name.length!=value.length||name.length!=result.length){
			rmap.put("oErrMessage","测试项目名称和值的项次不一致");
			return rmap;
		}
		for (int i=0;i<name.length;i++){
			sql.setLength(0);
			sql.append("Insert into STEPTESTDETAIL (STD_ID,STD_CLASS,STD_SN,STD_MAKECODE,STD_ACTUALVALUE,STD_TESTRESULT,STD_INDATE,STD_RESCODE)");
			sql.append("values(STEPTESTDETAIL_SEQ.nextval,'"+name[i]+"','" + iSN + "','" + map2.get("oMoCode") + "','" + value[i] + "','" + result[i] + "',sysdate,'" + iResCode + "')");
			baseDao.execute(sql.toString());
		}
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private Map<Object,Object> SetPcbaData(JSONObject map){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage = null;
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		String iSN=map.get("iSN").toString();
		String iResCode = null;
		String iOperator = null;
		String iResult = null;
		String iErrCode = null;
		if(map.get("iResCode")!=null){
			iResCode=map.get("iResCode").toString();
		}
		if(map.get("iOperator")!=null){
			iOperator=map.get("iOperator").toString();
		}
		if(map.get("iResult")!=null){
			iResult=map.get("iResult").toString();
		}
		if(map.get("iErrCode")!=null){
			iErrCode=map.get("iErrCode").toString();
		}
		JSONObject map3=new JSONObject();
		map3.put("iSN",iSN);
		Map<Object, Object> map2=GetRcardMOInfo(map3);
		String oMoCode=null;
		if(map2.get("oMoCode")!=null){
			oMoCode=map2.get("oMoCode").toString();
		}
		if (map2.get("oErrMessage")==null)
			return SetStepFinish(oMoCode, iResCode, iSN, "", iResult, iOperator, iErrCode);
		return rmap;
	}

	private Object SetPcbaData(String iSN,String iResCode,String iOperator,String iResult){
		//实际业务数据
		Map<Object, Object> rmap = new HashMap<>();
		String iErrCode = null;
		if(iSN==null){
			iErrCode = "SN不能为空";
			return iErrCode;
		}
		JSONObject map3=new JSONObject();
		map3.put("iSN",iSN);
		Map<Object, Object> map2=GetRcardMOInfo(map3);
		String oMoCode=null;
		if(map2.get("oMoCode")!=null){
			oMoCode=map2.get("oMoCode").toString();
		}
		if (map2.get("oErrMessage")==null)
			map2= SetStepFinish(oMoCode, iResCode, iSN, "", iResult, iResCode, iErrCode);
		return map2.get("oErrMessage");
	}

	/// <summary>
	/// 获取步骤代码
	/// </summary>
	/// <param name="Source"></param>
	/// <returns></returns>
	private String GetStepCodeBySource(String Source)
	{
		Object o=baseDao.getFieldDataByCondition("source", "sc_stepcode", "sc_code='" + Source + "'");
		if(o!=null)
			return o.toString();
		else
			return "";
	}

	private Boolean CheckUserLogin(String iUserCode, String iPassWord)
	{
		SqlRowList rs =baseDao.queryForRowSet("select em_code from employee where em_code='"+iUserCode+"' and em_password =?",iPassWord);
		if (rs.next())
			return true;
		else
		{
			return false;
		}
	}

	private Map<Object,Object> GetMakeInfoBySN(JSONObject map)
	{
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String iSN=null;
		String oErrMessage=null;
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		iSN=map.get("iSN").toString();
		SqlRowList rs=baseDao.queryForRowSet("select ma_remark1,ma_remark2,ma_remark3,ma_remark4,ma_remark5,ma_remark6,ma_remark7,ma_remark8,ma_remark9,ma_remark10,ma_remark11,ma_remark12,ma_remark13,ma_remark14,ma_remark15,ma_remark16 from  make  " +
				"left join makeserial on ms_makecode=ma_code  where ms_sncode='"+iSN+"'");
		if(rs.next()){
			rmap.put("oMaremark1",rs.getString("ma_remark1"));
			rmap.put("oMaremark2",rs.getString("ma_remark2"));
			rmap.put("oMaremark3",rs.getString("ma_remark3"));
			rmap.put("oMaremark4",rs.getString("ma_remark4"));
			rmap.put("oMaremark5",rs.getString("ma_remark5"));
			rmap.put("oMaremark6",rs.getString("ma_remark6"));
			rmap.put("oMaremark7",rs.getString("ma_remark7"));
			rmap.put("oMaremark8",rs.getString("ma_remark8"));
			rmap.put("oMaremark9",rs.getString("ma_remark9"));
			rmap.put("oMaremark10",rs.getString("ma_remark10"));
			rmap.put("oMaremark11",rs.getString("ma_remark11"));
			rmap.put("oMaremark12",rs.getString("ma_remark12"));
			rmap.put("oMaremark13",rs.getString("ma_remark13"));
			rmap.put("oMaremark14",rs.getString("ma_remark14"));
			rmap.put("oMaremark15",rs.getString("ma_remark15"));
			rmap.put("oMaremark16",rs.getString("ma_remark16"));
			return rmap;
		}else{
			oErrMessage = "SN未查询到关联信息";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
	}

	public Map<Object,Object> SetStepFinish(String iMakeCode, String iSourceCode, String iSN, String iMPKind, String iResult, String iUserCode, String iErrCode)
	{
		String oErrMessage = null;
		Object StepCode = baseDao.getFieldDataByCondition("Makeserial", "ms_stepcode", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
		String CurrentStep = GetStepCodeBySource(iSourceCode);
		Object BgCode = baseDao.getFieldDataByCondition("step", "nvl(st_badgroupcode,' ')", "st_code='" + CurrentStep + "'");
		Map<Object, Object> rmap = new HashMap<>();
		switch (iResult)
		{
			case "OK":
				break;
			case "NG":
				if (iErrCode == "")
				{
					oErrMessage = "测试结果为NG时必须传递不良代码";
					rmap.put("oErrMessage",oErrMessage);
					return rmap;
				}
				else
				{
					baseDao.updateByCondition("makebad", "mb_status=-1", "mb_sncode='" + iSN + "' and mb_makecode='" + iMakeCode + "' and mb_stepcode='" + CurrentStep + "' and mb_status=0");
					String[] BadCode = iErrCode.split(",");
					StringBuffer sql=new StringBuffer();
					for (int i = 0; i < BadCode.length; i++)
					{
						if(!baseDao.checkIf("badcode","bc_code='"+ BadCode[i]+"'")){
							oErrMessage = "不良代码"+BadCode[i]+"不存在";
							rmap.put("oErrMessage",oErrMessage);
							return rmap;
						}
						int mb_id = baseDao.getSeqId("makebad_seq");
						sql.setLength(0);
						sql.append("insert into makebad(mb_id,mb_makecode,mb_mscode,mb_sncode,mb_inman,mb_indate,mb_stepcode");
						sql.append(",mb_sourcecode,mb_badcode,mb_badtable,mb_bgcode,mb_soncode,mb_status) select '" + mb_id + "'");
						sql.append(",ma_code,ms_code,ms_sncode,'" + iUserCode + "',sysdate,'" + CurrentStep + "','" + iSourceCode + "','" + BadCode[i] + "','',");
						sql.append("'" + BgCode + "',sp_soncode,'0' from make left join makeSerial on ms_makecode=ma_code left join stepProduct on ");
						sql.append("sp_mothercode=ma_prodcode and sp_stepcode=ms_nextstepcode where ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
						baseDao.execute(sql.toString());
					}
					//将不良的序列号的状态码设为3
					baseDao.execute("update makeserial set ms_status='3' where ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
				}
				break;
			default:
				oErrMessage = "测试结果必须为NG或者OK";
				rmap.put("oErrMessage",oErrMessage);
				return rmap;
		}
		//不良采集为良品是更新
		if (StepCode!=null &&StepCode.toString().equals(CurrentStep) && iResult == "OK")
		{
			Object[] ob = baseDao.getFieldsDataByCondition("makeserial", "ms_status,ms_craftcode,ms_prodcode", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
			if (ob!=null)
			{
				String ms_status =ob[0].toString();
				String ms_craftcode= ob[1].toString();
				String ms_prodcode = ob[2].toString();
				if (ms_status == "3")
				{
					String nextstepcode =baseDao.getFieldDataByCondition("craft left join craftdetail on cr_id=cd_crid ", "cd_nextstepcode", "cr_code='" + ms_craftcode + "' and cr_prodcode='" + ms_prodcode + "' and cd_stepcode='" + CurrentStep + "'").toString();
					baseDao.updateByCondition("makeserial", "ms_status=1,ms_nextstepcode='" + nextstepcode + "'", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
					baseDao.updateByCondition("makebad", "mb_status=-1", "mb_sncode='" + iSN + "' and mb_makecode='" + iMakeCode + "'");
				}
			}
		}
		return CS_SetFinish(iMakeCode, iSourceCode, iSN, iUserCode, iResult);
	}

	private Map<Object,Object> CS_SetFinish(String iMakeCode, String iSourceCode, String iSN, String iUserCode, String iResult)
	{
		Map<Object, Object> rmap = new HashMap<>();
		String oErrMessage=null;
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_SETSTEPRESULT", new Object[]{
				String.valueOf(iMakeCode),
				String.valueOf(iSourceCode),
				String.valueOf(iSN),
				String.valueOf(iUserCode),
				String.valueOf(iResult),
		}, new Integer[]{1, 2, 3, 4, 5}, new Integer[]{6});
		oErrMessage = list.get(0);
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}



	@Override
	public Map<Object,Object> getMESSnCode(String data) {
		Map<String, Object> map=null;
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		try{
			map =BaseUtil.convertJsonToMap(data);
		}catch (Exception e){
			rmap.put("code",-1);
			rmap.put("message",e.getMessage());
			System.out.printf(e.getMessage()) ;
			return rmap;
		}
		String macode = map.get("moid") == null ? "" : String.valueOf(map.get("moid"));
		if("".equals(macode)){
			rmap.put("code",-1);
			rmap.put("message","工单不能为空");
			return rmap;
		}
		if (!baseDao.checkIf("make","ma_code='"+macode+"'")){
			rmap.put("code",-1);
			rmap.put("message","工单【"+macode+"】不存在");
			return rmap;
		}
		if (baseDao.checkIf("make","nvl(ma_statuscode,' ')<>'STARTED' and ma_code='"+macode+"'")){
			rmap.put("code",-1);
			rmap.put("message","工单不是已下放状态");
			return rmap;
		}
		if (!baseDao.checkIf("MakeSnList","msl_makecode='"+macode+"'")){
			rmap.put("code",-1);
			rmap.put("message","工单未维护SN");
			return rmap;
		}
		double sncount = map.get("count") == null ? 0 : Double.parseDouble(map.get("count").toString());
		if(sncount<=0){
			rmap.put("code",-1);
			rmap.put("message","SN数量必须大于0");
			return rmap;
		}
		int count = baseDao.getCountByCondition("MakeSnList", "msl_makecode='" + macode + "' and nvl(msl_status,0)=0");
		if (count<sncount){
			rmap.put("code",-1);
			rmap.put("message","SN不足！");
			return rmap;
		}
		List<String> sqls = new ArrayList<>();
		List<Map<String, Object>> maps = new ArrayList<>();
		Map<String, Object> snmap=null;
		SqlRowList rs = baseDao.queryForRowSet("select msl_sncode,msl_id from (select msl_sncode,msl_id from MakeSnList where msl_makecode='" + macode + "' and nvl(msl_status,0)=0 order by msl_sncode) where rownum<="+sncount +"  order by msl_sncode ");
		String mainbarcode="";
		String msl_id="";
		while (rs.next()){
			snmap=new HashMap<String, Object>();
			snmap.put("serialNo",rs.getGeneralString("msl_sncode"));
			mainbarcode=rs.getGeneralString("msl_sncode");
			maps.add(snmap);
			sqls.add("update MakeSnList set msl_signtime=sysdate,msl_status=-1 where msl_id="+rs.getGeneralInt("msl_id"));
			msl_id+=rs.getGeneralInt("msl_id")+",";
		}
		msl_id+="0";
		baseDao.execute("update MakeSnList set msl_mainbarcode='"+mainbarcode+"' where msl_id in ("+msl_id+")");

		if (sqls!=null&&sqls.size()>0){
			baseDao.execute(sqls);
		}
		rmap.put("code",0);
		rmap.put("data",maps);
		return rmap;
	}

}