update

go.mod

@@ -13,6 +13,7 @@ require (
 
 require (
 	filippo.io/edwards25519 v1.1.0 // indirect
+	github.com/go-xorm/xorm v0.7.9 // indirect
 	github.com/goccy/go-json v0.10.2 // indirect
 	github.com/golang/snappy v0.0.4 // indirect
 	github.com/jinzhu/copier v0.4.0 // indirect
@@ -28,5 +29,6 @@ require (
 	golang.org/x/net v0.10.0 // indirect
 	golang.org/x/sys v0.8.0 // indirect
 	golang.org/x/tools v0.0.0-20201124115921-2c860bdd6e78 // indirect
-	xorm.io/builder v0.3.11-0.20220531020008-1bd24a7dc978 // indirect
+	xorm.io/builder v0.3.13 // indirect
+	xorm.io/core v0.7.3 // indirect
 )

src/dao/egg_energy_basic_setting_dao.go

@@ -0,0 +1,11 @@
+package dao
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	"xorm.io/xorm"
+)
+
+type EggEnergyBasicSettingDao interface {
+	EggEnergyBasicSettingUpdate(session *xorm.Session, id interface{}, EggEnergyBasicSetting *model.EggEnergyBasicSetting, forceColums ...string) (int64, error)
+	EggEnergyBasicSettingGetOneByParams(params map[string]interface{}) (*model.EggEnergyBasicSetting, error)
+}

src/dao/egg_energy_community_dividends_dao.go

@@ -0,0 +1,5 @@
+package dao
+
+type EggEnergyCommunityDividendsDao interface {
+	//TODO:: You can add specific method definitions here
+}

src/dao/egg_energy_community_dividends_with_user_dao.go

@@ -0,0 +1,5 @@
+package dao
+
+type EggEnergyCommunityDividendsWithUserDao interface {
+	//TODO:: You can add specific method definitions here
+}

src/dao/egg_energy_community_dividends_with_user_records_dao.go

@@ -0,0 +1,5 @@
+package dao
+
+type EggEnergyCommunityDividendsWithUserRecordsDao interface {
+	//TODO:: You can add specific method definitions here
+}

src/dao/egg_energy_user_activity_dao.go

@@ -0,0 +1,5 @@
+package dao
+
+type EggEnergyUserActivityDao interface {
+	//TODO:: You can add specific method definitions here
+}

src/dao/egg_energy_user_watch_records_dao.go

@@ -0,0 +1,9 @@
+package dao
+
+import "code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+
+type EggEnergyUserWatchRecordsDao interface {
+	EggEnergyUserWatchRecordsInsert(OneCirclesUserWatchRecords *model.EggEnergyUserWatchRecords) (int64, error)
+	EggEnergyUserWatchRecordsUpdate(id interface{}, OneCirclesUserWatchRecords *model.EggEnergyUserWatchRecords, forceColums ...string) (int64, error)
+	EggEnergyUserWatchRecordsGetOneByParams(params map[string]interface{}) (*model.EggEnergyUserWatchRecords, error)
+}

src/dao/egg_public_platoon_basic_setting_dao.go

@@ -0,0 +1,15 @@
+package dao
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+)
+
+type PublicPlatoonBasicSettingDao interface {
+	PublicPlatoonBasicSettingInsert(PublicPlatoonBasicSetting *model.PublicPlatoonBasicSetting) (int, error)
+	BatchAddPublicPlatoonBasicSettings(PublicPlatoonBasicSettingData []*model.PublicPlatoonBasicSetting) (int64, error)
+	GetPublicPlatoonBasicSettingCount() int
+	PublicPlatoonBasicSettingDelete(id interface{}) (int64, error)
+	PublicPlatoonBasicSettingUpdate(id interface{}, PublicPlatoonBasicSetting *model.PublicPlatoonBasicSetting, forceColums ...string) (int64, error)
+	PublicPlatoonBasicSettingGetOneByParams(params map[string]interface{}) (*model.PublicPlatoonBasicSetting, error)
+	PublicPlatoonBasicSettingFindByParams(params map[string]interface{}) (*[]model.PublicPlatoonBasicSetting, error)
+}

src/dao/egg_sign_in_dao.go

@@ -0,0 +1,5 @@
+package dao
+
+type EggSignInDao interface {
+	//TODO:: You can add specific method definitions here
+}

src/dao/egg_star_level_dividends_records_dao.go

@@ -0,0 +1,12 @@
+package dao
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	"xorm.io/xorm"
+)
+
+type EggStarLevelDividendsRecordsDao interface {
+	EggStarLevelDividendsRecordsInsertBySession(session *xorm.Session, EggStarLevelDividendsRecords *model.EggStarLevelDividendsRecords) (int64, error)
+	EggStarLevelDividendsRecordsUpdateBySession(session *xorm.Session, id interface{}, EggStarLevelDividendsRecords *model.EggStarLevelDividendsRecords, forceColums ...string) (int64, error)
+	EggStarLevelDividendsRecordsGetOneByParamsBySession(session *xorm.Session, params map[string]interface{}) (*model.EggStarLevelDividendsRecords, error)
+}

src/dao/public_platoon_free_punish_with_user_dao.go

@@ -0,0 +1,12 @@
+package dao
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	"xorm.io/xorm"
+)
+
+type PublicPlatoonFreePunishWithUserDao interface {
+	FindAllPublicPlatoonFreePunishWithUser() (resp map[int64]*model.PublicPlatoonFreePunishWithUser, err error)
+	PublicPlatoonFreePunishWithUserInsert(PublicPlatoonFreePunishWithUser *model.PublicPlatoonFreePunishWithUser) (int, error)
+	PublicPlatoonFreePunishWithUserUpdate(Db *xorm.Engine, id interface{}, PublicPlatoonFreePunishWithUser *model.PublicPlatoonFreePunishWithUser, forceColums ...string) (int64, error)
+}

src/dao/public_platoon_records_punish_with_user_dao.go

@@ -0,0 +1,11 @@
+package dao
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+)
+
+type PublicPlatoonRecordsPunishWithUserDao interface {
+	FindAllPublicPlatoonRecordsPunishWithUser() (resp map[int64]*model.PublicPlatoonRecordsPunishWithUser, err error)
+	PublicPlatoonRecordsPunishWithUserInsert(PublicPlatoonRecordsPunishWithUser *model.PublicPlatoonRecordsPunishWithUser) (int, error)
+	PublicPlatoonRecordsPunishWithUserUpdate(id interface{}, PublicPlatoonRecordsPunishWithUser *model.PublicPlatoonRecordsPunishWithUser, forceColums ...string) (int64, error)
+}

src/dao/public_platoon_user_relation_dao.go

@@ -0,0 +1,16 @@
+package dao
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	"xorm.io/xorm"
+)
+
+type PublicPlatoonUserRelationDao interface {
+	PublicPlatoonUserRelationInsert(PublicPlatoonUserRelation *model.PublicPlatoonUserRelation) (int, error)
+	PublicPlatoonUserRelationUpdate(session *xorm.Session, id interface{}, PublicPlatoonUserRelation *model.PublicPlatoonUserRelation, forceColums ...string) (int64, error)
+	PublicPlatoonUserRelationGetOneByParams(params map[string]interface{}) (*model.PublicPlatoonUserRelation, error)
+	PublicPlatoonUserRelationGetOneByPid(recommendUid string, params map[string]interface{}) (*model.PublicPlatoonUserRelation, error)
+	PublicPlatoonUserRelationFindByPid(fatherUid int64, fatherName, positionName string) ([]model.PublicPlatoonUserRelation, error)
+	PublicPlatoonUserRelationFindCountByPosition(fatherUid int64, fatherName, positionName string, startPosition, endPosition int64) ([]model.PublicPlatoonUserRelation, int64, error)
+	PublicPlatoonUserRelationFindByParamsByPage(params map[string]interface{}, page, pageSize int) (*[]model.PublicPlatoonUserRelation, error)
+}

