This commit is contained in:
张秉卓
2025-12-25 17:45:44 +08:00
parent 175cac2340
commit 7935e43118
3 changed files with 67 additions and 4 deletions

View File

@ -6,6 +6,15 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.google.api.client.util.Lists;
import com.pictc.datalog.DataOperationContent;
import com.pictc.datalog.DataOperationListener;
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.common.model.result.R;
import com.xjrsoft.common.page.ConventPage;
import com.xjrsoft.common.page.PageOutput;
@ -42,7 +51,7 @@ public class ContractFactController {
private final IContractFactService contractFactService;
private final DatalogService dataService;
@GetMapping(value = "/page")
// @GetMapping(value = "/page")
@ApiOperation(value="LngContractFact列表(分页)")
@SaCheckPermission("contractFact:list")
public R page(@Valid LngContractFactPageDto dto){
@ -101,7 +110,17 @@ public class ContractFactController {
@ApiOperation(value = "新增LngContractFact")
@SaCheckPermission("contractFact:add")
public R add(@Valid @RequestBody UpdateLngContractFactDto dto){
UpdateLngContractFactDto res = dataService.insert(dto);
UpdateLngContractFactDto res = dataService.insert(dto, new DataOperationListener<UpdateLngContractFactDto>() {
@Override
public UpdateLngContractFactDto before(DataOperationContent<UpdateLngContractFactDto> content) {
return null;
}
@Override
public UpdateLngContractFactDto after(DataOperationContent<UpdateLngContractFactDto> content) {
return null;
}
});
return R.ok(res.getId());
}
@ -109,15 +128,44 @@ public class ContractFactController {
@ApiOperation(value = "修改LngContractFact")
@SaCheckPermission("contractFact:edit")
public R update(@Valid @RequestBody UpdateLngContractFactDto dto){
return R.ok(dataService.updateById(dto));
return R.ok(dataService.updateById(dto, new DataOperationListener<UpdateLngContractFactDto>() {
@Override
public UpdateLngContractFactDto before(DataOperationContent<UpdateLngContractFactDto> content) {
return null;
}
@Override
public UpdateLngContractFactDto after(DataOperationContent<UpdateLngContractFactDto> content) {
return null;
}
}));
}
@DeleteMapping
@ApiOperation(value = "删除")
@SaCheckPermission("contractFact:delete")
public R delete(@Valid @RequestBody List<Long> ids){
return R.ok(dataService.deleteByIds(UpdateLngContractFactDto.class, ids));
return R.ok(dataService.deleteByIds(UpdateLngContractFactDto.class, ids, new DataOperationListener<UpdateLngContractFactDto>() {
@Override
public UpdateLngContractFactDto before(DataOperationContent<UpdateLngContractFactDto> content) {
String sql = StringUtils.format("{? = call pc_{0}.f_before_delete(?)}", content.getTableName());
List<JdbcParam> 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();
}
@Override
public UpdateLngContractFactDto after(DataOperationContent<UpdateLngContractFactDto> content) {
return null;
}
}));
}