jy_docs/rpc/partnerlib/crontab/service/docsUpdateClass.go

package service

import (
	"app.yhyue.com/moapp/jy_docs/rpc/partnerlib/entity"
	jyDocRpcUtil "app.yhyue.com/moapp/jy_docs/services/util"
	"fmt"
	"log"
)

type Result struct {
	Code string
	Name string
}

// 获取分类详情
func GetClassInfo() (results []*Result) {
	var (
		jydb = jyDocRpcUtil.GetJyDocsDB()
	)
	err := jydb.Raw(fmt.Sprintf("SELECT dcs.code,dc.name FROM %s dcs LEFT JOIN %s dc ON dcs.code = dc.code AND dcs.state = dc.state ", entity.DocClassStatisticsTable, entity.DocClassTable)).Find(&results).Error
	if err != nil {
		log.Println("获取分类信息异常：", err.Error())
	}
	return
}

// 更新分类文档数据量
func UpdateDocsSize(classInfo *Result) {
	var (
		jydb  = jyDocRpcUtil.GetJyDocsDB()
		count int64
	)
	err := jydb.Table(entity.DocTable).Where(" FIND_IN_SET(?,docTags)", classInfo.Name).Count(&count).Error
	if err != nil {
		log.Println(fmt.Sprintf("获取%s分类的文档量异常：%s", classInfo.Name, err.Error()))
	} else if count > 0 {
		err = jydb.Table(entity.DocClassStatisticsTable).Where("code=?", classInfo.Code).UpdateColumn("total", count).Error
		if err != nil {
			log.Println(fmt.Sprintf("获取%s分类的文档量异常：%s", classInfo.Name, err.Error()))
		}
	}
}