Commit ff62e9ce by Vladislav

#19499 Загрузка модификаторов ставок

1 parent 3da4755f
......@@ -53,7 +53,7 @@ class BidModifiersAdd extends Command
$factory = APIRequest::getInstance(API::YANDEX);
$factory->setToken($token);
$goalAds = DB::table('goal_bid_modifiers')
$goalBidModifiers = DB::table('goal_bid_modifiers')
->join('bid_modifiers', 'goal_bid_modifiers.bid_modifier_id', '=', 'bid_modifiers.id')
->whereNull('bid_modifiers.deleted_at')
->whereNull('goal_bid_modifiers.external_id')
......@@ -67,19 +67,25 @@ class BidModifiersAdd extends Command
->whereNotNull('goal_bid_modifiers.dictionary_campaign_external_id')
->whereIn('goal_bid_modifiers.dictionary_campaign_id', $token->dictionaryCampaignsEnabledForExternalSynchronized->pluck('id'))
->select([
'goal_bid_modifiers.id as id',
'goal_bid_modifiers.dictionary_campaign_id as dictionary_campaign_id',
'goal_bid_modifiers.dictionary_campaign_external_id as dictionary_campaign_external_id',
'goal_bid_modifiers.goal_ad_group_external_id as goal_ad_group_external_id',
'bid_modifiers.mobile_adjustment as mobile_adjustment',
'bid_modifiers.desktop_adjustment as desktop_adjustment',
'bid_modifiers.demographics_adjustment as demographics_adjustment',
'bid_modifiers.retargeting_adjustment as retargeting_adjustment',
DB::raw('json_arrayagg(bid_modifiers.id) as ids'),
DB::raw('json_arrayagg(bid_modifiers.demographics_adjustment) as demographics_adjustments'),
DB::raw('json_arrayagg(bid_modifiers.retargeting_adjustment) as retargeting_adjustments'),
])
->groupBy([
'goal_bid_modifiers.dictionary_campaign_external_id',
'goal_bid_modifiers.goal_ad_group_external_id',
'bid_modifiers.mobile_adjustment',
'bid_modifiers.desktop_adjustment',
])
->get();
$factory->getRequest('Ads', 'add')
$factory->getRequest('BidModifiers', 'add')
->call([
'goalAds' => $goalAds,
'goalBidModifiers' => $goalBidModifiers,
]);
}
......
......@@ -152,8 +152,9 @@ class DictionaryCampaignsSyncByCampaign extends Command
FROM bid_modifiers bm
INNER JOIN campaigns c on bm.campaign_id = c.id
INNER JOIN dictionary_campaigns dc on dc.campaign_id = c.id
LEFT JOIN goal_ad_groups gag on dc.dictionary_id = gag.dictionary_campaign_id
LEFT JOIN goal_bid_modifiers gbm on bm.id = gbm.bid_modifier_id AND (gbm.goal_ad_group_id = gag.id OR gbm.goal_ad_group_id IS NULL)
LEFT JOIN ad_groups ag on c.id = ag.campaign_id AND bm.ad_group_id = ag.id
LEFT JOIN goal_ad_groups gag on dc.dictionary_id = gag.dictionary_campaign_id AND ag.id = gag.ad_group_id
LEFT JOIN goal_bid_modifiers gbm on bm.id = gbm.bid_modifier_id
WHERE gbm.bid_modifier_id is null
");
......
......@@ -451,7 +451,7 @@ class DictionaryCampaign extends Pivot
public function goalBidModifiers()
{
return $this->hasMany(BidModifier::class, 'dictionary_campaign_id');
return $this->hasMany(GoalBidModifier::class, 'dictionary_campaign_id');
}
public function goalBidModifiersForNotExternal()
......
......@@ -3,6 +3,7 @@
namespace App\Models\Pivots;
use App\Models\AdGroup;
use App\Models\BidModifier;
use App\Models\Variable;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Relations\Pivot;
......@@ -202,4 +203,9 @@ class GoalAdGroup extends Pivot
return $this->hasMany(GoalAdvertisement::class, 'goal_ad_group_id');
}
public function goalBidModifiers()
{
return $this->hasMany(BidModifier::class, 'goal_ad_group_id');
}
}
......@@ -8,7 +8,7 @@ use Illuminate\Database\Eloquent\Relations\Pivot;
use Illuminate\Database\Eloquent\SoftDeletes;
/**
* App\Models\Pivots\BidModifiers
* App\Models\Pivots\GoalBidModifier
*
* @property int $id
* @property int|null $external_id
......
......@@ -84,6 +84,10 @@ class AddAdGroups extends DirectRequest
'goal_ad_group_external_id' => $external_id,
]);
$goalAdGroup->goalBidModifiers()->update([
'goal_ad_group_external_id' => $external_id,
]);
}
} catch (\Exception $e) {
Log::debug($e);
......
......@@ -16,7 +16,7 @@ class AddBidModifiers extends DirectRequest
protected $max_count = 1000;
protected $timestamp;
/* @var Collection|GoalBidModifier[]|BidModifier[]|\stdClass[] */
/* @var Collection|\stdClass[] */
protected $goalBidModifiers;
public function call($params = null)
......@@ -49,7 +49,6 @@ class AddBidModifiers extends DirectRequest
public function handle($response)
{
try {
\Log::debug($response);
if (isset($response['result']['Errors'])) {
Log::debug($response['Errors']);
Log::debug($this->getParams());
......@@ -69,10 +68,10 @@ class AddBidModifiers extends DirectRequest
$external_id = (string)$add_result['Id'];
/* @var $goalAd GoalBidModifier|BidModifier|\stdClass */
/* @var $goalAd \stdClass */
$goalAd = $this->goalBidModifiers->get($key);
GoalBidModifier::whereId($goalAd->id)
GoalBidModifier::whereIn('id', $goalAd->ids)
->update([
'external_id' => $external_id,
'external_upload_at' => Carbon::now(),
......@@ -100,7 +99,7 @@ class AddBidModifiers extends DirectRequest
$this->setParams([
'BidModifiers' => $this->goalBidModifiers->map(function ($goalBidModifier) {
/* @var $goalBidModifier GoalBidModifier|BidModifier|\stdClass */
/* @var $goalBidModifier \stdClass */
$data = [
'CampaignId' => $goalBidModifier->dictionary_campaign_external_id,
......@@ -110,20 +109,43 @@ class AddBidModifiers extends DirectRequest
$data['AdGroupId'] = $goalBidModifier->goal_ad_group_external_id;
}
if ($mobile_adjustment = @json_decode($goalBidModifier->mobile_adjustment)) {
if ($mobile_adjustment = @json_decode($goalBidModifier->mobile_adjustment, true)) {
$data['MobileAdjustment'] = $mobile_adjustment;
}
if ($desktop_adjustment = @json_decode($goalBidModifier->desktop_adjustment)) {
} elseif ($desktop_adjustment = @json_decode($goalBidModifier->desktop_adjustment, true)) {
$data['DesktopAdjustment'] = $desktop_adjustment;
}
if ($demographics_adjustment = @json_decode($goalBidModifier->demographics_adjustment)) {
$data['DemographicsAdjustments'] = $demographics_adjustment;
}
} elseif ($demographics_adjustments = array_map(function ($demographics_adjustment) {
unset($demographics_adjustment['Enabled']);
if (is_null($demographics_adjustment['Gender'])) {
unset($demographics_adjustment['Gender']);
}
if (is_null($demographics_adjustment['Age'])) {
unset($demographics_adjustment['Age']);
}
return $demographics_adjustment;
}, array_filter(@json_decode($goalBidModifier->demographics_adjustments, true)))) {
$data['DemographicsAdjustments'] = $demographics_adjustments;
} elseif ($retargeting_adjustments = array_map(function ($retargeting_adjustment) {
unset($retargeting_adjustment['Accessible']);
unset($retargeting_adjustment['Enabled']);
return $retargeting_adjustment;
}, array_filter(@json_decode($goalBidModifier->retargeting_adjustments, true)))) {
if ($retargeting_adjustment = @json_decode($goalBidModifier->retargeting_adjustment)) {
$data['RetargetingAdjustments'] = $retargeting_adjustment;
$data['RetargetingAdjustments'] = $retargeting_adjustments;
}
return $data;
......
......@@ -90,6 +90,10 @@ class AddCampaigns extends DirectRequest
'dictionary_campaign_external_id' => $external_id,
]);
$dictionaryCampaign->goalBidModifiers()->update([
'dictionary_campaign_external_id' => $external_id,
]);
}
} catch (\Exception $e) {
Log::debug($e);
......
......@@ -114,12 +114,12 @@ class GetBidModifiers extends DirectRequest
'campaign_id' => $campaign->getKey(),
'ad_group_id' => $adGroup ? $adGroup->getKey() : null,
'level' => $bid_modifier['Status'],
'type' => $bid_modifier['State'],
'mobile_adjustment' => $bid_modifier['MobileAdjustment'],
'desktop_adjustment' => $bid_modifier['DesktopAdjustment'],
'demographics_adjustment' => $bid_modifier['DemographicsAdjustment'],
'retargeting_adjustment' => $bid_modifier['RetargetingAdjustment'],
'level' => $bid_modifier['Level'],
'type' => $bid_modifier['Type'],
'mobile_adjustment' => $bid_modifier['MobileAdjustment'] ?? null,
'desktop_adjustment' => $bid_modifier['DesktopAdjustment'] ?? null,
'demographics_adjustment' => $bid_modifier['DemographicsAdjustment'] ?? null,
'retargeting_adjustment' => $bid_modifier['RetargetingAdjustment'] ?? null,
'updated_self' => null,
];
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!