|
@@ -13,7 +13,7 @@ import (
|
|
|
func AutoTaskInvalid() error {
|
|
|
// 新建一个定时任务对象
|
|
|
crontab := cron.New(cron.WithSeconds()) // 精确到秒
|
|
|
- spec := "0 */5 * * * ?" //cron表达式,每5分钟一次
|
|
|
+ spec := "0 */1 * * * ?" //cron表达式,每5分钟一次
|
|
|
// "0 0 12 * * ?" 每天中午12点执行
|
|
|
|
|
|
// 添加定时任务
|
|
@@ -44,7 +44,7 @@ func AutoTaskInvalid() error {
|
|
|
func AutoProjectInvalidTask() {
|
|
|
log.Println("AutoProjectInvalidTask running Start, Time :", time.Now())
|
|
|
var projectInfos []*entity.Project
|
|
|
- projectInfos, _ = dao.ProjectDAO{}.GetProjectList(6, "project_status")
|
|
|
+ _ = dao.Db.Model(entity.Project{}).Where("project_status <= ?", 6).Select("project_id,project_status,recruit_ddl,auto_task_id,auto_fail_at").Find(&projectInfos).Error
|
|
|
// 对于所有未支付的品牌种草项目进行处理
|
|
|
for _, projectInfo := range projectInfos {
|
|
|
projectId := projectInfo.ProjectId
|
|
@@ -121,7 +121,7 @@ func AutoSelectionInvalidTask() {
|
|
|
func AutoLocalLifeInvalidTask() {
|
|
|
log.Println("AutoLocalLifeInvalidTask running Start, Time :", time.Now())
|
|
|
var localLifeInfos []*entity.LocalLifeInfo
|
|
|
- localLifeInfos, _ = dao.LocalLifeDao{}.GetLocalLifeList(6, "task_status")
|
|
|
+ _ = dao.Db.Model(entity.LocalLifeInfo{}).Where("task_status <= ?", 6).Select("local_id,task_status,recruit_ddl,auto_task_id,auto_fail_at").Find(&localLifeInfos).Error
|
|
|
// 对于所有未支付的本地生活项目进行处理
|
|
|
for _, localLifeInfo := range localLifeInfos {
|
|
|
localId := localLifeInfo.LocalID
|