parent
2789140740
commit
c0cce9fb0b
@ -1,31 +1,51 @@
|
|||||||
package com.xjs.apitools.factory.impl;
|
package com.xjs.apitools.factory.impl;
|
||||||
|
|
||||||
|
import com.alibaba.fastjson.JSONArray;
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
import com.xjs.apitools.domain.ApiHoliday;
|
import com.xjs.apitools.domain.ApiHoliday;
|
||||||
import com.xjs.apitools.factory.ApiToolsFactory;
|
import com.xjs.apitools.factory.ApiToolsFactory;
|
||||||
|
import com.xjs.common.client.api.roll.RollHolidayFeignClient;
|
||||||
import com.xjs.config.RollProperties;
|
import com.xjs.config.RollProperties;
|
||||||
|
import com.xjs.copywriting.domain.RequestBody;
|
||||||
import lombok.extern.log4j.Log4j2;
|
import lombok.extern.log4j.Log4j2;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Component;
|
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工厂实现
|
* roll平台获取节假日api工厂实现
|
||||||
|
*
|
||||||
* @author xiejs
|
* @author xiejs
|
||||||
* @since 2022-01-17
|
* @since 2022-01-17
|
||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
@Log4j2
|
@Log4j2
|
||||||
public class RollHolidayFactory implements ApiToolsFactory<ApiHoliday,Object> {
|
public class RollHolidayFactory implements ApiToolsFactory<ApiHoliday, Object> {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private RollProperties rollProperties;
|
private RollProperties rollProperties;
|
||||||
|
@Autowired
|
||||||
|
private RollHolidayFeignClient rollHolidayFeignClient;
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public ApiHoliday ApiData() {
|
public List<ApiHoliday> apiDataList() {
|
||||||
|
RequestBody requestBody = new RequestBody();
|
||||||
|
requestBody.setApp_id(rollProperties.getApp_id());
|
||||||
|
requestBody.setApp_secret(rollProperties.getApp_secret());
|
||||||
|
JSONObject jsonObject = rollHolidayFeignClient.holidayApi(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(ApiHoliday.class);
|
||||||
|
}).collect(Collectors.toList());
|
||||||
|
}
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -0,0 +1,44 @@
|
|||||||
|
package com.xjs.apitools.service.impl;
|
||||||
|
|
||||||
|
import com.xjs.apitools.domain.ApiHoliday;
|
||||||
|
import com.xjs.apitools.factory.ApiToolsFactory;
|
||||||
|
import com.xjs.apitools.factory.impl.RollHolidayFactory;
|
||||||
|
import com.xjs.apitools.service.ApiToolsService;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* api工具服务实现
|
||||||
|
*
|
||||||
|
* @author xiejs
|
||||||
|
* @since 2022-01-18
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
public class ApiToolsServiceImpl implements ApiToolsService {
|
||||||
|
|
||||||
|
private ApiToolsFactory<ApiHoliday, Object> holidayFactory;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
public void setHolidayFactory(RollHolidayFactory rollHolidayFactory) {
|
||||||
|
this.holidayFactory = rollHolidayFactory;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<ApiHoliday> getApiHolidayList() {
|
||||||
|
List<ApiHoliday> apiHolidayList = holidayFactory.apiDataList();
|
||||||
|
List<ApiHoliday> collect = apiHolidayList.stream().map(holidayFactory -> {
|
||||||
|
if (holidayFactory.getResidueDays() >= 0) {
|
||||||
|
return holidayFactory;
|
||||||
|
}else {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}).collect(Collectors.toList());
|
||||||
|
collect.removeIf(Objects::isNull);
|
||||||
|
return collect;
|
||||||
|
}
|
||||||
|
}
|
@ -0,0 +1,27 @@
|
|||||||
|
package com.xjs.common.client.api.roll;
|
||||||
|
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
|
import com.xjs.annotation.ApiLog;
|
||||||
|
import com.xjs.common.client.factory.RollHolidayFeignFactory;
|
||||||
|
import com.xjs.copywriting.domain.RequestBody;
|
||||||
|
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_HOLIDAYS;
|
||||||
|
import static com.xjs.consts.ApiConst.ROLL_HOLIDAYS_URL;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* roll节假日api接口feign远程调用
|
||||||
|
* @author xiejs
|
||||||
|
* @since 2022-01-18
|
||||||
|
*/
|
||||||
|
@FeignClient(name = "rollHoliday", url = ROLL_HOLIDAYS_URL, fallbackFactory = RollHolidayFeignFactory.class)
|
||||||
|
public interface RollHolidayFeignClient {
|
||||||
|
|
||||||
|
@GetMapping()
|
||||||
|
@ApiLog(name = ROLL_HOLIDAYS,
|
||||||
|
url = ROLL_HOLIDAYS_URL,
|
||||||
|
method = "Get")
|
||||||
|
JSONObject holidayApi(@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.RollHolidayFeignClient;
|
||||||
|
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-18
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
@Log4j2
|
||||||
|
public class RollHolidayFeignFactory implements FallbackFactory<RollHolidayFeignClient> {
|
||||||
|
@Override
|
||||||
|
public RollHolidayFeignClient 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