| | |
| | | if (!Constant.IS_TASK)
|
| | | return;
|
| | | long endTime = System.currentTimeMillis() - 1000 * 60;
|
| | | ;
|
| | | updateOrder(endTime - 1000 * 60 * 20L, endTime);
|
| | | }
|
| | |
|
| | |
| | | public void doJob2() {
|
| | | if (!Constant.IS_TASK)
|
| | | return;
|
| | | doTaoBaoWeiQuan();
|
| | |
|
| | | LogHelper.error("处理返利到账前置");
|
| | | try {
|
| | | |
| | | doTaoBaoWeiQuanOrder(2);
|
| | | } catch (Exception e) {
|
| | | LogHelper.errorDetailInfo(e);
|
| | | }
|
| | | LogHelper.error("开始处理返利");
|
| | | orderProcessService.fanli();
|
| | | }
|
| | |
|
| | |
| | | orderProcessService.fanliInvaiteAndShare();
|
| | | }
|
| | |
|
| | | // 维权订单处理-处理最近60天的
|
| | | // 30分钟一次
|
| | | @Scheduled(cron = "0 0/30 * * * ? ")
|
| | | public void doTaoBaoWeiQuan() {
|
| | | if (!Constant.IS_TASK)
|
| | | return;
|
| | | // 新版维权订单处理
|
| | | for (int i = 0; i < 60; i++) {
|
| | | private void doTaoBaoWeiQuanOrder(int day) {
|
| | |
|
| | | for (int i = 0; i < day; i++) {
|
| | | List<TaoBaoWeiQuanOrder> orderList = new ArrayList<>();
|
| | |
|
| | | // 按照维权发起时间查询
|
| | | WeiQuanOrderResult result = TaoKeOrderApiUtil
|
| | | .getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 1, false);
|
| | | "yyyy-MM-dd")), 1, 1, false);
|
| | | orderList.addAll(result.orderList);
|
| | | // 第三方
|
| | | result = TaoKeOrderApiUtil.getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 1, 1, true);
|
| | | orderList.addAll(result.orderList);
|
| | |
|
| | | result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 1, 1, false);
|
| | | orderList.addAll(result.orderList);
|
| | |
|
| | | // 第三方
|
| | | result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 1, 1, true);
|
| | | orderList.addAll(result.orderList);
|
| | |
|
| | | /**
|
| | | * 按照维权完成时间查询
|
| | | */
|
| | |
|
| | | result = TaoKeOrderApiUtil.getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 1, true);
|
| | | "yyyy-MM-dd")), 3, 1, false);
|
| | | orderList.addAll(result.orderList);
|
| | | // 第三方
|
| | | result = TaoKeOrderApiUtil.getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 3, 1, true);
|
| | | orderList.addAll(result.orderList);
|
| | |
|
| | | result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 1, false);
|
| | | "yyyy-MM-dd")), 3, 1, false);
|
| | | orderList.addAll(result.orderList);
|
| | |
|
| | | // 第三方
|
| | | result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp(
|
| | | TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"),
|
| | | "yyyy-MM-dd")), 1, true);
|
| | | "yyyy-MM-dd")), 3, 1, true);
|
| | | orderList.addAll(result.orderList);
|
| | |
|
| | | for (TaoBaoWeiQuanOrder order : orderList)
|
| | |
| | | // 处理维权订单
|
| | | orderProcessService.weiQuanOrder(orderList);
|
| | | }
|
| | |
|
| | | }
|
| | |
|
| | | // 维权订单处理-处理最近60天的
|
| | | // 30分钟一次
|
| | | @Scheduled(cron = "0 0/30 * * * ? ")
|
| | | public void doTaoBaoWeiQuan() {
|
| | | if (!Constant.IS_TASK)
|
| | | return;
|
| | | doTaoBaoWeiQuanOrder(5);
|
| | | }
|
| | |
|
| | | // 每6个小时执行一次
|