mes-client/UAS_MES_YDCY/FunctionCode/OQC/OQC_PlanMaintain_Cust.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using UAS_MES_NEW.DataOperate;
using UAS_MES_NEW.Entity;
using UAS_MES_NEW.PublicMethod;

namespace UAS_MES_NEW.OQC
{
    public partial class OQC_PlanMaintain_Cust : Form
    {
        AutoSizeFormClass asc = new AutoSizeFormClass();
        LogStringBuilder sql = new LogStringBuilder();
        DataTable dt;
        DataHelper dh;
        string ErrorMessage = "";
        DataTable Dbfind;
        public OQC_PlanMaintain_Cust()
        {
            InitializeComponent();
        }

        string pcd_okretuenstep = "";
        string pcd_ngretuenstep = "";

        private void 抽样计划维护_Load(object sender, EventArgs e)
        {
            asc.controllInitializeSize(this);
            dh = SystemInf.dh;
            pr_code.TableName = "QUA_Project";
            pr_code.SelectField = "pr_code # 方案编号,pr_name # 方案名称,pr_class # 检验单类型,pr_standard # 方案标准,pr_startdate # 生效日期,pr_enddate #失效日期 ,pr_status # 状态";
            pr_code.SetValueField = new string[] { "pr_code" };
            pr_code.FormName = Name;
            pr_code.DbChange += Pr_code_DbChange;
            GoodProduct.Checked = true;
            ChooseAll.ChooseAll(CheckTypeDGV);
        }


        private void Pr_code_DbChange(object sender, EventArgs e)
        {
            Dbfind = pr_code.ReturnData;
            BaseUtil.SetFormValue(this.Controls, Dbfind);
        }

        private void 抽样计划维护_SizeChanged(object sender, EventArgs e)
        {
            asc.controlAutoSize(this);
        }

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


        private void ob_projectcode_UserControlTextChanged(object sender, EventArgs e)
        {
            sql.Clear();
            sql.Append("select pd_itemname from QUA_PROJECT left join ");
            sql.Append(" QUA_ProjectDetail on pd_prid=pr_id  left join QUA_CheckItem on pd_ciid=ci_id ");
            sql.Append(" where pr_code='" + pr_code.Text + "'");
            DataTable dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
            BaseUtil.FillDgvWithDataTable(CheckTypeDGV, dt);
        }

        private void OQC_PlanMaintain_FormClosing(object sender, FormClosingEventArgs e)
        {
            dh.Dispose();
        }

        string oMakeCode = "";
        string oMSID = "";
        string ms_stepcode = "";
        string ms_ifqccheck = "";
        string cd_steptype = "";
        private void ms_sncode_KeyDown(object sender, KeyEventArgs e)
        {
            if (Keys.Enter == e.KeyCode)
            {
                if (oMakeCode == "null")
                {
                    oMakeCode = "";
                }
                if (LogicHandler.CheckStepSNAndMacode(oMakeCode, User.UserSourceCode, ms_sncode.Text, User.UserCode, out oMakeCode, out oMSID, out ErrorMessage))
                {
                    DataTable dt = (DataTable)dh.ExecuteSql("select nvl(MS_IFQCCHECK,0)MS_IFQCCHECK,ms_stepcode,pr_detail,pr_spec,ms_prodcode,PR_QUALMETHOD,ms_craftcode,cd_steptype from makeserial "
                        + " left join product on pr_code=ms_prodcode"
                        + " left join craft on cr_code=ms_craftcode and cr_prodcode=ms_prodcode"
                        + " left join craftdetail on cd_crid=cr_id and cd_stepcode=ms_stepcode"
                        + " where ms_id='" + oMSID + "'", "select");
                    if (dt.Rows.Count > 0)
                    {
                        ms_stepcode = dt.Rows[0]["ms_stepcode"].ToString();
                        ms_ifqccheck = dt.Rows[0]["MS_IFQCCHECK"].ToString();
                        ms_prodcode.Text = dt.Rows[0]["ms_prodcode"].ToString();
                        pr_detail.Text = dt.Rows[0]["pr_detail"].ToString();
                        pr_code.Text = dt.Rows[0]["PR_QUALMETHOD"].ToString();
                        //工序类型:按 产品编号+工艺路线编号+当前工序 到 craftdetail 取
                        cd_steptype = dt.Rows[0]["cd_steptype"].ToString();
                        if (ms_ifqccheck == "0")
                        {
                            OperateResult.AppendText(">>非客户QC抽检序列号，不允许采集\n", Color.Red);
                            return;
                        }
                    }
                    //取抽样计划明细:优先按工序类型匹配,匹配不到退回原逻辑
                    GetProductCheckRate();
                }
                else
                {
                    OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red);
                }
                ms_sncode.SelectAll();
            }
        }

