|
@@ -105,7 +105,10 @@ class ImportTable2Queue
|
|
|
Db::name('system_table2')->insertAll($insert_array);
|
|
|
Db::name('system_queue')->where('id',$info['id'])->setInc('deal_count',$count);
|
|
|
|
|
|
- $names = Db::name('system_table2')->where('import_log_id',$info['id'])->where('name','neq','')->group('name')->column('name');
|
|
|
+ $names = Db::name('system_table2')
|
|
|
+ ->where('import_log_id',$info['id'])
|
|
|
+ ->where('name','neq','')
|
|
|
+ ->group('name')->column('name');
|
|
|
if ($names){
|
|
|
$insert_array = array();
|
|
|
foreach ($names as &$v){
|
|
@@ -120,7 +123,10 @@ class ImportTable2Queue
|
|
|
Db::name('system_values2')->insertAll($insert_array);
|
|
|
}
|
|
|
|
|
|
- $dms = Db::name('system_table2')->where('import_log_id',$info['id'])->whereNotNull('dm')->group('dm')->column('dm');
|
|
|
+ $dms = Db::name('system_table2')->where('import_log_id',$info['id'])
|
|
|
+ ->whereNotNull('dm')
|
|
|
+ ->group('dm')
|
|
|
+ ->column('dm');
|
|
|
if ($dms){
|
|
|
$insertarray = array();
|
|
|
foreach ($dms as &$v){
|