数据处理

app/Http/Services/DataService.php

@@ -52,8 +52,8 @@ class DataService
                         $supplier['legal_representative'],
                         $supplier['tax_number'],
                         $supplier['supplier_group'],
-                        str_replace(" | ",',',$supplier['stockup_type']),
-                        trim($supplier['channel_username'],','),
+                        str_replace(" | ", ',', $supplier['stockup_type']),
+                        trim($supplier['channel_username'], ','),
                         $supplier['purchase_username'] ?: '',
                         $supplier['supplier_address'],
                     ];
@@ -116,4 +116,71 @@ class DataService
             });
         })->export('xlsx');
     }
+
+    //从金蝶修复采购员
+    public function repairChannelUser()
+    {
+        set_time_limit(0);
+        $startTime = time();
+        $path = 'data' . DIRECTORY_SEPARATOR . '金蝶采购导入.xls';
+        Excel::load($path, function ($reader) use ($startTime) {
+            $results = $reader->all()->toArray();
+            foreach ($results as $result) {
+                $supplierName = $result[1];
+                $channelUserName = $result[0];
+                $channelModel = new SupplierChannelModel();
+                //只处理正式供应商
+                $supplier = $channelModel->where('supplier_name', $supplierName)->where('is_type', 0)->first();
+                //先找出对应的供应商,没有名字一样的,跳过
+                if (empty($supplier)) {
+                    continue;
+                }
+                $supplier = $supplier->toArray();
+                /**
+                 * 如果找到对应的供应商的话,先找出目前数据库里面的所有采购和对应的联系方式
+                 * 如果联系方式是空的(之前有脚本设置的默认的空联系方式),就删除,并且要修改excel的采购员进去
+                 * 但是要排除联系方式不为空的采购(即已经有完整联系人的采购)
+                 **/
+                $channelUids = $supplier['channel_uid'];
+                $supplierId = $supplier['supplier_id'];
+                if (!empty($channelUids)) {
+                    //删除为空的联系人
+                    $contactModel = new SupplierContactModel();
+                    $contactModel->where('supplier_id', $supplierId)
+                        ->where('supplier_consignee', '')->where('supplier_telephone', '')
+                        ->where('supplier_mobile', '')->where('add_time', '<', $startTime)->delete();
+                    //得到剩下的采购员
+                    $remainChannelUids = $contactModel->where('supplier_id', $supplierId)
+                        ->pluck('can_check_uids')->toArray();
+                    $channelUidData = $remainChannelUids ? implode(',', $remainChannelUids) : '';
+                    $channelModel->where('supplier_id', $supplierId)->update(['channel_uid' => $channelUidData]);
+                    //把excel的新采购员写进去(先判断是否存在)
+                    //没有联系方式的,要添加一个空的联系方式
+                    $codeModel = new IntracodeModel();
+                    $excelChannelUid = $code = $codeModel->where('admin_id', '>', 0)->join('user_info',
+                        'lie_intracode.admin_id', '=', 'user_info.userId')
+                        ->where('user_info.name', $channelUserName)
+                        ->value('code_id');
+                    //存在就可以跳过了
+                    if (in_array($excelChannelUid, $remainChannelUids)) {
+                        continue;
+                    }
+                    //不存在的话,要写一个新的空白联系人进去
+                    $contact = [
+                        'supplier_id' => $supplierId,
+                        'admin_id' => 1000,
+                        'add_time' => time(),
+                        'can_check_uids' => $excelChannelUid,
+                    ];
+                    $contactModel->insert($contact);
+                    //插入联系方式以后,就可以查询当前有多少采购,然后更新回主表里面
+                    $finalChannelUids = $contactModel->where('supplier_id',
+                        $supplierId)->pluck('can_check_uids')->toArray();
+                    $finalChannelUids = implode(',', $finalChannelUids);
+                    $channelModel->where('supplier_id', $supplierId)->update(['channel_uid' => $finalChannelUids]);
+                    dd($supplierId);
+                }
+            }
+        });
+    }
 }
\ No newline at end of file

app/Http/routes.php

@@ -40,10 +40,11 @@ Route::group(['middleware' => ['web'], 'namespace' => 'Api'], function () {
     Route::match(['get', 'post'], '/api/supplier_account/{key}', 'SupplierAccountApiController@Entrance');
 });
 Route::match(['get', 'post'], '/test', function () {
-    set_time_limit(0);
-    sleep(30);
-    echo 123;
-//    $service = new \App\Http\Services\DataService();
+//    set_time_limit(0);
+//    sleep(30);
+//    echo 123;
+    $service = new \App\Http\Services\DataService();
+    $service->repairChannelUser();
 //    $service->exportSuppliers();
 //    $service->exportSupplierContact();
 //    $service->export();