Skip to content

杨树贤 / liexin_supplier

Go to a project
Commit f3019cfb by mushishixian
Options

test

parent e0775771
Inline Side-by-side
Showing with 178 additions and 169 deletions
app/Http/Services/DataService.php
......@@ -4,6 +4,7 @@
namespace App\Http\Services;
//后台用户相关信息服务
use App\Model\BrandModel;
use App\Model\IntracodeModel;
use App\Model\SupplierChannelModel;
use App\Model\SupplierContactModel;
......@@ -12,175 +13,181 @@ use Illuminate\Support\Facades\DB;
class DataService
{
//修复数据
public function repairData($limit = 0)
{
//先找出和无效采购员(离职或者不是采购员)相关的供应商
//写死
$invalidChannelUserName = [
"葛金菊",
"姜喆",
"罗晓民",
"周亚琳",
"左佳晨",
"陈泽彬",
"李跃",
"赵佩旋",
"朱国军",
"许金荣",
"余佳兰",
"李晶晶",
"朱玉嘉"
];
//找出对应的code_id
$userModel = new UserInfoModel();
$invalidChannelUserIds = $userModel->whereIn('name', $invalidChannelUserName)->pluck('userId');
//找出对应的codeId
$adminUserService = new AdminUserService();
$codeIds = $adminUserService->getCodeIdsByUserIds($invalidChannelUserIds);
$codeIds = $codeIds->toArray();
$likeSqlRaw = implode('|', $codeIds);
$model = new SupplierChannelModel();
//根据code_id去找供应商表里面找到包含该code_id的供应商
if (!empty($limit)) {
$suppliers = $model->whereRaw("channel_uid REGEXP '$likeSqlRaw'")->where('is_type',
0)->limit($limit)->get();
} else {
$suppliers = $model->whereRaw("channel_uid REGEXP '$likeSqlRaw'")->where('is_type', 0)->get();
}
if ($suppliers) {
$suppliers = $suppliers->toArray();
} else {
echo "已经处理完";
die;
}
$i = 0;
foreach ($suppliers as $supplier) {
$channelUidResult = [];
$channelUid = explode(',', $supplier['channel_uid']);
foreach ($channelUid as $key => $uid) {
//如果不属于不合理采购员codeId,则保留
if (!in_array($uid, $codeIds)) {
$channelUidResult[] = $uid;
}
}
$channelUidResult = implode(',', $channelUidResult);
$content = "采购员从" . implode(',', $channelUid) . '修改到' . $channelUidResult;
//写日志
$remark = implode(',', $channelUid) . "|" . $channelUidResult;
$logService = new LogService();
$logService->AddLog($supplier['supplier_id'], 1, "系统修改采购员", $content, $remark);
$model->where('supplier_id', $supplier['supplier_id'])->update([
'channel_uid' => $channelUidResult,
]);
$i++;
if (!empty($limit)) {
print_r($supplier['supplier_id'] . "<br>");
}
}
echo "修改了${i}条记录";
die;
}
//补全联系人
public function completeContact($limit = 0)
{
$i = 0;
//先找出联系人和采购员数量对不上的记录;
$model = new SupplierChannelModel();
if (!empty($limit)) {
$suppliers = $model->where('is_type', 0)->limit($limit)->get()->toArray();
} else {
$suppliers = $model->where('is_type', 0)->get()->toArray();
}
$contactModel = new SupplierContactModel();
foreach ($suppliers as $supplier) {
//找出联系人数量
if (empty($supplier['channel_uid'])) {
continue;
}
$contactCount = $contactModel->where('supplier_id', $supplier['supplier_id'])->where('can_check_uids', '!=',
'')->count();
$channelUidCount = count(explode(',', $supplier['channel_uid']));
if ($contactCount >= $channelUidCount) {
continue;
}
//直接根据采购员id
// $needAppendCount = $channelUidCount - $count;
// $countArray = array_fill(0, $needAppendCount, 1);
$countArray = array_fill(0, $channelUidCount, 1);
//补的时候,记得把采购员id写进去
$channelUids = explode(',', $supplier['channel_uid']);
foreach ($countArray as $key => $value) {
$channelUserId = $channelUids[$key];
$data = [
'supplier_id' => $supplier['supplier_id'],
'can_check_uids' => $channelUserId,
'add_time' => time(),
'admin_id' => 1000,
];
$contactModel->insert($data);
}
$i++;
if (!empty($limit)) {
print_r($supplier['supplier_id'] . "<br>");
}
// dd($supplier['supplier_id']);
}
echo "已经处理" . $i . "家供应商的联系方式";
}
//导出不合理的采购员的供应商
public function exportNotValidChannelUid()
{
$supplierModel = new SupplierChannelModel();
$list = $supplierModel->where('is_type', 0)->whereRaw('length(channel_uid) > 5')->get();
$result = [];
foreach ($list as $key => $item) {
$channelUid = explode(',', $item['channel_uid']);
$adminService = new AdminUserService();
$names = [];
foreach ($channelUid as $codeId) {
$user = $adminService->getAdminUserInfoByCodeId($codeId);
$name = array_get($user, 'name');
$names[] = $name;
}
$names = implode('|', $names);
$result[] = [
'name' => '"' . $item['supplier_name'] . '"',
'value' => $names,
'code' => $item['supplier_code']
];
}
// 需要导出的内容
// 文件名，这里都要将utf-8编码转为gbk，要不可能出现乱码现象
$filename = $this->utfToGbk('导出csv文件.csv');
// 拼接文件信息，这里注意两点
// 1、字段与字段之间用逗号分隔开
// 2、行与行之间需要换行符
$fileData = $this->utfToGbk('编码, 姓名, 采购') . "\n";
foreach ($result as $value) {
$temp = $value['code'] . ',' . $value['name'] . ',' .
$value['value'];
$fileData .= $this->utfToGbk($temp) . "\n";
}
// 头信息设置
header("Content-type:text/csv");
header("Content-Disposition:attachment;filename=" . $filename);
header('Cache-Control:must-revalidate,post-check=0,pre-check=0');
header('Expires:0');
header('Pragma:public');
echo $fileData;
exit;
}
// //修复数据
// public function repairData($limit = 0)
// {
// //先找出和无效采购员(离职或者不是采购员)相关的供应商
// //写死
// $invalidChannelUserName = [
// "葛金菊",
// "姜喆",
// "罗晓民",
// "周亚琳",
// "左佳晨",
// "陈泽彬",
// "李跃",
// "赵佩旋",
// "朱国军",
// "许金荣",
// "余佳兰",
// "李晶晶",
// "朱玉嘉"
// ];
// //找出对应的code_id
// $userModel = new UserInfoModel();
// $invalidChannelUserIds = $userModel->whereIn('name', $invalidChannelUserName)->pluck('userId');
// //找出对应的codeId
// $adminUserService = new AdminUserService();
// $codeIds = $adminUserService->getCodeIdsByUserIds($invalidChannelUserIds);
// $codeIds = $codeIds->toArray();
// $likeSqlRaw = implode('|', $codeIds);
// $model = new SupplierChannelModel();
// //根据code_id去找供应商表里面找到包含该code_id的供应商
// if (!empty($limit)) {
// $suppliers = $model->whereRaw("channel_uid REGEXP '$likeSqlRaw'")->where('is_type',
// 0)->limit($limit)->get();
// } else {
// $suppliers = $model->whereRaw("channel_uid REGEXP '$likeSqlRaw'")->where('is_type', 0)->get();
// }
// if ($suppliers) {
// $suppliers = $suppliers->toArray();
// } else {
//
// echo "已经处理完";
// die;
// }
// $i = 0;
// foreach ($suppliers as $supplier) {
// $channelUidResult = [];
// $channelUid = explode(',', $supplier['channel_uid']);
// foreach ($channelUid as $key => $uid) {
// //如果不属于不合理采购员codeId,则保留
// if (!in_array($uid, $codeIds)) {
// $channelUidResult[] = $uid;
// }
// }
// $channelUidResult = implode(',', $channelUidResult);
// $content = "采购员从" . implode(',', $channelUid) . '修改到' . $channelUidResult;
// //写日志
// $remark = implode(',', $channelUid) . "|" . $channelUidResult;
// $logService = new LogService();
// $logService->AddLog($supplier['supplier_id'], 1, "系统修改采购员", $content, $remark);
// $model->where('supplier_id', $supplier['supplier_id'])->update([
// 'channel_uid' => $channelUidResult,
// ]);
// $i++;
// if (!empty($limit)) {
// print_r($supplier['supplier_id'] . "<br>");
// }
// }
// echo "修改了${i}条记录";
// die;
// }
//
// //补全联系人
// public function completeContact($limit = 0)
// {
// $i = 0;
// //先找出联系人和采购员数量对不上的记录;
// $model = new SupplierChannelModel();
// if (!empty($limit)) {
// $suppliers = $model->where('is_type', 0)->limit($limit)->get()->toArray();
// } else {
// $suppliers = $model->where('is_type', 0)->get()->toArray();
// }
// $contactModel = new SupplierContactModel();
// foreach ($suppliers as $supplier) {
// //找出联系人数量
// if (empty($supplier['channel_uid'])) {
// continue;
// }
// $contactCount = $contactModel->where('supplier_id', $supplier['supplier_id'])->where('can_check_uids', '!=',
// '')->count();
// $channelUidCount = count(explode(',', $supplier['channel_uid']));
// if ($contactCount >= $channelUidCount) {
// continue;
// }
// //直接根据采购员id
//// $needAppendCount = $channelUidCount - $count;
//// $countArray = array_fill(0, $needAppendCount, 1);
// $countArray = array_fill(0, $channelUidCount, 1);
// //补的时候,记得把采购员id写进去
// $channelUids = explode(',', $supplier['channel_uid']);
// foreach ($countArray as $key => $value) {
// $channelUserId = $channelUids[$key];
// $data = [
// 'supplier_id' => $supplier['supplier_id'],
// 'can_check_uids' => $channelUserId,
// 'add_time' => time(),
// 'admin_id' => 1000,
// ];
// $contactModel->insert($data);
// }
// $i++;
// if (!empty($limit)) {
// print_r($supplier['supplier_id'] . "<br>");
// }
//// dd($supplier['supplier_id']);
// }
// echo "已经处理" . $i . "家供应商的联系方式";
// }
//
// //导出不合理的采购员的供应商
// public function exportNotValidChannelUid()
// {
// $supplierModel = new SupplierChannelModel();
// $list = $supplierModel->where('is_type', 0)->whereRaw('length(channel_uid) > 5')->get();
// $result = [];
// foreach ($list as $key => $item) {
// $channelUid = explode(',', $item['channel_uid']);
// $adminService = new AdminUserService();
// $names = [];
// foreach ($channelUid as $codeId) {
// $user = $adminService->getAdminUserInfoByCodeId($codeId);
// $name = array_get($user, 'name');
// $names[] = $name;
// }
// $names = implode('|', $names);
// $result[] = [
// 'name' => '"' . $item['supplier_name'] . '"',
// 'value' => $names,
// 'code' => $item['supplier_code']
// ];
// }
//
// // 需要导出的内容
//
// // 文件名，这里都要将utf-8编码转为gbk，要不可能出现乱码现象
// $filename = $this->utfToGbk('导出csv文件.csv');
//
// // 拼接文件信息，这里注意两点
// // 1、字段与字段之间用逗号分隔开
// // 2、行与行之间需要换行符
// $fileData = $this->utfToGbk('编码, 姓名, 采购') . "\n";
// foreach ($result as $value) {
// $temp = $value['code'] . ',' . $value['name'] . ',' .
// $value['value'];
// $fileData .= $this->utfToGbk($temp) . "\n";
// }
//
// // 头信息设置
// header("Content-type:text/csv");
// header("Content-Disposition:attachment;filename=" . $filename);
// header('Cache-Control:must-revalidate,post-check=0,pre-check=0');
// header('Expires:0');
// header('Pragma:public');
// echo $fileData;
// exit;
// }
//
// function utfToGbk($data)
// {
// return iconv('utf-8', 'GBK', $data);
// }
function utfToGbk($data)
public function test()
{
return iconv('utf-8', 'GBK', $data);
$model = new BrandModel();
dd(DB::connection('spu')->table('brand')->count());
}
}
\ No newline at end of file
app/Http/routes.php
......@@ -42,6 +42,7 @@ Route::group(['middleware' => ['web'], 'namespace' => 'Api'], function () {
});
Route::match(['get', 'post'], '/test', function () {
$service = new \App\Http\Services\DataService();
$service->repairData(10);
$service->test();
// $service->repairData(10);
// $service->completeContact(10);
});
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment