|
@@ -629,7 +629,18 @@ func ClueToDxTask() {
|
|
if data != nil && len(*data) > 0 {
|
|
if data != nil && len(*data) > 0 {
|
|
log.Println("企业下员工数:", gconv.Int(val["ent_id"]), len(*data))
|
|
log.Println("企业下员工数:", gconv.Int(val["ent_id"]), len(*data))
|
|
for _, vv := range *data {
|
|
for _, vv := range *data {
|
|
- childIds = append(childIds, gconv.String(vv["userid"]))
|
|
|
|
|
|
+ //判断员工是否有大会员权益
|
|
|
|
+ query := map[string]interface{}{
|
|
|
|
+ "uid": gconv.String(vv["uid"]),
|
|
|
|
+ "product_type": "大会员",
|
|
|
|
+ "equity_status": 1,
|
|
|
|
+ "user_type": 2,
|
|
|
|
+ "user_role": 1,
|
|
|
|
+ }
|
|
|
|
+ count := TiDb.Count("dwd_f_data_equity_info", query)
|
|
|
|
+ if count > 0 {
|
|
|
|
+ childIds = append(childIds, gconv.String(vv["userid"]))
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|