BWPB3
/
ButcherFactorySolution


								using ButcherFactory.BO.Utils;

								using Forks.EnterpriseServices.DomainObjects2;

								using Forks.JsonRpc.Client;

								using Newtonsoft.Json;

								using System;

								using System.Collections.Generic;

								using System.Linq;

								using System.Text;

								using System.Threading.Tasks;


								namespace ButcherFactory.BO.Rpcs

								{

								  public static class BaseInfoSyncRpc

								  {

								    const string baseInfoRpcPath = @"/MainSystem/B3ClientService/Rpcs/SyncBaseInfoRpc/";


								    static void TruncateTable(Type type, IDmoSession session)

								    {

								      var table = DmoInfo.Get(type).MappedDBObject;

								      var sql = string.Format("truncate table [{0}]", table);

								      session.ExecuteSqlNonQuery(sql);

								    }


								    public static void SyncBaseInfo<T>(string methodName = null)

								      where T : BaseInfo

								    {

								      var type = typeof(T);

								      if (string.IsNullOrEmpty(methodName))

								        methodName = "Sync" + type.Name;

								      var json = RpcFacade.Call<string>(baseInfoRpcPath + methodName);

								      var list = JsonConvert.DeserializeObject<List<T>>(json);

								      using (var session = Dmo.NewSession(AppContext.ConnectInfo.SqlConnection))

								      {

								        TruncateTable(type, session);

								        foreach (var item in list)

								          session.Insert(item);

								        session.Commit();

								      }

								    }


								    public static void SyncGoodsByTag(string tag)

								    {

								      //var json = RpcFacade.Call<string>(baseInfoRpcPath + "SyncGoods");

								      //var list = JsonConvert.DeserializeObject<List<Goods>>(json);

								      //using (var session = Dmo.NewSession(AppContext.ConnectInfo.SqlConnection))

								      //{

								      //  TruncateTable(typeof(Goods), session);

								      //  foreach (var item in list)

								      //    session.Insert(item);

								      //  session.Commit();

								      //}

								    }

								  }

								}