|
@@ -0,0 +1,122 @@
|
|
|
+/*
|
|
|
+ * Copyright [2022] [https://www.xiaonuo.vip]
|
|
|
+ *
|
|
|
+ * Snowy采用APACHE LICENSE 2.0开源协议,您在使用过程中,需要注意以下几点:
|
|
|
+ *
|
|
|
+ * 1.请不要删除和修改根目录下的LICENSE文件。
|
|
|
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
|
|
|
+ * 3.本项目代码可免费商业使用,商业使用请保留源码和相关描述文件的项目出处,作者声明等。
|
|
|
+ * 4.分发源码时候,请注明软件出处 https://www.xiaonuo.vip
|
|
|
+ * 5.不可二次分发开源参与同类竞品,如有想法可联系团队xiaonuobase@qq.com商议合作。
|
|
|
+ * 6.若您的项目无法满足以上几点,需要更多功能代码,获取Snowy商业授权许可,请在官网购买授权,地址为 https://www.xiaonuo.vip
|
|
|
+ */
|
|
|
+package vip.xiaonuo.modular.energy.energythreshold.service.impl;
|
|
|
+
|
|
|
+import cn.hutool.core.bean.BeanUtil;
|
|
|
+import cn.hutool.core.collection.CollStreamUtil;
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import org.checkerframework.checker.units.qual.A;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
+import vip.xiaonuo.common.enums.CommonSortOrderEnum;
|
|
|
+import vip.xiaonuo.common.exception.CommonException;
|
|
|
+import vip.xiaonuo.common.page.CommonPageRequest;
|
|
|
+import vip.xiaonuo.common.pojo.CommonResult;
|
|
|
+import vip.xiaonuo.modular.base.pigpen.entity.BasePigpen;
|
|
|
+import vip.xiaonuo.modular.base.pigpen.mapper.BasePigpenMapper;
|
|
|
+import vip.xiaonuo.modular.energy.energythreshold.entity.EnergyThreshold;
|
|
|
+import vip.xiaonuo.modular.energy.energythreshold.mapper.EnergyThresholdMapper;
|
|
|
+import vip.xiaonuo.modular.energy.energythreshold.param.*;
|
|
|
+import vip.xiaonuo.modular.energy.energythreshold.service.EnergyThresholdService;
|
|
|
+
|
|
|
+import java.util.List;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 阈值设置Service接口实现类
|
|
|
+ *
|
|
|
+ * @author wang
|
|
|
+ * @date 2023/12/25 09:43
|
|
|
+ **/
|
|
|
+@Service
|
|
|
+public class EnergyThresholdServiceImpl extends ServiceImpl<EnergyThresholdMapper, EnergyThreshold> implements EnergyThresholdService {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private EnergyThresholdMapper thresholdMapper;
|
|
|
+ @Autowired
|
|
|
+ private BasePigpenMapper basePigpenMapper;
|
|
|
+ @Override
|
|
|
+ public Page<EnergyThreshold> page(EnergyThresholdPageParam energyThresholdPageParam) {
|
|
|
+ QueryWrapper<EnergyThreshold> queryWrapper = new QueryWrapper<>();
|
|
|
+ if(ObjectUtil.isAllNotEmpty(energyThresholdPageParam.getSortField(), energyThresholdPageParam.getSortOrder())) {
|
|
|
+ CommonSortOrderEnum.validate(energyThresholdPageParam.getSortOrder());
|
|
|
+ queryWrapper.orderBy(true, energyThresholdPageParam.getSortOrder().equals(CommonSortOrderEnum.ASC.getValue()),
|
|
|
+ StrUtil.toUnderlineCase(energyThresholdPageParam.getSortField()));
|
|
|
+ } else {
|
|
|
+ queryWrapper.lambda().orderByAsc(EnergyThreshold::getId);
|
|
|
+ }
|
|
|
+ return this.page(CommonPageRequest.defaultPage(), queryWrapper);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ @Override
|
|
|
+ public CommonResult add(EnergyThresholdAddParam energyThresholdAddParam) {
|
|
|
+ EnergyThreshold energyThreshold = BeanUtil.toBean(energyThresholdAddParam, EnergyThreshold.class);
|
|
|
+ QueryWrapper<EnergyThreshold> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.eq("org_id", energyThreshold.getOrgId()).eq("unit_id", energyThreshold.getUnitId());
|
|
|
+ if (ObjectUtil.isEmpty(thresholdMapper.selectOne(queryWrapper))) {
|
|
|
+ this.save(energyThreshold);
|
|
|
+ return CommonResult.ok();
|
|
|
+ } else {
|
|
|
+ return new CommonResult(500, "阈值已存在,无需重复添加!", false);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ @Override
|
|
|
+ public void edit(EnergyThresholdEditParam energyThresholdEditParam) {
|
|
|
+ EnergyThreshold energyThreshold = this.queryEntity(energyThresholdEditParam.getId().toString());
|
|
|
+ BeanUtil.copyProperties(energyThresholdEditParam, energyThreshold);
|
|
|
+ this.updateById(energyThreshold);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ @Override
|
|
|
+ public void delete(List<EnergyThresholdIdParam> energyThresholdIdParamList) {
|
|
|
+ // 执行删除
|
|
|
+ this.removeByIds(CollStreamUtil.toList(energyThresholdIdParamList, EnergyThresholdIdParam::getId));
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public EnergyThreshold detail(EnergyThresholdIdParam energyThresholdIdParam) {
|
|
|
+ return this.queryEntity(energyThresholdIdParam.getId().toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public EnergyThreshold queryEntity(String id) {
|
|
|
+ EnergyThreshold energyThreshold = this.getById(id);
|
|
|
+ if(ObjectUtil.isEmpty(energyThreshold)) {
|
|
|
+ throw new CommonException("阈值设置不存在,id值为:{}", id);
|
|
|
+ }
|
|
|
+ return energyThreshold;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public CommonResult batchThreshold(EnergyThresholdBatchParam energyThresholdBatchParam) {
|
|
|
+ EnergyThreshold energyThreshold = BeanUtil.toBean(energyThresholdBatchParam, EnergyThreshold.class);
|
|
|
+ QueryWrapper<BasePigpen> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.eq("org_id", energyThresholdBatchParam.getOrgId())
|
|
|
+ .like("pids", energyThresholdBatchParam.getUnitId());
|
|
|
+ List<BasePigpen> basePigpens = basePigpenMapper.selectList(queryWrapper);
|
|
|
+ for (BasePigpen basePigpen : basePigpens) {
|
|
|
+ energyThreshold.setUnitId(basePigpen.getId());
|
|
|
+ thresholdMapper.insert(energyThreshold);
|
|
|
+ }
|
|
|
+ return CommonResult.ok();
|
|
|
+ }
|
|
|
+}
|