释放库存

@@ -4,6 +4,7 @@ package com.tianting.infoloop.service.grpc;
 import cn.hutool.core.date.LocalDateTimeUtil;
 import cn.hutool.core.date.LocalDateTimeUtil;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -56,6 +57,8 @@ import com.infoloop.tianting.clientcustomerorderservice.QuerySkuSellQuantitiesBy
 import com.infoloop.tianting.clientcustomerorderservice.QuerySkuSellQuantitiesByStallAndSkuIdsRpcResponse;
 import com.infoloop.tianting.clientcustomerorderservice.QuerySkuSellQuantitiesByStallAndSkuIdsRpcResponse;
 import com.infoloop.tianting.clientcustomerorderservice.QuerySkuSellQuantitiesByStallRpcRequest;
 import com.infoloop.tianting.clientcustomerorderservice.QuerySkuSellQuantitiesByStallRpcRequest;
 import com.infoloop.tianting.clientcustomerorderservice.QuerySkuSellQuantitiesByStallRpcResponse;
 import com.infoloop.tianting.clientcustomerorderservice.QuerySkuSellQuantitiesByStallRpcResponse;
+import com.infoloop.tianting.clientcustomerorderservice.ReleaseSkusSellQuantitiesRpcRequest;
+import com.infoloop.tianting.clientcustomerorderservice.ReleaseSkusSellQuantitiesRpcResponse;
 import com.infoloop.tianting.clientcustomerorderservice.SingleSkuSellQuantityRpcResponse;
 import com.infoloop.tianting.clientcustomerorderservice.SingleSkuSellQuantityRpcResponse;
 import com.infoloop.tianting.clientcustomerorderservice.SkuSellQuantityModification;
 import com.infoloop.tianting.clientcustomerorderservice.SkuSellQuantityModification;
 import com.infoloop.tianting.clientcustomerorderservice.UpdateClientCustomerOrderDetailRpcRequest;
 import com.infoloop.tianting.clientcustomerorderservice.UpdateClientCustomerOrderDetailRpcRequest;
@@ -785,4 +788,23 @@ public class OrderGrpcService extends ClientCustomerOrderServiceRpcGrpc.ClientCu
         responseStreamObserver.onCompleted();
         responseStreamObserver.onCompleted();
     }
     }
 
 
+    @Override
+    @DS(DATA_SOURCE_MASTER)
+    public void releaseSkusSellQuantities(final ReleaseSkusSellQuantitiesRpcRequest request,
+                                          final StreamObserver<ReleaseSkusSellQuantitiesRpcResponse> responseStreamObserver) {
+        final var builder = ReleaseSkusSellQuantitiesRpcResponse.newBuilder();
+        try {
+            LambdaUpdateWrapper<SkuSellQuantity> updateWrapper = new LambdaUpdateWrapper<>();
+            updateWrapper.eq(SkuSellQuantity::getEnterpriseId, request.getEnterpriseId());
+            updateWrapper.set(SkuSellQuantity::getTodaySellQuantity, 0);
+            builder.setIsReleased(skuSellQuantityService.update(updateWrapper));
+        } catch (final Exception e) {
+            log.error("releaseSkusSellQuantities error;", e);
+            responseStreamObserver.onError(Status.INTERNAL.withDescription(e.getMessage()).asException());
+            return;
+        }
+        responseStreamObserver.onNext(builder.build());
+        responseStreamObserver.onCompleted();
+    }
+
 }
 }

@@ -40,6 +40,7 @@ service ClientCustomerOrderServiceRpc {
   rpc QuerySkuSellQuantitiesByStallAndSkuIds(QuerySkuSellQuantitiesByStallAndSkuIdsRpcRequest) returns (QuerySkuSellQuantitiesByStallAndSkuIdsRpcResponse) {}
   rpc QuerySkuSellQuantitiesByStallAndSkuIds(QuerySkuSellQuantitiesByStallAndSkuIdsRpcRequest) returns (QuerySkuSellQuantitiesByStallAndSkuIdsRpcResponse) {}
   rpc BatchSaveSkuSellQuantities(BatchSaveSkuSellQuantitiesRpcRequest) returns (BatchSaveSkuSellQuantitiesRpcResponse) {}
   rpc BatchSaveSkuSellQuantities(BatchSaveSkuSellQuantitiesRpcRequest) returns (BatchSaveSkuSellQuantitiesRpcResponse) {}
   rpc AddSkusSellQuantities(AddSkusSellQuantitiesRpcRequest) returns (AddSkusSellQuantitiesRpcResponse) {}
   rpc AddSkusSellQuantities(AddSkusSellQuantitiesRpcRequest) returns (AddSkusSellQuantitiesRpcResponse) {}
+  rpc ReleaseSkusSellQuantities(ReleaseSkusSellQuantitiesRpcRequest) returns (ReleaseSkusSellQuantitiesRpcResponse) {}
 
 
 }
 }
 
 
@@ -684,3 +685,11 @@ message SkuSellQuantity {
 message AddSkusSellQuantitiesRpcResponse {
 message AddSkusSellQuantitiesRpcResponse {
   bool isAdded = 1;
   bool isAdded = 1;
 }
 }
+
+message ReleaseSkusSellQuantitiesRpcRequest {
+  int32 enterpriseId = 1;
+}
+
+message ReleaseSkusSellQuantitiesRpcResponse {
+  bool isReleased = 1;
+}