ai调用的业务接口

sckw-modules-api/sckw-order-api/src/main/java/com/sckw/order/api/model/TradeOrderPara.java

@@ -23,4 +23,5 @@ public class TradeOrderPara implements Serializable {
     private LocalDateTime endTime;
 
     private List<Long> entId;
+    private Long userId;
 }

sckw-modules/sckw-order/src/main/java/com/sckw/order/controller/KwoTradeOrderController.java

@@ -1,11 +1,14 @@
 package com.sckw.order.controller;
 
+import cn.hutool.core.date.LocalDateTimeUtil;
 import com.sckw.core.annotation.RepeatSubmit;
 import com.sckw.core.exception.CustomPromptException;
 import com.sckw.core.utils.CollectionUtils;
 import com.sckw.core.web.constant.HttpStatus;
 import com.sckw.core.web.response.HttpResult;
 import com.sckw.excel.utils.ExcelUtil;
+import com.sckw.order.api.model.TradeOrderPara;
+import com.sckw.order.enums.OrderPara;
 import com.sckw.order.model.vo.req.*;
 import com.sckw.order.serivce.KwoTradeOrderService;
 import io.seata.spring.annotation.GlobalTransactional;
@@ -13,6 +16,7 @@ import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.servlet.http.HttpServletResponse;
 import lombok.RequiredArgsConstructor;
+import org.springdoc.core.annotations.ParameterObject;
 import org.springframework.http.MediaType;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -32,7 +36,7 @@ public class KwoTradeOrderController {
 
     private final KwoTradeOrderService kwoTradeOrderService;
 
-//    /**
+    //    /**
 //     * @desc: 采购下单草稿
 //     * @author: yzc
 //     * @date: 2023-07-07 15:29
@@ -46,6 +50,15 @@ public class KwoTradeOrderController {
 //        kwoTradeOrderService.addPurchaseOrderDraft(param);
 //        return HttpResult.ok("采购下单草稿保存成功");
 //    }
+    @RequestMapping(value = "/trade", method = RequestMethod.GET)
+    @Operation(summary = "查询贸易订单", description = "查询贸易订单")
+    public HttpResult selectAll(@ParameterObject OrderPara orderPara) {
+        TradeOrderPara tradeOrderPara = new TradeOrderPara();
+        tradeOrderPara.setStartTime(LocalDateTimeUtil.parse(orderPara.getStartTime(), "yyyy-MM-dd HH:mm:ss"));
+        tradeOrderPara.setEndTime(LocalDateTimeUtil.parse(orderPara.getEndTime(), "yyyy-MM-dd HH:mm:ss"));
+        orderPara.setUserId(orderPara.getUserId());
+        return HttpResult.ok("查询成功", kwoTradeOrderService.queryOrder(tradeOrderPara));
+    }
 
     /**
      * @desc: 采购下单提交

sckw-modules/sckw-order/src/main/java/com/sckw/order/enums/OrderPara.java

@@ -0,0 +1,21 @@
+package com.sckw.order.enums;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @author xucaiqin
+ * @date 2025-12-02 19:41:55
+ */
+@Getter
+@Setter
+@Schema(description = "贸易订单查询参数")
+public class OrderPara {
+    @Schema(description = "开始时间")
+    private String startTime;
+    @Schema(description = "结束时间")
+    private String endTime;
+    @Schema(description = "用户id")
+    private Long userId;
+}

sckw-modules/sckw-order/src/main/java/com/sckw/order/serivce/KwoTradeOrderService.java

@@ -65,6 +65,7 @@ import com.sckw.stream.model.SckwBusSum;
 import com.sckw.stream.model.SckwMessage;
 import com.sckw.stream.model.UserInfo;
 import com.sckw.system.api.RemoteSystemService;
+import com.sckw.system.api.RemoteUserService;
 import com.sckw.system.api.model.dto.res.*;
 import com.sckw.transport.api.dubbo.TransportRemoteService;
 import com.sckw.transport.api.model.param.AddLogisticOrderParam;
@@ -99,6 +100,8 @@ public class KwoTradeOrderService {
 
     @DubboReference(version = "1.0.0", group = "design", check = false)
     private RemoteSystemService remoteSystemService;
+    @DubboReference(version = "1.0.0", group = "design", check = false)
+    private RemoteUserService remoteUserService;
 
     @DubboReference(version = "1.0.0", group = "design", check = false)
     private RemoteManageService remoteManageService;
@@ -2327,6 +2330,13 @@ public class KwoTradeOrderService {
     }
 
     public List<TradeOrderVo> queryOrder(TradeOrderPara tradeOrderPara) {
+        UserResDto userResDto = remoteSystemService.queryUserById(tradeOrderPara.getUserId());
+        if (Objects.nonNull(userResDto)) {
+            Integer systemType = userResDto.getSystemType();
+            if (!Objects.equals(systemType, SystemTypeEnum.MANAGE.getCode())) {
+                tradeOrderPara.setEntId(remoteUserService.findChildEntList(userResDto.getEntId()));
+            }
+        }
         List<TradeOrderVo> tradeOrderVos = kwoTradeOrderMapper.selectData(tradeOrderPara);
         if (CollUtil.isNotEmpty(tradeOrderVos)) {
             Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(List.of(DictTypeEnum.PRODUCT_NAME_TYPE.getType(), DictTypeEnum.UNIT_TYPE.getType(), DictTypeEnum.CHARGING_TYPE.getType()));