moral.git - Gitblit

			@@ -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);
			}
			}