Kepler-Release/Venus/Framework/Common/DBCore/LeakCheckDataRecorder.cs

using System;
using System.Collections.Generic;
using System.Data;
using Aitex.Core.RT.DBCore;
using Aitex.Core.RT.SCCore;
using MECF.Framework.Common.Equipment;
using Venus_Core;

namespace MECF.Framework.Common.DBCore
{
    public class LeakCheckDataRecorder
    {
        public static void Add(int leakCheckTime, double beginPressure, double endPressure, double leakRate, string status, string mode, string moduleName, string gaslines = "")
        {
            string sql = string.Format(
                "INSERT INTO \"leak_check_data\"(\"guid\", \"operate_time\", \"status\" , \"leak_rate\", \"start_pressure\", \"stop_pressure\", \"mode\", \"leak_check_time\" , \"module_name\", \"gasline_selection\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}','{8}','{9}' );",
                Guid.NewGuid(),
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                status,
                leakRate,
                beginPressure,
                endPressure,
                mode,
                leakCheckTime,
                moduleName,
                gaslines);

            DB.Insert(sql);
        }
        public static void AddKepler2200(int leakCheckTime, double basePressure, double beginPressure, double endPressure, double leakRate, string status, string mode, string moduleName, string gaslines = "")
        {
            string sql = string.Format(
                "INSERT INTO \"kepler_leak_check_data\"(\"guid\", \"operate_time\", \"status\" , \"leak_rate\",\"base_pressure\", \"start_pressure\", \"stop_pressure\", \"mode\", \"leak_check_time\" , \"module_name\", \"gasline_selection\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}','{8}','{9}','{10}');",
                Guid.NewGuid(),
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                status,
                leakRate,
                basePressure,
                beginPressure,
                endPressure,
                mode,
                leakCheckTime,
                moduleName,
                gaslines);

            DB.Insert(sql);
        }
        public static List<PMLeakCheckResult> GetAllLeakCheckData(string moduleName)
        {

            List<PMLeakCheckResult> result = new List<PMLeakCheckResult>();
            string tmValue = "";
            if (moduleName == "TM")
            {
                tmValue = $" or \"module_name\"='LLA' or \"module_name\"='LLB'";
            }
            else if (moduleName == "LLA")
            {
                tmValue = $" or \"module_name\"='TM' or \"module_name\"='LLB'";
            }
            else if (moduleName == "LLB")
            {
                tmValue = $" or \"module_name\"='LLA' or \"module_name\"='TM'";
            }
            string tableName = "leak_check_data";


            string sql = $"SELECT * FROM \"{tableName}\" where \"module_name\"='{moduleName}'{tmValue} order by operate_time desc LIMIT 50";

            DataSet ds = DB.ExecuteDataset(sql);
            if (ds == null)
                return result;
            if (ds.Tables.Count == 0)
                return result;

            for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
            {
                PMLeakCheckResult checkresult = new PMLeakCheckResult();

                checkresult.ModuleName = ds.Tables[0].Rows[i]["module_name"].ToString();
                checkresult.CheckDate = ds.Tables[0].Rows[i]["operate_time"].ToString();
                //checkresult.BasePressure = Convert.ToDouble(ds.Tables[0].Rows[i]["base_pressure"].ToString());

                checkresult.StartPressure = Convert.ToDouble(ds.Tables[0].Rows[i]["start_pressure"].ToString());
                checkresult.EndPressure = Convert.ToDouble(ds.Tables[0].Rows[i]["stop_pressure"].ToString());
                checkresult.LeakCheckTime = Convert.ToInt32(ds.Tables[0].Rows[i]["leak_check_time"].ToString());
                checkresult.LeakRate = Convert.ToDouble(ds.Tables[0].Rows[i]["leak_rate"].ToString());
                checkresult.CheckMode = ds.Tables[0].Rows[i]["mode"].ToString();
                checkresult.GasLines = ds.Tables[0].Rows[i]["gasline_selection"].ToString();
                checkresult.Result = ds.Tables[0].Rows[i]["status"].ToString();
                result.Add(checkresult);
            }

            ds.Clear();

            return result;
        }

        public static List<PMLeakCheckResult> GetAllLeakCheckDataWithBasePressure(string moduleName)
        {

            List<PMLeakCheckResult> result = new List<PMLeakCheckResult>();
            string tmValue = "";
            if (moduleName == "TM")
            {
                tmValue = $" or \"module_name\"='LLA' or \"module_name\"='LLB'";
            }
            else if (moduleName == "LLA")
            {
                tmValue = $" or \"module_name\"='TM' or \"module_name\"='LLB'";
            }
            else if (moduleName == "LLB")
            {
                tmValue = $" or \"module_name\"='LLA' or \"module_name\"='TM'";
            }
            string tableName = "leak_check_data";
            if (ModuleHelper.IsPm(moduleName))
            {
                JetChamber jetChamber = (JetChamber)SC.GetValue<int>($"{moduleName}.ChamberType");
                {
                    if (jetChamber == JetChamber.Kepler2200A || jetChamber == JetChamber.Kepler2200B)
                    {
                        tableName = "kepler_leak_check_data";
                    }
                }
            }


            string sql = $"SELECT * FROM \"{tableName}\" where \"module_name\"='{moduleName}'{tmValue} order by operate_time desc LIMIT 50";

            DataSet ds = DB.ExecuteDataset(sql);
            if (ds == null)
                return result;
            if (ds.Tables.Count == 0)
                return result;

            for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
            {
                PMLeakCheckResult checkresult = new PMLeakCheckResult();

                checkresult.ModuleName = ds.Tables[0].Rows[i]["module_name"].ToString();
                checkresult.CheckDate = ds.Tables[0].Rows[i]["operate_time"].ToString();
                if (ModuleHelper.IsPm(moduleName))
                {
                    JetChamber jetChamber = (JetChamber)SC.GetValue<int>($"{moduleName}.ChamberType");
                    {
                        if (jetChamber == JetChamber.Kepler2200A || jetChamber == JetChamber.Kepler2200B)
                        {
                            checkresult.BasePressure = Convert.ToDouble(ds.Tables[0].Rows[i]["base_pressure"].ToString());
                        }
                    }
                }
                checkresult.StartPressure = Convert.ToDouble(ds.Tables[0].Rows[i]["start_pressure"].ToString());
                checkresult.EndPressure = Convert.ToDouble(ds.Tables[0].Rows[i]["stop_pressure"].ToString());
                checkresult.LeakCheckTime = Convert.ToInt32(ds.Tables[0].Rows[i]["leak_check_time"].ToString());
                checkresult.LeakRate = Convert.ToDouble(ds.Tables[0].Rows[i]["leak_rate"].ToString());
                checkresult.CheckMode = ds.Tables[0].Rows[i]["mode"].ToString();
                checkresult.GasLines = ds.Tables[0].Rows[i]["gasline_selection"].ToString();
                checkresult.Result = ds.Tables[0].Rows[i]["status"].ToString();
                result.Add(checkresult);
            }

            ds.Clear();

            return result;
        }


    }
}