HC_YFZX
/
Infrastructure
11
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

原航飞库--暂存，添加专题信息

Insight
洁 任 2024-11-24 13:37:31 +08:00
parent 93c9b29552
commit 4dbba5ecb8
1 changed files with 29 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
OpenAuth.App/ServiceApp/DroneCaseInfo/DroneCaseInfoApp.cs
View File

@ -361,6 +361,32 @@ namespace OpenAuth.App.ServiceApp.DroneCaseInfo
});
}
//专题及平台数据处理
var dataBaseList = db.Queryable<DatabasePicture>().Where(c => req.databaseid.Contains(c.Id)).IgnoreColumns(c => new { c.org_id }).ToList();
List<DroneCaseSubject> subjectList = new List<DroneCaseSubject>();
//遍历库
for (int i = 0; i < dataBaseList.Count; i++)
{
//当前库
var _item = dataBaseList[i];
//专题信息
var subjectlist = db.Queryable<Subject>().Where(r => req.subjectkeys.Contains(r.Key) && r.PId == _item.Id).ToList();
var subjectkeys = "";
if (req.subjectkeys != null && req.subjectkeys.Count > 0 && subjectlist.Count > 0)
{
subjectkeys = db.Queryable<Subject>().Where(r => req.subjectkeys.Contains(r.Key) && r.PId == _item.Id).Select(r => r.Key).ToList().Aggregate((current, next) => current + "," + next);
}
DroneCaseSubject cject = new DroneCaseSubject();
cject.Id = Guid.NewGuid().ToString();
cject.CaseId = model.Id;
cject.DataBaseId = _item.Id;
cject.SubjectKeys = subjectkeys;
cject.CreateTime = DateTime.Now;
cject.CreateUser = user.Id.ToString();
cject.CreateUserName = user.Name;
subjectList.Add(cject);
}
//使用事务提交数据
var transFlag = db.AsTenant().UseTran(() =>
{
@ -375,6 +401,9 @@ namespace OpenAuth.App.ServiceApp.DroneCaseInfo
//新增案件标签
db.Insertable(tagList).ExecuteCommand();
//案件平台专题
db.Deleteable<DroneCaseSubject>().Where(a => a.CaseId == model.Id).ExecuteCommand();
db.Insertable(subjectList).ExecuteCommand();
});
if (transFlag.IsSuccess)