|
@@ -12,23 +12,13 @@ import (
|
|
|
"workTasks/userSign/userTag"
|
|
"workTasks/userSign/userTag"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
-func main1() {
|
|
|
|
|
- ctx := gctx.New()
|
|
|
|
|
- t := time.Unix(1738857600, 0)
|
|
|
|
|
- list, err := g.DB("subjectdb").Query(ctx, "SELECT position_id FROM dwd_f_crm_clue_change_record WHERE position_id!=-1 AND change_type='基本信息变更' AND new_value in ('意向客户','高意向客户','待签署客户') AND createtime>?", t.Format("2006-01-02 15:04:05"))
|
|
|
|
|
- if err != nil {
|
|
|
|
|
- panic(err)
|
|
|
|
|
- }
|
|
|
|
|
- g.Dump(list.Size())
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
func main() {
|
|
func main() {
|
|
|
ctx := gctx.New()
|
|
ctx := gctx.New()
|
|
|
- runOnce(context.TODO())
|
|
|
|
|
- if e := userTag.BaseUserTag(); e != nil {
|
|
|
|
|
- g.Log().Errorf(ctx, "BaseUserTag 异常", e)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
|
|
+ //runOnce(context.TODO())
|
|
|
|
|
+ //if e := userTag.BaseUserTag(); e != nil {
|
|
|
|
|
+ // g.Log().Errorf(ctx, "BaseUserTag 异常 %v", e)
|
|
|
|
|
+ //}
|
|
|
|
|
+ //g.Dump("FINISH")
|
|
|
_, err := gcron.Add(gctx.New(), g.Cfg().MustGet(ctx, "runCron", "# 0 2 * * *").String(), func(ctx context.Context) {
|
|
_, err := gcron.Add(gctx.New(), g.Cfg().MustGet(ctx, "runCron", "# 0 2 * * *").String(), func(ctx context.Context) {
|
|
|
runOnce(context.TODO())
|
|
runOnce(context.TODO())
|
|
|
if e := userTag.BaseUserTag(); e != nil {
|
|
if e := userTag.BaseUserTag(); e != nil {
|
