|
@@ -80,7 +80,6 @@ func GetProjectList(req *types.ProjectListReq) (resultList []*ProjectEntry, hasN
|
|
|
isSqlPage = true // 是否sql分页
|
|
|
}
|
|
|
countSql, findSql := getQuerySql(req, isSqlPage, buyerArr, plist)
|
|
|
- logx.Info("countSql: ", countSql)
|
|
|
logx.Info("findSql: ", findSql)
|
|
|
rows, err := T.ClickhouseConn.Query(context.TODO(), findSql)
|
|
|
defer rows.Close()
|
|
@@ -257,7 +256,7 @@ func getQuerySql(req *types.ProjectListReq, isPage bool, buyerArr, plist []strin
|
|
|
querys = append(querys, arr...)
|
|
|
}
|
|
|
//过滤掉已中标的招标项目数据
|
|
|
- querys = append(querys, fmt.Sprintf(" a.project_status in (%s) ", "2,3,4"))
|
|
|
+ querys = append(querys, fmt.Sprintf(" a.project_bidstatus in (%s) ", "2,3,4"))
|
|
|
findSql = "select a.project_id, a.project_name, a.business_type, a.buyer, a.buyer_id, a.area, a.city, a.district, a.zbtime, a.endtime, a.project_money, a.info_id, a.information_id, a.info_ids "
|
|
|
if len(querys) > 0 {
|
|
|
countSql = fmt.Sprintf("select count(1) from %s a where %s ", "information.transaction_info", strings.Join(querys, " and "))
|