| | |
| | | if(origin == DataSyncConfig.origin.erp){ |
| | | collect= companies.stream().filter(s -> ( StringUtils.defaultString(s.getErpParentId(),"").equals(StringUtils.defaultString(parentId)))).collect(Collectors.toList()); |
| | | }else if(origin == DataSyncConfig.origin.hk){ |
| | | collect= companies.stream().filter(s -> ( StringUtils.defaultString(s.getHkParentId(),"").equals(StringUtils.defaultString(parentId)))).collect(Collectors.toList()); |
| | | collect= companies.stream().filter(s -> |
| | | ( StringUtils.defaultString(s.getHkParentId(),"").equals(StringUtils.defaultString(parentId)))).collect(Collectors.toList()); |
| | | }else{ |
| | | collect= companies.stream().filter(s -> (StringUtils.defaultString(s.getParentId()+"","").equals(StringUtils.defaultString(parentId)))).collect(Collectors.toList()); |
| | | } |
| | |
| | | .selectAll(HiddenDanger.class) |
| | | .selectAs(HiddenDangerParam::getCompanyId, HiddenDanger::getAreaCompanyId) |
| | | .leftJoin(HiddenDangerParam.class,HiddenDangerParam::getId,HiddenDanger::getAreaId) //隐患区域 |
| | | .eq(HiddenDanger::getIsdeleted,Constants.ZERO) |
| | | .eq(Objects.nonNull(hiddenDanger.getStatus()),HiddenDanger::getStatus,hiddenDanger.getStatus()) |
| | | .ge(Objects.nonNull(hiddenDanger.getQueryStartTime()), HiddenDanger::getCreateDate,hiddenDanger.getQueryStartTime()) |
| | | .le(Objects.nonNull(hiddenDanger.getQueryEndTime()),HiddenDanger::getCreateDate,hiddenDanger.getQueryEndTime()) |