修改文件删除逻辑,改为物理删除,增加日志记录

master
孙亮 1 year ago
parent 33d5d22121
commit 2667bb38d6

@ -776,6 +776,7 @@ namespace IBKLinker_Minio.Controller.MinioController
data.CreatorTime = DateTime.Now;//创建时间 data.CreatorTime = DateTime.Now;//创建时间
data.ClearFlag = "0";//删除状态为未删除 data.ClearFlag = "0";//删除状态为未删除
data.FileLevel = date[0].FileLevel + 1;//层级 data.FileLevel = date[0].FileLevel + 1;//层级
data.DocumentType = item.DocumentType;//文件种类
db.Insert<MinioStoragePath>(data); db.Insert<MinioStoragePath>(data);
request.msg = "文件上传成功!"; request.msg = "文件上传成功!";
request.code = "0"; request.code = "0";
@ -853,6 +854,7 @@ namespace IBKLinker_Minio.Controller.MinioController
date.ModifyUsers = item.ModifyUsers;//修改用户 date.ModifyUsers = item.ModifyUsers;//修改用户
date.ModifyTime = time;//修改时间 date.ModifyTime = time;//修改时间
date.ClearFlag = "0";//删除标记 0未删除 1删除 date.ClearFlag = "0";//删除标记 0未删除 1删除
date.DocumentType = item.DocumentType;//文件种类
if (item.Bate64 != null)//如果是修改文件 if (item.Bate64 != null)//如果是修改文件
{ {
var contentType = item.FileCategory; var contentType = item.FileCategory;
@ -930,43 +932,31 @@ namespace IBKLinker_Minio.Controller.MinioController
//db.Delete<MinioStoragePath>(master); //db.Delete<MinioStoragePath>(master);
foreach (var item in master) foreach (var item in master)
{ {
#region 记录日志
MOdata.Pk = Convert.ToInt32(db.QueryScalar("select S_MINIO_OPERATIONLOG.nextval from dual"));///拿到表自增长的值赋值给自增长主键pk;
MOdata.OperateUser = item.CreatorUser;//操作者
MOdata.OperateTime = DateTime.Now;//操作时间
MOdata.Operater = item.CreatorUser + " 更新了 " + item.FileName + " 这个文档。 " + DateTime.Now.ToString();//操作
MOdata.CreationTime = DateTime.Now;//创建时间
db.Insert<MinioOperationlog>(MOdata);//写入数据库
#endregion
if (item.FileType == 1) //如果类型是文件 if (item.FileType == 1) //如果类型是文件
{ {
sql = "begin "; var DelTask = minio.RemoveObjectAsync(buckname, item.FileName);//minio操作删除文件
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);//更新文件路径表中的删除状态 DelTask.Wait();
sql += string.Format(" delete from MINIO_FILEASSOCIATION where FILE_PK like'%{0}%' or ASSOCIATION_FILE_PK like'%{0}%';", item.Pk);//删除关联表中的关联关系 if (DelTask.Status == TaskStatus.RanToCompletion && !DelTask.IsFaulted)//判断是否删除成功
sql += "end;"; {
db.Execute(sql); sql = "begin ";
//minio.RemoveObjectAsync(buckname, item.FileName);//minio操作删除文件 sql += string.Format("delete from MINIO_STORAGE_PATH where 1=1 and 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);
#region 记录日志
MOdata.Pk = Convert.ToInt32(db.QueryScalar("select S_MINIO_OPERATIONLOG.nextval from dual"));///拿到表自增长的值赋值给自增长主键pk;
MOdata.OperateUser = item.ClearUsers;//操作者
MOdata.OperateTime = DateTime.Now;//操作时间
MOdata.Operater = item.ClearUsers + " 删除了 " + item.FileName + " 这个文档。 " + DateTime.Now.ToString();//操作
MOdata.CreationTime = DateTime.Now;//创建时间
db.Insert<MinioOperationlog>(MOdata);//写入数据库
#endregion
}
} }
else else //如果类型是文件夹
{ {
//string sel =string.Format( "select * from MINIO_STORAGE_PATH where UPK='{0}'",item.Pk); sql = string.Format("delete from MINIO_STORAGE_PATH where 1=1 and PK='{2}' ", item.ClearUsers, time, 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); db.Execute(sql);
} }
} }
request.code = "0"; request.code = "0";

@ -123,7 +123,7 @@ namespace IBKLinker_Minio.Entity.MinioController
/// <summary> /// <summary>
///文件种类 主要分为技术协议、质量要点、工艺卡用于关联文件使用 ///文件种类 主要分为1、技术协议、2、质量要点、3、工艺卡 4、其他 用于关联文件使用
/// </summary> /// </summary>
[Persistent("DOCUMENT_TYPE"), DisplayName("文件种类")] [Persistent("DOCUMENT_TYPE"), DisplayName("文件种类")]
public string DocumentType { get; set; } public string DocumentType { get; set; }

Loading…
Cancel
Save