using DevExpress.XtraEditors; using static DevExpress.XtraEditors.XtraInputBox; using static System.Windows.Forms.VisualStyles.VisualStyleElement.Window; namespace HStation.WinFrmUI { /// /// /// public class ImportXhsProjectHelper { private const string _tempFolder = "ImportProjectTemp";//导入项目临时文件夹 /// /// 导入 /// /// 通用视图Model /// 信息反馈 /// 进度反馈 /// public static async Task Import(ImportXhsProjectViewModel vm, Action feedBackMsg, Action feedBackProgress) { #region 第一步 临时文件处理(进度5%) feedBackMsg?.Invoke("开始导入项目..."); //临时文件夹路径 var tempFolder = Path.Combine(Yw.Service.ConfigHelper.DataPath, HStation.Settings.XhsParasHelper.Xhs.DataFolder, _tempFolder); //如果存在临时文件夹,则删除临时文件夹及子目录与文件 if (Directory.Exists(tempFolder)) { Directory.Delete(tempFolder, true); } //创建临时文件夹 Directory.CreateDirectory(tempFolder); feedBackProgress?.Invoke(100, 5); #endregion #region 第二步 压缩文件解析 (进度10%) feedBackMsg?.Invoke("正在解析模型文件..."); var bol = Yw.FileFolderZipHelper.UnZip(vm.ZipFile, tempFolder, null); if (!bol) { feedBackMsg?.Invoke("模型文件解析失败!!!"); return false; } var tempFolderInfo = new DirectoryInfo(tempFolder); var allFileInfoList = tempFolderInfo.GetFiles(); if (allFileInfoList == null || allFileInfoList.Count() < 1) { feedBackMsg?.Invoke("模型文件格式错误!!!"); return false; } feedBackMsg?.Invoke("模型文件解析成功。。。"); feedBackProgress?.Invoke(100, 10); #endregion #region 第三步 解析水力结构文件 (进度15%) feedBackMsg?.Invoke("正在解析水力结构文件..."); var jsonFileInfo = allFileInfoList.Where(x => x.Extension == ".json").FirstOrDefault(); if (jsonFileInfo == null) { feedBackMsg?.Invoke("水力结构文件格式错误!!!"); return false; } var jsonText = File.ReadAllText(jsonFileInfo.FullName); var revitModel = JsonHelper.Json2Object(jsonText); if (revitModel == null) { feedBackMsg?.Invoke("水力结构文件格式错误!!!"); return false; } var hydroInfo = HStation.Hydro.ParseHelper.FromRevit(revitModel, out string msg); if (hydroInfo == null) { feedBackMsg?.Invoke($"水力结构文件解析失败,{msg}!!!"); return false; } var bllHydroInfo = new Yw.BLL.HydroModelInfo(); var hydroId = await bllHydroInfo.Save(hydroInfo); if (hydroId < 1) { feedBackMsg?.Invoke("水力结构信息保存失败!!!"); return false; } feedBackMsg?.Invoke("水力结构文件解析成功。。。"); feedBackProgress?.Invoke(100, 15); vm.HydroID = hydroId; #endregion #region 第四步 创建项目(进度 20%) feedBackMsg?.Invoke("正在创建项目..."); var bllXhsProjectExtensions = new Lazy(() => new BLL.XhsProjectExtensions()); var project = new AddXhsProjectExtensionsInput(); project.NO = vm.NO; project.Name = vm.Name; project.Address = vm.Address; project.Customer = vm.Customer; project.Flags = vm.Flags; project.TagName = vm.TagName; project.Description = vm.Description; project.SiteList = new List() { new AddXhsProjectSiteExtensionsInput(){ Name=vm.Name, Description=vm.Description } }; var projectId = await bllXhsProjectExtensions.Value.Insert(project); if (projectId < 1) { feedBackMsg?.Invoke("项目创建失败!!!"); return false; } feedBackMsg?.Invoke("项目创建成功。。。"); vm.ProjectID = projectId; feedBackProgress?.Invoke(100, 20); #endregion #region 第五步 关联水力结构模型(进度 25%) var bllXhsProjectSite = new BLL.XhsProjectSiteStd(); var projectSite = await bllXhsProjectSite.GetDefaultByProjectID(projectId); if (projectSite == null) { feedBackMsg?.Invoke("项目站信息错误..."); return false; } var projectSiteId = projectSite.ID; vm.ProjectSiteID = projectSite.ID; feedBackMsg?.Invoke("正在关联水力结构模型..."); var hydroRelation = new Yw.Dto.AddHydroModelRelationInput(); hydroRelation.ObjectType = HStation.Xhs.DataType.XhsProjectSite; hydroRelation.ObjectID = projectSiteId; hydroRelation.ModelID = hydroId; hydroRelation.Purpose = Yw.Hydro.Purpose.Simulation; hydroRelation.Content = null; hydroRelation.Description = null; var bllHydroRelation = new Yw.BLL.HydroModelRelation(); var hydroRelationId = await bllHydroRelation.Insert(hydroRelation); if (hydroRelationId < 1) { feedBackMsg?.Invoke("关联水力结构模型失败!!!"); return false; } vm.HydroRelationID = hydroRelationId; feedBackMsg?.Invoke("关联水力结构模型成功。。。"); feedBackProgress?.Invoke(100, 25); #endregion #region 第六步 设置地图位置(进度 30%) feedBackMsg?.Invoke("正在设置地图位置..."); if (vm.Location != null) { var mapInfo = new Yw.Dto.AddMapInfoInput(); mapInfo.ObjectType = HStation.Xhs.DataType.XhsProject; mapInfo.ObjectID = projectId; mapInfo.ObjectName = project.Name; mapInfo.Purpose = Yw.Map.Purpose.Location; mapInfo.Kind = Yw.Map.Kind.Gaodei; mapInfo.Shape = Yw.Map.Shape.Marker; mapInfo.Position = vm.Location.ToJson(); var mapInfoId = await new Yw.BLL.MapInfo().Insert(mapInfo); if (mapInfoId < 1) { feedBackMsg?.Invoke("设置地图位置失败!!!"); } else { vm.MapInfoID = mapInfoId; feedBackMsg?.Invoke("设置地图位置成功。。。"); } } else { feedBackMsg?.Invoke("未设置地图位置信息!!!"); } feedBackProgress?.Invoke(100, 30); #endregion #region 第七步 上传Revit模型文件(进度 45%) feedBackMsg?.Invoke("正在解析Revit模型文件..."); var rvtFileInfo = allFileInfoList.Where(x => x.Extension == ".rvt").FirstOrDefault(); if (rvtFileInfo == null) { feedBackMsg?.Invoke("Revit模型文件解析失败!!!"); feedBackMsg?.Invoke("项目导入结束。。。"); return true; } //var bimfaceId = await Yw.WinFrmUI.BimfaceHelper.UploadFile(rvtFileInfo.FullName);//上传 var bimfaceId = 10000870453147; //测试用例 if (bimfaceId < 1) { feedBackMsg?.Invoke("Revit模型文件上传失败!!!"); feedBackMsg?.Invoke("项目导入结束。。。"); return true; } vm.BimfaceId = bimfaceId; feedBackMsg?.Invoke("解析Revit模型文件成功。。。"); feedBackProgress?.Invoke(100, 45); #endregion #region 第八步 保存Bimface文件 (进度 50%) feedBackMsg?.Invoke("正在保存Bimface文件..."); var bimfaceFile = new Yw.Dto.AddBimfaceFileInput(); bimfaceFile.BimfaceId = bimfaceId.ToString(); bimfaceFile.Name = vm.Name; bimfaceFile.ModelType = (int)Yw.Bimface.eModelType.File; bimfaceFile.FileStatus = (int)Yw.Bimface.eFileStatus.UploadSucceed; bimfaceFile.FormatType = (int)Yw.Bimface.eFormatType._3D; bimfaceFile.FileSuffix = rvtFileInfo.Extension; bimfaceFile.FileSize = string.Format("{0}MB", System.Math.Ceiling(rvtFileInfo.Length / 1024.0 / 1024.0)); var bllBimfaceFile = new Yw.BLL.BimfaceFile(); var bimfaceFileId = await bllBimfaceFile.Insert(bimfaceFile); if (bimfaceFileId < 1) { feedBackMsg?.Invoke("Bimface文件保存失败!!!"); feedBackMsg?.Invoke("项目导入结束。。。"); return true; } vm.BimfaceFileID = bimfaceFileId; feedBackMsg?.Invoke("Bimface文件保存成功。。。"); feedBackProgress?.Invoke(100, 50); #endregion #region 第九步 关联Bimface文件(进度 55%) feedBackMsg?.Invoke("正在关联Bimface文件..."); var bimfaceRelation = new Yw.Dto.AddBimfaceFileRelationInput(); bimfaceRelation.ObjectType = HStation.Xhs.DataType.XhsProjectSite; bimfaceRelation.ObjectID = projectSiteId; bimfaceRelation.BimfaceFileID = bimfaceFileId; bimfaceRelation.Purpose = Yw.Bimface.Purpose.Simulation; bimfaceRelation.Description = vm.Description; var bllBimfaceRelation = new Yw.BLL.BimfaceFileRelation(); var bimfaceRelationId = await bllBimfaceRelation.Insert(bimfaceRelation); if (bimfaceRelationId < 1) { feedBackMsg?.Invoke("Bimface文件关联失败!!!"); feedBackMsg?.Invoke("项目导入结束。。。"); return true; } vm.BimfaceFileRelationID = bimfaceRelationId; feedBackMsg?.Invoke("Bimface文件关联成功。。。"); feedBackProgress?.Invoke(100, 55); #endregion #region 第九步 发起bimface转换(进度 80%) feedBackMsg?.Invoke("正在进行Bimface模型轻量化..."); // var bimfaceTranslateStatus = await Yw.WinFrmUI.BimfaceHelper.TranslateRvtFile(bimfaceId);//发起转换 var bimfaceTranslateStatus = Yw.BIMFace.eTranslateStatus.Processing;//测试代码 feedBackProgress?.Invoke(100, 60); if (bimfaceTranslateStatus != Yw.BIMFace.eTranslateStatus.Success) { var dlgResult = XtraMessageBox.Show("Bimface模型轻量化需要一定的时间,是否继续等待?", "询问", MessageBoxButtons.YesNo, MessageBoxIcon.Question); if (dlgResult == DialogResult.Yes) { await Yw.WinFrmUI.BimfaceHelper.WaitFileTranslateStatusUntilSuccess(bimfaceId, 3000); vm.BimfaceConverted = true; feedBackMsg?.Invoke("Bimface模型轻量化完成。。。"); } else { feedBackMsg?.Invoke("跳过Bimface模型轻量化等待。。。"); } } else { vm.BimfaceConverted = true; feedBackMsg?.Invoke("Bimface模型轻量化完成。。。"); } feedBackProgress?.Invoke(100, 80); #endregion #region 第十步 更新Bimface文件状态(进度 90%) feedBackMsg?.Invoke("正在更新Bimface文件状态..."); bol = await bllBimfaceFile.UpdateFileStatus(bimfaceFileId, (int)Yw.Bimface.eFileStatus.ConvertSucceed); if (bol) { feedBackMsg?.Invoke("Bimface文件状态更新成功。。。"); } else { feedBackMsg?.Invoke("Bimface文件状态更新失败!!!"); feedBackMsg?.Invoke("项目导入结束。。。"); return true; } feedBackProgress?.Invoke(100, 90); #endregion #region 第十一步 项目发布(进度 100%) feedBackMsg?.Invoke("正在发布项目..."); var bllXhsProject = new BLL.XhsProject(); bol = await bllXhsProject.Publish(projectId); if (!bol) { feedBackMsg?.Invoke("项目发布失败..."); } else { vm.IsPublished = true; feedBackMsg?.Invoke("项目发布成功..."); } feedBackProgress?.Invoke(100, 100); feedBackMsg?.Invoke("项目导入结束。。。"); return true; #endregion } } }