package cn.axzo.msg.center.notices.client.task.process;

import cn.axzo.msg.center.notices.client.task.LoggerJobHandler;
import cn.azxo.framework.common.model.JobPageRequest;
import cn.azxo.framework.common.utils.LogUtil;
import com.alibaba.fastjson.JSON;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * 短信批次拆分成每一个短信
 *
 * @author szg
 * @see BatchMessageSplitJobHandler
 * @since 2021-08-11 15:44
 */
@Slf4j
@Component
public class BatchMessageSplitJobHandler extends LoggerJobHandler {

    @Override
    @XxlJob(value = "batchMessageSendSplitHandle")
    public ReturnT<String> execute(String param) {
        return jobLoggerTemplate.execute(() -> {
            log.info("BatchMessageSplitJobHandler.execute task Start ......");
            try {
                JobPageRequest request = jobParamResolver.resolver(param);
                log.info("BatchMessageSplitJobHandler.execute task request is {}", JSON.toJSONString(request));
                taskService.batchMessageSendSplitHandle(request);
            } catch (Exception e) {
                LogUtil.error("BatchMessageSplitJobHandler.execute is error", e);
                return ReturnT.FAIL;
            }
            log.info("BatchMessageSplitJobHandler.execute task End ......");
            return ReturnT.SUCCESS;
        });
    }

}
