parent
1d448587bf
commit
90d7eb47d8
@ -0,0 +1,19 @@
|
|||||||
|
package com.xjs.run;
|
||||||
|
|
||||||
|
import org.springframework.boot.ApplicationArguments;
|
||||||
|
import org.springframework.boot.ApplicationRunner;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* springboot启动成功后执行
|
||||||
|
* @author xiejs
|
||||||
|
* @since 2022-01-19
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
public class ApplicationRunnerImpl implements ApplicationRunner {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void run(ApplicationArguments args) throws Exception {
|
||||||
|
System.out.println("-----------------启动成功!!!---------------------");
|
||||||
|
}
|
||||||
|
}
|
@ -0,0 +1,52 @@
|
|||||||
|
package com.xjs.apitools.factory.impl;
|
||||||
|
|
||||||
|
import com.alibaba.fastjson.JSONArray;
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.xjs.apitools.domain.ApiHistoryToday;
|
||||||
|
import com.xjs.apitools.domain.RequestBody;
|
||||||
|
import com.xjs.apitools.factory.ApiToolsFactory;
|
||||||
|
import com.xjs.common.client.api.roll.RollHistoryTodayFeignClient;
|
||||||
|
import com.xjs.config.RollProperties;
|
||||||
|
import lombok.extern.log4j.Log4j2;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
import static com.xjs.consts.ApiConst.DEMOTE_ERROR;
|
||||||
|
import static com.xjs.consts.ApiConst.ROLL_CODE_SUCCESS;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* roll平台获取历史今天api工厂实现
|
||||||
|
*
|
||||||
|
* @author xiejs
|
||||||
|
* @since 2022-01-19
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
@Log4j2
|
||||||
|
public class RollHistoryTodayFactory implements ApiToolsFactory<ApiHistoryToday, Object> {
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private RollProperties rollProperties;
|
||||||
|
@Autowired
|
||||||
|
private RollHistoryTodayFeignClient rollHistoryTodayFeignClient;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<ApiHistoryToday> apiDataList() {
|
||||||
|
RequestBody requestBody = new RequestBody();
|
||||||
|
requestBody.setApp_id(rollProperties.getApp_id());
|
||||||
|
requestBody.setApp_secret(rollProperties.getApp_secret());
|
||||||
|
//获取无详情的数据
|
||||||
|
requestBody.setType(0);
|
||||||
|
JSONObject jsonObject = rollHistoryTodayFeignClient.historyTodayApi(requestBody);
|
||||||
|
if (!jsonObject.containsKey(DEMOTE_ERROR) && jsonObject.getInteger("code") == ROLL_CODE_SUCCESS.intValue()) {
|
||||||
|
JSONArray jsonArrayData = jsonObject.getJSONArray("data");
|
||||||
|
return jsonArrayData.stream().map(data -> {
|
||||||
|
JSONObject jsonData = (JSONObject) data;
|
||||||
|
return jsonData.toJavaObject(ApiHistoryToday.class);
|
||||||
|
}).collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
@ -0,0 +1,27 @@
|
|||||||
|
package com.xjs.common.client.api.roll;
|
||||||
|
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.xjs.annotation.ApiLog;
|
||||||
|
import com.xjs.apitools.domain.RequestBody;
|
||||||
|
import com.xjs.common.client.factory.RollHistoryTodayFeignFactory;
|
||||||
|
import org.springframework.cloud.openfeign.FeignClient;
|
||||||
|
import org.springframework.cloud.openfeign.SpringQueryMap;
|
||||||
|
import org.springframework.web.bind.annotation.GetMapping;
|
||||||
|
|
||||||
|
import static com.xjs.consts.ApiConst.ROLL_HISTORY_TODAY;
|
||||||
|
import static com.xjs.consts.ApiConst.ROLL_HISTORY_TODAY_URL;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* roll历史今天api接口feign远程调用
|
||||||
|
* @author xiejs
|
||||||
|
* @since 2022-01-19
|
||||||
|
*/
|
||||||
|
@FeignClient(name = "rollHistoryToday", url = ROLL_HISTORY_TODAY_URL, fallbackFactory = RollHistoryTodayFeignFactory.class)
|
||||||
|
public interface RollHistoryTodayFeignClient {
|
||||||
|
|
||||||
|
@GetMapping()
|
||||||
|
@ApiLog(name = ROLL_HISTORY_TODAY,
|
||||||
|
url = ROLL_HISTORY_TODAY_URL,
|
||||||
|
method = "Get")
|
||||||
|
JSONObject historyTodayApi(@SpringQueryMap RequestBody requestBody);
|
||||||
|
}
|
@ -0,0 +1,29 @@
|
|||||||
|
package com.xjs.common.client.factory;
|
||||||
|
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.ruoyi.common.core.domain.R;
|
||||||
|
import com.xjs.common.client.api.roll.RollHistoryTodayFeignClient;
|
||||||
|
import lombok.extern.log4j.Log4j2;
|
||||||
|
import org.springframework.cloud.openfeign.FallbackFactory;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import static com.xjs.consts.ApiConst.DEMOTE_ERROR;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* roll历史今天api接口feign远程调用降级
|
||||||
|
* @author xiejs
|
||||||
|
* @since 2022-01-19
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
@Log4j2
|
||||||
|
public class RollHistoryTodayFeignFactory implements FallbackFactory<RollHistoryTodayFeignClient> {
|
||||||
|
@Override
|
||||||
|
public RollHistoryTodayFeignClient create(Throwable cause) {
|
||||||
|
log.error("api模块roll 历史上的今天服务调用失败:{},执行降级处理", cause.getMessage());
|
||||||
|
return requestBody -> {
|
||||||
|
JSONObject jsonObject = new JSONObject();
|
||||||
|
jsonObject.put(DEMOTE_ERROR, R.FAIL);
|
||||||
|
return jsonObject;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in new issue