package com.qianwen.smartman.modules.cps.controller;
|
|
import java.util.List;
|
import java.util.Optional;
|
import java.util.stream.Collectors;
|
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.qianwen.core.boot.ctrl.BladeController;
|
import com.qianwen.core.mp.support.Condition;
|
import com.qianwen.core.mp.support.Query;
|
import com.qianwen.core.scanner.modular.annotation.DeleteResource;
|
import com.qianwen.core.scanner.modular.annotation.GetResource;
|
import com.qianwen.core.scanner.modular.annotation.PostResource;
|
import com.qianwen.core.scanner.modular.annotation.PutResource;
|
import com.qianwen.core.scanner.modular.stereotype.ApiResource;
|
import com.qianwen.core.secure.annotation.PreAuth;
|
import com.qianwen.core.secure.utils.AuthUtil;
|
import com.qianwen.core.tool.api.R;
|
import com.qianwen.core.tool.api.ResultCode;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.cps.convert.ShiftConvert;
|
import com.qianwen.smartman.modules.cps.entity.ShiftModel;
|
import com.qianwen.smartman.modules.cps.service.IShiftModelService;
|
import com.qianwen.smartman.modules.cps.vo.ShiftIndexNameVO;
|
import com.qianwen.smartman.modules.cps.vo.ShiftModelSearchVO;
|
import com.qianwen.smartman.modules.cps.vo.ShiftModelVO;
|
import com.qianwen.smartman.modules.cps.vo.ShiftSaveVO;
|
import com.qianwen.smartman.modules.cps.vo.ShiftSimpleVO;
|
import com.qianwen.smartman.modules.cps.vo.ShiftUpdateBasicVO;
|
import com.qianwen.smartman.modules.cps.vo.ShiftUpdateVO;
|
import com.qianwen.smartman.modules.cps.vo.ShiftVO;
|
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
|
@ApiResource({"smis/shift"})
|
@Api(value = "班次", tags = {"班次"})
|
@RestController
|
public class ShiftController extends BladeController {
|
private final IShiftModelService shiftModelService;
|
|
|
public ShiftController(IShiftModelService shiftModelService) {
|
this.shiftModelService = shiftModelService;
|
}
|
|
@PreAuth
|
@PostResource
|
@ApiOperation("新建班次模型")
|
public R<ShiftModelVO> saveShift(@Validated @RequestBody ShiftSaveVO shiftSaveVO) {
|
return R.data(ShiftConvert.INSTANCE.convert(this.shiftModelService.saveShift(shiftSaveVO)));
|
}
|
|
@PreAuth
|
@PutResource
|
@ApiOperation("编辑班次模型")
|
public R<ShiftModelVO> updateShift(@Validated @RequestBody ShiftUpdateVO shiftUpdateVO) {
|
return R.data(ShiftConvert.INSTANCE.convert(this.shiftModelService.update(shiftUpdateVO)));
|
}
|
|
@PreAuth
|
@PutResource({"/updateBasic"})
|
@ApiOperation("编辑班次模型基础信息")
|
public R<ShiftModelVO> updateShiftBasic(@RequestBody ShiftUpdateBasicVO shiftUpdateBasicVO) {
|
return R.data(ShiftConvert.INSTANCE.convert(this.shiftModelService.updateShiftBasic(shiftUpdateBasicVO)));
|
}
|
|
@PreAuth
|
@DeleteResource({"/{id}"})
|
@ApiOperation("删除班次模型")
|
public R<Void> deleteShift(@PathVariable String id) {
|
this.shiftModelService.deleteShift(id);
|
return R.success(ResultCode.SUCCESS);
|
}
|
|
@PreAuth
|
@PostResource({"/page"})
|
@ApiOperation(value = "分页查询班次模型", notes = "传入分页条件")
|
public R<IPage<ShiftSimpleVO>> getPageShift(Query query, @Validated @RequestBody ShiftModelSearchVO shiftModelSearchVO) {
|
//return
|
return Optional.<IPage<ShiftModel>>ofNullable(this.shiftModelService.page(Condition.getPage(query), Wrappers.<ShiftModel>query().lambda()
|
.in(ShiftModel::getStatus, shiftModelSearchVO.getStatusList())
|
.eq(ShiftModel::getTenantId, AuthUtil.getTenantId())
|
.like(Func.isNotEmpty(shiftModelSearchVO.getCode()), ShiftModel::getCode, shiftModelSearchVO.getCode())
|
.like(Func.isNotEmpty(shiftModelSearchVO.getName()), ShiftModel::getName, shiftModelSearchVO.getName())
|
.orderByDesc(ShiftModel::getCreateTime)))
|
.map(iPage -> {
|
List<ShiftSimpleVO> list = iPage.getRecords().stream().map(ShiftConvert.INSTANCE::convertSimple).collect(Collectors.toList());
|
IPage<ShiftSimpleVO> page = new Page<>();
|
BeanUtils.copyProperties(iPage, page);
|
page.setRecords(list);
|
return R.data(page);
|
}).orElse(R.data(new Page<>()));
|
/*
|
return (R) Optional.ofNullable(this.shiftModelService.page(Condition.getPage(query), (Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().in((v0) -> {
|
return v0.getStatus();
|
}, shiftModelSearchVO.getStatusList())).eq((v0) -> {
|
return v0.getTenantId();
|
}, AuthUtil.getTenantId())).like(Func.isNotEmpty(shiftModelSearchVO.getCode()), (v0) -> {
|
return v0.getCode();
|
}, shiftModelSearchVO.getCode()).like(Func.isNotEmpty(shiftModelSearchVO.getName()), (v0) -> {
|
return v0.getName();
|
}, shiftModelSearchVO.getName()).orderByDesc((v0) -> {
|
return v0.getCreateTime();
|
}))).map(iPage -> {
|
Stream stream = iPage.getRecords().stream();
|
ShiftConvert shiftConvert = ShiftConvert.INSTANCE;
|
shiftConvert.getClass();
|
List<ShiftSimpleVO> list = (List) stream.map(this::convertSimple).collect(Collectors.toList());
|
Page page = new Page();
|
BeanUtils.copyProperties(iPage, page);
|
page.setRecords(list);
|
return R.data(page);
|
}).orElse(R.data(new Page()));
|
*/
|
}
|
|
@PreAuth
|
@PostResource({"/list"})
|
@ApiOperation(value = "班次模型列表", notes = "班次模型列表")
|
public R<List<ShiftSimpleVO>> getShiftList(@Validated @RequestBody ShiftModelSearchVO shiftModelSearchVO) {
|
return R.data(this.shiftModelService.list(new QueryWrapper<ShiftModel>().lambda()
|
.in(ShiftModel::getStatus, shiftModelSearchVO.getStatusList())
|
.eq(ShiftModel::getTenantId, AuthUtil.getTenantId()))
|
.stream()
|
.map(ShiftConvert.INSTANCE::convertSimple)
|
.collect(Collectors.toList()));
|
/*
|
Stream stream = this.shiftModelService.list((Wrapper) ((LambdaQueryWrapper) new QueryWrapper().lambda().in((v0) -> {
|
return v0.getStatus();
|
}, shiftModelSearchVO.getStatusList())).eq((v0) -> {
|
return v0.getTenantId();
|
}, AuthUtil.getTenantId())).stream();
|
ShiftConvert shiftConvert = ShiftConvert.INSTANCE;
|
shiftConvert.getClass();
|
return R.data(stream.map(this::convertSimple).collect(Collectors.toList()));
|
*/
|
}
|
|
@PreAuth
|
@GetResource({"/{id}"})
|
@ApiOperation(value = "查询班次详情", notes = "传入id")
|
public R<ShiftVO> getShiftDetail(@PathVariable String id) {
|
return R.data(this.shiftModelService.getShiftDetail(Long.valueOf(id)));
|
}
|
|
@GetResource({"/shiftIndex/{id}"})
|
@ApiOperation(value = "查询班次index详情", notes = "传入id")
|
public R<List<Integer>> getShiftIndex(@PathVariable String id) {
|
return R.data(this.shiftModelService.getShiftIndex(Long.valueOf(id)));
|
}
|
|
@GetResource({"/indexNames"})
|
@ApiOperation(value = "查询租户下所有班次模型对应名称", notes = "查询租户下所有班次模型对应名称")
|
public R<ShiftIndexNameVO> getShiftIndexName() {
|
return R.data(this.shiftModelService.getShiftIndexName());
|
}
|
}
|
