解绑删除商户

AppStart/BothdisDbconn.cs

@@ -60,7 +60,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddInt");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddInt");
             }
         }
         #endregion
@@ -83,7 +83,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddNumber");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddNumber");
             }
         }
         #endregion
@@ -123,7 +123,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:HSet");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:HSet");
             }
         }
         #endregion
@@ -146,7 +146,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:HAddInt");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:HAddInt");
             }
         }
         #endregion
@@ -169,7 +169,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:HAddNumber");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:HAddNumber");
             }
         }
         #endregion
@@ -229,7 +229,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:SAdd");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:SAdd");
             }
         }
         public void SAdd(string key, object[] value)
@@ -249,7 +249,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:SAdd");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:SAdd");
             }
         }
         #endregion
@@ -295,7 +295,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddList");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddList");
             }
         }
         public void AddList(string key, object[] value)
@@ -315,7 +315,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddList");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddList");
             }
         }
         #endregion
@@ -352,7 +352,7 @@ namespace MySystem
                     value = value,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddSort");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:AddSort");
             }
         }
         #endregion
@@ -396,7 +396,7 @@ namespace MySystem
                     end = end,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:Remove");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:Remove");
             }
         }
 
@@ -419,7 +419,7 @@ namespace MySystem
                     key = pattern,
                     errMsg = ex.ToString(),
                 };
-                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:Clear");  // TODO:重新执行，最多重试3次
+                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(err), "Tendis:Clear");
             }
         }
     }

AppStart/Helper/SycnSpServer/SycnSpBindService.cs

@@ -87,6 +87,21 @@ namespace MySystem
                                 //         spdb.SaveChanges();
                                 //     }
                                 // }
+
+                                // 删除对应商户
+                                PxcModels.MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == Bind.MerNo);
+                                if (forMerNo != null)
+                                {
+                                    PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PxcModels.PosMachinesTwo();
+                                    PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
+                                    if(merchant != null)
+                                    {
+                                        db.PosMerchantInfo.Remove(merchant);
+                                    }
+                                    db.MachineForMerNo.Remove(forMerNo);
+                                    db.SaveChanges();
+                                }
+
                                 BindRecord edit = spdb.BindRecord.FirstOrDefault(m => m.Id == Bind.Id);
                                 if (edit != null)
                                 {

AppStart/Helper/SycnSpServer/SycnSpMerchantService.cs

@@ -84,7 +84,7 @@ namespace MySystem
                                         Name = Name.Replace("个体商户", "");
                                         Name = Name.Replace("企业户", "");
                                         Name = Name.Replace("企业商户", "");
-                                        bool check = db.PosMerchantInfo.Any(m => m.MerIdcardNo.StartsWith(startNo) && m.MerIdcardNo.EndsWith(endNo) && m.MerchantName.Contains(Name));
+                                        bool check = db.PosMerchantInfo.Any(m => m.MerIdcardNo.StartsWith(startNo) && m.MerIdcardNo.EndsWith(endNo) && m.MerchantName.Contains(Name)); // TODO:重复绑定会识别成非首台机
                                         if(check)
                                         {
                                             IsFirst = 0;

AppStart/Helper/SycnSpServer/SycnSpUnBindService.cs

@@ -48,6 +48,12 @@ namespace MySystem
                                     db.MachineForMerNo.Remove(forMerNo);
                                     db.SaveChanges();
                                 }
+                                // 删除对应商户
+                                PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
+                                if(merchant != null)
+                                {
+                                    db.PosMerchantInfo.Remove(merchant);
+                                }
                                 db.MachineUnBind.Add(new PxcModels.MachineUnBind()
                                 {
                                     CreateDate = DateTime.Now,

AppStart/RabbitMQClient.cs

@@ -247,7 +247,6 @@ namespace MySystem
                 //     JobMqMsg job = Newtonsoft.Json.JsonConvert.DeserializeObject<JobMqMsg>(MsgContent);
                 //     FluxService.Instance.Start(job);
                 // }
-                // TODO: 需要等待回复jobserver成功才能清除
                 channel.BasicAck(e.DeliveryTag, true); //收到回复后，RabbitMQ会直接在队列中删除这条消息
             };
             channel.BasicConsume(QueueName, false, consumer);