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


@@ -3,23 +3,21 @@


import com.alibaba.excel.EasyExcel;


import com.alibaba.excel.context.AnalysisContext;


import com.alibaba.excel.event.AnalysisEventListener;


import com.baomidou.mybatisplus.core.conditions.Wrapper;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.toolkit.StringUtils;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.core.toolkit.support.SFunction;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.example.jz.dao.*;


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;


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


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


import com.example.jz.service.CauseService;


import com.example.jz.service.ReportService;


@@ -34,6 +32,8 @@




import javax.annotation.Resource;


import java.util.*;


import java.util.function.Function;


import java.util.function.Predicate;


import java.util.stream.Collectors;




/**


@@ -155,6 +155,41 @@


    }




    @Override


    public List<NewCauseVo> getVxCauseList(String phone) {




        User user = userDao.selectOne(new LambdaQueryWrapper<User>().eq(User::getUserMobile, phone));




        List<Report> reports = reportDao.selectList(new LambdaQueryWrapper<Report>().eq(Report::getUserId, user.getId()));




        List<Integer> list = reports.stream()


                .map(item -> item.getCauseId())


                .filter(integer -> integer != null)


                .distinct()


                .collect(Collectors.toList());


        List<NewCauseVo> res;


        if (!Objects.isNull(list) && list.size()!= 0){


            List<Cause> causes = causeDao.selectList(new LambdaQueryWrapper<Cause>().notIn(Cause::getId, list));


            res = causes.stream()


                    .map(item -> {


                        NewCauseVo newCauseVo = new NewCauseVo();


                        newCauseVo.setName(item.getName());


                        newCauseVo.setId(item.getId());


                        return newCauseVo;


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


        }else {


            List<Cause> causes = causeDao.selectList(null);


            res = causes.stream()


                    .map(item -> {


                        NewCauseVo newCauseVo = new NewCauseVo();


                        newCauseVo.setName(item.getName());


                        newCauseVo.setId(item.getId());


                        return newCauseVo;


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


        }


        return res;


    }




    @Override


    public List<UserVo> getManagerList() {


        return userDao.selectList(new QueryWrapper<User>().eq("role", 1)).stream().map(a -> {


            UserVo userVo = new UserVo();


@@ -171,6 +206,7 @@


        cause.setId(id);


        groupDao.update(null, Wrappers.lambdaUpdate(Group.class)


                .set(Group::getGroupName, causeDto.getName())


                        .set(Group::getUserId, causeDto.getUserId())


                .eq(Group::getCauseId, id));


        return causeDao.updateById(cause);


    }


@@ -203,12 +239,43 @@


    }




    @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));


    }




    @Override


    public void deleteCause(Integer id) {


        List<Report> reports = reportDao.selectList(new LambdaQueryWrapper<Report>().eq(Report::getCauseId, id));


        for (Report report : reports) {


            reportDao.deleteById(report.getId());


        }


        causeDao.deleteById(id);


        Group group = groupDao.selectOne(new LambdaQueryWrapper<Group>().eq(Group::getCauseId, id));


        if (group != null) {


@@ -313,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());