|
@@ -88,12 +88,13 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
public static final int RETRY_NUMBER = 3;
|
|
|
|
|
|
@Override
|
|
|
- public void resourceSync() {
|
|
|
+ public Boolean resourceSync() {
|
|
|
//先同步应用和服务数据
|
|
|
//再同步应用菜单数据
|
|
|
String[] resourceIds = new String[]{ResourceTypeEnum.TJ_APP.getResourceId(),
|
|
|
ResourceTypeEnum.TJ_SERVICE.getResourceId(),
|
|
|
- ResourceTypeEnum.TJ_APP_MENU.getResourceId()};
|
|
|
+ ResourceTypeEnum.TJ_APP_MENU.getResourceId(),
|
|
|
+ ResourceTypeEnum.BU_SERVICE.getResourceId()};
|
|
|
List<ResourceSync> resourceSyncs;
|
|
|
for (String resourceId : resourceIds) {
|
|
|
resourceSyncs = syncService.getNotSyncResource(resourceId);
|
|
@@ -105,6 +106,7 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
resourceSyncs.forEach(item -> item.setSync(BooleanEnum.TRUE.getValue()));
|
|
|
syncService.batchUpdate(resourceSyncs);
|
|
|
}
|
|
|
+ return true;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -508,7 +510,7 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
Integer currentPageNo = requestParamDTO.getCurrentPageNo();
|
|
|
List<String> resourceTypeList = requestParamDTO.getListAllResourceType();
|
|
|
for (ResourceTypeEnum resourceEnum : ResourceTypeEnum.values()) {
|
|
|
- if(!CollectionUtils.isEmpty(resourceTypeList)
|
|
|
+ if(CollectionUtils.isNotEmpty(resourceTypeList)
|
|
|
&& !resourceTypeList.contains(resourceEnum.getResourceType())) {
|
|
|
continue;
|
|
|
}
|
|
@@ -693,10 +695,10 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
*
|
|
|
* @param pageNo
|
|
|
* @param pageSize
|
|
|
- * @param url
|
|
|
* @return
|
|
|
*/
|
|
|
- private HttpResult getServiceResource(Integer pageNo, Integer pageSize, String url) {
|
|
|
+ private HttpResult getServiceResource(Integer pageNo, Integer pageSize) {
|
|
|
+ String url = resourceConfig.getResourceUrl();
|
|
|
HttpResult httpResult = new HttpResult();
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
map.put("page", String.valueOf(pageNo - 1));
|
|
@@ -715,6 +717,7 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
.busSreIdcard(busSreIdcard)
|
|
|
.build();
|
|
|
List<Header> headerList = getHeaders(busSendReqVO);
|
|
|
+ logger.info("-------------getServiceResource START -------------");
|
|
|
logger.info("getServiceResource url:{}", url);
|
|
|
String response = HttpUtil.postJSON(url, param, headerList, null);
|
|
|
if (null == response) {
|
|
@@ -729,6 +732,7 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
httpResult.setPages(data.getInteger("totalPages"));
|
|
|
httpResult.setTotals(data.getInteger("totalElements"));
|
|
|
}
|
|
|
+ logger.info("-------------getServiceResource END -------------");
|
|
|
return httpResult;
|
|
|
}
|
|
|
|
|
@@ -788,12 +792,13 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
*/
|
|
|
private HttpResult getResourceFromRemote(ResourceTypeEnum resourceTypeEnum, Integer pageNo, Integer pageSize) {
|
|
|
HttpResult httpResult;
|
|
|
- String url = resourceConfig.getResourceUrl();
|
|
|
//获取应用资源
|
|
|
if (ResourceTypeEnum.TJ_APP.equals(resourceTypeEnum)) {
|
|
|
- httpResult = getAppResource(pageNo, pageSize, url);
|
|
|
+ httpResult = getAppResource(pageNo, pageSize);
|
|
|
} else if (ResourceTypeEnum.TJ_SERVICE.equals(resourceTypeEnum)) {
|
|
|
- httpResult = getServiceResource(pageNo, pageSize, url);
|
|
|
+ httpResult = getServiceResource(pageNo, pageSize);
|
|
|
+ } else if (ResourceTypeEnum.BU_SERVICE.equals(resourceTypeEnum)) {
|
|
|
+ httpResult = getBuServiceResource(pageNo,pageSize);
|
|
|
} else {
|
|
|
httpResult = new HttpResult();
|
|
|
httpResult.setCode(ResponseStatus.SUCCESS_CODE);
|
|
@@ -803,15 +808,53 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
return httpResult;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 从大数据平台获取
|
|
|
+ * @param pageNo
|
|
|
+ * @param pageSize
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private HttpResult getBuServiceResource(Integer pageNo, Integer pageSize) {
|
|
|
+ String resourceUrl = resourceConfig.getBuServiceUrl();
|
|
|
+ HttpResult httpResult = new HttpResult();
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ map.put("page", pageNo -1);
|
|
|
+ map.put("size", pageSize);
|
|
|
+ JSONArray array = new JSONArray();
|
|
|
+ JSONObject searchCondition = new JSONObject();
|
|
|
+ searchCondition.put("name","isDeleted");
|
|
|
+ searchCondition.put("op","=");
|
|
|
+ searchCondition.put("value", BooleanEnum.FALSE.value);
|
|
|
+ array.add(searchCondition);
|
|
|
+ map.put("searchCondition", array.toJSONString());
|
|
|
+ String param = JSON.toJSONString(map);
|
|
|
+ logger.info("-------------getBuServiceResource START -------------");
|
|
|
+ logger.info("url:{}, param:{}", resourceUrl, param);
|
|
|
+ String response = HttpUtil.postForm(resourceUrl, param, null, null);
|
|
|
+ if (null == response) {
|
|
|
+ logger.info("get bu service fail,pageNo:{},pageSize:{}", pageNo, pageSize);
|
|
|
+ httpResult.setCode(ResponseStatus.FAIL_CODE);
|
|
|
+ } else {
|
|
|
+ logger.info("get app resource success,pageNo:{},pageSize:{}", pageNo, pageSize);
|
|
|
+ JSONObject parse = JSONObject.parseObject(response);
|
|
|
+ httpResult.setCode(ResponseStatus.SUCCESS_CODE);
|
|
|
+ httpResult.setPages(parse.getInteger("totalPages"));
|
|
|
+ httpResult.setTotals(parse.getInteger("totalElements"));
|
|
|
+ httpResult.setRecords(parse.getJSONArray("content"));
|
|
|
+ }
|
|
|
+ logger.info("-------------getBuServiceResource END -------------");
|
|
|
+ return httpResult;
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 从总线分页查询应用资源
|
|
|
*
|
|
|
* @param pageNo
|
|
|
* @param pageSize
|
|
|
- * @param url
|
|
|
* @return
|
|
|
*/
|
|
|
- private HttpResult getAppResource(Integer pageNo, Integer pageSize, String url) {
|
|
|
+ private HttpResult getAppResource(Integer pageNo, Integer pageSize) {
|
|
|
+ String url = resourceConfig.getResourceUrl();
|
|
|
HttpResult httpResult = new HttpResult();
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
//应用目录从0页开始查
|
|
@@ -831,6 +874,7 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
.build();
|
|
|
|
|
|
List<Header> headerList = getHeaders(busSendReqVO);
|
|
|
+ logger.info("-------------getAppResource START -------------");
|
|
|
logger.info("getAppResource url:{}", url);
|
|
|
String response = HttpUtil.postForm(url, param, headerList, null);
|
|
|
if (null == response) {
|
|
@@ -844,6 +888,7 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
httpResult.setTotals(parse.getInteger("total"));
|
|
|
httpResult.setRecords(parse.getJSONArray("content"));
|
|
|
}
|
|
|
+ logger.info("-------------getAppResource END -------------");
|
|
|
return httpResult;
|
|
|
}
|
|
|
|
|
@@ -920,15 +965,23 @@ public class ResourceBusiness implements IResourceBusiness {
|
|
|
resourceEnum.getResourceType(), resourceEnum.getResourceProvider());
|
|
|
dto.setContent(jsonString);
|
|
|
JSONObject jsonObject = JSONObject.parseObject(jsonString);
|
|
|
- String appCode = jsonObject.getString("yyxtbh");
|
|
|
- String serviceCode = jsonObject.getString("FWZYBSF");
|
|
|
- String appName = jsonObject.getString("yyxtmc");
|
|
|
- String serviceName = jsonObject.getString("FWZYMC");
|
|
|
+ if(ResourceTypeEnum.TJ_APP.equals(resourceEnum)) {
|
|
|
+ String appCode = jsonObject.getString("yyxtbh");
|
|
|
+ String appName = jsonObject.getString("yyxtmc");
|
|
|
+ dto.setAppCode(appCode);
|
|
|
+ dto.setAppName(appName);
|
|
|
+ } else if (ResourceTypeEnum.TJ_SERVICE.equals(resourceEnum)) {
|
|
|
+ String serviceCode = jsonObject.getString("FWZYBSF");
|
|
|
+ String serviceName = jsonObject.getString("FWZYMC");
|
|
|
+ dto.setServiceCode(serviceCode);
|
|
|
+ dto.setServiceName(serviceName);
|
|
|
+ } else if (ResourceTypeEnum.BU_SERVICE.equals(resourceEnum)) {
|
|
|
+ String serviceCode = jsonObject.getString("serviceId");
|
|
|
+ String serviceName = jsonObject.getString("serviceName");
|
|
|
+ dto.setServiceCode(serviceCode);
|
|
|
+ dto.setServiceName(serviceName);
|
|
|
+ }
|
|
|
dto.setExtId(jsonObject.getString("id"));
|
|
|
- dto.setAppCode(appCode);
|
|
|
- dto.setAppName(appName);
|
|
|
- dto.setServiceCode(serviceCode);
|
|
|
- dto.setServiceName(serviceName);
|
|
|
dto.setDeleted(BooleanEnum.FALSE.getValue());
|
|
|
dto.setSync(BooleanEnum.FALSE.getValue());
|
|
|
list.add(dto);
|