public interface IBaseService<T> where T :class{List<T> GetEntities(string sqlWhere);T GetOneEntityByID(int id);T AddEntity(T entity);bool UpdateEntity(T entity);bool DeleteEntity(string sqlWhere);}

    public interface ICommodityService:IBaseService<Model.CommodityModel>{}

        public override IDAL.ICommodityService CommdityDal{//缓存里拿get {OracleDAL.CommodityService instance = System.Web.HttpRuntime.Cache["CommodityDal"] as OracleDAL.CommodityService;if (instance == null){instance = new OracleDAL.CommodityService();System.Web.HttpRuntime.Cache.Add("CommodityDal", instance, null, System.Web.Caching.Cache.NoAbsoluteExpiration, System.Web.Caching.Cache.NoSlidingExpiration, System.Web.Caching.CacheItemPriority.Normal, null);}return instance;}}

namespace Insigma.Eyes.PSS.OracleDAL
{public class CommodityService:ICommodityService{public List<Model.CommodityModel> GetEntities(string sqlWhere){string sql = string.Format("select * from commodity where 1=1 {0}",sqlWhere);List<Model.CommodityModel> listCommodities = new List<Model.CommodityModel>();//Using 限定对象使用的范围在花括号里面，出了花括号后释放资源using (OracleDataReader odr=OracleHelper.ExecuteReader(OracleHelper.ConnectionString, CommandType.Text, sql, null)){while (odr.Read()){Model.CommodityModel commodity = new Model.CommodityModel();commodity.ID = odr.GetInt32(0);commodity.Name = odr.IsDBNull(1) ? "" : odr.GetString(1);commodity.Type = odr.IsDBNull(2) ? "" : odr.GetString(2);commodity.Manufacturer = odr.IsDBNull(3) ? "" : odr.GetString(3);commodity.Inventory = odr.IsDBNull(4) ? 0 : odr.GetInt32(4);commodity.UnitPrice = odr.IsDBNull(5) ? 0 : odr.GetDecimal(5);commodity.Unit = odr.IsDBNull(6) ? "" : odr.GetString(6);listCommodities.Add(commodity);}}return listCommodities;}public Model.CommodityModel GetOneEntityByID(int id){string sqlWhere = string.Format(" and id={0}",id);List<Model.CommodityModel> list = GetEntities(sqlWhere);return list.SingleOrDefault(c => c.ID == id);
        }private int GetNewID(){string sql = "select s_commodity.nextval from dual";return int.Parse(OracleHelper.ExecuteScalar(OracleHelper.ConnectionString,CommandType.Text,sql,null).ToString());}public Model.CommodityModel AddEntity(Model.CommodityModel entity){entity.ID = GetNewID();string sql = string.Format(@"insert into Commodity(ID,Name,Type,Manufacturer,Inventory,UnitPrice,Unit) values({0},'{1}','{2}','{3}',{4},{5},'{6}')", entity.ID, entity.Name, entity.Type, entity.Manufacturer, entity.Inventory, entity.UnitPrice, entity.UnitPrice);if (OracleHelper.ExecuteNonQuery(OracleHelper.ConnectionString,CommandType.Text,sql,null)>0){return entity;}else{return null;}}public bool UpdateEntity(Model.CommodityModel entity){string sql = string.Format("update Commodity set Name='{0}',Type='{1}',Manufacturer='{2}',Inventory={3},UnitPrice={4},Unit='{5}' where ID={6}",entity.Name, entity.Type, entity.Manufacturer, entity.Inventory, entity.UnitPrice, entity.Unit, entity.ID);return OracleHelper.ExecuteNonQuery(OracleHelper.ConnectionString,CommandType.Text,sql,null)>0; }public bool DeleteEntity(string sqlWhere){string sql = string.Format("delete form Commodity where 1=1 {0}",sqlWhere);return OracleHelper.ExecuteNonQuery(OracleHelper.ConnectionString, CommandType.Text, sql, null) > 0;}}
}

namespace Insigma.Eyes.PSS.BLLWCFService
{// 注意: 使用“重构”菜单上的“重命名”命令，可以同时更改代码和配置文件中的接口名“ICommodityManagerService”。
    [ServiceContract]public interface ICommodityManagerService{[OperationContract][FaultContract(typeof(Exception))]CommodityModel[] GetCommodities(string name,string type,string manufacturer,string priceLow,string priceHigh);[OperationContract]CommodityModel[] GetCommoditiesByCondition(string condition);[OperationContract]CommodityModel GetOneCommodity(int id);[OperationContract][FaultContract(typeof(Exception))]CommodityModel AddCommodity(CommodityModel oneCommodity);[OperationContract][FaultContract(typeof(Exception))]bool UpdateCommodity(Model.CommodityModel commodity);}
}

    public class PurchaseManagerService : IPurchaseManagerService{//
        private AbstractFactory.DalFactory dataFactory = null;public PurchaseManagerService(){dataFactory = DefaultProviderDal.DefaultDataProviderFactory;}public Model.PurchaseOrdersModel[] GetPurchaseOrders(string orderNumber, string orderDateStart, string orderDateEnd, string status){string sqlWhere = "";if (!string.IsNullOrWhiteSpace(orderNumber)){sqlWhere += string.Format(" and orderNumber like '%{0}%'", orderNumber);}if (!string.IsNullOrWhiteSpace(orderDateStart)){try{DateTime dt = DateTime.Parse(orderDateStart);sqlWhere += string.Format(" and orderDate>=to_date('{0}','yyyy-MM-dd')", dt.ToString("yyyy-MM-dd"));}catch{Exception oe = new Exception();throw new FaultException<Exception>(oe, "查询条件开始时间有误!");}}if (!string.IsNullOrWhiteSpace(orderDateEnd)){try{DateTime dt = DateTime.Parse(orderDateEnd);sqlWhere += string.Format(" and orderDate<=to_date('{0}','yyyy-MM-dd')", dt.ToString("yyyy-MM-dd"));}catch{Exception oe = new Exception();throw new FaultException<Exception>(oe, "查询条件截至时间有误!");}}if (!string.IsNullOrWhiteSpace(status)){sqlWhere += string.Format(" and Status='{0}'", status);}//IDAL.IPurchaseOrdersService purchaseOrdersService = new OracleDAL.PurchaseOrderService();//return purchaseOrdersService.GetEntities(sqlWhere).ToArray();return dataFactory.PurchaseOrderDal.GetEntities(sqlWhere).ToArray();}public Model.PurchaseCommodityModel[] GetPurchaseCommoditiesByID(int purchaseID){string sqlWhere = string.Format(" and PurchaseOrderID={0}",purchaseID);//看看数据库里面的字段//IDAL.IPurchaseCommodityService purchaseCommodityService =new OracleDAL.PurchaseCommodityService();//return purchaseCommodityService.GetEntities(sqlWhere).ToArray();return dataFactory.PurchaseCommdityDal.GetEntities(sqlWhere).ToArray();}public Model.PurchaseCommodityModel AddPurchaseCommodityModel(Model.PurchaseCommodityModel onePurchaseCommodity){//return new OracleDAL.PurchaseCommodityService().AddEntity(onePurchaseCommodity);return dataFactory.PurchaseCommdityDal.AddEntity(onePurchaseCommodity);}//几个ID要分清楚public bool PostPurchaseOrder(int id){Model.PurchaseOrdersModel oneOrder=GetOnePurchaseOrder(id);if (oneOrder.Status.Equals("已入库")){Exception oe = new Exception();throw new FaultException<Exception>(oe,"订单已经提交，请务重复提交");}List<Model.PurchaseCommodityModel> purchaseCommoditiesList = GetPurchaseCommoditiesByID(id).ToList();IDAL.ICommodityService commodityService = new OracleDAL.CommodityService();foreach (Model.PurchaseCommodityModel onePurchaseCommodity in purchaseCommoditiesList){Model.CommodityModel commodityModel = new Model.CommodityModel();commodityModel.ID = onePurchaseCommodity.CommodityID;commodityModel.Manufacturer = onePurchaseCommodity.CommodityManufacturer;commodityModel.Name = onePurchaseCommodity.CommodityName;commodityModel.Type = onePurchaseCommodity.CommodityType;commodityModel.Unit = onePurchaseCommodity.CommodityUnit;commodityModel.UnitPrice = onePurchaseCommodity.CommodityUnitPrice;commodityModel.Inventory = onePurchaseCommodity.CommodityInventory + onePurchaseCommodity.Count;//这儿不会出现异常了吧，否则要回滚
                commodityService.UpdateEntity(commodityModel);}oneOrder.Status = "已入库";return new OracleDAL.PurchaseOrderService().UpdateEntity(oneOrder);}public Model.PurchaseOrdersModel GetOnePurchaseOrder(int id){//return new OracleDAL.PurchaseOrderService().GetOneEntityByID(id);return dataFactory.PurchaseOrderDal.GetOneEntityByID(id);}public Model.PurchaseCommodityModel GetOnePurchaseCommoditiesByID(int purchaseCommodityID){//return new OracleDAL.PurchaseCommodityService().GetOneEntityByID(purchaseCommodityID);return dataFactory.PurchaseCommdityDal.GetOneEntityByID(purchaseCommodityID);}public bool UpdatePurchaseCommodity(Model.PurchaseCommodityModel model){//return new OracleDAL.PurchaseCommodityService().UpdateEntity(model);return dataFactory.PurchaseCommdityDal.UpdateEntity(model);}public bool DeletePurchaseCommodity(int id){string sqlWhere = " and id=" + id;//return new OracleDAL.PurchaseCommodityService().DeleteEntity(sqlWhere);return dataFactory.PurchaseCommdityDal.DeleteEntity(sqlWhere);}public Model.PurchaseOrdersModel AddPurchaseOrder(Model.PurchaseOrdersModel purchaseOrder){//return new OracleDAL.PurchaseOrderService().AddEntity(purchaseOrder);return dataFactory.PurchaseOrderDal.AddEntity(purchaseOrder);}public bool UpdatePurchaseOrder(Model.PurchaseOrdersModel onePurchaseOrder){//return new OracleDAL.PurchaseOrderService().UpdateEntity(onePurchaseOrder);return dataFactory.PurchaseOrderDal.UpdateEntity(onePurchaseOrder);}public bool DeletePurchaseCommoditiesByPurchaseOrderID(int purchaseOrderID){string sqlWhere = " and PurchaseOrderID=" + purchaseOrderID;//调用另一个模块，调用BLL比较好//return new OracleDAL.PurchaseCommodityService().DeleteEntity(sqlWhere);return dataFactory.PurchaseCommdityDal.DeleteEntity(sqlWhere);}public bool DeleteOrderID(int id){string sqlWhere = string.Format(" and id={0}", id);//return new OracleDAL.PurchaseOrderService().DeleteEntity(sqlWhere);return dataFactory.PurchaseOrderDal.DeleteEntity(sqlWhere);}}
}

    public class WCFServiceBLL{//对WCF而言，对象实例化越多，对服务器压力越大。static BLLCommodity.CommodityManagerServiceClient commodityClient;static BLLSalesOrders.SalesManagerServiceClient salesClient;static BLLUsers.UserManagerServiceClient userClient;static BLLPurchaseOrders.PurchaseManagerServiceClient purchaseClient;public static CommodityManagerServiceClient GetCommodityService(){if (commodityClient==null){commodityClient = new CommodityManagerServiceClient();}if (commodityClient.State==CommunicationState.Closed){commodityClient = new CommodityManagerServiceClient();}if (commodityClient.State==CommunicationState.Faulted){commodityClient = new CommodityManagerServiceClient();}return commodityClient;