From b64efba9b005c074b3963c9d650091c70e46108b Mon Sep 17 00:00:00 2001
From: 啊鑫 <t2856754968@163.com>
Date: 星期四, 01 八月 2024 14:53:18 +0800
Subject: [PATCH] 采购入库单和消息中心重推送

---
 MESApplication/Controllers/Base/MessageCenterController.cs |   60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 55 insertions(+), 5 deletions(-)

diff --git a/MESApplication/Controllers/Base/MessageCenterController.cs b/MESApplication/Controllers/Base/MessageCenterController.cs
index a079762..529df7f 100644
--- a/MESApplication/Controllers/Base/MessageCenterController.cs
+++ b/MESApplication/Controllers/Base/MessageCenterController.cs
@@ -3,6 +3,7 @@
 using MES.Service.service;
 using MES.Service.util;
 using Microsoft.AspNetCore.Mvc;
+using Newtonsoft.Json.Linq;
 
 namespace MESApplication.Controllers.Base;
 
@@ -10,6 +11,7 @@
 [Route("api/[controller]")]
 public class MessageCenterController : ControllerBase
 {
+    private readonly GetErpParametersServer ErpParametersServer = new();
     private readonly MessageCenterManager m = new();
 
 
@@ -34,13 +36,60 @@
         }
     }
 
-    [HttpPost("GetByPid")]
-    public ResponseResult ResetUpdate(int pid)
+    //Resend
+    [HttpPost("Resend")]
+    public ResponseResult Resend(MessageCenter data)
     {
         try
         {
             dynamic resultInfos = new ExpandoObject();
-            resultInfos.tbBillList = m.GetList(it => it.Pid == pid);
+            resultInfos.tbBillList = ErpParametersServer.Resend(data);
+            return new ResponseResult
+            {
+                status = 0,
+                message = "OK",
+                data = resultInfos
+            };
+        }
+        catch (Exception ex)
+        {
+            return ResponseResult.ResponseError(ex);
+        }
+    }
+
+    //saveError
+    [HttpPost("SetError")]
+    public ResponseResult SetError([FromBody] MessageCenter data)
+    {
+        try
+        {
+            dynamic resultInfos = new ExpandoObject();
+            resultInfos.tbBillList = m.SetError(data);
+            return new ResponseResult
+            {
+                status = 0,
+                message = "OK",
+                data = resultInfos
+            };
+        }
+        catch (Exception ex)
+        {
+            return ResponseResult.ResponseError(ex);
+        }
+    }
+
+    [HttpPost("GetByPid")]
+    public ResponseResult ResetUpdate([FromBody] JObject data)
+    {
+        var pid = Convert.ToDecimal(data["pid"].ToString());
+        try
+        {
+            dynamic resultInfos = new ExpandoObject();
+
+            var messageCenter = m.GetById(pid);
+            var messageCenters = m.GetList(it => it.Pid == pid);
+            messageCenters.Add(messageCenter);
+            resultInfos.tbBillList = messageCenters;
             return new ResponseResult
             {
                 status = 0,
@@ -60,7 +109,7 @@
         try
         {
             dynamic resultInfos = new ExpandoObject();
-            resultInfos.tbBillList = m.getPushFailedPage(query);
+            resultInfos.tbBillList = m.GetPushFailedPage(query);
             return new ResponseResult
             {
                 status = 0,
@@ -106,8 +155,9 @@
     /// </summary>
     /// <returns></returns>
     [HttpPost("GetById")]
-    public ResponseResult GetById(int id)
+    public ResponseResult GetById([FromBody] JObject data)
     {
+        var id = Convert.ToDecimal(data["id"].ToString());
         try
         {
             dynamic resultInfos = new ExpandoObject();

--
Gitblit v1.9.3