定时任务修改，活动状态

models/activity.go

@@ -3,6 +3,7 @@ package models
 import (
 	"rdluck_tools/orm"
 	"rdluck_tools/paging"
+	"time"
 )
 
 type Activity struct {
@@ -202,3 +203,35 @@ func DeleteActivity(activityId int) (err error) {
 	_, err = o.Raw(sql, activityId).Exec()
 	return
 }
+
+//修改活动状态至进行中
+func UpdateActivitySattusToHaveInHand() (err error) {
+	o := orm.NewOrm()
+	resultTime_30 := time.Now().Add(-time.Minute * 30).Format("2006-01-02 15:04:05")
+	resultTime_60 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05")
+	var sqlOr string
+	var condition string
+	condition += ` AND activity_time < NOW()`
+	sqlOr = condition
+	condition += ` AND (activity_type_id IN ( 1, 2, 3 ) AND  activity_time > ` + "'" + resultTime_30 + "'" + ")"
+	condition += ` OR(activity_type_id IN ( 4, 5, 6 ) AND  activity_time > ` + "'" + resultTime_60 + "'" + sqlOr + ")"
+	msql := " UPDATE cygx_activity SET active_state = 2 WHERE 1 = 1 " + condition
+	_, err = o.Raw(msql).Exec()
+	return
+}
+
+//修改活动状态至已结束
+func UpdateActivitySattusToComplete() (err error) {
+	o := orm.NewOrm()
+	resultTime_30 := time.Now().Add(-time.Minute * 30).Format("2006-01-02 15:04:05")
+	resultTime_60 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05")
+	//var sqlOr string
+	var condition string
+	//condition += ` AND activity_time < NOW()`
+	//sqlOr = condition
+	condition += ` AND (activity_type_id IN ( 1, 2, 3 ) AND  activity_time < ` + "'" + resultTime_30 + "'" + ")"
+	condition += ` OR(activity_type_id IN ( 4, 5, 6 ) AND  activity_time < ` + "'" + resultTime_60 + "'" + ")"
+	msql := " UPDATE cygx_activity SET active_state = 3 WHERE 1 = 1 " + condition
+	_, err = o.Raw(msql).Exec()
+	return
+}

services/activity.go

@@ -0,0 +1,20 @@
+package services
+
+import (
+	"fmt"
+	"hongze/hongze_cygx/models"
+)
+
+//修改活动状态
+func UpdateActivitySattus() (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println("同步失败，Err:", err.Error())
+		}
+	}()
+	fmt.Println("修改状态6661")
+	go models.UpdateActivitySattusToHaveInHand()
+	go models.UpdateActivitySattusToComplete()
+	fmt.Println("修改状态完成")
+	return
+}

services/task.go

@@ -28,6 +28,13 @@ func Task() {
 		toolbox.StartTask()
 	}
 
+	//updateActivitySattus := toolbox.NewTask("updateActivitySattus", "0 */5 * * * *", UpdateActivitySattus)
+	//toolbox.AddTask("updateActivitySattus", updateActivitySattus)
+
+	UpdateActivitySattus()
+
+	toolbox.StartTask()
+
 	//if utils.RunMode == "debug" {
 	//	//syncTacticsList := toolbox.NewTask("syncTacticsList", "0 */5 * * * *", SyncTacticsList)
 	//	//toolbox.AddTask("syncTacticsList", syncTacticsList)