From 06b00a178d194d33370e44410c4f04a4164f86c7 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Thu, 24 Jun 2021 14:07:02 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev_ --- screen-manage/src/main/java/com/moral/api/service/impl/UnitConversionServiceImpl.java | 94 ++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 81 insertions(+), 13 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/UnitConversionServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/UnitConversionServiceImpl.java index 16ff9d1..75593af 100644 --- a/screen-manage/src/main/java/com/moral/api/service/impl/UnitConversionServiceImpl.java +++ b/screen-manage/src/main/java/com/moral/api/service/impl/UnitConversionServiceImpl.java @@ -1,6 +1,8 @@ package com.moral.api.service.impl; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.moral.api.config.mybatis.wrapper.NullFilterWrapper; import com.moral.api.entity.SysDictData; @@ -8,17 +10,19 @@ import com.moral.api.mapper.UnitConversionMapper; import com.moral.api.pojo.dto.unitConversion.UnitConversionDTO; import com.moral.api.pojo.dto.unitConversion.UnitConversionQueryDTO; +import com.moral.api.pojo.form.unitConversion.UnitConversionDeleteForm; import com.moral.api.pojo.form.unitConversion.UnitConversionInsertForm; import com.moral.api.pojo.form.unitConversion.UnitConversionQueryForm; +import com.moral.api.pojo.form.unitConversion.UnitConversionUpdateForm; import com.moral.api.service.SysDictDataService; import com.moral.api.service.UnitConversionService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.moral.constant.Constants; import com.moral.constant.ResponseCodeEnum; import com.moral.util.ConvertUtils; -import net.bytebuddy.description.method.ParameterList; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ObjectUtils; import java.util.ArrayList; @@ -42,21 +46,33 @@ SysDictDataService sysDictDataService; @Override + @Transactional public UnitConversionDTO insertUnitConversion(UnitConversionInsertForm form) { //������������������ - UnitConversionDTO dto = new UnitConversionDTO(); + UnitConversionDTO dto = new UnitConversionDTO(); //������ UnitConversion unitConversion = form.formConvertEntity(); //������������������������������������������������������������������������ - QueryWrapper existWrapper = new QueryWrapper(); - existWrapper.eq("original_unit_key",unitConversion.getOriginalUnitKey()); - existWrapper.eq("target_unit_key",unitConversion.getTargetUnitKey()); - existWrapper.eq("is_delete",Constants.NOT_DELETE); - UnitConversion existConversion = unitConversionMapper.selectOne(existWrapper); - if(!ObjectUtils.isEmpty(existConversion)){ - dto.setCode(ResponseCodeEnum.UNIT_CONVERSION_EXIST.getCode()); - dto.setMsg(ResponseCodeEnum.UNIT_CONVERSION_EXIST.getMsg()); - return dto; + QueryWrapper<UnitConversion> existWrapper = new QueryWrapper(); + existWrapper.eq("original_unit_key", unitConversion.getOriginalUnitKey()); + existWrapper.eq("target_unit_key", unitConversion.getTargetUnitKey()); + existWrapper.eq("is_delete", Constants.NOT_DELETE); + List<UnitConversion> unitConversions = unitConversionMapper.selectList(existWrapper); + if (ObjectUtils.isEmpty(unitConversion.getSensorCode())) { + if (!ObjectUtils.isEmpty(unitConversions)) { + dto.setCode(ResponseCodeEnum.UNIT_CONVERSION_EXIST.getCode()); + dto.setMsg(ResponseCodeEnum.UNIT_CONVERSION_EXIST.getMsg()); + return dto; + } + } + if (!ObjectUtils.isEmpty(unitConversion.getSensorCode())) { + for (UnitConversion conversion : unitConversions) { + if (ObjectUtils.isEmpty(conversion.getSensorCode())||conversion.getSensorCode().equals(unitConversion.getSensorCode())) { + dto.setCode(ResponseCodeEnum.UNIT_CONVERSION_EXIST.getCode()); + dto.setMsg(ResponseCodeEnum.UNIT_CONVERSION_EXIST.getMsg()); + return dto; + } + } } //������������ unitConversionMapper.insert(unitConversion); @@ -81,8 +97,8 @@ //������������������ Page<UnitConversion> queryPage = new Page<>(page, size); NullFilterWrapper<UnitConversion> wrapper = new NullFilterWrapper<>(); - wrapper.eq("original_unit_key",originalUnitKey); - wrapper.eq("target_unit_key",targetUnitKey); + wrapper.eq("original_unit_key", originalUnitKey); + wrapper.eq("target_unit_key", targetUnitKey); //������������������������ if (!ObjectUtils.isEmpty(order) && !ObjectUtils.isEmpty(orderType)) { if (orderType.equals(Constants.ORDER_ASC)) @@ -120,4 +136,56 @@ dto.setMsg(ResponseCodeEnum.SUCCESS.getMsg()); return dto; } + + @Override + @Transactional + public UnitConversionDTO updateUnitConversion(UnitConversionUpdateForm form) { + //������������������ + UnitConversionDTO dto = new UnitConversionDTO(); + //������ + UnitConversion unitConversion = form.formConvertEntity(); + //������������������������ ������������������ + QueryWrapper<UnitConversion> oldWrapper = new QueryWrapper<>(); + UnitConversion oldUnitConversion = new UnitConversion(); + oldUnitConversion.setId(unitConversion.getId()); + oldUnitConversion.setIsDelete(Constants.NOT_DELETE); + oldWrapper.setEntity(oldUnitConversion); + oldUnitConversion = unitConversionMapper.selectOne(oldWrapper); + //������ + unitConversionMapper.updateById(unitConversion); + //������������������ + dto.setCode(ResponseCodeEnum.SUCCESS.getCode()); + dto.setMsg(ResponseCodeEnum.SUCCESS.getMsg()); + return dto; + } + + @Override + public UnitConversionDTO deleteUnitConversion(UnitConversionDeleteForm form) { + //������������������ + UnitConversionDTO dto = new UnitConversionDTO(); + //������ + Integer id = form.getId(); + //������������������������������������������ + QueryWrapper<UnitConversion> oldWrapper = new QueryWrapper<>(); + UnitConversion oldUnitConversion = new UnitConversion(); + oldUnitConversion.setId(id); + oldUnitConversion.setIsDelete(Constants.NOT_DELETE); + oldWrapper.setEntity(oldUnitConversion); + oldUnitConversion = unitConversionMapper.selectOne(oldWrapper); + //������������������ + UpdateWrapper deleteWrapper = new UpdateWrapper(); + deleteWrapper.set("is_delete", Constants.DELETE); + deleteWrapper.eq("id", id); + unitConversionMapper.update(null, deleteWrapper); + //������������������ + dto.setCode(ResponseCodeEnum.SUCCESS.getCode()); + dto.setMsg(ResponseCodeEnum.SUCCESS.getMsg()); + return dto; + } + + public static void main(String[] args) { + int[] array = new int[]{1,2,3,4,5,}; + String s = JSON.toJSONString(array); + System.out.println(s); + } } -- Gitblit v1.8.0