FurnaceELK/FrameworkLocal/Common/DBCore/JobDataRecorder.cs

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

namespace MECF.Framework.Common.DBCore
{
    public class JobDataRecorder
    {
        public static void StartCJ(string guid, string carrierGuid, string name, string portIn, string portOut, int totalWafer)
        {
            string sql = string.Format(
                "INSERT INTO \"cj_data\"(\"guid\", \"start_time\", \"carrier_data_guid\", \"name\",\"input_port\",\"output_port\",\"total_wafer_count\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}');",
                guid,
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                carrierGuid,
                name,
                portIn,
                portOut,
                totalWafer);

            DB.Insert(sql);
        }

        public static void EndCJ(string guid, int abortWafer, int unprocessedWafer)
        {
            string sql = string.Format("UPDATE \"cj_data\" SET \"end_time\"='{0}', \"abort_wafer_count\"='{1}', \"unprocessed_wafer_count\"='{2}'  WHERE \"guid\"='{3}';",
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                abortWafer, 
                unprocessedWafer,
                guid);

            DB.Insert(sql);
        }
        //废弃
        public static void StartPJ(string guid, string carrierGuid, string cjGuid, string lotGuid, string name, string portIn, string portOut, int totalWafer, string sequence)
        {
            string sql = string.Format(
                "INSERT INTO \"pj_data\"(\"guid\", \"start_time\", \"carrier_data_guid\", \"cj_data_guid\",\"lot_data_guid\",\"name\",\"input_port\",\"output_port\",\"total_wafer_count\",\"sequence_name\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}');",
                guid,
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                carrierGuid,
                cjGuid,
                lotGuid,
                name,
                portIn,
                portOut,
                totalWafer,
                sequence);

            DB.Insert(sql);


        }

        public static void EndPJ(string guid, int abortWafer, int unprocessedWafer)
        {
            string sql = string.Format("UPDATE \"pj_data\" SET \"end_time\"='{0}', \"abort_wafer_count\"='{2}', \"unprocessed_wafer_count\"='{3}' WHERE \"guid\"='{1}';",
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                guid, abortWafer, unprocessedWafer);

            DB.Insert(sql);
        }

        public static void CreatePJ(string guid, string batchId, string jobName, string recipeName, string layoutName, string layoutData, string form)
        {
            string sql = string.Format(
                "INSERT INTO \"pj_data\"(\"guid\", \"batch_id\", \"job_name\", \"recipe_name\", \"layout_name\", \"layout_data\", \"form\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}');",
                guid,
                batchId,
                jobName,
                recipeName,
                layoutName,
                layoutData,
                form);

            DB.Insert(sql);

        }

        public static void StartPJ(string guid)
        {
            string sql = string.Format("UPDATE \"pj_data\" SET \"start_time\"='{0}' WHERE \"guid\"='{1}';",
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                guid);

            DB.Insert(sql);
        }

        public static void UpdatePJ(string guid,string layoutData, string waferData, int totalWafer)
        {
            string sql = string.Format("UPDATE \"pj_data\" SET \"layout_data\"='{0}', \"wafer_data\"='{1}', \"total_wafer_count\"='{2}' WHERE \"guid\"='{3}';",
                layoutData,
                waferData,
                totalWafer,
                guid);

            DB.Insert(sql);
        }

        public static void EndPJ(string guid, string form)
        {
            string sql = string.Format("UPDATE \"pj_data\" SET \"form\"='{0}', \"end_time\"='{1}' WHERE \"guid\"='{2}';",
                form,
                DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
                guid);

            DB.Insert(sql);
        }
    }
}