Commit d91e6691 authored by 廖旭伟's avatar 廖旭伟

修改bug

parent fd646207
package com.mortals.xhx.feign.site; package com.mortals.xhx.feign.site;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.mortals.framework.common.Rest; import com.mortals.framework.common.Rest;
import com.mortals.xhx.common.pdu.RespData; import com.mortals.xhx.common.pdu.RespData;
import com.mortals.xhx.common.pdu.site.SitePdu; import com.mortals.xhx.common.pdu.site.SitePdu;
...@@ -76,7 +77,7 @@ public interface ISiteFeign extends IFeign { ...@@ -76,7 +77,7 @@ public interface ISiteFeign extends IFeign {
* @return * @return
*/ */
@PostMapping(value = "/site/getFlatSitesBySiteId") @PostMapping(value = "/site/getFlatSitesBySiteId")
Rest<List<SitePdu>> getFlatSitesBySiteId(@RequestBody SitePdu sitePdu); String getFlatSitesBySiteId(@RequestBody SitePdu sitePdu);
/** /**
...@@ -126,8 +127,8 @@ class SiteFeignFallbackFactory implements FallbackFactory<ISiteFeign> { ...@@ -126,8 +127,8 @@ class SiteFeignFallbackFactory implements FallbackFactory<ISiteFeign> {
} }
@Override @Override
public Rest<List<SitePdu>> getFlatSitesBySiteId(SitePdu sitePdu) { public String getFlatSitesBySiteId(SitePdu sitePdu) {
return Rest.fail("暂时无法获取站点子站点,请稍后再试!"); return JSONObject.toJSONString(Rest.fail("暂时无法获取站点子站点,请稍后再试!"));
} }
@Override @Override
......
package com.mortals.xhx.daemon.task; package com.mortals.xhx.daemon.task;
import com.alibaba.fastjson.JSONObject;
import com.mortals.framework.common.Rest; import com.mortals.framework.common.Rest;
import com.mortals.framework.exception.AppException; import com.mortals.framework.exception.AppException;
import com.mortals.framework.service.ITask; import com.mortals.framework.service.ITask;
...@@ -40,10 +41,12 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService { ...@@ -40,10 +41,12 @@ public class SyncSiteMatterTaskImpl implements ITaskExcuteService {
log.info("开始同步事项列表!"); log.info("开始同步事项列表!");
SitePdu sitePdu = new SitePdu(); SitePdu sitePdu = new SitePdu();
sitePdu.setId(1L); sitePdu.setId(1L);
Rest<List<SitePdu>> siteRest = siteFeign.getFlatSitesBySiteId(sitePdu); String resp = siteFeign.getFlatSitesBySiteId(sitePdu);
if (siteRest.getCode() == YesNoEnum.YES.getValue()) { JSONObject jsonObject = JSONObject.parseObject(resp);
log.info("总数量:{}",siteRest.getData().size()); if (jsonObject.getInteger("code") == YesNoEnum.YES.getValue()) {
siteRest.getData().forEach(site -> { List<SitePdu> siteList = JSONObject.parseArray(jsonObject.getString("data"),SitePdu.class);
log.info("总数量:{}",siteList.size());
siteList.forEach(site -> {
siteMatterService.getDao().delete(new SiteMatterQuery().siteId(site.getId())); siteMatterService.getDao().delete(new SiteMatterQuery().siteId(site.getId()));
int page=100; int page=100;
int pageNum=100; int pageNum=100;
......
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