using System; using System.Collections.Generic; using System.Linq; using System.Net; using System.Net.Http; using System.Web.Http; using System.Web.Http.Results; using MongoDB.Bson; using MongoDB.Driver; using Newtonsoft.Json.Linq; using ShadowEditor.Model.Scene; using ShadowEditor.Server.Base; using ShadowEditor.Server.Helpers; namespace ShadowEditor.Server.Controllers { /// /// 场景控制器 /// public class SceneController : ApiBase { /// /// 获取列表 /// /// [HttpGet] public JsonResult List() { var mongo = new MongoHelper(); // 获取所有类别 var categories = mongo.FindAll(Constant.CategoryCollectionName).ToList(); var scenes = mongo.FindAll(Constant.SceneCollectionName).ToList(); var list = new List(); foreach (var i in scenes) { var categoryID = ""; var categoryName = ""; if (i.Contains("Category") && !i["Category"].IsBsonNull && !string.IsNullOrEmpty(i["Category"].ToString())) { var doc = categories.Where(n => n["_id"].ToString() == i["Category"].ToString()).FirstOrDefault(); if (doc != null) { categoryID = doc["_id"].ToString(); categoryName = doc["Name"].ToString(); } } var info = new SceneModel { ID = i["ID"].AsObjectId.ToString(), Name = i["Name"].AsString, CategoryID = categoryID, CategoryName = categoryName, TotalPinYin = i["TotalPinYin"].ToString(), FirstPinYin = i["FirstPinYin"].ToString(), CollectionName = i["CollectionName"].AsString, Version = i["Version"].AsInt32, CreateTime = i["CreateTime"].ToUniversalTime(), UpdateTime = i["UpdateTime"].ToUniversalTime(), Thumbnail = i.Contains("Thumbnail") && !i["Thumbnail"].IsBsonNull ? i["Thumbnail"].ToString() : null }; list.Add(info); } list = list.OrderByDescending(o => o.UpdateTime).ToList(); return Json(new { Code = 200, Msg = "获取成功!", Data = list }); } /// /// 获取数据 /// /// /// /// [HttpGet] public JsonResult Load(string ID, int version = -1) { var mongo = new MongoHelper(); var filter = Builders.Filter.Eq("ID", BsonObjectId.Create(ID)); var doc = mongo.FindOne(Constant.SceneCollectionName, filter); if (doc == null) { return Json(new { Code = 300, Msg = "该场景不存在!" }); } var collectionName = doc["CollectionName"].AsString; List docs; if (version == -1) // 最新版本 { docs = mongo.FindAll(collectionName).ToList(); } else // 特定版本 { filter = Builders.Filter.Eq(Constant.VersionField, BsonInt32.Create(version)); docs = mongo.FindMany($"{collectionName}{Constant.HistorySuffix}", filter).ToList(); } var data = new JArray(); foreach (var i in docs) { i["_id"] = i["_id"].ToString(); // ObjectId data.Add(JsonHelper.ToObject(i.ToJson())); } return Json(new { Code = 200, Msg = "获取成功!", Data = data }); } /// /// 编辑 /// /// /// [HttpPost] public JsonResult Edit(SceneEditModel model) { var objectId = ObjectId.GenerateNewId(); if (!string.IsNullOrEmpty(model.ID) && !ObjectId.TryParse(model.ID, out objectId)) { return Json(new { Code = 300, Msg = "ID不合法。" }); } if (string.IsNullOrEmpty(model.Name)) { return Json(new { Code = 300, Msg = "名称不允许为空。" }); } if (model.Name.StartsWith("_")) { return Json(new { Code = 300, Msg = "名称不允许以下划线开头。" }); } var mongo = new MongoHelper(); var pinyin = PinYinHelper.GetTotalPinYin(model.Name); var filter = Builders.Filter.Eq("ID", objectId); var update1 = Builders.Update.Set("Name", model.Name); var update2 = Builders.Update.Set("TotalPinYin", pinyin.TotalPinYin); var update3 = Builders.Update.Set("FirstPinYin", pinyin.FirstPinYin); var update4 = Builders.Update.Set("Thumbnail", model.Image); UpdateDefinition update5; if (string.IsNullOrEmpty(model.Category)) { update5 = Builders.Update.Unset("Category"); } else { update5 = Builders.Update.Set("Category", model.Category); } var update = Builders.Update.Combine(update1, update2, update3, update4, update5); mongo.UpdateOne(Constant.SceneCollectionName, filter, update); return Json(new { Code = 200, Msg = "保存成功!" }); } /// /// 保存 /// /// 保存场景模型 /// [HttpPost] public JsonResult Save(SceneSaveModel model) { var objectId = ObjectId.GenerateNewId(); if (!string.IsNullOrEmpty(model.ID) && !ObjectId.TryParse(model.ID, out objectId)) { return Json(new { Code = 300, Msg = "场景ID不合法。" }); } if (string.IsNullOrEmpty(model.Name)) { return Json(new { Code = 300, Msg = "场景名称不允许为空。" }); } if (model.Name.StartsWith("_")) { return Json(new { Code = 300, Msg = "场景名称不允许以下划线开头。" }); } // 查询场景信息 var mongo = new MongoHelper(); var filter = Builders.Filter.Eq("ID", objectId); var doc = mongo.FindOne(Constant.SceneCollectionName, filter); var now = DateTime.Now; string collectionName; var version = -1; if (doc == null) // 新建场景 { collectionName = "Scene" + now.ToString("yyyyMMddHHmmss"); version = 0; } else // 编辑场景 { collectionName = doc["CollectionName"].ToString(); version = doc.Contains("Version") ? int.Parse(doc["Version"].ToString()) : 0; version++; } // 保存或更新场景综合信息 if (doc == null) { var pinyin = PinYinHelper.GetTotalPinYin(model.Name); doc = new BsonDocument { ["ID"] = objectId, ["Name"] = model.Name, ["TotalPinYin"] = string.Join("", pinyin.TotalPinYin), ["FirstPinYin"] = string.Join("", pinyin.FirstPinYin), ["CollectionName"] = collectionName, ["Version"] = version, ["CreateTime"] = BsonDateTime.Create(now), ["UpdateTime"] = BsonDateTime.Create(now) }; mongo.InsertOne(Constant.SceneCollectionName, doc); } else { var update1 = Builders.Update.Set("Version", version); var update2 = Builders.Update.Set("UpdateTime", BsonDateTime.Create(now)); var update = Builders.Update.Combine(update1, update2); mongo.UpdateOne(Constant.SceneCollectionName, filter, update); // 将当前场景移入历史表 var old = mongo.FindAll(collectionName).ToList(); foreach (var i in old) { i[Constant.VersionField] = version - 1; } if (old.Count > 0) { // 移除_id,避免移入历史表时重复 for (var i = 0; i < old.Count; i++) { old[i].Remove("_id"); } mongo.InsertMany($"{collectionName}{Constant.HistorySuffix}", old); } } // 保存新的场景信息 var list = JsonHelper.ToObject(model.Data); var docs = new List(); foreach (var i in list) { docs.Add(BsonDocument.Parse(i.ToString())); } mongo.DeleteAll(collectionName); mongo.InsertMany(collectionName, docs); return Json(new { Code = 200, Msg = "保存成功!", ID = objectId }); } /// /// 删除 /// /// /// [HttpPost] public JsonResult Delete(string ID) { var mongo = new MongoHelper(); var filter = Builders.Filter.Eq("ID", BsonObjectId.Create(ID)); var doc = mongo.FindOne(Constant.SceneCollectionName, filter); if (doc == null) { return Json(new { Code = 300, Msg = "该资源不存在!" }); } // 删除场景综合信息 mongo.DeleteOne(Constant.SceneCollectionName, filter); var collectionName = doc["CollectionName"].AsString; // 删除场景数据集 mongo.DropCollection(collectionName); return Json(new { Code = 200, Msg = "删除成功!" }); } } }