From df945af99bb7043009d682f34049fe4e6078db0a Mon Sep 17 00:00:00 2001 From: yibo <361071264@qq.com> Date: Wed, 13 Dec 2017 08:16:43 +0800 Subject: [PATCH] =?UTF-8?q?DQUpdate=20=E4=B8=8D=E8=83=BD=E9=80=9A=E8=BF=87?= =?UTF-8?q?ReferenceTo=E6=9B=B4=E6=96=B0=E5=AD=97=E6=AE=B5=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BO/Bill/WeightBill/WeightBillCheck.cs | 8 -------- B3ClientService/Tasks/UpdateLoad/DoCheckBills.cs | 12 +++++++++++- 2 files changed, 11 insertions(+), 9 deletions(-) diff --git a/B3ClientService/BO/Bill/WeightBill/WeightBillCheck.cs b/B3ClientService/BO/Bill/WeightBill/WeightBillCheck.cs index 86c4909..dc6bd08 100644 --- a/B3ClientService/BO/Bill/WeightBill/WeightBillCheck.cs +++ b/B3ClientService/BO/Bill/WeightBill/WeightBillCheck.cs @@ -51,13 +51,5 @@ namespace BWP.B3ClientService.BO query.Where.Conditions.Add(DQCondition.EQ("ID", id)); return query.EExists(); } - - public static void SetSynced(long b3ID) - { - var update = new DQUpdateDom(typeof(WeightBillCheck)); - update.Columns.Add(new DQUpdateColumn("Sync", true)); - update.Where.Conditions.Add(DQCondition.EQ("B3ID", b3ID)); - update.EExecute(); - } } } diff --git a/B3ClientService/Tasks/UpdateLoad/DoCheckBills.cs b/B3ClientService/Tasks/UpdateLoad/DoCheckBills.cs index 77080d1..2c43a9d 100644 --- a/B3ClientService/Tasks/UpdateLoad/DoCheckBills.cs +++ b/B3ClientService/Tasks/UpdateLoad/DoCheckBills.cs @@ -19,7 +19,17 @@ namespace BWP.B3ClientService.Tasks.UpdateLoad { var bwpClient = new BWPClient(uri, item.Item2); bwpClient.Call("/MainSystem/B3ButcherManage/Rpcs/WeighBillRpc/DoCheck", item.Item1); - WeightBillCheck.SetSynced(item.Item1); + SetSynced(item.Item1); + } + } + + static void SetSynced(long b3ID) + { + using (var session = Dmo.NewSession()) + { + var sql = "update a set a.[Sync]=1 from B3ClientService_WeightBillCheck a left outer join B3ClientService_WeightBill w on a.ID=w.ID where w.B3ID=" + b3ID; + session.ExecuteSqlNonQuery(sql); + session.Commit(); } }