no message

models/article_and_yanxuan_record.go

@@ -0,0 +1,33 @@
+package models
+
+import (
+	"github.com/beego/beego/v2/client/orm"
+	"time"
+)
+
+type CygxArticleAndYanxuanRecord struct {
+	Id               int       `orm:"column(id);pk"`
+	SourceId         int       `description:"资源ID"`
+	Source           string    `description:"资源I类型  文章、研选专栏"`
+	UserId           int       `description:"用户ID"`
+	CreateTime       string    `description:"创建时间"`
+	Mobile           string    `description:"手机号"`
+	Email            string    `description:"邮箱"`
+	CompanyId        int       `description:"公司id"`
+	CompanyName      string    `description:"公司名称"`
+	ModifyTime       time.Time `description:"修改时间"`
+	RealName         string    `description:"用户实际名称"`
+	SellerName       string    `description:"所属销售"`
+	StopTime         int       `description:"停留时间"`
+	RegisterPlatform int       `description:"来源 1小程序，2：网页"`
+}
+
+// 批量添加
+func AddCygxArticleAndYanxuanRecordMulti(items []*CygxArticleAndYanxuanRecord) (err error) {
+	o := orm.NewOrm()
+	if len(items) > 0 {
+		//批量添加
+		_, err = o.InsertMulti(len(items), items)
+	}
+	return
+}

models/article_history_record_all.go

@@ -0,0 +1,49 @@
+package models
+
+import (
+	"github.com/beego/beego/v2/client/orm"
+	"time"
+)
+
+type CygxArticleHistoryRecordAll struct {
+	Id             int `orm:"column(id);pk"`
+	ArticleId      int
+	UserId         int
+	CreateTime     string
+	ModifyTime     time.Time
+	Mobile         string    `description:"手机号"`
+	Email          string    `description:"邮箱"`
+	CompanyId      int       `description:"公司id"`
+	CompanyName    string    `description:"公司名称"`
+	StopTime       int       `description:"停留时间"`
+	OutType        int       `description:"退出方式，1正常退出，2强制关闭"`
+	Source         string    `description:"来源，MOBILE：手机端，PC：电脑端"`
+	RealName       string    `description:"用户实际名称"`
+	CreateDateApi  time.Time `description:"同步创建时间"`
+	CelueHistoryId int       `description:"策略平台记录的ID"`
+	Platfor        int       `description:"PV阅读记录来源，1：查研观向，2：策略平台"`
+	IsDel          int       `description:"是否删除"`
+}
+
+// 获取数量
+func GetCygxArticleHistoryRecordAllCountBycondition(condition string, pars []interface{}) (count int, err error) {
+	sqlCount := ` SELECT COUNT(1) AS count  FROM cygx_article_history_record_all as art WHERE 1= 1  `
+	if condition != "" {
+		sqlCount += condition
+	}
+	o := orm.NewOrm()
+	err = o.Raw(sqlCount, pars).QueryRow(&count)
+	return
+}
+
+// 列表
+func GetCygxArticleHistoryRecordAllList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxArticleHistoryRecordAll, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM cygx_article_history_record_all as art WHERE 1= 1 `
+	if condition != "" {
+		sql += condition
+	}
+	sql += ` LIMIT ?,?  `
+	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
+	return
+}

models/article_history_record_newpv.go

@@ -128,26 +128,6 @@ func UpdateCygxArticleViewRecordNewpvList(itemRep *CygxArticleHistoryRecordNewpv
 	return
 }
 
-type CygxArticleHistoryRecordAll struct {
-	Id             int `orm:"column(id);pk"`
-	ArticleId      int
-	UserId         int
-	CreateTime     string
-	ModifyTime     time.Time
-	Mobile         string    `description:"手机号"`
-	Email          string    `description:"邮箱"`
-	CompanyId      int       `description:"公司id"`
-	CompanyName    string    `description:"公司名称"`
-	StopTime       int       `description:"停留时间"`
-	OutType        int       `description:"退出方式，1正常退出，2强制关闭"`
-	Source         string    `description:"来源，MOBILE：手机端，PC：电脑端"`
-	RealName       string    `description:"用户实际名称"`
-	CreateDateApi  time.Time `description:"同步创建时间"`
-	CelueHistoryId int       `description:"策略平台记录的ID"`
-	Platfor        int       `description:"PV阅读记录来源，1：查研观向，2：策略平台"`
-	IsDel          int       `description:"是否删除"`
-}
-
 // 获取当天总表的阅读记录
 func GetArticleHistoryRecordAllList() (items []*CygxArticleHistoryRecordNewpv, err error) {
 	o := orm.NewOrm()

models/cygx_yanxuan_special_record.go

@@ -21,6 +21,22 @@ type CygxYanxuanSpecialRecord struct {
 	StopTime                   int       // 停留时间
 }
 
+type CygxYanxuanSpecialRecordResp struct {
+	CygxYanxuanSpecialRecordId int       `orm:"column(cygx_yanxuan_special_record_id);pk"`
+	UserId                     int       // 用户ID
+	Mobile                     string    // 手机号
+	Email                      string    // 邮箱
+	CompanyId                  int       // 公司ID
+	CompanyName                string    // 公司名称
+	RealName                   string    // 用户实际名称
+	SellerName                 string    // 所属销售
+	CreateTime                 string    // 创建时间
+	ModifyTime                 time.Time // 修改时间
+	RegisterPlatform           int       // 来源 1小程序，2：网页
+	YanxuanSpecialId           int       // cygx_yanxuan_special 表主键ID
+	StopTime                   int       // 停留时间
+}
+
 func AddCygxYanxuanSpecialRecord(item *CygxYanxuanSpecialRecord) (lastId int64, err error) {
 	o := orm.NewOrm()
 	lastId, err = o.Insert(item)
@@ -73,3 +89,15 @@ func AddCygxYanxuanSpecialRecordLog(item *CygxYanxuanSpecialRecordLog) (lastId i
 	lastId, err = o.Insert(item)
 	return
 }
+
+// 列表
+func GetCygxYanxuanSpecialRecordRespList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxYanxuanSpecialRecordResp, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM cygx_yanxuan_special_record as art WHERE 1= 1 `
+	if condition != "" {
+		sql += condition
+	}
+	sql += ` LIMIT ?,?  `
+	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
+	return
+}

