Workflow post_actions multiples

This topic contains 5 replies, has 2 voices, and was last updated by Mike Kudelya 6 years, 11 months ago.

Starting from March 1, 2020 the forum has been switched to the read-only mode. Please head to StackOverflow for support.

Creator

Topic

October 11, 2016 at 3:08 pm #34272

Geoffroy Cochard

Participant

Hi,

I’m using OroPlatform 1.10.5 to perform some workflows. In one of my transition definitions, many post_actions are defined, like this :

            batch_validated_definition:
                post_actions:
                    - @send_email_validated:
                        attribute: $subscription
                        from: 'geoffroycochard@gmail.com'
                        to: 'geoffroycochard@gmail.com'
                        template: 'subscription_confirmation'
                        entity: $.entity
                    - @assign_value:
                        [$status, 5]

batch_validated_definition:

post_actions:

- @send_email_validated:

attribute: $subscription

from: 'geoffroycochard@gmail.com'

to: 'geoffroycochard@gmail.com'

template: 'subscription_confirmation'

entity: $.entity

- @assign_value:

[$status, 5]

In my custom action @send_email_validated, it very similar to @send_email_template but with an attachment assignment, file generated through ImportExport service like this :

    /**
     * {@inheritdoc}
     */
    protected function executeAction($context)
    {
        $emailModel = $this->getEmailModel();

        $from = $this->getEmailAddress($context, $this->options['from']);
        $this->validateAddress($from);
        $emailModel->setFrom($from);
        $to = [];
        foreach ($this->options['to'] as $email) {
            if ($email) {
                $address = $this->getEmailAddress($context, $email);
                $this->validateAddress($address);
                $to[] = $this->getEmailAddress($context, $address);
            }
        }
        $emailModel->setTo($to);
        $entity = $this->contextAccessor->getValue($context, $this->options['entity']);
        $template = $this->contextAccessor->getValue($context, $this->options['template']);

        $emailTemplate = $this->objectManager->getRepository('OroEmailBundle:EmailTemplate')
            ->findByName($template);
        if (!$emailTemplate) {
            $errorMessage = sprintf('Template "%s" not found.', $template);
            $this->logger->error('Workflow send email action.' . $errorMessage);
            throw new EntityNotFoundException($errorMessage);
        }
        $templateData = $this->renderer->compileMessage($emailTemplate, ['entity' => $entity]);

        list ($subjectRendered, $templateRendered) = $templateData;

        $emailModel->setSubject($subjectRendered);
        $emailModel->setBody($templateRendered);
        $emailModel->setType($emailTemplate->getType());

        $attachmentEntity = $this->getEmailAttachmentEntity($entity);
        $emailModel->addAttachment($attachmentEntity);

        $emailUser = $this->emailProcessor->process(
            $emailModel,
            $this->emailProcessor->getEmailOrigin($emailModel->getFrom(), $emailModel->getOrganization())
        );

        if (array_key_exists('attribute', $this->options)) {
            $this->contextAccessor->setValue($context, $this->options['attribute'], $emailUser->getEmail());
        }
    }

    /**
     * @param string $email
     *
     * @throws \Symfony\Component\Validator\Exception\ValidatorException
     */
    protected function validateAddress($email)
    {
        $emailConstraint = new EmailConstraints();
        $emailConstraint->message = 'Invalid email address';
        if ($email) {
            $errorList = $this->validator->validate(
                $email,
                $emailConstraint
            );
            if ($errorList && $errorList->count() > 0) {
                throw new ValidatorException($errorList->get(0)->getMessage());
            }
        }
    }

    protected function getEmailAttachmentEntity(Subscription $subscription)
    {
        #TODO : check error from export handler
        // Export xlsx
        $options = [
            'filters' => [
                'codeBroker' => [$subscription->getCodeBroker()->getId()],
                'status' => [
                    'comparator' => 'lte',
                    'value' => 5
                ]
            ]
        ];

        $handler = $this->exportHandler->getExportResult(
            'dawkins_subscription_export_to_xlsx',
            'dawkins_subscription_subscription',
            'export',
            'xlsx',
            null,
            $options
        );

        // Get fileName
        $a = explode('/', $handler['url']);
        $fileName = end($a);
        
//        $fileName = 'dawkins_subscription_subscription_2016_10_11_21_12_54_57fd55d6d6bb3.xlsx';
        $fullFileName = $this->fileSystemOperator
            ->getTemporaryFile($fileName)
            ->getRealPath();
        $uploadedFile = new UploadedFile($fullFileName, $fileName);

        $emailAttachment = $this->emailAttachmentTransformer->entityFromUploadedFile($uploadedFile);

        $emailBody = new EmailBody();

        $emailAttachment->setEmailBody($emailBody);

        return $this->emailAttachmentTransformer->entityToModel($emailAttachment);
    }

100

101

102

103

104

105

106

107

108

109

110

111

