package stdlib

import (
	"log"
	"time"

	elastic "app.yhyue.com/moapp/jybase/esv7"
	jyDocsRpcUtil "app.yhyue.com/moapp/jy_docs/services/util"
)

func DocStatistics(docId string, dtype int) bool {
	sqlStr := ""
	state := false
	if dtype == 1 { //下载次数增加1
		sqlStr = "update doc_statistics set downTimes = downTimes + 1,updateDate = ? where docId = ?"
	} else if dtype == 2 { //浏览次数增加1
		sqlStr = "update doc_statistics set viewTimes = viewTimes + 1,updateDate = ? where docId = ?"
	}
	//mysql
	log.Println("sql ", sqlStr)
	updateDate := time.Now().Format("2006-01-02 15:04:05")
	err := jyDocsRpcUtil.GetJyDocsDB().Exec(sqlStr, updateDate, docId).Error
	if err != nil {
		//es
		data := map[string]interface{}{}
		jyDocsRpcUtil.GetJyDocsDB().Table("doc_statistics").Where("docId = ?", docId).Find(&data)
		if len(data) > 0 {
			//是否缓存
			//TODO
			if ok := elastic.UpdateNewDoc("jydocs", "jydocs", data); ok {
				state = true
			}
		}
	}
	return state
}