|
@@ -5,6 +5,7 @@ import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
|
|
|
|
+import com.style24.batch.biz.job.delivery.TsbShopGoodsStockJob;
|
|
|
import com.style24.batch.biz.job.goods.TsbGoodsBenefitJob;
|
|
import com.style24.batch.biz.job.goods.TsbGoodsBenefitJob;
|
|
|
import com.style24.batch.biz.job.goods.TsbGoodsBenefitPriceJob;
|
|
import com.style24.batch.biz.job.goods.TsbGoodsBenefitPriceJob;
|
|
|
import com.style24.batch.biz.job.goods.TsbGoodsEpNaverGoods;
|
|
import com.style24.batch.biz.job.goods.TsbGoodsEpNaverGoods;
|
|
@@ -19,6 +20,7 @@ import com.style24.batch.biz.job.goods.TsbGoodsWmsGoodsJob;
|
|
|
import com.style24.batch.biz.job.goods.TsbGoodsWmsGoodsStockJob;
|
|
import com.style24.batch.biz.job.goods.TsbGoodsWmsGoodsStockJob;
|
|
|
import com.style24.batch.biz.job.goods.TsbGoodsWmsIncomelotJob;
|
|
import com.style24.batch.biz.job.goods.TsbGoodsWmsIncomelotJob;
|
|
|
import com.style24.batch.biz.job.goods.TsbGoodsWmsMeasurementJob;
|
|
import com.style24.batch.biz.job.goods.TsbGoodsWmsMeasurementJob;
|
|
|
|
|
+import com.style24.batch.biz.job.social.TsbSocialGoodsJob;
|
|
|
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
|
|
@@ -73,6 +75,12 @@ public class TsbGoodsTask {
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private TsbGoodsBenefitJob goodsBenefitJob;
|
|
private TsbGoodsBenefitJob goodsBenefitJob;
|
|
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private TsbShopGoodsStockJob tsbShopGoodsStockJob;
|
|
|
|
|
+
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private TsbSocialGoodsJob socialGoodsJob;
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 초 분 시 일 월 주(년)
|
|
* 초 분 시 일 월 주(년)
|
|
|
* 0 0 12 * * ?" : 아무 요일, 매월, 매일 12:00:00
|
|
* 0 0 12 * * ?" : 아무 요일, 매월, 매일 12:00:00
|
|
@@ -100,11 +108,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.titlename.reserve}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.reserve.titlename.apply}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsTnmJob() throws Exception {
|
|
|
|
|
- goodsTnmJob.runById("cron.goods.titlename.reserve");
|
|
|
|
|
|
|
+ public void reserveTitlenameApplyJob() throws Exception {
|
|
|
|
|
+ goodsTnmJob.runById("cron.goods.reserve.titlename.apply");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -112,11 +119,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.price.reserve}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.reserve.price.apply}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsPriceJob() throws Exception {
|
|
|
|
|
- goodsPriceJob.runById("cron.goods.price.reserve");
|
|
|
|
|
|
|
+ public void reservePriceApplyJob() throws Exception {
|
|
|
|
|
+ goodsPriceJob.runById("cron.goods.reserve.price.apply");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -124,11 +130,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.search.keyword}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.keyword.create}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsSnmJob() throws Exception {
|
|
|
|
|
- goodsSnmJob.runById("cron.goods.search.keyword");
|
|
|
|
|
|
|
+ public void keywordCreateJob() throws Exception {
|
|
|
|
|
+ goodsSnmJob.runById("cron.goods.keyword.create");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -138,11 +143,10 @@ public class TsbGoodsTask {
|
|
|
* @author eskim
|
|
* @author eskim
|
|
|
* @since 2020. 12. 02.
|
|
* @since 2020. 12. 02.
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.benefit.price}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.benefit.price.create}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsBenefitPriceJob() throws Exception {
|
|
|
|
|
- goodsBenefitPriceJob.runById("cron.goods.benefit.price");
|
|
|
|
|
|
|
+ public void benefitPriceCreateJob() throws Exception {
|
|
|
|
|
+ goodsBenefitPriceJob.runById("cron.goods.benefit.price.create");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -150,11 +154,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.relate.score}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.relgoods.scoring}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsRelateScoreJob() throws Exception {
|
|
|
|
|
- goodsRelateScoreJob.runById("cron.goods.relate.score");
|
|
|
|
|
|
|
+ public void relationGoodsScoringJob() throws Exception {
|
|
|
|
|
+ goodsRelateScoreJob.runById("cron.goods.relgoods.scoring");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -162,11 +165,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.summary}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.summary.create}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsSummaryJob() throws Exception {
|
|
|
|
|
- goodsSummaryJob.run("cron.goods.summary");
|
|
|
|
|
|
|
+ public void summaryCreateJob() throws Exception {
|
|
|
|
|
+ goodsSummaryJob.run("cron.goods.summary.create");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -186,11 +188,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.wms.measurement}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.wms.measurement.receive}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsWmsMeasurementJob() throws Exception {
|
|
|
|
|
- goodsWmsMeasurementJob.runById("cron.goods.wms.measurement");
|
|
|
|
|
|
|
+ public void wmsMeasurementReceiveJob() throws Exception {
|
|
|
|
|
+ goodsWmsMeasurementJob.runById("cron.goods.wms.measurement.receive");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -198,11 +199,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.wms.incomelot}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.wms.incomelot.receive}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsWmsIncomelotJob() throws Exception {
|
|
|
|
|
- goodsWmsIncomelotJob.runById("cron.goods.wms.incomelot");
|
|
|
|
|
|
|
+ public void wmsIncomelotReceiveJob() throws Exception {
|
|
|
|
|
+ goodsWmsIncomelotJob.runById("cron.goods.wms.incomelot.receive");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -210,11 +210,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.wms.brandprovider}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.wms.brandprovider.send}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsWmsBrandproviderJob() throws Exception {
|
|
|
|
|
- goodsWmsBrandproviderJob.runById("cron.goods.wms.brandprovider");
|
|
|
|
|
|
|
+ public void wmsBrandproviderSendJob() throws Exception {
|
|
|
|
|
+ goodsWmsBrandproviderJob.runById("cron.goods.wms.brandprovider.send");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -222,11 +221,10 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.wms.goods}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.wms.goods.send}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsWmsGoodsJob() throws Exception {
|
|
|
|
|
- goodsWmsGoodsJob.runById("cron.goods.wms.goods");
|
|
|
|
|
|
|
+ public void wmsGoodsSendJob() throws Exception {
|
|
|
|
|
+ goodsWmsGoodsJob.runById("cron.goods.wms.goods.send");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -234,33 +232,53 @@ public class TsbGoodsTask {
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.wms.goods.stock}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.wms.stock.receive}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsWmsGoodsStockJob() throws Exception {
|
|
|
|
|
- goodsWmsGoodsStockJob.runById("cron.goods.wms.goods.stock");
|
|
|
|
|
|
|
+ public void wmsStockReceiveJob() throws Exception {
|
|
|
|
|
+ goodsWmsGoodsStockJob.runById("cron.goods.wms.stock.receive");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
- * EP 네이버 상품 생성 주기 : 시간배치 - 01분
|
|
|
|
|
|
|
+ * 네이버EP 전체상품 생성 주기 : 시간배치 - 01분
|
|
|
*
|
|
*
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.ep.naver.goods}")
|
|
|
|
|
- //@Scheduled(fixedDelay = 3500000)
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.ep.naver.all.goods.create}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void tsbGoodsEpNaverGoods() throws Exception {
|
|
|
|
|
- goodsEpNaverGoods.runById("cron.goods.ep.naver.goods");
|
|
|
|
|
|
|
+ public void naverEpAllGoodsCreateJob() throws Exception {
|
|
|
|
|
+ goodsEpNaverGoods.runById("cron.goods.ep.naver.all.goods.create");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 상품혜택(쿠폰할인, 무료배송, 사은품, 신상) 생성
|
|
* 상품혜택(쿠폰할인, 무료배송, 사은품, 신상) 생성
|
|
|
* @throws Exception
|
|
* @throws Exception
|
|
|
*/
|
|
*/
|
|
|
- @Scheduled(cron = "${cron.goods.benefit}")
|
|
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.benefit.create}")
|
|
|
|
|
+ @Async
|
|
|
|
|
+ public void benefitCreateJob() throws Exception {
|
|
|
|
|
+ goodsBenefitJob.runById("cron.goods.benefit.create");
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 매장상품재고 수신
|
|
|
|
|
+ *
|
|
|
|
|
+ * @throws Exception
|
|
|
|
|
+ */
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.shop.stock.receive}")
|
|
|
|
|
+ @Async
|
|
|
|
|
+ public void shopGoodsStockReceiveJob() throws Exception {
|
|
|
|
|
+ tsbShopGoodsStockJob.run("cron.goods.shop.stock.receive");
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 소셜 상품 적용 : 시간배치 - 매시 00분
|
|
|
|
|
+ *
|
|
|
|
|
+ * @throws Exception
|
|
|
|
|
+ */
|
|
|
|
|
+ @Scheduled(cron = "${cron.goods.social.price.apply}")
|
|
|
@Async
|
|
@Async
|
|
|
- public void createGoodsBenefit() throws Exception {
|
|
|
|
|
- goodsBenefitJob.runById("cron.goods.benefit");
|
|
|
|
|
|
|
+ public void socialPriceApplyJob() throws Exception {
|
|
|
|
|
+ socialGoodsJob.runById("cron.goods.social.price.apply");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|