京东消息

upstream/jingdong/jingdong_msg.go

@@ -13,7 +13,7 @@ type msgJD struct {
 var Msg = msgJD{}
 
 type GetPushMessages struct {
-	*CommonRes
+	CommonRes
 	Result []struct {
 		Id     int         `json:"id"`
 		Type   int         `json:"type"`
@@ -23,7 +23,7 @@ type GetPushMessages struct {
 }
 
 type DelPushMessages struct {
-	*CommonRes
+	CommonRes
 	Result bool `json:"result"`
 }
 
@@ -79,3 +79,152 @@ func (*msgJD) DeletePushMessage(ctx context.Context, id *garray.Array) (res *Del
 	err = gjson.New(result).Scan(&res)
 	return
 }
+
+type MsgSolitRes struct {
+	CommonRes
+	Result []struct {
+		Id     string `json:"id"`
+		Time   string `json:"time"`
+		Type   int    `json:"type"`
+		Result struct {
+			POrder string `json:"pOrder"`
+		} `json:"result"`
+	} `json:"result"`
+}
+
+//Solit 拆单
+func (*msgJD) Solit(ctx context.Context) (res *MsgSolitRes, err error) {
+	method := "message/get"
+	param := g.Map{
+		"type": "1",
+	}
+	result, err := server.requestApi(ctx, method, param)
+	if err != nil {
+		return
+	}
+	err = gjson.NewWithOptions(result, gjson.Options{
+		StrNumber: true,
+	}).Scan(&res)
+	return
+}
+
+type MsgSendRes struct {
+	CommonRes
+	Result []struct {
+		Id     string `json:"id"`
+		Time   string `json:"time"`
+		Type   int    `json:"type"`
+		Result struct {
+			OrderId string `json:"orderId"`
+		} `json:"result"`
+	} `json:"result"`
+}
+
+//Send 发货
+func (*msgJD) Send(ctx context.Context) (res *MsgSendRes, err error) {
+	method := "message/get"
+	param := g.Map{
+		"type": "12",
+	}
+	result, err := server.requestApi(ctx, method, param)
+	if err != nil {
+		return
+	}
+	err = gjson.NewWithOptions(result, gjson.Options{
+		StrNumber: true,
+	}).Scan(&res)
+	return
+}
+
+type MsgSuccessRes struct {
+	CommonRes
+	Result []struct {
+		Id     string `json:"id"`
+		Time   string `json:"time"`
+		Type   int    `json:"type"`
+		Result struct {
+			JdOrderState int    `json:"jdOrderState"`
+			Pin          string `json:"pin"`
+			CompleteTime string `json:"completeTime"`
+			OrderId      string `json:"orderId"`
+		} `json:"result"`
+	} `json:"result"`
+}
+
+//Success 订单完成
+func (*msgJD) Success(ctx context.Context) (res *MsgSuccessRes, err error) {
+	method := "message/get"
+	param := g.Map{
+		"type": "31",
+	}
+	result, err := server.requestApi(ctx, method, param)
+	if err != nil {
+		return
+	}
+	err = gjson.NewWithOptions(result, gjson.Options{
+		StrNumber: true,
+	}).Scan(&res)
+	return
+}
+
+type MsgReplaceRes struct {
+	CommonRes
+	Result []struct {
+		Id     string `json:"id"`
+		Time   string `json:"time"`
+		Type   int    `json:"type"`
+		Result struct {
+			AfsServiceId string `json:"afsServiceId"`
+			OrderId      string `json:"orderId"`
+		} `json:"result"`
+	} `json:"result"`
+}
+
+//Replace 换新订单
+func (*msgJD) Replace(ctx context.Context) (res *MsgReplaceRes, err error) {
+	method := "message/get"
+	param := g.Map{
+		"type": "13",
+	}
+	result, err := server.requestApi(ctx, method, param)
+	if err != nil {
+		return
+	}
+	err = gjson.NewWithOptions(result, gjson.Options{
+		StrNumber: true,
+	}).Scan(&res)
+	return
+}
+
+type MsgRefundRes struct {
+	CommonRes
+	Result []struct {
+		Id     string `json:"id"`
+		Time   string `json:"time"`
+		Type   int    `json:"type"`
+		Result struct {
+			Pin          string `json:"pin"`
+			AfsServiceId string `json:"afsServiceId"`
+			IsOffline    bool   `json:"isOffline"`
+			State        int    `json:"state,omitempty"`
+			SkuId        string `json:"skuId"`
+			OrderId      string `json:"orderId"`
+		} `json:"result"`
+	} `json:"result"`
+}
+
+//Refund 售后
+func (*msgJD) Refund(ctx context.Context) (res *MsgRefundRes, err error) {
+	method := "message/get"
+	param := g.Map{
+		"type": "110",
+	}
+	result, err := server.requestApi(ctx, method, param)
+	if err != nil {
+		return
+	}
+	err = gjson.NewWithOptions(result, gjson.Options{
+		StrNumber: true,
+	}).Scan(&res)
+	return
+}