From 7ca1f35e36afca65e9c2628efbb1a896ad4ade39 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Thu, 31 Oct 2024 17:11:34 +0800 Subject: [PATCH] 1 --- db/db_regional_agent_user_belong.go | 81 ++++++- rule/regional_agent_sess.go | 360 ++++++++++++++++++++++++++++ 2 files changed, 439 insertions(+), 2 deletions(-) create mode 100644 rule/regional_agent_sess.go diff --git a/db/db_regional_agent_user_belong.go b/db/db_regional_agent_user_belong.go index 45ba04e..f376725 100644 --- a/db/db_regional_agent_user_belong.go +++ b/db/db_regional_agent_user_belong.go @@ -56,7 +56,6 @@ func (rab RegionalAgentUserBelongWithSession) UpdateRegionalAgentUserBelong(cols 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). @@ -185,6 +184,27 @@ func GetCountByRegionalAgentUserBelongById(Db *xorm.Engine, uid interface{}, pvd return &m, nil } } +func GetCountByRegionalAgentUserBelongByIdSess(Db *xorm.Session, 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).Desc("id").Get(&m); err != nil || has == false { + return nil, err + } + return &m, nil + } else { + if has, err := Db.Where("uid = ? and pvd=?", uid, pvd).Desc("id").Get(&m); err != nil || has == false { + return nil, err + } + return &m, nil + } +} // RegionalAgentOrdBelongInsert 插入单条数据 func RegionalAgentOrdBelongInsert(Db *xorm.Engine, regionalAgentRegion *model.RegionalAgentOrdBelong) (int64, error) { @@ -194,6 +214,13 @@ func RegionalAgentOrdBelongInsert(Db *xorm.Engine, regionalAgentRegion *model.Re } return regionalAgentRegion.Id, nil } +func RegionalAgentOrdBelongInsertSess(Db *xorm.Session, 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) { @@ -204,7 +231,14 @@ func RegionalAgentRegionGetOneByParams(Db *xorm.Engine, params map[string]interf } return &m, nil } - +func RegionalAgentRegionGetOneByParamsSess(Db *xorm.Session, 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 and is_failure=0", regionId).Find(&m) @@ -213,6 +247,14 @@ func RegionalAgentUserFindByValid(Db *xorm.Engine, regionId string) (*[]model.Re } return &m, nil } +func RegionalAgentUserFindByValidSess(Db *xorm.Session, regionId string) (*[]model.RegionalAgentUser, error) { + var m []model.RegionalAgentUser + err := Db.Where("region_id=? and deleted_time IS NULL and is_failure=0", regionId).Find(&m) + if err != nil { + return nil, err + } + return &m, nil +} // GetCountByRegionalAgentBase 通过传入的参数查询数据(单条) func GetCountByRegionalAgentBase(Db *xorm.Engine) (*model.RegionalAgentBase, error) { @@ -226,6 +268,17 @@ func GetCountByRegionalAgentBase(Db *xorm.Engine) (*model.RegionalAgentBase, err } return &m, nil } +func GetCountByRegionalAgentBaseSess(Db *xorm.Session) (*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) { @@ -264,6 +317,15 @@ func VirtualCoinFindByAll(Db *xorm.Engine) (*[]model.VirtualCoin, error) { } return &m, nil } +func VirtualCoinFindByAllSess(Db *xorm.Session) (*[]model.VirtualCoin, error) { + var m []model.VirtualCoin + //查询全部数据 + err := Db.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 { @@ -271,6 +333,13 @@ func RegionalAgentCalcSystemRelateInsert(Db *xorm.Engine, regionalAgentCalcSyste } return regionalAgentCalcSystemRelate.Id, nil } +func RegionalAgentCalcSystemRelateInsertSess(Db *xorm.Session, 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) { @@ -281,3 +350,11 @@ func GetCountByRegionalAgentSchemeInfoByParams(Db *xorm.Engine, params map[strin } return &m, nil } +func GetCountByRegionalAgentSchemeInfoByParamsSess(Db *xorm.Session, 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 +} diff --git a/rule/regional_agent_sess.go b/rule/regional_agent_sess.go new file mode 100644 index 0000000..007f36c --- /dev/null +++ b/rule/regional_agent_sess.go @@ -0,0 +1,360 @@ +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 BindUserOrdToAgentSess(sess *xorm.Session, dbName string, data *md.InsertRegionalAgentOrdBelongData) { + CommRegionalAgentInsertSess(sess, data) +} + +// 公共调用 +func CommRegionalAgentInsertSess(sess *xorm.Session, args *md.InsertRegionalAgentOrdBelongData) int { + res, RegionId := InsertRegionalAgentOrdBelongSess(sess, args) + if !res { + return 0 + } + //todo::调用 “计算制度” 方法 + _, res = HandleCommissionDistributionSystemSess(sess, &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(RegionId), + }) + if !res { + return 2 + } + return 1 +} + +func HandleCommissionDistributionSystemSess(sess *xorm.Session, 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.GetCountByRegionalAgentUserBelongByIdSess(sess, 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.RegionalAgentRegionGetOneByParamsSess(sess, map[string]interface{}{ + "key": "id", + "value": zhios_order_relate_utils.AnyToInt64(regionId), + }) + if err != nil { + return nil, false + } + if regionalAgentRegion == nil { + return nil, true + } + //查询 regional_agent_base 表获取虚拟币相关配置信息 + agentBase, err := db.GetCountByRegionalAgentBaseSess(sess) + 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.VirtualCoinFindByAllSess(sess) + if err != nil { + return nil, false + } + var virtualCoinMap = map[int]string{} + if virtualCoin != nil { + for _, v := range *virtualCoin { + virtualCoinMap[v.Id] = v.ExchangeRatio + } + } + //查询代理网点的代理（网点、区、市、省）信息 + var parents, tempParents []map[string]interface{} + tempParents, amount, _, err = makeSystemDataSess(sess, regionalAgentRegion, &coinSet, virtualCoinMap, parents, amount, md.SITE) + if err != nil { + return nil, false + } + if tempParents != nil { + parents = tempParents + } + + tempParents, amount, _, err = makeSystemDataSess(sess, regionalAgentRegion, &coinSet, virtualCoinMap, parents, amount, md.COUNTRY) + if err != nil { + return nil, false + } + if tempParents != nil { + parents = tempParents + } + + tempParents, amount, _, err = makeSystemDataSess(sess, regionalAgentRegion, &coinSet, virtualCoinMap, parents, amount, md.CITY) + if err != nil { + return nil, false + } + if tempParents != nil { + parents = tempParents + } + + tempParents, amount, _, err = makeSystemDataSess(sess, 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.RegionalAgentCalcSystemRelateInsertSess(sess, &insertData) + if err != nil { + return nil, false + } + } + return parents, true +} + +func makeSystemDataSess(sess *xorm.Session, 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.RegionalAgentRegionGetOneByParamsSess(sess, map[string]interface{}{ + "key": "id", + "value": value, + }) + //查询代理地区用户 + agentUser, err := db.RegionalAgentUserFindByValidSess(sess, value) + if err != nil { + return nil, amount, 0, err + } + if regionalAgentRegionData == nil { + return nil, amount, 0, err + } + var divideAmount float64 = 0 + //查询对应的等级方案 + scheme, err := db.GetCountByRegionalAgentSchemeInfoByParamsSess(sess, 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 + +} + +//公共处理佣金 + +// InsertRegionalAgentOrdBelong 插入 regional_agent_ord_belong (用户订单归属表) 数据 +func InsertRegionalAgentOrdBelongSess(sess *xorm.Session, data *md.InsertRegionalAgentOrdBelongData) (bool, int) { + // 查询 regional_agent_user_belong 得到用户归属的区域代理 + RegionId := 0 + ProvinceId := 0 + RegionalName := "" + CityId := 0 + DistrictId := 0 + SiteId := 0 + Level := 0 + if data.BelongType == "1" { + ProvinceId = zhios_order_relate_utils.StrToInt(data.ProvinceId) + if ProvinceId > 0 { + Level = 1 + RegionId = ProvinceId + } + CityId = zhios_order_relate_utils.StrToInt(data.CityId) + if CityId > 0 { + Level = 2 + RegionId = CityId + } + DistrictId = zhios_order_relate_utils.StrToInt(data.CountyId) + if DistrictId > 0 { + Level = 3 + RegionId = DistrictId + } + SiteId = zhios_order_relate_utils.StrToInt(data.SiteId) + if SiteId > 0 { + Level = 4 + RegionId = SiteId + } + if RegionId > 0 { + regionalAgentRegion, err := db.RegionalAgentRegionGetOneByParamsSess(sess, map[string]interface{}{ + "key": "id", + "value": zhios_order_relate_utils.AnyToInt64(RegionId), + }) + if err != nil { + return false, 0 + } + if regionalAgentRegion == nil { + return false, 0 + } + RegionalName = regionalAgentRegion.RegionName + } + } else { + userBelong, err := db.GetCountByRegionalAgentUserBelongByIdSess(sess, data.Uid, data.Pvd, data.CommPvd) + if err != nil || userBelong == nil { + return false, 0 + } + RegionId = userBelong.RegionId + ProvinceId = int(userBelong.ProvinceId) + RegionalName = userBelong.RegionalName + CityId = int(userBelong.CityId) + DistrictId = int(userBelong.DistrictId) + SiteId = int(userBelong.SiteId) + Level = userBelong.Level + } + + date := time.Now() + _, err := db.RegionalAgentOrdBelongInsertSess(sess, &model.RegionalAgentOrdBelong{ + Uid: int(zhios_order_relate_utils.AnyToInt64(data.Uid)), + Pvd: data.Pvd, + OrderId: data.OrderId, + CurrencyType: 1, + Commission: data.Commission, + RegionId: RegionId, + RegionalName: RegionalName, + ProvinceId: int64(ProvinceId), + CityId: int64(CityId), + DistrictId: int64(DistrictId), + SiteId: int64(SiteId), + CreateTime: date, + UpdateTime: date, + Level: Level, + }) + if err != nil { + return false, 0 + } + + return true, RegionId +}