package com.qianwen.smartman.modules.cps.controller;
|
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.mp.support.Condition;
|
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.stereotype.ApiResource;
|
import com.qianwen.core.tenant.annotation.NonDS;
|
import com.qianwen.core.tool.api.R;
|
import com.qianwen.smartman.common.enums.GlobalWcsTypeEnum;
|
import com.qianwen.smartman.common.utils.Lambda;
|
import com.qianwen.smartman.common.utils.MessageUtils;
|
import com.qianwen.smartman.modules.cps.convert.GlobalWcsConvert;
|
import com.qianwen.smartman.modules.cps.entity.GlobalWcs;
|
import com.qianwen.smartman.modules.cps.service.IGlobalWcsService;
|
import com.qianwen.smartman.modules.cps.vo.GlobalWcsVO;
|
import com.qianwen.smartman.modules.cps.vo.WcsAchievementsUpdateVO;
|
import com.qianwen.smartman.modules.cps.vo.WcsAndAchievementsVO;
|
import com.qianwen.smartman.modules.mdc.entity.WorkstationFeedbackDetail;
|
import com.qianwen.smartman.modules.mdc.enums.FeedbackDetailStatus;
|
import com.qianwen.smartman.modules.mdc.service.IWorkstationFeedbackDetailService;
|
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import springfox.documentation.annotations.ApiIgnore;
|
|
@Api(value = "全局工况", tags = {"全局工况"})
|
@RestController
|
@ApiResource({"smis/global_wcs"})
|
@NonDS
|
public class GlobalWcsController {
|
private final IGlobalWcsService globalWcsService;
|
private final IWorkstationFeedbackDetailService feedbackDetailService;
|
|
|
public GlobalWcsController(final IGlobalWcsService globalWcsService, final IWorkstationFeedbackDetailService feedbackDetailService) {
|
this.globalWcsService = globalWcsService;
|
this.feedbackDetailService = feedbackDetailService;
|
}
|
|
@ApiOperationSupport(order = 1)
|
@ApiImplicitParams({@ApiImplicitParam(name = "code", value = "状态码", paramType = "query", dataType = "string"), @ApiImplicitParam(name = "name", value = "名称", paramType = "query", dataType = "string"), @ApiImplicitParam(name = "type", value = "类型1系统默认,2业务逻辑,4反馈", paramType = "query", dataType = "int")})
|
@ApiOperation(value = "列表", notes = "传入globalWcs")
|
@GetMapping({"/list"})
|
public R<List<GlobalWcsVO>> list(@RequestParam @ApiIgnore Map<String, Object> globalWcs) {
|
if (!globalWcs.containsKey("type")) {
|
globalWcs.put("type", GlobalWcsTypeEnum.DEFAULT.getType());
|
}
|
List<GlobalWcs> list = this.globalWcsService.list(Condition.getQueryWrapper(globalWcs, GlobalWcs.class).lambda().orderByAsc(GlobalWcs::getSeq));
|
return R.data(GlobalWcsConvert.INSTANCE.convert(list));
|
}
|
|
@GetResource({"/wcs-achievements"})
|
@ApiOperation(value = "获取状态和绩效时间", notes = "")
|
public R<List<WcsAndAchievementsVO>> getWcsAndAchievements() {
|
return R.data(this.globalWcsService.getWcsAndAchievements());
|
}
|
|
@PostResource({"/update-wcs-achievements"})
|
@ApiOperation(value = "编辑状态和绩效时间", notes = "传入wcsAchievementsUpdateVO")
|
public R<WcsAchievementsUpdateVO> updateWcsAndAchievements(@Validated @RequestBody WcsAchievementsUpdateVO wcsAchievementsUpdateVO) {
|
this.globalWcsService.updateWcsAndAchievements(wcsAchievementsUpdateVO);
|
return R.data(wcsAchievementsUpdateVO);
|
}
|
|
@PostResource({"/add-wcs-achievements"})
|
@ApiOperation(value = "添加人工反馈状态", notes = "传入FeedBackWcsAchievementsAddDTO")
|
public R<WcsAchievementsUpdateVO> addFeedbackAchievements(@Validated @RequestBody WcsAchievementsUpdateVO wcsAchievementsUpdateVO) {
|
return R.status(this.globalWcsService.insertWcsAndAchievements(wcsAchievementsUpdateVO));
|
}
|
|
@DeleteResource({"/delete-wcs-achievements/{code}"})
|
@ApiOperation(value = "删除人工反馈状态", notes = "传入ID")
|
public R<Boolean> delete(@PathVariable String code) {
|
//ExtraLambdaQueryWrapper<WorkstationFeedbackDetail> wra = Lambda.<WorkstationFeedbackDetail>eq(WorkstationFeedbackDetail::getWcs, code);
|
//wra.nested(w -> w.eq(WorkstationFeedbackDetail::getStatus, Integer.valueOf(FeedbackDetailStatus.EFFECTED.getValue())));
|
|
boolean exist = this.feedbackDetailService.count(Lambda.<WorkstationFeedbackDetail>eq(WorkstationFeedbackDetail::getWcs, code)
|
.nested(w -> w.eq(WorkstationFeedbackDetail::getStatus, FeedbackDetailStatus.EFFECTED.getValue()))
|
.or().eq(WorkstationFeedbackDetail::getStatus, FeedbackDetailStatus.WAIT_EFFECT.getValue())
|
|
.eq(WorkstationFeedbackDetail::getCancel, false)) != 0;
|
|
if (exist)
|
throw new ServiceException(MessageUtils.message("workstation.wcs.delete.used", new Object[0]));
|
return R.status(this.globalWcsService.removeByCode(code, GlobalWcsTypeEnum.FEEDBACK));
|
|
/*
|
boolean exist = this.feedbackDetailService.count(Lambda.<WorkstationFeedbackDetail>eq(WorkstationFeedbackDetail::getWcs, code).nested(w -> {
|
ExtraLambdaQueryWrapper<WorkstationFeedbackDetail> extraLambdaQueryWrapper = w.eq((v0) -> {
|
return v0.getStatus();
|
}, FeedbackDetailStatus.EFFECTED.getValue()).or()).eq((v0) -> {
|
return v0.getStatus();
|
}, Integer.valueOf(FeedbackDetailStatus.WAIT_EFFECT.getValue()));
|
}.eq((v0) -> {
|
return v0.getCancel();
|
}, false)) != 0;
|
|
if (exist) {
|
throw new ServiceException(MessageUtils.message("workstation.wcs.delete.used", new Object[0]));
|
}
|
return R.status(this.globalWcsService.removeByCode(code, GlobalWcsTypeEnum.FEEDBACK));
|
*/
|
}
|
|
@PostResource({"update-wcs-seq"})
|
@ApiOperation(value = "更新全局工况显示顺序", notes = "按顺序传入wcs的id")
|
public R<Boolean> updateWcsSeq(@RequestBody List<String> codeList) {
|
this.globalWcsService.updateWcsSeq(codeList);
|
return R.status(true);
|
}
|
}
|
