mes-client/UAS-MES/FunctionCode/Make/Make_FeedingCollection.cs

using System;
using System.Data;
using System.Text;
using System.Windows.Forms;
using UAS_MES.CustomControl.TextBoxWithIcon;
using UAS_MES.DataOperate;
using UAS_MES.Entity;
using UAS_MES.PublicMethod;
using System.Drawing;
using System.Text.RegularExpressions;
using System.Collections.Generic;

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

        //用于提醒的序列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> CollectDataSonCode = new List<string>();

        public Make_FeedingCollection()
        {
            InitializeComponent();
        }

        private void 上料采集_Load(object sender, EventArgs e)
        {
            code.Focus();
            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_detail # 产品名称,ma_bomversion # Bom版本";
            ma_code.FormName = Name;
            ma_code.DBTitle = "工单查询";
            ma_code.SetValueField = new string[] { "ma_code", "ma_prodcode", "ma_qty", "pr_detail", "ma_craftcode", "ma_bomversion" };
            ma_code.Condition = "ma_statuscode='STARTED'";
            ma_code.DbChange += Ma_code_DBChange;
            dh = new DataHelper();
        }

        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 sb_bomversion='" + ma_bomversion.Text + "' order by sp_detno").ToString();
            if (ifforsn != "" && ifforsn != "0")
                iflastsn.Checked = true;
            else
                iflastsn.Checked = false;
        }

        private void 上料采集_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 != "" && ma_code.Text != "" && sn_code.Text == "")
                        {
                            //根据序列号查出ma_code,ma_prodcode,stepcode
                            GetCollectItem();
                        }
                        //输入框有值但未选择工单号
                        else if (code.Text != "" && ma_code.Text == "" && sn_code.Text == "")
                            GetCollectItem();
                        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_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_ifforsn = dt1.Rows[RemainIndex]["sp_ifforsn"].ToString();
                            string sp_tracekind = dt1.Rows[RemainIndex]["sp_tracekind"].ToString();
                            string sp_barcoderule = dt1.Rows[RemainIndex]["sp_barcoderule"].ToString();
                            if (LogicHandler.CheckSNBeforeLoad(oMakeCode, code.Text, sp_soncode, sp_barcoderule, sp_prefix, length, out ErrorMessage))
                                Save_OtherCode(sp_soncode, make_code, sn_code.Text, sp_id);
                            else
                                OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, code);
                        }
                    }
                    //勾选了下料的时候
                    else if (UnLoading.Checked)
                    {
                        if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, code.Text, User.UserCode, out oMakeCode, out oMsid, out ErrorMessage))
                        {
                            dt = (DataTable)dh.ExecuteSql("select ms_firstsn,cm_makecode,cm_craftcode,nvl(cm_status,0)cm_status,cm_id,cm_stepcode,ms_makecode,cm_mccode,cm_materialtype from craftmaterial left join makeserial on cm_makecode=ms_makecode and cm_sncode=ms_sncode where ms_sncode='" + code.Text + "' and cm_makecode='" + ma_code.Text + "'", "select");
                            if (dt.Rows.Count > 0)
                            {
                                string ms_macode = dt.Rows[0]["ms_makecode"].ToString();
                                string ms_firstsn = dt.Rows[0]["ms_firstsn"].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("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 = '" + ma_code.Text + "' ");
                                sql.Append("and cm_status = 0 and cm_stepcode='" + User.CurrentStepCode + "'");
                                dh.ExecuteSql(sql.GetString(), "delete");
                                LogicHandler.InsertMakeProcess(ms_macode, code.Text, User.UserSourceCode, "上料采集操作", "下料成功", User.UserCode);
                                int count = dh.getRowCount("craftMaterial", "cm_mccode='" + cm_mccode + "' and cm_stepcode='" + cm_stepcode + "' and cm_sncode='" + code.Text + "'");
                                if (count == 0)
                                    dh.UpdateByCondition("makecraftdetail ", "mcd_inqty=mcd_inqty-1,mcd_outqty=mcd_outqty-1,mcd_okqty = mcd_okqty - 1", "mcd_mccode='" + cm_mccode + "' and mcd_stepcode='" + cm_stepcode + "'");
                                //清除已被使用的序列号
                                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_stepcode='" + cm_stepcode + "' and cm_craftcode='" + cm_craftcode + "' ");
                                sql.Append("and cm_materialtype=1 and nvl(cm_status,0) =0) and ms_nextmacode='" + ma_code.Text + "'");
                                dh.ExecuteSql(sql.GetString(), "update");
                                LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, ma_code.Text, 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()
        {
            if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, code.Text, User.UserCode, out oMakeCode, out oMsid, out ErrorMessage))
            {
                //将录入框的值给序列号
                sn_code.Text = code.Text;
                sql.Clear();
                sql.Append("select ma_prodcode,ms_firstsn,ma_craftcode,ma_bomversion,ma_qty,ma_code,pr_detail,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();
                    ms_craftcode = dt.Rows[0]["ms_craftcode"].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_firstsn = dt.Rows[0]["ms_firstsn"].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_craftcode='" + ma_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 (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 ms_craftcode = "";
                        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();
                            ms_craftcode = dt.Rows[0]["ms_craftcode"].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='" + ma_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_sncode='" + code.Text + "'"))
                                    {
                                        CollectDataSonCode.Add(sp_soncode);
                                        CollectData.Add(code.Text);
                                        sn_code.Text = code.Text;
                                        OperateResult.AppendText(">>序列号" + code.Text + ",物料" + sp_soncode + "上料成功\n", Color.Green);
                                        RemainIndex = RemainIndex + 1;
                                        GetItem();
                                        return;
                                    }
                                    else OperateResult.AppendText(">>序列号" + code.Text + "已经上料\n", Color.Red, code);
                                }
                                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_prodcode,pr_detail,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_sncode='" + sn_code.Text + "'");
                        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 sp_id,sp_tracekind,sp_barcoderule,sp_ifuseregex,sp_ifforsn,sp_length,sp_soncode,sp_repcode");
            sql.Append(",pr_id,sp_type,sp_prefix,sp_regex from stepproduct left join product on pr_code=sp_soncode where ");
            sql.Append("sp_bomversion='" + mabomversion + "' and sp_craftcode='" + ms_craftcode + "' and sp_stepcode='" + User.CurrentStepCode + "'");
            sql.Append("And sp_mothercode ='" + make_prodcode + "' and((sp_type = '物料' and( sp_tracekind <> 2 or sp_tracekind is null))or sp_type <> '物料')");
            sql.Append("and not exists(select 1 from craftmaterial where (cm_sncode='" + ms_firstsn + "' or cm_sncode in (select sn from makesnrelation where firstsn='" + ms_firstsn + "')) and cm_makecode='" + ma_code.Text + "' and cm_soncode=");
            sql.Append("sp_soncode and cm_status=0) order by SP_DETNO asc");
            dt1 = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
            code.Clear();
            //用于记录提醒的数据长度
            RemainList = new string[dt1.Rows.Count];
            for (int i = 0; i < dt1.Rows.Count; i++)
                RemainList[i] = dt1.Rows[i]["sp_soncode"].ToString();
            if (dt1.Rows.Count > 0)
            {
                try
                {
                    CollectDataSonCode.Add(dt1.Rows[RemainIndex]["sp_soncode"].ToString());
                    OperateResult.AppendText("<<请采集" + dt1.Rows[RemainIndex]["sp_soncode"].ToString() + "的" + dt1.Rows[RemainIndex]["sp_type"].ToString() + "数据\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
                    OperateResult.AppendText(">>序列号" + sn_code.Text + "采集成功！\n", Color.Green);
                code.Text = "";
                sn_code.Text = "";
            }
        }

        //此类中通用的保存逻辑
        private void Save_OtherCode(string sp_soncode, string ma_code, string ms_sncode, string sp_id)
        {
            //采集成功提示
            RemainIndex = RemainIndex + 1;
            OperateResult.SelectionColor = Color.Green;
            CollectData.Add(code.Text);
            OperateResult.AppendText(">>物料" + sp_soncode + "采集成功\n");
            code.Clear();
            //如果+1后不小于B序列的长度，则已采集完成，不需要进行提示了
            if (RemainIndex < RemainList.Length)
            {
                CollectDataSonCode.Add(dt1.Rows[RemainIndex]["sp_soncode"].ToString());
                OperateResult.AppendText("<<请采集" + RemainList[RemainIndex] + "的" + dt1.Rows[RemainIndex]["sp_type"].ToString() + "数据\n", Color.Black);
            }
            else
            {
                sql.Clear();
                sql.Append("insert into Craftmaterial (cm_id ,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)");
                sql.Append("select Craftmaterial_seq.nextval, ma_code, ma_id, ma_prodcode,:soncode,ms_code,ms_sncode,mcd_stepcode,");
                sql.Append("mcd_stepname,sp_fsoncode,ma_craftcode,ma_craftname,:barcode,1,sysdate,'" + User.UserCode + "',ma_linecode,ma_wccode,");
                sql.Append("'" + User.UserSourceCode + "','" + sp_id + "',0,1,ms_firstsn from make left join makecraftdetail on mcd_macode=ma_code  left join stepproduct on sp_stepcode=mcd_stepcode ");
                sql.Append("and sp_craftcode=ma_craftcode and sp_mothercode = ma_prodcode left join makeserial on ms_makecode=ma_code ");
                sql.Append("where ma_code='" + make_code + "'and sp_id=" + sp_id + " and mcd_stepcode = '" + User.CurrentStepCode + "' and ms_sncode='" + ms_sncode + "'");
                dh.BatchInsert(sql.GetString(), new string[] { "soncode", "barcode" }, CollectDataSonCode.ToArray(), CollectData.ToArray());
                if (ecn_label.Checked || softwareversion_label.Checked)
                {
                    string ecnText = ecn_label.Checked ? ecn.Text : "";
                    string softversionText = softwareversion_label.Checked ? softwareversion.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) 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 from makeserial where ms_sncode='" + sn_code.Text + "' and ms_makecode='" + ma_code + "'");
                    dh.ExecuteSql(sql.GetString(), "insert");
                }
                CollectData.Clear();
                CollectDataSonCode.Clear();
                //采集成功，设置序列号栏目为空
                RemainIndex = 0;
                OperateResult.AppendText(">>上料采集完成！\n", Color.Green);
                if (LogicHandler.SetStepResult(ma_code, User.UserSourceCode, sn_code.Text, "上料采集", "上料成功", User.UserCode, out ErrorMessage))
                {
                    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();
            CollectData.Clear();
            CollectDataSonCode.Clear();
            if (dt1 != null)
                BaseUtil.CleanDataTableData(dt1);
            RemainIndex = 0;
            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 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);
                }
            }
        }
    }
}