using HStation.Dto.TransferFile;
|
using Microsoft.AspNetCore.Http;
|
|
namespace HStation.CAL.LocalClient
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class TransferRevitFile : ITransferRevitFile
|
{
|
private readonly HStation.Service.TransferRevitFile _service = new();
|
|
public TransferRevitFile(IHttpContextAccessor httpContextAccessor)
|
{
|
_httpContextAccessor = httpContextAccessor;
|
}
|
|
private readonly IHttpContextAccessor _httpContextAccessor;
|
|
#region Query
|
|
/// <summary>
|
/// 获取所有
|
/// </summary>
|
public async Task<List<TransferRevitFileDto>> GetAll()
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var list = _service.GetAll();
|
var vmList = list?.Select(x => new TransferRevitFileDto(x)).ToList();
|
return vmList;
|
});
|
}
|
|
/// <summary>
|
/// 通过 ID 获取
|
/// </summary>
|
public async Task<TransferRevitFileDto> GetByID(long input)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var model = _service.GetByID(input);
|
return model == null ? null : new TransferRevitFileDto(model);
|
});
|
}
|
|
/// <summary>
|
/// 通过 Ids 获取
|
/// </summary>
|
public async Task<List<TransferRevitFileDto>> GetByIds(List<long> ids)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var list = _service.GetByIds(ids);
|
var vmList = list?.Select(x => new TransferRevitFileDto(x)).ToList();
|
return vmList;
|
});
|
}
|
|
/// <summary>
|
/// 获取模糊列表
|
/// </summary>
|
public async Task<List<TransferRevitFileDto>> GetFluzzyList
|
(
|
string FileName,
|
string FileCode,
|
string FileSuffix,
|
string UploadUserName,
|
DateTime? StartTime,
|
DateTime? EndTime
|
)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var list = _service.GetFluzzyList(FileName, FileCode, FileSuffix, UploadUserName, StartTime, EndTime);
|
var vmList = list?.Select(x => new TransferRevitFileDto(x)).ToList();
|
return vmList;
|
});
|
}
|
|
/// <summary>
|
/// 获取模糊分页列表
|
/// </summary>
|
public async Task<PageListOutput<TransferRevitFileDto>> GetFluzzyPageList(QueryTransferRevitFileFluzzyPageListInput input)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
int total = 0;
|
var list = _service.GetFluzzyPageList(input.FileName, input.FileCode, input.FileSuffix, input.UploadUserName, input.StartTime, input.EndTime, input.PageIndex, input.PageSize, ref total);
|
var vmList = list?.Select(x => new TransferRevitFileDto(x)).ToList();
|
return new PageListOutput<TransferRevitFileDto>() { Total = total, List = vmList };
|
});
|
}
|
|
#endregion Query
|
|
#region Insert
|
|
/// <summary>
|
/// 插入一条 (同时上传文件)
|
/// </summary>
|
public async Task<long> Insert(AddTransferRevitFileInput input)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var request = _httpContextAccessor.HttpContext.Request;
|
if (request.Form.Files == null || request.Form.Files.Count != 1)
|
{
|
throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, "文件验证错误");
|
}
|
var fileCode = input.FileCode;
|
if (string.IsNullOrEmpty(fileCode))
|
{
|
fileCode = Yw.YitIdHelper.NextId().ToString();
|
}
|
if (_service.IsExistFileCode(fileCode))
|
{
|
throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, "文件编码已存在");
|
}
|
var user = new HStation.Service.TransferFileUser().GetByName(input.UploadUserName);
|
if (user == null)
|
{
|
throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.V001, "用户名称不存在");
|
}
|
|
var uploadFile = request.Form.Files[0];
|
var model = new Model.TransferRevitFile();
|
model.FileName = uploadFile.FileName;
|
model.FileCode = fileCode;
|
model.FileSuffix = Path.GetExtension(uploadFile.FileName);
|
model.StorageHouse = ConfigHelper.DataFolder;
|
model.StorageCode = Yw.Service.FileHelper.UploadSubFile(ConfigHelper.DataFolder, uploadFile.OpenReadStream(), Path.GetExtension(uploadFile.FileName));
|
var filePath = Yw.Service.FileHelper.GetFilePath(model.StorageHouse, model.StorageCode);
|
var fileInfo = new FileInfo(filePath);
|
model.FileSize = fileInfo.Length;
|
model.UploadTime = DateTime.Now;
|
model.UploadUserID = user.ID;
|
model.UploadUserName = input.UploadUserName;
|
model.Description = input.Description;
|
var id = _service.Insert(model);
|
if (id < 1)
|
{
|
Yw.Service.FileHelper.Delete(model.StorageHouse, model.StorageCode);
|
}
|
return id;
|
});
|
}
|
|
#endregion Insert
|
|
#region Exist
|
|
/// <summary>
|
/// 判断 FileCode 是否存在
|
/// </summary>
|
public async Task<bool> IsExistFileCode(string FileCode)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var bol = _service.IsExistFileCode(FileCode);
|
return bol;
|
});
|
}
|
|
/// <summary>
|
/// 判断 FileCode 是否存在 ExceptID
|
/// </summary>
|
public async Task<bool> IsExistFileCodeExceptID(FileCodeExceptIDInput input)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var bol = _service.IsExistFileCodeExceptID(input.FileCode, input.ExceptID);
|
return bol;
|
});
|
}
|
|
#endregion Exist
|
|
#region Delete
|
|
/// <summary>
|
/// 通过 ID 删除
|
/// </summary>
|
public async Task<bool> DeleteByID(long input)
|
{
|
return await Task.Factory.StartNew(() =>
|
{
|
var model = _service.GetByID(input);
|
if (model == null)
|
{
|
throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D001, "数据不存在");
|
}
|
var bol = _service.DeleteByID(input, out string msg);
|
if (bol)
|
{
|
Yw.Service.FileHelper.Delete(model.StorageHouse, model.StorageCode);
|
return bol;
|
}
|
throw YOops.Oh(eResultCode.Alert, InternalErrorCodes.D999, msg);
|
});
|
}
|
|
#endregion Delete
|
}
|
}
|
