1
This commit is contained in:
@@ -1,7 +1,6 @@
|
||||
package mtwmapi
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"git.rosy.net.cn/jx-callback/globals"
|
||||
"regexp"
|
||||
"strings"
|
||||
@@ -180,20 +179,20 @@ func (a *API) RetailCatUpdate(poiCode, catName string, updateParams *Param4Updat
|
||||
params[KeyAppPoiCode] = poiCode
|
||||
params["category_name"] = catName
|
||||
|
||||
categoryChannel <- params
|
||||
for {
|
||||
select {
|
||||
case <-categoryChannel:
|
||||
if _, err := a.AccessAPI("retailCat/update", false, params); err != nil {
|
||||
errList = append(errList, err.Error())
|
||||
}
|
||||
default:
|
||||
return errors.New(strings.Join(errList, ","))
|
||||
}
|
||||
}
|
||||
//categoryChannel <- params
|
||||
//for {
|
||||
// select {
|
||||
// case <-categoryChannel:
|
||||
// if _, err := a.AccessAPI("retailCat/update", false, params); err != nil {
|
||||
// errList = append(errList, err.Error())
|
||||
// }
|
||||
// default:
|
||||
// return errors.New(strings.Join(errList, ","))
|
||||
// }
|
||||
//}
|
||||
|
||||
// _, err = a.AccessAPI("retailCat/update", false, params)
|
||||
//return err
|
||||
_, err = a.AccessAPI("retailCat/update", false, params)
|
||||
return err
|
||||
}
|
||||
|
||||
var categoryChannel = make(chan map[string]interface{}, 100)
|
||||
|
||||
Reference in New Issue
Block a user