package main

import (
	"fmt"
	"io/ioutil"
	"time"

	"github.com/silenceper/wechat"
	"github.com/silenceper/wechat/cache"
	"github.com/silenceper/wechat/tcb"
	"gopkg.in/yaml.v2"
)

//Config 配置信息
type Config struct {
	TcbEnv    string `yaml:"tcb_env"`
	AppID     string `yaml:"app_id"`
	AppSecret string `yaml:"app_secret"`
}

var cfg *Config
var _ = getConfig()

//通过getConfig方法获取配置参数
func getConfig() *Config {
	if cfg != nil {
		return cfg
	}
	data, err := ioutil.ReadFile("./config.yaml")
	if err != nil {
		panic(err)
	}
	cfg = &Config{}
	err = yaml.Unmarshal(data, cfg)
	if err != nil {
		panic(err)
	}
	return cfg
}

var wechatTcb *tcb.Tcb
var _ = getTcb()

//通过getTcb获取wechat sdk的配置参数
func getTcb() *tcb.Tcb {
	if wechatTcb != nil {
		return wechatTcb
	}
	memCache := cache.NewMemory()

	//配置小程序参数
	config := &wechat.Config{
		AppID:     getConfig().AppID,
		AppSecret: getConfig().AppSecret,
		Cache:     memCache,
	}
	wc := wechat.NewWechat(config)
	wechatTcb = wc.GetTcb()
	return wechatTcb
}

func main() {
	//1.从数据库test中查询所有数据

	res, err := wechatTcb.DatabaseQuery(getConfig().TcbEnv, "db.collection(\"test\").get()")
	if err != nil {
		fmt.Println(err)
	}
	for i, v := range res.Data {
		fmt.Println("第%d个数据是%v\n", i, v)
	}

	//2.创建数据库guestbook
	/*
		err := wechatTcb.DatabaseCollectionAdd(getConfig().TcbEnv, "guestbook")
		if err != nil {
			fmt.Println("创建数据库bookstore失败")
			return
		}
		fmt.Println("创建数据库bookstore成功")
	*/

	return
}

//FeedbackService service
type FeedbackService struct {
}

//NewFeedbackService new
func NewFeedbackService() *FeedbackService {
	return &FeedbackService{}
}

//Feedback 留言记录
type Feedback struct {
	Username   string `form:"username",json:"username"`
	Content    string `form:"content",json:"content"`
	FilePath   string `json:"filePath"` //文件路径
	FileID     string `json:"fileId"`   //存放文件
	CreateTime string `json:"createTime"`
}

func (svc *FeedbackService) Save(feedback *Feedback) error {
	if feedback.Username == "" || feedback.Content == "" {
		return fmt.Errorf("用户名或留言内容不能为空")
	}
	query := `db.collection(\"%s\").add({
      data: [{
        username: \"%s\",
        content: \"%s\",
		filePath: \"%s\",
		fileId: \"%s\",
        createTime: \"%s\",
      }]
      })`
	feedback.CreateTime = time.Now().Format("2006-01-02 15:04:05")
	query = fmt.Sprintf(query, "guestbook", feedback.Username, feedback.Content, feedback.FilePath, feedback.FileID, feedback.CreateTime)
	_, err := getTcb().DatabaseAdd(getConfig().TcbEnv, query)
	if err != nil {
		return err
	}
	return nil
}