public class UserMetric extends AbstractBaseEntity {

	@Column(name = "new_users", nullable = true)
	private Long newUsers;

	@Column(name = "total_users", nullable = true)
	private Long totalUsers;

	@Builder
	public UserMetric(Long newUsers, Long totalUsers) {
		this.newUsers = newUsers;
		this.totalUsers = totalUsers;
	}

	public static UserMetric of(Long newUsers, Long totalUsers, LocalDateTime createdAt) {
		UserMetric userMetric = new UserMetric();
		userMetric.setNewUsers(newUsers);
		userMetric.setTotalUsers(totalUsers);
		userMetric.setCreatedAt(createdAt);
		return userMetric;
	}
}

public interface UserMetricRepository extends JpaRepository<UserMetric, Long> {
	UserMetric findTopByCreatedAtBetween(LocalDateTime start, LocalDateTime end);
	UserMetric findTopByOrderByCreatedAtDesc();
}

@Slf4j
public class QuartzJobListener implements JobListener {

	@Override
	public String getName() {
		return "QuartzJobListener";
	}

	@Override
	public void jobToBeExecuted(JobExecutionContext context) {
		log.info("Job is about to be executed: {}", context.getJobDetail().getKey());
	}

	@Override
	public void jobExecutionVetoed(JobExecutionContext context) {
		log.info("Job execution was vetoed: {}", context.getJobDetail().getKey());
	}

	@Override
	public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
		if (ObjectUtils.isEmpty(jobException)) {
			log.info("Job execution resulted in exception: {}", context.getJobDetail().getKey(), jobException);
		} else {
			log.info("Job was executed successfully: {}", context.getJobDetail().getKey());
		}
	}
}

@Slf4j
public class QuartzTriggerListener implements TriggerListener {
	@Override
	public String getName() {
		return this.getClass().getName();
	}

	@Override
	public void triggerFired(Trigger trigger, JobExecutionContext context) {
		log.info("Trigger 실행");
	}

	@Override
	public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context) {
		return false;
	}

	@Override
	public void triggerMisfired(Trigger trigger) {
		log.warn("Trigger misfired: {}", trigger.getKey());
	}

	@Override
	public void triggerComplete(Trigger trigger, JobExecutionContext context,
		Trigger.CompletedExecutionInstruction triggerInstructionCode) {
		log.info("Trigger complete: {}", trigger.getKey());
	}
}

@Slf4j
@Component
@PersistJobDataAfterExecution
@DisallowConcurrentExecution
public class QuartzJob implements Job {
	@Autowired
	private UserRepository userRepository;
	@Autowired
	private UserMetricRepository userMetricRepository;
	@Autowired
	private SlackNotificationService slackNotificationService; // 슬랙 알림

    // 수행해야는 실제 작업은 execute 메서드에 구현해야 한다.
	@Override
	public void execute(JobExecutionContext context) throws JobExecutionException {
		try {
			updateDailyUserMetrics(context);
		} catch (Exception e) {
			JobExecutionException jobException = new JobExecutionException(e);
			jobException.setUnscheduleAllTriggers(true);
			throw new JobExecutionException(e);
		}
	}

	private void updateDailyUserMetrics(JobExecutionContext context) {
		JobDataMap dataMap = context.getJobDetail().getJobDataMap();
		String dateString = dataMap.getString("date");

		if (ObjectUtils.isEmpty(dateString)) {
			throw new IllegalArgumentException("Date is required in JobDataMap");
		}

		LocalDate date = LocalDate.parse(dateString);
		LocalDateTime startOfDay = date.atStartOfDay();
		LocalDateTime endOfDay = date.plusDays(1).atStartOfDay();

		Long newUserToday = userRepository.countNewUsersByDate(startOfDay, endOfDay);
		UserMetric lastMetric = userMetricRepository.findTopByOrderByCreatedAtDesc();
		Long totalUsersYesterday = (lastMetric != null) ? lastMetric.getTotalUsers() : 0;
		Long totalUserToday = totalUsersYesterday + newUserToday;

		UserMetric existingMetric = userMetricRepository.findTopByCreatedAtBetween(startOfDay, endOfDay);
		if (ObjectUtils.isEmpty(existingMetric)) {
			slackNotificationService.sendDailyUserMetrics(date, newUserToday, totalUserToday);
			return;
		}

		UserMetric userMetric = UserMetric.of(newUserToday, totalUserToday, LocalDateTime.now());
		userMetricRepository.save(userMetric);

		slackNotificationService.sendDailyUserMetrics(date, newUserToday, totalUserToday);
	}
}

