| | |
| | | import com.fzzy.igds.app.v1.dto.PSnapDto; |
| | | import com.fzzy.igds.app.v1.service.PhoneService; |
| | | import com.fzzy.igds.app.v1.util.PhoneRespUtil; |
| | | import com.fzzy.igds.domain.Dept; |
| | | import com.fzzy.igds.domain.PatrolRecord; |
| | | import com.fzzy.igds.domain.SnapRecord; |
| | | import com.fzzy.igds.domain.*; |
| | | import com.fzzy.igds.mapper.SnapRecordMapper; |
| | | import com.fzzy.igds.mapper.WeighbridgeSnapMapper; |
| | | import com.fzzy.igds.service.CoreDeptService; |
| | | import com.fzzy.igds.service.FileService; |
| | | import com.fzzy.igds.service.InoutConfService; |
| | | import com.fzzy.igds.service.SecCameraService; |
| | | import com.fzzy.igds.utils.ContextUtil; |
| | | import com.fzzy.igds.utils.DateUtil; |
| | | import org.apache.commons.lang3.StringUtils; |
| | |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * @Author: YYC |
| | |
| | | public class ServiceImpl5108 implements PhoneService { |
| | | |
| | | @Resource |
| | | private SnapRecordMapper snapRecordMapper; |
| | | private WeighbridgeSnapMapper weighbridgeSnapMapper; |
| | | @Resource |
| | | private CoreDeptService deptService; |
| | | @Resource |
| | | private InoutConfService inoutConfService; |
| | | |
| | | |
| | | @Override |
| | |
| | | if (null == param.getDateTime()) { |
| | | return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误,请重试!!"); |
| | | } |
| | | QueryWrapper<SnapRecord> queryWrapper = new QueryWrapper<>(); |
| | | QueryWrapper<WeighbridgeSnap> queryWrapper = new QueryWrapper<>(); |
| | | |
| | | param.setCompanyId(ContextUtil.getCompanyId()); |
| | | queryWrapper.eq("company_id", param.getCompanyId()); |
| | | queryWrapper.likeRight("dept_id", param.getDeptId()); |
| | | queryWrapper.ge("snap_time", DateUtil.getCurZero(param.getDateTime())); |
| | | queryWrapper.le("snap_time", DateUtil.getNextZero(param.getDateTime())); |
| | | queryWrapper.ge("time", DateUtil.getCurZero(param.getDateTime())); |
| | | queryWrapper.le("time", DateUtil.getNextZero(param.getDateTime())); |
| | | |
| | | List<SnapRecord> list = snapRecordMapper.selectList(queryWrapper); |
| | | List<WeighbridgeSnap> list = weighbridgeSnapMapper.selectList(queryWrapper); |
| | | PSnapDto snapDto; |
| | | Dept dept; |
| | | List<PSnapDto> snapDtoList = new ArrayList<>(); |
| | | for (SnapRecord snapRecord:list){ |
| | | List<InoutConf> collect; |
| | | //获取监控设备 |
| | | List<InoutConf> inoutConfs = inoutConfService.getInoutConfList(ContextUtil.getCompanyId(), param.getDeptId()); |
| | | for (WeighbridgeSnap weighbridgeSnap : list) { |
| | | snapDto = new PSnapDto(); |
| | | BeanUtils.copyProperties(snapRecord,snapDto); |
| | | dept = deptService.getDeptById(snapRecord.getDeptId()); |
| | | BeanUtils.copyProperties(weighbridgeSnap, snapDto); |
| | | |
| | | //映射监控设备名称 |
| | | collect = inoutConfs.stream().filter(camera -> camera.getId().equals(weighbridgeSnap.getSerId())).collect(Collectors.toList()); |
| | | if (!collect.isEmpty()) { |
| | | snapDto.setCameraId(collect.get(0).getName()); |
| | | } |
| | | dept = deptService.getDeptById(weighbridgeSnap.getDeptId()); |
| | | snapDto.setDeptName(dept.getKqmc()); |
| | | snapDtoList.add(snapDto); |
| | | } |