diff --git a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/ship/controller/MeaPurIntController.java b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/ship/controller/MeaPurIntController.java index 1d06153..8631c08 100644 --- a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/ship/controller/MeaPurIntController.java +++ b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/ship/controller/MeaPurIntController.java @@ -32,14 +32,11 @@ import com.xjrsoft.module.datalog.service.DatalogService; import com.xjrsoft.module.datalog.vo.DataChangeLogVo; import com.xjrsoft.module.ship.dto.LngMeaPurIntPageDto; import com.xjrsoft.module.ship.dto.UpdateLngMeaPurIntDto; -import com.xjrsoft.module.ship.dto.UpdateLngOpsPurIntDto; import com.xjrsoft.module.ship.entity.LngMeaPurInt; import com.xjrsoft.module.ship.service.IMeaPurIntService; import com.xjrsoft.module.ship.vo.LngMeaPurIntPageVo; -import com.xjrsoft.module.ship.vo.LngMeaPurIntVo; import cn.dev33.satoken.annotation.SaCheckPermission; -import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import io.swagger.annotations.Api; @@ -179,8 +176,29 @@ public class MeaPurIntController { @ApiOperation(value = "删除") @SaCheckPermission("meaPurInt:delete") public R delete(@Valid @RequestBody List ids){ - return R.ok(dataService.deleteByIds(UpdateLngMeaPurIntDto.class, ids)); - + return R.ok(dataService.deleteByIds(UpdateLngMeaPurIntDto.class, ids, new DataOperationListener() { + @Override + public UpdateLngMeaPurIntDto before(DataOperationContent content) { + return null; + } + + @Override + public UpdateLngMeaPurIntDto after(DataOperationContent content) { + String sql = StringUtils.format("{? = call pc_{0}.f_before_delete(?)}", + content.getTableName()); + List params = Lists.newArrayList(); + JdbcParam outParam = JdbcParam.ofString(null).setOut(true); + params.add(outParam); + params.add(JdbcParam.ofLong(content.getIdValue())); + + JdbcTools.call(sql,params); + String error = outParam.getStringValue(); + if (StringUtils.isNotEmpty(error)) { + throw new BusinessException(BusinessCode.ofArgs(ExceptionCommonCode.DB_FUNCTION_DELETE_EXEC_ERROR, error)); + } + return content.getObj(); + } + })); }