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;
|
|
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(dynamic queryObj)
|
{
|
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 factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
string result = channel.DefineTask_001("GS2025070700001","TEST.01","AGV测试物料名称", "AGV测试物料规格",100,"台",1);
|
((IClientChannel)channel).Close();
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
//立库检验
|
[HttpPost("DefineTask_002")]
|
public ResponseResult DefineTask_002(dynamic queryObj)
|
{
|
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 factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
string result = channel.DefineTask_002("GS2025070900010", "合格");
|
((IClientChannel)channel).Close();
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
//立库呼叫
|
[HttpPost("DefineTask_005")]
|
public ResponseResult DefineTask_005(dynamic queryObj)
|
{
|
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 factory = new ChannelFactory<IImesInterface>(binding, endpoint);
|
|
var channel = factory.CreateChannel();
|
string result = channel.DefineTask_005();
|
((IClientChannel)channel).Close();
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
return ResponseResult.ResponseError(ex);
|
}
|
}
|
|
|
//立库入库
|
[HttpPost("DefineTask_006")]
|
public ResponseResult DefineTask_006(dynamic queryObj)
|
{
|
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 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);
|
((IClientChannel)channel).Close();
|
|
return new ResponseResult
|
{
|
status = 0,
|
message = "OK",
|
data = result
|
};
|
}
|
catch (Exception ex)
|
{
|
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();
|
|
//立库入库
|
[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);
|
}
|
