package com.ruoyi.web.controller.api;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.ruoyi.common.core.domain.BaseModel;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.common.core.domain.model.LoginUser;
|
import com.ruoyi.system.dto.TConfirmBreedingAndPreservationDTO;
|
import com.ruoyi.system.model.*;
|
|
import java.util.List;
|
|
|
import com.alibaba.fastjson.JSON;
|
import com.ruoyi.common.annotation.Log;
|
import com.ruoyi.common.basic.PageInfo;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.enums.BusinessType;
|
import com.ruoyi.framework.web.service.TokenService;
|
import com.ruoyi.system.dto.TBreedingAndPreservationDTO;
|
import com.ruoyi.system.dto.TTrainLibraryDTO;
|
import com.ruoyi.system.query.TBreedingAndPreservationQuery;
|
import com.ruoyi.system.query.TPedigreeChartConfirmQuery;
|
import com.ruoyi.system.query.TPedigreeChartQuery;
|
import com.ruoyi.system.service.*;
|
import com.ruoyi.system.vo.TBreedingAndPreservationDetailVO;
|
import com.ruoyi.system.vo.TBreedingAndPreservationVO;
|
import com.ruoyi.system.vo.TPedigreeChartVO;
|
import com.ruoyi.system.vo.TProjectTeamVO;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.util.Random;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 菌种选育保藏记录 前端控制器
|
* </p>
|
*
|
* @author 无关风月
|
* @since 2025-04-12
|
*/
|
@RestController
|
@RequestMapping("")
|
@Api(tags = "菌种选育保藏记录")
|
public class TBreedingAndPreservationController {
|
@Resource
|
private TBreedingAndPreservationService breedingAndPreservationService;
|
@Resource
|
private TCulturePreservationService culturePreservationService;
|
@Resource
|
private TObservationOfPetriDishesService observationOfPetriDishesService;
|
@Resource
|
private TVaccinationSlopeService vaccinationSlopeService;
|
@Resource
|
private TSeparationOfCultureDishesService separationOfCultureDishesService;
|
@Resource
|
private TokenService tokenService;
|
@Resource
|
private ISysUserService sysUserService;
|
|
/**
|
* 菌种选育保藏记录分页列表
|
*/
|
//@PreAuthorize("@ss.hasPermi('system:breedingAndPreservation:list')")
|
@ApiOperation(value = "菌种选育保藏记录-获取菌种选育保藏记录分页列表",response = TBreedingAndPreservationQuery.class)
|
@PostMapping(value = "/api/t-breeding-and-preservation/pageList")
|
public R<PageInfo<TBreedingAndPreservationVO>> pageList(@RequestBody String param) {
|
|
TBreedingAndPreservationQuery query = JSON.parseObject(param, TBreedingAndPreservationQuery.class);
|
SysUser sysUser = sysUserService.selectUserById(tokenService.getLoginUser().getUserId());
|
if (sysUser.getRoleType().equals("2")){
|
List<String> allProjectIds = projectTeamStaffService.lambdaQuery().eq(TProjectTeamStaff::getUserId, tokenService.getLoginUser().getUserId())
|
.list().stream().map(TProjectTeamStaff::getTeamId).collect(Collectors.toList());
|
if (!allProjectIds.isEmpty()){ List<String> projectIds = projectTeamService.lambdaQuery().in(TProjectTeam::getId, allProjectIds)
|
.list().stream().map(TProjectTeam::getId).collect(Collectors.toList());
|
|
if (projectIds.isEmpty()){
|
return R.ok(new PageInfo<>());
|
}
|
query.setProjectIds(projectIds);
|
}else {
|
return R.ok(new PageInfo<>());
|
}
|
}else if (!sysUser.getRoleType().equals("1")){
|
List<String> allProjectIds = projectTeamStaffService.lambdaQuery().eq(TProjectTeamStaff::getUserId, tokenService.getLoginUser().getUserId())
|
.list().stream().map(TProjectTeamStaff::getTeamId).collect(Collectors.toList());
|
if (!allProjectIds.isEmpty()){
|
List<String> projectIds = projectTeamService.lambdaQuery().in(TProjectTeam::getId, allProjectIds)
|
.eq(TProjectTeam::getStatus, 1).list().stream().map(TProjectTeam::getId).collect(Collectors.toList());
|
|
if (projectIds.isEmpty()){
|
return R.ok(new PageInfo<>());
|
}
|
query.setProjectIds(projectIds);
|
}else {
|
return R.ok(new PageInfo<>());
|
}
|
}
|
|
return R.ok(breedingAndPreservationService.pageList(query));
|
}
|
/**
|
* 新增菌种库
|
*/
|
//@PreAuthorize("@ss.hasPermi('system:breedingAndPreservation:add')")
|
@Log(title = "菌种选育保藏记录-新增选育保藏记录", businessType = BusinessType.INSERT)
|
@ApiOperation(value = "菌种选育保藏记录-新增选育保藏记录",response = TBreedingAndPreservationDTO.class)
|
@PostMapping(value = "/api/t-breeding-and-preservation/add")
|
public R<Boolean> add(@RequestBody String param) {
|
if (tokenService.getLoginUser()==null){
|
return R.fail(401,"登陆失效");
|
}
|
TBreedingAndPreservationDTO dto = JSON.parseObject(param,TBreedingAndPreservationDTO.class);
|
if (dto.getStatus()==1){
|
return R.fail("有菌种待确认,无法提交");
|
}
|
|
if (dto.getStatus()==3){
|
dto.setIsDraft(1);
|
}
|
List<String> projectIds = projectTeamStaffService.lambdaQuery().eq(TProjectTeamStaff::getUserId, tokenService.getLoginUser().getUserId())
|
.list().stream().map(TProjectTeamStaff::getTeamId).collect(Collectors.toList());
|
if (!projectIds.isEmpty()){
|
TProjectTeam projectTeam = projectTeamService.lambdaQuery().in(TProjectTeam::getId, projectIds)
|
.eq(TProjectTeam::getStatus, 1)
|
.orderByDesc(BaseModel::getCreateTime)
|
.last("limit 1").one();
|
dto.setProjectId(projectTeam.getId());
|
}
|
breedingAndPreservationService.save(dto);
|
List<TSeparationOfCultureDishes> separationOfCultureDishesList = dto.getSeparationOfCultureDishesList();
|
for (TSeparationOfCultureDishes tSeparationOfCultureDishes : separationOfCultureDishesList) {
|
tSeparationOfCultureDishes.setBreedingPreserveId(dto.getId());
|
}
|
separationOfCultureDishesService.saveBatch(separationOfCultureDishesList);
|
List<TObservationOfPetriDishes> observationOfPetriDishes = dto.getObservationOfPetriDishes();
|
for (TObservationOfPetriDishes tSeparationOfCultureDishes : observationOfPetriDishes) {
|
tSeparationOfCultureDishes.setBreedingPreserveId(dto.getId());
|
}
|
observationOfPetriDishesService.saveBatch(observationOfPetriDishes);
|
List<TVaccinationSlope> vaccinationSlopes = dto.getVaccinationSlopes();
|
for (TVaccinationSlope tSeparationOfCultureDishes : vaccinationSlopes) {
|
tSeparationOfCultureDishes.setHandleId(tokenService.getLoginUser().getUserId()+"");
|
tSeparationOfCultureDishes.setHandleTime(LocalDateTime.now());
|
tSeparationOfCultureDishes.setBreedingPreserveId(dto.getId());
|
}
|
vaccinationSlopeService.saveBatch(vaccinationSlopes);
|
List<TCulturePreservation> culturePreservations = dto.getCulturePreservations();
|
for (TCulturePreservation tSeparationOfCultureDishes : culturePreservations) {
|
tSeparationOfCultureDishes.setHandleId(tokenService.getLoginUser().getUserId()+"");
|
tSeparationOfCultureDishes.setHandleTime(LocalDateTime.now());
|
tSeparationOfCultureDishes.setBreedingPreserveId(dto.getId());
|
}
|
culturePreservationService.saveBatch(culturePreservations);
|
if (dto.getStatus()!=null&&dto.getStatus()==2){
|
// 新增消息
|
TNotice tNotice = new TNotice();
|
List<String> allProjectIds = projectTeamStaffService.lambdaQuery()
|
.eq(TProjectTeamStaff::getTeamId,dto.getProjectId())
|
.eq(TProjectTeamStaff::getRoleType, 2)
|
.list().stream().map(TProjectTeamStaff::getTeamId).collect(Collectors.toList());
|
if (!allProjectIds.isEmpty()){
|
TProjectTeam projectTeam = projectTeamService.lambdaQuery().in(TProjectTeam::getId, allProjectIds)
|
.eq(TProjectTeam::getStatus, 1)
|
.orderByDesc(BaseModel::getCreateTime).last("limit 1").one();
|
TProjectTeamStaff projectTeamStaff = projectTeamStaffService.lambdaQuery()
|
.eq(TProjectTeamStaff::getTeamId, projectTeam.getId()).eq(TProjectTeamStaff::getRoleType, 2).one();
|
tNotice.setUserId(projectTeamStaff.getUserId());
|
|
tNotice.setCommitId(tokenService.getLoginUser().getUserId()+"");
|
tNotice.setStatus(1);
|
tNotice.setNoticeContent("您有【1】条【菌种选育保藏记录】等待签字入库确认;");
|
tNotice.setDataId(dto.getId());
|
tNotice.setNoticeType(5);
|
noticeService.save(tNotice);
|
}
|
|
}
|
return R.ok();
|
}
|
@Resource
|
private TProjectTeamService projectTeamService;
|
@Resource
|
private TProjectTeamStaffService projectTeamStaffService;
|
@Resource
|
private TNoticeService noticeService;
|
@Log(title = "菌种选育保藏记录-编辑选育保藏记录", businessType = BusinessType.UPDATE)
|
@ApiOperation(value = "菌种选育保藏记录-编辑选育保藏记录",response = TBreedingAndPreservationDTO.class)
|
@PostMapping(value = "/api/t-breeding-and-preservation/update")
|
public R<Boolean> update(@RequestBody String param) {
|
if (tokenService.getLoginUser()==null){
|
return R.fail(401,"登陆失效");
|
}
|
TBreedingAndPreservationDTO dto = JSON.parseObject(param,TBreedingAndPreservationDTO.class);
|
if (dto.getStatus()==3){
|
dto.setIsDraft(1);
|
}else{
|
dto.setIsDraft(0);
|
}
|
TBreedingAndPreservation breedingAndPreservationServiceById = breedingAndPreservationService.getById(dto.getId());
|
if (breedingAndPreservationServiceById.getStatus()==1){
|
return R.fail("该记录已提交，不可编辑！");
|
}
|
breedingAndPreservationService.updateById(dto);
|
List<TSeparationOfCultureDishes> separationOfCultureDishesList = dto.getSeparationOfCultureDishesList();
|
for (TSeparationOfCultureDishes tSeparationOfCultureDishes : separationOfCultureDishesList) {
|
tSeparationOfCultureDishes.setBreedingPreserveId(dto.getId());
|
}
|
separationOfCultureDishesService.remove(new LambdaQueryWrapper<TSeparationOfCultureDishes>().eq(TSeparationOfCultureDishes::getBreedingPreserveId, dto.getId()));
|
separationOfCultureDishesService.saveBatch(separationOfCultureDishesList);
|
List<TObservationOfPetriDishes> observationOfPetriDishes = dto.getObservationOfPetriDishes();
|
for (TObservationOfPetriDishes observationOfPetriDish : observationOfPetriDishes) {
|
observationOfPetriDish.setBreedingPreserveId(dto.getId());
|
}
|
observationOfPetriDishesService.remove(new LambdaQueryWrapper<TObservationOfPetriDishes>().eq(TObservationOfPetriDishes::getBreedingPreserveId, dto.getId()));
|
observationOfPetriDishesService.saveBatch(observationOfPetriDishes);
|
List<TVaccinationSlope> vaccinationSlopes = dto.getVaccinationSlopes();
|
for (TVaccinationSlope vaccinationSlope : vaccinationSlopes) {
|
if (dto.getStatus()==1&&!StringUtils.hasLength(vaccinationSlope.getPreserveId())){
|
return R.fail("接种斜面记录未确认，不能提交");
|
}
|
vaccinationSlope.setBreedingPreserveId(dto.getId());
|
}
|
vaccinationSlopeService.remove(new LambdaQueryWrapper<TVaccinationSlope>().eq(TVaccinationSlope::getBreedingPreserveId, dto.getId()));
|
vaccinationSlopeService.saveBatch(vaccinationSlopes);
|
List<TCulturePreservation> culturePreservations = dto.getCulturePreservations();
|
for (TCulturePreservation tSeparationOfCultureDishes : culturePreservations) {
|
|
tSeparationOfCultureDishes.setBreedingPreserveId(dto.getId());
|
}
|
culturePreservationService.remove(new LambdaQueryWrapper<TCulturePreservation>().eq(TCulturePreservation::getBreedingPreserveId, dto.getId()));
|
for (TCulturePreservation culturePreservation : culturePreservations) {
|
if (dto.getStatus()==1&&!StringUtils.hasLength(culturePreservation.getPreserveId())){
|
return R.fail("菌种保藏记录未确认，不能提交");
|
}
|
culturePreservation.setBreedingPreserveId(dto.getId());
|
}
|
culturePreservationService.saveBatch(culturePreservations);
|
if (dto.getStatus()==2){
|
// 新增消息
|
TNotice tNotice = new TNotice();
|
List<String> allProjectIds = projectTeamStaffService.lambdaQuery().eq(TProjectTeamStaff::getUserId, tokenService.getLoginUser().getUserId())
|
.eq(TProjectTeamStaff::getRoleType, 3)
|
.list().stream().map(TProjectTeamStaff::getTeamId).collect(Collectors.toList());
|
if (!allProjectIds.isEmpty()){
|
TProjectTeam projectTeam = projectTeamService.lambdaQuery().in(TProjectTeam::getId, allProjectIds)
|
.eq(TProjectTeam::getStatus, 1)
|
.orderByDesc(BaseModel::getCreateTime).last("limit 1").one();
|
TProjectTeamStaff one1 = projectTeamStaffService.lambdaQuery()
|
.eq(TProjectTeamStaff::getTeamId, projectTeam.getId()).eq(TProjectTeamStaff::getRoleType, 2).one();
|
tNotice.setUserId(one1.getUserId());
|
|
tNotice.setCommitId(tokenService.getLoginUser().getUserId()+"");
|
tNotice.setStatus(1);
|
tNotice.setNoticeContent("您有【1】条【菌种选育保藏记录】等待签字入库确认;");
|
tNotice.setDataId(dto.getId());
|
tNotice.setNoticeType(6);
|
noticeService.save(tNotice);
|
}
|
}
|
return R.ok();
|
}
|
@Log(title = "接种斜面记录确认入库", businessType = BusinessType.UPDATE)
|
@ApiOperation(value = "接种斜面记录确认入库",response = TConfirmBreedingAndPreservationDTO.class)
|
@PostMapping(value = "/api/t-breeding-and-preservation/vaccinationSlopesConfirm")
|
public R<Boolean> vaccinationSlopesConfirm(@RequestBody String param) {
|
Long userId = tokenService.getLoginUser().getUserId();
|
|
TConfirmBreedingAndPreservationDTO dto = JSON.parseObject(param,TConfirmBreedingAndPreservationDTO.class);
|
TVaccinationSlope vaccinationSlope = vaccinationSlopeService.getById(dto.getId());
|
vaccinationSlope.setPreserveId(userId+"");
|
vaccinationSlope.setPreserveTime(LocalDateTime.now());
|
vaccinationSlope.setPreserveSignature(dto.getPreserveSignature());
|
vaccinationSlopeService.updateById(vaccinationSlope);
|
return R.ok();
|
}
|
@Log(title = "菌种保藏记录确认入库", businessType = BusinessType.UPDATE)
|
@ApiOperation(value = "菌种保藏记录确认入库",response = TConfirmBreedingAndPreservationDTO.class)
|
@PostMapping(value = "/api/t-breeding-and-preservation/culturePreservationsConfirm")
|
public R<Boolean> culturePreservationsConfirm(@RequestBody String param) {
|
Long userId = tokenService.getLoginUser().getUserId();
|
TConfirmBreedingAndPreservationDTO dto = JSON.parseObject(param,TConfirmBreedingAndPreservationDTO.class);
|
TCulturePreservation culturePreservation = culturePreservationService.getById(dto.getId());
|
culturePreservation.setPreserveId(userId+"");
|
culturePreservation.setPreserveTime(LocalDateTime.now());
|
culturePreservation.setPreserveSignature(dto.getPreserveSignature());
|
culturePreservationService.updateById(culturePreservation);
|
return R.ok();
|
}
|
//@PreAuthorize("@ss.hasPermi('system:breedingAndPreservation:detail')")
|
@ApiOperation(value = "选育保藏记录详情")
|
@GetMapping(value = "/open/t-breeding-and-preservation/getDetailById")
|
public R<TBreedingAndPreservationDetailVO> getDetailById(@RequestParam String id) {
|
List<SysUser> sysUsers = sysUserService.selectAllList();
|
TBreedingAndPreservationDetailVO res = new TBreedingAndPreservationDetailVO();
|
TBreedingAndPreservation breedingAndPreservation = breedingAndPreservationService.getById(id);
|
BeanUtils.copyProperties(breedingAndPreservation, res);
|
List<TSeparationOfCultureDishes> separationOfCultureDishesList = separationOfCultureDishesService.lambdaQuery().eq(TSeparationOfCultureDishes::getBreedingPreserveId, id).list();
|
List<TObservationOfPetriDishes> observationOfPetriDishes = observationOfPetriDishesService.lambdaQuery().eq(TObservationOfPetriDishes::getBreedingPreserveId, id).list();
|
List<TVaccinationSlope> vaccinationSlopes = vaccinationSlopeService.lambdaQuery().eq(TVaccinationSlope::getBreedingPreserveId, id).list();
|
List<TCulturePreservation> culturePreservations = culturePreservationService.lambdaQuery().eq(TCulturePreservation::getBreedingPreserveId, id).list();
|
for (TCulturePreservation culturePreservation : culturePreservations) {
|
SysUser sysUser = sysUsers.stream().filter(e -> e.getUserId().equals(Long.valueOf(culturePreservation.getHandleId()))).findFirst()
|
.orElse(null);
|
if (sysUser!=null){
|
culturePreservation.setHandleName(sysUser.getNickName());
|
}
|
}
|
for (TVaccinationSlope vaccinationSlope : vaccinationSlopes) {
|
SysUser sysUser = sysUsers.stream().filter(e -> e.getUserId().equals(Long.valueOf(vaccinationSlope.getHandleId()))).findFirst()
|
.orElse(null);
|
if (sysUser!=null){
|
vaccinationSlope.setHandleName(sysUser.getNickName());
|
}
|
}
|
res.setSeparationOfCultureDishesList(separationOfCultureDishesList);
|
res.setObservationOfPetriDishes(observationOfPetriDishes);
|
res.setVaccinationSlopes(vaccinationSlopes);
|
res.setCulturePreservations(culturePreservations);
|
return R.ok(res);
|
}
|
//
|
// @Log(title = "培养皿分离记录删除", businessType = BusinessType.DELETE)
|
// @ApiOperation(value = "培养皿分离记录删除")
|
// @DeleteMapping(value = "/open/t_project_team/deleteSeparationOfCultureDishes")
|
// public R<Boolean> deleteSeparationOfCultureDishes(@RequestParam String id) {
|
// return R.ok(separationOfCultureDishesService.removeById(id));
|
// }
|
// @Log(title = "培养皿生物学形态观察记录", businessType = BusinessType.DELETE)
|
// @ApiOperation(value = "培养皿生物学形态观察记录删除")
|
// @DeleteMapping(value = "/open/t_project_team/deleteObservationOfPetriDishes")
|
// public R<Boolean> deleteObservationOfPetriDishes(@RequestParam String id) {
|
//
|
// return R.ok(observationOfPetriDishesService.removeById(id));
|
// }
|
// @Log(title = "接种斜面记录删除", businessType = BusinessType.DELETE)
|
// @ApiOperation(value = "接种斜面记录删除")
|
// @DeleteMapping(value = "/open/t_project_team/deleteVaccinationSlope")
|
// public R<Boolean> deleteVaccinationSlope(@RequestParam String id) {
|
// TVaccinationSlope byId = vaccinationSlopeService.getById(id);
|
// if (byId.getPreserveSignature()!=null){
|
// return R.fail("菌种保藏人签字确认之后，不可删除");
|
// }
|
// return R.ok(vaccinationSlopeService.removeById(id));
|
// }
|
// @Log(title = "菌种保藏记录删除", businessType = BusinessType.DELETE)
|
// @ApiOperation(value = "菌种保藏记录删除")
|
// @DeleteMapping(value = "/open/t_project_team/deleteCulturePreservation")
|
// public R<Boolean> deleteCulturePreservation(@RequestParam String id) {
|
// TCulturePreservation byId = culturePreservationService.getById(id);
|
// if (byId.getPreserveSignature()!=null){
|
// return R.fail("菌种保藏人签字确认之后，不可删除");
|
// }
|
// return R.ok(culturePreservationService.removeById(id));
|
// }
|
@Log(title = "菌种保藏记录删除", businessType = BusinessType.DELETE)
|
@ApiOperation(value = "菌种保藏记录删除")
|
@DeleteMapping(value = "/open/t_project_team/deleteBreedingAndPreservation")
|
public R<Boolean> deleteCulturePreservation(@RequestParam String id) {
|
return R.ok(breedingAndPreservationService.removeById(id));
|
}
|
}
|
