package com.qianwen.mdc.collect.job;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import javax.annotation.Resource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.mdc.collect.service.feedback.WorkstationFeedbackService;

import org.springframework.stereotype.Component;

@Component
public class FeedbackDealJob {
    private static final Logger log = LoggerFactory.getLogger(FeedbackDealJob.class);
    @Resource
    private WorkstationFeedbackService workstationFeedbackService;
  
    //executeWaitAnalyseFeedback
    @XxlJob("feedbackAnalyseJobHandler")
    public ReturnT<String> feedbackAnalyseJobHandler(String param) throws Exception {
        try {
            XxlJobLogger.log("XXL-JOB, 定时扫描反馈记录开始.....", new Object[0]);
            this.workstationFeedbackService.sendFeedbackAnalyseMessageForWorkStation(param);
            XxlJobLogger.log("XXL-JOB, 定时扫描反馈记录结束", new Object[0]);
        } catch (Exception ex) {
            log.info("定时扫描检查反馈记录,发生异常", ex);
            return ReturnT.FAIL;
        }
        return ReturnT.SUCCESS;
    }
}