diff --git a/task/ParseDemand.go b/task/ParseDemand.go index beb6abf..a25d8f1 100644 --- a/task/ParseDemand.go +++ b/task/ParseDemand.go @@ -78,15 +78,6 @@ func ParseWorkOrderFromDB() { * ******************************************************************************/ func CreateParseFromDBByDayTask() { - //if parseOrderFromFileStatus == 1 { - // return - //} - //if parseOrderFromDBStatus == 1 { - // return - //} - if createParseTaskFrmDBByTimeStatus == 1 { - return - } if createParseTaskFrmDBByDayStatus == 0 { createParseTaskFrmDBByDayStatus = 1 defer func() { @@ -113,9 +104,6 @@ func CreateParseFromDBByDayTask() { * ******************************************************************************/ func CreateParseFromDBByTimeTask() { - if createParseTaskFrmDBByDayStatus == 1 { - return - } if createParseTaskFrmDBByTimeStatus == 0 { createParseTaskFrmDBByTimeStatus = 1 defer func() { diff --git a/task/scheduler.go b/task/scheduler.go index 8356594..5149817 100644 --- a/task/scheduler.go +++ b/task/scheduler.go @@ -29,13 +29,13 @@ func Start() error { if err != nil { return err } - // - err = c.AddFunc("0 */30 * * * ?", CreateParseFromDBByTimeTask) + + err = c.AddFunc("0 0,30 * * * ?", CreateParseFromDBByTimeTask) if err != nil { return err } - err = c.AddFunc("0 */40 * * * ?", CreateParseFromDBByDayTask) + err = c.AddFunc("0 4,36 * * * ?", CreateParseFromDBByDayTask) if err != nil { return err }