交易审批多节点问题处理完善

Bang Hu

2 天以前 2b0b64182263d922b946ec898070e59b602382dc

 src/main/java/com/webmanage/service/impl/CartPersistenceServiceImpl.java

@@ -30,7 +30,7 @@
                cart.setUnitId(unitId);
            }
            cart.setUpdateTime(LocalDateTime.now());
            Cart existing = cartMapper.selectByUserIdUnitIdAndPricingId(userId, unitId, item.getPricingId());
            Cart existing = cartMapper.selectByUserIdUnitIdAndPricingId(userId, unitId,item.getProductId(), item.getPricingId());
            if (existing != null) {
                cart.setId(existing.getId());
                cartMapper.updateById(cart);
@@ -43,9 +43,9 @@

    @Override
    @Async("asyncExecutor")
    public void remove(String userId, String unitId, Long pricingId) {
    public void remove(String userId, String unitId, String productId,Long pricingId) {
        try {
            Cart existing = cartMapper.selectByUserIdUnitIdAndPricingId(userId, unitId, pricingId);
            Cart existing = cartMapper.selectByUserIdUnitIdAndPricingId(userId, unitId, productId,pricingId);
            if (existing != null) {
                cartMapper.deleteById(existing.getId());
            }
@@ -54,9 +54,9 @@

    @Override
    @Async("asyncExecutor")
    public void clear(String userId, String unitId) {
    public void clear(String userId, String unitId,String productId) {
        try {
            java.util.List<Cart> cartItems = cartMapper.selectByUserIdAndUnitId(userId, unitId);
            java.util.List<Cart> cartItems = cartMapper.selectByUserIdAndUnitId(userId, unitId, productId);
            for (Cart item : cartItems) {
                cartMapper.deleteById(item.getId());
            }