提交 07a6144d 作者: 925993793@qq.com

重新打分逻辑调试修改

上级 fec3c462
...@@ -2,6 +2,7 @@ package com.zzsn.event.controller; ...@@ -2,6 +2,7 @@ package com.zzsn.event.controller;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
...@@ -30,6 +31,7 @@ import org.apache.poi.xwpf.usermodel.XWPFDocument; ...@@ -30,6 +31,7 @@ import org.apache.poi.xwpf.usermodel.XWPFDocument;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpHeaders;
import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
...@@ -583,11 +585,14 @@ public class SubjectManageController { ...@@ -583,11 +585,14 @@ public class SubjectManageController {
*/ */
@PostMapping("/configScoreModel") @PostMapping("/configScoreModel")
public Result<?> configScoreModel(@RequestBody ScoreModelVo scoreModelVo) { public Result<?> configScoreModel(@RequestBody ScoreModelVo scoreModelVo) {
UserVo loginUser = UserUtil.getLoginUser();
scoreModelService.addOrUpdate(scoreModelVo, 1); scoreModelService.addOrUpdate(scoreModelVo, 1);
//调用接口,重新打分 //调用接口,重新打分
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
String subjectId = scoreModelVo.getSubjectId(); String subjectId = scoreModelVo.getSubjectId();
remoteModelService.reScoreRequest(subjectId, "1887695061047672834"); HttpHeaders headers = new HttpHeaders();
headers.set("loginUser", JSON.toJSONString(loginUser));
remoteModelService.reScoreRequest(subjectId, "1887695061047672834",headers);
log.info("专题-{},通用打分配置修改,重新打分请求发送成功",subjectId); log.info("专题-{},通用打分配置修改,重新打分请求发送成功",subjectId);
}); });
return Result.OK(); return Result.OK();
......
package com.zzsn.event.feign.api; package com.zzsn.event.feign.api;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.HttpHeaders;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
//feign调用 //feign调用
...@@ -17,5 +19,5 @@ public interface RemoteModelService { ...@@ -17,5 +19,5 @@ public interface RemoteModelService {
* @date 2025/2/7 * @date 2025/2/7
*/ */
@GetMapping("/modelArrange/clbBiz/detailSubjectDataWithFlow") @GetMapping("/modelArrange/clbBiz/detailSubjectDataWithFlow")
String reScoreRequest(@RequestParam("subjectId") String subjectId,@RequestParam("flowId") String flowId); String reScoreRequest(@RequestParam("subjectId") String subjectId,@RequestParam("flowId") String flowId, @RequestHeader HttpHeaders headers);
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论