/**

* {@inheritdoc}

protected function executeAction($context)

{

$emailModel = $this->getEmailModel();

$from = $this->getEmailAddress($context, $this->options['from']);

$this->validateAddress($from);

$emailModel->setFrom($from);

$to = [];

foreach ($this->options['to'] as $email) {

if ($email) {

$address = $this->getEmailAddress($context, $email);

$this->validateAddress($address);

$to[] = $this->getEmailAddress($context, $address);

}

$emailModel->setTo($to);

$entity = $this->contextAccessor->getValue($context, $this->options['entity']);

$template = $this->contextAccessor->getValue($context, $this->options['template']);

$emailTemplate = $this->objectManager->getRepository('OroEmailBundle:EmailTemplate')

->findByName($template);

if (!$emailTemplate) {

$errorMessage = sprintf('Template "%s" not found.', $template);

$this->logger->error('Workflow send email action.' . $errorMessage);

throw new EntityNotFoundException($errorMessage);

}

$templateData = $this->renderer->compileMessage($emailTemplate, ['entity' => $entity]);

list ($subjectRendered, $templateRendered) = $templateData;

$emailModel->setSubject($subjectRendered);

$emailModel->setBody($templateRendered);

$emailModel->setType($emailTemplate->getType());

$attachmentEntity = $this->getEmailAttachmentEntity($entity);

$emailModel->addAttachment($attachmentEntity);

$emailUser = $this->emailProcessor->process(

$emailModel,

$this->emailProcessor->getEmailOrigin($emailModel->getFrom(), $emailModel->getOrganization())

);

if (array_key_exists('attribute', $this->options)) {

$this->contextAccessor->setValue($context, $this->options['attribute'], $emailUser->getEmail());

}

/**

* @param string $email

* @throws \Symfony\Component\Validator\Exception\ValidatorException

protected function validateAddress($email)

{

$emailConstraint = new EmailConstraints();

$emailConstraint->message = 'Invalid email address';

if ($email) {

$errorList = $this->validator->validate(

$email,

$emailConstraint

);

if ($errorList && $errorList->count() > 0) {

throw new ValidatorException($errorList->get(0)->getMessage());

}

protected function getEmailAttachmentEntity(Subscription $subscription)

{

#TODO : check error from export handler

// Export xlsx

$options = [

'filters' => [

'codeBroker' => [$subscription->getCodeBroker()->getId()],

'status' => [

'comparator' => 'lte',

'value' => 5

]

];

$handler = $this->exportHandler->getExportResult(

'dawkins_subscription_export_to_xlsx',

'dawkins_subscription_subscription',

'export',

'xlsx',

null,

$options

);

// Get fileName

$a = explode('/', $handler['url']);

$fileName = end($a);

// $fileName = 'dawkins_subscription_subscription_2016_10_11_21_12_54_57fd55d6d6bb3.xlsx';

$fullFileName = $this->fileSystemOperator

->getTemporaryFile($fileName)

->getRealPath();

$uploadedFile = new UploadedFile($fullFileName, $fileName);

$emailAttachment = $this->emailAttachmentTransformer->entityFromUploadedFile($uploadedFile);

$emailBody = new EmailBody();

$emailAttachment->setEmailBody($emailBody);

return $this->emailAttachmentTransformer->entityToModel($emailAttachment);

}

When i use ImportExport service in my custom post_actions,@assign_value and transit don’t seem executed (no database update) and when i don’t use ImportExport->handler service transition work.
Is something in ImportExport->handler() service like manager->flush / clear, getting wrong in post_action execution ?

Creator

Topic

Viewing 5 replies - 1 through 5 (of 5 total)

Author

Replies
October 12, 2016 at 1:27 am #34273

Geoffroy Cochard
Participant

In fact if i get Doctrine UnitOfWork before call exportHandler(), there’s Workflow*Entities in identityMap and after there’re disappear…

October 12, 2016 at 5:21 am #34274

Geoffroy Cochard
Participant

Ok…

Manager is cleared when use XlsWriter / CsvWriter due to call DoctrineClearWriter who clear DoctrineManager after writing…

It’s clearing / detach each item due to performance ?

October 17, 2016 at 7:08 am #34275

Mike Kudelya
Participant

Hi,

Probably yes, here is an example how doctrine works with batches. If you really need work with import inside workflow, i think you need override XlsxFileWriter::write function and delete DoctrineClearWriter’s call. What is wrong with your transition, system doesn’t go to next step ?

October 19, 2016 at 7:21 am #34276

Geoffroy Cochard
Participant

Hi,

Right, system doesn’t go to next step cause current DoctrineManager is clearing by DoctrineClerWriter. StepId is not updated, etc…

Geoffroy

October 19, 2016 at 10:08 am #34277

Mike Kudelya
Participant

Hi,

I think you should create getConfig function in our XlsxFileWriter, add appropriate option to $option when you call $this->exportHandler->getExportResult and check it.
Author

Replies

Viewing 5 replies - 1 through 5 (of 5 total)

The forum ‘OroPlatform – Programming Questions’ is closed to new topics and replies.

OroPlatform Forums