|
@@ -123,7 +123,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
|
|
|
companyIds += strconv.Itoa(v.CompanyId) + ","
|
|
|
}
|
|
|
}
|
|
|
- ////获取冻结跟流失的用户
|
|
|
+ ////获取冻结跟流失的客户
|
|
|
listFreezeAndLoss, err := models.GetCompanyFreezeAndLoss(updateTime)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
return err
|
|
@@ -133,6 +133,19 @@ func DotongbuShangHai(cont context.Context) (err error) {
|
|
|
companyIds += strconv.Itoa(v.CompanyId) + ","
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ listDeleteUser, err := models.GetWxUserOpLogDelete(updateTime)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ ////获取删除客户
|
|
|
+ if len(listDeleteUser) > 0 {
|
|
|
+ for _, v := range listDeleteUser {
|
|
|
+ companyIds += strconv.Itoa(v.CompanyId) + ","
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
condition = ` AND p.modify_time > ` + "'" + updateTime + "'"
|
|
|
companyIds = strings.TrimRight(companyIds, ",")
|
|
|
|