Commit 539fe590 authored by 赵啸非's avatar 赵啸非

优化站点同步事项

parent c49b6dee
...@@ -80,13 +80,13 @@ public class SyncMatterTaskImpl implements ITaskExcuteService { ...@@ -80,13 +80,13 @@ public class SyncMatterTaskImpl implements ITaskExcuteService {
stopWatch.start("开始同步事项方法"); stopWatch.start("开始同步事项方法");
matterExtService.doMatterBySiteId(siteEntity,null); matterExtService.doMatterBySiteId(siteEntity,null);
stopWatch.stop(); stopWatch.stop();
log.info("同步事项完成,耗时:{}ms", stopWatch.getLastTaskTimeMillis()); log.info("同步事项完成,耗时:{}s", stopWatch.getLastTaskTimeMillis()/1000);
log.info("开始添加站点事项==》{}",siteEntity.getSiteName()); log.info("开始添加站点事项==》{}",siteEntity.getSiteName());
stopWatch.start("开始添加站点事项"); stopWatch.start("开始添加站点事项");
siteMatterService.doSyncSiteMatter(siteEntity, null); siteMatterService.doSyncSiteMatter(siteEntity, null);
stopWatch.stop(); stopWatch.stop();
log.info("开始添加站点事项,耗时:{}ms", stopWatch.getLastTaskTimeMillis()); log.info("开始添加站点事项,耗时:{} s", stopWatch.getLastTaskTimeMillis()/1000);
// syncMatter(siteEntity); // syncMatter(siteEntity);
} }
// syncDevice(); // syncDevice();
......
...@@ -13,6 +13,7 @@ import java.util.ArrayList; ...@@ -13,6 +13,7 @@ import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis; import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
import org.springframework.util.ObjectUtils;
import java.util.List; import java.util.List;
...@@ -56,6 +57,9 @@ public class MatterDaoImpl extends BaseCRUDDaoMybatis<MatterEntity, Long> implem ...@@ -56,6 +57,9 @@ public class MatterDaoImpl extends BaseCRUDDaoMybatis<MatterEntity, Long> implem
ParamDto param = new ParamDto(); ParamDto param = new ParamDto();
param.getCondition().put("areaCode", matterQuery.getAreaCode()); param.getCondition().put("areaCode", matterQuery.getAreaCode());
if(!ObjectUtils.isEmpty(matterQuery.getSource())){
param.getCondition().put("areaCode", matterQuery.getSource());
}
return this.getSqlSession().selectList(this.getSqlId("getMatterListByAreaCode"), param); return this.getSqlSession().selectList(this.getSqlId("getMatterListByAreaCode"), param);
} }
......
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