select_pendingRes[0][1]
This commit is contained in:
@@ -143,8 +143,19 @@ def hello_world():
|
|||||||
|
|
||||||
@app.route("/test/calendar")
|
@app.route("/test/calendar")
|
||||||
def test_calen():
|
def test_calen():
|
||||||
print("aameye yesy poimt")
|
SELECT_LAST_ENTRY = f"SELECT id, uid AS product_uid FROM members_products WHERE internal_url='23607.devprov.mermsemr.com'"
|
||||||
print(initial_product_url)
|
print(SELECT_LAST_ENTRY)
|
||||||
|
with connection:
|
||||||
|
with connection.cursor(cursor_factory=psycopg2.extras.DictCursor) as cursor:
|
||||||
|
cursor.execute(SELECT_LAST_ENTRY)
|
||||||
|
select_pendingRes = cursor.fetchall()
|
||||||
|
|
||||||
|
print(select_pendingRes)
|
||||||
|
myproduct_data = json.dumps( [dict(ix) for ix in select_pendingRes] )
|
||||||
|
print(myproduct_data)
|
||||||
|
print(select_pendingRes[0][0])
|
||||||
|
print(select_pendingRes[0][1])
|
||||||
|
|
||||||
dList = []
|
dList = []
|
||||||
sample_range = random.randint(20, 60)
|
sample_range = random.randint(20, 60)
|
||||||
for x in range(sample_range):
|
for x in range(sample_range):
|
||||||
@@ -853,20 +864,17 @@ def subscription_start(current_user):
|
|||||||
cursor.execute(INSERT_NEW_PRODUCT,val_insert)
|
cursor.execute(INSERT_NEW_PRODUCT,val_insert)
|
||||||
|
|
||||||
SELECT_LAST_ENTRY = f"SELECT id, uid AS product_uid FROM members_products WHERE internal_url='{internal_url}'"
|
SELECT_LAST_ENTRY = f"SELECT id, uid AS product_uid FROM members_products WHERE internal_url='{internal_url}'"
|
||||||
|
|
||||||
print(SELECT_LAST_ENTRY)
|
print(SELECT_LAST_ENTRY)
|
||||||
with connection:
|
with connection:
|
||||||
with connection.cursor(cursor_factory=psycopg2.extras.DictCursor) as cursor:
|
with connection.cursor(cursor_factory=psycopg2.extras.DictCursor) as cursor:
|
||||||
cursor.execute(SELECT_LAST_ENTRY)
|
cursor.execute(SELECT_LAST_ENTRY)
|
||||||
select_pendingRes = cursor.fetchall()
|
select_pendingRes = cursor.fetchall()
|
||||||
|
# Assume data is there
|
||||||
print(select_pendingRes)
|
print(select_pendingRes)
|
||||||
myproduct_data = json.dumps( [dict(ix) for ix in select_pendingRes] )
|
print(select_pendingRes[0][0])
|
||||||
print(myproduct_data)
|
print(select_pendingRes[0][1])
|
||||||
|
addProvisionAction(member_id,select_pendingRes[0][1],'Started initial provision - '+ internal_url)
|
||||||
|
|
||||||
print(myproduct_data[0]['product_uid'])
|
|
||||||
addProvisionAction(member_id,myproduct_data[0]['product_uid'],'Started initial provision - '+ internal_url)
|
|
||||||
# myproduct_data = []
|
|
||||||
return jsonify(myproduct_data=myproduct_data)
|
return jsonify(myproduct_data=myproduct_data)
|
||||||
|
|
||||||
def addProvisionAction(member_id,product_uid,action):
|
def addProvisionAction(member_id,product_uid,action):
|
||||||
|
|||||||
Reference in New Issue
Block a user