创建

robot-system/src/main/java/com/system/api/KingDeeApi.java

@@ -129,10 +129,10 @@ public class KingDeeApi {
     /**
      * 查询单据体
      */
-    public List<List<Object>> getKingDeeData(Map<String, String> config, String queueId, Map<String, String> key, Map<String, String> where, Integer pageNo, Integer pageSize) {
+    public List<List<Object>> getKingDeeData(Map<String, String> config, String queueId, Map<String, String> key, Map<String, String> where) {
         try {
             if (this.flag) {
-                String request = "{\"FormId\":\"" + config.get("sFormId") + "\"," + stringKey(key) + stringWhere(where) + ",\"StartRow\": " + (pageNo - 1) + ",\"Limit\": " + pageSize + "}";
+                String request = "{\"FormId\":\"" + config.get("sFormId") + "\"," + stringKey(key) + stringWhere(where) + "}";
                 System.out.println("================content==============" + request + "=================content===================");
                 List<List<Object>> response = kingDeeK3CloudApi.executeBillQuery(request);
                 //记录查询金蝶云数据的请求及响应信息

robot-system/src/main/java/com/system/kingdee/KingDeeCommonGetApi.java

@@ -23,9 +23,9 @@ public class KingDeeCommonGetApi {
     private KingDeeApi kingDeeApi;
 
 
-    public List<Map<String, Object>> getKingDeeData(Map<String, String> config, String queueId, List<Map<String, String>> fieldList, Map<String, String> where, Integer pageNo, Integer pageSize) {
+    public List<Map<String, Object>> getKingDeeData(Map<String, String> config, String queueId, List<Map<String, String>> fieldList, Map<String, String> where) {
         Map<String, String> key = KingDeeCommonSyncConstants.encapsulationKingDeeField(fieldList);
-        List<List<Object>> result = kingDeeApi.getKingDeeData(config, queueId, key, where, pageNo, pageSize);
+        List<List<Object>> result = kingDeeApi.getKingDeeData(config, queueId, key, where);
         return encapsulationIms(result, fieldList, config.get("mesEntryName"), Integer.valueOf(config.get("encapsulationFormat")));
     }
 

robot-system/src/main/java/com/system/serivce/impl/KingDeeCommonGetServiceImpl.java

@@ -5,6 +5,7 @@ import com.system.kingdee.KingDeeCommonGetApi;
 import com.system.serivce.IKingDeeCommonGetService;
 import com.system.transfer.kingdee.KingDeeDataListInVo;
 import com.system.transfer.response.RestResponse;
+import com.system.transfer.temp.KingDeeCommonGetListOutVo;
 import com.system.utils.JsonUtil;
 import com.system.utils.ProductLogUtil;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -54,7 +55,7 @@ public class KingDeeCommonGetServiceImpl implements IKingDeeCommonGetService {
             }
         }
 
-        List<Map<String, Object>> response = kingDeeCommonGetApi.getKingDeeData(config, queueId, fieldList, where, inVo.getPageNo(), inVo.getPageSize());
+        List<Map<String, Object>> response = kingDeeCommonGetApi.getKingDeeData(config, queueId, fieldList, where);
         long costTime = System.currentTimeMillis() - start;
         if (!CollectionUtils.isEmpty(response)) {
             String temp = "false";
@@ -64,7 +65,11 @@ public class KingDeeCommonGetServiceImpl implements IKingDeeCommonGetService {
             }
         }
         productLogUtil.productLogUpdate(id, JsonUtil.toString(response), "", Integer.valueOf(String.valueOf(costTime)));
-        return RestResponse.success(response);
+
+        KingDeeCommonGetListOutVo outVo = new KingDeeCommonGetListOutVo();
+        outVo.setTotal(response.size());
+        outVo.setRecords(response.stream().skip((inVo.getPageNo() - 1) * inVo.getPageSize()).limit(inVo.getPageSize()).collect(Collectors.toList()));
+        return RestResponse.success(outVo);
     }
 
 

robot-system/src/main/java/com/system/transfer/temp/KingDeeCommonGetListOutVo.java

+package com.system.transfer.temp;
+
+import lombok.Data;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author Inori
+ */
+@Data
+public class KingDeeCommonGetListOutVo {
+
+    /**
+     * 总数
+     */
+    private Integer total;
+
+
+    /**
+     * 记录
+     */
+    private List<Map<String, Object>> records;
+
+
+}