|
|
@@ -0,0 +1,197 @@
|
|
|
+<?php
|
|
|
+declare (strict_types = 1);
|
|
|
+
|
|
|
+namespace app\command;
|
|
|
+
|
|
|
+use app\admin\common\User;
|
|
|
+use think\console\Command;
|
|
|
+use think\console\Input;
|
|
|
+use think\console\input\Argument;
|
|
|
+use think\console\input\Option;
|
|
|
+use think\console\Output;use think\facade\Db;
|
|
|
+
|
|
|
+class InterMakeOrder extends Command
|
|
|
+{
|
|
|
+ protected function configure()
|
|
|
+ {
|
|
|
+ // 指令配置
|
|
|
+ $this->setName('intermakeorder')
|
|
|
+ ->setDescription('the intermakeorder command');
|
|
|
+ }
|
|
|
+
|
|
|
+ protected function execute(Input $input, Output $output)
|
|
|
+ {
|
|
|
+ $date=date("Y-m-d H:i:s");
|
|
|
+ Db::startTrans();
|
|
|
+ $interinfo =Db::name("inter_order")->where(["status"=>1,"is_del"=>1])->lock(True)->findOrEmpty();
|
|
|
+ try{
|
|
|
+ $this->makeOrder($interinfo);
|
|
|
+ $dip=Db::name("inter_order")->where($interinfo )->update(["status"=>2,"remark"=>'转单完成',"updatetime"=>date("Y-m-d H:i:s")]);
|
|
|
+ if($dip==false) throw new \Exception("录单更新失败");
|
|
|
+ Db::commit();
|
|
|
+ $output->writeln("[$date] 录单{$interinfo['interNo']} 转单成功");
|
|
|
+ }catch (\Exception $exception){
|
|
|
+ Db::rollback();
|
|
|
+ Db::name("inter_order")->where($interinfo)->update(["status"=>3,"remark"=>$exception->getMessage(),"updatetime"=>date("Y-m-d H:i:s")]);
|
|
|
+ $output->writeln("[$date] 录单{$interinfo['interNo']} 转单失败|".$exception->getMessage());
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ private function makeOrder($param):void{
|
|
|
+ $qrdcode = makeNo("QR");
|
|
|
+ $cgddcode = makeNo("CG");
|
|
|
+ $goodCode = makeNo("SKU");
|
|
|
+ $userCommon = User::getIns();
|
|
|
+ $payinfo = Db::name("platform")->where(["id"=> $param['platform_id'],"is_del"=>0])->findOrEmpty();
|
|
|
+ if (empty($payinfo)) throw new \Exception("未找到平台信息");
|
|
|
+ if ($payinfo['status'] != 1) throw new \Exception("平台信息已禁用");
|
|
|
+ if($payinfo['is_select_pay_rate']==1){
|
|
|
+ $supplierArr = Db::name("platform_pay_rate")->where(["platform_id" => $param['platform_id'], "status" => 1, "is_del" => 0])->column("companyNo");
|
|
|
+ if (in_array($param['companyNo'], $supplierArr)) throw new \Exception("平台支付渠道含有该业务公司，平台无法使用！");
|
|
|
+ }
|
|
|
+ $supplierinfo = $userCommon->handle("hqInfo",["code"=>$param['supplierNo']]);
|
|
|
+ if(!isset($supplierinfo['data'])|| empty($supplierinfo['data']))throw new \Exception("未找到供应商数据");
|
|
|
+ $person =$supplierinfo['data']['child']??["person"=>'',"person_id"=>0];
|
|
|
+ if($param['companyNo'] == $supplierinfo['data']['relation_code']) throw new \Exception("供应商和业务公司不能为同一家公司");
|
|
|
+ $qrddata = [
|
|
|
+ "orderCode" => $qrdcode,
|
|
|
+ "apply_id" => $param['apply_id'],
|
|
|
+ "apply_name" => $param['apply_name'],
|
|
|
+ "order_type" => 3,
|
|
|
+ "order_source" => 9,
|
|
|
+ "platform_id" => $param['platform_id'],
|
|
|
+ "good_code" => $goodCode,
|
|
|
+ "skuCode" => '',
|
|
|
+ "cat_id" => $param['cat_id'],
|
|
|
+ "good_name" => $param['good_name'],
|
|
|
+ "good_num" => $param['good_num'],
|
|
|
+ "good_type" => 1,
|
|
|
+ "origin_price" => $param['cgd_price'],
|
|
|
+ "sale_price" => $param['sale_price'],
|
|
|
+ "total_price" => round($param['sale_price'] * $param['good_num'], 2),
|
|
|
+ "post_fee" => 0,
|
|
|
+ "is_diff" => 0,
|
|
|
+ "is_activity" => 0,
|
|
|
+ "activity_code" => '',
|
|
|
+ "is_stock" => 0,
|
|
|
+ "arrive_time" => $param['sendtime'],
|
|
|
+ "customer_code" => $param['customerNo'],
|
|
|
+ "customerName" => $param['customerName'],
|
|
|
+ "supplierNo" => $param['companyNo'],
|
|
|
+ "supplierName" =>$param['companyName'],
|
|
|
+ "supName" => $param['supplierName'],
|
|
|
+ "supNo" => $param['supplierNo'],
|
|
|
+ "platform_order" => $param['poCode'],
|
|
|
+ "send_num" => $param['good_num'],
|
|
|
+ "wsend_num" => 0,
|
|
|
+ "send_status" => 3,
|
|
|
+ "send_type" => 1,
|
|
|
+ "status" => 2,
|
|
|
+ "is_del" => 0,
|
|
|
+ "pay_id" => 0,
|
|
|
+ "workNo" => $param['workCode'],
|
|
|
+ "addtime" => date("Y-m-d H:i:s"),
|
|
|
+ "updatetime" => date("Y-m-d H:i:s"),
|
|
|
+ "cgderid" => $person['personid'],
|
|
|
+ "cgder" => $person['person'],
|
|
|
+ "good_createrid" =>$param['apply_id'],
|
|
|
+ "good_creater" => $param['apply_name']
|
|
|
+ ];
|
|
|
+ $orderCgd = [
|
|
|
+ "orderCode" => $qrdcode,
|
|
|
+ "cgdNo" => $cgddcode,
|
|
|
+ "spuCode" => $goodCode,
|
|
|
+ "good_num" => $param['good_num'],
|
|
|
+ "wsend_num" => 0,
|
|
|
+ "send_num" => $param['good_num'],
|
|
|
+ "wait_num" => 0
|
|
|
+ ];
|
|
|
+ $cgddata = [
|
|
|
+ "cgdNo" => $cgddcode,
|
|
|
+ "bkcode" => '',
|
|
|
+ "wsm_code" => "",
|
|
|
+ "cgder_id" => $person['personid'],
|
|
|
+ 'cgder' => $person['person'],
|
|
|
+ "spuCode" => $goodCode,
|
|
|
+ "good_name" => $param['good_name'],
|
|
|
+ "good_num" => $param['good_num'],
|
|
|
+ "good_price" => $param['cgd_price'],
|
|
|
+ "total_fee" => round($param['cgd_price'] * $param['good_num'], 2),
|
|
|
+ "supplierNo" => $param['supplierNo'],
|
|
|
+ "supplier_name" =>$param['supplierName'],
|
|
|
+ "companyNo" => $param['companyNo'],
|
|
|
+ "companyName" => $param['companyName'],
|
|
|
+ "send_status" => 3,
|
|
|
+ "send_num" => $param['good_num'],
|
|
|
+ "wsend_num" => 0,
|
|
|
+ "status" => 3,
|
|
|
+ "lasttime" => date("Y-m-d H:i:s"),
|
|
|
+ "order_type" => 3,
|
|
|
+ "order_source" => 9,
|
|
|
+ "addtime" => date("Y-m-d H:i:s"),
|
|
|
+ "updatetime" => date("Y-m-d H:i:s"),
|
|
|
+ "good_createrid" =>$param['apply_id'],
|
|
|
+ "good_creater" => $param['apply_name']
|
|
|
+ ];
|
|
|
+ $goodinfo = [
|
|
|
+ "spuCode" => $goodCode,
|
|
|
+ "good_name" => $param['good_name'],
|
|
|
+ "brand_id" => 0,
|
|
|
+ "cat_id" => $param['cat_id'],
|
|
|
+ "good_unit" => $param['good_unit'],
|
|
|
+ "good_type" => 1,
|
|
|
+ "moq" => 1,
|
|
|
+ "customized" => 0,
|
|
|
+ "platform_id" => $param['platform_id'],
|
|
|
+ "tax" => $param['tax'],
|
|
|
+ "supplierNo" => $param['supplierNo'],
|
|
|
+ "supplierName" =>$param['supplierName'],
|
|
|
+ "is_auth" => 1,
|
|
|
+ "craft_desc" => '',
|
|
|
+ "good_remark" => '',
|
|
|
+ "good_img" => '',
|
|
|
+ "good_thumb_img" => '',
|
|
|
+ "good_info_img" => '',
|
|
|
+ "createrid" => $param['apply_id'],
|
|
|
+ "creater" => $param['apply_name'],
|
|
|
+ "specinfo" => '',
|
|
|
+ "work_day" => 0,
|
|
|
+ "noble_metal" => 0,
|
|
|
+ "good_weight" => 0,
|
|
|
+ "config" => "",
|
|
|
+ "weight" => 0,
|
|
|
+ "supply_area" => 0,
|
|
|
+ "is_diff" => 0,
|
|
|
+ "pay_way" => 0,
|
|
|
+ "send_way" => 0,
|
|
|
+ "companyNo" => $param['companyNo'],
|
|
|
+ "companyName" =>$param['companyName'],
|
|
|
+ "addtime" => date("Y-m-d H:i:s"),
|
|
|
+ "updatetime" => date("Y-m-d H:i:s"),
|
|
|
+ ];
|
|
|
+ $orderAddr = [
|
|
|
+ "orderCode" => $qrdcode,
|
|
|
+ "addr" => $param['addr'],
|
|
|
+ "addr_code" => '',
|
|
|
+ "contactor" => $param['contactor'],
|
|
|
+ "mobile" => $param['mobile'],
|
|
|
+ "arrive_time" => $param['sendtime'],
|
|
|
+ "customer_code" => $param['customerNo'],
|
|
|
+ "receipt_quantity" => $param['good_num'],
|
|
|
+ "addtime" => date("Y-m-d H:i:s"),
|
|
|
+ "updatetime" => date("Y-m-d H:i:s"),
|
|
|
+ ];
|
|
|
+ $qrd = Db::name("sale")->insert($qrddata);
|
|
|
+ if ($qrd == false) throw new \Exception("销售单生成失败");
|
|
|
+ $qrd = Db::name("order_num")->insert($orderCgd);
|
|
|
+ if ($qrd == false) throw new \Exception("销售单采购管联生成失败");
|
|
|
+ $qrd = Db::name("purchease_order")->insert($cgddata);
|
|
|
+ if ($qrd == false) throw new \Exception("采购单生成失败");
|
|
|
+ $qrd = Db::name("good_zixun")->insert($goodinfo);
|
|
|
+ if ($qrd == false) throw new \Exception("商品信息录入生成失败");
|
|
|
+ $qrd = Db::name("order_addr")->insert($orderAddr);
|
|
|
+ if ($qrd == false) throw new \Exception("销售单地址生成失败");
|
|
|
+ }
|
|
|
+}
|
