Commit 22be29c7 by 陶光胜

取数平台调整

parent c2ac2e06
...@@ -911,6 +911,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -911,6 +911,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
new BasicThreadFactory.Builder().namingPattern("applyTimer-%d").daemon(true).build()); new BasicThreadFactory.Builder().namingPattern("applyTimer-%d").daemon(true).build());
public void runApplyTask(Integer interval){ public void runApplyTask(Integer interval){
Config config = ConfigService.getConfig("application");
final String url = config.getProperty("applyUrl", "");
applyService.scheduleAtFixedRate(new Runnable() { applyService.scheduleAtFixedRate(new Runnable() {
@Override @Override
public void run() { public void run() {
...@@ -920,7 +922,7 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -920,7 +922,7 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
//log.debug("自助指标待审批任务状态变更", JSON.toJSONString(task)); //log.debug("自助指标待审批任务状态变更", JSON.toJSONString(task));
if (!task.getApplyId().equals("")) { if (!task.getApplyId().equals("")) {
// String applyStatusText = HttpUtils.doGet("http://www.gicdev.com/api-admin/apply-info?type=2&applyId=" + task.getApplyId()); // String applyStatusText = HttpUtils.doGet("http://www.gicdev.com/api-admin/apply-info?type=2&applyId=" + task.getApplyId());
String applyStatusText = HttpUtils.doGet("http://hope.demogic.com/api-admin/apply-info?type=2&applyId=" + task.getApplyId()); String applyStatusText = HttpUtils.doGet(url + task.getApplyId());
log.debug("runApplyTask.run", "查询自助指标查询 " + task.getId() + " 审核状态码" + applyStatusText); log.debug("runApplyTask.run", "查询自助指标查询 " + task.getId() + " 审核状态码" + applyStatusText);
if(StringUtils.isBlank(applyStatusText)){ if(StringUtils.isBlank(applyStatusText)){
break; break;
......
...@@ -2,6 +2,8 @@ package com.gic.cloud.data.hook.service.impl; ...@@ -2,6 +2,8 @@ package com.gic.cloud.data.hook.service.impl;
import cn.medubi.client.utils.LogPak; import cn.medubi.client.utils.LogPak;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.ctrip.framework.apollo.Config;
import com.ctrip.framework.apollo.ConfigService;
import com.gic.cloud.data.hook.api.dto.*; import com.gic.cloud.data.hook.api.dto.*;
import com.gic.cloud.data.hook.api.dto.DataDesensiType; import com.gic.cloud.data.hook.api.dto.DataDesensiType;
import com.gic.cloud.data.hook.api.entity.*; import com.gic.cloud.data.hook.api.entity.*;
...@@ -545,6 +547,8 @@ public class FreeQueryServiceImpl implements IFreeQueryService { ...@@ -545,6 +547,8 @@ public class FreeQueryServiceImpl implements IFreeQueryService {
* @param interval * @param interval
*/ */
private void runApplyTask(Integer interval) { private void runApplyTask(Integer interval) {
Config config = ConfigService.getConfig("application");
final String url = config.getProperty("applyUrl", "");
this.freeApplyService.scheduleAtFixedRate(new Runnable() { this.freeApplyService.scheduleAtFixedRate(new Runnable() {
@Override @Override
public void run() { public void run() {
...@@ -554,7 +558,7 @@ public class FreeQueryServiceImpl implements IFreeQueryService { ...@@ -554,7 +558,7 @@ public class FreeQueryServiceImpl implements IFreeQueryService {
log.debug("自定义查询任务审批状态变更:", JSON.toJSONString(task)); log.debug("自定义查询任务审批状态变更:", JSON.toJSONString(task));
if (!task.getApplyId().equals("")) { if (!task.getApplyId().equals("")) {
// String applyStatusText = HttpUtils.doGet("http://www.gicdev.com/api-admin/apply-info?type=2&applyId=" + task.getApplyId()); // String applyStatusText = HttpUtils.doGet("http://www.gicdev.com/api-admin/apply-info?type=2&applyId=" + task.getApplyId());
String applyStatusText = HttpUtils.doGet("http://hope.demogic.com/api-admin/apply-info?type=2&applyId=" + task.getApplyId()); String applyStatusText = HttpUtils.doGet(url + task.getApplyId());
log.debug("runApplyTask.run", "查询自助指标查询 " + task.getId() + " 审核状态码" + applyStatusText); log.debug("runApplyTask.run", "查询自助指标查询 " + task.getId() + " 审核状态码" + applyStatusText);
if(StringUtils.isBlank(applyStatusText)){ if(StringUtils.isBlank(applyStatusText)){
break; break;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment