Commit acc5f855 authored by alex yao's avatar alex yao

fix

parent 1da32b09
...@@ -8,7 +8,7 @@ import cn.com.yict.framemax.core.service.BaseService; ...@@ -8,7 +8,7 @@ import cn.com.yict.framemax.core.service.BaseService;
* @author alex.yao * @author alex.yao
* @date 2025/10/30 * @date 2025/10/30
*/ */
public interface OCRConsumerService extends BaseService { public interface OcrConsumerService extends BaseService {
void OCR(OCRMessage message) ; void OCR(OCRMessage message) ;
......
...@@ -8,7 +8,7 @@ import cn.com.yict.framemax.core.service.BaseService; ...@@ -8,7 +8,7 @@ import cn.com.yict.framemax.core.service.BaseService;
* @author alex.yao * @author alex.yao
* @date 2025/10/30 * @date 2025/10/30
*/ */
public interface OCRProducerService extends BaseService { public interface OcrProducerService extends BaseService {
OCRMessage OCR(OCRMessage message); OCRMessage OCR(OCRMessage message);
......
...@@ -23,7 +23,7 @@ import cn.com.poc.message.entity.AirportPDFPaperMessage; ...@@ -23,7 +23,7 @@ import cn.com.poc.message.entity.AirportPDFPaperMessage;
import cn.com.poc.message.entity.OCRMessage; import cn.com.poc.message.entity.OCRMessage;
import cn.com.poc.message.service.AirportConsumerService; import cn.com.poc.message.service.AirportConsumerService;
import cn.com.poc.message.service.AirportProducerService; import cn.com.poc.message.service.AirportProducerService;
import cn.com.poc.message.service.OCRProducerService; import cn.com.poc.message.service.OcrProducerService;
import cn.com.poc.message.topic.AirportTopic; import cn.com.poc.message.topic.AirportTopic;
import cn.com.poc.ocr.entity.BizFileOcrCacheEntity; import cn.com.poc.ocr.entity.BizFileOcrCacheEntity;
import cn.com.poc.ocr.service.BizFileOcrCacheService; import cn.com.poc.ocr.service.BizFileOcrCacheService;
...@@ -73,7 +73,7 @@ public class AirportConsumerServiceImpl implements AirportConsumerService { ...@@ -73,7 +73,7 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
private BizAiDataAuditTaskService bizAiDataAuditTaskService; private BizAiDataAuditTaskService bizAiDataAuditTaskService;
@Resource @Resource
private OCRProducerService ocrProducerService; private OcrProducerService ocrProducerService;
@Resource @Resource
private RedisService redisService; private RedisService redisService;
......
...@@ -9,8 +9,8 @@ import cn.com.poc.common.utils.StringUtils; ...@@ -9,8 +9,8 @@ import cn.com.poc.common.utils.StringUtils;
import cn.com.poc.common.utils.UUIDTool; import cn.com.poc.common.utils.UUIDTool;
import cn.com.poc.message.entity.OCRMessage; import cn.com.poc.message.entity.OCRMessage;
import cn.com.poc.message.entity.OCRStatusMessage; import cn.com.poc.message.entity.OCRStatusMessage;
import cn.com.poc.message.service.OCRConsumerService; import cn.com.poc.message.service.OcrConsumerService;
import cn.com.poc.message.service.OCRProducerService; import cn.com.poc.message.service.OcrProducerService;
import cn.com.poc.message.topic.OCRTopic; import cn.com.poc.message.topic.OCRTopic;
import cn.com.poc.ocr.entity.BizFileOcrCacheEntity; import cn.com.poc.ocr.entity.BizFileOcrCacheEntity;
import cn.com.poc.ocr.service.BizFileOcrCacheService; import cn.com.poc.ocr.service.BizFileOcrCacheService;
...@@ -22,7 +22,6 @@ import cn.com.yict.framemax.core.exception.BusinessException; ...@@ -22,7 +22,6 @@ import cn.com.yict.framemax.core.exception.BusinessException;
import cn.com.yict.framemax.tumbleweed.client.annotation.Consumer; import cn.com.yict.framemax.tumbleweed.client.annotation.Consumer;
import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.FileUtil;
import cn.hutool.crypto.digest.MD5; import cn.hutool.crypto.digest.MD5;
import org.beetl.ext.fn.StringUtil;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -38,9 +37,9 @@ import java.io.IOException; ...@@ -38,9 +37,9 @@ import java.io.IOException;
* @date 2025/10/30 * @date 2025/10/30
*/ */
@Service @Service
public class OCRConsumerServiceImpl implements OCRConsumerService { public class OcrConsumerServiceImpl implements OcrConsumerService {
private Logger logger = LoggerFactory.getLogger(OCRConsumerService.class); private Logger logger = LoggerFactory.getLogger(OcrConsumerService.class);
@Resource @Resource
private MinerUAPI minerUAPI; private MinerUAPI minerUAPI;
...@@ -55,7 +54,7 @@ public class OCRConsumerServiceImpl implements OCRConsumerService { ...@@ -55,7 +54,7 @@ public class OCRConsumerServiceImpl implements OCRConsumerService {
private BizFileUploadRecordService bizFileUploadRecordService; private BizFileUploadRecordService bizFileUploadRecordService;
@Resource @Resource
private OCRProducerService ocrProducerService; private OcrProducerService ocrProducerService;
@Override @Override
......
...@@ -2,9 +2,8 @@ package cn.com.poc.message.service.impl; ...@@ -2,9 +2,8 @@ package cn.com.poc.message.service.impl;
import cn.com.poc.message.entity.OCRMessage; import cn.com.poc.message.entity.OCRMessage;
import cn.com.poc.message.entity.OCRStatusMessage; import cn.com.poc.message.entity.OCRStatusMessage;
import cn.com.poc.message.service.OCRProducerService; import cn.com.poc.message.service.OcrProducerService;
import cn.com.poc.message.topic.OCRTopic; import cn.com.poc.message.topic.OCRTopic;
import cn.com.yict.framemax.core.service.BaseService;
import cn.com.yict.framemax.tumbleweed.client.annotation.Producer; import cn.com.yict.framemax.tumbleweed.client.annotation.Producer;
import cn.com.yict.framemax.tumbleweed.constant.PublishPoint; import cn.com.yict.framemax.tumbleweed.constant.PublishPoint;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -14,7 +13,7 @@ import org.springframework.stereotype.Service; ...@@ -14,7 +13,7 @@ import org.springframework.stereotype.Service;
* @date 2025/10/30 * @date 2025/10/30
*/ */
@Service @Service
public class OCRProducerServiceImpl implements OCRProducerService { public class OcrProducerServiceImpl implements OcrProducerService {
@Override @Override
@Producer(topic = OCRTopic.PARSE_PDF) @Producer(topic = OCRTopic.PARSE_PDF)
......
...@@ -4,7 +4,7 @@ import cn.com.poc.common.constant.CommonConstant; ...@@ -4,7 +4,7 @@ import cn.com.poc.common.constant.CommonConstant;
import cn.com.poc.common.utils.StringUtils; import cn.com.poc.common.utils.StringUtils;
import cn.com.poc.message.entity.OCRMessage; import cn.com.poc.message.entity.OCRMessage;
import cn.com.poc.message.entity.OCRStatusMessage; import cn.com.poc.message.entity.OCRStatusMessage;
import cn.com.poc.message.service.OCRProducerService; import cn.com.poc.message.service.OcrProducerService;
import cn.com.poc.ocr.entity.BizFileOcrCacheEntity; import cn.com.poc.ocr.entity.BizFileOcrCacheEntity;
import cn.com.poc.ocr.service.BizFileOcrCacheService; import cn.com.poc.ocr.service.BizFileOcrCacheService;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
...@@ -27,7 +27,7 @@ public class OCRScheduler { ...@@ -27,7 +27,7 @@ public class OCRScheduler {
private BizFileOcrCacheService bizFileOcrCacheService; private BizFileOcrCacheService bizFileOcrCacheService;
@Resource @Resource
private OCRProducerService ocrProducerService; private OcrProducerService ocrProducerService;
@Scheduled(fixedDelay = 10000) @Scheduled(fixedDelay = 10000)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment