|
|
@@ -13,7 +13,12 @@ import (
|
|
|
|
|
|
func EtaForumChartUpdate(cont context.Context) (err error) {
|
|
|
var tmpErr []error
|
|
|
+ deleteCache := true
|
|
|
+ cacheKey := "eta_forum_task:EtaForumChartUpdate"
|
|
|
defer func() {
|
|
|
+ if deleteCache {
|
|
|
+ _ = utils.Rc.Delete(cacheKey)
|
|
|
+ }
|
|
|
stack := ""
|
|
|
if err != nil {
|
|
|
stack = fmt.Sprintln(stack + err.Error())
|
|
|
@@ -27,6 +32,11 @@ func EtaForumChartUpdate(cont context.Context) (err error) {
|
|
|
go alarm_msg.SendAlarmMsg(utils.APP_NAME_CN+"更新社区图表信息失败"+time.Now().Format("2006-01-02 15:04:05")+"<br/>"+stack, 3)
|
|
|
}
|
|
|
}()
|
|
|
+ if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
|
|
|
+ deleteCache = false
|
|
|
+ err = fmt.Errorf("系统处理中，请稍后重试！")
|
|
|
+ return
|
|
|
+ }
|
|
|
// 设置缓存判断处理中则不更新
|
|
|
condition := " and forum_chart_info_id > 0 and source=1 "
|
|
|
// 查询需要更新的图表信息总数
|
