Merge branch 'Insight' of http://123.132.248.154:10000/HC_YFZX/Infrastructure into Insight

OpenAuth.App/ServiceApp/DroneCaseInfo/DroneCaseInfoApp.cs

@@ -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)