mes-client/UAS_MesInterface/LogicHandler.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace UAS_MesInterface
{
    public class LogicHandler
    {
        public LogicHandler(string Environment)
        {
            dh = new DataHelper(Environment);
        }

        DataHelper dh;
        //用于拼接SQL
        StringBuilder sql = new StringBuilder();
        //用于存放批量执行的SQL
        List<string> sqls = new List<string>();

        /// <summary>
        /// 检测当前的岗位资源对应的工序
        /// </summary>
        /// <param name="iSnCode"></param>
        /// <param name="iMakeCode"></param>
        /// <param name="iSourceCode"></param>
        /// <param name="oErrMessage"></param>
        /// <returns></returns>
        public bool CheckRoutePassed(string iSnCode, string iSourceCode, out string oErrMessage)
        {
            oErrMessage = "";
            string[] param = new string[] { "", iSourceCode, iSnCode, "", "", "", oErrMessage };
            dh.CallProcedure("CS_CHECKSTEPSNANDMACODE", ref param);
            oErrMessage = param[6];
            if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null")
                return true;
            else
                return false;
        }

        /// <summary>
        /// 验证用户身份信息
        /// </summary>
        /// <param name="iUserCode"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool CheckUserLogin(string iUserCode, string iPassWord, out string oErrorMessage)
        {
            oErrorMessage = "";
            string SQL = "select em_code from employee where em_code=:UserName and em_password =:PassWord";
            DataTable dt;
            dt = (DataTable)dh.ExecuteSql(SQL, "select", iUserCode, iPassWord);
            if (dt.Rows.Count > 0)
                return true;
            else
            {
                oErrorMessage = "用户名或者密码不正确!";
                return false;
            }
        }

        /// <summary>
        /// 验证用户身份信息和岗位资源
        /// </summary>
        /// <param name="iUserCode"></param>
        /// <param name="iPassWord"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool CheckUserAndResourcePassed(string iUserCode, string iSourceCode, out string oErrorMessage)
        {
            oErrorMessage = "";
            string SQL = "select em_code,em_type,em_name from employee where em_code=:UserName ";
            DataTable dt;
            dt = (DataTable)dh.ExecuteSql(SQL, "select", iUserCode);
            if (dt.Rows.Count > 0)
            {
                string em_name = dt.Rows[0]["em_name"].ToString();
                string em_type = dt.Rows[0]["em_type"].ToString();
                if (iSourceCode == "")
                {
                    oErrorMessage = "岗位资源不允许为空";
                    return false;
                }
                if (em_type == "admin")
                {
                    if (dh.CheckExist("Source", "sc_code='" + iSourceCode + "' and sc_statuscode='AUDITED'"))
                    {
                        return true;
                    }
                    else
                    {
                        oErrorMessage = "岗位资源编号错误或者未审核！";
                        return false;
                    }
                }
                else
                {
                    dt = dh.getFieldsDatasByCondition("cs$empgroup left join cs$userresource on ur_groupcode=eg_groupcode left join source on ur_resourcecode=sc_code", new string[] { "ur_resourcecode" }, "eg_emcode = '" + iUserCode + "' and sc_statuscode='AUDITED'");
                    //如果存在该编号
                    if (dt.Rows.Count > 0)
                    {
                        //判断如果多个岗位资源存在，用户输入的只要在其中就行
                        for (int i = 0; i < dt.Rows.Count; i++)
                        {
                            if (dt.Rows[i]["ur_resourcecode"].ToString() == iSourceCode)
                                return true;
                        }
                        oErrorMessage = "用户不处于当前资源所属分组!";
                    }
                    else
                        oErrorMessage = "岗位资源编号错误或者未审核！";
                }
            }
            else
                oErrorMessage = "用户不存在!";
            return false;
        }

        /// <summary>
        /// 分配Mac地址和BT地址
        /// </summary>
        /// <param name="iSnCode"></param>
        /// <param name="iMakeCode"></param>
        /// <param name="oMac"></param>
        /// <param name="oBT"></param>
        /// <param name="oCode1"></param>
        /// <param name="oCode2"></param>
        /// <param name="oCdoe3"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool GetAddressRangeByMO(string iSnCode, out string oMac, out string oBT, out string oCode1, out string oCode2, out string oCdoe3, out string oErrorMessage)
        {
            oMac = "";
            oBT = "";
            oCode1 = "";
            oCode2 = "";
            oCdoe3 = "";
            oErrorMessage = "";
            string omakeCode = "";
            GetRcardMOInfo(iSnCode,out omakeCode,out oErrorMessage);
            string[] param = new string[] { iSnCode, omakeCode, oMac, oBT, oCode1, oCode2, oCdoe3, oErrorMessage };
            dh.CallProcedure("CS_GETADDRESSBYMAKECODE", ref param);
            oMac = param[2];
            oBT = param[3];
            oCode1 = param[4];
            oCode2 = param[5];
            oCdoe3 = param[6];
            oErrorMessage = param[7];
            if (oErrorMessage == "" || oErrorMessage == null || oErrorMessage == "null")
                return true;
            else
                return false;
        }

        /// <summary>
        /// 输入的 SN 号查找在制品是否有 IMEI 信息存在，如果存在则将 IMEI 信息传出，如果没有则在该工单下未使用的 IMEI 中随机分配一组
        /// 如果iIMEI1、iNetCode不为空，则分别作为获取的附件加条件。
        /// </summary>
        /// <param name="iSN"></param>
        /// <param name="iMO"></param>
        /// <param name="iIMEI1"></param>
        /// <param name="iNetCode"></param>
        /// <param name="oIMEI1"></param>
        /// <param name="oIMEI2"></param>
        /// <param name="oIMEI3"></param>
        /// <param name="oMEID"></param>
        /// <param name="oNetCode"></param>
        /// <param name="oPSN"></param>
        /// <param name="oMac"></param>
        /// <param name="oBT"></param>
        /// <param name="oID1"></param>
        /// <param name="oID2"></param>
        /// <param name="oID3"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool GetMEIOrNetCodeRange(string iSnCode, string iIMEI1, string iNetCode, out string oIMEI1, out string oIMEI2, out string oIMEI3, out string oMEID, out string oNetCode, out string oPSN, out string oID1, out string oID2, out string oID3, out string oErrorMessage)
        {
            oIMEI1 = "";
            oIMEI2 = "";
            oIMEI3 = "";
            oMEID = "";
            oNetCode = "";
            oPSN = "";
            oID1 = "";
            oID2 = "";
            oID3 = "";
            oErrorMessage = "";
            string[] param = new string[] { iSnCode, "", iIMEI1, iNetCode, oIMEI1, oIMEI2, oIMEI3, oMEID, oNetCode, oPSN, oID1, oID2, oID3, oErrorMessage };
            dh.CallProcedure("CS_GETIMEIORNETCODERANGE", ref param);
            oIMEI1 = param[4];
            oIMEI2 = param[5];
            oIMEI3 = param[6];
            oMEID = param[7];
            oNetCode = param[8];
            oPSN = param[9];
            oID1 = param[10];
            oID2 = param[11];
            oID3 = param[12];
            oErrorMessage = param[13];
            if (oErrorMessage == "" || oErrorMessage == null || oErrorMessage == "null")
                return true;
            else
                return false;
        }

        /// <summary>
        /// 获取工单的最近一条执行记录
        /// </summary>
        /// <param name="iSnCode"></param>
        /// <param name="oMakeCode"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool GetRcardMOInfo(string iSnCode, out string oMakeCode, out string oErrorMessage)
        {
            //取MakeProcess表中的执行记录ID最大的一个工单的号码
            oMakeCode = "";
            oErrorMessage = "";
            string ms_id = dh.getFieldDataByCondition("MakeSerial", "max(ms_id) ms_id", "ms_sncode='" + iSnCode + "' or ms_firstsn in (select firstsn from makesnrelation where sn='" + iSnCode + "')").ToString();
            oMakeCode = dh.getFieldDataByCondition("MakeSerial", "ms_makecode", "ms_id='" + ms_id + "'").ToString();
            if (oMakeCode != "")
                return true;
            else
            {
                oErrorMessage = "序列号:" + iSnCode + " 未归属工单";
                return false;
            }
        }

        /// <summary>
        /// 获取序列号的所有串号信息
        /// </summary>
        /// <param name="iSnCode"></param>
        /// <param name="oIMEI1"></param>
        /// <param name="oIMEI2"></param>
        /// <param name="oIMEI3"></param>
        /// <param name="oMEID"></param>
        /// <param name="oNetCode"></param>
        /// <param name="oPSN"></param>
        /// <param name="oMac"></param>
        /// <param name="oBT"></param>
        /// <param name="oCode1"></param>
        /// <param name="oCode2"></param>
        /// <param name="oCode3"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool GetMobileAllInfo(string iSnCode, out string oMac, out string oBT, out string oCode1, out string oCode2, out string oCode3, out string oIMEI1, out string oIMEI2, out string oIMEI3, out string oMEID, out string oNetCode, out string oPSN, out string oID1, out string oID2, out string oID3, out string oErrorMessage)
        {
            oBT = "";
            oMEID = "";
            oMac = "";
            oPSN = "";
            oNetCode = "";
            oIMEI1 = "";
            oIMEI2 = "";
            oIMEI3 = "";
            oCode1 = "";
            oCode2 = "";
            oCode3 = "";
            oID1 = "";
            oID2 = "";
            oID3 = "";
            //通过序列号获取最近操作的工单号
            string ms_id = dh.getFieldDataByCondition("makeserial", "ms_id", "ms_sncode='" + iSnCode + "'").ToString();
            if (ms_id != "")
            {
                DataTable dt = dh.getFieldsDataByCondition("MakeSerial", new string[] { "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_id='" + ms_id + "'");
                if (dt.Rows.Count > 0)
                {
                    oMac = dt.Rows[0]["ms_mac"].ToString();
                    oBT = dt.Rows[0]["ms_bt"].ToString();
                    oPSN = dt.Rows[0]["ms_psn"].ToString();
                    oNetCode = dt.Rows[0]["ms_netcode"].ToString();
                    oMEID = dt.Rows[0]["ms_meid"].ToString();
                    oIMEI1 = dt.Rows[0]["ms_imei1"].ToString();
                    oIMEI2 = dt.Rows[0]["ms_imei2"].ToString();
                    oIMEI3 = dt.Rows[0]["ms_imei3"].ToString();
                    oCode1 = dt.Rows[0]["ms_othcode1"].ToString();
                    oCode2 = dt.Rows[0]["ms_othcode2"].ToString();
                    oCode3 = dt.Rows[0]["ms_othcode3"].ToString();
                    oID1 = dt.Rows[0]["ms_othid3"].ToString();
                    oID2 = dt.Rows[0]["ms_othid3"].ToString();
                    oID3 = dt.Rows[0]["ms_othid3"].ToString();
                    oErrorMessage = "";
                    return true;
                }
                else
                {
                    oErrorMessage = "序列号" + iSnCode + "不存在";
                    return false;
                }
            }
            else
            {
                oErrorMessage = "序列号" + iSnCode + "不存在";
                return false;
            }
        }

        /// <summary>
        /// 记录操作日志
        /// </summary>
        /// <param name="iSnCode"></param>
        /// <param name="iMakeCode"></param>
        /// <param name="iMPKind"></param>
        /// <param name="result"></param>
        /// <param name="iUserCode"></param>
        private void InsertMakeProcess(string iSnCode, string iMakeCode, string iSourceCode, string iMPKind, string result, string iUserCode)
        {
            string CurrentStep = "";
            string LineCode = "";
            string CurrentStepName = "";
            GetStepCodeAndNameAndLineBySource(iSourceCode, ref CurrentStep, ref CurrentStepName, ref LineCode);
            sql.Clear();
            sql.Append("insert into MakeProcess(mp_id,mp_makecode,mp_maid, mp_mscode,mp_sncode,mp_stepcode,mp_stepname,");
            sql.Append("mp_craftcode,mp_craftname,mp_kind,mp_result,mp_indate,mp_inman,mp_wccode,mp_linecode,mp_sourcecode,mp_snstatus,mp_sncheckno,mp_snoutboxcode)");
            sql.Append("select MakeProcess_seq.nextval, ma_code,ma_id,ms_code,ms_sncode,'" + CurrentStep + "','" + CurrentStepName + "',");
            sql.Append("ma_craftcode,ma_craftname,'" + iMPKind + "','" + result + "',sysdate,'" + iUserCode + "',ma_wccode,'" + LineCode + "','" + iSourceCode + "',");
            sql.Append("ms_status,ms_checkno,ms_outboxcode from make left join makeserial on ms_makecode=ma_code left join step on st_code=ms_stepcode ");
            sql.Append("where ms_sncode='" + iSnCode + "' and ma_code='" + iMakeCode + "' and st_code='" + CurrentStep + "'");
            dh.ExecuteSql(sql.ToString(), "insert");
        }

        /// <summary>
        /// 保存Mac地址和BT地址
        /// </summary>
        /// <param name="iSN"></param>
        /// <param name="iMac"></param>
        /// <param name="iBT"></param>
        /// <param name="iCode1"></param>
        /// <param name="iCode2"></param>
        /// <param name="iCode3"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool SetAddressInfo(string iSN, string iMac, string iBT, string iCode1, string iCode2, string iCode3, out string oErrorMessage)
        {
            oErrorMessage = "";
            string[] param = new string[] { iSN, iMac, iBT, iCode1, iCode2, iCode3, oErrorMessage };
            dh.CallProcedure("CS_SETADDRESSINFO", ref param);
            oErrorMessage = param[6];
            if (oErrorMessage == "" || oErrorMessage == null || oErrorMessage == "null")
                return true;
            else
                return false;
        }

        private bool SetStepFinish(string iMakeCode, string iSourceCode, string iSN, string iMPKind, string iResult, string iUserCode, string iErrCode, out string oErrorMessage)
        {
            oErrorMessage = "";
            string StepCode = dh.getFieldDataByCondition("Makeserial", "ms_stepcode", "ms_sncode='" + iSN + "'").ToString();
            string CurrentStep = GetStepCodeBySource(iSourceCode);
            switch (iResult)
            {
                case "OK":
                    break;
                case "NG":
                    if (iErrCode == "")
                    {
                        oErrorMessage = "测试结果为NG时必须传递不良代码";
                        return false;
                    }
                    else
                    {
                        string[] BadCode = iErrCode.Split(',');
                        sql.Clear();
                        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_soncode,mb_status) select makebad_seq.nextval");
                        sql.Append(",ma_code,ms_code,ms_sncode,'" + iUserCode + "',sysdate,'" + StepCode + "',ms_sourcecode,:bc_code,'',");
                        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 + "'");
                        dh.BatchInsert(sql.ToString(), new string[] { "bc_code" }, BadCode);
                        //将不良的序列号的状态码设为3
                        dh.ExecuteSql("update makeserial set ms_status='3' where ms_sncode=:sncode", "update", iSN);
                    }
                    break;
                default:
                    oErrorMessage = "测试结果必须为NG或者OK";
                    return false;
            }

            if (StepCode == CurrentStep)
            {
                InsertMakeProcess(iSN, iMakeCode, iSourceCode, iMPKind, iResult, iUserCode);
                return true;
            }
            else
            {
                return CS_SetFinish(iMakeCode, iSourceCode, iSN, iUserCode, iResult, out oErrorMessage);
            }
        }

        /// <summary>
        /// 设置测试结果
        /// </summary>
        /// <param name="iMakeCode"></param>
        /// <param name="iSourceCode"></param>
        /// <param name="iSN"></param>
        /// <param name="iMPKind"></param>
        /// <param name="iResult"></param>
        /// <param name="iUserCode"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool SetMobileData(string iSN, string iSourceCode, string iMPKind, string iResult, string iErrCode, out string oErrorMessage)
        {
            string omakecode = "";
            GetRcardMOInfo(iSN,out omakecode,out oErrorMessage);
            return SetStepFinish(omakecode, iSourceCode, iSN, iMPKind, iResult, "", iErrCode, out oErrorMessage);
        }

        private bool CS_SetFinish(string iMakeCode, string iSourceCode, string iSN, string iUserCode, string iResult, out string oErrorMessage)
        {
            oErrorMessage = "";
            string[] param = new string[] { iMakeCode, iSourceCode, iSN, iUserCode, iResult, oErrorMessage };
            dh.CallProcedure("CS_SETSTEPRESULT", ref param);
            oErrorMessage = param[5];
            if (oErrorMessage == "" || oErrorMessage == null || oErrorMessage == "null")
                return true;
            else
                return false;
        }

        /// <summary>
        /// 方法说明：测试详细信息录入系统，针对一个SN多个测试项目结果可循环调用
        /// </summary>
        /// <param name="iSnCode">序列号</param>
        /// <param name="iClass"></param>
        /// <param name="iSubClass1"></param>
        /// <param name="iSubClass2"></param>
        /// <param name="iSubClass3"></param>
        /// <param name="iMaxValue"></param>
        /// <param name="iMinValue"></param>
        /// <param name="iActualValue"></param>
        /// <param name="iValue1"></param>
        /// <param name="iValue2"></param>
        /// <param name="iValue3"></param>
        /// <param name="iTestResult"></param>
        /// <param name="oErrMessage"></param>                                                      
        /// <returns></returns>
        public bool SetTestDetail(string iSnCode, string iMakeCode, string iClass, string iSubClass1, string iSubClass2, string iSubClass3, string iMaxValue, string iMinValue, string iActualValue, string iValue1, string iValue2, string iValue3, string iTestResult, string iSourceCode, out string oErrMessage)
        {
            oErrMessage = "";
            sql.Clear();
            sql.Append("Insert into STEPTESTDETAIL (STD_ID,STD_SN,STD_MAKECODE,STD_CLASS,STD_SUBCLASS1,STD_SUBCLASS2,");
            sql.Append("STD_SUBCLASS3,STD_MAXVALUE,STD_MINVALUE,STD_ACTUALVALUE,STD_VALUE1,STD_VALUE2,STD_VALUE3,STD_TESTRESULT,");
            sql.Append("STD_DATE,STD_RESCODE) values (STEPTESTDETAIL_SEQ.nextval,:std_sn,:std_makecode,");
            sql.Append(":std_class,:std_subclass1,:std_subclass2,:std_subclass3,:std_maxvalue,:std_minvalue,:std_actualvalue,:std_value1,");
            sql.Append(":std_value2,:std_value3,:std_testresult,sysdate,:std_record)");
            dh.ExecuteSql(sql.ToString(), "select", iSnCode, iMakeCode, iClass, iSubClass1, iSubClass2, iSubClass3, iMaxValue, iMinValue, iActualValue, iValue1, iValue2, iValue3, iTestResult, iSourceCode);
            return true;
        }

        /// <summary>
        /// 作业调用该方法将确认接收SN对应的IMEI及附属信息。
        /// </summary>
        /// <param name="iSN"></param>
        /// <param name="iMO"></param>
        /// <param name="iIMEI1"></param>
        /// <param name="iIMEI2"></param>
        /// <param name="iIMEI3"></param>
        /// <param name="iMEID"></param>
        /// <param name="iNetCode"></param>
        /// <param name="iPSN"></param>
        /// <param name="iID1"></param>
        /// <param name="iBT"></param>
        /// <param name="iID1"></param>
        /// <param name="iID2"></param>
        /// <param name="iID3"></param>
        /// <param name="oErrorMessage"></param>
        /// <returns></returns>
        public bool SetIMEIInfo(string iSnCode, string iIMEI1, out string oErrMessage)
        {
            oErrMessage = "";
            string[] param = new string[] { iSnCode, iIMEI1, "", "", "", "", "", "", "", "", oErrMessage };
            dh.CallProcedure("CS_SETIMEIINFO", ref param);
            oErrMessage = param[10];
            if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null")
                return true;
            else
                return false;
        }

        /// <summary>
        /// 获取执行步骤代码，名称和线别
        /// </summary>
        /// <param name="Source"></param>
        /// <param name="StepCode"></param>
        /// <param name="StepName"></param>
        /// <param name="LineCode"></param>
        private void GetStepCodeAndNameAndLineBySource(string Source, ref string StepCode, ref string StepName, ref string LineCode)
        {
            DataTable dt = dh.getFieldsDataByCondition("source", new string[] { "sc_stepcode", "sc_stepname", "sc_linecode" }, "sc_code='" + Source + "'");
            if (dt.Rows.Count > 0)
            {
                StepCode = dt.Rows[0]["sc_stepcode"].ToString();
                StepName = dt.Rows[0]["sc_stepname"].ToString();
                LineCode = dt.Rows[0]["sc_linecode"].ToString();
            }
        }

        /// <summary>
        /// 获取步骤代码和名称
        /// </summary>
        /// <param name="Source"></param>
        /// <param name="StepCode"></param>
        /// <param name="StepName"></param>
        private void GetStepCodeAndNameBySource(string Source, ref string StepCode, ref string StepName)
        {
            DataTable dt = dh.getFieldsDataByCondition("source", new string[] { "sc_stepcode", "sc_stepname", "sc_linecode" }, "sc_code='" + Source + "'");
            if (dt.Rows.Count > 0)
            {
                StepCode = dt.Rows[0]["sc_stepcode"].ToString();
                StepName = dt.Rows[0]["sc_stepname"].ToString();
            }
        }

        /// <summary>
        /// 获取步骤代码
        /// </summary>
        /// <param name="Source"></param>
        /// <returns></returns>
        private string GetStepCodeBySource(string Source)
        {
            return dh.getFieldDataByCondition("source", "sc_stepcode", "sc_code='" + Source + "'").ToString();
        }
    }
}