// Микросервис чеков высоконагруженного маркетплейса, десятки тысяч заказов в сутки.
// Основные функции микросервиса - и 30 - сохранение и отправка чеков в налоговую (во внешний независимый сервис)
// (Инфраструктура - Kubernetes 8 подов (реплик), высоконагруженный).
// Две независимые функции (процесса)
//                1. Сохранение в бд (Postgres) сведения о данных в чек и отправка в Налоговую - метод sendReceipt (в реальном времени).
//                2. Сохранение по расписанию (раз в час) чеков возврата - метод processJobRunning.
// TaxClient - клиент налоговой (feign) - timeout = 60 секунд (не наш, не можем повлиять)

@Service
@AllArgsConstructor
public class SomeServiceImpl implements Someservice {
    private final TaxClient taxClient;
    private final ReceiptDao receiptDao;
    private final ReceiptTypeDao receiptTypeDao;

    private final ReceiptMapper mapper;
    private final ReceiptTypeMapper typeMapper;
    private final RefundReceiptMapper refundReceiptMapper;
    private final SomeService self;

    @Scheduled(cron = ""${cron.expression}"") // ""30 30 * * *""
    public void processJobRunning() {
        List<Receipt> receipts = getRefundReceipts();

        for (Receipt receipt : receipts) {
            receipt.setProcessed(true);
            eventListener.sendEventToAnalytics(new SomeEvent(receipt.getId()); //send simple event, using org.springframework.context.event, idempotent
            receiptDao.save(mapReceipt(mapper.map(receipt)));
        }
    }

    @Transactional(readOnly = true)
    public List<Receipt> getRefundReceipts() {
        return receiptDao.findAllBySourceAndProcessedFalse(ReceiptSource.REFUND); // select * from receipt where source = 'REFUNC' and processed = false;
    }

    private Receipt mapReceipt(ReceiptDto receiptDto) {
        return mapper.map(receiptDto);
    }

    //приходит http-запрос из другого микросервиса
    public void sendReceipt(ReceiptDto receiptDto) {
        ReceiptSource source = self.getReceiptSource(receiptDto);
        taxClient.sendReceipt(receiptDto, source);
    }

    @Transactional
    @Cacheable(value = ""receipt_type"", cacheManager = ""redisCacheManager"") // по сути работает как hashMap
    public ReceiptSource getReceiptSource(ReceiptDto receiptDto) {
        Receipt receipt = receiptDao.findById(receiptDto.getId());
        ReceiptSource source = receipt.getSource();
        return source;
    }
}


// граница класса ----
public interface ReceiptDao extends JpaRepository<Receipt, Long> {
    List<Receipt> findAllBySourceAndProcessedFalse(ReceiptSource source);
}

//тут все корректно - для наглядности - mapstruct
@Mapper(componentModel = SPRING)
public interface ReceiptMapper {
    Receipt map(ReceiptDto dto);
    ReceiptDto map(Receipt receipt);
}

// граница класса ----
// тут все корректно - dto для наглядности
public enum ReceiptSource {
    DISCOUNT,
    SELL,
    REFUND
}

// граница класса ----
//тут все корректно - dto для наглядности
@Data
@NoArgsConstructor
public class ReceiptDto {
    private Long id;
    private String address;
    private String sum;
    private ReceiptSource source;
}

// граница класса ----
//тут все корректно - entity для наглядности
//@Data
@Entity
@ALLArgsConstructor
@NoArgsConstructor
@Data
public class Receipt {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private boolean processed;
    private String address;
    private String sum;
    private ReceiptSource source;
}