nllsdfx · March 23, 2026 08:01
diff --git a/Employment.java b/Employment.java
 /**
   * Создает новую сущность Employment на основе приглашения.
   *
   * @param invite    приглашение, на основе которого создается занятость
   * @param now       текущее время
   * @param versionId идентификатор версии
   * @return новая сущность Employment
   */
  @NonNull
  public static Employment createFromInvite(@NonNull Invite invite,
      @NonNull Instant now,
      @NonNull Long versionId) {

    Employment employment = new Employment();
    employment.setEmployee(invite.getEmployee());
    employment.setClientProfile(invite.getClientProfile());
    employment.setExpirationDate(invite.getInviteDetail().getExpirationDate());
    employment.setCreatedAt(now);
    employment.setUpdatedAt(now);

    EmploymentStatus status = EmploymentStatus.builder()
        .createdAt(now)
        .employment(employment)
        .typeId(EmploymentStatusTypeName.AWAITING_APPLICATION_APPROVAL.getId())
        .build();
    employment.statuses.add(status);

    var version = EmploymentVersion.createNewVersion(employment,
        EmploymentRoleCreatorName.EMPLOYEE.getId(), now, versionId,
        invite);
    employment.versions.add(version);

    return employment;
  }
diff --git a/EmploymentCreationService.java b/EmploymentCreationService.java
 /**
 * Сервис создания записей занятости (Employment) на основе инвайта.
 */
 public interface EmploymentCreationService {

  /**
   * Создаёт запись Employment на основе переданного инвайта.
   *
   * @param invite инвайт, на основе которого создаётся Employment
   * @return идентификатор созданной записи Employment
   */
  @NonNull
  Long createFromInvite(@NonNull Invite invite);
 }
diff --git a/EmploymentCreationServiceImpl.java b/EmploymentCreationServiceImpl.java

 /**
 * {@inheritDoc}
 */
 @Service
 @RequiredArgsConstructor
 class EmploymentCreationServiceImpl implements EmploymentCreationService {

  private final DateTimeService dateTimeService;
  private final SequenceGenerator sequenceGenerator;
  private final EmploymentApplicationService applicationService;
  private final EmploymentRepository repository;
  private final EmploymentExportService employmentExportService;

  @Override
  @Transactional
  public @NonNull Long createFromInvite(@NonNull Invite invite) {
    var now = dateTimeService.nowInstant();

    var versionId = sequenceGenerator.getNextSequence(
        SequenceGenerator.EMPLOYMENT_VERSION_SEQUENCE);

    var employment = Employment.createFromInvite(invite, now, versionId);
    employment = repository.save(employment);

    applicationService.createApplicationFromEmployment(employment.getId(), now);

    // Экспортируем сведения о трудоустройстве через outbox
    employmentExportService.exportEmployment(employment, invite.getId());

    return employment.getId();
  }
 }
diff --git a/EmploymentExportServiceImpl.java b/EmploymentExportServiceImpl.java
 @Service
 @RequiredArgsConstructor
 class EmploymentExportServiceImpl implements EmploymentExportService {

  private final KafkaTopicsProperties kafkaTopicsProperties;
  private final TemporaryTextStorageService temporaryTextStorageService;
  private final OutboxService outboxService;
  private final EmploymentMessageMapper employmentMessageMapper;


  @Override
  @Transactional
  public void exportEmployment(@NonNull Employment employment, @NonNull Long inviteId) {

    Short statusId = employment.getStatuses().stream()
        .max(Comparator.comparing(EmploymentStatus::getCreatedAt))
        .map(EmploymentStatus::getTypeId)
        .orElseThrow();

    EmploymentVersion activeVersion = employment.getVersions().stream()
        .filter(v -> Boolean.TRUE.equals(v.getActive()))
        .findFirst()
        .orElseThrow();

    EmploymentPosition position = activeVersion.getPositions().stream().findFirst()
        .orElseThrow();

    EmploymentSalary salary = activeVersion.getSalaries().stream().findFirst()
        .orElseThrow();

    EmploymentConditions conditions = activeVersion.getConditions().stream().findFirst()
        .orElseThrow();

    EmploymentMessage message = employmentMessageMapper.toMessage(
        employment,
        statusId,
        activeVersion,
        position,
        salary,
        conditions,
        inviteId
    );

    TemporaryTextData textData = temporaryTextStorageService.saveData(message);
    var kafkaData = new SendKafkaData(kafkaTopicsProperties.getEmployment(),
        employment.getId().toString());
    outboxService.createOutbox(SEND_TO_KAFKA.getId(), kafkaData, textData);
  }
 }
