向外提供API接口

controllers/day_new.go

@@ -0,0 +1,35 @@
+package controllers
+
+import (
+	"hongze/hongze_open_api/services"
+)
+
+type DayNewController struct {
+	BaseCommon
+}
+
+// RefreshMsg
+// @Title 手动刷新企业微信群消息
+// @Description 手动刷新
+// @router /refresh [get]
+func (c *DayNewController) RefreshMsg() {
+	err := services.DayNewWeworkMsgRefresh()
+	if err != nil {
+		c.FailWithMessage("刷新失败, " + err.Error())
+		return
+	}
+	c.Ok()
+}
+
+// TranslateContent
+// @Title 手动翻译内容
+// @Description 手动翻译内容
+// @router /translate [get]
+func (c *DayNewController) TranslateContent() {
+	err := services.DayNewTranslateContent()
+	if err != nil {
+		c.FailWithMessage("翻译失败, " + err.Error())
+		return
+	}
+	c.Ok()
+}

routers/commentsRouter.go

@@ -34,6 +34,24 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hongze_open_api/controllers:DayNewController"] = append(beego.GlobalControllerRouter["hongze/hongze_open_api/controllers:DayNewController"],
+        beego.ControllerComments{
+            Method: "RefreshMsg",
+            Router: `/refresh`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
+    beego.GlobalControllerRouter["hongze/hongze_open_api/controllers:DayNewController"] = append(beego.GlobalControllerRouter["hongze/hongze_open_api/controllers:DayNewController"],
+        beego.ControllerComments{
+            Method: "TranslateContent",
+            Router: `/translate`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hongze_open_api/controllers:QuanShiControllerCommon"] = append(beego.GlobalControllerRouter["hongze/hongze_open_api/controllers:QuanShiControllerCommon"],
         beego.ControllerComments{
             Method: "CallBack",

routers/router.go

@@ -56,6 +56,11 @@ func init() {
 				&controllers.WeworkController{},
 			),
 		),
+		web.NSNamespace("/day_new",
+			web.NSInclude(
+				&controllers.DayNewController{},
+			),
+		),
 	)
 	web.AddNamespace(ns)
 }

services/day_new.go

@@ -15,12 +15,6 @@ import (
 )
 
 func DayNewWeworkMsgRefresh() (err error)  {
-	cacheKey := utils.CACHE_KEY_DAYNEW_REFRESH
-	//设置redis 防止频繁操作
-	if !utils.Rc.SetNX(cacheKey, 1, 1*time.Minute) {
-		err = errors.New(fmt.Sprintf("系统处理中，请1分钟之后再试"))
-		return
-	}
 	defer func() {
 		if err != nil {
 			go alarm_msg.SendAlarmMsg("企业微信 会议存档消息刷新失败, Err："+err.Error(), 1)
@@ -246,12 +240,6 @@ func GetWeWorkUsersNickName() (err error)  {
 }
 
 func DayNewTranslateContent() (err error) {
-	cacheKey := utils.CACHE_KEY_DAYNEW_TRANSLATE
-	//设置redis 防止频繁操作，控制每分钟执行1次
-	if !utils.Rc.SetNX(cacheKey, 1, 1*time.Minute) {
-		err = errors.New(fmt.Sprintf("系统处理中，请1分钟之后再试"))
-		return
-	}
 	defer func() {
 		if err != nil {
 			go alarm_msg.SendAlarmMsg("企业微信 中翻英操作失败, Err："+err.Error(), 1)