更新了商品类别

pom.xml

@@ -164,18 +164,27 @@
             <version>1.2.62</version>
         </dependency>
 
+
+
+
 <!--        配置注解处理器-->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-configuration-processor</artifactId>
             <optional>true</optional>
         </dependency>
-
+<!--      redis -->
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
             <version>5.2.0</version>
         </dependency>
+<!--        Gson-->
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.8.8</version>
+        </dependency>
 
 
 

src/main/java/com/cultural/heritage/config/WxAccessToken.java

@@ -0,0 +1,31 @@
+package com.cultural.heritage.config;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * 微信小程序获取token响应体
+ */
+@Configuration
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class WxAccessToken implements Serializable {
+
+    @Schema(description = "获取到的凭证")
+    private String access_token;
+
+    @Schema(description = "凭证有效时间，单位：秒。目前是7200秒之内的值。")
+    private String expires_in;
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/cultural/heritage/config/WxWaybillToken.java

@@ -0,0 +1,35 @@
+package com.cultural.heritage.config;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+
+/**
+ * 微信小程序获取waybillToken响应体
+ */
+@Configuration
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class WxWaybillToken implements Serializable {
+
+    @Schema(description = "返回码")
+    private Integer errcode;
+
+    @Schema(description = "错误信息")
+    private String errmsg;
+
+    @Schema(description = "物流查询id")
+    private String waybill_token;
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/cultural/heritage/controller/order/OrderController.java

@@ -67,6 +67,8 @@ public class OrderController {
     private CartRecordService cartRecordService;
 
 
+
+
     @Resource
     private GoodService goodService;
 

src/main/java/com/cultural/heritage/controller/wx/WeChatLogisticsController.java

@@ -0,0 +1,148 @@
+package com.cultural.heritage.controller.wx;
+
+
+import cn.hutool.http.HttpUtil;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.cultural.heritage.common.BaseResponse;
+import com.cultural.heritage.common.ErrorCode;
+import com.cultural.heritage.common.ResultUtils;
+import com.cultural.heritage.config.WxAccessToken;
+import com.cultural.heritage.config.WxWaybillToken;
+import com.cultural.heritage.exception.BusinessException;
+import com.cultural.heritage.exception.ThrowUtils;
+import com.cultural.heritage.model.dto.CommonRequest;
+import com.cultural.heritage.model.dto.snapshot.AddressSnapshot;
+import com.cultural.heritage.model.dto.snapshot.GoodSnapshot;
+import com.cultural.heritage.model.entity.Order;
+import com.cultural.heritage.model.entity.OrderItems;
+import com.cultural.heritage.model.entity.User;
+import com.cultural.heritage.model.vo.good.GoodLogisticsInfoVO;
+import com.cultural.heritage.model.vo.good.GoodsInfo;
+import com.cultural.heritage.service.order.OrderItemService;
+import com.cultural.heritage.service.order.OrderService;
+import com.cultural.heritage.service.user.UserService;
+import com.cultural.heritage.service.wx.WeChatLogisticsService;
+import com.google.gson.Gson;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.annotation.Resource;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.web.bind.annotation.*;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 微信小程序查看物流相关接口
+ **/
+@Slf4j
+@RestController
+@Tag(name = "微信物流接口")
+@RequestMapping("/logistics")
+public class WeChatLogisticsController {
+
+
+    private final static String ACCESS_TOKEN_KEY = "accessToken";
+
+
+    @Resource
+    private UserService userService;
+
+
+    @Resource
+    private WeChatLogisticsService weChatLogisticsService;
+
+
+    @Resource
+    private RedisTemplate redisTemplate;
+
+
+    @Resource
+    private Gson gson;
+
+
+    @Resource
+    private OrderService orderService;
+
+
+    @Resource
+    private OrderItemService orderItemService;
+
+
+    /**
+     * (小程序端)获取接口调用凭据
+     *
+     * @param request
+     */
+    @GetMapping("/get/token")
+    @Operation(summary = "(小程序端)微信小程序获取接口调用凭据", description = "参数：无, 权限：所有人, 方法名：getAccessToken")
+    public BaseResponse<WxAccessToken> getAccessToken(HttpServletRequest request) {
+        userService.getLoginUser(request);
+        String accessToken = (String) redisTemplate.opsForValue().get(ACCESS_TOKEN_KEY);
+        if (accessToken == null) {
+            weChatLogisticsService.addAccessToken();
+            accessToken = (String) redisTemplate.opsForValue().get(ACCESS_TOKEN_KEY);
+        }
+        WxAccessToken wxAccessToken = WxAccessToken.builder()
+                .access_token(accessToken)
+                .expires_in("7200").build();
+        return ResultUtils.success(wxAccessToken);
+    }
+
+
+    /**
+     * (小程序端)根据订单id查询物流信息
+     */
+    @PostMapping("/get/info")
+    @Operation(summary = "(小程序端)微信小程序获取接口调用凭据", description = "参数：无, 权限：所有人, 方法名：getAccessToken")
+    public BaseResponse<WxWaybillToken> getWaybillToken(@RequestBody CommonRequest commonRequest, HttpServletRequest request) throws IOException {
+        if (commonRequest == null || commonRequest.getId() <= 0) {
+            throw new BusinessException(ErrorCode.PARAMS_ERROR);
+        }
+        User loginUser = userService.getLoginUser(request);
+        String miniOpenId = loginUser.getMiniOpenId();
+        String accessToken = (String) redisTemplate.opsForValue().get(ACCESS_TOKEN_KEY);
+        if (accessToken == null) {
+            weChatLogisticsService.addAccessToken();
+            accessToken = (String) redisTemplate.opsForValue().get(ACCESS_TOKEN_KEY);
+        }
+        Long id = commonRequest.getId();
+        Order order = orderService.getById(id);
+        ThrowUtils.throwIf(order == null, ErrorCode.SYSTEM_ERROR, "订单不存在");
+        String trackingNumber = order.getTrackingNumber();
+        AddressSnapshot addressSnapshot = order.getAddressSnapshot();
+        String phone = addressSnapshot.getPhone();
+        QueryWrapper<OrderItems> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("orderId", id);
+        List<OrderItems> orderItemsList = orderItemService.list(queryWrapper);
+        List<GoodLogisticsInfoVO> goodLogisticsInfoVOS = orderItemsList.stream().map(orderItems -> {
+            GoodSnapshot goodSnapshot = orderItems.getGoodSnapshot();
+            String name = goodSnapshot.getName();
+            String goodImg = goodSnapshot.getGoodImg();
+            return GoodLogisticsInfoVO.builder().goods_name(name).goods_img_url(goodImg).build();
+        }).toList();
+        GoodsInfo goodsInfo = GoodsInfo.builder().detail_list(goodLogisticsInfoVOS).build();
+        Map<String, Object> param = new HashMap<>();
+        param.put("openid", miniOpenId);
+        param.put("waybill_id", trackingNumber);
+        param.put("receiver_phone", phone);
+        param.put("goods_info", goodsInfo);
+        String url = "https://api.weixin.qq.com/cgi-bin/express/delivery/open_msg/trace_waybill?access_token=" + accessToken;
+
+        String jsonParams = JSONUtil.toJsonStr(param);
+        String response = HttpUtil.createPost(url)
+                .header("Content-Type", "application/json")
+                .body(jsonParams)
+                .execute()
+                .body();
+
+        WxWaybillToken wxWaybillToken = gson.fromJson(response, WxWaybillToken.class);
+        return ResultUtils.success(wxWaybillToken);
+    }
+
+}

src/main/java/com/cultural/heritage/controller/wx/WeChatPayController.java

@@ -14,7 +14,7 @@ import com.cultural.heritage.model.entity.Order;
 import com.cultural.heritage.model.entity.User;
 import com.cultural.heritage.service.order.OrderService;
 import com.cultural.heritage.service.user.UserService;
-import com.cultural.heritage.service.wxpay.WeChatService;
+import com.cultural.heritage.service.wx.WeChatService;
 import com.wechat.pay.java.service.payments.jsapi.model.PrepayWithRequestPaymentResponse;
 import com.wechat.pay.java.service.payments.model.Transaction;
 import com.wechat.pay.java.service.refund.model.Refund;

src/main/java/com/cultural/heritage/model/vo/good/GoodLogisticsInfoVO.java

@@ -0,0 +1,32 @@
+package com.cultural.heritage.model.vo.good;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class GoodLogisticsInfoVO implements Serializable {
+
+    /**
+     * 商品名
+     */
+    private String goods_name;
+
+
+    /**
+     * 商品图片
+     */
+    private String goods_img_url;
+
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/cultural/heritage/model/vo/good/GoodsInfo.java

@@ -0,0 +1,27 @@
+package com.cultural.heritage.model.vo.good;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.List;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class GoodsInfo implements Serializable {
+
+
+    /**
+     * 物流信息商品列表
+     */
+    private List<GoodLogisticsInfoVO> detail_list;
+
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/cultural/heritage/service/wx/WeChatLogisticsService.java

@@ -0,0 +1,19 @@
+package com.cultural.heritage.service.wx;
+
+import com.cultural.heritage.config.WxAccessToken;
+
+public interface WeChatLogisticsService {
+
+    /**
+     * 获取微信token
+     */
+    WxAccessToken getAccessToken();
+
+
+    /**
+     * 两小时内重新获取token
+     */
+    void addAccessToken();
+
+
+}

src/main/java/com/cultural/heritage/service/wx/WeChatService.java

@@ -1,4 +1,4 @@
-package com.cultural.heritage.service.wxpay;
+package com.cultural.heritage.service.wx;
 
 
 import com.wechat.pay.java.service.payments.jsapi.model.PrepayWithRequestPaymentResponse;

src/main/java/com/cultural/heritage/service/wx/impl/WeChatLogisticsServiceImpl.java

@@ -0,0 +1,71 @@
+package com.cultural.heritage.service.wx.impl;
+
+import cn.hutool.http.HttpUtil;
+import com.cultural.heritage.config.WxAccessToken;
+import com.cultural.heritage.service.wx.WeChatLogisticsService;
+import com.google.gson.Gson;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+@Service
+public class WeChatLogisticsServiceImpl implements WeChatLogisticsService {
+
+
+    private final static String ACCESS_TOKEN_KEY = "accessToken";
+
+    Logger logger = LoggerFactory.getLogger(WeChatLogisticsService.class);
+
+    @Resource
+    private RedisTemplate redisTemplate;
+
+    @Resource
+    private Gson gson;
+
+
+    @Schema(description = "小程序 appId")
+    @Value("${wx.mini.appId}")
+    private String appId;
+
+    @Schema(description = "小程序 appSecret")
+    @Value("${wx.mini.appSecret}")
+    private String appSecret;
+
+
+    /**
+     * 获取微信token
+     */
+    @Override
+    public WxAccessToken getAccessToken() {
+        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appId + "&secret=" + appSecret;
+        String jsonString = null;
+        try {
+            jsonString = HttpUtil.get(url);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return gson.fromJson(jsonString, WxAccessToken.class);
+    }
+
+
+    /**
+     * 两小时内重新获取token
+     */
+    @Scheduled(fixedDelay = 7080000)
+    @Override
+    public void addAccessToken() {
+        String accessToken = getAccessToken().getAccess_token();
+        logger.info("定时任务启用===========" + accessToken);
+        //微信token2小时过期,每2小时重新获得一次
+        redisTemplate.opsForValue().set(ACCESS_TOKEN_KEY, accessToken, 7200, TimeUnit.SECONDS);
+    }
+}

src/main/java/com/cultural/heritage/service/wx/impl/WeChatServiceImpl.java

@@ -1,4 +1,4 @@
-package com.cultural.heritage.service.wxpay.impl;
+package com.cultural.heritage.service.wx.impl;
 
 
 import cn.binarywang.wx.miniapp.api.WxMaMsgService;
@@ -19,7 +19,7 @@ import com.cultural.heritage.model.entity.OrderItems;
 import com.cultural.heritage.service.good.GoodService;
 import com.cultural.heritage.service.order.OrderItemService;
 import com.cultural.heritage.service.order.OrderService;
-import com.cultural.heritage.service.wxpay.WeChatService;
+import com.cultural.heritage.service.wx.WeChatService;
 import com.wechat.pay.java.core.notification.NotificationParser;
 import com.wechat.pay.java.core.notification.RequestParam;
 import com.wechat.pay.java.service.payments.jsapi.model.Amount;