Develop/GZ_KD_Parino
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
liqionghai 2025-09-04 12:01:26 +08:00
parent 5f0dcee068
commit a032c22019
10 changed files with 170 additions and 131 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
GZ_KD_Parino/Common/CommonHelper.cs
View File

@ -113,12 +113,12 @@ namespace GZ_KD_Parino.Common
SaveTxt(Convert.ToString(httpClient.Url), FApiPath, JsonConvert.SerializeObject(resule));
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100","", JsonConvert.SerializeObject(resule), requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100","", JsonConvert.SerializeObject(resule), requestUrl, "文档云产生项目盒子", "接口日志");
}
catch(Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl, "文档云产生项目盒子", "接口日志");
Logger.Error("获取文档云的Token异常", ex.Message, new Exception());
}
@ -168,12 +168,12 @@ namespace GZ_KD_Parino.Common
SaveTxt(Convert.ToString(httpClient.Url), FApiPath, JsonConvert.SerializeObject(resule));
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", JsonConvert.SerializeObject(resule), requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", JsonConvert.SerializeObject(resule), requestUrl, "文档云产生项目盒子", "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl, "文档云产生项目盒子", "接口日志");
Logger.Error("获取文件夹异常", ex.Message, new Exception());
}
@ -217,12 +217,12 @@ namespace GZ_KD_Parino.Common
SaveTxt(Convert.ToString(httpClient.Url) + "\r\n" + httpClient.Content, FApiPath, JsonConvert.SerializeObject(resule));
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", JsonConvert.SerializeObject(resule), requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", JsonConvert.SerializeObject(resule), requestUrl, "文档云产生项目盒子", "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl, "文档云产生项目盒子", "接口日志");
Logger.Error("创建父项文件夹异常", ex.Message, new Exception());
}
@ -363,12 +363,12 @@ namespace GZ_KD_Parino.Common
SaveTxt(Convert.ToString(httpClient.Url) + "\r\n" + httpClient.Content, FApiPath, JsonConvert.SerializeObject(resule));
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", JsonConvert.SerializeObject(resule), requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", JsonConvert.SerializeObject(resule), requestUrl, "文档云产生项目盒子", "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl, "文档云产生项目盒子", "接口日志");
Logger.Error("创建多层级文件夹异常", ex.Message, new Exception());
}
@ -467,12 +467,12 @@ namespace GZ_KD_Parino.Common
string.Format(@"D:\Api日志\{2}\创建流程\{0}\创建流程\{1}.txt",
Convert.ToString(data[0]["单据编号"]), DateTime.Now.ToString("yyyyMMddHHmmssfff"), ctx.DataCenterName), retString);
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100","", retString, requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100","", retString, requestUrl, "产品生产出货预置单", "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrl, "产品生产出货预置单", "接口日志");
Logger.Error("创建流程异常", ex.Message,new Exception());
}
@ -577,12 +577,12 @@ namespace GZ_KD_Parino.Common
string.Format(@"D:\Api日志\{2}\创建流程\{0}\创建流程\{1}.txt",
Convert.ToString(data[0]["单据编号"]), DateTime.Now.ToString("yyyyMMddHHmmssfff"), ctx.DataCenterName), retString);
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100","", retString, requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100","", retString, requestUrl, "BPM产品定制再次出货确认单", "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4",ex.Message,"", requestUrl);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4",ex.Message,"", requestUrl, "BPM产品定制再次出货确认单", "接口日志");
Logger.Error("创建流程异常", ex.Message, new Exception());
}
@ -680,12 +680,12 @@ namespace GZ_KD_Parino.Common
userBinding = jo["binding"] == null ? "" : jo["binding"].ToString();
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result, getUserBinding_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result, getUserBinding_url, "PMS登录", "接口日志");
}
catch(Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", getUserBinding_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", getUserBinding_url, "PMS登录", "接口日志");
Logger.Error("调用PMS接口异常", ex.Message, new Exception());
}
@ -713,6 +713,7 @@ namespace GZ_KD_Parino.Common
Guid idkey = Guid.Empty;
string result2 = "";
string up_url = "";
try
{
//写入日志
@ -744,12 +745,12 @@ namespace GZ_KD_Parino.Common
Convert.ToString(data[0]["单据编号"]), DateTime.Now.ToString("yyyyMMddHHmmssfff"), ctx.DataCenterName, FType), result2);
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url, GetTypeName(FType), "接口日志");
}
catch(Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", up_url, GetTypeName(FType), "接口日志");
Logger.Error("创建待分配项目异常", ex.Message, new Exception());
}
@ -1164,12 +1165,12 @@ namespace GZ_KD_Parino.Common
Convert.ToString(data[0]["单据编号"]), DateTime.Now.ToString("yyyyMMddHHmmssfff"), ctx.DataCenterName, FType), result2);
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url, GetTypeName(FType), "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "",up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "",up_url, GetTypeName(FType), "接口日志");
Logger.Error("创建待分配项目异常", ex.Message, new Exception());
}
@ -1210,12 +1211,12 @@ namespace GZ_KD_Parino.Common
}
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url, GetTypeName(FType), "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", up_url, GetTypeName(FType), "接口日志");
Logger.Error("查询HTB的ID异常", ex.Message, new Exception());
}
@ -1244,12 +1245,12 @@ namespace GZ_KD_Parino.Common
Convert.ToString(data[0]["单据编号"]), DateTime.Now.ToString("yyyyMMddHHmmssfff"), ctx.DataCenterName, "htbaseinfo-BG"), result2);
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", result2, up_url, GetTypeName(Ftype), "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", up_url);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", up_url, GetTypeName(Ftype), "接口日志");
Logger.Error("更改订单金额异常", ex.Message, new Exception());
}
@ -1354,15 +1355,49 @@ namespace GZ_KD_Parino.Common
string.Format(@"D:\Api日志\{2}\创建流程\{0}\创建流程\{1}.txt", Convert.ToString(data[0]["单据编号"]), DateTime.Now.ToString("yyyyMMddHHmmssfff"), ctx.DataCenterName), retString);
//修改日志为成功
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", retString, requestUrL);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "100", "", retString, requestUrL, "BPM商务退货处理单", "接口日志");
}
catch (Exception ex)
{
//修改日志为异常，记录异常日志,不能抛异常
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrL);
SQL.SqlManage.UpdateDockingPLMLog(ctx, idkey, "4", ex.Message, "", requestUrL, "BPM商务退货处理单", "接口日志");
Logger.Error("创建待分配项目异常", ex.Message, new Exception());
}
return sn;
}
private static string GetTypeName(string type)
{
string TypeName = "";
switch (type)
{
case "xmfpb":
TypeName = "PMS项目分配表";
break;
case "htbaseinfo":
TypeName = "PMS合同基本信息";
break;
case "otherItem":
TypeName = "PMS系统项目资料检索表";
break;
case "CustMadeAgain":
TypeName = "BPM产品定制再次出货确认单";
break;
case "ProductShipInit":
TypeName = "产品生产出货预置单";
break;
case "ITBusiness":
TypeName = "BPM商务退货处理单";
break;
case "htbaseinfo-BG":
TypeName = "";
break;
case "Opportunity":
TypeName = "更改PMS商机阶段";
break;
}
return TypeName;
}
}
}

