diff --git a/super_cloud_issuance/svc/svc_deal_call_back.go b/super_cloud_issuance/svc/svc_deal_call_back.go index 75a2ca7..4e0f694 100644 --- a/super_cloud_issuance/svc/svc_deal_call_back.go +++ b/super_cloud_issuance/svc/svc_deal_call_back.go @@ -11,6 +11,7 @@ import ( "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils/cache" "code.fnuoos.com/go_rely_warehouse/zyos_model.git/src/implement" "code.fnuoos.com/go_rely_warehouse/zyos_model.git/src/models" + "errors" "fmt" "github.com/gin-gonic/gin" "time" @@ -222,6 +223,18 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi cache.NewRedis(cfg.RedisAddr) for _, superCloudIssuanceUserRobotBindSourceFollowGroup := range superCloudIssuanceUserRobotBindSourceFollowGroups { + group, err := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) + if err != nil { + fmt.Println("DealSourceGroupMessage_Err:::::", err.Error()) + return err + } + if group == nil { + fmt.Println("DealSourceGroupMessage_Err:::::", "未查询到激活群记录") + return errors.New("未查询到激活群记录") + } + if group.State != 1 { + continue + } //转链 if superCloudIssuanceUserRobotBindSourceFollowGroup.Uid > 0 { args := map[string]string{ @@ -267,6 +280,19 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi } for _, superCloudIssuanceUserRobotBindSourceFollowGroup := range superCloudIssuanceUserRobotBindSourceFollowGroups { + group, err := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) + if err != nil { + fmt.Println("DealSourceGroupMessage_Err:::::", err.Error()) + return err + } + if group == nil { + fmt.Println("DealSourceGroupMessage_Err:::::", "未查询到激活群记录") + return errors.New("未查询到激活群记录") + } + if group.State != 1 { + continue + } + superCloudIssuanceUserRobotDb := implement.NewSuperCloudIssuanceUserRobotDb(engine, superCloudIssuanceUserRobotBindSourceFollowGroup.Uid, dealSuperCloudIssuanceCallBackService.Context.GetString("mid")) robot, _ := superCloudIssuanceUserRobotDb.GetSuperCloudIssuanceUserRobot() if robot != nil { @@ -293,6 +319,19 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi return err } for _, superCloudIssuanceUserRobotBindSourceFollowGroup := range superCloudIssuanceUserRobotBindSourceFollowGroups { + group, err := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) + if err != nil { + fmt.Println("DealSourceGroupMessage_Err:::::", err.Error()) + return err + } + if group == nil { + fmt.Println("DealSourceGroupMessage_Err:::::", "未查询到激活群记录") + return errors.New("未查询到激活群记录") + } + if group.State != 1 { + continue + } + superCloudIssuanceUserRobotDb := implement.NewSuperCloudIssuanceUserRobotDb(engine, superCloudIssuanceUserRobotBindSourceFollowGroup.Uid, dealSuperCloudIssuanceCallBackService.Context.GetString("mid")) robot, _ := superCloudIssuanceUserRobotDb.GetSuperCloudIssuanceUserRobot() if robot != nil {