commit commit

src/main/java/com/example/afrishop_v3/controllers/OrderController.java

@@ -206,7 +206,9 @@ public class OrderController extends Controller {
 
         List<TbCfCartRecordR> allByUserId = new ArrayList<>();
 
-        if (!noPayNow) {
+        boolean payNow = !noPayNow;
+
+        if (payNow) {
 
             Optional<TbCfStationItem> byId = itemRepository.findById(itemId);
 
@@ -314,8 +316,15 @@ public class OrderController extends Controller {
         List<String> collect = allByUserId.stream().map(TbCfCartRecordR::getCartRecordId).collect(Collectors.toList());
 
         String[] strings = collect.toArray(new String[]{});
-        cartRepository.updateSkuQuantity(strings);
-        cartRepository.updateItemQuantity(strings);
+
+        if(payNow){
+            cartRepository.updateItemQuantity_(itemId,itemNum);
+            cartRepository.updateSkuQuantity_(itemSkuId,itemNum);
+        }else {
+
+            cartRepository.updateSkuQuantity(strings);
+            cartRepository.updateItemQuantity(strings);
+        }
         cartRepository.deleteAllByCartRecordIdIn(strings);
 
 

src/main/java/com/example/afrishop_v3/repository/TbCfCartRecordRRepository.java

@@ -32,4 +32,12 @@ public interface TbCfCartRecordRRepository extends PagingAndSortingRepository<Tb
     @Modifying
     @Query(value = "update tb_cf_station_item sk INNER JOIN tb_cf_cart_record_r r ON r.item_id=sk.item_id set sk.item_count=sk.item_count-r.item_num WHERE r.cart_record_id IN :ids ",nativeQuery = true)
     void updateItemQuantity(@Param("ids") String[] ids);
+
+    @Modifying
+    @Query(value = "update tb_cf_item_skus sk set sk.sku_count=sk.sku_count-:val WHERE sk.id = :id ",nativeQuery = true)
+    void updateSkuQuantity_(@Param("id") String id,@Param("val") int count);
+
+    @Modifying
+    @Query(value = "update tb_cf_station_item sk set sk.item_count=sk.item_count-:val WHERE sk.item_id = :id ",nativeQuery = true)
+    void updateItemQuantity_(@Param("id") String id,@Param("val") int count);
 }