admin1/jiangchengfeiyi-houduan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

this is 3.24 update

Browse Source
This commit is contained in:
chen-xin-zhi 2025-03-26 15:37:59 +08:00
parent b2eef9a436
commit ec17b8d35e
9 changed files with 313 additions and 68 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/com/cultural/heritage/config/RedisConfig.java
View File

@ -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<String, Clothes> clothesRedisTemplate(RedisConnectionFactory factory) {
RedisTemplate<String, Clothes> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(factory);
// 配置序列化器
Jackson2JsonRedisSerializer<Clothes> serializer = new Jackson2JsonRedisSerializer<>(Clothes.class);
redisTemplate.setValueSerializer(serializer);
redisTemplate.setKeySerializer(new StringRedisSerializer());
return redisTemplate;
}
}

2
src/main/java/com/cultural/heritage/constant/FileConstant.java
View File

@ -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=";
// 公众号文章路径

135
src/main/java/com/cultural/heritage/controller/clothes/ClothesController.java
View File

@ -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<String, Clothes> 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<ClothesVO> 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<ClothesLabelVO> 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(); // 查询结束，释放计数器
// }
//
}

45
src/main/java/com/cultural/heritage/controller/global/GlobalController.java
View File

@ -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<Boolean> 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<String> 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);
}
}

64
src/main/java/com/cultural/heritage/controller/wx/WeChatLogisticsController.java
View File

@ -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<String, Object> 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<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);
// /**
// * (小程序端)获取接口调用凭据
// *
// * @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);
// }
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<WxWaybillToken> 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<GoodLogisticsInfoVO> 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);
}

10
src/main/java/com/cultural/heritage/service/clothes/ClothesService.java
View File

@ -21,6 +21,14 @@ public interface ClothesService extends IService<Clothes> {
QueryWrapper<Clothes> getQueryWrapper(ClothesQueryRequest clothesQueryRequest);
/**
* 根据id获取服装主要信息
*/
ClothesVO getClothesById(Long id);
/**
* 根据id获取所有服装所有信息
*/
Clothes getClothesInfoById(Long id);
}

25
src/main/java/com/cultural/heritage/service/clothes/impl/ClothesServiceImpl.java
View File

@ -88,7 +88,7 @@ public class ClothesServiceImpl extends ServiceImpl<ClothesMapper, Clothes> impl
/**
* 根据服装id查询服装信息
* 根据id获取服装主要信息
*/
public ClothesVO getClothesById(Long id) {
if (id == null || id <= 0) {
@ -97,8 +97,31 @@ public class ClothesServiceImpl extends ServiceImpl<ClothesMapper, Clothes> impl
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("");
}
// 转换为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;
}
}

9
src/main/java/com/cultural/heritage/service/wx/WeChatLogisticsService.java
View File

@ -9,11 +9,16 @@ public interface WeChatLogisticsService {
*/
WxAccessToken getAccessToken();
//
// /**
// * 两小时内重新获取token
// */
// void addAccessToken();
/**
* 两小时内重新获取token
* 获取稳定版接口调用凭据
*/
void addAccessToken();
WxAccessToken getStableAccessToken();
}

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

@ -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<String, Object> redisTemplate;
@Schema(description = "小程序 appId")
@ -41,31 +36,61 @@ public class WeChatLogisticsServiceImpl implements WeChatLogisticsService {
private String appSecret;
/**
* 获取微信token
* 获取稳定版接口调用凭据
*/
@Override
public WxAccessToken getStableAccessToken() {
Map<String, Object> 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);
// }
}