添加云音响请求犯法

Controllers/HomeController.cs

@@ -26,12 +26,13 @@ namespace MySystem.Controllers
 
         public string test()
         {
-            List<int> MerchantIds = new List<int>();
-            MerchantIds.Add(5);
-            foreach(int MerchantId in MerchantIds)
-            {
-                RedisDbconn.Instance.AddList("MerchantConfirmHdQueue", "{\"MerchantId\":\"" + MerchantId + "\"}");
-            }
+            // List<int> MerchantIds = new List<int>();
+            // MerchantIds.Add(5);
+            // foreach(int MerchantId in MerchantIds)
+            // {
+            //     RedisDbconn.Instance.AddList("MerchantConfirmHdQueue", "{\"MerchantId\":\"" + MerchantId + "\"}");
+            // }
+            TianYuVoiceHelper.Instance.doSomething(DateTime.Now.ToString("yyyyMMddHHmmssfff"),"010929459594","100");
             return "ok";
         }
     }

Startup.cs

@@ -135,27 +135,27 @@ namespace MySystem
             });
 
             initMainServer();
-            if(Library.ConfigurationManager.EnvironmentFlag == 1)
-            {
-                TestHaoDaService.Instance.Start(); //好哒测试
-            }
-            if(Library.ConfigurationManager.EnvironmentFlag == 2)
-            {
-                MerchantConfirmService.Instance.Start(); //提交商户进件
-                CheckWeChatSignService.Instance.Start(); //查询商户审核状态
-                ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现
-                HaoDaExtHelper.Instance.StartWeChat();
-                HaoDaExtHelper.Instance.StartAlipay();
-                HaoDaExtQueryHelper.Instance.StartWeChat();
-                HaoDaExtQueryHelper.Instance.StartAlipay();
-                HaoDaExtQueryAuthHelper.Instance.StartWeChat();
-                HaoDaExtQueryAuthHelper.Instance.StartAlipay();
-                HaoDaAuthQueryHelper.Instance.Start(); //查询实名认证状态
-                WeChatPayBackService.Instance.Start(); //支付回调
-                WeChatPayBackService.Instance.StartProfitShare(); //分账队列
-                ProfitHelper.Instance.StartListenTrade(); //返现队列-支付宝
-                ProfitHelper.Instance.StartListenWxTrade(); //返现队列-微信
-            }
+            // if(Library.ConfigurationManager.EnvironmentFlag == 1)
+            // {
+            //     TestHaoDaService.Instance.Start(); //好哒测试
+            // }
+            // if(Library.ConfigurationManager.EnvironmentFlag == 2)
+            // {
+            //     MerchantConfirmService.Instance.Start(); //提交商户进件
+            //     CheckWeChatSignService.Instance.Start(); //查询商户审核状态
+            //     ProfitShareService.Instance.Start(); //分账状态监控队列，分账完成则提交返现
+            //     HaoDaExtHelper.Instance.StartWeChat();
+            //     HaoDaExtHelper.Instance.StartAlipay();
+            //     HaoDaExtQueryHelper.Instance.StartWeChat();
+            //     HaoDaExtQueryHelper.Instance.StartAlipay();
+            //     HaoDaExtQueryAuthHelper.Instance.StartWeChat();
+            //     HaoDaExtQueryAuthHelper.Instance.StartAlipay();
+            //     HaoDaAuthQueryHelper.Instance.Start(); //查询实名认证状态
+            //     WeChatPayBackService.Instance.Start(); //支付回调
+            //     WeChatPayBackService.Instance.StartProfitShare(); //分账队列
+            //     ProfitHelper.Instance.StartListenTrade(); //返现队列-支付宝
+            //     ProfitHelper.Instance.StartListenWxTrade(); //返现队列-微信
+            // }
         }
 
         //初始化数据结构

Util/HaoDa/WeChatPayBackService.cs

@@ -99,10 +99,14 @@ namespace MySystem
                         {
                             AliIotFunction.Instance.IotTradeVoice(machine.SeoDescription, addinfo.AliMerchantId, order.PayMoney.ToString("f2"), "OTHER");
                         }
-                        if(machine.BrandId == 2)
+                        else if(machine.BrandId == 2)
                         {
                             TianYuVoiceHelper.Instance.doSomething(DateTime.Now.ToString("yyyyMMddHHmmssfff"), machine.Detail, order.PayMoney.ToString("f2"));
                         }
+                        else if(machine.BrandId == 3)
+                        {
+                            MqLinksHelper.Instance.doSomething(machine.Detail, order.PayMoney.ToString("f2"));
+                        }
                     }
                     db1.Dispose();
                 }

Util/MqLinksHelper.cs

@@ -0,0 +1,53 @@
+using System;
+using System.Threading;
+using System.Linq;
+using System.Data;
+using Library;
+using MySystem.Models;
+using LitJson;
+using System.Collections.Generic;
+using System.Security.Cryptography;
+
+namespace MySystem
+{
+    public class MqLinksHelper
+    {
+        public readonly static MqLinksHelper Instance = new MqLinksHelper();
+        private MqLinksHelper()
+        {
+        }
+
+        string reqUrl = "http://cs.mqlinks.com/txmsgpush/";
+
+        public string doSomething(string DeviceId, string Amount)
+        {
+            string result = "";
+            try
+            {
+                Dictionary<string, object> data = new Dictionary<string, object>();
+                data.Add("cmd", "voice");
+                data.Add("msg", "来客吧收款" + Amount + "元");
+                data.Add("msgid", function.get_Random(1, 999999));
+                Dictionary<string, object> map = new Dictionary<string, object>();
+                map.Add("sbx_id", DeviceId);
+                map.Add("agent_id", data);
+                result = post(map);
+            }
+            catch (Exception ex)
+            {
+                LogHelper.Instance.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "云音响播报异常");
+            }
+            return result;
+        }
+
+        private string post(Dictionary<string, object> data)
+        {
+            string req = Newtonsoft.Json.JsonConvert.SerializeObject(data);
+            function.WriteLog("请求地址：" + reqUrl, "云音响播报日志");
+            function.WriteLog("请求参数：" + req, "云音响播报日志");
+            string result = function.PostWebRequest(reqUrl, req, "application/json");
+            function.WriteLog("响应数据：" + result, "云音响播报日志");
+            return result;
+        }
+    }
+}