添加蜂鸟配送

platformapi/fnpsapi/callback.go

@@ -1,13 +1,163 @@
 package fnpsapi
 
 import (
-	"net/url"
-
+	"encoding/json"
+	"errors"
+	"git.rosy.net.cn/baseapi"
 	"git.rosy.net.cn/jx-callback/globals"
+	"net/http"
+	"net/url"
 
 	"git.rosy.net.cn/baseapi/utils"
 )
 
+const (
+	OrderStatus             = "orderStatusNotify"             // 订单状态回调
+	AbnormalStatus          = "abnormalReportNotify"          // 异常报备回调
+	CookingFinishStatus     = "cookingFinishNotify"           // 商户出餐回调
+	ChainstoreStatus        = "chainstoreStatusNotify"        // 门店状态变更回调
+	ChainstoreServiceStatus = "chainstoreServiceStatusNotify" // 门店采购服务变更回调
+	NoServiceStatus         = "noServiceNotify"               // 城市屏蔽区域调整回调通知
+)
+
+var (
+	SuccessResponse  = &CallbackResponse{Code: 200}
+	SignatureIsNotOk = &CallbackResponse{Code: -1}
+)
+
+type CallbackResponse struct {
+	Code int `json:"code"`
+}
+
+func Err2CallbackResponse(err error, data string) *CallbackResponse {
+	if err == nil {
+		return SuccessResponse
+	}
+	return &CallbackResponse{
+		Code: -1,
+	}
+}
+
+type ShortStatus struct {
+	AppId        string `json:"app_id"`
+	Signature    string `json:"signature"`
+	Timestamp    string `json:"timestamp"`
+	BusinessData string `json:"business_data"`
+}
+
+// 门店状态回调
+type ChainstoreStatusNotify struct {
+	CallbackBusinessType string `json:"callback_business_type"`
+	Param                string `json:"param"`
+}
+
+// 门店状态回调paramter
+type ChainstoreParam struct {
+	MerchantId   string `json:"merchant_id"`    // 商户id
+	ChainStoreId string `json:"chain_store_id"` // 蜂鸟门店id
+	OutShopCode  string `json:"out_shop_code"`  // 外部门店编码
+	Status       string `json:"status"`         // 门店认证状态
+	ModifyStatus string `json:"modify_status"`  // 门店修改状态
+	Remark       string `json:"remark	"`        // 门店认证、修改等驳回时返回原因
+}
+
+// 订单状态回调paramter
+type OrderCallbackParam struct {
+	OrderId            int64  `json:"order_id"`             // 订单号
+	AppId              string `json:"app_id"`               // 应用id
+	PartnerOrderCode   string `json:"partner_order_code"`   // 外部订单号
+	OrderStatus        int    `json:"order_status"`         // 订单状态 订单生成0，运单生成成功1，20：骑手接单，80：骑手到 店，2：配送中，3：已完成，4：已取消，5：配送异常
+	CarrierDriverId    int64  `json:"carrier_driver_id"`    // 骑手id
+	CarrierLat         string `json:"carrier_lat"`          // 坐标高德(不要使用)
+	CarrierLng         string `json:"carrier_lng"`          // 坐标高德(不要使用)
+	CarrierDriverName  string `json:"carrier_driver_name"`  // 骑手姓名
+	CarrierDriverPhone string `json:"carrier_driver_phone"` // 骑手电话
+	Description        string `json:"description"`          // 描述
+	ErrorCode          string `json:"error_code"`           // 异常code
+	ErrorScene         string `json:"error_scene"`          // 异常描述
+	DetailDescription  string `json:"detail_description"`   // 详情描述
+	PushTime           int64  `json:"push_time"`            // 状态推送时间 （毫秒）
+	Transfer           int    `json:"transfer"`             // 转单标识 转单标识 1 是转单 0非转单
+}
+
+// 出餐回调
+type CookingFinishNotify struct {
+	OrderId           int64  `json:"order_id"`            // 订单号
+	AppId             string `json:"app_id"`              // 应用id
+	PartnerOrderCode  string `json:"partner_order_code"`  // 外部订单号
+	ChainStoreId      string `json:"chain_store_id"`      // 蜂鸟门店id
+	MerchantId        string `json:"merchant_id"`         // 商户id
+	CookingFinishTime int64  `json:"cooking_finish_time"` // 状态推送时间 （毫秒）
+}
+
+// 获取门店状态回调消息
+func (a *API) GetChainstoreStatusNotify(request *http.Request) (shopStatusMsg map[string]interface{}, callbackResponse *CallbackResponse) {
+	storeNotify := ShortStatus{}
+	err := utils.Map2StructByJson(utils.URLValues2Map(request.PostForm), &storeNotify, true)
+	if err != nil {
+		baseapi.SugarLogger.Debugf("FN GetShopStatusCallbackMsg failed with err:%v", err)
+		callbackResponse = &CallbackResponse{Code: -1}
+		return nil, callbackResponse
+	}
+
+	fnNotify := &ChainstoreStatusNotify{}
+	if err := json.Unmarshal([]byte(storeNotify.BusinessData), fnNotify); err != nil {
+		baseapi.SugarLogger.Debugf("FN callback string to ChainstoreStatusNotify  failed with err:%v", err)
+		callbackResponse = &CallbackResponse{Code: -1}
+		return nil, callbackResponse
+	}
+
+	// 解析蜂鸟返回值
+	shopStatusMsg, err = FnCallbackAnalysis(fnNotify)
+	if err != nil {
+		return nil, &CallbackResponse{Code: -1}
+	}
+
+	return shopStatusMsg, SuccessResponse
+}
+
+// 蜂鸟返回值解析
+func FnCallbackAnalysis(notify *ChainstoreStatusNotify) (result map[string]interface{}, err error) {
+	switch notify.CallbackBusinessType {
+	case OrderStatus: // 订单回调
+		orderRes := &OrderCallbackParam{}
+		if err := json.Unmarshal([]byte(notify.Param), orderRes); err != nil {
+			return nil, err
+		}
+		notifyObj := utils.Struct2FlatMap(orderRes)
+		notifyObj["orderStatusNotify"] = ChainstoreStatus
+		return notifyObj, nil
+	case AbnormalStatus: // 异常报备回调
+		return nil, nil
+	case CookingFinishStatus: // 商户出餐回调
+		//cokking := &CookingFinishNotify{}
+		//if err := json.Unmarshal([]byte(notify.Param), cokking); err != nil {
+		//	return nil, err
+		//}
+		//notifyObj := utils.Struct2FlatMap(cokking)
+		//notifyObj["cookingFinishNotify"] = ChainstoreStatus
+		//return notifyObj, nil
+		return nil, nil
+	case ChainstoreStatus: // 门店状态变更回调
+		storeRes := &ChainstoreParam{}
+		if err := json.Unmarshal([]byte(notify.Param), storeRes); err != nil {
+			return nil, err
+		}
+		notifyObj := utils.Struct2FlatMap(storeRes)
+		notifyObj["notifyUel"] = ChainstoreStatus
+		return notifyObj, nil
+	case ChainstoreServiceStatus: // 门店采购服务变更回调
+		return nil, nil
+	case NoServiceStatus: // 城市屏蔽区域调整回调通知
+		return nil, nil
+	default:
+		return nil, errors.New("回调函数,回调路径错误")
+	}
+
+	globals.SugarLogger.Warnf("Fn callback url func err:=[%s],dont's exits", "notify.CallbackBusinessType")
+	return nil, errors.New("回调函数,回调路径错误")
+}
+
 type CallBackInfo struct {
 	AppID     string `json:"app_id"`
 	Data      string `json:"data"`