src/dao/public_platoon_user_system_punish_records_dao.go

@@ -0,0 +1,12 @@
+package dao
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	"xorm.io/xorm"
+)
+
+type PublicPlatoonUserSystemPunishRecordsDao interface {
+	PublicPlatoonUserSystemPunishRecordsInsert(session *xorm.Session, PublicPlatoonUserSystemPunishRecords *model.PublicPlatoonUserSystemPunishRecords) (int64, error)
+	PublicPlatoonUserSystemPunishRecordsGetOneByParams(params map[string]interface{}) (*model.PublicPlatoonUserSystemPunishRecords, error)
+	PublicPlatoonUserSystemPunishRecordsFindByParams(params map[string]interface{}) (*[]model.PublicPlatoonUserSystemPunishRecords, error)
+}

src/dao/user_dao.go

@@ -0,0 +1,5 @@
+package dao
+
+type UserDao interface {
+	//TODO:: You can add specific method definitions here
+}

src/dao/user_level_dao.go

@@ -0,0 +1,12 @@
+package dao
+
+import "code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+
+type UserLevelDao interface {
+	//UserLevelInIDescByWeightLowWithOne 查询获取 权重最低 对应等级
+	UserLevelInIDescByWeightLowWithOne() (*model.UserLevel, error)
+	//UserLevelByID 根据id 获取对应的等级信息
+	UserLevelByID(id interface{}) (*model.UserLevel, error)
+	//UserLevelAllByAsc 获取所有开启等级并且升序返回
+	UserLevelAllByAsc() ([]*model.UserLevel, error)
+}

src/dao/user_relate_dao.go

@@ -0,0 +1,10 @@
+package dao
+
+import "code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+
+type UserRelateDao interface {
+	FindUserRelate(uid int64, level int) (*[]model.UserRelate, error)
+	GetUserParentUserRelate(uid int64) (*model.UserRelate, error)
+	FindUserRelateByParentUid(uid int64, level int) (*[]model.UserRelate, error)
+	SumUserRelateByParentUid(parentUid string) (total int64, userRelate []*model.UserRelate, err error)
+}

src/dao/user_wallet_dao.go

@@ -0,0 +1,5 @@
+package dao
+
+type UserWalletDao interface {
+	//TODO:: You can add specific method definitions here
+}

src/implement/egg_energy_basic_setting_implement.go

@@ -0,0 +1,42 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"fmt"
+	"xorm.io/xorm"
+)
+
+func NewEggEnergyBasicSettingDb(engine *xorm.Engine) dao.EggEnergyBasicSettingDao {
+	return &EggEnergyBasicSettingDb{Db: engine}
+}
+
+type EggEnergyBasicSettingDb struct {
+	Db *xorm.Engine
+}
+
+func (e EggEnergyBasicSettingDb) EggEnergyBasicSettingUpdate(session *xorm.Session, id interface{}, EggEnergyBasicSetting *model.EggEnergyBasicSetting, forceColums ...string) (int64, error) {
+	var (
+		affected int64
+		err      error
+	)
+	if forceColums != nil {
+		affected, err = session.Where("id=?", id).Cols(forceColums...).Update(EggEnergyBasicSetting)
+	} else {
+		affected, err = session.Where("id=?", id).Update(EggEnergyBasicSetting)
+	}
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}
+
+func (e EggEnergyBasicSettingDb) EggEnergyBasicSettingGetOneByParams(params map[string]interface{}) (*model.EggEnergyBasicSetting, error) {
+	var m model.EggEnergyBasicSetting
+	var query = fmt.Sprintf("%s =?", params["key"])
+	if has, err := e.Db.Where(query, params["value"]).Get(&m); err != nil || has == false {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	return &m, nil
+}

src/implement/egg_energy_community_dividends_implement.go

@@ -0,0 +1,14 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"xorm.io/xorm"
+)
+
+func NewEggEnergyCommunityDividendsDb(engine *xorm.Engine) dao.EggEnergyCommunityDividendsDao {
+	return &EggEnergyCommunityDividendsDb{Db: engine}
+}
+
+type EggEnergyCommunityDividendsDb struct {
+	Db *xorm.Engine
+}

src/implement/egg_energy_community_dividends_with_user_implement.go

@@ -0,0 +1,14 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"xorm.io/xorm"
+)
+
+func NewEggEnergyCommunityDividendsWithUserDb(engine *xorm.Engine) dao.EggEnergyCommunityDividendsWithUserDao {
+	return &EggEnergyCommunityDividendsWithUserDb{Db: engine}
+}
+
+type EggEnergyCommunityDividendsWithUserDb struct {
+	Db *xorm.Engine
+}

src/implement/egg_energy_community_dividends_with_user_records_implement.go

@@ -0,0 +1,14 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"xorm.io/xorm"
+)
+
+func NewEggEnergyCommunityDividendsWithUserRecordsDb(engine *xorm.Engine) dao.EggEnergyCommunityDividendsWithUserRecordsDao {
+	return &EggEnergyCommunityDividendsWithUserRecordsDb{Db: engine}
+}
+
+type EggEnergyCommunityDividendsWithUserRecordsDb struct {
+	Db *xorm.Engine
+}

src/implement/egg_energy_user_activity_implement.go

@@ -0,0 +1,14 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"xorm.io/xorm"
+)
+
+func NewEggEnergyUserActivityDb(engine *xorm.Engine) dao.EggEnergyUserActivityDao {
+	return &EggEnergyUserActivityDb{Db: engine}
+}
+
+type EggEnergyUserActivityDb struct {
+	Db *xorm.Engine
+}

src/implement/egg_energy_user_watch_records_implement.go

@@ -0,0 +1,54 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"fmt"
+	"xorm.io/xorm"
+)
+
+func NewEggEnergyUserWatchRecordsDb(engine *xorm.Engine) dao.EggEnergyUserWatchRecordsDao {
+	return &EggEnergyUserWatchRecordsDb{Db: engine}
+}
+
+type EggEnergyUserWatchRecordsDb struct {
+	Db *xorm.Engine
+}
+
+func (e EggEnergyUserWatchRecordsDb) EggEnergyUserWatchRecordsInsert(OneCirclesUserWatchRecords *model.EggEnergyUserWatchRecords) (int64, error) {
+	_, err := e.Db.InsertOne(OneCirclesUserWatchRecords)
+	if err != nil {
+		return 0, err
+	}
+	return OneCirclesUserWatchRecords.Id, nil
+}
+
+func (e EggEnergyUserWatchRecordsDb) EggEnergyUserWatchRecordsUpdate(id interface{}, OneCirclesUserWatchRecords *model.EggEnergyUserWatchRecords, forceColums ...string) (int64, error) {
+	var (
+		affected int64
+		err      error
+	)
+	if forceColums != nil {
+		affected, err = e.Db.Where("id=?", id).Cols(forceColums...).Update(OneCirclesUserWatchRecords)
+	} else {
+		affected, err = e.Db.Where("id=?", id).Update(OneCirclesUserWatchRecords)
+	}
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}
+
+func (e EggEnergyUserWatchRecordsDb) EggEnergyUserWatchRecordsGetOneByParams(params map[string]interface{}) (*model.EggEnergyUserWatchRecords, error) {
+	var m model.EggEnergyUserWatchRecords
+	var query = fmt.Sprintf("%s =?", params["key"])
+	has, err := e.Db.Where(query, params["value"]).Get(&m)
+	if err != nil {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	if !has {
+		return nil, nil
+	}
+	return &m, nil
+}

src/implement/egg_sign_in_implement.go

@@ -0,0 +1,14 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"xorm.io/xorm"
+)
+
+func NewEggSignInDb(engine *xorm.Engine) dao.EggSignInDao {
+	return &EggSignInDb{Db: engine}
+}
+
+type EggSignInDb struct {
+	Db *xorm.Engine
+}

