研选扣点，提交时间早于合同生效时间的bug处理

services/company_contract/company_contract.go

@@ -9,6 +9,7 @@ import (
 	"hongze/hongze_task/models/company_approval"
 	"hongze/hongze_task/models/company_contract"
 	"hongze/hongze_task/services/alarm_msg"
+	"hongze/hongze_task/services/cygx"
 	"hongze/hongze_task/utils"
 	"strings"
 	"time"
@@ -124,6 +125,11 @@ func HandleCompanyContract(cont context.Context) (err error) {
 			}
 			go models.AddCompanyProductUpdateLog(companyProductUpdateLog)
 		}
+
+		//研选审批通过的时候研选扣点更新
+		{
+			cygx.YanXuanCompanyApproval(v.CompanyId)
+		}
 	}
 
 	//错误信息，批量返回错误信息

services/cygx/activity_points_set.go

@@ -29,6 +29,27 @@ type YanXuanActivityPointsRedis struct {
 //	}
 //}
 
+// 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
+}
+
+
 // 7 正式专试用定时任务更新研选扣点
 func YanXuanCompanyCompanyTryOut(comapnyId int) (err error) {
 	defer func() {