提交

username@email.com

3 天以前 e4ee60ed94d24e394a7895daa9fb98df813e5953

 CY_ECommercePlatform/CY.SQLDAL/EC/EC_OrderBasicDAL.cs

@@ -165,6 +165,70 @@
            }
        }


        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModelsheji(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.EC_OrderBasic trueModel = model as Model.EC_OrderBasic;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter unitPricePar = null;
            if (trueModel.UnitPrice.HasValue)
            {
                unitPricePar = new SqlParameter("@UnitPrice", trueModel.UnitPrice);
            }
            else
            {
                unitPricePar = new SqlParameter("@UnitPrice", DBNull.Value);
            }
            SqlParameter DeliveryTime = null;
            if (trueModel.DeliveryTime.HasValue)
            {
                DeliveryTime = new SqlParameter("@DeliveryTime", trueModel.DeliveryTime);
            }
            else
            {
                DeliveryTime = new SqlParameter("@DeliveryTime", DBNull.Value);
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                    new SqlParameter(){ ParameterName ="@Keyid", SqlDbType=System.Data.SqlDbType.Int, DbType=System.Data.DbType.Int32, Direction=ParameterDirection.Output},
                    new SqlParameter(){ ParameterName="@SellerOrderId",SqlDbType=System.Data.SqlDbType.VarChar,Size=25,DbType=System.Data.DbType.String, Direction=ParameterDirection.Output},
                    new SqlParameter("@OrderTypeId",trueModel.OrderTypeId),
                    new SqlParameter("@PrintTypeId",trueModel.PrintTypeId),
                    new SqlParameter("@DocumentName",trueModel.DocumentName),
                    DeliveryTime,//new SqlParameter("@DeliveryTime",trueModel.DeliveryTime),
               new SqlParameter("@SellerId",trueModel.SellerId),
                    new SqlParameter("@BuyerId",trueModel.BuyerId),
                    new SqlParameter("@SellerName",trueModel.SellerName){SqlDbType=SqlDbType.VarChar,Size=200},
                    new SqlParameter("@BuyerName",trueModel.BuyerName){SqlDbType=SqlDbType.VarChar,Size=200},
                    unitPricePar,
                    new SqlParameter("@SumPrice",trueModel.SumPrice),
                    new SqlParameter("@Creater",trueModel.Creater),
                    new SqlParameter("@Operator",trueModel.Operator),
                    new SqlParameter("@Remark",trueModel.Remark??"") ,
                    new SqlParameter("@OutId",(trueModel.OutId==null ? "0":trueModel.OutId.ToString()))
            };
            try
            {
                _dataBase.Query("sp_EC_OrderBasic_Insertsheji", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
                trueModel.Keyid = CY.Infrastructure.Common.MyConvert.ConvertToInt32(sqlParms[0].Value);
                trueModel.SellerOrderId = CY.Infrastructure.Common.MyConvert.ConvertToString(sqlParms[1].Value);
                return trueModel.Keyid.HasValue;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }


        /// <summary>
        /// 修改
        /// </summary>
@@ -269,6 +333,49 @@
            }
            return true;
        }


        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool DeleteModelsheji(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.EC_OrderBasic trueModel = model as Model.EC_OrderBasic;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {

                _eC_OrderOperateDAL = null == _eC_OrderOperateDAL ? new EC_OrderOperateDAL(_dataBase) : _eC_OrderOperateDAL;
                bool isWin = _eC_OrderOperateDAL.InserModel(new EC_OrderOperate()
                {
                    OrderId = trueModel.Keyid,
                    OperateType = 0,
                    Remark = "终止订单",
                    Operator = trueModel.Operator
                });
                if (!isWin)
                    return false;
                else
                    ;
                _dataBase.Query("sp_EC_OrderBasic_DeleteRowsheji", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());

            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }


        /// <summary>
        /// 删除外协订单
@@ -1423,16 +1530,30 @@
        }



        /// <summary>
        /// 根据类型查询 订单
        /// </summary>
        /// <param name="orderId">订单编号</param>
        /// <returns></returns>
        public IEnumerable<EC_OrderBasic> GetOrderByPrintTypeId(int PrintTypeId)
        {
            
            IList<EC_OrderBasic> result = _dataBase.SelectModel<EC_OrderBasic>(" * ", "EC_OrderBasic ", string.Format(" PrintTypeId = {0} and OrderState = 4 ", PrintTypeId));
            return result;
        }


        /// <summary>
        /// 根据客户ID和订单支付状态获取订单列表 
        /// </summary>
        /// <param name="BuyerId">卖家ID</param>
        /// <returns></returns>
        public IList<EC_OrderBasic> GetOrderById(Guid BuyerId, int PayState)
        public IList<EC_OrderBasic> GetOrderById(Guid BuyerId, int PayState, Guid SellerId)
        {
            IList<EC_OrderBasic> result = new List<EC_OrderBasic>();
         
             result = _dataBase.SelectModel<EC_OrderBasic>(" * ", "EC_OrderBasic ", string.Format(" BuyerId = '{0}' and PayState!={1}", BuyerId,PayState));
             result = _dataBase.SelectModel<EC_OrderBasic>(" * ", "EC_OrderBasic ", string.Format(" BuyerId = '{0}' and PayState!={1} and  SellerId = '{2}'", BuyerId,PayState, SellerId));
            return result;
        }
        /// <summary>
@@ -1636,6 +1757,46 @@
            }

            return null == result || result.Count == 0 ? null : result[0];
        }


        /// <summary>
        /// 根据编号获取订单信息
        /// </summary>
        /// <param name="orderId">订单唯一编号</param>
        /// <returns></returns>
        public EC_OrderBasic SelectModelByxiadanId(int orderId)
        {
            if (0 >= orderId)
            {
                return null;
            }
            else
            {
            }
            string condition = "  ";
            if (orderId > 0)
            {
                condition = " b.[XiadanKeyid]=" + orderId + "";
            }
            else
            {
                return null;
            }


            try
            {
                IList<EC_OrderBasic> result = _dataBase.SelectModel<EC_OrderBasic>("a.*", " EC_OrderBasic a inner join   [EC_OrderExtend] b on a.[Keyid] = b.[Keyid] ", condition) as IList<EC_OrderBasic>;//执行查询

                return (null == result || result.Count == 0) ? null : result[0];//返回结果

            }
            catch (Exception ex)
            {
                throw ex;
            }

        }


@@ -2987,7 +3148,7 @@
                    condition += " and  a.CreateTime >= '" + StartCreatTime.Value + "' ";

                if (EndCreatTime != null)
                    condition += " and  a.CreateTime =< '" + EndCreatTime.Value.AddDays(1) + "' ";
                    condition += " and  a.CreateTime <= '" + EndCreatTime.Value.AddDays(1) + "' ";

                if (StartReturnTime != null)
                    condition += " and  d.DeliverTime >= '" + StartReturnTime.Value + "' ";