1
This commit is contained in:
@@ -2219,6 +2219,7 @@ func UpdateStoreName() error {
|
|||||||
var db = dao.GetDB()
|
var db = dao.GetDB()
|
||||||
sql := ` SELECT * FROM store_courier_map WHERE vendor_id IN (?,?,?,?) AND deleted_at = ?`
|
sql := ` SELECT * FROM store_courier_map WHERE vendor_id IN (?,?,?,?) AND deleted_at = ?`
|
||||||
courierList := make([]*model.StoreCourierMap, 0, 0)
|
courierList := make([]*model.StoreCourierMap, 0, 0)
|
||||||
|
globals.SugarLogger.Debugf("====================len : %d", len(courierList))
|
||||||
if err := dao.GetRows(db, &courierList, sql, []interface{}{model.VendorIDMTPS, model.VendorIDFengNiao, model.VendorIDDada, model.VendorIDUUPT, utils.DefaultTimeValue}...); err != nil {
|
if err := dao.GetRows(db, &courierList, sql, []interface{}{model.VendorIDMTPS, model.VendorIDFengNiao, model.VendorIDDada, model.VendorIDUUPT, utils.DefaultTimeValue}...); err != nil {
|
||||||
globals.SugarLogger.Debugf("query Order err := %v", err)
|
globals.SugarLogger.Debugf("query Order err := %v", err)
|
||||||
return err
|
return err
|
||||||
@@ -2227,6 +2228,7 @@ func UpdateStoreName() error {
|
|||||||
work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||||
var resultList []interface{}
|
var resultList []interface{}
|
||||||
storeCourier := batchItemList[0].(*model.StoreCourierMap)
|
storeCourier := batchItemList[0].(*model.StoreCourierMap)
|
||||||
|
globals.SugarLogger.Debugf("====================storeId : %d", storeCourier.StoreID)
|
||||||
errList := errlist.New()
|
errList := errlist.New()
|
||||||
db := dao.GetDB()
|
db := dao.GetDB()
|
||||||
|
|
||||||
@@ -2236,7 +2238,7 @@ func UpdateStoreName() error {
|
|||||||
if updateHandler, _ := handlerInfo.Handler.(partner.IDeliveryUpdateStoreHandler); updateHandler != nil {
|
if updateHandler, _ := handlerInfo.Handler.(partner.IDeliveryUpdateStoreHandler); updateHandler != nil {
|
||||||
if err := updateHandler.UpdateStoreName(storeDetail.VendorStoreID, storeDetail.Name); err != nil {
|
if err := updateHandler.UpdateStoreName(storeDetail.VendorStoreID, storeDetail.Name); err != nil {
|
||||||
errList.AddErr(err)
|
errList.AddErr(err)
|
||||||
globals.SugarLogger.Debugf("err := %s,storeID : %s,storeName :%s", utils.Format4Output(err, false), storeDetail.VendorStoreID, storeDetail.Name)
|
globals.SugarLogger.Debugf("err := %v,storeID : %s,storeName :%s , vendorId : %d", err, storeDetail.VendorStoreID, storeDetail.Name, storeDetail.VendorID)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -231,7 +231,7 @@ func Init() {
|
|||||||
ScheduleTimerFunc("UpdateStoreName ", func() {
|
ScheduleTimerFunc("UpdateStoreName ", func() {
|
||||||
cms.UpdateStoreName()
|
cms.UpdateStoreName()
|
||||||
}, []string{
|
}, []string{
|
||||||
"14:05:00",
|
"15:30:00",
|
||||||
})
|
})
|
||||||
|
|
||||||
// 定时任务更新昨天的都要商品和本地商品id的映射关系
|
// 定时任务更新昨天的都要商品和本地商品id的映射关系
|
||||||
|
|||||||
Reference in New Issue
Block a user