From 8c981d71b04795c0b83f63f4c8f4aff3dbd61adb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Wed, 6 Jan 2021 17:30:30 +0800 Subject: [PATCH] aa --- business/model/dao/dao_order.go | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/business/model/dao/dao_order.go b/business/model/dao/dao_order.go index f68ead8f8..09f903bdd 100644 --- a/business/model/dao/dao_order.go +++ b/business/model/dao/dao_order.go @@ -1,7 +1,6 @@ package dao import ( - "fmt" "time" "git.rosy.net.cn/baseapi/utils" @@ -235,7 +234,7 @@ func getFromSql(orderType, status int, alies string, userID string, pop int, cit } } if len(cityCodes) > 0 { - sql += ` AND a.city_code IN ` + GenQuestionMarks(len(cityCodes)) + `)` + sql += ` AND a.city_code IN (` + GenQuestionMarks(len(cityCodes)) + `)` sqlParams = append(sqlParams, cityCodes) } sql += `) ` + alies @@ -284,13 +283,11 @@ func GetPayStatistics(db *DaoDB, userID string, pop int, cityCodes []int, mobile } } if len(cityCodes) > 0 { - sql += ` AND a.city_code IN ` + GenQuestionMarks(len(cityCodes)) + `)` + sql += ` AND a.city_code IN (` + GenQuestionMarks(len(cityCodes)) + `)` sqlParams = append(sqlParams, cityCodes) } sql += ` ) t4` - fmt.Println(sql) - fmt.Println(sqlParams) err = GetRow(db, &getPayStatisticsResult, sql, sqlParams) sqlParams2 := []interface{}{} getPayStatisticsResult1 := &GetPayStatisticsResult{} @@ -324,7 +321,7 @@ func GetPayStatistics(db *DaoDB, userID string, pop int, cityCodes []int, mobile ` sqlParams2 = append(sqlParams2, model.UserStatusNormal, utils.DefaultTimeValue) if len(cityCodes) > 0 { - sql2 += ` AND a.city_code IN ` + GenQuestionMarks(len(cityCodes)) + `)` + sql2 += ` AND a.city_code IN (` + GenQuestionMarks(len(cityCodes)) + `)` sqlParams2 = append(sqlParams2, cityCodes) } if userID != "" { @@ -374,11 +371,11 @@ func getFromSqlManage(status int, alies string, cityCodes []int, jobTime, endTim sqlParams = append(sqlParams, endTime) } if len(cityCodes) > 0 { - sql += ` AND a.job_city_code IN ` + GenQuestionMarks(len(cityCodes)) + `)` + sql += ` AND a.job_city_code IN (` + GenQuestionMarks(len(cityCodes)) + `)` sqlParams = append(sqlParams, cityCodes) } if len(jobIDs) > 0 { - sql += ` AND a.id IN ` + GenQuestionMarks(len(jobIDs)) + `)` + sql += ` AND a.id IN (` + GenQuestionMarks(len(jobIDs)) + `)` sqlParams = append(sqlParams, jobIDs) } sql += ") " + alies @@ -395,11 +392,11 @@ func getWhereSqlManage(cityCodes []int, jobTime, endTime time.Time, jobIDs []int sqlParams = append(sqlParams, endTime) } if len(cityCodes) > 0 { - sql += ` AND a.job_city_code IN ` + GenQuestionMarks(len(cityCodes)) + `)` + sql += ` AND a.job_city_code IN (` + GenQuestionMarks(len(cityCodes)) + `)` sqlParams = append(sqlParams, cityCodes) } if len(jobIDs) > 0 { - sql += ` AND a.id IN ` + GenQuestionMarks(len(jobIDs)) + `)` + sql += ` AND a.id IN (` + GenQuestionMarks(len(jobIDs)) + `)` sqlParams = append(sqlParams, jobIDs) } return sql, sqlParams