|
|
@@ -4,6 +4,7 @@ using HKLib.RabbitMQ.Publisher; |
|
|
|
using Newtonsoft.Json.Linq; |
|
|
|
using System.Collections.Generic; |
|
|
|
using System.Linq; |
|
|
|
using System.Threading.Tasks; |
|
|
|
using XExten.Advance.HttpFramework.MultiCommon; |
|
|
|
using XExten.Advance.HttpFramework.MultiFactory; |
|
|
|
using XExten.Advance.LinqFramework; |
|
|
@@ -41,7 +42,7 @@ namespace HKLib.Interfaces |
|
|
|
var res = data.ToModel<JObject>()["data"]["isSuccess"].ToString().AsBool(); |
|
|
|
if (res) |
|
|
|
{ |
|
|
|
ServiceQueryPush.QueryPush.PushMQAsync(input, "TimeChanged", MQEnum.Push); |
|
|
|
Task.Run(() => ServiceQueryPush.QueryPush.PushMQAsync(input, "TimeChanged", MQEnum.Push)); |
|
|
|
return res; |
|
|
|
} |
|
|
|
return false; |
|
|
@@ -164,7 +165,7 @@ namespace HKLib.Interfaces |
|
|
|
}).Build().RunStringFirst().ToModel<JObject>()["data"]["isSuccess"].ToString().AsBool(); |
|
|
|
if (x) |
|
|
|
{ |
|
|
|
ServiceQueryPush.QueryPush.PushMQAsync(input, "CardStutasChanged", MQEnum.Top); |
|
|
|
Task.Run(() => ServiceQueryPush.QueryPush.PushMQAsync(input, "CardStutasChanged", MQEnum.Top)); |
|
|
|
return x; |
|
|
|
} |
|
|
|
return false; |
|
|
|