Merge branch 'crm/5.3'

cache/report_cache.go

@@ -0,0 +1,39 @@
+package cache
+
+import (
+	"fmt"
+	"hongze/hongze_api/models"
+	"hongze/hongze_api/utils"
+)
+
+// UserViewRedisData 阅读数据
+type UserViewRedisData struct {
+	Mobile      string `json:"mobile"`
+	Email       string `json:"email"`
+	RealName    string `json:"real_name"`
+	CompanyName string `json:"company_name"`
+	ViewTime    string `json:"view_time" description:"阅读时间，格式：2022-02-17 13:06:13"`
+	ProductId   int    `json:"product_id" description:"报告所属产品，ficc：1，权益：2"`
+	CompanyId   int    `json:"company_id" description:"客户id"`
+}
+
+// PushViewRecordNewRedisData 阅读数据加入到redis
+func PushViewRecordNewRedisData(reportViewRecord *models.ReportViewRecord, companyId int) bool {
+	data := &UserViewRedisData{
+		Mobile:      reportViewRecord.Mobile,
+		Email:       reportViewRecord.Email,
+		RealName:    reportViewRecord.RealName,
+		CompanyName: reportViewRecord.CompanyName,
+		ViewTime:    reportViewRecord.CreateTime.Format(utils.FormatDateTime),
+		ProductId:   1,
+		CompanyId:   companyId,
+	}
+	if utils.Re == nil {
+		err := utils.Rc.LPush(utils.CACHE_KEY_USER_VIEW, data)
+		if err != nil {
+			fmt.Println("PushViewRecordNewRedisData LPush Err:" + err.Error())
+		}
+		return true
+	}
+	return false
+}

controllers/report.go

@@ -2,6 +2,7 @@ package controllers
 
 import (
 	"encoding/json"
+	"hongze/hongze_api/cache"
 	"hongze/hongze_api/models"
 	"hongze/hongze_api/services"
 	"hongze/hongze_api/utils"
@@ -210,6 +211,10 @@ func (this *ReportController) Detail() {
 		if err != nil {
 			go utils.SendEmail(utils.APPNAME+"失败提醒", "新增报告阅读记录失败：Err:"+err.Error(), utils.EmailSendToUsers)
 		}
+
+		// 添加阅读日志的数据加入到redis
+		go cache.PushViewRecordNewRedisData(record, user.CompanyId)
+
 		//修改联系人最后一次阅读报告时间
 		go models.SetWxUserReportLastViewTime(user.UserId)
 	}
@@ -517,6 +522,10 @@ func (this *ReportController) AddViewRecordReport() {
 		br.ErrMsg = "获取数据失败,Err:" + err.Error()
 		return
 	}
+
+	// 添加阅读日志的数据加入到redis
+	go cache.PushViewRecordNewRedisData(record, user.CompanyId)
+
 	//修改联系人最后一次阅读报告时间
 	go models.SetWxUserReportLastViewTime(user.UserId)
 

models/company_product.go

@@ -32,6 +32,8 @@ type CompanyProduct struct {
 	LoseReason       string    `description:"流失原因"`
 	LossTime         time.Time `description:"流失时间"`
 	CompanyType      string    `description:"客户类型"`
+	ViewTotal        int       `description:"总阅读次数"`
+	LastViewTime     time.Time `description:"最后一次阅读时间"`
 }
 
 //判断客户权限总数
@@ -83,3 +85,11 @@ func GetCompanyProductsByUserId(userId int) (items []*CompanyProductDetail, err
 	_, err = o.Raw(sql, userId).QueryRows(&items)
 	return
 }
+
+// UpdateCompanyProductViewData 更新客户产品的阅读记录（阅读时间、总阅读次数）
+func UpdateCompanyProductViewData(companyId, productId int, lastViewTime string) (err error) {
+	sql := ` update company_product set view_total=view_total+1,last_view_time=? WHERE company_id=? and product_id =? `
+	o := orm.NewOrm()
+	_, err = o.Raw(sql, lastViewTime, companyId, productId).Exec()
+	return
+}

services/task.go

@@ -1,10 +1,43 @@
 package services
 
-import "fmt"
+import (
+	"encoding/json"
+	"fmt"
+	"hongze/hongze_api/cache"
+	"hongze/hongze_api/models"
+	"hongze/hongze_api/utils"
+)
 
 func Task() {
 	fmt.Println("start")
 	//InitSetUnionId()
 	//FixUnionId()
 	fmt.Println("end")
+
+	go AutoUpdateUserView()
+}
+
+// AutoUpdateUserView 自动添加阅读记录
+func AutoUpdateUserView() {
+	defer func() {
+		if err := recover(); err != nil {
+			fmt.Println("[AutoUpdateUserView]", err)
+		}
+	}()
+	for {
+		utils.Rc.Brpop(utils.CACHE_KEY_USER_VIEW, func(b []byte) {
+			var userViewRedisData cache.UserViewRedisData
+			if err := json.Unmarshal(b, &userViewRedisData); err != nil {
+				go utils.SendEmail(utils.APPNAME+" "+utils.RunMode+" 失败提醒", fmt.Sprint("AutoUpdateUserView ERR:", err, ";response data:", string(b)), utils.EmailSendToUsers)
+				//}
+				//if _, err := models.AddLogs(&log); err != nil {
+				//	fmt.Println("AddLogs:", err.Error(), log)
+			} else {
+				err = models.UpdateCompanyProductViewData(userViewRedisData.CompanyId, userViewRedisData.ProductId, userViewRedisData.ViewTime)
+				if err != nil {
+					go utils.SendEmail(utils.APPNAME+" "+utils.RunMode+" 失败提醒", fmt.Sprint("AutoUpdateUserView Update CompanyProduct ERR:", err, ";response data:", string(b)), utils.EmailSendToUsers)
+				}
+			}
+		})
+	}
 }

utils/constants.go

@@ -79,3 +79,8 @@ const (
 	COMPANY_STATUS_FORMAL    = "正式"
 	COMPANY_STATUS_POTENTIAL = "潜在"
 )
+
+//缓存key
+const (
+	CACHE_KEY_USER_VIEW = "user_view_record" //用户阅读数据
+)