/**
|
* LF_OrderFileDAL.cs
|
*
|
* 功 能： 卖家文件空间扩展类
|
* 类 名： LF_OrderFileDAL
|
*
|
* Ver 变更日期 负责人 变更内容
|
* ───────────────────────────────────
|
* V0.01 2013-6-17 16:26 吴崎均 初版
|
*
|
*/
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using CY.IDAL;
|
using CY.Model;
|
using System.Data.SqlClient;
|
using System.Data;
|
using System.Transactions;
|
using CY.Infrastructure.Common;
|
using System.IO;
|
using CY.Infrastructure.Query;
|
namespace CY.SQLDAL
|
{
|
public class LF_OrderFilesDAL : ILF_OrderFilesDAL
|
{
|
|
private Database _dataBase = null;
|
|
public LF_OrderFilesDAL()
|
{
|
_dataBase = new Database();
|
}
|
|
/// <summary>
|
/// 新增
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
LF_OrderFile orderFile = model as LF_OrderFile;
|
SqlParameter[] parameters = {
|
//new SqlParameter("@returnValue", SqlDbType.Int,4),
|
new SqlParameter("@OrderId", SqlDbType.Int,4),
|
new SqlParameter("@FileName", SqlDbType.VarChar,250),
|
new SqlParameter("@FilePath", SqlDbType.VarChar,1000),
|
new SqlParameter("@FileSize", SqlDbType.Decimal,5),
|
new SqlParameter("@FileType", SqlDbType.VarChar,10),
|
new SqlParameter("@FileState", SqlDbType.Int,4),
|
new SqlParameter("@UploadTime", SqlDbType.DateTime,8),
|
new SqlParameter("@UploaderId", SqlDbType.UniqueIdentifier,16),
|
new SqlParameter("@SellerId", SqlDbType.UniqueIdentifier,16)};
|
//new SqlParameter("@ClientPath", SqlDbType.VarChar,1000)};
|
parameters[0].Value = orderFile.OrderId;
|
parameters[1].Value = orderFile.FileName;
|
parameters[2].Value = orderFile.FilePath;
|
parameters[3].Value = orderFile.FileSize;
|
parameters[4].Value = orderFile.FileType;
|
parameters[5].Value = orderFile.FileState;
|
parameters[6].Value = orderFile.UploadTime;
|
parameters[7].Value = orderFile.UploaderId;
|
parameters[8].Value = orderFile.SellerId;
|
//parameters[8].Value = orderFile.ClientPath;
|
try
|
{
|
_dataBase.Query("sp_LF_OrderFiles_Insert", CommandType.StoredProcedure, parameters);
|
//return 1.Equals(parameters[0].Value);
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
|
return true;
|
|
}
|
/// <summary>
|
/// 更新一条数据
|
/// </summary>
|
public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
LF_OrderFile orderFile = model as LF_OrderFile;
|
SqlParameter[] parameters = {
|
//new SqlParameter("@returnValue", SqlDbType.Int,4),
|
new SqlParameter("@OrderId", SqlDbType.Int,4),
|
new SqlParameter("@FileName", SqlDbType.VarChar,250),
|
new SqlParameter("@FilePath", SqlDbType.VarChar,1000),
|
new SqlParameter("@FileSize", SqlDbType.Decimal,5),
|
new SqlParameter("@FileType", SqlDbType.VarChar,10),
|
new SqlParameter("@FileState", SqlDbType.Int,4),
|
new SqlParameter("@UploadTime", SqlDbType.DateTime,8),
|
new SqlParameter("@UploaderId", SqlDbType.UniqueIdentifier,16),
|
new SqlParameter("@SellerId", SqlDbType.UniqueIdentifier,16)};
|
//new SqlParameter("@ClientPath", SqlDbType.VarChar,1000)};
|
parameters[0].Value = orderFile.OrderId;
|
parameters[1].Value = orderFile.FileName;
|
parameters[2].Value = orderFile.FilePath;
|
parameters[3].Value = orderFile.FileSize;
|
parameters[4].Value = orderFile.FileType;
|
parameters[5].Value = orderFile.FileState;
|
parameters[6].Value = orderFile.UploadTime;
|
parameters[7].Value = orderFile.UploaderId;
|
parameters[8].Value = orderFile.SellerId;
|
//parameters[8].Value = orderFile.ClientPath;
|
try
|
{
|
_dataBase.Query("sp_LF_OrderFiles_Update", CommandType.StoredProcedure, parameters);
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
|
return true;
|
|
}
|
|
/// <summary>
|
/// 删除一条数据
|
/// </summary>
|
public bool DeleteFiles(int OrderId)
|
{
|
|
|
SqlParameter[] parameters = {new SqlParameter("@OrderId", SqlDbType.Int, 4) };
|
parameters[0].Value = OrderId;
|
try
|
{
|
_dataBase.Query("sp_LF_OrderFiles_DeleteRow", CommandType.StoredProcedure, parameters);
|
return true;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
|
}
|
|
/// <summary>
|
/// 得到一个对象实体
|
/// </summary>
|
public LF_OrderFile GetModel(int OrderId)
|
{
|
if (OrderId == null)
|
return null;//错误数据返会空
|
|
IList<LF_OrderFile> result = _dataBase.SelectModel<LF_OrderFile>("*", "LF_OrderFiles", string.Format(" OrderId='{0}'", OrderId)) as IList<LF_OrderFile>;//执行查询
|
|
return (null == result || result.Count == 0) ? null : result[0];//返回结果
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="m_EC_FirmInfo"></param>
|
/// <param name="m_LF_OrderFile"></param>
|
/// <returns></returns>
|
public bool AddOrderFiles(EC_FirmInfo m_EC_FirmInfo, LF_OrderFile m_LF_OrderFile)
|
{
|
try
|
{
|
bool result = false;
|
EC_FirmInfoDAL eC_FirmInfoDAL = new EC_FirmInfoDAL();
|
LF_OrderFile _lF_OrderFile = GetModel(Convert.ToInt32(m_LF_OrderFile.OrderId));
|
using (TransactionScope t_TransactionScope = new TransactionScope())
|
{
|
if (_lF_OrderFile != null)
|
{
|
result = DeleteFiles(Convert.ToInt32(_lF_OrderFile.OrderId));
|
if(result)
|
{
|
File.Delete(_lF_OrderFile.FilePath);
|
m_EC_FirmInfo.FileSize = m_EC_FirmInfo.FileSize - (Convert.ToInt32(m_LF_OrderFile.FileSize) - Convert.ToInt32(_lF_OrderFile.FileSize));
|
}
|
}
|
result = InserModel(m_LF_OrderFile);
|
if (result)
|
{
|
result = eC_FirmInfoDAL.UpdateModel(m_EC_FirmInfo);
|
if (result)
|
{
|
t_TransactionScope.Complete();
|
}
|
}
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
|
|
}
|
|
///// <summary>
|
///// 新增
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
|
//{
|
// return false;
|
//}
|
|
///// <summary>
|
///// 修改
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
|
//{
|
|
// return false;
|
|
//}
|
|
/// <summary>
|
/// 删除
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
|
return false;
|
|
}
|
|
/// <summary>
|
/// 查询符合条件的文件列表
|
/// </summary>
|
/// <param name="MemberId"></param>
|
/// <param name="startTime"></param>
|
/// <param name="endTime"></param>
|
/// <param name="FilesName"></param>
|
/// <param name="FilesStatus"></param>
|
/// <param name="pa"></param>
|
/// <returns></returns>
|
public IList<LF_OrderFile> GetModeListByMy(Guid MemberId, DateTime startTime, DateTime endTime, string FilesName, string CustomerName,int FilesStatus, Pagination pa)
|
{
|
string selectTarget = " a.*,b.FileSize as SurplusFileSize, c.SellerOrderId as Ordernumber,c.BuyerName as SellerName";
|
string fromSouce = " LF_OrderFiles a INNER JOIN dbo.EC_FirmInfo b ON a.SellerId=b.MemberId INNER JOIN dbo.EC_OrderBasic c ON a.OrderId=c.KeyId where a.SellerId='" + MemberId.ToString() + "' ";
|
if (startTime != DateTime.MinValue && endTime == DateTime.MaxValue)
|
{
|
fromSouce += " and a.UploadTime>='" + startTime + "'";
|
}
|
else if (startTime == DateTime.MinValue && endTime != DateTime.MaxValue)
|
{
|
fromSouce += " and a.UploadTime<='" + endTime + "'";
|
}
|
else if (startTime != DateTime.MinValue && endTime != DateTime.MaxValue)
|
{
|
fromSouce += " and a.UploadTime>='" + startTime + "' and a.UploadTime<='" + endTime + "'";
|
}
|
|
if (!string.IsNullOrEmpty(FilesName))
|
{
|
fromSouce += " and a.FileName like '%" + FilesName + "%'";
|
}
|
if (!string.IsNullOrEmpty(CustomerName))
|
{
|
fromSouce += " and c.BuyerName like '%" + CustomerName + "%'";
|
}
|
if (FilesStatus != -1)
|
{
|
fromSouce += " and a.FileState='" + FilesStatus + "'";
|
}
|
return _dataBase.SelectModelPage<Model.LF_OrderFile>(pa, selectTarget, fromSouce, "a.UploadTime desc ", "UploadTime desc ", string.Empty);
|
}
|
|
/// <summary>
|
/// 批量删除记录
|
/// </summary>
|
/// <param name="keyIdList"></param>
|
/// <returns></returns>
|
public bool DeleteModelList(List<int> keyIdList)
|
{
|
if (keyIdList == null || keyIdList.Count == 0)
|
{
|
return true;
|
}
|
EC_FirmInfoDAL eC_FirmInfoDAL = new EC_FirmInfoDAL();
|
EC_FirmInfo _ecFirmInfoModel = null;
|
bool isSuccess = true;
|
using (TransactionScope scope = new TransactionScope())
|
{
|
foreach (int keyId in keyIdList)
|
{
|
LF_OrderFile model = GetModel(keyId);
|
isSuccess = DeleteFiles(Convert.ToInt32(model.OrderId));
|
|
_ecFirmInfoModel = eC_FirmInfoDAL.GetModelByMemberId(model.SellerId);
|
if (isSuccess)
|
{
|
if (File.Exists(model.FilePath))
|
{
|
File.Delete(model.FilePath);
|
}
|
_ecFirmInfoModel.FileSize = _ecFirmInfoModel.FileSize + Convert.ToInt32(model.FileSize);
|
eC_FirmInfoDAL.UpdateModel(_ecFirmInfoModel);
|
}
|
else
|
{
|
break;
|
}
|
}
|
if (isSuccess)
|
scope.Complete();
|
}
|
return isSuccess;
|
}
|
|
|
}
|
}
|
