|
|
@@ -6,10 +6,7 @@ import com.github.benmanes.caffeine.cache.LoadingCache; |
|
|
|
import com.szyx.tcm.supervision.config.CacheAgent; |
|
|
|
import com.szyx.tcm.supervision.constant.CacheConstant; |
|
|
|
import com.szyx.tcm.supervision.constant.HttpConstants; |
|
|
|
import com.szyx.tcm.supervision.model.dto.supervise.CommonRsp; |
|
|
|
import com.szyx.tcm.supervision.model.dto.supervise.RspDetail; |
|
|
|
import com.szyx.tcm.supervision.model.dto.supervise.SuperviseDto; |
|
|
|
import com.szyx.tcm.supervision.model.dto.supervise.SuperviseTokenRep; |
|
|
|
import com.szyx.tcm.supervision.model.dto.supervise.*; |
|
|
|
import com.szyx.tcm.supervision.service.BjSuperviseUploadService; |
|
|
|
import com.szyx.tcm.supervision.util.HttpUtil; |
|
|
|
import com.szyx.tcm.supervision.util.XMLMapperUtil; |
|
|
@@ -41,37 +38,13 @@ import java.util.concurrent.TimeUnit; |
|
|
|
@Service |
|
|
|
public class BjSuperviseUploadServiceImpl implements BjSuperviseUploadService { |
|
|
|
|
|
|
|
@Value("${supervise.url}") |
|
|
|
private String url; |
|
|
|
@Value("${supervise.appid}") |
|
|
|
private String appid; |
|
|
|
@Value("${supervise.secret}") |
|
|
|
private String secret; |
|
|
|
|
|
|
|
@Resource |
|
|
|
private CacheAgent cacheAgent; |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
public SuperviseTokenRep getToken() { |
|
|
|
String requestUrl = url + "/getToken"; |
|
|
|
HashMap<String, Object> map = new HashMap<>(); |
|
|
|
map.put("appid", appid); |
|
|
|
map.put("secret", secret); |
|
|
|
String data = HttpUtil.get(requestUrl, null, map); |
|
|
|
CommonRsp res = JSONObject.parseObject(data, CommonRsp.class); |
|
|
|
if (StringUtils.isNotBlank(res.getData())) { |
|
|
|
return JSONObject.parseObject(res.getData(), SuperviseTokenRep.class); |
|
|
|
} |
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
@SneakyThrows |
|
|
|
public RspDetail dataUpload(SuperviseDto superviseDto) { |
|
|
|
String token = generateToken(); |
|
|
|
String requestUrl = url + "/upload?access_token=" + token; |
|
|
|
String data = HttpUtil.postByXMl(requestUrl, XMLMapperUtil.getInstance().writerWithDefaultPrettyPrinter().writeValueAsString(superviseDto)); |
|
|
|
public RspDetail dataUpload(SuperviseReq req) { |
|
|
|
String token = req.getToken(); |
|
|
|
String requestUrl = req.getUrl() + "/upload?access_token=" + token; |
|
|
|
String data = HttpUtil.postByXMl(requestUrl, XMLMapperUtil.getInstance().writerWithDefaultPrettyPrinter().writeValueAsString(req.getSuperviseDto())); |
|
|
|
CommonRsp res = JSONObject.parseObject(data, CommonRsp.class); |
|
|
|
if (res.isSuccess()) { |
|
|
|
return JSONObject.parseObject(res.getData(), RspDetail.class); |
|
|
@@ -79,28 +52,6 @@ public class BjSuperviseUploadServiceImpl implements BjSuperviseUploadService { |
|
|
|
return new RspDetail(HttpConstants.StatusCode.SERVER_ERROR, res.getMsg()); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 生成token header |
|
|
|
* |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
private String generateToken() { |
|
|
|
|
|
|
|
|
|
|
|
SuperviseTokenRep rep = cacheAgent.get(CacheConstant.SUPERVISE_TOKEN); |
|
|
|
if(null == rep){ |
|
|
|
rep = getToken(); |
|
|
|
cacheAgent.put(CacheConstant.SUPERVISE_TOKEN,rep); |
|
|
|
} |
|
|
|
|
|
|
|
String token = null; |
|
|
|
if (rep != null) { |
|
|
|
token = rep.getAccess_token(); |
|
|
|
log.info("更新监管平台token成功,token:{},过期时间为:{}", rep.getAccess_token(), DateUtil.offsetSecond(new Date(), rep.getExpires_in())); |
|
|
|
} else { |
|
|
|
log.warn("更新监管平台token失败"); |
|
|
|
} |
|
|
|
return token; |
|
|
|
} |
|
|
|
|
|
|
|
} |