| | |
| | | } |
| | | |
| | | @Override |
| | | public FebsResponse jobStateUpdate(String ids) { |
| | | if (StrUtil.isEmpty(ids)) { |
| | | throw new FebsException("参数错误"); |
| | | } |
| | | List<String> idList = StrUtil.split(ids, ','); |
| | | aiProductQuestionJobMapper.update(null, |
| | | Wrappers.lambdaUpdate(AiProductQuestionJob.class) |
| | | .set(AiProductQuestionJob::getState, 2) |
| | | .set(AiProductQuestionJob::getUpdatedTime, new Date()) |
| | | .in(AiProductQuestionJob::getId, idList)); |
| | | return new FebsResponse().success().message("操作成功"); |
| | | } |
| | | |
| | | @Override |
| | | public FebsResponse delete(String id) { |
| | | AiProductQuestion entity = this.getById(id); |
| | | if(ObjectUtil.isNotNull( entity)){ |
| | |
| | | Integer questionCnt = aiProductQuestionJob.getQuestionCnt(); |
| | | Integer questionDoneCnt = aiProductQuestionJob.getQuestionDoneCnt(); |
| | | if (questionCnt <= questionDoneCnt){ |
| | | aiProductQuestionJob.setState(2); |
| | | aiProductQuestionJobMapper.update(null, |
| | | Wrappers.lambdaUpdate(AiProductQuestionJob.class) |
| | | .set(AiProductQuestionJob::getState, 2) |
| | |
| | | Wrappers.lambdaUpdate(AiProductQuestionJob.class) |
| | | .set(AiProductQuestionJob::getQuestionDoneCnt, questionDoneCnt + questionList.size()) |
| | | .set(AiProductQuestionJob::getUpdatedTime, new Date()) |
| | | .set(AiProductQuestionJob::getState, 1) |
| | | .eq(AiProductQuestionJob::getId, id)); |
| | | } |
| | | AiProductQuestionJob aiProductQuestionJobDone = aiProductQuestionJobMapper.selectById(id); |