reset trans corntime once - http api

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" {

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)