节点在线、应用在线、配置在线使用令牌查询
大石头 authored at 2021-12-16 19:49:30
7.51 KiB
Stardust
using System.ComponentModel;
using System.Security.Cryptography;
using System.Text;
using Microsoft.AspNetCore.Mvc;
using NewLife;
using NewLife.Cube;
using NewLife.Cube.ViewModels;
using NewLife.Security;
using NewLife.Web;
using Stardust.Data;
using Stardust.Data.Deployment;
using Stardust.Server;
using XCode;
using XCode.Membership;

namespace Stardust.Web.Areas.Deployment.Controllers;

/// <summary>应用部署集。定义应用部署的元信息(部署模式/目标路径/启动参数/环境变量),一个应用可有多个部署集</summary>
[DeploymentArea]
[Menu(90)]
public class AppDeployController : DeploymentEntityController<AppDeploy>
{
    static AppDeployController()
    {
        ListFields.RemoveCreateField();
        ListFields.RemoveField("AppId", "MultiVersion", "Repository", "Branch", "ProjectPath", "PackageFilters", "WorkingDirectory", "UserName", "Environments", "MaxMemory", "Mode", "Remark");
        ListFields.RemoveField("RepoPassword");
        AddFormFields.RemoveCreateField();

        LogOnChange = true;

        {
            var df = ListFields.GetField("ProjectName") as ListField;
            df.Url = "/Platform/GalaxyProject?Id={ProjectId}";
            df.Target = "_frame";
        }
        {
            var df = ListFields.GetField("AppName") as ListField;
            df.Url = "/Registry/App?Id={AppId}";
            df.Target = "_blank";
        }
        {
            var df = ListFields.GetField("Name") as ListField;
            df.Url = "/Deployment/AppDeploy?appId={AppId}&deployId={Id}";
            df.Target = "_blank";
        }
        {
            var df = ListFields.AddListField("NodeManage", null, "Nodes") as ListField;
            df.DisplayName = "部署节点";
            df.Url = "/Deployment/AppDeployNode?deployId={Id}";
        }
        {
            var df = ListFields.AddListField("BuildNode", null, "Nodes") as ListField;
            df.DisplayName = "编译节点";
            df.Url = "/Deployment/AppBuildNode?deployId={Id}";
        }
        {
            var df = ListFields.GetField("Version") as ListField;
            df.Header = "版本";
            df.Title = "管理应用版本";
            df.Url = "/Deployment/AppDeployVersion?deployId={Id}";
        }
        {
            var df = ListFields.AddListField("AddVersion", "FileName");
            df.Header = "版本管理";
            df.DisplayName = "版本管理";
            df.Title = "管理所有版本文件";
            df.Url = "/Deployment/AppDeployVersion?deployId={Id}";
        }
        {
            var df = ListFields.AddListField("History", "UpdateUserId");
            df.DisplayName = "部署历史";
            df.Url = "/Deployment/AppDeployHistory?deployId={Id}";
        }
        {
            var df = ListFields.AddListField("Log", "UpdateUserId");
            df.DisplayName = "审计日志";
            df.Url = "/Admin/Log?category=应用部署&linkId={Id}";
            df.Target = "_frame";
        }
    }

    /// <summary>高级搜索。按条件分页查询</summary>
    /// <param name="p">分页参数</param>
    /// <returns>实体列表</returns>
    protected override IEnumerable<AppDeploy> Search(Pager p)
    {
        var id = p["deployId"].ToInt(-1);
        if (id <= 0) id = p["id"].ToInt(-1);
        if (id > 0)
        {
            var entity = AppDeploy.FindByKey(id);
            if (entity != null) return [entity];
        }
        var appId = p["appId"].ToInt(-1);
        if (appId > 0)
        {
            var list = AppDeploy.FindAllByAppId(appId);
            if (list.Count == 0)
            {
                // 自动新建发布集
                var app = App.FindById(appId);
                if (app != null)
                {
                    var entity = new AppDeploy
                    {
                        AppId = appId,
                        Name = app.Name,
                        ProjectId = app.ProjectId,
                        Category = app.Category
                    };
                    entity.Insert();
                }
            }
        }

        var projectId = p["projectId"].ToInt(-1);
        var category = p["category"];
        var enable = p["enable"]?.ToBoolean();

        var start = p["dtStart"].ToDateTime();
        var end = p["dtEnd"].ToDateTime();

        return AppDeploy.Search(projectId, appId, category, enable, start, end, p["Q"], p);
    }

    protected override Boolean Valid(AppDeploy entity, DataObjectMethodType type, Boolean post)
    {
        if (!post)
        {
            // GET 查询后:脱敏处理
            if (type == DataObjectMethodType.Insert)
            {
                entity.Enable = true;
                //entity.AutoStart = true;
            }
            else if (type == DataObjectMethodType.Update && !entity.RepoPassword.IsNullOrEmpty())
            {
                // 编辑表单回显时,密码显示为 *****
                entity.RepoPassword = "*****";
            }

            return base.Valid(entity, type, post);
        }

        // POST 保存前:处理密码加密与脏数据
        if (entity.Id == 0)
        {
            // 从应用表继承ID
            var app = App.FindByName(entity.Name);
            if (app != null) entity.Id = app.Id;
        }

        // 处理 RepoPassword
        if ((entity as IEntity).Dirtys[nameof(AppDeploy._.RepoPassword)])
        {
            if (entity.RepoPassword == "*****")
            {
                // 未修改密码:从数据库读取原密文回填,清除脏标记
                var old = AppDeploy.FindById(entity.Id);
                if (old != null)
                {
                    entity.RepoPassword = old.RepoPassword;
                    (entity as IEntity).Dirtys[nameof(AppDeploy._.RepoPassword)] = false;
                }
            }
            else if (!entity.RepoPassword.IsNullOrEmpty())
            {
                // 修改了密码:AES 加密存储
                var key = StarServerSetting.Current.TokenSecret.Split(':')[1];
                var pass = Encoding.UTF8.GetBytes(key);
                using var aes = Aes.Create();
                entity.RepoPassword = aes.Encrypt(Encoding.UTF8.GetBytes(entity.RepoPassword), pass, CipherMode.CBC, PaddingMode.PKCS7).ToHex();
            }
            // 空值:保持空值,允许清空
        }

        entity.Refresh();

        return base.Valid(entity, type, post);
    }

    //protected override Int32 OnUpdate(AppDeploy entity)
    //{
    //    // 如果执行了启用,则通知节点
    //    if ((entity as IEntity).Dirtys["Enable"]) Task.Run(() => NotifyChange(entity.Id));

    //    return base.OnUpdate(entity);
    //}

    //public async Task<ActionResult> NotifyChange(Int32 id)
    //{
    //    var deploy = AppDeploy.FindById(id);
    //    if (deploy != null)
    //    {
    //        // 通知该发布集之下所有节点,应用服务数据有变化,需要马上执行心跳
    //        var list = AppDeployNode.FindAllByAppId(deploy.Id);
    //        foreach (var item in list)
    //        {
    //            var node = item.Node;
    //            if (node != null)
    //            {
    //                // 通过接口发送指令给StarServer
    //                await _starFactory.SendNodeCommand(node.Code, "deploy/publish");
    //            }
    //        }
    //    }

    //    return RedirectToAction("Index");
    //}

    [EntityAuthorize(PermissionFlags.Update)]
    public ActionResult SyncApp()
    {
        var rs = AppDeploy.Sync();

        return JsonRefresh($"成功同步[{rs}]个应用!");
    }
}