package com.fzzy.security.manager;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.fzzy.common.manager.CommonManager;
|
import com.fzzy.igds.data.IgdsBaseParam;
|
import com.fzzy.igds.domain.Camera;
|
import com.fzzy.igds.domain.WeighbridgeSnap;
|
import com.fzzy.igds.service.SecCameraService;
|
import com.fzzy.igds.service.WeighbridgeSnapService;
|
import com.fzzy.igds.utils.ContextUtil;
|
import com.ruoyi.common.utils.StringUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Component
|
public class WeighbridgeSnapManager {
|
|
@Resource
|
private WeighbridgeSnapService weighbridgeSnapService;
|
@Resource
|
private CommonManager commonManager;
|
@Resource
|
private SecCameraService secCameraService;
|
|
|
/**
|
* 分页获取地磅抓拍数据
|
*
|
* @param param
|
* @author sgj
|
* @since 2026/02/25
|
*/
|
public Page<WeighbridgeSnap> pageData(IgdsBaseParam param) {
|
if (StringUtils.isEmpty(param.getCompanyId())) {
|
param.setCompanyId(ContextUtil.getCompanyId());
|
}
|
|
Page<WeighbridgeSnap> corePage = new Page<>(param.getPage(), param.getLimit());
|
weighbridgeSnapService.listPage(corePage, param);
|
|
if (null == corePage.getRecords() || corePage.getRecords().isEmpty()) {
|
return corePage.setRecords(new ArrayList<>());
|
}
|
//获取监控设备
|
List<Camera> cameras = secCameraService.listCamera(ContextUtil.getCompanyId(), null);
|
|
//判断文件是否存在
|
for (WeighbridgeSnap record : corePage.getRecords()) {
|
record.setImgName(commonManager.isImgExit(record.getImgName(), null));
|
|
//映射监控设备名称
|
List<Camera> collect = cameras.stream().filter(camera -> camera.getId().equals(record.getSerId())).collect(Collectors.toList());
|
if (!collect.isEmpty()) {
|
record.setSerId(collect.get(0).getName());
|
}
|
}
|
|
return corePage;
|
}
|
}
|
