傅里叶后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
16639036659
2024-04-07 c20b17fee68aa391bbbdaed34d1ee22f1ed21448 
 src/main/java/com/gkhy/fourierSpecialGasMonitor/service/impl/GasCategoryServiceImpl.java


@@ -3,6 +3,7 @@


import com.gkhy.fourierSpecialGasMonitor.commons.domain.Result;


import com.gkhy.fourierSpecialGasMonitor.commons.domain.SearchResult;


import com.gkhy.fourierSpecialGasMonitor.commons.enums.ResultCode;


import com.gkhy.fourierSpecialGasMonitor.commons.enums.SystemCacheKeyEnum;


import com.gkhy.fourierSpecialGasMonitor.commons.exception.BusinessException;


import com.gkhy.fourierSpecialGasMonitor.commons.model.PageQuery;


import com.gkhy.fourierSpecialGasMonitor.domain.account.entity.User;


@@ -20,8 +21,16 @@


import com.gkhy.fourierSpecialGasMonitor.service.GasCategoryService;


import com.gkhy.fourierSpecialGasMonitor.utils.ThreadLocalUtil;


import io.micrometer.core.instrument.util.StringUtils;


import org.apache.poi.hssf.usermodel.HSSFWorkbook;


import org.apache.poi.ss.usermodel.FormulaEvaluator;


import org.apache.poi.ss.usermodel.Row;


import org.apache.poi.ss.usermodel.Sheet;


import org.apache.poi.ss.usermodel.Workbook;


import org.apache.poi.xssf.usermodel.XSSFWorkbook;


import org.redisson.api.RBucket;


import org.redisson.api.RedissonClient;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.context.annotation.Bean;


@@ -31,11 +40,15 @@


import org.springframework.data.jpa.domain.Specification;


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;


import org.springframework.web.multipart.MultipartFile;




import javax.persistence.criteria.CriteriaBuilder;


import javax.persistence.criteria.CriteriaQuery;


import javax.persistence.criteria.Predicate;


import javax.persistence.criteria.Root;


import java.io.FileInputStream;


import java.io.IOException;


import java.io.InputStream;


import java.time.LocalDateTime;


import java.util.*;


import java.util.concurrent.locks.ReentrantLock;


@@ -64,7 +77,7 @@


    }




    @Override


    public Result createGasCategory(CreateGasCategoryReqDTO reqDto) {


    public synchronized Result createGasCategory(CreateGasCategoryReqDTO reqDto) {


        if (reqDto == null)


            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(),"参数不能为空");


        if (StringUtils.isBlank(reqDto.getMolecularFormula()))


@@ -95,7 +108,7 @@


            gasCategoryMolecularFormulaRepeatlock.unlock();


        }


        //清除redis缓存


        RBucket<List<GasCategory>> bucket = redissonClient.getBucket("gas_category_cache_info");


        RBucket<List<GasCategory>> bucket = redissonClient.getBucket(SystemCacheKeyEnum.KEY_GAS_CATEGORY.getKey());


        if (bucket.isExists()) {


            bucket.delete();


        }


@@ -135,7 +148,7 @@


            gasCategoryMolecularFormulaRepeatlock.unlock();


        }


        //清除redis缓存


        RBucket<List<GasCategory>> bucket = redissonClient.getBucket("gas_category_cache_info");


        RBucket<List<GasCategory>> bucket = redissonClient.getBucket(SystemCacheKeyEnum.KEY_GAS_CATEGORY.getKey());


        if (bucket.isExists()) {


            bucket.delete();


        }


@@ -167,7 +180,7 @@


    @Override


    public Result gasCategoryList() {


        Result success = Result.success();


        RBucket<List<GasCategory>> bucket = redissonClient.getBucket("gas_category_cache_info");


        RBucket<List<GasCategory>> bucket = redissonClient.getBucket(SystemCacheKeyEnum.KEY_GAS_CATEGORY.getKey());


        List<GasCategory> categories = bucket.get();


        if (CollectionUtils.isEmpty(categories)){


            categories = gasCategoryRepository.findAll();