商品审核状态增加一个2,表示预审核
This commit is contained in:
@@ -4674,16 +4674,19 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
|
||||
if status == model.StoreAuditStatusOnline {
|
||||
return nil, "", fmt.Errorf("审核标志不正确!")
|
||||
}
|
||||
for _, v := range storeSkuAudits {
|
||||
skuList, _ := dao.GetStoreSkusByNameIDs(db, []int{v.StoreID}, v.NameID)
|
||||
if len(skuList) > 0 {
|
||||
if int64(v.AuditPrice) > skuList[0].UnitPrice*2 {
|
||||
storeSkuAudits2 = append(storeSkuAudits2, v)
|
||||
//证明是预审核
|
||||
if status == 2 {
|
||||
for _, v := range storeSkuAudits {
|
||||
skuList, _ := dao.GetStoreSkusByNameIDs(db, []int{v.StoreID}, v.NameID)
|
||||
if len(skuList) > 0 {
|
||||
if int64(v.AuditPrice) > skuList[0].UnitPrice*2 {
|
||||
storeSkuAudits2 = append(storeSkuAudits2, v)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
if len(storeSkuAudits2) > 0 {
|
||||
return storeSkuAudits2, "", err
|
||||
if len(storeSkuAudits2) > 0 {
|
||||
return storeSkuAudits2, "", err
|
||||
}
|
||||
}
|
||||
task := tasksch.NewParallelTask("StoreSkuPriceAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(isContinueWhenError), ctx,
|
||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||
|
||||
@@ -876,7 +876,7 @@ func (c *StoreSkuController) GetStoreSkuAudit() {
|
||||
// @Description 审核商品
|
||||
// @Param token header string true "认证token"
|
||||
// @Param payload formData string true "json数据,storeskuaudit对象"
|
||||
// @Param status formData int false "审核标志,1通过,-1 不通过"
|
||||
// @Param status formData int false "审核标志,1通过,-1 不通过,2 预审核"
|
||||
// @Param isAsync formData bool false "是否异步,缺省是同步"
|
||||
// @Param isContinueWhenError formData bool false "单个同步失败是否继续,缺省false"
|
||||
// @Success 200 {object} controllers.CallResult
|
||||
|
||||
Reference in New Issue
Block a user