        /// <summary>
        /// 取抽样计划明细(检验方案/客户检验方案/OK回退工序/NG回退工序)
        /// 取值优先级:
        ///   ① 先按「产品编号 + 当前工序 + 工序类型(pcd_steptype=cd_steptype)」匹配
        ///   ② 匹配不到时去掉工序类型条件,退回按「产品编号 + 当前工序」匹配(即原有逻辑)
        /// 注意:若 cd_steptype 本身取不到(工艺未配置),第①步自动跳过,直接走原有逻辑;
        ///      调用前需保证 ms_prodcode.Text / ms_stepcode / cd_steptype 已赋值。
        /// </summary>
        private void GetProductCheckRate()
        {
            DataTable dtRate = null;
            //①优先按工序类型匹配
            if (cd_steptype != "")
            {
                dtRate = (DataTable)dh.ExecuteSql("select pcd_qualmethod,pcd_custqualmethod,pcd_okretuenstep,pcd_ngretuenstep from productcheckrate left join PRODUCTCHECKRATEDETAIL on pcd_pcrid=pcr_id where pcr_prodcode='" + ms_prodcode.Text + "' and   pcd_steptype='" + cd_steptype + "'", "select");
            }
            //②工序类型下没有数据,退回原有逻辑(不加 pcd_steptype 条件)
            if (dtRate == null || dtRate.Rows.Count == 0)
            {
                dtRate = (DataTable)dh.ExecuteSql("select pcd_qualmethod,pcd_custqualmethod,pcd_okretuenstep,pcd_ngretuenstep from productcheckrate left join PRODUCTCHECKRATEDETAIL on pcd_pcrid=pcr_id where pcr_prodcode='" + ms_prodcode.Text + "' and pcd_stepcode='" + ms_stepcode + "'", "select");
            }
            if (dtRate.Rows.Count > 0)
            {
                if (ms_ifqccheck == "-1")
                {
                    pr_code.Text = dtRate.Rows[0]["pcd_qualmethod"].ToString();
                }
                if (ms_ifqccheck == "-2")
                {
                    pr_code.Text = dtRate.Rows[0]["pcd_custqualmethod"].ToString();
                    pcd_okretuenstep = dtRate.Rows[0]["pcd_okretuenstep"].ToString();
                    pcd_ngretuenstep = dtRate.Rows[0]["pcd_ngretuenstep"].ToString();
                }
            }
        }

