mes-client/UAS_MES_YDCY/FunctionCode/Make/Make_FeedingCollectionNEW.cs

using System;
using System.Data;
using System.Text;
using System.Windows.Forms;
using UAS_MES_NEW.CustomControl.TextBoxWithIcon;
using UAS_MES_NEW.DataOperate;
using UAS_MES_NEW.Entity;
using UAS_MES_NEW.PublicMethod;
using System.Drawing;
using System.Text.RegularExpressions;
using System.Collections.Generic;
using UAS_MES_NEW.PublicForm;
using System.IO.Ports;
using DevExpress.XtraPrinting;
using static System.Runtime.CompilerServices.RuntimeHelpers;

namespace UAS_MES_NEW.Make
{
    public partial class Make_FeedingCollectionNEW : Form
    {
        //MakeSerial表主键
        string ms_id;
        //制造单号                                                                             
        string make_code;
        //产品编号
        string make_prodcode;
        //工序编号
        string nextstepcode;
        //完工状态
        string ms_status;
        //工艺路线编号
        //Bom版本
        string mabomversion;
        string ms_edistatus;
        string ErrorMessage = "";

        List<string> TSN = new List<string>();

        Dictionary<string, string> CheckBarcode = new Dictionary<string, string>();

        //用于提醒的序列B
        string[] RemainList = new string[0];
        //提醒序列的索引
        int RemainIndex = 0;

        string oMakeCode = "";
        string oMsid = "";

        string ms_firstsn = "";

        DataHelper dh;
        LogStringBuilder sql = new LogStringBuilder();
        DataTable DBFind;
        DataTable dt;
        //保存ListB中的数据
        DataTable dt1;

        AutoSizeFormClass asc = new AutoSizeFormClass();

        List<string> CollectData = new List<string>();

        List<string> ResultStr = new List<string>();

        List<string> ReturnUseRate = new List<string>();

        List<string> ReturnSubFix = new List<string>();

        List<string> CollectDataSonCode = new List<string>();

        List<string> SpSNType = new List<string>();

        List<string> SPID = new List<string>();

        public Make_FeedingCollectionNEW()
        {
            InitializeComponent();
        }

        private void Make_FeedingCollection_Load(object sender, EventArgs e)
        {
            asc.controllInitializeSize(this);
            LockMakeCode.GetMakeCodeCtl(ma_code);
            ma_code.SetLockCheckBox(LockMakeCode);
            //工单号放大镜配置
            ma_code.TableName = "make left join product on ma_prodcode=pr_code";
            ma_code.SelectField = "ma_code # 工单号,ma_prodcode # 产品编号,ma_qty # 工单数量,ma_craftcode # 途程编号,pr_spec # 产品名称,ma_bomversion # Bom版本,ma_softversion # 软件版本,ma_ecncode # ECN号";
            ma_code.FormName = Name;
            ma_code.DBTitle = "工单查询";
            ma_code.SetValueField = new string[] { "ma_code", "ma_prodcode", "ma_qty", "pr_spec", "ma_craftcode", "ma_bomversion", "ma_softversion", "ma_ecncode" };
            ma_code.Condition = "ma_statuscode='STARTED'";
            ma_code.DbChange += Ma_code_DBChange;
            code.Focus();
            dh = SystemInf.dh;
            StepCount.StepCode = User.CurrentStepCode;
            StepCount.Source = User.UserSourceCode;
            StepCount.LineCode = User.UserLineCode;
            StepCount.Dh = dh;
            StepCount.Start();
        }

        private void Ma_code_DBChange(object sender, EventArgs e)
        {
            DBFind = ma_code.ReturnData;
            BaseUtil.SetFormValue(this.Controls, DBFind);
            string ifforsn = dh.getFieldDataByCondition("make left join stepbom on ma_prodcode=sb_prodcode left join stepproduct on sb_id=sp_sbid", "nvl(sp_ifforsn,0) sp_ifforsn", "ma_code='" + ma_code.Text + "' and sp_craftcode='" + ma_craftcode.Text + "' and sp_stepcode='" + User.CurrentStepCode + "' and sb_bomversion='" + ma_bomversion.Text + "' order by sp_detno").ToString();
            if (ifforsn != "" && ifforsn != "0")
                iflastsn.Checked = true;
            else
                iflastsn.Checked = false;
        }

        private void Make_FeedingCollection_SizeChanged(object sender, EventArgs e)
        {
            asc.controlAutoSize(this);
        }

        private void Clean_Click(object sender, EventArgs e)
        {
            OperateResult.Clear();
        }

        private void Confirm_Click(object sender, EventArgs e)
        {
            KeyEventArgs e2 = new KeyEventArgs(Keys.Enter);
            code_KeyDown(sender, e2);
        }

