phpstock/app/admin/controller/Orderback.php

<?php


namespace app\admin\controller;

use app\admin\model\ActionLog;
use app\admin\model\DataGroup as DataGroupModel;
use app\admin\model\GoodLog;
use app\admin\model\GoodStockInfo;use app\admin\model\ProcessOrder;
use think\App;
use think\Exception;
use think\facade\Db;
use think\facade\Validate;

//退货单
class Orderback extends Base
{
    public function __construct(App $app)
    {
        parent::__construct($app);
    }

    public function list(){
        $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']):"1";
        $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']):"10";
        $where =[['a.is_del',"=",0]];
        $thNo = isset($this->post['thNo']) && $this->post['thNo']!="" ? trim($this->post['thNo']):"";
        if($thNo!=""){
            $where[]=['a.thNo',"like", "%{$thNo}%"];
        }
        $status = isset($this->post['status']) && $this->post['status']!=="" ? intval($this->post['status']):"";
        if($status!==""){
            // $where['status'] = $status;
            $where[]=['a.status',"=", $status];
        }
        $post_code= isset($this->post['post_code']) && $this->post['post_code']!="" ? trim($this->post['post_code']):"";
        if($post_code!=""){
            $where[]=['a.post_code',"like", "%{$post_code}%"];
        }
        $post_compay = isset($this->post['post_compay']) && $this->post['post_compay']!="" ? trim($this->post['post_compay']):"";
        if($post_compay!=""){
            $where[]=['a.post_company',"=", $post_compay];
        }
        $customer_code = isset($this->post['customer_code']) && $this->post['customer_code']!="" ? trim($this->post['customer_code']):"";
        if($customer_code!=""){
            $where[]=['a.customer_code',"like", "%{$customer_code}%"];
        }

        $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
        if($relaComNo!="") $where[]=['b.supplierNo','=', $relaComNo];

        $order_code = isset($this->post['order_code']) && $this->post['order_code']!="" ? trim($this->post['order_code']):"";
        if($order_code!=""){
            $where[]=['a.orderCode',"like", "%{$order_code}%"];
        }
        $out_code = isset($this->post['out_code']) && $this->post['out_code']!="" ? trim($this->post['out_code']):"";
        if($out_code!=""){
            $where[]=['a.outCode',"like", "%{$out_code}%"];
        }
        $return_code = isset($this->post['return_code']) && $this->post['return_code']!="" ? trim($this->post['return_code']):"";
        if($return_code!=""){
            $where[]=['a.returnCode',"like", "%{$return_code}%"];
        }
        $start =isset($this->post['start'])&&$this->post['start']!='' ? $this->post['start']:"";
        if($start!==""){
            $where[]=['a.addtime',">=", $start];
        }
        $end =isset($this->post['end'])&&$this->post['end']!='' ? $this->post['end']:"";
        if($end!==""){
            $where[]=['a.addtime',"<=", $end];
        }

        $supplierNo = $this->post['supplierNo'] ?? '';
        if ($supplierNo !== '') {
            $spuCode = Db::name('good_basic')
                ->where(['is_del' => 0, 'supplierNo' => $supplierNo])
                ->column('spuCode');
            $where[] = ['b.good_code', 'in', $spuCode];
        }

        $condition=[];
//        $role=$this->checkRole();
//        if(!empty($role['write']) && $this->uid!=""){
//            // $where[]=["a.apply_id","in",$role['write']];
//            $condition .="cgderid = {$this->uid} or apply_id in (".implode(',',$role['write']).")";
//        }
//		$hand = resign_hand_user($this->uid);
//        $role = $this->checkDataShare();
//        if (!empty($role[DataGroupModel::$type_全部])) $condition .= "cgderid in {$hand} or apply_id in (" . implode(',',
//        $role[DataGroupModel::$type_全部]) . ")";

        //只有level2的账号过滤数据权限
        if ($this->level == 2) {
            $role = $this->checkDataShare();
            $hand = resign_hand_user($this->uid, 0);
            if (!empty($role[DataGroupModel::$type_全部])) {
                $arr = array_unique(array_merge($hand, $role[DataGroupModel::$type_全部]));
                $condition[] = ['a.apply_id', 'in', $arr];
                $condition[] = ['a.cgderid', 'in', $hand];
            }
        }


        //供应商账号不允许看到库存品数据
        if ($this->level == 3) $where[]=['b.is_stock','<>',1];
//        if(!empty($role['platform']) ){
//            $where[]=["platform_id","in",$role['platform']];
//        }
        $count = Db::name("order_back")
            ->alias('a')
            ->leftJoin('sale b','b.orderCode=a.orderCode AND b.is_del=0')
            ->where($where)
            ->where(function ($query) use ($condition) {
                $query->whereOr($condition);
            })
            ->count('a.id');
        $total = ceil($count / $size);
        $page = $page >= $total ? $total : $page;
        $list = Db::name("order_back")
            ->alias('a')
            ->leftJoin('sale b','b.orderCode=a.orderCode AND b.is_del=0')
            ->where($where)
            ->where(function ($query) use ($condition) {
                $query->whereOr($condition);
            })
            ->field('a.*')
            ->page($page, $size)
            ->order("a.addtime desc")
            ->select()
            ->toArray();
        $data=[];

        $all_wsm = Db::name("warehouse_info")
            ->alias("a")
            ->where(["a.wsm_code"=>array_column($list,'return_wsm')])
            ->column("a.name,a.supplierNo",'a.wsm_code');//b.name,b.code

        $userCommon = new \app\admin\common\User();
        $names = $userCommon->handle('getCodeAndName', ['code' => array_merge(array_column($all_wsm,'supplierNo'),array_column($list,'customer_code'))]);

        foreach ($list as $value){
            $value['wsm_name']="";
            $value['wsm_supplier']='';
            $value['wsm_supplierNo']='';
            if($value['return_wsm']!=""){
//                $wsmcode = Db::name("warehouse_info")
//                    ->alias("a")
////                    ->leftJoin("supplier b","a.supplierNo=b.code")
//                    ->where(["a.wsm_code"=>$value['return_wsm']])
//                    ->field("a.name as wsm_name,a.supplierNo")//b.name,b.code
//                    ->find();
                $value['wsm_name'] =$all_wsm[$value['return_wsm']]['name']??'';//isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
                $value['wsm_supplier'] =$names['data'][$all_wsm[$value['return_wsm']]['supplierNo']]??'';//isset($wsmcode['name']) ? $wsmcode['name']:"";
                $value['wsm_supplierNo'] =$all_wsm[$value['return_wsm']]['supplierNo'];//isset($wsmcode['code']) ? $wsmcode['code']:"";
            }
            $value['customer_name']='';
            if($value['customer_code']!=''){
//                $customer = Db::name("customer_info")->where(['companyNo'=>$value['customer_code']])->find();
                $value['customer_name']=$names['data'][$value['customer_code']]??'';//isset($customer['companyName'])?$customer['companyName']:'';
            }
            $inorder= Db::name("order_backinfo")->where(['thNo'=>$value['thNo'],"is_del"=>0])->select();
            $value['child']=empty($inorder)? [] : $inorder;

            //是否具有编辑权限
//            $value['is_allow_update'] = 0;
//            if (in_array($this->roleid, [1, 33]) || in_array($value['apply_id'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;

            $data[]=$value;
        }
        return app_show(0,"获取成功",["list"=>$data ,"count"=>$count]);
    }

