package com.qianwen.smartman.modules.system.service.impl; import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.qianwen.core.log.exception.ServiceException; import com.qianwen.core.secure.utils.AuthUtil; import com.qianwen.core.tool.utils.CollectionUtil; import com.qianwen.smartman.common.utils.MessageUtils; import com.qianwen.smartman.modules.system.constant.IsSystemConstant; import com.qianwen.smartman.modules.system.constant.StatusConstant; import com.qianwen.smartman.modules.system.convert.WorkbenchConvert; import com.qianwen.smartman.modules.system.entity.Workbench; import com.qianwen.smartman.modules.system.entity.WorkbenchCard; import com.qianwen.smartman.modules.system.entity.WorkbenchTemplate; import com.qianwen.smartman.modules.system.entity.WorkbenchTemplateCard; import com.qianwen.smartman.modules.system.mapper.WorkbenchMapper; import com.qianwen.smartman.modules.system.service.IWorkbenchCardService; import com.qianwen.smartman.modules.system.service.IWorkbenchService; import com.qianwen.smartman.modules.system.service.IWorkbenchTemplateCardService; import com.qianwen.smartman.modules.system.service.IWorkbenchTemplateService; import com.qianwen.smartman.modules.system.vo.WorkbenchVO; @Service /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/service/impl/WorkbenchServiceImpl.class */ public class WorkbenchServiceImpl extends ServiceImpl implements IWorkbenchService { @Autowired @Lazy private IWorkbenchCardService workbenchCardService; @Autowired private IWorkbenchTemplateService workbenchTemplateService; @Autowired private IWorkbenchTemplateCardService workbenchTemplateCardService; @Override // org.springblade.modules.system.service.IWorkbenchService public List listWorkbench(Integer status) { List list = list(Wrappers.query().lambda().eq(Workbench::getCreateUser, AuthUtil.getUserId()) .eq((status != null), Workbench::getStatus, status).orderByAsc(Arrays.asList(Workbench::getSort, Workbench::getCreateTime) )); /* List list = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getCreateUser(); }, AuthUtil.getUserId())).eq(status != null, (v0) -> { return v0.getStatus(); }, status).orderByAsc((v0) -> { return v0.getSort(); }, new SFunction[]{(v0) -> { return v0.getCreateTime(); }}));*/ List workbenchVOS = WorkbenchConvert.INSTANCE.convert(list); return workbenchVOS; } @Override // org.springblade.modules.system.service.IWorkbenchService public Workbench addWorkbench(String name) { Workbench result = getOne(Wrappers.query().lambda().eq(Workbench::getName, name).eq(Workbench::getCreateUser, AuthUtil.getUserId())); /* Workbench result = (Workbench) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getName(); }, name)).eq((v0) -> { return v0.getCreateUser(); }, AuthUtil.getUserId()));*/ if (result == null) { Workbench workbench = new Workbench(); workbench.setCreateUser(AuthUtil.getUserId()); workbench.setUserName(AuthUtil.getUserAccount()); workbench.setName(name); save(workbench); return workbench; } throw new ServiceException(MessageUtils.message("work.bench.name.already.exist", new Object[0])); } @Override // org.springblade.modules.system.service.IWorkbenchService public Boolean updateWorkbench(WorkbenchVO workbenchVO) { Long number = Long.valueOf(count(Wrappers.query().lambda() .ne(Workbench::getId, workbenchVO.getId()) .eq(Workbench::getName, workbenchVO.getName()) .eq(Workbench::getCreateUser, AuthUtil.getUserId()))); /* Long number = Long.valueOf(count((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().ne((v0) -> { return v0.getId(); }, workbenchVO.getId())).eq((v0) -> { return v0.getName(); }, workbenchVO.getName())).eq((v0) -> { return v0.getCreateUser(); }, AuthUtil.getUserId())));*/ if (number.compareTo((Long) 0L) == 0) { return Boolean.valueOf(update(Wrappers.update().lambda().eq(Workbench::getId, workbenchVO.getId()).set(Workbench::getName, workbenchVO.getName()))); /* return Boolean.valueOf(update((Wrapper) ((LambdaUpdateWrapper) Wrappers.update().lambda().eq((v0) -> { return v0.getId(); }, workbenchVO.getId())).set((v0) -> { return v0.getName(); }, workbenchVO.getName())));*/ } throw new ServiceException(MessageUtils.message("work.bench.name.already.exist", new Object[0])); } @Override // org.springblade.modules.system.service.IWorkbenchService public Boolean switchWorkbench(Long id, Integer status) { Long count = Long.valueOf(count(Wrappers.query().lambda() .eq(Workbench::getCreateUser, AuthUtil.getUserId()) .eq(Workbench::getStatus, StatusConstant.open))); /* Long count = Long.valueOf(count((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getCreateUser(); }, AuthUtil.getUserId())).eq((v0) -> { return v0.getStatus(); }, StatusConstant.open)));*/ if (count.longValue() <= 1 && status.intValue() == 0) { throw new ServiceException(MessageUtils.message("work.bench.at.least.one", new Object[0])); } return Boolean.valueOf(update(Wrappers.update().lambda().eq(Workbench::getId, id).set(Workbench::getStatus, status))); /* return Boolean.valueOf(update((Wrapper) ((LambdaUpdateWrapper) Wrappers.update().lambda().eq((v0) -> { return v0.getId(); }, id)).set((v0) -> { return v0.getStatus(); }, status)));*/ } @Override // org.springblade.modules.system.service.IWorkbenchService public Boolean deleteWorkbench(Long id) { Workbench bench = getOne(Wrappers.query().lambda().eq(Workbench::getId, id)); if (bench.getIsSystem().equals(IsSystemConstant.IsSystem)) { throw new ServiceException(MessageUtils.message("system.work.bench.can.not.delete", new Object[0])); } //.getIsSystem().equals(IsSystemConstant.IsSystem) /* if (((Workbench) getOne((Wrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getId(); }, id))).getIsSystem().equals(IsSystemConstant.IsSystem)) { throw new ServiceException(MessageUtils.message("system.work.bench.can.not.delete", new Object[0])); }*/ Long count = Long.valueOf(count(Wrappers.query().lambda().eq(Workbench::getCreateUser, AuthUtil.getUserId()))); /* Long count = Long.valueOf(count((Wrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getCreateUser(); }, AuthUtil.getUserId())));*/ if (count.longValue() <= 1) { throw new ServiceException(MessageUtils.message("work.bench.at.least.one", new Object[0])); } boolean resultWorkbench = remove(Wrappers.query().lambda().eq(Workbench::getId, id)); /* boolean resultWorkbench = remove((Wrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getId(); }, id));*/ this.workbenchCardService.remove(Wrappers.query().lambda().eq(WorkbenchCard::getWorkbenchId, id)); /* this.workbenchCardService.remove((Wrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getWorkbenchId(); }, id));*/ return Boolean.valueOf(resultWorkbench); } @Override // org.springblade.modules.system.service.IWorkbenchService public Boolean sortWorkbench(List workbenchVOS) { List workbenchs = WorkbenchConvert.INSTANCE.convertVOs(workbenchVOS); return Boolean.valueOf(saveOrUpdateBatch(workbenchs)); } @Override // org.springblade.modules.system.service.IWorkbenchService public Boolean initWorkbench(Long userId, String userName) { List workbenchTemplateList = this.workbenchTemplateService.list(); workbenchTemplateList.forEach(i -> { Workbench workbench = new Workbench(); workbench.setName(i.getName()); workbench.setUserName("系统创建"); workbench.setIsSystem(Integer.valueOf("1")); workbench.setCreateUser(userId); workbench.setSort(i.getSort()); List workbenchTemplateCardList = this.workbenchTemplateCardService.list(Wrappers.query().lambda() .eq(WorkbenchTemplateCard::getWorkbenchId, i.getId())); /* List workbenchTemplateCardList = this.workbenchTemplateCardService.list((Wrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getWorkbenchId(); }, i.getId()));*/ if (!CollectionUtil.isEmpty(workbenchTemplateCardList)) { save(workbench); List list = workbenchTemplateCardList.stream().map(bean -> { WorkbenchCard workbenchCard = new WorkbenchCard(); workbenchCard.setWorkbenchId(workbench.getId()); workbenchCard.setCardKey(bean.getCardKey()); workbenchCard.setCardWide(bean.getCardWide()); workbenchCard.setCardLength(bean.getCardLength()); workbenchCard.setApiResource(bean.getApiResource()); workbenchCard.setXCoordinate(bean.getXCoordinate()); workbenchCard.setYCoordinate(bean.getYCoordinate()); workbenchCard.setCreateUser(userId); return workbenchCard; }).collect(Collectors.toList()); this.workbenchCardService.saveBatch(list); } }); return true; } }