MES_Client/TGMES/Core.StlMes.Client.Judge/Controls/AutoJudgeCtrl.cs

using Core.Mes.Client.Comm.Control;
using Core.Mes.Client.Comm.Tool;
using Core.StlMes.Client.Judge.Commons;
using CoreFS.CA06;
using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Threading;
using System.Windows.Forms;

namespace Core.StlMes.Client.Judge.Controls
{
    public partial class AutoJudgeCtrl : UserControl
    {
        private readonly Dal _d;
        private Thread _thread = null;
        public Thread Thread
        {
            get { return _thread; }
            set { _thread = value; }
        }
        
        private string customInfo;

        public string CustomInfo
        {
            get { return customInfo; }
            set { customInfo = value; }
        }
        private readonly string _userId;
        public AutoJudgeCtrl(Control container, OpeBase ob, string userId,string customerInfo)
        {
            InitializeComponent();
            _d = new Dal(ob);
            _userId = userId;
            customInfo=customerInfo;
            container.Controls.Add(this);
            this.Dock = DockStyle.Fill;
            _thread = new Thread(TaskMethod);
            _thread.Start();
            timer1.Start();
        }

        public void Quey()
        {
            try
            {
                this.TopLevelControl.Cursor = Cursors.WaitCursor;
                DataTable dt = _d.GetTableByXmlId("JdgQcmAutoJudge.get", new object[] { new string[] { customInfo } });
                GridHelper.CopyDataToDatatable(dt, dataTable1, true);
                GridHelper.RefreshAndAutoSize(ultraGrid1);
                BindDataTable2(dt.Rows[0]);
                GridHelper.RefreshAndAutoSize(ultraGrid2);
                foreach (DataRow drAuto in dt.Rows)
                {
                    DataTable dtApply;
                    string processCode = drAuto["processCode"].ToString();
                    if (processCode == "A")
                    {
                        dtApply = _d.GetTableByXmlId("QcmGpJugdeApplyDAL.QuerySteelMakingP", "", "", "", "",
                            "", 0, new string[] { }, "0", "", 0, new string[] { }, customInfo);
                    }
                    else
                    {
                        dtApply = GetTable(processCode);
                    }
                    Statistics(processCode, dtApply);
                }
            }
            finally
            {
                this.TopLevelControl.Cursor = Cursors.Default;
            }
        }

        private void BindDataTable2(DataRow dr)
        {
            dataTable2.Clear();
            DataRow newRow = dataTable2.NewRow();
            newRow["opUser"] = dr["opUser"].ToString();
            newRow["opTime"] = dr["opTime"].ToString();
            newRow["status"] = dr["status"].ToString();
            dataTable2.Rows.Add(newRow);
        }

        public void Save()
        {
            List<string> list = new List<string>();
            foreach (var row in ultraGrid1.Rows)
            {
                list.Add(JsonHelper.ToJson(row));
            }
            var result = _d.Set("com.steering.pss.judge.Bll.BllQcmAutoJudge.save", list, _userId);
            if (result.ReturnInfo.ToString2() != "")
            {
                MessageUtil.ShowWarning(result.ReturnInfo.ToString2());
                return;
            }
            MessageUtil.ShowTips("保存成功！");
        }

