U -d!@sddlZddlZddlZddlmZddlmZddlZGdddeZddZ Gdd d Z d d Z dd d Z ddZ edkre dS)N)datetime)Pathc@s eZdZdS) AcrmErrorN)__name__ __module__ __qualname__rr./common/acrm.pyr srcCs |dddo|ddkS)NloginZ723ad4b0phonez +79068099069)get startswith)datarrr is_auto_testsrc@sdeZdZedZeZeeeedddZ eddZ eddZ dd d Z dd d Z ddZdS) DelayPoolz/var/lib/account/acrm/)srcoldnewcCsF|||d}t|jjdddtd||||dS)NTparentsexist_okz Move %s to %s) ZabsoluteZas_posixreplacerparentmkdirlogginginforename)rrrdstrrr mvsz DelayPool.mvc Ksp|ddkrdnd}tj|td}td||jj ddd| d }t ||W5QRXdS) NZ lead_typeZ email_only new_stage1rz%Y-%m-%d.%s.jsonuTДобавляем задачу в отложенный пул обработки %sTrw) r r directoryrZnowstrftimerwarningrropenjsondump)_kwargsr#Zdatafilefdrrr pushs   zDelayPool.pushcCsJtdtjdD],}|r|jdrtd||SqdS)Nu$Ищем в пуле задачу...rz.jsonu Нашли %s)rrrr#iterdiris_filenameendswith)entryrrr pop's   z DelayPool.popFc Cstd||}t|}W5QRXzJtf|t|dd|d}|j |}|rrtd|| Wndt k r}zFt ||r|t |rtdt|ddnt|ddW5d}~XYnXdS) Nu(Обрабатываем задачу %srZdonelead_email_nameuSУдаляем файл %s т.к. человек дорегистрировалсяuhНас не волнуют разовые проблемы с сделками от автотестовzbad/auto_testsZbad)rrr&r'load_acrm_registerrr r at_stage1unlinkr exceptionrr%)selfr0strictr*remailZ stage1_fileerrrrr process_entry/s&         zDelayPool.process_entrycCsVtdtjdtjjdddt}|dk rH|||t}q*tddS)Nu"Обрабатываем пул %srTru(Что нашли - обработали)rrrr#rr1r<)r8r9r0rrr processEs  zDelayPool.processc Cs|jd}|s tddS|D]t}z"|}t|}W5QRXWn&tjk rtt d|Yq(YnX| d}|std|q(||j |<q(dS)Nr!uVДля реги по email даже папки нет, нечего загружатьu2Не удалось прочитать файл %sr2u?Каким-то образом %s создался без email) r#is_dirrr%r,r&r'r3ZJSONDecodeErrorr7r r5)r8Zstage1_directoryr0r*rr:rrr load_stage1Ns         zDelayPool.load_stage1N)F)F)rrrrr#dictr5 staticmethodstrr r+r1r<r=r?rrrr rs    rcKstdtjf|dS)u Обёртка с обработкой ошибок. Если acrm временно легла, клиент должен всё равно получить свою демку. А мы должны получить лида, но чуть попозже. Если проблема не в том, что acrm легла, всё равно сохраним данные. uРегистрация в ACRM:N)rrrr+)kwargsrrr acrm_registeras rDc Kstd|dkrtd|s(d|}||d<d|}|rF||d<|rR||d<|r^||d <ztj||d d id } td | j| | j| jdkrtd| jd| jkrt d| jt dt j |ddt d| j tdWn"tj jk r tdYnXdS)uO Создаем сделку на bcrm :param kwargs: :return: u+Собственно регистрацияNuKНе указан ID формы с которой пришёл запросu3Попробовать бесплатно org_name=user_askz+https://bcrm.carbonsoft.ru/pub/forms?token=r:Z company_namer z Content-typez!application/x-www-form-urlencoded)rZheaderszcode: %s resp: %s content: %suКод ответа ActiveCRM zaction=failureunФорма для создания лидов в BCRM вывела на страницу об ошибке: %suNДанные запроса, которые привели к ошибке: %s)indentu!Страница ошибки: %suYНе удалось зарегистрировать лида из-за ответа BCRMu+ActiveCRM вообще недоступна)rrrrequestsZpostdebugZ status_codeZcontenturlerrorr'dumpstext exceptionsConnectionError) r Zcompanyr Zform_idactionrEZorg_namerCrKZresprrr r4ts2      r4cCst}|jdddddd|jddtd d |jd d ddd d|jdddddd|jdddddd|}tjd|jrtjntj ddt }| |j r| }|r||n@|jr||jn,|jr|t|jntd|tddS)Nz-oz --process-one store_trueFu8Обработать одну запись из пула)rQdefaulthelpz-fz--process-fileu2Обработать конкретный файл)typerTz-az--process-poolu9Попробовать обработать вес пулz-ez--stop-on-errorsu{Упасть при первой ошибке обработки пула, не переносить задачу в ./bad/z-dz--debugu Выводить ответ bcrmz7[%(asctime)s] %(filename)s #%(levelname)-8s %(message)sz%Y-%m-%d %H:%M:%S)formatlevelZdatefmtz#Choose one of processing targets %sr)argparseArgumentParser add_argumentrB parse_argsrZ basicConfigrJDEBUGINFOrr?Z process_oner1r<Z process_poolr=Zstop_on_errorsZ process_filerrLexit)parserargsZpoolr0rrr mains:     ra__main__)NNNNNNN)rXr'rrpathlibrrI ExceptionrrrrDr4rarrrrr s  N &