|
@@ -36,14 +36,21 @@ class ViolationStore extends Model
|
|
|
public function addViolationStore_content($data)
|
|
public function addViolationStore_content($data)
|
|
|
{
|
|
{
|
|
|
$insert_data = [
|
|
$insert_data = [
|
|
|
- 'first_responsible_person' => $data['first_responsible_person'],
|
|
|
|
|
- 'responsible_person' => $data['responsible_person'],
|
|
|
|
|
|
|
+ 'source_id' => $data['source_id'],
|
|
|
|
|
+ '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'],
|
|
|
'social_credit_code' => $data['social_credit_code'],
|
|
'social_credit_code' => $data['social_credit_code'],
|
|
|
|
|
+ 'province_id' => $data['province_id'],
|
|
|
|
|
+ 'province_name' => $data['province_name'],
|
|
|
|
|
+ 'city_id' => $data['city_id'],
|
|
|
|
|
+ 'city_name' => $data['city_name'],
|
|
|
|
|
+ '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'],
|
|
|
|
|
|
|
+ 'source_responsible_person' => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
|
|
|
|
|
+ 'company_category_name' => $data['company_category_name'] ? $data['company_category_name'] : '',
|
|
|
'processing_status' => '1',
|
|
'processing_status' => '1',
|
|
|
'insert_time' => time(),
|
|
'insert_time' => time(),
|
|
|
];
|
|
];
|
|
@@ -73,8 +80,8 @@ class ViolationStore extends Model
|
|
|
$ViolationStoreMemberModel = new ViolationStoreMemberModel();
|
|
$ViolationStoreMemberModel = new ViolationStoreMemberModel();
|
|
|
$insert_data = [
|
|
$insert_data = [
|
|
|
'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'],
|
|
|
'social_credit_code' => $data['social_credit_code'],
|
|
'social_credit_code' => $data['social_credit_code'],
|
|
@@ -85,13 +92,13 @@ class ViolationStore 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'].',':'',
|
|
|
|
|
- 'company_category_name' => $data['company_category_name'],
|
|
|
|
|
|
|
+ 'source_responsible_person' => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
|
|
|
|
|
+ 'company_category_name' => $data['company_category_name'] ? $data['company_category_name'] : '',
|
|
|
'processing_status' => '1',
|
|
'processing_status' => '1',
|
|
|
'insert_time' => time(),
|
|
'insert_time' => time(),
|
|
|
];
|
|
];
|
|
|
$ViolationStore_id = $this->insertGetId($insert_data);
|
|
$ViolationStore_id = $this->insertGetId($insert_data);
|
|
|
- $first_responsible_persons = $data['first_responsible_person'] !=''? explode(',', $data['first_responsible_person']):[];
|
|
|
|
|
|
|
+ $first_responsible_persons = $data['first_responsible_person'] != '' ? explode(',', $data['first_responsible_person']) : [];
|
|
|
$first_responsible_person_data = [];
|
|
$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) {
|
|
@@ -103,7 +110,7 @@ class ViolationStore extends Model
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
$ViolationStoreMemberModel->insert($first_responsible_person_data);
|
|
$ViolationStoreMemberModel->insert($first_responsible_person_data);
|
|
|
- $responsible_persons = $data['responsible_person'] !='' ? explode(',', $data['responsible_person']):[];
|
|
|
|
|
|
|
+ $responsible_persons = $data['responsible_person'] != '' ? explode(',', $data['responsible_person']) : [];
|
|
|
$responsible_person_data = [];
|
|
$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) {
|
|
@@ -115,7 +122,7 @@ class ViolationStore extends Model
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
$ViolationStoreMemberModel->insert($responsible_person_data);
|
|
$ViolationStoreMemberModel->insert($responsible_person_data);
|
|
|
- $source_responsible_persons = $data['source_responsible_person'] !='' ? explode(',', $data['source_responsible_person']):[];
|
|
|
|
|
|
|
+ $source_responsible_persons = $data['source_responsible_person'] != '' ? explode(',', $data['source_responsible_person']) : [];
|
|
|
$source_responsible_person_data = [];
|
|
$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) {
|
|
@@ -132,7 +139,7 @@ class ViolationStore 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;
|
|
|
}
|
|
}
|