iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/sche/service/impl/StScheduleModelServiceImpl.java

@@ -1,145 +1,105 @@
package com.iailab.module.model.mcs.sche.service.impl;

import com.baomidou.dynamic.datasource.annotation.DSTransactional;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.iailab.framework.common.pojo.PageResult;
import com.iailab.framework.common.service.impl.BaseServiceImpl;
import com.iailab.framework.common.util.object.BeanUtils;
import com.iailab.module.model.mcs.sche.dao.StScheduleModelDao;
import com.iailab.module.model.mcs.sche.dto.StScheduleModelDto;
import com.iailab.module.model.mcs.sche.entity.StScheduleModelEntity;
import com.iailab.module.model.mcs.sche.entity.StScheduleModelUserParamEntity;
import com.iailab.module.model.mcs.sche.entity.StScheduleParamEntity;
import com.iailab.module.model.mcs.sche.entity.StScheduleParamSettingEntity;
import com.iailab.module.model.mcs.sche.service.StScheduleModelOutService;
import com.iailab.module.model.mcs.sche.service.StScheduleModelParamService;
import com.iailab.module.model.mcs.sche.service.StScheduleModelService;
import com.iailab.module.model.mcs.sche.vo.StScheduleModelRespVO;
import com.iailab.module.model.mcs.sche.service.StScheduleModelSettingService;
import com.iailab.module.model.mcs.sche.vo.StScheduleModelPageReqVO;
import com.iailab.module.model.mcs.sche.vo.StScheduleModelSaveReqVO;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Arrays;
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
import java.util.UUID;

/**
 * @author PanZhibao
 * @date 2021年07月20日 14:23
 */
@Service("stScheduleModelService")
public class StScheduleModelServiceImpl extends BaseServiceImpl<StScheduleModelDao, StScheduleModelEntity> implements StScheduleModelService {
    @Autowired
    private StScheduleParamSettingServiceImpl stScheduleParamSettingServiceImpl;
@Service
public class StScheduleModelServiceImpl implements StScheduleModelService {

    @Resource
    private StScheduleModelDao stScheduleModelDao;

    @Autowired
    private StScheduleParamServiceImpl stScheduleParamServiceImpl;
    private StScheduleModelParamService stScheduleModelParamService;

    @Autowired
    private StScheduleModelUserParamServiceImpl stScheduleModelUserParamServiceImpl;
    private StScheduleModelSettingService stScheduleModelSettingService;

    @Autowired
    private StScheduleModelOutService stScheduleModelOutService;

    @Override
    public PageResult<StScheduleModelRespVO> getPageList(Map<String, Object> params) {
        PageResult<StScheduleModelRespVO> result = new PageResult();
        IPage<StScheduleModelRespVO> page = baseDao.getPageList(
                getPage(params, null, false),
                params
        );
        result.setTotal(page.getTotal());
        result.setList(page.getRecords());
        return result;
    }

