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


@@ -6,22 +6,23 @@


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;


import com.example.jz.service.UserService;


import com.example.jz.utils.IdUtils;


import lombok.SneakyThrows;


import org.springframework.beans.BeanUtils;


import org.springframework.security.core.context.SecurityContextHolder;


@@ -31,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;




/**


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


@@ -166,6 +204,10 @@


        Cause cause = new Cause();


        BeanUtils.copyProperties(causeDto, cause);


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


    }




@@ -197,17 +239,46 @@


    }




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


                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())


                        .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){


            messageDao.delete(new LambdaQueryWrapper<Message>().eq(Message::getGroupId,group.getId()));


            groupUserDao.delete(new LambdaQueryWrapper<GroupUser>().eq(GroupUser::getGroupId,group.getId()));


        if (group != null) {


            messageDao.delete(new LambdaQueryWrapper<Message>().eq(Message::getGroupId, group.getId()));


            groupUserDao.delete(new LambdaQueryWrapper<GroupUser>().eq(GroupUser::getGroupId, group.getId()));


        }


        groupDao.delete(new QueryWrapper<Group>().eq("cause_id", id));


    }


@@ -236,6 +307,7 @@


                a -> {


                    Cause cause = new Cause();


                    BeanUtils.copyProperties(a, cause);


                    cause.setNumber(IdUtils.getAduitId());


                    if (StringUtils.isBlank(a.getStatus())) {


                        throw new BusinessException("状态不能为空");


                    }


@@ -295,8 +367,9 @@


                .setUserId(user.getId())


                .setCtime(new Date())


                .setStatus(1)


                .setReportMethod("后台录入")


                .setIsCommission("0").setReportTime(new Date())


                .setReportMethod("现场报案")


                .setIsCommission("0")


                .setReportTime(new Date())


                .setCauseId(addReportDto.getCauseId());


        reportService.save(report);


        return groupUserDao.insert(new GroupUser().setGroupId(group.getId()).setUserId(report.getId()).setCtime(new Date()).setBanSpeech(0)) > 0;


@@ -305,7 +378,7 @@


    @Override


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


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


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


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


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


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


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