|
|
@@ -41,17 +41,17 @@ func Timer() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- //// 定时更新前一天的统计数据
|
|
|
- //_, err := global.GVA_Timer.AddTaskByFunc("StatisticsLog", "2 8 5 * * * ", serviceStatisticsLog.CreateStatisticsLog)
|
|
|
- //if err != nil {
|
|
|
- // fmt.Println("add taskCode timer error:", err)
|
|
|
- //}
|
|
|
- //
|
|
|
- ////定时同步电脑相关的统计数据
|
|
|
- //_, err = global.GVA_Timer.AddTaskByFunc("CreateComputerStatisticsData", "40 9,19,29,39,49,59 7-23 * * * ", serviceStatisticsLog.CreateComputerStatisticsData)
|
|
|
- //if err != nil {
|
|
|
- // fmt.Println("add CreateComputerStatisticsData timer error:", err)
|
|
|
- //}
|
|
|
+ // 定时更新前一天的统计数据
|
|
|
+ _, err := global.GVA_Timer.AddTaskByFunc("StatisticsLog", "2 8 5 * * * ", serviceStatisticsLog.CreateStatisticsLog)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("add taskCode timer error:", err)
|
|
|
+ }
|
|
|
+
|
|
|
+ //定时同步电脑相关的统计数据
|
|
|
+ _, err = global.GVA_Timer.AddTaskByFunc("CreateComputerStatisticsData", "40 9,19,29,39,49,59 7-23 * * * ", serviceStatisticsLog.CreateComputerStatisticsData)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("add CreateComputerStatisticsData timer error:", err)
|
|
|
+ }
|
|
|
//// 同步游戏相关的统计数据
|
|
|
//_, err = global.GVA_Timer.AddTaskByFunc("TodayCreateStatisticsGameInfoLog", "2 8,18,28,38,48,58 6-23 * * * ", serviceStatisticsLog.TodayCreateStatisticsGameInfoLog)
|
|
|
//if err != nil {
|
|
|
@@ -88,7 +88,7 @@ func Timer() {
|
|
|
// fmt.Println("add EveryDaySyncTaskData timer error:", err)
|
|
|
//}
|
|
|
////同步任务数据
|
|
|
- //_, err = global.GVA_Timer.AddTaskByFunc("SyncTaskData", "2 0/3 1-23 * * *", syncData.SyncTaskData)
|
|
|
+ //_, err = global.GVA_Timer.AddTaskByFunc("SyncTaskData", "35 0/3 1-23 * * *", syncData.SyncTaskData)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add SyncTaskData timer error:", err)
|
|
|
//}
|
|
|
@@ -97,7 +97,7 @@ func Timer() {
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add DayTargetDataStatistics timer error:", err)
|
|
|
//}
|
|
|
-
|
|
|
+ //
|
|
|
//// 定时检查是否有电脑到期,修改租机状态@every 1s
|
|
|
//_, err = global.GVA_Timer.AddTaskByFunc("CheckIsExpire", "0 0/5 * * * *", serviceRentComputer.CheckIsExpire)
|
|
|
//if err != nil {
|
|
|
@@ -108,9 +108,9 @@ func Timer() {
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add CreateRentComputerLedger timer error:", err)
|
|
|
//}
|
|
|
-
|
|
|
- //定时获取扫码平台余额,每小时执行一次
|
|
|
- //_, err = global.GVA_Timer.AddTaskByFunc("SyncGetWeChatScannerBalance", "0 58 * * * *", serviceWeChatScannerApi.SyncGetWeChatScannerBalance)
|
|
|
+ //
|
|
|
+ ////定时获取扫码平台余额,每小时执行一次
|
|
|
+ ////_, err = global.GVA_Timer.AddTaskByFunc("SyncGetWeChatScannerBalance", "0 58 * * * *", serviceWeChatScannerApi.SyncGetWeChatScannerBalance)
|
|
|
//_, err = global.GVA_Timer.AddTaskByFunc("SyncGetWeChatScannerBalance", "0 58 * * * *", serviceWeChatScannerApi.SyncGetWeChatScannerBalance)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add SyncGetWeChatScannerBalance timer error:", err)
|
|
|
@@ -120,20 +120,20 @@ func Timer() {
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add SyncAbnormalRateByBatch timer error:", err)
|
|
|
//}
|
|
|
-
|
|
|
- //定时更新当日微信扫码订单列表
|
|
|
+ //
|
|
|
+ ////定时更新当日微信扫码订单列表
|
|
|
//_, err = global.GVA_Timer.AddTaskByFunc("SyncTodayWeChatScannerDetailed", "0 3,33 * * * *", serviceWeChatScannerDetailed.SyncTodayWeChatScannerDetailed)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add SyncTodayWeChatScannerDetailed timer error:", err)
|
|
|
//}
|
|
|
-
|
|
|
- //0点更新昨日微信扫码订单列表
|
|
|
+ //
|
|
|
+ ////0点更新昨日微信扫码订单列表
|
|
|
//_, err = global.GVA_Timer.AddTaskByFunc("SyncYesterdayWeChatScannerDetailed", "1 1 0 * * *", serviceWeChatScannerDetailed.SyncYesterdayWeChatScannerDetailed)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add SyncYesterdayWeChatScannerDetailed timer error:", err)
|
|
|
//}
|
|
|
-
|
|
|
- //半小时同步一次机房设备信息,播报是否有异常
|
|
|
+ //
|
|
|
+ ////半小时同步一次机房设备信息,播报是否有异常
|
|
|
//_, err = global.GVA_Timer.AddTaskByFunc("SyncJfDevicesMessage", "0 0,30 * * * *", robotService.SyncJfDevicesMessage)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add SyncJfDevicesMessage timer error:", err)
|
|
|
@@ -146,7 +146,7 @@ func Timer() {
|
|
|
//}
|
|
|
//
|
|
|
//// 活跃定时推送消息
|
|
|
- //_, err = global.GVA_Timer.AddTaskByFunc("TaskMsgSend", "20 0/10 22-23 * * *", syncData.TaskMsgSend)
|
|
|
+ //_, err = global.GVA_Timer.AddTaskByFunc("TaskMsgSend", "40 0/10 22-23 * * *", syncData.TaskMsgSend)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add TaskMsgSend timer error:", err)
|
|
|
//}
|
|
|
@@ -158,20 +158,20 @@ func Timer() {
|
|
|
//}
|
|
|
//
|
|
|
//// 付费定时推送消息
|
|
|
- //_, err = global.GVA_Timer.AddTaskByFunc("TaskMsgSend", "40 0/5 22-23 * * *", syncData.TaskFreeMsgSend)
|
|
|
+ //_, err = global.GVA_Timer.AddTaskByFunc("TaskMsgSend", "50 0/5 22-23 * * *", syncData.TaskFreeMsgSend)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add TaskFreeMsgSend timer error:", err)
|
|
|
//}
|
|
|
//
|
|
|
//// 23起检测任务完成情况
|
|
|
- //_, err = global.GVA_Timer.AddTaskByFunc("CheckTaskCompletedInfo", "10 0/4 23 * * *", syncData.CheckTaskCompletedInfo)
|
|
|
+ //_, err = global.GVA_Timer.AddTaskByFunc("CheckTaskCompletedInfo", "57 0/4 23 * * *", syncData.CheckTaskCompletedInfo)
|
|
|
//if err != nil {
|
|
|
// fmt.Println("add CheckTaskCompletedInfo timer error:", err)
|
|
|
//}
|
|
|
-
|
|
|
- //定时更新游戏版本号和链接
|
|
|
- _, err := global.GVA_Timer.AddTaskByFunc("UpdateGameVersion", "0 3/15 * * * *", serviceDownLoadUrl.UpdateGameVersion)
|
|
|
- if err != nil {
|
|
|
- fmt.Println("add UpdateGameVersion timer error:", err)
|
|
|
- }
|
|
|
+ //
|
|
|
+ ////定时更新游戏版本号和链接
|
|
|
+ //_, err = global.GVA_Timer.AddTaskByFunc("UpdateGameVersion", "0 3/15 * * * *", serviceDownLoadUrl.UpdateGameVersion)
|
|
|
+ //if err != nil {
|
|
|
+ // fmt.Println("add UpdateGameVersion timer error:", err)
|
|
|
+ //}
|
|
|
}
|