jz.git - Gitblit

			@@ -10,6 +10,7 @@
			import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.example.jz.dao.*;
			import com.example.jz.modle.PageParam;
			import com.example.jz.modle.dto.AddReportDto;
			import com.example.jz.modle.dto.ReportParamDto;
			import com.example.jz.modle.entity.*;
			@@ -17,9 +18,11 @@
			import com.example.jz.modle.vo.ReportListVo;
			import com.example.jz.service.MinIOService;
			import com.example.jz.service.ReportService;
			import com.example.jz.service.UserService;
			import lombok.SneakyThrows;
			import org.springframework.beans.BeanUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.security.core.context.SecurityContextHolder;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;

			@@ -33,6 +36,7 @@
			import java.util.ArrayList;
			import java.util.Date;
			import java.util.List;
			import java.util.stream.Collectors;

			/**
			* 报案表(Report)表服务实现类
			@@ -55,6 +59,10 @@

			@Resource
			UserDao userDao;
			@Resource
			UserService userService;
			@Resource
			ReportService reportService;

			@Resource
			MinIOService minIOService;
			@@ -66,21 +74,28 @@
			* @return
			*/
			@Override
			@Transactional
			@Transactional(rollbackFor = Exception.class)
			public Boolean audit(Report report) {
			// 1. 更新报案表
			report.setStatus(1);
			report.setIsInGroup(1);
			reportDao.updateById(report);
			// 2. 更新群用户表
			Group group = groupDao.selectOne(new LambdaQueryWrapper<>(Group.class)
			.eq(Group::getCauseId, report.getCauseId()));
			GroupUser groupUser = new GroupUser().setGroupId(group.getId()).setUserId(report.getUserId()).setCtime(new Date()).setBanSpeech(0);
			groupUserDao.insert(groupUser);
			if (!groupUserDao.selectUserList(group.getId()).contains(report.getUserId())) {
			GroupUser groupUser = new GroupUser().setGroupId(group.getId()).setUserId(report.getId()).setCtime(new Date()).setBanSpeech(0);
			return groupUserDao.insert(groupUser) == 1 ? true : false;
			}
			return true;
			}

			@Override
			public void leaveGroup(Integer id, Integer groupId) {
			Report report = new Report();
			report.setIsInGroup(0);
			report.setId(id);
			reportDao.updateById(report);
			groupUserDao.delete(new QueryWrapper<GroupUser>().eq("user_id", id).eq("group_id", groupId));
			}

			@@ -133,7 +148,7 @@
			}
			);
			String name = causeDao.selectOne(new QueryWrapper<Cause>().eq("id", id)).getName();
			response.setContentType("application/vnd.ms-excel");
			response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
			response.setCharacterEncoding("utf-8");
			response.setHeader("Content-disposition", "attachment;filename=" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")) + URLEncoder.encode(name + ".xlsx", "utf-8"));
			EasyExcel.write(response.getOutputStream(), ExportExcelReportVo.class).sheet("材料导出").doWrite(exportExcelReportVos);
			@@ -142,7 +157,8 @@
			@Override
			public Page<ReportListVo> getPage(Page<ReportListVo> page, ReportParamDto reportParamDto) {
			Page<ReportListVo> aaa = reportDao.getPage(page, reportParamDto);
			aaa.getRecords().stream().forEach(x -> x.setIdcard(x.getIdcard().replaceAll("(?<=[\\d]{3})\\d(?=[\\d]{4})", "*")));
			aaa.getRecords().stream()
			.forEach(x -> x.setIdcard(x.getIdcard().replaceAll("(?<=[\\d]{3})\\d(?=[\\d]{4})", "*")));
			return aaa;
			}

			@@ -152,8 +168,19 @@
			}

			@Override
			public Page<ReportListVo> getPageByGroupId(Page<ReportListVo> page, ReportParamDto reportParamDto, Integer groupId) {
			Page<ReportListVo> aaa = reportDao.getPageByGroupId(page, reportParamDto, groupId);
			public Page<ReportListVo> getPageByGroupId(Page<ReportListVo> page, ReportParamDto reportParamDto, Integer causeId) {
			Long size = (page.getCurrent() - 1) * page.getSize();
			Long current = page.getSize();
			Page<ReportListVo> aaa = new PageParam<>();
			List<ReportListVo> list = reportDao.getPageByGroupId(reportParamDto, causeId, size, current);
			list.forEach(item -> {
			if (item.getIsInGroup() == 1) {
			item.setGroupId(groupDao.selectOne(new QueryWrapper<Group>().eq("cause_id", causeId)).getId());
			}
			});
			aaa.setRecords(list);
			Integer pageByGroupIdCount = reportDao.getPageByGroupIdCount(reportParamDto, causeId);
			aaa.setTotal(pageByGroupIdCount);
			aaa.getRecords().stream().forEach(x -> x.setIdcard(x.getIdcard().replaceAll("(?<=[\\d]{3})\\d(?=[\\d]{4})", "*")));
			return aaa;
			}
			@@ -165,18 +192,26 @@
			if (user == null) {
			// 如果用户不存在则添加用户
			user = new User().setUserIdcard(addReportDto.getIdcard()).setUserMobile(addReportDto.getMobile()).setRealName(addReportDto.getReporterName())
			.setModifyTime(new Date()).setUserRegtime(new Date()).setPic(addReportDto.getPic());
			userDao.insert(user);
			.setModifyTime(new Date()).setUserRegtime(new Date()).setPic(addReportDto.getPic()).setCtime(new Date());
			userService.save(user);
			}
			// 添加人员进群组
			// groupUserDao.insert(new GroupUser()
			// .setGroupId(groupDao.selectOne(new QueryWrapper<Group>().eq("cause_id", addReportDto.getCauseId())).getId())
			// .setUserId(user.getId()).setCtime(new Date())
			// .setBanSpeech(0));
			// 添加报案信息
			Report report = new Report();
			BeanUtils.copyProperties(addReportDto, report);
			report
			.setCreator(userDao.selectOne(new QueryWrapper<User>().eq("login_username", SecurityContextHolder.getContext().getAuthentication().getPrincipal())).getId())
			.setUserId(user.getId())
			.setCtime(new Date())
			.setStatus(0)
			.setReportMethod("现场录入")
			.setIsCommission("0").setReportTime(new Date());
			return reportDao.insert(report) > 0;
			.setIsInGroup(0)
			.setReportMethod("后台录入")
			.setIsCommission("0").setReportTime(new Date())
			.setCauseId(addReportDto.getCauseId());
			return reportService.save(report);
			}
			}