zhouwentao
/
ocr-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

updates

Browse Source
master
周文涛 2 years ago
parent a5723cecd0
commit 69da49eed5
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File

8
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/ocr/service/impl/OcrIdentifyServiceImpl.java
Unescape View File

@ -592,7 +592,7 @@ public class OcrIdentifyServiceImpl extends ServiceImpl<OcrIdentifyMapper, OcrId
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
String task_ = (String) redisUtil.get("task_" + taskLevel); String task_ = (String) redisUtil.get("task_identify_" + taskLevel);//TODO task_
log.info("历史任务:" + task_); log.info("历史任务:" + task_);
if (task_ == null || task_.equals("[]")) { if (task_ == null || task_.equals("[]")) {
//无历史任务 //无历史任务
@ -627,7 +627,7 @@ public class OcrIdentifyServiceImpl extends ServiceImpl<OcrIdentifyMapper, OcrId
} }
} }
//存入redis //存入redis
redisUtil.set("task_" + taskLevel, task_); redisUtil.set("task_identify_" + taskLevel, task_);//TODO task_
//执行任务 //执行任务
executeTask(); executeTask();
return Result.OK("已追加到任务"); return Result.OK("已追加到任务");
@ -963,7 +963,7 @@ public class OcrIdentifyServiceImpl extends ServiceImpl<OcrIdentifyMapper, OcrId
TaskModel taskModel = taskList.stream().filter(t -> t.getTaskId().equals(taskId)).findFirst().get(); TaskModel taskModel = taskList.stream().filter(t -> t.getTaskId().equals(taskId)).findFirst().get();
if (taskModel!=null) { if (taskModel!=null) {
int taskLevel = taskModel.getTaskLevel(); int taskLevel = taskModel.getTaskLevel();
String task = (String) redisUtil.get("task_" + taskLevel); String task = (String) redisUtil.get("task_identify_" + taskLevel);//TODO task_
JSONArray taskJsonArray = JSONObject.parseArray(task); JSONArray taskJsonArray = JSONObject.parseArray(task);
taskList = new ArrayList<>(); taskList = new ArrayList<>();
if (task != null) { if (task != null) {
@ -982,7 +982,7 @@ public class OcrIdentifyServiceImpl extends ServiceImpl<OcrIdentifyMapper, OcrId
} }
String s = JSONObject.toJSONString(taskList); String s = JSONObject.toJSONString(taskList);
//存入redis //存入redis
redisUtil.set("task_" + taskLevel, s); redisUtil.set("task_identify_" + taskLevel, s);//TODO task_
} }
} }
} }

4
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/ocr/service/impl/TaskService.java
Unescape View File

@ -60,7 +60,7 @@ public class TaskService {
public Result saveTask(TaskModel taskModel) { public Result saveTask(TaskModel taskModel) {
String taskId = taskModel.getTaskId(); String taskId = taskModel.getTaskId();
String task_ = (String) redisUtil.get("task_" +taskModel.getTaskType()+"_"+taskModel.getTaskLevel()); String task_ = (String) redisUtil.get("task_" +taskModel.getTaskType()+"_"+taskModel.getTaskLevel());//TODO task_
if (task_ == null || task_.equals("[]")) { if (task_ == null || task_.equals("[]")) {
//无历史任务 //无历史任务
List<TaskModel> jsonObjects = Arrays.asList(taskModel); List<TaskModel> jsonObjects = Arrays.asList(taskModel);
@ -93,7 +93,7 @@ public class TaskService {
} }
} }
//存入redis //存入redis
redisUtil.set("task_" +taskModel.getTaskType()+"_"+taskModel.getTaskLevel(), task_); redisUtil.set("task_" +taskModel.getTaskType()+"_"+taskModel.getTaskLevel(), task_);//TODO task_
//执行任务 //执行任务
//executeTask(); //executeTask();
return Result.OK("已追加到任务"); return Result.OK("已追加到任务");

Write Preview
Loading…
Cancel
Save