update

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 {