接口改为富达模式

kyy

4 天以前 bd18a149bfd83807d7cbcf80a2384ef502184a96

 WebApi/Gs.Toolbox/InterfaceUtil.cs

@@ -18,16 +18,19 @@
    /// <param name="hNo"></param>
    /// <param name="urlType">如果为2，则是更新工单状态</param>
    /// <returns>如果成功返回日志guid,否则返回串</returns>
    public static (int, string) HttpPostErp(string param, string edtUserGuid = "", string abtGuid = "", string hNo = "", int urlType = 0)
    public static (int, string) HttpPostErp(string param,
        string edtUserGuid = "", string abtGuid = "", string hNo = "",
        int urlType = 0, string keyUrl = "")
    {
        int _rtn = 0;
        string docNo = string.Empty;
        //日志详细，发送的时候，记录日志，存储过程调用的时候，再累加上mes业务的操作结果
        System.Text.StringBuilder sbLog = new System.Text.StringBuilder();
        sbLog.Append(DateTime.Now.ToString() + "开始发送");
        string strLogGuid = Guid.NewGuid().ToString();
        string url = AppSettingsHelper.getValueByKey("TestErpUrl");
        string url = AppSettingsHelper.getValueByKey("TestErpUrl") + keyUrl;
        if (urlType == 2)
            url = AppSettingsHelper.getValueByKey("TestErpUrl2");
            url = AppSettingsHelper.getValueByKey("TestErpUrl2") + keyUrl;
        HttpWebRequest request = null;
        StreamWriter requestStream = null;
        WebResponse response = null;
@@ -41,7 +44,9 @@
            request.Timeout = 150000;
            request.AllowAutoRedirect = false;
            request.ServicePoint.Expect100Continue = false;
            HttpRequestCachePolicy noCachePolicy = new HttpRequestCachePolicy(HttpRequestCacheLevel.NoCacheNoStore);
            HttpRequestCachePolicy noCachePolicy =
                new HttpRequestCachePolicy(HttpRequestCacheLevel
                    .NoCacheNoStore);
            request.CachePolicy = noCachePolicy;
            requestStream = new StreamWriter(request.GetRequestStream());
            requestStream.Write(param);
@@ -57,7 +62,8 @@
        }
        catch (Exception ex)
        {
            LogHelper.Debug(url, "HttpPostErp response:" + param + "，ex:" + ex.Message);
            LogHelper.Debug(url,
                "HttpPostErp response:" + param + "，ex:" + ex.Message);
            responseStr = ex.Message;
            _rtn = -1;
        }
@@ -67,51 +73,110 @@
            requestStream = null;
            response = null;
        }

        /*if (_rtn != -1)
              {
                  Result _result = JsonConvert.DeserializeObject<Result>(responseStr);
                  if ("200".Equals(_result.code))
                      _rtn = 1;
              }*/
      
        if (_rtn != -1)
        {
            Result _result = JsonConvert.DeserializeObject<Result>(responseStr);
            if ("200".Equals(_result.state))
                _rtn = 1;
                Result _result = JsonConvert.DeserializeObject<Result>(responseStr);
                // 新判断规则：status=0 且 message=Success 才算成功
                if (_result?.status == "0" && _result?.message == "Success")
                    _rtn = 1;
               docNo = _result.data.doc_no;
        }

        sbLog.Append("," + DateTime.Now.ToString() + "结束发送");
        if (_rtn > 0)
        {
            sbLog.Append(",发送成功");

            //发送成功反写erp单号
           
            SqlParameter[] parameters =
               {
                new("@hNo", hNo),
                new("@erpNo",docNo),
                new("@Api", keyUrl)  ,
                new("@in1", ""),
                new("@in2", ""),
               };
            DbHelperSQL.RunProcedure("[prc_Rev_ErpNo]", parameters);
        }
        else
            sbLog.Append(",发送失败,mes退出操作");
        try
        {
            SqlParameter[] parameters =
    {
            new("@edtUserGuid", edtUserGuid),
            new("@abtGuid", abtGuid),
            new("@abtTable", ""),
            new("@detail", sbLog.ToString()),
            new("@hNo", hNo),
            new("@RtnLogGuid", strLogGuid),
            new("@SendJson", param),
            new("@RtnJson", responseStr),
            new("@isSuccess", (_rtn>0?1:0)),
            new("@isErp", 1),
        };
            {
                new("@edtUserGuid", edtUserGuid),
                new("@abtGuid", abtGuid),
                new("@abtTable", ""),
                new("@detail", sbLog.ToString()),
                new("@hNo", hNo),
                new("@RtnLogGuid", strLogGuid),
                new("@SendJson", param),
                new("@RtnJson", responseStr),
                new("@isSuccess", (_rtn > 0 ? 1 : 0)),
                new("@isErp", 1),
            };
            DbHelperSQL.RunProcedure("[prc_log_create]", parameters);
        }
        catch (Exception ex)
        {
            LogHelper.Debug(url, "HttpPostErp 写入日志表" + ex.Message);
        }

        return (_rtn, (_rtn > 0 ? strLogGuid : responseStr));
    }


}


/// <summary>
/// 接口返回结果根对象
/// </summary>
public class Result
{
    /// <summary>
    /// 200成功，否则失败
    /// 状态码：0表示成功，-1表示失败
    /// </summary>
    public string? state { get; set; }
    public string? msg { get; set; }

    public string? status { get; set; }

    /// <summary>
    /// 状态描述：Success表示成功，失败时为具体异常信息
    /// </summary>
    public string? message { get; set; }

    /// <summary>
    /// 数据体：成功时返回到货单信息，失败时为具体异常信息
    /// </summary>
    public ResultData? data { get; set; }
}

/// <summary>
/// 接口返回的Data对象（强类型）
/// 对应JSON：{"doc_type_no":"370","doc_no":"20251209001","msg":"创建到货单成功."}
/// </summary>
public class ResultData
{
    /// <summary>
    /// 单据类型编号
    /// </summary>
    public string? doc_type_no { get; set; }

    /// <summary>
    /// 单据编号
    /// </summary>
    public string? doc_no { get; set; }

    /// <summary>
    /// 操作结果描述
    /// </summary>
    public string? msg { get; set; }
}