pm/services/weixin/weixin.go

package weixin

import (
	"time"
	"zhiyuan/models"
	"zhiyuan/pkg/db"
	"zhiyuan/services/form"
)

var Weixin models.Weixin

func GetOne(where map[string]interface{}, fields []string, retVal interface{}) (*models.Weixin, error) {
	return Weixin.GetOne(where, fields, retVal)
}

func Add(form form.WeixinAdd) (int64, error) {
	weixinMap := map[string]interface{}{
		"weixin_name":  form.WeixinName,
		"app_id":       form.AppID,
		"app_secret":   form.AppSecret,
		"access_token": form.AccessToken,
		"expires_in":   form.ExpiresIn,
	}
	weixinID, err := db.InsertOne(Weixin.TableName(), weixinMap)
	if err != nil {
		return 0, nil
	}
	return weixinID, nil
}

func Edit(form form.WeixinAdd, id int) error {
	weixinMap := map[string]interface{}{
		"weixin_name":  form.WeixinName,
		"app_id":       form.AppID,
		"app_secret":   form.AppSecret,
		"access_token": form.AccessToken,
		"expires_in":   form.ExpiresIn,
	}
	_, err := db.Update(Weixin.TableName(), map[string]interface{}{"id": id}, weixinMap)
	return err
}

func EditToken(form form.WeixinEditToken, id int) error {
	weixinMap := map[string]interface{}{
		"access_token":            form.AccessToken,
		"access_token_expires_in": form.AccessTokenExpiresIn,
		"access_token_updated_at": time.Now().Unix(),
	}
	_, err := db.Update(Weixin.TableName(), map[string]interface{}{"id": id}, weixinMap)
	return err
}

func EditJsapi(form form.WeixinEditJsapi, id int) error {
	weixinMap := map[string]interface{}{
		"jsapi_ticket":            form.JsapiTicket,
		"jsapi_ticket_expires_in": form.JsapiTicketExpiresIn,
		"jsapi_ticket_updated_at": time.Now().Unix(),
	}
	_, err := db.Update(Weixin.TableName(), map[string]interface{}{"id": id}, weixinMap)
	return err
}