+ * 搴曞眰浣跨敤 Redis Hash 缁撴瀯锛屼繚璇佹寜 shopId + orderId 缁村害鐨 O(1) 璇诲啓鏁堢巼銆
+ *
+ * Key = SHOP_GROUP_ORDERS:{shopId}
+ * Field = orderId
+ * Value = MallOrderGroup 鐨 JSON 搴忓垪鍖
+ *
+ *
+ * 浣跨敤鍦烘櫙锛氳鍗曠姸鎬佸彂鐢熷彉鍖栨椂锛堝垱寤恒佹洿鏂般佸彇娑堛佸畬鎴愮瓑锛夛紝
+ * 鐢变笟鍔℃柟涓诲姩璋冪敤鏈伐鍏风被鐨勬柟娉曠淮鎶ょ紦瀛橈紝浠ュ噺灏 getMallOrderGroupByShopId 鎺ュ彛瀵规暟鎹簱鐨勬煡璇㈠帇鍔涖
+ *
+ * @author system
+ */
+@Slf4j
+@Component
+public class ShopGroupOrderCacheUtil {
+
+ /** Redis Key 鍓嶇紑 */
+ private static final String KEY_PREFIX = "SHOP_GROUP_ORDERS:";
+
+ /** 璁㈠崟涓嶅啀灞炰簬"寰呮垚鍥"鐨勭姸鎬侀泦鍚 */
+ private static final int STATUS_DONE = 0;
+
+ @Autowired
+ private RedisTemplateHelper redisTemplateHelper;
+
+ // ================================================================
+ // Key 鏋勫缓
+ // ================================================================
+
+ private String buildKey(String shopId) {
+ return KEY_PREFIX + shopId;
+ }
+
+ // ================================================================
+ // 瀛樻斁锛坧ut锛
+ // ================================================================
+
+ /**
+ * 瀛樻斁鍗曚釜璁㈠崟鍒扮紦瀛
+ *
+ * @param shopId 搴楅摵ID
+ * @param orderVO 璁㈠崟VO锛堝繀椤诲寘鍚湁鏁堢殑 id锛
+ */
+ public void put(String shopId, MallOrderGroup orderVO) {
+ if (StringUtils.isBlank(shopId) || orderVO == null || StringUtils.isBlank(orderVO.getId())) {
+ log.info("UserPendingOrderCacheUtil.put 鍙傛暟鏃犳晥, userId={}, orderVO={}", shopId, orderVO);
+ return;
+ }
+ try {
+ String key = buildKey(shopId);
+ String json = JSONUtil.toJsonStr(orderVO);
+ redisTemplateHelper.hPut(key, orderVO.getId(), json);
+ log.info("缂撳瓨搴楅摵寰呮垚鍥㈣鍗: shopId={}, orderId={}", shopId, orderVO.getId());
+ } catch (Exception e) {
+ log.info("缂撳瓨搴楅摵寰呮垚鍥㈣鍗曞け璐: shopId={}, orderId={}", shopId, orderVO.getId(), e);
+ }
+ }
+
+ /**
+ * 鎵归噺瀛樻斁璁㈠崟鍒扮紦瀛橈紙閫氬父鐢ㄤ簬缂撳瓨棰勭儹 / 棣栨鍔犺浇锛
+ *
+ * @param shopId 搴楅摵ID
+ * @param orders 璁㈠崟鍒楄〃
+ */
+ public void putAll(String shopId, List orders) {
+ if (StringUtils.isBlank(shopId) || orders == null || orders.isEmpty()) {
+ return;
+ }
+ try {
+ String key = buildKey(shopId);
+ Map map = new java.util.LinkedHashMap<>(orders.size());
+ for (MallOrderGroup order : orders) {
+ if (order != null && StringUtils.isNotBlank(order.getId())) {
+ map.put(order.getId(), JSONUtil.toJsonStr(order));
+ }
+ }
+ if (!map.isEmpty()) {
+ redisTemplateHelper.hPutAll(key, map);
+ log.info("鎵归噺缂撳瓨搴楅摵寰呮垚鍥㈣鍗: shopId={}, count={}", shopId, map.size());
+ }
+ } catch (Exception e) {
+ log.info("鎵归噺缂撳瓨搴楅摵寰呮垚鍥㈣鍗曞け璐: shopId={}", shopId, e);
+ }
+ }
+
+ // ================================================================
+ // 鍒犻櫎锛坮emove锛
+ // ================================================================
+
+ /**
+ * 鏍规嵁 shopId 鍜 orderId 浠庣紦瀛樹腑鍒犻櫎鎸囧畾璁㈠崟
+ *
+ * 鍏稿瀷鍦烘櫙锛氳鍗曟垚鍥€佸彇娑堛侀娆炬垚鍔熷悗璋冪敤銆
+ *
+ * @param shopId 搴楅摵ID
+ * @param orderId 璁㈠崟ID
+ */
+ public void remove(String shopId, String orderId) {
+ if (StringUtils.isBlank(shopId) || StringUtils.isBlank(orderId)) {
+ log.info("UserPendingOrderCacheUtil.remove 鍙傛暟鏃犳晥, shopId={}, orderId={}", shopId, orderId);
+ return;
+ }
+ try {
+ String key = buildKey(shopId);
+ redisTemplateHelper.hDelete(key, orderId);
+ log.info("鍒犻櫎寰呮垚鍥㈣鍗曠紦瀛: shopId={}, orderId={}", shopId, orderId);
+ } catch (Exception e) {
+ log.info("鍒犻櫎寰呮垚鍥㈣鍗曠紦瀛樺け璐: shopId={}, orderId={}", shopId, orderId, e);
+ }
+ }
+
+ /**
+ * 娓呴櫎鎸囧畾搴楅摵鎵鏈夊緟鎴愬洟璁㈠崟缂撳瓨
+ *
+ * 鍏稿瀷鍦烘櫙锛氶渶瑕佸己鍒跺埛鏂拌搴楅摵缂撳瓨鏃惰皟鐢ㄣ
+ *
+ * @param shopId 搴楅摵ID
+ */
+ public void removeAll(String shopId) {
+ if (StringUtils.isBlank(shopId)) {
+ return;
+ }
+ try {
+ redisTemplateHelper.delete(buildKey(shopId));
+ log.info("娓呴櫎搴楅摵寰呮垚鍥㈣鍗曠紦瀛: shopId={}", shopId);
+ } catch (Exception e) {
+ log.info("娓呴櫎搴楅摵寰呮垚鍥㈣鍗曠紦瀛樺け璐: shopId={}", shopId, e);
+ }
+ }
+
+ // ================================================================
+ // 鏇存柊锛坲pdate锛
+ // ================================================================
+
+ /**
+ * 鏍规嵁 shopId 鍜 orderId 鏇存柊缂撳瓨涓殑璁㈠崟淇℃伅
+ *
+ * 濡傛灉鏇存柊鍚庣殑璁㈠崟鐘舵佸凡缁忎笉灞炰簬"寰呭畬鎴"锛坰tatus 鈭 {10}锛夛紝
+ * 鍒欒嚜鍔ㄤ粠缂撳瓨涓Щ闄よ璁㈠崟锛屾棤闇璋冪敤鏂归澶栧垽鏂
+ *
+ * @param shopId 搴楅摵ID
+ * @param orderVO 鏇存柊鍚庣殑璁㈠崟VO
+ */
+ public void update(String shopId, MallOrderGroup orderVO) {
+ if (StringUtils.isBlank(shopId) || orderVO == null || StringUtils.isBlank(orderVO.getId())) {
+ log.warn("UserPendingOrderCacheUtil.update 鍙傛暟鏃犳晥, shopId={}, orderVO={}", shopId, orderVO);
+ return;
+ }
+ try {
+ // 濡傛灉璁㈠崟鐘舵佸凡涓嶅睘浜庡緟鎴愬洟锛岀洿鎺ュ垹闄
+ /*if (!isTerminalStatus(orderVO.getStatus())) {
+ remove(shopId, orderVO.getId());
+ log.debug("璁㈠崟宸茬粓鎬侊紝浠庣紦瀛樼Щ闄: shopId={}, orderId={}, status={}",
+ shopId, orderVO.getId(), orderVO.getStatus());
+ return;
+ }*/
+ // 瑕嗙洊鏇存柊
+ put(shopId, orderVO);
+ log.info("鏇存柊搴楅摵寰呮垚鍥㈢紦瀛: shopId={}, orderId={}, status={}",
+ shopId, orderVO.getId(), orderVO.getStatus());
+ } catch (Exception e) {
+ log.info("鏇存柊鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛樺け璐: shopId={}, orderId={}", shopId, orderVO.getId(), e);
+ }
+ }
+
+ // ================================================================
+ // 鏌ヨ锛坓et锛
+ // ================================================================
+
+ /**
+ * 鑾峰彇搴楅摵寰呮垚鍥㈣鍗曠紦瀛
+ *
+ * @param shopId 搴楅摵ID
+ * @return 缂撳瓨鐨勮鍗曞垪琛紝缂撳瓨涓嶅瓨鍦ㄦ椂杩斿洖 null锛堣皟鐢ㄦ柟鍙嵁姝ゅ垽鏂槸鍚﹂渶瑕佸洖婧愭煡搴擄級
+ */
+ public List getAll(String shopId) {
+ if (StringUtils.isBlank(shopId)) {
+ return null;
+ }
+ try {
+ String key = buildKey(shopId);
+ Map entries = redisTemplateHelper.hGetAll(key);
+ if (entries == null || entries.isEmpty()) {
+ return null;
+ }
+ List result = new ArrayList<>(entries.size());
+ for (Object value : entries.values()) {
+ if (value != null) {
+ result.add(JSONUtil.toBean(value.toString(), MallOrderGroup.class));
+ }
+ }
+ return result;
+ } catch (Exception e) {
+ log.info("鑾峰彇搴楅摵寰呮垚鍥㈣鍗曠紦瀛樺け璐: shopId={}", shopId, e);
+ return null;
+ }
+ }
+
+ /**
+ * 鑾峰彇搴楅摵缂撳瓨寰呮垚鍥㈠崟涓鍗
+ *
+ * @param shopId 搴楅摵ID
+ * @param orderId 璁㈠崟ID
+ * @return 缂撳瓨鐨勮鍗昖O锛屼笉瀛樺湪鏃惰繑鍥 null
+ */
+ public MallOrderVO get(String shopId, String orderId) {
+ if (StringUtils.isBlank(shopId) || StringUtils.isBlank(orderId)) {
+ return null;
+ }
+ try {
+ String key = buildKey(shopId);
+ Object value = redisTemplateHelper.hGet(key, orderId);
+ if (value == null) {
+ return null;
+ }
+ return JSONUtil.toBean(value.toString(), MallOrderVO.class);
+ } catch (Exception e) {
+ log.info("鑾峰彇搴楅摵鍗曚釜寰呮垚鍥㈣鍗曠紦瀛樺け璐: shopId={}, orderId={}", shopId, orderId, e);
+ return null;
+ }
+ }
+
+ /**
+ * 鍒ゆ柇璇ュ簵閾虹殑缂撳瓨鏄惁宸插瓨鍦
+ *
+ * @param shopId 搴楅摵ID
+ * @return true 琛ㄧず缂撳瓨瀛樺湪
+ */
+ public boolean exists(String shopId) {
+ if (StringUtils.isBlank(shopId)) {
+ return false;
+ }
+ Boolean hasKey = redisTemplateHelper.hasKey(buildKey(shopId));
+ return hasKey != null && hasKey;
+ }
+
+ // ================================================================
+ // 鍐呴儴宸ュ叿
+ // ================================================================
+
+ /**
+ * 鍒ゆ柇璁㈠崟鐘舵佹槸鍚︿负缁堟侊紙涓嶅啀灞炰簬"寰呮垚鍥"锛
+ */
+ private boolean isTerminalStatus(Integer status) {
+ if (status == null) {
+ return false;
+ }
+ return status == STATUS_DONE;
+ }
+}
diff --git a/hiver-modules/hiver-mall/src/main/java/cc/hiver/mall/utils/UserPendingOrderCacheUtil.java b/hiver-modules/hiver-mall/src/main/java/cc/hiver/mall/utils/UserPendingOrderCacheUtil.java
index 9abf521f..728e1a00 100644
--- a/hiver-modules/hiver-mall/src/main/java/cc/hiver/mall/utils/UserPendingOrderCacheUtil.java
+++ b/hiver-modules/hiver-mall/src/main/java/cc/hiver/mall/utils/UserPendingOrderCacheUtil.java
@@ -63,16 +63,16 @@ public class UserPendingOrderCacheUtil {
*/
public void put(String userId, MallOrderVO orderVO) {
if (StringUtils.isBlank(userId) || orderVO == null || StringUtils.isBlank(orderVO.getId())) {
- log.warn("UserPendingOrderCacheUtil.put 鍙傛暟鏃犳晥, userId={}, orderVO={}", userId, orderVO);
+ log.info("UserPendingOrderCacheUtil.put 鍙傛暟鏃犳晥, userId={}, orderVO={}", userId, orderVO);
return;
}
try {
String key = buildKey(userId);
String json = JSONUtil.toJsonStr(orderVO);
redisTemplateHelper.hPut(key, orderVO.getId(), json);
- log.debug("缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗: userId={}, orderId={}", userId, orderVO.getId());
+ log.info("缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗: userId={}, orderId={}", userId, orderVO.getId());
} catch (Exception e) {
- log.error("缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗曞け璐: userId={}, orderId={}", userId, orderVO.getId(), e);
+ log.info("缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗曞け璐: userId={}, orderId={}", userId, orderVO.getId(), e);
}
}
@@ -96,10 +96,10 @@ public class UserPendingOrderCacheUtil {
}
if (!map.isEmpty()) {
redisTemplateHelper.hPutAll(key, map);
- log.debug("鎵归噺缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗: userId={}, count={}", userId, map.size());
+ log.info("鎵归噺缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗: userId={}, count={}", userId, map.size());
}
} catch (Exception e) {
- log.error("鎵归噺缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗曞け璐: userId={}", userId, e);
+ log.info("鎵归噺缂撳瓨鐢ㄦ埛寰呭畬鎴愯鍗曞け璐: userId={}", userId, e);
}
}
@@ -117,15 +117,15 @@ public class UserPendingOrderCacheUtil {
*/
public void remove(String userId, String orderId) {
if (StringUtils.isBlank(userId) || StringUtils.isBlank(orderId)) {
- log.warn("UserPendingOrderCacheUtil.remove 鍙傛暟鏃犳晥, userId={}, orderId={}", userId, orderId);
+ log.info("UserPendingOrderCacheUtil.remove 鍙傛暟鏃犳晥, userId={}, orderId={}", userId, orderId);
return;
}
try {
String key = buildKey(userId);
redisTemplateHelper.hDelete(key, orderId);
- log.debug("鍒犻櫎鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛: userId={}, orderId={}", userId, orderId);
+ log.info("鍒犻櫎鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛: userId={}, orderId={}", userId, orderId);
} catch (Exception e) {
- log.error("鍒犻櫎鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}, orderId={}", userId, orderId, e);
+ log.info("鍒犻櫎鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}, orderId={}", userId, orderId, e);
}
}
@@ -142,9 +142,9 @@ public class UserPendingOrderCacheUtil {
}
try {
redisTemplateHelper.delete(buildKey(userId));
- log.debug("娓呴櫎鐢ㄦ埛鍏ㄩ儴寰呭畬鎴愯鍗曠紦瀛: userId={}", userId);
+ log.info("娓呴櫎鐢ㄦ埛鍏ㄩ儴寰呭畬鎴愯鍗曠紦瀛: userId={}", userId);
} catch (Exception e) {
- log.error("娓呴櫎鐢ㄦ埛鍏ㄩ儴寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}", userId, e);
+ log.info("娓呴櫎鐢ㄦ埛鍏ㄩ儴寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}", userId, e);
}
}
@@ -163,23 +163,23 @@ public class UserPendingOrderCacheUtil {
*/
public void update(String userId, MallOrderVO orderVO) {
if (StringUtils.isBlank(userId) || orderVO == null || StringUtils.isBlank(orderVO.getId())) {
- log.warn("UserPendingOrderCacheUtil.update 鍙傛暟鏃犳晥, userId={}, orderVO={}", userId, orderVO);
+ log.info("UserPendingOrderCacheUtil.update 鍙傛暟鏃犳晥, userId={}, orderVO={}", userId, orderVO);
return;
}
try {
// 濡傛灉璁㈠崟鐘舵佸凡涓嶅睘浜庡緟瀹屾垚锛岀洿鎺ュ垹闄
if (isTerminalStatus(orderVO.getStatus())) {
remove(userId, orderVO.getId());
- log.debug("璁㈠崟宸茬粓鎬侊紝浠庣紦瀛樼Щ闄: userId={}, orderId={}, status={}",
+ log.info("璁㈠崟宸茬粓鎬侊紝浠庣紦瀛樼Щ闄: userId={}, orderId={}, status={}",
userId, orderVO.getId(), orderVO.getStatus());
return;
}
// 鍚﹀垯瑕嗙洊鏇存柊
put(userId, orderVO);
- log.debug("鏇存柊鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛: userId={}, orderId={}, status={}",
+ log.info("鏇存柊鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛: userId={}, orderId={}, status={}",
userId, orderVO.getId(), orderVO.getStatus());
} catch (Exception e) {
- log.error("鏇存柊鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}, orderId={}", userId, orderVO.getId(), e);
+ log.info("鏇存柊鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}, orderId={}", userId, orderVO.getId(), e);
}
}
@@ -211,7 +211,7 @@ public class UserPendingOrderCacheUtil {
}
return result;
} catch (Exception e) {
- log.error("鑾峰彇鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}", userId, e);
+ log.info("鑾峰彇鐢ㄦ埛寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}", userId, e);
return null;
}
}
@@ -235,7 +235,7 @@ public class UserPendingOrderCacheUtil {
}
return JSONUtil.toBean(value.toString(), MallOrderVO.class);
} catch (Exception e) {
- log.error("鑾峰彇鐢ㄦ埛鍗曚釜寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}, orderId={}", userId, orderId, e);
+ log.info("鑾峰彇鐢ㄦ埛鍗曚釜寰呭畬鎴愯鍗曠紦瀛樺け璐: userId={}, orderId={}", userId, orderId, e);
return null;
}
}
diff --git a/hiver-modules/hiver-mall/src/main/resources/mapper/CommentMapper.xml b/hiver-modules/hiver-mall/src/main/resources/mapper/CommentMapper.xml
index 901853fa..c40e1805 100644
--- a/hiver-modules/hiver-mall/src/main/resources/mapper/CommentMapper.xml
+++ b/hiver-modules/hiver-mall/src/main/resources/mapper/CommentMapper.xml
@@ -60,7 +60,7 @@
delete from t_comment
- where order_id = #{orderId,jdbcType=VARCHAR}
+ where id = #{orderId,jdbcType=VARCHAR}
diff --git a/hiver-modules/hiver-mall/src/main/resources/mapper/MallOrderMapper.xml b/hiver-modules/hiver-mall/src/main/resources/mapper/MallOrderMapper.xml
index 2806a4b4..e43e99a8 100644
--- a/hiver-modules/hiver-mall/src/main/resources/mapper/MallOrderMapper.xml
+++ b/hiver-modules/hiver-mall/src/main/resources/mapper/MallOrderMapper.xml
@@ -53,6 +53,14 @@
GROUP BY counttype
+
+