diff --git a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClient.java b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClient.java index a879a1ea..b257dc98 100644 --- a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClient.java +++ b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClient.java @@ -25,6 +25,7 @@ public interface IErpDataProduceClient { String API_PREFIX = "/feign/erpdata/produce"; String QUERY_BATCH = API_PREFIX + "/queryBatch"; String REWORK_ORDER = API_PREFIX + "/loadReworkOrder"; + String REWORK_ORDER_SIZE = API_PREFIX + "/loadReworkOrderSize"; String PRODUCT_APP_AREA = API_PREFIX + "/productAppArea"; String VERSION = API_PREFIX + "/version"; String CUSTODIAN = API_PREFIX + "/getCustodian"; @@ -43,8 +44,17 @@ public interface IErpDataProduceClient { @GetMapping(REWORK_ORDER) R> loadReworkOrder(@RequestParam(value = "reworkCode", required = false) String reworkCode, @RequestParam(value = "partCode", required = false) String partCode, - @RequestParam(value = "batchNo", required = false) String batchNo); + @RequestParam(value = "batchNo", required = false) String batchNo, + @RequestParam(value = "current") Integer current, + @RequestParam(value = "size") Integer size); + /** + * 返工订单数量 + */ + @GetMapping(REWORK_ORDER_SIZE) + R loadReworkOrderSize(@RequestParam(value = "reworkCode", required = false) String reworkCode, + @RequestParam(value = "partCode", required = false) String partCode, + @RequestParam(value = "batchNo", required = false) String batchNo); /** * 获取产品区域 */ diff --git a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClientFallback.java b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClientFallback.java index 8a31e2f5..5c6a8960 100644 --- a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClientFallback.java +++ b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataProduceClientFallback.java @@ -1,5 +1,6 @@ package org.springblade.erpdata.feign; +import com.baomidou.mybatisplus.core.metadata.IPage; import org.springblade.core.tool.api.R; import org.springblade.erpdata.pojo.vo.QueryBatchVO; import org.springblade.erpdata.pojo.vo.ReworkProcessVO; @@ -23,7 +24,12 @@ public class IErpDataProduceClientFallback implements IErpDataProduceClient { } @Override - public R> loadReworkOrder(String reworkCode, String partCode, String batchNo) { + public R> loadReworkOrder(String reworkCode, String partCode, String batchNo, Integer current, Integer size) { + return R.fail("获取数据失败"); + } + + @Override + public R loadReworkOrderSize(String reworkCode, String partCode, String batchNo) { return R.fail("获取数据失败"); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/controller/ReworkProcessController.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/controller/ReworkProcessController.java index c0d65b55..88b3fda0 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/controller/ReworkProcessController.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/controller/ReworkProcessController.java @@ -71,12 +71,12 @@ public class ReworkProcessController extends BladeController { // records.add(reworkProcessVO); // page.setRecords(records); // return R.data(page); - IPage page = Condition.getPage(query); - String reworkCode = prReworkProcess.getReworkCode(); - String partCode = prReworkProcess.getPartCode(); - String batchNo = prReworkProcess.getBatchNo(); - R> listR = erpDataProduceClient.loadReworkOrder(reworkCode, partCode, batchNo); - return R.data(page.setRecords(listR.getData())); + IPage iPage = Condition.getPage(query); + List process = erpDataProduceClient.loadReworkOrder(prReworkProcess.getReworkCode(), prReworkProcess.getPartCode(), prReworkProcess.getBatchNo(), query.getCurrent(), query.getSize()).getData(); + iPage.setRecords(process); + int size = erpDataProduceClient.loadReworkOrderSize(prReworkProcess.getReworkCode(), prReworkProcess.getPartCode(), prReworkProcess.getBatchNo()).getData(); + iPage.setTotal(size); + return R.data(iPage); } // @GetMapping("/treeProcess") diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/MakeRecServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/MakeRecServiceImpl.java index 83178c25..56d5c9e1 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/MakeRecServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/MakeRecServiceImpl.java @@ -303,7 +303,9 @@ public class MakeRecServiceImpl extends BaseServiceImpl List ppsIds = new ArrayList<>(); List makeTeams = new ArrayList<>(); for (MesMakeRecVO record : records) { - ppsIds.add(record.getPpsId()); + if (record.getPpsId() != null) { + ppsIds.add(record.getPpsId()); + } if (record.getFrontPpsId() != null) { ppsIds.add(record.getFrontPpsId()); } diff --git a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/feign/ErpDataProduceClient.java b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/feign/ErpDataProduceClient.java index 7ca5c7fa..89b1b28d 100644 --- a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/feign/ErpDataProduceClient.java +++ b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/feign/ErpDataProduceClient.java @@ -1,5 +1,6 @@ package org.springblade.erpdata.feign; +import com.baomidou.mybatisplus.core.metadata.IPage; import io.swagger.v3.oas.annotations.Hidden; import lombok.AllArgsConstructor; import org.springblade.core.tenant.annotation.NonDS; @@ -35,8 +36,13 @@ public class ErpDataProduceClient implements IErpDataProduceClient { @Override @GetMapping(REWORK_ORDER) - public R> loadReworkOrder(String reworkCode, String partCode, String batchNo) { - return R.data(erpDataProduceService.loadReworkOrder(reworkCode, partCode, batchNo)); + public R> loadReworkOrder(String reworkCode, String partCode, String batchNo, Integer current, Integer size) { + return R.data(erpDataProduceService.loadReworkOrder(reworkCode, partCode, batchNo, current, size)); + } + + @Override + public R loadReworkOrderSize(String reworkCode, String partCode, String batchNo) { + return R.data(erpDataProduceService.loadReworkOrderSize(reworkCode, partCode, batchNo)); } @Override diff --git a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.java b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.java index 1ad9e5c6..fb028b90 100644 --- a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.java +++ b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.java @@ -18,11 +18,13 @@ public interface ErpDataProduceMapper extends Mapper { QueryBatchVO queryBatch(String partCode); - List loadReworkOrder(String reworkCode, String partCode, String batchNo); + List loadReworkOrder(String reworkCode, String partCode, String batchNo, Integer current, Integer size); Map getProductAppareaByPartCode(String partCode); String getVersionByPartCode(String partCode); String getCustodianByRecDept(String partCode, String recDept); + + int loadReworkOrderSize(String reworkCode, String partCode, String batchNo); } diff --git a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.xml b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.xml index baddd120..3239c6e1 100644 --- a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.xml +++ b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataProduceMapper.xml @@ -39,6 +39,10 @@ a.prtno = #{partCode} + diff --git a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/IErpDataProduceService.java b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/IErpDataProduceService.java index 47107ed7..2c2b494c 100644 --- a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/IErpDataProduceService.java +++ b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/IErpDataProduceService.java @@ -18,7 +18,7 @@ public interface IErpDataProduceService { QueryBatchVO queryBatch(String partCode); - List loadReworkOrder(String reworkCode, String partCode, String batchNo); + List loadReworkOrder(String reworkCode, String partCode, String batchNo, Integer current, Integer size); Map getProductAppareaByPartCode(String partCode); @@ -29,4 +29,6 @@ public interface IErpDataProduceService { String chkSjjd(String ypCode, String batchNo); String chkShjh(String woCode, String ypCode, String partCode, String productIdent, Double makeQty, String memo); + + Integer loadReworkOrderSize(String reworkCode, String partCode, String batchNo); } diff --git a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/impl/ErpDataProduceServiceImpl.java b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/impl/ErpDataProduceServiceImpl.java index d8df8036..36a39a92 100644 --- a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/impl/ErpDataProduceServiceImpl.java +++ b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/service/impl/ErpDataProduceServiceImpl.java @@ -3,6 +3,8 @@ package org.springblade.erpdata.service.impl; import com.baomidou.mybatisplus.core.metadata.IPage; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springblade.core.mp.support.Condition; +import org.springblade.core.mp.support.Query; import org.springblade.erpdata.mapper.ErpDataProduceMapper; import org.springblade.erpdata.pojo.dto.ReworkProcessDTO; import org.springblade.erpdata.pojo.vo.QueryBatchVO; @@ -15,6 +17,7 @@ import org.springframework.jdbc.core.simple.SimpleJdbcCall; import org.springframework.stereotype.Service; import java.sql.Types; +import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -38,8 +41,8 @@ public class ErpDataProduceServiceImpl implements IErpDataProduceService { } @Override - public List loadReworkOrder(String reworkCode, String partCode, String batchNo) { - return erpDataProduceMapper.loadReworkOrder(reworkCode, partCode, batchNo); + public List loadReworkOrder(String reworkCode, String partCode, String batchNo, Integer current, Integer size) { + return erpDataProduceMapper.loadReworkOrder(reworkCode, partCode, batchNo, current, size); } @Override @@ -128,4 +131,9 @@ public class ErpDataProduceServiceImpl implements IErpDataProduceService { return excflag; } + + @Override + public Integer loadReworkOrderSize(String reworkCode, String partCode, String batchNo) { + return erpDataProduceMapper.loadReworkOrderSize(reworkCode, partCode, batchNo); + } }