ERP接口增加详细错误日志

kyy

3 天以前 c78e94462c0ba8b3c1ec6fbcddaa3eec9ffcb980

ERP接口增加详细错误日志

在SendErp、GetErpParam和HttpPostErp方法中添加详细日志记录：
- 方法入口参数记录
- 存储过程调用前后记录
- HTTP请求发送和响应记录
- JSON构建和解析记录
- 所有分支逻辑记录

便于快速定位ERP接口错误位置

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>

 WebApi/Gs.Sys/Services/FmController.cs

@@ -389,8 +389,15 @@
            string _rtnStr = "";
            try
            {
                // 记录方法入口参数
                Gs.Toolbox.LogHelper.Debug(this.ToString(),
                    $"SendErp开始 - keyGuid:{model.keyGuid}, keyNo:{model.keyNo}, keyMeth:{model.keyMeth}, keyProduce:{model.keyProduce}, keyUrl:{model.keyUrl}");

                // 构建ERP请求参数
                Gs.Toolbox.LogHelper.Debug(this.ToString(), "SendErp - 开始调用GetErpParam");
                string _erpJson = GetErpParam(model);
                Gs.Toolbox.LogHelper.Debug(this.ToString(),
                    $"SendErp - GetErpParam返回，JSON长度:{_erpJson.Length}, 前100字符:{(_erpJson.Length > 100 ? _erpJson.Substring(0, 100) : _erpJson)}");
                if (_erpJson.Length <= 0)
                    return "-1读取erp参数失败！";
                string keyUserGuid = model.keyUserGuid;
@@ -401,14 +408,22 @@
                if (string.IsNullOrEmpty(idtype))
                {
                    // 常规接口：按操作类型推送单条业务数据
                    Gs.Toolbox.LogHelper.Debug(this.ToString(),
                        $"SendErp - 开始调用HttpPostErp(常规接口) - keyUserGuid:{keyUserGuid}, keyGuid:{keyGuid}, keyNo:{keyNo}, urlType:0, keyUrl:{keyUrl}");
                    (_rtnInt, _rtnStr) = InterfaceUtil.HttpPostErp(_erpJson,
                        keyUserGuid, keyGuid, keyNo, 0, keyUrl);
                    Gs.Toolbox.LogHelper.Debug(this.ToString(),
                        $"SendErp - HttpPostErp返回 - _rtnInt:{_rtnInt}, _rtnStr:{_rtnStr}");
                }
                else
                {
                    // 带idtype的请求用于特殊流程（如关闭、反关闭），ERP需要额外的状态标记
                    Gs.Toolbox.LogHelper.Debug(this.ToString(),
                        $"SendErp - 开始调用HttpPostErp(特殊流程) - keyUserGuid:{keyUserGuid}, keyGuid:{keyGuid}, keyNo:{keyNo}, urlType:2, keyUrl:{keyUrl}, idtype:{idtype}");
                    (_rtnInt, _rtnStr) = InterfaceUtil.HttpPostErp(_erpJson,
                        keyUserGuid, keyGuid, keyNo, 2, keyUrl);
                    Gs.Toolbox.LogHelper.Debug(this.ToString(),
                        $"SendErp - HttpPostErp返回 - _rtnInt:{_rtnInt}, _rtnStr:{_rtnStr}");
                }
            }
            catch (Exception ex)
