bug修复

3 months ago · 70811bfe89
1 changed files with 3 additions and 0 deletions
--- a/src/main/java/com/bw/ocr/service/impl/OcrTaskServiceImpl.java
+++ b/src/main/java/com/bw/ocr/service/impl/OcrTaskServiceImpl.java
@ -112,6 +112,9 @@ public class OcrTaskServiceImpl implements OcrTaskService {
            result.put(Constants.MESSAGE, Constants.PARSE_FIAL);
            result.put(Constants.STATUS, 2);
            task.put(Constants.RESULT, result);
+            //发送kafka
+            springBootKafka.send(topic, JSONObject.toJSONString(task));
+            log.info("数据流转至下游-------");
 		}