|
|
@@ -134,7 +134,25 @@ func monitor(ctx context.Context) {
|
|
|
|
|
|
// 查订单表
|
|
|
func selectOrder(num int) map[string]interface{} {
|
|
|
- sql := "SELECT user_phone,user_id,pay_time FROM `dataexport_order` WHERE product_type in ('VIP订阅','大会员','数据流量包') and pay_time !=null and order_status = 1 and is_backstage_order=0 AND TO_DAYS(create_time) = to_days(now()) ORDER BY pay_time limit ?,1;"
|
|
|
+ sql := `SELECT
|
|
|
+ order_code,
|
|
|
+ user_phone,
|
|
|
+ user_id,
|
|
|
+ pay_time
|
|
|
+FROM
|
|
|
+ dataexport_order
|
|
|
+WHERE order_status = 1 and
|
|
|
+ product_type IN (
|
|
|
+ "VIP订阅",
|
|
|
+ "大会员",
|
|
|
+ "数据流量包"
|
|
|
+ )
|
|
|
+AND is_backstage_order = 0
|
|
|
+AND TO_DAYS(pay_time) = to_days(now())
|
|
|
+ORDER BY
|
|
|
+ pay_time
|
|
|
+LIMIT ?,1
|
|
|
+`
|
|
|
rs := db.Mysql.SelectBySql(sql, num-1)
|
|
|
if rs != nil && len(*rs) == 1 {
|
|
|
return (*rs)[0]
|
