using IBKLinker_Minio.Entity ;
using log4net ;
using System ;
using System.Collections.Generic ;
using System.Linq ;
using System.Reflection ;
using System.Text ;
using System.Threading.Tasks ;
using System.Web.Http ;
using Minio ;
using System.Net.PeerToPeer ;
using System.IO ;
using System.Reactive.Linq ;
using Minio.DataModel ;
using System.Security.AccessControl ;
using System.IO.Pipes ;
using System.Net.Mime ;
using IBKLinker_Minio.Entity.MinioController ;
using SOA.Objects ;
using SOA.Persistent ;
using System.Web.Http.Results ;
using System.Runtime.InteropServices.ComTypes ;
using System.Xml ;
using Swashbuckle.Swagger ;
using System.Runtime.ConstrainedExecution ;
using System.Net.Http ;
using System.Web.UI.WebControls ;
using System.Runtime.Remoting.Contexts ;
using System.Runtime.InteropServices ;
using System.Net ;
using NPOI.XSSF.UserModel ;
using NPOI.SS.UserModel ;
using System.Net.Http.Headers ;
using NPOI.SS.Formula.Functions ;
using System.Xml.Linq ;
using NPOI.HPSF ;
using IBKLinker_Minio.Common ;
namespace IBKLinker_Minio.Controller.MinioController
{
/// <summary>
/// 作者：孙亮
/// 编写时间：
/// 编写内容：
/// </summary>
[RoutePrefix("minio/minioapi")]
public class MinioApiController : ApiController
{
/// <summary>
/// 调用log日志文件
/// </summary>
private static readonly ILog logger = LogManager . GetLogger ( MethodBase . GetCurrentMethod ( ) . DeclaringType ) ;
#region minio权限表
/// <summary>
/// 添加minio权限表
/// </summary>
/// <param name="minioAuthority">权限表</param>
[HttpPost, Route("AddAuthority")]
public RequestEntity AddAuthority ( MinioAuthority minioAuthority )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
///拿到表自增长的值赋值给自增长主键pk
minioAuthority . Id = getPk ( "S_MINIO_AUTHORITY" , "MINIO_AUTHORITY" ) ;
///给创建时间赋值
minioAuthority . CreatorTime = DateTime . Now ;
///把需要添加的数据同步到数据库
db . Insert < MinioAuthority > ( minioAuthority ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_AUTHORITY， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 修改minio权限表
/// </summary>
/// <param name="data">修改数据</param>
[HttpPost, Route("UpdateAuthority")]
public RequestEntity UpdateAuthority ( List < MinioAuthority > data )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
///启动事务
db . BeginTransaction ( ) ;
///给修改时间赋值
DateTime time = DateTime . Now ;
db . Update < MinioAuthority > ( data ) ;
db . Commit ( ) ;
request . code = "0" ;
}
catch ( Exception ex )
{
request . code = "1" ;
db . Rollback ( ) ;
///把错误日志写到日志文件
logger . ErrorFormat ( "主表:MINIO_AUTHORITY， ， , ex ) ;
}
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_AUTHORITY， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 删除minio权限表
/// </summary>
/// <param name="master">需要删除的数据</param>
[HttpPost, Route("RemoveAuthority")]
public RequestEntity RemoveAuthority ( List < MinioAuthority > master )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
db . BeginTransaction ( ) ;
db . Delete < MinioAuthority > ( master ) ;
db . Commit ( ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_AUTHORITY， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 查询minio权限表
/// </summary>
/// <returns></returns>
[HttpPost, Route("GetAuthority")]
public RequestEntity GetAuthority ( MinioAuthority minioAuthority )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
IList < MinioAuthority > result = new List < MinioAuthority > ( ) ;
if ( ! string . IsNullOrEmpty ( minioAuthority . LimitsAuthorityId . ToString ( ) ) )
{
sql + = " and LIMITS_AUTHORITY_ID ='" + minioAuthority . LimitsAuthorityId + "'" ;
}
request . data = db . Query < MinioAuthority > ( "select * from MINIO_AUTHORITY where 1=1 " + sql + " ORDER BY PK" ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_AUTHORITY， ， , ex ) ;
}
return request ;
}
# endregion
#region minio角色表
/// <summary>
/// 添加minio角色表
/// </summary>
/// <param name="minioUser">角色表</param>
[HttpPost, Route("AddUSER")]
public RequestEntity AddUSER ( MinioUser minioUser )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
///拿到表自增长的值赋值给自增长主键pk
minioUser . UserId = getPk ( "S_MINIO_USER" , "MINIO_USER" ) ;
///给创建时间赋值
minioUser . CreatorTime = DateTime . Now ;
///把需要添加的数据同步到数据库
db . Insert < MinioUser > ( minioUser ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_USER， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 修改minio角色表
/// </summary>
/// <param name="data">修改数据</param>
[HttpPost, Route("UpdateUSER")]
public RequestEntity UpdateUSER ( List < MinioUser > data )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
///启动事务
db . BeginTransaction ( ) ;
///给修改时间赋值
DateTime time = DateTime . Now ;
db . Update < MinioUser > ( data ) ;
db . Commit ( ) ;
request . code = "0" ;
}
catch ( Exception ex )
{
request . code = "1" ;
db . Rollback ( ) ;
///把错误日志写到日志文件
logger . ErrorFormat ( "主表:MINIO_USER， ， , ex ) ;
}
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_USER， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 删除minio角色表
/// </summary>
/// <param name="master">需要删除的数据</param>
[HttpPost, Route("RemoveUSER")]
public RequestEntity RemoveUSER ( List < MinioUser > master )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
db . BeginTransaction ( ) ;
db . Delete < MinioUser > ( master ) ;
db . Commit ( ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_USER， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 查询minio角色表
/// </summary>
/// <returns></returns>
[HttpPost, Route("GetUSER")]
public RequestEntity GetUSER ( MinioUser minioUser )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
IList < MinioUser > result = new List < MinioUser > ( ) ;
if ( ! string . IsNullOrEmpty ( minioUser . UserName . ToString ( ) ) )
{
sql + = " and USER_NAME ='" + minioUser . UserName + "'" ;
}
request . data = db . Query < MinioUser > ( "select * from MINIO_USER where 1=1 " + sql + " ORDER BY PK" ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_USER， ， , ex ) ;
}
return request ;
}
# endregion
#region minio文件关联表
/// <summary>
/// 添加minio文件关联表
/// </summary>
/// <param name="minioFileassociation">文件关联表</param>
[HttpPost, Route("AddFileassociation")]
public RequestEntity AddFileassociation ( MinioFileassociation minioFileassociation )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
///拿到表自增长的值赋值给自增长主键pk
minioFileassociation . Pk = getPk ( "S_MINIO_FILEASSOCIATION" , "MINIO_FILEASSOCIATION" ) ;
///给创建时间赋值
minioFileassociation . CreatorTime = DateTime . Now ;
///把需要添加的数据同步到数据库
db . Insert < MinioFileassociation > ( minioFileassociation ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_FILEASSOCIATION， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 修改minio文件关联表
/// </summary>
/// <param name="data">修改数据</param>
[HttpPost, Route("UpdateFileassociation")]
public RequestEntity UpdateFileassociation ( List < MinioFileassociation > data )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
///启动事务
db . BeginTransaction ( ) ;
///给修改时间赋值
DateTime time = DateTime . Now ;
db . Update < MinioFileassociation > ( data ) ;
db . Commit ( ) ;
request . code = "0" ;
}
catch ( Exception ex )
{
request . code = "1" ;
db . Rollback ( ) ;
///把错误日志写到日志文件
logger . ErrorFormat ( "主表:MINIO_FILEASSOCIATION， ， , ex ) ;
}
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_FILEASSOCIATION， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 删除minio文件关联表
/// </summary>
/// <param name="master">需要删除的数据</param>
[HttpPost, Route("RemoveFileassociation")]
public RequestEntity RemoveFileassociation ( List < MinioFileassociation > master )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
db . BeginTransaction ( ) ;
db . Delete < MinioFileassociation > ( master ) ;
db . Commit ( ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_FILEASSOCIATION， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 查询minio文件关联表
/// </summary>
/// <returns></returns>
[HttpPost, Route("GetFileassociation")]
public RequestEntity GetFileassociation ( string FileName )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
IList < MinioFileassociation > result = new List < MinioFileassociation > ( ) ;
if ( ! string . IsNullOrEmpty ( FileName . ToString ( ) ) )
{
sql + = " and FILE_NAME like'%" + FileName + "%'" ;
}
request . data = db . Query < MinioFileassociation > ( "select * from MINIO_FILEASSOCIATION where 1=1 " + sql + " ORDER BY PK" ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_FILEASSOCIATION， ， , ex ) ;
}
return request ;
}
# endregion
#region minio角色权限表
/// <summary>
/// 添加minio角色权限表
/// </summary>
/// <param name="minioRolePermission">minio角色权限表</param>
[HttpPost, Route("AddRolePermission")]
public RequestEntity AddRolePermission ( MinioRolePermission minioRolePermission )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
///拿到表自增长的值赋值给自增长主键pk
minioRolePermission . Pk = getPk ( "S_MINIO_ROLE_PERMISSION" , "MINIO_ROLE_PERMISSION" ) ;
///给创建时间赋值
minioRolePermission . CreatorTime = DateTime . Now ;
///把需要添加的数据同步到数据库
db . Insert < MinioRolePermission > ( minioRolePermission ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_ROLE_PERMISSION， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 修改minio角色表
/// </summary>
/// <param name="data">修改数据</param>
[HttpPost, Route("UpdateRolePermission")]
public RequestEntity UpdateRolePermission ( List < MinioRolePermission > data )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
///启动事务
db . BeginTransaction ( ) ;
///给修改时间赋值
DateTime time = DateTime . Now ;
db . Update < MinioRolePermission > ( data ) ;
db . Commit ( ) ;
request . code = "0" ;
}
catch ( Exception ex )
{
request . code = "1" ;
db . Rollback ( ) ;
///把错误日志写到日志文件
logger . ErrorFormat ( "主表:MINIO_ROLE_PERMISSION， ， , ex ) ;
}
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_ROLE_PERMISSION， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 删除minio角色表
/// </summary>
/// <param name="master">需要删除的数据</param>
[HttpPost, Route("RemoveRolePermission")]
public RequestEntity RemoveRolePermission ( List < MinioRolePermission > master )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
db . BeginTransaction ( ) ;
db . Delete < MinioRolePermission > ( master ) ;
db . Commit ( ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_ROLE_PERMISSION， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 查询minio角色表
/// </summary>
/// <returns></returns>
[HttpPost, Route("GetRolePermission")]
public RequestEntity GetRolePermission ( MinioRolePermission minioRolePermission )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
IList < MinioRolePermission > result = new List < MinioRolePermission > ( ) ;
if ( ! string . IsNullOrEmpty ( minioRolePermission . Id . ToString ( ) ) )
{
sql + = " and ID =" + minioRolePermission . Id ;
}
request . data = db . Query < MinioRolePermission > ( "select * from MINIO_ROLE_PERMISSION where 1=1 " + sql + " ORDER BY PK" ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_ROLE_PERMISSION， ， , ex ) ;
}
return request ;
}
# endregion
#region minio文件文件夹路径表
/// <summary>
/// 添加minio文件文件夹路径表
/// </summary>
/// <param name="minioStoragePath">minio文件文件夹路径表</param>
[HttpPost, Route("AddStoragePath")]
public RequestEntity AddStoragePath ( List < MinioStoragePath > minioStoragePath )
{
RequestEntity request = new RequestEntity ( ) ;
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
MinioClient minio = new MinioClient ( "172.15.88.212:9000" , "minioadmin" , "minioadmin" ) ; //连接所需minio所在地址、登录名、密码
string buckname = "dayetegang" ; //桶名称
List < MinioStoragePath > date = new List < MinioStoragePath > ( ) ;
///创建数据库连接上下文对象
db . BeginTransaction ( ) ; //启动事务
if ( minioStoragePath ! = null )
{
foreach ( var item in minioStoragePath )
{
MinioStoragePath data = new MinioStoragePath ( ) ;
date = db . Query < MinioStoragePath > ( "select * from MINIO_STORAGE_PATH where pk='" + minioStoragePath [ 0 ] . Upk + "' ORDER BY PK" ) . ToList ( ) ;
if ( item . FileType = = 0 ) //如果是文件夹
{
if ( item . Upk > 0 ) //判断如果创建的是根目录文件夹前端不需要对父级id传值
{
if ( date . Count > 0 )
{
data . Upk = minioStoragePath [ 0 ] . Upk ; //子文件夹的父级id
data . FileName = minioStoragePath [ 0 ] . FileName ; //文件名称
data . FileType = minioStoragePath [ 0 ] . FileType ; //文件类型
data . FilePath = minioStoragePath [ 0 ] . FilePath ; //文件路径
data . CreatorUser = minioStoragePath [ 0 ] . CreatorUser ; //创建者
data . ClearFlag = "0" ; //删除状态为未删除
data . CreatorTime = DateTime . Now ; //创建时间
data . FileLevel = date [ 0 ] . FileLevel + 1 ; //层级
data . Pk = Convert . ToInt32 ( db . QueryScalar ( "select S_MINIO_STORAGE_PATH.nextval from dual" ) ) ; ///拿到表自增长的值赋值给自增长主键pk
db . Insert < MinioStoragePath > ( data ) ;
}
}
else
{
data . Pk = Convert . ToInt32 ( db . QueryScalar ( "select S_MINIO_STORAGE_PATH.nextval from dual" ) ) ; ///拿到表自增长的值赋值给自增长主键pk
data . Upk = 0 ; //子文件夹的父级id（ ）
data . FileName = minioStoragePath [ 0 ] . FileName ; //文件名称
data . FileType = minioStoragePath [ 0 ] . FileType ; //文件类型
data . FilePath = minioStoragePath [ 0 ] . FilePath ; //文件路径
data . CreatorUser = minioStoragePath [ 0 ] . CreatorUser ; //创建者
data . CreatorTime = DateTime . Now ; //创建时间
data . ClearFlag = "0" ; //删除状态为未删除
data . FileLevel = 1 ; //层级
db . Insert < MinioStoragePath > ( data ) ;
}
#region minio创建文件夹
//var folderName = minioStoragePath[0].FilePath + "/";//取前端发送路径(或单一文件夹名称)
//minio.PutObjectAsync(buckname, folderName, new MemoryStream(), 0, "application/octet-stream");
# endregion
request . msg = "文件夹创建成功!" ;
request . code = "0" ;
}
if ( item . FileType = = 1 ) //如果是文件
{
string type = "" ;
if ( item . FileCategory = = "doc" )
{
type = "application/msword" ;
}
else if ( item . FileCategory = = "pdf" )
{
type = "application/pdf" ;
}
else if ( item . FileCategory = = "docx" )
{
type = "application/vnd.openxmlformats-officedocument.wordprocessingml.document" ;
}
var contentType = item . FileCategory ;
string strBase64 = item . Bate64 ; //取文件base64流数据
byte [ ] bt = Convert . FromBase64String ( strBase64 ) ; //获取html base64
var uploadTask = minio . PutObjectAsync ( buckname , "/" + item . FileName , new MemoryStream ( bt ) , bt . Length , contentType ) ; //上传文件到minio数据库
uploadTask . Wait ( ) ;
if ( uploadTask . Status = = TaskStatus . RanToCompletion & & ! uploadTask . IsFaulted ) //判断是否上传成功
{
data . Pk = Convert . ToInt32 ( db . QueryScalar ( "select S_MINIO_STORAGE_PATH.nextval from dual" ) ) ; ///拿到表自增长的值赋值给自增长主键pk
data . Upk = item . Upk ; //子文件夹的父级id（ ）
data . FileName = item . FileName ; //文件名称
data . FileType = item . FileType ; //文件类型
data . FilePath = item . FilePath ; //文件路径
data . CreatorUser = item . CreatorUser ; //创建者
data . CreatorTime = DateTime . Now ; //创建时间
data . ClearFlag = "0" ; //删除状态为未删除
data . FileLevel = date [ 0 ] . FileLevel + 1 ; //层级
db . Insert < MinioStoragePath > ( data ) ;
request . msg = "文件上传成功！" ;
request . code = "0" ;
}
else
{
request . msg = "文件上传失败，请检查文件是否正确！" ;
request . code = "0" ;
}
}
}
db . Commit ( ) ;
}
}
catch ( Exception ex )
{
db . Rollback ( ) ;
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_STORAGE_PATH， ， , ex ) ;
}
}
return request ;
}
/// <summary>
/// 修改minio文件文件夹路径
/// </summary>
/// <param name="data">修改数据</param>
[HttpPost, Route("UpdateStoragePath")]
public RequestEntity UpdateStoragePath ( List < MinioStoragePath > data )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
///启动事务
db . BeginTransaction ( ) ;
///给修改时间赋值
DateTime time = DateTime . Now ; //取当前时间
MinioStoragePath date = new MinioStoragePath ( ) ;
List < MinioStoragePath > datebase = new List < MinioStoragePath > ( ) ;
foreach ( var item in data )
{
date . Pk = item . Pk ; //主键ID
date . Upk = item . Upk ; //子文件夹的父ID
date . FileName = item . FileName ; //文件名称
date . FileType = item . FileType ; //文件类型
date . FilePath = item . FilePath ; //文件路径
date . CreatorUser = item . CreatorUser ; //创建者
date . CreatorTime = item . CreatorTime ; //创建时间
date . DownloadNum = item . DownloadNum ; //下载次数
date . FileLevel = item . FileLevel ; //层级
date . ModifyUsers = item . ModifyUsers ; //修改用户
date . ModifyTime = time ; //修改时间
date . ClearFlag = "0" ; //删除标记 0未删除 1删除
datebase . Add ( date ) ;
}
db . Update < MinioStoragePath > ( data ) ;
db . Commit ( ) ; //提交事务
request . code = "0" ;
request . msg = "修改成功！" ;
}
catch ( Exception ex )
{
request . code = "1" ;
db . Rollback ( ) ; //回滚
///把错误日志写到日志文件
logger . ErrorFormat ( "主表:MINIO_STORAGE_PATH， ， , ex ) ;
}
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_STORAGE_PATH， ， , ex ) ;
}
return request ;
}
/// <summary>
/// 删除minio文件文件夹路径表
/// </summary>
/// <param name="master">需要删除的数据</param>
[HttpPost, Route("RemoveStoragePath")]
public RequestEntity RemoveStoragePath ( List < MinioStoragePath > master )
{
RequestEntity request = new RequestEntity ( ) ;
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
DateTime time = DateTime . Now ; //取当前时间
MinioClient minio = new MinioClient ( "172.15.88.212:9000" , "minioadmin" , "minioadmin" ) ;
string buckname = "dayetegang" ; //桶名称
db . BeginTransaction ( ) ;
string sql = "" ;
//db.Delete<MinioStoragePath>(master);
foreach ( var item in master )
{
if ( item . FileType = = 1 ) //如果类型是文件
{
sql = "begin " ;
sql + = string . Format ( "update MINIO_STORAGE_PATH set CLEAR_FLAG='1',CLEAR_USERS='{0}',CLEAR_TIME='{1}' where PK='{2}';" , item . ClearUsers , time , item . Pk ) ; //更新文件路径表中的删除状态
sql + = string . Format ( " delete from MINIO_FILEASSOCIATION where FILE_PK like'%{0}%' or ASSOCIATION_FILE_PK like'%{0}%';" , item . Pk ) ; //删除关联表中的关联关系
sql + = "end;" ;
db . Execute ( sql ) ;
//minio.RemoveObjectAsync(buckname, item.FileName);//minio操作删除文件
}
else
{
string sel = string . Format ( "select * from MINIO_STORAGE_PATH where UPK='{0}'" , item . Pk ) ;
IList < MinioStoragePath > date = db . Query < MinioStoragePath > ( sel ) ; //查询删除文件夹时文件夹是否存在文件
if ( date . Count > 0 )
{
sql = "begin " ;
foreach ( var data in date )
{
sql + = string . Format ( "update MINIO_STORAGE_PATH set CLEAR_FLAG='1',CLEAR_USERS='{0}',CLEAR_TIME='{1}' where PK='{2}' " , item . ClearUsers , item . ClearTime , data . Pk ) ;
sql + = string . Format ( " delete from MINIO_FILEASSOCIATION where FILE_PK like'%{0}%' or ASSOCIATION_FILE_PK like'%{0}%';" , item . Pk ) ; //删除关联表中的关联关系
}
sql + = string . Format ( "update MINIO_STORAGE_PATH set CLEAR_FLAG='1',CLEAR_USERS='{0}',CLEAR_TIME='{1}' where PK='{2}' " , item . ClearUsers , time , item . Pk ) ; //更新文件路径表中的删除状态
}
else
{
sql = string . Format ( "update MINIO_STORAGE_PATH set CLEAR_FLAG='1',CLEAR_USERS='{0}',CLEAR_TIME='{1}' where PK='{2}' " , item . ClearUsers , time , item . Pk ) ; //更新文件路径表中的删除状态
}
db . Execute ( sql ) ;
}
}
request . code = "0" ;
request . msg = "删除成功" ;
db . Commit ( ) ;
}
catch ( Exception ex )
{
db . Rollback ( ) ;
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_ROLE_PERMISSION， ， , ex ) ;
}
}
return request ;
}
/// <summary>
/// 查询minio文件文件夹路径表
/// </summary>
/// <returns></returns>
[HttpPost, Route("GetStoragePath")]
public RequestEntity GetStoragePath ( MinioStoragePath minioStoragePath )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
IList < MinioStoragePath > result = new List < MinioStoragePath > ( ) ;
if ( ! string . IsNullOrEmpty ( minioStoragePath . FileName . ToString ( ) ) )
{
sql + = " and FILE_NAME ='" + minioStoragePath . FileName + "'" ;
}
request . data = db . Query < MinioStoragePath > ( "select * from MINIO_STORAGE_PATH where 1=1 " + sql + " and CLEAR_FLAG='0' ORDER BY PK" ) ;
request . code = "0" ;
}
}
catch ( Exception ex )
{
request . code = "1" ;
logger . ErrorFormat ( "主表:MINIO_STORAGE_PATH， ， , ex ) ;
}
return request ;
}
# endregion
#region minio文件菜单递归和权限判断
/// <summary>
/// 根据ID查询子菜单
/// </summary>
/// <param name="PK"></param>
/// <returns></returns>
[HttpPost, Route("GetMenuTree")]
public List < MinioStoragePath > GetMenuTree ( string PK = "" )
{
List < MinioStoragePath > date = new List < MinioStoragePath > ( ) ;
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
if ( ! string . IsNullOrEmpty ( PK ) )
{
sql + = " and UPK =" + int . Parse ( PK ) ;
}
date = db . Query < MinioStoragePath > ( "select * from MINIO_STORAGE_PATH where 1=1 " + sql + "and CLEAR_FLAG='0' ORDER BY PK" ) . ToList ( ) ;
}
return date ;
}
/// <summary>
/// 获取根目录和根目录下一级得菜单信息
/// </summary>
/// <returns></returns>
[HttpPost, Route("GetRecursion")]
public RequestEntity GetRecursion ( )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
//拿到根目录
List < RequstStoragePath > requstStoragePaths = new List < RequstStoragePath > ( ) ;
List < MinioStoragePath > date = new List < MinioStoragePath > ( ) ;
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
date = db . Query < MinioStoragePath > ( "select * from MINIO_STORAGE_PATH where UPK=0 AND FILE_LEVEL=1 and CLEAR_FLAG='0' ORDER BY PK" ) . ToList ( ) ;
}
if ( date . Count > 0 )
{
foreach ( var item in date )
{
RequstStoragePath model = new RequstStoragePath ( ) ;
model . Pk = item . Pk ;
model . FileName = item . FileName ;
model . FilePath = item . FilePath ;
model . FileType = item . FileType ;
model . FileLever = item . FileLevel ;
model . requstStoragePaths = new List < StoragePath > ( ) ;
List < MinioStoragePath > ds = GetMenuTree ( item . Pk . ToString ( ) ) ;
foreach ( var items in ds )
{
StoragePath models = new StoragePath ( ) ;
models . Pk = items . Pk ;
models . FileName = items . FileName ;
models . FilePath = items . FilePath ;
models . FileType = items . FileType ;
models . FileLever = items . FileLevel ;
model . requstStoragePaths . Add ( models ) ;
}
requstStoragePaths . Add ( model ) ;
}
}
request . data = requstStoragePaths ;
request . code = "0" ;
}
catch ( Exception )
{
request . code = "1" ;
throw ;
}
return request ;
}
/// <summary>
/// 权限查询
/// </summary>
/// <param name="UserID"></param>
/// <param name="FileName"></param>
/// <param name="EmpowerType"></param>
/// <returns></returns>
[HttpPost, Route("GetEmpower")]
public RequestEntity GetEmpower ( string UserID , string FileName , string EmpowerType )
{
RequestEntity request = new RequestEntity ( ) ;
try
{
//用户ID， ， （
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
string sql = string . Empty ;
if ( ! string . IsNullOrEmpty ( UserID ) )
{
sql + = "a.USER_ID=" + UserID ;
}
if ( ! string . IsNullOrEmpty ( FileName ) )
{
sql + = "d.File_Name='" + FileName + "'" ;
}
if ( ! string . IsNullOrEmpty ( EmpowerType ) )
{
if ( EmpowerType = = "打印" )
{
sql + = "b.PRINT_FLAG=1" ;
}
if ( EmpowerType = = "查看" )
{
sql + = "b.VIEW_FLAG=1" ;
}
if ( EmpowerType = = "上传" )
{
sql + = "b.UPLOAD_FLAG=1" ;
}
if ( EmpowerType = = "编辑" )
{
sql + = "b.EDIT_FLAG=1" ;
}
if ( EmpowerType = = "移动" )
{
sql + = "b.MOVE_FLAG=1" ;
}
if ( EmpowerType = = "删除" )
{
sql + = "b.DELETE_FLAG=1" ;
}
if ( EmpowerType = = "文件夹查看" )
{
sql + = "b.FILE_VIEW_PERMISSIONS=1" ;
}
if ( EmpowerType = = "文件夹控制" )
{
sql + = "b.FILE_CONTROL_PERMISSIONS=1" ;
}
}
request . data = db . Query < retqustUser > ( "select b.*， + sql + " ORDER BY a.creator_time" ) . ToList ( ) ;
request . code = "0" ;
}
}
catch ( Exception )
{
request . code = "1" ;
//throw;
}
//通过用户ID查询用户得角色ID，
//判断当前角色是否有操作权限
//通过角色ID查询用户有权限得文件夹
return request ;
}
# endregion
#region minio文件下载及预览
[HttpPost, Route("FileDownload")]
public RequestEntity FileDownload ( List < MinioStoragePath > minioStoragePath )
{
MinioBusinessLogic bb = new MinioBusinessLogic ( ) ;
RequestEntity request = new RequestEntity ( ) ;
MinioStoragePath data = new MinioStoragePath ( ) ;
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
if ( minioStoragePath ! = null )
{
foreach ( var item in minioStoragePath )
{
var minio = new MinioClient ( "172.15.88.212:9000" , "minioadmin" , "minioadmin" ) ;
string bucketName = "dayetegang" ;
var uploadTask = bb . Download ( bucketName , item . FileName ) ; //异步取base64
uploadTask . Wait ( ) ; //等待取值
if ( uploadTask . Status = = TaskStatus . RanToCompletion & & ! uploadTask . IsFaulted ) //判读是否有数值
{
data . Bate64 = uploadTask . Result ;
data . FileName = item . FileName ;
if ( item . OperationType = = "0" ) //操作类型为下载
{
int DownloadNum = item . DownloadNum + 1 ;
string sql = "update MINIO_STORAGE_PATH set DOWNLOAD_NUM='" + DownloadNum + "' where pk='" + item . Pk + "'" ;
db . Execute ( sql ) ;
}
request . code = "0" ;
}
else //如果不存在
{
request . msg = "请联系管理员检查！" ;
request . code = "1" ;
}
}
if ( data ! = null )
{
request . data = data ;
}
}
else
{
request . msg = "请联系管理员检查！" ;
request . code = "1" ;
}
}
catch ( Exception ex )
{
request . msg = "请联系管理员检查！" ;
request . code = "1" ;
logger . InfoFormat ( ex . ToString ( ) ) ;
}
}
return request ;
}
# endregion
#region 标准清单
[HttpGet, Route("StandardListGeneration")]
public HttpResponseMessage StandardListGeneration ( string InventoryName , string InventoryType , string BeginTime , string EndTime )
{
RequestEntity request = new RequestEntity ( ) ;
IList < MinioStoragePath > date = new List < MinioStoragePath > ( ) ;
HttpResponseMessage result = new HttpResponseMessage ( HttpStatusCode . OK ) ;
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
try
{
if ( InventoryName ! = null & & InventoryType ! = null )
{
string ExcelName = "" ; //定义导出Excel文件名称
FileStream file = new FileStream ( "D:/linshi/" + "清单模板.xlsx" , FileMode . Open , FileAccess . Read ) ;
XSSFWorkbook hssfworkbook = new XSSFWorkbook ( file ) ;
string sql = "select * from MINIO_STORAGE_PATH where 1=1 and FILE_TYPE='1' " ;
if ( InventoryType = = "0" ) //标准类型
{
if ( ! string . IsNullOrEmpty ( BeginTime ) )
{
sql + = string . Format ( " and CREATE_TIME >= to_date('{0}', 'yyyy/mm/dd hh24:mi:ss')" , BeginTime ) ; //开始时间
}
if ( ! string . IsNullOrEmpty ( EndTime ) )
{
sql + = string . Format ( " and CREATE_TIME <= to_date('{0}', 'yyyy/mm/dd hh24:mi:ss')" , EndTime ) ; //结束时间
}
sql + = string . Format ( " and FILE_PATH like'%{0}%'" , InventoryName ) ; //直接添加文件加名称
ExcelName = "标准清单" ;
}
else
{
#region 清单判断
if ( InventoryName = = "HY企业标准清单" )
{
sql + = "and FILE_PATH like'%HY%'" ;
ExcelName = "HY企业标准清单" ;
}
if ( InventoryName = = "Q-HY企业标准清单" )
{
sql + = "and (FILE_PATH like'%Q/HY%'" ;
ExcelName = "Q-HY企业标准清单" ;
}
if ( InventoryName = = "新产品标准清单" )
{
sql + = "and (FILE_PATH like'%XYGN%' or FILE_PATH like'%XYGW%')" ;
ExcelName = "新产品标准清单" ;
}
if ( InventoryName = = "标准目录有效清单" )
{
sql + = "and (FILE_PATH like'企业标准'" ;
ExcelName = "标准目录有效清单" ;
}
if ( InventoryName = = "企业标准明细表" )
{
sql + = "and (FILE_PATH like'企业标准'" ;
ExcelName = "企业标准明细表" ;
}
if ( InventoryName = = "过期标准清单" )
{
sql + = "and (FILE_PATH like'%过期标准%'" ;
ExcelName = "过期标准清单" ;
}
if ( InventoryName = = "参考标准清单" )
{
sql + = "and (FILE_PATH like'%参考标准%'" ;
ExcelName = "参考标准清单" ;
}
if ( InventoryName = = "工艺卡清单" )
{
sql + = "and (FILE_PATH like'%170钢管厂工艺卡%' or FILE_PATH like'%219钢管厂工艺卡%' or FILE_PATH like'%460钢管厂工艺卡%' or FILE_PATH like'%170热处理工艺卡%' or FILE_PATH like'%连模铸系列工艺卡/转炉厂%' or FILE_PATH like'%连模铸系列工艺卡/特冶厂%' or FILE_PATH like'%连模铸系列工艺卡/电炉厂%' or FILE_PATH like'%电炉厂工艺卡%' or FILE_PATH like'%转炉厂工艺卡%' or FILE_PATH like'%特冶厂工艺卡%' or FILE_PATH like'%大棒厂工艺卡%' or FILE_PATH like'%小棒厂工艺卡%' or FILE_PATH like'%中棒厂工艺卡%'or FILE_PATH like'%锻造厂工艺卡%' or FILE_PATH like'%扁棒厂工艺卡%')" ;
ExcelName = "工艺卡清单" ;
}
if ( InventoryName = = "工艺规程清单" )
{
sql + = "and FILE_PATH like'%工艺规程%'" ;
ExcelName = "工艺规程清单" ;
}
if ( InventoryName = = "技术制度清单" )
{
sql + = "and FILE_PATH like'%技术制度%'" ;
ExcelName = "技术制度清单" ;
}
if ( InventoryName = = "艺字工艺清单" )
{
sql + = "and FILE_PATH like'%艺字工艺%'" ;
ExcelName = "艺字工艺清单" ;
}
if ( InventoryName = = "技字通知清单" )
{
sql + = "and FILE_PATH like'%技字通知%'" ;
ExcelName = "技字通知清单" ;
}
# endregion
}
date = db . Query < MinioStoragePath > ( string . Format ( "{0} order by UPK ASC, CREATOR_TIME ASC " , sql ) ) ;
if ( date . Count > 0 )
{
request . data = date ; //测试查看数据用后去去掉
var sheet = hssfworkbook . GetSheetAt ( 0 ) ;
for ( int i = 0 ; i < date . Count ; i + + )
{
if ( sheet ! = null )
{
sheet . CopyRow ( 2 , 3 + i ) ;
}
}
var rowIndex = 3 ;
for ( int i = 0 ; i < date . Count ; i + + )
{
var curRow = sheet . GetRow ( rowIndex ) ;
var data = date [ i ] ;
if ( data . FilePath . IndexOf ( "企业标准/XYGN" ) > = 0 | | data . FilePath . IndexOf ( "企业标准/XYGW" ) > = 0 ) //对国内国外标准进行特殊处理
{
int Num = data . FileName . IndexOf ( "-" ) + 8 ; //取文件名称技术协议编号位数
int name = data . FileName . Length - Num ; //取文件名称技术协议名称位数
curRow . GetCell ( 0 ) . SetCellValue ( data . FilePath . Replace ( data . FileName , "" ) ) ; //路径
curRow . GetCell ( 1 ) . SetCellValue ( data . FileName . Substring ( 0 , Num ) . Trim ( ) ) ; //协议编号
curRow . GetCell ( 2 ) . SetCellValue ( data . FileName . Substring ( Num , name ) . Trim ( ) ) ; //名称
}
if ( data . FilePath . IndexOf ( "标准通知" ) > = 0 )
{
int Num = data . FileName . IndexOf ( "号" ) ; //取文件名称编号位数
int name = data . FileName . Length - Num ; //取文件名称名称位数
curRow . GetCell ( 0 ) . SetCellValue ( data . FilePath . Replace ( data . FileName , "" ) ) ; //路
curRow . GetCell ( 1 ) . SetCellValue ( data . FileName . Substring ( 0 , Num ) . Trim ( ) ) ; //编号
curRow . GetCell ( 2 ) . SetCellValue ( data . FileName . Substring ( Num , name ) . Replace ( "： , "" ) . Trim ( ) ) ; //名称
}
if ( data . FilePath . IndexOf ( "标准通知" ) = = - 1 & & data . FilePath . IndexOf ( "企业标准/XYGN" ) = = - 1 | | data . FilePath . IndexOf ( "企业标准/XYGW" ) = = - 1 )
{
var filecontent = data . FileName . Split ( ' ' ) ; //以空格进行区分
curRow . GetCell ( 0 ) . SetCellValue ( data . FilePath . Replace ( data . FileName , "" ) ) ; //路径
curRow . GetCell ( 1 ) . SetCellValue ( filecontent [ 0 ] . ToString ( ) . Trim ( ) ) ; //编号
curRow . GetCell ( 2 ) . SetCellValue ( data . FileName . Replace ( filecontent [ 0 ] . ToString ( ) , "" ) ) ; //名称
}
rowIndex = rowIndex + 1 ;
}
MemoryStream output = new MemoryStream ( ) ;
hssfworkbook . Write ( output ) ;
output . Seek ( 0 , SeekOrigin . Begin ) ;
result . Content = new StreamContent ( output ) ;
result . Content . Headers . ContentType = new MediaTypeHeaderValue ( "application/octet-stream" ) ;
result . Content . Headers . ContentDisposition = new ContentDispositionHeaderValue ( "attachment" ) ;
if ( ExcelName ! = null )
{
result . Content . Headers . ContentDisposition . FileName = ExcelName + ".xlsx" ;
}
else
{
result . Content . Headers . ContentDisposition . FileName = "标准清单.xlsx" ;
}
result . Content . Headers . ContentLength = output . Length ;
}
}
}
catch ( Exception ex )
{
logger . InfoFormat ( ex . ToString ( ) ) ;
}
}
return result ;
}
# endregion
#region 公用方法
/// <summary>
/// 矫正pk值
/// </summary>
/// <param name="sequenceName"></param>
/// <param name="tableName"></param>
/// <returns></returns>
public Int32 getPk ( String sequenceName , String tableName )
{
///创建数据库连接上下文对象
using ( IDbContext db = ObjectContainer . GetObject < IDbContext > ( "db" ) )
{
///拿到表自增长序列最大pk值
int pk_SequenceCurrentMax = Convert . ToInt32 ( db . QueryScalar ( "select " + sequenceName + ".nextval from dual" ) ) ;
///拿到表目前最大pk值
Object pk_TableCurrentMaxObj = db . QueryScalar ( "select t.pk from " + tableName + " t where rownum <=1 order by t.pk desc" ) ;
int pk_TableCurrentMax = pk_SequenceCurrentMax ;
//如果表最大值查询结果不为空进行对比，
if ( pk_TableCurrentMaxObj ! = null )
{
pk_TableCurrentMax = Convert . ToInt32 ( pk_TableCurrentMaxObj ) ;
//拿到表中最大值和序列最大值之间的差值
int num_BetweenTableSequence = pk_TableCurrentMax - pk_SequenceCurrentMax + 1 ;
//更改序列递增规则，
db . QueryScalar ( "alter sequence " + sequenceName + " increment by " + num_BetweenTableSequence . ToString ( ) ) ;
//执行nexval拿到下一个序列号
pk_TableCurrentMax = Convert . ToInt32 ( db . QueryScalar ( "select " + sequenceName + ".nextval from dual" ) ) ;
//更改序列递增规则为每次递增一个。
db . QueryScalar ( "alter sequence " + sequenceName + " increment by 1" ) ;
}
return pk_TableCurrentMax ;
}
}
/// <summary>
/// 编写内容：下载文件转换流数据方法
/// </summary>
public string Base64 ( string FilePath )
{
string data = "" ;
try
{
using ( MemoryStream msReader = new MemoryStream ( ) )
{
using ( FileStream fs = new FileStream ( FilePath , FileMode . Open ) )
{
byte [ ] buffer = new byte [ 1024 ] ;
int readLen = 0 ;
while ( ( readLen = fs . Read ( buffer , 0 , buffer . Length ) ) > 0 )
{
msReader . Write ( buffer , 0 , readLen ) ;
}
}
data = Convert . ToBase64String ( msReader . ToArray ( ) ) ; //转换base64
}
return data ; //返回值
}
catch ( Exception ex )
{
logger . InfoFormat ( ex . ToString ( ) ) ;
throw ;
}
}
# endregion
# region
# endregion
}
}
