修改费率逻辑修改，轮训

Util/HaoDa/HaoDaFeeHelper.cs

@@ -31,7 +31,7 @@ public class HaoDaFeeHelper
             string content = RedisDbconn.Instance.RPop<string>("HaoDaFeeQueue");
             if (!string.IsNullOrEmpty(content))
             {
-                SetFee(int.Parse(content));
+                SetFee(content);
             }
             else
             {
@@ -40,41 +40,63 @@ public class HaoDaFeeHelper
         }
     }
 
-    public void SetFee(int Id)
+    public void SetFee(string data)
     {
         try
         {
+            string[] list = data.Split('|');
+            int Id = int.Parse(list[0]);
+            string FeeRate = list[1];
             WebCMSEntities db = new WebCMSEntities();
             MerchantAddInfo addinfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == Id);
             MerchantInfo info = db.MerchantInfo.FirstOrDefault(m => m.Id == Id);
             if(info != null && addinfo != null)
             {
-                string FeeRate = addinfo.FeeRate;
+                // string FeeRate = addinfo.FeeRate;
                 if(string.IsNullOrEmpty(FeeRate)) FeeRate = "0.38";
-                string result = HaoDaHelper.Instance.SetFee(addinfo.MchtNo, FeeRate, addinfo.BrandId, addinfo.AgentName);
-                JsonData jsonObj = JsonMapper.ToObject(result);
-                result = result.Replace("null", "\"\"");
-                int Status = 0;
-                string Remark = "";
-                string resultCode = jsonObj["resultCode"].ToString();
-                if(resultCode != "1")
+                bool op = true;
+                int channel = int.Parse(addinfo.AgentName);
+                int reqCount = 0;
+                while(op)
                 {
-                    Remark = jsonObj["errorDesc"].ToString();
-                }
-                else
-                {
-                    Status = 1;
+                    string result = HaoDaHelper.Instance.SetFee(addinfo.MchtNo, FeeRate, addinfo.BrandId, channel.ToString());
+                    JsonData jsonObj = JsonMapper.ToObject(result);
+                    result = result.Replace("null", "\"\"");
+                    int Status = 0;
+                    string Remark = "";
+                    string resultCode = jsonObj["resultCode"].ToString();
+                    if(resultCode != "1")
+                    {
+                        Remark = jsonObj["errorDesc"].ToString();
+                    }
+                    else
+                    {
+                        Status = 1;
+                        addinfo.FeeRate = FeeRate;
+                        op = false;
+                    }
+                    db.MerchantFeeRecord.Add(new MerchantFeeRecord()
+                    {
+                        Status = Status,
+                        CreateDate = DateTime.Now,
+                        SettleFee = FeeRate,
+                        MerchantId = addinfo.Id,
+                        UserId = info.UserId,
+                        Remark = Remark,
+                    });
+                    db.SaveChanges();
+
+                    reqCount += 1;
+                    if(reqCount >= 5)
+                    {
+                        op = false;
+                    }
+                    if(Remark == "无权限的操作")
+                    {
+                        channel += 1;
+                        if(channel > 5) channel = 1;
+                    }
                 }
-                db.MerchantFeeRecord.Add(new MerchantFeeRecord()
-                {
-                    Status = Status,
-                    CreateDate = DateTime.Now,
-                    SettleFee = FeeRate,
-                    MerchantId = addinfo.Id,
-                    UserId = info.UserId,
-                    Remark = Remark,
-                });
-                db.SaveChanges();
             }            
             db.Dispose();
         }