| | |
|---|
| | | return orderList;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | private void addOrder(List<TaoBaoOrder> orderList) {
|
|---|
| | | public void addOrder(List<TaoBaoOrder> orderList) {
|
|---|
| | |
|
|---|
| | | if (orderList != null)
|
|---|
| | | for (int i = 0; i < orderList.size(); i++) {
|
|---|
| | |
|---|
| | | try {
|
|---|
| | | taoBaoOrderService.addTaoBaoOrderList(orderList);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | try {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | } catch (Exception e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | try {
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | } catch (Exception e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | public void addLostOrder() {
|
|---|
| | | if (!Constant.IS_TASK)
|
|---|
| | | return;
|
|---|
| | | LogHelper.test("处理丢失订单");
|
|---|
| | | List<LostOrder> list = lostOrderService.listByStateAndResultCode(LostOrder.STATE_PASS,
|
|---|
| | | LostOrder.RESULT_CODE_VERFING, 1, 50);
|
|---|
| | | if (list != null)
|
|---|
| | |
|---|
| | | List<TaoBaoOrder> taoBaoOrderList = taoBaoOrderService.getTaoBaoOrderByOrderId(lo.getOrderId());
|
|---|
| | | // 清除频率限制
|
|---|
| | | if (taoBaoOrderList != null && taoBaoOrderList.size() > 0) {
|
|---|
| | | String key = "addorder-" + lo.getOrderId();
|
|---|
| | | String key = "addorderqueue-" + lo.getOrderId();
|
|---|
| | | redisManager.removeCommonString(key);
|
|---|
| | | addOrder(taoBaoOrderList);
|
|---|
| | | LogHelper.test("自动处理淘宝订单:" + lo.getOrderId());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 处理淘宝结算订单,每小时执行一次
|
|---|
| | | * 处理淘宝结算订单,30fen执行一次
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "30 0 0/1 * * ? ")
|
|---|
| | | public void doSettleOrders() {
|
|---|
| | |
|---|
| | | addOrder(orderList);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 13分钟更新最近13分钟的结算数据
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0 0/13 * * * ? ")
|
|---|
| | | public void doSettleOrdersToday() {
|
|---|
| | | if (!Constant.IS_TASK)
|
|---|
| | | return;
|
|---|
| | | // 处理3-15天前的订单，每天跑一次
|
|---|
| | | Calendar ca = Calendar.getInstance();
|
|---|
| | | long startTime = ca.getTimeInMillis() - 1000 * 60 * 5L - 1000 * 60 * 13L;
|
|---|
| | | long endTime = startTime + 1000 * 60 * 13L;
|
|---|
| | | List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, false);
|
|---|
| | | List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoSettleOrders(startTime, endTime, true);
|
|---|
| | | if (tempOrderList != null && tempOrderList.size() > 0)
|
|---|
| | | orderList.addAll(tempOrderList);
|
|---|
| | | addOrder(orderList);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
