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(); } }