using System.Net.Cache;
|
using System.Net;
|
using System.Text;
|
using Newtonsoft.Json;
|
using System.Data.SqlClient;
|
|
|
namespace Gs.Toolbox;
|
|
public class InterfaceUtil
|
{
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="param">json参数</param>
|
/// <param name="edtUserGuid"></param>
|
/// <param name="abtGuid"></param>
|
/// <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, 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") + keyUrl;
|
if (urlType == 2)
|
url = AppSettingsHelper.getValueByKey("TestErpUrl2") + keyUrl;
|
HttpWebRequest request = null;
|
StreamWriter requestStream = null;
|
WebResponse response = null;
|
string responseStr = "";
|
try
|
{
|
request = (HttpWebRequest)WebRequest.Create(url);
|
request.Method = "POST";
|
request.ContentType = "application/json";
|
request.Accept = "*/*";
|
request.Timeout = 150000;
|
request.AllowAutoRedirect = false;
|
request.ServicePoint.Expect100Continue = false;
|
HttpRequestCachePolicy noCachePolicy =
|
new HttpRequestCachePolicy(HttpRequestCacheLevel
|
.NoCacheNoStore);
|
request.CachePolicy = noCachePolicy;
|
requestStream = new StreamWriter(request.GetRequestStream());
|
requestStream.Write(param);
|
requestStream.Close();
|
response = request.GetResponse();
|
if (response != null)
|
{
|
var reader = new StreamReader(response.GetResponseStream(),
|
Encoding.UTF8);
|
responseStr = reader.ReadToEnd();
|
reader.Close();
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(url,
|
"HttpPostErp response:" + param + "，ex:" + ex.Message);
|
responseStr = ex.Message;
|
_rtn = -1;
|
}
|
finally
|
{
|
request = null;
|
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);
|
// 新判断规则：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),
|
};
|
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>
|
/// 状态码：0表示成功，-1表示失败
|
/// </summary>
|
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; }
|
}
|
