|
@@ -65,8 +65,8 @@ class LowPriceGoods extends Model
|
|
|
'product_name' => $data['product_name'],
|
|
'product_name' => $data['product_name'],
|
|
|
'product_specs' => $data['product_specs'],
|
|
'product_specs' => $data['product_specs'],
|
|
|
'suggested_price' => $data['suggested_price'],
|
|
'suggested_price' => $data['suggested_price'],
|
|
|
- 'online_posting_price' => $data['online_posting_price'],
|
|
|
|
|
- 'online_posting_count' => $data['online_posting_count'],
|
|
|
|
|
|
|
+ 'online_posting_price' => isset($data['online_posting_price']) ? $data['online_posting_price'] : 1,
|
|
|
|
|
+ 'online_posting_count' => isset($data['online_posting_count']) ? $data['online_posting_count'] : 1,
|
|
|
'link_url' => $data['link_url'],
|
|
'link_url' => $data['link_url'],
|
|
|
'store_name' => $data['store_name'],
|
|
'store_name' => $data['store_name'],
|
|
|
'source_responsible_person' => $data['source_responsible_person'],
|
|
'source_responsible_person' => $data['source_responsible_person'],
|
|
@@ -86,7 +86,7 @@ class LowPriceGoods extends Model
|
|
|
* @param $data
|
|
* @param $data
|
|
|
* @return bool
|
|
* @return bool
|
|
|
*/
|
|
*/
|
|
|
- public function addLowPriceGoods($data,$is_import = false)
|
|
|
|
|
|
|
+ public function addLowPriceGoods($data, $is_import = false)
|
|
|
{
|
|
{
|
|
|
if ($is_import == false) {
|
|
if ($is_import == false) {
|
|
|
$source_where[] = ['company_id', '=', $data['company_id']];
|
|
$source_where[] = ['company_id', '=', $data['company_id']];
|
|
@@ -105,15 +105,15 @@ class LowPriceGoods extends Model
|
|
|
$insert_data = [
|
|
$insert_data = [
|
|
|
'company_id' => $data['company_id'],
|
|
'company_id' => $data['company_id'],
|
|
|
'source_id' => $data['source_id'],
|
|
'source_id' => $data['source_id'],
|
|
|
- 'first_responsible_person' => $data['first_responsible_person'] ? ','.$data['first_responsible_person'].',':'',
|
|
|
|
|
- 'responsible_person' => $data['responsible_person'] ? ','.$data['responsible_person'].',':'',
|
|
|
|
|
|
|
+ 'first_responsible_person' => $data['first_responsible_person'] ? ',' . $data['first_responsible_person'] . ',' : '',
|
|
|
|
|
+ 'responsible_person' => $data['responsible_person'] ? ',' . $data['responsible_person'] . ',' : '',
|
|
|
'platform' => $data['platform'],
|
|
'platform' => $data['platform'],
|
|
|
'company_name' => $data['company_name'],
|
|
'company_name' => $data['company_name'],
|
|
|
'product_name' => $data['product_name'],
|
|
'product_name' => $data['product_name'],
|
|
|
'product_specs' => $data['product_specs'],
|
|
'product_specs' => $data['product_specs'],
|
|
|
'suggested_price' => $data['suggested_price'],
|
|
'suggested_price' => $data['suggested_price'],
|
|
|
- 'online_posting_price' => $data['online_posting_price'],
|
|
|
|
|
- 'online_posting_count' => $data['online_posting_count'],
|
|
|
|
|
|
|
+ 'online_posting_price' => isset($data['online_posting_price']) ? $data['online_posting_price'] : 1,
|
|
|
|
|
+ 'online_posting_count' => isset($data['online_posting_count']) ? $data['online_posting_count'] : 1,
|
|
|
'social_credit_code' => $data['social_credit_code'],
|
|
'social_credit_code' => $data['social_credit_code'],
|
|
|
'province_id' => $data['province_id'],
|
|
'province_id' => $data['province_id'],
|
|
|
'province_name' => $data['province_name'],
|
|
'province_name' => $data['province_name'],
|
|
@@ -122,46 +122,46 @@ class LowPriceGoods extends Model
|
|
|
'area_info' => $data['area_info'],
|
|
'area_info' => $data['area_info'],
|
|
|
'link_url' => $data['link_url'],
|
|
'link_url' => $data['link_url'],
|
|
|
'store_name' => $data['store_name'],
|
|
'store_name' => $data['store_name'],
|
|
|
- 'source_responsible_person' => $data['source_responsible_person'] ? ','.$data['source_responsible_person'].',':'',
|
|
|
|
|
|
|
+ 'source_responsible_person' => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
|
|
|
'category_name' => $data['category_name'],
|
|
'category_name' => $data['category_name'],
|
|
|
'company_category_name' => $data['company_category_name'],
|
|
'company_category_name' => $data['company_category_name'],
|
|
|
'processing_status' => '1',
|
|
'processing_status' => '1',
|
|
|
'insert_time' => time(),
|
|
'insert_time' => time(),
|
|
|
];
|
|
];
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
$LowPriceGoods_id = $this->insertGetId($insert_data);
|
|
$LowPriceGoods_id = $this->insertGetId($insert_data);
|
|
|
- $first_responsible_persons =$data['first_responsible_person'] !=''? explode(',', $data['first_responsible_person']):[];
|
|
|
|
|
- $first_responsible_person_data=[];
|
|
|
|
|
|
|
+ $first_responsible_persons = $data['first_responsible_person'] != '' ? explode(',', $data['first_responsible_person']) : [];
|
|
|
|
|
+ $first_responsible_person_data = [];
|
|
|
if (count($first_responsible_persons) > 0) {
|
|
if (count($first_responsible_persons) > 0) {
|
|
|
foreach ($first_responsible_persons as $key => $employee_id) {
|
|
foreach ($first_responsible_persons as $key => $employee_id) {
|
|
|
$first_responsible_person_data[] = [
|
|
$first_responsible_person_data[] = [
|
|
|
'lowprice_product_logid' => $LowPriceGoods_id,
|
|
'lowprice_product_logid' => $LowPriceGoods_id,
|
|
|
'employee_id' => $employee_id,
|
|
'employee_id' => $employee_id,
|
|
|
- 'duty_type' => 1,//责任类型1=第一责任人,2=责任人,3=溯源责任人
|
|
|
|
|
|
|
+ 'duty_type' => 1, //责任类型1=第一责任人,2=责任人,3=溯源责任人
|
|
|
];
|
|
];
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
$LowPriceGoodsMemberModel->insert($first_responsible_person_data);
|
|
$LowPriceGoodsMemberModel->insert($first_responsible_person_data);
|
|
|
- $responsible_persons = $data['responsible_person'] !='' ? explode(',', $data['responsible_person']):[];
|
|
|
|
|
- $responsible_person_data=[];
|
|
|
|
|
|
|
+ $responsible_persons = $data['responsible_person'] != '' ? explode(',', $data['responsible_person']) : [];
|
|
|
|
|
+ $responsible_person_data = [];
|
|
|
if (count($responsible_persons) > 0) {
|
|
if (count($responsible_persons) > 0) {
|
|
|
foreach ($responsible_persons as $key => $employee_id) {
|
|
foreach ($responsible_persons as $key => $employee_id) {
|
|
|
$responsible_person_data[] = [
|
|
$responsible_person_data[] = [
|
|
|
'lowprice_product_logid' => $LowPriceGoods_id,
|
|
'lowprice_product_logid' => $LowPriceGoods_id,
|
|
|
'employee_id' => $employee_id,
|
|
'employee_id' => $employee_id,
|
|
|
- 'duty_type' => 2,//责任类型1=第一责任人,2=责任人,3=溯源责任人
|
|
|
|
|
|
|
+ 'duty_type' => 2, //责任类型1=第一责任人,2=责任人,3=溯源责任人
|
|
|
];
|
|
];
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
$LowPriceGoodsMemberModel->insert($responsible_person_data);
|
|
$LowPriceGoodsMemberModel->insert($responsible_person_data);
|
|
|
- $source_responsible_persons = $data['source_responsible_person'] !='' ? explode(',', $data['source_responsible_person']):[];
|
|
|
|
|
- $source_responsible_person_data=[];
|
|
|
|
|
|
|
+ $source_responsible_persons = $data['source_responsible_person'] != '' ? explode(',', $data['source_responsible_person']) : [];
|
|
|
|
|
+ $source_responsible_person_data = [];
|
|
|
if (count($source_responsible_persons) > 0) {
|
|
if (count($source_responsible_persons) > 0) {
|
|
|
foreach ($source_responsible_persons as $key => $employee_id) {
|
|
foreach ($source_responsible_persons as $key => $employee_id) {
|
|
|
$source_responsible_person_data[] = [
|
|
$source_responsible_person_data[] = [
|
|
|
'lowprice_product_logid' => $LowPriceGoods_id,
|
|
'lowprice_product_logid' => $LowPriceGoods_id,
|
|
|
'employee_id' => $employee_id,
|
|
'employee_id' => $employee_id,
|
|
|
- 'duty_type' => 3,//责任类型1=第一责任人,2=责任人,3=溯源责任人
|
|
|
|
|
|
|
+ 'duty_type' => 3, //责任类型1=第一责任人,2=责任人,3=溯源责任人
|
|
|
];
|
|
];
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -171,7 +171,7 @@ class LowPriceGoods extends Model
|
|
|
// 成功处理...
|
|
// 成功处理...
|
|
|
} catch (\Exception $e) {
|
|
} catch (\Exception $e) {
|
|
|
DB::rollBack();
|
|
DB::rollBack();
|
|
|
- Log::info('job_error', '数据清洗-新增低价商品处理记录失败', ['data'=>$data,'error' => $e->getMessage()]);
|
|
|
|
|
|
|
+ Log::info('job_error', '数据清洗-新增低价商品处理记录失败', ['data' => $data, 'error' => $e->getMessage()]);
|
|
|
// 错误处理...
|
|
// 错误处理...
|
|
|
return false;
|
|
return false;
|
|
|
}
|
|
}
|