        private void SaveData_Click(object sender, EventArgs e)
        {
            if (LogicHandler.CheckStepSNAndMacode(oMakeCode, User.UserSourceCode, ms_sncode.Text, User.UserCode, out oMakeCode, out oMSID, out ErrorMessage))
            {
                DataTable dt = (DataTable)dh.ExecuteSql("select nvl(MS_IFQCCHECK,0)MS_IFQCCHECK,pr_detail,pr_spec,ms_stepcode,ms_prodcode,PR_QUALMETHOD,ms_craftcode,cd_steptype from makeserial "
                    + " left join product on pr_code=ms_prodcode"
                    + " left join craft on cr_code=ms_craftcode and cr_prodcode=ms_prodcode"
                    + " left join craftdetail on cd_crid=cr_id and cd_stepcode=ms_stepcode"
                    + " where ms_id='" + oMSID + "'", "select");
                if (dt.Rows.Count > 0)
                {
                    string ms_ifqccheck = dt.Rows[0]["MS_IFQCCHECK"].ToString();
                    ms_stepcode = dt.Rows[0]["ms_stepcode"].ToString();
                    ms_prodcode.Text = dt.Rows[0]["ms_prodcode"].ToString();
                    pr_detail.Text = dt.Rows[0]["pr_detail"].ToString();
                    //工序类型:按 产品编号+工艺路线编号+当前工序 到 craftdetail 取
                    cd_steptype = dt.Rows[0]["cd_steptype"].ToString();
                    if (ms_ifqccheck == "0")
                    {
                        OperateResult.AppendText(">>非QC抽检序列号，不允许采集\n", Color.Red);
                        return;
                    }
                }
                //取抽样计划明细:优先按工序类型匹配,匹配不到退回原逻辑
                GetProductCheckRate();
            }
            else
            {
                OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red);
                return;
            }
            List<string> oi_itemcode_insert = new List<string>();
            List<string> ois_ifng_insert = new List<string>();
            for (int i = 0; i < CheckTypeDGV.Rows.Count; i++)
            {
                if (CheckTypeDGV.Rows[i].Cells["Choose"].FormattedValue.ToString() == "True")
                {
                    oi_itemcode_insert.Add(CheckTypeDGV.Rows[i].Cells["pd_itemname"].Value.ToString());
                    ois_ifng_insert.Add(CheckTypeDGV.Rows[i].Cells["CheckResult"].FormattedValue.ToString() == "True" ? "-1" : "0");
                }
            }
            if (oi_itemcode_insert.Count == 0)
            {
                OperateResult.AppendText(">>" + ms_sncode.Text + "必须勾选检验项目\n", Color.Green, ms_sncode);
                return;
            }
            if (GoodProduct.Checked)
            {
                sql.Clear();
                //when () then 
                sql.Append("insert into OQCItemSamples (ois_id,ois_stepcode,ois_checkno,ois_makecode, ois_sncode,ois_projectcode,ois_itemcode,");
                sql.Append("ois_ifng,ois_defectlevel,ois_remark,ois_indate)select OQCItemSamples_seq.nextval,'" + ms_stepcode + "','','" + oMakeCode + "'");
                sql.Append(",'" + ms_sncode.Text + "','" + pr_code.Text + "',:ois_itemcode,:ois_ifng,'','',sysdate from dual ");
                sql.Append("where not exists (select ois_id from OQCItemSamples where OIS_SNCODE='" + ms_sncode.Text + "' and ois_itemcode =:ois_itemcode)");
                dh.BatchInsert(sql.GetString(), new string[] { "ois_itemcode", "ois_ifng", "ois_itemcode" },
                    oi_itemcode_insert.ToArray(), ois_ifng_insert.ToArray(), oi_itemcode_insert.ToArray());
                if (ms_ifqccheck == "-2")
                {
                    sql.Clear();
                    sql.Append("select ms_craftcode  from makeserial left join craft on cr_prodcode=ms_prodcode and cr_code=ms_craftcode " +
                        " left join craftdetail on cd_crid=cr_id where ms_id='" + oMSID + "' and cd_stepcode='" + pcd_okretuenstep + "'");
                    dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                    if (dt.Rows.Count > 0)
                    {
                        string ms_craftcode = dt.Rows[0]["ms_craftcode"].ToString();
                        if (pcd_okretuenstep != "" && ms_ifqccheck == "-2")
                        {
                            string stepno = dh.getFieldDataByCondition("craft left join craftdetail on cd_crid=cr_id", "cd_stepno", "cr_prodcode='" + ms_prodcode.Text + "' and cr_code='" + ms_craftcode + "' and cd_stepcode='" + pcd_okretuenstep + "'").ToString();
                            if (stepno == "")
                            {
                                stepno = "100";
                            }
                            StringBuilder sql = new StringBuilder();
                            sql.Append("update craftmaterial set cm_status=-1,CM_DROPMAN='" + User.UserName + "' where  cm_stepcode in (select cd_stepcode from craft left join ");
                            sql.Append("craftdetail on cd_crid = cr_id where cr_prodcode = '" + ms_prodcode.Text + "'  and cd_detno >= " + stepno + ") ");
                            sql.Append("and cm_sncode='" + ms_sncode.Text + "' and cm_makecode='" + oMakeCode + "'");
                            dh.ExecuteSql(sql.ToString(), "update");
                            dh.ExecuteSql("update makeserial set MS_IFQCCHECK=0,ms_nextstepcode='" + pcd_okretuenstep + "' where ms_id='" + oMSID + "'", "select");
                        }
                        else
                        {
                            dh.ExecuteSql("update makeserial set MS_IFQCCHECK=0 where ms_id='" + oMSID + "'", "select");
                        }
                    }
                    else
                    {
                        dh.ExecuteSql("delete from makeserial where ms_id='" + oMSID + "'", "delete");
                        dh.ExecuteSql("update make set ma_inqty=ma_inqty-1 where ma_code='" + oMakeCode + "'", "update");
                        dh.ExecuteSql("update craftmaterial set cm_status=-1 where cm_sncode='" + ms_sncode.Text + "' and cm_makecode='" + oMakeCode + "'", "update");
                        dh.ExecuteSql("delete from steppassed where sp_sncode='" + ms_sncode.Text + "' and sp_makecode='" + oMakeCode + "'", "delete");
                        dh.ExecuteSql("update makecraftdetail set mcd_inqty=mcd_inqty-1,mcd_outqty=mcd_outqty-1,mcd_okqty=mcd_okqty-1 where mcd_macode='" + oMakeCode + "' and instr((select ms_paststep from makeserial where ms_id='" + oMSID + "'),mcd_stepcode)>0 ", "update");
                        dt = (DataTable)dh.ExecuteSql("select ms_id,ms_craftcode,ms_prodcode,ms_makecode from makeserial where ms_sncode='" + ms_sncode.Text + "' order by ms_id", "select");
                        if (dt.Rows.Count > 0)
                        {
                            string ms_id = dt.Rows[0]["ms_id"].ToString();
                            string ms_prodcode = dt.Rows[0]["ms_prodcode"].ToString();
                            string ms_makecode = dt.Rows[0]["ms_makecode"].ToString();
                            dh.ExecuteSql("update makeserial set ms_nextmacode='',ms_nextstepcode='" + pcd_okretuenstep + "',ms_status=1 where ms_id='" + ms_id + "'", "update");
                            string stepno = dh.getFieldDataByCondition("makeserial left join craft on cr_code=ms_craftcode and ms_prodcode=cr_prodcode left join craftdetail on cd_crid=cr_id", "cd_stepno", "ms_id='" + ms_id + "' and cd_stepcode='" + pcd_okretuenstep + "'").ToString();
                            if (stepno == "")
                            {
                                stepno = "100";
                            }
                            StringBuilder sql = new StringBuilder();
                            sql.Append("update craftmaterial set cm_status=-1,CM_DROPMAN='" + User.UserName + "' where  cm_stepcode in (select cd_stepcode from craft left join ");
                            sql.Append("craftdetail on cd_crid = cr_id where cr_prodcode = '" + ms_prodcode + "'  and cd_detno >= " + stepno + ") ");
                            sql.Append("and cm_sncode='" + ms_sncode.Text + "' and cm_makecode='" + ms_makecode + "'");
                            dh.ExecuteSql(sql.ToString(), "update");
                        }
                    }
                }
                //if (LogicHandler.SetStepResult(oMakeCode, User.UserSourceCode, ms_sncode.Text, "良品采集", "OK", User.UserCode, out ErrorMessage))
                //{
                OperateResult.AppendText(">>" + ms_sncode.Text + "良品采集成功\n", Color.Green, ms_sncode);
                LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, oMakeCode, User.UserLineCode, User.UserSourceCode, "采集良品", "采集良品成功", ms_sncode.Text, "");
                //}
                //else
                //{
                //    OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, ms_sncode);
                //}
            }
            else
            {
                //if (LogicHandler.SetStepResult(oMakeCode, User.UserSourceCode, ms_sncode.Text, "不良品采集", "NG", User.UserCode, out ErrorMessage))
                //{
                sql.Clear();
                //when () then 
                sql.Append("insert into OQCItemSamples (ois_id,ois_checkno,ois_makecode, ois_sncode,ois_projectcode,ois_itemcode,");
                sql.Append("ois_ifng,ois_defectlevel,ois_remark,ois_indate)select OQCItemSamples_seq.nextval,'','" + oMakeCode + "'");
                sql.Append(",'" + ms_sncode.Text + "','" + pr_code.Text + "',:ois_itemcode,:ois_ifng,'','',sysdate from dual ");
                sql.Append("where not exists (select ois_id from OQCItemSamples where OIS_SNCODE='" + ms_sncode.Text + "' and ois_itemcode =:ois_itemcode)");
                dh.BatchInsert(sql.GetString(), new string[] { "ois_itemcode", "ois_ifng", "ois_itemcode" },
                    oi_itemcode_insert.ToArray(), ois_ifng_insert.ToArray(), oi_itemcode_insert.ToArray());
                dh.ExecuteSql("update makeserial set MS_IFQCCHECK=0,ms_status=3,ms_nextstepcode='' where ms_id='" + oMSID + "'", "select");

                if (ms_ifqccheck == "-1")
                {
                    pcd_ngretuenstep = "";
                }

                if (ms_ifqccheck == "-2")
                {
                    sql.Clear();
                    sql.Append("select ms_craftcode  from makeserial left join craft on cr_prodcode=ms_prodcode and cr_code=ms_craftcode " +
                        " left join craftdetail on cd_crid=cr_id where ms_id='" + oMSID + "' and cd_stepcode='" + pcd_ngretuenstep + "'");
                    dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
                    if (dt.Rows.Count > 0)
                    {
                        string ms_craftcode = dt.Rows[0]["ms_craftcode"].ToString();
                        if (pcd_ngretuenstep != "")
                        {
                            string stepno = dh.getFieldDataByCondition("craft left join craftdetail on cd_crid=cr_id", "cd_stepno", "cr_prodcode='" + ms_prodcode.Text + "' and cr_code='" + ms_craftcode + "' and cd_stepcode='" + pcd_ngretuenstep + "'").ToString();
                            if (stepno == "")
                            {
                                stepno = "100";
                            }
                            StringBuilder sql = new StringBuilder();
                            sql.Append("update craftmaterial set cm_status=-1,CM_DROPMAN='" + User.UserName + "' where  cm_stepcode in (select cd_stepcode from craft left join ");
                            sql.Append("craftdetail on cd_crid = cr_id where cr_prodcode = '" + ms_prodcode.Text + "'  and cd_detno >= " + stepno + ") ");
                            sql.Append("and cm_sncode='" + ms_sncode.Text + "' and cm_makecode='" + oMakeCode + "'");
                            dh.ExecuteSql(sql.ToString(), "update");
                            dh.ExecuteSql("update makeserial set MS_IFQCCHECK=0,ms_nextstepcode='" + pcd_ngretuenstep + "' where ms_id='" + oMSID + "'", "select");
                        }
                        else
                        {
                            dh.ExecuteSql("update makeserial set MS_IFQCCHECK=0 where ms_id='" + oMSID + "'", "select");
                        }
                    }
                    else
                    {
                        dh.ExecuteSql("delete from makeserial where ms_id='" + oMSID + "'", "delete");
                        dh.ExecuteSql("update make set ma_inqty=ma_inqty-1 where ma_code='" + oMakeCode + "'", "update");
                        dh.ExecuteSql("update craftmaterial set cm_status=-1 where cm_sncode='" + ms_sncode.Text + "' and cm_makecode='" + oMakeCode + "'", "update");
                        dh.ExecuteSql("delete from steppassed where sp_sncode='" + ms_sncode.Text + "' and sp_makecode='" + oMakeCode + "'", "delete");
                        dh.ExecuteSql("update makecraftdetail set mcd_inqty=mcd_inqty-1,mcd_outqty=mcd_outqty-1,mcd_okqty=mcd_okqty-1 where mcd_macode='" + oMakeCode + "' and instr((select ms_paststep from makeserial where ms_id='" + oMSID + "'),mcd_stepcode)>0 ", "update");
                        dt = (DataTable)dh.ExecuteSql("select ms_id,ms_craftcode,ms_prodcode,ms_makecode from makeserial where ms_sncode='" + ms_sncode.Text + "' order by ms_id", "select");
                        if (dt.Rows.Count > 0)
                        {
                            string ms_id = dt.Rows[0]["ms_id"].ToString();
                            string ms_prodcode = dt.Rows[0]["ms_prodcode"].ToString();
                            string ms_makecode = dt.Rows[0]["ms_makecode"].ToString();
                            dh.ExecuteSql("update makeserial set ms_nextmacode='',ms_nextstepcode='',ms_status=3 where ms_id='" + ms_id + "'", "update");
                            string stepno = dh.getFieldDataByCondition("makeserial left join craft on cr_code=ms_craftcode and ms_prodcode=cr_prodcode left join craftdetail on cd_crid=cr_id", "cd_stepno", "ms_id='" + ms_id + "' and cd_stepcode='" + pcd_okretuenstep + "'").ToString();
                            if (stepno == "")
                            {
                                stepno = "100";
                            }
                            StringBuilder sql = new StringBuilder();
                            sql.Append("update craftmaterial set cm_status=-1,CM_DROPMAN='" + User.UserName + "' where  cm_stepcode in (select cd_stepcode from craft left join ");
                            sql.Append("craftdetail on cd_crid = cr_id where cr_prodcode = '" + ms_prodcode + "'  and cd_detno >= " + stepno + ") ");
                            sql.Append("and cm_sncode='" + ms_sncode.Text + "' and cm_makecode='" + ms_makecode + "'");
                            dh.ExecuteSql(sql.ToString(), "update");
                        }
                    }
                }
                dh.ExecuteSql("insert into makebad(MB_ID, MB_MAKECODE, MB_MSCODE, MB_SNCODE, MB_INMAN, MB_INDATE, MB_STEPCODE, MB_SOURCECODE, MB_BADCODE, MB_BGCODE, " +
                    "MB_BADNAME, MB_BGNAME, MB_YMD, MB_LINECODE, MB_TYPE, MB_RETURNSTEP)values(makebad_seq.nextval,'" + oMakeCode + "','" + ms_sncode.Text + "','" + ms_sncode.Text + "'," +
                    "'" + User.UserCode + "',sysdate,'" + ms_stepcode + "','" + User.UserSourceCode + "','CustError','CustError','客户抽检不良','客户抽检不良'," +
                    "to_char(sysdate,'yyyymmdd'),'" + User.UserLineCode + "','Client','" + pcd_ngretuenstep + "')", "insert");
                OperateResult.AppendText(">>" + ms_sncode.Text + "不良品采集成功\n", Color.Green, ms_sncode);
                LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, oMakeCode, User.UserLineCode, User.UserSourceCode, "采集不良品", "采集不良品成功", ms_sncode.Text, "");
                //}
                //else
                //{
                //    OperateResult.AppendText(">>" + ErrorMessage + "\n", Color.Red, ms_sncode);
                //}
            }
            BaseUtil.CleanDGVData(CheckTypeDGV);
            ms_prodcode.Clear();
            pr_detail.Clear();
            pr_code.Text = "";
        }
    }
}