package cn.gistack.sm.reportFlood.service.impl;
|
|
import cn.gistack.flow.core.constant.ProcessConstant;
|
import cn.gistack.flow.core.entity.BladeFlow;
|
import cn.gistack.flow.core.feign.IFlowClient;
|
import cn.gistack.flow.core.utils.FlowUtil;
|
import cn.gistack.flow.core.utils.TaskUtil;
|
import cn.gistack.sm.patrol.entity.PatrolTask;
|
import cn.gistack.sm.reportFlood.entity.ReportFloodRecord;
|
import cn.gistack.sm.reportFlood.mapper.ReportFloodRecordMapper;
|
import cn.gistack.sm.reportFlood.service.IReportFloodRecordService;
|
import cn.gistack.sm.reportFlood.vo.ReportFloodRecordVO;
|
import cn.gistack.sm.sjztmd.constant.PersonType;
|
import cn.gistack.sm.sjztmd.entity.AttResManagePerson;
|
import cn.gistack.sm.sjztmd.service.IAttResManagePersonService;
|
import cn.gistack.system.user.entity.User;
|
import cn.gistack.system.user.feign.IUserClient;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import lombok.AllArgsConstructor;
|
import org.apache.ibatis.annotations.Param;
|
import org.springblade.core.log.exception.ServiceException;
|
import org.springblade.core.mp.base.BaseServiceImpl;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.core.tool.support.Kv;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.core.tool.utils.ObjectUtil;
|
import org.springblade.core.tool.utils.StringUtil;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
import static org.springblade.core.launch.constant.FlowConstant.TASK_USR_PREFIX;
|
|
@Service
|
@AllArgsConstructor
|
public class ReportFloodRecordServiceImpl extends BaseServiceImpl<ReportFloodRecordMapper, ReportFloodRecord> implements IReportFloodRecordService {
|
private final IAttResManagePersonService attResManagePersonService;
|
private final IUserClient userClient;
|
|
@Override
|
public IPage<ReportFloodRecord> selectReportFloodRecordPages(IPage<ReportFloodRecord> page, ReportFloodRecord reportFloodRecord) {
|
return page.setRecords(baseMapper.selectReportFloodRecordPages(page,reportFloodRecord));
|
}
|
|
@Override
|
public ReportFloodRecordVO customizeGetDetail(ReportFloodRecordVO reportFloodRecordVO) {
|
return baseMapper.customizeGetDetail(reportFloodRecordVO);
|
}
|
|
/**
|
* 根据水库id和责任人类型获取用户
|
* @param type 责任人类型
|
* @param resGuid 水库id
|
* @return
|
*/
|
public User getUser(String type,String resGuid){
|
AttResManagePerson attResManagePerson = new AttResManagePerson();
|
attResManagePerson.setResGuid(resGuid);
|
List<AttResManagePerson> list = attResManagePersonService.list(Condition.getQueryWrapper(attResManagePerson));
|
|
//person_type人员类型： 1行政责任人，2主管责任人，3技术责任人，4管理责任人，5巡查责任人（确认）
|
list.stream().filter(e->Func.equals(type,e.getType())).collect(Collectors.toList());
|
attResManagePerson = list.get(0);
|
R<List<User>> res = userClient.userInfoByPhone("000000", attResManagePerson.getUserPhone());
|
if (res.isSuccess()){
|
return res.getData().get(0);
|
}else {
|
return null;
|
}
|
}
|
}
|
