hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-11 11:56:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

推送改为接口

Browse Source
This commit is contained in:
daihh
2023-02-13 10:42:28 +08:00
parent 3a60026381
commit 531f1adc7b
2 changed files with 35 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
servers/boe-server-all/src/main/java/com/xboe/data/outside/OutSideDataServiceImpl.java
View File

@@ -116,7 +116,7 @@ public class OutSideDataServiceImpl implements IOutSideDataService {
user.setDeleted(false); user.setDeleted(false);
user.setDepartId(getNodeText(result.get("departId"))); user.setDepartId(getNodeText(result.get("departId")));
user.setDepartName(getNodeText(result.get("departName")));//无此字段 user.setDepartName(getNodeText(result.get("departName")));//无此字段
user.setGender(1);//少此字段 user.setGender(result.get("gender").asInt());//
user.setKid(getNodeText(result.get("kid"))); user.setKid(getNodeText(result.get("kid")));
user.setLearningDuration(result.get("learningDuration").asInt()); user.setLearningDuration(result.get("learningDuration").asInt());
user.setName(result.get("realName").asText()); user.setName(result.get("realName").asText());

68
servers/boe-server-all/src/main/java/com/xboe/module/exam/service/impl/ExamUserTaskServiceImpl.java
View File

@@ -95,48 +95,22 @@ public class ExamUserTaskServiceImpl implements IExamUserTaskService{
public void rePushTask(ExamTestDto task) { public void rePushTask(ExamTestDto task) {
//执行推送，当前因为是固定人，所以这里直接添加处理，按受众添加到每个人中 //执行推送，当前因为是固定人，所以这里直接添加处理，按受众添加到每个人中
//查询受众的信息，2022、11、30 这个的返回需要从接口获取人员信息，然后推送 //查询受众的信息，2022、11、30 这个的返回需要从接口获取人员信息，然后推送
List<UserGroupItem> items = ugroupDao.findList("groupId", task.getGroupId()); // List<UserGroupItem> items = ugroupDao.findList("groupId", task.getGroupId());
if(items.size()>0) { // if(items.size()>0) {
//防止加入两条的问题，应该是先查询，再添加
Map<String,Object> amap= aloneExamDao.findMap("aid", "name",FieldFilters.eq("testId", task.getTestId()));
//这里应该是单独的线程去处理
for(UserGroupItem item :items) {
if(amap.containsKey(item.getAid())) {
continue;
}
//检查是否存在
AloneExam aloneExam = new AloneExam();
aloneExam.setAid(item.getAid());
aloneExam.setTestId(task.getTestId());
aloneExam.setTestName(task.getTestName());
aloneExam.setName(item.getName());
aloneExam.setUcode(item.getUserNo());
aloneExam.setTestDuration(task.getDuration());
aloneExam.setTaskTime(LocalDateTime.now());
aloneExam.setStartTime(task.getStartTime());
aloneExam.setStatus(AloneExamAnswer.STATUS_NONE);//未考试过
aloneExam.setScore(0f);
aloneExamDao.save(aloneExam);
}
}
//调用用户服务的接口,在启用下面的代码前，需要
// List<AudienceUser> sudienceUsers=outSideService.getUsersByAudienceId(task.getGroupId());
// if(sudienceUsers.size()>0) {
// //防止加入两条的问题，应该是先查询，再添加 // //防止加入两条的问题，应该是先查询，再添加
// Map<String,Object> amap= aloneExamDao.findMap("aid", "name",FieldFilters.eq("testId", task.getTestId())); // Map<String,Object> amap= aloneExamDao.findMap("aid", "name",FieldFilters.eq("testId", task.getTestId()));
// //这里应该是单独的线程去处理 // //这里应该是单独的线程去处理
// for(AudienceUser item :sudienceUsers) { // for(UserGroupItem item :items) {
// if(amap.containsKey(item.getId())) { // if(amap.containsKey(item.getAid())) {
// continue; // continue;
// } // }
// //检查是否存在 // //检查是否存在
// AloneExam aloneExam = new AloneExam(); // AloneExam aloneExam = new AloneExam();
// aloneExam.setAid(item.getId()); // aloneExam.setAid(item.getAid());
// aloneExam.setTestId(task.getTestId()); // aloneExam.setTestId(task.getTestId());
// aloneExam.setTestName(task.getTestName()); // aloneExam.setTestName(task.getTestName());
// aloneExam.setName(item.getName()); // aloneExam.setName(item.getName());
// aloneExam.setUcode(item.getCode()); // aloneExam.setUcode(item.getUserNo());
// aloneExam.setTestDuration(task.getDuration()); // aloneExam.setTestDuration(task.getDuration());
// aloneExam.setTaskTime(LocalDateTime.now()); // aloneExam.setTaskTime(LocalDateTime.now());
// aloneExam.setStartTime(task.getStartTime()); // aloneExam.setStartTime(task.getStartTime());
@@ -146,8 +120,34 @@ public class ExamUserTaskServiceImpl implements IExamUserTaskService{
// } // }
// } // }
//examUserTask.setStatus(ExamUserTask.STATUS_FINISH); //调用用户服务的接口,在启用下面的代码前，需要
//dao.update(examUserTask); List<AudienceUser> sudienceUsers=outSideService.getUsersByAudienceId(task.getGroupId());
if(sudienceUsers.size()>0) {
//防止加入两条的问题，应该是先查询，再添加
Map<String,Object> amap= aloneExamDao.findMap("aid", "name",FieldFilters.eq("testId", task.getTestId()));
//这里应该是单独的线程去处理
for(AudienceUser item :sudienceUsers) {
if(amap.containsKey(item.getId())) {
continue;
}
//检查是否存在
AloneExam aloneExam = new AloneExam();
aloneExam.setAid(item.getId());
aloneExam.setTestId(task.getTestId());
aloneExam.setTestName(task.getTestName());
aloneExam.setName(item.getName());
aloneExam.setUcode(item.getCode());
aloneExam.setTestDuration(task.getDuration());
aloneExam.setTaskTime(LocalDateTime.now());
aloneExam.setStartTime(task.getStartTime());
aloneExam.setStatus(AloneExamAnswer.STATUS_NONE);//未考试过
aloneExam.setScore(0f);
aloneExamDao.save(aloneExam);
}
}
// examUserTask.setStatus(ExamUserTask.STATUS_FINISH);
// dao.update(examUserTask);
} }