From d644ab75678ff94a2586ebd9ce5cc122fb44f851 Mon Sep 17 00:00:00 2001 From: "shunyi.kuang" <846002312@qq.com> Date: Mon, 13 Apr 2026 17:09:46 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B9=B4=E5=BA=A6=E8=AE=A1=E5=88=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../PlanYearDemandHdrEcController.java | 21 +++++-- .../impl/PlanYearDemandHdrEcServiceImpl.java | 63 ++++++++++++++++--- 2 files changed, 72 insertions(+), 12 deletions(-) diff --git a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/controller/PlanYearDemandHdrEcController.java b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/controller/PlanYearDemandHdrEcController.java index 3581e91..ba26b69 100644 --- a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/controller/PlanYearDemandHdrEcController.java +++ b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/controller/PlanYearDemandHdrEcController.java @@ -20,9 +20,8 @@ import com.alibaba.excel.EasyExcel; import com.alibaba.excel.support.ExcelTypeEnum; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; -import com.pictc.enums.ApproveCodeEnum; -import com.pictc.enums.BusinessCode; -import com.xjrsoft.common.exception.BusinessException; +import com.pictc.datalog.DataOperationContent; +import com.pictc.datalog.DataOperationListener; import com.xjrsoft.common.model.result.R; import com.xjrsoft.common.page.ConventPage; import com.xjrsoft.common.page.PageOutput; @@ -38,7 +37,6 @@ import com.xjrsoft.module.plan.service.IPlanYearDemandHdrEcService; import com.xjrsoft.module.plan.vo.LngPlanYearDemandHdrEcPageVo; import com.xjrsoft.module.plan.vo.LngPlanYearDemandHdrEcVo; import com.xjrsoft.module.plan.vo.LngPlanYearDemandHdrPageVo; -import com.xjrsoft.module.plan.vo.LngPlanYearDemandVo; import cn.dev33.satoken.annotation.SaCheckPermission; import cn.hutool.core.util.ObjectUtil; @@ -139,7 +137,20 @@ public class PlanYearDemandHdrEcController { @ApiOperation(value = "删除") @SaCheckPermission("planYearDemandHdrEc:delete") public R delete(@Valid @RequestBody List ids){ - return R.ok(dataService.deleteByIds(UpdateLngPlanYearDemandHdrEcDto.class, ids)); + + return R.ok(dataService.deleteByIds(UpdateLngPlanYearDemandHdrEcDto.class, ids,new DataOperationListener() { + + @Override + public UpdateLngPlanYearDemandHdrEcDto before(DataOperationContent content) { + return null; + } + + @Override + public UpdateLngPlanYearDemandHdrEcDto after(DataOperationContent content) { + + return null; + } + })); } diff --git a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/service/impl/PlanYearDemandHdrEcServiceImpl.java b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/service/impl/PlanYearDemandHdrEcServiceImpl.java index baa142e..fb7acc5 100644 --- a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/service/impl/PlanYearDemandHdrEcServiceImpl.java +++ b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/plan/service/impl/PlanYearDemandHdrEcServiceImpl.java @@ -12,6 +12,10 @@ import com.pictc.datalog.DataOperationContent; import com.pictc.datalog.DataOperationListener; import com.pictc.enums.ApproveCodeEnum; import com.pictc.enums.BusinessCode; +import com.pictc.enums.ExceptionCommonCode; +import com.pictc.jdbc.JdbcTools; +import com.pictc.jdbc.model.JdbcParam; +import com.pictc.utils.StringUtils; import com.xjrsoft.common.exception.BusinessException; import com.xjrsoft.module.datalog.service.DatalogService; import com.xjrsoft.module.plan.dto.UpdateLngPlanYearDemandHdrEcDto; @@ -57,7 +61,9 @@ public class PlanYearDemandHdrEcServiceImpl extends ServiceImpl content) { - //callSubmit(dto,content); + callSubmit(dto,content); return null; } }); @@ -93,13 +99,55 @@ public class PlanYearDemandHdrEcServiceImpl extends ServiceImpl content) { - //callSubmit(dto,content); + callSubmit(dto,content); return null; } }); } + } + + void callSubmit(UpdateLngPlanYearDemandHdrEcDto dto,DataOperationContent content) { + String sql = StringUtils.format("{? = call pc_{0}.f_save_submit(?,?)}", + content.getTableName()); + + List params = Lists.newArrayList(); + JdbcParam outParam = JdbcParam.ofString(null).setOut(true); + params.add(outParam); + params.add(JdbcParam.ofLong(content.getIdValue())); + if(dto.getId() != null) { + params.add(JdbcParam.ofString("U")); + }else { + params.add(JdbcParam.ofString("I")); + } + JdbcTools.call(sql,params); + String error = outParam.getStringValue(); + if (StringUtils.isNotEmpty(error)) { + throw new BusinessException(BusinessCode.ofArgs(ExceptionCommonCode.DB_FUNCTION_DELETE_EXEC_ERROR, error)); + } + + } + + void callSave(UpdateLngPlanYearDemandHdrEcDto dto,DataOperationContent content) { + String sql = StringUtils.format("{? = call pc_{0}.f_save(?,?)}", + content.getTableName()); + + List params = Lists.newArrayList(); + JdbcParam outParam = JdbcParam.ofString(null).setOut(true); + params.add(outParam); + params.add(JdbcParam.ofLong(content.getIdValue())); + if(dto.getId() != null) { + params.add(JdbcParam.ofString("U")); + }else { + params.add(JdbcParam.ofString("I")); + } + JdbcTools.call(sql,params); + String error = outParam.getStringValue(); + if (StringUtils.isNotEmpty(error)) { + throw new BusinessException(BusinessCode.ofArgs(ExceptionCommonCode.DB_FUNCTION_DELETE_EXEC_ERROR, error)); + } + } @Override @@ -131,8 +179,9 @@ public class PlanYearDemandHdrEcServiceImpl extends ServiceImpl content) { - //callSubmit(dto,content); - return null; + + callSave(dto,content); + return content.getObj(); } }); }else { @@ -147,8 +196,8 @@ public class PlanYearDemandHdrEcServiceImpl extends ServiceImpl content) { - //callSubmit(dto,content); - return null; + callSave(dto,content); + return content.getObj(); } }); }