using System.ComponentModel;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Filters;
using NewLife;
using NewLife.Cube;
using NewLife.Cube.Extensions;
using NewLife.Cube.ViewModels;
using NewLife.Web;
using Stardust.Data.Deployment;
using Stardust.Web.Services;
using XCode.Membership;
namespace Stardust.Web.Areas.Deployment.Controllers;
[Menu(88, false)]
[DeploymentArea]
public class AppDeployNodeController : EntityController<AppDeployNode>
{
static AppDeployNodeController()
{
ListFields.RemoveCreateField();
AddFormFields.RemoveCreateField();
ListFields.TraceUrl();
LogOnChange = true;
{
var df = ListFields.GetField("DeployName") as ListField;
df.Url = "/Deployment/AppDeploy?deployId={DeployId}";
}
{
var df = AddFormFields.GetField("NodeName") as FormField;
df.GroupView = "_Form_SelectNode";
}
{
var df = EditFormFields.GetField("NodeName") as FormField;
df.GroupView = "_Form_SelectNode";
}
{
var df = DetailFields.GetField("NodeName") as FormField;
df.GroupView = "_Form_SelectNode";
}
}
private readonly DeployService _deployService;
public AppDeployNodeController(DeployService deployService)
{
_deployService = deployService;
}
public override void OnActionExecuting(ActionExecutingContext filterContext)
{
base.OnActionExecuting(filterContext);
var appId = GetRequest("appId").ToInt(-1);
var deployId = GetRequest("deployId").ToInt(-1);
if (deployId > 0 || appId > 0)
{
PageSetting.NavView = "_App_Nav";
PageSetting.EnableNavbar = false;
}
var nodeId = GetRequest("nodeId").ToInt(-1);
if (nodeId > 0)
{
PageSetting.NavView = "_Node_Nav";
PageSetting.EnableNavbar = false;
}
}
protected override FieldCollection OnGetFields(ViewKinds kind, Object model)
{
var fields = base.OnGetFields(kind, model);
if (kind == ViewKinds.List)
{
var deployId = GetRequest("deployId").ToInt(-1);
if (deployId > 0) fields.RemoveField("DeployName");
var nodeId = GetRequest("nodeId").ToInt(-1);
if (nodeId > 0) fields.RemoveField("NodeName");
}
return fields;
}
protected override IEnumerable<AppDeployNode> Search(Pager p)
{
var id = p["id"].ToInt(-1);
if (id > 0)
{
var entity = AppDeployNode.FindById(id);
if (entity != null) return new List<AppDeployNode> { entity };
}
var appId = p["deployId"].ToInt(-1);
if (appId <= 0) appId = p["appId"].ToInt(-1);
var nodeId = p["nodeId"].ToInt(-1);
var enable = p["enable"]?.ToBoolean();
PageSetting.EnableAdd = appId > 0;
PageSetting.EnableNavbar = false;
return AppDeployNode.Search(appId, nodeId, enable, p["Q"], p);
}
protected override Boolean Valid(AppDeployNode entity, DataObjectMethodType type, Boolean post)
{
if (!post) return base.Valid(entity, type, post);
var node = entity.Node;
if (node != null) entity.IP = node.IP;
entity.Deploy?.Fix();
return base.Valid(entity, type, post);
}
protected override Int32 OnInsert(AppDeployNode entity)
{
var rs = base.OnInsert(entity);
entity.Deploy?.Fix();
return rs;
}
protected override Int32 OnUpdate(AppDeployNode entity)
{
var rs = base.OnUpdate(entity);
entity.Deploy?.Fix();
return rs;
}
protected override Int32 OnDelete(AppDeployNode entity)
{
var rs = base.OnDelete(entity);
entity.Deploy?.Fix();
return rs;
}
/// <summary>执行操作</summary>
/// <param name="act"></param>
/// <param name="id"></param>
/// <returns></returns>
[EntityAuthorize(PermissionFlags.Update)]
public async Task<ActionResult> Operate(String act, Int32 id)
{
var dn = AppDeployNode.FindById(id);
if (dn == null || dn.Node == null || dn.Deploy == null) return Json(500, $"[{id}]不存在");
var deployName = dn.DeployName;
if (deployName.IsNullOrEmpty()) deployName = dn.Deploy?.Name;
await _deployService.Control(dn.Deploy, dn, act, UserHost, 0);
return JsonRefresh($"在节点[{dn.NodeName}]上对应用[{deployName}]执行[{act}]操作", 1);
}
/// <summary>批量执行操作</summary>
/// <param name="act"></param>
/// <returns></returns>
[EntityAuthorize(PermissionFlags.Update)]
public async Task<ActionResult> BatchOperate(String act)
{
var ts = new List<Task>();
var ids = SelectKeys.Select(e => e.ToInt()).Where(e => e > 0).Distinct().ToList();
foreach (var id in ids)
{
var dn = AppDeployNode.FindById(id);
if (dn != null && dn.Enable && dn.Node != null && dn.Deploy != null)
{
ts.Add(_deployService.Control(dn.Deploy, dn, act, UserHost, 0));
}
}
await Task.WhenAll(ts);
return JsonRefresh($"批量执行[{act}]操作", 1);
}
}
|