package org.springblade.mdm.machineback.filewatch;

import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;

import java.io.File;
import java.lang.management.ManagementFactory;


@Slf4j
@AllArgsConstructor
@Service
public class DirectorLockService {
	private final JdbcTemplate jdbcTemplate;

	public boolean acquireLock() {
		int affect = 0;
		try {
			affect = jdbcTemplate.update(
				"INSERT INTO mdm_file_locks (lock_id,locked_by, lock_time) " +
					"VALUES (1,?, CURRENT_TIMESTAMP)",getInstanceId());
		} catch (Exception e) {
			log.info("文件锁定失败，不进行目录监控",e);
		}
		return affect > 0;
	}

	public void releaseLock() {
		jdbcTemplate.update(
			"DELETE FROM mdm_file_locks");
	}

	private String getInstanceId() {
		// 返回当前实例的唯一标识
		return ManagementFactory.getRuntimeMXBean().getName();
	}

}