diff --git a/InviteApi.java b/InviteApi.java
 @Generated(value = "org.openapitools.codegen.languages.SpringCodegen", date = "2025-10-22T14:08:34.831722+03:00[Europe/Moscow]", comments = "Generator version: 7.13.0")
 @Validated
 public interface InviteApi {

    /**
     * GET /api/v1/invite/{invite_id} : Получение инвайта
     * Получение инвайта по ID 
     *
     * @param inviteId Внутренний идентификатор инвайта (required)
     * @return Успешное получение информации об инвайте (status code 200)
     *         or Неверные входные данные (status code 400)
     *         or Неавторизованный доступ (status code 401)
     *         or Нет доступа (status code 403)
     */
    @RequestMapping(
        method = RequestMethod.GET,
        value = "/api/v1/invite/{invite_id}",
        produces = { "application/json" }
    )
    
    ResponseEntity<GetInviteById200Response> getInviteById(
        @Min(1L)  @PathVariable("invite_id") Long inviteId
    );


    /**
     * GET /api/v1/invites : Получение списка инвайтов
     * Получение списка инвайтов сотрудника 
     *
     * @return Успешное получение информации об инвайтах (status code 200)
     *         or Ошибка авторизации (status code 401)
     */
    @RequestMapping(
        method = RequestMethod.GET,
        value = "/api/v1/invites",
        produces = { "application/json" }
    )
    
    ResponseEntity<GetInvites200Response> getInvites(
        final Pageable pageable
    );


    /**
     * PATCH /api/v1/invite/{invite_id} : Отправка инвайта повторно или отзыв
     * Отправка инвайта повторно или отзыв 
     *
     * @param inviteId Внутренний идентификатор инвайта (required)
     * @param patchInviteStatusRequest  (required)
     * @return Успешное изменение статуса инвайта (status code 200)
     *         or Неверные входные данные (status code 400)
     *         or Неавторизованный доступ (status code 401)
     *         or Нет доступа (status code 403)
     */
    @RequestMapping(
        method = RequestMethod.PATCH,
        value = "/api/v1/invite/{invite_id}",
        produces = { "application/json" },
        consumes = { "application/json" }
    )
    
    ResponseEntity<PatchInviteStatus200Response> patchInviteStatus(
        @Min(1L)  @PathVariable("invite_id") Long inviteId,
         @Valid @RequestBody PatchInviteStatusRequest patchInviteStatusRequest
    );

 }
diff --git a/InviteController.java b/InviteController.java
 /**
 * Контроллер для работы с инвайтами пользователя. Предоставляет REST API для получения информации
 * об инвайтах.
 */
 @RestController
 @RequiredArgsConstructor
 public class InviteController implements InviteApi {

  private final InviteService inviteService;
  private final InviteMapper inviteMapper;
  private final AuthService authService;

  /**
   * Получить инвайт по ID.
   */
  @Override
  public ResponseEntity<GetInviteById200Response> getInviteById(Long inviteId) {
    var userId = authService.getCurrentUserId();
    return ResponseEntity.ok(
        inviteMapper.mapInviteById(inviteService.findByInviteIdAndEmployeeId(inviteId, userId)));
  }

  /**
   * Получить список всех инвайтов пользователя.
   */
  @Override
  public ResponseEntity<GetInvites200Response> getInvites(Pageable pageable) {
    var userId = authService.getCurrentUserId();
    var invites = inviteService.getAllInvites(userId, pageable);
    return ResponseEntity.ok(inviteMapper.mapInvitesListInner(invites));
  }

  /**
   * Обновить статус инвайта.
   */
  @Override
  public ResponseEntity<PatchInviteStatus200Response> patchInviteStatus(Long inviteId,
      PatchInviteStatusRequest patchInviteByIdRequest) {
    var userId = authService.getCurrentUserId();
    var patchedInviteId = inviteService.patchInviteStatus(
        inviteId,
        userId,
        inviteMapper.mapInviteStatus(patchInviteByIdRequest.getStatus()));
    return ResponseEntity.ok(inviteMapper.mapInviteIdToPatchInviteStatusDto(patchedInviteId));
  }
 }
