| | |
| | | import com.doumee.dao.business.YwPatrolTaskRecordMapper; |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.dao.system.SystemUserMapper; |
| | | import com.doumee.dao.system.join.NoticesJoinMapper; |
| | | import com.doumee.dao.system.model.Notices; |
| | | import com.doumee.dao.system.model.SystemUser; |
| | | import com.doumee.service.business.YwPatrolSchemeService; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | |
| | | private SystemUserMapper systemUserMapper; |
| | | @Autowired |
| | | private RedisTemplate<String, Object> redisTemplate; |
| | | @Autowired |
| | | private NoticesJoinMapper noticesJoinMapper; |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = {Exception.class,BusinessException.class}) |
| | |
| | | ywPatrolTaskRecordList.add(ywPatrolTaskRecord); |
| | | } |
| | | ywPatrolTaskRecordMapper.insert(ywPatrolTaskRecordList); |
| | | |
| | | if(StringUtils.isNotBlank(ywPatrolScheme.getUserIds())){ |
| | | String [] userIds = ywPatrolScheme.getUserIds().split(","); |
| | | for (String userId:userIds) { |
| | | //添加待办信息 |
| | | Notices notices = new Notices(); |
| | | notices.setCreateDate(new Date()); |
| | | notices.setCreator(ywPatrolScheme.getCreator()); |
| | | notices.setIsdeleted(Constants.ZERO); |
| | | notices.setParam1(DateUtil.formatDate(ywPatrolTask.getStartDate(),"yyyy-MM-dd")); |
| | | notices.setTitle("巡检任务待办"); |
| | | notices.setContent("["+ywPatrolTask.getCode()+"]将在["+notices.getParam1()+"]进行巡检,请按时执行"); |
| | | notices.setObjId(ywPatrolTask.getId()); |
| | | notices.setObjType(Constants.ONE); |
| | | notices.setType(notices.getObjType()); |
| | | notices.setUserId(Integer.valueOf(userId)); |
| | | notices.setStatus(Constants.ZERO); |
| | | noticesJoinMapper.insert(notices); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |