| | |
| | | private UserResourcesClient userResourcesClient; |
| | | |
| | | |
| | | @Scheduled(cron = "0 0/1 * * * *") |
| | | @Scheduled(cron = "0/30 0 * * * *") |
| | | public void taskOrder() { |
| | | xpActicityService.updateStatus(); |
| | | //循环发放的活动 |
| | |
| | | .eq("status", 8).eq("is_deleted", 0)); |
| | | return R.ok(count); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 将订单推单状态还原重新推单 |
| | | * @param orderId |
| | | * @return |
| | | */ |
| | | @PostMapping("/logan/inner/order/againPushOrder") |
| | | public R<?> againPushOrder(@RequestParam("orderId") String orderId){ |
| | | XpOrder xpOrder = xpOrderService.getById(orderId); |
| | | String firstElement = redisService.getFirstElement(xpOrder.getQueueName()); |
| | | String[] split = firstElement.split("_"); |
| | | if (split[2].equals("1")) { |
| | | String value = split[0] + "_" + split[1] + "_0" + "_" + split[3] + "_" + split[4] + "_" + split[5] + "_" + split[6] + "_" + split[7]; |
| | | // 状态改为处理中 |
| | | redisService.updateFirst(xpOrder.getQueueName(), value); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | } |
| | |
| | | |
| | | XpPoint startPoint = getPointById(startPointId); |
| | | if (startPoint == null) { |
| | | log.warn("获取用户快捷胶囊失败,起点不存在,uid:{}, startPointId:{}", uid, startPointId); |
| | | log.info("获取用户快捷胶囊失败,起点不存在,uid:{}, startPointId:{}", uid, startPointId); |
| | | return null; |
| | | } |
| | | |
| | |
| | | private Integer getMinOrderDistanceSafely(String uid, Long startPointId) { |
| | | R<Integer> result = xpSystemSettingClient.getMinOrderDistance(); |
| | | if (result == null || result.getCode() != R.SUCCESS || result.getData() == null) { |
| | | log.error("获取用户快捷胶囊失败,最小下单距离配置异常,uid:{}, startPointId:{}, result:{}", uid, startPointId, JSON.toJSONString(result)); |
| | | log.info("获取用户快捷胶囊失败,最小下单距离配置异常,uid:{}, startPointId:{}, result:{}", uid, startPointId, JSON.toJSONString(result)); |
| | | return null; |
| | | } |
| | | return result.getData(); |