diff --git a/junie.md b/junie.md
	/**
	* Создает новую сущность Employment на основе приглашения.
	*
	* @param invite приглашение, на основе которого создается занятость
	* @param now текущее время
	* @param versionId идентификатор версии
	* @return новая сущность Employment
	*/
	@NonNull
	public static Employment createFromInvite(@NonNull Invite invite,
	@NonNull Instant now,
	@NonNull Long versionId) {

	Employment employment = new Employment();
	employment.setEmployee(invite.getEmployee());
	employment.setClientProfile(invite.getClientProfile());
	employment.setExpirationDate(invite.getInviteDetail().getExpirationDate());
	employment.setCreatedAt(now);
	employment.setUpdatedAt(now);

	EmploymentStatus status = EmploymentStatus.builder()
	.createdAt(now)
	.employment(employment)
	.typeId(EmploymentStatusTypeName.AWAITING_APPLICATION_APPROVAL.getId())
	.build();
	employment.statuses.add(status);

	var version = EmploymentVersion.createNewVersion(employment,
	EmploymentRoleCreatorName.EMPLOYEE.getId(), now, versionId,
	invite);
	employment.versions.add(version);

	return employment;
	}
	/**
	* Сервис создания записей занятости (Employment) на основе инвайта.
	*/
	public interface EmploymentCreationService {

	/**
	* Создаёт запись Employment на основе переданного инвайта.
	*
	* @param invite инвайт, на основе которого создаётся Employment
	* @return идентификатор созданной записи Employment
	*/
	@NonNull
	Long createFromInvite(@NonNull Invite invite);
	}

	/**
	* {@inheritDoc}
	*/
	@Service
	@RequiredArgsConstructor
	class EmploymentCreationServiceImpl implements EmploymentCreationService {

	private final DateTimeService dateTimeService;
	private final SequenceGenerator sequenceGenerator;
	private final EmploymentApplicationService applicationService;
	private final EmploymentRepository repository;
	private final EmploymentExportService employmentExportService;

	@Override
	@Transactional
	public @NonNull Long createFromInvite(@NonNull Invite invite) {
	var now = dateTimeService.nowInstant();

	var versionId = sequenceGenerator.getNextSequence(
	SequenceGenerator.EMPLOYMENT_VERSION_SEQUENCE);

	var employment = Employment.createFromInvite(invite, now, versionId);
	employment = repository.save(employment);

	applicationService.createApplicationFromEmployment(employment.getId(), now);

	// Экспортируем сведения о трудоустройстве через outbox
	employmentExportService.exportEmployment(employment, invite.getId());

	return employment.getId();
	}
	}
	@Service
	@RequiredArgsConstructor
	class EmploymentExportServiceImpl implements EmploymentExportService {

	private final KafkaTopicsProperties kafkaTopicsProperties;
	private final TemporaryTextStorageService temporaryTextStorageService;
	private final OutboxService outboxService;
	private final EmploymentMessageMapper employmentMessageMapper;


	@Override
	@Transactional
	public void exportEmployment(@NonNull Employment employment, @NonNull Long inviteId) {

	Short statusId = employment.getStatuses().stream()
	.max(Comparator.comparing(EmploymentStatus::getCreatedAt))
	.map(EmploymentStatus::getTypeId)
	.orElseThrow();

	EmploymentVersion activeVersion = employment.getVersions().stream()
	.filter(v -> Boolean.TRUE.equals(v.getActive()))
	.findFirst()
	.orElseThrow();

	EmploymentPosition position = activeVersion.getPositions().stream().findFirst()
	.orElseThrow();

	EmploymentSalary salary = activeVersion.getSalaries().stream().findFirst()
	.orElseThrow();

	EmploymentConditions conditions = activeVersion.getConditions().stream().findFirst()
	.orElseThrow();

	EmploymentMessage message = employmentMessageMapper.toMessage(
	employment,
	statusId,
	activeVersion,
	position,
	salary,
	conditions,
	inviteId
	);

	TemporaryTextData textData = temporaryTextStorageService.saveData(message);
	var kafkaData = new SendKafkaData(kafkaTopicsProperties.getEmployment(),
	employment.getId().toString());
	outboxService.createOutbox(SEND_TO_KAFKA.getId(), kafkaData, textData);
	}
	}
	@Generated(value = "org.openapitools.codegen.languages.SpringCodegen", date = "2025-10-22T14:08:34.831722+03:00[Europe/Moscow]", comments = "Generator version: 7.13.0")
	@Validated
	public interface InviteApi {

	/**
	* GET /api/v1/invite/{invite_id} : Получение инвайта
	* Получение инвайта по ID
	*
	* @param inviteId Внутренний идентификатор инвайта (required)
	* @return Успешное получение информации об инвайте (status code 200)
	* or Неверные входные данные (status code 400)
	* or Неавторизованный доступ (status code 401)
	* or Нет доступа (status code 403)
	*/
	@RequestMapping(
	method = RequestMethod.GET,
	value = "/api/v1/invite/{invite_id}",
	produces = { "application/json" }
	)

	ResponseEntity<GetInviteById200Response> getInviteById(
	@Min(1L) @PathVariable("invite_id") Long inviteId
	);


	/**
	* GET /api/v1/invites : Получение списка инвайтов
	* Получение списка инвайтов сотрудника
	*
	* @return Успешное получение информации об инвайтах (status code 200)
	* or Ошибка авторизации (status code 401)
	*/
	@RequestMapping(
	method = RequestMethod.GET,
	value = "/api/v1/invites",
	produces = { "application/json" }
	)

	ResponseEntity<GetInvites200Response> getInvites(
	final Pageable pageable
	);


	/**
	* PATCH /api/v1/invite/{invite_id} : Отправка инвайта повторно или отзыв
	* Отправка инвайта повторно или отзыв
	*
	* @param inviteId Внутренний идентификатор инвайта (required)
	* @param patchInviteStatusRequest (required)
	* @return Успешное изменение статуса инвайта (status code 200)
	* or Неверные входные данные (status code 400)
	* or Неавторизованный доступ (status code 401)
	* or Нет доступа (status code 403)
	*/
	@RequestMapping(
	method = RequestMethod.PATCH,
	value = "/api/v1/invite/{invite_id}",
	produces = { "application/json" },
	consumes = { "application/json" }
	)

	ResponseEntity<PatchInviteStatus200Response> patchInviteStatus(
	@Min(1L) @PathVariable("invite_id") Long inviteId,
	@Valid @RequestBody PatchInviteStatusRequest patchInviteStatusRequest
	);

	}
	/**
	* Контроллер для работы с инвайтами пользователя. Предоставляет REST API для получения информации
	* об инвайтах.
	*/
	@RestController
	@RequiredArgsConstructor
	public class InviteController implements InviteApi {

	private final InviteService inviteService;
	private final InviteMapper inviteMapper;
	private final AuthService authService;

	/**
	* Получить инвайт по ID.
	*/
	@Override
	public ResponseEntity<GetInviteById200Response> getInviteById(Long inviteId) {
	var userId = authService.getCurrentUserId();
	return ResponseEntity.ok(
	inviteMapper.mapInviteById(inviteService.findByInviteIdAndEmployeeId(inviteId, userId)));
	}

	/**
	* Получить список всех инвайтов пользователя.
	*/
	@Override
	public ResponseEntity<GetInvites200Response> getInvites(Pageable pageable) {
	var userId = authService.getCurrentUserId();
	var invites = inviteService.getAllInvites(userId, pageable);
	return ResponseEntity.ok(inviteMapper.mapInvitesListInner(invites));
	}

	/**
	* Обновить статус инвайта.
	*/
	@Override
	public ResponseEntity<PatchInviteStatus200Response> patchInviteStatus(Long inviteId,
	PatchInviteStatusRequest patchInviteByIdRequest) {
	var userId = authService.getCurrentUserId();
	var patchedInviteId = inviteService.patchInviteStatus(
	inviteId,
	userId,
	inviteMapper.mapInviteStatus(patchInviteByIdRequest.getStatus()));
	return ResponseEntity.ok(inviteMapper.mapInviteIdToPatchInviteStatusDto(patchedInviteId));
	}
	}