liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- fk

Browse Source
This commit is contained in:
gazebo
2018-11-07 09:56:53 +08:00
parent 1befa2805d
commit a3cc68088f
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxstore/promotion/jd_promotion.go
View File

@@ -689,6 +689,7 @@ func RefreshJdStoreSkuStock() (err error) {
for _, v := range batchItemList { for _, v := range batchItemList {
promotionItem := v.(*tPromotionItemInfo) promotionItem := v.(*tPromotionItemInfo)
if promotionItem.JdStoreID != stationNo { if promotionItem.JdStoreID != stationNo {
globals.SugarLogger.Debugf("RefreshJdStoreSkuStock BatchUpdateCurrentQtys stationNo:%s, stockList:%s", stationNo, utils.Format4Output(stockList, false))
_, err = api.JdAPI.BatchUpdateCurrentQtys("", stationNo, stockList, userName) _, err = api.JdAPI.BatchUpdateCurrentQtys("", stationNo, stockList, userName)
if err != nil { if err != nil {
globals.SugarLogger.Warnf("RefreshJdStoreSkuStock BatchUpdateCurrentQtys failed with error:%v", err) globals.SugarLogger.Warnf("RefreshJdStoreSkuStock BatchUpdateCurrentQtys failed with error:%v", err)
@@ -701,6 +702,7 @@ func RefreshJdStoreSkuStock() (err error) {
StockQty: model.MaxStoreSkuStockQty, StockQty: model.MaxStoreSkuStockQty,
}) })
} }
globals.SugarLogger.Debugf("RefreshJdStoreSkuStock BatchUpdateCurrentQtys stationNo:%s, stockList:%s", stationNo, utils.Format4Output(stockList, false))
_, err = api.JdAPI.BatchUpdateCurrentQtys("", stationNo, stockList, userName) _, err = api.JdAPI.BatchUpdateCurrentQtys("", stationNo, stockList, userName)
if err != nil { if err != nil {
globals.SugarLogger.Warnf("RefreshJdStoreSkuStock BatchUpdateCurrentQtys failed with error:%v", err) globals.SugarLogger.Warnf("RefreshJdStoreSkuStock BatchUpdateCurrentQtys failed with error:%v", err)
@@ -718,7 +720,7 @@ func UpdateJdPromotionStatus() (num int64, err error) {
sql := ` sql := `
UPDATE promotion t1 UPDATE promotion t1
SET t1.status = ? SET t1.status = ?
WHERE t1.deleted_at = ? AND t1.vendor_id = ? AND t1.status = ? AND (t1.begin_at > ? OR t1.end_at < ?) WHERE t1.deleted_at = ? AND t1.vendor_id = ? AND t1.status = ? AND t1.end_at < ?
` `
nowDate := utils.GetCurDate() nowDate := utils.GetCurDate()
sqlParams := []interface{}{ sqlParams := []interface{}{
@@ -727,13 +729,13 @@ func UpdateJdPromotionStatus() (num int64, err error) {
model.VendorIDJD, model.VendorIDJD,
model.PromotionStatusRemoteCreated, model.PromotionStatusRemoteCreated,
nowDate, nowDate,
nowDate,
} }
db := dao.GetDB() db := dao.GetDB()
return dao.ExecuteSQL(db, sql, sqlParams...) return dao.ExecuteSQL(db, sql, sqlParams...)
} }
func RefreshJdPromotionItemListLockStatus(promotionItemList []*tPromotionItemInfo) (err error) { func RefreshJdPromotionItemListLockStatus(promotionItemList []*tPromotionItemInfo) (err error) {
globals.SugarLogger.Debugf("RefreshJdPromotionItemListLockStatus promotionItemList:%s", utils.Format4Output(promotionItemList, false))
if len(promotionItemList) > 0 { if len(promotionItemList) > 0 {
expire := promotionItemList[0].EndAt.Add(24 * time.Hour) expire := promotionItemList[0].EndAt.Add(24 * time.Hour)
for _, item := range promotionItemList { for _, item := range promotionItemList {