src/implement/egg_star_level_dividends_records_implement.go

@@ -0,0 +1,54 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"fmt"
+	"xorm.io/xorm"
+)
+
+func NewEggStarLevelDividendsRecordsDb(engine *xorm.Engine) dao.EggStarLevelDividendsRecordsDao {
+	return &EggStarLevelDividendsRecordsDb{Db: engine}
+}
+
+type EggStarLevelDividendsRecordsDb struct {
+	Db *xorm.Engine
+}
+
+func (e EggStarLevelDividendsRecordsDb) EggStarLevelDividendsRecordsInsertBySession(session *xorm.Session, EggStarLevelDividendsRecords *model.EggStarLevelDividendsRecords) (int64, error) {
+	_, err := session.InsertOne(EggStarLevelDividendsRecords)
+	if err != nil {
+		return 0, err
+	}
+	return EggStarLevelDividendsRecords.Id, nil
+}
+
+func (e EggStarLevelDividendsRecordsDb) EggStarLevelDividendsRecordsUpdateBySession(session *xorm.Session, id interface{}, EggStarLevelDividendsRecords *model.EggStarLevelDividendsRecords, forceColums ...string) (int64, error) {
+	var (
+		affected int64
+		err      error
+	)
+	if forceColums != nil {
+		affected, err = session.Where("id=?", id).Cols(forceColums...).Update(EggStarLevelDividendsRecords)
+	} else {
+		affected, err = session.Where("id=?", id).Update(EggStarLevelDividendsRecords)
+	}
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}
+
+func (e EggStarLevelDividendsRecordsDb) EggStarLevelDividendsRecordsGetOneByParamsBySession(session *xorm.Session, params map[string]interface{}) (*model.EggStarLevelDividendsRecords, error) {
+	var m model.EggStarLevelDividendsRecords
+	var query = fmt.Sprintf("%s =?", params["key"])
+	has, err := session.Where(query, params["value"]).Get(&m)
+	if err != nil {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	if has == false {
+		return nil, nil
+	}
+	return &m, nil
+}

src/implement/public_platoon_basic_setting_implement.go

@@ -0,0 +1,109 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_utils "code.fnuoos.com/EggPlanet/egg_models.git/utils"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"errors"
+	"fmt"
+	"reflect"
+	"xorm.io/xorm"
+)
+
+func NewPublicPlatoonBasicSettingDb(engine *xorm.Engine) dao.PublicPlatoonBasicSettingDao {
+	return &PublicPlatoonBasicSettingDb{Db: engine}
+}
+
+type PublicPlatoonBasicSettingDb struct {
+	Db *xorm.Engine
+}
+
+func (p PublicPlatoonBasicSettingDb) PublicPlatoonBasicSettingInsert(PublicPlatoonBasicSetting *model.PublicPlatoonBasicSetting) (int, error) {
+	_, err := p.Db.InsertOne(PublicPlatoonBasicSetting)
+	if err != nil {
+		return 0, err
+	}
+	return PublicPlatoonBasicSetting.Id, nil
+}
+
+func (p PublicPlatoonBasicSettingDb) BatchAddPublicPlatoonBasicSettings(PublicPlatoonBasicSettingData []*model.PublicPlatoonBasicSetting) (int64, error) {
+	affected, err := p.Db.Insert(PublicPlatoonBasicSettingData)
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}
+
+func (p PublicPlatoonBasicSettingDb) GetPublicPlatoonBasicSettingCount() int {
+	var PublicPlatoonBasicSetting model.PublicPlatoonBasicSetting
+	session := p.Db.Where("")
+	count, err := session.Count(&PublicPlatoonBasicSetting)
+	if err != nil {
+		return 0
+	}
+	return int(count)
+}
+
+func (p PublicPlatoonBasicSettingDb) PublicPlatoonBasicSettingDelete(id interface{}) (int64, error) {
+	if reflect.TypeOf(id).Kind() == reflect.Slice {
+		return p.Db.In("id", id).Delete(model.PublicPlatoonBasicSetting{})
+	} else {
+		return p.Db.Where("id = ?", id).Delete(model.PublicPlatoonBasicSetting{})
+	}
+}
+
+func (p PublicPlatoonBasicSettingDb) PublicPlatoonBasicSettingUpdate(id interface{}, PublicPlatoonBasicSetting *model.PublicPlatoonBasicSetting, forceColums ...string) (int64, error) {
+	var (
+		affected int64
+		err      error
+	)
+	if forceColums != nil {
+		affected, err = p.Db.Where("id=?", id).Cols(forceColums...).Update(PublicPlatoonBasicSetting)
+	} else {
+		affected, err = p.Db.Where("id=?", id).Update(PublicPlatoonBasicSetting)
+	}
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}
+
+func (p PublicPlatoonBasicSettingDb) PublicPlatoonBasicSettingGetOneByParams(params map[string]interface{}) (*model.PublicPlatoonBasicSetting, error) {
+	var m model.PublicPlatoonBasicSetting
+	var query = fmt.Sprintf("%s =?", params["key"])
+	if has, err := p.Db.Where(query, params["value"]).Get(&m); err != nil || has == false {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	return &m, nil
+}
+
+func (p PublicPlatoonBasicSettingDb) PublicPlatoonBasicSettingFindByParams(params map[string]interface{}) (*[]model.PublicPlatoonBasicSetting, error) {
+	var m []model.PublicPlatoonBasicSetting
+	if params["value"] == nil {
+		return nil, errors.New("参数有误")
+	}
+	if params["key"] == nil {
+		//查询全部数据
+		err := p.Db.Find(&m)
+		if err != nil {
+			return nil, zhios_order_relate_logx.Error(err)
+		}
+		return &m, nil
+	} else {
+		if reflect.TypeOf(params["value"]).Kind() == reflect.Slice {
+			//指定In查询
+			if err := p.Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).Find(&m); err != nil {
+				return nil, zhios_order_relate_logx.Warn(err)
+			}
+			return &m, nil
+		} else {
+			var query = fmt.Sprintf("%s =?", params["key"])
+			err := p.Db.Where(query, params["value"]).Find(&m)
+			if err != nil {
+				return nil, zhios_order_relate_logx.Error(err)
+			}
+			return &m, nil
+		}
+	}
+}

src/implement/public_platoon_free_punish_with_user_implement.go