    /**
     * @return \think\response\Json|void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
  public function info(){
      $thNo = isset($this->post['thNo']) && $this->post['thNo']!="" ? trim($this->post['thNo']):"";
      if($thNo==""){
        return error_show(1004,"参数thNo不能为空");
      }
      $info =Db::name("order_back")->where(['thNo'=>$thNo])->find();
      if(empty($info)){
          return error_show(1004,"未找到数据");
      }
      $orderinfo = Db::name("sale")->where(["orderCode"=>$info["orderCode"]])->find();
      $info['origin_price']=$orderinfo['origin_price'];
      $info['sale_price']=$orderinfo['sale_price'];
      $info['order_type']=$orderinfo['order_type'];
      $info['order_source']=$orderinfo['order_source'];
      $info['total_price']=$orderinfo['total_price'];
      $info['companyNo']=$orderinfo['supplierNo'];

      $userCommon = new \app\admin\common\User();
      $tmp = $userCommon->handle('getCodeAndName', ['code' => $orderinfo['supplierNo']]);
      if (!isset($tmp['code']) || $tmp['code'] != 0) return json_show($tmp['code'], $tmp['message'], $tmp['data']);

      $info['company'] = $tmp['data'][$orderinfo['supplierNo']] ?? '';

//      $info['company'] = Db::name('business')
//          ->where(['companyNo' => $orderinfo['supplierNo'], 'is_del' => 0])
//          ->value('company','');
      $info['addr_cn']=GetAddr($info['addr_code']);
      if($orderinfo['order_type']==3){
          $goon = Db::name("good_zixun")->where(["spuCode"=>$orderinfo['good_code'],"is_del"=>0])->find();
          $is_stock=0;
      }else {
          $goon = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
              ->where(['a.skuCode' => $orderinfo['skuCode']])->find();
          $is_stock=$goon['is_stock'];
      }
      if (empty($goon)) {
          return error_show(1003, "未找到商品数据");
      }
      $info['out_wsm_name']="";
      $info['out_wsm_supplier']='';
      $info['out_wsm_supplierNo']='';
      if($is_stock==1){
          $out =Db::name("order_out")->where(['outCode'=>$info['outCode']])->find();
          if($out==false){
              return error_show(1003, "未找到出库单数据");
          }
          if($out['wsm_code']!=''){
              $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
                  ->where(["a.wsm_code"=>$out['wsm_code']])->field("a.name as wsm_name,b.name,b.code")->find();
              $info['out_wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
              $info['out_wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
              $info['out_wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
          }
      }
      $retutninfo = Db::name("order_return")->where(['returnCode'=>$info['returnCode']])->find();
      $info['apply_id'] = $retutninfo['apply_id'];
      $info['apply_name'] = $retutninfo['apply_name'];
      $info['return_tag'] = $retutninfo['return_tag'];
      $int = isset($goon['cat_id']) && $goon['cat_id'] != 0 ? made($goon['cat_id']) : [];
      $info['wsm_name']="";
      $info['wsm_supplier']='';
      $info['wsm_supplierNo']='';
      if($info['return_wsm']!=""){
          $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
              ->where(["a.wsm_code"=>$info['return_wsm']])->field("a.name as wsm_name,b.name,b.code")->find();
          $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
          $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
          $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
      }
      $inorder= Db::name("order_backinfo")->alias("a")->leftJoin("result_info b","a.error_code=b.result_code")
          ->where(['a.thNo'=>$info['thNo'],"a.is_del"=>0])->field("a.*,b.result as error_msg")->select();
      $info['child']=empty($inorder)? [] : $inorder;

      $info['can']=$int;


      //补充仓库名称
      $warehouse = Db::name('warehouse_info')
          ->alias('wi')
          ->where(['wi.is_del' => 0, 'wi.status' => 1])
          ->whereIn('wi.wsm_code', [$info['can_sell_wsm'], $info['defective_wsm']])
          ->leftJoin('supplier s', 's.code=wi.supplierNo AND s.is_del=0')
          ->column('wi.name,wi.supplierNo,s.name supplier', 'wi.wsm_code');

      $info['can_sell_wsm_name'] = isset($warehouse[$info['can_sell_wsm']]['name']) ? $warehouse[$info['can_sell_wsm']]['name'] : '';
      $info['can_sell_wsm_supplierNo'] = isset($warehouse[$info['can_sell_wsm']]['supplierNo']) ? $warehouse[$info['can_sell_wsm']]['supplierNo'] : '';
      $info['can_sell_wsm_supplier'] = isset($warehouse[$info['can_sell_wsm']]['supplier']) ? $warehouse[$info['can_sell_wsm']]['supplier'] : '';
      $info['defective_wsm_name'] = isset($warehouse[$info['defective_wsm']]['name']) ? $warehouse[$info['defective_wsm']]['name'] : '';
      $info['defective_wsm_supplierNo'] = isset($warehouse[$info['defective_wsm']]['supplierNo']) ? $warehouse[$info['defective_wsm']]['supplierNo'] : '';
      $info['defective_wsm_supplier'] = isset($warehouse[$info['defective_wsm']]['supplier']) ? $warehouse[$info['defective_wsm']]['supplier'] : '';
      return app_show(0, "获取成功", $info);
  }

    /**
     * @return \think\response\Json|void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
  public function check(){
      $thNo = isset($this->post['thNo']) && $this->post['thNo']!="" ? trim($this->post['thNo']):"";
      if($thNo==""){
          return error_show(1004,"参数thNo不能为空");
      }
      $info =Db::name("order_back")->where(['thNo'=>$thNo])->find();
      if(empty($info)){
          return error_show(1004,"未找到数据");
      }
      $normal = isset($this->post['normal']) && $this->post['normal']!=="" ? intval($this->post['normal']):"";
      if($normal===""){
          return error_show(1004,"参数normal不能为空");
      }
      $errorlist = isset($this->post['errorlist']) && $this->post['errorlist']!=="" ? $this->post['errorlist']:[];
      if($info['status']== 2){
          return error_show(1002,"退货单已验货");
      }
      $receive=$normal+array_sum(array_column($errorlist,'error_num'));
      $remark =  isset($this->post['remark']) && $this->post['remark']!=="" ? trim($this->post['remark']):"";
      $info['received_num'] = $receive;
      $info['normal_num'] = $normal;
      $info['remark'] = $remark;
     $str = $info['status'];
      $info['status'] =empty($errorlist)?3: 2;
      $info['updatetime'] = date("Y-m-d H:i:s");
      Db::startTrans();
      try{
          $up=Db::name("order_back")->save($info);
          if($up){
              $stn = ["order_code"=>$info['thNo'],"status"=>$str,"action_remark"=>'',"action_type"=>"edit"];
              ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname],$stn,"CKTHD",$info['status'],$info);

              if($info['status'] == 2) $roleid = [10, 31, 41];//特殊处理，写入到10采购负责人、31库管人员、41库管-张凯旋这三个角色下的所有人
              else $roleid = [31,41];//特殊处理，写入到31库管人员、41库管-张凯旋这三个角色下的所有人

              $handle_user_list = Db::name('user_role')
                  ->where('is_del', 0)
                  ->whereIn('roleid', $roleid)
                  ->column('uid');
              $process = ["order_code" => $info['thNo'], "order_id" => $info['id'], "order_status" => $info['status'], 'order_type' => "CKTHD", "before_status" => $str, 'handle_user_list' => implode(',', $handle_user_list)];
              ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);
              if(empty($errorlist)){
                  Db::commit();
                  return app_show(0,'更新成功');
              }

              foreach($errorlist as $value){
                  $data=[];
                  isset($value['id'])&&$value['id']!=''?$data['id']=$value['id']:"";
                  $data['thNo']=$thNo;
                  $data['error_num']=$value['error_num'];
                  $data['error_code']=$value['error_code'];
                  $data['error_remark']=$value['error_remark'];
                  $data['is_del']=isset($value['is_del'])?$value['is_del']:0;
                  isset($value['id'])&&$value['id']!=''? "" : $data['addtime']=date("Y-m-d H:i:s");
                  $data['updatetime']=date("Y-m-d H:i:s");
                  $in = Db::name("order_backinfo")->save($data);
                  if(!$in){
                      Db::rollback();
                      return error_show(1005,'更新失败');
                  }
              }
             Db::commit();
             return app_show(0,'更新成功');
          }
          Db::rollback();
          return error_show(1005,'更新失败');
      }catch (\Exception $e){
          Db::rollback();
          return error_show(1004,$e->getMessage());
      }
  }

  public function CheckExam(){
      $thNo = isset($this->post['thNo']) && $this->post['thNo']!="" ? trim($this->post['thNo']):"";
      if($thNo==""){
          return error_show(1004,"参数thNo不能为空");
      }
      $info =Db::name("order_back")->where(['thNo'=>$thNo])->find();
      if(empty($info)){
          return error_show(1004,"未找到数据");
      }
      $errorlist = isset($this->post['errorlist']) && $this->post['errorlist']!=="" ? $this->post['errorlist']:[];
      Db::startTrans();
      try{
          $temp=$info['status'];
          $info['status'] =3;
          $info['updatetime'] = date("Y-m-d H:i:s");
          $up=Db::name("order_back")->save($info);
          if($up){
              $stn = ["order_code"=>$thNo,"status"=>$temp,"action_remark"=>'',"action_type"=>"edit"];
              ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], $stn, "CKTHD", $info['status'], $stn);

              //特殊处理，写入到31库管人员、41库管-张凯旋这三个角色下的所有人
              $handle_user_list = Db::name('user_role')
                  ->where('is_del', 0)
                  ->whereIn('roleid', [31, 41])
                  ->column('uid');
              $process = ["order_code" => $info['thNo'], "order_id" => $info['id'], "order_status" => 3, "order_type" => "CKTHD", "before_status" => $temp, 'handle_user_list' => implode(',', $handle_user_list)];
              ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);

              if(empty($errorlist)){
                  $up =Db::name("order_backinfo")->where(["thNo"=>$thNo,"is_del"=>0])->save(["status"=>1,
                      "updatetime"=>date("Y-m-d H:i:s")]);
                  if($up){
                      Db::commit();
                      return app_show(0,'更新成功');
                  }else{
                      Db::rollback();
                      return error_show(1005,'异常记录数据更新失败');
                  }
              }else{
                  foreach($errorlist as $value){
                      $temp=Db::name("order_backinfo")->where(['id'=>$value["id"],"is_del"=>0,"thNo"=>$thNo])->find();
                      if(empty($temp)){
                          Db::rollback();
                          return error_show(1005,'异常记录数据未找到');
                      }
                      $temp['status']=$value['status'];
                      $temp['exam_remark']=$value['remark'];
                      $temp['updatetime']=date("Y-m-d H:i:s");
                      $com = Db::name("order_backinfo")->save($temp);
                      if($com==false){
                          Db::rollback();
                          return error_show(1005,'异常记录数据更新失败');
                      }
                  }
                  Db::commit();
                  return app_show(0,'更新成功');
              }
          }
          Db::rollback();
          return error_show(1005,'更新失败');
      }catch (\Exception $e){
          Db::rollback();
          return error_show(1004,$e->getMessage());
      }
  }
    public function Exam(){
        $thNo = isset($this->post['thNo']) && $this->post['thNo']!="" ? trim($this->post['thNo']):"";
        if($thNo==""){
            return error_show(1004,"参数thNo不能为空");
        }
        $info =Db::name("order_back")->where(['thNo'=>$thNo])->find();
        if(empty($info)){
            return error_show(1004,"未找到数据");
        }
        $status = isset($this->post['status']) && $this->post['status']!=="" ? intval($this->post['status']):"";
        if($status===""){
            return error_show(1004,"参数status不能为空");
        }
        $return_wsm=isset($this->post["return_wsm"])&&$this->post["return_wsm"]!=""?trim($this->post["return_wsm"]):"";

        $normal_num=isset($this->post["normal_num"])&&$this->post["normal_num"]!=""?intval($this->post["normal_num"])
            :"";
//        $defective_wsm=isset($this->post["defective_wsm"])&&$this->post["defective_wsm"]!=""?trim($this->post["defective_wsm"]):"";

//        $defective_num=isset($this->post["defective_num"])&&$this->post["defective_num"]!==""?intval($this->post["defective_num"]):"";
//        $loss_num=isset($this->post["loss_num"])&&$this->post["loss_num"]!=""?intval($this->post["loss_num"]):"";
        if($status==4){
//            if($defective_num===""){
//                return error_show(1004,"参数defective_num不能为空");
//            }
//            if($loss_num===""){
//                return error_show(1004,"参数loss_num不能为空");
//            }
            if($normal_num===""){
                return error_show(1004,"参数normal_num不能为空");
            }
//            if($defective_wsm===""){
//                return error_show(1004,"参数defective_wsm不能为空");
//            }
            if($return_wsm===""){
                return error_show(1004,"参数return_wsm不能为空");
            }
            $info['return_wsm']=$return_wsm;
            $info['normal_num']=$normal_num;
//            $info['loss_num']=$loss_num;//order_back表里没有这三个字段，不知道是干嘛的
//            $info['defective_wsm']=$defective_wsm;
//            $info['defective_num']=$defective_num;
        }
        $remark= isset($this->post['remark']) && $this->post['remark']!="" ? trim($this->post['remark']):"";
        Db::startTrans();
        try{
            $var = $info['status'];
            $info['status'] =$status;
            $info['remark'] =$remark;
            $info['updatetime'] = date("Y-m-d H:i:s");
            $up=Db::name("order_back")->save($info);
            if($up){
                $stn = ["order_code"=>$thNo,"status"=>$var,"action_remark"=>'',"action_type"=>"edit"];
                ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$stn,"CKTHD",$info['status'],$this->post);

                if (in_array($status, [2, 3])) {

                    if ($status == 2) $roleid = [10, 31, 41];//特殊处理，写入到10采购负责人、31库管人员、41库管-张凯旋这三个角色下的所有人
                    else $roleid = [31, 41];//特殊处理，写入到、31库管人员、41库管-张凯旋这三个角色下的所有人

                    $handle_user_list = Db::name('user_role')
                        ->where('is_del', 0)
                        ->whereIn('roleid', $roleid)
                        ->column('uid');
                    $process = ["order_code" => $info['thNo'], "order_id" => $info['id'], "order_status" => $status, "order_type" => "CKTHD", "before_status" => $var, 'handle_user_list' => implode(',', $handle_user_list)];

                } else $process = ["order_code" => $info['thNo'], "order_id" => $info['id'], "order_status" => $status, "order_type" => "CKTHD", "before_status" => $var];

                ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);
                Db::commit();
                return app_show(0,'更新成功');
            }
            Db::rollback();
            return error_show(1005,'更新失败');
        }catch (\Exception $e){
            Db::rollback();
            return error_show(1004,$e->getMessage());
        }
    }


    //新写一个退货接口
    public function ExamNew()
    {
        $param = $this->request->only(['thNo', 'status', 'status_remark', 'can_sell_wsm' => '', 'can_sell_num' => 0, 'defective_wsm' => '', 'defective_num' => 0, 'loss_num' => 0], 'post', 'trim');

        $val = Validate::rule(['thNo|退货编码' => 'require', 'status|状态' => 'require|number|in:4,2,1', 'status_remark|备注' => 'checkRemark:']);

        $val->extend('checkRemark', function ($val, $rule, $data) {
            return $data['status'] == 4 ? true : (empty($val) ? '请填写备注' : true);
        });
        if (!$val->check($param)) return error_show(1004, $val->getError());
        Db::startTrans();
        try {

            $info = Db::name("order_back")
                ->field('id,order_type,status,outCode,good_code,return_num,orderCode,returnCode,apply_id,apply_name')
                ->where(['thNo' => $param['thNo'], 'is_del' => 0])
                ->find();

            if (empty($info)) throw new Exception('未找到数据');
            $sale= Db::name('sale')->where(['orderCode'=>$info['orderCode'],"is_del"=>0])->find();
            if($sale==false){
                Db::rollback();
                return error_show(1004,"未找到销售单数据");
            }
            $spuCode= $info['good_code'];
            if($sale['order_type']!=1){
              if($sale['order_type']==3){
		          $goon = Db::name("good_zixun")->where(["spuCode"=>$sale['good_code'],"is_del"=>0])->find();
		          $isZx=1;
		      }else {
		          $goon = Db::name('good_basic')->where(['spuCode' => $sale['good_code']])->find();
		          $isZx=2;
		      }
              $spuCode = $this->CheckGoodZx($goon,$isZx,$param['thNo']);
            }
            $out =Db::name("order_out")->where(['outCode'=>$info['outCode']])->find();
            if($out==false){
                Db::rollback();
                return error_show(1004,"未找到发货单数据");
            }
            $returninfo =Db::name("order_return")->where(['returnCode'=>$info['returnCode']])->find();
            if($returninfo==false){
                Db::rollback();
                return error_show(1004,"未找到售后单数据");
            }
			$sabebn =Db::name("sale_info")->where([["orderCode",'=',$info['orderCode']],["num",">",0]])->select()->toArray();
            if($param['can_sell_num']!=0&& $param['can_sell_wsm']!=''){
//                    if($sale['is_stock']==1){ //库存品退回原仓库 备库单释放数量 采购单
//                        $param['can_sell_wsm'] = $out['wsm_code'];
//                    }
                    $stock = Db::name("good_stock")->where(["spuCode"=>$spuCode,'wsm_code'=>$param['can_sell_wsm']])
                    ->find();
                    if(empty($stock)) {
                        $stock=[
                            "spuCode"=>$spuCode,
                            "wsm_code"=>$param['can_sell_wsm'],
                            "usable_stock"=>0,
                            "wait_out_stock"=>0,
                            "wait_in_stock"=>0,
                            "total_stock"=>0,
                            "addtime"=>date("Y-m-d H:i:s"),
                            "updatetime"=>date("Y-m-d H:i:s"),
                        ];
                    }
                    $stock['usable_stock']+=$param['can_sell_num'];
                    $stock['updatetime']=date("Y-m-d H:i:s");
                    $st_up = Db::name("good_stock")->save($stock);
                    if($st_up==false){
                        return error_show(1005,'可售商品入库失败');
                    }
                    $stockid = isset($stock['id']) ? $stock['id'] : Db::name("good_stock")->getLastInsID();

                        if(!empty($sabebn)){
                        	$total_num =$param['can_sell_num'];
                        	foreach ($sabebn as $ve){
                        		$tempnum=0;
                        		if ($total_num==0) break;
                        		if($total_num>=$ve['num']){
                        			$tempnum = $ve['num'];
                        			$total_num-=$ve['num'];
                        			$ve['th_num']+=$ve['num'];
                        			$ve['num']=0;
                        		}else{
                        		    $tempnum = $total_num;
                        			$ve['num']-=$total_num;
                        			$ve['th_num']+=$total_num;
                        			$total_num=0;
                        		}
                        		$bnin=GoodStockInfo::ReturnAdd($stockid,$ve['bnCode'],$tempnum,$ve['stockid']);
                        		if($bnin==false){
                        			 Db::rollback();
                                    return error_show(1005, '可售商品Bn库存数入库失败');
                        		}
								$up=Db::name("sale_info")->save($ve);
                        		if($up==false){
                        			 Db::rollback();
                                    return error_show(1005, '可售商品Bn库存数入库失败');
                        		}
								$bnin=GoodStockInfo::ReturnBn($info['returnCode'],$ve['id'],$tempnum);
                        		if($bnin==false){
                        			 Db::rollback();
                                    return error_show(1005, '可售商品Bn库存数入库失败');
                        		}
                        	}
                        }else{
                        	if($sale['order_type']==1){
                        	 $ordernum = Db::name("order_num")->where(['orderCode' =>$info['orderCode']])->find();
					        if ($ordernum == false) {
					        	Db::rollback();
					            return error_show(1005, '未找到关联采购单');
					        }
					         $cgd = Db::name("purchease_order")->where(["cgdNo" => $ordernum['cgdNo'], "is_del" => 0])->find();
					        if ($cgd == false) {
					        	Db::rollback();
					            return error_show(1005, '未找到采购单数据');
					        }
					        $bn =makeNo("BN");
					        $yp=GoodStockInfo::AddBn($stockid,$bn,$param['can_sell_num'],$cgd['good_price']);
					        if($yp==false){
					        	Db::rollback();
								return error_show(1005, '商品批次退货入库失败');
					        }
                        	}
                        }
                $good_data=['good_log_code'=>$param['thNo'],"stock_id"=> $stockid,"type"=>1,'stock'=>$param['can_sell_num'],"stock_name"=>"usable_stock"];
                GoodLog::LogAdd($this->post['token'],$good_data,'RKTHD');
             }

            if($param['defective_num']!=0&& $param['defective_wsm']!=''){
                $defective = Db::name("good_stock")->where(["spuCode"=>$spuCode,'wsm_code'=>$param['defective_wsm']])->find();
                if(empty($defective)) {
                    $defective=[
                        "spuCode"=>$spuCode,
                        "wsm_code"=>$param['defective_wsm'],
                        "usable_stock"=>0,
                        "wait_out_stock"=>0,
                        "wait_in_stock"=>0,
                        "total_stock"=>0,
                        "addtime"=>date("Y-m-d H:i:s"),
                        "updatetime"=>date("Y-m-d H:i:s"),
                    ];
                    $order = ["order_code"=>$spuCode,"status"=>1,"action_remark"=>'', "action_type"=>"create"];
                }else{
                    $order = ["order_code"=>$spuCode,"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
                }
                $defective['usable_stock']+=$param['defective_num'];
                $defective['updatetime'] = date("Y-m-d H:i:s");
                $upd=  Db::name("good_stock")->save($defective);
                if($upd==false){
                    Db::rollback();
                    return error_show(1005,'次品商品入库失败');
                }
                $stockid = isset($defective['id']) ? $defective['id'] : Db::name("good_stock")->getLastInsID();
                $sabebn =Db::name("sale_info")->where(["orderCode"=>$info['orderCode']])->select()->toArray();
                 if(!empty($sabebn)){
                        	$total_num =$param['defective_num'];
                        	foreach ($sabebn as $ve){
                        		$tempnum=0;
                        		if ($total_num==0) break;
                        		if($total_num>=$ve['num']){
                        			$tempnum = $ve['num'];
                        			$total_num-=$ve['num'];
                        			$ve['th_num']+=$ve['num'];
                        			$ve['num']=0;
                        		}else{
                        		    $tempnum = $total_num;
                        			$ve['num']-=$total_num;
                        			$ve['th_num']+=$total_num;
                        			$total_num=0;
                        		}
                        	    $bnin=GoodStockInfo::ReturnAdd($stockid,$ve['bnCode'],$tempnum,$ve['stockid']);
                        		if($bnin==false){
                        			 Db::rollback();
                                    return error_show(1005, '可售商品Bn库存数入库失败');
                        		}
								$up=Db::name("sale_info")->save($ve);
                        		if($up==false){
                        			 Db::rollback();
                                    return error_show(1005, '可售商品Bn库存数入库失败');
                        		}
								$bnin=GoodStockInfo::ReturnBn($info['returnCode'],$ve['id'],$tempnum);
                        		if($bnin==false){
                        			 Db::rollback();
                                    return error_show(1005, '可售商品Bn库存数入库失败');
                        		}
                        	}
                        }else{
	                        if($sale['order_type']==1){
	                             $ordernum = Db::name("order_num")->where(['orderCode' =>$info['orderCode']])->find();
						        if ($ordernum == false) {
						            Db::rollback();
						            return error_show(1005, '未找到关联采购单');
						        }
						         $cgd = Db::name("purchease_order")->where(["cgdNo" => $ordernum['cgdNo'], "is_del" => 0])->find();
						        if ($cgd == false) {
						            Db::rollback();
						            return error_show(1005, '未找到采购单数据');
						        }
						        $bn =makeNo("BN");
						        $yp=GoodStockInfo::AddBn($stockid,$bn,$param['defective_num'],$cgd['good_price']);
						        if($yp==false){
						            Db::rollback();
									return error_show(1005, '商品批次退货入库失败');
						        }
	                            }
                        }
                $good_data=['good_log_code'=>$param['thNo'],"stock_id"=>isset($defective['id'])? $defective['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$param['defective_num'],"stock_name"=>"usable_stock"];
                GoodLog::LogAdd($this->post['token'],$good_data,'RKTHD');
            }
            $update_data = ['status' => $param['status'], 'updatetime' => date('Y-m-d H:i:s')];

            //status==4通过，其他值表示驳回
            if ($param['status'] != 4) $update_data['status_remark'] = $param['status_remark'];
            else {
                $update_data['can_sell_wsm'] = $param['can_sell_wsm'];
                $update_data['can_sell_num'] = $param['can_sell_num'];
                $update_data['defective_wsm'] = $param['defective_wsm'];
                $update_data['defective_num'] = $param['defective_num'];
                $update_data['loss_num'] = $param['loss_num'];

                if($sale['is_stock']==1){
                    $sale['th_num']+= $info['return_num'];
                    if($sale['th_num']==$sale['send_num']&& $sale['wsend_num']==0){
                        $sale['status']=3;
                    }
                    $sale['th_fee']+= round($info['return_num']*$sale['sale_price'],2);
                    $sale['updatetime']= date("Y-m-d H:i:s");
                    $uap=Db::name("sale")->save($sale);
                    if($uap==false){
                        Db::rollback();
                        return error_show(1005,'销售单订单更新失败');
                    }
//                    $ordernum =Db::name("order_num")->where(['orderCode'=>$info['orderCode']])->find();
//                    if($ordernum==false){
//                        Db::rollback();
//                        return error_show(1005,'未找到关联采购单');
//                    }
//                    $ordernum['send_num']-=$info['return_num'];
//                    $orderup =Db::name("order_num")->save($ordernum);
//                    if($orderup==false){
//                        Db::rollback();
//                        return error_show(1005,'关联数据更新失败');
//                    }
//                    $cgd =Db::name("purchease_order")->where(["cgdNo"=>$ordernum['cgdNo'],"is_del"=>0])->find();
//                    if($cgd==false){
//                        Db::rollback();
//                        return error_show(1005,'未找到采购单数据');
//                    }
//                    $cgd['th_fee']+= round($cgd['good_price']*$param['can_sell_num'],2);
//                    $cgd['th_num']+=  $param['can_sell_num'];
//                    if($cgd['th_num']==$cgd['send_num']&& $cgd['wsend_num']==0){
//                        $cgd['status']=4;
//                    }
//                    $cgd['updatetime']= date("Y-m-d H:i:s");
//                    $cgdup =Db::name("purchease_order")->save($cgd);
//                    if($cgdup==false){
//                        Db::rollback();
//                        return error_show(1005,'采购单数据更新失败');
//                    }
//                    if($cgd['bkcode']!=""){
//                        $bk=Db::name("purchease_order")->where(["bkcode"=>$cgd['bkcode'],"order_type"=>1,"order_source"=>0,"is_del"=>0])->find();
//                        if($bk==false){
//                            Db::rollback();
//                            return error_show(1005,'未找到备库单数据');
//                        }
//                       $orderbk = Db::name("order_bk")->where(['cgdNo'=>$bk['cgdNo'],"is_del"=>0])->find();
//                        if($orderbk==false){
//                            Db::rollback();
//                            return error_show(1005,'备库单未完全入库');
//                        }
//                        $merge_num = Db::name("purchease_order")->where(["bkcode"=>$bk['bkcode'],"order_type"=>1,"is_del"=>0])->where("order_source","<>",0)->field("sum(send_num)-sum(th_num) as num")->find();
//
//                        $orderbk['balance_num']=$orderbk['total_num']-$merge_num['num'];
//                        $orderbk['merge_num']=$merge_num['num'];
//                        $orderbk['updatetime']=date("Y-m-d H:i:s");
//                        $orderbkup=Db::name("order_bk")->save($orderbk);
//                        if($orderbkup==false){
//                            Db::rollback();
//                            return error_show(1005,'备库单库存数据释放失败');
//                        }
//                    }
                }else{
                    if($returninfo['return_tag']==1){
                        $sale['th_num']+= $info['return_num'];
                        if($sale['th_num']==$sale['send_num']&& $sale['wsend_num']==0){
                            $sale['status']=3;
                        }
                        $sale['th_fee']+= round($info['return_num']*$sale['sale_price'],2);
                        $sale['updatetime']= date("Y-m-d H:i:s");
                        $uap=Db::name("sale")->save($sale);
                        if($uap==false){
                            Db::rollback();
                            return error_show(1005,'销售单订单更新失败');
                        }
                        $ordernum =Db::name("order_num")->where(['orderCode'=>$info['orderCode']])->find();
                        if($ordernum==false){
                            Db::rollback();
                            return error_show(1005,'未找到关联采购单');
                        }
                        $ordernum['send_num']-=$info['return_num'];
                        $orderup =Db::name("order_num")->save($ordernum);
                        if($orderup==false){
                            Db::rollback();
                            return error_show(1005,'关联数据更新失败');
                        }
                        $cgd =Db::name("purchease_order")->where(["cgdNo"=>$ordernum['cgdNo'],"is_del"=>0])->find();
                        if($cgd==false){
                            Db::rollback();
                            return error_show(1005,'未找到采购单数据');
                        }
                        $cgd['th_num']+=  $info['return_num'];
                        if($cgd['th_num']==$cgd['send_num']&& $cgd['wsend_num']==0){
                            $cgd['status']=4;
                        }
                        $cgd['th_fee']+=  round($info['return_num']*$cgd['good_price'],2);
                        $cgd['updatetime']= date("Y-m-d H:i:s");
                        $cgdup =Db::name("purchease_order")->save($cgd);
                        if($cgdup==false){
                            Db::rollback();
                            return error_show(1005,'采购单数据更新失败');
                        }

                    }else{
                        $sale['th_num']+= $info['return_num'];
                        if($sale['th_num']==$sale['send_num']&& $sale['wsend_num']==0){
                            $sale['status']=3;
                        }
                        $sale['th_fee']+= round($info['return_num']*$sale['sale_price'],2);
                        $sale['updatetime']= date("Y-m-d H:i:s");
                        $uap=Db::name("sale")->save($sale);
                        if($uap==false){
                            Db::rollback();
                            return error_show(1005,'销售单订单更新失败');
                        }
//                        $ordernum =Db::name("order_num")->where(['orderCode'=>$info['orderCode']])->find();
//                        if($ordernum==false){
//                            Db::rollback();
//                            return error_show(1005,'未找到关联采购单');
//                        }
//                        $ordernum['send_num']-=$info['return_num'];
//                        $orderup =Db::name("order_num")->save($ordernum);
//                        if($orderup==false){
//                            Db::rollback();
//                            return error_show(1005,'关联数据更新失败');
//                        }
//                        $cgd =Db::name("purchease_order")->where(["cgdNo"=>$ordernum['cgdNo'],"is_del"=>0])->find();
//                        if($cgd==false){
//                            Db::rollback();
//                            return error_show(1005,'未找到采购单数据');
//                        }
//                        $cgd['th_fee']+= round($cgd['good_price']*$param['can_sell_num'],2);
//                        $cgd['th_num']+=  $param['can_sell_num'];
//                        if($cgd['th_num']==$cgd['send_num']&& $cgd['wsend_num']==0){
//                            $cgd['status']=4;
//                        }
//                        $cgd['updatetime']= date("Y-m-d H:i:s");
//                        $cgdup =Db::name("purchease_order")->save($cgd);
//                        if($cgdup==false){
//                            Db::rollback();
//                            return error_show(1005,'采购单数据更新失败');
//                        }
                    }
                }
            }

            $res = Db::name("order_back")
                ->where(['id' => $info['id']])
                ->update($update_data);

            if ($res) {
                $data=[
                    "orderCode"=>$info['orderCode'],
                    "th_type"=>3,
                    "th_num"=>$info['return_num'],
                    "th_fee"=>round($info['return_num']*$sale['sale_price'],2),
                    "thCode"=>$info['returnCode'],
                    "apply_id"=>$info['apply_id'],
                    "apply_name"=>$info['apply_name'],
                    "spuCode"=>$sale['good_code'],
                    "good_name"=>$sale['good_name'],
                    "cat_id"=>$sale['cat_id'],
                    "addtime"=>date("Y-m-d H:i:s"),
                    "status"=>1,
                    "is_del"=>0
                ];
                $inse=Db::name("th_data")->insert($data);
                if($inse==false){
                    Db::rollback();
                    return error_show(1004,"退货单更新失败");
                }
                if($info['return_num']>=$out['send_num']){
                    $out['status']=4;
                    $out['updatetime']=date("Y-m-d H:i:s");
                    $upout =Db::name("order_out")->save($out);
                    if($upout==false){
                        Db::rollback();
                        return error_show(1005,'出库单数据更新失败');
                    }
                }

                $stn = ["order_code" => $param['thNo'], "status" => $info['status'], "action_remark" => '', "action_type" => "edit"];
                ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname], $stn, "CKTHD",  $param['status'], $stn);

                if (in_array($param['status'], [1,2, 3])) {
                    if ($param['status'] == 2) $roleid = [10, 31, 41];//特殊处理，写入到10采购负责人、31库管人员、41库管-张凯旋这三个角色下的所有人
                    else $roleid = [31, 41];//特殊处理，写入到、31库管人员、41库管-张凯旋这三个角色下的所有人

                    $handle_user_list = Db::name('user_role')
                        ->where('is_del', 0)
                        ->whereIn('roleid', $roleid)
                        ->column('uid');

                    //如果是退货商品验收(节点1)，把供应商负责人也加进去
                    if ($param['status'] == 1) $handle_user_list[] = $sale['cgderid'];

                    $process = ["order_code" => $param['thNo'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "CKTHD", "before_status" => $info['status'], 'handle_user_list' => implode(',', $handle_user_list)];

                } else $process = ["order_code" => $param['thNo'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "CKTHD", "before_status" => $info['status']];

                ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);

                Db::commit();
                return app_show(0, '操作成功');
            } else throw new Exception('操作失败');

        } catch (Exception $exception) {

            Db::rollback();
            return error_show(1005, $exception->getMessage());
        }

    }
}