czg_team/cashier-admin-java
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

销售统计

Browse Source
This commit is contained in:
wangw
2024-10-14 15:29:23 +08:00
parent 2d03914963
commit 68fac45b7a
1 changed files with 40 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

73
eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/TbProductStockDetailServiceImpl.java
View File

@@ -32,6 +32,7 @@ import java.text.ParseException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.CompletableFuture;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
@Service @Service
@@ -243,39 +244,45 @@ public class TbProductStockDetailServiceImpl implements TbProductStockDetailServ
@Override @Override
public void addSaleRecord(Integer orderId) { public void addSaleRecord(Integer orderId) {
List<StockCountDTO> stockCountDTOS = stockCountRepository.countStockById(orderId); // 先进行延迟
try { CompletableFuture<Void> delayFuture = CompletableFuture.runAsync(() -> {
Thread.sleep(3000l); try {
} catch (InterruptedException e) { Thread.sleep(3000L);
throw new RuntimeException(e); } catch (InterruptedException e) {
} Thread.currentThread().interrupt();
log.info("查询到订单id: {}的所有库存数据: {}", orderId, stockCountDTOS); throw new RuntimeException(e);
// stockCountDTOS.forEach(s -> { }
// //客座费不统计 });
// if (s.getProId() > 0) {
// if (s.getStockCount() > 0) { delayFuture.thenRun(() -> {
// TbProductStockDetail productStockDetail = new TbProductStockDetail(); List<StockCountDTO> stockCountDTOS = stockCountRepository.countStockById(orderId);
// productStockDetail.setCreatedAt(System.currentTimeMillis()); log.info("查询到订单id: {}的所有库存数据: {}", orderId, stockCountDTOS);
// productStockDetail.setUpdatedAt(System.currentTimeMillis()); stockCountDTOS.forEach(s -> {
// productStockDetail.setShopId(s.getShopId()); if (s.getProId() > 0) {
// productStockDetail.setProductId(s.getProId().toString()); if (s.getStockCount() > 0) {
// productStockDetail.setProductName(s.getProName()); TbProductStockDetail productStockDetail = new TbProductStockDetail();
// productStockDetail.setOrderId(orderId.toString()); productStockDetail.setCreatedAt(System.currentTimeMillis());
//// productStockDetail.setSkuId(s.getSkuId().toString()); productStockDetail.setUpdatedAt(System.currentTimeMillis());
// productStockDetail.setIsStock(s.getIsStock());//是否开启库存 productStockDetail.setShopId(s.getShopId());
// productStockDetail.setLeftNumber(s.getStockNumber() + s.getStockCount());//原库存 productStockDetail.setProductId(s.getProId().toString());
// productStockDetail.setSpecSnap(s.getSpecSnap()); productStockDetail.setProductName(s.getProName());
// productStockDetail.setUnitName(s.getUnitName()); productStockDetail.setOrderId(orderId.toString());
// productStockDetail.setStockNumber(-Double.valueOf(s.getStockCount())); // productStockDetail.setSkuId(s.getSkuId().toString());
// productStockDetail.setSourcePath("NORMAL"); productStockDetail.setIsStock(s.getIsStock());// 是否开启库存
// productStockDetail.setType("售出记录"); productStockDetail.setLeftNumber(s.getStockNumber() + s.getStockCount());// 原库存
// productStockDetail.setRemark("售出记录:" + orderId); productStockDetail.setSpecSnap(s.getSpecSnap());
// productStockDetail.setSubType(-1); productStockDetail.setUnitName(s.getUnitName());
// tbProductStockDetailRepository.save(productStockDetail); productStockDetail.setStockNumber(-Double.valueOf(s.getStockCount()));
// } productStockDetail.setSourcePath("NORMAL");
// skutMapper.incrRealSalesNumber(s.getSkuId().intValue(), s.getStockCount()); productStockDetail.setType("售出记录");
// } productStockDetail.setRemark("售出记录:" + orderId);
// }); productStockDetail.setSubType(-1);
tbProductStockDetailRepository.save(productStockDetail);
}
skutMapper.incrRealSalesNumber(s.getSkuId().intValue(), s.getStockCount());
}
});
});
} }
} }