| | |
| | | package com.ruoyi.web.controller.api; |
| | | |
| | | |
| | | import cn.hutool.core.util.RandomUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.ruoyi.common.annotation.Log; |
| | | import com.ruoyi.common.basic.PageInfo; |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | import com.ruoyi.common.core.domain.BaseModel; |
| | | import com.ruoyi.common.core.domain.R; |
| | | import com.ruoyi.common.core.domain.entity.SysRole; |
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
| | | import com.ruoyi.common.enums.BusinessType; |
| | | import com.ruoyi.common.redis.service.RedisService; |
| | | import com.ruoyi.common.utils.DateUtils; |
| | | import com.ruoyi.common.utils.bean.BeanUtils; |
| | | import com.ruoyi.framework.web.service.TokenService; |
| | | import com.ruoyi.system.applet.dto.*; |
| | | import com.ruoyi.system.applet.query.AppealListQuery; |
| | | import com.ruoyi.system.applet.query.KnowledgeListUserQuery; |
| | | import com.ruoyi.system.applet.query.TaskUserListQuery; |
| | | import com.ruoyi.system.applet.vo.KnowledgeVO; |
| | | import com.ruoyi.system.applet.vo.TaskListAllVO; |
| | | import com.ruoyi.system.applet.vo.TaskUserListVO; |
| | | import com.ruoyi.system.applet.query.*; |
| | | import com.ruoyi.system.applet.vo.*; |
| | | import com.ruoyi.system.dto.KnowledgeDTO; |
| | | import com.ruoyi.system.dto.TTaskAuditBatchDTO; |
| | | import com.ruoyi.system.dto.TTaskAuditDTO; |
| | |
| | | import com.ruoyi.system.query.KnowledgeListQuery; |
| | | import com.ruoyi.system.query.TaskListQuery; |
| | | import com.ruoyi.system.service.*; |
| | | import com.ruoyi.system.utils.wx.body.resp.Code2SessionRespBody; |
| | | import com.ruoyi.system.utils.wx.body.resq.Code2SessionResqBody; |
| | | import com.ruoyi.system.utils.wx.model.WeixinProperties; |
| | | import com.ruoyi.system.utils.wx.pojo.AppletUserDecodeData; |
| | | import com.ruoyi.system.utils.wx.pojo.AppletUserEncrypteData; |
| | | import com.ruoyi.system.utils.wx.tools.WxAppletTools; |
| | | import com.ruoyi.system.utils.wx.tools.WxUtils; |
| | | import com.ruoyi.system.vo.system.*; |
| | | import com.ruoyi.web.controller.tool.EmailUtils; |
| | | import com.ruoyi.web.controller.tool.MsgUtils; |
| | | import com.sun.jna.platform.win32.LMAccess; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.util.StringUtils; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import org.springframework.web.client.RestTemplate; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.validation.Valid; |
| | | import java.math.BigDecimal; |
| | | import java.math.RoundingMode; |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.LocalDate; |
| | | import java.time.LocalDateTime; |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.List; |
| | | import java.time.LocalTime; |
| | | import java.time.format.DateTimeFormatter; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | |
| | | * @author xiaochen |
| | | * @since 2025-05-28 |
| | | */ |
| | | @Slf4j |
| | | @Api(tags = "个人中心") |
| | | @RestController |
| | | @RequestMapping("/t-user") |
| | |
| | | @Resource |
| | | private ISysUserService sysUserService; |
| | | @Resource |
| | | private ISysRoleService roleService; |
| | | @Resource |
| | | private TDictDataService dictDataService; |
| | | @Resource |
| | | private TNoticeSetService noticeSetService; |
| | | @Resource |
| | | private TLeaveService leaveService; |
| | | @Resource |
| | | private TLeaveAuditService leaveAuditService; |
| | | @Resource |
| | | private TokenService tokenService; |
| | | @Resource |
| | |
| | | private TFeedbackService feedbackService; |
| | | @Resource |
| | | private TProblemEscalationService problemEscalationService; |
| | | @Resource |
| | | private TNoticeService noticeService; |
| | | @Autowired |
| | | private RestTemplate wxRestTemplate; |
| | | @Autowired |
| | | private WeixinProperties weixinProperties; |
| | | @Resource |
| | | private RedisService redisService; |
| | | @ApiOperation(value = "通过code获得openid,获取用户信息",tags = {"微信小程序登录"}) |
| | | @GetMapping("/openIdByJsCode") |
| | | public R<String> openIdByJsCode(@RequestParam String code) { |
| | | Long userId = tokenService.getLoginUser().getUserId(); |
| | | SysUser sysUser = sysUserService.selectUserById(userId); |
| | | if(Objects.isNull(sysUser)){ |
| | | return R.fail("未查询到当前登录用户信息"); |
| | | } |
| | | if(StringUtils.hasLength(sysUser.getOpenId())){ |
| | | return R.ok(); |
| | | } |
| | | log.info("<<<<<<<<换取openid开始<<<<<<<<:{}", code); |
| | | WxAppletTools appletTools = new WxAppletTools(wxRestTemplate, weixinProperties, redisService); |
| | | Code2SessionRespBody body = appletTools.getOpenIdByJscode2session(new Code2SessionResqBody().build(code)); |
| | | String openid = body.getOpenid(); |
| | | sysUser.setOpenId(openid); |
| | | sysUserService.updateUser(sysUser); |
| | | return R.ok(); |
| | | } |
| | | @Resource |
| | | private MsgUtils msgUtils; |
| | | |
| | | @ApiOperation(value = "消息通知列表") |
| | | @PostMapping(value = "/noticeList") |
| | | public R<PageInfo<NoticeListVO>> noticeList(@RequestBody NoticeListQuery query) { |
| | | Long userId = tokenService.getLoginUserApplet().getUserId(); |
| | | query.setUserId(userId + ""); |
| | | PageInfo<NoticeListVO> noticeListVOPageInfo = noticeService.noticeList(query); |
| | | List<NoticeListVO> records = noticeListVOPageInfo.getRecords(); |
| | | List<NoticeListVO> noticeListVOS = new ArrayList<>(records); |
| | | for (NoticeListVO noticeListVO : noticeListVOS) { |
| | | noticeListVO.setStatus(2); |
| | | noticeService.updateById(noticeListVO); |
| | | } |
| | | return R.ok(noticeListVOPageInfo); |
| | | } |
| | | |
| | | /** |
| | | * 生成数据 |
| | | * |
| | | * @param id |
| | | * @return |
| | | */ |
| | | @ApiOperation(value = "测试接口不要调") |
| | | |
| | | @GetMapping(value = "/testData") |
| | | public R<AppealDetailVO> testData(@RequestParam String id) { |
| | | // List<TAppeal> tAppeals = new ArrayList<>(); |
| | | // for (int i = 0; i < 25; i++) { |
| | | // TAppeal tAppeal = new TAppeal(); |
| | | // tAppeal.setTaskId("1938536771253641217"); |
| | | // tAppeal.setAppealPerson("152"); |
| | | // tAppeal.setStatus(1); |
| | | // tAppeal.setAppealContent("申诉"); |
| | | // tAppeal.setPictures("https://bjxj.oss-cn-guangzhou.aliyuncs.com/bjxj/88d2d5614fe6492bba5666a7ab01e76b.png"); |
| | | // tAppeals.add(tAppeal); |
| | | // } |
| | | // appealService.saveBatch(tAppeals); |
| | | // List<TAppeal> tAppeals1 = new ArrayList<>(); |
| | | // for (int i = 0; i < 25; i++) { |
| | | // TAppeal tAppeal = new TAppeal(); |
| | | // tAppeal.setTaskId("1938536771253641217"); |
| | | // tAppeal.setAppealPerson("152"); |
| | | // tAppeal.setStatus(2); |
| | | // tAppeal.setAppealContent("申诉"); |
| | | // tAppeal.setPictures("https://bjxj.oss-cn-guangzhou.aliyuncs.com/bjxj/88d2d5614fe6492bba5666a7ab01e76b.png"); |
| | | // tAppeal.setAuditPerson("162"); |
| | | // tAppeal.setAuditRemark("备注"); |
| | | // tAppeal.setAuditTime(LocalDateTime.now()); |
| | | // tAppeals1.add(tAppeal); |
| | | // } |
| | | // appealService.saveBatch(tAppeals1); |
| | | // List<TAppeal> tAppeals2 = new ArrayList<>(); |
| | | // for (int i = 0; i < 25; i++) { |
| | | // TAppeal tAppeal = new TAppeal(); |
| | | // tAppeal.setTaskId("1938536771253641217"); |
| | | // tAppeal.setAppealPerson("152"); |
| | | // tAppeal.setStatus(3); |
| | | // tAppeal.setAppealContent("申诉"); |
| | | // tAppeal.setPictures("https://bjxj.oss-cn-guangzhou.aliyuncs.com/bjxj/88d2d5614fe6492bba5666a7ab01e76b.png"); |
| | | // tAppeal.setAuditPerson("162"); |
| | | // tAppeal.setAuditRemark("备注"); |
| | | // tAppeal.setAuditTime(LocalDateTime.now()); |
| | | // tAppeals2.add(tAppeal); |
| | | // } |
| | | // appealService.saveBatch(tAppeals2); |
| | | // List<TAppeal> tAppeals3 = new ArrayList<>(); |
| | | // for (int i = 0; i < 25; i++) { |
| | | // TAppeal tAppeal = new TAppeal(); |
| | | // tAppeal.setTaskId("1938536771253641217"); |
| | | // tAppeal.setAppealPerson("152"); |
| | | // tAppeal.setStatus(4); |
| | | // tAppeal.setAppealContent("申诉"); |
| | | // tAppeal.setPictures("https://bjxj.oss-cn-guangzhou.aliyuncs.com/bjxj/88d2d5614fe6492bba5666a7ab01e76b.png"); |
| | | // |
| | | // tAppeals3.add(tAppeal); |
| | | // |
| | | // } |
| | | // appealService.saveBatch(tAppeals3); |
| | | return R.ok(); |
| | | } |
| | | |
| | | @ApiOperation(value = "个人中心-首页") |
| | | @PostMapping(value = "/userIndex") |
| | | public R<UserIndexVO> userIndex() { |
| | | UserIndexVO userIndexVO = new UserIndexVO(); |
| | | List<SysUser> userAll = sysUserService.selectAllList(); |
| | | List<SysUser> users = userAll.stream().filter(e -> e.getUserId() != 1).collect(Collectors.toList()); |
| | | |
| | | Long userId = tokenService.getLoginUserApplet().getUserId(); |
| | | SysUser sysUser = sysUserService.selectUserById(userId); |
| | | userIndexVO.setAvatar(sysUser.getAvatar()); |
| | | userIndexVO.setNickName(sysUser.getNickName()); |
| | | userIndexVO.setPhonenumber(sysUser.getPhonenumber()); |
| | | if (sysUser.getDeptType() == 1) { |
| | | TProjectDept tProjectDept = projectDeptService.getById(sysUser.getDeptId()); |
| | | if (!tProjectDept.getParentId().equals("0")) { |
| | | TProjectDept tProjectDept1 = projectDeptService.getById(tProjectDept.getParentId()); |
| | | userIndexVO.setDeptName(tProjectDept1.getProjectName() + ">" + tProjectDept.getProjectName()); |
| | | } else { |
| | | userIndexVO.setDeptName(tProjectDept.getProjectName()); |
| | | } |
| | | } else { |
| | | TDept tDept = deptService.getById(sysUser.getDeptId()); |
| | | if (tDept != null) { |
| | | userIndexVO.setDeptName(tDept.getDeptName()); |
| | | } |
| | | } |
| | | // 查询请假状态 |
| | | List<TLeave> list = leaveService.lambdaQuery().eq(TLeave::getLeavePerson, userId) |
| | | .eq(TLeave::getAuditStatus, 2) |
| | | .list(); |
| | | userIndexVO.setIsLeave(0); |
| | | for (TLeave tLeave : list) { |
| | | LocalDate now = LocalDate.now(); |
| | | LocalDate startDate = tLeave.getStartTime().toLocalDate(); |
| | | LocalDate endDate = tLeave.getStartTime().toLocalDate(); |
| | | if (now.isAfter(startDate) && now.isBefore(endDate)) { |
| | | userIndexVO.setIsLeave(1); |
| | | } else if (now.isEqual(startDate) || now.isEqual(endDate)) { |
| | | userIndexVO.setIsLeave(1); |
| | | } |
| | | } |
| | | // 获取本月第一天凌晨00:00:00 和本月最后一天23:59:59 类型为LocalDateTime |
| | | // 获取当前日期 |
| | | LocalDate now = LocalDate.now(); |
| | | // 本月第一天 |
| | | LocalDate firstDayOfMonth = now.withDayOfMonth(1); |
| | | // 本月最后一天 |
| | | LocalDate lastDayOfMonth = now.withDayOfMonth(now.lengthOfMonth()); |
| | | // 转换为 LocalDateTime:第一天的 00:00:00 |
| | | LocalDateTime startOfMonth = LocalDateTime.of(firstDayOfMonth, LocalTime.MIN); |
| | | // 转换为 LocalDateTime:最后一天的 23:59:59 |
| | | LocalDateTime endOfMonth = LocalDateTime.of(lastDayOfMonth, LocalTime.MAX); |
| | | List<TTask> finishTask = taskCleanerService.lambdaQuery().eq(TTask::getPatrolInspector, userId) |
| | | .ge(TTask::getImplementTime, startOfMonth) |
| | | .le(TTask::getImplementTime, endOfMonth).list(); |
| | | List<String> taskIds = finishTask.stream().map(TTask::getId).collect(Collectors.toList()); |
| | | if (taskIds.isEmpty()){ |
| | | taskIds.add("-1"); |
| | | } |
| | | List<TTaskDetail> taskDetails = taskDetailService.lambdaQuery() |
| | | .in(TTaskDetail::getTaskId, taskIds) |
| | | .eq(TTaskDetail::getAuditStatus, 1) |
| | | .eq(TTaskDetail::getHandleType,1) |
| | | .isNotNull(TTaskDetail::getClearStatus) |
| | | .orderByDesc(TTaskDetail::getCreateTime).list(); |
| | | // 使用 stream 去重,保留每个 taskId 最新的一条 |
| | | taskDetails = new ArrayList<>(taskDetails.stream() |
| | | .collect(Collectors.groupingBy( |
| | | TTaskDetail::getTaskId, |
| | | Collectors.collectingAndThen( |
| | | Collectors.toList(), |
| | | listAll -> listAll.get(0) |
| | | ) |
| | | )) |
| | | .values()); |
| | | |
| | | int size = (int) finishTask.stream().filter(e -> e.getStatus() == 5 || e.getStatus() == 6).count(); |
| | | List<String> taskIdsStatus = finishTask.stream().map(TTask::getId).collect(Collectors.toList()); |
| | | if (taskIdsStatus.isEmpty()){ |
| | | taskIdsStatus.add("-1"); |
| | | } |
| | | userIndexVO.setFinishCount(size); |
| | | List<TTaskDetail> status1 = taskDetails.stream().filter(e -> e.getClearStatus() == 1&&taskIdsStatus.contains(e.getTaskId())).collect(Collectors.toList()); |
| | | List<TTaskDetail> status2 = taskDetails.stream().filter(e -> e.getClearStatus() == 2&&taskIdsStatus.contains(e.getTaskId())).collect(Collectors.toList()); |
| | | if (!status1.isEmpty()) { |
| | | BigDecimal divide = new BigDecimal(status1.size()) |
| | | .divide(new BigDecimal(status1.size()+status2.size()), 2, BigDecimal.ROUND_DOWN).multiply(new BigDecimal(100)); |
| | | userIndexVO.setRate(divide); |
| | | } else { |
| | | userIndexVO.setRate(new BigDecimal(0)); |
| | | } |
| | | |
| | | // 判断时间 |
| | | String startTime = ""; |
| | | String endTime = ""; |
| | | Map<String, Date> monthDate = DateUtils.getMonthDate(new Date()); |
| | | startTime = new SimpleDateFormat("yyyy-MM-dd").format((monthDate.get("first"))) + " 00:00:00"; |
| | | endTime = new SimpleDateFormat("yyyy-MM-dd").format((monthDate.get("last"))) + " 23:59:59"; |
| | | List<TTask> taskRank = taskCleanerService.lambdaQuery().between(TTask::getImplementTime, startTime, endTime).list(); |
| | | List<String> taskIdsRank = taskRank.stream().map(TTask::getId).collect(Collectors.toList()); |
| | | if (taskIdsRank.isEmpty()){ |
| | | userIndexVO.setRanking(0); |
| | | }else{ |
| | | |
| | | for (SysUser user : users) { |
| | | int finishCount = (int) taskRank.stream().filter(e->e.getPatrolInspector().equals(user.getUserId()+"")&&e.getStatus() == 5 || e.getStatus() == 6).count(); |
| | | int totalCount = (int) taskRank.stream().filter(e->e.getPatrolInspector().equals(user.getUserId()+"")).count(); |
| | | if (totalCount!=0){ |
| | | user.setFinish(new BigDecimal(finishCount).divide(new BigDecimal(totalCount),2, RoundingMode.HALF_DOWN)); |
| | | }else{ |
| | | user.setFinish(BigDecimal.ZERO); |
| | | } |
| | | List<TTaskDetail> status1User = taskDetails.stream().filter(e -> e.getClearStatus() == 1).collect(Collectors.toList()); |
| | | List<TTaskDetail> status2User = taskDetails.stream().filter(e -> e.getClearStatus() == 2).collect(Collectors.toList()); |
| | | if (!status1User.isEmpty()) { |
| | | BigDecimal divide = new BigDecimal(status1User.size() + status2User.size()) |
| | | .divide(new BigDecimal(status1User.size()), 2, BigDecimal.ROUND_DOWN).multiply(new BigDecimal(100)); |
| | | user.setRate(divide); |
| | | } else { |
| | | user.setRate(new BigDecimal(0)); |
| | | } |
| | | } |
| | | // 将users进行排序,优先根据rate倒叙排序,如果rate相同 再finish倒叙排序 |
| | | users.sort((o1, o2) -> { |
| | | if (o1.getRate().compareTo(o2.getRate()) == 0) { |
| | | return o2.getFinish().compareTo(o1.getFinish()); |
| | | } else { |
| | | return o2.getRate().compareTo(o1.getRate()); |
| | | } |
| | | }); |
| | | // 查询当前登陆人处于哪一个排名 |
| | | for (int i = 0; i < users.size(); i++) { |
| | | if (users.get(i).getUserId().equals(userId)) { |
| | | userIndexVO.setRanking(i + 1); |
| | | break; |
| | | } |
| | | } |
| | | |
| | | } |
| | | return R.ok(userIndexVO); |
| | | } |
| | | |
| | | @ApiOperation(value = "任务记录分页列表") |
| | | @PostMapping(value = "/taskList") |
| | | public R<PageInfo<TaskUserListVO>> pageList(@RequestBody TaskUserListQuery query) { |
| | | Long userId = tokenService.getLoginUserApplet().getUserId(); |
| | | query.setUserId(userId+""); |
| | | query.setUserId(userId + ""); |
| | | return R.ok(taskCleanerService.pageListUser(query)); |
| | | } |
| | | |
| | |
| | | BeanUtils.copyProperties(byId, taskDetailVO); |
| | | TLocation byId1 = locationService.getById(byId.getLocationId()); |
| | | TLocationType byId2 = locationTypeService.getById(byId1.getLocationType()); |
| | | taskDetailVO.setLocationName(byId1.getLocationName()); |
| | | taskDetailVO.setLocationAddress(byId1.getLocationAddress()); |
| | | taskDetailVO.setLocationAddressEnd(byId1.getLocationAddressEnd()); |
| | | taskDetailVO.setLocationIcon(byId2.getLocationIcon()); |
| | | taskDetailVO.setLocationName(byId2.getLocationName()); |
| | | taskDetailVO.setLocationTypeName(byId2.getLocationName()); |
| | | taskDetailVO.setLocationLon(byId1.getLocationLon()); |
| | | taskDetailVO.setLocationLat(byId1.getLocationLat()); |
| | | taskDetailVO.setLocationLatEnd(byId1.getLocationLatEnd()); |
| | | taskDetailVO.setLocationLonEnd(byId1.getLocationLonEnd()); |
| | | TTaskDetail tTaskDetail = list.stream().filter(e -> e.getHandleType() == 1).findFirst().orElse(null); |
| | | if (tTaskDetail!=null && tTaskDetail.getUnqualified()!=null){ |
| | | if (tTaskDetail != null && tTaskDetail.getUnqualified() != null) { |
| | | TDictData byId3 = dictDataService.getById(tTaskDetail.getUnqualified()); |
| | | if (byId3!=null){ |
| | | if (byId3 != null) { |
| | | tTaskDetail.setUnqualifiedName(byId3.getDataContent()); |
| | | } |
| | | } |
| | | if (tTaskDetail != null) { |
| | | tTaskDetail.setFinishTime(tTaskDetail.getCreateTime()); |
| | | } |
| | | taskDetailVO.setTaskDetail(tTaskDetail); |
| | | taskDetailVO.setRecords(list); |
| | | if (byId.getStatus()==4){ |
| | | TTaskDetail reject = taskDetailService.lambdaQuery().eq(TTaskDetail::getTaskId, id) |
| | | .eq(TTaskDetail::getHandleType,3) |
| | | .orderByDesc(BaseModel::getCreateTime).last("limit 1").one(); |
| | | if (reject!=null){ |
| | | taskDetailVO.setRejectRemark(reject.getAuditRemark()); |
| | | } |
| | | } |
| | | return R.ok(taskDetailVO); |
| | | } |
| | | |
| | | @ApiOperation(value = "详情任务-操作记录-详情") |
| | | @GetMapping(value = "/detailRecord") |
| | | public R<TaskRecordDetailVO> detailRecord(@RequestParam String id) { |
| | |
| | | taskDetailVO.setLocationAddress(byId1.getLocationAddress()); |
| | | taskDetailVO.setLocationIcon(byId2.getLocationIcon()); |
| | | taskDetailVO.setLocationName(byId2.getLocationName()); |
| | | if ( byId4.getUnqualified()!=null){ |
| | | if (byId4.getUnqualified() != null) { |
| | | TDictData byId3 = dictDataService.getById(byId4.getUnqualified()); |
| | | if (byId3!=null){ |
| | | if (byId3 != null) { |
| | | byId4.setUnqualifiedName(byId3.getDataContent()); |
| | | } |
| | | } |
| | | byId4.setFinishTime(byId4.getCreateTime()); |
| | | SysUser sysUser = sysUserService.selectUserById(Long.valueOf(byId4.getAuditPerson())); |
| | | if (sysUser!=null){ |
| | | if (sysUser != null) { |
| | | byId4.setAuditPersonName(sysUser.getUserName()); |
| | | } |
| | | taskDetailVO.setTaskDetail(byId4); |
| | | return R.ok(taskDetailVO); |
| | | } |
| | | |
| | | @ApiOperation(value = "申诉记录分页列表") |
| | | @PostMapping(value = "/appealList") |
| | | public R<PageInfo<AppealListVO>> pageListUser(@RequestBody AppealListQuery query) { |
| | | query.setUserId(tokenService.getLoginUserApplet().getUserId() + ""); |
| | | return R.ok(appealService.pageListUser(query)); |
| | | } |
| | | |
| | | @ApiOperation(value = "详情申诉记录") |
| | | @GetMapping(value = "/appealDetail") |
| | | public R<AppealDetailVO> appealDetail(@RequestParam String id) { |
| | | AppealDetailVO appealDetailVO = new AppealDetailVO(); |
| | | TAppeal appeal = appealService.getById(id); |
| | | BeanUtils.copyProperties(appeal,appealDetailVO); |
| | | BeanUtils.copyProperties(appeal, appealDetailVO); |
| | | TTask byId = taskCleanerService.getById(appeal.getTaskId()); |
| | | TLocation byId1 = locationService.getById(byId.getLocationId()); |
| | | TLocationType byId2 = locationTypeService.getById(byId1.getLocationType()); |
| | | appealDetailVO.setLocationAddress(byId1.getLocationAddress()); |
| | | appealDetailVO.setLocationIcon(byId2.getLocationIcon()); |
| | | appealDetailVO.setLocationName(byId2.getLocationName()); |
| | | appealDetailVO.setLocationName(byId1.getLocationName()); |
| | | appealDetailVO.setTaskId(byId.getId()); |
| | | SysUser sysUser = sysUserService.selectUserById(Long.valueOf(appeal.getAuditPerson())); |
| | | if (sysUser!=null){ |
| | | appealDetailVO.setAuditPersonName(sysUser.getUserName()); |
| | | appealDetailVO.setLocationTypeName(byId2.getLocationName()); |
| | | if (StringUtils.hasLength(appeal.getAuditPerson())) { |
| | | SysUser sysUser = sysUserService.selectUserById(Long.valueOf(appeal.getAuditPerson())); |
| | | if (sysUser != null) { |
| | | appealDetailVO.setAuditPersonName(sysUser.getUserName()); |
| | | } |
| | | } |
| | | appealDetailVO.setTaskName(byId.getTaskName()); |
| | | appealDetailVO.setTaskCode(byId.getTaskCode()); |
| | | return R.ok(appealDetailVO); |
| | | } |
| | | |
| | | @Log(title = "取消申诉记录", businessType = BusinessType.OTHER) |
| | | @ApiOperation(value = "取消申诉记录") |
| | | @GetMapping(value = "/cancelAppeal") |
| | |
| | | appealService.updateById(byId); |
| | | return R.ok(); |
| | | } |
| | | |
| | | @ApiOperation(value = "获取距离最近的任务列表") |
| | | @PostMapping(value = "/listAllTask") |
| | | public R<List<TaskListAllVO>> listAllTask(@RequestBody AppealListDTO appealListDTO) { |
| | | appealListDTO.setUserId(tokenService.getLoginUserApplet().getUserId() + ""); |
| | | SysUser sysUser = sysUserService.selectUserById(tokenService.getLoginUserApplet().getUserId()); |
| | | // if (sysUser.getDeptType()==2){ |
| | | // // 公司部门查询所有任务 |
| | | // appealListDTO.setUserId(null); |
| | | // } |
| | | List<TaskListAllVO> res = appealService.listAllTask(appealListDTO); |
| | | return R.ok(res); |
| | | } |
| | | |
| | | @ApiOperation(value = "不合格原因列表") |
| | | @PostMapping(value = "/unqualifiedList") |
| | | public R<List<TDictData>> unqualifiedList() { |
| | | List<TDictData> list = dictDataService.list( |
| | | new LambdaQueryWrapper<TDictData>() |
| | | .eq(TDictData::getDataType,2) |
| | | .eq(TDictData::getDataType, 2) |
| | | ); |
| | | return R.ok(list); |
| | | } |
| | | |
| | | @ApiOperation(value = "上传督察任务") |
| | | @PostMapping(value = "/addInspector") |
| | | public R<Boolean> addInspector(@RequestBody InspectorAddDTO dto) { |
| | | dto.setCommit_person(tokenService.getLoginUser().getUserId()+""); |
| | | if (dto.getClearStatus()==1){ |
| | | public R<Boolean> addInspector(@RequestBody InspectorAddDTO dto) throws Exception { |
| | | TTask task = taskCleanerService.getById(dto.getTaskId()); |
| | | TLocation location = locationService.getById(task.getLocationId()); |
| | | SysUser sysUser = sysUserService.selectUserById(Long.valueOf(task.getPatrolInspector())); |
| | | dto.setCommitPerson(tokenService.getLoginUserApplet().getUserId() + ""); |
| | | |
| | | if (dto.getClearStatus() == 1) { |
| | | dto.setStatus(4); |
| | | }else{ |
| | | } else { |
| | | dto.setStatus(1); |
| | | |
| | | } |
| | | inspectorService.save(dto); |
| | | return R.ok(); |
| | | } |
| | | |
| | | @ApiOperation(value = "上传意见反馈") |
| | | @PostMapping(value = "/addFeedback") |
| | | public R<Boolean> addFeedback(@RequestBody FeedbackDTO dto) { |
| | | dto.setFeedbackPerson(tokenService.getLoginUser().getUserId()+""); |
| | | dto.setFeedbackPerson(tokenService.getLoginUserApplet().getUserId() + ""); |
| | | feedbackService.save(dto); |
| | | return R.ok(); |
| | | } |
| | | |
| | | @ApiOperation(value = "上传问题上报") |
| | | @PostMapping(value = "/addProblem") |
| | | public R<Boolean> addProblem(@RequestBody ProblemDTO dto) { |
| | | dto.setEscalationId(tokenService.getLoginUser().getUserId()+""); |
| | | dto.setEscalationId(tokenService.getLoginUserApplet().getUserId() + ""); |
| | | problemEscalationService.save(dto); |
| | | return R.ok(); |
| | | } |
| | | |
| | | @ApiOperation(value = "问题类型列表") |
| | | @PostMapping(value = "/problemList") |
| | | public R<List<TDictData>> problemList() { |
| | | List<TDictData> list = dictDataService.list( |
| | | new LambdaQueryWrapper<TDictData>() |
| | | .eq(TDictData::getDataType,3) |
| | | .eq(TDictData::getDataType, 3) |
| | | ); |
| | | return R.ok(list); |
| | | } |
| | | @ApiOperation(value = "发起请假") |
| | | @PostMapping(value = "/addLeave") |
| | | public R<Boolean> addLeave(@RequestBody LeaveDTO leaveDTO) { |
| | | leaveService.save(leaveDTO); |
| | | // todo 生成审批记录 |
| | | return R.ok(); |
| | | } |
| | | |
| | | |
| | | @Resource |
| | | private TKnowledgeService knowledgeService; |
| | |
| | | public R<PageInfo<KnowledgeVO>> pageList(@RequestBody KnowledgeListUserQuery query) { |
| | | |
| | | |
| | | return R.ok( knowledgeService.pageListUser(query)); |
| | | return R.ok(knowledgeService.pageListUser(query)); |
| | | } |
| | | |
| | | @ApiOperation(value = "详情环卫知识") |
| | |
| | | knowledgeService.updateById(byId); |
| | | return R.ok(byId); |
| | | } |
| | | |
| | | @ApiOperation(value = "发起请假-获取审批流程") |
| | | @GetMapping(value = "/leaveAuditList") |
| | | public R<LeaveAuditListVO> leaveAuditList() { |
| | | LeaveAuditListVO res = new LeaveAuditListVO(); |
| | | Long userId = tokenService.getLoginUserApplet().getUserId(); |
| | | SysUser user = sysUserService.selectUserById(userId); |
| | | Long userRole = sysUserService.getUserRole(userId); |
| | | SysRole sysRole = roleService.selectRoleById(userRole); |
| | | List<SysUser> sysUsers = sysUserService.selectAllList(); |
| | | SysUser auditPerson = sysUserService.selectUserById(999L); |
| | | |
| | | List<TProjectDept> paojectList = projectDeptService.lambdaQuery().eq(TProjectDept::getParentId, "0").list(); |
| | | //项目部负责人、部门负责人、公司成员提交由最终审批人审批; |
| | | if (user.getDeptType() == 2 || sysRole.getRoleName().contains("项目部负责人") || sysRole.getRoleName().contains("部门负责人")) { |
| | | LeaveAuditVO tLeaveAudit = new LeaveAuditVO(); |
| | | tLeaveAudit.setAvatar(auditPerson.getAvatar()); |
| | | tLeaveAudit.setNickName(auditPerson.getNickName()); |
| | | res.setAuditPerson(tLeaveAudit); |
| | | res.setAuditPersonId("999"); |
| | | } else if (!sysRole.getRoleName().equals("部门助理")) { |
| | | // 审批人根据当前角色类型来 |
| | | if (sysRole.getRoleName().contains("片区负责人") || sysRole.getRoleName().contains("组长")|| sysRole.getRoleName().contains("队长") |
| | | ||sysRole.getRoleName().contains("项目部助理")) { |
| | | TProjectDept userDept = projectDeptService.getById(user.getDeptId()); |
| | | |
| | | List<SysUser> collect = sysUsers.stream().filter(e -> e.getDeptType() == 1).collect(Collectors.toList()); |
| | | for (SysUser sysUser : collect) { |
| | | Long userRole1 = sysUserService.getUserRole(sysUser.getUserId()); |
| | | SysRole sysRole1 = roleService.selectRoleById(userRole1); |
| | | // if (sysRole1 != null && sysRole1.getRoleName().equals("项目部负责人")) { |
| | | // if (userDept.getId().equals(sysUser.getDeptId())){ |
| | | // LeaveAuditVO tLeaveAudit = new LeaveAuditVO(); |
| | | // tLeaveAudit.setAvatar(sysUser.getAvatar()); |
| | | // tLeaveAudit.setNickName(sysUser.getNickName()); |
| | | // res.setAuditPerson(tLeaveAudit); |
| | | // res.setAuditPersonId(sysUser.getUserId() + ""); |
| | | // break; |
| | | // } |
| | | // } |
| | | if (sysRole1 != null && sysRole1.getRoleName().equals("项目部负责人")) { |
| | | if (!sysRole.getRoleName().contains("项目部助理")){ |
| | | if (userDept.getParentId().equals(sysUser.getDeptId())){ |
| | | LeaveAuditVO tLeaveAudit = new LeaveAuditVO(); |
| | | tLeaveAudit.setAvatar(sysUser.getAvatar()); |
| | | tLeaveAudit.setNickName(sysUser.getNickName()); |
| | | res.setAuditPerson(tLeaveAudit); |
| | | res.setAuditPersonId(sysUser.getUserId() + ""); |
| | | break; |
| | | } |
| | | }else{ |
| | | if (userDept.getId().equals(sysUser.getDeptId())){ |
| | | LeaveAuditVO tLeaveAudit = new LeaveAuditVO(); |
| | | tLeaveAudit.setAvatar(sysUser.getAvatar()); |
| | | tLeaveAudit.setNickName(sysUser.getNickName()); |
| | | res.setAuditPerson(tLeaveAudit); |
| | | res.setAuditPersonId(sysUser.getUserId() + ""); |
| | | break; |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | } else { |
| | | List<SysUser> collect = sysUsers.stream().filter(e -> e.getDeptType() == 1 && |
| | | e.getDeptId().equals(user.getDeptId())).collect(Collectors.toList()); |
| | | for (SysUser sysUser : collect) { |
| | | Long userRole1 = sysUserService.getUserRole(sysUser.getUserId()); |
| | | SysRole sysRole1 = roleService.selectRoleById(userRole1); |
| | | if (sysRole1 != null && sysRole1.getRoleName().contains("部门负责人")) { |
| | | LeaveAuditVO tLeaveAudit = new LeaveAuditVO(); |
| | | tLeaveAudit.setAvatar(sysUser.getAvatar()); |
| | | tLeaveAudit.setNickName(sysUser.getNickName()); |
| | | res.setAuditPerson(tLeaveAudit); |
| | | res.setAuditPersonId(sysUser.getUserId() + ""); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | List<LeaveAuditVO> leaveAuditVOS = new ArrayList<>(); |
| | | // 当前登陆人-抄送人 |
| | | LeaveAuditVO leaveAuditVO1 = new LeaveAuditVO(); |
| | | leaveAuditVO1.setAvatar(user.getAvatar()); |
| | | leaveAuditVO1.setNickName(user.getNickName()); |
| | | // 最终审核人-抄送人 |
| | | LeaveAuditVO leaveAuditVO = new LeaveAuditVO(); |
| | | leaveAuditVO.setAvatar(auditPerson.getAvatar()); |
| | | leaveAuditVO.setNickName(auditPerson.getNickName()); |
| | | leaveAuditVOS.add(leaveAuditVO); |
| | | leaveAuditVOS.add(leaveAuditVO1); |
| | | res.setCopyPerson(leaveAuditVOS); |
| | | return R.ok(res); |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | String temp = "2025-06-30 00:00:00"; |
| | | // 轉化爲localdateTime |
| | | LocalDateTime parse = LocalDateTime.parse(temp, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); |
| | | System.out.println(parse); |
| | | } |
| | | |
| | | @ApiOperation(value = "发起请假") |
| | | @PostMapping(value = "/addLeave") |
| | | public R addLeave(@RequestBody LeaveDTO leaveDTO) throws Exception { |
| | | // String startTime1 = leaveDTO.getStartTime1(); |
| | | // // 轉化爲LocalDateTime類型 |
| | | // leaveDTO.setStartTime(LocalDateTime.parse(startTime1, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); |
| | | // String endTime1 = leaveDTO.getEndTime1(); |
| | | // // 轉化爲LocalDateTime類型 |
| | | // leaveDTO.setStartTime(LocalDateTime.parse(endTime1, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); |
| | | Long userId = tokenService.getLoginUserApplet().getUserId(); |
| | | SysUser user = sysUserService.selectUserById(userId); |
| | | Long userRole = sysUserService.getUserRole(userId); |
| | | SysRole sysRole = roleService.selectRoleById(userRole); |
| | | List<SysUser> sysUsers = sysUserService.selectAllList(); |
| | | SysUser auditPerson = sysUserService.selectUserById(999L); |
| | | leaveDTO.setAuditStatus(1); |
| | | Date date = new Date(); |
| | | SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmmss"); |
| | | // 生成随机数字6位 |
| | | String format = simpleDateFormat.format(date); |
| | | leaveDTO.setCode(format + RandomUtil.randomNumbers(6)); |
| | | leaveDTO.setTemplateId(user.getTemplateId()); |
| | | leaveDTO.setLeavePerson(userId + ""); |
| | | leaveService.save(leaveDTO); |
| | | TNoticeSet noticeSet = noticeSetService.lambdaQuery().eq(TNoticeSet::getType, 2).last("limit 1") |
| | | .one(); |
| | | // 邮箱 |
| | | TDictData email = dictDataService.lambdaQuery().eq(TDictData::getDataType,4).one(); |
| | | // 授权码 |
| | | TDictData code = dictDataService.lambdaQuery().eq(TDictData::getDataType,5).one(); |
| | | //项目部负责人、部门负责人、公司成员提交由最终审批人审批; |
| | | if (user.getDeptType() == 2 || sysRole.getRoleName().contains("项目部负责人") || sysRole.getRoleName().contains("部门负责人")) { |
| | | TLeaveAudit tLeaveAudit1 = new TLeaveAudit(); |
| | | tLeaveAudit1.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit1.setAuditStatus(1); |
| | | tLeaveAudit1.setAuditId(auditPerson.getUserId() + ""); |
| | | tLeaveAudit1.setAuditType(1); |
| | | leaveAuditService.save(tLeaveAudit1); |
| | | TLeaveAudit tLeaveAudit2 = new TLeaveAudit(); |
| | | tLeaveAudit2.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit2.setAuditStatus(2); |
| | | tLeaveAudit2.setAuditId(user.getUserId() + "," + auditPerson.getUserId()); |
| | | tLeaveAudit2.setAuditType(2); |
| | | tLeaveAudit2.setAuditTime(LocalDateTime.now()); |
| | | leaveAuditService.save(tLeaveAudit2); |
| | | } else if (!sysRole.getRoleName().equals("部门助理")) { |
| | | // 审批人根据当前角色类型来 |
| | | if (sysRole.getRoleName().contains("片区负责人") || sysRole.getRoleName().contains("组长")|| sysRole.getRoleName().contains("队长") |
| | | ||sysRole.getRoleName().contains("项目部助理")) { |
| | | TProjectDept userDept = projectDeptService.getById(user.getDeptId()); |
| | | |
| | | List<SysUser> collect = sysUsers.stream().filter(e -> e.getDeptType() == 1).collect(Collectors.toList()); |
| | | for (SysUser sysUser : collect) { |
| | | Long userRole1 = sysUserService.getUserRole(sysUser.getUserId()); |
| | | SysRole sysRole1 = roleService.selectRoleById(userRole1); |
| | | |
| | | if (sysRole1 != null && sysRole1.getRoleName().equals("项目部负责人")) { |
| | | if (!sysRole.getRoleName().contains("项目部助理")){ |
| | | if (userDept.getParentId().equals(sysUser.getDeptId())){ |
| | | LeaveAuditVO tLeaveAudit = new LeaveAuditVO(); |
| | | tLeaveAudit.setAvatar(sysUser.getAvatar()); |
| | | tLeaveAudit.setNickName(sysUser.getNickName()); |
| | | TLeaveAudit tLeaveAudit1 = new TLeaveAudit(); |
| | | tLeaveAudit1.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit1.setAuditStatus(1); |
| | | tLeaveAudit1.setAuditId(sysUser.getUserId() + ""); |
| | | tLeaveAudit1.setAuditType(1); |
| | | leaveAuditService.save(tLeaveAudit1); |
| | | // 新增消息 |
| | | TNotice tNotice = new TNotice(); |
| | | tNotice.setUserId(sysUser.getUserId()+""); |
| | | tNotice.setNoticeContent(user.getNickName() + "提交了请假申请,请尽快审核"); |
| | | tNotice.setStatus(1); |
| | | tNotice.setDataId(leaveDTO.getId()); |
| | | tNotice.setNoticeType(6); |
| | | |
| | | switch (noticeSet.getNoticeType()) { |
| | | case 1: |
| | | msgUtils.sendMsg4(sysUser.getPhonenumber()); |
| | | break; |
| | | case 2: |
| | | if (StringUtils.hasLength(email.getDataContent()) && StringUtils.hasLength(code.getDataContent())) { |
| | | EmailUtils.sendEmail(sysUser.getEmail(), email.getDataContent(), code.getDataContent(), "你有一条请假申请待处理,请登录沿海市政质管小程序处理。"); |
| | | } |
| | | break; |
| | | case 3: |
| | | break; |
| | | } |
| | | |
| | | |
| | | noticeService.save(tNotice); |
| | | TLeaveAudit tLeaveAudit2 = new TLeaveAudit(); |
| | | tLeaveAudit2.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit2.setAuditStatus(2); |
| | | tLeaveAudit2.setAuditId(user.getUserId() + "," + sysUser.getUserId()); |
| | | tLeaveAudit2.setAuditType(2); |
| | | tLeaveAudit2.setAuditTime(LocalDateTime.now()); |
| | | leaveAuditService.save(tLeaveAudit2); |
| | | break; |
| | | } |
| | | }else{ |
| | | if (userDept.getId().equals(sysUser.getDeptId())){ |
| | | LeaveAuditVO tLeaveAudit = new LeaveAuditVO(); |
| | | tLeaveAudit.setAvatar(sysUser.getAvatar()); |
| | | tLeaveAudit.setNickName(sysUser.getNickName()); |
| | | TLeaveAudit tLeaveAudit1 = new TLeaveAudit(); |
| | | tLeaveAudit1.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit1.setAuditStatus(1); |
| | | tLeaveAudit1.setAuditId(sysUser.getUserId() + ""); |
| | | tLeaveAudit1.setAuditType(1); |
| | | leaveAuditService.save(tLeaveAudit1); |
| | | // 新增消息 |
| | | TNotice tNotice = new TNotice(); |
| | | tNotice.setUserId(sysUser.getUserId()+""); |
| | | tNotice.setNoticeContent(user.getNickName() + "提交了请假申请,请尽快审核"); |
| | | tNotice.setStatus(1); |
| | | tNotice.setDataId(leaveDTO.getId()); |
| | | tNotice.setNoticeType(6); |
| | | noticeService.save(tNotice); |
| | | switch (noticeSet.getNoticeType()) { |
| | | case 1: |
| | | msgUtils.sendMsg4(sysUser.getPhonenumber()); |
| | | break; |
| | | case 2: |
| | | if (StringUtils.hasLength(email.getDataContent()) && StringUtils.hasLength(code.getDataContent())) { |
| | | EmailUtils.sendEmail(sysUser.getEmail(), email.getDataContent(), code.getDataContent(), "你有一条请假申请待处理,请登录沿海市政质管小程序处理。"); |
| | | } |
| | | break; |
| | | case 3: |
| | | break; |
| | | } |
| | | TLeaveAudit tLeaveAudit2 = new TLeaveAudit(); |
| | | tLeaveAudit2.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit2.setAuditStatus(2); |
| | | tLeaveAudit2.setAuditId(user.getUserId() + "," + sysUser.getUserId()); |
| | | tLeaveAudit2.setAuditType(2); |
| | | tLeaveAudit2.setAuditTime(LocalDateTime.now()); |
| | | leaveAuditService.save(tLeaveAudit2); |
| | | break; |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | } else { |
| | | List<SysUser> collect = sysUsers.stream().filter(e -> e.getDeptType() == 1 && |
| | | e.getDeptId().equals(user.getDeptId())).collect(Collectors.toList()); |
| | | for (SysUser sysUser : collect) { |
| | | Long userRole1 = sysUserService.getUserRole(sysUser.getUserId()); |
| | | SysRole sysRole1 = roleService.selectRoleById(userRole1); |
| | | if (sysRole1 != null && sysRole1.getRoleName().contains("部门负责人")) { |
| | | TLeaveAudit tLeaveAudit1 = new TLeaveAudit(); |
| | | tLeaveAudit1.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit1.setAuditStatus(1); |
| | | tLeaveAudit1.setAuditId(sysUser.getUserId() + ""); |
| | | tLeaveAudit1.setAuditType(1); |
| | | leaveAuditService.save(tLeaveAudit1); |
| | | // 新增消息 |
| | | TNotice tNotice = new TNotice(); |
| | | tNotice.setUserId(sysUser.getUserId()+""); |
| | | tNotice.setNoticeContent(user.getNickName() + "提交了请假申请,请尽快审核"); |
| | | tNotice.setStatus(1); |
| | | tNotice.setDataId(leaveDTO.getId()); |
| | | tNotice.setNoticeType(6); |
| | | noticeService.save(tNotice); |
| | | switch (noticeSet.getNoticeType()) { |
| | | case 1: |
| | | msgUtils.sendMsg4(sysUser.getPhonenumber()); |
| | | break; |
| | | case 2: |
| | | if (StringUtils.hasLength(email.getDataContent()) && StringUtils.hasLength(code.getDataContent())) { |
| | | EmailUtils.sendEmail(sysUser.getEmail(), email.getDataContent(), code.getDataContent(), "你有一条请假申请待处理,请登录沿海市政质管小程序处理。"); |
| | | } |
| | | break; |
| | | case 3: |
| | | break; |
| | | } |
| | | TLeaveAudit tLeaveAudit2 = new TLeaveAudit(); |
| | | tLeaveAudit2.setLeaveId(leaveDTO.getId()); |
| | | tLeaveAudit2.setAuditStatus(2); |
| | | tLeaveAudit2.setAuditId(user.getUserId() + "," + auditPerson.getUserId()); |
| | | tLeaveAudit2.setAuditType(2); |
| | | tLeaveAudit2.setAuditTime(LocalDateTime.now()); |
| | | leaveAuditService.save(tLeaveAudit2); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | return R.ok(); |
| | | } |
| | | |
| | | @ApiOperation(value = "我的审批-我的申请") |
| | | @PostMapping(value = "/leaveList") |
| | | public R<PageInfo<LeaveUserListVO>> leaveList(@RequestBody LeaveListUserQuery query) { |
| | | query.setUserId(tokenService.getLoginUserApplet().getUserId() + ""); |
| | | return R.ok(leaveService.leaveList(query)); |
| | | } |
| | | |
| | | @ApiOperation(value = "我的审批-审批") |
| | | @PostMapping(value = "/auditLeave") |
| | | public R<Boolean> auditLeave(@RequestBody LeaveAuditDTO dto) throws Exception { |
| | | |
| | | dto.setAuditId(tokenService.getLoginUserApplet().getUserId() + ""); |
| | | dto.setAuditTime(LocalDateTime.now()); |
| | | leaveService.updateById(dto); |
| | | List<SysUser> sysUsers = sysUserService.selectAllList(); |
| | | SysUser sysUser = sysUserService.selectUserById(Long.valueOf(dto.getLeavePerson())); |
| | | TLeaveAudit leaveAudit = leaveAuditService.lambdaQuery().eq(TLeaveAudit::getLeaveId, dto.getId()) |
| | | .eq(TLeaveAudit::getAuditType, 2).one(); |
| | | TNoticeSet noticeSet = noticeSetService.lambdaQuery().eq(TNoticeSet::getType, 2).last("limit 1") |
| | | .one(); |
| | | // 邮箱 |
| | | TDictData email = dictDataService.lambdaQuery().eq(TDictData::getDataType,4).one(); |
| | | // 授权码 |
| | | TDictData code = dictDataService.lambdaQuery().eq(TDictData::getDataType,5).one(); |
| | | TNotice tNotice = new TNotice(); |
| | | tNotice.setUserId(leaveAudit.getAuditId().split(",")[0]); |
| | | tNotice.setNoticeContent(sysUser.getNickName()+"的请假申请已审核,请查收"); |
| | | tNotice.setStatus(1); |
| | | tNotice.setDataId(dto.getId()); |
| | | tNotice.setNoticeType(7); |
| | | noticeService.save(tNotice); |
| | | LocalDateTime startTime = dto.getStartTime(); |
| | | LocalDateTime endTime = dto.getEndTime(); |
| | | SysUser sysUser1 = sysUsers.stream().filter(e -> e.getUserId().equals(Long.valueOf(leaveAudit.getAuditId().split(",")[0]))) |
| | | .findFirst().orElse(null); |
| | | SysUser sysUser2 = sysUsers.stream().filter(e -> e.getUserId().equals(Long.valueOf(leaveAudit.getAuditId().split(",")[1]))) |
| | | .findFirst().orElse(null); |
| | | // 转化为yyyy-MM-dd 格式字符串 |
| | | String leaveTime = startTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))+"至"+endTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); |
| | | if (sysUser1!=null){ |
| | | switch (noticeSet.getNoticeType()) { |
| | | case 1: |
| | | msgUtils.sendMsg5(sysUser1.getPhonenumber(),sysUser1.getNickName(),leaveTime); |
| | | break; |
| | | case 2: |
| | | if (StringUtils.hasLength(email.getDataContent())&&StringUtils.hasLength(code.getDataContent())){ |
| | | EmailUtils.sendEmail(sysUser1.getEmail(),email.getDataContent(),code.getDataContent(),sysUser1.getNickName()+"的请假申请已审核,请查收"); |
| | | } |
| | | break; |
| | | case 3: |
| | | break; |
| | | } |
| | | } |
| | | |
| | | TNotice tNotice1 = new TNotice(); |
| | | tNotice1.setUserId(leaveAudit.getAuditId().split(",")[1]); |
| | | tNotice1.setNoticeContent(sysUser.getNickName()+"的请假申请已审核,请查收"); |
| | | tNotice1.setStatus(1); |
| | | tNotice1.setDataId(dto.getId()); |
| | | tNotice1.setNoticeType(7); |
| | | noticeService.save(tNotice1); |
| | | if (sysUser2!=null) { |
| | | switch (noticeSet.getNoticeType()) { |
| | | case 1: |
| | | msgUtils.sendMsg5(sysUser2.getPhonenumber(), sysUser2.getNickName(), leaveTime); |
| | | break; |
| | | case 2: |
| | | if (StringUtils.hasLength(email.getDataContent()) && StringUtils.hasLength(code.getDataContent())) { |
| | | EmailUtils.sendEmail(sysUser2.getEmail(), email.getDataContent(), code.getDataContent(), sysUser2.getNickName() + "的请假申请已审核,请查收"); |
| | | } |
| | | break; |
| | | case 3: |
| | | break; |
| | | } |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | | @ApiOperation(value = "我的审批-详情") |
| | | @GetMapping(value = "/leaveDetail") |
| | | public R<LeaveUserDetailVO> leaveDetail(@RequestParam String id) { |
| | | TLeave leave = leaveService.getById(id); |
| | | LeaveUserDetailVO leaveUserDetailVO = new LeaveUserDetailVO(); |
| | | SysUser sysUser = sysUserService.selectUserById(tokenService.getLoginUserApplet().getUserId()); |
| | | Long userRole = sysUserService.getUserRole(sysUser.getUserId()); |
| | | SysRole sysRole = roleService.selectRoleById(userRole); |
| | | if (sysRole.getRoleName().contains("片区负责人") || sysRole.getRoleName().equals("组长")|| sysRole.getRoleName().equals("队长")||sysRole.getRoleName().contains("项目部助理")) { |
| | | if (sysUser.getDeptType() == 1) { |
| | | TProjectDept tProjectDept = projectDeptService.getById(sysUser.getDeptId()); |
| | | if (!tProjectDept.getParentId().equals("0")) { |
| | | TProjectDept tProjectDept1 = projectDeptService.getById(tProjectDept.getParentId()); |
| | | leaveUserDetailVO.setDeptName(tProjectDept1.getProjectName() + ">" + tProjectDept.getProjectName()); |
| | | } else { |
| | | leaveUserDetailVO.setDeptName(tProjectDept.getProjectName()); |
| | | } |
| | | } else { |
| | | TDept tDept = deptService.getById(sysUser.getDeptId()); |
| | | leaveUserDetailVO.setDeptName(tDept.getDeptName()); |
| | | } |
| | | } else if (sysRole.getRoleName().contains("项目部负责人")) { |
| | | TProjectDept tProjectDept = projectDeptService.getById(sysUser.getDeptId()); |
| | | leaveUserDetailVO.setDeptName(tProjectDept.getProjectName()); |
| | | } |
| | | if (sysUser.getDeptType() == 2) { |
| | | TDept byId = deptService.getById(sysUser.getDeptId()); |
| | | leaveUserDetailVO.setDeptName(byId.getDeptName()); |
| | | } |
| | | if (sysUser.getDeptType()==1){ |
| | | TProjectDept projectDept = projectDeptService.getById(sysUser.getDeptId()); |
| | | if (projectDept.getParentId().equals("0")){ |
| | | leaveUserDetailVO.setDeptName(projectDept.getProjectName()); |
| | | }else{ |
| | | TProjectDept projectDept1 = projectDeptService.getById(projectDept.getParentId()); |
| | | leaveUserDetailVO.setDeptName(projectDept1.getProjectName()+">"+projectDept.getProjectName()); |
| | | } |
| | | } |
| | | leaveUserDetailVO.setLeavePersonName(sysUser.getNickName()); |
| | | LeaveAuditListVO leaveAuditListVO = new LeaveAuditListVO(); |
| | | List<TLeaveAudit> list = leaveAuditService.list(new LambdaQueryWrapper<TLeaveAudit>() |
| | | .eq(TLeaveAudit::getLeaveId, leave.getId())); |
| | | for (TLeaveAudit tLeaveAudit : list) { |
| | | if (tLeaveAudit.getAuditType() == 1) { |
| | | LeaveAuditVO leaveAuditVO = new LeaveAuditVO(); |
| | | SysUser sysUser1 = sysUserService.selectUserById(Long.valueOf(tLeaveAudit.getAuditId())); |
| | | if (sysUser1 != null) { |
| | | leaveAuditVO.setAvatar(sysUser1.getAvatar()); |
| | | leaveAuditVO.setNickName(sysUser1.getNickName()); |
| | | } |
| | | leaveAuditVO.setCreateTime(tLeaveAudit.getAuditTime()); |
| | | leaveAuditVO.setAuditStatus(tLeaveAudit.getAuditStatus()); |
| | | leaveAuditListVO.setAuditPerson(leaveAuditVO); |
| | | } else { |
| | | List<LeaveAuditVO> leaveAuditVOS = new ArrayList<>(); |
| | | // 抄送人 |
| | | LeaveAuditVO leaveAuditVO = new LeaveAuditVO(); |
| | | SysUser sysUser1 = sysUserService.selectUserById(Long.valueOf(tLeaveAudit.getAuditId().split(",")[0])); |
| | | leaveAuditVO.setAvatar(sysUser1.getAvatar()); |
| | | leaveAuditVO.setNickName(sysUser1.getNickName()); |
| | | leaveAuditVO.setCreateTime(tLeaveAudit.getCreateTime()); |
| | | leaveAuditVO.setAuditStatus(tLeaveAudit.getAuditStatus()); |
| | | leaveAuditVOS.add(leaveAuditVO); |
| | | LeaveAuditVO leaveAuditVO1 = new LeaveAuditVO(); |
| | | SysUser sysUser2 = sysUserService.selectUserById(Long.valueOf(tLeaveAudit.getAuditId().split(",")[1])); |
| | | leaveAuditVO1.setAvatar(sysUser2.getAvatar()); |
| | | leaveAuditVO1.setNickName(sysUser2.getNickName()); |
| | | leaveAuditVO1.setCreateTime(tLeaveAudit.getCreateTime()); |
| | | leaveAuditVO1.setAuditStatus(tLeaveAudit.getAuditStatus()); |
| | | leaveAuditVOS.add(leaveAuditVO1); |
| | | leaveAuditListVO.setCopyPerson(leaveAuditVOS); |
| | | } |
| | | } |
| | | leaveUserDetailVO.setAudit(leaveAuditListVO); |
| | | leaveUserDetailVO.setId(leave.getId()); |
| | | leaveUserDetailVO.setLeavePerson(leave.getLeavePerson()); |
| | | leaveUserDetailVO.setStartTime(leave.getStartTime()); |
| | | leaveUserDetailVO.setEndTime(leave.getEndTime()); |
| | | leaveUserDetailVO.setLeaveType(leave.getLeaveType()); |
| | | leaveUserDetailVO.setLeaveDay(leave.getLeaveDay()); |
| | | leaveUserDetailVO.setLeaveCause(leave.getLeaveCause()); |
| | | leaveUserDetailVO.setPictures(leave.getPictures()); |
| | | leaveUserDetailVO.setAuditStatus(leave.getAuditStatus()); |
| | | leaveUserDetailVO.setAuditId(leave.getAuditId()); |
| | | leaveUserDetailVO.setAuditTime(leave.getAuditTime()); |
| | | leaveUserDetailVO.setAuditRemark(leave.getAuditRemark()); |
| | | leaveUserDetailVO.setCode(leave.getCode()); |
| | | return R.ok(leaveUserDetailVO); |
| | | } |
| | | } |
| | | |