@@ -446,9 +461,16 @@
            string keyMeth = model.keyMeth;
            string keyNo = model.keyNo;
            string idtype = model.idtype; // 仅在更新工单状态时使用

            Gs.Toolbox.LogHelper.Debug(this.ToString(),
                $"GetErpParam开始 - keyGuid:{keyGuid}, keyMeth:{keyMeth}, keyProduce:{keyProduce}, keyTaskName:{keyTaskName}, idtype:{idtype}");

            if (keyMeth.ToUpper() == "delete".ToUpper())
            {
                // 删除操作无需向ERP推送数据，只需返回空串
                Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - 删除操作，返回空串");
                return "";
            }
            try
            {
                System.Data.DataSet dset = new System.Data.DataSet();
@@ -459,31 +481,53 @@
                    new("@keyMeth", keyMeth.ToLower()),
                };
                // 调用业务定义的存储过程，将MES数据打包给ERP
                Gs.Toolbox.LogHelper.Debug(this.ToString(),
                    $"GetErpParam - 开始调用存储过程:{keyProduce}, 参数:@inOrderGuid={keyGuid}, @inEdtUserGuid={keyUserGuid}, @keyMeth={keyMeth.ToLower()}");
                dset = DbHelperSQL.RunProcedure(keyProduce, parameters, "0");
                Gs.Toolbox.LogHelper.Debug(this.ToString(),
                    $"GetErpParam - 存储过程返回，DataSet表数量:{(dset == null ? 0 : dset.Tables.Count)}");
                if (dset == null)
                {
                    Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - DataSet为null，返回空串");
                    return "";
                }
                if (dset.Tables.Count <= 0)
                {
                    Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - DataSet表数量为0，返回空串");
                    return "";
                }
                if (dset.Tables[0].Rows.Count <= 0)
                {
                    Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - 第一张表行数为0，返回空串");
                    return "";
                }

                Gs.Toolbox.LogHelper.Debug(this.ToString(),
                    $"GetErpParam - 第一张表行数:{dset.Tables[0].Rows.Count}, 列数:{dset.Tables[0].Columns.Count}");

                // 常规接口处理逻辑
                if (string.IsNullOrEmpty(idtype))
                {
                    Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - 常规接口处理逻辑");
                    // 常规出参：第一张表是主数据，第二张表（若存在）是子表集合
                    string _mesGuid = dset.Tables[0].Rows[0][0].ToString();
                    dynamic _datajson = new ExpandoObject();
                    if (dset.Tables.Count > 1)
                    {
                        Gs.Toolbox.LogHelper.Debug(this.ToString(),
                            $"GetErpParam - 多表返回，第二张表行数:{dset.Tables[1].Rows.Count}");
                        // 多表返回时，需要把子表集合挂到datajson中
                        // 结案操作的结构与其他不一样，特殊处理
                        if (keyMeth.ToLower() == "toclose".ToLower() ||
                            keyMeth.ToLower() == "closure".ToLower() ||
                            keyMeth.ToLower() == "unfinish")
                        {
                            Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - 结案操作，使用第二张表");
                            _datajson = dset.Tables[1].Rows[0].RowToDynamic();
                        }
                        else
                        {
                            Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - 常规多表，主表+子表结构");
                            _datajson = dset.Tables[0].Rows[0].RowToDynamic();
                            List<dynamic> _lst =
                                dset.Tables[1].TableToDynamicList();
@@ -493,6 +537,7 @@
                    }
                    else if (dset.Tables.Count == 1)
                    {
                        Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - 单表返回");
                        _datajson = dset.Tables[0].Rows[0].RowToDynamic();
                    }

@@ -504,10 +549,14 @@
                    //     datajson = JsonConvert.SerializeObject(_datajson),
                    // };
                    // return JsonConvert.SerializeObject(_obj);
                    return JsonConvert.SerializeObject(_datajson);
                    string jsonResult = JsonConvert.SerializeObject(_datajson);
                    Gs.Toolbox.LogHelper.Debug(this.ToString(),
                        $"GetErpParam - 常规接口JSON构建完成，长度:{jsonResult.Length}");
                    return jsonResult;
                }

                // 订单回传标识处理逻辑（带idtype）
                Gs.Toolbox.LogHelper.Debug(this.ToString(), "GetErpParam - 订单回传标识处理逻辑(idtype)");
                List<dynamic> _datajson22 = new List<dynamic>();
                dynamic _ob = new ExpandoObject();
                _ob.ENTRY = dset.Tables[0].TableToDynamicList();
@@ -519,7 +568,10 @@
                //     datajson = JsonConvert.SerializeObject(_datajson22),
                // };
                // return JsonConvert.SerializeObject(_obj22);
                return JsonConvert.SerializeObject(_datajson22);
                string jsonResult22 = JsonConvert.SerializeObject(_datajson22);
                Gs.Toolbox.LogHelper.Debug(this.ToString(),
                    $"GetErpParam - idtype接口JSON构建完成，长度:{jsonResult22.Length}");
                return jsonResult22;
            }
            catch (Exception ex)
            {

 WebApi/Gs.Toolbox/InterfaceUtil.cs

@@ -31,12 +31,17 @@
        string url = AppSettingsHelper.getValueByKey("TestErpUrl") + keyUrl;
        if (urlType == 2)
            url = AppSettingsHelper.getValueByKey("TestErpUrl2") + keyUrl;

        LogHelper.Debug("InterfaceUtil.HttpPostErp",
            $"方法入口 - url:{url}, urlType:{urlType}, hNo:{hNo}, param长度:{param.Length}, param前200字符:{(param.Length > 200 ? param.Substring(0, 200) : param)}");

        HttpWebRequest request = null;
        StreamWriter requestStream = null;
        WebResponse response = null;
        string responseStr = "";
        try
        {
            LogHelper.Debug("InterfaceUtil.HttpPostErp", $"开始创建HTTP请求 - URL:{url}");
            request = (HttpWebRequest)WebRequest.Create(url);
            request.Method = "POST";
            request.ContentType = "application/json";
@@ -48,16 +53,21 @@
                new HttpRequestCachePolicy(HttpRequestCacheLevel
                    .NoCacheNoStore);
            request.CachePolicy = noCachePolicy;
            LogHelper.Debug("InterfaceUtil.HttpPostErp", "HTTP请求配置完成，开始发送数据");
            requestStream = new StreamWriter(request.GetRequestStream());
            requestStream.Write(param);
            requestStream.Close();
            LogHelper.Debug("InterfaceUtil.HttpPostErp", "数据发送完成，等待响应");
            response = request.GetResponse();
            LogHelper.Debug("InterfaceUtil.HttpPostErp", "收到响应");
            if (response != null)
            {
                var reader = new StreamReader(response.GetResponseStream(),
                    Encoding.UTF8);
                responseStr = reader.ReadToEnd();
                reader.Close();
                LogHelper.Debug("InterfaceUtil.HttpPostErp",
                    $"响应读取完成 - 响应长度:{responseStr.Length}, 响应内容:{responseStr}");
            }
        }
        catch (Exception ex)
@@ -80,13 +90,24 @@
                  if ("200".Equals(_result.code))
                      _rtn = 1;
              }*/
      

        if (_rtn != -1)
        {
                LogHelper.Debug("InterfaceUtil.HttpPostErp", $"开始解析响应JSON - responseStr:{responseStr}");
                Result _result = JsonConvert.DeserializeObject<Result>(responseStr);
                LogHelper.Debug("InterfaceUtil.HttpPostErp",
                    $"JSON解析完成 - status:{_result?.status}, message:{_result?.message}, doc_no:{_result?.data?.doc_no}");
                // 新判断规则：status=0 且 message=Success 才算成功
                if (_result?.status == "0" && _result?.message == "Success")
                {
                    _rtn = 1;
                    LogHelper.Debug("InterfaceUtil.HttpPostErp", "判断结果：成功");
                }
                else
                {
                    LogHelper.Debug("InterfaceUtil.HttpPostErp",
                        $"判断结果：失败 - status不为0或message不为Success");
                }
               docNo = _result.data.doc_no;
        }

