ad

app/admin/controller/Base.php

@@ -303,7 +303,6 @@ class Base extends \app\BaseController
         $newAdd = Db::name("good_change_log")->insert($log);
         if ($newAdd == false) throw new \Exception("非库存商品转库存失败", 1005);
         return $spuCode;
-
     }
 
 }

app/admin/model/GoodExam.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class GoodExam extends Model
+{
+    //
+}

app/admin/model/GoodLadder.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class GoodLadder extends Model
+{
+    //
+}

app/admin/model/GoodNake.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class GoodNake extends Model
+{
+    //
+}

app/admin/model/GoodOffineLog.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class GoodOffineLog extends Model
+{
+    //
+}

app/admin/model/GoodPlatform.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class GoodPlatform extends Model
+{
+    //
+}

app/admin/model/GoodProof.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model;
+
+use think\Model;
+
+/**
+ * @mixin \think\Model
+ */
+class GoodProof extends Model
+{
+    //
+}

app/bbc/controller/Base.php

@@ -0,0 +1,56 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\bbc\controller;
+
+use think\App;
+use think\exception\HttpResponseException;
+use think\Response;
+
+class Base extends \app\admin\controller\Base
+{
+  public function __construct(App $app) {parent::__construct($app);}
+  
+   /**
+	* @param string $message
+	* @param int $code
+	* @param null $data
+	 */
+    public function error($message='',$code=1003,$data=null){
+        $this->result($message,$data,$code);
+    }
+    /**
+	* @param string $message
+	* @param int $code
+	* @param null $data
+	 */
+     public function success($message='',$data=null,$code=0){
+        $this->result($message,$data,$code);
+    }
+    
+     /**
+	* @param string $msg
+	* @param null $data
+	* @param int $code
+	* @param string|null $type
+	* @param array $header
+	* @param array $options
+	 */
+    private function result(string $msg, $data = null, int $code = 0, string $type = "json", array $header = [], array
+    $options = [])
+    {
+        $result = [
+            'code' => $code,
+            'message'  => $msg,
+            'data' => $data,
+        ];
+        $code = 200;
+        if (isset($header['statuscode'])) {
+            $code = $header['statuscode'];
+            unset($header['statuscode']);
+        }
+
+        $response = Response::create($result, $type, $code)->header($header)->options($options);
+         throw new HttpResponseException($response);
+    }
+}

app/bbc/controller/Good.php

