From ed2b233ddf7256612722f7f652b2606e6da93a98 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E4=B9=BE=E7=BF=94?= Date: Mon, 25 May 2026 17:57:08 +0800 Subject: [PATCH 1/8] =?UTF-8?q?=E5=88=86=E6=B4=BE=E6=8E=A7=E5=88=B6?= =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/PlanAssignSteerModifyServiceImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/PlanAssignSteerModifyServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/PlanAssignSteerModifyServiceImpl.java index 579527f26..7e5afddda 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/PlanAssignSteerModifyServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/PlanAssignSteerModifyServiceImpl.java @@ -171,7 +171,7 @@ public class PlanAssignSteerModifyServiceImpl extends BaseServiceImpl Date: Mon, 25 May 2026 18:13:52 +0800 Subject: [PATCH 2/8] =?UTF-8?q?=E5=B7=A5=E5=BA=8F=E6=8E=A5=E6=94=B6?= =?UTF-8?q?=E8=80=90=E8=9A=80=E6=80=A7=E6=A3=80=E6=B5=8B=E9=A1=B9=E7=9B=AE?= =?UTF-8?q?=E7=94=9F=E6=88=90=E6=A0=A1=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../desk/produce/service/impl/PlateAroundServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/PlateAroundServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/PlateAroundServiceImpl.java index 45d4da6f7..4a0b1980b 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/PlateAroundServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/PlateAroundServiceImpl.java @@ -107,7 +107,7 @@ public class PlateAroundServiceImpl extends BaseServiceImpl tsIds = getTsIds(); BeforePlatInVO beforePlatOutCardNo = baseMapper.getBeforePlatOutCardNo(wo.getId(), tsIds, AuthUtil.getUserId()); if (beforePlatOutCardNo == null) { - throw new ServiceException("未找到镀前入库记录，无法出库!"); + throw new ServiceException("未找到镀前入库记录，请上序班组镀前入库!"); } long count = this.count(Wrappers.lambdaQuery(PlateAround.class).eq(PlateAround::getWpId, beforePlatOutCardNo.getWpId()).eq(PlateAround::getPaType, PlateAround.BEFORE_PLAN_OUT)); if (count > 0) { From 4a717cbc6d776a2910a48e804f1b857873643f53 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E6=B6=9B?= Date: Mon, 25 May 2026 20:05:35 +0800 Subject: [PATCH 3/8] =?UTF-8?q?=E5=B7=A5=E5=BA=8F=E6=8E=A5=E6=94=B6?= =?UTF-8?q?=E8=80=90=E8=9A=80=E6=80=A7=E6=A3=80=E6=B5=8B=E9=A1=B9=E7=9B=AE?= =?UTF-8?q?=E7=94=9F=E6=88=90=E6=A0=A1=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../desk/produce/feign/IDisTaskingClient.java | 8 ++++++++ .../desk/produce/feign/DisTaskingClient.java | 10 ++++++++++ .../desk/produce/service/IWorkOrderService.java | 2 +- .../produce/service/impl/WorkOrderServiceImpl.java | 6 +++++- 4 files changed, 24 insertions(+), 2 deletions(-) diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java index ccc10cca3..7e479377f 100644 --- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java +++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java @@ -3,6 +3,7 @@ package org.springblade.desk.produce.feign; import org.springblade.core.launch.constant.AppConstant; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestParam; /** * 调度任务同步接口 @@ -20,6 +21,7 @@ public interface IDisTaskingClient { String RECEIVE_ORDER = API_PREFIX + "/receiveOrder"; String RB_TRANSFER_ORDER = API_PREFIX + "/rbTransferOrder"; String UN_BIND_EC = API_PREFIX + "/unBindEc"; + String SAVE_WORK_ORDER_RUN = API_PREFIX + "/saveWorkOrderRun"; /** @@ -43,4 +45,10 @@ public interface IDisTaskingClient { @GetMapping(UN_BIND_EC) boolean unBindEc(); + + /** + * 保存生产运行记录 + */ + @GetMapping(SAVE_WORK_ORDER_RUN) + boolean saveWorkOrderRun(@RequestParam String woId); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java index 1e5838a27..7e204021e 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java @@ -6,6 +6,7 @@ import org.springblade.core.tenant.annotation.NonDS; import org.springblade.desk.produce.service.IDisTaskingService; import org.springblade.desk.produce.service.IHandoverRecordService; import org.springblade.desk.produce.service.IPdaSaveService; +import org.springblade.desk.produce.service.IWorkOrderService; import org.springframework.web.bind.annotation.RestController; /** @@ -25,6 +26,8 @@ public class DisTaskingClient implements IDisTaskingClient { private final IHandoverRecordService handoverRecordService; + private final IWorkOrderService workOrderService; + @Override public boolean syncDisTasking() { return disTaskingService.syncDisTasking(false); @@ -44,4 +47,11 @@ public class DisTaskingClient implements IDisTaskingClient { public boolean unBindEc() { return pdaSaveServiceImpl.unBindEc(); } + + @Override + public boolean saveWorkOrderRun(String woId) { + workOrderService.addPrWorkOrderRun(woId); + return true; + } + } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/IWorkOrderService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/IWorkOrderService.java index cef1c2a7a..897d4449c 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/IWorkOrderService.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/IWorkOrderService.java @@ -295,5 +295,5 @@ public interface IWorkOrderService extends BaseService { /** * 生产运行记录 */ - void addPrWorkOrderRun(WorkOrder workOrder); + void addPrWorkOrderRun(String woId); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderServiceImpl.java index 14c084140..886d4758c 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderServiceImpl.java @@ -2910,7 +2910,11 @@ public class WorkOrderServiceImpl extends BaseServiceImpl Date: Tue, 26 May 2026 09:28:30 +0800 Subject: [PATCH 4/8] =?UTF-8?q?=E6=80=A5=E4=BB=B6=E7=BB=B4=E6=8A=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../desk/basic/service/impl/UrgentPartServiceImpl.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java index 59942ceb7..41a5c22c1 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java @@ -169,7 +169,7 @@ public class UrgentPartServiceImpl extends BaseServiceImpl Date: Tue, 26 May 2026 09:40:22 +0800 Subject: [PATCH 5/8] =?UTF-8?q?=E5=A4=96=E5=8D=8F=E7=BB=93=E7=AE=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../desk/oem/pojo/request/PriceSheetQuery.java | 4 ++++ .../erpdata/feign/IErpDataOemClient.java | 4 ++-- .../feign/IErpDataOemClientFallback.java | 2 +- .../desk/oem/controller/OemOrderController.java | 6 ++++-- .../service/impl/OemStatementServiceImpl.java | 17 ++++++++++------- .../erpdata/feign/ErpDataOemClientImpl.java | 3 ++- .../erpdata/mapper/ErpDataOemMapper.xml | 4 ++-- 7 files changed, 25 insertions(+), 15 deletions(-) diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/oem/pojo/request/PriceSheetQuery.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/oem/pojo/request/PriceSheetQuery.java index 11dbdc731..bbd8ce6ed 100644 --- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/oem/pojo/request/PriceSheetQuery.java +++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/oem/pojo/request/PriceSheetQuery.java @@ -2,6 +2,7 @@ package org.springblade.desk.oem.pojo.request; import io.swagger.v3.oas.annotations.media.Schema; import lombok.Data; +import org.springblade.core.mp.support.Query; import org.springframework.format.annotation.DateTimeFormat; import java.time.LocalDate; @@ -69,4 +70,7 @@ public class PriceSheetQuery { @Schema(description = "价格类型") private String pricetype; + + @Schema(description = "查询条件") + private Query query; } diff --git a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClient.java b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClient.java index 0c48a5ad8..7fe7606cc 100644 --- a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClient.java +++ b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClient.java @@ -44,10 +44,10 @@ public interface IErpDataOemClient { /** * 报价单查询 * - * @param query + * @param priceSheetQuery */ @GetMapping(PRICE_SHEET_DATA) - R> priceSheetData(@SpringQueryMap PriceSheetQuery priceSheetQuery, @SpringQueryMap Query query); + R> priceSheetData(@SpringQueryMap PriceSheetQuery priceSheetQuery); /** * 协作外协订单接收 diff --git a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClientFallback.java b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClientFallback.java index 5613325ba..da5723554 100644 --- a/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClientFallback.java +++ b/blade-service-api/blade-erpdata-api/src/main/java/org/springblade/erpdata/feign/IErpDataOemClientFallback.java @@ -22,7 +22,7 @@ public class IErpDataOemClientFallback implements IErpDataOemClient { } @Override - public R> priceSheetData(PriceSheetQuery priceSheetQuery, Query query) { + public R> priceSheetData(PriceSheetQuery priceSheetQuery) { return R.fail("查询报价单 失败"); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/controller/OemOrderController.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/controller/OemOrderController.java index 2461af9d0..a096736e7 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/controller/OemOrderController.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/controller/OemOrderController.java @@ -184,7 +184,8 @@ public class OemOrderController extends BladeController { @ApiOperationSupport(order = 9) @Operation(summary = "报价单分页", description = "传入mesOemStatement") public R> priceSheetData(PriceSheetQuery priceSheetQuery, Query query) { - R> pageR = erpDataOemClient.priceSheetData(priceSheetQuery, query); + priceSheetQuery.setQuery(query); + R> pageR = erpDataOemClient.priceSheetData(priceSheetQuery); Page data = pageR.getData(); Page pages = new Page<>(); // 复制分页属性 @@ -250,7 +251,8 @@ public class OemOrderController extends BladeController { @Operation(summary = "报价单导出数据", description = "") public void exportPriceSheetData(PriceSheetQuery priceSheetQuery, Query query, HttpServletResponse response) { query.setSize(99999); - R> pageR = erpDataOemClient.priceSheetData(priceSheetQuery, query); + priceSheetQuery.setQuery(query); + R> pageR = erpDataOemClient.priceSheetData(priceSheetQuery); Page data = pageR.getData(); List list = data.getRecords(); List excels = new ArrayList<>(); diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/service/impl/OemStatementServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/service/impl/OemStatementServiceImpl.java index d23970155..49f027066 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/service/impl/OemStatementServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/oem/service/impl/OemStatementServiceImpl.java @@ -654,10 +654,10 @@ public class OemStatementServiceImpl extends BaseServiceImpl> pageR = erpDataOemClient.priceSheetData(query, new Query() {{ + query.setQuery(new Query() {{ setSize(99999); }}); + R> pageR = erpDataOemClient.priceSheetData(query); if (pageR != null && pageR.getData() != null) { return pageR.getData().getRecords(); @@ -675,9 +675,10 @@ public class OemStatementServiceImpl extends BaseServiceImpl getPriceSheets(String oemName) { PriceSheetQuery query = new PriceSheetQuery(); query.setOcName(oemName); - R> pageR = erpDataOemClient.priceSheetData(query, new Query() {{ + query.setQuery(new Query() {{ setSize(99999); }}); + R> pageR = erpDataOemClient.priceSheetData(query); if (pageR != null && pageR.getData() != null) { return pageR.getData().getRecords(); @@ -1508,7 +1509,7 @@ public class OemStatementServiceImpl extends BaseServiceImpl - Map> priceSheetMap = priceSheetAllList.stream().collect(Collectors.groupingBy(PriceSheetVO::getGxinfo, () -> new TreeMap<>(Collections.reverseOrder()), // 按键的倒序排序 + Map> priceSheetMap = priceSheetAllList.stream().filter(item -> item.getGxinfo() != null).collect(Collectors.groupingBy(PriceSheetVO::getGxinfo, () -> new TreeMap<>(Collections.reverseOrder()), // 按键的倒序排序 Collectors.collectingAndThen(Collectors.toList(), list -> { // 对每个分组内的列表按生效日期倒序排序 return list.stream().sorted(Comparator.comparing(PriceSheetVO::getStartdat).reversed()).collect(Collectors.toList()); @@ -1573,9 +1574,10 @@ public class OemStatementServiceImpl extends BaseServiceImpl> pageR = erpDataOemClient.priceSheetData(query, new Query() {{ + query.setQuery(new Query() {{ setSize(99999); }}); + R> pageR = erpDataOemClient.priceSheetData(query); if (pageR != null && pageR.getData() != null) { return pageR.getData().getRecords(); @@ -1715,11 +1717,12 @@ public class OemStatementServiceImpl extends BaseServiceImpl> priceSheetData(@SpringQueryMap PriceSheetQuery priceSheetQuery, @SpringQueryMap Query query) { + public R> priceSheetData(@SpringQueryMap PriceSheetQuery priceSheetQuery) { + Query query = priceSheetQuery.getQuery(); IPage iPages = erpDataOemService.priceSheetData(Condition.getPage(query), priceSheetQuery); Page pages = new Page<>(); diff --git a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataOemMapper.xml b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataOemMapper.xml index 27c931caf..571b70de9 100644 --- a/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataOemMapper.xml +++ b/blade-service/blade-erpdata/src/main/java/org/springblade/erpdata/mapper/ErpDataOemMapper.xml @@ -31,10 +31,10 @@ AND a.remark LIKE concat(concat('%', #{query.memo}),'%') - AND to_date(${query.inDateStart},'YYYY-MM-DD'), = ]]> a.startdat + AND #{query.inDateStart} = ]]> a.startdat - AND to_date(${query.inDateEnd},'YYYY-MM-DD'), a.validdat + AND #{query.inDateEnd} a.validdat AND a.validflag IN From f08dffee92bf2d4f6c19297a2748e94b67322218 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E4=B9=BE=E7=BF=94?= Date: Tue, 26 May 2026 09:50:52 +0800 Subject: [PATCH 6/8] =?UTF-8?q?=E6=80=A5=E4=BB=B6=E7=BB=B4=E6=8A=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../desk/basic/pojo/vo/UrgentPartVO.java | 13 +++++++++++++ .../basic/service/impl/UrgentPartServiceImpl.java | 3 +++ 2 files changed, 16 insertions(+) diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/basic/pojo/vo/UrgentPartVO.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/basic/pojo/vo/UrgentPartVO.java index e1e921281..d22d1b0e2 100644 --- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/basic/pojo/vo/UrgentPartVO.java +++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/basic/pojo/vo/UrgentPartVO.java @@ -3,12 +3,16 @@ */ package org.springblade.desk.basic.pojo.vo; +import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.v3.oas.annotations.media.Schema; import lombok.Data; import lombok.EqualsAndHashCode; +import org.springblade.core.tool.utils.DateUtil; import org.springblade.desk.basic.pojo.entity.UrgentPart; +import org.springframework.format.annotation.DateTimeFormat; import java.io.Serial; +import java.util.Date; /** * [急件维护] 视图实体类 @@ -33,4 +37,13 @@ public class UrgentPartVO extends UrgentPart { @Schema(description = "状态名称") private String statusName; + + @Schema(description = "需求交期") + @DateTimeFormat(pattern = DateUtil.PATTERN_DATETIME) + @JsonFormat(pattern = DateUtil.PATTERN_DATETIME) + private Date requireDateStart; + @Schema(description = "需求交期") + @DateTimeFormat(pattern = DateUtil.PATTERN_DATETIME) + @JsonFormat(pattern = DateUtil.PATTERN_DATETIME) + private Date requireDateEnd; } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java index 41a5c22c1..351b80760 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/basic/service/impl/UrgentPartServiceImpl.java @@ -66,6 +66,9 @@ public class UrgentPartServiceImpl extends BaseServiceImpl iPage = page(page, queryWrapper); String userIdSet = iPage.getRecords().stream().map(s -> { From 73a188be102e2403c36f4ac705891eb5f3230f71 Mon Sep 17 00:00:00 2001 From: wusiyu <2015098864@qq.com> Date: Tue, 26 May 2026 10:06:30 +0800 Subject: [PATCH 7/8] =?UTF-8?q?=E4=BB=93=E5=BA=93=E7=AE=A1=E7=90=86?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../springblade/wms/service/impl/StClassRequestServiceImpl.java | 1 - 1 file changed, 1 deletion(-) diff --git a/blade-service/blade-wms/src/main/java/org/springblade/wms/service/impl/StClassRequestServiceImpl.java b/blade-service/blade-wms/src/main/java/org/springblade/wms/service/impl/StClassRequestServiceImpl.java index 8cfa2b02e..4a1149ecb 100644 --- a/blade-service/blade-wms/src/main/java/org/springblade/wms/service/impl/StClassRequestServiceImpl.java +++ b/blade-service/blade-wms/src/main/java/org/springblade/wms/service/impl/StClassRequestServiceImpl.java @@ -354,7 +354,6 @@ public class StClassRequestServiceImpl extends BaseServiceImpl Date: Tue, 26 May 2026 11:32:59 +0800 Subject: [PATCH 8/8] =?UTF-8?q?=E5=A4=96=E5=8D=8F=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E3=80=81=E5=AE=A1=E6=89=B9=E9=97=AE=E9=A2=98=E4=BF=AE=E6=94=B9?= =?UTF-8?q?=EF=BC=8C=E5=A2=9E=E5=8A=A0=E6=8A=A5=E9=94=99=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E8=BE=93=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../produce/mapper/WorkOrderRunMapper.xml | 2 +- .../service/impl/WorkOrderRunServiceImpl.java | 40 ++++++++++++++----- 2 files changed, 32 insertions(+), 10 deletions(-) diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/mapper/WorkOrderRunMapper.xml b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/mapper/WorkOrderRunMapper.xml index 507bd5b91..f5ba6c869 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/mapper/WorkOrderRunMapper.xml +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/mapper/WorkOrderRunMapper.xml @@ -133,7 +133,7 @@ AND mwor.run_type = #{query.runType} - AND two.wo_code LIKE CONCAT('%', CONCAT(#{query.orderCode}, '%')) + AND mwor.wo_code LIKE CONCAT('%', CONCAT(#{query.orderCode}, '%')) AND tyo.part_code LIKE CONCAT('%', CONCAT(#{query.partCode}, '%')) diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderRunServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderRunServiceImpl.java index 3472a19d5..2ea44e522 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderRunServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/WorkOrderRunServiceImpl.java @@ -163,16 +163,22 @@ public class WorkOrderRunServiceImpl extends BaseServiceImpl approvals) { + List errors = new ArrayList<>(); for (int i = 0; i < approvals.size(); i++) { OemApproval approval = approvals.get(i); try { R r = singleApprovalInNewTransaction(approval); } catch (Exception e) { - log.error(String.format("审批失败，单据ID: {}", approval.getWorkOrderRunId()), e); + String errMsg = "审批失败，单据ID: " + approval.getWorkOrderRunId(); + log.error(errMsg, e); + errors.add(errMsg + "，" + e.getMessage()); } } + if (!errors.isEmpty()) { + return R.fail(String.join("；", errors)); + } return R.success("操作完成"); } @@ -203,10 +209,11 @@ public class WorkOrderRunServiceImpl extends BaseServiceImpl() - .eq(WorkPlan::getWoId, wo.getId())); + if (oldWorkOrderRun != null) { + oldWorkOrderRun.setRunStatus(WorkOrderRun.RUN_STATUS_VOIDED); + workOrderRunMapper.updateById(oldWorkOrderRun); + } + wp = workPlanMapper.selectById(wo.getWpId()); wo.setCollaborate(workOrderRun.getCollaborate()); // 若当前序小于等于已接收 @@ -296,16 +303,31 @@ public class WorkOrderRunServiceImpl extends BaseServiceImpl() .eq(WorkPlan::getId, wp.getNextWpId())); - oa = oemCraftAbilityMapper.selectOne(new LambdaQueryWrapper().eq(OemCraftAbilityEntity::getOtherId, nextWp.getOcId()) - .eq(OemCraftAbilityEntity::getCraftAbilityId, nextWp.getCaId())); + if (nextWp != null) { + oemId = nextWp.getOcId(); + craftAbilityId = nextWp.getCaId(); + oa = oemCraftAbilityMapper.selectOne(new LambdaQueryWrapper().eq(OemCraftAbilityEntity::getOtherId, oemId) + .eq(OemCraftAbilityEntity::getCraftAbilityId, craftAbilityId)); + } } else { - oa = oemCraftAbilityMapper.selectOne(new LambdaQueryWrapper().eq(OemCraftAbilityEntity::getOtherId, wp.getOcId()) - .eq(OemCraftAbilityEntity::getCraftAbilityId, wp.getCaId())); + oemId = wp.getOcId(); + craftAbilityId = wp.getCaId(); + oa = oemCraftAbilityMapper.selectOne(new LambdaQueryWrapper().eq(OemCraftAbilityEntity::getOtherId, oemId) + .eq(OemCraftAbilityEntity::getCraftAbilityId, craftAbilityId)); } //更改订单调度员和计划员 + if (oa == null) { + Oem oem = oemMapper.selectById(oemId); + String oemName = oem != null ? oem.getOcName() : "未知厂商"; + String errorMsg = String.format("外协厂商【%s】(ID:%s)的工艺能力（ID:%s）未维护，可在基础数据-外协工艺能力页面维护", oemName, oemId, craftAbilityId); + log.error(errorMsg); + throw new ServiceException(errorMsg); + } workOrderService.maintainOrder(wo, oa.getPlanner(), oa.getDispatcher(), workOrderRun, true); } Date date = DateUtil.plusDays(wo.getSendDownTime(), days);