订单列表/分红列表修改

yangfu
pkg/application/dividend/dividend.go
pkg/application/order/order.go
pkg/domain/order.go
pkg/infrastructure/dao/pg_order_dao.go
pkg/infrastructure/pg/models/order.go
pkg/protocol/order.go
--- a/pkg/application/dividend/dividend.go
查看文件 @7abef24
+++ b/pkg/application/dividend/dividend.go
查看文件 @7abef24
@@ -67,7 +67,7 @@ func QuartersBonusStatics(orders []*domain.Order, action int) (bonus []protocol.
 	bonus = make([]protocol.Bonus, 4)
 	for i := range orders {
 		o := orders[i]
-		quarter := o.CreateAt.Month() / 4
+		quarter := o.CreateAt.Month() / 3
 		bonus[quarter].Received += o.OrderBonusReceive()
 		bonus[quarter].Outstanding += o.OrderBonusWait()
 		bonus[quarter].Expend += o.OrderBonusOutstanding()
@@ -99,13 +99,14 @@ func DividendOrders(header *protocol.RequestHeader, request *protocol.DividendOr
 	rsp = &protocol.DividendOrdersResponse{List: make([]*protocol.DividendOrderListItem, 0)}
 	count, orders, err = OrderDao.DividendOrders(&domain.DividendOrdersQueryOption{
-		PartnerId:      header.UserId,
-		DetailAction:   request.DetailAction,
-		DividendAction: request.DividendAction,
-		StartTime:      request.StartTime,
-		EndTime:        request.EndTime,
-		Offset:         request.PageIndex * request.PageSize,
-		Limit:          request.PageSize,
+		PartnerId:        header.UserId,
+		DetailAction:     request.DetailAction,
+		DividendAction:   request.DividendAction,
+		StartTime:        request.StartTime,
+		EndTime:          request.EndTime,
+		Offset:           request.PageIndex * request.PageSize,
+		Limit:            request.PageSize,
+		SortByUpdateTime: domain.DESC,
 	})
 	if err != nil {
 		return
--- a/pkg/application/order/order.go
查看文件 @7abef24
+++ b/pkg/application/order/order.go
查看文件 @7abef24
@@ -53,6 +53,7 @@ func OrderDetail(header *protocol.RequestHeader, request *protocol.OrderDetailRe
 		OrderQuantity:     order.OrderActualCount,
 		OrderAmount:       order.OrderActualAmount,
 		OrderAmountCancel: order.OrderAmountCancel(),
+		OrderUpdateReason: order.Reason,
 		OrderDistrict:     map[string]interface{}{"id": order.OrderRegionInfo.RegionId, "name": order.OrderRegionInfo.RegionName},
 		Customer:          protocol.Customer{Uname: order.Buyer.BuyerName, Phone: order.Buyer.ContactInfo},
 		MyDividend:        order.OrderTotalBonus(),
@@ -149,8 +150,7 @@ func OrderList(header *protocol.RequestHeader, request *protocol.OrderListReques
 	if request.PageIndex == 0 {
 		var (
 			partShipmentQuantity, allShipmentQuantity int
-			//cumulativeQuantity,
-			intentionQuantity int
+			cumulativeQuantity, intentionQuantity     int
 		)
 		//部分发货的订单数量
 		partShipmentQuantity, _, err = OrderDao.OrderStatics(&domain.OrderStaticQuery{
@@ -169,24 +169,24 @@ func OrderList(header *protocol.RequestHeader, request *protocol.OrderListReques
 			OrderStatus: domain.OrderStatusDeliverAll,
 		})
 		//累计实发订单
-		//cumulativeQuantity, _, err = OrderDao.OrderStatics(&domain.OrderStaticQuery{
-		//	EndTime:   request.EndTime,
-		//	BeginTime: request.StartTime,
-		//	OrderType: domain.OrderReal,
-		//	PartnerId: header.UserId,
-		//})
+		cumulativeQuantity, _, err = OrderDao.OrderStatics(&domain.OrderStaticQuery{
+			EndTime: time.Now().Unix() * 1000,
+			//BeginTime: request.StartTime,
+			OrderType: domain.OrderReal,
+			PartnerId: header.UserId,
+		})
 		//累计意向订单
 		intentionQuantity, _, err = OrderDao.OrderStatics(&domain.OrderStaticQuery{
-			EndTime:   request.EndTime,
-			BeginTime: request.StartTime,
+			EndTime: time.Now().Unix() * 1000,
+			//BeginTime: request.StartTime,
 			OrderType: domain.OrderIntention,
 			PartnerId: header.UserId,
 		})
 		//订单数量
 		rsp.Statistics["partShipmentQuantity"] = partShipmentQuantity
 		rsp.Statistics["allShipmentQuantity"] = allShipmentQuantity
-		rsp.Statistics["orderQuantity"] = partShipmentQuantity + allShipmentQuantity      //所有订单 = 部分发货 + 已经发货
-		rsp.Statistics["cumulativeQuantity"] = partShipmentQuantity + allShipmentQuantity //实发订单 = 部分发货 + 全部发货
+		rsp.Statistics["orderQuantity"] = partShipmentQuantity + allShipmentQuantity //所有订单 = 部分发货 + 已经发货
+		rsp.Statistics["cumulativeQuantity"] = cumulativeQuantity                    //实发订单 = 部分发货 + 全部发货
 		rsp.Statistics["intentionQuantity"] = intentionQuantity
 	}
@@ -207,7 +207,7 @@ func DomainOrderToOrderListItem(order *domain.Order) *protocol.OrderListItem {
 		OrderType:        order.OrderType,
 		OrderNo:          order.OrderCode,
 		OrderName:        order.OrderName,
-		OrderAmount:      order.OrderAmount,
+		OrderAmount:      order.OrderActualAmount,
 		OrderActualCount: order.OrderActualCount,
 		OrderStatus:      order.OrderStatus,
 		UpdateTime:       order.UpdateAt.Unix() * 1000,
--- a/pkg/domain/order.go
查看文件 @7abef24
+++ b/pkg/domain/order.go
查看文件 @7abef24
@@ -63,6 +63,8 @@ type Order struct {
 	//上一次查看时间 已读情况
 	LastViewTime time.Time `json:"lastViewTime,omitempty"`
+	//订单更新理由
+	Reason string `json:"reason,omitempty"`
 }
 func (m *Order) Identify() interface{} {
@@ -149,13 +151,14 @@ type OrderQueryOption struct {
 }
 type DividendOrdersQueryOption struct {
-	PartnerId      int64 `json:"partnerId"`
-	DetailAction   int   `json:"detailAction"`   //明细类型（0已收明细、1未收明细）
-	DividendAction int   `json:"dividendAction"` //分红类型（0累计分红、1分红支出）
-	StartTime      int64 `json:"startTime" `
-	EndTime        int64 `json:"endTime"`
-	Offset         int   `json:"offset,omitempty"`
-	Limit          int   `json:"limit,omitempty"`
+	PartnerId        int64  `json:"partnerId"`
+	DetailAction     int    `json:"detailAction"`   //明细类型（0已收明细、1未收明细）
+	DividendAction   int    `json:"dividendAction"` //分红类型（0累计分红、1分红支出）
+	StartTime        int64  `json:"startTime" `
+	EndTime          int64  `json:"endTime"`
+	Offset           int    `json:"offset,omitempty"`
+	Limit            int    `json:"limit,omitempty"`
+	SortByUpdateTime string `json:"sortByUpdateTime,omitempty"`
 }
 //买家
--- a/pkg/infrastructure/dao/pg_order_dao.go
查看文件 @7abef24
+++ b/pkg/infrastructure/dao/pg_order_dao.go
查看文件 @7abef24
@@ -74,6 +74,9 @@ func (dao *OrderDao) DividendOrders(option *domain.DividendOrdersQueryOption) (c
 	if option.Offset > 0 {
 		q.Offset(option.Offset)
 	}
+	if len(option.SortByUpdateTime) > 0 {
+		q.Order(fmt.Sprintf("order.id %v", option.SortByUpdateTime))
+	}
 	count, err = q.Distinct().SelectAndCount()
 	return
 }
--- a/pkg/infrastructure/pg/models/order.go
查看文件 @7abef24
+++ b/pkg/infrastructure/pg/models/order.go
查看文件 @7abef24
@@ -45,4 +45,6 @@ type Order struct {
 	//上一次查看时间 已读情况
 	LastViewTime time.Time
+	//订单更新理由
+	Reason string
 }
--- a/pkg/protocol/order.go
查看文件 @7abef24
+++ b/pkg/protocol/order.go
查看文件 @7abef24
@@ -17,6 +17,7 @@ type OrderDetail struct {
 	OrderQuantity     int         `json:"orderQuantity"`
 	OrderAmount       float64     `json:"orderAmount"`
 	OrderAmountCancel float64     `json:"orderAmountCancel"`
+	OrderUpdateReason string      `json:"orderUpdateReason"`
 	OrderDistrict     interface{} `json:"orderDistrict"`
 	Customer          Customer    `json:"customer"`
 	MyDividend        float64     `json:"myDividend"`