|
@@ -202,7 +202,6 @@ func monitorMode2(ctx context.Context) {
|
|
}
|
|
}
|
|
rs := selectOrder2(num, rules.Products, rules.PriceLimit, rules.PriceStart, rules.PriceEnd, date.FormatDate(&activity.MembershipDay.T2, date.Date_Full_Layout), date.FormatDate(&activity.MembershipDay.Ed, date.Date_Full_Layout))
|
|
rs := selectOrder2(num, rules.Products, rules.PriceLimit, rules.PriceStart, rules.PriceEnd, date.FormatDate(&activity.MembershipDay.T2, date.Date_Full_Layout), date.FormatDate(&activity.MembershipDay.Ed, date.Date_Full_Layout))
|
|
if len(rs) == 0 {
|
|
if len(rs) == 0 {
|
|
- logger.Info("未查到", num)
|
|
|
|
break // 如果没有查询到 等待下一轮任务再查询
|
|
break // 如果没有查询到 等待下一轮任务再查询
|
|
}
|
|
}
|
|
logger.Info(num, "查到")
|
|
logger.Info(num, "查到")
|
|
@@ -275,7 +274,6 @@ LIMIT ?,1
|
|
|
|
|
|
// 查询活动期间指定支付顺序的订单
|
|
// 查询活动期间指定支付顺序的订单
|
|
func selectOrder2(num int, productType []string, priceLimit bool, priceStart, priceEnd int, startTime, endTime string) map[string]interface{} {
|
|
func selectOrder2(num int, productType []string, priceLimit bool, priceStart, priceEnd int, startTime, endTime string) map[string]interface{} {
|
|
- logger.Info(startTime, endTime, "==================")
|
|
|
|
var products []string
|
|
var products []string
|
|
var values []interface{}
|
|
var values []interface{}
|
|
productTypeStr := "" // 产品类型
|
|
productTypeStr := "" // 产品类型
|
|
@@ -315,7 +313,7 @@ WHERE order_status = 1 and pay_time >=? and pay_time<?` + productTypeStr +
|
|
if rs != nil && len(*rs) == 1 {
|
|
if rs != nil && len(*rs) == 1 {
|
|
return (*rs)[0]
|
|
return (*rs)[0]
|
|
}
|
|
}
|
|
- logger.Info("未查到", rs)
|
|
|
|
|
|
+ logger.Info(num, "未查到", rs)
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|