package com.ruoyi.account.task;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.ruoyi.account.api.model.TAppUser;
|
import com.ruoyi.account.api.model.TAppUserSiteFavorite;
|
import com.ruoyi.account.service.TAppUserService;
|
import com.ruoyi.account.service.TAppUserSiteFavoriteService;
|
import com.ruoyi.account.wx.model.WeixinProperties;
|
import com.ruoyi.account.wx.tools.WxAppletTools;
|
import com.ruoyi.chargingPile.api.feignClient.SiteClient;
|
import com.ruoyi.chargingPile.api.vo.FavoriteSitePriceVO;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.utils.HttpUtils;
|
import com.ruoyi.common.redis.service.RedisService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.redisson.api.RLock;
|
import org.redisson.api.RedissonClient;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.concurrent.TimeUnit;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Component
|
public class FavoritePriceDropTask {
|
|
private static final String SEND_URL = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=";
|
|
@Resource
|
private TAppUserSiteFavoriteService favoriteService;
|
@Resource
|
private TAppUserService appUserService;
|
@Resource
|
private SiteClient siteClient;
|
@Resource
|
private RestTemplate wxRestTemplate;
|
@Resource
|
private WeixinProperties wxConfig;
|
@Resource
|
private RedisService redisService;
|
@Resource
|
private RedissonClient redissonClient;
|
|
@Value("${wx.applet.price-drop-template-id:7nCycRUZxQ2jxAb2UaYazjp2sPZy3qYyeLqVytyhHhY}")
|
private String templateId;
|
|
@Value("${wx.applet.price-drop-page:pagesMine/favoriteSite/favoriteSite}")
|
private String page;
|
|
// 降价推送已改为计费策略审批通过时触发（TAccountingStrategyController.authPass → TAppUserSiteFavoriteClient），此轮询任务暂停（如需回退恢复 @Scheduled 即可）
|
// @Scheduled(fixedDelay = 30 * 60 * 1000L, initialDelay = 2 * 60 * 1000L)
|
public void notifyPriceDrop() {
|
if (!StringUtils.hasText(templateId)) {
|
return;
|
}
|
RLock lock = redissonClient.getLock("FAVORITE_SITE_PRICE_DROP_TASK");
|
boolean locked = false;
|
try {
|
locked = lock.tryLock(0, 10, TimeUnit.MINUTES);
|
if (!locked) {
|
return;
|
}
|
List<TAppUserSiteFavorite> favorites = favoriteService.lambdaQuery()
|
.eq(TAppUserSiteFavorite::getNotifyEnabled, true)
|
.list();
|
if (favorites.isEmpty()) {
|
return;
|
}
|
List<Integer> siteIds = favorites.stream().map(TAppUserSiteFavorite::getSiteId)
|
.filter(Objects::nonNull).distinct().collect(Collectors.toList());
|
R<List<FavoriteSitePriceVO>> response = siteClient.getFavoriteSitePrices(siteIds);
|
List<FavoriteSitePriceVO> prices = response == null || response.getData() == null
|
? Collections.emptyList() : response.getData();
|
Map<Integer, FavoriteSitePriceVO> priceMap = prices.stream()
|
.collect(Collectors.toMap(FavoriteSitePriceVO::getSiteId, Function.identity(), (a, b) -> a));
|
for (TAppUserSiteFavorite favorite : favorites) {
|
FavoriteSitePriceVO price = priceMap.get(favorite.getSiteId());
|
if (price == null || price.getCurrentPrice() == null || favorite.getFavoritePrice() == null
|
|| price.getCurrentPrice().compareTo(favorite.getFavoritePrice()) >= 0) {
|
continue;
|
}
|
TAppUser user = appUserService.getById(favorite.getAppUserId());
|
if (user == null || !StringUtils.hasText(user.getWxOpenid())) {
|
log.info("收藏站点降价提醒未发送，用户openid为空，userId={}, siteId={}",
|
favorite.getAppUserId(), favorite.getSiteId());
|
continue;
|
}
|
if (sendSubscribeMessage(user.getWxOpenid(), favorite, price)) {
|
favorite.setNotifyEnabled(false);
|
favorite.setLastNotifiedPrice(price.getCurrentPrice());
|
favoriteService.updateById(favorite);
|
log.info("收藏站点降价提醒发送成功，userId={}, siteId={}, currentPrice={}",
|
favorite.getAppUserId(), favorite.getSiteId(), price.getCurrentPrice());
|
}
|
}
|
} catch (InterruptedException e) {
|
Thread.currentThread().interrupt();
|
} catch (Exception e) {
|
log.error("收藏站点降价提醒任务执行失败", e);
|
} finally {
|
if (locked && lock.isHeldByCurrentThread()) {
|
lock.unlock();
|
}
|
}
|
}
|
|
private boolean sendSubscribeMessage(String openId, TAppUserSiteFavorite favorite, FavoriteSitePriceVO price) {
|
JSONObject body = new JSONObject();
|
body.put("touser", openId);
|
body.put("template_id", templateId);
|
body.put("page", page + "?siteId=" + favorite.getSiteId());
|
JSONObject data = new JSONObject();
|
data.put("thing1", value(limit(price.getSiteName(), 20)));
|
data.put("amount4", value(formatAmount(price.getCurrentPrice())));
|
body.put("data", data);
|
String accessToken = new WxAppletTools(wxRestTemplate, wxConfig, redisService).getAccessToken("");
|
String result = HttpUtils.post(SEND_URL + accessToken, body.toJSONString());
|
JSONObject response = JSON.parseObject(result);
|
boolean success = response != null && response.getIntValue("errcode") == 0;
|
if (!success) {
|
log.warn("发送收藏站点降价提醒失败，userId={}, siteId={}, response={}",
|
favorite.getAppUserId(), favorite.getSiteId(), result);
|
}
|
return success;
|
}
|
|
private JSONObject value(String value) {
|
JSONObject item = new JSONObject();
|
item.put("value", value);
|
return item;
|
}
|
|
private String formatAmount(BigDecimal amount) {
|
return amount.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString() + "元";
|
}
|
|
private String limit(String value, int length) {
|
if (!StringUtils.hasText(value) || value.length() <= length) {
|
return value;
|
}
|
return value.substring(0, length);
|
}
|
}
|
