MES_Client/TGMES/Core.StlMes.Client.PlnSaleOrd/PlanStove/DAL/BaseEntityDAL.cs

using Core.Mes.Client.Comm.Format;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Reflection;
using Core.Mes.Client.Comm.Server;
using Core.Mes.Client.Comm.Tool;
using Infragistics.Win.UltraWinGrid;
using CoreFS.CA06;

namespace Core.StlMes.Client.PlnSaleOrd.PlanStove
{

    public class BaseEntityDAL
    {
        /// <summary>
        /// 使用实体类与后台交互时，与后台交互的通用方法,实际上是可以执行查询，插入，更新的
        /// </summary>
        /// <typeparam name="T">实体类类型</typeparam>
        /// <param name="Entityobj">实体类的实例</param>
        /// <param name="sqlID">需要执行的语句的sqlid</param>
        /// <param name="javaEntityClassID">java端的实体类的全名，包路径.类名</param>
        /// <param name="paramList">sqlid对应的参数List</param>
        /// <param name="ob">OpeBase对象</param>
        /// <returns>成功执行的条数</returns>
        public static int ExcuteNonQuery<T>(T Entityobj, string sqlID, string javaEntityClassID, List<Object> paramList, CoreFS.CA06.OpeBase ob)
        {
            int nret = 0;
            string jsonObj = JSONFormat.Format(Entityobj);
            nret = Core.Mes.Client.Comm.Server.ServerHelper.SetData(MethodDef.StoveBase.ExcuteNonQuery, new Object[] { jsonObj, sqlID, javaEntityClassID, paramList }, ob);
            return nret;
        }

        public static int ExcuteTransaction(List<String> entitySqlIDs,List<string> entityJsonStrings,List<String> entityClassNames,List<String> sqlIds,List<List<Object>> paramList,CoreFS.CA06.OpeBase ob)
        {
            int nRet = 0;
            nRet = Core.Mes.Client.Comm.Server.ServerHelper.SetData(MethodDef.StoveBase.ExeTransction, new Object[] { entitySqlIDs, entityJsonStrings, entityClassNames, sqlIds, paramList }, ob);
            return nRet;
        }

        public static int ExcuteTransaction(List<String> sqlIds, List<List<Object>> paramList, CoreFS.CA06.OpeBase ob)
        {
            int nRet = 0;
            nRet = Core.Mes.Client.Comm.Server.ServerHelper.SetData(MethodDef.StoveBase.ExeTransction, new Object[] { sqlIds, paramList }, ob);
            return nRet;
        }

        /// <summary>
        /// 不使用实体类与后台交互，的非查询执行方法
        /// </summary>
        /// <param name="sqlId"></param>
        /// <param name="paramList"></param>
        /// <param name="ob"></param>
        /// <returns></returns>
        public static int ExcuteNonQuery(string sqlId,List<Object> paramList,CoreFS.CA06.OpeBase ob)
        {
            int nRet = 0;
            nRet = Core.Mes.Client.Comm.Server.ServerHelper.SetData(MethodDef.StoveBase.ExcuteNonQuery,new Object[]{sqlId,paramList},ob);
            return nRet;
        }

        /// <summary>
        /// HEAT_PLAN_NO的格式如E201605160001，本函数获取获取DBK，RCL，ZG，JGX表中其后四位+1的整形数字
        /// </summary>
        /// <param name="tableName">表名，ZY_M表的表名</param>
        /// <param name="ob"></param>
        /// <returns></returns>
        public static DataTable GetMaxHeatNo(string tableName, CoreFS.CA06.OpeBase ob)
        {
            return Core.Mes.Client.Comm.Server.ServerHelper.GetData(MethodDef.StoveBase.getMaxHeatPlanNo, new Object[] { tableName }, ob);
        }

        /// <summary>
        /// 根据PROPlanID和GXPLANNO更新BATCHED_WT和BATCHED_NUM
        /// </summary>
        /// <param name="tableName">表名，四大工序的Order_S表全名</param>
        /// <param name="BATCHED_WT"></param>
        /// <param name="BATCHED_NUM"></param>
        /// <param name="PRO_PLAN_ID"></param>
        /// <param name="GX_PLAN_NO"></param>
        /// <param name="ob">frmbase的ob对象</param>
        public static void UpdateOrder_WT_NUM(string tableName, string BATCHED_WT, string BATCHED_NUM, string PRO_PLAN_ID, string GX_PLAN_NO, CoreFS.CA06.OpeBase ob)
        {
            Core.Mes.Client.Comm.Server.ServerHelper.SetData(MethodDef.StoveBase.UpdateOrder_WT_NUM, new Object[] { tableName, new List<string>() { BATCHED_WT, BATCHED_NUM, PRO_PLAN_ID, GX_PLAN_NO } }, ob);
        }

