|
|
@@ -8,8 +8,11 @@ import (
|
|
|
"eta/eta_task/utils"
|
|
|
"fmt"
|
|
|
"strings"
|
|
|
+ "sync"
|
|
|
)
|
|
|
|
|
|
+var lockSyncUser sync.Mutex
|
|
|
+
|
|
|
// SyncUser
|
|
|
// @Description: 定时同步ETA指标信息变更数据至第三方
|
|
|
// @author: Roc
|
|
|
@@ -17,12 +20,14 @@ import (
|
|
|
// @param cont context.Context
|
|
|
// @return err error
|
|
|
func SyncUser(cont context.Context) (err error) {
|
|
|
+ lockSyncUser.Lock()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
tips := "SyncUser-定时将第三方的用户数据同步到ETA失败, ErrMsg:\n" + err.Error()
|
|
|
utils.FileLog.Info(tips)
|
|
|
go alarm_msg.SendAlarmMsg(tips, 3)
|
|
|
}
|
|
|
+ lockSyncUser.Unlock()
|
|
|
}()
|
|
|
|
|
|
uri := "/xy/user/pull"
|