        private void TaskMethod()
        {
            while (_thread.IsAlive)
            {
                try
                {
                    DataTable dtAuto = _d.GetTableByXmlId("JdgQcmAutoJudge.get", new object[] { new string[] { customInfo } });
                    if (dtAuto == null)
                    {
                        Thread.Sleep(5 * 1000);
                        continue;
                    }
                    foreach (DataRow drAuto in dtAuto.Rows)
                    {
                        if (drAuto["isAuto"].ToString() == "True" && drAuto["opUserId"].ToString() != _userId) continue;
                        if (drAuto["isAuto"].ToString() != "True") continue;
                        string processCode = drAuto["processCode"].ToString();
                        if (processCode.Equals("A"))
                        {
                            LgJudge(drAuto);
                        }
                        else
                        {
                            BcJudge(drAuto, processCode);
                        }
                    }

                    int judgeCnt = 0;
                    foreach (var row in ultraGrid1.Rows)
                    {
                        if (row.GetValue("isAuto") == "True")
                        {
                            if (row.GetValue("totalCount").TryParseInt() && row.GetValue("failJudgeCount").TryParseInt())
                            {
                                judgeCnt += int.Parse(row.GetValue("totalCount")) - int.Parse(row.GetValue("failJudgeCount"));
                            }
                        }
                    }
                    if (judgeCnt == 0)
                    {
                        //懒惰模式
                        Thread.Sleep(10 * 1000);
                        Debug.WriteLine("懒惰模式10s");
                    }
                    else
                    {
                        //积极模式
                        Thread.Sleep(1000);
                        Debug.WriteLine("积极模式1s");
                    }
                }
                catch (Exception ex)
                {
                    Debug.WriteLine(ex.Message);
                    Thread.Sleep(5 * 1000);
                }
            }
        }

        private void LgJudge(DataRow drAuto)
        {
            DataTable drLgApply = _d.GetTableByXmlId("QcmGpJugdeApplyDAL.QuerySteelMakingP", "", "", "", "",
                "", 0, new string[] { }, "0", "", 0, new string[] { }, customInfo);
            Statistics("A", drLgApply);//统计
            DataRow[] drApplys = drLgApply.Select("autoJudge = '0' or autoJudge is null");
            if (drApplys.Length == 0) return;
            DataRow drApply = drApplys[0];
            string judgeApplyCode = drApply["jugdeApplyCode"].ToString();
            string judgeApplySeq = drApply["jugdeApplySqe"].ToString();
            string judgeStoveNo = drApply["judgeStoveNo"].ToString();
            string judgeMemo = drApply["judgeMemo"].ToString();
            string judgeMemo2 = drApply["judgeMemo2"].ToString();
            DataRow drAutoNew2 = _d.GetRowByXmlId("JdgQcmAutoJudge.getById", drAuto["id"].ToString());
            if (drAutoNew2["isAuto"].ToString() == "True" && drAutoNew2["opUserId"].ToString() != _userId) return;
            if (drAutoNew2["isAuto"].ToString() != "True") return;
            if (drApply["autoJudge"].ToString() == "1") return;
            //Debug.WriteLine($"{drAuto["processDesc"].ToString()} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
            _d.Set("com.steering.pss.judge.Bll.BllSteelMakingColligateJudge.JudgeSteelMaking", judgeApplyCode,
              judgeApplySeq, judgeStoveNo, "SYSTEM", "", "", judgeMemo, judgeMemo2, ((int)JudgeType.SteelMakingColligate).ToString());
            _d.Set("com.steering.pss.judge.Bll.BllSteelMakingColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo);
        }

        private void BcJudge(DataRow drAuto, string processCode)
        {
            DataTable dtApply = GetTable(processCode);
            Statistics(processCode, dtApply);//统计
            DataRow[] drApplys = dtApply.Select("autoJudge = '0' or autoJudge is null");
            if ("120504" == customInfo)
                drApplys = dtApply.Select(" (autoJudge = '0' or autoJudge is null) ");//注释and applyMemo is null
            if (drApplys.Length == 0) return;
            DataRow drApply = drApplys[0];
            string judgeApplyCode = drApply["jugdeApplyCode"].ToString();
            string judgeStoveNo = drApply["judgeStoveNo"].ToString();
            string batchNo = drApply["batchNo"].ToString();
            string memo = drApply["memo"].ToString();
            string judgeMemo = drApply["judgeMemo"].ToString();
            DataRow drAutoNew2 = _d.GetRowByXmlId("JdgQcmAutoJudge.getById", drAuto["id"].ToString());
            if (drAutoNew2["isAuto"].ToString() == "True" && drAutoNew2["opUserId"].ToString() != _userId) return;
            if (drAutoNew2["isAuto"].ToString() != "True") return;
            if (drApply["autoJudge"].ToString() == "1") return;

            DataRow drExistJudge = _d.GetRowByXmlId("QcmZgJugdeApplyDAL.existJudgeQualified", judgeApplyCode,
                    judgeStoveNo, batchNo, processCode);
            if (drExistJudge["ordLnDlyPk"].ToString() == "")
                return;
            if (drExistJudge["judgeResultCode"].ToString() == "40740701" || drExistJudge["judgeResultCode"].ToString() == "40740706"
                || drExistJudge["judgeResultCode"].ToString() == "40740707") //如果已经判定则不判。   AND T.JUDGE_RESULT_CODE IN ('40740701', '40740702')
            {
                _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
                return;
            }


            //验证是否符合取样数量
            var sampleCountResult = _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.checkSampleCount",
                judgeApplyCode, judgeStoveNo, batchNo, "0");

            var sampleCntResultFd = _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.checkSampleCount",
                judgeApplyCode, judgeStoveNo, batchNo, "1");

