1.AGV调用新增日志。

南骏 池

3 天以前 6dae2517aa69e7a81e87b8cc2bcb63f401fa77dd

 Controllers/AGV/AgvApiController.cs

@@ -8,6 +8,8 @@
using System.ServiceModel;
using System.IO;
using NewPdaSqlServer.Dto.Warehouse;
using NewPdaSqlServer.DB;
using Newtonsoft.Json;

namespace NewPdaSqlServer.Controllers.AGV;

@@ -60,6 +62,12 @@
    [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
@@ -69,6 +77,7 @@
            };

            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();
@@ -84,6 +93,28 @@
            
            ((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,
@@ -93,6 +124,21 @@
        }
        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);
        }
    }
@@ -101,6 +147,12 @@
    [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
@@ -110,6 +162,7 @@
            };

            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();
@@ -120,6 +173,28 @@
            
            ((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,
@@ -129,6 +204,22 @@
        }
        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);
        }
    }
@@ -137,6 +228,11 @@
    [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
@@ -146,6 +242,7 @@
            };

            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();
@@ -153,6 +250,29 @@
            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
            {
@@ -163,6 +283,22 @@
        }
        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);
        }
    }
@@ -172,6 +308,12 @@
    [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
@@ -181,6 +323,7 @@
            };

            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();
@@ -195,6 +338,29 @@
                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,
@@ -204,6 +370,22 @@
        }
        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);
        }
    }