工业互联网平台
查看 | 历史 | 提交 | 提交对比
潘志宝
2025-01-14 cb5066ddca3d7c8d0959b20715f0f46948e6753e
提交 | 用户 | 时间
a6de49 1 package com.iailab.module.data.point.service.impl;
H 2
139c6a 3 import cn.hutool.core.collection.CollUtil;
a6de49 4 import com.alibaba.fastjson.JSONArray;
cfbd83 5 import com.baomidou.dynamic.datasource.annotation.DSTransactional;
a6de49 6 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
250190 7 import com.baomidou.mybatisplus.core.metadata.IPage;
6bf63b 8 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
48c064 9 import com.iailab.framework.common.constant.Constant;
6bf63b 10 import com.iailab.framework.common.pojo.PageResult;
48c064 11 import com.iailab.framework.common.service.impl.BaseServiceImpl;
139c6a 12 import com.iailab.framework.common.util.object.BeanUtils;
6bf63b 13 import com.iailab.framework.common.util.object.ConvertUtils;
07890e 14 import com.iailab.module.data.api.point.dto.ApiPointDTO;
01d6f8 15 import com.iailab.module.data.channel.common.service.ChannelSourceService;
a6de49 16 import com.iailab.module.data.common.enums.CommonConstant;
H 17 import com.iailab.module.data.common.enums.IsEnableEnum;
c96e44 18 import com.iailab.module.data.common.enums.IncreaseCodeEnum;
a6de49 19 import com.iailab.module.data.point.common.PointTypeEnum;
6bf63b 20 import com.iailab.module.data.point.dao.DaPointDao;
0ed8ac 21 import com.iailab.module.data.point.dto.DaCumulatePointDTO;
潘 22 import com.iailab.module.data.point.dto.DaMathPointDTO;
a6de49 23 import com.iailab.module.data.point.dto.DaMeasurePointDTO;
H 24 import com.iailab.module.data.point.dto.DaPointDTO;
139c6a 25 import com.iailab.module.data.point.entity.DaMeasurePointEntity;
a6de49 26 import com.iailab.module.data.point.entity.DaPointEntity;
0ed8ac 27 import com.iailab.module.data.point.service.*;
f21253 28 import com.iailab.module.data.point.vo.DaPointPageReqVO;
J 29 import com.iailab.module.data.point.vo.PointImportExcelVO;
30 import com.iailab.module.data.point.vo.PointImportRespVO;
48c57b 31 import org.apache.commons.lang3.ObjectUtils;
0ed8ac 32 import org.springframework.beans.factory.annotation.Autowired;
a6de49 33 import org.springframework.stereotype.Service;
H 34 import org.springframework.util.CollectionUtils;
35
6bf63b 36 import javax.annotation.Resource;
a6de49 37 import java.util.*;
9df837 38 import java.util.concurrent.ConcurrentHashMap;
139c6a 39
D 40 import static com.iailab.framework.common.exception.util.ServiceExceptionUtil.exception;
f21253 41 import static com.iailab.module.data.enums.ErrorCodeConstants.POINT_EXISTS;
J 42 import static com.iailab.module.data.enums.ErrorCodeConstants.POINT_IMPORT_LIST_IS_EMPTY;
a6de49 43
H 44 /**
6bf63b 45  * @author lirm
a6de49 46  * @Description
6bf63b 47  * @createTime 2024年09月2日
a6de49 48  */
H 49 @Service
48c064 50 public class DaPointServiceImpl extends BaseServiceImpl<DaPointDao, DaPointEntity> implements DaPointService {
a6de49 51
0ed8ac 52     @Autowired
a6de49 53     private DaMeasurePointService daMeasurePointService;
H 54
0ed8ac 55     @Autowired
a6de49 56     private DaMathPointService daMathPointService;
H 57
0ed8ac 58     @Autowired
潘 59     private DaCumulatePointService daCumulatePointService;
60
61     @Autowired
a6de49 62     private DaSequenceNumService daSequenceNumService;
6bf63b 63     
L 64     @Resource
65     private DaPointDao daPointDao;
66
139c6a 67     @Resource
01d6f8 68     private ChannelSourceService channelSourceService;
9df837 69
90e342 70     @Resource
潘 71     private DaPointCollectStatusService daPointCollectStatusService;
72
07890e 73     private static Map<String, ApiPointDTO> pointIdMap = new ConcurrentHashMap<>();
a4891a 74
9df837 75     private static Map<String, DaPointDTO> pointNoMap = new ConcurrentHashMap<>();
a6de49 76
H 77     @Override
250190 78     public PageResult<DaPointDTO> queryPage(DaPointPageReqVO reqVO) {
139c6a 79         IPage<DaPointDTO> page = daPointDao.selectPageList(reqVO);
a4891a 80         return new PageResult<>(page.getRecords(), page.getTotal());
潘 81     }
82
83     private void clearCache() {
84         pointIdMap.clear();
85         pointNoMap.clear();
a6de49 86     }
H 87
88     @Override
6bf63b 89     public DaPointDTO info(String id) {
L 90         DaPointEntity entity = daPointDao.selectById(id);
a6de49 91         DaPointDTO result = ConvertUtils.sourceToTarget(entity, DaPointDTO.class);
0ed8ac 92         result.setMeasurePoint(new DaMeasurePointDTO());
潘 93         result.setMathPoint(new DaMathPointDTO());
94         result.setCumulatePoint(new DaCumulatePointDTO());
95         switch (PointTypeEnum.getEumByCode(result.getPointType())) {
96             case MEASURE_POINT:
97                 DaMeasurePointDTO measurePoint = daMeasurePointService.getByPoint(id);
98                 result.setMeasurePoint(measurePoint);
99                 List<String> sourceOption = new ArrayList<>();
100                 sourceOption.add(measurePoint.getSourceType());
101                 sourceOption.add(measurePoint.getSourceId());
102                 sourceOption.add(measurePoint.getTagNo());
103                 result.setSourceOption(sourceOption);
104                 break;
105             case CALCULATE_POINT:
106                 result.setMathPoint(daMathPointService.getByPoint(id));
107                 break;
108             case CUMULATE:
109                 result.setCumulatePoint(daCumulatePointService.getByPoint(id));
110                 break;
111             default:
112                 break;
a6de49 113         }
H 114         return result;
115     }
116
117     @Override
07890e 118     public ApiPointDTO getSimpleInfoById(String id) {
a4891a 119         if (pointIdMap.containsKey(id)) {
潘 120             return pointIdMap.get(id);
121         }
07890e 122         ApiPointDTO dto = ConvertUtils.sourceToTarget(daPointDao.selectById(id), ApiPointDTO.class);
5f7008 123         if (dto == null) {
潘 124             return null;
125         }
a4891a 126         pointIdMap.put(id, dto);
07890e 127         return dto;
b8b8cb 128     }
潘 129
130     @Override
131     public DaPointDTO getSimpleInfoByNo(String no) {
29b971 132         QueryWrapper<DaPointEntity> queryWrapper = new QueryWrapper<>();
7511af 133         queryWrapper.eq("point_no", no);
b8b8cb 134         return ConvertUtils.sourceToTarget(daPointDao.selectOne(queryWrapper), DaPointDTO.class);
潘 135     }
136
137     @Override
a6de49 138     public List<DaPointDTO> list(Map<String, Object> params) {
48c57b 139         Object pointType = params.get("pointType");
a6de49 140         List<String> pointNos = new ArrayList<>();
H 141         if (params.get("pointNos") != null) {
142             pointNos = JSONArray.parseArray(JSONArray.toJSONString(params.get("pointNos")), String.class);
143         }
14cb32 144         List<String> pointTypes = new ArrayList<>();
潘 145         if (params.get("pointTypes") != null) {
146             pointTypes = Arrays.asList(params.get("pointTypes").toString().split(","));
147         }
148
48c57b 149         Object pointNoLike = params.get("pointNoLike");
a6de49 150         QueryWrapper<DaPointEntity> queryWrapper = new QueryWrapper();
48c57b 151         queryWrapper.eq(!ObjectUtils.isEmpty(pointType), "point_type", pointType);
L 152         queryWrapper.in(pointNos.size() != 0,"point_no", pointNos);
153         queryWrapper.like(!ObjectUtils.isEmpty(pointNoLike), "point_no", pointNoLike);
14cb32 154         queryWrapper.in(pointTypes.size() != 0,"point_type", pointTypes);
6bf63b 155         List<DaPointEntity> list = daPointDao.selectList(queryWrapper);
a6de49 156         return ConvertUtils.sourceToTarget(list, DaPointDTO.class);
H 157     }
158
159     @Override
cfbd83 160     @DSTransactional(rollbackFor = Exception.class)
a6de49 161     public void add(DaPointDTO dataPoint) {
H 162         DaPointEntity daPointEntity = ConvertUtils.sourceToTarget(dataPoint, DaPointEntity.class);
163         daPointEntity.setId(UUID.randomUUID().toString());
01d6f8 164         switch (PointTypeEnum.getEumByCode(dataPoint.getPointType())) {
潘 165             case MEASURE_POINT:
166                 DaMeasurePointDTO measurePoint = new DaMeasurePointDTO();
167                 measurePoint.setSourceType(dataPoint.getSourceOption().get(0));
168                 measurePoint.setSourceId(dataPoint.getSourceOption().get(1));
169                 measurePoint.setTagNo(dataPoint.getSourceOption().get(2));
170                 daMeasurePointService.add(measurePoint, daPointEntity.getId());
171                 daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_M.name()));
172                 break;
173             case CALCULATE_POINT:
174                 daMathPointService.add(dataPoint.getMathPoint(), daPointEntity.getId());
175                 daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_C.name()));
176                 break;
177             case CONSTANT:
178                 daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_F.name()));
179                 break;
0ed8ac 180             case CUMULATE:
潘 181                 daCumulatePointService.add(dataPoint.getCumulatePoint(), daPointEntity.getId());
182                 daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_L.name()));
183                 break;
01d6f8 184             default:
潘 185                 break;
a6de49 186         }
H 187         daPointEntity.setIsEnable(CommonConstant.IS_ENABLE);
188         daPointEntity.setCreateTime(new Date());
6bf63b 189         daPointDao.insert(daPointEntity);
9df837 190
90e342 191         daPointCollectStatusService.add(daPointEntity.getPointNo());
9df837 192         // 清空缓存
a4891a 193         clearCache();
a6de49 194     }
H 195
196     @Override
cfbd83 197     @DSTransactional(rollbackFor = Exception.class)
a6de49 198     public void update(DaPointDTO dataPoint) {
H 199         DaPointEntity daPointEntity = ConvertUtils.sourceToTarget(dataPoint, DaPointEntity.class);
200         daPointEntity.setUpdateTime(new Date());
6bf63b 201         daPointDao.updateById(daPointEntity);
01d6f8 202         switch (PointTypeEnum.getEumByCode(dataPoint.getPointType())) {
潘 203             case MEASURE_POINT:
204                 DaMeasurePointDTO measurePoint = dataPoint.getMeasurePoint();
205                 measurePoint.setSourceType(dataPoint.getSourceOption().get(0));
206                 measurePoint.setSourceId(dataPoint.getSourceOption().get(1));
207                 measurePoint.setTagNo(dataPoint.getSourceOption().get(2));
208                 daMeasurePointService.update(measurePoint);
209                 break;
210             case CALCULATE_POINT:
211                 daMathPointService.update(dataPoint.getMathPoint());
212                 break;
0ed8ac 213             case CUMULATE:
潘 214                 daCumulatePointService.update(dataPoint.getCumulatePoint());
215                 break;
01d6f8 216             default:
潘 217                 break;
a6de49 218         }
9df837 219         // 清空缓存
a4891a 220         clearCache();
a6de49 221     }
H 222
223     @Override
cfbd83 224     @DSTransactional(rollbackFor = Exception.class)
eb1c5f 225     public void delete(String[] ids) {
潘 226         daPointDao.deleteBatchIds(Arrays.asList(ids));
227         daMeasurePointService.deleteByPoint(ids);
228         daMathPointService.deleteByPoint(ids);
229         daCumulatePointService.deleteByPoint(ids);
9df837 230         // 清空缓存
a4891a 231         clearCache();
a6de49 232     }
H 233
234     @Override
14cb32 235     public List<DaPointDTO> getConstantPoint(DaPointPageReqVO reqVO) {
潘 236         Map<String, Object> params = new HashMap<>();
237         params.put("pointType", PointTypeEnum.CONSTANT.getCode());
238         params.put("pointNo", reqVO.getPointNo());
239         params.put("pointName", reqVO.getPointName());
240         return daPointDao.getConstantPoint(params);
241     }
242
243     @Override
a6de49 244     public List<DaPointDTO> getConstantPoint(String freq) {
H 245         Map<String, Object> params = new HashMap<>();
246         params.put("pointType", PointTypeEnum.CONSTANT.getCode());
247         params.put("isEnable", CommonConstant.IS_ENABLE);
248         params.put("minfreqid", freq);
6bf63b 249         return daPointDao.getConstantPoint(params);
a6de49 250     }
H 251
252     @Override
253     public List<DaPointDTO> getConstantPoint(List<String> pointNos) {
254         Map<String, Object> params = new HashMap<>();
255         params.put("pointType", PointTypeEnum.CONSTANT.getCode());
256         params.put("isEnable", CommonConstant.IS_ENABLE);
257         params.put("pointNos", pointNos);
6bf63b 258         return daPointDao.getConstantPoint(params);
14cb32 259     }
潘 260
261     @Override
262     public List<DaPointDTO> getMeasurePoint(DaPointPageReqVO reqVO) {
263         Map<String, Object> params = new HashMap<>();
264         params.put("pointType", PointTypeEnum.MEASURE_POINT.getCode());
265         params.put("pointNo", reqVO.getPointNo());
266         params.put("pointName", reqVO.getPointName());
267         params.put("sourceName", reqVO.getSourceName());
268         return daPointDao.getMeasurePoint(params);
a6de49 269     }
H 270
271     @Override
272     public List<DaPointDTO> getMeasurePoint(String freq) {
273         Map<String, Object> params = new HashMap<>();
274         params.put("pointType", PointTypeEnum.MEASURE_POINT.getCode());
275         params.put("isEnable", CommonConstant.IS_ENABLE);
276         params.put("minfreqid", freq);
6bf63b 277         return daPointDao.getMeasurePoint(params);
a6de49 278     }
H 279
280     @Override
281     public List<DaPointDTO> getMeasurePoint(List<String> pointNos) {
282         Map<String, Object> params = new HashMap<>();
283         params.put("pointType", PointTypeEnum.MEASURE_POINT.getCode());
284         params.put("isEnable", CommonConstant.IS_ENABLE);
285         params.put("pointNos", pointNos);
6bf63b 286         return daPointDao.getMeasurePoint(params);
a6de49 287     }
H 288
289     @Override
290     public DaPointDTO getMeasurePointByNo(String pointNo) {
291         Map<String, Object> params = new HashMap<>();
292         params.put("pointType", PointTypeEnum.MEASURE_POINT.getCode());
293         params.put("pointNo", pointNo);
6bf63b 294         List<DaPointDTO> list = daPointDao.getMeasurePoint(params);
a6de49 295         if (CollectionUtils.isEmpty(list)) {
H 296             return null;
297         }
298         return list.get(0);
14cb32 299     }
潘 300
301     @Override
302     public List<DaPointDTO> getMathPoint(DaPointPageReqVO reqVO) {
303         Map<String, Object> params = new HashMap<>();
304         params.put("pointType", PointTypeEnum.CALCULATE_POINT.getCode());
305         params.put("pointNo", reqVO.getPointNo());
306         params.put("pointName", reqVO.getPointName());
307         return daPointDao.getMathPoint(params);
a6de49 308     }
H 309
310     @Override
48c064 311     public PageResult<ApiPointDTO> getPointPage(HashMap map) {
L 312         IPage<ApiPointDTO> page = daPointDao.getPointPage(getPage(map, Constant.CREATE_TIME, false),map);
313         return new PageResult<>(page.getRecords(), page.getTotal());
314     }
315
316     @Override
a6de49 317     public List<DaPointDTO> getMathPoint(String freq) {
H 318         Map<String, Object> params = new HashMap<>();
319         params.put("pointType", PointTypeEnum.CALCULATE_POINT.getCode());
320         params.put("isEnable", CommonConstant.IS_ENABLE);
321         params.put("minfreqid", freq);
6bf63b 322         return daPointDao.getMathPoint(params);
a6de49 323     }
H 324
325     @Override
326     public List<DaPointDTO> getMathPoint(List<String> pointNos) {
327         Map<String, Object> params = new HashMap<>();
328         params.put("pointType", PointTypeEnum.CALCULATE_POINT.getCode());
329         params.put("isEnable", CommonConstant.IS_ENABLE);
330         params.put("pointNos", pointNos);
6bf63b 331         return daPointDao.getMathPoint(params);
a6de49 332     }
H 333
334     @Override
56dba6 335     public List<DaPointDTO> getCumulatePoint(String freq) {
eb1c5f 336         Map<String, Object> params = new HashMap<>(3);
56dba6 337         params.put("pointType", PointTypeEnum.CUMULATE.getCode());
潘 338         params.put("isEnable", CommonConstant.IS_ENABLE);
339         params.put("minfreqid", freq);
eb1c5f 340         return daPointDao.getCumulatePoint(params);
潘 341     }
342
343     @Override
d64649 344     public List<DaPointDTO> getCumulatePoint(List<String> pointNos) {
潘 345         Map<String, Object> params = new HashMap<>(3);
346         params.put("pointType", PointTypeEnum.CUMULATE.getCode());
347         params.put("isEnable", CommonConstant.IS_ENABLE);
348         params.put("pointNos", pointNos);
349         return daPointDao.getCumulatePoint(params);
350     }
351
352     @Override
eb1c5f 353     public List<DaPointDTO> getCumulatePoint(DaPointPageReqVO reqVO) {
潘 354         Map<String, Object> params = new HashMap<>(3);
355         params.put("pointType", PointTypeEnum.CUMULATE.getCode());
356         params.put("pointNo", reqVO.getPointNo());
357         params.put("pointName", reqVO.getPointName());
56dba6 358         return daPointDao.getCumulatePoint(params);
潘 359     }
360
361     @Override
a6de49 362     public DaPointDTO getByNo(String pointNo) {
9df837 363         if (pointNoMap.containsKey(pointNo)) {
潘 364             return pointNoMap.get(pointNo);
365         }
a6de49 366         QueryWrapper<DaPointEntity> wrapper = new QueryWrapper<>();
H 367         wrapper.eq("point_no", pointNo);
6bf63b 368         DaPointEntity entity = daPointDao.selectOne(wrapper);
9df837 369         DaPointDTO dto = ConvertUtils.sourceToTarget(entity, DaPointDTO.class);
潘 370         pointNoMap.put(pointNo, dto);
371         return dto;
a6de49 372     }
H 373
374     @Override
375     public List<DaPointDTO> getByNos(List<String> pointNos) {
376         QueryWrapper<DaPointEntity> wrapper = new QueryWrapper<>();
377         wrapper.in("point_no", pointNos);
6bf63b 378         List<DaPointEntity> list = daPointDao.selectList(wrapper);
a6de49 379         return ConvertUtils.sourceToTarget(list, DaPointDTO.class);
H 380     }
381
382     @Override
383     public void updateDefaultValue(DaPointDTO dto) {
384         QueryWrapper<DaPointEntity> wrapper = new QueryWrapper<>();
385         wrapper.eq("point_no", dto.getPointNo());
386         DaPointEntity entity = new DaPointEntity();
387         entity.setDefaultValue(dto.getDefaultValue());
6bf63b 388         daPointDao.update(entity, wrapper);
a6de49 389     }
H 390
391     @Override
139c6a 392     @DSTransactional(rollbackFor = Exception.class) // 添加事务，异常则回滚所有导入
D 393     public PointImportRespVO importPointList(List<PointImportExcelVO> importPoints, boolean isUpdateSupport) {
394         // 1.1 参数校验
395         if (CollUtil.isEmpty(importPoints)) {
396             throw exception(POINT_IMPORT_LIST_IS_EMPTY);
397         }
01d6f8 398
潘 399         Map<String, Map<String, String>> sourcesIdMap = channelSourceService.getSourcesId();
139c6a 400         // 2. 遍历，逐个创建 or 更新
D 401         PointImportRespVO respVO = PointImportRespVO.builder().createPointnames(new ArrayList<>())
402                 .updatePointnames(new ArrayList<>()).failurePointnames(new LinkedHashMap<>()).build();
403         importPoints.forEach(importPoint -> {
404
405             // 判断如果不存在，再进行插入
48c064 406             DaPointEntity existPoint = baseDao.selectByPointName(importPoint.getPointName());
139c6a 407             if (existPoint == null) {
D 408                 DaPointEntity daPointEntity = ConvertUtils.sourceToTarget(importPoint, DaPointEntity.class);
409                 daPointEntity.setId(UUID.randomUUID().toString());
410                 daPointEntity.setIsEnable(CommonConstant.IS_ENABLE);
411                 daPointEntity.setCreateTime(new Date());
01d6f8 412                 switch (PointTypeEnum.getEumByCode(daPointEntity.getPointType())) {
潘 413                     case MEASURE_POINT:
414                         DaMeasurePointDTO measurePoint = new DaMeasurePointDTO();
415                         measurePoint.setSourceType(importPoint.getSourceType());
416                         measurePoint.setSourceId(sourcesIdMap.get(importPoint.getSourceType()).get(importPoint.getSourceName()));
417                         measurePoint.setTagNo(importPoint.getTagNo());
418                         measurePoint.setValueType(importPoint.getValueType());
419                         measurePoint.setDimension(importPoint.getDimension());
420                         daMeasurePointService.add(measurePoint, daPointEntity.getId());
421                         daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_M.name()));
422                         break;
423                     case CALCULATE_POINT:
424                         daMathPointService.add(importPoint.getExpression(), daPointEntity.getId());
425                         daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_C.name()));
426                         break;
427                     case CONSTANT:
428                         daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_F.name()));
429                         break;
eb1c5f 430                     case CUMULATE:
潘 431                         DaCumulatePointDTO cumulatePoint = new DaCumulatePointDTO();
432                         cumulatePoint.setMomentPoint(importPoint.getMomentPoint());
433                         cumulatePoint.setLength(importPoint.getLength());
434                         cumulatePoint.setDivisor(importPoint.getDivisor());
435                         daCumulatePointService.add(cumulatePoint, daPointEntity.getId());
436                         daPointEntity.setPointNo(daSequenceNumService.getAndIncreaseByCode(IncreaseCodeEnum.POINT_L.name()));
01d6f8 437                     default:
潘 438                         break;
439                 }
139c6a 440
D 441                 daPointDao.insert(daPointEntity);
13e045 442                 daPointCollectStatusService.add(daPointEntity.getPointNo());
139c6a 443                 respVO.getCreatePointnames().add(importPoint.getPointName());
D 444                 return;
445             }
446
447             // 如果存在，判断是否允许更新
448             if (!isUpdateSupport) {
449                 respVO.getFailurePointnames().put(importPoint.getPointName(), POINT_EXISTS.getMsg());
450                 return;
451             }
452
453             DaPointEntity updatePoint = BeanUtils.toBean(importPoint, DaPointEntity.class);
454             updatePoint.setId(existPoint.getId());
48c064 455             baseDao.updateById(updatePoint);
139c6a 456             DaMeasurePointEntity measurePoint = new DaMeasurePointEntity();
D 457             measurePoint.setSourceType(importPoint.getSourceType());
01d6f8 458             measurePoint.setSourceId(sourcesIdMap.get(importPoint.getSourceType()).get(importPoint.getSourceName()));
139c6a 459             measurePoint.setTagNo(importPoint.getTagNo());
D 460             daMeasurePointService.update(measurePoint, new QueryWrapper<DaMeasurePointEntity>().eq("point_id",updatePoint.getId()));
461             respVO.getUpdatePointnames().add(importPoint.getPointName());
462         });
463         return respVO;
464     }
465
466     @Override
14cb32 467     public List<DaPointDTO> getList(DaPointPageReqVO exportReqVO) {
潘 468         return daPointDao.getList(exportReqVO);
139c6a 469     }
D 470
471     @Override
ee9f60 472     @DSTransactional(rollbackFor = Exception.class)
a6de49 473     public void enableByIds(String[] ids) {
H 474         if (CollectionUtils.isEmpty(Arrays.asList(ids))) {
475             return;
476         }
477         Arrays.asList(ids).forEach(item -> {
478             DaPointEntity entity = new DaPointEntity();
479             entity.setId(item);
f21253 480             entity.setIsEnable(IsEnableEnum.ENABLE.getCode());
ee9f60 481             entity.setUpdateTime(new Date());
6bf63b 482             daPointDao.updateById(entity);
a6de49 483         });
H 484     }
485
486     @Override
ee9f60 487     @DSTransactional(rollbackFor = Exception.class)
a6de49 488     public void disableByIds(String[] ids) {
H 489         if (CollectionUtils.isEmpty(Arrays.asList(ids))) {
490             return;
491         }
492         Arrays.asList(ids).forEach(item -> {
493             DaPointEntity entity = new DaPointEntity();
494             entity.setId(item);
f21253 495             entity.setIsEnable(IsEnableEnum.DISABLE.getCode());
ee9f60 496             entity.setUpdateTime(new Date());
6bf63b 497             daPointDao.updateById(entity);
a6de49 498         });
H 499     }
500 }