help_friends.java

@Override
public void savePaymentStatus(String paymentId, AcquiringResponse.PaymentStatus paymentStatus) {
  pmcRedisTemplate.execute(new SessionCallback<Void>(){
    @Override
    public Void execute(RedisOperations operations) throws DataAccessException {
      operations.watch(paymentId);
      if (!findPaymentStatusByPaymentId(paymentId).isPresent()) {
        operations.multi();
        updatePaymentStatus(paymentId, paymentStatus.getValue());
        operations.exec();
        logger.debug("Saving status {} of payment id {} success", paymentStatus.getValue(), paymentId);
      } else {
        logger.debug("Payment id {} is already in redis", paymentId);
      }
      return null;
    }
  });

}