From 2510ff614cd2962d2a91ec1a9eb6668009e9b671 Mon Sep 17 00:00:00 2001
From: hutongqing <hutongqing@hnkhzn.com>
Date: 星期四, 12 十二月 2024 10:43:35 +0800
Subject: [PATCH] 1
---
代码管理/WMS/WIDESEA_WMSServer/WIDESEA_WMSServer/Controllers/Approval/ApprovalTaskController.cs | 45 +++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 43 insertions(+), 2 deletions(-)
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_WMSServer/Controllers/Approval/ApprovalTaskController.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_WMSServer/Controllers/Approval/ApprovalTaskController.cs"
index d9c631b..ac7b02d 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_WMSServer/Controllers/Approval/ApprovalTaskController.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_WMSServer/Controllers/Approval/ApprovalTaskController.cs"
@@ -1,8 +1,13 @@
-锘縰sing Microsoft.AspNetCore.Http;
+锘縰sing HslCommunication.WebSocket;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
+using Newtonsoft.Json;
using WIDESEA_Core;
using WIDESEA_Core.BaseController;
+using WIDESEA_Core.Helper;
using WIDESEA_IApprovalService;
+using WIDESEA_ICheckRepository;
using WIDESEA_Model.Models;
namespace WIDESEA_WMSServer.Controllers.Approval
@@ -11,8 +16,13 @@
[ApiController]
public class ApprovalTaskController : ApiBaseController<IApprovalTaskService, Dt_ApprovalTask>
{
- public ApprovalTaskController(IApprovalTaskService service) : base(service)
+ private readonly ICheckOrderRepository _checkOrderRepository;
+ private readonly WebSocketServer _webSocketServer;
+
+ public ApprovalTaskController(IApprovalTaskService service, ICheckOrderRepository checkOrderRepository, WebSocketServer webSocketServer) : base(service)
{
+ _checkOrderRepository = checkOrderRepository;
+ _webSocketServer = webSocketServer;
}
[HttpGet, HttpPost, Route("AuditAgree")]
@@ -26,5 +36,36 @@
{
return Service.AuditReject(sourceKey);
}
+
+ [HttpGet, HttpPost, Route("PushTest"), AllowAnonymous]
+ public WebResponseContent PushTest()
+ {
+ try
+ {
+ List<Dt_CheckOrder> checkOrders = _checkOrderRepository.Db.Queryable<Dt_CheckOrder>().Includes(x => x.Details).ToList();
+
+ foreach (var checkOrder in checkOrders)
+ {
+ object obj = new
+ {
+ title = "IQC璐ㄦ缁撴灉瀹℃壒",
+ formData = checkOrder,
+ tableData = checkOrder.Details,
+ message = "鎺ㄩ�佹祴璇曚俊鎭綋",
+ date = DateTime.Now.ToString(),
+ };
+ JsonSerializerSettings settings = new JsonSerializerSettings()
+ {
+ ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
+ };
+ _webSocketServer.PublishAllClientPayload(JsonConvert.SerializeObject(obj, settings));
+ }
+ return WebResponseContent.Instance.OK();
+ }
+ catch (Exception ex)
+ {
+ return WebResponseContent.Instance.Error(ex.Message);
+ }
+ }
}
}
--
Gitblit v1.9.3