This commit is contained in:
苏尹岚
2021-03-10 17:25:59 +08:00
parent 8859a41bdf
commit a76e30bc35
3 changed files with 49 additions and 24 deletions

View File

@@ -478,39 +478,27 @@ func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, f
}
result.OpenTime = optime * float64(dayCount)
//商品数
skuCount, highSkuCount := 0, 0
dao.GetStoresSkusInfo(db, storeIDs, skuIDs)
storeSkus, _ := dao.GetStoresSkusInfo(db, []int{v}, nil)
highSkuCount := 0
storeSkus, _ := dao.GetStoresSkusForManageState(db, v, model.StoreSkuBindStatusNormal)
for _, v := range storeSkus {
if v.Status == model.StoreSkuBindStatusNormal && v.Stock > 0 {
skuCount++
if priceRefer, err := dao.GetPriceReferPrice(db, 0, v.SkuID, utils.Time2Date(time.Now().AddDate(0, 0, -1))); err == nil && priceRefer != nil {
if v.UnitPrice > priceRefer.MidUnitPrice {
highSkuCount++
}
}
if v.UnitPrice > v.MidUnitPrice {
highSkuCount++
}
}
result.SkuCount, result.HighSkuCount = skuCount, highSkuCount
result.SkuCount, result.HighSkuCount = len(storeSkus), highSkuCount
//活动丰富度
handler := partner.GetPurchasePlatformFromVendorID(vendorID)
ample, _ := handler.GetActAmple(ctx, storeDetail.VendorStoreID, storeDetail.VendorStoreID)
result.ActAmple = ample
//订单
nullOrderCount, refuseOrderCount := 0, 0
if orderList, err := dao.QueryOrders(db, "", 0, []int{vendorID}, v, fromTimeT, toTimeT); err == nil {
for _, v := range orderList {
if v.Status == model.OrderStatusCanceled {
nullOrderCount++
}
if waybills, err2 := dao.GetWayBillByOrderID(db, 0, vendorID, 0, v.VendorOrderID); err2 == nil {
if len(waybills) == 0 {
refuseOrderCount++
}
}
refuseOrderCount := 0
orderList, err := dao.QueryOrdersForManageState(db, v, vendorID, model.OrderStatusCanceled, fromTimeT, toTimeT)
for _, v := range orderList {
if v.BindID == 0 {
refuseOrderCount++
}
}
result.NullOrderCount, result.RefuseOrderCount = nullOrderCount, refuseOrderCount
result.NullOrderCount, result.RefuseOrderCount = len(orderList), refuseOrderCount
//评分(美团)
if vendorID == model.VendorIDMTWM {
mtapi := partner.CurAPIManager.GetAPI(model.VendorIDMTWM, storeDetail.VendorOrgCode).(*mtwmapi.API)

View File

@@ -1607,3 +1607,40 @@ func GetUserCoupons(db *DaoDB, couponIDs []int, userIDs, mobiles []string, userS
err = GetRows(db, &userCoupons, sql, sqlParams)
return userCoupons, err
}
type QueryOrdersForManageStateResult struct {
VendorOrderID string `orm:"column(vendor_order_id)"`
BindID int `orm:"column(bind_id)"`
}
func QueryOrdersForManageState(db *DaoDB, storeID, vendorID, status int, fromTime, toTime time.Time) (userCoupons []*QueryOrdersForManageStateResult, err error) {
sql := `
SELECT a.vendor_order_id ,b.id bind_id
FROM goods_order a
LEFT JOIN waybill b ON a.vendor_order_id = b.vendor_order_id
WHERE 1 = 1
`
sqlParams := []interface{}{}
if storeID != 0 {
sql += " AND (a.storeID = ? OR a.jx_store_id = ?)"
sqlParams = append(sqlParams, storeID, storeID)
}
if vendorID != -1 {
sql += " AND a.vendor_id = ?"
sqlParams = append(sqlParams, vendorID)
}
if status != 0 {
sql += " AND a.status = ?"
sqlParams = append(sqlParams, status)
}
if !utils.IsTimeZero(fromTime) {
sql += " AND a.order_created_at > ?"
sqlParams = append(sqlParams, fromTime)
}
if !utils.IsTimeZero(toTime) {
sql += " AND a.order_created_at < ?"
sqlParams = append(sqlParams, toTime)
}
err = GetRows(db, &userCoupons, sql, sqlParams)
return userCoupons, err
}

View File

@@ -769,7 +769,7 @@ func GetDataResFieldName(vendorID int) (fieldName string) {
// return fieldName
// }
func GetStoresSkusInfo(db *DaoDB, storeIDs, skuIDs []int, status int) (storeSkuList []*model.StoreSkuBind, err error) {
func GetStoresSkusInfo(db *DaoDB, storeIDs, skuIDs []int) (storeSkuList []*model.StoreSkuBind, err error) {
sql := `
SELECT *
FROM store_sku_bind t1