Compare commits
No commits in common. "bbb9ce8487f0cc41981d91fff15fc7263ff55e2d" and "097f0633f5edc002fa14675a88a6f0d72149a384" have entirely different histories.
bbb9ce8487
...
097f0633f5
@ -101,7 +101,7 @@ async def get_contacts(
|
||||
{where_sql}
|
||||
GROUP BY c.id, c.first_name, c.last_name, c.email, c.phone, c.mobile,
|
||||
c.title, c.department, c.is_active, c.created_at, c.updated_at
|
||||
ORDER BY company_count DESC, c.last_name, c.first_name
|
||||
ORDER BY c.first_name, c.last_name
|
||||
LIMIT %s OFFSET %s
|
||||
"""
|
||||
params.extend([limit, offset])
|
||||
|
||||
@ -1,33 +1,6 @@
|
||||
"""
|
||||
System Sync Router
|
||||
API endpoints for syncing data between vTiger, e-conomic and Hub
|
||||
|
||||
SYNC ARCHITECTURE - Field Ownership:
|
||||
=====================================
|
||||
|
||||
E-CONOMIC owns and syncs:
|
||||
- economic_customer_number (primary key from e-conomic)
|
||||
- address, city, postal_code, country (physical address)
|
||||
- email_domain, website (contact information)
|
||||
- cvr_number (used for matching only, not overwritten if already set)
|
||||
|
||||
vTIGER owns and syncs:
|
||||
- vtiger_id (primary key from vTiger)
|
||||
- vtiger_account_no
|
||||
- Contact records and contact-company relationships
|
||||
|
||||
HUB owns (manual or first-sync only):
|
||||
- name (can be synced initially but not overwritten)
|
||||
- cvr_number (used for matching, set once)
|
||||
- Tags, notes, custom fields
|
||||
|
||||
SYNC RULES:
|
||||
===========
|
||||
1. NEVER overwrite source ID if already set (vtiger_id, economic_customer_number)
|
||||
2. Match order: CVR → Source ID → Name (normalized)
|
||||
3. Re-sync is idempotent - can run multiple times safely
|
||||
4. Contact relationships are REPLACED on sync (not added)
|
||||
5. Each sync only updates fields it owns
|
||||
"""
|
||||
|
||||
import logging
|
||||
@ -151,7 +124,6 @@ async def sync_from_vtiger() -> Dict[str, Any]:
|
||||
continue
|
||||
|
||||
if current_vtiger_id is None:
|
||||
# Only set vtiger_id if it's currently NULL
|
||||
execute_query(
|
||||
"UPDATE customers SET vtiger_id = %s, last_synced_at = NOW() WHERE id = %s",
|
||||
(vtiger_id, existing[0]['id'])
|
||||
@ -159,10 +131,13 @@ async def sync_from_vtiger() -> Dict[str, Any]:
|
||||
linked_count += 1
|
||||
logger.info(f"🔗 Linket: {existing[0]['name']} → vTiger #{vtiger_id} (match: {match_method}, CVR: {cvr or 'ingen'})")
|
||||
elif current_vtiger_id != vtiger_id:
|
||||
# SKIP if different vTiger ID - do NOT overwrite existing vtiger_id
|
||||
logger.warning(f"⚠️ Springer over: {existing[0]['name']} har allerede vTiger #{current_vtiger_id}, vil ikke overskrive med #{vtiger_id}")
|
||||
not_found_count += 1
|
||||
continue
|
||||
# Update if different vTiger ID
|
||||
execute_query(
|
||||
"UPDATE customers SET vtiger_id = %s, last_synced_at = NOW() WHERE id = %s",
|
||||
(vtiger_id, existing[0]['id'])
|
||||
)
|
||||
updated_count += 1
|
||||
logger.info(f"✏️ Opdateret vTiger ID: {existing[0]['name']} → {vtiger_id} (var: {current_vtiger_id})")
|
||||
else:
|
||||
# Already linked, just update timestamp
|
||||
execute_query("UPDATE customers SET last_synced_at = NOW() WHERE id = %s", (existing[0]['id'],))
|
||||
@ -411,14 +386,19 @@ async def sync_vtiger_contacts() -> Dict[str, Any]:
|
||||
customer_id = customer_result[0]['id']
|
||||
customer_name = customer_result[0]['name']
|
||||
|
||||
# DELETE existing links for this contact (we replace, not append)
|
||||
# This ensures re-sync updates links to match current vTiger state
|
||||
execute_query(
|
||||
"DELETE FROM contact_companies WHERE contact_id = %s",
|
||||
(contact_id,)
|
||||
# Check if link already exists
|
||||
existing_link = execute_query(
|
||||
"SELECT id FROM contact_companies WHERE contact_id = %s AND customer_id = %s",
|
||||
(contact_id, customer_id)
|
||||
)
|
||||
|
||||
# CREATE new link from vTiger
|
||||
if existing_link:
|
||||
# Already linked
|
||||
if debug_count <= 20:
|
||||
logger.warning(f" ↳ Already linked to '{customer_name}'")
|
||||
continue
|
||||
|
||||
# CREATE LINK
|
||||
execute_query(
|
||||
"INSERT INTO contact_companies (contact_id, customer_id, is_primary) VALUES (%s, %s, false)",
|
||||
(contact_id, customer_id)
|
||||
@ -522,13 +502,13 @@ async def sync_from_economic() -> Dict[str, Any]:
|
||||
)
|
||||
|
||||
if existing:
|
||||
# Update existing customer - ONLY update fields e-conomic owns
|
||||
# E-conomic does NOT overwrite: name, cvr_number (set once only)
|
||||
# Update existing customer (always sync economic_customer_number from e-conomic)
|
||||
update_query = """
|
||||
UPDATE customers SET
|
||||
name = %s,
|
||||
economic_customer_number = %s,
|
||||
cvr_number = %s,
|
||||
email_domain = %s,
|
||||
address = %s,
|
||||
city = %s,
|
||||
postal_code = %s,
|
||||
country = %s,
|
||||
@ -537,7 +517,7 @@ async def sync_from_economic() -> Dict[str, Any]:
|
||||
WHERE id = %s
|
||||
"""
|
||||
execute_query(update_query, (
|
||||
customer_number, email_domain, address, city, zip_code, country, website, existing[0]['id']
|
||||
name, customer_number, cvr, email_domain, city, zip_code, country, website, existing[0]['id']
|
||||
))
|
||||
updated_count += 1
|
||||
logger.info(f"✏️ Opdateret: {name} (e-conomic #{customer_number}, CVR: {cvr or 'ingen'})")
|
||||
@ -546,12 +526,12 @@ async def sync_from_economic() -> Dict[str, Any]:
|
||||
insert_query = """
|
||||
INSERT INTO customers
|
||||
(name, economic_customer_number, cvr_number, email_domain,
|
||||
address, city, postal_code, country, website, last_synced_at)
|
||||
VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, NOW())
|
||||
city, postal_code, country, website, last_synced_at)
|
||||
VALUES (%s, %s, %s, %s, %s, %s, %s, %s, NOW())
|
||||
RETURNING id
|
||||
"""
|
||||
result = execute_query(insert_query, (
|
||||
name, customer_number, cvr, email_domain, address, city, zip_code, country, website
|
||||
name, customer_number, cvr, email_domain, city, zip_code, country, website
|
||||
))
|
||||
|
||||
if result:
|
||||
|
||||
@ -84,10 +84,7 @@ class OrderService:
|
||||
(customer_id,))
|
||||
|
||||
if not customer:
|
||||
raise HTTPException(status_code=404, detail=f"Customer {customer_id} not found in tmodule_customers")
|
||||
|
||||
# Debug log
|
||||
logger.info(f"✅ Found customer: {customer.get('name') if isinstance(customer, dict) else type(customer)}")
|
||||
raise HTTPException(status_code=404, detail="Customer not found")
|
||||
|
||||
# Hent godkendte tider for kunden med case og contact detaljer
|
||||
query = """
|
||||
|
||||
@ -118,69 +118,6 @@ async def test_vtiger_connection():
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
|
||||
@router.get("/debug/raw-stats", tags=["Debug"])
|
||||
async def get_debug_raw_stats():
|
||||
"""
|
||||
🔍 DEBUG: Vis rå statistik fra databasen uden filtering.
|
||||
|
||||
Bruges til at diagnosticere hvorfor timelogs ikke vises.
|
||||
"""
|
||||
try:
|
||||
# Total counts without any filtering
|
||||
total_query = """
|
||||
SELECT
|
||||
(SELECT COUNT(*) FROM tmodule_customers) as total_customers,
|
||||
(SELECT COUNT(*) FROM tmodule_cases) as total_cases,
|
||||
(SELECT COUNT(*) FROM tmodule_times) as total_times,
|
||||
(SELECT COUNT(*) FROM tmodule_times WHERE billable = true) as billable_times,
|
||||
(SELECT COUNT(*) FROM tmodule_times WHERE status = 'pending') as pending_times,
|
||||
(SELECT COUNT(*) FROM tmodule_times WHERE vtiger_data->>'cf_timelog_invoiced' = '0') as not_invoiced_times,
|
||||
(SELECT COUNT(*) FROM tmodule_times WHERE vtiger_data->>'cf_timelog_invoiced' IS NULL) as null_invoiced_times,
|
||||
(SELECT COUNT(*) FROM tmodule_times WHERE billable = true AND status = 'pending') as billable_pending,
|
||||
(SELECT COUNT(*) FROM tmodule_times WHERE billable = true AND status = 'pending' AND vtiger_data->>'cf_timelog_invoiced' = '0') as filtered_pending
|
||||
"""
|
||||
totals = execute_query_single(total_query)
|
||||
|
||||
# Sample timelogs to see actual data
|
||||
sample_query = """
|
||||
SELECT
|
||||
id, vtiger_id, description, worked_date, original_hours,
|
||||
status, billable,
|
||||
vtiger_data->>'cf_timelog_invoiced' as cf_timelog_invoiced,
|
||||
vtiger_data->>'isbillable' as is_billable_field,
|
||||
customer_id, case_id
|
||||
FROM tmodule_times
|
||||
ORDER BY worked_date DESC
|
||||
LIMIT 10
|
||||
"""
|
||||
samples = execute_query(sample_query)
|
||||
|
||||
# Check what invoice statuses actually exist
|
||||
invoice_status_query = """
|
||||
SELECT
|
||||
vtiger_data->>'cf_timelog_invoiced' as invoice_status,
|
||||
COUNT(*) as count
|
||||
FROM tmodule_times
|
||||
GROUP BY vtiger_data->>'cf_timelog_invoiced'
|
||||
ORDER BY count DESC
|
||||
"""
|
||||
invoice_statuses = execute_query(invoice_status_query)
|
||||
|
||||
return {
|
||||
"totals": totals,
|
||||
"sample_timelogs": samples,
|
||||
"invoice_statuses": invoice_statuses,
|
||||
"explanation": {
|
||||
"issue": "If not_invoiced_times is 0 but total_times > 0, then the cf_timelog_invoiced field is not '0' in vTiger",
|
||||
"solution": "The SQL views filter on cf_timelog_invoiced = '0' but vTiger might use different values",
|
||||
"check": "Look at invoice_statuses to see what values actually exist"
|
||||
}
|
||||
}
|
||||
except Exception as e:
|
||||
logger.error(f"❌ Debug query failed: {e}")
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
|
||||
# ============================================================================
|
||||
# WIZARD / APPROVAL ENDPOINTS
|
||||
# ============================================================================
|
||||
|
||||
@ -567,9 +567,8 @@
|
||||
caseLink = 'Ingen case';
|
||||
}
|
||||
|
||||
// Get hourly rate (customer rate or default) - parse as float if string
|
||||
const rateValue = e.customer_rate || currentEntry.customer_rate || defaultHourlyRate;
|
||||
const hourlyRate = typeof rateValue === 'string' ? parseFloat(rateValue) : rateValue;
|
||||
// Get hourly rate (customer rate or default)
|
||||
const hourlyRate = e.customer_rate || currentEntry.customer_rate || defaultHourlyRate;
|
||||
|
||||
return `
|
||||
<div class="card time-entry-card mb-3" id="entry-card-${e.id}">
|
||||
@ -805,9 +804,7 @@
|
||||
const response = await fetch(`/api/v1/timetracking/wizard/progress/${currentEntry.customer_id}`);
|
||||
const progress = await response.json();
|
||||
|
||||
// Parse hourly rate as number (may be string from DB)
|
||||
const rateValue = currentEntry.customer_rate || defaultHourlyRate;
|
||||
const hourlyRate = typeof rateValue === 'string' ? parseFloat(rateValue) : rateValue;
|
||||
const hourlyRate = currentEntry.customer_rate || defaultHourlyRate;
|
||||
document.getElementById('context-hourly-rate').textContent = hourlyRate.toFixed(2) + ' DKK';
|
||||
|
||||
// Vis antal registreringer (vi har ikke timer-totaler i progress endpointet)
|
||||
@ -1084,8 +1081,7 @@
|
||||
|
||||
// Get billable hours and hourly rate from calculation
|
||||
const billableHours = window.entryBillableHours?.[entryId] || entry.original_hours;
|
||||
const rateValue = window.entryHourlyRates?.[entryId] || entry.customer_rate || defaultHourlyRate;
|
||||
const hourlyRate = typeof rateValue === 'string' ? parseFloat(rateValue) : rateValue;
|
||||
const hourlyRate = window.entryHourlyRates?.[entryId] || entry.customer_rate || defaultHourlyRate;
|
||||
|
||||
// Get travel checkbox state
|
||||
const travelCheckbox = document.getElementById(`travel-${entryId}`);
|
||||
|
||||
@ -1,53 +0,0 @@
|
||||
#!/bin/bash
|
||||
# Deploy BMC Hub to production server
|
||||
# Usage: ./deploy_to_prod.sh v1.3.56
|
||||
|
||||
set -e
|
||||
|
||||
VERSION=$1
|
||||
PROD_SERVER="bmcadmin@172.16.31.183"
|
||||
PROD_DIR="/srv/podman/bmc_hub_v1.0"
|
||||
|
||||
if [ -z "$VERSION" ]; then
|
||||
echo "❌ Usage: ./deploy_to_prod.sh v1.3.56"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
echo "🚀 Deploying $VERSION to production..."
|
||||
echo "======================================="
|
||||
|
||||
# Update .env file
|
||||
echo "📝 Updating RELEASE_VERSION to $VERSION..."
|
||||
ssh $PROD_SERVER "sed -i 's/^RELEASE_VERSION=.*/RELEASE_VERSION=$VERSION/' $PROD_DIR/.env"
|
||||
|
||||
# Stop containers
|
||||
echo "🛑 Stopping containers..."
|
||||
ssh $PROD_SERVER "cd $PROD_DIR && podman-compose down"
|
||||
|
||||
# Rebuild with no cache (to pull latest version from Gitea)
|
||||
echo "🔨 Building new image from version $VERSION..."
|
||||
ssh $PROD_SERVER "cd $PROD_DIR && podman-compose build --no-cache"
|
||||
|
||||
# Start containers
|
||||
echo "▶️ Starting containers..."
|
||||
ssh $PROD_SERVER "cd $PROD_DIR && podman-compose up -d"
|
||||
|
||||
# Wait for service to be ready
|
||||
echo "⏳ Waiting for service to start..."
|
||||
sleep 15
|
||||
|
||||
# Check health
|
||||
echo "🏥 Checking service health..."
|
||||
HEALTH=$(curl -s http://172.16.31.183:8000/health || echo "FAILED")
|
||||
if echo "$HEALTH" | grep -q "ok"; then
|
||||
echo "✅ Deployment successful!"
|
||||
echo "$HEALTH"
|
||||
else
|
||||
echo "❌ Health check failed:"
|
||||
echo "$HEALTH"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
echo ""
|
||||
echo "🎉 Production is now running version $VERSION"
|
||||
echo " http://172.16.31.183:8000"
|
||||
@ -42,7 +42,6 @@ services:
|
||||
# Mount for local development - live code reload
|
||||
- ./app:/app/app:ro
|
||||
- ./main.py:/app/main.py:ro
|
||||
- ./VERSION:/app/VERSION:ro
|
||||
env_file:
|
||||
- .env
|
||||
environment:
|
||||
|
||||
9
main.py
9
main.py
@ -4,7 +4,6 @@ Main application entry point
|
||||
"""
|
||||
|
||||
import logging
|
||||
from pathlib import Path
|
||||
from fastapi import FastAPI
|
||||
from fastapi.middleware.cors import CORSMiddleware
|
||||
from fastapi.staticfiles import StaticFiles
|
||||
@ -14,14 +13,6 @@ from contextlib import asynccontextmanager
|
||||
from app.core.config import settings
|
||||
from app.core.database import init_db
|
||||
|
||||
def get_version():
|
||||
"""Read version from VERSION file"""
|
||||
try:
|
||||
version_file = Path(__file__).parent / "VERSION"
|
||||
return version_file.read_text().strip()
|
||||
except Exception:
|
||||
return "unknown"
|
||||
|
||||
# Import Feature Routers
|
||||
from app.customers.backend import router as customers_api
|
||||
from app.customers.backend import views as customers_views
|
||||
|
||||
@ -1,20 +0,0 @@
|
||||
#!/usr/bin/env python3
|
||||
import asyncio
|
||||
import sys
|
||||
sys.path.insert(0, '/Users/christianthomas/DEV/bmc_hub_dev')
|
||||
from app.services.vtiger_service import VTigerService
|
||||
|
||||
async def test_accounts():
|
||||
vtiger = VTigerService()
|
||||
|
||||
# Check what 3x760 and 3x811 are in vTiger
|
||||
for vtiger_id in ['3x760', '3x811']:
|
||||
query = f"SELECT id, accountname FROM Accounts WHERE id = '{vtiger_id}';"
|
||||
result = await vtiger.query(query)
|
||||
|
||||
if result:
|
||||
print(f"{vtiger_id} = {result[0].get('accountname')}")
|
||||
else:
|
||||
print(f"{vtiger_id} = NOT FOUND")
|
||||
|
||||
asyncio.run(test_accounts())
|
||||
@ -1,44 +0,0 @@
|
||||
#!/usr/bin/env python3
|
||||
"""
|
||||
Test script to check vTiger contact data
|
||||
"""
|
||||
import asyncio
|
||||
import sys
|
||||
sys.path.insert(0, '/Users/christianthomas/DEV/bmc_hub_dev')
|
||||
|
||||
from app.services.vtiger_service import VTigerService
|
||||
|
||||
async def test_contact():
|
||||
vtiger = VTigerService()
|
||||
|
||||
# Fetch contact by email
|
||||
query = "SELECT id, firstname, lastname, email, account_id FROM Contacts WHERE email = 'accounting@arbodania.com';"
|
||||
print(f"Query: {query}")
|
||||
|
||||
result = await vtiger.query(query)
|
||||
|
||||
if result:
|
||||
contact = result[0]
|
||||
print(f"\n✅ Contact found:")
|
||||
print(f" ID: {contact.get('id')}")
|
||||
print(f" Name: {contact.get('firstname')} {contact.get('lastname')}")
|
||||
print(f" Email: {contact.get('email')}")
|
||||
print(f" Account ID: {contact.get('account_id')}")
|
||||
|
||||
# Now fetch the account details
|
||||
account_id = contact.get('account_id')
|
||||
if account_id:
|
||||
account_query = f"SELECT id, accountname FROM Accounts WHERE id = '{account_id}';"
|
||||
print(f"\nFetching account: {account_query}")
|
||||
account_result = await vtiger.query(account_query)
|
||||
|
||||
if account_result:
|
||||
account = account_result[0]
|
||||
print(f"\n✅ Account found:")
|
||||
print(f" ID: {account.get('id')}")
|
||||
print(f" Name: {account.get('accountname')}")
|
||||
else:
|
||||
print("❌ Contact not found")
|
||||
|
||||
if __name__ == "__main__":
|
||||
asyncio.run(test_contact())
|
||||
Loading…
Reference in New Issue
Block a user