数据采集
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
yangys
2024-04-18 85bb45834b1a2fd993d9f8653c48d14efc12a59e 
 smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/InitServiceImpl.java


@@ -1,14 +1,7 @@


package com.qianwen.smartman.modules.cps.service.impl;




import cn.hutool.core.io.IoUtil;


import com.alibaba.fastjson.JSONObject;


import com.aliyuncs.utils.StringUtils;


import com.baomidou.mybatisplus.core.conditions.Wrapper;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import java.io.File;


import java.io.FileReader;


import java.lang.invoke.SerializedLambda;


import java.sql.Connection;


import java.util.ArrayList;


import java.util.Collection;


@@ -16,7 +9,9 @@


import java.util.concurrent.Future;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;




import javax.sql.DataSource;




import org.apache.commons.io.FileUtils;


import org.apache.ibatis.jdbc.ScriptRunner;


import org.slf4j.Logger;


@@ -24,15 +19,25 @@


import org.smartboot.license.client.License;


import org.smartboot.license.client.LicenseEntity;


import org.smartboot.license.client.LicenseException;


import com.qianwen.smartman.common.constant.CommonConstant;


import com.qianwen.smartman.common.constant.FmsConstant;


import com.qianwen.smartman.common.utils.LicenseUtil;


import com.qianwen.smartman.common.utils.MessageUtils;


import org.springframework.core.env.Environment;


import org.springframework.core.io.ClassPathResource;


import org.springframework.data.redis.connection.RedisConnection;


import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import com.alibaba.fastjson.JSONObject;


import com.aliyuncs.utils.StringUtils;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.qianwen.core.log.exception.ServiceException;


import com.qianwen.core.redis.cache.BladeRedis;


import com.qianwen.core.tool.api.ResultCode;


import com.qianwen.core.tool.utils.DigestUtil;


import com.qianwen.core.tool.utils.Func;


import com.qianwen.smartman.common.constant.CommonConstant;


import com.qianwen.smartman.common.constant.FmsConstant;


import com.qianwen.smartman.common.utils.LicenseUtil;


import com.qianwen.smartman.common.utils.MessageUtils;


import com.qianwen.smartman.modules.cps.enums.AppEnum;


import com.qianwen.smartman.modules.cps.mapper.InitMapper;


import com.qianwen.smartman.modules.cps.mapper.TdengineMapper;


@@ -47,15 +52,10 @@


import com.qianwen.smartman.modules.system.service.IApplicationService;


import com.qianwen.smartman.modules.visual.entity.VisualConfig;


import com.qianwen.smartman.modules.visual.service.IVisualConfigService;


import org.springframework.core.env.Environment;


import org.springframework.core.io.ClassPathResource;


import org.springframework.data.redis.connection.RedisConnection;


import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import cn.hutool.core.io.IoUtil;




@Service


/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/InitServiceImpl.class */


public class InitServiceImpl implements IInitService {


    private static final Logger log = LoggerFactory.getLogger(InitServiceImpl.class);


    private final InitMapper initMapper;


@@ -83,17 +83,17 @@


        this.environment = environment;


    }




    @Override // org.springblade.modules.cps.service.IInitService


    @Override


    public Boolean checkIsNeedInit() {


        return Boolean.valueOf(this.initMapper.checkIsNeedInit(this.configVO.getDatabase(), this.configVO.getType()).intValue() <= 0);


    }




    @Override // org.springblade.modules.cps.service.IInitService


    @Override


    public ConfigVO getConfig() {


        return this.configVO;


    }




    @Override // org.springblade.modules.cps.service.IInitService


    @Override


    public List<AppVO> getApp() {


        List<AppVO> result = new ArrayList<>();


        AppEnum[] values = AppEnum.values();


@@ -110,7 +110,7 @@


        return result;


    }




    @Override // org.springblade.modules.cps.service.IInitService


    @Override


    @Transactional(rollbackFor = {Exception.class})


    public Boolean initSystem(InitSettingVO initSettingVO) {


       try {


@@ -162,7 +162,7 @@


       }


    }




    @Override // org.springblade.modules.cps.service.IInitService


    @Override


    public Boolean init(InitSettingVO initSettingVO) {


        if (!checkIsNeedInit().booleanValue()) {


            throw new ServiceException(MessageUtils.message("system.has.been.initialized", new Object[0]));


@@ -207,7 +207,7 @@


        return true;


    }




    @Override // org.springblade.modules.cps.service.IInitService


    @Override


    public LicenseDetailDTO licenseDetail() {


        try {


            Boolean needInit = checkIsNeedInit();


@@ -218,6 +218,7 @@


            LicenseEntity licenseEntity = new License().loadLicense(text);


            return (LicenseDetailDTO) JSONObject.parseObject(new String(licenseEntity.getData()), LicenseDetailDTO.class);


        } catch (LicenseException e) {


           log.error("加载licenseDetail错误",e);


            return null;


        }


    }