package tech.powerjob.server.web.controller;

import com.google.common.collect.Lists;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.MapUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import tech.powerjob.common.serialize.JsonUtils;
import tech.powerjob.common.utils.CollectionUtils;
import tech.powerjob.server.common.utils.TestUtils;
import tech.powerjob.server.core.alarm.AlarmCenter;
import tech.powerjob.server.core.alarm.module.JobInstanceAlarm;
import tech.powerjob.server.extension.alarm.AlarmTarget;

import javax.annotation.Resource;
import java.util.Map;

/**
 * 开发团队专用（或者 PRO 用户用来做自检也可以 lol）
 * 测试某些强依赖运行时环境的组件，如 Mail 告警等
 *
 * @author tjq
 * @since 2023/7/31
 */
@Slf4j
@RestController
@RequestMapping("/test")
public class TestController {

    @Value("${server.port}")
    private int port;

    @Resource
    private AlarmCenter alarmCenter;

    @RequestMapping("/io")
    public Map<String, Object> io(@RequestBody Map<String, Object> input) {
        log.info("[TestController] input: {}", JsonUtils.toJSONString(input));
        return input;
    }

    @GetMapping("/check")
    public void check() {
        Map<String, Object> testConfig = TestUtils.fetchTestConfig();
        if (CollectionUtils.isEmpty(testConfig)) {
            log.info("[TestController] testConfig not exist, skip check!");
            return;
        }

        log.info("[TestController] testConfig: {}", JsonUtils.toJSONString(testConfig));

        testAlarmCenter();
    }

    void testAlarmCenter() {
        JobInstanceAlarm jobInstanceAlarm = new JobInstanceAlarm().setAppId(277).setJobId(1).setInstanceId(2)
                .setJobName("test-alarm").setJobParams("jobParams").setInstanceParams("instanceParams")
                .setExecuteType(1).setFinishedTime(System.currentTimeMillis());

        AlarmTarget target = new AlarmTarget().setName("ald").setPhone("208140").setExtra("extra")
                .setPhone(MapUtils.getString(TestUtils.fetchTestConfig(), TestUtils.KEY_PHONE_NUMBER))
                .setEmail("tjq@zju.edu.cn")
                .setWebHook(localUrlPath().concat("/test/io"));

        log.info("[TestController] start to testAlarmCenter, target: {}", target);
        alarmCenter.alarmFailed(jobInstanceAlarm, Lists.newArrayList(target));
    }

    private String localUrlPath() {
        return String.format("http://127.0.0.1:%d", port);
    }
}