设置服务费和费率用MQ实现

AppStart/Helper/ChangePosFeeQueue.cs

@@ -15,138 +15,123 @@ public class ChangePosFeeQueue
     {
     }
 
-    public void StartEverTime()
+    public bool ChangePosDeposit(string data)
     {
-        Thread th = new Thread(ChangePosFeeQueueDo);
-        th.IsBackground = true;
-        th.Start();
-    }
-
-    private void ChangePosFeeQueueDo()
-    {
-        while (true)
+        bool result = true;
+        WebCMSEntities db = new WebCMSEntities();
+        try
         {
-            WebCMSEntities db = new WebCMSEntities();
-            try
-            {
-                string data = RedisDbconn.Instance.RPop<string>("ChangePosFeeQueue");
-                if (!string.IsNullOrEmpty(data))
-                {
-                    function.WriteLog("data:" + data, "金控机具服务费调整日志");
-                    JsonData Info = JsonMapper.ToObject(data);
-                    string PosSnId = Info["PosSnId"].ToString(); //机具Id
-                    string BrandId = Info["BrandId"].ToString(); //品牌Id
-                    string Deposit = Info["Deposit"].ToString(); //服务费
-                    int bId = int.Parse(BrandId);
+            function.WriteLog("data:" + data, "金控机具服务费调整日志");
+            JsonData Info = JsonMapper.ToObject(data);
+            string PosSnId = Info["PosSnId"].ToString(); //机具Id
+            string BrandId = Info["BrandId"].ToString(); //品牌Id
+            string Deposit = Info["Deposit"].ToString(); //服务费
+            int bId = int.Parse(BrandId);
 
-                    //金控
-                    if (bId == 1 || bId == 3)
-                    {
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetJKDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //开店宝
-                    if (bId == 2)
-                    {
-                        if (Deposit == "0") Deposit = "470";
-                        else if (Deposit == "99") Deposit = "471";
-                        else if (Deposit == "199") Deposit = "472";
-                        else if (Deposit == "299") Deposit = "473";
-                        ChangePosFeeUtil.SetKDBDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //乐刷
-                    if (bId == 4 || bId == 5)
-                    {
-                        if (Deposit == "99") Deposit = "100";
-                        else if (Deposit == "199") Deposit = "200";
-                        else if (Deposit == "299") Deposit = "300";
-                        ChangePosFeeUtil.SetLSDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //立刷
-                    if (bId == 6)
-                    { 
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetLISDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //立刷微电签
-                    if (bId == 22)
-                    { 
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetLISDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //盛付通
-                    if (bId == 7)
-                    { 
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetSFTDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //海科
-                    if (bId == 8 || bId == 9)
-                    { 
-                        if (Deposit == "99") Deposit = "100";
-                        else if (Deposit == "199") Deposit = "200";
-                        else if (Deposit == "299") Deposit = "300";
-                        ChangePosFeeUtil.SetHKDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //联动
-                    if (bId == 10 || bId == 11)
-                    { 
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetLDDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //盒易付
-                    if (bId == 12 || bId == 13)
-                    { 
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetHYFDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //联客宝
-                    if (bId == 15 || bId == 16)
-                    { 
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetPosPDeposit(PosSnId.ToString(), Deposit);
-                    }
-                    //拉卡拉
-                    if (bId == 30 || bId == 31)
-                    { 
-                        if (Deposit == "0") Deposit = "0";
-                        else if (Deposit == "99") Deposit = "99";
-                        else if (Deposit == "199") Deposit = "199";
-                        else if (Deposit == "299") Deposit = "299";
-                        ChangePosFeeUtil.SetLKLDeposit(PosSnId.ToString(), Deposit);
-                    }
-                }
-                else
-                {
-                    Thread.Sleep(5000);
-                }
+            //金控
+            if (bId == 1 || bId == 3)
+            {
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetJKDeposit(PosSnId.ToString(), Deposit);
             }
-            catch (Exception ex)
+            //开店宝
+            if (bId == 2)
             {
-                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "机具服务费调整线程异常");
+                if (Deposit == "0") Deposit = "470";
+                else if (Deposit == "99") Deposit = "471";
+                else if (Deposit == "199") Deposit = "472";
+                else if (Deposit == "299") Deposit = "473";
+                ChangePosFeeUtil.SetKDBDeposit(PosSnId.ToString(), Deposit);
+            }
+            //乐刷
+            if (bId == 4 || bId == 5)
+            {
+                if (Deposit == "99") Deposit = "100";
+                else if (Deposit == "199") Deposit = "200";
+                else if (Deposit == "299") Deposit = "300";
+                ChangePosFeeUtil.SetLSDeposit(PosSnId.ToString(), Deposit);
+            }
+            //立刷
+            if (bId == 6)
+            { 
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetLISDeposit(PosSnId.ToString(), Deposit);
+            }
+            //立刷微电签
+            if (bId == 22)
+            { 
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetLISDeposit(PosSnId.ToString(), Deposit);
             }
-            db.Dispose();
+            //盛付通
+            if (bId == 7)
+            { 
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetSFTDeposit(PosSnId.ToString(), Deposit);
+            }
+            //海科
+            if (bId == 8 || bId == 9)
+            { 
+                if (Deposit == "99") Deposit = "100";
+                else if (Deposit == "199") Deposit = "200";
+                else if (Deposit == "299") Deposit = "300";
+                ChangePosFeeUtil.SetHKDeposit(PosSnId.ToString(), Deposit);
+            }
+            //联动
+            if (bId == 10 || bId == 11)
+            { 
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetLDDeposit(PosSnId.ToString(), Deposit);
+            }
+            //盒易付
+            if (bId == 12 || bId == 13)
+            { 
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetHYFDeposit(PosSnId.ToString(), Deposit);
+            }
+            //联客宝
+            if (bId == 15 || bId == 16)
+            { 
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetPosPDeposit(PosSnId.ToString(), Deposit);
+            }
+            //拉卡拉
+            if (bId == 30 || bId == 31)
+            { 
+                if (Deposit == "0") Deposit = "0";
+                else if (Deposit == "99") Deposit = "99";
+                else if (Deposit == "199") Deposit = "199";
+                else if (Deposit == "299") Deposit = "299";
+                ChangePosFeeUtil.SetLKLDeposit(PosSnId.ToString(), Deposit);
+            }
+        }
+        catch (Exception ex)
+        {
+            function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "机具服务费调整线程异常");
+            result = false;
         }
+        db.Dispose();
+        return result;
     }
 }

AppStart/Helper/SetDepositPostService.cs

@@ -17,414 +17,399 @@ namespace MySystem
         private SetDepositPostService()
         { }
 
-        public void Start()
-        {
-            Thread th = new Thread(dosomething);
-            th.IsBackground = true;
-            th.Start();
-        }
 
-        public void dosomething()
+        public bool ChangeFee(string data)
         {
-            while (true)
+            bool result = true;
+            try
             {
-                string data = RedisDbconn.Instance.RPop<string>("SetDepositPostQueue");
-                if (!string.IsNullOrEmpty(data))
+                WebCMSEntities db = new WebCMSEntities();
+                JsonData jsonObj = JsonMapper.ToObject(data);
+                string PosIds = jsonObj["PosId"].ToString();
+                int Kind = int.Parse(function.CheckInt(jsonObj["Kind"].ToString()));
+                int RecordId = 0;
+                if(data.Contains("\"RecordId\""))
+                {
+                    RecordId = int.Parse(function.CheckInt(jsonObj["RecordId"].ToString()));
+                }
+                string OpMan = jsonObj["OpMan"].ToString();
+                if(!string.IsNullOrEmpty(PosIds) && Kind > 0)
                 {
-                    try
+                    List<int> ids = new List<int>();
+                    string[] PosIdList = PosIds.Split(',');
+                    foreach(string sub in PosIdList)
                     {
-                        WebCMSEntities db = new WebCMSEntities();
-                        JsonData jsonObj = JsonMapper.ToObject(data);
-                        string PosIds = jsonObj["PosId"].ToString();
-                        int Kind = int.Parse(function.CheckInt(jsonObj["Kind"].ToString()));
-                        int RecordId = 0;
-                        if(data.Contains("\"RecordId\""))
-                        {
-                            RecordId = int.Parse(function.CheckInt(jsonObj["RecordId"].ToString()));
-                        }
-                        string OpMan = jsonObj["OpMan"].ToString();
-                        if(!string.IsNullOrEmpty(PosIds) && Kind > 0)
+                        ids.Add(int.Parse(sub));
+                    }
+                    List<KqProducts> brands = db.KqProducts.ToList();
+                    List<PosMachinesTwo> poslist = db.PosMachinesTwo.Where(m => ids.Contains(m.Id)).ToList();
+                    List<int> mids = poslist.Select(m => m.BindMerchantId).ToList();
+                    List<PosMerchantInfo> merchantlist = db.PosMerchantInfo.Where(m => mids.Contains(m.Id)).ToList();
+                    foreach(PosMachinesTwo pos in poslist)
+                    {
+                        PosMerchantInfo merchant = merchantlist.FirstOrDefault(m => m.Id == pos.BindMerchantId);
+                        if(merchant != null)
                         {
-                            List<int> ids = new List<int>();
-                            string[] PosIdList = PosIds.Split(',');
-                            foreach(string sub in PosIdList)
+                            decimal Fee = 0.63M;
+                            int addRate = 0;
+                            if(pos.BrandId != 12 && pos.BrandId != 13)
                             {
-                                ids.Add(int.Parse(sub));
-                            }
-                            List<KqProducts> brands = db.KqProducts.ToList();
-                            List<PosMachinesTwo> poslist = db.PosMachinesTwo.Where(m => ids.Contains(m.Id)).ToList();
-                            List<int> mids = poslist.Select(m => m.BindMerchantId).ToList();
-                            List<PosMerchantInfo> merchantlist = db.PosMerchantInfo.Where(m => mids.Contains(m.Id)).ToList();
-                            foreach(PosMachinesTwo pos in poslist)
-                            {
-                                PosMerchantInfo merchant = merchantlist.FirstOrDefault(m => m.Id == pos.BindMerchantId);
-                                if(merchant != null)
+                                if(Kind == 1)
                                 {
-                                    decimal Fee = 0.63M;
-                                    int addRate = 0;
-                                    if(pos.BrandId != 12 && pos.BrandId != 13)
-                                    {
-                                        if(Kind == 1)
-                                        {
-                                            addRate = 3;
-                                        }
-                                        else
-                                        {
-                                            addRate = 0;
-                                            if(Kind == 3)
-                                            {
-                                                Fee = 0.6M;
-                                            }
-                                        }
-                                    }
-                                    if(pos.BrandId == 12 || pos.BrandId == 13)
-                                    {
-                                        if(Kind == 1) Kind = 2;
-                                        if(Kind == 3) Fee = 0.6M;
-                                    }
-                                    if(pos.BrandId == 7 && Kind == 4)
-                                    {
-                                        Fee = decimal.Parse(function.CheckNum(jsonObj["Fee"].ToString()));
-                                        addRate = int.Parse(function.CheckInt(jsonObj["AddRate"].ToString()));
-                                    }
-                                    if(pos.BrandId == 1 || pos.BrandId == 3) //金控
-                                    {
-                                        addRate = addRate * 100;
-                                        // string content = function.GetWebRequest("http://connect.kexiaoshuang.com/home/setfee?merNo=" + merchant.KqMerNo + "&sn=" + pos.PosSn + "&fee=" + Fee + "&addRate=" + addRate);
-                                        // string content = SetFee(merchant.KqMerNo, pos.PosSn, Fee, addRate);
-                                        string content = PublicImportDataService.Instance.LkbSetFee(pos.PosSn, Fee, addRate);
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if (obj["respCode"].ToString() == "00")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["respMsg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
-                                    }
-                                    else if(pos.BrandId == 2) //开店宝
-                                    {
-                                        Fee = Fee / 100;
-                                        string content = ModifyFee(pos.PosSn, Fee, addRate.ToString());
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if(content.Contains("orderNo"))
-                                        {
-                                            pos.SeoDescription = "提交成功|" + obj["orderNo"].ToString() + "|" + RecordId;
-                                            // SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["msg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
-                                    }
-                                    else if(pos.BrandId == 4 || pos.BrandId == 5) //乐刷
+                                    addRate = 3;
+                                }
+                                else
+                                {
+                                    addRate = 0;
+                                    if(Kind == 3)
                                     {
-                                        // 电签
-                                        // 电签标准0.63 729702301652492288
-                                        // 电签优惠0.63 729702442300088320
-                                        // 电签pos不加  696339175297294336
-
-                                        // 大POS
-                                        // PY-传统POS标准0.63 554666598481842176
-                                        // PY-传统POS优惠0.63 683857388021264384
-                                        // 大pos不加  698228081038991360
-
-                                        // 大POS
-                                        // 大POS标准0.6：713806109336940544
-                                        // 大POS优惠0.6：713806774515802112
-
-                                        // 电签POS
-                                        // 电签标准0.6：712391426860134400
-                                        // 电签优惠0.6：712391668250718208
-                                        // S0电签pos不加：696339175297294336
-                                        string bzConfigId = "", yhConfigId = "", surfeeConfigId = "";
-                                        if(pos.BrandId == 4)
-                                        {
-                                            if(Kind == 1)
-                                            {
-                                                bzConfigId = "729702301652492288";
-                                                yhConfigId = "729702442300088320";
-                                                surfeeConfigId = "696339175297294336";
-                                            }
-                                            else
-                                            {
-                                                bzConfigId = "712391426860134400";
-                                                yhConfigId = "712391668250718208";
-                                                surfeeConfigId = "696339175297294336";
-                                            }
-                                        }
-                                        else
-                                        {
-                                            if(Kind == 1)
-                                            {
-                                                bzConfigId = "554666598481842176";
-                                                yhConfigId = "683857388021264384";
-                                                surfeeConfigId = "698228081038991360";
-                                            }
-                                            else
-                                            {
-                                                bzConfigId = "713806109336940544";
-                                                yhConfigId = "713806774515802112";
-                                                surfeeConfigId = "698228081038991360";
-                                            }
-                                        }
-                                        string content = SetFeeForBrand(pos.PosSn, bzConfigId, yhConfigId, surfeeConfigId, pos.BrandId);
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if(obj["code"].ToString() == "0")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["msg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        Fee = 0.6M;
                                     }
-                                    else if(pos.BrandId == 6) //立刷
+                                }
+                            }
+                            if(pos.BrandId == 12 || pos.BrandId == 13)
+                            {
+                                if(Kind == 1) Kind = 2;
+                                if(Kind == 3) Fee = 0.6M;
+                            }
+                            if(pos.BrandId == 7 && Kind == 4)
+                            {
+                                Fee = decimal.Parse(function.CheckNum(jsonObj["Fee"].ToString()));
+                                addRate = int.Parse(function.CheckInt(jsonObj["AddRate"].ToString()));
+                            }
+                            if(pos.BrandId == 1 || pos.BrandId == 3) //金控
+                            {
+                                addRate = addRate * 100;
+                                // string content = function.GetWebRequest("http://connect.kexiaoshuang.com/home/setfee?merNo=" + merchant.KqMerNo + "&sn=" + pos.PosSn + "&fee=" + Fee + "&addRate=" + addRate);
+                                // string content = SetFee(merchant.KqMerNo, pos.PosSn, Fee, addRate);
+                                string content = PublicImportDataService.Instance.LkbSetFee(pos.PosSn, Fee, addRate);
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if (obj["respCode"].ToString() == "00")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["respMsg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 2) //开店宝
+                            {
+                                Fee = Fee / 100;
+                                string content = ModifyFee(pos.PosSn, Fee, addRate.ToString());
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if(content.Contains("orderNo"))
+                                {
+                                    pos.SeoDescription = "提交成功|" + obj["orderNo"].ToString() + "|" + RecordId;
+                                    // SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["msg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 4 || pos.BrandId == 5) //乐刷
+                            {
+                                // 电签
+                                // 电签标准0.63 729702301652492288
+                                // 电签优惠0.63 729702442300088320
+                                // 电签pos不加  696339175297294336
+
+                                // 大POS
+                                // PY-传统POS标准0.63 554666598481842176
+                                // PY-传统POS优惠0.63 683857388021264384
+                                // 大pos不加  698228081038991360
+
+                                // 大POS
+                                // 大POS标准0.6：713806109336940544
+                                // 大POS优惠0.6：713806774515802112
+
+                                // 电签POS
+                                // 电签标准0.6：712391426860134400
+                                // 电签优惠0.6：712391668250718208
+                                // S0电签pos不加：696339175297294336
+                                string bzConfigId = "", yhConfigId = "", surfeeConfigId = "";
+                                if(pos.BrandId == 4)
+                                {
+                                    if(Kind == 1)
                                     {
-                                        addRate = addRate * 100;
-                                        string content = PublicImportDataService.Instance.SetLiSFee(pos.PosSn, merchant.KqMerNo, Fee.ToString("f2"), addRate.ToString());
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if (obj["ret_code"].ToString() == "00")
-                                        {
-                                            SetRecordResult(db, RecordId, 1);
-                                            AddFeeRecord(db, merchant, pos);
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["ret_msg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "729702301652492288";
+                                        yhConfigId = "729702442300088320";
+                                        surfeeConfigId = "696339175297294336";
                                     }
-                                    else if(pos.BrandId == 22) //立刷微电签
+                                    else
                                     {
-                                        addRate = addRate * 100;
-                                        string content = PublicImportDataService.Instance.SetLiSWeFee(pos.PosSn, merchant.KqMerNo, Fee.ToString("f2"), addRate.ToString());
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if (obj["ret_code"].ToString() == "00")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1);
-                                            AddFeeRecord(db, merchant, pos);
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["ret_msg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "712391426860134400";
+                                        yhConfigId = "712391668250718208";
+                                        surfeeConfigId = "696339175297294336";
                                     }
-                                    else if(pos.BrandId == 7) //盛付通
+                                }
+                                else
+                                {
+                                    if(Kind == 1)
                                     {
-                                        string content = SetFeeForSft(merchant.KqMerNo, Fee.ToString("f4"), addRate.ToString());
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if(obj["respCode"].ToString() == "00")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["errorMsg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "554666598481842176";
+                                        yhConfigId = "683857388021264384";
+                                        surfeeConfigId = "698228081038991360";
                                     }
-                                    else if(pos.BrandId == 8 || pos.BrandId == 9) //海科
+                                    else
                                     {
-                                        // 【融通金宝大POS】
-                                        // 584068951081226240    大POS标准贷0.60|借0.50
-                                        // 584070145207963648    大POS优惠贷0.60|借0.5
-                                        // 574600660289888256    大POS不加
-
-                                        // 691739824478494720    大POS标准贷0.63|借0.50
-                                        // 691740128238383104    大POS优惠贷0.63|借0.50
-                                        // 574600660289888256    大POS不加
-
-                                        // 【融通金宝电签POS】
-                                        // 585167132691009536    电签POS标准贷0.60|借0.50
-                                        // 579355312831074304    电签POS优惠贷0.6|借0.5
-                                        // 570331704834170880    电签POS不加
-
-                                        // 684753829778436096    电签POS标准贷0.63|借0.50
-                                        // 684754046342934528    电签POS优惠贷0.63|借0.5
-                                        // 570331704834170880    电签POS不加
-                                        string bzConfigId = "", yhConfigId = "", surfeeConfigId = "";
-                                        if(pos.BrandId == 8)
-                                        {
-                                            if(Kind == 1)
-                                            {
-                                                bzConfigId = "684753829778436096";
-                                                yhConfigId = "684754046342934528";
-                                                surfeeConfigId = "570331704834170880";
-                                            }
-                                            else
-                                            {
-                                                bzConfigId = "585167132691009536";
-                                                yhConfigId = "579355312831074304";
-                                                surfeeConfigId = "570331704834170880";
-                                            }
-                                        }
-                                        else
-                                        {
-                                            if(Kind == 1)
-                                            {
-                                                bzConfigId = "691739824478494720";
-                                                yhConfigId = "691740128238383104";
-                                                surfeeConfigId = "574600660289888256";
-                                            }
-                                            else
-                                            {
-                                                bzConfigId = "584068951081226240";
-                                                yhConfigId = "584070145207963648";
-                                                surfeeConfigId = "574600660289888256";
-                                            }
-                                        }
-                                        string content = HKSetFeeForBrand(pos.PosSn, bzConfigId, yhConfigId, surfeeConfigId, pos.BrandId);
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if(obj["code"].ToString() == "0")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["msg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "713806109336940544";
+                                        yhConfigId = "713806774515802112";
+                                        surfeeConfigId = "698228081038991360";
                                     }
-                                    else if(pos.BrandId == 10 || pos.BrandId == 11) //联动
+                                }
+                                string content = SetFeeForBrand(pos.PosSn, bzConfigId, yhConfigId, surfeeConfigId, pos.BrandId);
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if(obj["code"].ToString() == "0")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["msg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 6) //立刷
+                            {
+                                addRate = addRate * 100;
+                                string content = PublicImportDataService.Instance.SetLiSFee(pos.PosSn, merchant.KqMerNo, Fee.ToString("f2"), addRate.ToString());
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if (obj["ret_code"].ToString() == "00")
+                                {
+                                    SetRecordResult(db, RecordId, 1);
+                                    AddFeeRecord(db, merchant, pos);
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["ret_msg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 22) //立刷微电签
+                            {
+                                addRate = addRate * 100;
+                                string content = PublicImportDataService.Instance.SetLiSWeFee(pos.PosSn, merchant.KqMerNo, Fee.ToString("f2"), addRate.ToString());
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if (obj["ret_code"].ToString() == "00")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1);
+                                    AddFeeRecord(db, merchant, pos);
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["ret_msg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 7) //盛付通
+                            {
+                                string content = SetFeeForSft(merchant.KqMerNo, Fee.ToString("f4"), addRate.ToString());
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if(obj["respCode"].ToString() == "00")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["errorMsg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 8 || pos.BrandId == 9) //海科
+                            {
+                                // 【融通金宝大POS】
+                                // 584068951081226240    大POS标准贷0.60|借0.50
+                                // 584070145207963648    大POS优惠贷0.60|借0.5
+                                // 574600660289888256    大POS不加
+
+                                // 691739824478494720    大POS标准贷0.63|借0.50
+                                // 691740128238383104    大POS优惠贷0.63|借0.50
+                                // 574600660289888256    大POS不加
+
+                                // 【融通金宝电签POS】
+                                // 585167132691009536    电签POS标准贷0.60|借0.50
+                                // 579355312831074304    电签POS优惠贷0.6|借0.5
+                                // 570331704834170880    电签POS不加
+
+                                // 684753829778436096    电签POS标准贷0.63|借0.50
+                                // 684754046342934528    电签POS优惠贷0.63|借0.5
+                                // 570331704834170880    电签POS不加
+                                string bzConfigId = "", yhConfigId = "", surfeeConfigId = "";
+                                if(pos.BrandId == 8)
+                                {
+                                    if(Kind == 1)
                                     {
-                                        decimal LastFee = Fee / 100;
-                                        string content = LDFeeRate(merchant.KqMerNo, LastFee.ToString("f4"), pos.BrandId, addRate);
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if(obj["code"].ToString() == "000000")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["msg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "684753829778436096";
+                                        yhConfigId = "684754046342934528";
+                                        surfeeConfigId = "570331704834170880";
                                     }
-                                    else if(pos.BrandId == 12 || pos.BrandId == 13) //盒易付
+                                    else
                                     {
-                                        string content = BoxFee(merchant.KqMerNo, Fee.ToString("f2"));
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if(obj["resultCode"].ToString() == "1")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["errorDesc"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "585167132691009536";
+                                        yhConfigId = "579355312831074304";
+                                        surfeeConfigId = "570331704834170880";
                                     }
-                                    else if(pos.BrandId == 15 || pos.BrandId == 16) //联客宝
+                                }
+                                else
+                                {
+                                    if(Kind == 1)
                                     {
-                                        List<string> merno = new List<string>();
-                                        merno.Add(merchant.KqMerNo);
-                                        string policy_code = "";
-                                        string policy_name = "";
-                                        if(Kind == 1)
-                                        {
-                                            policy_code = "LKB_0.63+3";
-                                            policy_name = "联客宝";
-                                        }
-                                        else if(Kind == 2)
-                                        {
-                                            policy_code = "LKB_0.63+0";
-                                            policy_name = "联客宝0.63+0";
-                                        }
-                                        else if(Kind == 3)
-                                        {
-                                            policy_code = "LKB_0.6+0";
-                                            policy_name = "联客宝0.6+0";
-                                        }
-                                        string content = PublicImportDataService.Instance.PospFee(merno, policy_code, policy_name);
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if(obj["code"].ToString() == "200")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["msg"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "691739824478494720";
+                                        yhConfigId = "691740128238383104";
+                                        surfeeConfigId = "574600660289888256";
                                     }
-                                    else if(pos.BrandId == 30 || pos.BrandId == 31) //拉卡拉
+                                    else
                                     {
-                                        string content = PublicImportDataService.Instance.LkLSetFee(merchant.KqMerNo, Fee, addRate);
-                                        JsonData obj = JsonMapper.ToObject(content);
-                                        if (obj["message"].ToString() == "SUCCESS")
-                                        {
-                                            pos.SeoDescription = "设置成功";
-                                            SetRecordResult(db, RecordId, 1, "设置成功");
-                                            db.SaveChanges();
-                                        }
-                                        else
-                                        {
-                                            string msg = obj["message"].ToString();
-                                            pos.SeoDescription = msg;
-                                            SetRecordResult(db, RecordId, -1, msg);
-                                            db.SaveChanges();
-                                        }
+                                        bzConfigId = "584068951081226240";
+                                        yhConfigId = "584070145207963648";
+                                        surfeeConfigId = "574600660289888256";
                                     }
                                 }
+                                string content = HKSetFeeForBrand(pos.PosSn, bzConfigId, yhConfigId, surfeeConfigId, pos.BrandId);
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if(obj["code"].ToString() == "0")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["msg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 10 || pos.BrandId == 11) //联动
+                            {
+                                decimal LastFee = Fee / 100;
+                                string content = LDFeeRate(merchant.KqMerNo, LastFee.ToString("f4"), pos.BrandId, addRate);
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if(obj["code"].ToString() == "000000")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["msg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 12 || pos.BrandId == 13) //盒易付
+                            {
+                                string content = BoxFee(merchant.KqMerNo, Fee.ToString("f2"));
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if(obj["resultCode"].ToString() == "1")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["errorDesc"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 15 || pos.BrandId == 16) //联客宝
+                            {
+                                List<string> merno = new List<string>();
+                                merno.Add(merchant.KqMerNo);
+                                string policy_code = "";
+                                string policy_name = "";
+                                if(Kind == 1)
+                                {
+                                    policy_code = "LKB_0.63+3";
+                                    policy_name = "联客宝";
+                                }
+                                else if(Kind == 2)
+                                {
+                                    policy_code = "LKB_0.63+0";
+                                    policy_name = "联客宝0.63+0";
+                                }
+                                else if(Kind == 3)
+                                {
+                                    policy_code = "LKB_0.6+0";
+                                    policy_name = "联客宝0.6+0";
+                                }
+                                string content = PublicImportDataService.Instance.PospFee(merno, policy_code, policy_name);
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if(obj["code"].ToString() == "200")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["msg"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
+                            }
+                            else if(pos.BrandId == 30 || pos.BrandId == 31) //拉卡拉
+                            {
+                                string content = PublicImportDataService.Instance.LkLSetFee(merchant.KqMerNo, Fee, addRate);
+                                JsonData obj = JsonMapper.ToObject(content);
+                                if (obj["message"].ToString() == "SUCCESS")
+                                {
+                                    pos.SeoDescription = "设置成功";
+                                    SetRecordResult(db, RecordId, 1, "设置成功");
+                                    db.SaveChanges();
+                                }
+                                else
+                                {
+                                    string msg = obj["message"].ToString();
+                                    pos.SeoDescription = msg;
+                                    SetRecordResult(db, RecordId, -1, msg);
+                                    db.SaveChanges();
+                                }
                             }
                         }
-                        db.Dispose();
-                        Thread.Sleep(500);
-                    }
-                    catch (Exception ex)
-                    {
-                        function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "设置费率到支付平台异常");
                     }
                 }
-                else
-                {
-                    Thread.Sleep(500);
-                }
+                db.Dispose();
             }
+            catch (Exception ex)
+            {
+                function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "设置费率到支付平台异常");
+                result = false;
+            }
+            return result;
         }
 
         private void SetRecordResult(WebCMSEntities db, int RecordId, int Status, string Note = "")

AppStart/RabbitMQClient.cs

@@ -5,112 +5,46 @@ using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
 using Library;
 using System.Threading;
+using LitJson;
 
 namespace MySystem
 {
     public class RabbitMQClient
     {
         public readonly static RabbitMQClient Instance = new RabbitMQClient();
-        string UserName,Password,HostName;
+        string UserName,Password,HostName,VirtualHostName;
         private RabbitMQClient()
         {
             UserName = ConfigurationManager.AppSettings["MqUserName"].ToString();
             Password = ConfigurationManager.AppSettings["MqPassword"].ToString();
             HostName = ConfigurationManager.AppSettings["MqHostName"].ToString();
+            VirtualHostName = ConfigurationManager.AppSettings["MqVirtualHostName"].ToString();
         }
 
         #region 单对单发送
-        public void SendMsg(string content, string QueueName = "")
+        public void SendMsg(string content, string QueueName, uint delayMilliseconds = 0)
         {
-            RedisDbconn.Instance.AddList(QueueName, content);
-            //创建连接对象工厂
-            // var factory = new ConnectionFactory()
-            // {
-            //     UserName = UserName,
-            //     Password = Password,
-            //     AutomaticRecoveryEnabled = true,  //如果connection挂掉是否重新连接
-            //     TopologyRecoveryEnabled = true  //连接恢复后，连接的交换机，队列等是否一同恢复
-            // };
-            // List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
-            // string[] HostNames = HostName.Split(',');
-            // foreach (string subHostName in HostNames)
-            // {
-            //     string[] subHostNameData = subHostName.Split(':');
-            //     p.Add(new AmqpTcpEndpoint(subHostNameData[0], int.Parse(subHostNameData[1])));
-            // }
-            // var conn = factory.CreateConnection(p);
-            // var channel = conn.CreateModel();
-            // channel.QueueDeclare(QueueName, true, false, false);
-            // channel.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
-            // channel.Dispose();
-            // conn.Dispose();
-        }
-        #endregion
-
-        #region 单对单发送
-        public void ListenSendMsg()
-        {
-            Thread th = new Thread(ListenSendMsgDo);
-            th.IsBackground = true;
-            th.Start();
-        }
-        Dictionary<string, IModel> channels = new Dictionary<string, IModel>();
-        public void ListenSendMsgDo()
-        {
-            while (true)
+            if(delayMilliseconds > 0)
             {
-                //创建连接对象工厂
-                var factory = new ConnectionFactory()
+                // 设置消息的延迟时间
+                var properties = _channel_send.CreateBasicProperties();
+                properties.Headers = new Dictionary<string, object>
                 {
-                    UserName = UserName,
-                    Password = Password,
-                    AutomaticRecoveryEnabled = true,  //如果connection挂掉是否重新连接
-                    TopologyRecoveryEnabled = true  //连接恢复后，连接的交换机，队列等是否一同恢复
+                    { "x-delay", delayMilliseconds } // 延迟5秒
                 };
-                List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
-                string[] HostNames = HostName.Split(',');
-                foreach (string subHostName in HostNames)
-                {
-                    string[] subHostNameData = subHostName.Split(':');
-                    p.Add(new AmqpTcpEndpoint(subHostNameData[0], int.Parse(subHostNameData[1])));
-                }
-                var conn = factory.CreateConnection(p);
-                bool op = true;
-                while (op)
-                {
-                    string data = RedisDbconn.Instance.RPop<string>("MainServerMq");
-                    if (!string.IsNullOrEmpty(data))
-                    {
-                        try
-                        {
-                            string[] dataList = data.Split("#cut#");
-                            string QueueName = dataList[0];
-                            if (!channels.ContainsKey(QueueName))
-                            { 
-                                var channelCreate = conn.CreateModel();
-                                channels.Add(QueueName, channelCreate);
-                            }
-                            var channel = channels[QueueName];
-                            channel.QueueDeclare(QueueName, true, false, false);
-                            channel.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(dataList[1]));
-                        }
-                        catch (Exception ex)
-                        {
-                            op = false;
-                            function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "MQ消息队列单对单发送监听异常");
-                        }
-                    }
-                }
-                // channel.Dispose();
-                conn.Dispose();
-                function.WriteLog(DateTime.Now.ToString(), "MQ测试");
+                _channel_send.BasicPublish("kxs_direct_ranch", QueueName, properties, Encoding.Default.GetBytes(content));
             }
+            else
+            {
+                _channel_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
+            }
+            function.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "SendMsg2");
         }
         #endregion
 
         #region 单对单接收
-        public static IConnection _connection;
-        public void CreateConn()
+        public static IModel _channel_send;
+        public void CreateConn(string QueueName)
         { 
             var factory = new ConnectionFactory()
             {
@@ -118,7 +52,7 @@ namespace MySystem
                 Password = Password,
                 AutomaticRecoveryEnabled = true,  //如果connection挂掉是否重新连接
                 TopologyRecoveryEnabled = true,  //连接恢复后，连接的交换机，队列等是否一同恢复
-                RequestedHeartbeat = TimeSpan.FromMinutes(1),
+                VirtualHost = VirtualHostName,
             };
             List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
             string[] HostNames = HostName.Split(',');
@@ -127,144 +61,29 @@ namespace MySystem
                 string[] subHostNameData = subHostName.Split(':');
                 p.Add(new AmqpTcpEndpoint(subHostNameData[0], int.Parse(subHostNameData[1])));
             }
-            _connection = factory.CreateConnection(p);
-        }
-        public void StartReceive(string QueueName)
-        {
-            if (_connection == null)
-            {
-                CreateConn();
-            }
-            else if (!_connection.IsOpen)
-            {
-                CreateConn();
-            }
-            var channel = _connection.CreateModel();
-            channel.QueueDeclare(QueueName, true, false, false);
-            EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
-            consumer.Received += (a, e) =>
+            var conn = factory.CreateConnection(p);
+            _channel_send = conn.CreateModel();
+            _channel_send.ExchangeDeclare("kxs_direct_ranch", "x-delayed-message", true);
+            _channel_send.QueueDeclare(QueueName, true, false, false);
+            string routingKey = "delayed_routing_key";
+            IDictionary<string, object> arguments = new Dictionary<string, object>
             {
-                string MsgContent = Encoding.Default.GetString(e.Body.ToArray());                
-                if (QueueName == "TimerStat")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    StatTimerService.Instance.Start(job);
-                }
-                else if (QueueName == "PosTradeStat")
-                {
-                    // JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    // StatService.Instance.Start(job);
-                }
-                else if (QueueName == "SycnSpServer")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    SycnSpService.Instance.Start(job);
-                }
-                else if (QueueName == "CheckWeChatSign")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    CheckWeChatSignService.Instance.Start(job);
-                }
-                else if (QueueName == "CheckAlipaySign")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    CheckAlipaySignService.Instance.Start(job);
-                }
-                else if (QueueName == "WeChatPayBack")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    WeChatPayBackService.Instance.Start(job);
-                }
-                else if (QueueName == "AlipayPayBack")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    AlipayPayBackService.Instance.Start(job);
-                }
-                else if (QueueName == "AlipayPayBack2")
-                {
-                    // JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    // AlipayPayBack2Service.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersDiviList")
-                { 
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ReceiveProfitService.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersStat")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ConsumerOrdersStatService.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersReturnDo")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ConsumerOrdersReturnDoService.Instance.Start(job);
-                }
-                else if (QueueName == "ConsumerOrdersReturnStat")
-                {
-                    JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                    ConsumerOrdersReturnStatService.Instance.Start(job);
-                }
-                else if (QueueName == "MerchantConfirmList")
-                {
-                    MerchantConfirmService.Instance.Start(MsgContent);
-                }
-                else if (QueueName == "DeleteMySqlData")
-                {
-                    DeleteMySqlDataService.Instance.Start(MsgContent);
-                }
-                // else if (QueueName == "PublicMainServer")
-                // { 
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     ReceiveTaskService.Instance.Start(job);
-                // }
-                // else if (QueueName == "SycnTableData")
-                // {
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     if (job.BrandInfo.DataType == 1)
-                //     {
-                //         //同步激活
-                //         SycnActiveRewardService.Instance.Start(job);
-                //     }
-                //     else if (job.BrandInfo.DataType == 2)
-                //     {
-                //         //同步交易
-                //         SycnTradeRecordService.Instance.Start(job);
-                //     }
-                //     else if (job.BrandInfo.DataType == 8)
-                //     {
-                //         //同步商户
-                //         SycnMerchantInfoService.Instance.Start(job);
-                //     }
-                // }
-                // else if (QueueName == "ProfitForEverMonth")
-                // {
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     ProfitService.Instance.Start(job);
-                // }
-                // else if (QueueName == "FluxPrize")
-                // {
-                //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
-                //     FluxService.Instance.Start(job);
-                // }
-                channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                { "x-delayed-type", "direct" } // 这里可以指定不同的交换机类型
             };
-            channel.BasicConsume(QueueName, false, consumer);
+            _channel_send.QueueBind(QueueName, "kxs_direct_ranch", routingKey, arguments);
         }
-        #endregion
-
-
 
-        #region 单对多发送
-        public void SendMsgToExchange(string content, string Exchange = "")
-        {
-            //创建连接对象工厂
+        public static IConnection _connection;
+        public void CreateConn()
+        { 
             var factory = new ConnectionFactory()
             {
                 UserName = UserName,
                 Password = Password,
                 AutomaticRecoveryEnabled = true,  //如果connection挂掉是否重新连接
-                TopologyRecoveryEnabled = true  //连接恢复后，连接的交换机，队列等是否一同恢复
+                TopologyRecoveryEnabled = true,  //连接恢复后，连接的交换机，队列等是否一同恢复
+                RequestedHeartbeat = TimeSpan.FromMinutes(1),
+                VirtualHost = VirtualHostName,
             };
             List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
             string[] HostNames = HostName.Split(',');
@@ -273,48 +92,42 @@ namespace MySystem
                 string[] subHostNameData = subHostName.Split(':');
                 p.Add(new AmqpTcpEndpoint(subHostNameData[0], int.Parse(subHostNameData[1])));
             }
-            var conn = factory.CreateConnection(p);
-            var channel = conn.CreateModel();
-            channel.ExchangeDeclare(Exchange, ExchangeType.Fanout, true, false);
-            channel.BasicPublish(Exchange, "", null, Encoding.Default.GetBytes(content));
-            channel.Dispose();
-            conn.Dispose();
+            _connection = factory.CreateConnection(p);
         }
-        #endregion
-
-        #region 单对多接收
-        public void StartReceiveFromExchange(string QueueName = "", string Exchange = "")
+        public void StartReceive(string QueueName)
         {
-            var factory = new ConnectionFactory()
+            if (_connection == null)
             {
-                UserName = UserName,
-                Password = Password,
-                AutomaticRecoveryEnabled = true,  //如果connection挂掉是否重新连接
-                TopologyRecoveryEnabled = true  //连接恢复后，连接的交换机，队列等是否一同恢复
-            };
-            List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
-            string[] HostNames = HostName.Split(',');
-            foreach (string subHostName in HostNames)
+                CreateConn();
+            }
+            else if (!_connection.IsOpen)
             {
-                string[] subHostNameData = subHostName.Split(':');
-                p.Add(new AmqpTcpEndpoint(subHostNameData[0], int.Parse(subHostNameData[1])));
+                CreateConn();
             }
-            var conn = factory.CreateConnection(p);
-            var channel = conn.CreateModel();
-            //定义队列
-            channel.QueueDeclare(QueueName, true, false, false);
-            //定义交换机
-            channel.ExchangeDeclare(Exchange, ExchangeType.Fanout, true, false);
-            //绑定队列到交换机
-            channel.QueueBind(QueueName, Exchange, "");
-            var consumer = new EventingBasicConsumer(channel);
+            var channel = _connection.CreateModel();
+            channel.QueueBind(QueueName, "kxs_direct_ranch", QueueName);
+            EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
             consumer.Received += (a, e) =>
             {
-                Library.function.WriteLog(Encoding.Default.GetString(e.Body.ToArray()), "接收到的MQ消息");
-                channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
+                if(QueueName == "KXS_DEPOSIT_QUEUE")
+                {
+                    if(ChangePosFeeQueue.Instance.ChangePosDeposit(MsgContent))
+                    {
+                        channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                    }
+                }
+                if(QueueName == "KXS_FEE_QUEUE")
+                {
+                    if(SetDepositPostService.Instance.ChangeFee(MsgContent))
+                    {
+                        channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+                    }
+                }
             };
             channel.BasicConsume(QueueName, false, consumer);
         }
         #endregion
+
     }
 }