4
GZ_KD_Parino/SAL_ORDERCHANGE/OrderChangeSubmitCreatePms.cs
View File

@ -71,12 +71,12 @@ namespace GZ_KD_Parino.SAL_ORDERCHANGE
}
}
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", result2, Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", result2, Convert.ToString(Billobj["Id"]), "PMS合同基本信息","插件日志");
}
catch (Exception ex)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]), "PMS合同基本信息", "插件日志");
}
}

4
GZ_KD_Parino/SAL_RETURNNOTICE/AuditPushPLM.cs
View File

@ -35,12 +35,12 @@ namespace GZ_KD_Parino.SAL_RETURNNOTICE
SqlManage.UpdateSal_ReturnnoticeSH(this.Context, Convert.ToString(Billobj["Id"]));
}
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", sn, Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", sn, Convert.ToString(Billobj["Id"]), "BPM商务退货处理单", "插件日志");
}
catch (Exception ex)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]), "BPM商务退货处理单","插件日志");
}

8
GZ_KD_Parino/SQL/SqlManage.cs
View File

@ -517,15 +517,17 @@ namespace GZ_KD_Parino.SQL
}
public static void UpdateDockingPLMLog(Context ctx, Guid newid,string FuncStatus,string ExceptionInfo, string Result,string RequestParamInfo)
public static void UpdateDockingPLMLog(Context ctx, Guid newid,string FuncStatus,string ExceptionInfo, string Result,string RequestParamInfo,string Method,string FuncMethod)
{
string sql = $@" UPDATE [ZZZ_DockingPLMLog] SET [FuncStatus] = @FuncStatus,[ExceptionInfo] = @ExceptionInfo,[Result] = @Result,[ParamInfo] = @ParamInfo WHERE [Id]= @newid";
SqlParam[] param = new SqlParam[5];
string sql = $@" UPDATE [ZZZ_DockingPLMLog] SET [FuncStatus] = @FuncStatus,[ExceptionInfo] = @ExceptionInfo,[Result] = @Result,[ParamInfo] = @ParamInfo,[MethodType] = @MethodType,[FuncMethod] = @FuncMethod WHERE [Id]= @newid";
SqlParam[] param = new SqlParam[7];
param[0] = new SqlParam("@newid", KDDbType.Guid, newid);
param[1] = new SqlParam("@FuncStatus", KDDbType.String, FuncStatus);
param[2] = new SqlParam("@ExceptionInfo", KDDbType.String, ExceptionInfo);
param[3] = new SqlParam("@Result", KDDbType.String, Result);
param[4] = new SqlParam("@ParamInfo", KDDbType.String, RequestParamInfo);
param[5] = new SqlParam("@MethodType", KDDbType.String, Method);
param[6] = new SqlParam("@FuncMethod", KDDbType.String, FuncMethod);
var n = DBServiceHelper.Execute(ctx, sql.ToString(), param.ToList());
}

