diff --git a/modules/hero/hero_test.go b/modules/hero/hero_test.go index 1697337f3..dce0a1d87 100644 --- a/modules/hero/hero_test.go +++ b/modules/hero/hero_test.go @@ -7,6 +7,7 @@ import ( "go_dreamfactory/lego" "go_dreamfactory/lego/base/rpcx" "go_dreamfactory/lego/core" + "go_dreamfactory/lego/sys/cron" "go_dreamfactory/lego/sys/log" "go_dreamfactory/modules/equipment" "go_dreamfactory/modules/hero" @@ -26,7 +27,9 @@ import ( "time" "github.com/golang/protobuf/ptypes" + "go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/bson/primitive" + "go.mongodb.org/mongo-driver/mongo/options" flag "github.com/spf13/pflag" ) @@ -71,8 +74,35 @@ func GetMonthStartEnd() (int64, int64) { fmt.Printf("%d,%d", _d1, _d2) return _d1, _d2 } -func Test_Main(t *testing.T) { +func TimerStar() { + //star := configure.Now() + if !db.IsCross() { + conn, err := db.Cross() + if err == nil { + model := db.NewDBModel(comm.TableSeasonData, 0, conn) + model.DB.DeleteMany(comm.TableSeasonPagoda, bson.M{}, options.Delete()) + model.DB.DeleteMany(comm.TableSeasonRecord, bson.M{}, options.Delete()) + for pos := 0; pos < comm.MaxRankNum; pos++ { + key1 := fmt.Sprintf("pagodaList%d", pos) + if err := model.Redis.Delete(key1); err != nil { + log.Errorf("delete failed") + } + } + + if err := model.Redis.Delete("pagodaSeasonRank"); err != nil { + log.Errorf("delete failed") + } + } + + // DB.DeleteMany(comm.TableSeasonRecord, bson.M{}, options.Delete()) + + } + //this.module.Debugf("=====%d,", time.Since(star).Milliseconds()) +} + +func Test_Main(t *testing.T) { + cron.AddFunc("0 0 5 /* * ?", TimerStar) //每月第一天5点执行一次 sz := make([]string, 0) for i := 0; i < 10; i++ { sz = append(sz, "1") diff --git a/modules/hero/module.go b/modules/hero/module.go index d5371c5af..0999779ac 100644 --- a/modules/hero/module.go +++ b/modules/hero/module.go @@ -96,9 +96,9 @@ func (this *Hero) createRepeatHero(session comm.IUserSession, heroCfgId string, cfg := this.configure.GetHeroConfig(heroCfgId) if cfg != nil { var szTask []*comm.TaskParam - szTask = append(szTask, comm.GettaskParam(comm.Rtype1, utils.ToInt32(heroCfgId))) - szTask = append(szTask, comm.GettaskParam(comm.Rtype30, cfg.Color)) - szTask = append(szTask, comm.GettaskParam(comm.Rtype31, cfg.Color)) + szTask = append(szTask, comm.GettaskParam(comm.Rtype1, 1, utils.ToInt32(heroCfgId))) + szTask = append(szTask, comm.GettaskParam(comm.Rtype30, 1, cfg.Color)) + szTask = append(szTask, comm.GettaskParam(comm.Rtype31, 1, cfg.Color)) go this.ModuleRtask.TriggerTask(session.GetUserId(), szTask...) }