DECLARE
activityId NUMBER;
dicstatus NUMBER;
BEGIN
DELETE FROM error_messages WHERE object_id = 781379;

FOR cu_row IN (SELECT id, message, object_id FROM error_messages WHERE EXCEPTION LIKE '%com.comarch.integration.endpoint.api.PluginProcessException: java.lang.NumberFormatException: null%')
LOOP
      SELECT activity_id INTO activityId FROM TT_TASKS_TG@CRMDB.LINK WHERE id = cu_row.object_id;
      DBMS_OUTPUT.PUT_LINE('TaskId: ' || cu_row.id || ' ActivityId: ' || activityId);
      UPDATE error_messages SET message =
      (
        SELECT INSERTCHILDXML(XMLTYPE(message), 'task', 'activityId',  XMLType('<activityId>' || activityId || '</activityId>')).getclobval() FROM error_messages WHERE id = cu_row.id
      ), status = 'P' WHERE id = cu_row.id AND status = 'E';

      SELECT dic_task_status_id INTO dicstatus FROM TT_TASKS_TG@CRMDB.LINK WHERE id = cu_row.object_id;

      IF dicstatus = 344 THEN
        UPDATE TT_TASKS_TG@CRMDB.LINK SET dic_task_status_id=345 WHERE id = cu_row.object_id;
      END IF;
END LOOP;

COMMIT;
END;