package controller

import (
	. "app.yhyue.com/moapp/jybase/api"
	"context"
	"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
		uMsg := jyutil.GetUserMsgFromCtx(r.Context())
		if uMsg != nil {
			currentUserEntId = uMsg.EntUserId
		}
		userDep := make(map[string]interface{})
		equity := statusRights(r.Context(), currentUserEntId)
		if equity == 1 { //部门经理
			dept := jyutil.JyDepartmentManager.GetDeptNode(gconv.Int(uMsg.EntDeptId))
			if dept != nil {
				userDep["label"] = dept.Name
				userDep["value"] = dept.Id
			}
		}
		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,
			"equity":             equity,  //1待一审 2待二审 3待三审 初始选项
			"userDep":            userDep, //部门经理 固定部门信息 不可选
		}, nil
	}()
	if err != nil {
		g.Log().Errorf(r.Context(), "GetSelectItemHandler 异常 %v", err)
	}
	r.Response.WriteJson(NewResult(rData, err))
}

func statusRights(context context.Context, entUserId int64) int {
	//获取查询审核订单权益功能
	var equity int
	examine := g.Cfg().MustGet(context, "examine").Maps()
	for _, m := range examine {
		for _, s := range gconv.Int64s(m["userid"]) {
			if s == entUserId {
				equity = gconv.Int(m["equity"])
			}
		}
	}
	return equity
}

// 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))
}