From e782b2bcfd89f7ce2e3079c7ebb0867bb00124a7 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期一, 01 四月 2019 18:54:27 +0800 Subject: [PATCH] 爬单修改 --- fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java | 39 ++++++++++++++++++++++----------------- 1 files changed, 22 insertions(+), 17 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java index ad6d5b0..99b781d 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java @@ -10,20 +10,18 @@ import org.springframework.scheduling.annotation.Scheduled; +import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper; import com.yeshi.fanli.entity.bus.user.Order; import com.yeshi.fanli.entity.taobao.TaoBaoOrder; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.common.DataMonitorService; -import com.yeshi.fanli.service.inter.hongbao.HongBaoService; -import com.yeshi.fanli.service.inter.hongbao.ThreeSaleGiftService; import com.yeshi.fanli.service.inter.order.LostOrderService; -import com.yeshi.fanli.service.inter.order.OrderItemServcie; import com.yeshi.fanli.service.inter.order.OrderProcessService; import com.yeshi.fanli.service.inter.order.OrderService; -import com.yeshi.fanli.service.inter.order.PidOrderService; import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService; import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService; import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService; +import com.yeshi.fanli.util.BeanUtil; import com.yeshi.fanli.util.CMQManager; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.RedisManager; @@ -39,18 +37,6 @@ public UpdateCommonOrderJob() { System.out.println("鍒濆鍖�:UpdateOrderJob"); } - - @Resource - private OrderItemServcie orderItemServcie; - - @Resource - private ThreeSaleGiftService threeSaleGiftService; - - @Resource - private HongBaoService hongBaoService; - - @Resource - private PidOrderService pidOrderService; @Resource private OrderProcessService orderProcessService; @@ -78,6 +64,9 @@ @Resource private OrderService orderService; + + @Resource + private TaoBaoOrderMapper taoBaoOrderMapper; /** * 鏂扮増鑾峰彇鏅�氳鍗� @@ -209,7 +198,7 @@ - (1000 * 60 * 60 * 24L * (90 - pos)); long endTime = startTime + 1000 * 60 * 60 * 24L; LogHelper.orderInfo("姝e湪鎵ц璁㈠崟鐖彇..."); -// updateOrder(startTime, endTime); + // updateOrder(startTime, endTime); } // 娣樺疂鎺ㄥ箍璁㈠崟 姣忛殧30绉掓墽琛屼竴娆� @@ -223,4 +212,20 @@ addOrderNew(orderList); } + // 姣忔櫄10鐐规墽琛屾紡鍗� + @Scheduled(cron = "0 0 22 * * ? ") + public void doJob3() { + List<TaoBaoOrder> orderList = taoBaoOrderMapper.listLongTimeNoUpdateOrders(0, 10); + List<TaoBaoOrder> updateOrderList = new ArrayList<>(); + for (TaoBaoOrder order : orderList) { + List<TaoBaoOrder> newList = TaoKeOrderApiUtil.getTaoBaoAllOrder(order.getCreateTime(), 60, 1, + Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET); + for (TaoBaoOrder o : newList) { + if (o.getOrderId().equalsIgnoreCase(order.getOrderId())) + updateOrderList.add(o); + } + } + addOrderNew(updateOrderList); + } + } -- Gitblit v1.8.0