|
@@ -146,7 +146,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- condition = ` AND p.modify_time > ` + "'" + updateTime + "'"
|
|
|
+ condition = ` AND p.is_suspend = 0 AND p.modify_time > ` + "'" + updateTime + "'"
|
|
|
companyIds = strings.TrimRight(companyIds, ",")
|
|
|
|
|
|
fmt.Println("获取冻结跟流失的用户", len(listFreezeAndLoss))
|
|
@@ -165,7 +165,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
|
|
|
//原有的公司如果新增了也同步
|
|
|
companyIds = strings.TrimRight(companyIds, ",")
|
|
|
if companyIds != "" {
|
|
|
- condition = ` AND c.company_id IN (` + companyIds + ")"
|
|
|
+ condition = ` AND p.is_suspend = 0 AND c.company_id IN (` + companyIds + ")"
|
|
|
DotongbuShangHaApi(condition)
|
|
|
}
|
|
|
|