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

清空购物车删除缓存

Browse Source
This commit is contained in:
SongZhang
2024-09-27 15:27:03 +08:00
parent e9eabd149e
commit c981268289
1 changed files with 2 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
View File

@@ -1111,20 +1111,6 @@ public class CartService {
String shopId = jsonObject.getString("shopId");
String tableId = jsonObject.getString("tableId");
Integer userId = TokenUtil.getUserId();
// List<String> skuIds=new ArrayList<>();
// if (redisUtil.exists(RedisCst.TABLE_CART.concat(jsonObject.getString("tableId").concat("-").concat(shopId)))) {
// JSONArray array = JSON.parseArray(redisUtil.getMessage(RedisCst.TABLE_CART.concat(jsonObject.getString("tableId").concat("-").concat(shopId))));
// if (Objects.isNull(array) || array.isEmpty() || array.size() < 1) {
// for (int i = 0; i < array.size(); i++) {
// TbCashierCart cashierCart = JSONUtil.parseJSONStr2T(array.get(i).toString(), TbCashierCart.class);
// redisUtil.secAdd(RedisCst.PRODUCT + shopId + ":" + jsonObject.getString("skuId"), cashierCart.getNumber().toString());
// productSkuMapper.updateAddStockById(jsonObject.getString("skuId"), cashierCart.getNumber());
// skuIds.add(cashierCart.getSkuId());
// }
// }
// }
if (StrUtil.isNotBlank(tableId)) {
cashierCartMapper.updateStatusByOrderIdForMini(jsonObject.getString("tableId"), "closed");
}else {
@@ -1135,21 +1121,15 @@ public class CartService {
.gt(TbCashierCart::getCreatedAt, DateUtil.offsetDay(DateUtil.date(), -1).getTime())
.set(TbCashierCart::getStatus, "closed"));
}
// cashierCartMapper.updateStatusByTableId(jsonObject.getString("tableId"), "closed");
String tableCartKey = RedisCst.getTableCartKey(shopId, tableId, userId);
redisUtil.saveMessage(tableCartKey, new JSONArray().toJSONString());
redisUtil.deleteByKey(tableCartKey);
// redisUtil.saveMessage(tableCartKey, new JSONArray().toJSONString());
JSONObject jsonObject1 = new JSONObject();
jsonObject1.put("status", "success");
jsonObject1.put("msg", "成功");
jsonObject1.put("type", "addcart");
jsonObject1.put("amount", BigDecimal.ZERO);
jsonObject1.put("data", new ArrayList<>());
// //修改耗材数据
// JSONObject jsonObject2=new JSONObject();
// jsonObject2.put("type","delete");
// jsonObject2.put("skuIds",skuIds);
// jsonObject2.put("shopId",shopId);
// producer.cons(jsonObject2.toString());
PushToAppChannelHandlerAdapter.getInstance().AppSendInfo(jsonObject1.toString(), tableCartKey, "", false);
} catch (Exception e) {
log.info("长链接错误 clearCart{}", e.getMessage());