@@ -0,0 +1,251 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\bbc\controller;
+
+use app\admin\model\GoodBasic;use app\admin\model\GoodExam;use app\admin\model\GoodLadder;use app\admin\model\GoodNake;use app\admin\model\GoodPlatform;use app\admin\model\GoodProof;use app\admin\model\Platform;use app\admin\model\PlatformYouzan;use app\model\AccountItem;use app\youzan\model\Account;use think\App;use think\Exception;use thinkException;use think\facade\Validate;
+
+class Good extends Base
+{
+   public function __construct(App $app) {parent::__construct($app);}
+   
+   public function list(){
+   	 $param = $this->request->only([
+        	'page' => 1,
+            'size' => 15,
+            'cat_id' => '',
+            'good_name' => '',
+            'skucode' => '',
+            'spucode' => '',
+            'start' => '',
+            'end' => '',
+            'is_stock' => '',
+            'good_type' => '',
+            'supplierNo' => '',
+            'companyNo' => '',
+            'creater' => '',
+            'online_creater' => '',
+            'createrid' => '',
+            'status' => '',
+            'platform_code' => '',
+            'platform_type' => 1,
+            'plat_code' => '',
+            'exam_status' => '',
+            'brand_id' => '',
+            'company_name' => '',
+            'create_source' => '',
+            'is_compliance' => '',
+            'relaComNo' => '',
+            ],'post','trim');
+        
+         $where = [['b.is_del', '=', 0]];
+         $platfrom =new Platform();
+        if ($param['cat_id'] !== '') $where[] = ['a.cat_id', '=', $param['cat_id']];
+        if ($param['good_name'] !== '') $where[] = ['a.good_name', 'like', '%' . $param['good_name'] . '%'];
+        if ($param['skucode'] !== '') $where [] = ['b.skucode', 'like', '%' . $param['skucode'] . '%'];
+        if ($param['spucode'] !== '') $where [] = ['b.spucode', 'like', '%' . $param['spucode'] . '%'];
+        if ($param['start'] !== '') $where[] = ['b.addtime', '>=', date('Y-m-d H:i:s', strtotime($param['start']))];
+        if ($param['end'] !== '') $where[] = ['b.addtime', '<', date('Y-m-d H:i:s', strtotime($param['end']) + 24 * 3600)];
+        if ($param['is_stock'] !== '') $where[] = ['a.is_stock', '=', $param['is_stock']];
+        if ($param['good_type'] !== '') $where[] = ['a.good_type', '=', $param['good_type']];
+        if ($param['supplierNo'] !== '') $where[] = ['a.supplierNo', '=', $param['supplierNo']];
+        if ($param['companyNo'] !== '') $where[] = ['a.companyNo', 'like', '%' . $param['companyNo'] . '%'];
+        if ($param['online_creater'] !== '') $where[] = ['b.creater', 'like', '%' . $param['online_creater'] . '%'];
+        if ($param['creater'] !== '') $where[] = ['a.creater', 'like', '%' . $param['creater'] . '%'];
+        if ($param['createrid'] !== '') $where[] = ['a.createrid', '=', $param['createrid']];
+        if ($param['status'] !== '') $where[] = ['a.status', '=', $param['status']];
+        if ($param['platform_code'] !== '') $where[] = ['b.platform_code', '=', $param['platform_code']];
+        if ($param['plat_code'] !== '') $where[] = ['b.plat_code', 'like', '%' . $param['plat_code'] . '%'];
+        if ($param['exam_status'] !== '') $where[] = ['b.exam_status', '=', $param['exam_status']];
+        if ($param['create_source'] !== '') $where[] = ['a.create_source', '=', $param['create_source']];
+        if ($param['is_compliance'] !== '') $where[] = ['b.is_compliance', '=', $param['is_compliance']];
+        if ($param['brand_id'] !== '') $where[] = ['a.brand_id', '=', $param['brand_id']];
+        if($param['platform_type'] == ''){
+            $platfromId = $platfrom->where(['platform_type'=>$param['platform_type'],'is_del'=>0])->column('id');
+            $where[] = ['b.platform_id', 'in', $platfromId ];
+        }
+         if($param['relaComNo'] !== '') $where[]=['a.companyNo|a.supplierNo','=', $param['relaComNo']];
+         $list = (new GoodPlatform()) ->alias('b')
+            ->leftJoin('good a', 'a.spuCode=b.spuCode')
+            ->field('b.skuCode,b.platform_code,b.plat_code,b.id as good_id,a.cat_id,a.good_name,a.good_img,b.is_fixed,
+            a.good_info_img,a.good_thumb_img,b.createrid,a.is_exclusive,a.brand_id,a.supplierNo,a.supplierName,a.create_source,
+            a.good_unit,a.noble_metal,a.companyNo,a.companyName,a.spuCode,a.good_type,b.creater,b.addtime,b.updatetime,
+            b.exam_status,a.createrid purchase_id,a.creater purchase,a.is_stock,b.is_compliance,b.compliance_remark')
+            ->where($where)->order('b.id desc')->paginate(['page'=>$param['page'],'list_rows'=>$param['size']]);
+         $cat =new \app\admin\model\Cat();
+         $Brand =new \app\admin\model\Brand();
+         $unit =new \app\admin\model\Unit();
+         $account = new AccountItem();
+         foreach ($list->items() as $item){
+         	$catinfo= $cat->where(['id'=>$item['cat_id']])->value('search','');
+            $item['cat_info'] =explode('_',$catinfo);
+            $item['brand_name'] =$Brand->where(['id'=>$item['brand_id']])->value('brand_name','');
+//            $item['unit'] =$unit->where(['id'=>$item['good_unit']])->value('unit','');
+            $item['platform_name'] =$platfrom->where(['id'=>$item['platform_code']])->value('platform_name','');
+//            $item['exclusive'] = makeExcluse($item['is_exclusive']);
+            $item['company_name'] =$account->alias('a')->leftJoin('company_item b','a.itemid=b.id')
+            ->where('a.account_id',$item['createrid'])->value('b.name');
+         }
+      $this->success("获取成功", ['list' => $list->items(), 'count' => $list->total()]);
+   }
+   
+   
+    //审核
+    public function exam(){
+    	$post =$this->request->only([
+    		'skuCode'=>'',          //商品成本编号
+    		'exam_status'=>'',      //审核状态 1 提交待完善成本 2待审核 3上线完成 4 审核驳回 5 下线完成 6 待bbc上线补录bbc编号 7 bbc驳回
+    		'offline_reason'=>'',   //下线原因
+    		'offline_remark'=>'',   //下线备注
+    		'plat_code'=>'',        //平台订单号
+    		'exam_remark'=>'',      //审核备注
+    		'good_ladder'=>[],      //售价阶梯
+    		'proof_type'=>'',       // 售价凭证类型
+    		'proof_url'=>'',       // 售价凭证
+    		],'post','trim');
+    	$valide = Validate::rule([
+    		'skuCode|商品编号'=>'require|max:255',
+    		'exam_status|审核状态'=>'require|number|in:0,1,2,3,4,5,6,7',
+    		'offline_reason|线下原因'=>'requireIf:exam_status,5|max:255',
+    		'offline_remark|下线备注'=>'requireIf:exam_status,5|max:255',
+    		'plat_code|平台商品编码'=>'requireIf:exam_status,3|max:255',
+    		'exam_remark|审核备注'=>'max:255',
+    		'good_ladder|售价阶梯'=>'requireIf:exam_status,3|array',
+    		'proof_type|售价凭证类型'=>'requireIf:exam_status,3|number|gt:0',
+    		'proof_url|售价凭证'=>'requireIf:exam_status,3|max:255',
+    		]);
+		if($valide->check($post)==false) $this->error($valide->getError());
+		$goodPlat = new GoodPlatform();
+		$goodNake = new GoodNake();
+        $platform = $goodPlat->where(['skuCode'=>$post['skuCode'],'is_del'=>0])->findOrEmpty();
+        if($platform->isEmpty()) $this->error('未找到商品数据');
+        
+//         if($platform->is_fixed==1){
+//        	//使用实时金价
+//        	 $nake=$goodNake->where(['spuCode'=> $platform->spuCode,'is_del'=>0,'nake_fee'=>0])
+//        	 ->findOrEmpty();
+//        	 if($nake->isEmpty()) $this->error('一口价商品请先完善商品成本单价');
+//        }
+        if($post['exam_status']==3){
+            $is_exit = $goodPlat
+                ->where(['plat_code' =>$post['plat_code'],'is_del' =>0, 'exam_status' =>3])//bbc商品编号唯一不可重复
+                ->where('id', '<>', $platform['id'])
+                ->findOrEmpty();
+            if($is_exit->isEmpty()) $platform->plat_code=$post['plat_code'];
+            else  $this->error("平台商品编码 {$post['plat_code']} 已存在");
+        }
+          if($post['exam_status']==5){
+	            $platform->is_compliance=0;
+	            $platform->compliance_remark='';
+          }
+         $before= $platform['exam_status'];
+        $platform->exam_status=$post['exam_status'];
+        $platform->updatetime=date('Y-m-d H:i:s');
+        $createrid= $this->uid;
+        $creater= $this->uname;
+        $platform->startTrans();
+        try {
+            $up = $platform->save();
+            if($up){
+                $data=[
+                    'code'=>$platform->skuCode,
+                    'exam_status'=>$post['exam_status'],//$exam_status,
+                    'type'=>2,
+                    'exam_id'=>$createrid,
+                    'exam_name'=>$creater,
+                    'exam_remark'=>$post['exam_remark'],
+                    'addtime'=>date('Y-m-d H:i:s')
+                ];
+                $inr=(new GoodExam())->save($data);
+                if($inr){
+                	$event=[];
+//					 ActionLog::logAdd(['id' => $createrid, 'nickname' => $creater], [
+//                        'order_code' => $platform['skuCode'],//编号
+//                        'status' => $before,
+//                        'action_remark' => '',//备注
+//                        'action_type' => 'status'//新建create，编辑edit，更改状态status
+//                    ], 'SPSX', $post['exam_status'], $platform);
+//
+                    //如果是商品下线的话，记入商品下线记录表
+                    if ($post['exam_status'] == 5) {
+                    
+//                        $offline_id = Db::name('good_offline_log')->insertGetId([
+//                            'spuCode' => $platform['spuCode'],
+//                            'skuCodes' => $platform['skuCode'],
+//                            'good_name' => Db::name('good_basic')->where('spuCode', $platform['spuCode'])->value('good_name', ''),
+//                            'offline_reason' => $post['offline_reason'],
+//                            'offline_remark' => $post['offline_remark'],
+//                            'createrid' => $createrid,
+//                            'creater' => $creater,
+//                            'addtime' => date('Y-m-d H:i:s'),
+//                        ]);
+                    }
+                    if ($post['exam_status'] == 3) {
+                    	//todo::需要去掉；
+                    	if($post['proof_url']!=''){
+                    		$proof=[
+		                    'spuCode'=>$platform->spuCode,
+		                    'proof_type'=>$post['proof_type'],
+		                    'proof_url'=>$post['proof_url'],
+		                    'is_del'=>0,
+		                    'creater'=>$this->uname,
+		                    'createrid'=>$this->uid,
+		                    'addtime'=>date('Y-m-d H:i:s'),
+		                    'updatetime'=>date('Y-m-d H:i:s')
+		                    ];
+		                    GoodProof::create($proof);
+                    	}
+                    	
+		                if(empty($post['good_ladder']))throw new Exception('商品阶梯价不能为空');
+		                $goodLadder =new GoodLadder();
+		                $saveArr=[];
+		                foreach ($post['good_ladder'] as $value){
+		                	    $lemp=[];
+				                isset($value['id'])?$lemp['id']=$value['id']:$lemp['addtime'] = date('Y-m-d H:i:s');
+				                $lemp['skuCode']=$platform->spuCode;
+				                $lemp['min_num'] = $value['min_num'];
+				                $lemp['max_num'] = 0;
+				                $lemp['sale_price'] = $value['sale_price'];
+				                $lemp['market_price'] = $value['market_price'];
+				                $lemp['market_platform'] = $value['market_platform'];
+				                $lemp['cost_fee'] = $value['cost_fee'];
+				                $lemp['is_del'] = isset($value['is_del'])?$value['is_del']:0;
+                                $lemp['updatetime'] =date('Y-m-d H:i:s');
+                                $saveArr[]=$lemp;
+		                }
+		                $ladderUp = $goodLadder->saveAll($saveArr);
+		                if($ladderUp==false) throw new Exception('商品阶梯价录入失败');
+                    }
+                   
+                }else throw new Exception('商品审核失败');
+            }else throw new Exception('商品审核失败');
+                    $platform->commit();
+                    $event=[ 'order_type' => 'SPSX',
+                        'order_code' =>$platform->skuCode,//咨询单详情编号
+                        'order_id' => $platform->id,
+                        'order_status' => 2,
+                        'action_process' =>$post['exam_status'],
+                        'action_status' => $before,
+                        'action_uid' => $this->uid,
+                        'action_name' => $this->uname,
+                        ];
+                   event('ProcessOrder',$event);
+                   if($post['exam_status']==5){
+                   	$enevt=[
+                   		    'spuCode' => $platform->spuCode,
+                            'skuCodes' => $platform->skuCode,
+                            'good_name' => (new GoodBasic())->where('spuCode',$platform->spuCode)->value('good_name', ''),
+                            'offline_reason' => $post['offline_reason'],
+                            'offline_remark' => $post['offline_remark'],
+                            'createrid' => $createrid,
+                            'creater' => $creater,
+						];
+                   	event('goodOff',$enevt);
+                   }
+                   $this->success('商品审核成功');
+        }catch (Exception $e){
+            $platform->rollback();
+            $this->error($e->getMessage().$e->getLine().$e->getFile());
+        }
+    }
+}

app/bbc/event/GoodOffineLog.php

@@ -0,0 +1,8 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\bbc\event;
+
+class GoodOffineLog
+{
+}

app/bbc/event/ProcessOrder.php

@@ -0,0 +1,8 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\bbc\event;
+
+class ProcessOrder
+{
+}

app/bbc/listener/GoodOffine.php

@@ -0,0 +1,18 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\bbc\listener;
+
+use app\admin\model\GoodOffineLog;
+class GoodOffine
+{
+    /**
+     * 事件监听处理
+     *
+     * @return mixed
+     */
+    public function handle($event)
+    {
+       GoodOffineLog::create($event);
+    }
+}

app/bbc/listener/ProcessOrder.php

@@ -0,0 +1,18 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\bbc\listener;
+
+class ProcessOrder
+{
+    /**
+     * 事件监听处理
+     *
+     * @return mixed
+     */
+    public function handle($event)
+    {
+       
+       \app\admin\model\ProcessOrder::create($event);
+    }
+}

app/event.php

@@ -2,6 +2,8 @@
 // 事件定义文件
 return [
     'bind'      => [
+//    	"GoodOff"=>\app\bbc\event\GoodOffineLog::class,
+//    	"ProcessOrder"=>\app\bbc\event\ProcessOrder::class
     ],
 
     'listen'    => [
@@ -10,6 +12,8 @@ return [
         'HttpEnd'  => [],
         'LogLevel' => [],
         'LogWrite' => [],
+        'ProcessOrder' => [\app\bbc\listener\ProcessOrder::class],
+        'GoodOff' => [\app\bbc\listener\GoodOffine::class],
     ],
 
     'subscribe' => [

app/report/controller/Stats.php

@@ -345,7 +345,7 @@ class Stats extends Base
 				    }
 				    )
 	            ->select();
-				if($list->isEmpty())$noArr['result'][$start]['total_price']==0;
+				if($list->isEmpty())$noArr['result'][$start]=['total_price'=>0];
 				else{
 					$total =strval(array_sum(array_column($list->toArray() , 'total_price')));
 					$before_th =strval(array_sum(array_column($list->toArray() , 'before_th')));