青羊经侦大队-数据平台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
baizonghao
2023-05-19 1c3f11dfd7493a4c4a8d41e2499477840bcc070c 
 src/main/java/com/example/jz/service/impl/CauseServiceImpl.java


@@ -13,10 +13,7 @@


import com.example.jz.enums.CauseEnums;


import com.example.jz.exception.BusinessException;


import com.example.jz.modle.PageParam;


import com.example.jz.modle.dto.AddReportDto;


import com.example.jz.modle.dto.AddReportLoadDto;


import com.example.jz.modle.dto.CauseDto;


import com.example.jz.modle.dto.CauseLoadDto;


import com.example.jz.modle.dto.*;


import com.example.jz.modle.entity.*;


import com.example.jz.modle.vo.CauseReportVo;


import com.example.jz.modle.vo.CauseVo;


@@ -242,6 +239,33 @@


    }




    @Override


    public List<CauseReportExpDto> getExpList(Integer causeId) {


        List<Report> reports = reportDao.selectList(Wrappers.<Report>lambdaQuery().eq(Report::getCauseId, causeId));


        List<Integer> userIds = reports.stream().map(report -> report.getUserId()).collect(Collectors.toList());


        List<User> users = userDao.selectList(Wrappers.<User>lambdaQuery().in(User::getId, userIds));


        List<CauseReportExpDto> res = users.stream().map(new Function<User, CauseReportExpDto>() {


            @Override


            public CauseReportExpDto apply(User user) {


                Double amountInvolved = reportDao.selectOne(Wrappers.<Report>lambdaQuery().eq(Report::getCauseId, causeId).eq(Report::getUserId, user.getId())).getAmountInvolved();


                CauseReportExpDto build = CauseReportExpDto.builder()


                        .realName(user.getRealName())


                        .userMobile(user.getUserMobile())


                        .userIdcard(user.getUserMobile())


                        .userIdcard(user.getUserIdcard())


                        .sex(user.getSex())


                        .location(user.getLocation())


                        .workingLocation(user.getWorkingLocation())


                        .amountInvolved(amountInvolved)


                        .ctime(user.getCtime())


                        .userMemo(user.getUserMemo())


                        .build();


                return build;


            }


        }).collect(Collectors.toList());


        return res;


    }




    @Override


    public List<Announcement> getGroupAnnouncement(Integer groupId) {


        return announcementDao.selectList(new QueryWrapper<Announcement>().eq("group_id", groupId));


    }


@@ -356,7 +380,7 @@


    @Override


    public List<Map<String, String>> getCauseIdAndName() {


        ArrayList<Map<String, String>> maps = new ArrayList<>();


        causeDao.selectList(new QueryWrapper<Cause>().eq("status", 0).or().eq("status", 2)).stream().forEach(a -> {


        causeDao.selectList(null).stream().forEach(a -> {


            Map<String, String> map = new HashMap<>();


            map.put("id", a.getId().toString());


            map.put("name", a.getName());