Integration Options

# Create payment request for Sales Invoice
def make_payment_request(**args):
    pr = frappe.new_doc("Payment Request")
    pr.payment_gateway_account = args.get("payment_gateway_account")
    pr.reference_doctype = "Sales Invoice"
    pr.reference_name = args.get("sales_invoice")
    pr.grand_total = args.get("grand_total")
    pr.insert(ignore_permissions=True)
    pr.submit()
    
    # Send payment link via email
    pr.send_email()
    return pr

# Shopify webhook handler
@frappe.whitelist(allow_guest=True)
def shopify_webhook_handler():
    data = frappe.request.get_data(as_text=True)
    webhook_type = frappe.request.headers.get("X-Shopify-Topic")
    
    if webhook_type == "orders/create":
        create_sales_order_from_shopify(json.loads(data))
    elif webhook_type == "products/update":
        update_item_from_shopify(json.loads(data))

# erpnext/crm/doctype/email_campaign/email_campaign.py
class EmailCampaign(Document):
    def send_campaign_emails(self):
        for recipient in self.get_recipients():
            if not recipient.unsubscribed:
                self.send_email_to_recipient(recipient)
                recipient.email_sent = 1
                recipient.save()

# Configure digest settings
email_digest = frappe.get_doc({
    "doctype": "Email Digest",
    "frequency": "Weekly",
    "recipients": ["[email protected]"],
    "income_year_to_date": 1,
    "bank_balance": 1,
    "pending_sales_orders": 1,
    "pending_purchase_orders": 1
})
email_digest.insert()

from frappe.core.doctype.data_import.data_import import import_file

# Import items from CSV
import_file(
    doctype="Item",
    file_path="/path/to/items.csv",
    import_type="Insert"
)

@frappe.whitelist()
def export_report_to_excel(report_name, filters):
    from frappe.desk.query_report import run
    
    result = run(report_name, filters=filters)
    return result

# Example: Custom ERP Integration
class CustomERPConnector:
    def __init__(self, api_key, base_url):
        self.api_key = api_key
        self.base_url = base_url
    
    def sync_customers(self):
        customers = self.fetch_customers_from_api()
        for customer_data in customers:
            self.create_or_update_customer(customer_data)
    
    def fetch_customers_from_api(self):
        response = requests.get(
            f"{self.base_url}/customers",
            headers={"Authorization": f"Bearer {self.api_key}"}
        )
        return response.json()
    
    def create_or_update_customer(self, data):
        if frappe.db.exists("Customer", {"external_id": data["id"]}):
            customer = frappe.get_doc("Customer", {"external_id": data["id"]})
            customer.customer_name = data["name"]
            customer.save()
        else:
            customer = frappe.get_doc({
                "doctype": "Customer",
                "customer_name": data["name"],
                "external_id": data["id"]
            })
            customer.insert()

# hooks.py
scheduler_events = {
    "hourly": [
        "your_app.integrations.sync_with_external_system"
    ],
    "daily": [
        "your_app.integrations.sync_products",
        "your_app.integrations.sync_inventory"
    ]
}

doc_events = {
    "Sales Order": {
        "on_submit": "your_app.integrations.send_to_external_system"
    }
}