jyOrderManager/internal/controller/commonHandler.go

package controller

import (
	. "app.yhyue.com/moapp/jybase/api"
	"fmt"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/net/ghttp"
	"github.com/gogf/gf/v2/os/gctx"
	"github.com/gogf/gf/v2/util/gconv"
	"github.com/pkg/errors"
	"jyOrderManager/internal/jyutil"
)

func GetSelectItemHandler(r *ghttp.Request) {
	rData, err := func() (interface{}, error) {
		displayMap := make(map[string]interface{})
		for deptId, channelCode := range g.Cfg("global").MustGet(gctx.New(), "deptDefaultChannel").Map() {
			displayMap[deptId] = channelCode
			for _, node := range jyutil.JyDepartmentManager.GetDeptAllChildNode(gconv.Int(deptId)) {
				displayMap[gconv.String(node.Id)] = channelCode
			}
		}
		var currentUserEntId int64 = 0
		if uMsg := jyutil.GetUserMsgFromCtx(r.Context()); uMsg != nil {
			currentUserEntId = uMsg.EntUserId
		}
		return g.Map{
			"deptTree":           jyutil.JyDepartmentManager.GetShowDeptTree(g.Cfg("global").MustGet(r.Context(), "saleDeptShowArr").Strings()...), //可选择销售部门tree
			"defaultSaleChannel": displayMap,                                                                                                       //默认销售渠道
			"channel":            jyutil.GetChannel(r.Context()),                                                                                   //销售渠道
			"orderChannel":       jyutil.GetOrderChannel(r.Context()),                                                                              //下单渠道
			"currentUserEntId":   currentUserEntId,
		}, nil
	}()
	if err != nil {
		g.Log().Errorf(r.Context(), "GetSelectItemHandler 异常 %v", err)
	}
	r.Response.WriteJson(NewResult(rData, err))
}

// GetSalesListHandler 获取销售人员列表
func GetSalesListHandler(r *ghttp.Request) {
	rData, err := func() (interface{}, error) {
		return jyutil.JyDepartmentManager.GetShowDeptSales(r.Context()), nil
	}()
	if err != nil {
		g.Log().Errorf(r.Context(), "GetSelectItemHandler 异常 %v", err)
	}
	r.Response.WriteJson(NewResult(rData, err))
}

func GetAccountVipStatusHandler(r *ghttp.Request) {
	rData, err := func() (interface{}, error) {
		rj, err := r.GetJson()
		if err != nil {
			return nil, errors.Wrap(err, "请求参数格式异常")
		}
		var (
			buySet  = rj.Get("buyset").Int()     //购买主体
			phone   = rj.Get("phone").String()   //手机号
			company = rj.Get("company").String() //公司名称
		)
		return g.Map{
			"xx": fmt.Sprintf("%d-%s-%s", buySet, phone, company),
		}, nil
	}()
	if err != nil {
		g.Log().Errorf(r.Context(), "GetAccountVipStatusHandler 异常 %v", err)
	}
	r.Response.WriteJson(NewResult(rData, err))
}