|
|
@@ -223,10 +223,10 @@ 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 |
|
|
|
group, err1 := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) |
|
|
|
if err1 != nil { |
|
|
|
fmt.Println("DealSourceGroupMessage_Err:::::", err1.Error()) |
|
|
|
return err1 |
|
|
|
} |
|
|
|
if group == nil { |
|
|
|
fmt.Println("DealSourceGroupMessage_Err:::::", "未查询到激活群记录") |
|
|
@@ -256,14 +256,14 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi |
|
|
|
robot, _ := superCloudIssuanceUserRobotDb.GetSuperCloudIssuanceUserRobot() |
|
|
|
if robot != nil { |
|
|
|
cloudIssuanceService.Set(nil, enum.RobotMacSendTextMethodName, "127.0.0.1") |
|
|
|
err = cloudIssuanceService.RobotMacSendText(md.RobotMacSendTextRequest{ |
|
|
|
err2 := cloudIssuanceService.RobotMacSendText(md.RobotMacSendTextRequest{ |
|
|
|
RobotId: robot.RobotId, |
|
|
|
WxId: superCloudIssuanceUserRobotBindSourceFollowGroup.FollowChatRoomId, |
|
|
|
Content: req.Data.Content, |
|
|
|
}) |
|
|
|
if err != nil { |
|
|
|
fmt.Println("DealCallBack_err::::", err.Error()) |
|
|
|
return |
|
|
|
if err2 != nil { |
|
|
|
fmt.Println("DealCallBack_err::::", err2.Error()) |
|
|
|
return err2 |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
@@ -280,10 +280,10 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi |
|
|
|
} |
|
|
|
|
|
|
|
for _, superCloudIssuanceUserRobotBindSourceFollowGroup := range superCloudIssuanceUserRobotBindSourceFollowGroups { |
|
|
|
group, err := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) |
|
|
|
if err != nil { |
|
|
|
fmt.Println("DealSourceGroupMessage_Err:::::", err.Error()) |
|
|
|
return err |
|
|
|
group, err4 := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) |
|
|
|
if err4 != nil { |
|
|
|
fmt.Println("DealSourceGroupMessage_Err:::::", err4.Error()) |
|
|
|
return err4 |
|
|
|
} |
|
|
|
if group == nil { |
|
|
|
fmt.Println("DealSourceGroupMessage_Err:::::", "未查询到激活群记录") |
|
|
@@ -297,13 +297,13 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi |
|
|
|
robot, _ := superCloudIssuanceUserRobotDb.GetSuperCloudIssuanceUserRobot() |
|
|
|
if robot != nil { |
|
|
|
cloudIssuanceService.Set(nil, enum.RobotMacSendRecvImageMethodName, "127.0.0.1") |
|
|
|
err = cloudIssuanceService.RobotMacSendRecvImage(md.RobotMacSendRecvImageRequest{ |
|
|
|
err3 := cloudIssuanceService.RobotMacSendRecvImage(md.RobotMacSendRecvImageRequest{ |
|
|
|
RobotId: robot.RobotId, |
|
|
|
WxId: superCloudIssuanceUserRobotBindSourceFollowGroup.FollowChatRoomId, |
|
|
|
Content: req.Data.Content, |
|
|
|
}) |
|
|
|
if err != nil { |
|
|
|
fmt.Println("DealCallBack_err::::", err.Error()) |
|
|
|
if err3 != nil { |
|
|
|
fmt.Println("DealCallBack_err::::", err3.Error()) |
|
|
|
return |
|
|
|
} |
|
|
|
} |
|
|
@@ -319,9 +319,9 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi |
|
|
|
return err |
|
|
|
} |
|
|
|
for _, superCloudIssuanceUserRobotBindSourceFollowGroup := range superCloudIssuanceUserRobotBindSourceFollowGroups { |
|
|
|
group, err := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) |
|
|
|
if err != nil { |
|
|
|
fmt.Println("DealSourceGroupMessage_Err:::::", err.Error()) |
|
|
|
group, err6 := superCloudIssuanceUserRobotWithActivateGroupDb.GetSuperCloudIssuanceUserRobotWithActivateGroup(superCloudIssuanceUserRobotBindSourceFollowGroup.ActivateGroupId) |
|
|
|
if err6 != nil { |
|
|
|
fmt.Println("DealSourceGroupMessage_Err:::::", err6.Error()) |
|
|
|
return err |
|
|
|
} |
|
|
|
if group == nil { |
|
|
@@ -336,13 +336,13 @@ func (dealSuperCloudIssuanceCallBackService *DealSuperCloudIssuanceCallBackServi |
|
|
|
robot, _ := superCloudIssuanceUserRobotDb.GetSuperCloudIssuanceUserRobot() |
|
|
|
if robot != nil { |
|
|
|
cloudIssuanceService.Set(nil, enum.RobotMacSendRecvViedoMethodName, "127.0.0.1") |
|
|
|
err = cloudIssuanceService.RobotMacSendRecvVideo(md.RobotMacSendRecvVideoRequest{ |
|
|
|
err5 := cloudIssuanceService.RobotMacSendRecvVideo(md.RobotMacSendRecvVideoRequest{ |
|
|
|
RobotId: robot.RobotId, |
|
|
|
WxId: superCloudIssuanceUserRobotBindSourceFollowGroup.FollowChatRoomId, |
|
|
|
Content: req.Data.Content, |
|
|
|
}) |
|
|
|
if err != nil { |
|
|
|
fmt.Println("DealCallBack_err::::", err.Error()) |
|
|
|
if err5 != nil { |
|
|
|
fmt.Println("DealCallBack_err::::", err5.Error()) |
|
|
|
return |
|
|
|
} |
|
|
|
} |
|
|
|