diff --git a/src/main/java/com/cultural/heritage/config/RedisConfig.java b/src/main/java/com/cultural/heritage/config/RedisConfig.java index 4f36d39..d2b7d42 100644 --- a/src/main/java/com/cultural/heritage/config/RedisConfig.java +++ b/src/main/java/com/cultural/heritage/config/RedisConfig.java @@ -1,6 +1,7 @@ package com.cultural.heritage.config; +import com.cultural.heritage.model.entity.Clothes; import com.cultural.heritage.model.entity.Festival; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -39,4 +40,17 @@ public class RedisConfig { return redisTemplate; } + + @Bean + public RedisTemplate clothesRedisTemplate(RedisConnectionFactory factory) { + RedisTemplate redisTemplate = new RedisTemplate<>(); + redisTemplate.setConnectionFactory(factory); + + // 配置序列化器 + Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer<>(Clothes.class); + redisTemplate.setValueSerializer(serializer); + redisTemplate.setKeySerializer(new StringRedisSerializer()); + return redisTemplate; + } + } diff --git a/src/main/java/com/cultural/heritage/constant/FileConstant.java b/src/main/java/com/cultural/heritage/constant/FileConstant.java index 8cf5a1c..1b60bf3 100644 --- a/src/main/java/com/cultural/heritage/constant/FileConstant.java +++ b/src/main/java/com/cultural/heritage/constant/FileConstant.java @@ -8,7 +8,7 @@ public interface FileConstant { // String SERVER_HOST = "http://123.249.108.160:8888/api/file/downloadFile?objectKey="; -// String SERVER_HOST = "https://www.carboner.cn:8888/api/file/downloadFile?objectKey="; + String SERVER_HOST = "https://www.carboner.cn:8888/api/file/downloadFile?objectKey="; // 公众号文章路径 diff --git a/src/main/java/com/cultural/heritage/controller/clothes/ClothesController.java b/src/main/java/com/cultural/heritage/controller/clothes/ClothesController.java index 739d100..d03d050 100644 --- a/src/main/java/com/cultural/heritage/controller/clothes/ClothesController.java +++ b/src/main/java/com/cultural/heritage/controller/clothes/ClothesController.java @@ -28,12 +28,14 @@ import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.util.List; +import java.util.concurrent.TimeUnit; @RestController @RequestMapping("/clothes") @@ -49,6 +51,14 @@ public class ClothesController { private CommonService commonService; + @Resource + private RedisTemplate clothesRedisTemplate; + + + private static final String CLOTHES_KEY = "clothes:"; + + + /** * Web端管理员添加服装租赁产品 * @param clothesAddRequest 服装租赁产品添加请求体 @@ -66,6 +76,11 @@ public class ClothesController { clothesService.validClothes(clothes, false); boolean save = clothesService.save(clothes); ThrowUtils.throwIf(!save, ErrorCode.OPERATION_ERROR, "服装租赁产品添加失败"); + + // 缓存商品详情到 Redis + String clothesCacheKey = CLOTHES_KEY + clothes.getId(); + clothesRedisTemplate.opsForValue().set(clothesCacheKey, clothes, 1, TimeUnit.HOURS); // 缓存商品详情，1小时 + return ResultUtils.success(clothes.getId()); } @@ -89,6 +104,10 @@ public class ClothesController { boolean result = clothesService.updateById(clothes); ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "服装租赁产品更新失败"); + // 清除 Redis 缓存 + String cacheKey = CLOTHES_KEY + clothes.getId(); + clothesRedisTemplate.delete(cacheKey); + return ResultUtils.success(true); } @@ -107,6 +126,11 @@ public class ClothesController { } boolean result = clothesService.removeById(commonRequest.getId()); ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "服装租赁产品删除失败"); + + // 删除缓存中的相应数据 + String cacheKey = CLOTHES_KEY + commonRequest.getId(); + clothesRedisTemplate.delete(cacheKey); + return ResultUtils.success(true); } @@ -134,8 +158,23 @@ public class ClothesController { @PostMapping("/get/id") @Operation(summary = "小程序端用户根据id查询服装", description = "参数：服装id，权限：所有人，方法名：getClothesById") public BaseResponse getClothesById(@RequestBody CommonRequest commonRequest) { - if (commonRequest == null) throw new BusinessException(ErrorCode.PARAMS_ERROR); - return ResultUtils.success(clothesService.getClothesById(commonRequest.getId())); + if (commonRequest == null || commonRequest.getId() <= 0) throw new BusinessException(ErrorCode.PARAMS_ERROR); + Long id = commonRequest.getId(); + // Redis缓存的key + String cacheKey = CLOTHES_KEY + id; + // 先从Redis中获取商品信息 + ClothesVO clothesVO; + Clothes clothes = clothesRedisTemplate.opsForValue().get(cacheKey); + // 如果缓存命中，直接返回 + if (clothes != null) { + clothesVO = commonService.copyProperties(clothes, ClothesVO.class); + System.out.println("走缓存"); + return ResultUtils.success(clothesVO); + } + Clothes clothesInfo = clothesService.getClothesInfoById(id); + clothesRedisTemplate.opsForValue().set(cacheKey, clothesInfo, 1, TimeUnit.HOURS); // 缓存1小时 + clothesVO = commonService.copyProperties(clothesInfo, ClothesVO.class); + return ResultUtils.success(clothesVO); } @@ -146,11 +185,22 @@ public class ClothesController { @PostMapping("/get/label/id") @Operation(summary = "小程序端用户根据id查询服装（不包含富文本）", description = "参数：服装id，权限：所有人，方法名：getClothesLabelById") public BaseResponse getClothesLabelById(@RequestBody CommonRequest commonRequest) { - if (commonRequest == null) throw new BusinessException(ErrorCode.PARAMS_ERROR); + if (commonRequest == null || commonRequest.getId() <= 0) throw new BusinessException(ErrorCode.PARAMS_ERROR); Long id = commonRequest.getId(); - Clothes clothes = clothesService.getById(id); - ThrowUtils.throwIf(clothes == null, ErrorCode.OPERATION_ERROR, "服装不存在"); - ClothesLabelVO clothesLabelVO = commonService.copyProperties(clothes, ClothesLabelVO.class); + // Redis缓存的key + String cacheKey = CLOTHES_KEY + id; + // 先从Redis中获取商品信息 + ClothesLabelVO clothesLabelVO; + Clothes clothes = clothesRedisTemplate.opsForValue().get(cacheKey); + // 如果缓存命中，直接返回 + if (clothes != null) { + clothesLabelVO = commonService.copyProperties(clothes, ClothesLabelVO.class); + System.out.println("走缓存"); + return ResultUtils.success(clothesLabelVO); + } + Clothes clothesInfo = clothesService.getClothesInfoById(id); + clothesRedisTemplate.opsForValue().set(cacheKey, clothesInfo, 1, TimeUnit.HOURS); // 缓存1小时 + clothesLabelVO = commonService.copyProperties(clothesInfo, ClothesLabelVO.class); return ResultUtils.success(clothesLabelVO); } @@ -208,6 +258,12 @@ public class ClothesController { boolean result = clothesService.removeBatchByIds(idList); ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "服装批量删除失败"); + // 批量删除缓存中的数据 + for (Long id : idList) { + String cacheKey = CLOTHES_KEY + id; + clothesRedisTemplate.delete(cacheKey); // 删除每个服装的缓存 + } + return ResultUtils.success(true); } @@ -236,10 +292,77 @@ public class ClothesController { updateWrapper.set("isShelves", status); boolean update = clothesService.update(updateWrapper); ThrowUtils.throwIf(!update, ErrorCode.OPERATION_ERROR, "上架状态更新失败"); + return ResultUtils.success(true); } + + + + + + + + + + +// +// // Redis 查询模拟接口 +// @PostMapping("/query/redis") +// public String simulateRedisQuery(@RequestParam int count) throws InterruptedException { +// long startTime = System.currentTimeMillis(); +// +// CountDownLatch latch = new CountDownLatch(count); +// for (int i = 1; i <= count; i++) { +// queryFromRedis(2L, latch); +// } +// latch.await(); // 等待所有线程完成 +// +// long endTime = System.currentTimeMillis(); +// return "Redis Query completed in: " + (endTime - startTime) + " ms"; +// } +// +// // MySQL 查询模拟接口 +// @PostMapping("/query/mysql") +// public String simulateMySQLQuery(@RequestParam int count) throws InterruptedException { +// long startTime = System.currentTimeMillis(); +// +// CountDownLatch latch = new CountDownLatch(count); +// for (int i = 1; i <= count; i++) { +// queryFromMySQL(2L, latch); +// } +// latch.await(); // 等待所有线程完成 +// +// long endTime = System.currentTimeMillis(); +// return "MySQL Query completed in: " + (endTime - startTime) + " ms"; +// } +// +// private static int redisCnt = 0; +// private static int mysqlCnt = 0; +// +// @Async +// public void queryFromRedis(Long id, CountDownLatch latch) { +// String cacheKey = "clothes:" + id; +// Clothes clothes = clothesRedisTemplate.opsForValue().get(cacheKey); +// System.out.println("缓存 ==============》 " + redisCnt ++ ); +// if (clothes == null) { +// clothes = clothesService.getById(id); +// } +// latch.countDown(); // 查询结束，释放计数器 +// } +// +// // 通过 MySQL 获取商品 +// @Async +// public void queryFromMySQL(Long id, CountDownLatch latch) { +// Clothes clothes = clothesService.getById(id); +// System.out.println("缓存 ==============》 " + mysqlCnt ++ ); +// latch.countDown(); // 查询结束，释放计数器 +// } +// + + + } diff --git a/src/main/java/com/cultural/heritage/controller/global/GlobalController.java b/src/main/java/com/cultural/heritage/controller/global/GlobalController.java index 87d149f..83c814f 100644 --- a/src/main/java/com/cultural/heritage/controller/global/GlobalController.java +++ b/src/main/java/com/cultural/heritage/controller/global/GlobalController.java @@ -24,11 +24,13 @@ import com.cultural.heritage.service.good.CategoryService; import com.cultural.heritage.service.good.GoodService; import com.cultural.heritage.service.order.ClothesRentOrderService; import com.cultural.heritage.service.order.OrderService; +import com.cultural.heritage.utils.DecoderUtils; 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 lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.*; @@ -90,6 +92,9 @@ public class GlobalController { // 节日集合的键 private static final String COUPON_PRICER_KEY = "couponPrice"; + // 预约须知的键 + private static final String NOTICE_KEY = "noticeKey"; + /** @@ -327,9 +332,49 @@ public class GlobalController { String couponPrice = (String) redisTemplate.opsForValue().get(COUPON_PRICER_KEY); ThrowUtils.throwIf(couponPrice == null, ErrorCode.OPERATION_ERROR, "参数不存在"); + return ResultUtils.success(new BigDecimal(couponPrice).setScale(2, RoundingMode.HALF_UP)); } + + /** + * web端更新预约须知 + * @return 当前类别的商品列表 + */ + @GetMapping("/update/notice") + @Operation(summary = "web端更新预约须知", description = "参数：无，方法名：updateNotice") + @AuthCheck(mustRole = UserConstant.ADMIN_ROLE) + public BaseResponse updateNotice(@RequestParam String richText) { + + redisTemplate.opsForValue().set(NOTICE_KEY, richText); + + return ResultUtils.success(true); + } + + + + + /** + * 小程序端预约须知 + * @return 当前类别的商品列表 + */ + @GetMapping("/update/notice") + @Operation(summary = "web端更新预约须知", description = "参数：无，方法名：updateNotice") + public BaseResponse queryNotice() { + + String notice = (String) redisTemplate.opsForValue().get(NOTICE_KEY); + ThrowUtils.throwIf(notice == null, ErrorCode.OPERATION_ERROR, "参数不存在"); + try { + if (StringUtils.isNotBlank(notice)) notice = DecoderUtils.decodeText(notice); + } catch (Exception e) { + notice = ""; + } + + return ResultUtils.success(notice); + } + + + } diff --git a/src/main/java/com/cultural/heritage/controller/wx/WeChatLogisticsController.java b/src/main/java/com/cultural/heritage/controller/wx/WeChatLogisticsController.java index aaf0a04..c1f614a 100644 --- a/src/main/java/com/cultural/heritage/controller/wx/WeChatLogisticsController.java +++ b/src/main/java/com/cultural/heritage/controller/wx/WeChatLogisticsController.java @@ -7,8 +7,8 @@ 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.constant.FileConstant; import com.cultural.heritage.exception.BusinessException; import com.cultural.heritage.exception.ThrowUtils; import com.cultural.heritage.model.dto.CommonRequest; @@ -30,7 +30,10 @@ 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 org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; import java.io.IOException; import java.util.HashMap; @@ -59,12 +62,9 @@ public class WeChatLogisticsController { @Resource - private RedisTemplate redisTemplate; + private RedisTemplate redisTemplate; - @Resource - private Gson gson; - @Resource private OrderService orderService; @@ -74,32 +74,33 @@ public class WeChatLogisticsController { private OrderItemService orderItemService; - /** - * (小程序端)获取接口调用凭据 - * - * @param request - */ - @GetMapping("/get/token") - @Operation(summary = "(小程序端)微信小程序获取接口调用凭据", description = "参数：无, 权限：所有人, 方法名：getAccessToken") - public BaseResponse 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); - } + +// /** +// * (小程序端)获取接口调用凭据 +// * +// * @param request +// */ +// @GetMapping("/get/token") +// @Operation(summary = "(小程序端)微信小程序获取接口调用凭据", description = "参数：无, 权限：所有人, 方法名：getAccessToken") +// public BaseResponse 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") + @Operation(summary = "(小程序端)根据订单id查询物流信息", description = "参数：无, 权限：所有人, 方法名：getWaybillToken") public BaseResponse getWaybillToken(@RequestBody CommonRequest commonRequest, HttpServletRequest request) throws IOException { if (commonRequest == null || commonRequest.getId() <= 0) { throw new BusinessException(ErrorCode.PARAMS_ERROR); @@ -107,10 +108,10 @@ public class WeChatLogisticsController { 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); -// } + if (accessToken == null) { + weChatLogisticsService.getAccessToken(); + accessToken = (String) redisTemplate.opsForValue().get(ACCESS_TOKEN_KEY); + } Long id = commonRequest.getId(); Order order = orderService.getById(id); ThrowUtils.throwIf(order == null, ErrorCode.SYSTEM_ERROR, "订单不存在"); @@ -123,7 +124,7 @@ public class WeChatLogisticsController { List goodLogisticsInfoVOS = orderItemsList.stream().map(orderItems -> { GoodSnapshot goodSnapshot = orderItems.getGoodSnapshot(); String name = goodSnapshot.getName(); - String goodImg = goodSnapshot.getGoodImg(); + String goodImg = FileConstant.SERVER_HOST + goodSnapshot.getGoodImg(); return GoodLogisticsInfoVO.builder().goods_name(name).goods_img_url(goodImg).build(); }).toList(); GoodsInfo goodsInfo = GoodsInfo.builder().detail_list(goodLogisticsInfoVOS).build(); @@ -132,6 +133,7 @@ public class WeChatLogisticsController { param.put("waybill_id", trackingNumber); param.put("receiver_phone", phone); param.put("goods_info", goodsInfo); + param.put("order_detail_path", "pages/my-order/myGeneralOrderDetail/myGeneralOrderDetail?id=" + order.getId()); String url = "https://api.weixin.qq.com/cgi-bin/express/delivery/open_msg/trace_waybill?access_token=" + accessToken; String jsonParams = JSONUtil.toJsonStr(param); @@ -140,7 +142,7 @@ public class WeChatLogisticsController { .body(jsonParams) .execute() .body(); - + Gson gson = new Gson(); WxWaybillToken wxWaybillToken = gson.fromJson(response, WxWaybillToken.class); return ResultUtils.success(wxWaybillToken); } diff --git a/src/main/java/com/cultural/heritage/service/clothes/ClothesService.java b/src/main/java/com/cultural/heritage/service/clothes/ClothesService.java index c610d8f..31985d9 100644 --- a/src/main/java/com/cultural/heritage/service/clothes/ClothesService.java +++ b/src/main/java/com/cultural/heritage/service/clothes/ClothesService.java @@ -21,6 +21,14 @@ public interface ClothesService extends IService { QueryWrapper getQueryWrapper(ClothesQueryRequest clothesQueryRequest); - + /** + * 根据id获取服装主要信息 + */ ClothesVO getClothesById(Long id); + + + /** + * 根据id获取所有服装所有信息 + */ + Clothes getClothesInfoById(Long id); } diff --git a/src/main/java/com/cultural/heritage/service/clothes/impl/ClothesServiceImpl.java b/src/main/java/com/cultural/heritage/service/clothes/impl/ClothesServiceImpl.java index 1be9dc7..ff4fa42 100644 --- a/src/main/java/com/cultural/heritage/service/clothes/impl/ClothesServiceImpl.java +++ b/src/main/java/com/cultural/heritage/service/clothes/impl/ClothesServiceImpl.java @@ -88,7 +88,7 @@ public class ClothesServiceImpl extends ServiceImpl impl /** - * 根据服装id查询服装信息 + * 根据id获取服装主要信息 */ public ClothesVO getClothesById(Long id) { if (id == null || id <= 0) { @@ -97,8 +97,31 @@ public class ClothesServiceImpl extends ServiceImpl impl Clothes clothes = this.getById(id); ThrowUtils.throwIf(clothes == null, ErrorCode.OPERATION_ERROR, "服装不存在"); // 处理富文本字段 - if (StringUtils.isNotBlank(clothes.getRichText())) clothes.setRichText(DecoderUtils.decodeText(clothes.getRichText())); + try { + if (StringUtils.isNotBlank(clothes.getRichText())) clothes.setRichText(DecoderUtils.decodeText(clothes.getRichText())); + } catch (Exception e) { + clothes.setRichText(""); + } // 转换为VO对象 return commonService.copyProperties(clothes, ClothesVO.class); } + + + /** + * 根据id获取所有服装所有信息 + */ + @Override + public Clothes getClothesInfoById(Long id) { + if (id == null || id <= 0) { + throw new BusinessException(ErrorCode.PARAMS_ERROR); + } + Clothes clothes = this.getById(id); + ThrowUtils.throwIf(clothes == null, ErrorCode.OPERATION_ERROR, "服装不存在"); + try { + if (StringUtils.isNotBlank(clothes.getRichText())) clothes.setRichText(DecoderUtils.decodeText(clothes.getRichText())); + } catch (Exception e) { + clothes.setRichText(""); + } + return clothes; + } } diff --git a/src/main/java/com/cultural/heritage/service/wx/WeChatLogisticsService.java b/src/main/java/com/cultural/heritage/service/wx/WeChatLogisticsService.java index 1f14be3..676c184 100644 --- a/src/main/java/com/cultural/heritage/service/wx/WeChatLogisticsService.java +++ b/src/main/java/com/cultural/heritage/service/wx/WeChatLogisticsService.java @@ -9,11 +9,16 @@ public interface WeChatLogisticsService { */ WxAccessToken getAccessToken(); +// +// /** +// * 两小时内重新获取token +// */ +// void addAccessToken(); /** - * 两小时内重新获取token + * 获取稳定版接口调用凭据 */ - void addAccessToken(); + WxAccessToken getStableAccessToken(); } diff --git a/src/main/java/com/cultural/heritage/service/wx/impl/WeChatLogisticsServiceImpl.java b/src/main/java/com/cultural/heritage/service/wx/impl/WeChatLogisticsServiceImpl.java index 5628abe..d2fe422 100644 --- a/src/main/java/com/cultural/heritage/service/wx/impl/WeChatLogisticsServiceImpl.java +++ b/src/main/java/com/cultural/heritage/service/wx/impl/WeChatLogisticsServiceImpl.java @@ -1,19 +1,19 @@ package com.cultural.heritage.service.wx.impl; import cn.hutool.http.HttpUtil; +import cn.hutool.json.JSONUtil; 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.HashMap; +import java.util.Map; import java.util.concurrent.TimeUnit; @Slf4j @@ -23,13 +23,8 @@ 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; + private RedisTemplate redisTemplate; @Schema(description = "小程序 appId") @@ -41,31 +36,61 @@ public class WeChatLogisticsServiceImpl implements WeChatLogisticsService { private String appSecret; + /** - * 获取微信token + * 获取稳定版接口调用凭据 + */ + @Override + public WxAccessToken getStableAccessToken() { + Map param = new HashMap<>(); + param.put("grant_type", "client_credential"); + param.put("appid", appId); + param.put("secret", appSecret); + String url = "https://api.weixin.qq.com/cgi-bin/stable_token"; + + String jsonParams = JSONUtil.toJsonStr(param); + String response = HttpUtil.createPost(url) + .header("Content-Type", "application/json") + .body(jsonParams) + .execute() + .body(); + Gson gson = new Gson(); + WxAccessToken wxAccessToken = gson.fromJson(response, WxAccessToken.class); + String access_token = wxAccessToken.getAccess_token(); + redisTemplate.opsForValue().set(ACCESS_TOKEN_KEY, access_token, 7200, TimeUnit.SECONDS); + return wxAccessToken; + } + + + /** + * 获取接口调用凭据 */ @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; + String response = null; try { - jsonString = HttpUtil.get(url); + response = HttpUtil.get(url); } catch (Exception e) { e.printStackTrace(); } - return gson.fromJson(jsonString, WxAccessToken.class); + Gson gson = new Gson(); + WxAccessToken wxAccessToken = gson.fromJson(response, WxAccessToken.class); + String access_token = wxAccessToken.getAccess_token(); + redisTemplate.opsForValue().set(ACCESS_TOKEN_KEY, access_token, 7200, TimeUnit.SECONDS); + return wxAccessToken; } - /** - * 两小时内重新获取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); - } +// /** +// * 两小时内重新获取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); +// } }