ELK/FrameworkLocal/Common/DBCore/LinearProcessDataRecorder.cs

using System;
using System.Collections.Generic;
using System.Data;
using Aitex.Core.RT.DBCore;
using Aitex.Core.RT.Log;
using Aitex.Core.UI.ControlDataContext;
using Aitex.Sorter.Common;
using MECF.Framework.Common.DataCenter;
using MECF.Framework.Common.Equipment;

namespace MECF.Framework.Common.DBCore
{
    public class LinearProcessDataRecorder
    {
        public static void Start(string guid, string recipeName, int ppId,  string batchId, string cassette1Id, string cassette2Id, string user)
        {

                string sql = string.Format(
					"INSERT INTO \"process_data_linear\"(\"guid\", \"process_begin_time\", \"recipe_name\" , \"pp_id\", \"batch_id\", \"cassette1_id\", \"cassette2_id\", \"user\" , \"cassette1_load_wafer_position\", \"cassette2_load_wafer_position\", \"cassette1_unload_wafer_position\", \"cassette2_unload_wafer_position\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}',' ',' ',' ',' ');",
                    guid,
                    DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                    recipeName,
                    ppId,
                    batchId,
                    cassette1Id,
                    cassette2Id,
                    user);

                DB.Insert(sql);


        }

        public static void UpdateWaferCount(string guid, int cassette1Count, int cassette2Count)
        {

                string sql = string.Format(
                            "UPDATE \"process_data_linear\" SET \"cassette1_count\"='{1}', \"cassette2_count\"='{2}' WHERE \"guid\"='{0}';",
                            guid,
                            cassette1Count,
                            cassette2Count);

                DB.Insert(sql);


        }

        public static void UpdateLoadWaferPosition(string guid, string cassette1WaferPosition, string cassette2WaferPosition)
        {

		        string sql = string.Format(
					"UPDATE \"process_data_linear\" SET \"cassette1_load_wafer_position\" = '{1}', \"cassette2_load_wafer_position\"='{2}' WHERE \"guid\"='{0}';",
			        guid,
			        cassette1WaferPosition,
			        cassette2WaferPosition);

		        DB.Insert(sql);


        }

        public static void UpdateUnloadWaferPosition(string guid, string cassette1WaferPosition, string cassette2WaferPosition)
        {

		        string sql = string.Format(
			        "UPDATE \"process_data_linear\" SET \"cassette1_unload_wafer_position\" = '{1}', \"cassette2_unload_wafer_position\"='{2}' WHERE \"guid\"='{0}';",
			        guid,
			        cassette1WaferPosition,
			        cassette2WaferPosition);

		        DB.Insert(sql);


        }
		public static void End(string guid, string finishType)
        {

                string sql = string.Format(
                            "UPDATE \"process_data_linear\" SET \"process_end_time\"='{1}',\"finish_type\"='{2}' WHERE \"guid\"='{0}';",
                            guid,
                            DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                            finishType);

                DB.Insert(sql);


        }

        public static List<string> GetProcesData(int ppId, string batchId)
        {
                List<string> processData = new List<string>();
                string sql = string.Format(
                    "SELECT * FROM \"process_data_linear\" where \"pp_id\" = '{0}' and \"batch_id\" = '{1}' and (\"finish_type\" is null or \"finish_type\" != 'RecipeFinish')  order by \"process_begin_time\" ASC;",
                    ppId.ToString(), batchId);

                DataSet dataSet = DB.ExecuteDataset(sql);
                if (dataSet == null || dataSet.Tables.Count == 0)
                    return processData;

                DataTable queryDataTable = dataSet.Tables[0];
                if (queryDataTable == null || queryDataTable.Rows.Count == 0)
                    return processData;
                try
                {
	                processData.Add(queryDataTable.Rows[queryDataTable.Rows.Count - 1]["guid"].ToString());
	                processData.Add(queryDataTable.Rows[queryDataTable.Rows.Count - 1]["cassette1_count"].ToString());
	                processData.Add(queryDataTable.Rows[queryDataTable.Rows.Count - 1]["cassette2_count"].ToString());
					processData.Add(queryDataTable.Rows[queryDataTable.Rows.Count - 1]["process_begin_time"].ToString());
                }
                catch (Exception ex)
                {
                    LOG.Write(ex);
	                return null;
				}


				return processData;

        }

    }
}