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 net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import net.sf.json.JsonConfig;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import sun.awt.TimedWindowEvent;

import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
public class MESHelperServiceImpl implements MESHelperService {

	@Autowired
	private BaseDao baseDao;

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

	@Override
	public Map<Object,Object> DLLMain(String accessKey, String requestId, String data) {
		String AE_MASTER = checkAccessKey(accessKey, requestId);
		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));
		}
		int err = 0;
		//返回值
		Map<Object, Object> remap = new HashMap<Object, Object>();
		switch(helperType){
			case CheckRoutePassed:
				remap = CheckRoutePassed(json);
				break;
			case GetSnRelation:
				remap = GetSnRelation(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 SetIMEIInfo_NEW:
				remap = SetIMEIInfo_NEW(json);
				break;
			case SetTestDetail:
				remap = SetTestDetail(json);
				break;
			case GetMaterialInfo:
				remap = GetMaterialInfo(json);
				break;
			case SetPcbaData:
				remap = SetPcbaData(json);
				break;
			case SetPcbaData_NG:
				remap = SetPcbaData_NG(json);
				break;
			case GetInfoByMaterial:
				remap = GetInfoByMaterial(json);
				break;
			case GoMo:
				remap = GoMo(json);
				break;
			case GetMakeInfoBySN:
				remap = GetMakeInfoBySN(json);
				break;
			case SnList:
				remap = SnList(json);
				break;
			case GetOutBoxCode:
				remap = GetOutBoxCode(json);
				break;
			case ReSetSN:
				remap = ReSetSN(json);
				break;
			case UpdateMakeStatus:
				remap = UpdateMakeStatus(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> UpdateMakeStatus(JSONObject map){
		String oErrMessage=null;
		Map<Object, Object> relist = new HashMap<Object, Object>();
		if(map.get("iMakeCode")==null){
			oErrMessage = "工单号不能为空";
			relist.put("oErrMessage",oErrMessage);
			return relist;
		}
		baseDao.execute("insert into messagelog(ML_ID, ML_DATE, ML_CONTENT, ML_RESULT, CODE)" +
				"values(messagelog_seq.nextval,sysdate,'工单结案','工单结案成功','"+map.get("iMakeCode")+"')");
		baseDao.execute("update make set ma_status='已结案',ma_statuscode='FINISH' where ma_code='"+map.get("iMakeCode")+"'");
		relist.put("oStatus","Success");
		return relist;
	}

	private Map<Object, Object> ReSetSN(JSONObject map){
		String oErrMessage=null;
		Map<Object, Object> relist = new HashMap<Object, Object>();
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			relist.put("oErrMessage",oErrMessage);
			return relist;
		}
		String iSN=map.get("iSN").toString();
		Object obj=baseDao.getFieldDataByCondition("makeserial","ms_sncode","ms_sncode='"+iSN+"'");
		if(obj==null){
			relist.put("oStatus","Pass");
			return relist;
		}
		SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_outboxcode,ms_craftcode,nvl(ms_iostatus,0)ms_iostatus,ms_firstsn,ms_id,ms_makecode,ms_prodcode 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<>' '))");
		if(rs.next()){
			String ms_id=rs.getString("ms_id");
			String ms_outboxcode=rs.getString("ms_outboxcode");
			String ms_makecode=rs.getString("ms_makecode");
			String ms_firstsn=rs.getString("ms_firstsn");
			String ms_prodcode=rs.getString("ms_prodcode");
			String ms_craftcode=rs.getString("ms_craftcode");
			String ms_iostatus=rs.getString("ms_iostatus");
			if(ms_iostatus.equals("-1")){
				oErrMessage = "SN已经入库，不允许操作";
				relist.put("oErrMessage",oErrMessage);
				relist.put("oStatus","Fail");
				return relist;
			}
			Object stepcode=baseDao.getFieldDataByCondition("craftdetail left join craft on cr_id=cd_crid","cd_stepcode","CD_STEPNO=(select min (CD_STEPNO) from craft left join craftdetail on cr_id=cd_crid where cr_prodcode='"+ms_prodcode+"' and cr_code='"+ms_craftcode+"') and cr_code='"+ms_craftcode+"' and cr_prodcode='"+ms_prodcode+"'");
			baseDao.execute("update craftmaterial set cm_status=-1 where cm_sncode='"+ms_firstsn+"' and cm_makecode='"+ms_makecode+"'");
			baseDao.execute("update makeserial set ms_outboxcode='',ms_nextstepcode='"+stepcode+"',ms_status=1 where ms_id='"+ms_id+"'");
			baseDao.execute("delete from packagedetail where pd_makecode='"+ms_makecode+"' and pd_barcode='"+iSN+"'");
			baseDao.execute("update package set PA_PACKAGEQTY=PA_PACKAGEQTY-1, PA_TOTALQTY=PA_TOTALQTY-1, PA_CURRENTQTY=PA_CURRENTQTY-1 where pa_outboxcode='"+ms_outboxcode+"'");
			relist.put("oStatus","Pass");
			return relist;
		}
		return relist;
	}


	private Map<Object, Object> GetOutBoxCode(JSONObject map){
		Map<Object, Object> relist = new HashMap<Object, Object>();
		String Caller=null;
		String iMakeCode=null;
		String iProdCode=null;
		String iUserCode=null;
		String oErrMessage=null;
		String oBox=null;
		if(map.get("iCaller")==null){
			oErrMessage = "Caller不能为空";
			relist.put("oErrMessage",oErrMessage);
			return relist;
		}
		if(map.get("iMakeCode")==null){
			oErrMessage = "工单号不能为空";
			relist.put("oErrMessage",oErrMessage);
			return relist;
		}
		Caller=map.get("iCaller").toString();
		iMakeCode=map.get("iMakeCode").toString();
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("SP_GETPACKORPALLETCODE", new Object[]{
				String.valueOf(Caller),
				String.valueOf(iMakeCode),
				String.valueOf(iProdCode),
				String.valueOf(iUserCode)
		}, new Integer[]{1, 2, 3, 4}, new Integer[]{5});
		oBox=list.get(0);
		relist.put("oBoxCode",oBox);
		return relist;
	}

	private Map<Object, Object> SnList(JSONObject map){
		Map<Object, Object> relist = new HashMap<Object, Object>();
		List<Map<Object, Object>> Err = new ArrayList<>();
		JSONArray snlist= map.getJSONArray("SNLIST");
		for (int i=0;i<snlist.size();i++) {
			Map<Object, Object> DataErr = new HashMap<Object, Object>();
			JSONObject map1=snlist.getJSONObject(i);
			String sncode=map1.getString("SN");
			String macode=map1.getString("MACODE");
			String type=map1.getString("TYPE");
			if(!(type.equals("before")||type.equals("after"))){
				DataErr.put("TypeErr","类型必须是before或者after,SN["+sncode+"]");
				Err.add(DataErr);
				continue;
			}
			if(!baseDao.checkIf("make","ma_code='"+macode+"'")){
				DataErr.put("MakeErr","工单号"+macode+"不存在,SN["+sncode+"]");
				Err.add(DataErr);
				continue;
			}
			if(baseDao.checkIf("makesnlist","msl_makecode='"+macode+"' and msl_sncode='"+sncode+"'")){
				DataErr.put("SnErr","SN["+sncode+"]重复");
				Err.add(DataErr);
				continue;
			}
			baseDao.execute("insert into makesnlist (msl_id,msl_makecode,msl_indate,msl_sncode,msl_type)" +
					"values(makesnlist_seq.nextval,'"+macode+"',sysdate,'"+sncode+"','"+type+"')");
		}
		relist.put("oErrMessage",Err);
		return relist;
	}


	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 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 ms_firstsn,ms_sncode,ma_bios,ma_ec,ma_hardware from CRAFTMATERIAL left join make on cm_makecode=ma_code " +
				"left join makeserial on ms_firstsn=cm_firstsn and cm_makecode=ms_makecode  where cm_barcode='"+iPCBA+"'");
		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> GetSnRelation(JSONObject map){
		Map<Object, Object> rmap = new HashMap<>();
		String iSN=map.get("iSN").toString();
		String oSN="";
		String oErrMessage="";
		if (iSN ==null)
		{
			oErrMessage = "SN不能为空";
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("GetSnRelation", new Object[]{
				String.valueOf(iSN)
		}, new Integer[]{1}, new Integer[]{2,3});
		oSN = list.get(0);
		oErrMessage= list.get(1);
		if(oErrMessage!=null){
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		rmap.put("oSN",oSN);
		rmap.put("oErrMessage",oErrMessage);
		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 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 (rs1.next())
						{
							if (rs1.getString("ur_resourcecode").equals(iResCode)){
								oErrMessage=null;
								rmap.put("oErrMessage",oErrMessage);
								return rmap;
							}else
							{
								oErrMessage = "用户不处于当前资源所属分组!";
							}
						}
					}
					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 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", new Object[]{
				String.valueOf(iSN),
				String.valueOf(map2.get("oMoCode").toString()),
		}, new Integer[]{1,2}, new Integer[]{3,4,5,6,7,8});
		oWIFI = list.get(0);
		oBT =  list.get(1);
		oCode1 =  list.get(2);
		oCode2 = list.get(3);
		oCode3 =  list.get(4);
		oErrMessage= list.get(5);
		if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
			rmap.put("oWIFI",oWIFI);
			rmap.put("oBT",oBT);
			rmap.put("oCode1",oCode1);
			rmap.put("oCode2",oCode2);
			rmap.put("oCode3",oCode3);
		}
		else
			rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private Map<Object,Object> GetMaterialInfo(JSONObject map){
		Map<Object, Object> rmap = new HashMap<>();
		String iSN="123";
		String oErrMessage = null;
		String Code1 = "";
		String Code2 = "";
		String Code3 = "";
		String Code4 = "";
		String Code5 = "";
		String Code6 = "";
		String Code7 = "";
		if(map.get("iSN")==null){
			oErrMessage = "SN不能为空";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		iSN=map.get("iSN").toString();
		String ms_id =baseDao.getFieldDataByCondition("makeserial", "max(ms_id)", "ms_sncode='" + iSN + "' or ms_firstsn='" + iSN + "'").toString();
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("GetMaterialInfo", new Object[]{
				String.valueOf(ms_id),
		}, new Integer[]{1}, new Integer[]{2,3,4,5,6,7,8,9,10,11,12,13,14,15,16});
		Code1 = list.get(0);
		Code2 = list.get(1);
		Code3 = list.get(2);
		Code4 = list.get(3);
		Code5 = list.get(4);
		Code6 = list.get(5);
		Code7 = list.get(7);
		if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
			rmap.put("BT",Code1);
			rmap.put("MAC1",Code2);
			rmap.put("RFID",Code3);
			rmap.put("空白贴纸",Code4);
			rmap.put("NFC",Code5);
			rmap.put("主板",Code6);
			rmap.put("光机",Code7);
		}
		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 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();
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_GETIMEIORNETCODERANGE", 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});
		oIMEI1 = list.get(0);
		oIMEI2 =  list.get(1);
		oIMEI3 =  list.get(2);
		oMEID =  list.get(3);
		oNetCode = list.get(4);
		oPSN =  list.get(5);
		oID1 =  list.get(6);
		oID2 =  list.get(7);
		oID3 =  list.get(8);
		oErrMessage= list.get(9);
		if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
			rmap.put("oIMEI1",oIMEI1);
			rmap.put("oIMEI2",oIMEI2);
			rmap.put("oIMEI3",oIMEI3);
			rmap.put("oMEID",oMEID);
			rmap.put("oNetCode",oNetCode);
			rmap.put("oPSN",oPSN);
			rmap.put("oID1",oID1);
			rmap.put("oID2",oID2);
			rmap.put("oID3",oID3);
		}
		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 oMEID = "";
		String oNetCode = "";
		String oPSN = "";
		String oID1 = "";
		String oID2 = "";
		String oID3 = "";
		String oID4 = "";
		String oID5 = "";
		String oWIFI = "";
		String oBT = "";
		String oCode1 = "";
		String oCode2 = "";
		String oCode3 = "";
		String UUID="";
		String KEYID="";
		String KEYPRODCODE="";
		String ICCID="";
		String IMSI="";
		String SIM="";
		String CARCODE="";
		String CORLID="";
		String CPU="";
		String PN="";
		String oWIDEVINE="";
		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_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_UUID, MS_KEYID, MS_KEYPRODCODE,ms_widevine_base64, MS_ICCID, MS_IMSI, MS_SIM, MS_CARCODE, MS_CORLID, MS_CPU, MS_PN 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");
				oMEID = rs.getString("ms_meid");
				oIMEI1 = rs.getString("ms_imei1");
				oIMEI2 = rs.getString("ms_imei2");
				oCode1 = rs.getString("ms_othcode1");
				oCode2 = rs.getString("ms_othcode2");
				oCode3 = rs.getString("ms_othcode3");
				oID1 = rs.getString("ms_othid3");
				oID2 = rs.getString("ms_othid3");
				oID3 = rs.getString("ms_othid3");
				UUID=rs.getString("ms_uuid");
				KEYID=rs.getString("ms_keyid");
				KEYPRODCODE=rs.getString("ms_keyprodcode");
				ICCID=rs.getString("ms_iccid");
				IMSI=rs.getString("ms_imsi");
				SIM=rs.getString("ms_sim");
				CARCODE=rs.getString("ms_carcode");
				CORLID=rs.getString("ms_corlid");
				CPU=rs.getString("ms_cpu");
				PN=rs.getString("ms_pn");
				oWIDEVINE=rs.getString("ms_widevine_base64");
			}
		}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("oMEID",oMEID);
			rmap.put("oNetCode",oNetCode);
			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("oUUID",UUID);
			rmap.put("oKEYID",KEYID);
			rmap.put("oKEYPRODCODE",KEYPRODCODE);
			rmap.put("oICCID",ICCID);
			rmap.put("oIMSI",IMSI);
			rmap.put("oSIM",SIM);
			rmap.put("oCARCODE",CARCODE);
			rmap.put("oCORLID",CORLID);
			rmap.put("oCPU",CPU);
			rmap.put("oPN",PN);
			rmap.put("oWIDEVINE",oWIDEVINE);
		}
		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 MAC5G=null;
		String ETHMAC=null;
		String WIDEVINE_BASE64=null;
		if(map.get("iWIFI")!=null){
			iWIFI=map.get("iWIFI").toString();
		}
		if(map.get("iBT")!=null){
			iBT=map.get("iBT").toString();
		}
		if(map.get("iCode1")!=null){
			iCode1=map.get("iCode1").toString();
		}
		if(map.get("iCode2")!=null){
			iCode2=map.get("iCode2").toString();
		}
		if(map.get("iCode3")!=null){
			iCode3=map.get("iCode3").toString();
		}
		if(map.get("iMac5G")!=null){
			MAC5G=map.get("iMac5G").toString();
		}
		if(map.get("iEthMac")!=null){
			ETHMAC=map.get("iEthMac").toString();
		}
		if(map.get("iWIDEVINE")!=null){
			WIDEVINE_BASE64=map.get("iWIDEVINE").toString();
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_SETADDRESSINFO_TOOL_NEW", new Object[]{
				String.valueOf(iSN),
				String.valueOf(iWIFI),
				String.valueOf(iBT),
				String.valueOf(iCode1),
				String.valueOf(iCode2),
				String.valueOf(iCode3),
				String.valueOf(MAC5G),
				String.valueOf(ETHMAC),
				String.valueOf(WIDEVINE_BASE64)
		}, new Integer[]{1, 2, 3, 4, 5, 6,7,8,9}, new Integer[]{10});
		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 iResCode = null;
		String iOperator = null;
		String iResult = null;
		String flag = 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("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(iResCode),
				String.valueOf(iOperator),
				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 iMEID = null;
		String iNET = null;
		String iID1 = null;
		String iID2 = null;
		String iID3 = null;
		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("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", new Object[]{
				String.valueOf(iSN),
				String.valueOf(iIMEI1),
				String.valueOf(iIMEI2),
				String.valueOf(iIMEI3),
				String.valueOf(iMEID),
				String.valueOf(iNET),
				String.valueOf(""),
				String.valueOf(iID1),
				String.valueOf(iID2),
				String.valueOf(iID3),
		}, new Integer[]{1, 2, 3, 4, 5, 6,7,8,9,10}, new Integer[]{11});
		oErrMessage = list.get(0);
		rmap.put("oErrMessage",oErrMessage);
		return rmap;
	}

	private Map<Object,Object> SetIMEIInfo_NEW(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 iMEID = null;
		String iNET = null;
		String iID1 = null;
		String iID2 = null;
		String iID3 = null;
		String iUUID = null;
		String iKEYID = null;
		String iKEYPRODCODE = null;
		String iCCID = null;
		String iMSI = null;
		String iSIM = null;
		String iCARDCODE = null;
		String iCORLID = null;
		String iCPU = null;
		String iFIELD = null;
		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("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();
		}
		if(map.get("iUUID")!=null){
			iUUID=map.get("iUUID").toString();
		}
		if(map.get("iKEYID")!=null){
			iKEYID=map.get("iKEYID").toString();
		}
		if(map.get("iKEYPRODCODE")!=null){
			iKEYPRODCODE=map.get("iKEYPRODCODE").toString();
		}
		if(map.get("iCCID")!=null){
			iCCID=map.get("iCCID").toString();
		}
		if(map.get("iMSI")!=null){
			iMSI=map.get("iMSI").toString();
		}
		if(map.get("iSIM")!=null){
			iSIM=map.get("iSIM").toString();
		}
		if(map.get("iCARDCODE")!=null){
			iCARDCODE=map.get("iCARDCODE").toString();
		}
		if(map.get("iCORLID")!=null){
			iCORLID=map.get("iCORLID").toString();
		}
		if(map.get("iCPU")!=null){
			iCPU=map.get("iCPU").toString();
		}
		if(map.get("iFIELD")!=null){
			iFIELD=map.get("iFIELD").toString();
		}
		List<String> list = new ArrayList<String>();
		list = baseDao.callProcedureWithOut("CS_SETIMEIINFO_NEW", new Object[]{
				String.valueOf(iSN),
				String.valueOf(iIMEI1),
				String.valueOf(iIMEI2),
				String.valueOf(iIMEI3),
				String.valueOf(iMEID),
				String.valueOf(iNET),
				String.valueOf(""),
				String.valueOf(iID1),
				String.valueOf(iID2),
				String.valueOf(iID3),
				String.valueOf(iUUID),
				String.valueOf(iKEYID),
				String.valueOf(iKEYPRODCODE),
				String.valueOf(iCCID),
				String.valueOf(iMSI),
				String.valueOf(iSIM),
				String.valueOf(iCARDCODE),
				String.valueOf(iCORLID),
				String.valueOf(iCPU),
				String.valueOf(iFIELD),
		}, new Integer[]{1, 2, 3, 4, 5, 6,7,8,9,10,11,12,13,14,15,16,17,18,19,20}, new Integer[]{21});
		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 Map<Object,Object> SetPcbaData_NG(JSONObject map){
		String iErrCode="";
		String iSN="";
		Map<Object, Object> rmap = new HashMap<Object, Object>();
		String oErrMessage;
		if(map.get("iErrCode")!=null){
			iErrCode=map.get("iErrCode").toString();
		}
		if(map.get("iSN")!=null){
			iSN=map.get("iSN").toString();
		}
		SqlRowList rs=baseDao.queryForRowSet("select ms_sncode,ms_makecode,ms_status,ms_outboxcode from makeserial where ms_sncode='"+iSN+"' order by ms_id desc");
		if(rs.next()){

			String ms_status=rs.getString("ms_status");
			String iMakeCode=rs.getString("ms_makecode");
			String ms_outboxcode=rs.getString("ms_outboxcode");
			if(!ms_status.equals("2")){
				oErrMessage = "SN未完工，不允许采集";
				rmap.put("oErrMessage",oErrMessage);
				return rmap;
			}
			//实际业务数据
			String[] BadCode = iErrCode.split(",");
			StringBuffer sql=new StringBuffer();
			for (int i = 0; i < BadCode.length; i++)
			{
				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,'',sysdate,'','','" + BadCode[i] + "','',");
				sql.append("'',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',ms_outboxcode='' where ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
			baseDao.execute("delete from packagedetail where pd_barcode='"+iSN+"' and pd_makecode='"+iMakeCode+"'");
			baseDao.execute("update package set pa_status=0,PA_PACKAGEQTY=PA_PACKAGEQTY-1, PA_TOTALQTY=PA_TOTALQTY-1, PA_CURRENTQTY=PA_CURRENTQTY-1 where pa_outboxcode='"+ms_outboxcode+"'");
		}else {
			oErrMessage = "SN不存在";
			rmap.put("oErrMessage",oErrMessage);
			return rmap;
		}
		return rmap;
	}

	/// <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_softversion from  make  " +
				"left join makeserial on ms_makecode=ma_code  where ms_sncode='"+iSN+"' order by ms_id desc");
		if(rs.next()){
			rmap.put("oSoftVersion",rs.getString("ma_softversion"));
			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++)
					{
						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;
	}



	private String checkAccessKey(String accessKey,String requestId){
		Object accessSecret_O = baseDao.getFieldDataByCondition("APIEMPLOYEE", "AE_SECRET", "AE_KEY='" + accessKey + "'");
		Object AE_MASTER = baseDao.getFieldDataByCondition("APIEMPLOYEE", "AE_MASTER", "AE_KEY='" + accessKey + "'");
		String accessSecret = accessSecret_O == null ? "" : accessSecret_O.toString();
		// 检查KEY是否合理
		if (StringUtils.isEmpty(accessKey) || StringUtils.isEmpty(accessSecret) || AE_MASTER== null || "".equals(AE_MASTER.toString())) {
			ApiResult apiResult = new ApiResult(ErrorMessage.ACCESSKEY_ILLEGAL.getCode(),ErrorMessage.ACCESSKEY_ILLEGAL.getMessage(),requestId);
			throw new ApiSystemException(apiResult);
		}
		return AE_MASTER.toString();
	}



}