@Slf4j
@Configuration
@RequiredArgsConstructor
public class QuartzService {
	private final Scheduler scheduler;

	@PostConstruct
	public void init() throws SchedulerException {
		scheduler.clear();
		scheduler.getListenerManager().addJobListener(new QuartzJobListener());
		scheduler.getListenerManager().addTriggerListener(new QuartzTriggerListener());

		Map<String, Object> paramsMap = new HashMap<>();
		paramsMap.put("executeCount", 1);
		paramsMap.put("date", LocalDate.now().toString());

		addJob(QuartzJob.class, "UserMetricSendQuartzJob", "유저 회원가입 통계 Job 입니다.", paramsMap, "0 0 0 * * ?");

		if (!scheduler.isStarted()) {
			scheduler.start();
		}
	}

	public void addJob(Class<? extends Job> jobClass, String jobName, String jobDescription,
		Map<String, Object> jobDataMap, String cronExpression) throws SchedulerException {
		JobDetail jobDetail = buildJobDetail(jobClass, jobName, jobDescription, jobDataMap);
		Trigger trigger = buildCronTrigger(cronExpression, jobName + "Trigger");

		if (scheduler.checkExists(jobDetail.getKey())) {
			log.error("업데이트 할 Job : {}", jobDetail.getKey());
			scheduler.deleteJob(jobDetail.getKey());
		} else {
			log.error("새로운 Job 추가 : {}", jobDetail.getKey());
		}
		scheduler.scheduleJob(jobDetail, trigger);

	}

	private JobDetail buildJobDetail(Class<? extends Job> job, String name, String desc,
		Map<String, Object> paramsMap) {
		JobDataMap jobDataMap = new JobDataMap();
		jobDataMap.putAll(paramsMap);

		return JobBuilder.newJob(job)
			.withIdentity(name)
			.withDescription(desc)
			.usingJobData(jobDataMap)
			.build();
	}

	private Trigger buildCronTrigger(String cronExp, String triggerName) {
		return TriggerBuilder.newTrigger()
			.withIdentity(triggerName, "NewUserMetric")
			.withSchedule(CronScheduleBuilder.cronSchedule(cronExp))
			.build();
	}
}

@Slf4j
@Service
public class SlackNotificationService {

	@Value(value = "${slack.token}")
	private String token;
	@Value(value = "${slack.channel.welcome}")
	private String welcomeChannel;

	public void sendDailyUserMetrics(LocalDate date, Long newUsers, Long totalUsers) {
		ChatPostMessageRequest request = getSlackMetricsType(date, newUsers, totalUsers);
		sendNotification(request);
	}

	private void sendNotification(
		ChatPostMessageRequest request
	) {
		try {
			ChatPostMessageResponse response = Slack.getInstance().methods(token).chatPostMessage(request);
			SlackResponseErrorUtils.slackNotificationErrorValidate(request, response);

			//TODO response 검증 이후에도 문제가 없을때 공통 코드 필요한경우 작성할 것
		} catch (IOException e) {
			throw new RuntimeException(e + "슬랙 전송에 실패하였습니다. - IOException");
		} catch (SlackApiException e) {
			throw new RuntimeException(e + "슬랙 API 사용에 실패하였습니다. - SlackApiException");
		}
	}

	private ChatPostMessageRequest getSlackMetricsType(LocalDate date, Long newUsers, Long totalUsers) {
		List<TextObject> metricsTextBlock = new ArrayList<>();

		metricsTextBlock.add(
			markdownText(markdownBoldText("날짜:") + "\n" + markdownHighlightText(date.toString())));
		metricsTextBlock.add(
			markdownText(markdownBoldText("신규 유저 수:") + "\n" + markdownHighlightText(newUsers.toString())));
		metricsTextBlock.add(
			markdownText(markdownBoldText("전체 유저 수:") + "\n" + markdownHighlightText(totalUsers.toString())));

		return ChatPostMessageRequest.builder()
			.channel(welcomeChannel) 
			.blocks(Blocks.asBlocks(
				Blocks.header(header -> header.text(plainText("Daily User Metrics"))),
				Blocks.divider(),
				Blocks.section(section -> section.fields(metricsTextBlock))
			))
			.build();
	}

	private String markdownBoldText(String text) {
		return "*" + text + "*";
	}

	private String markdownHighlightText(String text) {
		return "`" + text + "`";
	}
}

    private SlackNotificationService slackNotificationService;
    
    // 생략 
    private void updateDailyUserMetrics(JobExecutionContext context) {
		// 생략 

		slackNotificationService.sendDailyUserMetrics(date, newUserToday, totalUserToday);
    }