add reverse:for v3.5.3 区域代理分佣

db/db_regional_agent_user_belong.go

@@ -0,0 +1,274 @@
+package db
+
+import (
+	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/db/model"
+	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/md"
+	zhios_order_relate_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/utils"
+	"errors"
+	"fmt"
+	"reflect"
+	"strings"
+	"xorm.io/xorm"
+)
+
+type RegionalAgentUserBelongWithSession struct {
+	Session                 *xorm.Session
+	RegionalAgentUserBelong *model.RegionalAgentUserBelong
+}
+
+// 联表查询
+type RegionalAgentUserBelongJoinUser struct {
+	model.RegionalAgentUserBelong `xorm:"extends"`
+	model.User                    `xorm:"extends"`
+	model.UserLevel               `xorm:"extends"`
+	model.UserProfile             `xorm:"extends"`
+}
+
+// 单条记录插入
+func (rab RegionalAgentUserBelongWithSession) InsertOne() error {
+	_, err := rab.Session.InsertOne(rab.RegionalAgentUserBelong)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// 多条记录插入
+func (rab RegionalAgentUserBelongWithSession) InsertMulti(belong []model.RegionalAgentUserBelong) error {
+	_, err := rab.Session.Table("regional_agent_user_belong").InsertMulti(belong)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// 跟pvd和uid更新
+func (rab RegionalAgentUserBelongWithSession) UpdateRegionalAgentUserBelong(cols ...string) (bool, error) {
+	_, err := rab.Session.Table("regional_agent_user_belong").
+		Where("id = ? ", rab.RegionalAgentUserBelong.Id).
+		Cols(cols...).
+		Update(rab.RegionalAgentUserBelong)
+	/*Where("uid = ? AND pvd = '?' is_use = ?", rab.RegionalAgentUserBelong.Uid, rab.RegionalAgentUserBelong.Pvd).
+	Update(rab.RegionalAgentUserBelong)*/
+	if err != nil {
+		return false, err
+	}
+	return true, nil
+}
+
+//
+func (rab RegionalAgentUserBelongWithSession) GetOneRecordByUidAndRegionId() (bool, error) {
+	isHas, err := rab.Session.Table("regional_agent_user_belong").
+		Where("uid = ? AND pvd = 'COMMON' AND is_use = 1", rab.RegionalAgentUserBelong.Uid).
+		Get(rab.RegionalAgentUserBelong)
+	sql, _ := rab.Session.LastSQL()
+	fmt.Printf("123 %s\n uid: %s\n", sql, rab.RegionalAgentUserBelong.Uid)
+	if err != nil {
+		return false, err
+	}
+	return isHas, nil
+}
+
+// 获取代理区域所有会员
+func (rab RegionalAgentUserBelongWithSession) GetAllRegionalAgentUserBelong(condition string, page, pageSize int, keyword,
+	sort, commissionSort, orderSort, userLevel string) (*[]RegionalAgentUserBelongJoinUser, error) {
+	if page == 0 && pageSize == 0 {
+		page = 1
+		pageSize = 10
+	}
+	var userBelongList []RegionalAgentUserBelongJoinUser
+	userJoinCondition := ""
+	orderBy := ""
+	//groupBy := ""
+	selectColumn := "*"
+	if keyword != "" {
+		userJoinCondition = " AND (phone like '%" + keyword + "%' OR nickname like '%" + keyword + "%')"
+	}
+
+	if sort != "" {
+		selectColumn += ",count(user_relate.parent_uid) as sort"
+		orderBy += "sort " + sort + ","
+	}
+	if commissionSort != "" {
+		orderBy += "user_profile.fin_commission " + commissionSort + ","
+	}
+	if orderSort != "" {
+		selectColumn += ", count(regional_agent_user_ord.uid) as order_count,"
+		orderBy += "order_count " + orderSort + ","
+	}
+	if userLevel != "" {
+		condition += " AND regional_agent_user_belong.user_level = " + userLevel
+		orderBy += "regional_agent_user_belong.create_time DESC"
+	}
+	orderBy = strings.TrimRight(orderBy, ",")
+	selectColumn = strings.TrimRight(selectColumn, ",")
+	//rab.Session.Join("INNER", "user_relate", "")
+	rab.Session.Join("INNER", "user", "regional_agent_user_belong.uid = user.uid"+userJoinCondition)
+	rab.Session.Join("INNER", "user_level", "user.level = user_level.id")
+	rab.Session.Join("INNER", "user_profile", "regional_agent_user_belong.uid = user_profile.uid")
+	rab.Session.Join("LEFT", "regional_agent_user_ord", "regional_agent_user_belong.uid = regional_agent_user_ord.uid")
+	rab.Session.Join("LEFT", "user_relate", "regional_agent_user_ord.uid = user_relate.parent_uid")
+	err := rab.Session.Select(selectColumn).Table("regional_agent_user_belong").
+		Where(condition).
+		GroupBy("regional_agent_user_belong.uid").
+		Limit(pageSize, (page-1)*pageSize).
+		OrderBy(orderBy).
+		Find(&userBelongList)
+	if err != nil {
+		return nil, err
+	}
+	return &userBelongList, nil
+}
+
+// 根据pvd查询
+func (rab RegionalAgentUserBelongWithSession) GetRegionalAgentUserBelongByUidAndPvd() (bool, error) {
+	//var belong *model.RegionalAgentUserBelong
+	isHas, err := rab.Session.Table("regional_agent_user_belong").
+		Get(rab.RegionalAgentUserBelong)
+	sql, _ := rab.Session.LastSQL()
+	fmt.Printf("%s\n", sql)
+	if err != nil {
+		return false, err
+	}
+	return isHas, nil
+}
+
+// 根据用户id查找用户加入的所有网点
+func (rab RegionalAgentUserBelongWithSession) GetRegionalAgentUserBelongByUid() ([]*model.RegionalAgentUserBelong, error) {
+	var list []*model.RegionalAgentUserBelong
+	err := rab.Session.Table("regional_agent_user_belong").Where("uid = ? AND is_use = 1", rab.RegionalAgentUserBelong.Uid).Find(&list)
+	if err != nil {
+		return nil, err
+	}
+	return list, nil
+}
+
+func GetCountByRegionalAgentUserBelong(Db *xorm.Engine, condition string) int {
+	var RegionalAgentUserBelong model.RegionalAgentUserBelong
+	session := Db.Where(condition)
+	count, err := session.Count(&RegionalAgentUserBelong)
+	if err != nil {
+		return 0
+	}
+	return int(count)
+}
+
+// GetCountByRegionalAgentUserBelongByParams 通过传入的参数查询数据(单条)
+func GetCountByRegionalAgentUserBelongByParams(Db *xorm.Engine, uid interface{}, params map[string]interface{}) (*model.RegionalAgentUserBelong, error) {
+	var m model.RegionalAgentUserBelong
+	var query = fmt.Sprintf("%s =?", params["key"])
+	if has, err := Db.Where("uid = ?", uid).Where(query, params["value"]).Get(&m); err != nil || has == false {
+		return nil, err
+	}
+	return &m, nil
+}
+
+// GetCountByRegionalAgentUserBelong 通过传入的参数查询数据(单条)
+func GetCountByRegionalAgentUserBelongById(Db *xorm.Engine, uid interface{}, pvd string, newPvd string) (*model.RegionalAgentUserBelong, error) {
+	var m model.RegionalAgentUserBelong
+	if newPvd == md.PVD_COMMON { //公共的
+		pvd = newPvd
+	}
+	if pvd == md.PVD_USER_LV_UP || pvd == md.PVD_CARD {
+		pvd = md.PVD_COMMON
+	}
+	fmt.Println(pvd)
+	if pvd == md.PVD_COMMON {
+		if has, err := Db.Where("uid = ? and (pvd='' or pvd=?)", uid, pvd).Get(&m); err != nil || has == false {
+			return nil, err
+		}
+		return &m, nil
+	} else {
+		if has, err := Db.Where("uid = ? and pvd=?", uid, pvd).Get(&m); err != nil || has == false {
+			return nil, err
+		}
+		return &m, nil
+	}
+}
+
+// RegionalAgentOrdBelongInsert 插入单条数据
+func RegionalAgentOrdBelongInsert(Db *xorm.Engine, regionalAgentRegion *model.RegionalAgentOrdBelong) (int64, error) {
+	_, err := Db.InsertOne(regionalAgentRegion)
+	if err != nil {
+		return 0, err
+	}
+	return regionalAgentRegion.Id, nil
+}
+
+// RegionalAgentRegionGetOneByParams 通过传入的参数查询数据(单条)
+func RegionalAgentRegionGetOneByParams(Db *xorm.Engine, params map[string]interface{}) (*model.RegionalAgentRegion, error) {
+	var m model.RegionalAgentRegion
+	var query = fmt.Sprintf("%s =?", params["key"])
+	if has, err := Db.Where(query, params["value"]).Get(&m); err != nil || has == false {
+		return nil, err
+	}
+	return &m, nil
+}
+
+func RegionalAgentUserFindByValid(Db *xorm.Engine, regionId string) (*[]model.RegionalAgentUser, error) {
+	var m []model.RegionalAgentUser
+	err := Db.Where("region_id=? and deleted_time IS NULL", regionId).Find(&m)
+	if err != nil {
+		return nil, err
+	}
+	return &m, nil
+}
+
+// GetCountByRegionalAgentBase 通过传入的参数查询数据(单条)
+func GetCountByRegionalAgentBase(Db *xorm.Engine) (*model.RegionalAgentBase, error) {
+	var m model.RegionalAgentBase
+	get, err := Db.Get(&m)
+	if err != nil {
+		return &m, err
+	}
+	if !get {
+		return &m, errors.New("无")
+	}
+	return &m, nil
+}
+
+// VirtualCoinFindByParams 通过传入的参数查询数据(多条)
+func VirtualCoinFindByParams(Db *xorm.Engine, params map[string]interface{}) (*[]model.VirtualCoin, error) {
+	var m []model.VirtualCoin
+	if params["key"] == nil {
+		//查询全部数据
+		err := Db.Find(&m)
+		if err != nil {
+			return nil, err
+		}
+		return &m, nil
+	} else {
+		if reflect.TypeOf(params["value"]).Kind() == reflect.Slice {
+			//指定In查询
+			if err := Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).Find(&m); err != nil {
+				return nil, err
+			}
+			return &m, nil
+		} else {
+			var query = fmt.Sprintf("%s =?", params["key"])
+			err := Db.Where(query, params["value"]).Find(&m)
+			if err != nil {
+				return nil, err
+			}
+			return &m, nil
+		}
+
+	}
+}
+func RegionalAgentCalcSystemRelateInsert(Db *xorm.Engine, regionalAgentCalcSystemRelate *model.RegionalAgentCalcSystemRelate) (int64, error) {
+	_, err := Db.InsertOne(regionalAgentCalcSystemRelate)
+	if err != nil {
+		return 0, err
+	}
+	return regionalAgentCalcSystemRelate.Id, nil
+}
+
+// GetCountByRegionalAgentSchemeInfoByParams 通过传入的参数查询数据(单条)
+func GetCountByRegionalAgentSchemeInfoByParams(Db *xorm.Engine, params map[string]interface{}) (*model.RegionalAgentScheme, error) {
+	var m model.RegionalAgentScheme
+	var query = fmt.Sprintf("%s =?", params["key"])
+	if has, err := Db.Where(query, params["value"]).Get(&m); err != nil || has == false {
+		return nil, err
+	}
+	return &m, nil
+}

db/model/regional_agent_base.go

@@ -0,0 +1,39 @@
+package model
+
+import (
+	"time"
+)
+
+type RegionalAgentBase struct {
+	Id                              int       `json:"id" xorm:"not null pk autoincr INT(11)"`
+	OpenProvinceAgent               int       `json:"open_province_agent" xorm:"not null comment('是否开启省级代理（否：0；是：1）') TINYINT(1)"`
+	ProvinceSchemeId                int       `json:"province_scheme_id" xorm:"comment('省级方案id') INT(11)"`
+	OpenCityAgent                   int       `json:"open_city_agent" xorm:"not null default 0 comment('是否开启市级代理（否：0；是：1）') TINYINT(1)"`
+	CitySchemeId                    int       `json:"city_scheme_id" xorm:"comment('市级方案id') INT(11)"`
+	OpenDistrictAgent               int       `json:"open_district_agent" xorm:"not null default 0 comment('是否开启县区级代理（否：0；是：1）') TINYINT(1)"`
+	DistrictSchemeId                int       `json:"district_scheme_id" xorm:"default 0 comment('县区级方案id') INT(11)"`
+	OpenBranchesAgent               int       `json:"open_branches_agent" xorm:"not null default 0 comment('是否开启网点代理（否：0；是：1）') TINYINT(1)"`
+	BranchesSchemeId                int       `json:"branches_scheme_id" xorm:"default 1 comment('网点方案id') INT(11)"`
+	UpgradeSequence                 int       `json:"upgrade_sequence" xorm:"not null default 0 comment('升级顺序（1逐级升级2任意级别升级）') TINYINT(1)"`
+	AutoOrderBy                     int       `json:"auto_order_by" xorm:"not null default 0 comment('订单归属，网点加入方式（1定位后自动加入，2用户手动选择加入）') TINYINT(1)"`
+	ScopeOfOrder                    int       `json:"scope_of_order" xorm:"default 0 comment('当选择定位后自动加入，该字段必填；订单归属范围（km单位）用处：定位后自动绑定xxkm之内离用户最近的网点') INT(11)"`
+	RemindType                      int       `json:"remind_type" xorm:"default 0 comment('当选择用户手动选择加入，该字段必填；应用内用户选择网点弹窗方式（0关闭，1正常开启，2强制开启）') TINYINT(1)"`
+	ScopeOfBranches                 int       `json:"scope_of_branches" xorm:"not null comment('网点展示范围（单位：km）') INT(11)"`
+	PayChannel                      string    `json:"pay_channel" xorm:"not null comment('支付方式设置（[1,2,3]）1余额支付2微信支付3支付宝支付') VARCHAR(255)"`
+	CreateTime                      time.Time `json:"create_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('创建时间') DATETIME"`
+	UpdateTime                      time.Time `json:"update_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('更新时间') DATETIME"`
+	MallAutoOrderBy                 int       `json:"mall_auto_order_by" xorm:"default 0 comment('订单归属，网点加入方式（1定位后自动加入，2用户手动选择加入 3以订单收货地址自动归属）') TINYINT(1)"`
+	O2oAutoOrderBy                  int       `json:"o2o_auto_order_by" xorm:"default 0 comment('订单归属，网点加入方式（1定位后自动加入，2用户手动选择加入 4以消费商家定位自动归属）') TINYINT(1)"`
+	MallScopeOfOrder                int       `json:"mall_scope_of_order" xorm:"default 0 comment('当选择定位后自动加入，该字段必填；订单归属范围（km单位）用处：定位后自动绑定xxkm之内离用户最近的网点') INT(11)"`
+	MallRemindType                  int       `json:"mall_remind_type" xorm:"default 0 comment('当选择用户手动选择加入，该字段必填；应用内用户选择网点弹窗方式（0关闭，1正常开启，2强制开启）') TINYINT(1)"`
+	O2oScopeOfOrder                 int       `json:"o2o_scope_of_order" xorm:"default 0 comment('当选择定位后自动加入，该字段必填；订单归属范围（km单位）用处：定位后自动绑定xxkm之内离用户最近的网点') INT(11)"`
+	O2oRemindType                   int       `json:"o2o_remind_type" xorm:"default 0 comment('当选择用户手动选择加入，该字段必填；应用内用户选择网点弹窗方式（0关闭，1正常开启，2强制开启）') TINYINT(1)"`
+	IsJoin                          int       `json:"is_join" xorm:"default 0 comment('是否加入，1：是，2：否， 3:关闭') TINYINT"`
+	CoinRewardOpen                  int       `json:"coin_reward_open" xorm:"default 0 comment('1：启用,2：关闭') TINYINT(1)"`
+	CoinSelect                      string    `json:"coin_select" xorm:"default 0 comment('选中的虚拟币') VARCHAR(255)"`
+	CoinSet                         string    `json:"coin_set" xorm:"comment('虚拟币设置') TEXT"`
+	UserToBeRegionSet               int       `json:"user_to_be_region_set" xorm:"default 0 comment('用户成为区域代理设置：1、一个用户可以成为多个区域代理身份，2、一个用户只能有一个区域代理身份') TINYINT(4)"`
+	AutoAddRegion                   int       `json:"auto_add_region" xorm:"default 0 comment('自动加入网点设置：1、自动获取位置并加入网点 2、手动选择网点加入') TINYINT(4)"`
+	CustomerSetRegion               int       `json:"customer_set_region" xorm:"default 0 comment('网点自定义设置：1、用户可以手动添加网点 2、只允许后台添加网点') TINYINT(4)"`
+	SiteOfMinimumSeparationDistance string    `json:"site_of_minimum_separation_distance" xorm:"comment('网点之间最小间隔距离(单位:km)') VARCHAR(255)"`
+}

db/model/regional_agent_calc_system_relate.go

@@ -0,0 +1,19 @@
+package model
+
+import (
+	"time"
+)
+
+type RegionalAgentCalcSystemRelate struct {
+	Id                    int64     `json:"id" xorm:"pk autoincr BIGINT(11)"`
+	Uid                   int       `json:"uid" xorm:"not null comment('用户Id') INT(11)"`
+	DivideAmount          float64   `json:"divide_amount" xorm:"not null comment('分佣所得金额') DOUBLE"`
+	DivideVirtualCurrency string    `json:"divide_virtual_currency" xorm:"comment('分佣所得虚拟币详情') TEXT"`
+	Ext                   string    `json:"ext" xorm:"comment('额外字段') TEXT"`
+	Status                int       `json:"status" xorm:"not null default 1 comment('状态（1：未结算，2：已结算）') TINYINT(3)"`
+	Type                  int       `json:"type" xorm:"not null default 1 comment('1:分佣记录 2:返佣记录') TINYINT(1)"`
+	BelongOrdId           string    `json:"belong_ord_id" xorm:"not null comment('所属订单id') VARCHAR(255)"`
+	Pvd                   string    `json:"pvd" xorm:"not null comment('渠道') VARCHAR(255)"`
+	CreatedAt             time.Time `json:"created_at" xorm:"not null default 'CURRENT_TIMESTAMP' comment('创建时间') TIMESTAMP"`
+	UpdatedAt             time.Time `json:"updated_at" xorm:"default 'CURRENT_TIMESTAMP' comment('更新时间') TIMESTAMP"`
+}

db/model/regional_agent_ord_belong.go

@@ -0,0 +1,23 @@
+package model
+
+import (
+	"time"
+)
+
+type RegionalAgentOrdBelong struct {
+	Id           int64     `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Uid          int       `json:"uid" xorm:"not null comment('用户id') index(mgbgu_uid_ord_id_group_id_index) INT(11)"`
+	Pvd          string    `json:"pvd" xorm:"not null comment('渠道：自营，导购，o2o。。。。') VARCHAR(255)"`
+	OrderId      int64     `json:"order_id" xorm:"not null comment('订单id') BIGINT(20)"`
+	CurrencyType int       `json:"currency_type" xorm:"not null default 1 comment('币种类型：（1:佣金，2:积分，3:区块币，4:...）') INT(3)"`
+	Commission   string    `json:"commission" xorm:"not null comment('订单区域代理总佣金') DECIMAL(12,4)"`
+	RegionId     int       `json:"region_id" xorm:"not null comment('区域id') INT(11)"`
+	RegionalName string    `json:"regional_name" xorm:"not null comment('地区名：（例如：广东省；广东省-珠海市；广东省-珠海市-香洲区；广东省-珠海市-香洲区-港湾一号）') VARCHAR(255)"`
+	ProvinceId   int64     `json:"province_id" xorm:"comment('省级区域id') BIGINT(20)"`
+	CityId       int64     `json:"city_id" xorm:"comment('市级区域id') BIGINT(20)"`
+	DistrictId   int64     `json:"district_id" xorm:"comment('区/县级id') BIGINT(20)"`
+	SiteId       int64     `json:"site_id" xorm:"comment('网点id') BIGINT(20)"`
+	CreateTime   time.Time `json:"create_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('创建时间') index(mgbgu_uid_ord_id_group_id_index) TIMESTAMP"`
+	UpdateTime   time.Time `json:"update_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('更新时间') TIMESTAMP"`
+	Level        int       `json:"level" xorm:"not null default 0 comment('等级（1:省级；2:市级；3:区/县 级；4:网点）') TINYINT(1)"`
+}

db/model/regional_agent_region.go

@@ -0,0 +1,35 @@
+package model
+
+import (
+	"time"
+)
+
+type RegionalAgentRegion struct {
+	Id                    int64     `json:"id" xorm:"pk autoincr comment('表的主键id（亦可以代表省级id）') BIGINT(20)"`
+	ProvinceId            int64     `json:"province_id" xorm:"comment('设置市级代理数据时，省级的id') BIGINT(20)"`
+	CityId                int64     `json:"city_id" xorm:"comment('设置县区级代理数据时，市级的id') BIGINT(20)"`
+	DistrictId            int64     `json:"district_id" xorm:"comment('设置网点代理数据时，县，区id') BIGINT(20)"`
+	RegionName            string    `json:"region_name" xorm:"not null comment('地区名：（例如：广东省；广东省-珠海市；广东省-珠海市-香洲区；广东省-珠海市-香洲区-港湾一号）') VARCHAR(255)"`
+	Name                  string    `json:"name" xorm:"not null comment('地区名）') VARCHAR(255)"`
+	Longitude             string    `json:"longitude" xorm:"comment('经度（只有设置网点代理才会有数据）') DECIMAL(10,7)"`
+	Latitude              string    `json:"latitude" xorm:"comment('纬度（只有设置网点代理才会有数据）') DECIMAL(10,7)"`
+	AgPrice               string    `json:"ag_price" xorm:"not null comment('永久代理价格') DECIMAL(12,2)"`
+	MonthAgPrice          string    `json:"month_ag_price" xorm:"not null comment('月代理价格') DECIMAL(12,2)"`
+	QuarterAgPrice        string    `json:"quarter_ag_price" xorm:"not null comment('季度代理价格') DECIMAL(12,2)"`
+	YearAgPrice           string    `json:"year_ag_price" xorm:"not null comment('年代理价格') DECIMAL(12,2)"`
+	RenewalAgPrice        string    `json:"renewal_ag_price" xorm:"not null comment('续费永久代理价格') DECIMAL(12,2)"`
+	RenewalMonthAgPrice   string    `json:"renewal_month_ag_price" xorm:"not null comment('续费月代理价格') DECIMAL(12,2)"`
+	RenewalQuarterAgPrice string    `json:"renewal_quarter_ag_price" xorm:"not null comment('续费季度代理价格') DECIMAL(12,2)"`
+	RenewalYearAgPrice    string    `json:"renewal_year_ag_price" xorm:"not null comment('续费年代理价格') DECIMAL(12,2)"`
+	CommissionRate        string    `json:"commission_rate" xorm:"not null comment('分佣比例') DECIMAL(6,4)"`
+	ReturnedRate          string    `json:"returned_rate" xorm:"not null comment('返佣比例') DECIMAL(6,4)"`
+	VirtualCurrencyRate   string    `json:"virtual_currency_rate" xorm:"not null comment('虚拟币比例') DECIMAL(6,4)"`
+	LimitPerson           int       `json:"limit_person" xorm:"not null comment('限制人数（默认为0则不限制）') INT(11) "`
+	Remark                string    `json:"remark" xorm:"comment('备注') VARCHAR(255)"`
+	IsUse                 int       `json:"is_use" xorm:"not null default 1 comment('是否使用（否：0；是：1）') TINYINT(1)"`
+	Level                 int       `json:"level" xorm:"not null default 0 comment('等级（1:省级；2:市级；3:区/县 级；4:网点）') TINYINT(1)"`
+	CreateTime            time.Time `json:"create_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('创建时间') TIMESTAMP"`
+	UpdateTime            time.Time `json:"update_time" xorm:"default 'CURRENT_TIMESTAMP' comment('更新时间') TIMESTAMP"`
+	WebsiteRegionId       string    `json:"website_region_id" xorm:"default '' comment('关联总后台地区的id') TIMESTAMP"`
+	IsCustomer            int       `json:"is_customer" xorm:"not null default 1 comment('是否自定义新增的区域代理（否：0；是：1）') TINYINT(1)"`
+}

db/model/regional_agent_scheme.go

@@ -0,0 +1,35 @@
+package model
+
+import (
+	"time"
+)
+
+type RegionalAgentScheme struct {
+	Id                        int       `json:"id" xorm:"not null pk autoincr INT(11)"`
+	Name                      string    `json:"name" xorm:"comment('方案名称') VARCHAR(255)"`
+	Comment                   string    `json:"comment" xorm:"comment('备注') VARCHAR(2048)"`
+	IsUse                     int       `json:"is_use" xorm:"not null default 0 comment('是否使用') TINYINT(1)"`
+	AgentType                 int       `json:"agent_type" xorm:"not null comment('（1省级代理2市级代理3县，区代理4网点代理）') TINYINT(1)"`
+	Label                     string    `json:"label" xorm:"not null default '0' comment('别名，给前端使用') VARCHAR(255)"`
+	IsUnify                   int       `json:"is_unify" xorm:"not null default 0 comment('是否统一佣金比例（否：0；是：1）') TINYINT(1)"`
+	UnifyCommissionRate       string    `json:"unify_commission_rate" xorm:"not null default 0.0000 comment('统一佣金比例') DECIMAL(6,4)"`
+	FistAutoAudit             int       `json:"fist_auto_audit" xorm:"not null default 1 comment('初次购买审核方式（1自动，2手动）') TINYINT(1)"`
+	RenewalAutoAudit          int       `json:"renewal_auto_audit" xorm:"not null default 0 comment('续费审核方式（1自动，2手动）') TINYINT(1)"`
+	IsUnifyAgentPrice         int       `json:"is_unify_agent_price" xorm:"default 0 comment('是否统一代理价格（1统一价格，2按区域设置不用价格）') TINYINT(1)"`
+	LevelUpdateCondition      int       `json:"level_update_condition" xorm:"default 0 comment('1是无条件升级,2是条件升级,3是组合条件升级') TINYINT(1)"`
+	FinishTaskNum             int       `json:"finish_task_num" xorm:"default 0 comment('完成任务数量（如果是组合条件，则该数指的是完成几组）') INT(11)"`
+	AgentDate                 int       `json:"agent_date" xorm:"not null default 0 comment('代理有效期（0永久有效，单位月）') INT(11)"`
+	IsRenewal                 int       `json:"is_renewal" xorm:"not null comment('是否开启续费功能（否：0；是：1）') TINYINT(1)"`
+	RenewalAgPrice            string    `json:"renewal_ag_price" xorm:"comment('续费永久代理价格') DECIMAL(12,2)"`
+	RenewalMonthAgPrice       string    `json:"renewal_month_ag_price" xorm:"default 0.00 comment('续费月代理价格') DECIMAL(12,2)"`
+	RenewalQuarterAgPrice     string    `json:"renewal_quarter_ag_price" xorm:"comment('续费季度代理价格') DECIMAL(12,2)"`
+	RenewalYearAgPrice        string    `json:"renewal_year_ag_price" xorm:"comment('续费年代理价格') DECIMAL(12,2)"`
+	RewardCoins               string    `json:"reward_coins" xorm:"comment('奖励虚拟币设置') TEXT"`
+	IsReward                  int       `json:"is_reward" xorm:"not null comment('代理奖励（1:开启,2:关闭）') TINYINT(1)"`
+	CreateTime                time.Time `json:"create_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('创建时间') DATETIME"`
+	UpdateTime                time.Time `json:"update_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('更新时间') DATETIME"`
+	IsUnifyCommissionReturn   int       `json:"is_unify_commission_return" xorm:"not null default 0 comment('统一返佣金比例（是：0；否：1）') TINYINT(1)"`
+	UnifyCommissionReturnRate string    `json:"unify_commission_return_rate" xorm:"not null default 0.0000 comment('统一返佣金比例') DECIMAL(6,4)"`
+	IsUnifyLimmitPersion      int       `json:"is_unify_limmit_persion" xorm:"not null default 0 comment('统一限制人数（是：0；否：1）') TINYINT(1)"`
+	UnifyLimmitPersion        string    `json:"unify_limmit_persion" xorm:"not null default 0 comment('统一限制人数') VARCHAR(50)"`
+}

db/model/regional_agent_user_belong.go

@@ -0,0 +1,22 @@
+package model
+
+import (
+	"time"
+)
+
+type RegionalAgentUserBelong struct {
+	Id           int64     `json:"id" xorm:"pk autoincr BIGINT(20)"`
+	Uid          int       `json:"uid" xorm:"not null comment('用户id') index(mgbgu_uid_ord_id_group_id_index) INT(11)"`
+	RegionId     int       `json:"region_id" xorm:"not null comment('区域id') INT(11)"`
+	ProvinceId   int64     `json:"province_id" xorm:"comment('省级区域id') BIGINT(20)"`
+	CityId       int64     `json:"city_id" xorm:"comment('市级区域id') BIGINT(20)"`
+	DistrictId   int64     `json:"district_id" xorm:"comment('区/县级id') BIGINT(20)"`
+	SiteId       int64     `json:"site_id" xorm:"comment('网点id') BIGINT(20)"`
+	RegionalName string    `json:"regional_name" xorm:"not null comment('地区名：（例如：广东省；广东省-珠海市；广东省-珠海市-香洲区；广东省-珠海市-香洲区-港湾一号）') VARCHAR(255)"`
+	CreateTime   time.Time `json:"create_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('创建时间') index(mgbgu_uid_ord_id_group_id_index) TIMESTAMP"`
+	UpdateTime   time.Time `json:"update_time" xorm:"not null default 'CURRENT_TIMESTAMP' comment('更新时间') TIMESTAMP"`
+	Level        int       `json:"level" xorm:"not null default 0 comment('等级（1:省级；2:市级；3:区/县 级；4:网点）') TINYINT(1)"`
+	Pvd          string    `json:"pvd" xorm:"default '' comment('GUIDE:导购，SELF_MALL：自营，O2O：O2O') VARCHAR(20)"`
+	IsUse        int       `json:"is_use" xorm:"default 0 comment('是否在使用，1：是，2，否') TINYINT(1)"`
+	UserLevel    int       `json:"user_level" xorm:"default 0 comment('会员等级') INT"`
+}

md/regional_agent.go

@@ -0,0 +1,46 @@
+package md
+
+const (
+	PROVINCE = "province"
+	CITY     = "city"
+	COUNTRY  = "country"
+	SITE     = "site"
+)
+
+const (
+	ProvinceKey = 1
+	CityKey     = 2
+	CountryKey  = 3
+	SiteKey     = 4
+)
+
+type InsertRegionalAgentOrdBelongData struct {
+	Uid        interface{} `json:"uid"`
+	Pvd        string      `json:"pvd"`
+	CommPvd    string      `json:"comm_pvd"`
+	Commission string      `json:"commission"`
+	OrderId    int64       `json:"order_id"`
+	Status     string      `json:"status"`
+}
+
+type RegionalAgentSystemArgs struct {
+	Uid      string `json:"uid"`
+	Amount   string `json:"amount"`
+	OrdId    string `json:"ord_id"`
+	Pvd      string `json:"pvd"`
+	CommPvd  string `json:"comm_pvd"`
+	Type     string `json:"type"`
+	RegionId string `json:"regionId"`
+	Status   string `json:"status"`
+}
+type CoinSetDetail struct {
+	CoinID   int    `json:"coin_id"`
+	CoinName string `json:"coin_name"`
+	Value    string `json:"value"`
+}
+type CoinSet struct {
+	ProvinceAgent []CoinSetDetail `json:"province_agent"`
+	CityAgent     []CoinSetDetail `json:"city_agent"`
+	DistrictAgent []CoinSetDetail `json:"district_agent"`
+	SiteAgent     []CoinSetDetail `json:"site_agent"`
+}

rule/regional_agent.go

@@ -0,0 +1,354 @@
+package rule
+
+import (
+	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/db"
+	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/db/model"
+	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/md"
+	zhios_order_relate_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/utils"
+	"encoding/json"
+	"fmt"
+	"time"
+	"xorm.io/xorm"
+)
+
+func BindUserOrdToAgent(eg *xorm.Engine, dbName string, data *md.InsertRegionalAgentOrdBelongData) {
+	CommRegionalAgentInsert(eg, data)
+}
+
+//公共调用
+func CommRegionalAgentInsert(engine *xorm.Engine, args *md.InsertRegionalAgentOrdBelongData) int {
+	res, userBelong := InsertRegionalAgentOrdBelong(engine, args)
+	if !res {
+		return 0
+	}
+	//todo::调用 “计算制度” 方法
+	_, res = HandleCommissionDistributionSystem(engine, &md.RegionalAgentSystemArgs{
+		Uid:      zhios_order_relate_utils.AnyToString(args.Uid),
+		Amount:   args.Commission,
+		OrdId:    zhios_order_relate_utils.AnyToString(args.OrderId),
+		Pvd:      args.Pvd,
+		CommPvd:  args.CommPvd,
+		Status:   args.Status,
+		Type:     "2",
+		RegionId: zhios_order_relate_utils.AnyToString(userBelong.RegionId),
+	})
+	if !res {
+		return 2
+	}
+	return 1
+}
+
+func HandleCommissionDistributionSystem(engine *xorm.Engine, args *md.RegionalAgentSystemArgs) ([]map[string]interface{}, bool) {
+	amount := zhios_order_relate_utils.AnyToFloat64(args.Amount)
+	var regionId string
+	if args.Type == "1" {
+		//获取当前用户的 归属
+		userBelong, err := db.GetCountByRegionalAgentUserBelongById(engine, args.Uid, args.Pvd, args.CommPvd)
+		fmt.Println(err)
+		fmt.Println(userBelong)
+		if err != nil || userBelong == nil {
+			return nil, false
+		}
+		regionId = zhios_order_relate_utils.AnyToString(userBelong.RegionId)
+	} else {
+		regionId = args.RegionId
+	}
+
+	//查询用户所属 “代理网点”  信息
+	regionalAgentRegion, err := db.RegionalAgentRegionGetOneByParams(engine, map[string]interface{}{
+		"key":   "id",
+		"value": zhios_order_relate_utils.AnyToInt64(regionId),
+	})
+	if err != nil {
+		return nil, false
+	}
+	//查询 regional_agent_base 表获取虚拟币相关配置信息
+	agentBase, err := db.GetCountByRegionalAgentBase(engine)
+	if err != nil {
+		return nil, false
+	}
+	var coinSet = md.CoinSet{}
+	err = json.Unmarshal([]byte(agentBase.CoinSet), &coinSet)
+	if err != nil {
+		return nil, false
+	}
+
+	//查询 virtual_coin 获取虚拟货币的 “兑换比例”
+	virtualCoin, err := db.VirtualCoinFindByParams(engine, map[string]interface{}{})
+	if err != nil {
+		return nil, false
+	}
+	var virtualCoinMap = map[int]string{}
+	for _, v := range *virtualCoin {
+		virtualCoinMap[v.Id] = v.ExchangeRatio
+	}
+	//查询代理网点的代理（网点、区、市、省）信息
+	var parents, tempParents []map[string]interface{}
+	tempParents, amount, _, err = makeSystemData(engine, regionalAgentRegion, &coinSet, virtualCoinMap, parents, amount, md.SITE)
+	if err != nil {
+		return nil, false
+	}
+	if tempParents != nil {
+		parents = tempParents
+	}
+
+	tempParents, amount, _, err = makeSystemData(engine, regionalAgentRegion, &coinSet, virtualCoinMap, parents, amount, md.COUNTRY)
+	if err != nil {
+		return nil, false
+	}
+	if tempParents != nil {
+		parents = tempParents
+	}
+
+	tempParents, amount, _, err = makeSystemData(engine, regionalAgentRegion, &coinSet, virtualCoinMap, parents, amount, md.CITY)
+	if err != nil {
+		return nil, false
+	}
+	if tempParents != nil {
+		parents = tempParents
+	}
+
+	tempParents, amount, _, err = makeSystemData(engine, regionalAgentRegion, &coinSet, virtualCoinMap, parents, amount, md.PROVINCE)
+	if err != nil {
+		return nil, false
+	}
+	if tempParents != nil {
+		parents = tempParents
+	}
+
+	fmt.Println("区域代理")
+	fmt.Println(parents)
+
+	for _, v := range parents {
+		var divideVirtualCurrency = ""
+		if !zhios_order_relate_utils.IsNil(v["divide_virtual_currency"]) {
+			jsonStr, err := json.Marshal(v["divide_virtual_currency"])
+			if err != nil {
+				fmt.Println("虚拟币查询")
+				fmt.Println(err)
+				return nil, false
+			}
+			divideVirtualCurrency = string(jsonStr)
+		}
+		status := 1
+		if args.Status == "0" { //导购的一开始不用返的 导购结算才返
+			status = 0
+		}
+		var insertData = model.RegionalAgentCalcSystemRelate{
+			Uid:                   v["uid"].(int),
+			DivideAmount:          zhios_order_relate_utils.AnyToFloat64(v["divide_amount"]),
+			DivideVirtualCurrency: divideVirtualCurrency,
+			BelongOrdId:           args.OrdId,
+			Pvd:                   args.Pvd,
+			Status:                status,
+			Type:                  zhios_order_relate_utils.StrToInt(args.Type),
+			CreatedAt:             time.Now(),
+			UpdatedAt:             time.Now(),
+		}
+		_, err := db.RegionalAgentCalcSystemRelateInsert(engine, &insertData)
+		if err != nil {
+			return nil, false
+		}
+	}
+	return parents, true
+}
+
+func makeSystemData(engine *xorm.Engine, regionalAgentRegion *model.RegionalAgentRegion, coinSet *md.CoinSet, virtualCoin map[int]string, parents []map[string]interface{}, amount float64, level string) ([]map[string]interface{}, float64, float64, error) {
+	var value string
+	coinSetDetail := coinSet.SiteAgent
+	if regionalAgentRegion.Level == md.SiteKey {
+		switch level {
+		case md.PROVINCE:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.ProvinceId)
+			break
+		case md.CITY:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.CityId)
+			break
+		case md.COUNTRY:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.DistrictId)
+			break
+		case md.SITE:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.Id)
+			break
+		}
+		//获得虚拟币的比例
+		coinSetDetail = coinSet.SiteAgent
+	}
+	if regionalAgentRegion.Level == md.CountryKey {
+		switch level {
+		case md.PROVINCE:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.ProvinceId)
+			break
+		case md.CITY:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.CityId)
+			break
+		case md.COUNTRY:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.Id)
+			break
+		case md.SITE:
+			value = zhios_order_relate_utils.AnyToString(0)
+			break
+		}
+		//获得虚拟币的比例
+		coinSetDetail = coinSet.DistrictAgent
+	}
+	if regionalAgentRegion.Level == md.CityKey {
+		switch level {
+		case md.PROVINCE:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.ProvinceId)
+			break
+		case md.CITY:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.Id)
+			break
+		case md.COUNTRY:
+			value = zhios_order_relate_utils.AnyToString(0)
+			break
+		case md.SITE:
+			value = zhios_order_relate_utils.AnyToString(0)
+			break
+		}
+		//获得虚拟币的比例
+		coinSetDetail = coinSet.CityAgent
+	}
+	if regionalAgentRegion.Level == md.ProvinceKey {
+		switch level {
+		case md.PROVINCE:
+			value = zhios_order_relate_utils.AnyToString(regionalAgentRegion.Id)
+			break
+		case md.CITY:
+			value = zhios_order_relate_utils.AnyToString(0)
+			break
+		case md.COUNTRY:
+			value = zhios_order_relate_utils.AnyToString(0)
+			break
+		case md.SITE:
+			value = zhios_order_relate_utils.AnyToString(0)
+			break
+		}
+		//获得虚拟币的比例
+		coinSetDetail = coinSet.ProvinceAgent
+	}
+	fmt.Println("地区ID:", value)
+	fmt.Println("余额：", amount)
+	if value == "0" {
+		return nil, amount, 0, nil
+	}
+
+	//查询代理地区
+	regionalAgentRegionData, err := db.RegionalAgentRegionGetOneByParams(engine, map[string]interface{}{
+		"key":   "id",
+		"value": value,
+	})
+	//查询代理地区用户
+	agentUser, err := db.RegionalAgentUserFindByValid(engine, value)
+	if err != nil {
+		return nil, amount, 0, err
+	}
+	var divideAmount float64 = 0
+	//查询对应的等级方案
+	scheme, err := db.GetCountByRegionalAgentSchemeInfoByParams(engine, map[string]interface{}{
+		"key":   "agent_type",
+		"value": regionalAgentRegionData.Level,
+	})
+	if scheme == nil || err != nil {
+		return nil, amount, 0, err
+	}
+	var commissionRate string
+	if scheme.IsUnify == 1 {
+		commissionRate = regionalAgentRegionData.CommissionRate
+	} else {
+		commissionRate = scheme.UnifyCommissionRate
+	}
+	parents, amount, divideAmount, err = CommAmount(zhios_order_relate_utils.AnyToFloat64(commissionRate), amount, agentUser, coinSetDetail, virtualCoin, parents, false)
+	if err != nil {
+		return nil, amount, 0, err
+	}
+	return parents, amount, divideAmount, nil
+
+}
+
+//公共处理佣金
+func CommAmount(CommissionRate float64, amount float64, agentUser *[]model.RegionalAgentUser, coinSetDetail []md.CoinSetDetail, virtualCoin map[int]string, parents []map[string]interface{}, isTest bool) ([]map[string]interface{}, float64, float64, error) {
+	var divideAmount float64 = 0
+	if amount == 0 {
+		for _, v := range *agentUser {
+			var temp = map[string]interface{}{}
+			temp["uid"] = v.Uid
+			temp["divide"] = 0
+			parents = append(parents, temp)
+		}
+	} else {
+		rate := CommissionRate / 100
+		fmt.Println("比例：", rate)
+		divideAmount = rate * amount
+		personNum := len(*agentUser)
+		fmt.Println("人数：", personNum)
+		if personNum == 0 && isTest == false {
+			return nil, amount, divideAmount, nil
+		}
+		everyPersonDivideAmount := divideAmount / zhios_order_relate_utils.AnyToFloat64(personNum)
+		for _, v := range *agentUser {
+			var temp = map[string]interface{}{}
+			temp["uid"] = v.Uid
+			if amount == 0 {
+				temp["divide_amount"] = 0
+			} else {
+				temp["divide_amount"] = everyPersonDivideAmount
+				var coinSetDetailMap []map[string]interface{}
+				for _, v := range coinSetDetail {
+					var exchangeRatio float64
+					if zhios_order_relate_utils.AnyToFloat64(virtualCoin[v.CoinID]) != 0 {
+						exchangeRatio = zhios_order_relate_utils.AnyToFloat64(virtualCoin[v.CoinID])
+					} else {
+						exchangeRatio = 0
+					}
+					coinSetDetailMap = append(coinSetDetailMap, map[string]interface{}{
+						"coin_id":      v.CoinID,
+						"coin_name":    v.CoinName,
+						"divide_value": zhios_order_relate_utils.AnyToFloat64(temp["divide_amount"]) * (zhios_order_relate_utils.AnyToFloat64(v.Value) / 100) * exchangeRatio,
+					})
+				}
+				temp["divide_virtual_currency"] = coinSetDetailMap
+			}
+			parents = append(parents, temp)
+		}
+		if amount-divideAmount <= 0 {
+			amount = 0
+		} else {
+			amount = amount - divideAmount
+		}
+	}
+	return parents, amount, divideAmount, nil
+}
+
+//InsertRegionalAgentOrdBelong 插入 regional_agent_ord_belong (用户订单归属表) 数据
+func InsertRegionalAgentOrdBelong(engine *xorm.Engine, data *md.InsertRegionalAgentOrdBelongData) (bool, *model.RegionalAgentUserBelong) {
+	// 查询 regional_agent_user_belong 得到用户归属的区域代理
+	userBelong, err := db.GetCountByRegionalAgentUserBelongById(engine, data.Uid, data.Pvd, data.CommPvd)
+
+	if err != nil || userBelong == nil {
+		return false, nil
+	}
+	date := time.Now()
+	_, err = db.RegionalAgentOrdBelongInsert(engine, &model.RegionalAgentOrdBelong{
+		Uid:          int(zhios_order_relate_utils.AnyToInt64(data.Uid)),
+		Pvd:          data.Pvd,
+		OrderId:      data.OrderId,
+		CurrencyType: 1,
+		Commission:   data.Commission,
+		RegionId:     userBelong.RegionId,
+		RegionalName: userBelong.RegionalName,
+		ProvinceId:   userBelong.ProvinceId,
+		CityId:       userBelong.CityId,
+		DistrictId:   userBelong.DistrictId,
+		SiteId:       userBelong.SiteId,
+		CreateTime:   date,
+		UpdateTime:   date,
+		Level:        userBelong.Level,
+	})
+	if err != nil {
+		return false, nil
+	}
+
+	return true, userBelong
+}

utils/convert.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"math"
+	"reflect"
 	"strconv"
 	"strings"
 )
@@ -22,7 +23,13 @@ func ToInt64(raw interface{}, e error) int64 {
 	}
 	return AnyToInt64(raw)
 }
-
+func IsNil(i interface{}) bool {
+	vi := reflect.ValueOf(i)
+	if vi.Kind() == reflect.Ptr {
+		return vi.IsNil()
+	}
+	return false
+}
 func AnyToBool(raw interface{}) bool {
 	switch i := raw.(type) {
 	case float32, float64, int, int64, uint, uint8, uint16, uint32, uint64, int8, int16, int32: