| | |
| | | package org.springblade.modules.task.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import org.springblade.common.utils.SpringUtils; |
| | | import org.springblade.core.mp.base.BaseServiceImpl; |
| | | import org.springblade.core.secure.utils.AuthUtil; |
| | | import org.springblade.modules.grid.entity.GridmanEntity; |
| | |
| | | import org.springblade.modules.task.entity.TaskEntity; |
| | | import org.springblade.modules.task.entity.TaskReportForRepairsEntity; |
| | | import org.springblade.modules.task.mapper.TaskReportForRepairsMapper; |
| | | import org.springblade.modules.task.service.ITaskRepairStepService; |
| | | import org.springblade.modules.task.service.ITaskReportForRepairsService; |
| | | import org.springblade.modules.task.service.ITaskService; |
| | | import org.springblade.modules.task.vo.TaskReportForRepairsVO; |
| | |
| | | @Override |
| | | public IPage<TaskReportForRepairsVO> selectTaskReportForRepairsPage(IPage<TaskReportForRepairsVO> page, TaskReportForRepairsVO taskReportForRepairs) { |
| | | Dept dept = deptService.getById(AuthUtil.getDeptId()); |
| | | if (null!=dept){ |
| | | if (null != dept) { |
| | | taskReportForRepairs.setRegionCode(dept.getRegionCode()); |
| | | } |
| | | List<String> list = new ArrayList<>(); |
| | |
| | | list = gridService.getAddressCodeListByUserId(AuthUtil.getUserId()); |
| | | } else if (taskReportForRepairs.getRoleName().equals("居民")) { |
| | | taskReportForRepairs.setCreateUser(AuthUtil.getUserId()); |
| | | } else if (taskReportForRepairs.getRoleName().equals("物业")) { |
| | | taskReportForRepairs.setRegionCode(""); |
| | | taskReportForRepairs.setConfirmUserId(AuthUtil.getUserId()); |
| | | } |
| | | } |
| | | return page.setRecords(baseMapper.selectTaskReportForRepairsPage(page, taskReportForRepairs,list)); |
| | | if (AuthUtil.getUserRole().equals("wygly")) { |
| | | taskReportForRepairs.setRegionCode(""); |
| | | taskReportForRepairs.setConfirmUserId(AuthUtil.getUserId()); |
| | | } |
| | | return page.setRecords(baseMapper.selectTaskReportForRepairsPage(page, taskReportForRepairs, list)); |
| | | } |
| | | |
| | | /** |
| | | * 查询报事报修统计 |
| | | * |
| | | * @return |
| | | */ |
| | | @Override |
| | |
| | | |
| | | /** |
| | | * 报事报修任务表 新增 |
| | | * |
| | | * @param taskReportForRepairs |
| | | * @return |
| | | */ |
| | |
| | | taskEntity.setStatus(1); |
| | | taskEntity.setType(1); |
| | | taskEntity.setFrequency(3); |
| | | if (null!=taskReportForRepairs.getAddressCode() && !taskReportForRepairs.getAddressCode().equals("")){ |
| | | if (null != taskReportForRepairs.getAddressCode() && !taskReportForRepairs.getAddressCode().equals("")) { |
| | | taskEntity.setHouseCode(taskReportForRepairs.getAddressCode()); |
| | | } |
| | | // 新增 |
| | | boolean save = taskService.save(taskEntity); |
| | | if (save){ |
| | | if (save) { |
| | | taskReportForRepairs.setTaskId(taskEntity.getId()); |
| | | taskReportForRepairs.setConfirmFlag(1); |
| | | flag = save(taskReportForRepairs); |
| | | // 同时向web 端推送消息 |
| | | SSEServer.sendMessage("web:1","1"); |
| | | SSEServer.sendMessage("web:1", "1"); |
| | | } |
| | | return flag; |
| | | } |
| | | |
| | | /** |
| | | * 报事报修任务表 自定义修改 |
| | | * |
| | | * @param taskReportForRepairs |
| | | * @return |
| | | */ |
| | |
| | | |
| | | /** |
| | | * 报事报修任务表 审核 |
| | | * |
| | | * @param taskReportForRepairs |
| | | * @return |
| | | */ |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Integer getStatistics(Long userId,String neiCode) { |
| | | return baseMapper.getStatistics(userId,neiCode); |
| | | public Integer getStatistics(Long userId, String neiCode) { |
| | | return baseMapper.getStatistics(userId, neiCode); |
| | | } |
| | | |
| | | /** |