package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.api.R;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.UserWorkMapper;
|
import com.whyc.mapper.WorkAlarmMapper;
|
import com.whyc.mapper.WorkflowAlarmMapper;
|
import com.whyc.pojo.BattDevAlarmData;
|
import com.whyc.pojo.BattalarmData;
|
import com.whyc.pojo.UserWork;
|
import com.whyc.pojo.WorkAlarm;
|
import com.whyc.util.RSAUtil;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
@Service
|
public class WorkAlarmService {
|
@Resource
|
private WorkAlarmMapper mapper;
|
@Resource
|
private UserWorkMapper userWorkMapper;
|
|
public Response searchByUserIdAndStatus(int pageNum,int pageSize,Integer uId,Integer status){
|
PageHelper.startPage(pageNum,pageSize);
|
//Integer status = null;
|
////查询全部列表
|
//if(pageInfo.getNote()==1){
|
// status = null;
|
//}
|
////查询待处理列表
|
//else if(pageInfo.getNote()==2){
|
// status = 1;
|
//}
|
////查询处理中列表
|
//else if(pageInfo.getNote()==3){
|
// status = 2;
|
//}
|
////查询已完成列表
|
//else if(pageInfo.getNote()==4){
|
// status = 3;
|
//}
|
List<WorkAlarm> list = mapper.searchByUserIdAndStatus(uId,status);
|
PageInfo pageInfo = new PageInfo(list);
|
return new Response().set(1,pageInfo,"查询成功");
|
}
|
|
public Response updateWorkAlarm(WorkAlarm workAlarm){
|
int flag = mapper.updateById(workAlarm);
|
return new Response().set(1,flag>0?true:false);
|
}
|
|
public Response searchById(int id){
|
WorkAlarm result = mapper.selectById(id);
|
//去告警表查询是否存在
|
int flag = 1;
|
if (result.getAlarmRecordId()==null){
|
flag = 0;
|
}
|
boolean bl = alarmIsExist(result.getAlarmRecId(),result.getAlarmRecordId());
|
if (!bl){
|
flag = 0;
|
}
|
result.setFlag(flag);
|
QueryWrapper<UserWork> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("workId",id);
|
queryWrapper.orderByDesc("endTime");
|
List<UserWork> list = userWorkMapper.selectList(queryWrapper);
|
result.setUserWorkList(list);
|
return new Response().set(1,result,"查询成功");
|
}
|
|
public boolean alarmIsExist(int num,long recordId){
|
boolean bl = false;
|
List<BattalarmData> list = mapper.getBattAlarm(num,recordId);
|
if (list != null && list.size() > 0) {
|
bl = true;
|
}
|
List<BattDevAlarmData> list2 = mapper.getDevAlarm(num,recordId);
|
if (list2 != null && list2.size() > 0) {
|
bl = true;
|
}
|
return bl;
|
}
|
|
public Response getTaskListWithFlag(Integer uId,Integer note,int pageNum,int pageSize){
|
PageHelper.startPage(pageNum,pageSize);
|
Integer status = null;
|
Integer checkStatus = null;
|
//查询未派单列表
|
if(note==1){
|
status = 0;
|
//此时还没生成user_work表记录
|
checkStatus = null;
|
}
|
//查询已派单列表
|
else if(note==2){
|
status = 1;
|
checkStatus = null;
|
}
|
//查询待审核列表
|
else if(note==3){
|
status = 2;
|
checkStatus = 2;
|
}
|
//查询已完成列表
|
else if(note==4){
|
status = 3;
|
checkStatus = 3;
|
}
|
List<WorkAlarm> list = mapper.getTaskListWithFlag(uId,status,checkStatus);
|
PageInfo pageInfo = new PageInfo(list);
|
return new Response().set(1,pageInfo,"查询成功");
|
}
|
|
|
public Response dispatchTask(){
|
|
return null;
|
}
|
|
|
}
|
