package youngee_talent_service

import (
	"youngmini_server/app/dao"
	"youngmini_server/app/model"
	"youngmini_server/app/model/youngee_talent_model"
	"youngmini_server/app/utils"

	"github.com/gogf/gf/encoding/gjson"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/net/ghttp"
)

// 修改达人收货地址
func OnUpdateLogisticsAddress(r *ghttp.Request) *TalentHttpResult {
	tid, err := utils.SessionTalentInfo.GetTalentIdFromSession(r)
	if err != nil {
		return &TalentHttpResult{Code: -1, Msg: "Update talent address failed"}
	}

	var modifyReq *youngee_talent_model.TaskLogisticsAddress
	err = r.ParseForm(&modifyReq)
	if err != nil {
		return &TalentHttpResult{Code: -2, Msg: "params error"}
	}
	address := model.YoungeeTalentDeliveryAddress{
		TalentId:     tid,
		RegionCode:   modifyReq.RegionCode,
		DetailAddr:   modifyReq.DetailAddr,
		PhoneNumber:  modifyReq.PhoneNumber,
		ReceiverName: modifyReq.ReceiverName,
	}
	// 生成收货地址快照
	addrSnap, err := gjson.Encode(address)
	if err != nil {
		return &TalentHttpResult{Code: -3, Msg: "encode delivery address snap failed"}
	}
	_, err = g.DB().Model(dao.YoungeeTaskInfo.Table).Data("talent_post_addr_snap", addrSnap).Where("task_id = ?", modifyReq.TaskId).Update()
	if err != nil {
		return &TalentHttpResult{Code: -4, Msg: "update failed"}
	}

	return &TalentHttpResult{Code: 0, Msg: "success"}
}

// 获取物流信息
func GetTaskLogisticsInfo(r *ghttp.Request) *TalentHttpResult {
	taskId := r.GetQueryInt("task_id", -1)

	var logistics *model.YoungeeTaskLogistics
	err := g.Model(dao.YoungeeTaskLogistics.Table).Where("task_id = ?", taskId).Scan(&logistics)
	if err != nil {
		return &TalentHttpResult{Code: -1, Msg: "Get logistics info failed"}
	}

	return &TalentHttpResult{Code: 0, Msg: "success", Data: logistics}
}