            //验证是否复取样，如果复取样则不自动判定
            var checkFsample = _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.checkFsample",
                judgeApplyCode, judgeStoveNo, batchNo, processCode);

            if (sampleCountResult.ReturnObject.ToString2() != "")
            {
                _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
                return;
            }
            else if (processCode == "F" && sampleCntResultFd.ReturnObject.ToString2() != "")
            {
                _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
                return;
            }
            else if (checkFsample.ReturnInfo.ToString2() != "")
            {
                _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
                return;
            }
            else if (sampleCountResult.ReturnInfo.ToString2() != "")
            {
                _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
                return;
            }

            CoreClientParam ccpDetect = _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.checkDetect", judgeApplyCode,
                    judgeStoveNo, batchNo);
            if (ccpDetect.ReturnInfo.ToString2() != "")
            {
                _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
                return;
            }
            else
            {
                if (ccpDetect.ReturnObject.ToString2() != "")
                {
                    _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
                    return;
                }
            }

            // Debug.WriteLine($"{drAuto["processDesc"].ToString()} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
            _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.judge", judgeApplyCode,
                judgeStoveNo, batchNo, processCode, "SYSTEM", "", "", memo, judgeMemo, "1", new List<string>());
            _d.Set("com.steering.pss.judge.Bll.BllRolledTubeColligateJudge.setAutoJudge", judgeApplyCode, judgeStoveNo, batchNo);
        }

        private void Statistics(string processCode, DataTable dtApply)
        {
            DataRow dr = dataTable1.Select("processCode = '" + processCode + "'")[0];
            int failCount = 0;
            foreach (DataRow drApply in dtApply.Rows)
            {
                if (drApply["autoJudge"].ToString() == "1") failCount++;
            }

            this.BeginInvoke(new Func<string>(delegate ()
            {
                dr["totalCount"] = dtApply.Rows.Count;
                dr["failJudgeCount"] = failCount;
                return "";
            }));
        }

        private DataTable GetTable(string processCode)
        {
            string[] judgeStates = new string[] { "0" };
            string judgeCondition = "1";
            string timeType = "1";
            DataTable dt = _d.GetTableByXmlId("QcmZgJugdeApplyDAL.QueryBcColligate", "", "", judgeStates.Length, judgeStates,
                "", "", 0, new string[] { }, processCode, judgeCondition, "", "", timeType, CustomInfo);

            return dt;
        }

        private void UltraGrid1_CellChange(object sender, Infragistics.Win.UltraWinGrid.CellEventArgs e)
        {
            e.Cell.Row.Update();
        }

        private void Timer1_Tick(object sender, EventArgs e)
        {
            String id = "1";
            if (customInfo == "120504")
                id = "7";
            DataRow drAuto = _d.GetRowByXmlId("JdgQcmAutoJudge.getById", id);
            BindDataTable2(drAuto);
            if (drAuto["opUserId"].ToString() == _userId)
            {
                _d.Set("com.steering.pss.judge.Bll.BllQcmAutoJudge.setLastOnlineTime");
            }
        }
    }
}