From 8c0b5b30e5200e7bd45aa34507c3623e17fcce91 Mon Sep 17 00:00:00 2001
From: lidongdong <1459917685@qq.com>
Date: 星期四, 24 八月 2023 13:47:24 +0800
Subject: [PATCH] 新增小程序积分列表  修改积分发放流程

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerOrderServiceImpl.java |   24 +++++++++++++-----------
 1 files changed, 13 insertions(+), 11 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerOrderServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerOrderServiceImpl.java
index 8b4909d..89eab55 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerOrderServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerOrderServiceImpl.java
@@ -37,6 +37,7 @@
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
+import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -342,15 +343,12 @@
             log.error("调用微信支付异常,异常原因:" + e.getMessage());
         }
         //发送消息到mq
-        rabbitTemplate.convertAndSend(RabbitmqConfig.SHOP_ORDER_EXCHANGE, RabbitmqConfig.SHOP_ORDER_ROUTING_KEY, shopOrderVO, message -> {
-            message.getMessageProperties().setHeader("x-delay", 60*1000);
+        rabbitTemplate.convertAndSend("huacheng.shop.order.exchange", "huacheng.shop.order.key", shopOrderVO, message -> {
+            //30分钟后
+            message.getMessageProperties().setHeader("x-delay", 1800*1000);
             return message;
         });
         return R.ok(shopOrderVO);
-    }
-
-    private Long dateToSecond(Date expireTime){
-        return DateUtil.between(new Date(),expireTime, DateUnit.MS);
     }
 
     /**
@@ -709,10 +707,12 @@
             comShopFlowerOrderOperateDAO.insert(orderOperateDO);
 
             //一个自提订单算一个货
-            ConvenientElevatingPointDO convenientElevatingPointDO = convenientElevatingPointDAO.selectById(shopOrderDO.getPointId());
-            convenientElevatingPointDO.setPrepareGoodsNum(convenientElevatingPointDO.getPrepareGoodsNum() - 1);
-            convenientElevatingPointDO.setAlreadyGoodsNum(convenientElevatingPointDO.getAlreadyGoodsNum() + 1);
-            convenientElevatingPointDAO.updateById(convenientElevatingPointDO);
+            if (ComShopFlowerOrderDO.deliveryType.store == shopOrderDO.getDeliveryType()){
+                ConvenientElevatingPointDO convenientElevatingPointDO = convenientElevatingPointDAO.selectById(shopOrderDO.getPointId());
+                convenientElevatingPointDO.setPrepareGoodsNum(convenientElevatingPointDO.getPrepareGoodsNum() - 1);
+                convenientElevatingPointDO.setAlreadyGoodsNum(convenientElevatingPointDO.getAlreadyGoodsNum() + 1);
+                convenientElevatingPointDAO.updateById(convenientElevatingPointDO);
+            }
             return R.ok();
         } else {
             return R.fail("确认收货失败");
@@ -971,9 +971,11 @@
             if (R.isOk(sysUserVOR)) {
                 SysUserVO sysUserVO = JSONObject.parseObject(JSONObject.toJSONString(sysUserVOR.getData()), SysUserVO.class);
                 try {
+                    DecimalFormat df = new DecimalFormat("#.00");
                     WxUtil.sendNewOrderNotice(sysUserVO.getOpenid(),maService.getAccessToken(),shopOrderDO.getOrderNo(),
                             shopOrderDO.getDeliveryType()==1?"拼单订单":"快递订单",orderGoodsList.get(0).getGoodsName(),
-                            shopOrderDO.getTotalAmount().toString(),DateUtil.format(shopOrderDO.getCreateAt(),"yyyy-MM-dd HH:mm"));
+                            df.format(shopOrderDO.getTotalAmount()),
+                            DateUtil.format(shopOrderDO.getCreateAt(),"yyyy-MM-dd HH:mm"));
                 } catch (WxErrorException e) {
                     e.printStackTrace();
                 }

--
Gitblit v1.7.1