上海策略品台同步名单返回结果邮件发送

models/shanghai_company_log.go

@@ -42,3 +42,11 @@ func GetCygxShanghaiCompanyLog() (items []*CygxShanghaiCompanyLog, err error) {
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }
+
+//三十天之后的日志自行删除
+func DeleteCygxShanghaiCompanyLog() (err error) {
+	o := orm.NewOrm()
+	sql := `DELETE FROM cygx_shanghai_company_log WHERE  DATE_SUB(CURDATE(), INTERVAL 30 DAY) > date(create_time)`
+	_, err = o.Raw(sql).Exec()
+	return
+}

services/send_company_user.go

@@ -388,5 +388,6 @@ func DotongbuShangHaiSendEmail(cont context.Context) (err error) {
 		utils.SendEmailByHongze(title, content, "cxzhang@hzinsights.com;tshen@hzinsights.com", fileName, title+".xlsx")
 	}
 	os.Remove(downLoadnFilePath)
+	go models.DeleteCygxShanghaiCompanyLog()
 	return
 }

services/task.go

@@ -68,7 +68,7 @@ func Task() {
 	//GetAddpArticle() //同步日度点评数据
 	//SendEmailAllUserWithRAI()     //发送当前所有权益用户到沈大爷的邮箱
 	//SendEmailAllUserWithCompany() //发送这些公司下的用户到沈大爷的邮箱
-	//task.StartTask()
+	task.StartTask()
 	//StatisticalReport()//导出报表
 	fmt.Println("end")
 }