Commit 403f22a8 authored by 赵啸非's avatar 赵啸非

添加事项同步数据

parent 0ee0af23
package com.mortals.xhx.module.site.service.impl; package com.mortals.xhx.module.site.service.impl;
import com.mortals.xhx.module.business.model.BusinessEntity; import com.mortals.xhx.module.business.model.BusinessEntity;
import com.mortals.xhx.module.business.model.BusinessQuery; import com.mortals.xhx.module.business.model.BusinessQuery;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -12,28 +13,29 @@ import com.mortals.xhx.module.site.model.SiteBusinessQuery; ...@@ -12,28 +13,29 @@ import com.mortals.xhx.module.site.model.SiteBusinessQuery;
import com.mortals.xhx.module.site.service.SiteBusinessService; import com.mortals.xhx.module.site.service.SiteBusinessService;
import com.mortals.xhx.module.site.model.SiteBusinessTreeSelect; import com.mortals.xhx.module.site.model.SiteBusinessTreeSelect;
import org.springframework.util.ObjectUtils; import org.springframework.util.ObjectUtils;
import java.util.*; import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
* SiteBusinessService * SiteBusinessService
* 站点事项 service实现 * 站点事项 service实现
* *
* @author zxfei * @author zxfei
* @date 2022-01-13 * @date 2022-01-13
*/ */
@Service("siteBusinessService") @Service("siteBusinessService")
public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusinessDao, SiteBusinessEntity, Long> implements SiteBusinessService { public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusinessDao, SiteBusinessEntity, Long> implements SiteBusinessService {
@Override @Override
protected void findAfter(SiteBusinessEntity params, Context context, List<SiteBusinessEntity> list) throws AppException { protected void findAfter(SiteBusinessEntity params, Context context, List<SiteBusinessEntity> list) throws AppException {
list.stream().peek(item->{ list.stream().peek(item -> {
List<SiteBusinessEntity> childs = this.find(new SiteBusinessQuery().parentId(item.getBusinessId()));
if(!ObjectUtils.isEmpty(childs)){ List<SiteBusinessEntity> childs = this.find(new SiteBusinessQuery().parentId(item.getBusinessId()));
item.setChildren(childs); item.setChildren(childs);
}else{
item.setChildren(null);
}
}).count(); }).count();
super.findAfter(params, context, list); super.findAfter(params, context, list);
} }
...@@ -68,7 +70,6 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines ...@@ -68,7 +70,6 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines
} }
@Override @Override
public boolean hasChildBySiteBusinessId(Long siteBusinessId) { public boolean hasChildBySiteBusinessId(Long siteBusinessId) {
List<SiteBusinessEntity> list = this.find(new SiteBusinessQuery().parentId(siteBusinessId)); List<SiteBusinessEntity> list = this.find(new SiteBusinessQuery().parentId(siteBusinessId));
...@@ -92,8 +93,8 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines ...@@ -92,8 +93,8 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines
recursionFn(list, siteBusinessEntity); recursionFn(list, siteBusinessEntity);
returnList.add(siteBusinessEntity); returnList.add(siteBusinessEntity);
} }
} }
if (returnList.isEmpty()) { if (returnList.isEmpty()) {
returnList = list; returnList = list;
} }
...@@ -102,8 +103,8 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines ...@@ -102,8 +103,8 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines
/** /**
* 递归列表 * 递归列表
*/ */
private void recursionFn(List<SiteBusinessEntity> list, SiteBusinessEntity t) { private void recursionFn(List<SiteBusinessEntity> list, SiteBusinessEntity t) {
// 得到子节点列表 // 得到子节点列表
List<SiteBusinessEntity> childList = getChildList(list, t); List<SiteBusinessEntity> childList = getChildList(list, t);
...@@ -116,22 +117,22 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines ...@@ -116,22 +117,22 @@ public class SiteBusinessServiceImpl extends AbstractCRUDServiceImpl<SiteBusines
} }
/** /**
* 判断是否有子节点 * 判断是否有子节点
*/ */
private boolean hasChild(List<SiteBusinessEntity> list, SiteBusinessEntity t) { private boolean hasChild(List<SiteBusinessEntity> list, SiteBusinessEntity t) {
return getChildList(list, t).size() > 0 ? true : false; return getChildList(list, t).size() > 0 ? true : false;
} }
/** /**
* 得到子节点列表 * 得到子节点列表
*/ */
private List<SiteBusinessEntity> getChildList(List<SiteBusinessEntity> list, SiteBusinessEntity t) { private List<SiteBusinessEntity> getChildList(List<SiteBusinessEntity> list, SiteBusinessEntity t) {
return list.stream().map(item->{ return list.stream().map(item -> {
if (!ObjectUtils.isEmpty(item.getParentId()) && item.getParentId() == t.getId()) { if (!ObjectUtils.isEmpty(item.getParentId()) && item.getParentId() == t.getId()) {
return item; return item;
} }
return null; return null;
}).filter(f->f!=null).collect(Collectors.toList()); }).filter(f -> f != null).collect(Collectors.toList());
} }
} }
\ No newline at end of file
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