@@ -0,0 +1,53 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"xorm.io/xorm"
+)
+
+func NewPublicPlatoonFreePunishWithUserDb(engine *xorm.Engine) dao.PublicPlatoonFreePunishWithUserDao {
+	return &PublicPlatoonFreePunishWithUserDb{Db: engine}
+}
+
+type PublicPlatoonFreePunishWithUserDb struct {
+	Db *xorm.Engine
+}
+
+func (p PublicPlatoonFreePunishWithUserDb) FindAllPublicPlatoonFreePunishWithUser() (resp map[int64]*model.PublicPlatoonFreePunishWithUser, err error) {
+	var m []model.PublicPlatoonFreePunishWithUser
+	err = p.Db.Where("1=1").Find(&m)
+	if err != nil {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	resp = map[int64]*model.PublicPlatoonFreePunishWithUser{}
+	for _, v := range m {
+		resp[v.Uid] = &v
+	}
+	return
+}
+
+func (p PublicPlatoonFreePunishWithUserDb) PublicPlatoonFreePunishWithUserInsert(PublicPlatoonFreePunishWithUser *model.PublicPlatoonFreePunishWithUser) (int, error) {
+	_, err := p.Db.InsertOne(PublicPlatoonFreePunishWithUser)
+	if err != nil {
+		return 0, err
+	}
+	return PublicPlatoonFreePunishWithUser.Id, nil
+}
+
+func (p PublicPlatoonFreePunishWithUserDb) PublicPlatoonFreePunishWithUserUpdate(Db *xorm.Engine, id interface{}, PublicPlatoonFreePunishWithUser *model.PublicPlatoonFreePunishWithUser, forceColums ...string) (int64, error) {
+	var (
+		affected int64
+		err      error
+	)
+	if forceColums != nil {
+		affected, err = Db.Where("id=?", id).Cols(forceColums...).Update(PublicPlatoonFreePunishWithUser)
+	} else {
+		affected, err = Db.Where("id=?", id).Update(PublicPlatoonFreePunishWithUser)
+	}
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}

src/implement/public_platoon_records_punish_with_user_implement.go

@@ -0,0 +1,53 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"xorm.io/xorm"
+)
+
+func NewPublicPlatoonRecordsPunishWithUserDb(engine *xorm.Engine) dao.PublicPlatoonRecordsPunishWithUserDao {
+	return &PublicPlatoonRecordsPunishWithUserDb{Db: engine}
+}
+
+type PublicPlatoonRecordsPunishWithUserDb struct {
+	Db *xorm.Engine
+}
+
+func (p PublicPlatoonRecordsPunishWithUserDb) FindAllPublicPlatoonRecordsPunishWithUser() (resp map[int64]*model.PublicPlatoonRecordsPunishWithUser, err error) {
+	var m []model.PublicPlatoonRecordsPunishWithUser
+	err = p.Db.Where("1=1").Find(&m)
+	if err != nil {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	resp = map[int64]*model.PublicPlatoonRecordsPunishWithUser{}
+	for _, v := range m {
+		resp[v.Uid] = &v
+	}
+	return
+}
+
+func (p PublicPlatoonRecordsPunishWithUserDb) PublicPlatoonRecordsPunishWithUserInsert(PublicPlatoonRecordsPunishWithUser *model.PublicPlatoonRecordsPunishWithUser) (int, error) {
+	_, err := p.Db.InsertOne(PublicPlatoonRecordsPunishWithUser)
+	if err != nil {
+		return 0, err
+	}
+	return PublicPlatoonRecordsPunishWithUser.Id, nil
+}
+
+func (p PublicPlatoonRecordsPunishWithUserDb) PublicPlatoonRecordsPunishWithUserUpdate(id interface{}, PublicPlatoonRecordsPunishWithUser *model.PublicPlatoonRecordsPunishWithUser, forceColums ...string) (int64, error) {
+	var (
+		affected int64
+		err      error
+	)
+	if forceColums != nil {
+		affected, err = p.Db.Where("id=?", id).Cols(forceColums...).Update(PublicPlatoonRecordsPunishWithUser)
+	} else {
+		affected, err = p.Db.Where("id=?", id).Update(PublicPlatoonRecordsPunishWithUser)
+	}
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}

src/implement/public_platoon_user_relation_implement.go

@@ -0,0 +1,121 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_utils "code.fnuoos.com/EggPlanet/egg_models.git/utils"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"errors"
+	"fmt"
+	"reflect"
+	"xorm.io/xorm"
+)
+
+func NewPublicPlatoonUserRelationDb(engine *xorm.Engine) dao.PublicPlatoonUserRelationDao {
+	return &PublicPlatoonUserRelationDb{Db: engine}
+}
+
+type PublicPlatoonUserRelationDb struct {
+	Db *xorm.Engine
+}
+
+func (p PublicPlatoonUserRelationDb) PublicPlatoonUserRelationInsert(PublicPlatoonUserRelation *model.PublicPlatoonUserRelation) (int, error) {
+	_, err := p.Db.InsertOne(PublicPlatoonUserRelation)
+	if err != nil {
+		return 0, err
+	}
+	return PublicPlatoonUserRelation.Id, nil
+}
+
+func (p PublicPlatoonUserRelationDb) PublicPlatoonUserRelationUpdate(session *xorm.Session, id interface{}, PublicPlatoonUserRelation *model.PublicPlatoonUserRelation, forceColums ...string) (int64, error) {
+	var (
+		affected int64
+		err      error
+	)
+	if forceColums != nil {
+		affected, err = session.Where("id=?", id).Cols(forceColums...).Update(PublicPlatoonUserRelation)
+	} else {
+		affected, err = session.Where("id=?", id).Update(PublicPlatoonUserRelation)
+	}
+	if err != nil {
+		return 0, err
+	}
+	return affected, nil
+}
+
+func (p PublicPlatoonUserRelationDb) PublicPlatoonUserRelationGetOneByParams(params map[string]interface{}) (*model.PublicPlatoonUserRelation, error) {
+	var m model.PublicPlatoonUserRelation
+	var query = fmt.Sprintf("%s =?", params["key"])
+	if has, err := p.Db.Where(query, params["value"]).Get(&m); err != nil || has == false {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	return &m, nil
+}
+
+func (p PublicPlatoonUserRelationDb) PublicPlatoonUserRelationGetOneByPid(recommendUid string, params map[string]interface{}) (*model.PublicPlatoonUserRelation, error) {
+	var m model.PublicPlatoonUserRelation
+	var query = fmt.Sprintf("%s <=?", params["key"])
+	if has, err := p.Db.Where("recommend_uid = ?", recommendUid).And(query, params["value"]).OrderBy("id ASC").Get(&m); err != nil || has == false {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	return &m, nil
+}
+
+func (p PublicPlatoonUserRelationDb) PublicPlatoonUserRelationFindByPid(fatherUid int64, fatherName, positionName string) ([]model.PublicPlatoonUserRelation, error) {
+	var m []model.PublicPlatoonUserRelation
+	var query2 = fmt.Sprintf("%s = ?", fatherName)
+	var order = fmt.Sprintf("%s Desc", positionName)
+	if err := p.Db.Where(query2, fatherUid).OrderBy(order).
+		Find(&m); err != nil {
+		return nil, zhios_order_relate_logx.Warn(err)
+	}
+	return m, nil
+}
+
+func (p PublicPlatoonUserRelationDb) PublicPlatoonUserRelationFindCountByPosition(fatherUid int64, fatherName, positionName string, startPosition, endPosition int64) ([]model.PublicPlatoonUserRelation, int64, error) {
+	var m []model.PublicPlatoonUserRelation
+	var count int64
+	var query1 = fmt.Sprintf("%s >= ?", positionName)
+	var query2 = fmt.Sprintf("%s <= ?", positionName)
+	var query3 = fmt.Sprintf("%s = ?", fatherName)
+	if count, err := p.Db.Where(query3, fatherUid).And(query1, startPosition).And(query2, endPosition).OrderBy("has_son_num ASC").
+		FindAndCount(&m); err != nil {
+		return nil, count, zhios_order_relate_logx.Warn(err)
+	}
+	return m, count, nil
+}
+
+func (p PublicPlatoonUserRelationDb) PublicPlatoonUserRelationFindByParamsByPage(params map[string]interface{}, page, pageSize int) (*[]model.PublicPlatoonUserRelation, error) {
+	var m []model.PublicPlatoonUserRelation
+	if params["value"] == nil {
+		return nil, errors.New("参数有误")
+	}
+	if page == 0 && pageSize == 0 {
+		page = 1
+		pageSize = 10
+	}
+
+	if params["key"] == nil {
+		//查询全部数据
+		err := p.Db.Limit(pageSize, (page-1)*pageSize).Find(&m)
+		if err != nil {
+			return nil, zhios_order_relate_logx.Error(err)
+		}
+		return &m, nil
+	} else {
+		if reflect.TypeOf(params["value"]).Kind() == reflect.Slice {
+			//指定In查询
+			if err := p.Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).Limit(pageSize, (page-1)*pageSize).Find(&m); err != nil {
+				return nil, zhios_order_relate_logx.Warn(err)
+			}
+			return &m, nil
+		} else {
+			var query = fmt.Sprintf("%s =?", params["key"])
+			err := p.Db.Where(query, params["value"]).Limit(pageSize, (page-1)*pageSize).Find(&m)
+			if err != nil {
+				return nil, zhios_order_relate_logx.Error(err)
+			}
+			return &m, nil
+		}
+	}
+}

src/implement/public_platoon_user_system_punish_records_implement.go

@@ -0,0 +1,67 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_utils "code.fnuoos.com/EggPlanet/egg_models.git/utils"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"errors"
+	"fmt"
+	"reflect"
+	"xorm.io/xorm"
+)
+
+func NewPublicPlatoonUserSystemPunishRecordsDb(engine *xorm.Engine) dao.PublicPlatoonUserSystemPunishRecordsDao {
+	return &PublicPlatoonUserSystemPunishRecordsDb{Db: engine}
+}
+
+type PublicPlatoonUserSystemPunishRecordsDb struct {
+	Db *xorm.Engine
+}
+
+func (p PublicPlatoonUserSystemPunishRecordsDb) PublicPlatoonUserSystemPunishRecordsInsert(session *xorm.Session, PublicPlatoonUserSystemPunishRecords *model.PublicPlatoonUserSystemPunishRecords) (int64, error) {
+	_, err := session.InsertOne(PublicPlatoonUserSystemPunishRecords)
+	if err != nil {
+		return 0, err
+	}
+	return PublicPlatoonUserSystemPunishRecords.Id, nil
+}
+
+func (p PublicPlatoonUserSystemPunishRecordsDb) PublicPlatoonUserSystemPunishRecordsGetOneByParams(params map[string]interface{}) (*model.PublicPlatoonUserSystemPunishRecords, error) {
+	var m model.PublicPlatoonUserSystemPunishRecords
+	var query = fmt.Sprintf("%s =?", params["key"])
+	if has, err := p.Db.Where(query, params["value"]).Get(&m); err != nil || has == false {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	return &m, nil
+}
+
+func (p PublicPlatoonUserSystemPunishRecordsDb) PublicPlatoonUserSystemPunishRecordsFindByParams(params map[string]interface{}) (*[]model.PublicPlatoonUserSystemPunishRecords, error) {
+	var m []model.PublicPlatoonUserSystemPunishRecords
+	if params["value"] == nil {
+		return nil, errors.New("参数有误")
+	}
+	if params["key"] == nil {
+		//查询全部数据
+		err := p.Db.Find(&m)
+		if err != nil {
+			return nil, zhios_order_relate_logx.Error(err)
+		}
+		return &m, nil
+	} else {
+		if reflect.TypeOf(params["value"]).Kind() == reflect.Slice {
+			//指定In查询
+			if err := p.Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).Find(&m); err != nil {
+				return nil, zhios_order_relate_logx.Warn(err)
+			}
+			return &m, nil
+		} else {
+			var query = fmt.Sprintf("%s =?", params["key"])
+			err := p.Db.Where(query, params["value"]).Find(&m)
+			if err != nil {
+				return nil, zhios_order_relate_logx.Error(err)
+			}
+			return &m, nil
+		}
+	}
+}

