火车票增加手动刷新订单信息接口

ruoyi-modules/ruoyi-server/src/main/java/org/dromara/server/controller/train/TrainController.java

@@ -6,6 +6,7 @@ import lombok.RequiredArgsConstructor;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.dromara.common.core.domain.R;
+import org.dromara.common.core.utils.StreamUtils;
 import org.dromara.common.mybatis.core.page.PageQuery;
 import org.dromara.common.mybatis.core.page.TableDataInfo;
 import org.dromara.common.redis.utils.RedisUtils;
@@ -21,6 +22,7 @@ import org.dromara.common.ys.service.ITrainService;
 import org.dromara.server.base.BaseController;
 import org.dromara.server.domain.bo.OrderTrainBo;
 import org.dromara.server.domain.vo.OrderTrainVo;
+import org.dromara.server.dubbo.RemoteOrderServiceImpl;
 import org.dromara.server.service.IOrderTrainService;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -233,5 +235,19 @@ public class TrainController extends BaseController {
         return R.ok(orderTrainService.queryPageList(bo, pageQuery));
     }
 
+    /**
+     * 手动刷新订单状态
+     *
+     * @return 是否成功
+     */
+    @PostMapping("/local/refresh")
+    public R<Boolean> refresh() throws InterruptedException {
+        List<OrderTrainVo> orderList = orderTrainService.queryList(new OrderTrainBo().setPersonCode(getUserId()));
+        List<String> orderStatusList = RemoteOrderServiceImpl.TRAIN_ORDER_STATUS_LIST;
+        List<String> orderNoList = StreamUtils.filter(orderList, o -> !orderStatusList.contains(o.getOrderStatus())).stream().map(OrderTrainVo::getOrderNo).collect(Collectors.toList());
+        orderTrainService.updateOrderInfo(orderNoList);
+        Thread.sleep(3000);
+        return R.ok(true);
+    }
 
 }

ruoyi-modules/ruoyi-server/src/main/java/org/dromara/server/domain/bo/OrderTrainBo.java

@@ -5,6 +5,7 @@ import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
 import org.dromara.common.core.validate.AddGroup;
 import org.dromara.common.core.validate.EditGroup;
 import org.dromara.common.mybatis.core.domain.BaseEntity;
@@ -20,6 +21,7 @@ import java.math.BigDecimal;
  */
 @Data
 @EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
 @AutoMapper(target = OrderTrain.class, reverseConvertGenerate = false)
 public class OrderTrainBo extends BaseEntity {
 

ruoyi-modules/ruoyi-server/src/main/java/org/dromara/server/dubbo/RemoteOrderServiceImpl.java

@@ -59,7 +59,7 @@ public class RemoteOrderServiceImpl implements RemoteOrderService {
     /**
      * 不需要更新的火车订单状态
      */
-    private static final List<String> TRAIN_ORDER_STATUS_LIST = Arrays.asList(
+    public static final List<String> TRAIN_ORDER_STATUS_LIST = Arrays.asList(
         org.dromara.common.ys.constant.train.OrderStatus.CANCEL_ORDER.getCode(),
         org.dromara.common.ys.constant.train.OrderStatus.CANCEL_SYSTEM.getCode(),
         org.dromara.common.ys.constant.train.OrderStatus.FINISHED.getCode(),