- fix beginAt

business/jxstore/promotion/jd_promotion.go

@@ -590,6 +590,8 @@ func GetJdPromotions(ctx *jxcontext.Context, keyword string, params map[string]i
 }
 
 func CancelJdPromotion(ctx *jxcontext.Context, promotionID int) (err error) {
+	globals.SugarLogger.Debug("CancelJdPromotion promotionID:%d", promotionID)
+
 	db := dao.GetDB()
 	promotion := &model.Promotion{}
 	promotion.ID = promotionID
@@ -615,6 +617,8 @@ func CancelJdPromotion(ctx *jxcontext.Context, promotionID int) (err error) {
 
 // 每一段时间运行一次
 func RefreshJdLockStoreSku() (err error) {
+	globals.SugarLogger.Debug("RefreshJdLockStoreSku")
+
 	sql := `
 	SELECT t1.end_at, t22.vendor_store_id, t32.jd_id, t3.*
 	FROM promotion t1
@@ -646,6 +650,8 @@ func RefreshJdLockStoreSku() (err error) {
 }
 
 func RefreshJdStoreSkuStock() (err error) {
+	globals.SugarLogger.Debug("RefreshJdStoreSkuStock")
+
 	sql := `
 	SELECT t4.store_id, t4.sku_id
 	FROM promotion t1
@@ -653,7 +659,7 @@ func RefreshJdStoreSkuStock() (err error) {
 	JOIN store_map t22 ON t2.store_id = t22.store_id AND t22.vendor_id = ? AND t22.deleted_at = ?
 	JOIN promotion_sku t3 ON t1.id = t3.promotion_id AND t3.is_lock = 1
 	JOIN store_sku_bind t4 ON t2.store_id = t4.store_id AND t3.sku_id = t4.sku_id AND t4.deleted_at = ?
-	WHERE t3.is_lock = 1 AND t1.deleted_at = ? AND t1.vendor_id = ? AND t1.status = ? AND (t1.beginAt <= ? AND t1.endAt >= ?)
+	WHERE t3.is_lock = 1 AND t1.deleted_at = ? AND t1.vendor_id = ? AND t1.status = ? AND (t1.begin_at <= ? AND t1.end_at >= ?)
 	GROUP BY 1,2
 	ORDER BY 1,2
 	`