Custom.php 8.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226
  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\FilesManager;
  10. use App\Models\WeiBan\External as WeiBanExternal;
  11. /**
  12. * 客户管理
  13. *
  14. * @author 刘相欣
  15. *
  16. */
  17. class Custom extends Auth{
  18. protected function _initialize(){
  19. parent::_initialize();
  20. $this->assign('breadcrumb1','用户管理');
  21. $this->assign('breadcrumb2','客户管理');
  22. }
  23. /**
  24. * 列表页
  25. *
  26. * */
  27. public function index(Model $Model,CustomScore $CustomScore,WeiBanFollow $WeiBanFollow,City $City){
  28. // 接受参数
  29. $code = request('custom_code','');
  30. $phone = request('phone','');
  31. $username = request('username','');
  32. $weibanId = request('weiban_extid','');
  33. $cityId = request('city_id',0);
  34. $status = request('status');
  35. $startTime = request('start_time','');
  36. // 编码转ID
  37. $uid = $Model->codeToId($code);
  38. // 查询条件
  39. $map = [];
  40. // 编码ID
  41. if( $uid ) $map[] = ['uid','=',$uid];
  42. if( $phone ) $map[] = ['phone','=',$phone];
  43. if( $username ) $map[] = ['username','=',$username];
  44. if( $cityId ) $map[] = ['city_id','=',$cityId];
  45. if( $weibanId ) $map[] = ['weiban_extid','=',$weibanId];
  46. if( $startTime ) $map[] = ['insert_time','>=',Carbon::createFromFormat('Y-m-d',$startTime)->startOfDay()->getTimestamp()];
  47. if( $startTime ) $map[] = ['insert_time','<=',Carbon::createFromFormat('Y-m-d',$startTime)->endOfDay()->getTimestamp()];
  48. if( !is_null($status) ) $map[] = ['status','=',$status];
  49. // 查询数据
  50. $list = $Model->query()->where($map)->orderByDesc('uid')->paginate(config('page_num',10))->appends(request()->all());
  51. // 循环处理数据
  52. foreach ($list as $key => $value) {
  53. // 城市名
  54. $value['city_name'] = $value['city_id'] ? $City->getOne($value['city_id'],'name') : '';
  55. // id转编号
  56. $value['custom_code'] = $Model->idToCode($value['uid']);
  57. // id转编号
  58. $value['custom_score'] = $CustomScore->getCustomScore($value['uid']);
  59. // 如果不存在微伴ID
  60. if( !$value['weiban_extid'] ) {
  61. // 通过手机号查询注册的账号
  62. $value['weiban_extid'] = (string) $WeiBanFollow->query()->where([['phone_number','=',$value['phone']]])->value('weiban_extid');
  63. // 如果存在的话,修正
  64. if( $value['weiban_extid'] ) $Model->edit($value['uid'],['weiban_extid'=>$value['weiban_extid']]);
  65. }
  66. // 重组
  67. $list[$key] = $value;
  68. }
  69. // 获取列表
  70. $cityList = $City->getCityList();
  71. // 分配数据
  72. $this->assign('cityList',$cityList);
  73. // 分配数据
  74. $this->assign('empty', '<tr><td colspan="20">~~暂无数据</td></tr>');
  75. $this->assign('list',$list);
  76. // 加载模板
  77. return $this->fetch();
  78. }
  79. /**
  80. * 添加
  81. *
  82. * */
  83. public function add(Request $request,Model $Model){
  84. if( request()->isMethod('post') ){
  85. // 验证参数
  86. $request->scene('add')->validate();
  87. // 接收数据
  88. // 接收数据
  89. $data['username'] = request('username','');
  90. $data['phone'] = request('phone','');
  91. // 写入数据表
  92. $uid = $Model->add($data);
  93. // 如果操作失败
  94. if( !$uid ) return json_send(['code'=>'error','msg'=>'新增失败']);
  95. // 记录行为
  96. $this->addAdminHistory(admin('uid'),$Model->getTable(),$uid,1,[],$data);
  97. // 告知结果
  98. return json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
  99. }
  100. // 分配数据
  101. $this->assign('crumbs','新增');
  102. // 加载模板
  103. return $this->fetch();
  104. }
  105. /**
  106. * 修改
  107. *
  108. * */
  109. public function edit(Request $request,Model $Model,City $City){
  110. // 接收参数
  111. $uid = request('uid',0);
  112. // 查询用户
  113. $oldData = $Model->where(['uid'=>$uid])->first();
  114. // 修改
  115. if(request()->isMethod('post')){
  116. // 验证参数
  117. $request->scene('edit')->validate();
  118. // 如果用户不存在
  119. if( !$oldData ) return json_send(['code'=>'error','msg'=>'用户不存在']);
  120. // 转数组
  121. $oldData = $oldData->toArray();
  122. // 接收数据
  123. $data['username'] = request('username','');
  124. $data['phone'] = request('phone','');
  125. $data['city_id'] = request('city_id',0);
  126. $data['weiban_extid'] = request('weiban_extid','');
  127. // 写入数据表
  128. $result = $Model->edit($uid,$data);
  129. // 如果操作失败
  130. if( !$result ) return json_send(['code'=>'error','msg'=>'新增失败']);
  131. // 记录行为
  132. $this->addAdminHistory(admin('uid'),$Model->getTable(),$uid,2,$oldData,$data);
  133. // 告知结果
  134. return json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);
  135. }
  136. // 错误告知
  137. if( !$oldData ) return $this->error('查无数据');
  138. // 获取列表
  139. $cityList = $City->getCityList();
  140. // 分配数据
  141. $this->assign('cityList',$cityList);
  142. $this->assign('oldData',$oldData);
  143. $this->assign('crumbs','修改');
  144. // 加载模板
  145. return $this->fetch();
  146. }
  147. /**
  148. * 修改状态
  149. *
  150. * */
  151. public function set_status(Request $request,Model $Model){
  152. // 验证参数
  153. $request->scene('set_status')->validate();
  154. // 设置状态
  155. $uid = request('uid',0);
  156. $status = request('status',0);
  157. // 查询用户
  158. $oldData = $Model->where(['uid'=>$uid])->first();
  159. // 如果用户不存在
  160. if( !$oldData ) return json_send(['code'=>'error','msg'=>'用户不存在']);
  161. // 执行修改
  162. $result = $Model->edit($uid,['status'=>$status]);
  163. // 提示新增失败
  164. if( !$result ) return json_send(['code'=>'error','msg'=>'设置失败']);
  165. // 记录行为
  166. $this->addAdminHistory(admin('uid'),$Model->getTable(),$uid,2,$oldData,['status'=>$status]);
  167. // 告知结果
  168. return json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
  169. }
  170. /**
  171. * 表格导入
  172. *
  173. * */
  174. public function import_execl( Request $request,Model $Model,FilesManager $FilesManager,City $City,CustomAddr $CustomAddr,WeiBanExternal $WeiBanExternal){
  175. // 验证参数
  176. $request->scene('import_execl')->validate();
  177. // 获取表格信息
  178. $file = request()->file('custom_file');
  179. // 返回结果
  180. $sheetList = $FilesManager->excelToCustom($file);
  181. // 如果不存在结果
  182. if( isset($sheetList['error']) ) return json_send(['code'=>'error','msg'=>$sheetList['error']]);
  183. // 循环表格数据
  184. foreach ($sheetList as $value) {
  185. // 获取城市ID
  186. $value['city_id'] = 0;
  187. // 存在城市名称,查询城市ID
  188. if( $value['contact_city'] ) {
  189. // 获取城市ID
  190. $value['city_id'] = (int) $City->getIdByName($value['contact_city']);
  191. // 如果城市不存在的话
  192. if ( !$value['city_id'] ) return json_send(['code'=>'error','msg'=>$value['contact_city'].' => 未找到匹配的城市,请核对城市全称']);
  193. }
  194. // 获取手机号,查询是否用客户
  195. $custom = $Model->getOneByPhone($value['phone']);
  196. // 组装数据
  197. $data = ['weiban_extid'=>$value['weiban_extid'],'username'=>$value['username']];
  198. // 如果客户不存在
  199. if( !$custom ) $data['phone'] = $value['phone'];
  200. // 如果存在城市ID,才修改城市
  201. if( $value['city_id'] ) $data['city_id'] = $value['city_id'];
  202. // 如果存在手机号
  203. $uid = $custom ? $Model->edit($custom['uid'],$data) : $Model->add($data);
  204. // 如果客户存在
  205. if( !$uid ) return json_send(['code'=>'error','msg'=>$value['username'].'【'.$value['phone'].'】'.'用户创建或者更新失败']);
  206. // 存在详细地址,才创建地址库
  207. if( $value['contact_name'] && $value['contact_phone'] && $value['contact_province'] && $value['contact_city'] && $value['contact_area'] && $value['contact_addr'] ) {
  208. // 收件地址是否存在
  209. $oldAddr = $CustomAddr->query()->where([['custom_uid','=',$uid]])->first();
  210. // 如果不存在地址
  211. 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']]);
  212. }
  213. }
  214. // 提示成功
  215. return json_send(['code'=>'success','msg'=>'批量导入成功','path'=>'']);
  216. }
  217. }