| Line 165... |
Line 165... |
| 165 |
# else:
|
165 |
# else:
|
| 166 |
# clicksMap[appDetail.appmasters.app_name] = 1
|
166 |
# clicksMap[appDetail.appmasters.app_name] = 1
|
| 167 |
# retailerMap[retailerId] = clicksMap
|
167 |
# retailerMap[retailerId] = clicksMap
|
| 168 |
|
168 |
|
| 169 |
def dumpAppTransactionsMysql():
|
169 |
def dumpAppTransactionsMysql():
|
| - |
|
170 |
newTransaction_id=''
|
| 170 |
appTransactions = get_mongo_connection().AppOrder.AppTransaction.find();
|
171 |
appTransactions = get_mongo_connection().AppOrder.AppTransaction.find();
|
| 171 |
for appTransaction in appTransactions:
|
172 |
for appTransaction in appTransactions:
|
| 172 |
app_transaction = app_transactions()
|
- |
|
| 173 |
app_transaction.retailer_id = appTransaction.get('retailer_id')
|
- |
|
| 174 |
app_transaction.app_id = appTransaction.get('app_id')
|
173 |
newTransaction_id=appTransaction.get('_id')
|
| 175 |
app_transaction.app_name=getAppName(appTransaction.get('app_id'))
|
174 |
checkAppTransaction = app_transactions.get_by(transaction_id=newTransaction_id)
|
| 176 |
app_transaction.cashback_status = appTransaction.get('cashback_status')
|
- |
|
| 177 |
app_transaction.redirect_url = appTransaction.get('redirect_url')
|
175 |
if checkAppTransaction is None:
|
| 178 |
app_transaction.cash_back_description = appTransaction.get('cash_back_description')
|
- |
|
| 179 |
app_transaction.payout_status = appTransaction.get('payout_status')
|
- |
|
| 180 |
app_transaction.overridenCashBack = appTransaction.get('overridenCashBack')
|
- |
|
| 181 |
app_transaction.isCashBackOverriden = appTransaction.get('isCashBackOverriden')
|
- |
|
| 182 |
app_transaction.transaction_time =utils.to_py_date(appTransaction.get('transaction_time'))
|
- |
|
| 183 |
if appTransaction.get('payout_time') is None:
|
176 |
print 'Inserting new record inside table'
|
| 184 |
app_transaction.payout_time = None
|
177 |
insertNewAppTransaction(appTransaction)
|
| 185 |
else:
|
178 |
else:
|
| 186 |
app_transaction.payout_time = utils.to_py_date(app_transaction.payout_time)
|
179 |
print 'In else',checkAppTransaction.payout_description
|
| 187 |
app_transaction.offer_price = appTransaction.get('offer_price')
|
180 |
if checkAppTransaction.payout_description!=appTransaction.get('payout_description'):
|
| 188 |
app_transaction.payout_amount = appTransaction.get('payout_amount')
|
181 |
print 'Need to update the record',checkAppTransaction.payout_description
|
| 189 |
app_transaction.user_payout = appTransaction.get('user_payout')
|
182 |
session.query(app_transactions).filter(app_transactions.transaction_id == newTransaction_id).update({'payout_description': appTransaction.get('payout_description'),'payout_amount':appTransaction.get('payout_amount'),'cash_back_description':appTransaction.get('cash_back_description'),'cashback_status':appTransaction.get('cashback_status'),'payout_status':appTransaction.get('payout_status')})
|
| - |
|
183 |
else:
|
| 190 |
app_transaction.payout_description = appTransaction.get('payout_description')
|
184 |
print 'Record should not be updated'
|
| 191 |
session.commit()
|
185 |
session.commit()
|
| 192 |
|
186 |
|
| - |
|
187 |
def insertNewAppTransaction(appTransaction):
|
| - |
|
188 |
app_transaction = app_transactions()
|
| - |
|
189 |
app_transaction.transaction_id=appTransaction.get('_id')
|
| - |
|
190 |
app_transaction.retailer_id = appTransaction.get('retailer_id')
|
| - |
|
191 |
app_transaction.app_id = appTransaction.get('app_id')
|
| - |
|
192 |
app_transaction.app_name=getAppName(appTransaction.get('app_id'))
|
| - |
|
193 |
app_transaction.cashback_status = appTransaction.get('cashback_status')
|
| - |
|
194 |
app_transaction.redirect_url = appTransaction.get('redirect_url')
|
| - |
|
195 |
app_transaction.cash_back_description = appTransaction.get('cash_back_description')
|
| - |
|
196 |
app_transaction.payout_status = appTransaction.get('payout_status')
|
| - |
|
197 |
app_transaction.overridenCashBack = appTransaction.get('overridenCashBack')
|
| - |
|
198 |
app_transaction.isCashBackOverriden = appTransaction.get('isCashBackOverriden')
|
| - |
|
199 |
app_transaction.transaction_time =utils.to_py_date(appTransaction.get('transaction_time'))
|
| - |
|
200 |
if appTransaction.get('payout_time') is None:
|
| - |
|
201 |
app_transaction.payout_time = None
|
| - |
|
202 |
else:
|
| - |
|
203 |
app_transaction.payout_time = utils.to_py_date(appTransaction.get('payout_time'))
|
| - |
|
204 |
app_transaction.offer_price = appTransaction.get('offer_price')
|
| - |
|
205 |
app_transaction.payout_amount = appTransaction.get('payout_amount')
|
| - |
|
206 |
app_transaction.user_payout = appTransaction.get('user_payout')
|
| - |
|
207 |
app_transaction.payout_description = appTransaction.get('payout_description')
|
| - |
|
208 |
session.commit()
|
| 193 |
|
209 |
|
| 194 |
def deleteAppTransactions():
|
210 |
def deleteAppTransactions():
|
| 195 |
try:
|
211 |
try:
|
| 196 |
session.query(app_transactions).delete()
|
212 |
session.query(app_transactions).delete()
|
| 197 |
session.commit()
|
213 |
session.commit()
|
| 198 |
except:
|
214 |
except:
|
| 199 |
session.rollback()
|
215 |
session.rollback()
|
| 200 |
|
216 |
|
| 201 |
def main():
|
217 |
def main():
|
| 202 |
#getAppTransactions()
|
218 |
#getAppTransactions()
|
| 203 |
deleteAppTransactions()
|
219 |
#deleteAppTransactions()
|
| 204 |
dumpAppTransactionsMysql()
|
220 |
dumpAppTransactionsMysql()
|
| 205 |
|
221 |
|
| 206 |
def getTime():
|
222 |
def getTime():
|
| 207 |
tdate=datetime.datetime.strftime(datetime.datetime.now(),'%Y-%m-%d')
|
223 |
tdate=datetime.datetime.strftime(datetime.datetime.now(),'%Y-%m-%d')
|
| 208 |
return tdate
|
224 |
return tdate
|
| 209 |
|
225 |
|
| 210 |
|
- |
|
| 211 |
if __name__ == '__main__':
|
226 |
if __name__ == '__main__':
|
| 212 |
main()
|
227 |
main()
|
| 213 |
session.close()
|
228 |
session.close()
|
| 214 |
|
229 |
|