sql查询修改

clueSync/jobutil.go

@@ -1915,7 +1915,15 @@ func nextYearActivity() {
 		return
 	}
 	activityTimeEnd := cfg.ActivityTime
-	sql := fmt.Sprintf(`select * from jyactivities.lottery_user_account where create_time > "%s" order by  create_time asc`, activityTimeEnd)
+	sql := fmt.Sprintf(`SELECT
+							 a.*
+							FROM
+								jyactivities.lottery_user_account a  
+								INNER JOIN  jyactivities.lottery_prize_info b  on     a.create_time > "%s"  and  a.prize_id=b.id
+								INNER JOIN  jyactivities.prize_base_info c  on   c.name like "%s"  and b.pb_id=c.id
+							ORDER BY
+								a.create_time ASC
+`, activityTimeEnd, "%超级订阅%")
 	data := Mysql.SelectBySql(sql)
 	if data != nil && *data != nil && len(*data) > 0 {
 		for _, v := range *data {