        /// <summary>
        /// 根据PROPlanID和GXPLANNO更新MatchWtIn和MatchNumIn
        /// </summary>
        /// <param name="tableName"></param>
        /// <param name="MatchWtIn"></param>
        /// <param name="MatchNumIn"></param>
        /// <param name="PRO_PLAN_ID"></param>
        /// <param name="GX_PLAN_NO"></param>
        /// <param name="ob"></param>
        public static void UpdateOrder_MATCHIN_WT_NUM(string tableName, string MatchWtIn, string MatchNumIn, string PRO_PLAN_ID, string GX_PLAN_NO, CoreFS.CA06.OpeBase ob)
        {
            Core.Mes.Client.Comm.Server.ServerHelper.SetData(MethodDef.StoveBase.UpdateOrder_MATCHIN_WT_NUM, new Object[] { tableName, new List<string>() { MatchWtIn, MatchNumIn, PRO_PLAN_ID, GX_PLAN_NO } }, ob);
        }

        /// <summary>
        /// 待条件查询Order表
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="tableName"></param>
        /// <param name="PLINE_CODE"></param>
        /// <param name="ORD_NO"></param>
        /// <param name="PRO_PLAN_ID"></param>
        /// <param name="statusArr"></param>
        /// <param name="ob"></param>
        /// <returns></returns>
        public static Object queryALL<T>(string tableName, string PLINE_CODE, string ORD_NO, string PRO_PLAN_ID, string[] statusArr, CoreFS.CA06.OpeBase ob)
        {
            return Core.Mes.Client.Comm.Tool.EntityHelper.GetData<T>(MethodDef.StoveBase.queryAll, new Object[] { tableName, PLINE_CODE, ORD_NO, PRO_PLAN_ID, statusArr }, ob);
        }


        /// <summary>
        /// 查询某个表的所有的内容，并把它填充进指定的实体类
        /// </summary>
        /// <typeparam name="T">实体类</typeparam>
        /// <param name="tableName">表名</param>
        /// <param name="ob"></param>
        /// <returns>datasouceList对象</returns>
        public static Object queryALL<T>(string tableName, CoreFS.CA06.OpeBase ob)
        {
            return Core.Mes.Client.Comm.Tool.EntityHelper.GetData<T>(MethodDef.StoveBase.queryAll, new Object[] { tableName }, ob);
        }

        /// <summary>
        /// 
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="ServerParams"></param>
        /// <param name="ob"></param>
        /// <returns></returns>
        public static Object queryALL<T>(Object[] ServerParams, CoreFS.CA06.OpeBase ob)
        {
            return Core.Mes.Client.Comm.Tool.EntityHelper.GetData<T>(MethodDef.StoveBase.queryAll, ServerParams, ob);
        }

        /// <summary>
        /// 根据heatplanno更新作业计划表的planstatus
        /// </summary>
        /// <param name="tablename">需要更新的表名</param>
        /// <param name="PLAN_STATUS">需要更新的下发状态（0计划，1下发，2生产完成）</param>
        /// <param name="HEAT_PLAN_NO">作业计划表主键</param>
        /// <param name="ob"></param>
        public static int UpdateZYPlanStatus(string tablename, string PLAN_STATUS, string HEAT_PLAN_NO,string UpdateName, CoreFS.CA06.OpeBase ob)
        {
             return Core.Mes.Client.Comm.Server.ServerHelper.SetData(MethodDef.StoveBase.UpdatePlnStatus, new Object[] { tablename, new List<String>() { PLAN_STATUS,UpdateName, HEAT_PLAN_NO} }, ob);
        }

        /// <summary>
        /// 获取作业计划表的批次生产序号()
        /// </summary>
        /// <param name="tablename"></param>
        /// <param name="ob"></param>
        public static DataTable GetMaxProdIndex(string tablename, CoreFS.CA06.OpeBase ob)
        {
            return Core.Mes.Client.Comm.Server.ServerHelper.GetData(MethodDef.StoveBase.queryMaxProdIndex, new Object[] { tablename }, ob);
        }

        /// <summary>
        /// 获取CHECKJVAL
        /// </summary>
        /// <param name="ORDLNDLYPK"></param>
        /// <param name="ob"></param>
        /// <returns></returns>
        public static Double GetCHECKJVAL(string ORDLNDLYPK, CoreFS.CA06.OpeBase ob)
        {
            DataTable dt = Core.Mes.Client.Comm.Server.ServerHelper.GetData(MethodDef.StoveBase.queryCHECKJVAL, new Object[] { ORDLNDLYPK }, ob);
            string CHECKJVAL = "";
            if (dt.Rows.Count > 0)
            {
                CHECKJVAL = dt.Rows[0][0].ToString();
            }
            try
            {
                return Convert.ToDouble(CHECKJVAL);
            }
            catch
            {
                return 0;
            }
        }

    }
}