        private void code_KeyDown(object sender, KeyEventArgs e)
        {
            if (e.KeyCode == Keys.Enter)
            {
                if (LogicHandler.CheckStepAttribute(Tag.ToString(), User.UserSourceCode, out ErrorMessage))
                {
                    if (Loading.Checked)
                    {
                        if (code.Text.Replace(" ", "") == "")
                        {
                            OperateResult.AppendText(">>采集数据不可为空\n", Color.Red);
                            return;
                        }
                        //如果录入框和工单号均有输入
                        if (code.Text != "" && ma_code.Text != "" && sn_code.Text == "")
                        {
                            GetCollectItem();
                            BaseUtil.FillDgvWithDataTable(LabelDataGridView, dt1);
                        }
                        //输入框有值但未选择工单号
                        else if (code.Text != "" && ma_code.Text == "" && sn_code.Text == "")
                        {
                            GetCollectItem();
                            BaseUtil.FillDgvWithDataTable(LabelDataGridView, dt1);
                        }
                        else if (sn_code.Text != "")
                        {
                            //索引超出长度表示内容均已提醒
                            if (RemainIndex >= RemainList.Length)
                            {
                                OperateResult.AppendText(">>当前序列号" + sn_code.Text + "不在本道工序，请采集其它序列号\n", Color.Red);
                                sn_code.Text = "";
                                code.Text = "";
                                return;
                            }
                            string sp_soncode = dt1.Rows[RemainIndex]["sp_soncode"].ToString();
                            string sp_fsoncode = dt1.Rows[RemainIndex]["sp_fsoncode"].ToString();
                            string sp_prefix = dt1.Rows[RemainIndex]["sp_prefix"].ToString();
                            string sp_regex = dt1.Rows[RemainIndex]["sp_regex"].ToString();
                            string length = dt1.Rows[RemainIndex]["sp_length"].ToString();
                            string sp_id = dt1.Rows[RemainIndex]["sp_id"].ToString();
                            string sp_ifrepeat = dt1.Rows[RemainIndex]["sp_ifrepeat"].ToString();
                            string sp_ifforsn = dt1.Rows[RemainIndex]["sp_ifforsn"].ToString();
                            string sp_barcoderule = dt1.Rows[RemainIndex]["sp_barcoderule"].ToString();
                            string sp_checkbarcode = dt1.Rows[RemainIndex]["sp_checkbarcode"].ToString();
                            string sp_checksalecode = dt1.Rows[RemainIndex]["sp_checksalecode"].ToString();
                            string sp_subnum = dt1.Rows[RemainIndex]["sp_subnum"].ToString();
                            string sp_subnumlength = dt1.Rows[RemainIndex]["sp_subnumlength"].ToString();
                            string sp_rate = dt1.Rows[RemainIndex]["sp_rate"].ToString();
                            string sp_sntype = dt1.Rows[RemainIndex]["sp_sntype"].ToString();
                            string resultstr = "";
                            string subfix = "";
                            string userate = "0";
                            string fsoncode = "";
                            string sntype = "";
                            if (LogicHandler.CheckSNBeforeLoad(ma_code.Text, sn_code.Text, code.Text, sp_fsoncode, sp_soncode, sp_barcoderule, sp_prefix, length, sp_ifrepeat, sp_checksalecode, sp_subnum, sp_subnumlength, "0", sp_rate, sp_sntype, out resultstr, out userate, out subfix, out fsoncode, out sntype, out ErrorMessage))
                            {
                                //判断采集的条码和本次采集的也不能重复
                                if (CollectData.Contains(code.Text) && sp_ifrepeat != "-1")
                                {
                                    OperateResult.AppendText(">>条码" + code.Text + "已经上料\n", Color.Red, code);
                                    return;
                                }
                                if (sp_checkbarcode != "")
                                {
                                    if (CheckBarcode.ContainsKey(sp_checkbarcode))
                                    {
                                        if (CheckBarcode[sp_checkbarcode] != code.Text)
                                        {
                                            OperateResult.AppendText(">>条码" + code.Text + "需要检查物料，未匹配到之前上料数据\n", Color.Red, code);
                                            return;
                                        }
                                    }
                                    else
                                    {
                                        OperateResult.AppendText(">>条码" + code.Text + "需要检查物料，未匹配到之前上料数据\n", Color.Red, code);
                                        return;
                                    }
                                }
                                TSN.Add(code.Text);
                                if (sp_barcoderule == "BARCODE")
                                {
                                    sp_soncode = ErrorMessage;
                                }
                                LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, oMakeCode, User.UserLineCode, User.UserSourceCode, "上物料", sn_code.Text + "上物料" + code.Text + "料号" + sp_fsoncode, sn_code.Text, "");
                                Save_OtherCode(fsoncode, sp_soncode, make_code, sn_code.Text, sp_id, resultstr, userate, subfix, sntype);
                            }
                            else
                            {
                                OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
                                SetCheck set = new SetCheck("NG", Color.Red);
                                BaseUtil.SetFormCenter(set);
                                set.ShowDialog();
                            }
                        }
                    }
                    //勾选了下料的时候
                    else if (UnLoading.Checked)
                    {
                        if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, code.Text, User.UserCode, out oMakeCode, out oMsid, out ErrorMessage))
                        {
                            sql.Clear();
                            sql.Append("select ms_firstsn,ms_sncode,cm_makecode,cm_craftcode,nvl(cm_status,0)cm_status,cm_id,cm_stepcode,");
                            sql.Append("ms_makecode,cm_mccode,cm_materialtype from craftmaterial left join makeserial on cm_makecode");
                            sql.Append("=ms_makecode and cm_sncode=ms_sncode where cm_sncode='" + code.Text + "' and cm_makecode='" + oMakeCode + "'");
                            sql.Append("and cm_materialtype=1 and cm_stepcode='" + User.CurrentStepCode + "' ");
                            dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                            if (dt.Rows.Count > 0)
                            {
                                string ms_macode = dt.Rows[0]["ms_makecode"].ToString();
                                string ms_firstsn = dt.Rows[0]["ms_sncode"].ToString();
                                string cm_stepcode = dt.Rows[0]["cm_stepcode"].ToString();
                                string cm_mccode = dt.Rows[0]["cm_mccode"].ToString();
                                string cm_materialtype = dt.Rows[0]["cm_materialtype"].ToString();
                                string cm_status = dt.Rows[0]["cm_status"].ToString();
                                string cm_makecode = dt.Rows[0]["cm_makecode"].ToString();
                                string cm_craftcode = dt.Rows[0]["cm_craftcode"].ToString();
                                //清除已被使用的序列号
                                sql.Clear();
                                sql.Append("update makeserial set ms_nextmacode='' where ms_sncode in(select cm_barcode from craftmaterial where ");
                                sql.Append("cm_makecode='" + cm_makecode + "' and cm_sncode='" + code.Text + "' and cm_stepcode='" + cm_stepcode + "' and cm_craftcode='" + cm_craftcode + "' ");
                                sql.Append("and cm_materialtype=1 and nvl(cm_status,0) =0) and ms_nextmacode='" + oMakeCode + "'");
                                dh.ExecuteSql(sql.GetString(), "update");
                                sql.Clear();
                                sql.Append("update makeserial set ms_nextstepcode=ms_stepcode where ms_id='" + ms_id + "'");
                                dh.ExecuteSql(sql.GetString(), "update");
                                //进行下料
                                sql.Clear();
                                sql.Append("delete from craftmaterial where (cm_sncode in (select sn from makesnrelation where firstsn");
                                sql.Append("='" + ms_firstsn + "') or cm_sncode = '" + ms_firstsn + "') and cm_makecode = '" + oMakeCode + "' ");
                                sql.Append("and cm_status = 0 and cm_stepcode='" + User.CurrentStepCode + "' and cm_materialtype=1");
                                dh.ExecuteSql(sql.GetString(), "delete");
                                LogicHandler.InsertMakeProcess(ms_macode, code.Text, User.UserSourceCode, "上料采集操作", "下料成功", User.UserCode);
                                //刷新界面值
                                sql.Clear();
                                sql.Append("select mcd_inqty,ma_qty-mcd_inqty mcd_remainqty ");
                                sql.Append("from make left join makecraftdetail on mcd_macode=ma_code where ");
                                sql.Append("ma_code='" + oMakeCode + "' and mcd_stepcode='" + User.CurrentStepCode + "'");
                                dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                                BaseUtil.SetFormValue(Controls, dt);
                                LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, oMakeCode, User.UserLineCode, User.UserSourceCode, "上料采集", "下料成功", code.Text, "");
                                OperateResult.AppendText(">>序列号" + code.Text + "下料成功\n", Color.Green, code);
                            }
                            else OperateResult.AppendText(">>序列号" + code.Text + "未上料，无需下料\n", Color.Red, code);
                        }
                        else OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
                    }
                }
                else OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
            }
        }

        //获取采集的项目
        private void GetCollectItem()
        {
            bool NoteAlready = LogicHandler.CheckDiffMakeCodeBeforeStepCheck(code.Text, ma_code.Text, NoteForChange.Checked, out oMakeCode, out ErrorMessage);
            if (!NoteAlready)
            {
                OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
                return;
            }
            dt = (DataTable)dh.ExecuteSql("select ms_sncode from makeserial where ms_imei1='" + code.Text + "' order by ms_id desc", "select");
            if (dt.Rows.Count > 0)
            {
                code.Text = dt.Rows[0]["ms_sncode"].ToString();
            }
            else
            {
                dt = (DataTable)dh.ExecuteSql("select ms_sncode from makeserial where ms_imei2='" + code.Text + "' order by ms_id desc", "select");
                if (dt.Rows.Count > 0)
                {
                    code.Text = dt.Rows[0]["ms_sncode"].ToString();
                }
            }
            if (LogicHandler.CheckStepSNAndMacode(oMakeCode, User.UserSourceCode, code.Text, User.UserCode, out oMakeCode, out oMsid, out ErrorMessage))
            {
                nextstepcode = dh.getFieldDataByCondition("makeserial", "ms_nextstepcode", "ms_id='" + oMsid + "'").ToString();
                if (nextstepcode != User.CurrentStepCode)
                {
                    string stname = dh.getFieldDataByCondition("step", "st_name", "st_code='" + nextstepcode + "'").ToString();
                    OperateResult.AppendText("<<序列号:" + code.Text + "下一工序是" + stname + ",不是当前岗位的工序\n", Color.Red, code);
                    return;
                }
                if (!LogicHandler.CheckDiffMakeCodeAfterStepCheck(code.Text, oMakeCode, NoteForChange.Checked, NoteAlready, ma_code, out ErrorMessage))
                {
                    OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
                    return;
                }
                //将录入框的值给序列号
                sn_code.Text = code.Text;
                sql.Clear();
                sql.Append("select ma_prodcode,nvl(ms_edistatus,0)ms_edistatus,ms_bomversion,ma_ecncode,ms_sncode,ma_softversion,ms_firstsn,ma_bomversion,ma_qty,ma_code,pr_spec,ms_status,ms_id,ms_craftcode,ms_nextstepcode");
                sql.Append(",ms_prodcode,ms_makecode,ms_code,ms_stepname  from makeserial left join make on ma_code=ms_makecode ");
                sql.Append("left join product on ms_prodcode=pr_code where ms_sncode='" + code.Text + "' order by ms_id desc");
                dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                if (dt.Rows.Count > 0)
                {
                    ms_id = dt.Rows[0]["ms_id"].ToString();
                    make_code = dt.Rows[0]["ma_code"].ToString();
                    mabomversion = dt.Rows[0]["ma_bomversion"].ToString();
                    make_prodcode = dt.Rows[0]["ms_prodcode"].ToString();
                    nextstepcode = dt.Rows[0]["ms_nextstepcode"].ToString();
                    ms_status = dt.Rows[0]["ms_status"].ToString();
                    ms_edistatus = dt.Rows[0]["ms_edistatus"].ToString();
                    ms_firstsn = dt.Rows[0]["ms_sncode"].ToString();
                    BaseUtil.SetFormValue(this.Controls, dt);
                    string ifforsn = dh.getFieldDataByCondition("make left join stepbom on ma_prodcode=sb_prodcode left join stepproduct on sb_id=sp_sbid", "nvl(sp_ifforsn,0) sp_ifforsn", "ma_code='" + ma_code.Text + "' and sp_stepcode='" + User.CurrentStepCode + "'  and sp_craftcode='" + ms_craftcode.Text + "' and sb_bomversion='" + ma_bomversion.Text + "' order by sp_detno").ToString();
                    if (ifforsn != "" && ifforsn != "0")
                        iflastsn.Checked = true;
                    else
                        iflastsn.Checked = false;
                    LockMakeCode.Checked = true;
                    if (ms_edistatus == "-1")
                    {
                        OperateResult.AppendText(">>序列号" + code.Text + "已被召回，当前界面不允许采集\n", Color.Red);
                        return;
                    }
                    //勾选了前一工单
                    if (iflastsn.Checked)
                    {
                        dt = (DataTable)dh.ExecuteSql("select ms_id,ms_makecode,ms_craftcode,ms_status,ms_nextstepcode,ms_prodcode,ms_code from makeserial where ms_sncode='" + code.Text + "' and ms_makecode<>'" + ma_code.Text + "' order by ms_id desc", "select");
                        string make_code = "";
                        string make_prodcode = "";
                        string nextstepcode = "";
                        string ms_status = "";
                        if (dt.Rows.Count > 0)
                        {
                            ms_id = dt.Rows[0]["ms_id"].ToString();
                            make_code = dt.Rows[0]["ms_makecode"].ToString();
                            make_prodcode = dt.Rows[0]["ms_prodcode"].ToString();
                            nextstepcode = dt.Rows[0]["ms_nextstepcode"].ToString();
                            ms_status = dt.Rows[0]["ms_status"].ToString();
                            //判断序列号的前一工单是否已经完工
                            if (dt.Rows[0]["ms_makecode"].ToString() != ma_code.Text && dt.Rows[0]["ms_status"].ToString() == "2")
                            {
                                sql.Clear();
                                sql.Append("select sp_id,sp_soncode from make inner join stepbom on ma_prodcode=sb_prodcode and ma_bomversion=sb_bomversion left ");
                                sql.Append("join stepproduct on sp_sbid=sb_id where ma_code='" + ma_code.Text + "' and sp_craftcode='" + ms_craftcode.Text + "' ");
                                sql.Append("and sp_stepcode='" + User.CurrentStepCode + "' and nvl(sp_ifforsn,0)<>0");
                                dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                                if (dt.Rows.Count > 0)
                                {
                                    string sp_id = dt.Rows[0]["sp_id"].ToString();
                                    string sp_soncode = dt.Rows[0]["sp_soncode"].ToString();
                                    if (!dh.CheckExist("Craftmaterial", "cm_makecode='" + ma_code.Text + "' and cm_soncode='" + make_prodcode + "' and cm_sncode='" + code.Text + "' and cm_status=0"))
                                    {
                                        CollectDataSonCode.Add(sp_soncode);
                                        SPID.Add(sp_id);
                                        CollectData.Add(code.Text);
                                        sn_code.Text = code.Text;
                                        OperateResult.AppendText(">>序列号" + code.Text + ",物料" + sp_soncode + "上料成功\n", Color.Green);
                                        RemainIndex = RemainIndex + 1;
                                        GetItem();
                                        return;
                                    }
                                    else
                                    {
                                        GetItem();
                                    }
                                }
                                else OperateResult.AppendText(">>序列号" + code.Text + "无生产信息\n", Color.Red, code);
                            }
                            else OperateResult.AppendText(">>序列号" + code.Text + "已被工单" + dt.Rows[0]["ms_makecode"].ToString() + "绑定,尚未完工\n", Color.Red, code);
                        }
                        else OperateResult.AppendText(">>序列号" + code.Text + "无生产信息\n", Color.Red, code);
                    }
                    else
                    {
                        dt = (DataTable)dh.ExecuteSql("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_sncode='" + code.Text + "' and ms_makecode='" + ma_code.Text + "' order by ms_id desc", "select");
                        nextstepcode = dt.Rows[0]["ms_nextstepcode"].ToString();
                        ms_status = dt.Rows[0]["ms_status"].ToString();
                        sn_code.Text = code.Text;
                        sql.Clear();
                        sql.Append("select ma_code,ma_softversion,ma_ecncode,ma_prodcode,pr_spec,ma_qty from makeserial left join product ");
                        sql.Append(" on ms_prodcode=pr_code left join make on ms_makecode=ma_code left join ");
                        sql.Append("makecraftdetail on mcd_macode=ms_makecode where ms_id='" + oMsid + "' and mcd_stepcode='" + User.CurrentStepCode + "'");
                        dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                        BaseUtil.SetFormValue(this.Controls, dt);
                        OperateResult.AppendText(">>获取序列号" + code.Text + "成功\n", Color.Green);
                        GetItem();
                    }
                }
                else
                {
                    OperateResult.AppendText(">>序列号" + code.Text + "不存在\n", Color.Red, code);
                    code.Text = "";
                    sn_code.Text = "";
                }
            }
            else OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
        }

        private void GetItem()
        {
            //单独用一个DataTable存储一个
            dt1 = new DataTable();
            sql.Clear();
            sql.Append("select max(sptype)sptype,case when spr_isreplace=-1 then to_char(spr_isreplace) else sp_fsoncode end A,SP_ID, max(sp_rate)sp_rate,replace(wm_concat(sp_fsoncode),',','?')sp_fsoncode,replace(wm_concat(sp_prefix),',','?')sp_prefix,max(pr_lightbox)pr_lightbox,replace(wm_concat(nvl(sp_subnum,0)),',','?')sp_subnum,replace(wm_concat(nvl(sp_subnumlength,0)),',','?')sp_subnumlength,max(sp_detno)sp_detno,min(sp_ifrepeat)sp_ifrepeat,max(sp_checkbarcode)sp_checkbarcode,min(sp_checksalecode)sp_checksalecode,max(sp_barcoderule)sp_barcoderule,replace(wm_concat(sp_sntype),',','?')sp_sntype,wm_concat(sp_soncode) sp_soncode,max(sp_ifuseregex)sp_ifuseregex,max(sp_ifforsn)sp_ifforsn,replace(wm_concat(sp_length),',','?')sp_length,max(sp_type)sp_type,max(sp_regex)sp_regex,max(pr_detail)pr_detail,max(substr(pr_spec,0,20))pr_spec from(");
            sql.Append("select '主料' sptype,0 spr_id,-1 spr_isreplace,max(sp_rate)sp_rate,max(pr_lightbox)pr_lightbox,sp_id,max(nvl(sp_subnum,0))sp_subnum,max(nvl(sp_subnumlength,0))sp_subnumlength,max(sp_detno)sp_detno,min(sp_ifrepeat)sp_ifrepeat,max(sp_checkbarcode)sp_checkbarcode,min(sp_checksalecode)sp_checksalecode,");
            sql.Append("sp_fsoncode,max(sp_barcoderule)sp_barcoderule,max(nvl(sp_sntype,'原厂'))sp_sntype,wm_concat(sp_soncode) sp_soncode,max(sp_ifuseregex)sp_ifuseregex,max(sp_ifforsn)");
            sql.Append("sp_ifforsn,max(sp_length)sp_length,max(sp_type)sp_type,replace(wm_concat(sp_prefix),',','|')sp_prefix,max(sp_regex)");
            sql.Append("sp_regex,max(pr_detail)pr_detail,max(substr(pr_spec,0,20))pr_spec from stepproduct left join product on pr_code=sp_fsoncode where ");
            sql.Append("sp_bomversion='" + ms_bomversion.Text + "' and sp_craftcode='" + ms_craftcode.Text + "' and sp_stepcode='" + User.CurrentStepCode + "' ");
            sql.Append("And sp_mothercode ='" + ma_prodcode.Text + "' and sp_tracekind=1 and not exists(select 1 from craftmaterial where ");
            sql.Append("cm_sncode in (select '" + ms_firstsn + "' from dual union select sn from makesnrelation where firstsn='" + ms_firstsn + "') and cm_makecode='" + ma_code.Text + "' and cm_fsoncode=");
            sql.Append("sp_fsoncode and cm_status=0 and cm_stepcode=sp_stepcode) group by sp_fsoncode,sp_id union ");
            sql.Append("select '替代' sptype,spr_id,max(spr_isreplace),max(spr_rate)spr_rate,max(pr_lightbox)pr_lightbox,spr_spid,max(nvl(spr_subnum,0))spr_subnum,max(nvl(spr_subnumlength,0))spr_subnumlength,max(spr_detno)spr_detno,min(spr_ifrepeat)spr_ifrepeat,max(spr_checkbarcode)spr_checkbarcode,min(spr_checksalecode)spr_checksalecode,");
            sql.Append("spr_fsoncode,max(spr_barcoderule)spr_barcoderule,max(nvl(spr_sntype,'原厂'))spr_sntype,wm_concat(spr_soncode) spr_soncode,max(spr_ifuseregex)spr_ifuseregex,max(spr_ifforsn)");
            sql.Append("spr_ifforsn,max(spr_length)spr_length,max(spr_type)spr_type,replace(wm_concat(spr_prefix),',','|')spr_prefix,max(spr_regex)");
            sql.Append("spr_regex,max(pr_detail)pr_detail,max(substr(pr_spec,0,20))pr_spec from stepproductrep left join product on pr_code=spr_fsoncode where ");
            sql.Append("spr_bomversion='" + ms_bomversion.Text + "' and spr_craftcode='" + ms_craftcode.Text + "' and spr_stepcode='" + User.CurrentStepCode + "' ");
            sql.Append("And spr_mothercode ='" + ma_prodcode.Text + "' and spr_tracekind=1 and not exists(select 1 from craftmaterial where ");
            sql.Append("cm_sncode in (select '" + ms_firstsn + "' from dual union select sn from makesnrelation where firstsn='" + ms_firstsn + "') and cm_makecode='" + ma_code.Text + "' and cm_fsoncode=");
            sql.Append("spr_fsoncode and cm_status=0 and cm_stepcode=spr_stepcode) group by spr_fsoncode,spr_id,spr_spid ");
            sql.Append(") group by sp_sntype,case when spr_isreplace=-1 then to_char(spr_isreplace) else sp_fsoncode end,sp_id order by sp_id");
            dt1 = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
            code.Clear();
            //用于记录提醒的数据长度
            RemainList = new string[dt1.Rows.Count];
            for (int i = 0; i < dt1.Rows.Count; i++)
            {
                string soncode = dt1.Rows[i]["sp_soncode"].ToString();
                string prdetail = dt1.Rows[i]["pr_detail"].ToString();
                string pr_lightbox = dt1.Rows[i]["pr_lightbox"].ToString();
                if (port.IsOpen)
                {
                    byte[] t = new byte[2];
                    t[0] = 0x00;
                    switch (pr_lightbox)
                    {
                        case "01":
                            t[1] = 0X01;
                            break;
                        case "02":
                            t[1] = 0X02;
                            break;
                        case "03":
                            t[1] = 0X03;
                            break;
                        case "04":
                            t[1] = 0X04;
                            break;
                        case "05":
                            t[1] = 0X05;
                            break;
                        case "06":
                            t[1] = 0X06;
                            break;
                        case "07":
                            t[1] = 0X07;
                            break;
                        case "08":
                            t[1] = 0X08;
                            break;
                        case "09":
                            t[1] = 0X09;
                            break;
                        case "10":
                            t[1] = 0X10;
                            break;
                        case "11":
                            t[1] = 0X11;
                            break;
                        case "0A":
                            t[1] = 0X0A;
                            break;
                        case "12":
                            t[1] = 0X12;
                            break;
                        case "13":
                            t[1] = 0X13;
                            break;
                        case "14":
                            t[1] = 0X14;
                            break;
                        case "15":
                            t[1] = 0X15;
                            break;
                        case "16":
                            t[1] = 0X16;
                            break;
                        case "17":
                            t[1] = 0X17;
                            break;
                        case "18":
                            t[1] = 0X18;
                            break;
                        case "19":
                            t[1] = 0X19;
                            break;
                        case "1A":
                            t[1] = 0X1A;
                            break;
                        case "1B":
                            t[1] = 0X1B;
                            break;
                        default:
                            break;
                    }
                    port.Write(t, 0, 2);
                }
                RemainList[i] = soncode + "(" + prdetail + ")";
            }
            if (dt1.Rows.Count > 0)
            {
                try
                {
                    string soncode = dt1.Rows[RemainIndex]["sp_soncode"].ToString();
                    string prdetail = dt1.Rows[RemainIndex]["pr_detail"].ToString();
                    OperateResult.AppendText("<<请采集" + soncode + "(" + prdetail + ")的物料数据\n", Color.Black);
                }
                catch (Exception)
                {
                    OperateResult.AppendText(">>序列号" + sn_code.Text + "上料采集完成！\n", Color.Green);
                    code.Text = "";
                    sn_code.Text = "";
                }
            }
            else
            {
                OperateResult.AppendText(">>序列号" + sn_code.Text + "不在本道工序，请采集其它序列号\n", Color.Red);
                if (!LogicHandler.SetStepResult(ma_code.Text, User.UserSourceCode, sn_code.Text, "上料采集", "上料成功", User.UserCode, out ErrorMessage))
                    OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red);
                else
                {
                    //提示正确返回时传递的信息
                    if (ErrorMessage.Contains("AFTERSUCCESS"))
                        OperateResult.AppendText(">>" + ErrorMessage + "\n");
                    OperateResult.AppendText(">>序列号" + sn_code.Text + "采集成功！\n", Color.Green);
                }
                code.Text = "";
                sn_code.Text = "";
            }
        }

        //此类中通用的保存逻辑
        private void Save_OtherCode(string sp_fsoncode, string sp_soncode, string ma_code, string ms_sncode, string sp_id, string resultstr, string userate, string subfix, string spsntype)
        {
            LogicHandler.CheckBarcode(ma_code, ms_sncode, code.Text, resultstr, Tag.ToString());
            CollectDataSonCode.Add(sp_fsoncode);
            //采集成功提示
            ResultStr.Add(resultstr);
            ReturnUseRate.Add(userate);
            ReturnSubFix.Add(subfix);
            CollectData.Add(code.Text);
            SpSNType.Add(spsntype);
            if (!CheckBarcode.ContainsKey(sp_fsoncode))
            {
                CheckBarcode.Add(sp_fsoncode, code.Text);
            }
            SPID.Add(sp_id);
            OperateResult.AppendText(">>物料" + sp_soncode + "采集成功,条码" + code.Text + "\n", Color.Green);
            LabelDataGridView.Rows[RemainIndex].Cells["BarCode"].Value = code.Text;
            if (code.Text.Length > 80)
                OperateResult.AppendText(">>采集条码" + code.Text + "程度超过长度限制80，内容截取前80位进行采集\n", Color.Red);
            code.Clear();
            RemainIndex = RemainIndex + 1;
            //如果+1后不小于B序列的长度，则已采集完成，不需要进行提示了
            if (RemainIndex < RemainList.Length)
            {
                OperateResult.AppendText("<<请采集" + RemainList[RemainIndex] + "的物料数据\n", Color.Black);
            }
            else
            {
                sql.Clear();
                sql.Append("insert into Craftmaterial (cm_id ,cm_prodtype,cm_makecode,cm_maid,cm_maprodcode, cm_soncode, cm_mscode, cm_sncode, cm_stepcode, cm_stepname,cm_fsoncode,");
                sql.Append("cm_craftcode,cm_craftname,cm_barcode,cm_inqty,cm_indate,cm_inman,cm_linecode,cm_wccode,cm_sourcecode,cm_spid,cm_status,cm_materialtype,cm_firstsn,cm_substr,cm_subfix,cm_rate,cm_type)");
                sql.Append("select Craftmaterial_seq.nextval,sp_prodtype, ma_code, ma_id, ma_prodcode,:soncode,ms_code,ms_sncode,mcd_stepcode,");
                sql.Append("mcd_stepname,sp_fsoncode,ms_craftcode,ms_craftname,:barcode,1,sysdate,'" + User.UserCode + "','" + User.UserLineCode + "',ma_wccode,");
                sql.Append("'" + User.UserSourceCode + "',:sp_id,0,1,ms_firstsn,:substr,:subfix,:rate,:sptype from make left join makecraftdetail on mcd_maid=ma_id  left join stepproduct on sp_stepcode=mcd_stepcode ");
                sql.Append(" and sp_mothercode = ma_prodcode left join makeserial on ms_makecode=ma_code and sp_craftcode=ms_craftcode ");
                sql.Append("where ma_code='" + make_code + "'and sp_id=:sp_id1 and mcd_stepcode = '" + User.CurrentStepCode + "' and ms_sncode='" + ms_sncode + "'");
                dh.BatchInsert(sql.GetString(), new string[] { "soncode", "barcode", "sp_id", "substr", "subfix", "rate", "sptype", "sp_id1", }, CollectDataSonCode.ToArray(), CollectData.ToArray(), SPID.ToArray(), ResultStr.ToArray(), ReturnSubFix.ToArray(), ReturnUseRate.ToArray(), SpSNType.ToArray(), SPID.ToArray());
                try
                {
                    string Log = "";
                    for (int i = 0; i < CollectDataSonCode.Count; i++)
                    {
                        Log += CollectDataSonCode.ToArray()[i] + " " + CollectData.ToArray()[i] + " " + SPID.ToArray()[i];
                    }
                    LogManager.DoLog(Log);
                }
                catch (Exception)
                {

                }
                //更新序列号半成品已被使用
                dh.BatchInsert("update makeserial set ms_nextmacode='" + ma_code + "' where ms_id=(select max(ms_id) from makeserial where ms_sncode=:sncode and ms_nextmacode is null and ms_makecode<>'" + ma_code + "')", new string[] { "sncode" }, TSN.ToArray());
                if (ma_ecncode_label.Checked || ma_softversion_label.Checked)
                {
                    string ecnText = ma_ecncode_label.Checked ? ma_ecncode.Text : "";
                    string softversionText = ma_softversion_label.Checked ? ma_softversion.Text : "";
                    string remark = sir_remark_label.Checked ? sir_remark.Text : "";
                    sql.Clear();
                    sql.Append("insert into SNRELATIONINFORECORD(SIR_ID,SIR_SNCODE,SIR_MSCODE,SIR_ECNCODE,SIR_SOFTVER,");
                    sql.Append("SIR_LINECODE,SIR_SOURCECODE,SIR_STEPCODE,SIR_MACODE,SIR_PRODCODE,SIR_INMAN,SIR_INDATE,sir_firstsn,sir_remark) select ");
                    sql.Append("SNRELATIONINFORECORD_SEQ.nextval,'" + sn_code.Text + "',ms_code,'" + ecnText + "','" + softversionText + "',");
                    sql.Append("'" + User.UserLineCode + "','" + User.UserSourceCode + "','" + User.CurrentStepCode + "','" + ma_code + "','" + ma_prodcode.Text + "',");
                    sql.Append("'" + User.UserCode + "',sysdate,ms_firstsn,'" + remark + "' from makeserial where ms_sncode='" + sn_code.Text + "' and ms_makecode='" + ma_code + "'");
                    dh.ExecuteSql(sql.GetString(), "insert");
                }
                CollectData.Clear();
                TSN.Clear();
                SPID.Clear();
                ReturnUseRate.Clear();
                ReturnSubFix.Clear();
                SpSNType.Clear();
                ResultStr.Clear();
                CheckBarcode.Clear();
                CollectDataSonCode.Clear();
                //采集成功，设置序列号栏目为空
                RemainIndex = 0;
                OperateResult.AppendText(">>序列号" + sn_code.Text + "上料采集完成！\n", Color.Green);
                LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, oMakeCode, User.UserLineCode, User.UserSourceCode, "上料采集", "上料成功", sn_code.Text, "");
                if (LogicHandler.SetStepResult(ma_code, User.UserSourceCode, sn_code.Text, "上料采集", "上料成功", User.UserCode, out ErrorMessage))
                {
                    if (port.IsOpen)
                    {
                        byte[] t = new byte[2];
                        t[0] = 0X00;
                        t[1] = 0XFF;
                        port.Write(t, 0, 2);
                    }
                    //提示正确返回时传递的信息
                    if (ErrorMessage.Contains("AFTERSUCCESS"))
                        OperateResult.AppendText(">>" + ErrorMessage + "\n");
                    sn_code.Text = "";
                    //刷新数据
                    EventArgs e = new EventArgs();
                    object sender = null;
                    ma_code_UserControlTextChanged(sender, e);
                }
                else
                {
                    OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
                }
            }
        }

        private void ClearSn_code_Click(object sender, EventArgs e)
        {
            sn_code.Clear();
            SPID.Clear();
            TSN.Clear();
            CheckBarcode.Clear();
            ReturnUseRate.Clear();
            ReturnSubFix.Clear();
            SpSNType.Clear();
            ResultStr.Clear();
            CollectData.Clear();
            CollectDataSonCode.Clear();
            if (dt1 != null)
                BaseUtil.CleanDataTableData(dt1);
            RemainIndex = 0;
            BaseUtil.CleanDGVData(LabelDataGridView);
            OperateResult.AppendText(">>请采集序列号\n", Color.Black);
        }

        private void ma_code_UserControlTextChanged(object sender, EventArgs e)
        {
            if (ma_code.Text.Length > 5)
            {
                string ErrMessage = "";
                if (LogicHandler.CheckMakeStatus(ma_code.Text, out ErrMessage))
                {
                    mcd_inqty.Text = "";
                    mcd_remainqty.Text = "";
                    sql.Clear();
                    sql.Append("select mcd_inqty,ma_qty-mcd_inqty mcd_remainqty ");
                    sql.Append("from make left join makecraftdetail_view on mcd_macode=ma_code where ");
                    sql.Append("ma_code='" + ma_code.Text + "' and mcd_stepcode='" + User.CurrentStepCode + "'");
                    DataTable dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                    if (dt.Rows.Count > 0)
                        BaseUtil.SetFormValue(Controls, dt);
                }
            }
        }
        SerialPort port = new SerialPort();

        private void OpenPort_Click(object sender, EventArgs e)
        {
            port.PortName = serialPortCombox1.Text;
            port.BaudRate = 9600;
            port.Open();
            OperateResult.AppendText(">>串口打开成功\n");
        }

        private void ma_prodcode_TextChanged(object sender, EventArgs e)
        {
            code.Str = ma_prodcode.Text;
        }
    }
}