Mirko 2

.gitignore

@@ -17,3 +17,4 @@ __pycache__/
 *.vscode
 reset*
 !session_config/**
+!AnonPay/payments/**

AnonPay/_builtin/__init__.py

@@ -0,0 +1,21 @@
+# Don't change anything in this file.
+from .. import models
+import otree.api
+
+
+class Page(otree.api.Page):
+    subsession: models.Subsession
+    group: models.Group
+    player: models.Player
+
+
+class WaitPage(otree.api.WaitPage):
+    subsession: models.Subsession
+    group: models.Group
+    player: models.Player
+
+
+class Bot(otree.api.Bot):
+    subsession: models.Subsession
+    group: models.Group
+    player: models.Player

AnonPay/anonpay.py

@@ -0,0 +1,143 @@
+import math, random, sys
+
+# These are the other AnonPay algorithms (ROD, NUN, SPA).
+# They must be invoked manually from within your app.
+# The remainder of this directory is the oTree equivalent of CPY+TDY.
+
+def count(l, x):
+	return sum([1 for el in l if el == x])
+
+def p_print2(paym):
+	for pi in paym:
+		print(pi, end = ", ")
+
+	print()
+
+def hadUniqPaym(paym):
+	return any([count(paym, pi) == 1 for pi in paym])
+
+def P(paym, attr, q):
+	a = sum([1 for (i, el) in enumerate(paym) if el == q and attr[i] == 1])/count(attr, 1)
+	b = sum([1 for (i, el) in enumerate(paym) if el == q and attr[i] == 0])/count(attr, 0)
+	c = count(attr, 1)/len(paym)
+
+	return (a * c)/(a * c + b * (1 - c))
+
+def infoBayes(paym, attr):
+	return {pi: P(paym, attr, pi) for pi in [_pi for (_pi, _x) in zip(paym, attr) if _x == 1]}
+
+def ROD(paym, chi):
+	for (i, pi) in enumerate(paym):
+		paym[i] = math.ceil(pi/chi)*chi
+
+	return paym
+
+def NUN(paym):
+	if len(paym) > 3:
+		s = 1
+
+		while True:
+			if s == 1:
+				rank = [sum([1 for pi2 in paym if pi2 >= pi]) for pi in paym]
+
+			if count(rank, s) > 0:
+				q = [paym[i] for (i, r) in enumerate(rank) if r == s][0]
+
+				if count(paym, q) == 1:
+					who1 = max([pi for pi in paym if pi < q], default = -math.inf)
+					who2 = min([pi for pi in paym if pi > q], default = +math.inf)
+
+					if count(paym, who1) > 0 and count(paym, who1)*(q-who1) <= who2-q:
+						for (i, pi) in enumerate(paym):
+							if pi == who1:
+								paym[i] = q
+
+								s = 0
+								break
+					else:
+						for (i, pi) in enumerate(paym):
+							if pi == q:
+								paym[i] = who2
+
+
+			s = s + 1
+
+			if s > len(paym):
+				break
+
+		return paym
+	else:
+		print("ok - few subjects, payments all equalized", file = sys.stderr)
+
+		paym = [max(paym) for _ in paym]
+
+		return paym
+
+def SPA(paym, attr, eta):
+	if eta > 0 and eta < 1 and len(paym) > 3 and count(attr, 1) > 0 and count(attr, 0) > 0:
+		s = 1
+		hadUniq = hadUniqPaym(paym)
+
+		while True:
+			if s == 1:
+				rank = [sum([1 for pi2 in paym if pi2 >= pi]) for pi in paym]
+
+			if count(rank, s) > 0:
+				q = [paym[i] for (i, r) in enumerate(rank) if r == s][0]
+
+				if count(attr, 1)/len(paym) > eta:
+					print("ERROR: too many attribute bearers, infeasible", file = sys.stderr)
+
+					break
+				else:
+					while P(paym, attr, q) > eta:
+						if any([pi < q for (i, pi) in enumerate(paym) if attr[i] == 0]) or any([pi > q for (i, pi) in enumerate(paym) if attr[i] == 0]):
+							who1 = max([pi for (i, pi) in enumerate(paym) if pi < q and attr[i] == 0], default = -math.inf)
+							who2 = min([pi for (i, pi) in enumerate(paym) if pi > q and attr[i] == 0], default = +math.inf)
+
+							c = sum([1 for (i, pi) in enumerate(paym) if pi == who1 and attr[i] == 0])
+
+							if c > 0 and c*(q-who1) <= count(paym, q)*(who2-q):
+								for (i, pi) in enumerate(paym):
+									if pi == who1 and attr[i] == 0:
+										paym[i] = q
+										break
+
+								s = 0
+								break
+							else:
+								for (i, pi) in enumerate(paym):
+									if pi == q:
+										paym[i] = who2
+
+								s = 0
+								break
+						else:
+							print(f"ERROR: no valid candidates", file = sys.stderr) # should be impossible
+							break
+
+					if s == len(paym) and not hadUniq:
+						if any([count(paym, pi) == 1 for pi in paym]):
+							paym = NUN(paym)
+							s = 0
+
+			s = s + 1
+
+			if s > len(paym):
+				break
+
+		return paym
+	elif eta <= 0 or eta >= 1:
+		print("(disabled)", file = sys.stderr)
+
+		return paym
+	elif len(paym) <= 3:
+		paym = [max(paym) for _ in paym]
+
+		print("err - few subjects, payments all equalized", file = sys.stderr)
+
+		return paym
+	else:
+		print("ok - inactive", file = sys.stderr)
+
+		return paym

AnonPay/models.py

@@ -0,0 +1,39 @@
+from otree.api import (
+    models,
+    widgets,
+    BaseConstants,
+    BaseSubsession,
+    BaseGroup,
+    BasePlayer,
+    Currency as c,
+    currency_range,
+)
+
+
+author = 'AnonPay'
+
+doc = """
+AnonPay (CPY/TDY oTree equivalent, the other algorithms are in anonpay.py)
+"""
+
+
+class Constants(BaseConstants):
+    name_in_url = 'AnonPay'
+    players_per_group = None
+    num_rounds = 1
+
+
+class Subsession(BaseSubsession):
+    pass
+
+
+class Group(BaseGroup):
+    pass
+
+
+class Player(BasePlayer):
+    error = models.StringField(initial = '')
+    email = models.StringField(initial = '')
+    emergency_code = models.StringField(initial = '')
+
+    feedback = models.LongStringField(blank = True)

AnonPay/pages.py

@@ -0,0 +1,119 @@
+from otree.api import Currency as c, currency_range
+from ._builtin import Page, WaitPage
+from .models import Constants
+
+import random, os
+
+try:
+    import fcntl
+except ModuleNotFoundError:
+    pass
+
+
+def formatNicely(amount):
+    return "{:.2f}".format(amount)
+    # return "{:.2f}".format(amount).replace('.', ',') # for EUR
+
+
+class PageWithAmount(Page):
+    #timeout_seconds = 5*60
+    def vars_for_template(self):
+        try:
+            vft = {
+                    'random_payoff': self.participant.vars['random_payoff'],
+                    'random_round_num': self.participant.vars['random_round_num'],
+                    'earned_more_than_max': self.participant.vars['earned_more_than_max'],
+                    'participation_fee': self.participant.vars['participation_fee'],
+                    'exchange_rate': self.participant.vars['exchange_rate'],
+                    'total_cash_payment_before_exchange_rate': float(self.participant.vars['payment_before_participation_fee'] / self.participant.vars['exchange_rate']),
+                    'negative_payoff': self.participant.vars['negative_payoff'],
+                    'max_payment': self.player.participant.vars['max_payment'],
+                    }
+        except:
+            vft = {
+                    'random_payoff': False,
+                    'random_round_num': 0,
+                    'earned_more_than_max': False,
+                    'participation_fee': self.participant.vars['payment'],
+                    'exchange_rate': 0,
+                    'negative_payoff': False,
+                    }
+
+        vft['emailEntered'] = self.player.email
+        vft['feedback_next_button_timeout'] = self.session.config['feedback_next_button_timeout']
+        vft['consent'] = self.player.participant.vars['consent']
+        vft['overbooked'] = self.player.participant.vars['overbooked']
+        vft['underbooked'] = self.player.participant.vars['underbooked']
+        vft['nicePayment'] = formatNicely(self.participant.vars['payment'])
+
+
+        self.player.email = '[REDACTED]'
+        return vft
+
+class Feedback(PageWithAmount):
+    def is_displayed(self):
+        return self.player.participant.vars['consent'] == True and self.player.participant.vars['overbooked'] == False and self.player.participant.vars['underbooked'] == False
+
+
+
+class Details(PageWithAmount):
+    form_fields = ['email']
+    form_model = 'player'
+
+    #timeout_seconds = 5*60
+
+    def before_next_page(self):
+        self.player.emergency_code = ''.join(random.choices(list('ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789'), k = 8))
+
+        try:
+            pfile = os.path.join(os.path.dirname(os.path.abspath(__file__)), "payments", self.session.code + ".csv")
+
+            with open(pfile, "a+") as fp:
+                try:
+                    fcntl.flock(fp, fcntl.LOCK_EX)
+                except NameError:
+                    pass
+
+                fp.seek(0)
+
+                lines = fp.read().splitlines()
+
+                player_status = ''
+
+                if self.participant.vars["consent"]:
+                    if self.participant.vars["overbooked"]:
+                        player_status = 'Overbooked'
+                    elif self.participant.vars["underbooked"]:
+                        player_status = 'Underbooked'
+                    else:
+                        player_status = 'Consented'
+                else:
+                    player_status = 'Did not consent'
+
+                lines.append(f'Email: {self.player.email}, Payment Amount: {self.participant.vars["payment"]}, {player_status}')
+
+                random.shuffle(lines)
+
+                fp.seek(0)
+                fp.truncate()
+
+                fp.write('\n'.join(lines))
+
+                try:
+                    fcntl.flock(fp, fcntl.LOCK_UN)
+                except NameError:
+                    pass
+        except:
+            # This should not happen, but if the payment file is not writable, we will write all data
+            # to the first subject's error variable.
+
+            self.group.get_players()[0].error = self.group.get_players()[0].error + "email: " + self.player.email + ", payment: " + str(self.participant.vars["payment"]) + " | "
+
+
+class FinalPage(PageWithAmount):
+    #timeout_seconds = 5*60
+    form_model = 'player'
+    form_fields = ['feedback']
+
+
+page_sequence = [Feedback, Details, FinalPage]

AnonPay/payments/.gitignore

@@ -0,0 +1,2 @@
+*
+!.gitignore

AnonPay/templates/AnonPay/Details.html

@@ -0,0 +1,52 @@
+{% extends "global/Page.html" %}
+{% load otree static %}
+
+{% block title %}
+    Auszahlungsformular
+{% endblock %}
+
+{% block content %}
+    <p>Willkommen beim Auszahlungsformular des Kölner Laboratoriums für Wirtschaftsforschung.</p>
+
+    <p>Die Verwendung dieses Formulars stellt sicher, dass Ihre Verhaltensdaten nicht mit Ihren Auszahlungsdaten verknüpft werden können.</p>
+
+    {% if negative_payoff %}
+        <p>Leider ist die Summe ihrer Gewinne aller Handelsperioden negativ, so dass ihre Auszahlung der Show-Up Fee von <b>{{ participation_fee }}</b> entspricht.</p>
+    {% elif overbooked %}
+        <p>Vielen Dank für Ihr Erscheinen und Interesse an unserem Experiment.  Typischerweise laden wir mehr Teilnehmer als nötig ein, für den Fall, dass einige nicht erscheinen oder nicht mit den Bedingungen einverstanden sind. Falls jedoch alle erscheinen und einverstanden sind, wählen wir die Personen, die an dem Experiment teilnehmen nach dem Zufallsprinzip aus. Sie wurden leider nicht für die Teilnahme an der heutigen Sitzung ausgewählt, aber da Sie pünktlich zur Sitzung erschienen sind, erhalten Sie im nächsten Schritt Ihre Show-Up Fee. Vielen Danken für Ihr Verständnis.</p>
+    {% elif underbooked %}
+        <p>Vielen Dank für Ihr Erscheinen und Interesse an unserem Experiment.  Leider sind nicht genügend Teilnehmer erschienen und mit den Bedingungen einverstanden, sodass das Experiment nicht zustande kommen kann. Da Sie aber rechtzeitig zu dieser Sitzung erschienen sind, erhalten Sie im nächsten Schritt Ihre Show-Up Fee. Vielen Dank für Ihr Verständnis.</p>
+    {% elif consent %}
+        {% if earned_more_than_max %}
+            <p>Die Summe ihrer Gewinne aller Handelsperioden ist außerordentlich hoch, so dass ihre Auszahlung dem maximalen Wert von {{max_payment}} zuzüglich Show-Up Fee von {{ participation_fee }} entspricht.</p>
+        {% else %}
+            {% if random_payoff %}
+                <p>Runde {{ random_round_num }} wurde zufällig ausgewählt. In dieser Runde haben Sie einen Gewinn von <b>{{ total_cash_payment_before_exchange_rate }} ECU</b> erzielt. Zusammen mit der Show-Up Fee ergibt dies einen Auszahlungsbetrag in der Höhe von: {{ nicePayment }} = {{ total_cash_payment_before_exchange_rate }} ECU x {{ exchange_rate}} (Wechselkurs) + {{ participation_fee }} (Show-Up Fee).</p>
+            {% else %}
+                <p>Sie haben insgesamt einen Gewinn von <b>{{ total_cash_payment_before_exchange_rate }} ECU</b> erzielt. Zusammen mit der Show-Up Fee summiert sich dies auf: {{ nicePayment }} = {{ total_cash_payment_before_exchange_rate }} ECU x {{ exchange_rate }} (Wechselkurs) + {{ participation_fee }} (Show-Up Fee).</p>
+            {% endif %}
+        {% endif %}
+    {% else %}
+        <p>Da Sie mit den Bedingungen des Experiments nicht einverstanden sind, endet das Experiment für Sie an dieser Stelle mit einer Auszahlung in Höhe der Show-Up Fee.</p>
+    {% endif %}
+
+    <p>Ihr Auszahlungsbetrag beträgt <b>€{{ nicePayment }}</b>. Damit wir die Auszahlung vornehmen können, geben Sie bitte hier Ihre Auszahlungsdaten ein.</p>
+
+    {% formfield player.email label="Ihre E-Mail-Adresse auf PayPal" %}
+
+    <script type="text/javascript">
+	    document.getElementsByName("email")[0].value = "";
+    </script>
+
+    <p>Mit dem Absenden dieses Formulars stimmen Sie den <a href="https://www.lab.uni-koeln.de/public/privacy.php" target="_new">Datenschutzbestimmungen des Kölner Laboratoriums für Wirtschaftsforschung</a> zu. Darüber hinaus erklären Sie sich damit einverstanden, dass Ihre Zahlungsdaten für die Zwecke der Zahlung verarbeitet werden dürfen. In diesem Rahmen übermitteln wir an PayPal Ihren Auszahlungsbetrag und Ihre E-Mail-Adresse. Die Datenschutzbestimmungen von PayPal finden Sie <a href="https://www.paypal.com/webapps/mpp/ua/privacy-full" target="_new">hier</a>. Ihre Verhaltensdaten werden nicht mit Ihren Auszahlungsdaten verknüpft.</p>
+
+    {% next_button %}
+
+    <audio id="my_audio" src="{% static "notification.mp3" %}"></audio>
+    <script>
+        window.onload = function() {
+            document.getElementById("my_audio").play();
+        }
+    </script>
+
+{% endblock %}