This commit is contained in:
苏尹岚
2021-01-06 15:58:06 +08:00
parent 453c6a2e9c
commit c8827012b0

View File

@@ -304,11 +304,12 @@ func getStoreStatusCount(db *dao.DaoDB, cityCodes []int, vendorID, status int) (
countType := &struct{ Count int }{} countType := &struct{ Count int }{}
sqlParams := []interface{}{} sqlParams := []interface{}{}
sql := ` sql := `
SELECT COUNT(a.id) count SELECT COUNT(DISTINCT a.id) count
FROM store a FROM store a
LEFT JOIN store_map b ON a.id = b.store_id AND b.deleted_at = ? LEFT JOIN store_map b ON a.id = b.store_id AND b.deleted_at = ?
WHERE a.deleted_at = ?
` `
sqlParams = append(sqlParams, utils.DefaultTimeValue) sqlParams = append(sqlParams, utils.DefaultTimeValue, utils.DefaultTimeValue)
if len(cityCodes) > 0 { if len(cityCodes) > 0 {
sql += " AND a.city_code IN (" + dao.GenQuestionMarks(len(cityCodes)) + ")" sql += " AND a.city_code IN (" + dao.GenQuestionMarks(len(cityCodes)) + ")"
sqlParams = append(sqlParams, cityCodes) sqlParams = append(sqlParams, cityCodes)
@@ -320,13 +321,8 @@ func getStoreStatusCount(db *dao.DaoDB, cityCodes []int, vendorID, status int) (
sql += " AND a.status = ?" sql += " AND a.status = ?"
sqlParams = append(sqlParams, status) sqlParams = append(sqlParams, status)
} }
sql += `
WHERE a.deleted_at = ?
`
sqlParams = append(sqlParams, utils.DefaultTimeValue)
fmt.Println(sql) fmt.Println(sql)
fmt.Println(sqlParams) fmt.Println(sqlParams)
sqlParams = append(sqlParams, utils.DefaultTimeValue, utils.DefaultTimeValue)
err = dao.GetRow(db, &countType, sql, sqlParams) err = dao.GetRow(db, &countType, sql, sqlParams)
return countType.Count, err return countType.Count, err
} }