|
@@ -769,7 +769,7 @@ func saleLeads() {
|
|
|
func userbase() {
|
|
func userbase() {
|
|
|
log.Println("userbase定时任务开始")
|
|
log.Println("userbase定时任务开始")
|
|
|
timeUnix := time.Now().Unix()
|
|
timeUnix := time.Now().Unix()
|
|
|
- selectTimeStart := time.Unix(timeUnix-1800, 0).Format("2006-01-02 15:04:05")
|
|
|
|
|
|
|
+ selectTimeStart := cfg.LastUserBindingTime
|
|
|
selectTimeEnd := time.Unix(timeUnix, 0).Format("2006-01-02 15:04:05")
|
|
selectTimeEnd := time.Unix(timeUnix, 0).Format("2006-01-02 15:04:05")
|
|
|
sql := fmt.Sprintf(`SELECT
|
|
sql := fmt.Sprintf(`SELECT
|
|
|
a.phone,b.uid,a.baseinfo_id,b.l_registedate,a.createtime,b.id,b.userid,b.rsource
|
|
a.phone,b.uid,a.baseinfo_id,b.l_registedate,a.createtime,b.id,b.userid,b.rsource
|
|
@@ -780,10 +780,9 @@ func userbase() {
|
|
|
and (b.s_platform != 'xcx' or b.s_sourceid='jyzbw' or b.s_platform is NULL)
|
|
and (b.s_platform != 'xcx' or b.s_sourceid='jyzbw' or b.s_platform is NULL)
|
|
|
AND a.phone = b.phone and a.baseinfo_id= b.uid and b.source ="0101"
|
|
AND a.phone = b.phone and a.baseinfo_id= b.uid and b.source ="0101"
|
|
|
and a.phone is not NULL
|
|
and a.phone is not NULL
|
|
|
- and a.createtime >="%s"
|
|
|
|
|
- and a.createtime <"%s"
|
|
|
|
|
|
|
+ and a.createtime >"%s"
|
|
|
and a.is_delete=1
|
|
and a.is_delete=1
|
|
|
- ORDER BY a.createtime `, selectTimeStart, selectTimeEnd)
|
|
|
|
|
|
|
+ ORDER BY a.createtime `, selectTimeStart)
|
|
|
data := TiDb.SelectBySql(sql)
|
|
data := TiDb.SelectBySql(sql)
|
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
|
for _, v := range *data {
|
|
for _, v := range *data {
|
|
@@ -799,10 +798,12 @@ func userbase() {
|
|
|
})
|
|
})
|
|
|
}
|
|
}
|
|
|
registedate := common.ObjToString(v["l_registedate"])
|
|
registedate := common.ObjToString(v["l_registedate"])
|
|
|
|
|
+
|
|
|
name := common.ObjToString(v["name"])
|
|
name := common.ObjToString(v["name"])
|
|
|
nowTime := time.Now().Format(date.Date_Full_Layout)
|
|
nowTime := time.Now().Format(date.Date_Full_Layout)
|
|
|
layout := "2006-01-02 15:04:05"
|
|
layout := "2006-01-02 15:04:05"
|
|
|
createtime := gconv.String(v["createtime"])
|
|
createtime := gconv.String(v["createtime"])
|
|
|
|
|
+ cfg.LastUserBindingTime = createtime
|
|
|
createtimeInt64, _ := time.Parse(layout, createtime)
|
|
createtimeInt64, _ := time.Parse(layout, createtime)
|
|
|
registedateInt64, _ := time.Parse(layout, registedate)
|
|
registedateInt64, _ := time.Parse(layout, registedate)
|
|
|
count := TiDb.CountBySql("select count(1) as count from dwd_f_crm_clue_info where uid = ?", uId)
|
|
count := TiDb.CountBySql("select count(1) as count from dwd_f_crm_clue_info where uid = ?", uId)
|
|
@@ -883,6 +884,7 @@ func userbase() {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ common.WriteSysConfig(&cfg)
|
|
|
log.Println("userbase定时任务结束")
|
|
log.Println("userbase定时任务结束")
|
|
|
}
|
|
}
|
|
|
|
|
|
