新增投诉骑手接口

platformapi/dadaapi/order.go

@@ -58,6 +58,11 @@ type CancelOrderResponse struct {
 	DeductFee float64 `json:"deduct_fee"`
 }
 
+type ComplaintReason struct {
+	ID     int    `json:"id"`
+	Reason string `json:"reason"`
+}
+
 func (a *API) QueryOrderInfo(orderID string) (retVal map[string]interface{}, err error) {
 	params := make(map[string]interface{})
 	params["order_id"] = orderID
@@ -128,3 +133,25 @@ func (a *API) CancelOrder(thirdPartOrderID string, cancelOrderReasonId int, canc
 	retVal.DeductFee = utils.MustInterface2Float64(mapResult["deduct_fee"])
 	return retVal, nil
 }
+
+//获取投诉原因
+func (a *API) GetComplaintReasons() (complaintReasonList []*ComplaintReason, err error) {
+	result, err := a.AccessAPI("api/complaint/reasons", nil)
+	if err != nil {
+		return nil, err
+	}
+	for _, v := range result.Result.([]interface{}) {
+		mapResult := v.(map[string]interface{})
+		complaintReason := &ComplaintReason{}
+		err = utils.Map2StructByJson(mapResult, complaintReason, false)
+		complaintReasonList = append(complaintReasonList, complaintReason)
+	}
+	return complaintReasonList, nil
+}
+
+//投诉骑手
+func (a *API) ComplaintRider(orderID string, resonID int) (err error) {
+	mapData := utils.Params2Map("order_id", orderID, "reason_id", resonID)
+	_, err = a.AccessAPI("api/complaint/dada", mapData)
+	return err
+}

platformapi/dadaapi/order_test.go

@@ -1,6 +1,7 @@
 package dadaapi
 
 import (
+	"fmt"
 	"testing"
 
 	"git.rosy.net.cn/baseapi"
@@ -45,3 +46,18 @@ func TestCancel(t *testing.T) {
 	}
 	baseapi.SugarLogger.Debug(utils.Format4Output(cancelResponse, false))
 }
+
+func TestGetComplaintReasons(t *testing.T) {
+	complaintReason, err := dadaapi.GetComplaintReasons()
+	if err != nil {
+		t.Fatal(err)
+	}
+	fmt.Println(complaintReason)
+}
+
+func TestComplaintRider(t *testing.T) {
+	err := dadaapi.ComplaintRider("123", 1)
+	if err != nil {
+		t.Fatal(err)
+	}
+}