| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | LogHelper.test("---执行--updateQualityFactoryWeightJob--");
|
|---|
| | |
|
|---|
| | | qualityFactoryService.updateWeight(10, 3);
|
|---|
| | |
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | }
|
|---|
| | |
|---|
| | | // 添加精选库中需要更新的淘宝商品ID(2个小时执行一次)
|
|---|
| | | @Scheduled(cron = "0 0 1/2 * * ? ")
|
|---|
| | | public void addNeddUpdateTaoBaoGoods() {
|
|---|
| | | if (!Constant.IS_TASK) {
|
|---|
| | | if (!Constant.IS_TASK) |
|---|
| | | return;
|
|---|
| | | |
|---|
| | | List<Long> list = qualityFactoryService.queryNeedUpdate(0, 1000, 4);
|
|---|
| | | if (list == null || list.size() == 0) {
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | LogHelper.test("---addNeddUpdateTaoBaoGoods----execute ");
|
|---|
| | |
|
|---|
| | | List<Long> list = qualityFactoryService.queryNeedUpdate(0, 3000, 4);
|
|---|
| | | if (list != null) {
|
|---|
| | | for (Long id : list) {
|
|---|
| | | try {
|
|---|
| | | CMQManager.getInstance().addNeedUpdateTaoBaoGoodsId(id);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | for (Long id : list) {
|
|---|
| | | try {
|
|---|
| | | CMQManager.getInstance().addNeedUpdateTaoBaoGoodsId(id);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | while (true) {
|
|---|
| | | List<Long> list = qualityFlashSaleService.queryNeedRemove(0, 100, 6);
|
|---|
| | |
|
|---|
| | | List<Long> list = qualityFlashSaleService.queryNeedRemove(0, 200, 6);
|
|---|
| | | if (list == null || list.size() == 0) {
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
