|
@@ -28,36 +28,31 @@ import cn.hutool.core.bean.BeanUtil;
|
|
import cn.hutool.core.date.DateTime;
|
|
import cn.hutool.core.date.DateTime;
|
|
import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
-import cn.hutool.core.util.StrUtil;
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
-import com.huimv.core.consts.CommonConstant;
|
|
|
|
import com.huimv.core.context.login.LoginContextHolder;
|
|
import com.huimv.core.context.login.LoginContextHolder;
|
|
-import com.huimv.core.enums.CommonStatusEnum;
|
|
|
|
import com.huimv.core.exception.ServiceException;
|
|
import com.huimv.core.exception.ServiceException;
|
|
import com.huimv.core.factory.PageFactory;
|
|
import com.huimv.core.factory.PageFactory;
|
|
-import com.huimv.core.pojo.login.SysLoginUser;
|
|
|
|
import com.huimv.core.pojo.page.PageResult;
|
|
import com.huimv.core.pojo.page.PageResult;
|
|
import com.huimv.core.pojo.response.ResponseData;
|
|
import com.huimv.core.pojo.response.ResponseData;
|
|
import com.huimv.core.pojo.response.SuccessResponseData;
|
|
import com.huimv.core.pojo.response.SuccessResponseData;
|
|
-import com.huimv.core.util.PoiUtil;
|
|
|
|
import com.huimv.modular.collectorregister.entity.CollectorRegister;
|
|
import com.huimv.modular.collectorregister.entity.CollectorRegister;
|
|
import com.huimv.modular.collectorregister.enums.CollectorRegisterExceptionEnum;
|
|
import com.huimv.modular.collectorregister.enums.CollectorRegisterExceptionEnum;
|
|
import com.huimv.modular.collectorregister.mapper.CollectorRegisterMapper;
|
|
import com.huimv.modular.collectorregister.mapper.CollectorRegisterMapper;
|
|
import com.huimv.modular.collectorregister.param.CollectorRegisterParam;
|
|
import com.huimv.modular.collectorregister.param.CollectorRegisterParam;
|
|
import com.huimv.modular.collectorregister.service.CollectorRegisterService;
|
|
import com.huimv.modular.collectorregister.service.CollectorRegisterService;
|
|
|
|
+import com.huimv.modular.eartagregister.entity.EartagRegister;
|
|
|
|
+import com.huimv.modular.eartagregister.mapper.EartagRegisterMapper;
|
|
import com.huimv.sys.modular.org.entity.SysOrg;
|
|
import com.huimv.sys.modular.org.entity.SysOrg;
|
|
import com.huimv.sys.modular.org.mapper.SysOrgMapper;
|
|
import com.huimv.sys.modular.org.mapper.SysOrgMapper;
|
|
|
|
+import org.springframework.beans.BeanUtils;
|
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
-import javax.annotation.Resource;
|
|
|
|
-import java.sql.Timestamp;
|
|
|
|
-import java.util.Date;
|
|
|
|
-import java.util.LinkedHashMap;
|
|
|
|
-import java.util.List;
|
|
|
|
-import java.util.Map;
|
|
|
|
|
|
+
|
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
/**
|
|
* 设备管理service接口实现类
|
|
* 设备管理service接口实现类
|
|
@@ -68,15 +63,22 @@ import java.util.Map;
|
|
@Service
|
|
@Service
|
|
public class CollectorRegisterServiceImpl extends ServiceImpl<CollectorRegisterMapper, CollectorRegister> implements CollectorRegisterService {
|
|
public class CollectorRegisterServiceImpl extends ServiceImpl<CollectorRegisterMapper, CollectorRegister> implements CollectorRegisterService {
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ private SysOrgMapper sysOrgMapper;
|
|
|
|
+ @Autowired
|
|
|
|
+ EartagRegisterMapper eartagRegisterMapper;
|
|
|
|
+
|
|
|
|
|
|
- //这儿直接全部查出来算了
|
|
|
|
|
|
+
|
|
|
|
+ //这儿直接全部查出来算了-- 添加字段
|
|
|
|
+ //2022.5.6--添加下属耳标个数--最近上传次数
|
|
@Override
|
|
@Override
|
|
public PageResult<CollectorRegister> page(CollectorRegisterParam collectorRegisterParam) {
|
|
public PageResult<CollectorRegister> page(CollectorRegisterParam collectorRegisterParam) {
|
|
QueryWrapper<CollectorRegister> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<CollectorRegister> queryWrapper = new QueryWrapper<>();
|
|
if (ObjectUtil.isNotNull(collectorRegisterParam)) {
|
|
if (ObjectUtil.isNotNull(collectorRegisterParam)) {
|
|
Long orgId = LoginContextHolder.me().getSysLoginUserOrgId();
|
|
Long orgId = LoginContextHolder.me().getSysLoginUserOrgId();
|
|
// 根据组织id 查询
|
|
// 根据组织id 查询
|
|
- // queryWrapper.lambda().eq(CollectorRegister::getOrgId, orgId);
|
|
|
|
|
|
+ // queryWrapper.lambda().eq(CollectorRegister::getOrgId, orgId);
|
|
if (ObjectUtil.isNotEmpty(collectorRegisterParam.getRegisterTime())) {
|
|
if (ObjectUtil.isNotEmpty(collectorRegisterParam.getRegisterTime())) {
|
|
Date registerTime = collectorRegisterParam.getRegisterTime();
|
|
Date registerTime = collectorRegisterParam.getRegisterTime();
|
|
DateTime startTime = DateUtil.beginOfDay(registerTime);
|
|
DateTime startTime = DateUtil.beginOfDay(registerTime);
|
|
@@ -84,7 +86,6 @@ public class CollectorRegisterServiceImpl extends ServiceImpl<CollectorRegisterM
|
|
queryWrapper.lambda().ge(CollectorRegister::getRegisterTime,startTime);
|
|
queryWrapper.lambda().ge(CollectorRegister::getRegisterTime,startTime);
|
|
queryWrapper.lambda().le(CollectorRegister::getRegisterTime,endTime);
|
|
queryWrapper.lambda().le(CollectorRegister::getRegisterTime,endTime);
|
|
}
|
|
}
|
|
-
|
|
|
|
// 根据设备编码查询
|
|
// 根据设备编码查询
|
|
if (ObjectUtil.isNotEmpty(collectorRegisterParam.getPigpenId())) {
|
|
if (ObjectUtil.isNotEmpty(collectorRegisterParam.getPigpenId())) {
|
|
queryWrapper.lambda().like(CollectorRegister::getPigpenId, collectorRegisterParam.getPigpenId());
|
|
queryWrapper.lambda().like(CollectorRegister::getPigpenId, collectorRegisterParam.getPigpenId());
|
|
@@ -105,32 +106,61 @@ public class CollectorRegisterServiceImpl extends ServiceImpl<CollectorRegisterM
|
|
//按照最后上传时间倒序
|
|
//按照最后上传时间倒序
|
|
queryWrapper.lambda().orderByDesc(CollectorRegister::getLastTime);
|
|
queryWrapper.lambda().orderByDesc(CollectorRegister::getLastTime);
|
|
}
|
|
}
|
|
- return new PageResult<>(this.page(PageFactory.defaultPage(), queryWrapper));
|
|
|
|
|
|
+
|
|
|
|
+ //添加字段
|
|
|
|
+
|
|
|
|
+ PageResult<CollectorRegister> collectorRegisterPageResult = new PageResult<>(this.page(PageFactory.defaultPage(), queryWrapper));
|
|
|
|
+
|
|
|
|
+ List<CollectorRegisterParam> rows01 = new ArrayList<>();
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ List<CollectorRegister> rows = collectorRegisterPageResult.getRows();
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ for (CollectorRegister row : rows) {
|
|
|
|
+
|
|
|
|
+ LambdaQueryWrapper<EartagRegister> lambdaQuery = Wrappers.lambdaQuery();
|
|
|
|
+ lambdaQuery.eq(EartagRegister::getDeviceCode, row.getDeviceCode());
|
|
|
|
+
|
|
|
|
+ CollectorRegisterParam collectorRegisterParam1 = new CollectorRegisterParam();
|
|
|
|
+ BeanUtils.copyProperties(row,collectorRegisterParam1);
|
|
|
|
+ collectorRegisterParam1.setTotalEartag(eartagRegisterMapper.selectCount(lambdaQuery) );
|
|
|
|
+ rows01.add(collectorRegisterParam1);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //返回行的 目前只能逐个赋值
|
|
|
|
+
|
|
|
|
+ return collectorRegisterPageResult;
|
|
|
|
+
|
|
|
|
+
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
public List<CollectorRegister> list(CollectorRegisterParam collectorRegisterParam) {
|
|
public List<CollectorRegister> list(CollectorRegisterParam collectorRegisterParam) {
|
|
return this.list();
|
|
return this.list();
|
|
}
|
|
}
|
|
|
|
|
|
- @Resource
|
|
|
|
- private SysOrgMapper sysOrgMapper;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public void add(CollectorRegisterParam collectorRegisterParam) {
|
|
public void add(CollectorRegisterParam collectorRegisterParam) {
|
|
CollectorRegister collectorRegister = new CollectorRegister();
|
|
CollectorRegister collectorRegister = new CollectorRegister();
|
|
- //之前是拿组织ID 之后添加---现在应该改变这里
|
|
|
|
BeanUtil.copyProperties(collectorRegisterParam, collectorRegister);
|
|
BeanUtil.copyProperties(collectorRegisterParam, collectorRegister);
|
|
Long sysLoginUserOrgId = LoginContextHolder.me().getSysLoginUserOrgId();
|
|
Long sysLoginUserOrgId = LoginContextHolder.me().getSysLoginUserOrgId();
|
|
SysOrg sysOrg = sysOrgMapper.selectById(sysLoginUserOrgId);
|
|
SysOrg sysOrg = sysOrgMapper.selectById(sysLoginUserOrgId);
|
|
-
|
|
|
|
- collectorRegister.setOrgId(sysLoginUserOrgId);//非省平台不需要这个
|
|
|
|
- collectorRegister.setOrgName(sysOrg.getName());//非省平台不需要这个
|
|
|
|
|
|
+ collectorRegister.setOrgId(sysLoginUserOrgId);
|
|
|
|
+ collectorRegister.setOrgName(sysOrg.getName());
|
|
this.save(collectorRegister);
|
|
this.save(collectorRegister);
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Override
|
|
@Override
|
|
public void delete(List<Integer> ids) {
|
|
public void delete(List<Integer> ids) {
|
|
@@ -169,10 +199,10 @@ public class CollectorRegisterServiceImpl extends ServiceImpl<CollectorRegisterM
|
|
if (ObjectUtil.isEmpty(orgId)){
|
|
if (ObjectUtil.isEmpty(orgId)){
|
|
orgId = LoginContextHolder.me().getSysLoginUserOrgId();
|
|
orgId = LoginContextHolder.me().getSysLoginUserOrgId();
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+ List<Long> orgIds = getOrgid(orgId);
|
|
|
|
|
|
LambdaQueryWrapper<CollectorRegister> lambdaQuery = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<CollectorRegister> lambdaQuery = Wrappers.lambdaQuery();
|
|
- lambdaQuery.eq(CollectorRegister::getOrgId, orgId);
|
|
|
|
|
|
+ lambdaQuery.in(CollectorRegister::getOrgId, orgIds);
|
|
|
|
|
|
Map<String, Integer> map = new LinkedHashMap<>();
|
|
Map<String, Integer> map = new LinkedHashMap<>();
|
|
map.put("total", count(lambdaQuery));
|
|
map.put("total", count(lambdaQuery));
|
|
@@ -192,4 +222,19 @@ public class CollectorRegisterServiceImpl extends ServiceImpl<CollectorRegisterM
|
|
|
|
|
|
return new SuccessResponseData(map);
|
|
return new SuccessResponseData(map);
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ public List<Long> getOrgid(Long orgId){
|
|
|
|
+ QueryWrapper<SysOrg> sysOrgQueryWrapper = new QueryWrapper<>();
|
|
|
|
+ sysOrgQueryWrapper.select("id");
|
|
|
|
+ sysOrgQueryWrapper.like("pids",orgId);
|
|
|
|
+ List<SysOrg> sysOrgs = sysOrgMapper.selectList(sysOrgQueryWrapper);
|
|
|
|
+ List<Long> orgIds = new ArrayList<>();
|
|
|
|
+ orgIds.add(orgId);
|
|
|
|
+ for (SysOrg sysOrg : sysOrgs) {
|
|
|
|
+ orgIds.add(sysOrg.getId());
|
|
|
|
+ }
|
|
|
|
+ return orgIds;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
}
|
|
}
|