From b8b10b5176f22ec49d9a6659399942d9ba936749 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= <iwind.liu@gmail.com>
Date: Thu, 15 Sep 2022 15:57:53 +0800
Subject: [PATCH] =?UTF-8?q?=E9=9B=86=E7=BE=A4=E5=A2=9E=E5=8A=A0=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E5=90=8C=E6=AD=A5=E6=97=B6=E9=92=9F=E9=80=89=E9=A1=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../clusters/cluster/settings/index.go        | 35 ++++++++++++++++++-
 .../clusters/cluster/settings/index.html      | 18 ++++++++++
 2 files changed, 52 insertions(+), 1 deletion(-)

diff --git a/internal/web/actions/default/clusters/cluster/settings/index.go b/internal/web/actions/default/clusters/cluster/settings/index.go
index 4cc5aa04..1517880c 100644
--- a/internal/web/actions/default/clusters/cluster/settings/index.go
+++ b/internal/web/actions/default/clusters/cluster/settings/index.go
@@ -1,6 +1,7 @@
 package settings
 
 import (
+	"encoding/json"
 	"github.com/TeaOSLab/EdgeAdmin/internal/oplogs"
 	"github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils"
 	"github.com/TeaOSLab/EdgeAdmin/internal/web/actions/default/clusters/grants/grantutils"
@@ -65,6 +66,19 @@ func (this *IndexAction) RunGet(params struct {
 	}
 	this.Data["timeZoneLocation"] = nodeconfigs.FindTimeZoneLocation(cluster.TimeZone)
 
+	// 时钟
+	var clockConfig = nodeconfigs.DefaultClockConfig()
+	if len(cluster.ClockJSON) > 0 {
+		err = json.Unmarshal(cluster.ClockJSON, clockConfig)
+		if err != nil {
+			this.ErrorPage(err)
+			return
+		}
+		if clockConfig == nil {
+			clockConfig = nodeconfigs.DefaultClockConfig()
+		}
+	}
+
 	this.Data["cluster"] = maps.Map{
 		"id":             cluster.Id,
 		"name":           cluster.Name,
@@ -72,6 +86,7 @@ func (this *IndexAction) RunGet(params struct {
 		"timeZone":       cluster.TimeZone,
 		"nodeMaxThreads": cluster.NodeMaxThreads,
 		"autoOpenPorts":  cluster.AutoOpenPorts,
+		"clock":          clockConfig,
 	}
 
 	// 默认值
@@ -91,6 +106,8 @@ func (this *IndexAction) RunPost(params struct {
 	TimeZone       string
 	NodeMaxThreads int32
 	AutoOpenPorts  bool
+	ClockAutoSync  bool
+	ClockServer    string
 
 	Must *actions.Must
 }) {
@@ -108,7 +125,22 @@ func (this *IndexAction) RunPost(params struct {
 			Lte(int64(nodeconfigs.DefaultMaxThreadsMax), "单节点最大线程数最大值不能大于"+types.String(nodeconfigs.DefaultMaxThreadsMax))
 	}
 
-	_, err := this.RPC().NodeClusterRPC().UpdateNodeCluster(this.AdminContext(), &pb.UpdateNodeClusterRequest{
+	var clockConfig = nodeconfigs.DefaultClockConfig()
+	clockConfig.AutoSync = params.ClockAutoSync
+	clockConfig.Server = params.ClockServer
+	clockConfigJSON, err := json.Marshal(clockConfig)
+	if err != nil {
+		this.ErrorPage(err)
+		return
+	}
+
+	err = clockConfig.Init()
+	if err != nil {
+		this.ErrorPage(err)
+		return
+	}
+
+	_, err = this.RPC().NodeClusterRPC().UpdateNodeCluster(this.AdminContext(), &pb.UpdateNodeClusterRequest{
 		NodeClusterId:  params.ClusterId,
 		Name:           params.Name,
 		NodeGrantId:    params.GrantId,
@@ -116,6 +148,7 @@ func (this *IndexAction) RunPost(params struct {
 		TimeZone:       params.TimeZone,
 		NodeMaxThreads: params.NodeMaxThreads,
 		AutoOpenPorts:  params.AutoOpenPorts,
+		ClockJSON:      clockConfigJSON,
 	})
 	if err != nil {
 		this.ErrorPage(err)
diff --git a/web/views/@default/clusters/cluster/settings/index.html b/web/views/@default/clusters/cluster/settings/index.html
index 8b3cf8ca..b2510d79 100644
--- a/web/views/@default/clusters/cluster/settings/index.html
+++ b/web/views/@default/clusters/cluster/settings/index.html
@@ -60,6 +60,24 @@
                         <p class="comment">选中后会自动尝试在边缘节点正在运行的firewalld中开放所需端口；如果有别的防火墙或者安全策略，仍然需要手工操作。</p>
                     </td>
                 </tr>
+                <tr>
+                    <td class="color-border">自动同步节点时钟</td>
+                    <td>
+                        <div class="ui fields inline">
+                            <div class="ui field">
+                                <checkbox name="clockAutoSync" v-model="cluster.clock.autoSync"></checkbox>
+                            </div>
+                        </div>
+                        <p class="comment">选中后表示尝试自动同步节点时钟。</p>
+                    </td>
+                </tr>
+                <tr v-show="cluster.clock.autoSync">
+                    <td class="color-border">NTP时钟服务器</td>
+                    <td>
+                        <input type="text" name="clockServer" v-model="cluster.clock.server" maxlength="100"/>
+                        <p class="comment">可选项。默认使用<code-label>pool.ntp.org</code-label>。</p>
+                    </td>
+                </tr>
             </tbody>
 		</table>
 		<submit-btn></submit-btn>