@@ -96,7 +117,8 @@
            sbLog.Append(",发送成功");

            //发送成功反写erp单号
           
            LogHelper.Debug("InterfaceUtil.HttpPostErp",
                $"开始调用存储过程反写ERP单号 - hNo:{hNo}, erpNo:{docNo}, Api:{keyUrl}");
            SqlParameter[] parameters =
               {
                new("@hNo", hNo),
@@ -106,11 +128,16 @@
                new("@in2", ""),
               };
            DbHelperSQL.RunProcedure("[prc_Rev_ErpNo]", parameters);
            LogHelper.Debug("InterfaceUtil.HttpPostErp", "反写ERP单号完成");
        }
        else
        {
            sbLog.Append(",发送失败,mes退出操作");
            LogHelper.Debug("InterfaceUtil.HttpPostErp", $"发送失败 - _rtn:{_rtn}");
        }
        try
        {
            LogHelper.Debug("InterfaceUtil.HttpPostErp", "开始写入日志表");
            SqlParameter[] parameters =
            {
                new("@edtUserGuid", edtUserGuid),
@@ -125,12 +152,15 @@
                new("@isErp", 1),
            };
            DbHelperSQL.RunProcedure("[prc_log_create]", parameters);
            LogHelper.Debug("InterfaceUtil.HttpPostErp", "日志表写入完成");
        }
        catch (Exception ex)
        {
            LogHelper.Debug(url, "HttpPostErp 写入日志表" + ex.Message);
        }

        LogHelper.Debug("InterfaceUtil.HttpPostErp",
            $"方法结束 - 返回值:(_rtn:{_rtn}, {(_rtn > 0 ? "strLogGuid:" + strLogGuid : "responseStr:" + responseStr)})");
        return (_rtn, (_rtn > 0 ? strLogGuid : responseStr));
    }