From 36c07a21e06f453ab3638e2f7353cf51e5140894 Mon Sep 17 00:00:00 2001
From: wubijie <wubijie@kylinos.cn>
Date: Wed, 6 Nov 2024 10:56:10 +0800
Subject: [PATCH] add sshdconfig apply func

---
 configmanage/server/service/sshd.go | 82 ++++++++++++++++++++++++++++-
 1 file changed, 81 insertions(+), 1 deletion(-)

diff --git a/configmanage/server/service/sshd.go b/configmanage/server/service/sshd.go
index ed59bf5a..27d48e43 100644
--- a/configmanage/server/service/sshd.go
+++ b/configmanage/server/service/sshd.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"
 )
 
@@ -70,7 +75,82 @@ func (sdc *SSHDConfig) Load() error {
 
 // TODO:
 func (sdc *SSHDConfig) Apply() (json.RawMessage, error) {
-	return nil, errors.New("failed to apply SSHDConfig")
+	// 从数据库获取下发的信息
+	sdf, err := internal.GetHostFileByUUID(sdc.UUID)
+	if err != nil {
+		return nil, err
+	}
+	if sdf.ConfigInfoUUID != sdc.ConfigInfoUUID || sdf.UUID != sdc.UUID {
+		return nil, errors.New("数据库不存在此配置")
+	}
+
+	batchids, err := internal.GetConfigBatchByUUID(sdc.ConfigInfoUUID)
+	if err != nil {
+		return nil, err
+	}
+	departids, err := internal.GetConfigDepartByUUID(sdc.ConfigInfoUUID)
+	if err != nil {
+		return nil, err
+	}
+	nodes, err := internal.GetConfigNodesByUUID(sdc.ConfigInfoUUID)
+	if err != nil {
+		return nil, err
+	}
+
+	// 从hc中解析下发的文件内容，逐一进行下发
+	Repofile := common.File{}
+	err = json.Unmarshal([]byte(sdf.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 = sdf.UpdateByuuid()
+		return nil, err
+	}
+	return nil, errors.New(result + "failed to apply SSHDConfig")
 }
 
 // TODO:
-- 
Gitee