添加淘宝

platformapi/tao_vegetable/order_afs.go

@@ -9,10 +9,12 @@ import (
 	"git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability591"
 	domain591 "git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability591/domain"
 	request591 "git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability591/request"
+	"git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/util"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/globals"
 	"io/ioutil"
 	"net/http"
+	"time"
 )
 
 // AgreeUserCancel 同意用户售后申请
@@ -113,6 +115,17 @@ func (a *API) UserCancelRefundApply(c *http.Request) (*UserCancelRefundApply, er
 	return result, nil
 }
 
+// OnSaleRefundOrder 用户售中取消
+func (a *API) OnSaleRefundOrder(c *http.Request) (*OnSaleCancel, error) {
+	body, _ := ioutil.ReadAll(c.Body)
+
+	var onSaleOrder *OnSaleCancel
+	if err := json.Unmarshal(body, &onSaleOrder); err != nil {
+		return nil, err
+	}
+	return onSaleOrder, nil
+}
+
 // RefundOrderFinish 同城零售逆向订单状态完成接口(退款完成)
 func (a *API) RefundOrderFinish(c *http.Request) (*RefundOrderFinish, error) {
 	data, err := ioutil.ReadAll(c.Body)
@@ -162,6 +175,46 @@ func (a *API) QueryAfsOrderDetailList(req *request591.AlibabaWdkOrderRefundListR
 	return &data.Result, nil
 }
 
+// GetTransactionOrderListByTime 获取门店当天订单
+func (a *API) GetTransactionOrderListByTime(storeId string, queryData time.Time) ([]string, error) {
+	createTime := util.LocalTime(time.Date(queryData.Year(), queryData.Month(), queryData.Day(), 0, 0, 0, 0, queryData.Location()))
+	endTime := util.LocalTime(time.Date(queryData.Year(), queryData.Month(), queryData.Day(), 23, 59, 59, 59, queryData.Location()))
+	var pageIndex int64 = 0
+	var PageSize int64 = 200
+	param := &request591.AlibabaWdkOrderListRequest{
+		BatchQueryRequest: &domain591.AlibabaWdkOrderListBatchQueryRequest{
+			StoreIds:  &[]string{storeId},
+			StartTime: &createTime,
+			EndTime:   &endTime,
+			OrderFrom: utils.Int64ToPointer(ChannelCome),
+			ShopId:    nil,
+			StoreId:   nil,
+			BizType:   nil,
+		},
+	}
+	vendorOrderList := make([]string, 0, 0)
+
+	for {
+		param.BatchQueryRequest.SetPageSize(PageSize)
+		param.BatchQueryRequest.SetPageIndex(pageIndex)
+		result, err := a.GetTransactionOrderList(param)
+		if err != nil {
+			return nil, err
+		}
+
+		for _, v := range *result.Orders {
+			vendorOrderList = append(vendorOrderList, utils.Int64ToStr(*v.BizOrderId))
+		}
+		if *result.NextIndex != -1 {
+			pageIndex += 1
+		} else {
+			break
+		}
+	}
+
+	return vendorOrderList, nil
+}
+
 // GetTransactionOrderList 实时拉取交易列表
 func (a *API) GetTransactionOrderList(req *request591.AlibabaWdkOrderListRequest) (*domain591.AlibabaWdkOrderListResult, error) {
 	client := ability591.NewAbility591(&a.client)