419 lines
16 KiB
C#
419 lines
16 KiB
C#
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using WebApi.Models;
|
|
using WebApi.Helpers;
|
|
using System.Reflection;
|
|
using Logger;
|
|
using System.Net.Http;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace WebApi
|
|
{
|
|
public class ServerController
|
|
{
|
|
private static readonly HttpClient httpClient;
|
|
public static event Action<string> ShowMsg; // 记录日志事件
|
|
|
|
static ServerController()
|
|
{
|
|
httpClient = new HttpClient();
|
|
httpClient.Timeout = TimeSpan.FromSeconds(20); // 设置超时时间为20秒
|
|
}
|
|
|
|
/// <summary>
|
|
/// UUID生成
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public static string UuidUtil()
|
|
{
|
|
string result = Guid.NewGuid().ToString();
|
|
return result;
|
|
}
|
|
|
|
public static int SaveWebApiReqLogo(string url, string JSON)
|
|
{
|
|
int AID = -1;
|
|
try
|
|
{
|
|
//存储日志
|
|
var CreateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
|
var param = new Dictionary<string, Object>{
|
|
{ "接口地址", url },
|
|
{ "接口类型", 2 },
|
|
{ "请求内容", JSON },
|
|
{ "请求时间", CreateTime }
|
|
};
|
|
SqlServer.ExecuteProcedure("接口_IOT接口交互日志_请求记录", param, out DataTable dt, out string err);
|
|
if (dt.Rows.Count > 0)
|
|
{
|
|
AID = Convert.ToInt32(dt.Rows[0]["AID"]);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Log.FunError(ex, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
return AID;
|
|
}
|
|
|
|
public static int SaveWebApiResLogo(int AID, string JSON)
|
|
{
|
|
try
|
|
{
|
|
|
|
//new SqlParameter("@AID",AID),
|
|
//new SqlParameter("@响应时间",CreateTime),
|
|
//new SqlParameter("@响应内容",JsonConvert.SerializeObject(result))
|
|
|
|
//存储日志
|
|
var CreateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
|
var param = new Dictionary<string, Object>{
|
|
{ "AID", AID },
|
|
{ "响应时间", CreateTime },
|
|
{ "响应内容", JSON },
|
|
};
|
|
SqlServer.ExecuteProcedure("接口_IOT接口交互日志_响应记录", param, out DataTable dt, out string err);
|
|
if (dt.Rows.Count > 0)
|
|
{
|
|
AID = Convert.ToInt32(dt.Rows[0]["AID"]);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Log.FunError(ex, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
return AID;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 测试标准接口方法
|
|
/// </summary>
|
|
/// <param name="url"></param>
|
|
/// <param name="str"></param>
|
|
/// <returns></returns>
|
|
public static string TestPost(string url, string json)
|
|
{
|
|
var result = new msgResHeader();
|
|
//result.taskId = UuidUtil();
|
|
result.Result = false;
|
|
result.ErrMsg = "";
|
|
result.Data = "";
|
|
|
|
string errorMessage = "";
|
|
int AID = -1;
|
|
try
|
|
{
|
|
AID = SaveWebApiReqLogo(url, json);
|
|
|
|
// 解析订单内容，存储数据库，根据实际业务来写
|
|
test personnelBaseData = JsonConvert.DeserializeObject<test>(json);
|
|
ShowMsg?.Invoke("【" + url + "】code" + personnelBaseData.code + ",msg:" + personnelBaseData.msg);
|
|
//result.msg = errorMessage;
|
|
|
|
AID = SaveWebApiResLogo(AID, JsonConvert.SerializeObject(result));
|
|
}
|
|
catch (Exception err)
|
|
{
|
|
result.Result = false;
|
|
result.ErrMsg = err.Message;
|
|
result.Data = "ERROR";
|
|
Log.FunError(err, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 前端对AGV通用的接口转发
|
|
/// </summary>
|
|
/// <param name="url"></param>
|
|
/// <param name="str"></param>
|
|
/// <returns></returns>
|
|
public static async Task<string> MES_To_AGV_From_WEB(string url, string json)
|
|
{
|
|
var result = new msgResHeader();
|
|
result.Result = false;
|
|
result.ErrMsg = "";
|
|
result.Data = "";
|
|
|
|
string errorMessage = "";
|
|
int AID = -1;
|
|
try
|
|
{
|
|
// 显示一下接口日志
|
|
ShowMsg?.Invoke("Receive【" + url + "】" + json);
|
|
AID = SaveWebApiReqLogo(url, json);
|
|
|
|
MES_To_AGV_From_WEB_Req personnelBaseData = JsonConvert.DeserializeObject<MES_To_AGV_From_WEB_Req>(json);
|
|
// 验证必填字段
|
|
if (!ValidationHelper.ValidateRequired(personnelBaseData, out errorMessage))
|
|
{
|
|
ShowMsg?.Invoke($"****************{errorMessage}");
|
|
result.ErrMsg = errorMessage;
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
string AGVApiBaseUrl = Tools.AppConfigManage.ReadConfig("AGVApiBaseUrl");
|
|
string AGVIP = Tools.AppConfigManage.ReadConfig("AGVIP");
|
|
string AGVApiUrl = "http://" + AGVIP + AGVApiBaseUrl + personnelBaseData.url;
|
|
|
|
// 发送POST请求
|
|
var content = new StringContent(
|
|
JsonConvert.SerializeObject(personnelBaseData.data),
|
|
Encoding.UTF8,
|
|
"application/json"
|
|
);
|
|
|
|
var response = await httpClient.PostAsync(AGVApiUrl, content);
|
|
var responseContent = await response.Content.ReadAsStringAsync();
|
|
|
|
if (response.IsSuccessStatusCode)
|
|
{
|
|
result.Result = true;
|
|
result.Data = responseContent;
|
|
}
|
|
else
|
|
{
|
|
result.Result = false;
|
|
result.ErrMsg = $"请求失败: {response.StatusCode} - {responseContent}";
|
|
}
|
|
|
|
AID = SaveWebApiResLogo(AID, JsonConvert.SerializeObject(result));
|
|
}
|
|
catch (TaskCanceledException ex)
|
|
{
|
|
if (!ex.CancellationToken.IsCancellationRequested)
|
|
{
|
|
ShowMsg?.Invoke("请求超时，请检查目标服务是否可达或响应过慢！");
|
|
result.ErrMsg = "请求超时，请检查目标服务是否可达或响应过慢！";
|
|
}
|
|
else
|
|
{
|
|
ShowMsg?.Invoke("请求被主动取消！");
|
|
result.ErrMsg = "请求被主动取消！";
|
|
}
|
|
result.Data = "ERROR";
|
|
Log.FunError(ex, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
catch (Exception err)
|
|
{
|
|
result.Result = false;
|
|
result.ErrMsg = err.Message;
|
|
result.Data = "ERROR";
|
|
Log.FunError(err, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 前端对AGV通用的接口转发
|
|
/// 测试版
|
|
/// </summary>
|
|
/// <param name="url"></param>
|
|
/// <param name="str"></param>
|
|
/// <returns></returns>
|
|
public static async Task<string> MES_To_AGV_From_WEB_Test(string url, string json)
|
|
{
|
|
var result = new msgResHeader();
|
|
result.Result = false;
|
|
result.ErrMsg = "";
|
|
result.Data = "";
|
|
|
|
string errorMessage = "";
|
|
int AID = -1;
|
|
try
|
|
{
|
|
// 显示一下接口日志
|
|
ShowMsg?.Invoke("Receive【" + url + "】" + json);
|
|
AID = SaveWebApiReqLogo(url, json);
|
|
|
|
var result2 = new msgResHeader();
|
|
result2.Result = true;
|
|
result2.ErrMsg = "";
|
|
result2.Data = "";
|
|
|
|
MES_To_AGV_From_WEB_Req personnelBaseData = JsonConvert.DeserializeObject<MES_To_AGV_From_WEB_Req>(json);
|
|
// 验证必填字段
|
|
if (!ValidationHelper.ValidateRequired(personnelBaseData, out errorMessage))
|
|
{
|
|
ShowMsg?.Invoke($"****************{errorMessage}");
|
|
result.ErrMsg = errorMessage;
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
// 手动模拟
|
|
// 接口1 库区列表查询 返回固定JSON数据
|
|
if(personnelBaseData.url == "getPartitionList")
|
|
{
|
|
var partitionList = new List<object>
|
|
{
|
|
new { PartitionCode = "1", PartitionName = "隔离开关操作试验区" },
|
|
new { PartitionCode = "2", PartitionName = "断路器线边缓存位" },
|
|
new { PartitionCode = "3", PartitionName = "CT装配区" },
|
|
new { PartitionCode = "4", PartitionName = "断路器下线" },
|
|
new { PartitionCode = "5", PartitionName = "OP30产线工位" },
|
|
new { PartitionCode = "6", PartitionName = "线边缓存库" },
|
|
new { PartitionCode = "7", PartitionName = "断路器试验区" },
|
|
new { PartitionCode = "8", PartitionName = "隔离开关安装操作缓存区" },
|
|
new { PartitionCode = "9", PartitionName = "隔离开关下线" },
|
|
new { PartitionCode = "10", PartitionName = "断路器缓存区" },
|
|
new { PartitionCode = "11", PartitionName = "OP20产线工位" },
|
|
new { PartitionCode = "12", PartitionName = "OP10产线工位" }
|
|
};
|
|
result.Result = true;
|
|
result2.Data = partitionList;
|
|
result.Data = JsonConvert.SerializeObject(result2);
|
|
}
|
|
|
|
// 接口2 库位列表查询 返回固定JSON数据
|
|
if(personnelBaseData.url == "getStockList")
|
|
{
|
|
var stockList = new List<object>
|
|
{
|
|
// StockCode 库位编号
|
|
// StockName 库位名称
|
|
// StockStatus 满料状态 bool
|
|
// PalletCode 托盘编号
|
|
// EngineNo 产品编号
|
|
// SortNo 产品型号
|
|
// TaskId 任务号
|
|
|
|
new { StockCode = "6", StockName = "工位线边缓存位1", StockStatus = true, PalletCode = "pallTestCode1", EngineNo = "GCBTest01", SortNo = "P7223814G003", TaskId = "12312" },
|
|
new { StockCode = "16", StockName = "工位线边缓存位2", StockStatus = true, PalletCode = "pallTestCode2", EngineNo = "CTTest01-1", SortNo = "P7223363G001", TaskId = (string)null },
|
|
new { StockCode = "30", StockName = "工位线边缓存位3", StockStatus = false, PalletCode = "pallTestCode3", EngineNo = (string)null, SortNo = (string)null, TaskId = (string)null },
|
|
new { StockCode = "2", StockName = "工位线边缓存位4", StockStatus = false, PalletCode = (string)null, EngineNo = (string)null, SortNo = (string)null, TaskId = (string)null },
|
|
};
|
|
result.Result = true;
|
|
result2.Data = stockList;
|
|
result.Data = JsonConvert.SerializeObject(result2);
|
|
|
|
}
|
|
|
|
// 接口3 更新库位信息
|
|
if (personnelBaseData.url == "updateStockInfo")
|
|
{
|
|
result.Result = true;
|
|
result.Data = JsonConvert.SerializeObject(result2);
|
|
}
|
|
|
|
// 接口4 创建送料任务
|
|
if (personnelBaseData.url == "createTask")
|
|
{
|
|
result.Result = true;
|
|
result.Data = JsonConvert.SerializeObject(result2);
|
|
}
|
|
|
|
AID = SaveWebApiResLogo(AID, JsonConvert.SerializeObject(result));
|
|
}
|
|
catch (TaskCanceledException ex)
|
|
{
|
|
if (!ex.CancellationToken.IsCancellationRequested)
|
|
{
|
|
ShowMsg?.Invoke("请求超时，请检查目标服务是否可达或响应过慢！");
|
|
result.ErrMsg = "请求超时，请检查目标服务是否可达或响应过慢！";
|
|
}
|
|
else
|
|
{
|
|
ShowMsg?.Invoke("请求被主动取消！");
|
|
result.ErrMsg = "请求被主动取消！";
|
|
}
|
|
result.Data = "ERROR";
|
|
Log.FunError(ex, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
catch (Exception err)
|
|
{
|
|
result.Result = false;
|
|
result.ErrMsg = err.Message;
|
|
result.Data = "ERROR";
|
|
Log.FunError(err, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
/// <summary>
|
|
/// AGV到位,离开
|
|
/// </summary>
|
|
/// <param name="url"></param>
|
|
/// <param name="str"></param>
|
|
/// <returns></returns>
|
|
public static async Task<string> AGV_To_MES_AgvPass(string url, string json)
|
|
{
|
|
var result = new msgResHeader();
|
|
result.Result = false;
|
|
result.ErrMsg = "";
|
|
result.Data = "";
|
|
|
|
string errorMessage = "";
|
|
int AID = -1;
|
|
try
|
|
{
|
|
// 显示一下接口日志
|
|
ShowMsg?.Invoke("Receive【" + url + "】" + json);
|
|
AID = SaveWebApiReqLogo(url, json);
|
|
|
|
// 解析订单内容，存储数据库，根据实际业务来写
|
|
AGV_To_MES_AgvPass_Req personnelBaseData = JsonConvert.DeserializeObject<AGV_To_MES_AgvPass_Req>(json);
|
|
|
|
// 验证必填字段
|
|
if (!ValidationHelper.ValidateRequired(personnelBaseData, out errorMessage))
|
|
{
|
|
ShowMsg?.Invoke($"****************{errorMessage}");
|
|
result.ErrMsg = errorMessage;
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
|
|
int workOverType = 0;
|
|
if (personnelBaseData.type == 0)
|
|
{
|
|
workOverType = 1;
|
|
}
|
|
else if (personnelBaseData.type == 1)
|
|
{
|
|
workOverType = 3;
|
|
}
|
|
else
|
|
{
|
|
ShowMsg?.Invoke($"****************未识别的type{workOverType}");
|
|
result.ErrMsg = $"未识别的Type{workOverType}";
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
var param = new Dictionary<string, Object>{
|
|
{ "工位号", personnelBaseData.station },
|
|
{ "任务编号", personnelBaseData.taskId },
|
|
{ "工件编号", personnelBaseData.EngineNo },
|
|
{ "type", workOverType},
|
|
};
|
|
SqlServer.ExecuteProcedure("PTCHV_AGV_进离站", param, out DataTable dt, out errorMessage);
|
|
// 验证必填字段
|
|
if (errorMessage.Length > 0)
|
|
{
|
|
ShowMsg?.Invoke($"****************{errorMessage}");
|
|
result.ErrMsg = errorMessage;
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
|
|
await MqttServer.SendMqttMessageToOp(personnelBaseData.station, "AGVStatus", workOverType.ToString());
|
|
|
|
result.Result = true;
|
|
AID = SaveWebApiResLogo(AID, JsonConvert.SerializeObject(result));
|
|
}
|
|
catch (Exception err)
|
|
{
|
|
result.Result = false;
|
|
result.ErrMsg = err.Message;
|
|
result.Data = "ERROR";
|
|
Log.FunError(err, MethodBase.GetCurrentMethod().Name);
|
|
}
|
|
|
|
return JsonConvert.SerializeObject(result);
|
|
}
|
|
}
|
|
}
|