4
GZ_KD_Parino/Sal_Order/AuditF_BOM.cs
View File

@ -54,12 +54,12 @@ namespace GZ_KD_Parino.Sal_Order
}
}
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", Token, Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", Token, Convert.ToString(Billobj["Id"]), "更改PMS商机阶段", "插件日志");
}
catch (Exception ex)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]), "更改PMS商机阶段", "插件日志");
}
}

4
GZ_KD_Parino/Sal_Order/CreateDocument.cs
View File

@ -64,12 +64,12 @@ namespace GZ_KD_Parino.Sal_Order
SqlManage.UpdateBMPSN(this.Context, Convert.ToString(Billobj["Id"]), sn);
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", sn, Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", sn, Convert.ToString(Billobj["Id"]), "产品生产出货预置单,BPM产品定制再次出货确认单", "插件日志");
}
catch (Exception ex)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]), "产品生产出货预置单,BPM产品定制再次出货确认单", "插件日志");
}
}
}

4
GZ_KD_Parino/Sal_Order/CreateFolder.cs
View File

@ -118,12 +118,12 @@ namespace GZ_KD_Parino.Sal_Order
}
}
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", "", Convert.ToString(Billobj["Id"]), "文档云产生项目盒子", "插件日志");
}
catch (Exception ex)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]), "文档云产生项目盒子", "插件日志");
}
}

4
GZ_KD_Parino/Sal_Order/CreateItem.cs
View File

@ -149,12 +149,12 @@ namespace GZ_KD_Parino.Sal_Order
}
}
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", "", Convert.ToString(Billobj["Id"]), "PMS项目分配表,PMS系统项目资料检索表", "插件日志");
}
catch(Exception ex)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]), "PMS项目分配表,PMS系统项目资料检索表", "插件日志");
}
}

