成长路径图，考试实时同步

servers/boe-server-all/src/main/java/com/xboe/api/ThirdApi.java

@@ -4,18 +4,21 @@ import cn.hutool.core.collection.ListUtil;
 import cn.hutool.core.lang.Opt;
 import cn.hutool.http.HttpRequest;
 import cn.hutool.json.JSONUtil;
-import com.alibaba.nacos.shaded.com.google.gson.Gson;
+import com.alibaba.nacos.shaded.com.google.gson.*;
 import com.xboe.api.vo.*;
 import com.xboe.module.course.vo.StudyCourseVo;
 import com.xboe.module.course.vo.TeacherInfoVo;
 import com.xboe.module.course.vo.TeacherVo;
 import com.xboe.module.dict.entity.DictDto;
+import com.xboe.module.exam.entity.AloneExam;
 import com.xboe.school.study.entity.StudyCourse;
 import com.xboe.system.user.dao.UserDao;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.concurrent.ForkJoinPool;
 import java.util.stream.Collectors;
@@ -65,6 +68,9 @@ public class ThirdApi {
     @Value("${coursesuilt.checkBanding}")
     private String checkBanding;
 
+    @Value("${coursesuilt.syncExamScoreToCourseSuite}")
+    private String syncExamScoreToCourseSuite;
+
     //获取例外人员的id
     public  List<String> getUserId(){
         String responseBody = Optional.ofNullable(HttpRequest.get(infarasApiUrl+"?pid=316&type=1").execute() //prod 316
@@ -250,4 +256,22 @@ public class ThirdApi {
         return checkExamBandingBean.getData().toString();
     }
 
+
+    public void syncExamScoreToCourseSuite(AloneExam aloneExam,String token) {
+        Gson gson = new GsonBuilder()
+                .registerTypeAdapter(LocalDateTime.class, new LocalDateTimeSerializer())
+                .create();
+
+        String json = gson.toJson(aloneExam);
+        String resp = HttpRequest.post(syncExamScoreToCourseSuite)
+                .body(json)
+                .header("token", token)
+                .execute()
+                .body();
+
+        if (StringUtils.isBlank(resp)){
+            return;
+        }
+        JSONUtil.toBean(resp, SyncExamScoreBean.class).success();
+    }
 }

servers/boe-server-all/src/main/java/com/xboe/api/vo/LocalDateTimeSerializer.java

@@ -0,0 +1,19 @@
+package com.xboe.api.vo;
+
+import com.alibaba.nacos.shaded.com.google.gson.JsonElement;
+import com.alibaba.nacos.shaded.com.google.gson.JsonPrimitive;
+import com.alibaba.nacos.shaded.com.google.gson.JsonSerializationContext;
+import com.alibaba.nacos.shaded.com.google.gson.JsonSerializer;
+
+import java.lang.reflect.Type;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+public class LocalDateTimeSerializer implements JsonSerializer<LocalDateTime> {
+    private  final DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+    @Override
+    public JsonElement serialize(LocalDateTime src, Type typeOfSrc, JsonSerializationContext context) {
+        return new JsonPrimitive(formatter.format(src));
+    }
+}

servers/boe-server-all/src/main/java/com/xboe/api/vo/SyncExamScoreBean.java

@@ -0,0 +1,31 @@
+package com.xboe.api.vo;
+
+import cn.hutool.json.JSONUtil;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Data
+@Slf4j
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class SyncExamScoreBean {
+
+    private boolean show;
+    private String version;
+    private int code;
+    private String msg;
+    private Object data;
+    private boolean success;
+
+    public SyncExamScoreBean success() {
+        if (this.code!=200) {
+            log.error("同步考试到boe库失败----{}", JSONUtil.toJsonPrettyStr(this));
+            return null;
+        }
+        return this;
+    }
+}

servers/boe-server-all/src/main/java/com/xboe/module/exam/api/AloneExamApi.java

@@ -547,7 +547,7 @@ public class AloneExamApi extends ApiBaseController {
         	//Float realScore=this.calculateScore(answer);
         	//转化成百分数
         	//answer.setScore(this.calculateScore(detail));
-            service.submit(answer,scoreType);
+            service.submit(answer,scoreType,request);
             return success(map);
         } catch (Exception e) {
             log.error("提交答卷错误", e);

servers/boe-server-all/src/main/java/com/xboe/module/exam/entity/AloneExam.java

@@ -65,6 +65,7 @@ public class AloneExam extends IdBaseEntity {
     private String ucode;
     
     /**关联类型*/
+    /**关联类型 新增关联类型14，代表成长路径图*/
     @Column(name = "ref_type", length = 30)
     private String refType;
     

servers/boe-server-all/src/main/java/com/xboe/module/exam/service/IAloneExamService.java

@@ -1,6 +1,5 @@
 package com.xboe.module.exam.service;
 
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -95,9 +94,11 @@ public interface IAloneExamService {
 
 	/**
 	 * 提交考试
+	 *
 	 * @param aea
+	 * @param request
 	 */
-	void submit(AloneExamAnswer aea,Integer scoreType);
+	void submit(AloneExamAnswer aea, Integer scoreType, HttpServletRequest request);
 	
 	/**
 	 * 更新答案

servers/boe-server-all/src/main/java/com/xboe/module/exam/service/impl/AloneExamServiceImpl.java

@@ -2,6 +2,7 @@ package com.xboe.module.exam.service.impl;
 
 import java.time.LocalDateTime;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
 
 import javax.annotation.Resource;
@@ -11,6 +12,8 @@ import com.xboe.api.ThirdApi;
 import com.xboe.module.exam.dao.ExamTestDao;
 import com.xboe.module.exam.dto.*;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -36,6 +39,7 @@ import org.springframework.transaction.support.DefaultTransactionDefinition;
 @Service
 public class AloneExamServiceImpl implements IAloneExamService{
 
+	private static final Logger log = LoggerFactory.getLogger(AloneExamServiceImpl.class);
 	@Resource
 	AloneExamAnswerDao dao;
 	
@@ -65,7 +69,7 @@ public class AloneExamServiceImpl implements IAloneExamService{
 
 	@Override
 	@Transactional
-	public void submit(AloneExamAnswer aea,Integer scoreType){
+	public void submit(AloneExamAnswer aea, Integer scoreType, HttpServletRequest request){
 		//dao.update(aea);
 		aea.setStatus(AloneExamAnswer.STATUS_FINISH);
 		LocalDateTime now=LocalDateTime.now();
@@ -112,6 +116,30 @@ public class AloneExamServiceImpl implements IAloneExamService{
 //				//这种情况汶是不存在的
 //			}
 		}
+		syncExamScoreToCourseSuite(aea, request);
+	}
+
+	private void syncExamScoreToCourseSuite(AloneExamAnswer aea, HttpServletRequest request) {
+		String token = request.getHeader("Xboe-Access-Token");
+		if (StringUtils.isEmpty(token)) {
+			token = request.getHeader("token");
+		}
+
+		String finalToken = token;
+		CompletableFuture.supplyAsync(() -> {
+			AloneExam aloneExam = aeDao.findOne(FieldFilters.eq("aid", aea.getAid()), FieldFilters.eq("testId", aea.getTestId()));
+			if (aloneExam.getRefType().equals("14")){
+				int i = 1 / 0;  // 这行将引发异常
+				thirdApi.syncExamScoreToCourseSuite(aloneExam, finalToken);
+			}
+			return "完成结果";
+		}).exceptionally(ex -> {
+			log.error("异步操作中发生错误: " + ex.getMessage(), ex);
+			return "发生错误";
+		}).thenAccept(result -> {
+			log.info("同步考试成绩到课程项目完成：" + result);
+		});
+
 	}
 
 	@Override

servers/boe-server-all/src/main/resources/application.properties

@@ -75,4 +75,5 @@ manageApi.stu.offcourse=${boe.domain}/manageApi/stu/offcourse/getOffCourseId
 userBasic.getTeacherIds=${boe.domain}/userbasic/user/getTeacherInfo
 userBasic.getUserIdByWorkNum=${boe.domain}/userbasic/user/getUserIdByWorkNum
 coursesuilt.getStudyStatus=${boe.domain}/manageApi/stu/project/completeStatus
-coursesuilt.checkBanding=${boe.domain}/manageApi/stu/task/exam/checkBanding
+coursesuilt.checkBanding=${boe.domain}/manageApi/stu/task/exam/checkBanding
+coursesuilt.syncExamScoreToCourseSuite=${boe.domain}/manageApi/stu/task/exam/syncExamScoreToCourseSuite