package com.zy.asrs.task.handler;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.zy.asrs.entity.ApiLog;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.utils.DingDingPush;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;


@Slf4j
@Service
@Transactional
public class ExceptionNoticeHandler extends AbstractHandler<String> {
    @Autowired
    private ApiLogService apiLogService;
    @Transactional
    public ReturnT<String> start() {
        try {
            EntityWrapper<ApiLog> wrapper = new EntityWrapper<>();
            wrapper.eq("result", 0).isNull("memo").orderBy("create_time", false);
            Page<ApiLog> page = apiLogService.selectPage(new Page<>(1, 1), wrapper);
            if (page.getRecords() != null && !page.getRecords().isEmpty()) {
                ApiLog item = page.getRecords().get(0);
                StringBuilder sb = new StringBuilder();
                sb.append("异常告警-ERROR").append("\n");
                sb.append("时间: ").append(item.getCreateTime$()).append("\n");
                sb.append("接口: ").append(nvl(item.getNamespace())).append(" ").append(nvl(item.getUrl())).append("\n");
                sb.append("相关信息: ").append(nvl(item.getClientIp())).append("\n");
                sb.append("请求: ").append(cut(nvl(item.getRequest()), 500)).append("\n");
                sb.append("响应: ").append(cut(nvl(item.getResponse()), 500)).append("\n");
                DingDingPush.send(sb.toString());
                item.setMemo("PUSHED");
                apiLogService.updateById(item);
            }
        } catch (Exception e) {
            e.printStackTrace();
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return FAIL.setMsg(e.getMessage());
        }
        return SUCCESS;
    }

    private String nvl(String s) {
        return s == null ? "" : s;
    }

    private String cut(String s, int max) {
        if (s == null) {
            return "";
        }
        return s.length() > max ? s.substring(0, max) : s;
    }
}