Browse Source

修改创建解析portal db任务的时间和限制状态

pull/334/head
zhangxin 3 years ago
parent
commit
5e4ff94564
2 changed files with 3 additions and 15 deletions
  1. +0
    -12
      task/ParseDemand.go
  2. +3
    -3
      task/scheduler.go

+ 0
- 12
task/ParseDemand.go View File

@ -78,15 +78,6 @@ func ParseWorkOrderFromDB() {
* *
******************************************************************************/ ******************************************************************************/
func CreateParseFromDBByDayTask() { func CreateParseFromDBByDayTask() {
//if parseOrderFromFileStatus == 1 {
// return
//}
//if parseOrderFromDBStatus == 1 {
// return
//}
if createParseTaskFrmDBByTimeStatus == 1 {
return
}
if createParseTaskFrmDBByDayStatus == 0 { if createParseTaskFrmDBByDayStatus == 0 {
createParseTaskFrmDBByDayStatus = 1 createParseTaskFrmDBByDayStatus = 1
defer func() { defer func() {
@ -113,9 +104,6 @@ func CreateParseFromDBByDayTask() {
* *
******************************************************************************/ ******************************************************************************/
func CreateParseFromDBByTimeTask() { func CreateParseFromDBByTimeTask() {
if createParseTaskFrmDBByDayStatus == 1 {
return
}
if createParseTaskFrmDBByTimeStatus == 0 { if createParseTaskFrmDBByTimeStatus == 0 {
createParseTaskFrmDBByTimeStatus = 1 createParseTaskFrmDBByTimeStatus = 1
defer func() { defer func() {


+ 3
- 3
task/scheduler.go View File

@ -29,13 +29,13 @@ func Start() error {
if err != nil { if err != nil {
return err return err
} }
//
err = c.AddFunc("0 */30 * * * ?", CreateParseFromDBByTimeTask)
err = c.AddFunc("0 0,30 * * * ?", CreateParseFromDBByTimeTask)
if err != nil { if err != nil {
return err return err
} }
err = c.AddFunc("0 */40 * * * ?", CreateParseFromDBByDayTask)
err = c.AddFunc("0 4,36 * * * ?", CreateParseFromDBByDayTask)
if err != nil { if err != nil {
return err return err
} }


Loading…
Cancel
Save