浏览代码

取消给job返回队列执行结果,以后优化此功能

lichunlei 2 年之前
父节点
当前提交
4138ef47cb

+ 4 - 4
AppStart/Helper/AlipayPayBack2Service.cs

@@ -20,10 +20,10 @@ namespace MySystem
             try
             {
                 dosomething();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/AlipayPayBackService.cs

@@ -19,10 +19,10 @@ namespace MySystem
             try
             {
                 dosomething();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/CheckAlipaySignService.cs

@@ -114,9 +114,9 @@ namespace MySystem
                     RedisDbconn.Instance.Clear("AliaySignList");
                     RedisDbconn.Instance.AddList("AliaySignList", signs.ToArray());
                 }
-                jobInfo.Status = 1;
-                jobInfo.Msg = "执行完成";
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // jobInfo.Status = 1;
+                // jobInfo.Msg = "执行完成";
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/CheckWeChatSignService.cs

@@ -130,9 +130,9 @@ namespace MySystem
                     RedisDbconn.Instance.Clear("WeChatSignList");
                     RedisDbconn.Instance.AddList("WeChatSignList", signs.ToArray());
                 }
-                jobInfo.Status = 1;
-                jobInfo.Msg = "执行完成";
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // jobInfo.Status = 1;
+                // jobInfo.Msg = "执行完成";
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/ConsumerOrdersReturnDoService.cs

@@ -19,10 +19,10 @@ namespace MySystem
             try
             {
                 DoRefund();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/ConsumerOrdersReturnStatService.cs

@@ -19,10 +19,10 @@ namespace MySystem
             try
             {
                 ProfitHelper.Instance.StartListenTradeDo();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/ConsumerOrdersStatService.cs

@@ -19,10 +19,10 @@ namespace MySystem
             try
             {
                 dosomething();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/MerchantTypeSetService.cs

@@ -19,10 +19,10 @@ namespace MySystem
             try
             {
                 dosomething();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/Profit/ActiveService.cs

@@ -19,9 +19,9 @@ namespace MySystem
             try
             {
                 string Msg = CheckData();
-                jobInfo.Status = Msg == "success" ? 1: 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "ActiveBack");
+                // jobInfo.Status = Msg == "success" ? 1: 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "ActiveBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/Profit/DiviService.cs

@@ -19,9 +19,9 @@ namespace MySystem
             try
             {
                 string Msg = CheckData();
-                jobInfo.Status = Msg == "success" ? 1: 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "DiviBack");
+                // jobInfo.Status = Msg == "success" ? 1: 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "DiviBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/Profit/FluxService.cs

@@ -19,9 +19,9 @@ namespace MySystem
             try
             {
                 string Msg = CheckFlux();
-                jobInfo.Status = Msg == "success" ? 1: 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "FluxBack");
+                // jobInfo.Status = Msg == "success" ? 1: 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "FluxBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/Profit/OpenService.cs

@@ -19,9 +19,9 @@ namespace MySystem
             try
             {
                 string Msg = CheckData();
-                jobInfo.Status = Msg == "success" ? 1: 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "OpenBack");
+                // jobInfo.Status = Msg == "success" ? 1: 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "OpenBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/Profit/ProfitService.cs

@@ -19,9 +19,9 @@ namespace MySystem
             try
             {
                 string Msg = Profit();
-                jobInfo.Status = Msg == "success" ? 1: 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "ProfitBack");
+                // jobInfo.Status = Msg == "success" ? 1: 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "ProfitBack");
             }
             catch (Exception ex)
             {

+ 3 - 3
AppStart/Helper/Profit/StandardService.cs

@@ -19,9 +19,9 @@ namespace MySystem
             try
             {
                 string Msg = CheckData();
-                jobInfo.Status = Msg == "success" ? 1: 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "StandardBack");
+                // jobInfo.Status = Msg == "success" ? 1: 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成": Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "StandardBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/ReceiveProfitService.cs

@@ -18,15 +18,15 @@ namespace MySystem
             try
             {
                 string OrderString = jobInfo.OrderString;
-                string Msg = "success";
+                // string Msg = "success";
                 if (OrderString == "SplitAccount")
                 {
                     string Table = OrderString.Split(':')[1];
                     ProfitHelper.Instance.StartListenSplitAccount();
                 }
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/ReceiveTaskService.cs

@@ -18,15 +18,15 @@ namespace MySystem
             try
             {
                 string OrderString = jobInfo.OrderString;
-                string Msg = "success";
+                // string Msg = "success";
                 if (OrderString.StartsWith("Ap:") && OrderString.EndsWith(":Sycn"))
                 {
                     string Table = OrderString.Split(':')[1];
                     PublicTableHelper.Instance.Start(Table);
                 }
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 9 - 9
AppStart/Helper/StatService.cs

@@ -36,10 +36,10 @@ namespace MySystem
                         dosomething4(doDate);
                         ListenFluxRecord(doDate);
                     }
-                    string Msg = "success";
-                    jobInfo.Status = Msg == "success" ? 1 : 0;
-                    jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                    RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                    // string Msg = "success";
+                    // jobInfo.Status = Msg == "success" ? 1 : 0;
+                    // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                    // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
                 }
             }
             catch (Exception ex)
@@ -65,11 +65,11 @@ namespace MySystem
             {
                 dosomething3();
                 activePrizeWithoutDeposit();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
-                function.WritePage("/static/", "act.txt", DateTime.Now.ToString());
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // function.WritePage("/static/", "act.txt", DateTime.Now.ToString());
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/StatTimerService.cs

@@ -19,10 +19,10 @@ namespace MySystem
             try
             {
                 dosomething();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {

+ 4 - 4
AppStart/Helper/WeChatPayBackService.cs

@@ -23,10 +23,10 @@ namespace MySystem
             try
             {
                 dosomething();
-                string Msg = "success";
-                jobInfo.Status = Msg == "success" ? 1 : 0;
-                jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
-                RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
+                // string Msg = "success";
+                // jobInfo.Status = Msg == "success" ? 1 : 0;
+                // jobInfo.Msg = Msg == "success" ? "执行完成" : Msg;
+                // RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "PublicBack");
             }
             catch (Exception ex)
             {