resourceCenter/public/entity/base_ent_wait_empower.go

package entity

import (
	"errors"
	"fmt"

	. "app.yhyue.com/moapp/jybase/common"
	. "app.yhyue.com/moapp/jybase/date"
	. "bp.jydev.jianyu360.cn/BaseService/resourceCenter/public/db"
)

var Base_ent_wait_empower = base_ent_wait_empower{}

//企业授权表
type base_ent_wait_empower struct {
	Id                  int64
	Appid               string
	Goods_spec_power_id int64  //商品规格权益id
	Function_code       string //功能代码
	Ent_id              int64  //企业id
	Start_time          string //开始时间
	End_time            string //结束时间
	Empower_count       int64  //授权数量
	Limit_strategy      string //限制频率；1d：1天 1m：1个月
}

//根据商品规格获取待授权记录
func (b *base_ent_wait_empower) WaitEmpowersBySpecId(appid string, spec_id, ent_id int64) *[]*base_ent_wait_empower {
	list := Mysql_BaseService.SelectBySql(`SELECT c.* FROM base_goods_spec a
	INNER JOIN base_goods_spec_power b ON (a.id=? AND a.appid=? AND a.id=b.spec_id)
	INNER JOIN base_ent_wait_empower c ON (c.ent_id=? AND c.end_time>? AND b.id=c.goods_spec_power_id)`, spec_id, appid, ent_id, NowFormat(Date_Full_Layout))
	return JsonUnmarshal(list, &[]*base_ent_wait_empower{}).(*[]*base_ent_wait_empower)
}

//根据功能代码获取待授权记录
func (b *base_ent_wait_empower) WaitEmpowers(appid, function_code string, ent_id int64) *[]*base_ent_wait_empower {
	list := Mysql_BaseService.SelectBySql(`select * from base_ent_wait_empower where appid=? and function_code=? and ent_id=? and end_time>?`, appid, function_code, ent_id, NowFormat(Date_Full_Layout))
	return JsonUnmarshal(list, &[]*base_ent_wait_empower{}).(*[]*base_ent_wait_empower)
}

//所有待授权记录
func (b *base_ent_wait_empower) AllWaitEmpowers(appid string, ent_id int64) *[]*base_ent_wait_empower {
	list := Mysql_BaseService.SelectBySql(`select * from base_ent_wait_empower where appid=? and ent_id=? and end_time>?`, appid, ent_id, NowFormat(Date_Full_Layout))
	return JsonUnmarshal(list, &[]*base_ent_wait_empower{}).(*[]*base_ent_wait_empower)
}

//校验功能代码
func (b *base_ent_wait_empower) CheckBeforeEmpower(appid string, function_code []string, ent_id int64, ent_user_id []int64) (int64, error) {
	list := b.AllWaitEmpowers(appid, ent_id)
	if list == nil {
		return -1, errors.New(fmt.Sprintf("企业%d没有任何待授权的功能代码", ent_id))
	}
	m := map[string]int64{}
	for _, v := range *list {
		if v.Empower_count < 0 {
			m[v.Function_code] = v.Empower_count
		} else {
			m[v.Function_code] = m[v.Function_code] + v.Empower_count
		}
	}
	for _, v := range function_code {
		if count, ok := m[v]; !ok {
			return -1, errors.New(fmt.Sprintf("企业%d没有该待授权%s功能代码", ent_id, v))
		} else if count >= 0 && int64(len(ent_user_id)) > count {
			return -2, errors.New(fmt.Sprintf("企业%d功能代码%s可授权数量不足", ent_id, v))
		}
	}
	return 1, nil
}

//是否全部授权
func (b *base_ent_wait_empower) IsAllEmpower(appid, function_code string, ent_id int64) bool {
	return Mysql_BaseService.CountBySql(`select count(1) as count from base_ent_wait_empower where appid=? and function_code=? and ent_id=? and end_time>? and empower_count=-1`, appid, function_code, ent_id, NowFormat(Date_Full_Layout)) > 0
}