审核门店
This commit is contained in:
@@ -3601,7 +3601,7 @@ func GetStoreAudit(ctx *jxcontext.Context, statuss []int, keyword, applyTimeStar
|
|||||||
|
|
||||||
func StoreAudit(ctx *jxcontext.Context, storeAudits []*model.StoreAudit, status int) (err error) {
|
func StoreAudit(ctx *jxcontext.Context, storeAudits []*model.StoreAudit, status int) (err error) {
|
||||||
db := dao.GetDB()
|
db := dao.GetDB()
|
||||||
if status == model.StoreAuditStatusOnline {
|
if status != model.StoreAuditStatusCreated && status != model.StoreAuditStatusRejected {
|
||||||
return fmt.Errorf("审核标志不正确!")
|
return fmt.Errorf("审核标志不正确!")
|
||||||
}
|
}
|
||||||
task := tasksch.NewParallelTask("StoreAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx,
|
task := tasksch.NewParallelTask("StoreAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx,
|
||||||
@@ -3618,8 +3618,10 @@ func StoreAudit(ctx *jxcontext.Context, storeAudits []*model.StoreAudit, status
|
|||||||
if status == model.StoreAuditStatusCreated {
|
if status == model.StoreAuditStatusCreated {
|
||||||
storeAudits[0].AuditStatus = model.StoreAuditStatusCreated
|
storeAudits[0].AuditStatus = model.StoreAuditStatusCreated
|
||||||
//添加门店
|
//添加门店
|
||||||
var storeExt *StoreExt
|
storeExt := &StoreExt{}
|
||||||
utils.Map2StructByJson(utils.Struct2MapByJson(&storeAudits[0]), &storeExt, false)
|
if data, err := json.Marshal(&storeAudits[0]); err == nil {
|
||||||
|
utils.UnmarshalUseNumber(data, &storeExt)
|
||||||
|
}
|
||||||
storeID, err := CreateStore(ctx, storeExt, ctx.GetUserName())
|
storeID, err := CreateStore(ctx, storeExt, ctx.GetUserName())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return retVal, fmt.Errorf(err.Error())
|
return retVal, fmt.Errorf(err.Error())
|
||||||
|
|||||||
Reference in New Issue
Block a user