fanli-server.git

			@@ -15,6 +15,7 @@
			import com.yeshi.fanli.service.inter.jd.JDOrderService;
			import com.yeshi.fanli.util.Constant;
			import com.yeshi.fanli.util.RedisManager;
			import com.yeshi.fanli.util.TimeUtil;
			import com.yeshi.fanli.util.cmq.JDOrderCMQManager;
			import com.yeshi.fanli.util.jd.JDApiUtil;

			@@ -93,4 +94,61 @@
			saveJDOrders(jdOrderList);
			}

			/**
			* 更新一个小时的订单
			*
			* @param date
			*/
			private List<JDOrder> getHourOrder(Date date) {
			List<JDOrder> jdOrderList = new ArrayList<>();
			int pageSize = 200;
			int page = 1;
			JDOrderResult result = JDApiUtil.getOrderList(page++, pageSize, date, JDApiUtil.ORDER_TYPE_UPDATETIME);
			if (result != null) {
			jdOrderList.addAll(result.getOrderList());
			while (result != null && result.isHasMore()) {
			result = JDApiUtil.getOrderList(page++, pageSize,date, JDApiUtil.ORDER_TYPE_UPDATETIME);
			if (result != null)
			jdOrderList.addAll(result.getOrderList());
			}
			}
			return jdOrderList;
			}

			/**
			* 更新一天的数据
			*
			* @param date
			*/
			public void updateDayOrder(Date date) {
			Date now = new Date();
			List<JDOrder> orderList = new ArrayList<>();
			Date startTime = new Date(
			TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(date.getTime(), "yyyy-MM-dd"), "yyyy-MM-dd"));
			// 一个小时为一个步长
			for (int i = 0; i < 24; i++) {
			Date da = new Date(startTime.getTime() + 1000 * 60 * 60L * i);
			if (da.getTime() > now.getTime())
			return;
			List<JDOrder> tempOrderList = getHourOrder(da);
			if (tempOrderList != null && tempOrderList.size() > 0)
			orderList.addAll(tempOrderList);
			}
			saveJDOrders(orderList);
			}


			/**
			* 更新最近3天的订单（每天早上凌晨0点过10分，早上8点过10分）
			*/
			@Scheduled(cron = "0 10 0,8 * * ? ")
			public void updateLatest3DayOrder() {
			if (!Constant.IS_TASK)
			return;
			Date now = new Date();
			for (int i = 1; i < 4; i++) {
			updateDayOrder(new Date(now.getTime() - 1000 * 60 * 60 * 24L * i));
			}
			}

			}