From 57cb8260873aca50895ee92908c441fb40975044 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Wed, 6 Jan 2021 15:23:08 +0800 Subject: [PATCH] aa --- business/jxstore/report/report.go | 101 ++++++++++++++++++++++++++ controllers/jx_report.go | 18 +++++ routers/commentsRouter_controllers.go | 9 +++ 3 files changed, 128 insertions(+) diff --git a/business/jxstore/report/report.go b/business/jxstore/report/report.go index 6fadcdcfe..c1352495b 100644 --- a/business/jxstore/report/report.go +++ b/business/jxstore/report/report.go @@ -283,3 +283,104 @@ func BeginSavePriceRefer(ctx *jxcontext.Context, cityCodes, skuIDs []int, isAsyn } return hint, err } + +type GetManageStateResult struct { + OpenStoreCount int `json:"openStoreCount"` //营业店铺数 + HaveRestStoreCount int `json:"haveRestStoreCount"` //临时休息店铺数 + RestStoreCount int `json:"restStoreCount"` //休息店铺数 + FinishOrderState *GetManageStateOrderInfo //完成订单情况 + IngOrderState *GetManageStateOrderInfo //进行中订单情况 + CancelOrderState *GetManageStateOrderInfo //取消订单情况 +} + +type GetManageStateOrderInfo struct { + ActualPayPrice int `json:"actualPayPrice"` //支付总额 + TotalShopMoney int `json:"totalShopMoney"` //平台结算 + DesiredFee int `json:"desiredFee"` //配送费 + Yhld string `json:"yhld"` //优惠力度（支付总额-平台结算-配送支出）/支付总额*100% +} + +func getStoreStatusCount(db *dao.DaoDB, cityCodes []int, vendorID, status int) (count int, err error) { + countType := &struct{ Count int }{} + sqlParams := []interface{}{} + sql := ` + SELECT COUNT(a.id) count + FROM store a + LEFT JOIN store_map b ON a.id = b.store_id AND b.deleted_at = ? + ` + if len(cityCodes) > 0 { + sql += " AND a.city_code IN (" + dao.GenQuestionMarks(len(cityCodes)) + ")" + sqlParams = append(sqlParams, cityCodes) + } + if vendorID != -1 { + sql += " AND b.vendor_id = ? AND b.status = ?" + sqlParams = append(sqlParams, vendorID, status) + } else { + sql += " AND a.status = ?" + sqlParams = append(sqlParams, status) + } + sql += ` + WHERE a.deleted_at = ? + ` + sqlParams = append(sqlParams, utils.DefaultTimeValue, utils.DefaultTimeValue) + err = dao.GetRow(db, &countType, sql, sqlParams) + return countType.Count, err +} + +func getOrderStateCount(db *dao.DaoDB, cityCodes []int, vendorID, status int) (getManageStateOrderInfo *GetManageStateOrderInfo, err error) { + sqlParams := []interface{}{} + endTime := time.Now().AddDate(0, -3, 0) + sql := ` + SELECT SUM(b.actual_pay_price) actual_pay_price, SUM(b.total_shop_money) total_shop_money, SUM(IFNULL(c.desired_fee, 0)) desired_fee + FROM store a + LEFT JOIN goods_order b ON a.id = IF(b.jx_store_id = 0, b.store_id, b.jx_store_id) + LEFT JOIN waybill c ON IF(a.waybill_vendor_id = -1,a.vendor_order_id,a.vendor_waybill_id) = b.vendor_waybill_id + WHERE a.deleted_at = ? AND a.status <> ? + AND b.order_created_at < ? AND b.order_created_at > ? + ` + sqlParams = append(sqlParams, utils.DefaultTimeValue, model.StoreStatusDisabled, time.Now(), endTime) + if len(cityCodes) > 0 { + sql += " AND a.city_code IN (" + dao.GenQuestionMarks(len(cityCodes)) + ")" + sqlParams = append(sqlParams, cityCodes) + } + if vendorID != -1 { + sql += " AND b.vendor_id = ?" + sqlParams = append(sqlParams, vendorID, status) + } + if status != model.OrderStatusDelivering { + sql += " AND b.status = ?" + sqlParams = append(sqlParams, status) + } else { + sql += " AND b.status < ? AND b.status >= ?" + sqlParams = append(sqlParams, model.OrderStatusEndBegin, model.OrderStatusWait4Pay) + } + err = dao.GetRow(db, &getManageStateOrderInfo, sql, sqlParams) + getManageStateOrderInfo.Yhld = utils.Float64ToStr((float64(getManageStateOrderInfo.ActualPayPrice-getManageStateOrderInfo.TotalShopMoney-getManageStateOrderInfo.DesiredFee) / float64(getManageStateOrderInfo.ActualPayPrice) * 100)) + "%" + return getManageStateOrderInfo, err +} + +func GetManageState(ctx *jxcontext.Context, cityCodes []int, vendorID int) (getManageStateResult *GetManageStateResult, err error) { + var ( + db = dao.GetDB() + ) + getManageStateResult = &GetManageStateResult{} + if openCount, err := getStoreStatusCount(db, cityCodes, vendorID, model.StoreStatusOpened); err == nil { + getManageStateResult.OpenStoreCount = openCount + } + if haveRestCount, err := getStoreStatusCount(db, cityCodes, vendorID, model.StoreStatusHaveRest); err == nil { + getManageStateResult.HaveRestStoreCount = haveRestCount + } + if restCount, err := getStoreStatusCount(db, cityCodes, vendorID, model.StoreStatusClosed); err == nil { + getManageStateResult.RestStoreCount = restCount + } + if finishCount, err := getOrderStateCount(db, cityCodes, vendorID, model.OrderStatusFinished); err == nil { + getManageStateResult.FinishOrderState = finishCount + } + if ingCount, err := getOrderStateCount(db, cityCodes, vendorID, model.OrderStatusDelivering); err == nil { + getManageStateResult.IngOrderState = ingCount + } + if cancelCount, err := getOrderStateCount(db, cityCodes, vendorID, model.OrderStatusCanceled); err == nil { + getManageStateResult.CancelOrderState = cancelCount + } + return getManageStateResult, err +} diff --git a/controllers/jx_report.go b/controllers/jx_report.go index 7966917de..c51c45836 100644 --- a/controllers/jx_report.go +++ b/controllers/jx_report.go @@ -96,3 +96,21 @@ func (c *ReportController) AutoFocusStoreSkus() { return retVal, "", err }) } + +// @Title 查询经营概况 +// @Description 查询经营概况 +// @Param token header string true "认证token" +// @Param cityCodes query string false "城市ID列表[1,2,3]" +// @Param vendorID query int false "vendorID 全部传-1" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetManageState [get] +func (c *ReportController) GetManageState() { + c.callGetManageState(func(params *tReportGetManageStateParams) (retVal interface{}, errCode string, err error) { + var cityCodes []int + if err = jxutils.Strings2Objs(params.CityCodes, &cityCodes); err == nil { + retVal, err = report.GetManageState(params.Ctx, cityCodes, params.VendorID) + } + return retVal, "", err + }) +} diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go index e9603eecf..262cea321 100644 --- a/routers/commentsRouter_controllers.go +++ b/routers/commentsRouter_controllers.go @@ -1539,6 +1539,15 @@ func init() { Filters: nil, Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ReportController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ReportController"], + beego.ControllerComments{ + Method: "GetManageState", + Router: `/GetManageState`, + AllowHTTPMethods: []string{"get"}, + MethodParams: param.Make(), + Filters: nil, + Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ReportController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:ReportController"], beego.ControllerComments{ Method: "PriceRefer",