| Line 2827... |
Line 2827... |
| 2827 |
get_mongo_connection().Dtr.crmrefundwallet.update({'_id':ObjectId(_id),},{"$set":{"status":status,"update_timestamp":to_java_date(datetime.now())}})
|
2827 |
get_mongo_connection().Dtr.crmrefundwallet.update({'_id':ObjectId(_id),},{"$set":{"status":status,"update_timestamp":to_java_date(datetime.now())}})
|
| 2828 |
else:
|
2828 |
else:
|
| 2829 |
get_mongo_connection().Dtr.crmrefundwallet.update({'_id':ObjectId(_id),},{"$set":{"status":status,"update_timestamp":to_java_date(datetime.now()),"batchId":batchId,"approved_by":approvedBy}})
|
2829 |
get_mongo_connection().Dtr.crmrefundwallet.update({'_id':ObjectId(_id),},{"$set":{"status":status,"update_timestamp":to_java_date(datetime.now()),"batchId":batchId,"approved_by":approvedBy}})
|
| 2830 |
|
2830 |
|
| 2831 |
def fetchCrmRefundUsers(status,offset,limit):
|
2831 |
def fetchCrmRefundUsers(status,offset,limit):
|
| - |
|
2832 |
if status is not None:
|
| 2832 |
cursor = list(get_mongo_connection().Dtr.crmrefundwallet.find({"status":status}).skip(offset).limit(limit).sort("created_timestamp",-1))
|
2833 |
cursor = list(get_mongo_connection().Dtr.crmrefundwallet.find({"status":status}).skip(offset).limit(limit).sort("created_timestamp",-1))
|
| - |
|
2834 |
else:
|
| - |
|
2835 |
cursor = list(get_mongo_connection().Dtr.crmrefundwallet.find().skip(offset).limit(limit).sort("created_timestamp",-1))
|
| 2833 |
return cursor
|
2836 |
return cursor
|
| 2834 |
|
2837 |
|
| 2835 |
def fetchCrmRefundByBatchId(batchId):
|
2838 |
def fetchCrmRefundByBatchId(batchId):
|
| 2836 |
cursor = get_mongo_connection().Dtr.crmrefundwallet.find_one({"batchId":int(batchId)})
|
2839 |
cursor = get_mongo_connection().Dtr.crmrefundwallet.find_one({"batchId":int(batchId)})
|
| 2837 |
return cursor
|
2840 |
return cursor
|