|
|
@@ -12,7 +12,7 @@ using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Data;
|
|
|
using System.Text;
|
|
|
-
|
|
|
+using Curtain.DataAccess;
|
|
|
using Dongke.IBOSS.PRD.Basics.BaseResources;
|
|
|
using Dongke.IBOSS.PRD.Basics.DataAccess;
|
|
|
using Dongke.IBOSS.PRD.Service.CMNModuleService;
|
|
|
@@ -20,6 +20,7 @@ using Dongke.IBOSS.PRD.Service.DataModels;
|
|
|
using Dongke.IBOSS.PRD.WCF.DataModels;
|
|
|
using Dongke.WinForm.Utilities;
|
|
|
using Oracle.ManagedDataAccess.Client;
|
|
|
+using DataBaseType = Curtain.DataAccess.DataBaseType;
|
|
|
|
|
|
namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
{
|
|
|
@@ -42,7 +43,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
DataTable dataTable = CMNModuleLogic.GetTP_MST_GMouldType(conn, user, Constant.ValueFlag.Effective);
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
sre.Data = new DataSet();
|
|
|
@@ -74,7 +75,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
List<OracleParameter> parameters = new List<OracleParameter>();
|
|
|
StringBuilder sql = new StringBuilder(PMModuleLogic.GetFPM0101SSQL());
|
|
|
parameters.Add(new OracleParameter(":AccountID", OracleDbType.Int32, user.AccountID, ParameterDirection.Input));
|
|
|
@@ -125,7 +126,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
List<OracleParameter> parameters = new List<OracleParameter>();
|
|
|
StringBuilder sql = new StringBuilder(PMModuleLogic.GetFPM0101SSQL());
|
|
|
parameters.Add(new OracleParameter(":AccountID", OracleDbType.Int32, user.AccountID, ParameterDirection.Input));
|
|
|
@@ -381,7 +382,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
DataTable dataTable = CMNModuleLogic.GetTP_MST_DataDictionary(conn, user, Constant.DictionaryType.TPC004, Constant.ValueFlag.Effective);
|
|
|
// 账务日期
|
|
|
@@ -542,7 +543,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
// 账务日期
|
|
|
object date = CMNModuleLogic.GetAccountDate(conn, user);
|
|
|
@@ -787,7 +788,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
|
|
|
// 'S_PM_021', '注浆登记限制天数' add by chenxy 2018-12-15 begin
|
|
|
@@ -1037,7 +1038,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
return sre;
|
|
|
}
|
|
|
|
|
|
- tran = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ tran = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
int executeResult = 0;
|
|
|
|
|
|
DataTable dtGroutingLine = groutingInfo.Tables[0];
|
|
|
@@ -2029,7 +2030,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
|
|
|
// 'S_PM_023', '注浆绑码限制天数' add by chenxy 2019-05-07 begin
|
|
|
@@ -2193,7 +2194,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
StringBuilder sql = new StringBuilder();
|
|
|
List<OracleParameter> parameters = new List<OracleParameter>();
|
|
|
@@ -2375,7 +2376,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
return sre;
|
|
|
}
|
|
|
|
|
|
- tran = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ tran = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
int executeResult = 0;
|
|
|
|
|
|
// 绑定条码
|
|
|
@@ -2890,7 +2891,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
// 'S_PM_024', '未交坯可否替换条码' add by chenxy 2019-05-07 begin
|
|
|
string spm024 = conn.GetSqlResultToStr("select ss.SETTINGVALUE from tp_mst_systemsetting ss where ss.SETTINGCODE = 'S_PM_024' and ss.AccountID = " + user.AccountID);
|
|
|
@@ -3186,7 +3187,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
return sre;
|
|
|
}
|
|
|
|
|
|
- tran = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ tran = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
#region 校验条码
|
|
|
/*
|
|
|
@@ -3365,7 +3366,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
List<OracleParameter> parameters = new List<OracleParameter>();
|
|
|
StringBuilder sql = new StringBuilder(PMModuleLogic.GetFPM0203SSQL());
|
|
|
parameters.Add(new OracleParameter(":AccountID", OracleDbType.Int32, user.AccountID, ParameterDirection.Input));
|
|
|
@@ -3492,7 +3493,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
List<OracleParameter> parameters = new List<OracleParameter>();
|
|
|
StringBuilder sql = new StringBuilder(PMModuleLogic.GetFPM0203SSQL());
|
|
|
parameters.Add(new OracleParameter(":AccountID", OracleDbType.Int32, user.AccountID, ParameterDirection.Input));
|
|
|
@@ -3624,7 +3625,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
return sre;
|
|
|
}
|
|
|
|
|
|
- tran = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ tran = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
int executeResult = 0;
|
|
|
|
|
|
#region 校验时间戳
|
|
|
@@ -3765,7 +3766,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
//SearchProductionDataEntity searchEntity = cre.Request as SearchProductionDataEntity;
|
|
|
@@ -3955,7 +3956,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
public static ServiceResultEntity GetGBCheckedList(SUserInfo sUserInfo, ClientRequestEntity cre)
|
|
|
{
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -3986,7 +3987,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
public static ServiceResultEntity GetAllGBCheckList(SUserInfo sUserInfo, ClientRequestEntity cre)
|
|
|
{
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -4042,7 +4043,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
{
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
int checkedID = Convert.ToInt32(cre.Properties["CheckedID"]);
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
sre.Data = new DataSet();
|
|
|
@@ -4164,7 +4165,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
{
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
int checkedID = Convert.ToInt32(cre.Properties["CheckedID"]);
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -4214,7 +4215,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
string remarks = cre.Properties["Remarks"].ToString();
|
|
|
|
|
|
int returnRows = 0;
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
string sql = null;
|
|
|
@@ -4524,7 +4525,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
int checkedID = Convert.ToInt32(cre.Properties["CheckedID"]);
|
|
|
int returnRows = 0;
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
string sql = "update TP_PM_GroutingChecked set valueflag='0', updateuserid=:updateuserid where GBCheckedID=:GBCheckedID and valueflag='1'";
|
|
|
@@ -4578,7 +4579,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
int checkedID = Convert.ToInt32(cre.Properties["CheckedID"]);
|
|
|
string barcode = cre.Properties["Barcode"].ToString();
|
|
|
int returnRows = 0;
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
string sql = null;
|
|
|
@@ -4835,7 +4836,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
barcodes = cre.Properties["Barcodes"].ToString();
|
|
|
}
|
|
|
int returnRows = 0;
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
string sql = null;
|
|
|
OracleParameter[] paras = null;
|
|
|
@@ -4955,7 +4956,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns>DataSet</returns>
|
|
|
public static DataSet GetUpdateGBCheckedInfo(int checkedID, SUserInfo sUserInfo)
|
|
|
{
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -5044,7 +5045,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
barcodes = cre.Properties["Barcodes"].ToString();
|
|
|
}
|
|
|
int returnRows = 0;
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
string sql = null;
|
|
|
@@ -5126,7 +5127,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
barcodes = cre.Properties["Barcodes"].ToString();
|
|
|
}
|
|
|
int returnRows = 0;
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
string sql = null;
|
|
|
@@ -5207,7 +5208,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
//// 列表中产品数量
|
|
|
@@ -5277,7 +5278,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns>DataSet</returns>
|
|
|
public static ServiceResultEntity GetGroutingScrapProduct(ClientRequestEntity cre, SUserInfo userInfo)
|
|
|
{
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
ServiceResultEntity result = new ServiceResultEntity();
|
|
|
@@ -5491,7 +5492,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
{
|
|
|
ServiceResultEntity result = new ServiceResultEntity();
|
|
|
result.Status = Constant.ServiceResultStatus.Success;
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
string sqlString = string.Empty;
|
|
|
int returnRow = Constant.INT_IS_ZERO;
|
|
|
|
|
|
@@ -5896,7 +5897,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
public static ServiceResultEntity AuditGroutingScrapProduct(ClientRequestEntity cre, SUserInfo userInfo)
|
|
|
{
|
|
|
ServiceResultEntity result = new ServiceResultEntity();
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
string sqlString = string.Empty;
|
|
|
int returnRow = Constant.INT_IS_ZERO;
|
|
|
|
|
|
@@ -5972,7 +5973,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
ServiceResultEntity result = new ServiceResultEntity();
|
|
|
result.Status = Constant.ServiceResultStatus.Success;
|
|
|
|
|
|
- IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
string sqlString = string.Empty;
|
|
|
int returnRow = Constant.INT_IS_ZERO;
|
|
|
|
|
|
@@ -6070,7 +6071,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns></returns>
|
|
|
public static ServiceResultEntity GetGroutingDailyDetail(ClientRequestEntity cre, SUserInfo userInfo)
|
|
|
{
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
ServiceResultEntity result = new ServiceResultEntity();
|
|
|
@@ -6151,7 +6152,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "SELECT p.procedureid, p.procedurename\n" +
|
|
|
@@ -6203,7 +6204,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "SELECT 1 AS SEL, gdd.groutingdailydetailid\n" +
|
|
|
@@ -6275,7 +6276,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBTransaction conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
string suspendBatchNo = Guid.NewGuid().ToString();
|
|
|
|
|
|
@@ -6375,7 +6376,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "SELECT 0 AS SEL, gdd.barcode\n" +
|
|
|
@@ -6465,7 +6466,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBTransaction conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
string suspendBatchNo = Guid.NewGuid().ToString();
|
|
|
|
|
|
@@ -6518,7 +6519,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
//string sqlString = "SELECT gdd.barcode\n" +
|
|
|
@@ -6678,7 +6679,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "SELECT gdd.groutingdailydetailid\n" +
|
|
|
@@ -6759,7 +6760,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBTransaction conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
string sqlInsert = "INSERT INTO TP_PM_QASpotCheck\n" +
|
|
|
" (GroutingDailyDetailID\n" +
|
|
|
@@ -6821,7 +6822,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBTransaction conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
|
|
|
string sqlString = "SELECT gdd.groutingdailydetailid\n" +
|
|
|
" ,gdd.barcode\n" +
|
|
|
@@ -6928,7 +6929,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "select gdd.barcode\n" +
|
|
|
@@ -7017,7 +7018,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
//string sqlString = "select gdd.barcode,\n" +
|
|
|
@@ -7166,7 +7167,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "select nvl(max(fl.loadingno), 0) + 1\n" +
|
|
|
@@ -7212,7 +7213,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns></returns>
|
|
|
public static ServiceResultEntity CheckFinishedLaodingBarcode(SUserInfo sUserInfo, string barcode)
|
|
|
{
|
|
|
- IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
oracleConn.Open();
|
|
|
@@ -7342,7 +7343,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
public static ServiceResultEntity SaveFinishedLoading(SUserInfo sUserInfo, int loadingNo,
|
|
|
string carLicense, int palletNum, int goodsNum, string remarks, Dictionary<string, object>[] details)
|
|
|
{
|
|
|
- IDBTransaction oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction oracleConn = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
oracleConn.Connect();
|
|
|
@@ -7452,7 +7453,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "select sr.SemiReworkID\n" +
|
|
|
@@ -7545,7 +7546,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
{
|
|
|
if (conn == null)
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
}
|
|
|
|
|
|
@@ -7605,7 +7606,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
public static int GetSemiReworkEditFuntion(SUserInfo userInfo)
|
|
|
{
|
|
|
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -7638,7 +7639,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns></returns>
|
|
|
public static ServiceResultEntity CheckSemiReworkBarcode(string barcode)
|
|
|
{
|
|
|
- IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
oracleConn.Open();
|
|
|
@@ -7718,7 +7719,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "select sr.SemiReworkID\n" +
|
|
|
@@ -7867,7 +7868,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
IDBConnection conn = null;
|
|
|
try
|
|
|
{
|
|
|
- conn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ conn = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
conn.Open();
|
|
|
|
|
|
string sqlString = "select p.procedureid, p.procedurecode, p.procedurename\n" +
|
|
|
@@ -7907,7 +7908,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns>DataSet</returns>
|
|
|
public static ServiceResultEntity GetSemiReworkPassProcedure(string barcode)
|
|
|
{
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -7954,7 +7955,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns></returns>
|
|
|
public static ServiceResultEntity GetSemiReworkDefectStaffByProductionDataID(int productionDataID)
|
|
|
{
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -8001,7 +8002,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns>DataSet</returns>
|
|
|
public static ServiceResultEntity GetSemiReworkDefectStaffByUserID(int userid)
|
|
|
{
|
|
|
- IDBConnection con = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBConnection con = ClsDbFactory.CreateDBConnection(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
con.Open();
|
|
|
@@ -8048,7 +8049,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// </remarks>
|
|
|
public static ServiceResultEntity AddSemiRework(SemiReworkEntity entityobj, SUserInfo sUserInfo)
|
|
|
{
|
|
|
- IDBTransaction con = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction con = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
ServiceResultEntity resultEntity = new ServiceResultEntity();
|
|
|
@@ -8350,7 +8351,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns></returns>
|
|
|
public static ServiceResultEntity EditSemiRework(SemiReworkEntity entityobj, SUserInfo sUserInfo)
|
|
|
{
|
|
|
- IDBTransaction con = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction con = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
ServiceResultEntity resultEntity = new ServiceResultEntity();
|
|
|
@@ -8696,7 +8697,7 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
/// <returns></returns>
|
|
|
public static ServiceResultEntity CancelSemiRework(SemiReworkEntity entityobj, SUserInfo sUserInfo)
|
|
|
{
|
|
|
- IDBTransaction con = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
+ IDBTransaction con = ClsDbFactory.CreateDBTransaction(Basics.DataAccess.DataBaseType.ORACLE, DataManager.ConnectionString);
|
|
|
try
|
|
|
{
|
|
|
ServiceResultEntity resultEntity = new ServiceResultEntity();
|
|
|
@@ -8815,11 +8816,349 @@ namespace Dongke.IBOSS.PRD.Service.PMModuleService
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-
|
|
|
public static ServiceResultEntity GetSemiReworkForPDAEdit(int semiReworkID, SUserInfo sUserInfo)
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
#endregion
|
|
|
+
|
|
|
+ #region 窑车漏扫补件
|
|
|
+ /// <summary>
|
|
|
+ /// 验证窑车是否存在
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="cre"></param>
|
|
|
+ /// <param name="userInfo"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public static ServiceResultEntity CheckKilnCar(ClientRequestEntity cre, SUserInfo userInfo)
|
|
|
+ {
|
|
|
+ IDataAccess dataAccess = DataAccess.Create(DataBaseType.Oracle, DataManager.ConnectionString);
|
|
|
+ try
|
|
|
+ {
|
|
|
+ string sqlString = "select kc.kilncarid,kc.kilnid\n" +
|
|
|
+ " from tp_mst_kilncar kc\n" +
|
|
|
+ " where kc.valueflag = '1'\n" +
|
|
|
+ " and kc.accountid = @accountID@\n" +
|
|
|
+ " and kc.kilncarcode = @kilncarcode@";
|
|
|
+
|
|
|
+ CDAParameter[] paras = new CDAParameter[]
|
|
|
+ {
|
|
|
+ new CDAParameter("accountID", userInfo.AccountID),
|
|
|
+ new CDAParameter("kilncarcode", cre.Properties["kilncarcode"]),
|
|
|
+ };
|
|
|
+
|
|
|
+ ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
+ DataTable data = dataAccess.ExecuteDatatable(sqlString, paras);
|
|
|
+ if (data == null || data.Rows.Count == 0)
|
|
|
+ {
|
|
|
+ sre.Status = Constant.ServiceResultStatus.Other;
|
|
|
+ sre.OtherStatus = 1;
|
|
|
+ sre.Message = "此窑车不存在";
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+ sre.Result = data.Rows[0]["kilncarid"];
|
|
|
+
|
|
|
+ sqlString = "Select procedureID From tp_pc_procedureKiln t where t.KilnID = @KilnID@ and t.procedureID = @procedureID@";
|
|
|
+ paras = new CDAParameter[]
|
|
|
+ {
|
|
|
+ new CDAParameter("KilnID", data.Rows[0]["kilnid"]),
|
|
|
+ new CDAParameter("procedureID", cre.Properties["procedureID"]),
|
|
|
+ };
|
|
|
+
|
|
|
+ data = dataAccess.ExecuteDatatable(sqlString, paras);
|
|
|
+ if (data == null || data.Rows.Count == 0)
|
|
|
+ {
|
|
|
+ sre.Status = Constant.ServiceResultStatus.Other;
|
|
|
+ sre.OtherStatus = 2;
|
|
|
+ sre.Message = "此窑车不不允许经过此工序";
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ throw ex;
|
|
|
+ }
|
|
|
+ finally
|
|
|
+ {
|
|
|
+ dataAccess?.Dispose();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 验证窑车烧成批次号是否存在 和 是否能补漏扫
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="cre"></param>
|
|
|
+ /// <param name="userInfo"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public static ServiceResultEntity CheckKilnCarBatchNo(ClientRequestEntity cre, SUserInfo userInfo)
|
|
|
+ {
|
|
|
+ IDataAccess dataAccess = DataAccess.Create(DataBaseType.Oracle, DataManager.ConnectionString);
|
|
|
+ try
|
|
|
+ {
|
|
|
+ string sqlString = "select t.kilncardataid, t.modelType, t.procedureid\n" +
|
|
|
+ " from tp_pm_kilncardata t\n" +
|
|
|
+ " where t.kilnid = @kilnid@\n" +
|
|
|
+ " and t.kilncarid = @kilncarid@\n" +
|
|
|
+ " and t.valueflag = '1'\n" +
|
|
|
+ " and t.kilncarbatchno = @kilncarbatchno@";
|
|
|
+
|
|
|
+ CDAParameter[] paras = new CDAParameter[]
|
|
|
+ {
|
|
|
+ new CDAParameter("kilnid", cre.Properties["KilnID"]),
|
|
|
+ new CDAParameter("kilncarid", cre.Properties["KilnCarID"]),
|
|
|
+ new CDAParameter("kilncarbatchno", cre.Properties["KilnCarBatchNo"]),
|
|
|
+ };
|
|
|
+
|
|
|
+ ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
+ DataTable data = dataAccess.ExecuteDatatable(sqlString, paras);
|
|
|
+ if (data == null || data.Rows.Count == 0)
|
|
|
+ {
|
|
|
+ sre.Status = Constant.ServiceResultStatus.Other;
|
|
|
+ sre.OtherStatus = 1;
|
|
|
+ sre.Message = "此烧成批次号不存在";
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+
|
|
|
+ int carProcedureid = Convert.ToInt32(data.Rows[0]["procedureid"]);
|
|
|
+ string modelType = data.Rows[data.Rows.Count-1]["modelType"] + "";
|
|
|
+
|
|
|
+ if (modelType != "4")
|
|
|
+ {
|
|
|
+ sre.Status = Constant.ServiceResultStatus.Other;
|
|
|
+ sre.OtherStatus = 2;
|
|
|
+ sre.Message = "此窑车还未卸窑不能补件";
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+ if (carProcedureid != Convert.ToInt32(cre.Properties["ProcedureID"]))
|
|
|
+ {
|
|
|
+ sre.Status = Constant.ServiceResultStatus.Other;
|
|
|
+ sre.OtherStatus = 3;
|
|
|
+ sre.Message = "此窑车烧成批次不是在当前工序登窑";
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ throw ex;
|
|
|
+ }
|
|
|
+ finally
|
|
|
+ {
|
|
|
+ dataAccess?.Dispose();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 窑车漏扫补件
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="cre"></param>
|
|
|
+ /// <param name="userInfo"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public static ServiceResultEntity SetKilnCarMissing(ClientRequestEntity cre, SUserInfo userInfo)
|
|
|
+ {
|
|
|
+ IDataAccess dataAccess = DataAccess.Create(DataBaseType.Oracle, DataManager.ConnectionString);
|
|
|
+ try
|
|
|
+ {
|
|
|
+ ServiceResultEntity sre = new ServiceResultEntity();
|
|
|
+ dataAccess.Open(true);
|
|
|
+
|
|
|
+ DataTable data = cre.Data.Tables[0];
|
|
|
+ string CENTRALIZEDBATCHNO = System.Guid.NewGuid().ToString();
|
|
|
+
|
|
|
+ string sqlString = "\n" +
|
|
|
+ "insert into tp_pm_productiondatain\n" +
|
|
|
+ " (BARCODE\n" +
|
|
|
+ " ,CENTRALIZEDBATCHNO\n" +
|
|
|
+ " ,PRODUCTIONLINEID\n" +
|
|
|
+ " ,PRODUCTIONLINECODE\n" +
|
|
|
+ " ,PRODUCTIONLINENAME\n" +
|
|
|
+ " ,PROCEDUREID\n" +
|
|
|
+ " ,PROCEDURECODE\n" +
|
|
|
+ " ,PROCEDURENAME\n" +
|
|
|
+ " ,PROCEDUREMODEL\n" +
|
|
|
+ " ,MODELTYPE\n" +
|
|
|
+ " ,PIECETYPE\n" +
|
|
|
+ " ,ISREWORKED\n" +
|
|
|
+ " ,NODETYPE\n" +
|
|
|
+ " ,ISPUBLICBODY\n" +
|
|
|
+ " ,ISREFIRE\n" +
|
|
|
+ " ,ORGANIZATIONID\n" +
|
|
|
+ " ,GOODSID\n" +
|
|
|
+ " ,GOODSCODE\n" +
|
|
|
+ " ,GOODSNAME\n" +
|
|
|
+ " ,USERID\n" +
|
|
|
+ " ,USERCODE\n" +
|
|
|
+ " ,USERNAME\n" +
|
|
|
+ " ,KILNID\n" +
|
|
|
+ " ,KILNCODE\n" +
|
|
|
+ " ,KILNNAME\n" +
|
|
|
+ " ,KILNCARID\n" +
|
|
|
+ " ,KILNCARCODE\n" +
|
|
|
+ " ,KILNCARNAME\n" +
|
|
|
+ " ,KILNCARBATCHNO\n" +
|
|
|
+ " ,KILNCARPOSITION\n" +
|
|
|
+ " ,REMARKS\n" +
|
|
|
+ " ,ACCOUNTDATE\n" +
|
|
|
+ " ,ACCOUNTID\n" +
|
|
|
+ " ,VALUEFLAG\n" +
|
|
|
+ " ,CREATEUSERID\n" +
|
|
|
+ " ,UPDATEUSERID\n" +
|
|
|
+ " ,GROUTINGDATE\n" +
|
|
|
+ " ,GROUTINGMOULDCODE\n" +
|
|
|
+ " ,MOULDCODE\n" +
|
|
|
+ " ,GROUTINGUSERID\n" +
|
|
|
+ " ,GROUTINGUSERCODE\n" +
|
|
|
+ " ,GROUTINGNUM\n" +
|
|
|
+ " ,GROUTINGDAILYID\n" +
|
|
|
+ " ,GROUTINGDAILYDETAILID\n" +
|
|
|
+ " ,GROUTINGLINEID\n" +
|
|
|
+ " ,GROUTINGLINECODE\n" +
|
|
|
+ " ,GROUTINGLINENAME\n" +
|
|
|
+ " ,GMOULDTYPEID\n" +
|
|
|
+ " ,CANMANYTIMES\n" +
|
|
|
+ " ,GROUTINGLINEDETAILID\n" +
|
|
|
+ " ,SPECIALREPAIRFLAG\n" +
|
|
|
+ " ,CLASSESSETTINGID\n" +
|
|
|
+ " ,LOGOID\n" +
|
|
|
+ " ,CHECKTIME)\n" +
|
|
|
+ " select inp.barcode\n" +
|
|
|
+ " ,@CENTRALIZEDBATCHNO@\n" +
|
|
|
+ " ,kd.productionlineid\n" +
|
|
|
+ " ,pline.PRODUCTIONLINECODE\n" +
|
|
|
+ " ,pline.PRODUCTIONLINENAME\n" +
|
|
|
+ " ,kd.procedureid\n" +
|
|
|
+ " ,pcp.PROCEDURECODE\n" +
|
|
|
+ " ,pcp.PROCEDURENAME\n" +
|
|
|
+ " ,pcp.proceduremodel\n" +
|
|
|
+ " ,pcp.modeltype\n" +
|
|
|
+ " ,pcp.piecetype\n" +
|
|
|
+ " ,'0'\n" +
|
|
|
+ " ,pcp.nodetype\n" +
|
|
|
+ " ,inp.ispublicbody\n" +
|
|
|
+ " ,inp.isrefire\n" +
|
|
|
+ " ,pcp.organizationid\n" +
|
|
|
+ " ,inp.goodsid\n" +
|
|
|
+ " ,inp.goodscode\n" +
|
|
|
+ " ,inp.goodsname\n" +
|
|
|
+ " ,kd.USERID\n" +
|
|
|
+ " ,kd.USERCODE\n" +
|
|
|
+ " ,kd.USERNAME\n" +
|
|
|
+ " ,kd.KILNID\n" +
|
|
|
+ " ,k.KILNCODE\n" +
|
|
|
+ " ,k.KILNNAME\n" +
|
|
|
+ " ,kc.KILNCARID\n" +
|
|
|
+ " ,kc.KILNCARCODE\n" +
|
|
|
+ " ,kc.KILNCARNAME\n" +
|
|
|
+ " ,kd.KILNCARBATCHNO\n" +
|
|
|
+ " ,@KILNCARPOSITION@\n" +
|
|
|
+ " ,'窑车漏扫补件'\n" +
|
|
|
+ " ,trunc(sysdate)\n" +
|
|
|
+ " ,@ACCOUNTID@\n" +
|
|
|
+ " ,'1'\n" +
|
|
|
+ " ,@CREATEUSERID@\n" +
|
|
|
+ " ,@CREATEUSERID@\n" +
|
|
|
+ " ,inp.GROUTINGDATE\n" +
|
|
|
+ " ,inp.GROUTINGMOULDCODE\n" +
|
|
|
+ " ,inp.MOULDCODE\n" +
|
|
|
+ " ,inp.GROUTINGUSERID\n" +
|
|
|
+ " ,inp.GROUTINGUSERCODE\n" +
|
|
|
+ " ,inp.GROUTINGNUM\n" +
|
|
|
+ " ,inp.GROUTINGDAILYID\n" +
|
|
|
+ " ,inp.GROUTINGDAILYDETAILID\n" +
|
|
|
+ " ,inp.GROUTINGLINEID\n" +
|
|
|
+ " ,inp.GROUTINGLINECODE\n" +
|
|
|
+ " ,inp.GROUTINGLINENAME\n" +
|
|
|
+ " ,inp.GMOULDTYPEID\n" +
|
|
|
+ " ,inp.CANMANYTIMES\n" +
|
|
|
+ " ,inp.GROUTINGLINEDETAILID\n" +
|
|
|
+ " ,inp.SPECIALREPAIRFLAG\n" +
|
|
|
+ " ,kd.CLASSESSETTINGID\n" +
|
|
|
+ " ,inp.LOGOID\n" +
|
|
|
+ " ,kd.CREATETIME\n" +
|
|
|
+ " from tp_pm_inproduction inp\n" +
|
|
|
+ " inner join tp_pm_kilncardata kd\n" +
|
|
|
+ " on kd.kilncarbatchno = @kilncarbatchno@\n" +
|
|
|
+ " and kd.valueflag = '1'\n" +
|
|
|
+ " inner join tp_pc_productionline pline\n" +
|
|
|
+ " on pline.productionlineid = kd.productionlineid\n" +
|
|
|
+ " inner join tp_pc_procedure pcp\n" +
|
|
|
+ " on pcp.procedureid = kd.procedureid\n" +
|
|
|
+ " inner join tp_mst_kiln k\n" +
|
|
|
+ " on kd.kilnid = k.kilnid\n" +
|
|
|
+ " inner join tp_mst_kilncar kc\n" +
|
|
|
+ " on kc.kilncarid = kd.kilncarid\n" +
|
|
|
+ " where inp.barcode = @barcode@\n" +
|
|
|
+ " order by kd.kilncardataid";
|
|
|
+
|
|
|
+ string sqlUpdate = "update tp_pm_inproduction t\n" +
|
|
|
+ " set (t.KILNID\n" +
|
|
|
+ " ,t.KILNCODE\n" +
|
|
|
+ " ,t.KILNNAME\n" +
|
|
|
+ " ,t.KILNCARID\n" +
|
|
|
+ " ,t.KILNCARCODE\n" +
|
|
|
+ " ,t.KILNCARNAME\n" +
|
|
|
+ " ,t.KILNCARBATCHNO\n" +
|
|
|
+ " ,t.KILNCARPOSITION\n" +
|
|
|
+ " ,t.PROCEDUREMODEL\n" +
|
|
|
+ " ,t.MODELTYPE\n" +
|
|
|
+ " ,t.FLOWPROCEDUREID\n" +
|
|
|
+ " ,t.FLOWPROCEDURETIME\n" +
|
|
|
+ " ,t.PROCEDUREID\n" +
|
|
|
+ " ,t.PROCEDURETIME\n" +
|
|
|
+ " ,t.PRODUCTIONDATAID) =\n" +
|
|
|
+ " (select pin.KILNID\n" +
|
|
|
+ " ,pin.KILNCODE\n" +
|
|
|
+ " ,pin.KILNNAME\n" +
|
|
|
+ " ,pin.KILNCARID\n" +
|
|
|
+ " ,pin.KILNCARCODE\n" +
|
|
|
+ " ,pin.KILNCARNAME\n" +
|
|
|
+ " ,pin.KILNCARBATCHNO\n" +
|
|
|
+ " ,pin.KILNCARPOSITION\n" +
|
|
|
+ " ,pin.PROCEDUREMODEL\n" +
|
|
|
+ " ,pin.MODELTYPE\n" +
|
|
|
+ " ,pin.PROCEDUREID\n" +
|
|
|
+ " ,sysdate\n" +
|
|
|
+ " ,pin.PROCEDUREID\n" +
|
|
|
+ " ,sysdate\n" +
|
|
|
+ " ,pin.PRODUCTIONDATAID\n" +
|
|
|
+ " from tp_pm_productiondatain pin\n" +
|
|
|
+ " where pin.productiondataid =\n" +
|
|
|
+ " (select max(productiondataid)\n" +
|
|
|
+ " from tp_pm_productiondatain ppin\n" +
|
|
|
+ " where ppin.barcode = t.barcode))\n" +
|
|
|
+ " where t.barcode = @barcode@";
|
|
|
+ foreach (DataRow item in data.Rows)
|
|
|
+ {
|
|
|
+ CDAParameter[] paras = new CDAParameter[]
|
|
|
+ {
|
|
|
+ new CDAParameter("CENTRALIZEDBATCHNO", CENTRALIZEDBATCHNO),
|
|
|
+ new CDAParameter("ACCOUNTID", userInfo.AccountID),
|
|
|
+ new CDAParameter("CREATEUSERID", userInfo.UserID),
|
|
|
+ new CDAParameter("kilncarbatchno", cre.Properties["KilnCarBatchNo"]),
|
|
|
+ new CDAParameter("barcode", item["barcode"]),
|
|
|
+ new CDAParameter("KILNCARPOSITION", item["KILNCARPOSITION"]),
|
|
|
+ };
|
|
|
+
|
|
|
+ // 插入生产数据
|
|
|
+ dataAccess.ExecuteNonQuery(sqlString, paras);
|
|
|
+ // 更新在产数据
|
|
|
+ dataAccess.ExecuteNonQuery(sqlUpdate, new CDAParameter("barcode", item["barcode"]));
|
|
|
+ }
|
|
|
+
|
|
|
+ dataAccess.Commit();
|
|
|
+ return sre;
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ throw ex;
|
|
|
+ }
|
|
|
+ finally
|
|
|
+ {
|
|
|
+ dataAccess?.Dispose();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
}
|
|
|
}
|