diff --git a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/mdm/service/impl/CurrencyServiceImpl.java b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/mdm/service/impl/CurrencyServiceImpl.java index ff00e70..52a1486 100644 --- a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/mdm/service/impl/CurrencyServiceImpl.java +++ b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/mdm/service/impl/CurrencyServiceImpl.java @@ -16,6 +16,7 @@ import com.pictc.enums.ExceptionCommonCode; import com.pictc.enums.ValidEnum; import com.pictc.utils.DataLogTools; import com.xjrsoft.common.advice.tran.CurrencyDataProvider; +import com.xjrsoft.common.advice.tran.TranDataManager; import com.xjrsoft.common.enums.YesOrNoEnum; import com.xjrsoft.common.exception.BusinessException; import com.xjrsoft.module.common.db.service.CommonCallService; @@ -39,8 +40,8 @@ public class CurrencyServiceImpl extends ServiceImpl content) { String msg = CommonCallUtils.saveAfter(content.getTableName(),content.getIdValue()); - if (StringUtils.isNotBlank(msg)) { - throw new BusinessException(BusinessCode.ofArgs(ExceptionCommonCode.DB_FUNCTION_EXEC_ERROR, msg)); - } - UpdateLngCustomerDto obj =content.getObj(); + if (StringUtils.isNotBlank(msg)) { + throw new BusinessException(BusinessCode.ofArgs(ExceptionCommonCode.DB_FUNCTION_EXEC_ERROR, msg)); + } + UpdateLngCustomerDto obj =content.getObj(); tranProvider.saveData(obj.getCuCode(), obj); return obj; } @@ -172,6 +172,8 @@ public class CustomerController { @Override public UpdateLngCustomerDto after(DataOperationContent content) { + UpdateLngCustomerDto obj =content.getObj(); + tranProvider.removeCacheData(obj.getCuCode()); return null; } })); @@ -191,6 +193,8 @@ public class CustomerController { @Override public UpdateLngCustomerDto after(DataOperationContent content) { + UpdateLngCustomerDto obj =content.getObj(); + tranProvider.saveData(obj.getCuCode(), obj); return null; } })); @@ -210,6 +214,8 @@ public class CustomerController { @Override public UpdateLngCustomerDto after(DataOperationContent content) { + UpdateLngCustomerDto obj =content.getObj(); + tranProvider.saveData(obj.getCuCode(), obj); return null; } })); diff --git a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/controller/GradeSystemController.java b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/controller/GradeSystemController.java index bd4bb8c..59518b1 100644 --- a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/controller/GradeSystemController.java +++ b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/controller/GradeSystemController.java @@ -123,7 +123,7 @@ public class GradeSystemController { throw new BusinessException(BusinessCode.ofArgs(ExceptionCommonCode.DB_FUNCTION_EXEC_ERROR, msg)); } codeRuleClient.useEncode(GS_CODE); - UpdateLngGradeSystemDto obj =content.getObj(); + UpdateLngGradeSystemDto obj =content.getObj(); tranProvider.saveData(obj.getId().toString(), obj); return obj; } @@ -178,6 +178,8 @@ public class GradeSystemController { @Override public UpdateLngGradeSystemDto after(DataOperationContent content) { + UpdateLngGradeSystemDto obj =content.getObj(); + tranProvider.saveData(obj.getId().toString(), obj); return null; } })); @@ -196,6 +198,8 @@ public class GradeSystemController { @Override public UpdateLngGradeSystemDto after(DataOperationContent content) { + UpdateLngGradeSystemDto obj =content.getObj(); + tranProvider.saveData(obj.getId().toString(), obj); return null; } })); diff --git a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/service/impl/CustomerServiceImpl.java b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/service/impl/CustomerServiceImpl.java index 3d6393f..2f9d094 100644 --- a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/service/impl/CustomerServiceImpl.java +++ b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/sales/service/impl/CustomerServiceImpl.java @@ -12,6 +12,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.github.yulichang.base.MPJBaseServiceImpl; import com.pictc.enums.BusinessCode; +import com.xjrsoft.common.advice.tran.CustomerDataProvider; import com.xjrsoft.common.exception.BusinessException; import com.xjrsoft.module.mdm.client.ILngBankClient; import com.xjrsoft.module.mdm.dto.UpdateLngBBankDto; @@ -46,6 +47,7 @@ import lombok.AllArgsConstructor; @Service @AllArgsConstructor public class CustomerServiceImpl extends MPJBaseServiceImpl implements ICustomerService { + private final LngCustomerMapper lngCustomerMapper; private final LngCustomerAttrPowerMapper lngCustomerAttrPowerMapper; @@ -56,6 +58,8 @@ public class CustomerServiceImpl extends MPJBaseServiceImpl ids) { List customerList = lngCustomerMapper.selectList(Wrappers.lambdaQuery(LngCustomer.class).in(LngCustomer::getId, ids)); + for(LngCustomer customer: customerList) { + tranProvider.removeCacheData(customer.getCuCode()); + } List cuCodeList = customerList.stream().map(LngCustomer::getCuCode).filter(Objects::nonNull).collect(Collectors.toList()); lngCustomerMapper.deleteBatchIds(ids); if(CollectionUtil.isNotEmpty(cuCodeList)) { diff --git a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/supplier/controller/SupplierController.java b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/supplier/controller/SupplierController.java index 82cbb4e..b1de485 100644 --- a/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/supplier/controller/SupplierController.java +++ b/itc-pcitc-mdm/itc-pcitc-mdm-service/src/main/java/com/xjrsoft/module/supplier/controller/SupplierController.java @@ -148,7 +148,7 @@ public class SupplierController { if (StringUtils.isNotBlank(msg)) { throw new BusinessException(BusinessCode.ofArgs(ExceptionCommonCode.DB_FUNCTION_EXEC_ERROR, msg)); } - UpdateLngSupplierDto obj =content.getObj(); + UpdateLngSupplierDto obj =content.getObj(); tranProvider.saveData(obj.getSuCode(), obj); return obj; } @@ -168,6 +168,8 @@ public class SupplierController { @Override public UpdateLngSupplierDto after(DataOperationContent content) { + UpdateLngSupplierDto obj =content.getObj(); + tranProvider.removeCacheData(obj.getSuCode()); return null; } })); @@ -187,6 +189,8 @@ public class SupplierController { @Override public UpdateLngSupplierDto after(DataOperationContent content) { + UpdateLngSupplierDto obj =content.getObj(); + tranProvider.saveData(obj.getSuCode(), obj); return null; } })); @@ -206,6 +210,8 @@ public class SupplierController { @Override public UpdateLngSupplierDto after(DataOperationContent content) { + UpdateLngSupplierDto obj =content.getObj(); + tranProvider.saveData(obj.getSuCode(), obj); return null; } }));