|
|
@@ -185,11 +185,16 @@ func LoadOrderHisMore() {
|
|
|
g.Log().Infof(ctx, "LoadOrderHisMore start")
|
|
|
now := time.Now().Format(time.DateTime)
|
|
|
sql := `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM dataexport_order WHERE order_status = 1 AND vip_endtime > '2024-11-16 00:00:00' AND vip_endtime < ? AND filter LIKE '%2024年新用户注册赠送7天超级订阅%' ORDER BY id DESC`
|
|
|
+ sql1 := `SELECT id, vip_endtime FROM jianyu.dataexport_order WHERE (product_type = 'VIP订阅' OR product_type = '大会员') AND id > ? AND user_id = ? AND order_status = 1`
|
|
|
res, err := g.DB("jianyu").Query(ctx, sql, now)
|
|
|
if err == nil && !res.IsEmpty() {
|
|
|
for _, m := range res.List() {
|
|
|
+ id := gconv.Int64(m["id"])
|
|
|
userid := gconv.String(m["user_id"])
|
|
|
- g.DB("bi_service").Exec(ctx, `INSERT INTO user_statistics (userId, createTime, event) SELECT ?, ?, 3 WHERE NOT EXISTS ( SELECT 1 FROM user_statistics WHERE userId = ? AND event = 3)`, userid, now, userid)
|
|
|
+ res1, err := g.DB("jianyu").Query(ctx, sql1, id, userid)
|
|
|
+ if err == nil && res1.IsEmpty() {
|
|
|
+ g.DB("bi_service").Exec(ctx, `INSERT INTO user_statistics (userId, createTime, event) SELECT ?, ?, 3 WHERE NOT EXISTS ( SELECT 1 FROM user_statistics WHERE userId = ? AND event = 3)`, userid, now, userid)
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
g.Log().Infof(ctx, "LoadOrderHisMore end")
|