    private QueryWrapper<StScheduleModelEntity> getWrapper(Map<String, Object> params) {
        QueryWrapper<StScheduleModelEntity> wrapper = new QueryWrapper<>();
        return wrapper;
    public PageResult<StScheduleModelEntity> page(StScheduleModelPageReqVO reqVO) {
        return stScheduleModelDao.selectPage(reqVO);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveStScheduleModel(StScheduleModelDto scheduleModel) {
        StScheduleModelEntity stScheduleModelEntity = new StScheduleModelEntity();
        BeanUtils.copyProperties(scheduleModel, stScheduleModelEntity);
        stScheduleModelEntity.setId(UUID.randomUUID().toString());
        baseDao.insert(stScheduleModelEntity);
    public List<StScheduleModelEntity> list() {

        scheduleModel.getStScheduleParamSettingList().forEach(item -> {
            item.setModelid(stScheduleModelEntity.getId());
        });
        stScheduleParamSettingServiceImpl.saveList(scheduleModel.getStScheduleParamSettingList());

        scheduleModel.getStScheduleParamList().forEach(item -> {
            item.setModelid(stScheduleModelEntity.getId());
        });
        stScheduleParamServiceImpl.saveList(scheduleModel.getStScheduleParamList());

        scheduleModel.getStScheduleModelUserParamList().forEach(item -> {
            item.setModelid(stScheduleModelEntity.getId());
        });
        stScheduleModelUserParamServiceImpl.saveList(scheduleModel.getStScheduleModelUserParamList());
        return stScheduleModelDao.selectList(null);
    }

    @Override
    public StScheduleModelDto getDetailById(String id) {
        StScheduleModelDto scheduleMode = new StScheduleModelDto();
        StScheduleModelEntity stScheduleModelEntity = baseDao.selectById(id);
        BeanUtils.copyProperties(stScheduleModelEntity, scheduleMode);
        List<StScheduleParamSettingEntity> stScheduleParamSettingList = stScheduleParamSettingServiceImpl.getByModelid(stScheduleModelEntity.getId());
        scheduleMode.setStScheduleParamSettingList(stScheduleParamSettingList);
        List<StScheduleParamEntity> stScheduleParamList = stScheduleParamServiceImpl.getByModelid(stScheduleModelEntity.getId());
        scheduleMode.setStScheduleParamList(stScheduleParamList);
        List<StScheduleModelUserParamEntity> stScheduleModelUserParamList = stScheduleModelUserParamServiceImpl.getByModelid(stScheduleModelEntity.getId());
        scheduleMode.setStScheduleModelUserParamList(stScheduleModelUserParamList);
        return scheduleMode;
    @DSTransactional(rollbackFor = Exception.class)
    public void create(StScheduleModelSaveReqVO reqVO) {
        StScheduleModelEntity entity = BeanUtils.toBean(reqVO, StScheduleModelEntity.class);
        entity.setId(UUID.randomUUID().toString());
        stScheduleModelDao.insert(entity);
        stScheduleModelParamService.saveList(entity.getId(), reqVO.getParamList());
        stScheduleModelOutService.insertList(reqVO.getModelOut(), entity.getId());
        stScheduleModelSettingService.saveList(entity.getId(), reqVO.getSettingList());
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void update(StScheduleModelDto scheduleModel) {
        StScheduleModelEntity stScheduleModelEntity = new StScheduleModelEntity();
        BeanUtils.copyProperties(scheduleModel, stScheduleModelEntity);
        baseDao.updateById(stScheduleModelEntity);

        scheduleModel.getStScheduleParamSettingList().forEach(item -> {
            item.setModelid(stScheduleModelEntity.getId());
        });
        stScheduleParamSettingServiceImpl.saveList(scheduleModel.getStScheduleParamSettingList());

        scheduleModel.getStScheduleParamList().forEach(item -> {
            item.setModelid(stScheduleModelEntity.getId());
        });
        stScheduleParamServiceImpl.saveList(scheduleModel.getStScheduleParamList());

        scheduleModel.getStScheduleModelUserParamList().forEach(item -> {
            item.setModelid(stScheduleModelEntity.getId());
        });
        stScheduleModelUserParamServiceImpl.saveList(scheduleModel.getStScheduleModelUserParamList());
    @DSTransactional(rollbackFor = Exception.class)
    public void update(StScheduleModelSaveReqVO reqVO) {
        StScheduleModelEntity entity = BeanUtils.toBean(reqVO, StScheduleModelEntity.class);
        stScheduleModelDao.updateById(entity);
        stScheduleModelParamService.saveList(entity.getId(), reqVO.getParamList());
        stScheduleModelSettingService.saveList(entity.getId(), reqVO.getSettingList());
        stScheduleModelOutService.deleteScheduleModelOut(entity.getId());
        stScheduleModelOutService.insertList(reqVO.getModelOut(), entity.getId());
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteBatch(String[] scheduleModelIds) {
        baseDao.deleteBatchIds(Arrays.asList(scheduleModelIds));
        stScheduleParamSettingServiceImpl.deleteBatch(scheduleModelIds);
        stScheduleParamServiceImpl.deleteBatch(scheduleModelIds);
        stScheduleModelUserParamServiceImpl.deleteBatch(scheduleModelIds);
    public StScheduleModelEntity get(String id) {
        return stScheduleModelDao.selectById(id);
    }

    @Override
    public int check(StScheduleModelEntity scheduleModel) {
        String id = scheduleModel.getId();
        String modelname = scheduleModel.getModelname();
    @DSTransactional(rollbackFor = Exception.class)
    public void delete(String id) {
        stScheduleModelDao.deleteById(id);
        stScheduleModelParamService.deleteByModelId(id);
        stScheduleModelSettingService.deleteByModelId(id);
        stScheduleModelOutService.deleteScheduleModelOut(id);
    }

    @Override
    public Long check(StScheduleModelSaveReqVO reqVO) {
        String id = reqVO.getId();
        String modelname = reqVO.getModelName();
        QueryWrapper<StScheduleModelEntity> scheduleModelWrapper = new QueryWrapper<>();
        scheduleModelWrapper.ne(StringUtils.isNotBlank(id), "id", id);
        scheduleModelWrapper.and(wrapper -> wrapper.eq("modelname", modelname));

        List<StScheduleModelEntity> list = baseDao.selectList(scheduleModelWrapper);
        return list.size();
        scheduleModelWrapper.and(wrapper -> wrapper.eq("model_name", modelname));
        return stScheduleModelDao.selectCount(scheduleModelWrapper);
    }

    @Override
    public Long count() {
        QueryWrapper<StScheduleModelEntity> wrapper = new QueryWrapper<>();
        return baseDao.selectCount(wrapper);
        return stScheduleModelDao.selectCount(wrapper);
    }
}