Browse Source

去掉一些没用的同步。

master
yibo 7 years ago
parent
commit
8d5eb9dc54
3 changed files with 119 additions and 120 deletions
  1. +2
    -2
      B3ClientService/Tasks/SyncBillFromServer.cs
  2. +115
    -116
      B3ClientService/Tasks/SyncInfoFromServer.cs
  3. +2
    -2
      B3ClientService/Tasks/UpdateLoad/UploadTest.cs

+ 2
- 2
B3ClientService/Tasks/SyncBillFromServer.cs View File

@ -30,8 +30,8 @@ namespace BWP.B3ClientService.Tasks
throw; throw;
} }
SyncSaleOutStore();
SyncProductTask();
//SyncSaleOutStore();
//SyncProductTask();
} }


+ 115
- 116
B3ClientService/Tasks/SyncInfoFromServer.cs View File

@ -54,136 +54,135 @@ namespace BWP.B3ClientService.Tasks
SyncSanction(); SyncSanction();
SyncLiveVarieties(); SyncLiveVarieties();
SyncBodyDiscontItem(); SyncBodyDiscontItem();
SyncClientGoodsSet();
SyncCustomer();
SyncDeliverGoodsLine();
//SyncClientGoodsSet();
//SyncCustomer();
//SyncDeliverGoodsLine();
SyncWorkShop();
SyncWorkUnit();
SyncProductBatch();
SyncStore();
//SyncWorkShop();
//SyncWorkUnit();
//SyncProductBatch();
//SyncStore();
} }
//catch //catch
{ } { }
} }
private void SyncStore()
{
var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncStoreList");
var list = JsonConvert.DeserializeObject<List<BO.Store>>(json);
using (var context = new TransactionContext())
{
var sql1 = @"truncate table [B3ClientService_Store];";
context.Session.ExecuteSqlNonQuery(sql1);
foreach (BO.Store dmo in list)
{
context.Session.Insert(dmo);
}
context.Commit();
}
}
//private void SyncStore()
//{
// var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncStoreList");
// var list = JsonConvert.DeserializeObject<List<BO.Store>>(json);
// using (var context = new TransactionContext())
// {
// var sql1 = @"truncate table [B3ClientService_Store];";
// context.Session.ExecuteSqlNonQuery(sql1);
// foreach (BO.Store dmo in list)
// {
// context.Session.Insert(dmo);
// }
// context.Commit();
// }
//}
private void SyncProductBatch()
{
var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncProductBatch");
json = json.ESerializeDateTime();
var list = JsonConvert.DeserializeObject<List<ProductBatch>>(json);
using (var context = new TransactionContext())
{
var sql1 = @"truncate table [B3ClientService_ProductBatch];";
context.Session.ExecuteSqlNonQuery(sql1);
foreach (ProductBatch dmo in list)
{
// var dmo = new ProductBatch();
// dmo.Name = name;
context.Session.Insert(dmo);
}
context.Commit();
}
}
// private void SyncProductBatch()
// {
// var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncProductBatch");
// json = json.ESerializeDateTime();
// var list = JsonConvert.DeserializeObject<List<ProductBatch>>(json);
// using (var context = new TransactionContext())
// {
// var sql1 = @"truncate table [B3ClientService_ProductBatch];";
// context.Session.ExecuteSqlNonQuery(sql1);
// foreach (ProductBatch dmo in list)
// {
//// var dmo = new ProductBatch();
//// dmo.Name = name;
// context.Session.Insert(dmo);
// }
// context.Commit();
// }
// }
private void SyncWorkUnit()
{
var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncWorkUnitList");
var list = JsonConvert.DeserializeObject<List<WorkUnit>>(json);
using (var context = new TransactionContext())
{
var sql1 = @"truncate table [B3ClientService_WorkUnit];";
context.Session.ExecuteSqlNonQuery(sql1);
foreach (WorkUnit dmo in list)
{
context.Session.Insert(dmo);
}
context.Commit();
}
}
//private void SyncWorkUnit()
//{
// var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncWorkUnitList");
// var list = JsonConvert.DeserializeObject<List<WorkUnit>>(json);
// using (var context = new TransactionContext())
// {
// var sql1 = @"truncate table [B3ClientService_WorkUnit];";
// context.Session.ExecuteSqlNonQuery(sql1);
// foreach (WorkUnit dmo in list)
// {
// context.Session.Insert(dmo);
// }
// context.Commit();
// }
//}
private void SyncWorkShop()
{
var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncWorkShopList");
var list = JsonConvert.DeserializeObject<List<WorkShop>>(json);
using (var context = new TransactionContext())
{
var sql1 = @"truncate table [B3ClientService_WorkShop];";
context.Session.ExecuteSqlNonQuery(sql1);
foreach (WorkShop dmo in list)
{
context.Session.Insert(dmo);
}
context.Commit();
}
}
private void SyncDeliverGoodsLine()
{
var json = RpcFacade.Call<string>("/MainSystem/B3Sale/Rpcs/OffLineRpc/OffLineBaseInfo/OffLineBaseInfoRpc/SyncDeliverGoodsLineList");
var list = JsonConvert.DeserializeObject<List<DeliverGoodsLine>>(json);
using (var context = new TransactionContext())
{
var sql1 = @"truncate table [B3ClientService_DeliverGoodsLine];";
context.Session.ExecuteSqlNonQuery(sql1);
foreach (DeliverGoodsLine dmo in list)
{
context.Session.Insert(dmo);
}
context.Commit();
}
//private void SyncWorkShop()
//{
// var json = RpcFacade.Call<string>("/MainSystem/B3ButcherManage/Rpcs/TouchScreenRpcs/SyncWorkShopList");
// var list = JsonConvert.DeserializeObject<List<WorkShop>>(json);
// using (var context = new TransactionContext())
// {
// var sql1 = @"truncate table [B3ClientService_WorkShop];";
// context.Session.ExecuteSqlNonQuery(sql1);
// foreach (WorkShop dmo in list)
// {
// context.Session.Insert(dmo);
// }
// context.Commit();
// }
//}
}
//private void SyncDeliverGoodsLine()
//{
// var json = RpcFacade.Call<string>("/MainSystem/B3Sale/Rpcs/OffLineRpc/OffLineBaseInfo/OffLineBaseInfoRpc/SyncDeliverGoodsLineList");
// var list = JsonConvert.DeserializeObject<List<DeliverGoodsLine>>(json);
// using (var context = new TransactionContext())
// {
// var sql1 = @"truncate table [B3ClientService_DeliverGoodsLine];";
// context.Session.ExecuteSqlNonQuery(sql1);
// foreach (DeliverGoodsLine dmo in list)
// {
// context.Session.Insert(dmo);
// }
// context.Commit();
// }
private void SyncCustomer()
{
var json = RpcFacade.Call<string>("/MainSystem/B3Sale/Rpcs/OffLineRpc/OffLineBaseInfo/OffLineBaseInfoRpc/SyncCustomerList");
var list = JsonConvert.DeserializeObject<List<Customer>>(json);
using (var context = new TransactionContext())
{
var sql1 = @"truncate table [B3ClientService_Customer];";
context.Session.ExecuteSqlNonQuery(sql1);
foreach (Customer dmo in list)
{
context.Session.Insert(dmo);
}
context.Commit();
}
//}
}
//private void SyncCustomer()
//{
// var json = RpcFacade.Call<string>("/MainSystem/B3Sale/Rpcs/OffLineRpc/OffLineBaseInfo/OffLineBaseInfoRpc/SyncCustomerList");
// var list = JsonConvert.DeserializeObject<List<Customer>>(json);
// using (var context = new TransactionContext())
// {
// var sql1 = @"truncate table [B3ClientService_Customer];";
// context.Session.ExecuteSqlNonQuery(sql1);
// foreach (Customer dmo in list)
// {
// context.Session.Insert(dmo);
// }
// context.Commit();
// }
//}
private void SyncClientGoodsSet()
{
var jsonStr = RpcFacade.Call<string>("/MainSystem/B3ButcherManageForClient/Rpcs/ClientGoodsSetRpc/GetList");
var list = JsonConvert.DeserializeObject<List<ClientGoodsSet>>(jsonStr);
using (var context = new TransactionContext())
{
var sql1 = @"truncate table [B3ClientService_ClientGoodsSet];truncate table [B3ClientService_ClientGoodsSet_Detail];";
context.Session.ExecuteSqlNonQuery(sql1);
foreach (ClientGoodsSet entity in list)
{
context.Session.Insert(entity);
}
context.Commit();
}
}
//private void SyncClientGoodsSet()
//{
// var jsonStr = RpcFacade.Call<string>("/MainSystem/B3ButcherManageForClient/Rpcs/ClientGoodsSetRpc/GetList");
// var list = JsonConvert.DeserializeObject<List<ClientGoodsSet>>(jsonStr);
// using (var context = new TransactionContext())
// {
// var sql1 = @"truncate table [B3ClientService_ClientGoodsSet];truncate table [B3ClientService_ClientGoodsSet_Detail];";
// context.Session.ExecuteSqlNonQuery(sql1);
// foreach (ClientGoodsSet entity in list)
// {
// context.Session.Insert(entity);
// }
// context.Commit();
// }
//}
static void SyncWpfUser() static void SyncWpfUser()
{ {


+ 2
- 2
B3ClientService/Tasks/UpdateLoad/UploadTest.cs View File

@ -26,8 +26,8 @@ namespace BWP.B3ClientService.Tasks
UploadOrderDetail.Execute(serverUri); UploadOrderDetail.Execute(serverUri);
UploadSecondOrder.Execute(serverUri); UploadSecondOrder.Execute(serverUri);
DoCheckBills.Execute(serverUri); DoCheckBills.Execute(serverUri);
UploadTrunksIousOutInStoreRecord.Execute(serverUri);
UploadMaterialRequisitionRecord.Execute(serverUri);
//UploadTrunksIousOutInStoreRecord.Execute(serverUri);
//UploadMaterialRequisitionRecord.Execute(serverUri);
} }
public string Name public string Name


Loading…
Cancel
Save