|
@@ -1,8 +1,6 @@
|
|
|
package cron_controller
|
|
package cron_controller
|
|
|
|
|
|
|
|
import (
|
|
import (
|
|
|
- "fohow.com/apps/models/project_model"
|
|
|
|
|
- "fohow.com/apps/models/share_model"
|
|
|
|
|
"fohow.com/apps/models/user_model"
|
|
"fohow.com/apps/models/user_model"
|
|
|
"github.com/astaxie/beego"
|
|
"github.com/astaxie/beego"
|
|
|
"github.com/astaxie/beego/orm"
|
|
"github.com/astaxie/beego/orm"
|
|
@@ -71,85 +69,4 @@ func updateUserNicknameAndHead() {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-/*
|
|
|
|
|
-团购有支付成功的投资记录
|
|
|
|
|
-邀请佣金管理有记录的
|
|
|
|
|
-分享情况管理,有分享记录的
|
|
|
|
|
-给他们开通微信推广模块
|
|
|
|
|
-*/
|
|
|
|
|
-func updateWxUserShowInviteMode() {
|
|
|
|
|
-
|
|
|
|
|
- //查找真实投资人
|
|
|
|
|
- var list1 []*project_model.ProjectJoin
|
|
|
|
|
- sql1 := `
|
|
|
|
|
- select *
|
|
|
|
|
- FROM project_joins
|
|
|
|
|
- where state= 1
|
|
|
|
|
- and is_deleted= 0
|
|
|
|
|
- and is_refunded= 0
|
|
|
|
|
- GROUP BY user_id ;
|
|
|
|
|
- `
|
|
|
|
|
-
|
|
|
|
|
- _, err1 := orm.NewOrm().Raw(sql1).QueryRows(&list1)
|
|
|
|
|
-
|
|
|
|
|
- if err1 != nil {
|
|
|
|
|
- beego.Debug("GetProjectUsers err=[%s]", err1)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- for _, item := range list1 {
|
|
|
|
|
-
|
|
|
|
|
- wxUser := user_model.GetWxUserByUserId(item.UserId, true)
|
|
|
|
|
- if wxUser != nil && wxUser.ShowInviteMode != 1 {
|
|
|
|
|
- wxUser.ShowInviteMode = int64(1)
|
|
|
|
|
- wxUser.Save()
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- //邀请佣金管理有记录的
|
|
|
|
|
- var list2 []*user_model.InviteOrder
|
|
|
|
|
- sql2 := `
|
|
|
|
|
- select *
|
|
|
|
|
- from invite_benefit_orders
|
|
|
|
|
- where source!= 'binding'
|
|
|
|
|
- GROUP BY benefit_wx_uid ;
|
|
|
|
|
- `
|
|
|
|
|
- _, err2 := orm.NewOrm().Raw(sql2).QueryRows(&list2)
|
|
|
|
|
- if err2 != nil {
|
|
|
|
|
- beego.Debug("GetInviteOrderUsers err=[%s]", err2)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- for _, item := range list2 {
|
|
|
|
|
-
|
|
|
|
|
- wxUser := user_model.GetWxUserById(item.BenefitWxUId, true)
|
|
|
|
|
-
|
|
|
|
|
- if wxUser != nil && wxUser.ShowInviteMode != 1 {
|
|
|
|
|
- wxUser.ShowInviteMode = int64(1)
|
|
|
|
|
- wxUser.Save()
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- //分享情况
|
|
|
|
|
- var list3 []*share_model.ShareInfo
|
|
|
|
|
- sql3 := `
|
|
|
|
|
- select *
|
|
|
|
|
- from share_infos
|
|
|
|
|
- GROUP BY wx_user_id ;
|
|
|
|
|
- `
|
|
|
|
|
- _, err3 := orm.NewOrm().Raw(sql3).QueryRows(&list3)
|
|
|
|
|
- if err3 != nil {
|
|
|
|
|
- beego.Debug("GetInviteOrderUsers err=[%s]", err3)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- for _, item := range list3 {
|
|
|
|
|
-
|
|
|
|
|
- wxUser := user_model.GetWxUserById(item.WxUserId, true)
|
|
|
|
|
- if wxUser != nil && wxUser.ShowInviteMode != 1 {
|
|
|
|
|
- wxUser.ShowInviteMode = int64(1)
|
|
|
|
|
- wxUser.Save()
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
}
|
|
}
|