db69de1c11
Some checks failed
Frontend / Unit Tests & Coverage (push) Has been skipped
Regenerate POT file (translatable strings) / Regenerate POT file (develop) (push) Failing after 1m13s
Regenerate POT file (translatable strings) / Regenerate POT file (main-hotfix) (push) Failing after 6s
Server / Tests (frappe ${{ matrix.frappe-branch }}) (push) Has been skipped
Server / Resolve frappe matrix (push) Failing after 1s
Frontend / Lint (push) Failing after 1s
Frontend / Production Build (push) Failing after 1s
Server / Coverage Wrap Up (push) Has been skipped
Frontend / Coverage Wrap Up (push) Has been skipped
70 lines
2.0 KiB
Python
70 lines
2.0 KiB
Python
import frappe
|
|
from frappe.query_builder import Order
|
|
|
|
|
|
@frappe.whitelist()
|
|
def get_notifications():
|
|
Notification = frappe.qb.DocType("CRM Notification")
|
|
query = (
|
|
frappe.qb.from_(Notification)
|
|
.select("*")
|
|
.where(Notification.to_user == frappe.session.user)
|
|
.orderby("creation", order=Order.desc)
|
|
)
|
|
notifications = query.run(as_dict=True)
|
|
|
|
_notifications = []
|
|
for notification in notifications:
|
|
_notifications.append(
|
|
{
|
|
"creation": notification.creation,
|
|
"from_user": {
|
|
"name": notification.from_user,
|
|
"full_name": frappe.get_value("User", notification.from_user, "full_name"),
|
|
},
|
|
"type": notification.type,
|
|
"to_user": notification.to_user,
|
|
"read": notification.read,
|
|
"hash": get_hash(notification),
|
|
"notification_text": notification.notification_text,
|
|
"notification_type_doctype": notification.notification_type_doctype,
|
|
"notification_type_doc": notification.notification_type_doc,
|
|
"reference_doctype": ("deal" if notification.reference_doctype == "CRM Deal" else "lead"),
|
|
"reference_name": notification.reference_name,
|
|
"route_name": ("Deal" if notification.reference_doctype == "CRM Deal" else "Lead"),
|
|
}
|
|
)
|
|
|
|
return _notifications
|
|
|
|
|
|
@frappe.whitelist()
|
|
def mark_as_read(doc: str | None = None):
|
|
user = frappe.session.user
|
|
filters = {"to_user": user, "read": False}
|
|
or_filters = []
|
|
if doc:
|
|
or_filters = [
|
|
{"comment": doc},
|
|
{"notification_type_doc": doc},
|
|
]
|
|
for n in frappe.get_all("CRM Notification", filters=filters, or_filters=or_filters):
|
|
d = frappe.get_doc("CRM Notification", n.name)
|
|
d.read = True
|
|
d.save()
|
|
|
|
|
|
def get_hash(notification):
|
|
_hash = ""
|
|
if notification.type == "Mention" and notification.notification_type_doc:
|
|
_hash = "#" + notification.notification_type_doc
|
|
|
|
if notification.type == "WhatsApp":
|
|
_hash = "#whatsapp"
|
|
|
|
if notification.type == "Assignment" and notification.notification_type_doctype == "CRM Task":
|
|
_hash = "#tasks"
|
|
if "has been removed by" in notification.message:
|
|
_hash = ""
|
|
return _hash
|