Kaynağa Gözat

[定时任务][修改][获取客流TOKEN时间30分钟一次]

release_toaliyun_real
gongbiao 7 yıl önce
ebeveyn
işleme
42e02d5ad8
2 değiştirilmiş dosya ile 18 ekleme ve 4 silme
  1. +6
    -2
      mallinkSchedule/src/main/java/com/iformall/schedule/WiwideTokenSchedule.java
  2. +12
    -2
      mallinkService/src/main/java/com/iformall/utils/WiwideUtil.java

+ 6
- 2
mallinkSchedule/src/main/java/com/iformall/schedule/WiwideTokenSchedule.java Dosyayı Görüntüle

@@ -25,13 +25,17 @@ public class WiwideTokenSchedule {
@Autowired @Autowired
private WxWiwideInfoMapper wxWiwideInfoMapper; private WxWiwideInfoMapper wxWiwideInfoMapper;


@Scheduled(cron = "0 0/45 * * * ?")
@Scheduled(cron = "0 0/30 * * * ?")
public void requestToken() { public void requestToken() {
List<WxWiWideInfo> list = wxWiwideInfoMapper.findList(null); List<WxWiWideInfo> list = wxWiwideInfoMapper.findList(null);
for (int i = 0, size = list.size(); i < size; i++) { for (int i = 0, size = list.size(); i < size; i++) {
WxWiWideInfo wxWiWideInfo = list.get(i); WxWiWideInfo wxWiWideInfo = list.get(i);
String data = WiwideUtil.queryToken(wxWiWideInfo); String data = WiwideUtil.queryToken(wxWiWideInfo);
String token = (String) JSONObject.parseObject(data).get("data"); String token = (String) JSONObject.parseObject(data).get("data");
if(token==null){
logger.error("商场:"+wxWiWideInfo.getTenantId()+",token为空");
continue;
}
updateToken(wxWiWideInfo, token); updateToken(wxWiWideInfo, token);
} }


@@ -47,7 +51,7 @@ public class WiwideTokenSchedule {
try { try {
wxWiwideInfoMapper.updateToken(record); wxWiwideInfoMapper.updateToken(record);
} catch (MallinkException e) { } catch (MallinkException e) {
logger.info("更新TOKEN失败:商场" + wxWiWideInfo.getTenantId());
logger.error("更新TOKEN失败:商场" + wxWiWideInfo.getTenantId());
} }
} }




+ 12
- 2
mallinkService/src/main/java/com/iformall/utils/WiwideUtil.java Dosyayı Görüntüle

@@ -2,9 +2,9 @@ package com.iformall.utils;


import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.iformall.common.ErrorCode; import com.iformall.common.ErrorCode;
import com.iformall.domain.po.WxMall;
import com.iformall.domain.po.WxWiWideInfo; import com.iformall.domain.po.WxWiWideInfo;
import com.iformall.exception.MallinkException; import com.iformall.exception.MallinkException;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.codec.Base64; import org.apache.shiro.codec.Base64;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -135,7 +135,17 @@ public class WiwideUtil {
logger.info("获取TOKEN"); logger.info("获取TOKEN");
String username = wiWideInfo.getWiwideId(); String username = wiWideInfo.getWiwideId();
String authVal = WiwideUtil.encrypt(wiWideInfo.getWiwideKey()); String authVal = WiwideUtil.encrypt(wiWideInfo.getWiwideKey());
Map<String, String> params = new HashMap<>();
if(StringUtils.isEmpty(username)){
logger.error("商场:" + wiWideInfo.getTenantId() + ",wiwideId为空" );
return null;
}

if(StringUtils.isEmpty(authVal)){
logger.error("商场:" + wiWideInfo.getTenantId() + ",wiwideKey为空" );
return null;
}

Map<String, String> params = new HashMap<>(2);
params.put("username", username); params.put("username", username);
params.put("authVal", authVal); params.put("authVal", authVal);
String wiwideUrl = wiWideInfo.getWiwideUrl(); String wiwideUrl = wiWideInfo.getWiwideUrl();


Yükleniyor…
İptal
Kaydet