src/implement/user_implement.go

@@ -0,0 +1,14 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"xorm.io/xorm"
+)
+
+func NewUserDb(engine *xorm.Engine) dao.UserDao {
+	return &UserDb{Db: engine}
+}
+
+type UserDb struct {
+	Db *xorm.Engine
+}

src/implement/user_level_implement.go

@@ -0,0 +1,51 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"errors"
+	"xorm.io/xorm"
+)
+
+func NewUserLevelDb(engine *xorm.Engine) dao.UserLevelDao {
+	return &UserLevelDb{Db: engine}
+}
+
+type UserLevelDb struct {
+	Db *xorm.Engine
+}
+
+func (u UserLevelDb) UserLevelInIDescByWeightLowWithOne() (*model.UserLevel, error) {
+	var ms model.UserLevel
+	has, err := u.Db.Where("is_use=1").Asc("level_weight").Get(&ms)
+	if err != nil {
+		return nil, err
+	}
+	if has == false {
+		return nil, zhios_order_relate_logx.Warn(errors.New("等级不存在"))
+	}
+	return &ms, nil
+}
+
+func (u UserLevelDb) UserLevelByID(id interface{}) (*model.UserLevel, error) {
+	m := new(model.UserLevel)
+	has, err := u.Db.Where("id = ?", id).Get(m)
+	if err != nil {
+		return nil, err
+	}
+	if !has {
+		return nil, errors.New("no found")
+	}
+
+	return m, nil
+}
+
+func (u UserLevelDb) UserLevelAllByAsc() ([]*model.UserLevel, error) {
+	var m []*model.UserLevel
+	err := u.Db.Where("is_use = ?", 1).Asc("level_weight").Find(&m)
+	if err != nil {
+		return nil, zhios_order_relate_logx.Warn(err)
+	}
+	return m, nil
+}

src/implement/user_relate_implement.go

