From 32fbb2aa1ae230eef72fe831968509029021a857 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BE=90=E4=BA=91=E9=87=91YunjinXu?= <xuyunjin@foxmail.com>
Date: Sun, 25 Jun 2023 09:58:08 +0800
Subject: [PATCH] reset trans corntime once - http api

---
 dtmsvr/api.go      | 5 +++++
 dtmsvr/api_http.go | 5 +++++
 2 files changed, 10 insertions(+)

diff --git a/dtmsvr/api.go b/dtmsvr/api.go
index 25c24c9..61510f9 100644
--- a/dtmsvr/api.go
+++ b/dtmsvr/api.go
@@ -86,6 +86,11 @@ func svcForceStop(t *TransGlobal) interface{} {
 	return nil
 }
 
+func svcResetNextCronTime(t *TransGlobal) error {
+	dbt := GetTransGlobal(t.Gid)
+	return dbt.resetNextCronTime()
+}
+
 func svcRegisterBranch(transType string, branch *TransBranch, data map[string]string) error {
 	branches := []TransBranch{*branch, *branch}
 	if transType == "tcc" {
diff --git a/dtmsvr/api_http.go b/dtmsvr/api_http.go
index 64a291d..3d8d09d 100644
--- a/dtmsvr/api_http.go
+++ b/dtmsvr/api_http.go
@@ -40,6 +40,7 @@ func addRoute(engine *gin.Engine) {
 	engine.DELETE("/api/dtmsvr/topic/:topicName", dtmutil.WrapHandler2(deleteTopic))
 	engine.GET("/api/dtmsvr/scanKV", dtmutil.WrapHandler2(scanKV))
 	engine.GET("/api/dtmsvr/queryKV", dtmutil.WrapHandler2(queryKV))
+	engine.POST("/api/dtmsvr/resetNextCronTime", dtmutil.WrapHandler2(resetNextCronTime)) // one global trans only
 
 	// add prometheus exporter
 	h := promhttp.Handler()
@@ -69,6 +70,10 @@ func forceStop(c *gin.Context) interface{} {
 	return svcForceStop(TransFromContext(c))
 }
 
+func resetNextCronTime(c *gin.Context) interface{} {
+	return svcResetNextCronTime(TransFromContext(c))
+}
+
 func registerBranch(c *gin.Context) interface{} {
 	data := map[string]string{}
 	err := c.BindJSON(&data)