记得上下班打卡 | git大法好,push需谨慎

Commit 8338ffdf authored by zhengfuxin's avatar zhengfuxin

修改bug

parent 202c8fee
...@@ -241,7 +241,7 @@ public class MQConst { ...@@ -241,7 +241,7 @@ public class MQConst {
GOBLIN_STORE_MARKET("goblin:stream:store.market", "group.store.market", "店铺活动"), GOBLIN_STORE_MARKET("goblin:stream:store.market", "group.store.market", "店铺活动"),
GOBLIN_SELF_MARKET("goblin:stream:self.market", "group.self.market", "平台活动"), GOBLIN_SELF_MARKET("goblin:stream:self.market", "group.self.market", "平台活动"),
GOBLIN_ORDER_CREATE_PAY("goblin:stream:order:create_pay", "group.order:create_pay", "订单创建&支付"), GOBLIN_ORDER_CREATE_PAY("goblin:stream:order:create_pay", "group.order:create_pay", "订单创建&支付"),
GOBLIN_SHOP_CART("goblin:stream:shopcart","group.shop:shopcart","购物车"), GOBLIN_SHOP_CART("goblin:stream:sql.shopcart","group.shop.shopcart","购物车"),
GOBLIN_ORDER_AGAIN("goblin:stream:order:again", "group.order:again", "订单再次支付"), GOBLIN_ORDER_AGAIN("goblin:stream:order:again", "group.order:again", "订单再次支付"),
GOBLIN_ORDER_CLOSE("goblin:stream:order:close", "group.order:close", "订单关闭"), GOBLIN_ORDER_CLOSE("goblin:stream:order:close", "group.order:close", "订单关闭"),
GOBLIN_STORE_ORDER_OPERA("goblin:stream:order:store", "group.order:store", "商铺订单操作"), GOBLIN_STORE_ORDER_OPERA("goblin:stream:order:store", "group.order:store", "商铺订单操作"),
......
...@@ -24,5 +24,5 @@ XADD goblin:stream:order:store * 0 0 ...@@ -24,5 +24,5 @@ XADD goblin:stream:order:store * 0 0
XGROUP CREATE goblin:stream:order:store group.order:store 0 XGROUP CREATE goblin:stream:order:store group.order:store 0
#---- # #---- #
#---- 购物车 #---- 购物车
XADD goblin:stream:shopcart * 0 0 XADD goblin:stream:sql.shopcart * 0 0
XGROUP CREATE goblin:stream:shopcart group.shop:shopcart 0 XGROUP CREATE goblin:stream:sql.shopcart group.shop.shopcart 0
\ No newline at end of file \ No newline at end of file
...@@ -225,7 +225,16 @@ public class GoblinFrontServiceImpl implements GoblinFrontService { ...@@ -225,7 +225,16 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
GoblinFrontGoodDetailVo goblinFrontGoodDetailVo=GoblinFrontGoodDetailVo.getNew(); GoblinFrontGoodDetailVo goblinFrontGoodDetailVo=GoblinFrontGoodDetailVo.getNew();
GoblinGoodsInfoVo goblinGoodsInfoVo=goblinRedisUtils.getGoodsInfoVo(spuId); GoblinGoodsInfoVo goblinGoodsInfoVo=goblinRedisUtils.getGoodsInfoVo(spuId);
goblinFrontGoodDetailVo.setGoblinGoodsInfoVo(goblinGoodsInfoVo); goblinFrontGoodDetailVo.setGoblinGoodsInfoVo(goblinGoodsInfoVo);
//skuIdList
if(null!=goblinGoodsInfoVo){
List<String> skuIdList=goblinGoodsInfoVo.getSkuIdList();
ArrayList<GoblinGoodsSkuInfoVo> list=ObjectUtil.getGoblinGoodsSkuInfoVoArrayList();
for(String sku:skuIdList){
GoblinGoodsSkuInfoVo goblinGoodsSkuInfoVo=goblinRedisUtils.getGoodsSkuInfoVo(sku);
list.add(goblinGoodsSkuInfoVo);
}
goblinFrontGoodDetailVo.setGoblinGoodsSkuInfoVolist(list);
}
return goblinFrontGoodDetailVo; return goblinFrontGoodDetailVo;
} }
/** /**
...@@ -552,6 +561,15 @@ public class GoblinFrontServiceImpl implements GoblinFrontService { ...@@ -552,6 +561,15 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_SHOP_CART.getKey(), sqlDatas); queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_SHOP_CART.getKey(), sqlDatas);
log.info("发送购物车消息队列完毕"); log.info("发送购物车消息队列完毕");
} }
public void insertShopCartMysql(String carId ,String spuId, String storeId,String skuId,Integer number,String userId){
LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("goblin_shop.cart.insert"));
LinkedList<Object[]> sqlData = CollectionUtil.linkedListObjectArr();
sqlData.add(new Object[]{
//(car_id, user_id, store_id,spu_id, sku_id, `number`,marketing_id, del_tag, created_at,updated_at, `comment`)
carId,userId,storeId,spuId,skuId,1,"",0,
});
}
//删除 //删除
public void deleteMysql(String userId,String[] skuIds){ public void deleteMysql(String userId,String[] skuIds){
//mysql 删除 按照 userid 、skuid //mysql 删除 按照 userid 、skuid
......
...@@ -65,4 +65,4 @@ goblin_order.store.refundSkuPrice=UPDATE goblin_order_sku SET price_refund = ? , ...@@ -65,4 +65,4 @@ goblin_order.store.refundSkuPrice=UPDATE goblin_order_sku SET price_refund = ? ,
goblin_order.store.refundBackOrder=UPDATE goblin_back_order SET status = ? , updated_at = ? WHERE back_order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null) goblin_order.store.refundBackOrder=UPDATE goblin_back_order SET status = ? , updated_at = ? WHERE back_order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
#---- 购物车操作 #---- 购物车操作
goblin_shop.cart.delete = UPDATE goblin_shopping_cart set user_id=? and sku_id=? and del_tag=? goblin_shop.cart.delete = UPDATE goblin_shopping_cart set user_id=? and sku_id=? and del_tag=?
goblin_shop.cart.insert = insert into goblin_shopping_cart (car_id, user_id, store_id,spu_id, sku_id, `number`,marketing_id, del_tag, created_at,updated_at, `comment`) values (?,?,?,?,?,?,?,?,?,?,?) goblin_shop.cart.insert = insert into goblin_shopping_cart (car_id, user_id, store_id,spu_id, sku_id, `number`,marketing_id, del_tag, `comment`) values (?,?,?,?,?,?,?,?,?)
\ No newline at end of file \ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment