package org.springblade.mdm.program.service;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import lombok.AllArgsConstructor;
|
import org.springblade.core.mp.base.BizServiceImpl;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.oss.OssTemplate;
|
import org.springblade.core.tool.utils.DateUtil;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.mdm.flow.service.CureFlowService;
|
import org.springblade.mdm.program.entity.DncBackFile;
|
import org.springblade.mdm.program.entity.NcProgram;
|
import org.springblade.mdm.program.mapper.DncBackFileMapper;
|
import org.springblade.mdm.program.vo.DncBackFileQueryVO;
|
import org.springblade.mdm.program.vo.DncBackFileVO;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
@AllArgsConstructor
|
@Service
|
public class DncBackFileService extends BizServiceImpl<DncBackFileMapper, DncBackFile> {
|
private final NcProgramService progService;
|
private final OssTemplate ossTemplate;
|
|
private final CureFlowService cureFlowService;
|
/**
|
* 接受
|
* @param ids
|
*/
|
public void accept(String ids) {
|
|
List<Long> idList = Func.toLongList(ids);
|
|
for(Long id : idList){
|
DncBackFile backFile = this.getById(id);
|
backFile.setStatus(DncBackFile.STATUS_ACCEPTED);
|
backFile.setConfirmTime(DateUtil.now());
|
this.updateById(backFile);
|
|
//新建一个程序，将老的程序isLastEditon设置未0，然后启动流程
|
this.upgradeProgramAndStartCure(backFile.getNcProgramId(),backFile);
|
}
|
}
|
|
void upgradeProgramAndStartCure(long ncProgramId,DncBackFile backFile) {
|
NcProgram oldProgram = this.progService.getById(ncProgramId);
|
//更新文件信息
|
oldProgram.setOssName(backFile.getOssName());
|
oldProgram.setUrl(backFile.getUrl());
|
//TODO，是否删除原来的文件？
|
progService.updateById(oldProgram);
|
/*
|
NcProgram newProgram = new NcProgram();
|
BeanUtils.copyProperties(oldProgram,newProgram);
|
|
oldProgram.setIsLastEdition(0);
|
progService.updateById(oldProgram);
|
|
newProgram.setId(null);
|
newProgram.setIsLastEdition(1);
|
progService.updateById(newProgram);
|
|
*/
|
|
cureFlowService.startOne(oldProgram);//启动一个程序的固化流程
|
}
|
|
/**
|
* 拒绝
|
* @param ids
|
*/
|
public void reject(String ids) {
|
List<Long> idList = Func.toLongList(ids);
|
|
for(Long id : idList){
|
DncBackFile backFile = this.getById(id);
|
backFile.setStatus(DncBackFile.STATUS_REJECTED);
|
backFile.setConfirmTime(DateUtil.now());
|
this.ossTemplate.removeFile(backFile.getOssName());
|
this.updateById(backFile);
|
}
|
|
}
|
|
/**
|
* DNC回传程序处理分页查询
|
* @param query 查询参数
|
* @return 分页数据
|
*/
|
public IPage<DncBackFileVO> pageQuery(DncBackFileQueryVO query) {
|
/*
|
IPage<DncBackFileVO> page = this.getBaseMapper().pageQuery(Condition.getPage(query),query);
|
*/
|
return this.getBaseMapper().pageQuery(Condition.getPage(query),query);
|
}
|
|
}
|
