no message

models/company_no_renewed_ascribe.go

@@ -0,0 +1,13 @@
+package models
+
+import (
+	"github.com/beego/beego/v2/client/orm"
+)
+
+// 删除数据
+func DeleteCompanNoRenewedAscribe(companyId , productId int) (err error) {
+	o := orm.NewOrm()
+	sql := ` DELETE FROM company_no_renewed_ascribe WHERE company_id = ? AND product_id = ? `
+	_, err = o.Raw(sql, companyId,productId).Exec()
+	return
+}

services/company/company_ascribe.go

@@ -0,0 +1,20 @@
+package company
+
+import (
+	"fmt"
+	"hongze/hongze_task/models"
+	"hongze/hongze_task/services/alarm_msg"
+)
+
+// 正式转试用，删除不续约归因内容
+func DeleteCompanNoRenewedAscribe(companyId ,productId int) () {
+	var err error
+	defer func() {
+		if err != nil {
+			msg := fmt.Sprint("companyId:", companyId,"productId:", productId)
+			go alarm_msg.SendAlarmMsg("正式转试用，删除不续约归因内容失败："+err.Error()+msg, 2)
+		}
+	}()
+	err = models.DeleteCompanNoRenewedAscribe(companyId,productId)
+	return
+}

services/company_product.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"hongze/hongze_task/models"
+	"hongze/hongze_task/services/company"
 	"hongze/hongze_task/services/cygx"
 	"hongze/hongze_task/utils"
 	"strconv"
@@ -145,6 +146,11 @@ func CompanyTryOut(cont context.Context) (err error) {
 			}
 		}
 
+		{
+			//正式转试用，删除不续约归因内容
+			company.DeleteCompanNoRenewedAscribe(v.CompanyId, v.ProductId)
+		}
+
 		//正式转试用定时任务更新研选扣点
 		{
 			cygx.YanXuanCompanyCompanyTryOut(v.CompanyId)