商品审核查询增加全国中位价
This commit is contained in:
@@ -4501,6 +4501,12 @@ func doStoreSkuAudit(ctx *jxcontext.Context, storeIDs []int, skuBindInfos []*Sto
|
|||||||
if len(storeAudits) > 0 {
|
if len(storeAudits) > 0 {
|
||||||
storeAudits[0].DeletedAt = time.Now()
|
storeAudits[0].DeletedAt = time.Now()
|
||||||
dao.UpdateEntity(db, storeAudits[0], "DeletedAt")
|
dao.UpdateEntity(db, storeAudits[0], "DeletedAt")
|
||||||
|
if !globals.IsProductEnv() {
|
||||||
|
skuAndNames, err := dao.GetSkus(db, nil, []int{skuBindInfo.NameID}, nil, nil, nil)
|
||||||
|
if len(skuAndNames) > 0 && err == nil {
|
||||||
|
weixinmsg.NotifyStoreOpRequestStatus(true, storeID, skuBindInfo.NameID, jxutils.ComposeSpuName(skuAndNames[0].Prefix, skuAndNames[0].Name, 0), storeAudits[0].OriginUnitPrice, skuBindInfo.UnitPrice, "")
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
globals.SugarLogger.Debugf("doStoreSkuAudit return3 storeID : %v nameID: %v", storeID, skuBindInfo.NameID)
|
globals.SugarLogger.Debugf("doStoreSkuAudit return3 storeID : %v nameID: %v", storeID, skuBindInfo.NameID)
|
||||||
return false, err
|
return false, err
|
||||||
|
|||||||
@@ -1545,19 +1545,24 @@ type tStoreSkuAudit struct {
|
|||||||
SpecUnit string `orm:"size(8)" json:"-"` // 为份必然为克,这个主要作用只是用于确保SkuName的唯一性
|
SpecUnit string `orm:"size(8)" json:"-"` // 为份必然为克,这个主要作用只是用于确保SkuName的唯一性
|
||||||
Img string `orm:"size(512)" json:"img"`
|
Img string `orm:"size(512)" json:"img"`
|
||||||
Name string `json:"name"`
|
Name string `json:"name"`
|
||||||
|
MidUnitPrice int `json:"midUnitPrice"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetStoreSkuAudit(db *DaoDB, storeIDs, nameIDs, skuIDs, statuss, types []int, name, remark, keyword, marketManPhone string, applyTimeStart, applyTimeEnd, auditTimeStart, auditTimeEnd time.Time, pageSize, offset int) (pagedInfo *model.PagedInfo, err error) {
|
func GetStoreSkuAudit(db *DaoDB, storeIDs, nameIDs, skuIDs, statuss, types []int, name, remark, keyword, marketManPhone string, applyTimeStart, applyTimeEnd, auditTimeStart, auditTimeEnd time.Time, pageSize, offset int) (pagedInfo *model.PagedInfo, err error) {
|
||||||
var requestList []*tStoreSkuAudit
|
var requestList []*tStoreSkuAudit
|
||||||
sql := `
|
sql := `
|
||||||
SELECT SQL_CALC_FOUND_ROWS a.*, c.name sku_name, c.prefix, c.unit, c.spec_quality, c.spec_unit, c.img, d.name store_name, b.name
|
SELECT SQL_CALC_FOUND_ROWS a.*, c.name sku_name, c.prefix, c.unit, c.spec_quality, c.spec_unit, c.img, d.name store_name, b.name, e.mid_unit_price
|
||||||
FROM store_sku_audit a
|
FROM store_sku_audit a
|
||||||
LEFT JOIN user b ON a.user_id = b.user_id
|
LEFT JOIN user b ON a.user_id = b.user_id
|
||||||
LEFT JOIN sku_name c ON c.id = a.name_id AND c.deleted_at = ?
|
LEFT JOIN sku_name c ON c.id = a.name_id AND c.deleted_at = ?
|
||||||
LEFT JOIN store d ON d.id = a.store_id AND d.deleted_at = ?
|
LEFT JOIN store d ON d.id = a.store_id AND d.deleted_at = ?
|
||||||
|
LEFT JOIN price_refer_snapshot e ON e.name_id = c.id AND e.city_code = ? AND e.snapshot_at = ?
|
||||||
WHERE a.deleted_at = ?
|
WHERE a.deleted_at = ?
|
||||||
`
|
`
|
||||||
sqlParams := []interface{}{utils.DefaultTimeValue, utils.DefaultTimeValue, utils.DefaultTimeValue}
|
sqlParams := []interface{}{
|
||||||
|
utils.DefaultTimeValue, utils.DefaultTimeValue,
|
||||||
|
0, utils.Time2Date(time.Now().AddDate(0, 0, -1)),
|
||||||
|
utils.DefaultTimeValue}
|
||||||
if len(storeIDs) > 0 {
|
if len(storeIDs) > 0 {
|
||||||
sql += " AND a.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
|
sql += " AND a.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
|
||||||
sqlParams = append(sqlParams, storeIDs)
|
sqlParams = append(sqlParams, storeIDs)
|
||||||
|
|||||||
Reference in New Issue
Block a user