models/db.go

@@ -186,6 +186,7 @@ func init() {
 		new(CygxAskserieVideoCollection),
 		new(CygxAskserieVideoCollect),
 		new(CygxVoiceAndVideoHistory),
+		new(CygxArticleAndYanxuanRecord),
 	)
 	// 记录ORM查询日志
 	orm.Debug = true

services/init12.8.go

@@ -3,6 +3,7 @@ package services
 import (
 	"fmt"
 	"hongze/hongze_cygx/models"
+	"hongze/hongze_cygx/utils"
 )
 
 func init11() {
@@ -18,3 +19,91 @@ func init11() {
 		UdpateYanxuanSpecialauthorArticleNum(v.UserId)
 	}
 }
+
+func init77() {
+	var condition string
+	var pars []interface{}
+
+	//condition = " AND  is_del = 0 AND company_id > 1 AND article_id IN (SELECT  article_id FROM cygx_article) "
+	//total, err := models.GetCygxArticleHistoryRecordAllCountBycondition(condition, pars)
+	//
+	//if err != nil {
+	//	fmt.Println(err)
+	//	return
+	//}
+	//for i := 0; i <= total/2000; i++ {
+	//	allList, err := models.GetCygxArticleHistoryRecordAllList(condition, pars, 2000*i, 2000)
+	//	if err != nil {
+	//		fmt.Println("GetCygxArticleHistoryRecordByCompanyListNew Err:", err.Error())
+	//
+	//	}
+	//	var items []*models.CygxArticleAndYanxuanRecord
+	//	fmt.Println(len(allList))
+	//	for _, v := range allList {
+	//		item := new(models.CygxArticleAndYanxuanRecord)
+	//		item.SourceId = v.ArticleId
+	//		item.Source = utils.CYGX_OBJ_ARTICLE
+	//		item.UserId = v.UserId
+	//		item.RealName = v.RealName
+	//		item.Mobile = v.Mobile
+	//		item.Email = v.Email
+	//		item.CompanyId = v.CompanyId
+	//		item.CompanyName = v.CompanyName
+	//		item.CompanyId = v.CompanyId
+	//		item.CreateTime = v.CreateTime
+	//		item.ModifyTime = v.ModifyTime
+	//		item.StopTime = v.StopTime
+	//
+	//		if v.Source == "CELUE" {
+	//			item.RegisterPlatform = 3
+	//		} else if v.Source == "WEB" {
+	//			item.RegisterPlatform = 2
+	//		} else {
+	//			item.RegisterPlatform = 1
+	//		}
+	//
+	//		items = append(items, item)
+	//	}
+	//
+	//	err = models.AddCygxArticleAndYanxuanRecordMulti(items)
+	//	if err != nil {
+	//		fmt.Println(err)
+	//	}
+	//
+	//}
+	condition = " AND yanxuan_special_id IN (SELECT  id FROM cygx_yanxuan_special ) "
+	list, err := models.GetCygxYanxuanSpecialRecordRespList(condition, pars, 0, 99999)
+	if err != nil {
+		fmt.Println("GetCygxArticleHistoryRecordByCompanyListNew Err:", err.Error())
+
+	}
+	var items []*models.CygxArticleAndYanxuanRecord
+	fmt.Println(len(list))
+	for _, v := range list {
+		item := new(models.CygxArticleAndYanxuanRecord)
+		item.SourceId = v.YanxuanSpecialId
+		item.Source = utils.CYGX_OBJ_YANXUANSPECIAL
+		item.UserId = v.UserId
+		item.RealName = v.RealName
+		item.Mobile = v.Mobile
+		item.Email = v.Email
+		item.CompanyId = v.CompanyId
+		item.CompanyName = v.CompanyName
+		item.CompanyId = v.CompanyId
+		item.CreateTime = v.CreateTime
+		item.ModifyTime = v.ModifyTime
+		item.StopTime = v.StopTime
+
+		item.RegisterPlatform = v.RegisterPlatform
+
+		items = append(items, item)
+	}
+	fmt.Println(len(items))
+
+	//return
+	err = models.AddCygxArticleAndYanxuanRecordMulti(items)
+	if err != nil {
+		fmt.Println(err)
+	}
+
+}