|
@@ -151,7 +151,7 @@ func (n *network) Associate(in *types.AssociateReq) (reply *types.Reply) {
|
|
wh, newArgs := NetworkCom.WhArgs(probusfors)
|
|
wh, newArgs := NetworkCom.WhArgs(probusfors)
|
|
args = append(args, newArgs...)
|
|
args = append(args, newArgs...)
|
|
q := `select DISTINCT b.winner_id,b.winner from information.transaction_info a
|
|
q := `select DISTINCT b.winner_id,b.winner from information.transaction_info a
|
|
- inner join information.transaction_info b on (has(a.winner, ?) and a.buyer_id<>'' and a.buyer_id=b.buyer_id and hasAny(b.property_form,[` + wh + `])) ORDER BY b.project_id`
|
|
|
|
|
|
+ inner join information.transaction_info b on (has(a.winner, ?) and a.buyer_id<>'' and a.buyer_id=b.buyer_id and hasAny(b.property_form,[` + wh + `])=0) ORDER BY b.project_id`
|
|
rows, err := ClickhouseConn.Query(context.Background(), q, args...)
|
|
rows, err := ClickhouseConn.Query(context.Background(), q, args...)
|
|
if err != nil {
|
|
if err != nil {
|
|
logx.Error(err)
|
|
logx.Error(err)
|