Custom.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347
  1. <?php namespace App\Http\Controllers\Admin;
  2. use App\Http\Requests\Admin\Custom as Request;
  3. use App\Models\City;
  4. use App\Models\Custom as Model;
  5. use App\Models\CustomAddr;
  6. use App\Models\CustomScore;
  7. use Illuminate\Support\Carbon;
  8. use App\Models\WeiBan\Follow as WeiBanFollow;
  9. use App\Models\Work\User as WorkUser;
  10. use App\Models\FilesManager;
  11. use App\Models\WeiBan\External as WeiBanExternal;
  12. use PhpOffice\PhpSpreadsheet\Cell\DataType;
  13. use PhpOffice\PhpSpreadsheet\IOFactory;
  14. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  15. use PhpOffice\PhpSpreadsheet\Style\Alignment;
  16. use PhpOffice\PhpSpreadsheet\Style\Fill;
  17. /**
  18. * 客户管理
  19. *
  20. * @author 刘相欣
  21. *
  22. */
  23. class Custom extends Auth{
  24. protected function _initialize(){
  25. parent::_initialize();
  26. $this->assign('breadcrumb1','用户管理');
  27. $this->assign('breadcrumb2','客户管理');
  28. }
  29. /**
  30. * 列表页
  31. *
  32. * */
  33. public function index(Model $Model,CustomScore $CustomScore,WeiBanFollow $WeiBanFollow,City $City,WorkUser $WorkUser){
  34. // 接受参数
  35. $code = request('custom_code','');
  36. $phone = request('phone','');
  37. $username = request('username','');
  38. $weibanId = request('external_userid','');
  39. $cityId = request('city_id',0);
  40. $status = request('status');
  41. $startTime = request('start_time','');
  42. // 编码转ID
  43. $uid = $Model->codeToId($code);
  44. // 查询条件
  45. $map = [];
  46. // 编码ID
  47. if( $uid ) $map[] = ['uid','=',$uid];
  48. if( $phone ) $map[] = ['phone','=',$phone];
  49. if( $username ) $map[] = ['username','=',$username];
  50. if( $cityId ) $map[] = ['city_id','=',$cityId];
  51. if( $weibanId ) $map[] = ['external_userid','=',$weibanId];
  52. if( $startTime ) $map[] = ['insert_time','>=',Carbon::createFromFormat('Y-m-d',$startTime)->startOfDay()->getTimestamp()];
  53. if( $startTime ) $map[] = ['insert_time','<=',Carbon::createFromFormat('Y-m-d',$startTime)->endOfDay()->getTimestamp()];
  54. if( !is_null($status) ) $map[] = ['status','=',$status];
  55. // 查询数据
  56. $list = $Model->query()->where($map)->orderByDesc('uid')->paginate(config('page_num',10))->appends(request()->all());
  57. // 循环处理数据
  58. foreach ($list as $key => $value) {
  59. // 城市名
  60. $value['city_name'] = $value['city_id'] ? $City->getOne($value['city_id'],'name') : '';
  61. // id转编号
  62. $value['custom_code'] = $Model->idToCode($value['uid']);
  63. // id转编号
  64. $value['custom_score'] = $CustomScore->getCustomScore($value['uid']);
  65. // 如果不存在微伴ID
  66. if( !$value['external_userid'] ) {
  67. // 通过手机号查询注册的账号
  68. $value['external_userid'] = (string) $WorkUser->query()->where([['remark_mobiles','=',$value['phone']]])->value('external_userid');
  69. // 如果存在的话,修正
  70. if( $value['external_userid'] ) $Model->edit($value['uid'],['external_userid'=>$value['external_userid']]);
  71. }
  72. // 重组
  73. $list[$key] = $value;
  74. }
  75. // 获取列表
  76. $cityList = $City->getCityList();
  77. // 分配数据
  78. $this->assign('cityList',$cityList);
  79. // 分配数据
  80. $this->assign('empty', '<tr><td colspan="20">~~暂无数据</td></tr>');
  81. $this->assign('list',$list);
  82. // 加载模板
  83. return $this->fetch();
  84. }
  85. /**
  86. * 添加
  87. *
  88. * */
  89. public function add(Request $request,Model $Model){
  90. if( request()->isMethod('post') ){
  91. // 验证参数
  92. $request->scene('add')->validate();
  93. // 接收数据
  94. // 接收数据
  95. $data['username'] = request('username','');
  96. $data['phone'] = request('phone','');
  97. // 写入数据表
  98. $uid = $Model->add($data);
  99. // 如果操作失败
  100. if( !$uid ) return json_send(['code'=>'error','msg'=>'新增失败']);
  101. // 记录行为
  102. $this->addAdminHistory(admin('uid'),$Model->getTable(),$uid,1,[],$data);
  103. // 告知结果
  104. return json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
  105. }
  106. // 分配数据
  107. $this->assign('crumbs','新增');
  108. // 加载模板
  109. return $this->fetch();
  110. }
  111. /**
  112. * 修改
  113. *
  114. * */
  115. public function edit(Request $request,Model $Model,City $City){
  116. // 接收参数
  117. $uid = request('uid',0);
  118. // 查询用户
  119. $oldData = $Model->where(['uid'=>$uid])->first();
  120. // 修改
  121. if(request()->isMethod('post')){
  122. // 验证参数
  123. $request->scene('edit')->validate();
  124. // 如果用户不存在
  125. if( !$oldData ) return json_send(['code'=>'error','msg'=>'用户不存在']);
  126. // 转数组
  127. $oldData = $oldData->toArray();
  128. // 接收数据
  129. $data['username'] = request('username','');
  130. $data['phone'] = request('phone','');
  131. $data['city_id'] = request('city_id',0);
  132. $data['external_userid'] = request('external_userid','');
  133. // 写入数据表
  134. $result = $Model->edit($uid,$data);
  135. // 如果操作失败
  136. if( !$result ) return json_send(['code'=>'error','msg'=>'新增失败']);
  137. // 记录行为
  138. $this->addAdminHistory(admin('uid'),$Model->getTable(),$uid,2,$oldData,$data);
  139. // 告知结果
  140. return json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);
  141. }
  142. // 错误告知
  143. if( !$oldData ) return $this->error('查无数据');
  144. // 获取列表
  145. $cityList = $City->getCityList();
  146. // 分配数据
  147. $this->assign('cityList',$cityList);
  148. $this->assign('oldData',$oldData);
  149. $this->assign('crumbs','修改');
  150. // 加载模板
  151. return $this->fetch();
  152. }
  153. /**
  154. * 修改状态
  155. *
  156. * */
  157. public function set_status(Request $request,Model $Model){
  158. // 验证参数
  159. $request->scene('set_status')->validate();
  160. // 设置状态
  161. $uid = request('uid',0);
  162. $status = request('status',0);
  163. // 查询用户
  164. $oldData = $Model->where(['uid'=>$uid])->first();
  165. // 如果用户不存在
  166. if( !$oldData ) return json_send(['code'=>'error','msg'=>'用户不存在']);
  167. // 执行修改
  168. $result = $Model->edit($uid,['status'=>$status]);
  169. // 提示新增失败
  170. if( !$result ) return json_send(['code'=>'error','msg'=>'设置失败']);
  171. // 记录行为
  172. $this->addAdminHistory(admin('uid'),$Model->getTable(),$uid,2,$oldData,['status'=>$status]);
  173. // 告知结果
  174. return json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
  175. }
  176. /**
  177. * 表格导入
  178. *
  179. * */
  180. public function import_execl( Request $request,Model $Model,FilesManager $FilesManager,City $City,CustomAddr $CustomAddr,WeiBanExternal $WeiBanExternal){
  181. // 验证参数
  182. $request->scene('import_execl')->validate();
  183. // 获取表格信息
  184. $file = request()->file('custom_file');
  185. // 返回结果
  186. $sheetList = $FilesManager->excelToCustom($file);
  187. // 如果不存在结果
  188. if( isset($sheetList['error']) ) return json_send(['code'=>'error','msg'=>$sheetList['error']]);
  189. // 循环表格数据
  190. foreach ($sheetList as $value) {
  191. // 获取城市ID
  192. $value['city_id'] = 0;
  193. // 存在城市名称,查询城市ID
  194. if( $value['contact_city'] ) {
  195. // 获取城市ID
  196. $value['city_id'] = (int) $City->getIdByName($value['contact_city']);
  197. // 如果城市不存在的话
  198. if ( !$value['city_id'] ) return json_send(['code'=>'error','msg'=>$value['contact_city'].' => 未找到匹配的城市,请核对城市全称']);
  199. }
  200. // 获取手机号,查询是否用客户
  201. $custom = $Model->getOneByPhone($value['phone']);
  202. // 组装数据
  203. $data = ['external_userid'=>$value['external_userid'],'username'=>$value['username']];
  204. // 如果客户不存在
  205. if( !$custom ) $data['phone'] = $value['phone'];
  206. // 如果存在城市ID,才修改城市
  207. if( $value['city_id'] ) $data['city_id'] = $value['city_id'];
  208. // 如果存在手机号
  209. $uid = $custom ? $Model->edit($custom['uid'],$data) : $Model->add($data);
  210. // 如果客户存在
  211. if( !$uid ) return json_send(['code'=>'error','msg'=>$value['username'].'【'.$value['phone'].'】'.'用户创建或者更新失败']);
  212. // 存在详细地址,才创建地址库
  213. if( $value['contact_name'] && $value['contact_phone'] && $value['contact_province'] && $value['contact_city'] && $value['contact_area'] && $value['contact_addr'] ) {
  214. // 收件地址是否存在
  215. $oldAddr = $CustomAddr->query()->where([['custom_uid','=',$uid]])->first();
  216. // 如果不存在地址
  217. if( !$oldAddr ) $CustomAddr->add(['custom_uid'=>$uid,'contact_name'=>$value['contact_name'],'contact_shop'=>$value['contact_shop'],'contact_phone'=>$value['contact_phone'],'contact_province'=>$value['contact_province'],'contact_city'=>$value['contact_city'],'contact_area'=>$value['contact_area'],'contact_addr'=>$value['contact_addr']]);
  218. }
  219. }
  220. // 提示成功
  221. return json_send(['code'=>'success','msg'=>'批量导入成功','path'=>'']);
  222. }
  223. /**
  224. * 导出表格
  225. *
  226. * */
  227. public function down_excel(Model $Model,City $City){
  228. // 接受参数
  229. $code = request('custom_code','');
  230. $phone = request('phone','');
  231. $username = request('username','');
  232. $weibanId = request('external_userid','');
  233. $cityId = request('city_id',0);
  234. $status = request('status');
  235. $startTime = request('start_time','');
  236. // 编码转ID
  237. $uid = $Model->codeToId($code);
  238. // 查询条件
  239. $map = [];
  240. // 编码ID
  241. if( $uid ) $map[] = ['uid','=',$uid];
  242. if( $phone ) $map[] = ['phone','=',$phone];
  243. if( $username ) $map[] = ['username','=',$username];
  244. if( $cityId ) $map[] = ['city_id','=',$cityId];
  245. if( $weibanId ) $map[] = ['external_userid','=',$weibanId];
  246. if( $startTime ) $map[] = ['insert_time','>=',Carbon::createFromFormat('Y-m-d',$startTime)->startOfDay()->getTimestamp()];
  247. if( $startTime ) $map[] = ['insert_time','<=',Carbon::createFromFormat('Y-m-d',$startTime)->endOfDay()->getTimestamp()];
  248. if( !is_null($status) ) $map[] = ['status','=',$status];
  249. // 查询数据
  250. $list = $Model->query()->where($map)->orderByDesc('uid')->get()->toArray();
  251. // 循环处理数据
  252. foreach ($list as $key => $value) {
  253. // 城市名
  254. $value['city_name'] = $value['city_id'] ? $City->getOne($value['city_id'],'name') : '';
  255. // id转编号
  256. $value['custom_code'] = $Model->idToCode($value['uid']);
  257. // 重组
  258. $list[$key] = $value;
  259. }
  260. try {
  261. // 去下载
  262. $this->toDown($list);
  263. } catch (\Throwable $th) {
  264. echo $th->getMessage();
  265. }
  266. }
  267. /**
  268. * 去下载
  269. */
  270. private function toDown($data){
  271. // 创建新的电子表格对象
  272. $spreadsheet = new Spreadsheet();
  273. // 设置合并单元格的行和列,例如合并A1到B2的单元格
  274. $sheet = $this->setStyle($spreadsheet);
  275. // 从第二行写入
  276. $row = 2;
  277. // 循环写入
  278. foreach ($data as $value) {
  279. // 单元格内容写入
  280. $sheet->setCellValue('A'.$row, $value['custom_code']);
  281. //避免 = + - 识别成公式
  282. $sheet->setCellValueExplicit('B'.$row, $value['username'],DataType::TYPE_STRING);
  283. $sheet->setCellValue('C'.$row, $value['phone']);
  284. $sheet->setCellValue('D'.$row, $value['external_userid']);
  285. $sheet->setCellValue('E'.$row, $value['city_name']);
  286. $sheet->setCellValue('F'.$row, $value['status']?'禁用':'正常');
  287. $sheet->setCellValue('G'.$row, date('Y-m-d H:i:s',$value['insert_time']));
  288. $sheet->setCellValue('H'.$row, date('Y-m-d H:i:s',$value['update_time']));
  289. // 行数+1
  290. $row++;
  291. }
  292. // 创建内容
  293. $writer = IOFactory::createWriter($spreadsheet, 'Xlsx');
  294. header('Pragma: public');
  295. header('Content-type:application/vnd.ms-excel');
  296. header('Content-Disposition: inline;filename=客户列表.xlsx');
  297. // 输出数据流
  298. return $writer->save('php://output');
  299. }
  300. /**
  301. * 设置表格样式
  302. *
  303. */
  304. private function setStyle(Spreadsheet $spreadsheet){
  305. // 选择当前活动的工作表
  306. $sheet = $spreadsheet->getActiveSheet();
  307. // 宽
  308. $sheet->getColumnDimension('A')->setWidth(15);
  309. $sheet->getColumnDimension('B')->setWidth(15);
  310. $sheet->getColumnDimension('C')->setWidth(15);
  311. $sheet->getColumnDimension('D')->setWidth(30);
  312. $sheet->getColumnDimension('E')->setWidth(15);
  313. $sheet->getColumnDimension('F')->setWidth(15);
  314. $sheet->getColumnDimension('G')->setWidth(20);
  315. $sheet->getColumnDimension('H')->setWidth(20);
  316. // 默认高度
  317. $sheet->getDefaultRowDimension()->setRowHeight(18);
  318. // 加粗第一行
  319. $sheet->getStyle('A:H')->getAlignment()->setHorizontal(Alignment::HORIZONTAL_CENTER)->setVertical(Alignment::VERTICAL_CENTER);
  320. $sheet->getStyle('A1:H1')->getFont()->setBold(true);
  321. $sheet->getStyle('A1:H1')->getFill()->setFillType(Fill::FILL_SOLID)->getStartColor()->setARGB('FF00FF00'); // ARGB颜色代码,例如绿色
  322. // 设置表格标题
  323. $sheet
  324. ->setCellValue('A1', '客户编码')
  325. ->setCellValue('B1', '客户昵称')
  326. ->setCellValue('C1', '联系方式')
  327. ->setCellValue('D1', '微伴ID')
  328. ->setCellValue('E1', '客户城市')
  329. ->setCellValue('F1', '客户状态')
  330. ->setCellValue('G1', '创建时间')
  331. ->setCellValue('H1', '更新时间');
  332. // 返回结果
  333. return $sheet;
  334. }
  335. }