@@ -0,0 +1,60 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"xorm.io/xorm"
+)
+
+func NewUserRelateDb(engine *xorm.Engine) dao.UserRelateDao {
+	return &UserRelateDb{Db: engine}
+}
+
+type UserRelateDb struct {
+	Db *xorm.Engine
+}
+
+func (u UserRelateDb) FindUserRelate(uid int64, level int) (*[]model.UserRelate, error) {
+	var userRelate []model.UserRelate
+	sess := u.Db.Where("uid = ?", uid)
+	if level > 0 {
+		sess.And("level<=?", level)
+	}
+	if err := sess.Asc("level").Find(&userRelate); err != nil {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	if len(userRelate) == 0 {
+		return nil, nil
+	}
+	return &userRelate, nil
+}
+
+func (u UserRelateDb) GetUserParentUserRelate(uid int64) (*model.UserRelate, error) {
+	var data model.UserRelate
+	get, err := u.Db.Where("level=1 and uid =?", uid).Get(&data)
+	if get == false || err != nil {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	return &data, nil
+}
+
+func (u UserRelateDb) FindUserRelateByParentUid(uid int64, level int) (*[]model.UserRelate, error) {
+	var userRelate []model.UserRelate
+	sess := u.Db.Where("parent_uid = ?", uid)
+	if level > 0 {
+		sess.And("level<=?", level)
+	}
+	if err := sess.Asc("level").Find(&userRelate); err != nil {
+		return nil, zhios_order_relate_logx.Error(err)
+	}
+	if len(userRelate) == 0 {
+		return nil, nil
+	}
+	return &userRelate, nil
+}
+
+func (u UserRelateDb) SumUserRelateByParentUid(parentUid string) (total int64, userRelate []*model.UserRelate, err error) {
+	total, err = u.Db.Where("parent_uid = ?", parentUid).And("level = 1").FindAndCount(&userRelate)
+	return
+}

src/implement/user_wallet_implement.go

@@ -0,0 +1,14 @@
+package implement
+
+import (
+	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
+	"xorm.io/xorm"
+)
+
+func NewUserWalletDb(engine *xorm.Engine) dao.UserWalletDao {
+	return &UserWalletDb{Db: engine}
+}
+
+type UserWalletDb struct {
+	Db *xorm.Engine
+}

src/model/admin_bind_medium.go

@@ -1,13 +1,9 @@
 package model
 
-import (
-	"time"
-)
-
 type AdminBindMedium struct {
-	Id       int       `json:"id" xorm:"not null pk autoincr INT(11)"`
-	AdminId  int       `json:"admin_id" xorm:"default 0 comment('管理员id') INT(11)"`
-	MediumId int       `json:"medium_id" xorm:"not null default 0 comment('媒体id') INT(11)"`
-	CreateAt time.Time `json:"create_at" xorm:"not null default CURRENT_TIMESTAMP DATETIME"`
-	UpdateAt time.Time `json:"update_at" xorm:"not null default CURRENT_TIMESTAMP DATETIME"`
+	Id       int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	AdminId  int    `json:"admin_id" xorm:"default 0 comment('管理员id') INT(11)"`
+	MediumId int    `json:"medium_id" xorm:"not null default 0 comment('媒体id') INT(11)"`
+	CreateAt string `json:"create_at" xorm:"not null default CURRENT_TIMESTAMP DATETIME"`
+	UpdateAt string `json:"update_at" xorm:"not null default CURRENT_TIMESTAMP DATETIME"`
 }

src/model/egg_energy_basic_setting.go

@@ -0,0 +1,41 @@
+package model
+
+type EggEnergyBasicSetting struct {
+	Id                         int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	IsOpen                     int    `json:"is_open" xorm:"not null default 1 comment('是否开启(1:开启 0:关闭)') TINYINT(1)"`
+	PersonEggEnergyCoinId      int    `json:"person_egg_energy_coin_id" xorm:"not null default 0 comment('个人蛋蛋能量对应虚拟币id') INT(11)"`
+	TeamEggEnergyCoinId        int    `json:"team_egg_energy_coin_id" xorm:"not null default 0 comment('团队绿色能量对应虚拟币id') INT(11)"`
+	PersonEggPointsCoinId      int    `json:"person_egg_points_coin_id" xorm:"not null default 0 comment('个人蛋蛋积分对应虚拟币id') INT(11)"`
+	TeamEggPointsCoinId        int    `json:"team_egg_points_coin_id" xorm:"not null default 0 comment('团队蛋蛋积分对应虚拟币id') INT(11)"`
+	ContributionCoinId         int    `json:"contribution_coin_id" xorm:"not null default 0 comment('贡献值对应虚拟币id') INT(11)"`
+	TotalIssuanceAmount        string `json:"total_issuance_amount" xorm:"not null comment('总发行量') DECIMAL(28,8)"`
+	TotalTechnologyTeam        string `json:"total_technology_team" xorm:"not null comment('技术团队') DECIMAL(28,8)"`
+	TotalAngelInvestor         string `json:"total_angel_investor" xorm:"not null comment('天使投资人') DECIMAL(28,8)"`
+	TotalOperateFund           string `json:"total_operate_fund" xorm:"not null comment('运营资金') DECIMAL(28,8)"`
+	TotalEcologicalDevelopment string `json:"total_ecological_development" xorm:"not null comment('生态建设') DECIMAL(28,8)"`
+	TotalTeamDividends         string `json:"total_team_dividends" xorm:"not null comment('团队分红') DECIMAL(28,8)"`
+	TotalUserForPerson         string `json:"total_user_for_person" xorm:"not null comment('个人区域') DECIMAL(28,8)"`
+	TotalUserForTeam           string `json:"total_user_for_team" xorm:"not null comment('团队区域') DECIMAL(28,8)"`
+	InitialPrice               string `json:"initial_price" xorm:"not null comment('初始价格') DECIMAL(28,8)"`
+	NowPrice                   string `json:"now_price" xorm:"not null comment('当前价格') DECIMAL(28,8)"`
+	PlanetTotalValue           string `json:"planet_total_value" xorm:"not null comment('星球总价值') DECIMAL(28,8)"`
+	MarketplaceMerchantNums    string `json:"marketplace_merchant_nums" xorm:"not null comment('市商数量') DECIMAL(28,8)"`
+	MarketplaceMerchantFunds   string `json:"marketplace_merchant_funds" xorm:"not null comment('市商资金') DECIMAL(28,8)"`
+	DevelopmentCommittee       string `json:"development_committee" xorm:"not null comment('发展委员会') DECIMAL(28,8)"`
+	PublicWelfareAndCharity    string `json:"public_welfare_and_charity" xorm:"not null comment('公益慈善') DECIMAL(28,8)"`
+	StarLevelDividends         string `json:"star_level_dividends" xorm:"not null comment('星级分红') DECIMAL(28,8)"`
+	DestructionQuantityNums    string `json:"destruction_quantity_nums" xorm:"not null comment('销毁数量') DECIMAL(28,8)"`
+	DestructionSetting         string `json:"destruction_setting" xorm:"not null comment('销毁设置') TEXT"`
+	IsLimitDividend            int    `json:"is_limit_dividend" xorm:"not null default 1 comment('是否限制分红(会员本人不活跃,没有星级能量分红)') TINYINT(1)"`
+	SettlementQuantity         int    `json:"settlement_quantity" xorm:"not null default 0 comment('结算数量(百分比)') INT(11)"`
+	DirectPushReward           string `json:"direct_push_reward" xorm:"not null comment('直推奖励') TEXT"`
+	PriceSetting               string `json:"price_setting" xorm:"not null comment('价格设置') TEXT"`
+	VipEquitySetting           string `json:"vip_equity_setting" xorm:"not null comment('会员权益') TEXT"`
+	VideoRewardIsOpen          int    `json:"video_reward_is_open" xorm:"not null default 1 comment('视屏奖励是否开启(1:开启 0:关闭)') TINYINT(1)"`
+	VideoRewardSystem          string `json:"video_reward_system" xorm:"not null comment('视屏奖励机制') TEXT"`
+	ExchangeRules              string `json:"exchange_rules" xorm:"not null comment('兑换规则') TEXT"`
+	NewUserIncentiveRules      string `json:"new_user_incentive_rules" xorm:"not null comment('新用户激励规则') TEXT"`
+	RewardSystem               string `json:"reward_system" xorm:"not null comment('圈层奖励机制') TEXT"`
+	CreateAt                   string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt                   string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/egg_energy_community_dividends.go

@@ -0,0 +1,12 @@
+package model
+
+type EggEnergyCommunityDividends struct {
+	Id         int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	Nums       int    `json:"nums" xorm:"not null default 0 comment('分红数量') INT(11)"`
+	Name       string `json:"name" xorm:"not null default '' comment('名称') VARCHAR(255)"`
+	CoinId     int    `json:"coin_id" xorm:"not null default 0 comment('虚拟币id') INT(11)"`
+	PersonsNum int    `json:"persons_num" xorm:"not null default 0 comment('分红人数') INT(11)"`
+	IsOver     int    `json:"is_over" xorm:"not null default 0 comment('是否分红完毕') TINYINT(1)"`
+	CreateAt   string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt   string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/egg_energy_community_dividends_with_user.go

@@ -0,0 +1,9 @@
+package model
+
+type EggEnergyCommunityDividendsWithUser struct {
+	Id       int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	Uid      int64  `json:"uid" xorm:"not null default 0 comment('用户id') BIGINT(20)"`
+	Memo     string `json:"memo" xorm:"not null default '' comment('备注') VARCHAR(255)"`
+	CreateAt string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/egg_energy_community_dividends_with_user_records.go

@@ -0,0 +1,11 @@
+package model
+
+type EggEnergyCommunityDividendsWithUserRecords struct {
+	Id        int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	Uid       int64  `json:"uid" xorm:"not null default 0 comment('用户id') BIGINT(20)"`
+	Value     string `json:"value" xorm:"not null default 0.0000000000 comment('数量') DECIMAL(28,10)"`
+	RecordsId int    `json:"records_id" xorm:"not null default 0 comment('记录id') INT(11)"`
+	CoinId    int    `json:"coin_id" xorm:"not null default 0 comment('虚拟币id') INT(11)"`
+	CreateAt  string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt  string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/egg_energy_user_activity.go

@@ -0,0 +1,7 @@
+package model
+
+type EggEnergyUserActivity struct {
+	Id   int64  `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Uid  int    `json:"uid" xorm:"not null default 0 comment('用户id') index(idx_uid_date) INT(11)"`
+	Date string `json:"date" xorm:"not null default '0000-00-00' comment('日期') index(idx_uid_date) CHAR(50)"`
+}

src/model/egg_energy_user_watch_records.go

@@ -0,0 +1,14 @@
+package model
+
+import (
+	"time"
+)
+
+type EggEnergyUserWatchRecords struct {
+	Id                int64     `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Uid               int64     `json:"uid" xorm:"not null default 0 comment('用户id') index BIGINT(20)"`
+	NextWatchAdDate   time.Time `json:"next_watch_ad_date" xorm:"not null default 'CURRENT_TIMESTAMP' comment('下一轮观看视屏时间') DATETIME"`
+	ResidueWatchAdNum int       `json:"residue_watch_ad_num" xorm:"not null default 0 comment('剩余观看视屏数') INT(11)"`
+	CreateAt          time.Time `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt          time.Time `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/egg_sign_in.go

@@ -0,0 +1,9 @@
+package model
+
+type EggSignIn struct {
+	Id          int64  `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Uid         int64  `json:"uid" xorm:"not null default 0 comment('用户id') INT(11)"`
+	StartTime   string `json:"start_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('签到开始时间') DATETIME"`
+	EndTime     string `json:"end_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('签到结束时间') DATETIME"`
+	IsCompleted int    `json:"is_completed" xorm:"not null default 0 comment('是否完成(0:未完成 1:已完成)') TINYINT(1)"`
+}

src/model/egg_star_level_dividends_records.go

@@ -0,0 +1,9 @@
+package model
+
+type EggStarLevelDividendsRecords struct {
+	Id                     int64  `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Amount                 string `json:"amount" xorm:"not null default 0.00000000 comment('分红值') DECIMAL(20,8)"`
+	AlreadyDividendsAmount string `json:"already_dividends_amount" xorm:"not null default 0.00000000 comment('已分红值') DECIMAL(20,8)"`
+	NotDividendsAmount     string `json:"not_dividends_amount" xorm:"not null default 0.00000000 comment('未分红值') DECIMAL(20,8)"`
+	Date                   string `json:"date" xorm:"not null default '0000-00-00' comment('日期') CHAR(50)"`
+}

src/model/public_platoon_basic_setting.go

@@ -0,0 +1,14 @@
+package model
+
+type PublicPlatoonBasicSetting struct {
+	Id                         int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	IsOpen                     int    `json:"is_open" xorm:"not null default 1 comment('是否开启(1:开启 0:关闭)') TINYINT(1)"`
+	OriginatorUid              int    `json:"originator_uid" xorm:"not null default 0 comment('创始人uid') INT(11)"`
+	SeveralTimes               int    `json:"several_times" xorm:"not null default 3 comment('几乘') TINYINT(3)"`
+	SeveralRows                int    `json:"several_rows" xorm:"not null default 3 comment('几排') TINYINT(3)"`
+	SystemPunishReplace        int    `json:"system_punish_replace" xorm:"not null default 1 comment('是否位置滑落 被新用户替换 0否 1是') TINYINT(1)"`
+	SystemPunishReplaceValue   int    `json:"system_punish_replace_value" xorm:"not null default 0 comment('xx天未活跃，处罚滑落') INT(11)"`
+	IsSelfActiveGetTeamRevenue int    `json:"is_self_active_get_team_revenue" xorm:"not null default 1 comment('会员本人没有日活，没有团队奖励(1:开启 0:关闭)') TINYINT(1)"`
+	CreateAt                   string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt                   string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/public_platoon_free_punish_with_user.go

@@ -0,0 +1,6 @@
+package model
+
+type PublicPlatoonFreePunishWithUser struct {
+	Id  int   `json:"id" xorm:"not null pk autoincr INT(11)"`
+	Uid int64 `json:"uid" xorm:"not null default 0 comment('用户id') INT(11)"`
+}

src/model/public_platoon_records_punish_with_user.go

@@ -0,0 +1,7 @@
+package model
+
+type PublicPlatoonRecordsPunishWithUser struct {
+	Id   int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	Uid  int64  `json:"uid" xorm:"not null default 0 comment('用户id') INT(11)"`
+	Date string `json:"date" xorm:"default '0000-00-00' comment('处罚日期') CHAR(50)"`
+}

src/model/public_platoon_user_relation.go

@@ -0,0 +1,52 @@
+package model
+
+type PublicPlatoonUserRelation struct {
+	Id            int    `json:"id" xorm:"not null pk autoincr INT(11)"`
+	Uid           int64  `json:"uid" xorm:"not null default 0 comment('用户id(若为-1,则代表等待新用户填充)') index INT(11)"`
+	RecommendUid  int64  `json:"recommend_uid" xorm:"not null default 0 comment('推荐人id') INT(11)"`
+	FatherUid     string `json:"father_uid" xorm:"not null default '' comment('父级uid(123456-563464-438384)') index VARCHAR(100)"`
+	FatherUid1    int64  `json:"father_uid1" xorm:"not null default 0 comment('父级uid_1') INT(11)"`
+	FatherUid2    int64  `json:"father_uid2" xorm:"not null default 0 comment('父级uid_2') INT(11)"`
+	FatherUid3    int64  `json:"father_uid3" xorm:"not null default 0 comment('父级uid_3') INT(11)"`
+	FatherUid4    int64  `json:"father_uid4" xorm:"not null default 0 comment('父级uid_4') INT(11)"`
+	FatherUid5    int64  `json:"father_uid5" xorm:"not null default 0 comment('父级uid_5') INT(11)"`
+	FatherUid6    int64  `json:"father_uid6" xorm:"not null default 0 comment('父级uid_6') INT(11)"`
+	FatherUid7    int64  `json:"father_uid7" xorm:"not null default 0 comment('父级uid_7') INT(11)"`
+	FatherUid8    int64  `json:"father_uid8" xorm:"not null default 0 comment('父级uid_8') INT(11)"`
+	FatherUid9    int64  `json:"father_uid9" xorm:"not null default 0 comment('父级uid_9') INT(11)"`
+	Pid1          int64  `json:"pid1" xorm:"not null default 0 comment('父级id_1') INT(11)"`
+	Pid2          int64  `json:"pid2" xorm:"not null default 0 comment('父级id_2') INT(11)"`
+	Pid3          int64  `json:"pid3" xorm:"not null default 0 comment('父级id_3') INT(11)"`
+	Pid4          int64  `json:"pid4" xorm:"not null default 0 comment('父级id_4') INT(11)"`
+	Pid5          int64  `json:"pid5" xorm:"not null default 0 comment('父级id_5') INT(11)"`
+	Pid6          int64  `json:"pid6" xorm:"not null default 0 comment('父级id_6') INT(11)"`
+	Pid7          int64  `json:"pid7" xorm:"not null default 0 comment('父级id_7') INT(11)"`
+	Pid8          int64  `json:"pid8" xorm:"not null default 0 comment('父级id_8') INT(11)"`
+	Pid9          int64  `json:"pid9" xorm:"not null default 0 comment('父级id_9') INT(11)"`
+	Position      int64  `json:"position" xorm:"not null default 1 comment('位置(以自己为创始人)') INT(11)"`
+	Position1     int64  `json:"position1" xorm:"not null default 0 comment('位置_1(以pid1为创始人中网的位置)') INT(11)"`
+	Position2     int64  `json:"position2" xorm:"not null default 0 comment('位置_2') INT(11)"`
+	Position3     int64  `json:"position3" xorm:"not null default 0 comment('位置_3') INT(11)"`
+	Position4     int64  `json:"position4" xorm:"not null default 0 comment('位置_4') INT(11)"`
+	Position5     int64  `json:"position5" xorm:"not null default 0 comment('位置_5') INT(11)"`
+	Position6     int64  `json:"position6" xorm:"not null default 0 comment('位置_6') INT(11)"`
+	Position7     int64  `json:"position7" xorm:"not null default 0 comment('位置_7') INT(11)"`
+	Position8     int64  `json:"position8" xorm:"not null default 0 comment('位置_8') INT(11)"`
+	Position9     int64  `json:"position9" xorm:"not null default 0 comment('位置_9') INT(11)"`
+	Level         int    `json:"level" xorm:"not null default 1 comment('等级(以自己为创始人)') INT(11)"`
+	Level1        int    `json:"level1" xorm:"not null default 0 comment('等级_1(以pid1为创始人中网的等级)') INT(11)"`
+	Level2        int    `json:"level2" xorm:"not null default 0 comment('等级_2') INT(11)"`
+	Level3        int    `json:"level3" xorm:"not null default 0 comment('等级_3') INT(11)"`
+	Level4        int    `json:"level4" xorm:"not null default 0 comment('等级_4') INT(11)"`
+	Level5        int    `json:"level5" xorm:"not null default 0 comment('等级_5') INT(11)"`
+	Level6        int    `json:"level6" xorm:"not null default 0 comment('等级_6') INT(11)"`
+	Level7        int    `json:"level7" xorm:"not null default 0 comment('等级_7') INT(11)"`
+	Level8        int    `json:"level8" xorm:"not null default 0 comment('等级_8') INT(11)"`
+	Level9        int    `json:"level9" xorm:"default 0 comment('等级_9') INT(11)"`
+	LevelTotal    int    `json:"level_total" xorm:"not null default 1 comment('等级(整个系统)') INT(11)"`
+	JoinAt        string `json:"join_at" xorm:"not null default 'CURRENT_TIMESTAMP' comment('加入公排时间') DATETIME"`
+	HasSonNum     int    `json:"has_son_num" xorm:"not null default 0 comment('拥有直属下级数量') TINYINT(2)"`
+	IsAllowPunish int    `json:"is_allow_punish" xorm:"not null default 1 comment('是否允许处罚(1:允许 2:不允许)') TINYINT(1)"`
+	CreateAt      string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt      string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/public_platoon_user_system_punish_records.go

@@ -0,0 +1,14 @@
+package model
+
+type PublicPlatoonUserSystemPunishRecords struct {
+	Id          int64  `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Uid         int64  `json:"uid" xorm:"not null comment('用户id') index INT(11)"`
+	OldPosition int64  `json:"old_position" xorm:"not null default 0 comment('位置(旧)') INT(11)"`
+	NewPosition int64  `json:"new_position" xorm:"not null default 0 comment('位置(新)') INT(11)"`
+	Date        string `json:"date" xorm:"not null default '' comment('日期(0000-00)') VARCHAR(50)"`
+	Title       string `json:"title" xorm:"not null default '' comment('标题') VARCHAR(100)"`
+	Reason      string `json:"reason" xorm:"not null default '' comment('原因') VARCHAR(255)"`
+	Type        int    `json:"type" xorm:"not null default 1 comment('类型(1:大公排 2:小公排)') TINYINT(1)"`
+	CreateAt    string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt    string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/user.go

@@ -0,0 +1,23 @@
+package model
+
+type User struct {
+	Id               int64  `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Phone            string `json:"phone" xorm:"not null default '' comment('手机号') VARCHAR(255)"`
+	UnionId          string `json:"union_id" xorm:"not null default '' comment('微信用户id') VARCHAR(255)"`
+	OpenId           string `json:"open_id" xorm:"not null default '' comment('微信openid') VARCHAR(255)"`
+	Nickname         string `json:"nickname" xorm:"not null default '' comment('昵称') VARCHAR(255)"`
+	Avatar           string `json:"avatar" xorm:"not null default '' comment('头像') VARCHAR(255)"`
+	Password         string `json:"password" xorm:"not null default '' comment('密码') CHAR(50)"`
+	Passcode         string `json:"passcode" xorm:"not null default '' comment('支付密码') CHAR(50)"`
+	Level            int    `json:"level" xorm:"not null default 0 comment('用户等级id') INT(11)"`
+	InviteTotal      int    `json:"invite_total" xorm:"not null default 0 comment('直推邀请总人数') INT(11)"`
+	State            int    `json:"state" xorm:"not null default 1 comment('1正常,2冻结') TINYINT(1)"`
+	LastLoginIp      string `json:"last_login_ip" xorm:"not null default '' comment('最后登录IP') CHAR(50)"`
+	Sex              int    `json:"sex" xorm:"not null default 0 comment('性别(0:未知 1:男 2:女)') TINYINT(1)"`
+	ParentUid        int64  `json:"parent_uid" xorm:"not null default 0 comment('父级id') BIGINT(20)"`
+	SystemInviteCode string `json:"system_invite_code" xorm:"not null default '' comment('系统邀请码') CHAR(50)"`
+	CustomInviteCode string `json:"custom_invite_code" xorm:"not null default '' comment('自定义邀请码') CHAR(50)"`
+	Memo             string `json:"memo" xorm:"not null default '' comment('备注信息') VARCHAR(244)"`
+	CreateAt         string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt         string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/user_level.go

@@ -0,0 +1,11 @@
+package model
+
+type UserLevel struct {
+	Id          int    `json:"id" xorm:"not null pk autoincr comment('等级id') INT(11)"`
+	LevelName   string `json:"level_name" xorm:"not null default '' comment('等级名称') CHAR(50)"`
+	LevelWeight int    `json:"level_weight" xorm:"not null default 0 comment('等级权重') INT(11)"`
+	IsUse       int    `json:"is_use" xorm:"not null default 1 comment('是否开启(0否，1是)') TINYINT(1)"`
+	Memo        string `json:"memo" xorm:"not null default '' comment('备注') VARCHAR(255)"`
+	CreateAt    string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt    string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}

src/model/user_relate.go

@@ -0,0 +1,9 @@
+package model
+
+type UserRelate struct {
+	Id         int64  `json:"id" xorm:"pk autoincr comment('主键') BIGINT(10)"`
+	ParentUid  int    `json:"parent_uid" xorm:"not null default 0 comment('上级会员ID') unique(idx_union_u_p_id) INT(20)"`
+	Uid        int64  `json:"uid" xorm:"not null default 0 comment('关联UserID') unique(idx_union_u_p_id) INT(20)"`
+	Level      int    `json:"level" xorm:"not null default 1 comment('推广等级(1直属，大于1非直属)') INT(10)"`
+	InviteTime string `json:"invite_time" xorm:"default 'CURRENT_TIMESTAMP' comment('邀请时间') TIMESTAMP"`
+}

src/model/user_wallet.go

@@ -0,0 +1,9 @@
+package model
+
+type UserWallet struct {
+	Id       int64  `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Uid      int64  `json:"uid" xorm:"not null default 0 comment('用户id') BIGINT(20)"`
+	Amount   string `json:"amount" xorm:"not null default 0.00 comment('用户余额') DECIMAL(10,2)"`
+	CreateAt string `json:"create_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+	UpdateAt string `json:"update_at" xorm:"not null default 'CURRENT_TIMESTAMP' DATETIME"`
+}