From 2165bb553f194f3c284a37cb33f2f63c5d3db912 Mon Sep 17 00:00:00 2001
From: wubijie <wubijie@kylinos.cn>
Date: Thu, 7 Nov 2024 11:24:30 +0800
Subject: [PATCH] add sysctl config apply func

---
 configmanage/server/service/sshd.go   |  2 +-
 configmanage/server/service/sysctl.go | 83 ++++++++++++++++++++++++++-
 2 files changed, 82 insertions(+), 3 deletions(-)

diff --git a/configmanage/server/service/sshd.go b/configmanage/server/service/sshd.go
index b65032dc..90051d7f 100644
--- a/configmanage/server/service/sshd.go
+++ b/configmanage/server/service/sshd.go
@@ -88,7 +88,7 @@ func (sdc *SSHDConfig) Load() error {
 // TODO:
 func (sdc *SSHDConfig) Apply() (json.RawMessage, error) {
 	// 从数据库获取下发的信息
-	sdf, err := internal.GetHostFileByUUID(sdc.UUID)
+	sdf, err := internal.GetSSHDFileByUUID(sdc.UUID)
 	if err != nil {
 		return nil, err
 	}
diff --git a/configmanage/server/service/sysctl.go b/configmanage/server/service/sysctl.go
index dbcb6084..be5c12d2 100644
--- a/configmanage/server/service/sysctl.go
+++ b/configmanage/server/service/sysctl.go
@@ -4,8 +4,13 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"net/http"
+	"strconv"
 	"time"
 
+	"gitee.com/openeuler/PilotGo/sdk/common"
+	"gitee.com/openeuler/PilotGo/sdk/plugin/client"
+	"gitee.com/openeuler/PilotGo/sdk/utils/httputils"
 	"openeuler.org/PilotGo/configmanage-plugin/internal"
 )
 
@@ -79,9 +84,83 @@ func (sysc *SysctlConfig) Load() error {
 	return nil
 }
 
-// TODO:
 func (sysc *SysctlConfig) Apply() (json.RawMessage, error) {
-	return nil, errors.New("failed to apply SysctlConfig")
+	// 从数据库获取下发的信息
+	sysf, err := internal.GetSysctlFileByUUID(sysc.UUID)
+	if err != nil {
+		return nil, err
+	}
+	if sysf.ConfigInfoUUID != sysc.ConfigInfoUUID || sysf.UUID != sysc.UUID {
+		return nil, errors.New("数据库不存在此配置")
+	}
+
+	batchids, err := internal.GetConfigBatchByUUID(sysc.ConfigInfoUUID)
+	if err != nil {
+		return nil, err
+	}
+	departids, err := internal.GetConfigDepartByUUID(sysc.ConfigInfoUUID)
+	if err != nil {
+		return nil, err
+	}
+	nodes, err := internal.GetConfigNodesByUUID(sysc.ConfigInfoUUID)
+	if err != nil {
+		return nil, err
+	}
+
+	// 从hc中解析下发的文件内容，逐一进行下发
+	Repofile := common.File{}
+	err = json.Unmarshal([]byte(sysf.Content), &Repofile)
+	if err != nil {
+		return nil, err
+	}
+	result := ""
+	de := Deploy{
+		DeployBatch: common.Batch{
+			BatchIds:      batchids,
+			DepartmentIDs: departids,
+			MachineUUIDs:  nodes,
+		},
+		DeployPath:     Repofile.Path,
+		DeployFileName: Repofile.Name,
+		DeployText:     Repofile.Content,
+	}
+	url := "http://" + client.GetClient().Server() + "/api/v1/pluginapi/file_deploy"
+	r, err := httputils.Post(url, &httputils.Params{
+		Body: de,
+	})
+	if err != nil {
+		return nil, err
+	}
+	if r.StatusCode != http.StatusOK {
+		return nil, errors.New("server process error:" + strconv.Itoa(r.StatusCode))
+	}
+
+	resp := &common.CommonResult{}
+	if err := json.Unmarshal(r.Body, resp); err != nil {
+		return nil, err
+	}
+	if resp.Code != http.StatusOK {
+		return nil, errors.New(resp.Message)
+	}
+
+	data := []common.NodeResult{}
+	if err := resp.ParseData(&data); err != nil {
+		return nil, err
+	}
+	// 将执行失败的文件、机器信息和原因添加到结果字符串中
+	for _, d := range data {
+		if d.Error != "" {
+			result = result + Repofile.Content + "文件" + d.UUID + ":" + d.Error + "\n"
+		}
+	}
+
+	// TODO:部分成功如何修改数据库
+	if result == "" {
+		//下发成功修改数据库应用版本
+		err = sysf.UpdateByuuid()
+		return nil, err
+	}
+	return nil, errors.New(result + "failed to apply SysctlConfig")
 }
 
 // TODO:
-- 
Gitee