Customer.php 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  1. <?php
  2. namespace app\admin\controller;
  3. use app\BaseController;
  4. use think\App;
  5. use think\facade\Db;
  6. class Customer extends BaseController
  7. {
  8. public $post = "";
  9. public function __construct(App $app)
  10. {
  11. parent::__construct($app);
  12. $this->post = $this->request->post();
  13. $token = isset($this->post['token']) ? trim($this->post['token']) : "";
  14. if($token==""){
  15. return error_show(101,'token不能为空');
  16. }
  17. $effetc = VerifyTokens($token);
  18. if(!empty($effetc) && $effetc['code']!=0){
  19. return error_show($effetc['code'],$effetc['message']);
  20. }
  21. }
  22. /*列表*/
  23. public function list(){
  24. $page= isset($this->post['page']) && $this->post['page']!==""? intval($this->post['page']):"1";
  25. $size = isset($this->post['size']) && $this->post['size'] != "" ? intval($this->post['size']) : 10;
  26. $pid = isset($this->post['pid']) &&$this->post['pid']!=="" ?intval($this->post['pid']): "";
  27. if($pid!==""){
  28. $condition[]=["pid","=",$pid];
  29. }
  30. $name= isset($this->post['name'])&&$this->post['name']!=="" ? trim($this->post['name']):"";
  31. if($name!=""){
  32. $condition[]=["name","like","%{$this->post['name']}%"];
  33. }
  34. $condition[] = ['is_del',"=",0];
  35. $count = Db::name('customer_org1')->where($condition)->count();
  36. $page>=ceil($count/$size) ? $page=ceil($count/$size) :"";
  37. $list = Db::name('customer_org1')->where($condition)->page($page,$size)->column("pid,name,level,depart_link");
  38. return app_show(0,"获取成功",['list'=>$list,'count'=>$count]);
  39. }
  40. /*新建*/
  41. public function create()
  42. {
  43. $name = isset($this->post['name']) && $this->post['name'] !== "" ? trim($this->post['name']) : "";
  44. if ($name == "") {
  45. return error_show(1003, "公司名称不能为空");
  46. }
  47. $rename = Db::name('customer_org1')->where(['is_del' => 0, 'name' => $name])->find();
  48. if (!empty($rename)) {
  49. return error_show(1002, "公司名称已存在");
  50. }
  51. $weight = isset($this->post['weight']) && $this->post['weight'] !== "" ? trim($this->post['weight']) : "0";
  52. $pid = isset($this->post['pid']) && $this->post['pid'] !== "" ? trim($this->post['pid']) : "";
  53. if ($pid === "") {
  54. return error_show(1002, "父级id不能为空");
  55. }
  56. if($pid!=0){
  57. $spid = Db::name('customer_org1')->where(['id'=>$pid, 'is_del'=>0])->find();
  58. //var_dump( Db::name('customer_org1')->getLastSql());
  59. if(empty($spid)){
  60. return error_show(1004,"父级不能为空");
  61. }
  62. }
  63. $level = isset($this->post['level']) && $this->post['level'] !== "" ? trim($this->post['level']) : "1";
  64. Db::startTrans();
  65. try {
  66. $tada = [
  67. "name" => $name,
  68. "weight" => $weight, "pid" => $pid,
  69. "level" => $level,
  70. "updatetime" => date("Y-m-d H:i:s"),
  71. "addtime" => date("Y-m-d H:i:s"),
  72. "depart_link" => "", "is_del" => 0,"pname"=>isset($spid['name']) ? $spid['name']:"",
  73. ];
  74. $t = Db::name('customer_org1')->insert($tada, true);
  75. //var_dump(Db::name('customer_org1')->getLastSql());
  76. if ($t > 0) {
  77. if(isset($spid)){
  78. // var_dump($spid);
  79. $depart_link = $spid['depart_link']."{$t}-";
  80. }else{
  81. $depart_link="{$t}-";
  82. }
  83. $level = explode('-', $depart_link);
  84. // var_dump($level);
  85. $level = array_filter($level);
  86. $level = count($level);
  87. $k = ['depart_link' => $depart_link, 'level' => $level];
  88. $u = Db::name('customer_org1')->where(['id' => $t])->save($k);
  89. // var_dump( Db::name('customer_org1')->getLastSql());
  90. if ($u) {
  91. Db::commit();
  92. return error_show(0, "新建成功");
  93. }
  94. }
  95. Db::rollback();
  96. } catch (\Exception $e) {
  97. Db::rollback();
  98. return error_show(1003, $e->getMessage());
  99. }
  100. }
  101. /*更新*/
  102. public function updat(){
  103. $id = isset($this->post['id'])?intval($this->post['id']):"";
  104. $sid = Db::name('customer_org1')->where("id","=","$id")->find();
  105. // var_dump(Db::name('customer_org1')->getLastSql());
  106. if($sid==false){
  107. return error_show(1004,"公司不存在");
  108. }
  109. $pid = isset($this->post['pid']) && $this->post['pid'] !=="" ? intval($this->post['pid']):"";
  110. if($pid===""){
  111. return error_show(1004,"父级id不能为空");
  112. }
  113. if($pid!=0){
  114. $fpid = Db::name('customer_org1')->where(['id'=>"$pid",'is_del'=>0])->find();
  115. if(empty($fpid)){
  116. return error_show(1004,"父级不能为空");
  117. }
  118. }
  119. $weight = isset($this->post['weight']) && $this->post['weight'] !==""? intval($this->post['weight']):"0";
  120. // $level = isset($this->post['level']) && $this->post['level'] !==""? intval($this->post['level']):"";
  121. $name = isset($this->post['name'])? trim($this->post['name']):"";
  122. if($name==""){
  123. return error_show(1004,"公司名称不能为空");
  124. }
  125. $repeat_name = Db::name('customer_org1')->where(["is_del"=>0,"name"=>$name])->where("id","<>","$id")->find();
  126. // echo Db::name('customer_org1')->getLastSql();
  127. if(!empty($repeat_name)){
  128. return error_show(1004,"部门名称已存在");
  129. }
  130. if(isset($fpid)){
  131. $depart_link=$fpid['depart_link']."{$id}-";
  132. }else{
  133. $depart_link= "{$id}-";
  134. }
  135. $level =explode('-',$depart_link);
  136. $level = array_filter($level);
  137. $level= count($level);
  138. $vir=[
  139. "id"=>$id,
  140. "name"=>$name,"pid"=>$pid,
  141. "weight"=>$weight,"depart_link"=>$depart_link,
  142. "level"=>$level,"is_del"=>0,"addtime"=>date("Y-m-d H:i:s"),
  143. "updatetime"=>date("Y-m-d H:i:s"),
  144. ];
  145. $org = Db::name('customer_org1')->save($vir);
  146. return $org ? error_show(0,"更新成功") : error_show(1004,"更新失败");
  147. }
  148. /*查询*/
  149. public function selec(){
  150. $id =isset($this->post['id']) && $this->post['id'] !==""? intval($this->post['id']) :"";
  151. if($id==""){
  152. return error_show(1004,"公司客户不存在");
  153. }
  154. $tod=Db::name('customer_org1')->where(['id'=>$id,'is_del'=>0])->find();
  155. //var_dump(Db::name('customer_org1')->getLastSql());
  156. return app_show(0,"获取成功",$tod);
  157. }
  158. /*删除*/
  159. public function dell(){
  160. $id=isset($this->post['id']) ?intval($this->post['id']):"";
  161. $custy = Db::name('customer_org1')->where(["is_del"=>0,'id'=>$id])->find();
  162. if($custy==false){
  163. return error_show(1004,"公司不存在");
  164. }
  165. $custy['is_del']=1;
  166. $custy['updatetime']=date("Y-m-d H:i:s");
  167. $compy = Db::name('customer_org1')->save($custy);
  168. return $compy ? error_show(0,"删除成功"):error_show(1004,"删除失败");
  169. }
  170. }