From a032c220199d4b094b9c90685591b9330f9c1908 Mon Sep 17 00:00:00 2001 From: liqionghai <1> Date: Thu, 4 Sep 2025 12:01:26 +0800 Subject: [PATCH] 1 --- GZ_KD_Parino/Common/CommonHelper.cs | 83 +++++--- .../OrderChangeSubmitCreatePms.cs | 4 +- GZ_KD_Parino/SAL_RETURNNOTICE/AuditPushPLM.cs | 4 +- GZ_KD_Parino/SQL/SqlManage.cs | 8 +- GZ_KD_Parino/Sal_Order/AuditF_BOM.cs | 4 +- GZ_KD_Parino/Sal_Order/CreateDocument.cs | 4 +- GZ_KD_Parino/Sal_Order/CreateFolder.cs | 4 +- GZ_KD_Parino/Sal_Order/CreateItem.cs | 4 +- .../Sal_Order/OrderSubmitCreatePms.cs | 4 +- GZ_KD_Parino/Sal_Order/Save.cs | 182 +++++++++--------- 10 files changed, 170 insertions(+), 131 deletions(-) diff --git a/GZ_KD_Parino/Common/CommonHelper.cs b/GZ_KD_Parino/Common/CommonHelper.cs index 1ac9491..c316c79 100644 --- a/GZ_KD_Parino/Common/CommonHelper.cs +++ b/GZ_KD_Parino/Common/CommonHelper.cs @@ -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; + + } } } \ No newline at end of file diff --git a/GZ_KD_Parino/SAL_ORDERCHANGE/OrderChangeSubmitCreatePms.cs b/GZ_KD_Parino/SAL_ORDERCHANGE/OrderChangeSubmitCreatePms.cs index 01d7902..254e282 100644 --- a/GZ_KD_Parino/SAL_ORDERCHANGE/OrderChangeSubmitCreatePms.cs +++ b/GZ_KD_Parino/SAL_ORDERCHANGE/OrderChangeSubmitCreatePms.cs @@ -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合同基本信息", "插件日志"); } } diff --git a/GZ_KD_Parino/SAL_RETURNNOTICE/AuditPushPLM.cs b/GZ_KD_Parino/SAL_RETURNNOTICE/AuditPushPLM.cs index cae7a2d..7881f2e 100644 --- a/GZ_KD_Parino/SAL_RETURNNOTICE/AuditPushPLM.cs +++ b/GZ_KD_Parino/SAL_RETURNNOTICE/AuditPushPLM.cs @@ -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商务退货处理单","插件日志"); } diff --git a/GZ_KD_Parino/SQL/SqlManage.cs b/GZ_KD_Parino/SQL/SqlManage.cs index 622e6cc..ac3871f 100644 --- a/GZ_KD_Parino/SQL/SqlManage.cs +++ b/GZ_KD_Parino/SQL/SqlManage.cs @@ -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()); } diff --git a/GZ_KD_Parino/Sal_Order/AuditF_BOM.cs b/GZ_KD_Parino/Sal_Order/AuditF_BOM.cs index 3086dc7..e78ac07 100644 --- a/GZ_KD_Parino/Sal_Order/AuditF_BOM.cs +++ b/GZ_KD_Parino/Sal_Order/AuditF_BOM.cs @@ -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商机阶段", "插件日志"); } } diff --git a/GZ_KD_Parino/Sal_Order/CreateDocument.cs b/GZ_KD_Parino/Sal_Order/CreateDocument.cs index 3b4f11d..6791275 100644 --- a/GZ_KD_Parino/Sal_Order/CreateDocument.cs +++ b/GZ_KD_Parino/Sal_Order/CreateDocument.cs @@ -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产品定制再次出货确认单", "插件日志"); } } } diff --git a/GZ_KD_Parino/Sal_Order/CreateFolder.cs b/GZ_KD_Parino/Sal_Order/CreateFolder.cs index ae3497b..b7fe184 100644 --- a/GZ_KD_Parino/Sal_Order/CreateFolder.cs +++ b/GZ_KD_Parino/Sal_Order/CreateFolder.cs @@ -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"]), "文档云产生项目盒子", "插件日志"); } } diff --git a/GZ_KD_Parino/Sal_Order/CreateItem.cs b/GZ_KD_Parino/Sal_Order/CreateItem.cs index 6b8a7de..57cd69e 100644 --- a/GZ_KD_Parino/Sal_Order/CreateItem.cs +++ b/GZ_KD_Parino/Sal_Order/CreateItem.cs @@ -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系统项目资料检索表", "插件日志"); } } diff --git a/GZ_KD_Parino/Sal_Order/OrderSubmitCreatePms.cs b/GZ_KD_Parino/Sal_Order/OrderSubmitCreatePms.cs index d7f5022..9d4a8de 100644 --- a/GZ_KD_Parino/Sal_Order/OrderSubmitCreatePms.cs +++ b/GZ_KD_Parino/Sal_Order/OrderSubmitCreatePms.cs @@ -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合同基本信息", "插件日志"); } } diff --git a/GZ_KD_Parino/Sal_Order/Save.cs b/GZ_KD_Parino/Sal_Order/Save.cs index 11eefb3..7fe45b7 100644 --- a/GZ_KD_Parino/Sal_Order/Save.cs +++ b/GZ_KD_Parino/Sal_Order/Save.cs @@ -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(); - 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(); - //获取元数据服务 - IMetaDataService metaDataService = ServiceHelper.GetService(); + //获取加载数据服务 + IViewService viewService = ServiceHelper.GetService(); - //获取保存服务 - ISaveService saveService = ServiceHelper.GetService(); + //获取物料元数据 + FormMetadata materialMetadata = metaDataService.Load(this.Context, "BAS_PreBaseDataOne") as FormMetadata; - //获取加载数据服务 - IViewService viewService = ServiceHelper.GetService(); + //获取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"])); + //} } }