You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
2175 lines
84 KiB
C#
2175 lines
84 KiB
C#
using Confluent.Kafka;
|
|
using Google.OrTools.ConstraintSolver;
|
|
using log4net;
|
|
using log4net.Repository.Hierarchy;
|
|
using MongoDB.Bson;
|
|
using MongoDB.Driver;
|
|
using MongoDB.Driver.Linq;
|
|
using SlabHandle.Enity;
|
|
using SOA.Objects;
|
|
using SOA.Persistent;
|
|
using Swashbuckle.Swagger;
|
|
using System;
|
|
using System.CodeDom;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Data;
|
|
using System.Dynamic;
|
|
using System.Globalization;
|
|
using System.Linq;
|
|
using System.Reflection;
|
|
using System.Security.Cryptography;
|
|
using System.Text;
|
|
using System.Text.RegularExpressions;
|
|
using System.Threading.Tasks;
|
|
using System.Web;
|
|
using System.Web.Http.Results;
|
|
using static System.Net.WebRequestMethods;
|
|
|
|
namespace StandardizedManagement
|
|
{
|
|
public class SycnDataControler
|
|
{
|
|
#region 变量常量
|
|
|
|
//Log4net 日志输出
|
|
private static readonly ILog logger = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
|
|
//后端 Service
|
|
#endregion 变量常量
|
|
|
|
/// <summary>
|
|
/// 接口批量替代板坯
|
|
/// </summary>
|
|
/// <param name="TM">定时器</param>
|
|
/// <returns></returns>
|
|
///
|
|
public static RequestEntity reqBulkSlabSupersede()
|
|
{
|
|
RequestEntity result = new RequestEntity(); //声明返回参数实体类
|
|
|
|
try
|
|
{
|
|
Execute();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
result.msg = "数据库错误！";
|
|
result.code = "0";
|
|
logger.Error("AddSurplusMaterial 报错 : ", ex);
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
public static void Execute()
|
|
{
|
|
Task[] tasks = new Task[17];
|
|
tasks[0] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_ASROLL_LEN_STDinfo();
|
|
});
|
|
tasks[1] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_CHARGE_S2info();
|
|
});
|
|
tasks[2] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncCP_NISCO_CHMC_NEWinfo();
|
|
});
|
|
tasks[3] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_STD_CROP_LENinfo();
|
|
});
|
|
tasks[4] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncQP_NISCO_CHMCinfo();
|
|
});
|
|
tasks[5] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_SMS_TTTinfo();
|
|
});
|
|
tasks[6] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_TOP_END_STDinfo();
|
|
});
|
|
tasks[7] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_LADLE_TIMEinfo();
|
|
});
|
|
tasks[8] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_CCM_TIMEinfo();
|
|
});
|
|
tasks[9] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncQP_QLTY_TECH_REPLACEinfo();
|
|
});
|
|
|
|
tasks[10] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncCP_PRC_COOL_DATEinfo();
|
|
});
|
|
tasks[11] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_PLATEWID_STDinfo();
|
|
});
|
|
tasks[12] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncCP_NISCO_CHMC_SLinfo();
|
|
});
|
|
tasks[13] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncBP_ODER_XYinfo();
|
|
});
|
|
tasks[14] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncEP_SLABDESIGNinfo();
|
|
});
|
|
tasks[15] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncQP_PROD_RATIOinfo();
|
|
});
|
|
tasks[16] = Task.Factory.StartNew(() =>
|
|
{
|
|
SyncQP_STD_HEADinfo();
|
|
});
|
|
Task.WaitAll(tasks);
|
|
}
|
|
|
|
private static void SyncQP_STD_HEADinfo()
|
|
{
|
|
//标准头表规范
|
|
IList<QP_STD_HEAD> QP_STD_HEADinfo = new List<QP_STD_HEAD>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.QP_STD_HEAD ";
|
|
QP_STD_HEADinfo = db_sur.Query<QP_STD_HEAD>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM QP_STD_HEAD ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (QP_STD_HEADinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
|
|
if (db.Insert<QP_STD_HEAD>(QP_STD_HEADinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**QP_STD_HEAD数据获取成功.数量：{0} .", QP_STD_HEADinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncQP_PROD_RATIOinfo()
|
|
{
|
|
//压缩比规范
|
|
IList<QP_PROD_RATIO> QP_PROD_RATIOinfo = new List<QP_PROD_RATIO>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.QP_PROD_RATIO ";
|
|
QP_PROD_RATIOinfo = db_sur.Query<QP_PROD_RATIO>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM QP_PROD_RATIO ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (QP_PROD_RATIOinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
|
|
if (db.Insert<QP_PROD_RATIO>(QP_PROD_RATIOinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**QP_PROD_RATIO数据获取成功.数量：{0} .", QP_PROD_RATIOinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_SLABDESIGNinfo()
|
|
{
|
|
//适用项目规范
|
|
IList<EP_SLABDESIGN> EP_SLABDESIGNinfo = new List<EP_SLABDESIGN>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_SLABDESIGN ";
|
|
EP_SLABDESIGNinfo = db_sur.Query<EP_SLABDESIGN>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_SLABDESIGN ";
|
|
//IList<EP_SLABDESIGN> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_SLABDESIGNinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<EP_SLABDESIGN>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<EP_SLABDESIGN>(EP_SLABDESIGNinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_SLABDESIGN数据获取成功.数量：{0} .", EP_SLABDESIGNinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**EP_SLABDESIGN数据获取失败.数量：{0} .", EP_SLABDESIGNinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<EP_SLABDESIGN>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncBP_ODER_XYinfo()
|
|
{
|
|
//协议订单规范
|
|
IList<BP_ODER_XY> BP_ODER_XYinfo = new List<BP_ODER_XY>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.BP_ODER_XY ";
|
|
BP_ODER_XYinfo = db_sur.Query<BP_ODER_XY>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM BP_ODER_XY ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (BP_ODER_XYinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<BP_ODER_XY>(BP_ODER_XYinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**BP_ODER_XY数据获取成功.数量：{0} .", BP_ODER_XYinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**BP_ODER_XYo数据获取失败.数量：{0} .", BP_ODER_XYinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncCP_NISCO_CHMC_SLinfo()
|
|
{
|
|
//一坯多标准规范
|
|
IList<CP_NISCO_CHMC_SL> CP_NISCO_CHMC_SLinfo = new List<CP_NISCO_CHMC_SL>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.CP_NISCO_CHMC_SL ";
|
|
CP_NISCO_CHMC_SLinfo = db_sur.Query<CP_NISCO_CHMC_SL>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM CP_NISCO_CHMC_SL ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (CP_NISCO_CHMC_SLinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<CP_NISCO_CHMC_SL>(CP_NISCO_CHMC_SLinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**CP_NISCO_CHMC_SL数据获取成功.数量：{0} .", CP_NISCO_CHMC_SLinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**CP_NISCO_CHMC_SLinfo数据获取失败.数量：{0} .", CP_NISCO_CHMC_SLinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.InfoFormat(ex.ToString());
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_PLATEWID_STDinfo()
|
|
{
|
|
//产品宽度余量标准规范
|
|
IList<EP_PLATEWID_STD> EP_PLATEWID_STDinfo = new List<EP_PLATEWID_STD>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_PLATEWID_STD ";
|
|
EP_PLATEWID_STDinfo = db_sur.Query<EP_PLATEWID_STD>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_PLATEWID_STD ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_PLATEWID_STDinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
string upddate = DateTime.Now.ToString("yyyyMMdd");
|
|
string updtime = DateTime.Now.ToString("HHmmss");
|
|
string insdate = DateTime.Now.ToString("yyyyMMdd");
|
|
string instime = DateTime.Now.ToString("HHmmss");
|
|
foreach (EP_PLATEWID_STD xy in EP_PLATEWID_STDinfo)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(xy.INS_DATE))
|
|
{
|
|
xy.INS_DATE = insdate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_TIME))
|
|
{
|
|
xy.INS_TIME = instime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_DATE))
|
|
{
|
|
xy.UPD_DATE = upddate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_TIME))
|
|
{
|
|
xy.UPD_TIME = updtime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_EMP))
|
|
{
|
|
xy.UPD_EMP = "SYSTEM";
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_EMP))
|
|
{
|
|
xy.INS_EMP = "SYSTEM";
|
|
}
|
|
xy.INS_DATE = xy.INS_DATE.PadLeft(6,'0');
|
|
xy.INS_TIME=xy.INS_TIME.PadLeft(6, '0');
|
|
xy.UPD_DATE=xy.UPD_DATE.PadLeft(6, '0');
|
|
xy.UPD_TIME=xy.UPD_TIME.PadLeft(6, '0');
|
|
}
|
|
if (db.Insert<EP_PLATEWID_STD>(EP_PLATEWID_STDinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_PLATEWID_STD数据获取成功.数量：{0} .", EP_PLATEWID_STDinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**EP_PLATEWID_STD数据获取失败.数量：{0} .", EP_PLATEWID_STDinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.InfoFormat(ex.ToString());
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncCP_PRC_COOL_DATEinfo()
|
|
{
|
|
//板坯堆冷信息标准
|
|
IList<CP_PRC_COOL_DATE> CP_PRC_COOL_DATEinfo = new List<CP_PRC_COOL_DATE>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.CP_PRC_COOL_DATE ";
|
|
CP_PRC_COOL_DATEinfo = db_sur.Query<CP_PRC_COOL_DATE>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM CP_PRC_COOL_DATE ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (CP_PRC_COOL_DATEinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<CP_PRC_COOL_DATE>(CP_PRC_COOL_DATEinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**CP_PRC_COOL_DATE数据获取成功.数量：{0} .", CP_PRC_COOL_DATEinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.InfoFormat("**CP_PRC_COOL_DATE数据获取失败.数量：{0} .", 0);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncQP_QLTY_TECH_REPLACEinfo()
|
|
{
|
|
//异钢种替代规范
|
|
IList<QP_QLTY_TECH_REPLACE> QP_QLTY_TECH_REPLACEinfo = new List<QP_QLTY_TECH_REPLACE>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.QP_QLTY_TECH_REPLACE ";
|
|
QP_QLTY_TECH_REPLACEinfo = db_sur.Query<QP_QLTY_TECH_REPLACE>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM QP_QLTY_TECH_REPLACE ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (QP_QLTY_TECH_REPLACEinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
string upddate = DateTime.Now.ToString("yyyyMMdd");
|
|
string updtime = DateTime.Now.ToString("HHmmss");
|
|
string insdate = DateTime.Now.ToString("yyyyMMdd");
|
|
string instime = DateTime.Now.ToString("HHmmss");
|
|
foreach (QP_QLTY_TECH_REPLACE xy in QP_QLTY_TECH_REPLACEinfo)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(xy.INS_DATE))
|
|
{
|
|
xy.INS_DATE = insdate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_TIME))
|
|
{
|
|
xy.INS_TIME = instime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_DATE))
|
|
{
|
|
xy.UPD_DATE = upddate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_TIME))
|
|
{
|
|
xy.UPD_TIME = updtime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_EMP))
|
|
{
|
|
xy.UPD_EMP = "SYSTEM";
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_EMP))
|
|
{
|
|
xy.INS_EMP = "SYSTEM";
|
|
}
|
|
|
|
}
|
|
if (db.Insert<QP_QLTY_TECH_REPLACE>(QP_QLTY_TECH_REPLACEinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**QP_QLTY_TECH_REPLACE数据获取成功.数量：{0} .", QP_QLTY_TECH_REPLACEinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**QP_QLTY_TECH_REPLACE数据获取失败.数量：{0} .", QP_QLTY_TECH_REPLACEinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_CCM_TIMEinfo()
|
|
{
|
|
//浇铸作业时间标准
|
|
IList<EP_CCM_TIME> EP_CCM_TIMEinfo = new List<EP_CCM_TIME>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_CCM_TIME ";
|
|
EP_CCM_TIMEinfo = db_sur.Query<EP_CCM_TIME>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_CCM_TIME ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_CCM_TIMEinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
string upddate = DateTime.Now.ToString("yyyyMMdd");
|
|
string updtime = DateTime.Now.ToString("HHmmss");
|
|
string insdate = DateTime.Now.ToString("yyyyMMdd");
|
|
string instime = DateTime.Now.ToString("HHmmss");
|
|
foreach (EP_CCM_TIME xy in EP_CCM_TIMEinfo)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(xy.INS_DATE))
|
|
{
|
|
xy.INS_DATE = insdate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_TIME))
|
|
{
|
|
xy.INS_TIME = instime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_DATE))
|
|
{
|
|
xy.UPD_DATE = upddate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_TIME))
|
|
{
|
|
xy.UPD_TIME = updtime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_EMP))
|
|
{
|
|
xy.UPD_EMP = "SYSTEM";
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_EMP))
|
|
{
|
|
xy.INS_EMP = "SYSTEM";
|
|
}
|
|
xy.INS_DATE = xy.INS_DATE.PadLeft(6, '0');
|
|
xy.INS_TIME = xy.INS_TIME.PadLeft(6, '0');
|
|
xy.UPD_DATE = xy.UPD_DATE.PadLeft(6, '0');
|
|
xy.UPD_TIME = xy.UPD_TIME.PadLeft(6, '0');
|
|
}
|
|
if (db.Insert<EP_CCM_TIME>(EP_CCM_TIMEinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_CCM_TIME数据获取成功.数量：{0} .", EP_CCM_TIMEinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**EP_CCM_TIME数据获取失败.数量：{0} .", EP_CCM_TIMEinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.InfoFormat("**EP_CCM_TIME数据获取失败.数量：{0} .", 0);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_LADLE_TIMEinfo()
|
|
{
|
|
//钢包移动时间标准
|
|
IList<EP_LADLE_TIME> EP_LADLE_TIMEinfo = new List<EP_LADLE_TIME>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_LADLE_TIME ";
|
|
EP_LADLE_TIMEinfo = db_sur.Query<EP_LADLE_TIME>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_LADLE_TIME ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_LADLE_TIMEinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
|
|
if (db.Insert<EP_LADLE_TIME>(EP_LADLE_TIMEinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_LADLE_TIME数据获取成功.数量：{0} .", EP_LADLE_TIMEinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.InfoFormat("**EP_LADLE_TIME数据获取失败.数量：{0} .", 0);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_TOP_END_STDinfo()
|
|
{
|
|
//头尾坯切割标准
|
|
IList<EP_TOP_END_STD> EP_TOP_END_STDinfo = new List<EP_TOP_END_STD>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_TOP_END_STD ";
|
|
EP_TOP_END_STDinfo = db_sur.Query<EP_TOP_END_STD>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_TOP_END_STD ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_TOP_END_STDinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
|
|
if (db.Insert<EP_TOP_END_STD>(EP_TOP_END_STDinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_TOP_END_STD数据获取成功.数量：{0} .", EP_TOP_END_STDinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_SMS_TTTinfo()
|
|
{
|
|
//炼钢周期标准
|
|
IList<EP_SMS_TTT> EP_SMS_TTTinfo = new List<EP_SMS_TTT>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_SMS_TTT ";
|
|
EP_SMS_TTTinfo = db_sur.Query<EP_SMS_TTT>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_SMS_TTT ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_SMS_TTTinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<EP_SMS_TTT>(EP_SMS_TTTinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_SMS_TTT数据获取成功.数量：{0} .", EP_SMS_TTTinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncQP_NISCO_CHMCinfo()
|
|
{
|
|
//炉次间钢种连浇标准
|
|
IList<QP_NISCO_CHMC> QP_NISCO_CHMCinfo = new List<QP_NISCO_CHMC>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.QP_NISCO_CHMC ";
|
|
QP_NISCO_CHMCinfo = db_sur.Query<QP_NISCO_CHMC>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM QP_NISCO_CHMC ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (QP_NISCO_CHMCinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
string upddate = DateTime.Now.ToString("yyyyMMdd");
|
|
string updtime = DateTime.Now.ToString("HHmmss");
|
|
string insdate = DateTime.Now.ToString("yyyyMMdd");
|
|
string instime = DateTime.Now.ToString("HHmmss");
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
foreach (QP_NISCO_CHMC xy in QP_NISCO_CHMCinfo)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(xy.INS_DATE))
|
|
{
|
|
xy.INS_DATE = insdate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_TIME))
|
|
{
|
|
xy.INS_TIME = instime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_DATE))
|
|
{
|
|
xy.UPD_DATE = upddate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_TIME))
|
|
{
|
|
xy.UPD_TIME = updtime;
|
|
}
|
|
}
|
|
if (db.Insert<QP_NISCO_CHMC>(QP_NISCO_CHMCinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**QP_NISCO_CHMC数据获取成功.数量：{0} .", QP_NISCO_CHMCinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_STD_CROP_LENinfo()
|
|
{
|
|
//头尾放尺规范
|
|
IList<EP_STD_CROP_LEN> EP_STD_CROP_LENinfo = new List<EP_STD_CROP_LEN>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_STD_CROP_LEN ";
|
|
EP_STD_CROP_LENinfo = db_sur.Query<EP_STD_CROP_LEN>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string upddate = DateTime.Now.ToString("yyyyMMdd");
|
|
string updtime = DateTime.Now.ToString("HHmmss");
|
|
string insdate = DateTime.Now.ToString("yyyyMMdd");
|
|
string instime = DateTime.Now.ToString("HHmmss");
|
|
string strSql = "DELETE FROM EP_STD_CROP_LEN ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_STD_CROP_LENinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
foreach (EP_STD_CROP_LEN xy in EP_STD_CROP_LENinfo)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(xy.INS_DATE))
|
|
{
|
|
xy.INS_DATE = insdate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_TIME))
|
|
{
|
|
xy.INS_TIME = instime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_DATE))
|
|
{
|
|
xy.UPD_DATE = upddate;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_TIME))
|
|
{
|
|
xy.UPD_TIME = updtime;
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.UPD_EMP))
|
|
{
|
|
xy.UPD_EMP = "SYSTEM";
|
|
}
|
|
if (string.IsNullOrWhiteSpace(xy.INS_EMP))
|
|
{
|
|
xy.INS_EMP = "SYSTEM";
|
|
}
|
|
}
|
|
if (db.Insert<EP_STD_CROP_LEN>(EP_STD_CROP_LENinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_STD_CROP_LEN数据获取成功.数量：{0} .", EP_STD_CROP_LENinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncCP_NISCO_CHMC_NEWinfo()
|
|
{
|
|
//多钢种组炉编制标准
|
|
IList<CP_NISCO_CHMC_NEW> CP_NISCO_CHMC_NEWinfo = new List<CP_NISCO_CHMC_NEW>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.CP_NISCO_CHMC_NEW ";
|
|
CP_NISCO_CHMC_NEWinfo = db_sur.Query<CP_NISCO_CHMC_NEW>(strsql);
|
|
}
|
|
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM CP_NISCO_CHMC_NEW ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (CP_NISCO_CHMC_NEWinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<CP_NISCO_CHMC_NEW>(CP_NISCO_CHMC_NEWinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**CP_NISCO_CHMC_NEW数据获取成功.数量：{0} .", CP_NISCO_CHMC_NEWinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**CP_NISCO_CHMC_NEW数据获取失败.数量：{0} .", CP_NISCO_CHMC_NEWinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 炉次编制量
|
|
/// </summary>
|
|
private static void SyncEP_CHARGE_S2info()
|
|
{
|
|
//炉次编制量
|
|
IList<EP_CHARGE_S2> EP_CHARGE_S2info = new List<EP_CHARGE_S2>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_CHARGE_S2 ";
|
|
EP_CHARGE_S2info = db_sur.Query<EP_CHARGE_S2>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_CHARGE_S2 ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_CHARGE_S2info.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<EP_CHARGE_S2>(EP_CHARGE_S2info) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_CHARGE_S2数据获取成功.数量：{0} .", EP_CHARGE_S2info.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.InfoFormat("**EP_CHARGE_S2数据获取失败.数量：{0} .", 0);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static void SyncEP_ASROLL_LEN_STDinfo()
|
|
{
|
|
//产品厚度轧制长度标准规范
|
|
IList<EP_ASROLL_LEN_STD> EP_ASROLL_LEN_STDinfo = new List<EP_ASROLL_LEN_STD>();
|
|
using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
{
|
|
string strsql = "SELECT * FROM NISCO.EP_ASROLL_LEN_STD ";
|
|
EP_ASROLL_LEN_STDinfo = db_sur.Query<EP_ASROLL_LEN_STD>(strsql);
|
|
}
|
|
|
|
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
{
|
|
try
|
|
{
|
|
string strSql = "DELETE FROM EP_ASROLL_LEN_STD ";
|
|
//IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
if (EP_ASROLL_LEN_STDinfo.Count > 0)
|
|
{
|
|
db.BeginTransaction();
|
|
bool b = true;
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
if (db.Execute(strSql) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (db.Insert<EP_ASROLL_LEN_STD>(EP_ASROLL_LEN_STDinfo) == 0)
|
|
{
|
|
b = false;
|
|
}
|
|
if (b)
|
|
{
|
|
logger.InfoFormat("**EP_ASROLL_LEN_STD数据获取成功.数量：{0} .", EP_ASROLL_LEN_STDinfo.Count);
|
|
//数据操作成功则保存数据
|
|
db.Commit();
|
|
|
|
}
|
|
else
|
|
{
|
|
logger.InfoFormat("**EP_ASROLL_LEN_STD数据获取失败.数量：{0} .", EP_ASROLL_LEN_STDinfo.Count);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
//db.Insert<BP_ODER_XY>(info);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.InfoFormat("**EP_ASROLL_LEN_STD数据获取失败.数量：{0} .", 0);
|
|
//操作失败回滚数据到初始状态
|
|
db.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
#region 暂时未用代码
|
|
|
|
//对接管理规范
|
|
//IList<SPECI_DOCK_MANAGEMENT> SPECI_DOCK_MANAGEMENTinfo = new List<SPECI_DOCK_MANAGEMENT>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.SPECI_DOCK_MANAGEMENT ";
|
|
// SPECI_DOCK_MANAGEMENTinfo = db_sur.Query<SPECI_DOCK_MANAGEMENT>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM SPECI_DOCK_MANAGEMENT ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (SPECI_DOCK_MANAGEMENTinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (SPECI_DOCK_MANAGEMENT xy in SPECI_DOCK_MANAGEMENTinfo)
|
|
// {
|
|
// if (db.Insert<SPECI_DOCK_MANAGEMENT>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**SPECI_DOCK_MANAGEMENT数据获取成功.数量：{0} .", SPECI_DOCK_MANAGEMENTinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
//热装热送规范
|
|
//IList<DELI_CHARGE_SPECI> DELI_CHARGE_SPECIinfo = new List<DELI_CHARGE_SPECI>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.DELI_CHARGE_SPECI ";
|
|
// DELI_CHARGE_SPECIinfo = db_sur.Query<DELI_CHARGE_SPECI>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM DELI_CHARGE_SPECI ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (DELI_CHARGE_SPECIinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (DELI_CHARGE_SPECI xy in DELI_CHARGE_SPECIinfo)
|
|
// {
|
|
// if (db.Insert<DELI_CHARGE_SPECI>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**DELI_CHARGE_SPECI数据获取成功.数量：{0} .", DELI_CHARGE_SPECIinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// logger.InfoFormat("**DELI_CHARGE_SPECI数据获取失败.数量：{0} .", 0);
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
//结晶器寿命
|
|
//IList<MOLD_LIFE> MOLD_LIFEinfo = new List<MOLD_LIFE>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.MOLD_LIFE ";
|
|
// MOLD_LIFEinfo = db_sur.Query<MOLD_LIFE>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM MOLD_LIFE ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (MOLD_LIFEinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (MOLD_LIFE xy in MOLD_LIFEinfo)
|
|
// {
|
|
// if (db.Insert<MOLD_LIFE>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**MOLD_LIFE数据获取成功.数量：{0} .", MOLD_LIFEinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
//母版长度余量 --这个整理下
|
|
//IList<ZP_APLY_ITEM> ZP_APLY_ITEMinfo = new List<ZP_APLY_ITEM>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.ZP_APLY_ITEM ";
|
|
// ZP_APLY_ITEMinfo = db_sur.Query<ZP_APLY_ITEM>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM ZP_APLY_ITEM ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (ZP_APLY_ITEMinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (ZP_APLY_ITEM xy in ZP_APLY_ITEMinfo)
|
|
// {
|
|
// if (db.Insert<ZP_APLY_ITEM>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**ZP_APLY_ITEM数据获取成功.数量：{0} .", ZP_APLY_ITEMinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
////产品厚度轧制长度标准规范
|
|
//IList<EP_ASROLL_LEN_STD> EP_ASROLL_LEN_STDinfo = new List<EP_ASROLL_LEN_STD>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.EP_ASROLL_LEN_STD ";
|
|
// EP_ASROLL_LEN_STDinfo = db_sur.Query<EP_ASROLL_LEN_STD>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM EP_ASROLL_LEN_STD ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (EP_ASROLL_LEN_STDinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (EP_ASROLL_LEN_STD xy in EP_ASROLL_LEN_STDinfo)
|
|
// {
|
|
// if (db.Insert<EP_ASROLL_LEN_STD>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**EP_ASROLL_LEN_STD数据获取成功.数量：{0} .", EP_ASROLL_LEN_STDinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// logger.InfoFormat("**EP_ASROLL_LEN_STD数据获取失败.数量：{0} .", 0);
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
//适用项目规范 已有
|
|
//IList<ZP_APLY_ITEM> ZP_APLY_ITEMinfo = new List<ZP_APLY_ITEM>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.ZP_APLY_ITEM ";
|
|
// ZP_APLY_ITEMinfo = db_sur.Query<ZP_APLY_ITEM>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM ZP_APLY_ITEM ";
|
|
// //IList<ZP_APLY_ITEM> info = db.Query<TBDIPDI>(strsql);
|
|
// if (ZP_APLY_ITEMinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<ZP_APLY_ITEM>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (ZP_APLY_ITEM xy in ZP_APLY_ITEMinfo)
|
|
// {
|
|
// if (db.Insert<ZP_APLY_ITEM>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**ZP_APLY_ITEM数据获取成功.数量：{0} .", ZP_APLY_ITEMinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<ZP_APLY_ITEM>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
//热轧厂常规断面定义
|
|
//IList<MILL_PLT_CONVEN_SEC> MILL_PLT_CONVEN_SECinfo = new List<MILL_PLT_CONVEN_SEC>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.MILL_PLT_CONVEN_SEC ";
|
|
// MILL_PLT_CONVEN_SECinfo = db_sur.Query<MILL_PLT_CONVEN_SEC>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM MILL_PLT_CONVEN_SEC ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (MILL_PLT_CONVEN_SECinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (MILL_PLT_CONVEN_SEC xy in MILL_PLT_CONVEN_SECinfo)
|
|
// {
|
|
// if (db.Insert<MILL_PLT_CONVEN_SEC>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**MILL_PLT_CONVEN_SEC数据获取成功.数量：{0} .", MILL_PLT_CONVEN_SECinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
//热轧厂坯料定义
|
|
//IList<MILL_PLT_SLAB> MILL_PLT_SLABinfo = new List<MILL_PLT_SLAB>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.MILL_PLT_SLAB ";
|
|
// MILL_PLT_SLABinfo = db_sur.Query<MILL_PLT_SLAB>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM MILL_PLT_SLAB ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (MILL_PLT_SLABinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (MILL_PLT_SLAB xy in MILL_PLT_SLABinfo)
|
|
// {
|
|
// if (db.Insert<MILL_PLT_SLAB>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**MILL_PLT_SLAB数据获取成功.数量：{0} .", MILL_PLT_SLABinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
//替代厚度限制
|
|
//IList<SUBS_THICK_LIMIT> SUBS_THICK_LIMITinfo = new List<SUBS_THICK_LIMIT>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.SUBS_THICK_LIMIT ";
|
|
// SUBS_THICK_LIMITinfo = db_sur.Query<SUBS_THICK_LIMIT>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM SUBS_THICK_LIMIT ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (SUBS_THICK_LIMITinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (SUBS_THICK_LIMIT xy in SUBS_THICK_LIMITinfo)
|
|
// {
|
|
// if (db.Insert<SUBS_THICK_LIMIT>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**SUBS_THICK_LIMIT数据获取成功.数量：{0} .", SUBS_THICK_LIMITinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
//钢板堆冷规范
|
|
//IList<SPECIF_PLA_STACK_COOLING> SPECIF_PLA_STACK_COOLINGinfo = new List<SPECIF_PLA_STACK_COOLING>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.SPECIF_PLA_STACK_COOLING ";
|
|
// SPECIF_PLA_STACK_COOLINGinfo = db_sur.Query<SPECIF_PLA_STACK_COOLING>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM SPECIF_PLA_STACK_COOLING ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (SPECIF_PLA_STACK_COOLINGinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (SPECIF_PLA_STACK_COOLING xy in SPECIF_PLA_STACK_COOLINGinfo)
|
|
// {
|
|
// if (db.Insert<SPECIF_PLA_STACK_COOLING>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**SPECIF_PLA_STACK_COOLING数据获取成功.数量：{0} .", SPECIF_PLA_STACK_COOLINGinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
//剪切规范
|
|
//IList<SHEAR_SPECI> SHEAR_SPECIinfo = new List<SHEAR_SPECI>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.SHEAR_SPECI ";
|
|
// SHEAR_SPECIinfo = db_sur.Query<SHEAR_SPECI>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM SHEAR_SPECI ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (SHEAR_SPECIinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (SHEAR_SPECI xy in SHEAR_SPECIinfo)
|
|
// {
|
|
// if (db.Insert<SHEAR_SPECI>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**SHEAR_SPECI数据获取成功.数量：{0} .", SHEAR_SPECIinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
//精整货位管理规范
|
|
//IList<GOODS_POS_MANAGE_SPECI> GOODS_POS_MANAGE_SPECIinfo = new List<GOODS_POS_MANAGE_SPECI>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.GOODS_POS_MANAGE_SPECI ";
|
|
// GOODS_POS_MANAGE_SPECIinfo = db_sur.Query<GOODS_POS_MANAGE_SPECI>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM GOODS_POS_MANAGE_SPECI ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (GOODS_POS_MANAGE_SPECIinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (GOODS_POS_MANAGE_SPECI xy in GOODS_POS_MANAGE_SPECIinfo)
|
|
// {
|
|
// if (db.Insert<GOODS_POS_MANAGE_SPECI>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**GOODS_POS_MANAGE_SPECI数据获取成功.数量：{0} .", GOODS_POS_MANAGE_SPECIinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
//精整货位管理规范
|
|
//IList<TB_UST_FL> TB_UST_FLinfo = new List<TB_UST_FL>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.TB_UST_FL ";
|
|
// TB_UST_FLinfo = db_sur.Query<TB_UST_FL>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM TB_UST_FL ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (TB_UST_FLinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (TB_UST_FL xy in TB_UST_FLinfo)
|
|
// {
|
|
// if (db.Insert<TB_UST_FL>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**TB_UST_FL数据获取成功.数量：{0} .", TB_UST_FLinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
//精整货位管理规范
|
|
// IList<HEAT_TREAT_PLA_ENTRY_SPECI> HEAT_TREAT_PLA_ENTRY_SPECIinfo = new List<HEAT_TREAT_PLA_ENTRY_SPECI>();
|
|
// using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
// {
|
|
// string strsql = "SELECT * FROM NISCO.HEAT_TREAT_PLA_ENTRY_SPECI ";
|
|
// HEAT_TREAT_PLA_ENTRY_SPECIinfo = db_sur.Query<HEAT_TREAT_PLA_ENTRY_SPECI>(strsql);
|
|
// }
|
|
|
|
// using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
// {
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM HEAT_TREAT_PLA_ENTRY_SPECI ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (HEAT_TREAT_PLA_ENTRY_SPECIinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (HEAT_TREAT_PLA_ENTRY_SPECI xy in HEAT_TREAT_PLA_ENTRY_SPECIinfo)
|
|
// {
|
|
// if (db.Insert<HEAT_TREAT_PLA_ENTRY_SPECI>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**HEAT_TREAT_PLA_ENTRY_SPECI数据获取成功.数量：{0} .", HEAT_TREAT_PLA_ENTRY_SPECIinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// }
|
|
|
|
//IList<EP_CAST_S2> EP_CAST_S2info = new List<EP_CAST_S2>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.EP_CAST_S2 ";
|
|
// EP_CAST_S2info = db_sur.Query<EP_CAST_S2>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM EP_CAST_S2 ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (EP_CAST_S2info.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (EP_CAST_S2 xy in EP_CAST_S2info)
|
|
// {
|
|
// if (db.Insert<EP_CAST_S2>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**EP_CAST_S2数据获取成功.数量：{0} .", EP_CAST_S2info.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// logger.InfoFormat("**EP_CAST_S2数据获取失败.数量：{0} .",0);
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
//IList<EP_CCM_LOSS_STD> EP_CCM_LOSS_STDinfo = new List<EP_CCM_LOSS_STD>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.EP_CCM_LOSS_STD ";
|
|
// EP_CCM_LOSS_STDinfo = db_sur.Query<EP_CCM_LOSS_STD>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM EP_CCM_LOSS_STD ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (EP_CCM_LOSS_STDinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (EP_CCM_LOSS_STD xy in EP_CCM_LOSS_STDinfo)
|
|
// {
|
|
// if (db.Insert<EP_CCM_LOSS_STD>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**EP_CCM_LOSS_STD数据获取成功.数量：{0} .", EP_CCM_LOSS_STDinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// logger.InfoFormat("**EP_CCM_LOSS_STD数据获取失败.数量：{0} .", 0);
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//IList<EP_CHARGE_S2> EP_CHARGE_S2info = new List<EP_CHARGE_S2>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.EP_CHARGE_S2 ";
|
|
// EP_CHARGE_S2info = db_sur.Query<EP_CHARGE_S2>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM EP_CHARGE_S2 ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (EP_CHARGE_S2info.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (EP_CHARGE_S2 xy in EP_CHARGE_S2info)
|
|
// {
|
|
// if (db.Insert<EP_CHARGE_S2>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**EP_CHARGE_S2数据获取成功.数量：{0} .", EP_CHARGE_S2info.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// logger.InfoFormat("**EP_CHARGE_S2数据获取失败.数量：{0} .", 0);
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//IList<EP_SLAB_SIZE> EP_SLAB_SIZEinfo = new List<EP_SLAB_SIZE>();
|
|
//using (IDbContext db_sur = ObjectContainer.GetObject<IDbContext>("db_sur"))
|
|
//{
|
|
// string strsql = "SELECT * FROM NISCO.EP_SLAB_SIZE ";
|
|
// EP_SLAB_SIZEinfo = db_sur.Query<EP_SLAB_SIZE>(strsql);
|
|
//}
|
|
|
|
//using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
|
|
//{
|
|
// try
|
|
// {
|
|
// string strSql = "DELETE FROM EP_SLAB_SIZE ";
|
|
// //IList<BP_ODER_XY> info = db.Query<TBDIPDI>(strsql);
|
|
// if (EP_SLAB_SIZEinfo.Count > 0)
|
|
// {
|
|
// db.BeginTransaction();
|
|
// bool b = true;
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// if (db.Execute(strSql) == 0)
|
|
// {
|
|
// b = false;
|
|
// }
|
|
// foreach (EP_SLAB_SIZE xy in EP_SLAB_SIZEinfo)
|
|
// {
|
|
// if (db.Insert<EP_SLAB_SIZE>(xy) == 0)
|
|
// {
|
|
// b = false;
|
|
// break;
|
|
// }
|
|
// }
|
|
// if (b)
|
|
// {
|
|
// logger.InfoFormat("**EP_SLAB_SIZE数据获取成功.数量：{0} .", EP_SLAB_SIZEinfo.Count);
|
|
// //数据操作成功则保存数据
|
|
// db.Commit();
|
|
|
|
// }
|
|
// else
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
// //db.Insert<BP_ODER_XY>(info);
|
|
// }
|
|
// }
|
|
// catch (Exception ex)
|
|
// {
|
|
// //操作失败回滚数据到初始状态
|
|
// db.Rollback();
|
|
// }
|
|
//}
|
|
#endregion
|
|
}
|
|
|
|
} |