using System.Dynamic;
|
using Azure;
|
using Microsoft.AspNetCore.Mvc;
|
using NewPdaSqlServer.Dto.service;
|
using NewPdaSqlServer.entity;
|
using NewPdaSqlServer.util;
|
using Newtonsoft.Json.Linq;
|
using System.ServiceModel;
|
using System.IO;
|
using NewPdaSqlServer.Dto.Warehouse;
|
using NewPdaSqlServer.DB;
|
using Newtonsoft.Json;
|
|
namespace NewPdaSqlServer.Controllers.AGV;
|
|
[Route("api/[controller]")]
|
[ApiController]
|
public class AgvApiController : ControllerBase
|
{
|
OaApiService m = new OaApiService();
|
|
//在类内添加日志方法
|
// private void LogToFile(string methodName, object request, string response)
|
//{
|
// string logPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Logs", $"AgvLog_{DateTime.Now:yyyyMMdd}.log");
|
// Directory.CreateDirectory(Path.GetDirectoryName(logPath));
|
|
// string logContent = $"[{DateTime.Now:HH:mm:ss}] 方法：{methodName}\n" +
|
// $"请求参数：{JObject.FromObject(request)}\n" +
|
// $"响应结果：{response}\n\n";
|
|
// File.AppendAllText(logPath, logContent);
|
//}
|
|
// 修改现有方法（以AgvTest为例）
|
[HttpPost("AgvTest")]
|
public ResponseResult AgvTest(dynamic queryObj)
|
{
|
try
|
{
|
var binding = new BasicHttpBinding { /* 原有配置 */ };
|
var endpoint = new EndpointAddress("http://192.168.35.251:8000/MesGet");
|
var factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
string result = channel.PrintHello();
|
((IClientChannel)channel).Close();
|
|
// 记录日志
|
//LogToFile(nameof(AgvTest), new { queryObj }, result);
|
|
return new ResponseResult { status = 0, message = "OK", data = result };
|
}
|
catch (Exception ex)
|
{
|
//LogToFile(nameof(AgvTest), new { queryObj }, $"异常：{ex}");
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
//立库送检
|
[HttpPost("DefineTask_001")]
|
public ResponseResult DefineTask_001(DefineTask001Dto dto)
|
{
|
string _requestJson = string.Empty;
|
dynamic _responseData = new System.Dynamic.ExpandoObject();
|
string _executeTimestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
int sendStatus = 0;
|
string _logMessage = "【AGV】立库送检";
|
|
try
|
{
|
var binding = new BasicHttpBinding
|
{
|
MaxReceivedMessageSize = 10485760, // 10MB
|
TextEncoding = System.Text.Encoding.UTF8
|
};
|
|
var endpoint = new EndpointAddress("http://192.168.35.251:8000/MesGet");
|
//var endpoint = new EndpointAddress("http://192.168.32.17:8000/MesGet");
|
var factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
//string result = channel.DefineTask_001("GS2025070700001","TEST.01","AGV测试物料名称", "AGV测试物料规格",100,"台",1);
|
string result = channel.DefineTask_001(
|
dto.MesId,
|
dto.MatId,
|
dto.MatName,
|
dto.MatStandard,
|
dto.MatNumber,
|
dto.MatUnit,
|
dto.Postition);
|
|
((IClientChannel)channel).Close();
|
|
// 记录请求报文
|
_requestJson = JsonConvert.SerializeObject(dto);
|
|
_responseData = result;
|
sendStatus = 1;
|
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage,
|
orderNo: dto.MesId,
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: sendStatus,
|
executeTime: _executeTimestamp
|
);
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage + $"系统异常：{ex.Message}",
|
orderNo: dto.MesId,
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: 0,
|
executeTime: _executeTimestamp
|
);
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
//立库检验
|
[HttpPost("DefineTask_002")]
|
public ResponseResult DefineTask_002(DefineTask002Dto dto)
|
{
|
string _requestJson = string.Empty;
|
dynamic _responseData = new System.Dynamic.ExpandoObject();
|
string _executeTimestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
int sendStatus = 0;
|
string _logMessage = "【AGV】立库检验";
|
|
try
|
{
|
var binding = new BasicHttpBinding
|
{
|
MaxReceivedMessageSize = 10485760, // 10MB
|
TextEncoding = System.Text.Encoding.UTF8
|
};
|
|
var endpoint = new EndpointAddress("http://192.168.35.251:8000/MesGet");
|
//var endpoint = new EndpointAddress("http://192.168.32.17:8000/MesGet");
|
var factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
//string result = channel.DefineTask_002("GS2025070900010", "合格");
|
string result = channel.DefineTask_002(
|
dto.MesId,
|
dto.MatStatus);
|
|
((IClientChannel)channel).Close();
|
|
// 记录请求报文
|
_requestJson = JsonConvert.SerializeObject(dto);
|
|
_responseData = result;
|
sendStatus = 1;
|
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage,
|
orderNo: dto.MesId,
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: sendStatus,
|
executeTime: _executeTimestamp
|
);
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage + $"系统异常：{ex.Message}",
|
orderNo: dto.MesId,
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: 0,
|
executeTime: _executeTimestamp
|
);
|
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
//立库呼叫
|
[HttpPost("DefineTask_005")]
|
public ResponseResult DefineTask_005(DefineTask005Dto dto)
|
{
|
string _requestJson = string.Empty;
|
dynamic _responseData = new System.Dynamic.ExpandoObject();
|
string _executeTimestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
int sendStatus = 0;
|
string _logMessage = "【AGV】立库呼叫";
|
try
|
{
|
var binding = new BasicHttpBinding
|
{
|
MaxReceivedMessageSize = 10485760, // 10MB
|
TextEncoding = System.Text.Encoding.UTF8
|
};
|
|
var endpoint = new EndpointAddress("http://192.168.35.251:8000/MesGet");
|
//var endpoint = new EndpointAddress("http://192.168.32.17:8000/MesGet");
|
var factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
//string result = channel.DefineTask_005(2);
|
string result = channel.DefineTask_005(
|
dto.Postition);
|
((IClientChannel)channel).Close();
|
|
// 记录请求报文
|
_requestJson = JsonConvert.SerializeObject(dto);
|
|
_responseData = result;
|
sendStatus = 1;
|
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage,
|
orderNo: "",
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: sendStatus,
|
executeTime: _executeTimestamp
|
);
|
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage + $"系统异常：{ex.Message}",
|
orderNo: "",
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: 0,
|
executeTime: _executeTimestamp
|
);
|
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
|
//立库入库
|
[HttpPost("DefineTask_006")]
|
public ResponseResult DefineTask_006(DefineTask006Dto dto)
|
{
|
string _requestJson = string.Empty;
|
dynamic _responseData = new System.Dynamic.ExpandoObject();
|
string _executeTimestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
int sendStatus = 0;
|
string _logMessage = "【AGV】立库入库";
|
|
try
|
{
|
var binding = new BasicHttpBinding
|
{
|
MaxReceivedMessageSize = 10485760, // 10MB
|
TextEncoding = System.Text.Encoding.UTF8
|
};
|
|
var endpoint = new EndpointAddress("http://192.168.35.251:8000/MesGet");
|
//var endpoint = new EndpointAddress("http://192.168.32.17:8000/MesGet");
|
var factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
//string result = channel.DefineTask_006("C2025070400040", "2.02.51.463", "管线饮水机", "C638-1HA(万和VGX-SR-1A-XM白)", 48, "台", 4);
|
string result = channel.DefineTask_006(
|
dto.MesId,
|
dto.MatId,
|
dto.MatName,
|
dto.MatStandard,
|
dto.MatNumber,
|
dto.MatUnit,
|
dto.Postition);
|
((IClientChannel)channel).Close();
|
|
// 记录请求报文
|
_requestJson = JsonConvert.SerializeObject(dto);
|
|
_responseData = result;
|
sendStatus = 1;
|
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage,
|
orderNo: dto.MesId,
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: sendStatus,
|
executeTime: _executeTimestamp
|
);
|
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
|
var logService = new LogService();
|
logService.CreateLogI(
|
db: null,
|
edtUserGuid: Guid.Parse("11111111-1111-1111-1111-111111111111"),
|
abtGuid: null,
|
abtTable: "AGV_TASK",
|
detail: _logMessage + $"系统异常：{ex.Message}",
|
orderNo: dto.MesId,
|
sendJson: _requestJson,
|
rtnJson: JsonConvert.SerializeObject(_responseData),
|
xkyBeginTime: null,
|
xkyEndTime: null,
|
sendStatus: 0,
|
executeTime: _executeTimestamp
|
);
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
|
|
}
|
|
// 在类外部添加服务契约接口
|
[ServiceContract(Namespace = "http://tempuri.org/")]
|
public interface IImesInterface
|
{
|
[OperationContract(Action = "http://tempuri.org/ImesInterface/PrintHello",
|
ReplyAction = "http://tempuri.org/ImesInterface/PrintHelloResponse")]
|
string PrintHello();
|
|
//立库送检
|
[OperationContract(Action = "http://tempuri.org/ImesInterface/DefineTask_001",
|
ReplyAction = "http://tempuri.org/ImesInterface/DefineTask_001Response")]
|
string DefineTask_001(string MesId, string MatId, string MatName, string MatStandard, int MatNumber, string MatUnit, int Postition);
|
|
//立库检验
|
[OperationContract(Action = "http://tempuri.org/ImesInterface/DefineTask_002",
|
ReplyAction = "http://tempuri.org/ImesInterface/DefineTask_002Response")]
|
string DefineTask_002(string MesId, string MatStatus);
|
|
//立库呼叫
|
[OperationContract(Action = "http://tempuri.org/ImesInterface/DefineTask_005",
|
ReplyAction = "http://tempuri.org/ImesInterface/DefineTask_005Response")]
|
string DefineTask_005(int Postition);
|
|
//立库入库
|
[OperationContract(Action = "http://tempuri.org/ImesInterface/DefineTask_006",
|
ReplyAction = "http://tempuri.org/ImesInterface/DefineTask_006Response")]
|
string DefineTask_006(string MesId,string MatId,string MatName,string MatStandard,int MatNumber,string MatUnit,int Postition);
|
}
|
