修复调度任务 第二次不执行的bug，调整定时任务时间间隔

scheduler/ParseDemand.go

@@ -9,10 +9,12 @@ var status int
 func ParseDemandFile() {
 	if status == 0 {
 		status = 1
+		defer func() {
+			status = 0
+		}()
 	} else {
 		return
 	}
 	omService := services.NewDemandHeadService()
 	omService.OMParseDemand()
-	status = 0
 }

scheduler/scheduler.go

@@ -6,7 +6,7 @@ import (
 
 func Start() error {
 		c := cron.New()
-		err := c.AddFunc("*/10 * * * * ?", ParseDemandFile)
+		err := c.AddFunc("*/5 * * * * ?", ParseDemandFile)
 		if err != nil {
 			return err
 		}

services/om/implments/DemandHead.service.impl.go

@@ -529,7 +529,7 @@ func (impl *DemandHeadServiceImplement) OMParseDemand() {
  ******************************************************************************/
 func (impl *DemandHeadServiceImplement) DealDemandHead(demandHead model.DemandHead, wg *sync.WaitGroup) {
 	log, _ := logger.NewLogger("admin", "OM")
-	defer wg.Wait()
+	defer wg.Done()
 	engine := db.Eloquent.Master()
 	session := engine.NewSession()
 	defer session.Close()