first

models/english_report_email.go

@@ -0,0 +1,63 @@
+package models
+
+import (
+	"github.com/beego/beego/v2/client/orm"
+	"hongze/hongze_task/utils"
+	"time"
+)
+
+// EnglishReportEmail 英文研报-邮箱/客户联系人
+type EnglishReportEmail struct {
+	Id              int       `orm:"column(id);pk" description:"邮箱ID"`
+	CompanyId       int       `description:"客户ID"`
+	Name            string    `description:"联系人名称"`
+	Email           string    `description:"邮箱地址"`
+	Mobile          string    `description:"手机号"`
+	CountryCode     string    `description:"区号，86、852、886等"`
+	BusinessCardUrl string    `description:"名片"`
+	ViewTotal       int       `description:"累计点击量/阅读量"`
+	LastViewTime    time.Time `description:"最后阅读时间"`
+	IsDeleted       int       `description:"删除状态：0-正常；1-已删除"`
+	Enabled         int       `description:"邮箱状态：1:有效，0:禁用"`
+	AdminId         int       `description:"创建人ID"`
+	AdminName       string    `description:"创建人姓名"`
+	Status          int       `description:"1:正式,2:临时,3:终止"`
+	CompanyName     string    `description:"公司名称"`
+	CreateTime      time.Time `description:"创建时间"`
+	ModifyTime      time.Time `description:"更新时间"`
+	RegisterTime    time.Time `description:"注册时间"`
+}
+
+func (item *EnglishReportEmail) TableName() string {
+	return "english_report_email"
+}
+
+func (item *EnglishReportEmail) Create() (err error) {
+	o := orm.NewOrmUsingDB("rddp")
+	id, err := o.Insert(item)
+	if err != nil {
+		return
+	}
+	item.Id = int(id)
+	return
+}
+
+func (item *EnglishReportEmail) Update(cols []string) (err error) {
+	o := orm.NewOrmUsingDB("rddp")
+	_, err = o.Update(item, cols...)
+	return
+}
+
+func GetEndEnglishReportEmailListByDate(endDate string) (items []*EnglishReportEmail, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM english_report_email WHERE register_time < '`+endDate+`'  `
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}
+
+func UpdateEnglishReportEmailTermination(disableIds []int) (err error) {
+	o := orm.NewOrm()
+	sql := `UPDATE english_report_email SET status = 3 WHERE id IN (` + utils.GetOrmInReplace(len(disableIds)) + `) `
+	_, err = o.Raw(sql, disableIds, ).Exec()
+	return
+}

services/english_report_email.go

@@ -0,0 +1,40 @@
+package services
+
+import (
+	"context"
+	"fmt"
+	"hongze/hongze_task/models"
+	"hongze/hongze_task/utils"
+	"time"
+)
+
+//英文研报客户 临时->终止
+func EnglishReportEmailTermination(cont context.Context) (err error) {
+	defer func() {
+		if err != nil {
+			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "英文研报客户 临时->终止 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
+		}
+	}()
+
+	expiredTime := time.Now().AddDate(0, 0, -31).Format(utils.FormatDate)
+
+	items, err := models.GetEndEnglishReportEmailListByDate(expiredTime)
+	if err != nil && err.Error() != utils.ErrNoRow() {
+		fmt.Println("GetEndEnglishReportEmailListByDate Err:" + err.Error())
+		utils.FileLog.Info("GetEndEnglishReportEmailListByDate Err:%s" + err.Error())
+		return
+	}
+	disableIds := make([]int, 0)
+	for _, v := range items {
+		disableIds = append(disableIds, v.Id)
+	}
+
+	if len(disableIds) > 0 {
+		err = models.UpdateEnglishReportEmailTermination(disableIds)
+		if err != nil {
+			return err
+		}
+	}
+
+	return
+}

services/task.go

@@ -134,6 +134,10 @@ func Task() {
 	eTATrialDisabled := task.NewTask("eTATrialDisabled", "0 15 2 * * *", ETATrialDisabled)
 	task.AddTask("ETA试用客户 启用->禁用", eTATrialDisabled)
 
+	//英文研报客户 临时->终止
+	englishReportEmailTermination := task.NewTask("englishReportEmailTermination", "0 15 3 * * *", EnglishReportEmailTermination)
+	task.AddTask("英文研报客户 临时->终止", englishReportEmailTermination)
+
 	task.StartTask()
 
 	fmt.Println("task end")