|
|
@@ -87,7 +87,7 @@ func (jm *JobManager) LoadAgainSubUser() {
|
|
|
// @Description 过滤订单 筛选活动注册用户
|
|
|
// @Date 2024/11/18
|
|
|
func loadOrder() {
|
|
|
- sql := `SELECT id, filter, order_code, product_type, user_id, user_phone FROM dataexport_order WHERE id > ? AND order_status = 1 ORDER BY id ASC`
|
|
|
+ sql := `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM dataexport_order WHERE id > ? AND order_status = 1 ORDER BY id ASC`
|
|
|
res, err := g.DB("jianyu").Query(ctx, sql, LastId)
|
|
|
if err == nil && !res.IsEmpty() {
|
|
|
for _, m := range res.List() {
|
|
|
@@ -131,7 +131,7 @@ func loadOrder() {
|
|
|
}
|
|
|
|
|
|
func LoadOrderOther() {
|
|
|
- sql := `SELECT id, filter, order_code, product_type, user_id, user_phone FROM dataexport_order WHERE vip_endtime > ? AND vip_endtime < ? AND order_status = 1 AND (filter LIKE '%邀请好友成功%' OR filter LIKE '%被邀请注册成功%' OR filter LIKE '%2024年新用户注册赠送7天超级订阅%') ORDER BY id ASC`
|
|
|
+ sql := `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM dataexport_order WHERE vip_endtime > ? AND vip_endtime < ? AND order_status = 1 AND (filter LIKE '%邀请好友成功%' OR filter LIKE '%被邀请注册成功%' OR filter LIKE '%2024年新用户注册赠送7天超级订阅%') ORDER BY id ASC`
|
|
|
sql1 := `SELECT count(1) FROM dataexport_order WHERE vip_endtime > ? AND vip_endtime < ? AND order_status = 1 AND (filter LIKE '%邀请好友成功%' OR filter LIKE '%被邀请注册成功%' OR filter LIKE '%2024年新用户注册赠送7天超级订阅%')`
|
|
|
sql2 := `SELECT id, vip_endtime FROM jianyu.dataexport_order WHERE (product_type = 'VIP订阅' OR product_type = '大会员') AND id > ? AND user_id = ? AND order_status = 1`
|
|
|
now := time.Now().Format(time.DateTime)
|
|
|
@@ -164,7 +164,7 @@ func verifyDate(v int64) bool {
|
|
|
// @Date 2024/11/19
|
|
|
func LoadOrderHis() {
|
|
|
g.Log().Infof(ctx, "LoadOrderHis start")
|
|
|
- sql := `SELECT id, filter, order_code, product_type, user_id, user_phone FROM dataexport_order WHERE id <= ? AND order_status = 1 AND filter LIKE '%邀请好友成功%' ORDER BY id DESC`
|
|
|
+ sql := `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM dataexport_order WHERE id <= ? AND order_status = 1 AND filter LIKE '%邀请好友成功%' ORDER BY id DESC`
|
|
|
res, err := g.DB("jianyu").Query(ctx, sql, LastId)
|
|
|
if err == nil && !res.IsEmpty() {
|
|
|
for _, m := range res.List() {
|
WH01243