chenken 6 роки тому
батько
коміт
11bb6cd1a1

+ 45 - 0
examcloud-core-oe-admin-api-client/src/main/java/cn/com/qmth/examcloud/core/oe/admin/client/OeAdminScorePushCloudServiceClient.java

@@ -0,0 +1,45 @@
+package cn.com.qmth.examcloud.core.oe.admin.client;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import cn.com.qmth.examcloud.commons.web.redis.RedisClient;
+import cn.com.qmth.examcloud.core.oe.admin.api.OeAdminScorePushCloudService;
+import cn.com.qmth.examcloud.core.oe.admin.api.request.SaveExamScoreQueueReq;
+
+@Service
+public class OeAdminScorePushCloudServiceClient extends AdminCloudClientSupport implements OeAdminScorePushCloudService{
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1682623291259562715L;
+
+	@Autowired
+	private RestTemplate restTemplate;
+
+	@Autowired
+	private RedisClient redisClient;
+	
+	@Override
+	protected RestTemplate getRestTemplate() {
+		return restTemplate;
+	}
+
+	@Override
+	protected RedisClient getRedisClient() {
+		return redisClient;
+	}
+	
+	@Override
+	public void disposeScoreQueue() {
+		post("oeAdminScorePush/disposeScoreQueue", null);
+	}
+	
+	@Override
+	public void saveExamScoreQueue(SaveExamScoreQueueReq req) {
+		post("oeAdminScorePush/saveExamScoreQueue", req);
+	}
+
+}

+ 27 - 0
examcloud-core-oe-admin-api/src/main/java/cn/com/qmth/examcloud/core/oe/admin/api/OeAdminScorePushCloudService.java

@@ -0,0 +1,27 @@
+package cn.com.qmth.examcloud.core.oe.admin.api;
+
+import cn.com.qmth.examcloud.commons.web.cloud.api.CloudService;
+import cn.com.qmth.examcloud.core.oe.admin.api.request.SaveExamScoreQueueReq;
+
+/**
+ * 
+ * @author  	chenken
+ * @date    	2018年9月8日 上午10:37:42
+ * @company 	QMTH
+ * @description 分数推送
+ */
+public interface OeAdminScorePushCloudService extends CloudService{
+	
+	/**
+	 * 分数推送:定时器调用
+	 * @return
+	 */
+	public void disposeScoreQueue();
+	
+	/**
+	 * 保存推分队列
+	 * @param examRecordDataId
+	 */
+	public void saveExamScoreQueue(SaveExamScoreQueueReq req);
+	
+}

+ 44 - 0
examcloud-core-oe-admin-api/src/main/java/cn/com/qmth/examcloud/core/oe/admin/api/request/SaveExamScoreQueueReq.java

@@ -0,0 +1,44 @@
+package cn.com.qmth.examcloud.core.oe.admin.api.request;
+
+import cn.com.qmth.examcloud.commons.web.cloud.api.BaseRequest;
+
+public class SaveExamScoreQueueReq extends BaseRequest{
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 5382845064059370506L;
+
+	private Long examRecordDataId;
+	
+	private Long scoreId;
+	
+	private String serviceName;
+
+	public Long getExamRecordDataId() {
+		return examRecordDataId;
+	}
+
+	public void setExamRecordDataId(Long examRecordDataId) {
+		this.examRecordDataId = examRecordDataId;
+	}
+
+	public Long getScoreId() {
+		return scoreId;
+	}
+
+	public void setScoreId(Long scoreId) {
+		this.scoreId = scoreId;
+	}
+
+	public String getServiceName() {
+		return serviceName;
+	}
+
+	public void setServiceName(String serviceName) {
+		this.serviceName = serviceName;
+	}
+	
+	
+	
+}