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/opt/account/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) absoluteas_posixreplacerparentmkdirlogginginforename)rrrdstrrr mvsz DelayPool.mvc Ksp|ddkrdnd}tj|td}td||jj ddd| d }t ||W5QRXdS) N lead_type email_only new_stage1rz%Y-%m-%d.%s.jsonuTДобавляем задачу в отложенный пул обработки %sTrw) r r directoryrnowstrftimerwarningrropenjsondump)_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(Обрабатываем задачу %srdonelead_email_nameuSУдаляем файл %s т.к. человек дорегистрировалсяuhНас не волнуют разовые проблемы с сделками от автотестовzbad/auto_testsbad)rrr+r,load_acrm_registerrr"r at_stage1unlinkr exceptionrr*)selfr5strictr/remailZ stage1_fileerrrrr process_entry/s&         zDelayPool.process_entrycCsVtdtjdtjjdddt}|dk rH|||t}q*tddS)Nu"Обрабатываем пул %srTru(Что нашли - обработали)rrrr'rr6rC)r?r@r5rrr 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Не удалось прочитать файл %sr8u?Каким-то образом %s создался без email) r'is_dirrr*r1r+r,r:JSONDecodeErrorr>r r<)r?Zstage1_directoryr5r/rrArrr load_stage1Ns         zDelayPool.load_stage1N)F)F)rrrrr'dictr< staticmethodstrr"r0r6rCrDrGrrrr rs    rcKstdtjf|dS)u Обёртка с обработкой ошибок. Если acrm временно легла, клиент должен всё равно получить свою демку. А мы должны получить лида, но чуть попозже. Если проблема не в том, что acrm легла, всё равно сохраним данные. uРегистрация в ACRM:N)rrrr0)kwargsrrr acrm_registeras rLc 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=rAZ company_namer z Content-typez!application/x-www-form-urlencoded)rheaderszcode: %s resp: %s content: %suКод ответа ActiveCRM zaction=failureunФорма для создания лидов в BCRM вывела на страницу об ошибке: %suNДанные запроса, которые привели к ошибке: %s)indentu!Страница ошибки: %suYНе удалось зарегистрировать лида из-за ответа BCRMu+ActiveCRM вообще недоступна)rrrrequestspostdebug status_codecontenturlerrorr,dumpstext exceptionsConnectionError) r companyr Zform_idactionrMorg_namerKrWresprrr r;ts2      r;cCst}|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Обработать одну запись из пула)r^defaulthelpz-fz--process-fileu2Обработать конкретный файл)typercz-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)formatleveldatefmtz#Choose one of processing targets %sr)argparseArgumentParser add_argumentrJ parse_argsr basicConfigrTDEBUGINFOrrGZ process_oner6rCZ process_poolrDZstop_on_errorsZ process_filerrXexit)parserargspoolr5rrr mains:     rs__main__)NNNNNNN)rhr,rrpathlibrrR ExceptionrrrrLr;rsrrrrr s  N &