177 lines
7.1 KiB
Python
177 lines
7.1 KiB
Python
from apps.lead.models import Lead as LeadModel,\
|
|
LeadType as LeadTypeModel, LeadStep as LeadStepModel, LeadSource as LeadSourceModel, LeadComment as LeadCommentModel, LeadEvent as LeadEventModel
|
|
from apps.shop.models import ProductType as ProductTypeModel
|
|
from utils.get_user_workspace import get_user_workspace
|
|
from utils.get_cuser_role import get_cuser_role
|
|
from utils.validations import ObjectValidationById
|
|
from apps.customer.models import Customer as CustomerModel
|
|
from apps.workspace.models import City as CityModel
|
|
from utils.services.sms import DefaultSmsProvider
|
|
from rest_framework import exceptions
|
|
|
|
|
|
def create_new_lead(request, title: str, customer_id: str, mobile1: int, desc: str, product_type_id: int,
|
|
lead_type_id: int, lead_source_id: int, city_id: int, lead_step_id: int, mobile2: int = None, phone: int = None, lead_event_id: int = None) -> LeadModel:
|
|
try:
|
|
sys_ws = get_user_workspace(request=request)
|
|
cuser_role = get_cuser_role(request=request)
|
|
|
|
customer = ObjectValidationById(object_model=CustomerModel, request=request).is_valid(int(customer_id))
|
|
lead_type = ObjectValidationById(object_model=LeadTypeModel, request=request).is_valid(lead_type_id)
|
|
lead_step = ObjectValidationById(object_model=LeadStepModel, request=request).is_valid(lead_step_id)
|
|
lead_source = ObjectValidationById(object_model=LeadSourceModel, request=request).is_valid(lead_source_id)
|
|
product_type = ObjectValidationById(object_model=ProductTypeModel, request=request).is_valid(product_type_id)
|
|
city = ObjectValidationById(object_model=CityModel, request=request).is_valid(city_id)
|
|
|
|
lead_event_obj = None
|
|
|
|
new_lead = LeadModel()
|
|
new_lead.title = title
|
|
new_lead.customer = customer
|
|
if mobile1:
|
|
new_lead.mobile1 = mobile1
|
|
if mobile2:
|
|
new_lead.mobile2 = mobile2
|
|
if phone:
|
|
new_lead.phone = phone
|
|
if lead_event_id and (lead_event_id != '0' or lead_event_id != 0):
|
|
lead_event_obj = LeadEventModel.objects.get(id=lead_event_id, sys_ws=sys_ws)
|
|
new_lead.lead_event = lead_event_obj
|
|
new_lead.desc = desc
|
|
new_lead.type = lead_type
|
|
new_lead.step = lead_step
|
|
new_lead.source = lead_source
|
|
new_lead.product_type = product_type
|
|
new_lead.city = city
|
|
new_lead.sys_ws = sys_ws
|
|
new_lead.cuser_role = cuser_role
|
|
|
|
new_lead.save()
|
|
|
|
# send sms
|
|
if lead_event_obj and lead_event_obj.send_sms:
|
|
sms_provider = DefaultSmsProvider()
|
|
if mobile1:
|
|
sms_provider.send_sms(str(mobile1), lead_event_obj.message)
|
|
if mobile2:
|
|
sms_provider.send_sms(str(mobile2), lead_event_obj.message)
|
|
|
|
return new_lead
|
|
|
|
except Exception as exp:
|
|
print("error creae lead")
|
|
message = f'Error Create New Lead: {exp}'
|
|
raise exceptions.ValidationError({'error': message})
|
|
|
|
|
|
def update_lead(request, lead_id: int, title: str, customer_id: str, desc: str, product_type_id: int,
|
|
lead_type_id: int, lead_source_id: int, city_id: int, lead_step_id: int, mobile1: int = None, mobile2: int = None, phone: int = None) -> LeadModel:
|
|
try:
|
|
sys_ws = get_user_workspace(request=request)
|
|
#cuser_role = get_cuser_role(request=request)
|
|
|
|
customer = ObjectValidationById(object_model=CustomerModel, request=request).is_valid(int(customer_id))
|
|
lead_type = ObjectValidationById(object_model=LeadTypeModel, request=request).is_valid(lead_type_id)
|
|
lead_step = ObjectValidationById(object_model=LeadStepModel, request=request).is_valid(lead_step_id)
|
|
lead_source = ObjectValidationById(object_model=LeadSourceModel, request=request).is_valid(lead_source_id)
|
|
product_type = ObjectValidationById(object_model=ProductTypeModel, request=request).is_valid(product_type_id)
|
|
city = ObjectValidationById(object_model=CityModel, request=request).is_valid(city_id)
|
|
|
|
#lead = LeadModel.objects.get(id=lead_id, sys_ws=sys_ws, cuser_role=cuser_role)
|
|
lead = LeadModel.objects.get(id=lead_id, sys_ws=sys_ws)
|
|
lead.title = title
|
|
lead.customer = customer
|
|
if mobile1:
|
|
lead.mobile1 = mobile1
|
|
if mobile2:
|
|
lead.mobile2 = mobile2
|
|
if phone:
|
|
lead.phone = phone
|
|
lead.desc = desc
|
|
lead.type = lead_type
|
|
lead.step = lead_step
|
|
lead.source = lead_source
|
|
lead.product_type = product_type
|
|
lead.city = city
|
|
|
|
lead.save()
|
|
|
|
return lead
|
|
|
|
except Exception as exp:
|
|
message = f'Error Update Lead: {exp}'
|
|
raise exceptions.ValidationError({'error': message})
|
|
|
|
|
|
def update_lead_status(request, lead_id: int, status: str) -> LeadModel:
|
|
try:
|
|
sys_ws = get_user_workspace(request=request)
|
|
cuser_role = get_cuser_role(request=request)
|
|
|
|
lead = LeadModel.objects.get(id=lead_id, sys_ws=sys_ws, cuser_role=cuser_role)
|
|
lead.status = status
|
|
|
|
lead.save()
|
|
|
|
return lead
|
|
|
|
except Exception as exp:
|
|
message = f'Error Update Lead Status: {exp}'
|
|
raise exceptions.ValidationError({'error': message})
|
|
|
|
|
|
def update_lead_comment(request, lead_comment_id: int, desc: str) -> LeadModel:
|
|
try:
|
|
sys_ws = get_user_workspace(request=request)
|
|
#cuser_role = get_cuser_role(request=request)
|
|
|
|
#lead_comment = LeadCommentModel.objects.get(id=lead_comment_id, sys_ws=sys_ws, cuser_role=cuser_role)
|
|
lead_comment = LeadCommentModel.objects.get(id=lead_comment_id, sys_ws=sys_ws)
|
|
lead_comment.desc = desc
|
|
|
|
lead_comment.save()
|
|
|
|
return lead_comment
|
|
|
|
except Exception as exp:
|
|
message = f'Error Update Lead_comment: {exp}'
|
|
raise exceptions.ValidationError({'error': message})
|
|
|
|
|
|
def create_lead_comment(request, lead_id, desc: str) -> LeadCommentModel:
|
|
try:
|
|
sys_ws = get_user_workspace(request=request)
|
|
cuser_role = get_cuser_role(request=request)
|
|
|
|
lead_comment = LeadCommentModel()
|
|
#lead_comment.lead = LeadModel.objects.get(id=lead_id, sys_ws=sys_ws, cuser_role=cuser_role)
|
|
lead_comment.lead = LeadModel.objects.get(id=lead_id, sys_ws=sys_ws)
|
|
lead_comment.sys_ws = sys_ws
|
|
lead_comment.cuser_role = cuser_role
|
|
lead_comment.desc = desc
|
|
lead_comment.save()
|
|
|
|
return lead_comment
|
|
|
|
except Exception as exp:
|
|
message = f'Error Create Lead comment: {exp}'
|
|
raise exceptions.ValidationError({'error': message})
|
|
|
|
|
|
def delete_lead_comment(request, lead_comment_id: int) -> LeadModel:
|
|
try:
|
|
sys_ws = get_user_workspace(request=request)
|
|
#cuser_role = get_cuser_role(request=request)
|
|
|
|
#lead_comment = LeadCommentModel.objects.get(id=lead_comment_id, sys_ws=sys_ws, cuser_role=cuser_role)
|
|
lead_comment = LeadCommentModel.objects.get(id=lead_comment_id, sys_ws=sys_ws)
|
|
lead_comment.delete()
|
|
|
|
return lead_comment
|
|
|
|
except Exception as exp:
|
|
message = f'Error Delete Lead_comment: {exp}'
|
|
raise exceptions.ValidationError({'error': message})
|
|
|
|
|