查研观向10.7

services/company_approval/company_approval.go

@@ -402,7 +402,6 @@ func Approved(approvalRecord *contract_approval_record.ContractApprovalRecord, o
 		// 客户单审批后的异步操作（修改客户单信息、修改合同权限等）
 		go func() {
 			_ = afterApproved(recordInfo.CompanyApprovalId, opUser.AdminId, opUser.RealName)
-
 			// 注意此处下面的处理原本都是各开了协程，现改为只在一个协程里处理，不然可能会导致数据还没完全更新，紧接着就被错误更新对应的数据
 			if recordInfo.ProductId == 2 && recordInfo.CompanyContractId > 0 {
 				//处理权益客户的身份信息
@@ -413,6 +412,8 @@ func Approved(approvalRecord *contract_approval_record.ContractApprovalRecord, o
 
 				//客户研选行业转正时(王芳审批通过)，模板消息提醒汪洋
 				services.AddCompanyApprovalMessageWangYang(recordInfo.CompanyId, recordInfo.CompanyContractId, recordInfo.ApplyRealName, companyInfo.CompanyName)
+
+				 cygxService.YanXuanCompanyApproval(recordInfo.CompanyId) //研选审批通过的时候研选扣点更新
 			}
 		}()
 	} else {

services/cygx/activity_points_set.go

@@ -0,0 +1,40 @@
+package cygxService
+
+import (
+	"fmt"
+	"hongze/hongze_mobile_admin/services/alarm_msg"
+	"hongze/hongze_mobile_admin/utils"
+	"time"
+)
+
+type YanXuanActivityPointsRedis struct {
+	UserId           int       `description:"用户ID"`
+	ComapnyId        int       `description:"公司ID"`
+	ActivityId       int       `description:"活动ID"`
+	PublishStatus    int       `description:"发布状态 1已发布，0未发布"`
+	SourceType       int       `description:"1：报名、 2：取消报名、3：活动编辑、4：活动发布，取消发布、5：活动到会、6 研选审批通过的时候研选扣点更新。"`
+	AdminId          int       `description:"管理员、销售ID"`
+	Source           int       `description:" 来源，1客户端，2后台添加, 3开发人员手动添加、4定时任务"`
+	RegisterPlatform int       `description:"来源 1小程序，2：网页"`
+	CreateTime       time.Time `description:"创建时间"`
+}
+
+// 6 研选审批通过的时候研选扣点更新
+func YanXuanCompanyApproval(comapnyId int) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			msg := fmt.Sprint("comapnyId:", comapnyId)
+			go alarm_msg.SendAlarmMsg("研选审批通过的时候研选扣点更新，写入Redis队列消息失败："+err.Error()+msg, 2)
+		}
+	}()
+	//SourceType int       `description:"1：报名、 2：取消报名、3：活动编辑、4：活动发布，取消发布、5：活动到会。6 研选审批通过的时候研选扣点更新。7,正式专试用定时任务更新"`
+	log := &YanXuanActivityPointsRedis{ComapnyId: comapnyId, SourceType: 6, Source: 2, CreateTime: time.Now()}
+	if utils.Re == nil {
+		err := utils.Rc.LPush(utils.CYGX_YANXUAN_POINTS_KEY, log)
+		if err != nil {
+			fmt.Println("YanXuanActivityPointsRedis LPush Err:" + err.Error())
+		}
+	}
+	return
+}

utils/constants.go

@@ -170,3 +170,8 @@ const (
 	CHART_PERMISSION_ID_45W            = 2002                // 权益45w大套餐表示的权限ID(自定义)
 	TPL_MSG_WANG_YANG                  = "tpl_msg_wang_yang" //汪洋手机号地址参数
 )
+
+const (
+	CYGX_YANXUAN_POINTS_KEY          string = "CYGX_YANXUAN_POINTS_KEY"                                       //查研观向研选活动扣点KEY
+)
+