4
GZ_KD_Parino/Sal_Order/OrderSubmitCreatePms.cs
View File

@ -82,12 +82,12 @@ namespace GZ_KD_Parino.Sal_Order
}
}
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", Resultstring, Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", Resultstring, Convert.ToString(Billobj["Id"]), "PMS合同基本信息","插件日志");
}
catch (Exception ex)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]), "PMS合同基本信息", "插件日志");
}
}

182
GZ_KD_Parino/Sal_Order/Save.cs
View File

@ -59,115 +59,117 @@ namespace GZ_KD_Parino.Sal_Order
//获取销售组织
var SalZZFid = Billobj["SaleOrgId_Id"].ToString();
var key = SqlManage.SetDockingPLMLog(this.Context, "销售订单--创建工程项目", Convert.ToInt32(Billobj["Id"]));
try
var FBILLTYPEID = Convert.ToString(Billobj["BILLTYPEID_Id"]);
if (F_BON == null)
{
var FBILLTYPEID = Convert.ToString(Billobj["BILLTYPEID_Id"]);
if (F_BON == null)
{
continue;
}
//获取纸质合同号
var FlexNumber = SqlManage.GetFlexNumber(this.Context, Convert.ToString(Billobj["Id"]));
//如果已经存在纸质合同号，则不继续执行操作
if (FlexNumber == "")
{
return;
}
//退货订单不需要创建工程项目
if (FBILLTYPEID != "eacb50844fc84a10b03d7b841f3a6278")
{
continue;
}
//创建上下文变量,默认为administrator
var ctx = this.Context;
continue;
}
//获取纸质合同号
var FlexNumber = SqlManage.GetFlexNumber(this.Context, Convert.ToString(Billobj["Id"]));
//如果已经存在纸质合同号，则不继续执行操作
if (FlexNumber == "")
{
return;
}
//退货订单不需要创建工程项目
if (FBILLTYPEID != "eacb50844fc84a10b03d7b841f3a6278")
{
continue;
}
//创建上下文变量,默认为administrator
var ctx = this.Context;
//获取当前用户名 和 用户ID
ctx.UserId = Convert.ToInt32(this.Context.UserId);
ctx.UserName = Convert.ToString(this.Context.UserName);
//获取当前用户名 和 用户ID
ctx.UserId = Convert.ToInt32(this.Context.UserId);
ctx.UserName = Convert.ToString(this.Context.UserName);
string fid = "";
if (SqlManage.CheckItem(this.Context, FlexNumber, "1").Count == 0)
string fid = "";
if (SqlManage.CheckItem(this.Context, FlexNumber, "1").Count == 0)
{
//创建工程项目
fid = CommonHelper.CreateItemData(ctx, "1", FlexNumber, Convert.ToString(F_BON["Name"]));
}
else
{
string sql = string.Format(@"SELECT A.FID AS FID,A.FNUMBER AS FNUMBER FROM T_BAS_PREBDONE A LEFT JOIN T_BAS_PREBDONE_L B on A.FID = B.FID WHERE FNUMBER = '{0}' AND A.FUSEORGID = '1' AND B.FNAME = '{1}'", FlexNumber, Convert.ToString(Convert.ToString(F_BON["Name"])));
var sqlDS = DBUtils.ExecuteDynamicObject(this.Context, sql);
if (sqlDS.Count != 0)
{
//创建工程项目
fid = CommonHelper.CreateItemData(ctx, "1", FlexNumber, Convert.ToString(F_BON["Name"]));
fid = sqlDS[0]["FID"].ToString();
}
else
{
string sql = string.Format(@"SELECT A.FID AS FID,A.FNUMBER AS FNUMBER FROM T_BAS_PREBDONE A LEFT JOIN T_BAS_PREBDONE_L B on A.FID = B.FID WHERE FNUMBER = '{0}' AND A.FUSEORGID = '1' AND B.FNAME = '{1}'", FlexNumber, Convert.ToString(Convert.ToString(F_BON["Name"])));
var sqlDS = DBUtils.ExecuteDynamicObject(this.Context, sql);
if (sqlDS.Count != 0)
string sql1 = string.Format(@"SELECT FID FROM T_BAS_PREBDONE WHERE FNUMBER = '{0}' AND FUSEORGID = '{1}'", FlexNumber, SalZZFid);
var sqlDS1 = DBUtils.ExecuteDynamicObject(this.Context, sql1);
if (sqlDS1.Count == 0)
{
fid = sqlDS[0]["FID"].ToString();
throw new Exception($"商机名称：{F_BON["Name"].ToString()},不存在对应的工程项目。");
}
else
{
string sql1 = string.Format(@"SELECT FID FROM T_BAS_PREBDONE WHERE FNUMBER = '{0}' AND FUSEORGID = '{1}'", FlexNumber, SalZZFid);
fid = sqlDS1[0]["FID"].ToString();
// 更新项目名称
string F_contractnumberSQL1 = string.Format(@"UPDATE T_BAS_PREBDONE_L SET FNAME = '{0}' WHERE fid in (SELECT FID FROM T_BAS_PREBDONE WHERE FNUMBER = '{1}' AND FUSEORGID = '{2}' )", Convert.ToString(F_BON["Name"]), FlexNumber, SalZZFid);
DBUtils.ExecuteDynamicObject(ctx, F_contractnumberSQL1.ToString(), null, null, CommandType.Text, null);
// 更新项目状态
var F_contractnumberSQL2 = string.Format(@"UPDATE T_BAS_PREBDONE SET F_CXSFBG = 1 WHERE FNUMBER = '{0}' AND FUSEORGID = '{1}'", FlexNumber, SalZZFid);
DBUtils.ExecuteDynamicObject(ctx, F_contractnumberSQL2.ToString(), null, null, CommandType.Text, null);
var sqlDS1 = DBUtils.ExecuteDynamicObject(this.Context, sql1);
//获取元数据服务
IMetaDataService metaDataService = ServiceHelper.GetService<IMetaDataService>();
if (sqlDS1.Count == 0)
{
throw new Exception($"商机名称：{F_BON["Name"].ToString()},不存在对应的工程项目。");
}
fid = sqlDS1[0]["FID"].ToString();
// 更新项目名称
string F_contractnumberSQL1 = string.Format(@"UPDATE T_BAS_PREBDONE_L SET FNAME = '{0}' WHERE fid in (SELECT FID FROM T_BAS_PREBDONE WHERE FNUMBER = '{1}' AND FUSEORGID = '{2}' )", Convert.ToString(F_BON["Name"]), FlexNumber, SalZZFid);
DBUtils.ExecuteDynamicObject(ctx, F_contractnumberSQL1.ToString(), null, null, CommandType.Text, null);
// 更新项目状态
var F_contractnumberSQL2 = string.Format(@"UPDATE T_BAS_PREBDONE SET F_CXSFBG = 1 WHERE FNUMBER = '{0}' AND FUSEORGID = '{1}'", FlexNumber, SalZZFid);
DBUtils.ExecuteDynamicObject(ctx, F_contractnumberSQL2.ToString(), null, null, CommandType.Text, null);
//获取保存服务
ISaveService saveService = ServiceHelper.GetService<ISaveService>();
//获取元数据服务
IMetaDataService metaDataService = ServiceHelper.GetService<IMetaDataService>();
//获取加载数据服务
IViewService viewService = ServiceHelper.GetService<IViewService>();
//获取保存服务
ISaveService saveService = ServiceHelper.GetService<ISaveService>();
//获取物料元数据
FormMetadata materialMetadata = metaDataService.Load(this.Context, "BAS_PreBaseDataOne") as FormMetadata;
//获取加载数据服务
IViewService viewService = ServiceHelper.GetService<IViewService>();
//获取ID的工程项目数据
DynamicObject[] objs = viewService.Load(
this.Context,
new object[] { fid },
materialMetadata.BusinessInfo.GetDynamicObjectType()
);
//获取物料元数据
FormMetadata materialMetadata = metaDataService.Load(this.Context, "BAS_PreBaseDataOne") as FormMetadata;
//获取ID的工程项目数据
DynamicObject[] objs = viewService.Load(
this.Context,
new object[] { fid },
materialMetadata.BusinessInfo.GetDynamicObjectType()
);
//调用保存工程项目数据的保存服务
saveService.Save(this.Context, objs);
saveService.Save(this.Context, materialMetadata.BusinessInfo, objs);
}
//调用保存工程项目数据的保存服务
saveService.Save(this.Context, objs);
saveService.Save(this.Context, materialMetadata.BusinessInfo, objs);
}
//判断该销售组织是否存在工程项目
if (SqlManage.CheckItem(this.Context, FlexNumber, Convert.ToString((Billobj["SaleOrgId"] as DynamicObject)["Id"])).Count == 0)
{
var SaleOrgId = Billobj["SaleOrgId"] as DynamicObject;
CommonHelper.Allocate(ctx, fid, "BAS_PreBaseDataOne", Convert.ToString(SaleOrgId["Id"]), Convert.ToString(SaleOrgId["Name"]));
}
//判断该备货组织是否存在工程项目
if (SqlManage.CheckItem(this.Context, FlexNumber, Convert.ToString((Billobj["F_SaleOrgId"] as DynamicObject)["Id"])).Count == 0)
{
var F_SaleOrgId = Billobj["F_SaleOrgId"] as DynamicObject;
//分配工程项目
CommonHelper.Allocate(ctx, fid, "BAS_PreBaseDataOne", Convert.ToString(F_SaleOrgId["Id"]), Convert.ToString(F_SaleOrgId["Name"]));
}
//反写工程项目
SqlManage.UpdateItemData(this.Context, Convert.ToString(Billobj["Id"]), FlexNumber);
//修改日志为成功
SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", "", Convert.ToString(Billobj["Id"]));
}
catch (Exception ex)
//判断该销售组织是否存在工程项目
if (SqlManage.CheckItem(this.Context, FlexNumber, Convert.ToString((Billobj["SaleOrgId"] as DynamicObject)["Id"])).Count == 0)
{
//修改日志为异常
SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
var SaleOrgId = Billobj["SaleOrgId"] as DynamicObject;
CommonHelper.Allocate(ctx, fid, "BAS_PreBaseDataOne", Convert.ToString(SaleOrgId["Id"]), Convert.ToString(SaleOrgId["Name"]));
}
//判断该备货组织是否存在工程项目
if (SqlManage.CheckItem(this.Context, FlexNumber, Convert.ToString((Billobj["F_SaleOrgId"] as DynamicObject)["Id"])).Count == 0)
{
var F_SaleOrgId = Billobj["F_SaleOrgId"] as DynamicObject;
//分配工程项目
CommonHelper.Allocate(ctx, fid, "BAS_PreBaseDataOne", Convert.ToString(F_SaleOrgId["Id"]), Convert.ToString(F_SaleOrgId["Name"]));
}
//反写工程项目
SqlManage.UpdateItemData(this.Context, Convert.ToString(Billobj["Id"]), FlexNumber);
//var key = SqlManage.SetDockingPLMLog(this.Context, "销售订单--创建工程项目", Convert.ToInt32(Billobj["Id"]));
//try
//{
// //修改日志为成功
// SqlManage.UpdateDockingPLMLog(this.Context, key, "100", "", "", Convert.ToString(Billobj["Id"]));
//}
//catch (Exception ex)
//{
// //修改日志为异常
// SqlManage.UpdateDockingPLMLog(this.Context, key, "4", ex.Message, "", Convert.ToString(Billobj["Id"]));
//}
}
}