<?php
namespace app\admin\controller;
use app\admin\model\GoodLog;
use app\admin\model\ProcessOrder;
use Exception;
use think\App;
use think\facade\Db;
use app\admin\model\ActionLog;
use think\facade\Validate;
//销售单
class Sale extends Base
{
public $noble=[];
public function __construct(App $app)
{
parent::__construct($app);
$this->noble=\think\facade\Config::get("noble");
}
public function create()
{
$token = isset($this->post['token']) && $this->post['token'] !=="" ?trim($this->post['token']):"";
$orderCode=makeNo("QR");
$customer_code= isset($this->post['customer_code'])&& $this->post['customer_code'] !=="" ? trim($this->post['customer_code']) :"";
if($customer_code==""){
return error_show(1002,"客户customer_code不能为空");
}
$customer=Db::name("customer_info")->where(["companyNo"=>$customer_code])->find();
if($customer==false){
return error_show(1004,"未找到客户数据");
}
$supplierNo= isset($this->post['supplierNo']) && $this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']) :"";
if($supplierNo==""){
return error_show(1002,"参数supplierNo不能为空");
}
$supplier=Db::name("business")->where(["companyNo"=>$supplierNo])->find();
if($supplier==false){
return error_show(1004,"未找到平台供应商数据");
}
$goodtype =isset($this->post['goodtype']) && $this->post['goodtype'] !=="" ?intval($this->post['goodtype']):"1";
$order_type =isset($this->post['order_type']) && $this->post['order_type'] !=="" ?intval($this->post['order_type'])
:"1";
$sendtype =isset($this->post['sendtype']) && $this->post['sendtype'] !=="" ?intval($this->post['sendtype']):"";
if($sendtype===''){
return error_show(1004,"参数sendtype不能为空");
}
$platform_id =isset($this->post['platform_id']) && $this->post['platform_id'] !=="" ?intval($this->post['platform_id']):"";
if($platform_id==''){
return error_show(1004,"参数platform_id不能为空");
}
$platform_order =isset($this->post['platform_order']) && $this->post['platform_order'] !=="" ?trim($this->post['platform_order']):"";
$good_code =isset($this->post['good_code']) && $this->post['good_code'] !=="" ?trim($this->post['good_code']):"";
if($good_code==''){
return error_show(1004,"参数good_code不能为空");
}
$good_num =isset($this->post['good_num']) && $this->post['good_num'] !=="" ?intval($this->post['good_num']):"";
if($good_num===''){
return error_show(1004,"参数good_num不能为空");
}
$arrtime = isset($this->post['arrtime'])&&$this->post['arrtime']!="" ?$this->post['arrtime']:"";
if($arrtime==""){
return error_show(1004,"参数arrtime不能为空");
}
$paytime =isset($this->post['paytime'])&&$this->post['paytime']!=""? $this->post['paytime']:"";
$workNo =isset($this->post['workNo'])&&$this->post['workNo']!=""? trim($this->post['workNo']):"";
// $poNo =isset($this->post['poNo'])&&$this->post['poNo']!=""? trim($this->post['poNo']):"";
$ct = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $good_code])->field("b.*,a.skuCode,a.platform_code,a.plat_code")->find();
if ($ct == false) {
return error_show(1002, "未找到商品数据");
}
$goodinfo=$ct;
$is_stock=$ct['is_stock'];
$spuCode = $ct['spuCode'];
$skuCode = $ct['skuCode'];
$is_activity= isset($this->post['is_activity'])&&$this->post['is_activity']!=="" ?$this->post['is_activity']:"";
$actcode= isset($this->post['act_code'])&&$this->post['act_code']!=="" ?trim($this->post['act_code']):"";
if($order_type==1){
if($is_activity===""){
return error_show(1002, "参数is_activity不能为空");
}
if($is_activity==1 &&$actcode=="" ){
return error_show(1002, "参数act_code不能为空");
}
}
if($goodinfo['is_stock']==1){
$stock =Db::name("good_stock")->alias("a")->leftJoin("warehouse_info b","a.wsm_code=b.wsm_code")->where
(["spuCode"=>$spuCode, "a.is_del"=>0,"a.status"=>1,"b.companyNo"=>$supplierNo])->field("a.id,a.usable_stock,a.wait_out_stock")->find();
if($stock==false||$stock['usable_stock']<$good_num){
return error_show(1003,"库存数量不足");
}
}
$origin = Db::name("good_nake")->where([["spuCode","=",$spuCode],["min_num","<=",$good_num],["is_del","=",
0]])->order("min_num desc")->find();
if($origin==false){
return error_show(1003,"未找到相关阶梯成本价格");
}
$origin_price = $origin['nake_total'];
$sale_price = isset($this->post['good_price'])&&$this->post['good_price']!="" ? floatval($this->post['good_price']):0;
if($goodtype==1){
$good = Db::name("good_ladder")->where(["skuCode"=>$skuCode,"is_del"=>0,"status"=>1])->where([["min_num",
"<=",$good_num]])->order("min_num desc")->find();
if($good==false){
return error_show(1003,"未找到相关阶梯价格");
}
$sale_price = $good['sale_price'];
if($is_activity==1){
$act = Db::name("activity_info")->alias("a")->leftJoin("good_activity b","a.activity_code=b.activity_code")
->where(["a.skuCode"=>$skuCode,"a.activity_code"=>$actcode,"a.is_del"=>0,"a.status"=>1,"b.status"=>6,"b.is_del"=>0])
->find();
if($act==false){
return error_show(1003,"未找到相关活动价");
}
if($act['moq_num']>$good_num){
return error_show(1003,"商品不满足活动价起订量{$act['moq_num']}");
}
if($act['activity_stock']<$good_num){
return error_show(1003,"商品活动库存剩余{$act['activity_stock']}");
}
$sale_price=$act['activity_price'];
}
}
$cgd=[
"supplierNo"=>$ct['supplierNo'],
"companyNo"=>$supplierNo,
"orderCode"=>$orderCode,
"spuCode"=>$ct['spuCode'],
"skuCode"=>$ct['skuCode'],
"good_name"=>$ct['good_name'],
"sale_price"=>$origin_price,
"total_fee"=>$origin_price*$good_num,
"pakge_fee"=>$ct['packing_fee'],
"cert_fee"=>$ct['cert_fee'],
"open_fee"=>$ct['open_fee'],
"cost_fee"=>$ct['cost_fee'],
"mark_fee"=>$ct['mark_fee'],
"demo_fee"=>$ct['demo_fee'],
"good_num"=>$good_num,
"good_type"=>$goodtype,
"order_type"=>$is_stock==1?1:2,
"createrid"=>$ct['createrid'],
"creater"=>$ct['creater'],
'send_way'=>2
];
$addrlist = isset($this->post['addrlist']) && $this->post['addrlist'] !=="" ?$this->post['addrlist']:"";
$send_num =0;
if($sendtype==1){
if($addrlist=="" || empty($addrlist) ||!is_array($addrlist)){
return error_show(1004,"参数addrlist不能为空");
}
$send_num = array_sum(array_column($addrlist,"receipt_quantity"));
}
$remark =isset($this->post['remark']) && $this->post['remark'] !=="" ?trim($this->post['remark']):"";
$apply_id =GetUserInfo($token);
if(empty($apply_id)||$apply_id['code']!=0){
return error_show(1002,"申请人数据不存在");
}
$rm= isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri= isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
Db::startTrans();
try {
$data=[
"orderCode"=>$orderCode,
"good_code"=>$spuCode,
"skuCode"=>$skuCode,
"customer_code"=>$customer_code,
"good_name"=>isset($goodinfo['good_name'])&&$goodinfo['good_name']!==''?$goodinfo['good_name']:'',
"good_num"=>$good_num,
"cat_id"=>$goodinfo['cat_id'],
"apply_id"=>$rm,
"apply_name"=>$ri,
"origin_price"=>$origin_price,
"sale_price"=>$sale_price,
"post_fee"=>0,
"status"=>$send_num == 0 ? 3 : ($good_num==$send_num ? 5 : 4),
"send_num"=>$send_num,
"wsend_num"=>$good_num-$send_num,
"send_status"=>$good_num==$send_num? 3 :($send_num==0?1 :2) ,
"good_type"=>$goodtype,
"send_type"=>$sendtype,
"supplierNo"=>$supplierNo,
"is_del"=>0,
"zxNo"=>"",
"platform_order"=>$platform_order,
"platform_id"=>$platform_id,
"remark"=>$remark,
"is_stock"=>$is_stock,
"is_activity"=>$is_activity===""?0:$is_activity,
"order_type"=>$order_type,
// "poNo"=>$poNo,
'good_weight'=>$ct['weight'],
'gold_price'=>$ct['cgd_gold_price'],
'cost_price'=>$ct['cost_fee'],
'diff_weight'=>0,
'diff_fee'=>0,
"workNo"=>$workNo,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s"),
'total_price'=>round($sale_price*$good_num,2),
];
$paytime==""?"": $data['paytime'] = $paytime;
$datainfo = Db::name('sale')->insert($data,true);
if($datainfo>0){
if($is_activity==1){
$actup =[
"activity_stock"=> $act['activity_stock'] - $good_num,
"updatetime"=>date("Y-m-d H:i:s")
];
$actupp= Db::name("activity_info")->where(["skuCode"=>$skuCode,"activity_code"=>$actcode,
"is_del"=>0,"status"=>1])->save($actup);
if($actupp==false){
Db::rollback();
return error_show(1002,"活动库存修改失败");
}
}
if($is_stock==0){
$bol=$this->createCgd($cgd);
if($bol==false){
Db::rollback();
return error_show(1002,"订单创建失败");
}
}else{
$bol =$this->RelaCgd(['orderCode'=>$orderCode,"good_num"=>$good_num,"spuCode"=>$spuCode,"companyNo"=>$supplierNo]);
if($bol==false){
Db::rollback();
return error_show(1002,"库存商品关联采购单失败");
}
if(isset($stock)){
$stck = [
"usable_stock"=>$stock['usable_stock']-$good_num,
"wait_out_stock"=>$stock['wait_out_stock']+$good_num,
"updatetime"=>date("Y-m-d H:i:s")
];
$upad=Db::name("good_stock")->where($stock)->update($stck);
if($upad==false){
Db::rollback();
return error_show(1002,"库存商品更新库存失败");
}
//商品变动日志表，good_log_code字段存储采购单号
$good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 2,'stock'=>$good_num, "stock_name" => "usable_stock"];
$good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 1,'stock'=>$good_num, "stock_name" => "wait_out_stock"];
GoodLog::LogAdd($this->post['token'],$good_data,"XSQRD");
}
}
if($sendtype==1){
foreach ($addrlist as $value){
$temp=[];
$addrs=[];
if($value['addr_code']!==''&&is_array($value['addr_code'])){
$addrs['provice_code'] = $value['addr_code'][0];
$addrs['city_code'] = $value['addr_code'][1];
$addrs['area_code'] = $value['addr_code'][2];
$addr = json_encode($addrs);
}else{
$addr = isset($value['addr_code'])?$value['addr_code']:'';
}
$temp['orderCode']=$orderCode;
$temp['contactor']=$value['contactor'];
$temp['mobile'] = $value['mobile'];
$temp['addr'] = $value['addr'];
$temp['addr_code']=$addr;
$temp['customer_code'] =$customer_code;
$temp['receipt_quantity']=$value['receipt_quantity'];
$temp['post_fee'] =0;
$temp['is_del'] =0;
$temp['addtime'] =date("Y-m-d H:i:s");
$temp['updatetime'] =date("Y-m-d H:i:s");
$temp['arrive_time']=$arrtime;
$vmp = Db::name('order_addr')->insert($temp,true);
if($vmp>0){
if($is_stock==1) {
$order = Db::name("order_num")->where(["orderCode" => $orderCode, "status" => 1])->where([["wsend_num", ">=", 0]])
->lock(true)->find();
if ($order==false) {
return error_show(1004, "未找到可以发货得采购单数据");
}
$num = $value['receipt_quantity'];
$outCode = makeNo("DF");
$order['wsend_num']-=$num;
$order['send_num']+=$num;
$or = Db::name("order_num")->save($order);
if ($or == false) {
Db::rollback();
return error_show(1002, "发货地址添加创建失败");
}
$tep = [
"cgdNo" => $order['cgdNo'],
"outCode" => $outCode,
"send_num" => $num,
"status" => 1,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$sen = Db::name("order_send")->save($tep);
if ($sen == false) {
Db::rollback();
return error_show(1002, "发货地址添加创建失败");
}
$cgdinfo = Db::name("purchease_order")->where(["cgdNo" => $order['cgdNo']])->find();
if ($cgdinfo == false) {
Db::rollback();
return error_show(1002, "未匹配到采购数据");
}
$out = [
"orderCode" => $orderCode,
"outCode" => $outCode,
"apply_id" => $rm,
"apply_name" => $ri,
"addrid" => $vmp,
"post_name" => "",
"post_code" => "",
"post_fee" => 0,
"sendtime" => date("Y-m-d H:i:s"),
"send_num" => $num,
"check_num" => 0,
"error_num" => 0,
"wsm_code" => $cgdinfo['wsm_code'],
"order_type" =>1,
"status" => 1,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$ou = Db::name("order_out")->insert($out);
if ($ou == false) {
Db::rollback();
return error_show(1002, "发货地址添加创建失败");
}else{
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $outCode,//出库单号
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKD", 0, $out);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CKD',
"order_code" => $outCode,//出库单号
"order_id" => 0,
"order_status" => 0
]);
}
}
}else{
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
}
}
Db::commit();
return error_show(0,"咨询订单创建成功",["order_code"=>$orderCode]);
}
Db::rollback();
return error_show(1002,"咨询订单创建失败");
}catch(\Exception $e){
Db::rollback();
return error_show(1005,$e->getMessage());
}
}
//采购单
public function createCgd($data){
$cgdCode = makeNo("CG");
$supplier=Db::name("supplier")->where(["code"=>$data['supplierNo'],"is_del"=>0])->find();
if($supplier==false){
return false;
}
$wsm= Db::name("warehouse_info")->where(["supplierNo"=>$data["supplierNo"],"companyNo"=>$data['companyNo'],"is_del"=>0])->find();
if($wsm==false){
$wsm_code = makeNo("WSM");
$inwsm=[
"wsm_code"=>$wsm_code,
"name"=>$supplier['name'],
"wsm_type"=>2,
"supplierNo"=>$supplier['code'],
"addr"=>"",
"addrs_code"=>"",
"contactor"=>0,
"contactor_name"=>0,
"mobile"=>"",
"position"=>"",
"companyNo"=>$data['companyNo'],
"status"=>1,
"is_del"=>0,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$in = Db::name("warehouse_info")->insert($inwsm);
if($in==false){
return false;
}
}else{
$wsm_code =$wsm['wsm_code'];
}
$cg =["cgdNo"=>$cgdCode,
"bkcode"=>"",
"wsm_code"=>$wsm_code,
"cgder"=>$supplier['person'],
"cgder_id"=>$supplier['personid'],
"spuCode"=>$data['spuCode'],
"skuCode"=>$data['skuCode'],
"good_name"=>$data['good_name'],
"good_num"=>$data['good_num'],
"good_price"=>$data['sale_price'],
"total_fee"=>round($data['sale_price']*$data['good_num'],2),
"pakge_fee"=>$data['pakge_fee'],
"cert_fee"=>$data['cert_fee'],
"open_fee"=>$data['open_fee'],
"teach_fee"=>$data['cost_fee'],
"mark_fee"=>$data['mark_fee'],
"demo_fee"=>$data['demo_fee'],
#"weight"=>$data['weight'],
"diff_weight"=>"0",
"diff_fee"=>"0",
"gold_price"=>"0",
"supplierNo"=>$data['supplierNo'],
"supplier_name"=>$supplier['name'],
"companyNo"=>$data['companyNo'],
"send_status"=>1,
"send_num"=>0,
"wsend_num"=>$data['good_num'],
"remark"=>"",
"status"=>0,//0初始化
"lasttime"=>date("Y-m-d H:i:s"),
"is_del"=>0,
"order_type"=>$data['order_type'],
"good_type"=>$data['good_type'],
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$up =Db::name("purchease_order")->insert($cg,true);
if($up){
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $cg['cgdNo'],//销售单code
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CGD", $cg['status'], $cg);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CGD',
"order_code" => $cg['cgdNo'],//销售单code
"order_id" => $up,
"order_status" => $cg['status']
]);
$rela=[
"orderCode"=>$data['orderCode'],
"cgdNo"=>$cgdCode,
"spuCode"=>$data['spuCode'],
"good_num"=>$data['good_num'],
"wsend_num"=>$data['good_num'],
"send_num"=>0,
"wait_num"=>0,
"status"=>1,
"source"=>2
];
$re =Db::name("order_num")->save($rela);
if($re==false){
return false;
}else{
$stokc =Db::name("good_stock")->where(['spuCode'=>$data['spuCode'],"wsm_code"=>$wsm_code,
"is_del"=>0])->find();
if($stokc==false){
$stokc=[
"spuCode"=>$data['spuCode'],
"wsm_code"=>$wsm_code,
"wait_in_stock"=>0,
"wait_out_stock"=>0,
"usable_stock"=>0,
"intra_stock"=>0,
"total_stock"=>0,
"status"=>1,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$stoc= Db::name("good_stock")->save($stokc);
if($stoc==false){
return false;
}
}
return true;
}
}else{
return false;
}
}
public function addAddr(){
$orderCode = isset($this->post['orderCode'])&&$this->post['orderCode']!=""? trim($this->post['orderCode']):"";
$etid = Db::name("sale")->where(["orderCode" => $orderCode, "is_del" => 0])->find();
if (empty($etid)) {
return error_show(1002, "未找到数据");
}
$arrtime = isset($this->post['arrtime'])&&$this->post['arrtime']!="" ?$this->post['arrtime']:"";
if($arrtime==""){
return error_show(1004,"参数arrtime不能为空");
}
$token = isset($this->post['token']) && $this->post['token'] !=="" ?trim($this->post['token']):"";
$apply_id =GetUserInfo($token);
if(empty($apply_id)||$apply_id['code']!=0){
return error_show(1002,"申请人数据不存在");
}
$rm= isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri= isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
$addrlist = isset($this->post['addrlist']) && $this->post['addrlist'] !=="" ?$this->post['addrlist']:"";
if($addrlist=="" || empty($addrlist) ||!is_array($addrlist)){
return error_show(1004,"参数addrlist不能为空");
}
Db::startTrans();
try{
foreach ($addrlist as $value){
$temp=[];
$addrs=[];
if($value['addr_code']!==''&&is_array($value['addr_code'])){
$addrs['provice_code'] = $value['addr_code'][0];
$addrs['city_code'] = $value['addr_code'][1];
$addrs['area_code'] = $value['addr_code'][2];
$addr = json_encode($addrs);
}else{
$addr = isset($value['addr_code'])?$value['addr_code']:'';
}
$temp['orderCode']=$orderCode;
$temp['contactor']=$value['contactor'];
$temp['mobile'] = $value['mobile'];
$temp['addr'] = $value['addr'];
$temp['addr_code']=$addr;
$temp['customer_code'] =$etid['customer_code'];
$temp['receipt_quantity']=$value['receipt_quantity'];
$temp['post_fee'] =0;
$temp['is_del'] =0;
$temp['addtime'] =date("Y-m-d H:i:s");
$temp['updatetime'] =date("Y-m-d H:i:s");
$temp['arrive_time']=$arrtime;
$vmp = Db::name('order_addr')->insert($temp,true);
if($vmp>0){
$order =Db::name("order_num")->where(["orderCode"=>$orderCode,"status"=>1])->where([["wsend_num",">=",0]])
->select()->toArray();
if(empty($order)){
return error_show(1004,"未找到可以发货得采购单数据");
}
$num = $value['receipt_quantity'];
$orsend=[];
foreach ($order as $val){
$outCode=makeNo("DF");
$tep=[];
$ornum=0;
if($val['wsend_num']>=$num){
$val['wsend_num']-=$num;
$val['send_num']+=$num;
$ornum =$num;
$num=0;
}else{
$num-=$val['wsend_num'];
$val['send_num']+=$val['wsend_num'];
$ornum =$val['wsend_num'];
$val['wsend_num']=0;
}
$or =Db::name("order_num")->save($val);
if($or==false){
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
$tep=[
"cgdNo"=>$val['cgdNo'],
"outCode"=>$outCode,
"send_num"=>$ornum,
"status"=>1,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$sen=Db::name("order_send")->save($tep);
if($sen==false){
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
$cgdinfo =Db::name("purchease_order")->where(["cgdNo"=>$val['cgdNo']])->find();
if($cgdinfo==false){
Db::rollback();
return error_show(1002,"未匹配到采购数据");
}
$out=[
"orderCode"=>$orderCode,
"outCode"=>$outCode,
"apply_id"=>$rm,
"apply_name"=>$ri,
"addrid"=>$vmp,
"post_name"=>"",
"post_code"=>"",
"post_fee"=>0,
"sendtime"=>date("Y-m-d H:i:s"),
"send_num"=>$ornum,
"check_num"=>0,
"error_num"=>1,
"wsm_code"=>$cgdinfo['wsm_code'],
"order_type"=>$etid['order_type'],
"status"=>0,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$ou =Db::name("order_out")->insert($out);
if($ou==false){
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}else{
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $outCode,//出库单号
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKD", 0, $out);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CKD',
"order_code" => $outCode,//出库单号
"order_id" => 0,
"order_status" => 0
]);
}
//维护商品所在仓库的库存 --- start
$temp = Db::name('good_stock')
->field('id,usable_stock,wait_out_stock')
->where(['spuCode' => $val['spuCode'], 'wsm_code' => $cgdinfo['wsm_code']])
->find();
if ($temp == false) {
Db::rollback();
return error_show(1004, '库存不足');
}
if (($temp['usable_stock'] - $ornum) < 0) {
Db::rollback();
return error_show(1004, '库存不足');
}
$up =Db::name('good_stock')
->where('id', $temp['id'])
->update([
'usable_stock' => $temp['usable_stock'] - $ornum,
'wait_out_stock' => $temp['wait_out_stock'] + $ornum,
'updatetime' => date('Y-m-d H:i:s'),
]);
if($up==false){
Db::rollback();
return error_show(1004, '库存更新失败');
}
//维护商品所在仓库的库存 --- end
if($num==0){
break;
}
}
}else{
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
}
Db::commit();
return app_show(0,"发货地址添加完成");
}catch(\Exception $e){
Db::rollback();
return error_show(1002,$e->getMessage());
}
}
public function consultOrder(){
$bidNo =isset($this->post['bidNo'])&&$this->post['bidNo']!="" ? trim($this->post['bidNo']):"";
if($bidNo==""){
return error_show(1003,"参数bidNo不能为空");
}
$zxinfo = Db::name("consult_bids")->where(["bidNo"=>$bidNo,"is_del"=>0])->find();
if($zxinfo==false){
return error_show(1003,"未找到咨询单商品信息");
}
if($zxinfo['status']!=6){
return error_show(1003,"咨询单状态有误无法转单");
}
$zx =Db::name("consult_info")->where(["infoNo"=>$zxinfo['infoNo'],"is_del"=>0])->find();
if($zx==false){
return error_show(1003,"未找到咨询单信息");
}
if($zx['status']!=4){
return error_show(1003,"咨询单状态有误无法转单");
}
$zxorder =Db::name("consult_order")->where(["zxNo"=>$zx["zxNo"],"is_del"=>0])->find();
if($zxorder==false){
return error_show(1003,"未找到咨询单信息");
}
$good_num =isset($this->post['good_num'])&&$this->post['good_num']!="" ? intval($this->post['good_num']):"";
if($good_num===""){
return error_show(1003,"参数 good_num 不能为空");
}
$sale_price = isset($this->post['sale_price']) && $this->post['sale_price'] != "" ? floatval($this->post['sale_price']) : "";
if ($sale_price === "") {
return error_show(1003, "参数 sale_price 销售单价 不能为空");
}
if ($sale_price < $zxinfo['sale_price']) {
return error_show(1003, "修改的销售单价不能低于原来的销售单价");
}
$sendtype = isset($this->post['sendtype'])&&$this->post['sendtype']!="" ? intval($this->post['sendtype']):"";
if($sendtype==""){
return error_show(1003,"参数sendtype不能为空");
}
$remark = isset($this->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']):"";
$orderCode = makeNo("QR");
$spuCode = $zxinfo['spuCode'];
$skuCode = "";
$is_stock=0;
$cgd=[
"supplierNo"=>$zxinfo['supplierNo'],
"companyNo"=>$zxorder['companyNo'],
"spuCode"=>$spuCode,
"skuCode"=>$skuCode,
"orderCode"=>$orderCode,
"good_name"=>$zxinfo['good_name'],
"sale_price"=>$zxinfo['total_fee'],
"total_fee"=>round($zxinfo['total_fee']* $good_num, 2),
"pakge_fee"=>$zxinfo['pakge_fee'],
"cert_fee"=>$zxinfo['cert_fee'],
"open_fee"=>$zxinfo['open_fee'],
"cost_fee"=>$zxinfo['cost_fee'],
"mark_fee"=>$zxinfo['mark_fee'],
"demo_fee"=>$zxinfo['demo_fee'],
"good_num"=>$good_num,
"createrid"=>$zxinfo['createrid'],
"creater"=>$zxinfo['creater'],
"good_type"=>1,
"is_diff"=>$zxinfo['is_diff'],
"order_type"=>3,
'send_way'=>$zxinfo['send_way']
];
$token=isset($this->post['token'])&&$this->post['token']!=""? trim($this->post['token']):"";
if($token==""){
return error_show(102, "参数token不能为空");
}
$apply_id = GetUserInfo($token);
if (empty($apply_id) || $apply_id['code'] != 0) {
return error_show(102, "申请人数据不存在");
}
$rm = isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri = isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
$va = isset($this->post['order_addr']) && $this->post['order_addr'] !== "" ? $this->post['order_addr'] : "";
$send_num=0;
if($sendtype==1){
if ($va == "") {
return error_show(1002, "参数order_addr不能为空");
}
$send_num = array_sum(array_column($va,"receipt_quantity"));
}
$arrtime=isset($this->post['arrtime'])&&$this->post['arrtime']!="" ?$this->post['arrtime']:"";
if($arrtime==""){
return error_show(1002, "参数arrtime不能为空");
}
//新加字段
$platform_order=isset($this->post['platform_order'])&&$this->post['platform_order']!="" ?$this->post['platform_order']:"";
$workNo=isset($this->post['workNo'])&&$this->post['workNo']!="" ?$this->post['workNo']:"";
Db::startTrans();
try{
$data=[
"orderCode"=>$orderCode,
"good_code"=>$spuCode,
"skuCode"=>$skuCode,
"customer_code"=>$zxorder['khNo'],
"good_name"=>isset($zxinfo['good_name'])&&$zxinfo['good_name']!==''?$zxinfo['good_name']:'',
"good_num"=>$good_num,
"cat_id"=>$zxinfo['cat_id'],
"apply_id"=>$rm,
"apply_name"=>$ri,
"origin_price"=>$zxinfo['total_fee'],
"sale_price" => $sale_price,//销售单价支持修改
"post_fee"=>0,
"status"=>$send_num == 0 ? 3 : ($good_num==$send_num ? 5 : 4),
"send_num"=>$send_num,
"wsend_num"=>$good_num-$send_num,
"send_status"=>$good_num==$send_num? 3 :($send_num==0?1 :2) ,
"good_type"=>1,
"send_type"=>$sendtype,
"supplierNo"=>$zxorder['companyNo'],
"is_del"=>0,
"zxNo"=>$bidNo,
"platform_order"=>$platform_order,
"platform_id"=>0,
"remark"=>$remark,
"arrive_time"=>$arrtime,
"is_stock"=>0,
"is_activity"=>0,
"proof_id"=>0,
"order_type"=>3,
'good_weight'=>$zxinfo['good_weight'],
'gold_price'=>$zxinfo['total_fee'],
'cost_price'=>$zxinfo['sale_cost_fee'],
'diff_weight'=>0,
'diff_fee'=>0,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s"),
'total_price' => round($sale_price * $good_num, 2),
'workNo'=>$workNo,
];
$datainfo = Db::name('sale')->insert($data, true);
if($datainfo>0){
$old_zx_status = $zx['status'];
$zx['status']=5;
$zx['updatetime']=date("Y-m-d H:i:s");
$sa=Db::name("consult_info")->save($zx);
if($sa==false){
Db::rollback();
return error_show(1002,"咨询单修改失败");
}else{
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $zx['infoNo'],//咨询单详情编号
"status" => $old_zx_status,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "status"//新建create，编辑edit，更改状态status
], "ZXD", 5, $zx);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'ZXD',
"order_code" => $zx['infoNo'],//咨询单详情编号
"order_id" => $zx['id'],
"order_status" => 5
]);
}
$bol=$this->createCgd($cgd);
if($bol==false){
Db::rollback();
return error_show(1002,"咨询订单创建失败");
}
$limt=[
"spuCode"=>$zxinfo['spuCode'],
"good_name"=>$zxinfo['good_name'],
"brand_id"=>$zxinfo['brand_id'],
"good_unit"=>$zxinfo['unit_id'],
"cat_id"=>$zxinfo['cat_id'],
"good_type"=>0,
"moq"=>1,
"customized"=>$zxinfo['work_day'],
"tax"=>$zxinfo['tax'],
"supplierNo"=>$zxinfo["supplierNo"],
"is_auth"=>0,
"craft_desc"=>$zxinfo['good_name'],
"good_remark"=>"",
"platform_id"=>$zxorder['platform_id'],
"good_img"=>$zxinfo['good_img'],
"good_thumb_img"=>"",
"good_info_img"=>"",
"specinfo"=>$zxinfo['specinfo'],
"work_day"=>$zxinfo['work_day'],
"noble_metal"=>$zxinfo['metal_id'],
"is_gold_price"=>$zxinfo['is_gold_price'],
"config"=>$zxinfo['config'],
"other_config"=>$zxinfo['other_config'],
"weight"=>$zxinfo['weight'],
"good_weight"=>$zxinfo['good_weight'],
"is_diff"=>$zxinfo['is_diff'],
"supply_area"=>$zxinfo['supply_area'],
"pay_way"=>$zxinfo['pay_way'],
"send_way"=>$zxinfo['send_way'],
"status"=>1,
"is_del"=>0,
"createrid"=>$zxinfo['createrid'],
"creater"=>$zxinfo['creater'],
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$good = Db::name("good_zixun")->insert($limt);
if(!$good){
Db::rollback();
return error_show(1006,"咨询商品录入失败");
}
if(!empty($va)){
$order =Db::name("order_num")->where(["orderCode"=>$orderCode,"status"=>1])->where([["wsend_num",">=",0]])
->find();
if($order==false){
Db::rollback();
return error_show(1006,"采购单关联数据未找到");
}
foreach ($va as $value){
$temp=[];
$addrs=[];
if($value['addr_code']!==''&&is_array($value['addr_code'])){
$addrs['provice_code'] = $value['addr_code'][0];
$addrs['city_code'] = $value['addr_code'][1];
$addrs['area_code'] = $value['addr_code'][2];
$addr = json_encode($addrs);
}else{
$addr = isset($value['addr_code'])?$value['addr_code']:'';
}
$temp['orderCode']=$orderCode;
$temp['contactor']=$value['contactor'];
$temp['mobile'] = $value['mobile'];
$temp['addr'] = $value['addr'];
$temp['addr_code']=$addr;
$temp['customer_code'] =$zxorder['khNo'];
$temp['receipt_quantity']=$value['receipt_quantity'];
$temp['post_fee'] =0;
$temp['is_del'] =0;
$temp['addtime'] =date("Y-m-d H:i:s");
$temp['updatetime'] =date("Y-m-d H:i:s");
$temp['arrive_time']=$arrtime;
$vmp = Db::name('order_addr')->insert($temp,true);
if($vmp>0){
$outCode=makeNo("DF");
$out=[
"orderCode"=>$orderCode,
"outCode"=>$outCode,
"apply_id"=>$rm,
"apply_name"=>$ri,
"addrid"=>$vmp,
"post_name"=>"",
"post_code"=>"",
"post_fee"=>0,
"sendtime"=>date("Y-m-d H:i:s"),
"send_num"=>$value['receipt_quantity'],
"check_num"=>0,
"error_num"=>0,
"wsm_code"=>"",
"order_type"=>3,
"status"=>0,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$ou =Db::name("order_out")->insert($out);
if($ou==false){
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}else{
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $outCode,//出库单号
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKD", 0, $out);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CKD',
"order_code" => $outCode,//出库单号
"order_id" => 0,
"order_status" => 0
]);
}
$order['send_num']+=$value['receipt_quantity'];
$order['wsend_num']-=$value['receipt_quantity'];
if($order['wsend_num']<0){
Db::rollback();
return error_show(1002,"发货数量已超出总数");
}
$ups = Db::name("order_num")->save($order);
if($ups){
$tep=[
"cgdNo"=>$order['cgdNo'],
"outCode"=>$outCode,
"send_num"=>$value['receipt_quantity'],
"status"=>1,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$sen=Db::name("order_send")->save($tep);
if($sen==false){
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
}
}else{
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
}
}
Db::commit();
return error_show(0,"咨询订单创建成功",["order_code"=>$orderCode]);
}
Db::rollback();
return error_show(1002,"咨询订单创建失败");
}catch(\Exception $e){
Db::rollback();
return error_show(1003,$e->getMessage());
}
}
/**
* @return \think\response\Json|void
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function projectCreate(){
$planNo =isset($this->post['planNo'])&&$this->post['planNo']!=""?trim($this->post['planNo']):"";
if($planNo==""){
return error_show(1004,"参数planNo不能为空");
}
$plan =Db::name("project_plan")->where(["planNo"=>$planNo,"is_del"=>0])->find();
if($plan==false){
return error_show(1004,"未找到方案信息");
}
$feedbackid = Db::name("project_plan_rela")->where(["planNo"=>$planNo,"is_del"=>0])->column("feedback_id,sale_price,sale_num");
if($feedbackid==false){
return error_show(1004,"未找到方案反馈信息");
}
$project = Db::name("project")->where(["projectNo"=>$plan['projectNo'],"is_del"=>0])->find();
if($project==false){
return error_show(1004,"未找到方案信息");
}
$arrtime=isset($this->post['arrtime'])&&$this->post['arrtime']!="" ?$this->post['arrtime']:"";
if($arrtime==""){
return error_show(1002, "参数arrtime不能为空");
}
$planinfo =isset($this->post['planinfo'])&&!empty($this->post['planinfo']) ?$this->post['planinfo']:"";
if($planinfo==""){
return error_show(1002, "参数planinfo不能为空");
}
$token=isset($this->post['token'])&&$this->post['token']!=""? trim($this->post['token']):"";
if($token==""){
return error_show(102, "参数token不能为空");
}
$apply_id = GetUserInfo($token);
if (empty($apply_id) || $apply_id['code'] != 0) {
return error_show(102, "申请人数据不存在");
}
$rm = isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri = isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
Db::startTrans();
try {
$feedid = array_column($feedbackid,"feedback_id");
foreach ($planinfo as $value){
$good=[];
$feedback = Db::name("project_feedback")->where(["id"=>$value['feedback_id'],"projectNo"=>$plan['projectNo'],
"is_del"=>0])->find();
if($feedback==false){
Db::rollback();
return error_show(1002, "反馈数据未找到");
}
$key =array_search($feedback['id'],$feedid);
$price = $feedbackid[$key];
$good['spuCode'] = $feedback['spuCode'];
$good['skuCode'] = $feedback['skuCode'];
$good['good_num'] = $price['sale_num'];
$good['sendtype'] = $value['sendtype'];
$good['sale_price']=$price['sale_price'];
$good['origin_price']=$feedback['origin_price'];
$good['companyNo']=$project['companyNo'];
$good['customerNo']=$project['khNo'];
$good['pgNo']=$feedback['pgNo'];
$good['arrtime']=$arrtime;
$good['rm']=$rm;
$good['ri']=$ri;
$good['send_num']=0;
if($value['sendtype']==1){
if(!isset($value['addrlist'])||empty($value['addrlist'])){
Db::rollback();
return error_show(1002, "订单地址不能为空");
}
$good['addrlist'] = $value['addrlist'];
$good['send_num'] = array_sum(array_column($value['addrlist'],"receipt_quantity"));
}
if($feedback['data_source']==1){
$feed=$this->project_good($good);
if($feed !==true){
Db::rollback();
switch ($feed){
case 1:
$msg='库存不足';
break;
case 2:
$msg='库存更新失败';
break;
case 3:
$msg='关联采购失败';
break;
case 4:
$msg='商品信息未找到';
break;
default:
$msg='咨询订单生成失败';
}
return error_show(1002,$msg);
}
}else{
$feed=$this->project_zx($good);
if($feed==false){
Db::rollback();
return error_show(1002, "咨询订单生成失败");
}
}
$feedback['status']=2;
$feedback['updatetime']=date("Y-m-d H:i:s");
$fed =Db::name("project_feedback")->save($feedback);
if($fed==false){
Db::rollback();
return error_show(1002, "项目订单生成失败");
}
}
$old_plan_status = $plan['status'];
$plan['status']=2;
$plan['updatetime']=date("Y-m-d H:i:s");
$in =Db::name("project_plan")->save($plan);
if($in==false){
Db::rollback();
return error_show(1002, "项目订单生成失败");
}else{
//修改状态，添加待办，只记录动作
ActionLog::logAdd($this->post['token'], [
"order_code" => $planNo,//编码
"status" => $old_plan_status,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "edit"//新建create，编辑edit，更改状态status
], "PRO", 2, $plan);
}
$old_project_status = $project["status"];
$project["status"]=6;
$project['updatetime']=date("Y-m-d H:i:s");
$pr =Db::name("project")->save($project);
if($pr==false){
Db::rollback();
return error_show(1002, "项目订单生成失败");
}else{
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $project['projectNo'],//项目编码
"status" => $old_project_status,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "status"//新建create，编辑edit，更改状态status
], "PRO", 6, $project);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'PRO',
"order_code" => $project['projectNo'],
"order_id" => $project['id'],
"order_status" => 6
]);
}
Db::commit();
return app_show(0, "咨询订单生成成功");
}catch (\Exception $e){
Db::rollback();
return error_show(1002, $e->getMessage());
}
}
/**
* @param $data
* @return false
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*
*/
public function project_zx($data){
$goodinfo = Db::name("consult_bids")->where(["spuCode"=>$data['spuCode'],"is_del"=>0])->find();
if($goodinfo==false){
return false;
}
$orderCode=makeNo("QR");
$cgd=[
"supplierNo"=>$goodinfo['supplierNo'],
"companyNo"=>$data['companyNo'],
"spuCode"=>$data['spuCode'],
"skuCode"=>"",
"orderCode"=>$orderCode,
"good_name"=>$goodinfo['good_name'],
"sale_price"=>$goodinfo['total_fee'],
"total_fee"=>round($goodinfo['total_fee']*$data['good_num'],2),
"pakge_fee"=>$goodinfo['pakge_fee'],
"cert_fee"=>$goodinfo['cert_fee'],
"open_fee"=>$goodinfo['open_fee'],
"cost_fee"=>$goodinfo['cost_fee'],
"mark_fee"=>$goodinfo['mark_fee'],
"demo_fee"=>$goodinfo['demo_fee'],
"good_num"=>$data['good_num'],
"createrid"=>$goodinfo['createrid'],
"creater"=>$goodinfo['creater'],
"good_type"=>1,
"order_type"=>4,
"send_way"=>$goodinfo['send_way'],
];
$datas=[
"orderCode"=>$orderCode,
"good_code"=>$data['spuCode'],
"skuCode"=>"",
"customer_code"=>$data['customerNo'],
"good_name"=>isset($goodinfo['good_name'])&&$goodinfo['good_name']!==''?$goodinfo['good_name']:'',
"good_num"=>$data['good_num'],
"cat_id"=>$goodinfo['cat_id'],
"apply_id"=>$data['rm'],
"apply_name"=>$data['ri'],
"origin_price"=>$goodinfo['total_fee'],
"sale_price"=>$data['sale_price'],
"post_fee"=>0,
"status"=>$data['good_num']==$data['send_num']? 5 :($data['send_num']==0?3 :4),
"send_num"=>$data['send_num'],
"wsend_num"=>$data['good_num']-$data['send_num'],
"send_status"=>$data['good_num']==$data['send_num']? 3 :($data['send_num']==0?1 :2),
"good_type"=>1,
"send_type"=>$data['sendtype'],
"supplierNo"=>$data['companyNo'],
"is_del"=>0,
"zxNo"=>$data["pgNo"],
"platform_order"=>"",
"platform_id"=>0,
"remark"=>"",
"is_stock"=>0,
"is_activity"=>0,
"proof_id"=>0,
"order_type"=>4,
'good_weight'=>$goodinfo['good_weight'],
'gold_price'=>$goodinfo['sale_price'],
'cost_price'=>$goodinfo['sale_cost_fee'],
'diff_weight'=>0,
'diff_fee'=>0,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s"),
'total_price'=>round($data['sale_price']*$data['good_num'],2),
];
$datainfo = Db::name('sale')->insert($datas, true);
if($datainfo>0){
$bol = $this->createCgd($cgd);
if ($bol == false) {
return false;
}
$goodinfo['status']=6;
$goodinfo['updatetime']=date("Y-m-d H:i:s");
$sa=Db::name("consult_bids")->save($goodinfo);
if($sa==false){
return false;
}
$zxorder =Db::name("consult_order")->where(["zxNo"=>$goodinfo["zxNo"],"is_del"=>0])->find();
if($zxorder==false){
return false;
}
$limt=[
"spuCode"=>$goodinfo['spuCode'],
"good_name"=>$goodinfo['good_name'],
"brand_id"=>$goodinfo['brand_id'],
"good_unit"=>$goodinfo['unit_id'],
"cat_id"=>$goodinfo['cat_id'],
"good_type"=>0,
"moq"=>1,
"customized"=>$goodinfo['work_day'],
"tax"=>$goodinfo['tax'],
"supplierNo"=>$goodinfo["supplierNo"],
"is_auth"=>0,
"craft_desc"=>$goodinfo['good_name'],
"good_remark"=>"",
"good_img"=>$goodinfo['good_img'],
"good_thumb_img"=>"",
"good_info_img"=>"",
"platform_id"=>$zxorder['platform_id'],
"specinfo"=>$goodinfo['specinfo'],
"work_day"=>$goodinfo['work_day'],
"noble_metal"=>$goodinfo['metal_id'],
"is_gold_price"=>$goodinfo['is_gold_price'],
"good_weight"=>$goodinfo['good_weight'],
"config"=>$goodinfo['config'],
"other_config"=>$goodinfo['other_config'],
"weight"=>$goodinfo['weight'],
"is_diff"=>$goodinfo['is_diff'],
"supply_area"=>$goodinfo['supply_area'],
"pay_way"=>$goodinfo['pay_way'],
"send_way"=>$goodinfo['send_way'],
"status"=>1,
"is_del"=>0,
"createrid"=>$goodinfo['createrid'],
"creater"=>$goodinfo['creater'],
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$good = Db::name("good_zixun")->insert($limt);
if(!$good){
return false;
}
if ($data['sendtype']==1&&!empty($data['addrlist'])) {
$order = Db::name("order_num")->where(["orderCode" => $orderCode, "status" => 1])->where([["wsend_num", ">=", 0]])
->find();
if ($order == false) {
return false;
}
foreach ($data['addrlist'] as $value) {
$temp = [];
$addrs = [];
if ($value['addr_code'] !== '' && is_array($value['addr_code'])) {
$addrs['provice_code'] = $value['addr_code'][0];
$addrs['city_code'] = $value['addr_code'][1];
$addrs['area_code'] = $value['addr_code'][2];
$addr = json_encode($addrs);
} else {
$addr = isset($value['addr_code']) ? $value['addr_code'] : '';
}
$temp['orderCode'] = $orderCode;
$temp['contactor'] = $value['contactor'];
$temp['mobile'] = $value['mobile'];
$temp['addr'] = $value['addr'];
$temp['addr_code'] = $addr;
$temp['customer_code'] = $data['companyNo'];
$temp['receipt_quantity'] = $value['receipt_quantity'];
$temp['post_fee'] = 0;
$temp['is_del'] = 0;
$temp['addtime'] = date("Y-m-d H:i:s");
$temp['updatetime'] = date("Y-m-d H:i:s");
$temp['arrive_time'] = $data['arrtime'];
$vmp = Db::name('order_addr')->insert($temp, true);
if ($vmp > 0) {
// $outCode = makeNo("CK");
// $out = [
// "orderCode" => $orderCode,
// "outCode" => $outCode,
// "apply_id"=>$data['rm'],
// "apply_name"=>$data['ri'],
// "addrid" => $vmp,
// "post_name" => "",
// "post_code" => "",
// "post_fee" => 0,
// "sendtime" => date("Y-m-d H:i:s"),
// "send_num" => $value['receipt_quantity'],
// "check_num" => 0,
// "error_num" => 0,
// "wsm_code" => "",
// "order_type" => 4,
// "status" => 0,
// "addtime" => date("Y-m-d H:i:s"),
// "updatetime" => date("Y-m-d H:i:s")
// ];
// $ou = Db::name("order_out")->insert($out);
// if ($ou == false) {
// return false;
// }
// $order['send_num'] += $value['receipt_quantity'];
// $order['wsend_num'] -= $value['receipt_quantity'];
// if ($order['wsend_num'] < 0) {
// return false;
// }
// $ups = Db::name("order_num")->save($order);
// if ($ups) {
// $tep = [
// "cgdNo" => $order['cgdNo'],
// "outCode" => $outCode,
// "send_num" => $value['receipt_quantity'],
// "status" => 1,
// "addtime" => date("Y-m-d H:i:s"),
// "updatetime" => date("Y-m-d H:i:s")
// ];
// $sen = Db::name("order_send")->save($tep);
// if ($sen == false) {
// return false;
// }
// }
} else {
return false;
}
}
}
}
return true;
}
/**
* @param $data
* @return bool
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function project_good($data){
$good=Db::name('good')
->alias("a")
->leftJoin("good_platform b","a.spuCode=b.spuCode")
->where(["b.skuCode"=>$data['skuCode'],"a.is_del"=>0,"b.is_del"=>0])
->find();
if($good==false){
return 4; //商品信息未找到
}
$goodlass = Db::name("good_ladder")->where(["skuCode"=>$data['skuCode'],"is_del"=>0,"status"=>1])->where([["min_num",
"<=",$data['good_num']]])->order("min_num desc")->find();
if($goodlass==false){
return 4;//商品信息未找到
}
$sale_price = $goodlass['sale_price'];
$origin = Db::name("good_nake")->where([["spuCode","=",$data['spuCode']],["min_num","<=",$data['good_num']],
["is_del","=",0]])->order("min_num desc")->find();
if($origin==false){
return 4;//商品信息未找到
}
$origin_price = $origin['nake_total'];
$orderCode=makeNo("QR");
$datas=[
"orderCode"=>$orderCode,
"good_code"=>$data['spuCode'],
"skuCode"=>$data['skuCode'],
"customer_code"=>$data['customerNo'],
"good_name"=>isset($good['good_name'])&&$good['good_name']!==''?$good['good_name']:'',
"good_num"=>$data['good_num'],
"cat_id"=>$good['cat_id'],
"apply_id"=>$data['rm'],
"apply_name"=>$data['ri'],
"origin_price"=>$origin_price,
"sale_price"=>$sale_price,
"post_fee"=>0,
"status"=>$data['good_num']==$data['send_num']? 5 :($data['send_num']==0?3 :4),
"send_num"=>$data['send_num'],
"wsend_num"=>$data['good_num']-$data['send_num'],
"send_status"=>$data['good_num']==$data['send_num']? 3 :($data['send_num']==0?1 :2) ,
"good_type"=>1,
"send_type"=>$data['sendtype'],
"supplierNo"=>$data['companyNo'],
"is_del"=>0,
"zxNo"=>$data["pgNo"],
"platform_order"=>"",
"platform_id"=>0,
"remark"=>"",
"is_stock"=>$good['is_stock'],
"is_activity"=>0,
"proof_id"=>0,
"order_type"=>2,
'good_weight'=>$good['weight'],
'gold_price'=>$good['cgd_gold_price'],
'cost_price'=>$good['cost_fee'],
'diff_weight'=>0,
'diff_fee'=>0,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s"),
'total_price'=>round($sale_price*$data['good_num'],2),
];
$datainfo = Db::name('sale')->insert($datas, true);
if($datainfo>0) {
$cgd=[
"supplierNo"=>$good['supplierNo'],
"companyNo"=>$data['companyNo'],
"orderCode"=>$orderCode,
"spuCode"=>$good['spuCode'],
"skuCode"=>$good['skuCode'],
"good_name"=>$good['good_name'],
"sale_price"=>$origin_price,
"total_fee"=>$origin_price*$data['good_num'],
"pakge_fee"=>$origin['package_fee'],
"cert_fee"=>$origin['cert_fee'],
"open_fee"=>$good['open_fee'],
"cost_fee"=>$origin['cost_fee'],
"mark_fee"=>$origin['mark_fee'],
"demo_fee"=>$good['demo_fee'],
"good_num"=>$data['good_num'],
"good_type"=>1,
"createrid"=>$good['createrid'],
"creater"=>$good['creater'],
"order_type"=>$good['is_stock']==1?1:2,
'send_way'=>2
];
if($good['is_stock']==0) {
$bol = $this->createCgd($cgd);
if ($bol == false) {
return 3;//关联采购失败
}
}else{
$stock =Db::name("good_stock")->alias("a")->leftJoin("warehouse_info b","a.wsm_code=b.wsm_code")->where
(["spuCode"=>$good['spuCode'], "a.is_del"=>0,"a.status"=>1,"b.companyNo"=>$data['companyNo']])->field("a.id,a.usable_stock,a.wait_out_stock")->find();
if($stock==false||$stock['usable_stock']<$data['good_num']){
return 1; //库存不足
}
$bol =$this->RelaCgd(['orderCode'=>$orderCode,"good_num"=>$data['good_num'],"spuCode"=>$good['spuCode'],"companyNo"=>$data['companyNo']]);
if($bol==false){
return 3;//关联采购失败
}
if(isset($stock)){
$stck = [
"usable_stock"=>$stock['usable_stock']-$data['good_num'],
"wait_out_stock"=>$stock['wait_out_stock']+$data['good_num'],
"updatetime"=>date("Y-m-d H:i:s")
];
$upad=Db::name("good_stock")->where($stock)->update($stck);
if($upad==false){
return 2; //库存更新失败
}
//商品变动日志表，good_log_code字段存储采购单号
$good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 2,'stock'=>$data['good_num'], "stock_name" => "usable_stock"];
$good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 1,'stock'=>$data['good_num'], "stock_name" => "wait_out_stock"];
GoodLog::LogAdd($this->post['token'],$good_data,"XSQRD");
}
}
if ($data['sendtype']==1&&!empty($data['addrlist'])) {
foreach ($data['addrlist'] as $value) {
$temp = [];
$addrs = [];
if ($value['addr_code'] !== '' && is_array($value['addr_code'])) {
$addrs['provice_code'] = $value['addr_code'][0];
$addrs['city_code'] = $value['addr_code'][1];
$addrs['area_code'] = $value['addr_code'][2];
$addr = json_encode($addrs);
} else {
$addr = isset($value['addr_code']) ? $value['addr_code'] : '';
}
$temp['orderCode'] = $orderCode;
$temp['contactor'] = $value['contactor'];
$temp['mobile'] = $value['mobile'];
$temp['addr'] = $value['addr'];
$temp['addr_code'] = $addr;
$temp['customer_code'] =$data['companyNo'];
$temp['receipt_quantity'] = $value['receipt_quantity'];
$temp['post_fee'] = 0;
$temp['is_del'] = 0;
$temp['addtime'] = date("Y-m-d H:i:s");
$temp['updatetime'] = date("Y-m-d H:i:s");
$temp['arrive_time'] = $data['arrtime'];
$vmp = Db::name('order_addr')->insert($temp, true);
if ($vmp > 0) {
if ($good['is_stock'] == 1) {
$order = Db::name("order_num")->where(["orderCode" => $orderCode, "status" => 1])->where([["wsend_num", ">=", 0]])
->lock(true)->find();
if ($order == false) {
return 3;
}
$num = $value['receipt_quantity'];
$outCode = makeNo("DF");
$order['wsend_num'] -= $num;
$order['send_num'] += $num;
$or = Db::name("order_num")->save($order);
if ($or == false) {
return 3;
}
$tep = [
"cgdNo" => $order['cgdNo'],
"outCode" => $outCode,
"send_num" => $num,
"status" => 1,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$sen = Db::name("order_send")->save($tep);
if ($sen == false) {
return 3;
}
$cgdinfo = Db::name("purchease_order")->where(["cgdNo" => $order['cgdNo']])->find();
if ($cgdinfo == false) {
return 4;
}
$out = [
"orderCode" => $orderCode,
"outCode" => $outCode,
"apply_id" => $data['rm'],
"apply_name" => $data['ri'],
"addrid" => $vmp,
"post_name" => "",
"post_code" => "",
"post_fee" => 0,
"sendtime" => date("Y-m-d H:i:s"),
"send_num" => $num,
"check_num" => 0,
"error_num" => 0,
"wsm_code" => $cgdinfo['wsm_code'],
"order_type" => 1,
"status" => 1,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$ou = Db::name("order_out")->insert($out);
if ($ou == false) {
return 0;
} else {
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $outCode,//出库单号
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKD", 0, $out);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CKD',
"order_code" => $outCode,//出库单号
"order_id" => 0,
"order_status" => 0
]);
}
} else {
return false;
}
}
}
}
}
return true;
}
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[] = ['is_del', "=", 0];
$orderCode = isset($this->post['orderCode']) && $this->post['orderCode'] !== "" ? trim($this->post['orderCode']) : "";
if ($orderCode !== "") {
$where[] = ['orderCode', "like", "%$orderCode%"];
}
$apply_name = isset($this->post['apply_name']) && $this->post['apply_name'] !== "" ? trim($this->post['apply_name'])
: "";
if ($apply_name !== "") {
$where[] = ['apply_name', "like", "%$apply_name%"];
}
$good_name = isset($this->post['good_name']) && $this->post['good_name'] !== "" ? trim($this->post['good_name'])
: "";
if ($good_name !== "") {
$where[] = ['good_name', "like", "%$good_name%"];
}
$good_code = isset($this->post['good_code']) && $this->post['good_code'] !== "" ? trim($this->post['good_code']) : "";
if ($good_code !== "") {
$where[] = ['good_code', "like", "%$good_code%"];
}
$customer_code = isset($this->post['customer_code']) && $this->post['customer_code'] !== "" ? trim($this->post['customer_code']) : "";
if ($customer_code !== "") {
$where[] = ['customer_code', "like", "%$customer_code%"];
}
$supplierNo = isset($this->post['supplierNo']) && $this->post['supplierNo'] !== "" ? trim($this->post['supplierNo']) : "";
if ($supplierNo !== "") {
$where[] = ['supplierNo', "like", "%$supplierNo%"];
}
$ordertype = isset($this->post['order_type']) && $this->post['order_type'] !== "" ? intval($this->post['order_type'])
: "";
if ($ordertype !== "") {
$where[] = ['order_type', "=", $ordertype];
}
$status = isset($this->post['status']) && $this->post['status'] !== "" ? trim($this->post['status']) : "";
if ($status !== "") {
$where[] = ['status', "=", $status];
}
$start = isset($this->post['start']) && $this->post['start'] !== "" ? $this->post['start'] : "";
if ($start != "") {
$where[] = ["addtime", '>=', $start];
}
$end = isset($this->post['end']) && $this->post['end'] !== "" ? $this->post['end'] : "";
if ($end != "") {
$where[] = ["addtime", '<=', $end];
}
$count = Db::name('sale')->where($where)->count();
$total = ceil($count / $size);
$page = $page >= $total ? $total : $page;
$list = Db::name('sale')->where($where)->order("addtime desc")->page($page, $size)->select();
$data = [];
foreach ($list as $value) {
if($value['order_type']==3|| $value['order_type']==4){
$var = Db::name("good_zixun")->where(["spuCode"=>$value['good_code'],"is_del"=>0])->find();
$value["speclist"]=isset($var['specinfo'])&&$var['specinfo']!=""? json_decode($var['specinfo'],true):"";
}else {
$var = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $value['skuCode']])->find();
$spec = Db::name("good_spec")->where(["spuCode"=>$var['spuCode'],"is_del"=>0])->select()->toArray();
$speclist=[];
if(!empty($spec)){
foreach ($spec as $val){
$temp=[];
$temp['id']=$val['id'];
$temp['spuCode']=$val['spuCode'];
$temp['spec_id']=$val['spec_id'];
$temp['spec_value_id']=$val['spec_value_id'];
$sp = Db::name("specs")->where(["id"=>$val['spec_id']])->find();
$temp['spec_name']=isset($sp["spec_name"]) ? $sp["spec_name"]:"";
$spv = Db::name("spec_value")->where(["id"=>$val['spec_value_id']])->find();
$temp['spec_value']=isset($spv["spec_value"]) ? $spv["spec_value"]:"";
$speclist[]=$temp;
}
}
$value["speclist"]=empty($speclist)?[]:$speclist;
}
$value['can'] = isset($var['cat_id']) && $var['cat_id'] != 0 ? made($var['cat_id']) : [];
$value['supplierName'] = '';
if ($value['supplierNo'] != "") {
$supplier = Db::name("business")->where(["companyNo" => $value['supplierNo']])->find();
$value['supplierName'] = isset($supplier['company']) ? $supplier['company'] : "";
}
$value['customerName'] = '';
if ($value['customer_code'] != "") {
$supplier = Db::name("customer_info")->where(["companyNo" => $value['customer_code']])->find();
$value['customerName'] = isset($supplier['companyName']) ? $supplier['companyName'] : "";
}
$value['useage']="";
if($value['use_order']!=0){
$use =Db::name("order_use")->where(["id"=>$value['use_order']])->find();
$value['useage'] = isset($use['order_use']) ?$use['order_use']:"";
}else{
$value['use_order']='';
}
$data[] = $value;
}
return app_show(0, "获取成功", ['list' => $data, 'count' => $count]);
}
public function edit()
{
$token = isset($this->post['token']) && $this->post['token'] !== "" ? trim($this->post['token']) : "";
$id = isset($this->post['id']) && $this->post['id'] !== "" ? trim($this->post['id']) : "";
if ($id == "") {
return error_show(1002, "参数id不能为空");
}
$etid = Db::name("sale")->where(["id" => $id, "is_del" => 0])->find();
if (empty($etid)) {
return error_show(1002, "未找到数据");
}
// $orderCode=isset($this->post['orderCode']) && $this->post['orderCode'] !=="" ? trim($this->post['orderCode']) :"";
// if($orderCode==""){
// return error_show(1002,"销售单code不能为空");
// }
$good_code = isset($this->post['good_code']) && $this->post['good_code'] !== "" ? trim($this->post['good_code']) : "";
if ($good_code == "") {
return error_show(1002, "商品code不能为空");
}
$ct = Db::name('good')->alias('a')->join('good_type b', 'b.good_code=a.good_code', 'left')
->where(['b.type_code' => $good_code])->find();
if ($ct == "") {
return error_show(1002, "未找到商品数据");
}
$customer_code = isset($this->post['customer_code']) && $this->post['customer_code'] !== "" ? trim($this->post['customer_code']) : "";
if ($customer_code == "") {
return error_show(1002, "客户code不能为空");
}
$customer = Db::name("customer_info")->where(["companyNo" => $customer_code])->find();
if ($customer == false) {
return error_show(1004, "未找到客户数据");
}
$supplierNo = $this->post['supplierNo'] && $this->post['supplierNo'] !== "" ? trim($this->post['supplierNo']) : "";
if ($supplierNo == "") {
return error_show(1002, "参数supplierNo不能为空");
}
$supplier = Db::name("supplier")->where(["code" => $supplierNo])->find();
if ($supplier == false) {
return error_show(1004, "未找到平台供应商数据");
}
$apply_id = GetUserInfo($token);
if (empty($apply_id) || $apply_id['code'] != 0) {
return error_show(1002, "申请人数据不存在");
}
$rm = isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri = isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
// $good_name = isset($this->post['good_name']) && $this->post['good_name'] !== "" ? trim
//($this->post['good_name']) : "";
// $good_num = isset($this->post['good_num']) && $this->post['good_num'] !== "" ? intval
//($this->post['good_num']) : "";
// $origin_price = isset($this->post['origin_price']) && $this->post['origin_price'] !== "" ? intval
// ($this->post['origin_price']) : "";
// $sale_price = isset($this->post['sale_price']) && $this->post['sale_price'] !== "" ? trim($this->post['sale_price']) : "";
// $total_price = isset($this->post['total_price']) && $this->post['total_price'] !== "" ? trim($this->post['total_price']) : "";
// $post_fee = isset($this->post['post_fee']) && $this->post['post_fee'] !== "" ? trim($this->post['post_fee']) : "";
// $status = isset($this->post['status']) && $this->post['status'] !== "" ? intval($this->post['status']) : "";
$vr = isset($this->post['order_addr']) && $this->post['order_addr'] !== "" ? $this->post['order_addr'] : "";
if ($vr == "") {
return error_show(1002, "参数order_addr不能为空");
}
$vi = isset($this->post['good_stock']) && $this->post['good_stock'] !== "" ? $this->post['good_stock'] : "";
if ($vi == "") {
return error_show(1002, "参数good_stock不能为空");
}
$good_num = intval(array_sum(array_column($vi, "num")));
Db::startTrans();
try {
$datn = [
"id" => $id,
"good_code" => $good_code,
"customer_code" => $customer_code,
"good_num" => $good_num,
"supplierNo" => $supplierNo,
"apply_id" => $rm,
"apply_name" => $ri,
"is_del" => 0,
"updatetime" => date("Y-m-d H:i:s")
];
$datninfo = Db::name('sale')->where(['id' => $id, 'is_del' => 0])->save($datn);
if ($datninfo > 0) {
$stn = ["order_code"=>$etid['orderCode'],"status"=>$etid['status'],"action_remark"=>'',"action_type"=>"edit"];
ActionLog::logAdd($this->post['token'],$stn,"XSQRD",$etid['status'],$datn);
$order=["order_type"=>'XSQRD',"order_code"=>$etid['orderCode'],"order_id"=>$id,"order_status"=>$etid['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
foreach ($vi as $ion) {
$iten = [];
isset($ion['id']) && $ion['id'] !== "" ? $iten['id'] = $ion['id'] : '';
$iten['orderCode'] = $etid['orderCode'];
$iten['wsm_code'] = $ion['wsm_code'];
$iten['stock_id'] = 0;
$iten['num'] = $ion['num'];
$iten['status'] = 1;
$iten['sale_price'] = $ct['original_price'];
isset($ion['id']) && $ion['id'] !== "" ? '' : $iten['addtime'] = date("Y-m-d H:i:s");
$iten['updatetime'] = date("Y-m-d H:i:s");
$vp = Db::name('sale_info')->save($iten);
if ($vp == false)
{
Db::rollback();
return error_show(1002, "更新失败");
}
}
foreach ($vr as $value) {
$temp = [];
isset($value['id']) && $value['id'] !== "" ? $temp['id'] = $value['id'] : '';
$temp['orderCode'] = $etid['orderCode'];
$temp['contactor'] = $value['contactor'];
$temp['mobile'] = $value['mobile'];
$temp['addr'] = $value['addr'];
$temp['addr_code'] = $value['addr_code'];
$temp['customer_code'] = $customer_code;
$temp['receipt_quantity'] = $value['receipt_quantity'];
$temp['post_fee'] = 0;
$temp['is_del'] = $value['is_del'];
isset($value['id']) && $value['id'] !== "" ? '' : $temp['addtime'] = date("Y-m-d H:i:s");
$temp['updatetime'] = date("Y-m-d H:i:s");
$temp['arrive_time'] = date("Y-m-d H:i:s");
$dat = Db::name('order_addr')->save($temp);
if ($dat == false) {
Db::rollback();
return error_show(1002, "更新失败");
}
}
Db::commit();
return error_show(0, "更新成功");
}
Db::rollback();
return error_show(1002, "更新失败");
} catch (Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage());
}
}
public function info()
{
$id = isset($this->post['id']) && $this->post['id'] !== "" ? intval($this->post['id']) : "";
if ($id == "") {
return error_show(1002, "参数id不能为空");
}
$einfo = Db::name('sale')->where(['id' => $id, 'is_del' => 0])->find();
if (empty($einfo)) {
return error_show(1002, "未找到销售订单数据");
}
if($einfo['order_type']==3|| $einfo['order_type']==4){
$goon = Db::name("good_zixun")->where(["spuCode"=>$einfo['good_code'],"is_del"=>0])->find();
}else {
$goon = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $einfo['skuCode']])->find();
}
if ($goon==false) {
return error_show(1003, "未找到商品数据");
}else{
$goon['exclusive']=isset($goon['is_exclusive'])?makeExcluse($goon['is_exclusive']):"";
$unit =Db::name("unit")->where(["id"=>$goon['good_unit']])->find();
$goon['unit'] = isset($unit['unit'])?$unit['unit']:'';
$spec = Db::name("good_spec")->where(["spuCode"=>$goon['spuCode'],"is_del"=>0])->select()->toArray();
$speclist=[];
if(!empty($spec)){
foreach ($spec as $value){
$temp=[];
$temp['id']=$value['id'];
$temp['spuCode']=$value['spuCode'];
$temp['spec_id']=$value['spec_id'];
$temp['spec_value_id']=$value['spec_value_id'];
$temp['is_del']=$value['is_del'];
$sp = Db::name("specs")->where(["id"=>$value['spec_id']])->find();
$temp['spec_name']=isset($sp["spec_name"]) ? $sp["spec_name"]:"";
$spv = Db::name("spec_value")->where(["id"=>$value['spec_value_id']])->find();
$temp['spec_value']=isset($spv["spec_value"]) ? $spv["spec_value"]:"";
$speclist[]=$temp;
}
}
$goon["speclist"]=empty($speclist)?[]:$speclist;
$proof =Db::name("good_proof")->where(["spuCode"=>$goon['spuCode'],"is_del"=>0])->order("updatetime desc")->field("id,proof_type,proof_url")->find();
$goon['proof'] = isset($proof)&&$proof!=false? $proof:[];
$goon['origin_place_cn']="";
$goon['delivery_place_cn']="";
if(isset($goon['delivery_place'])&&$goon['delivery_place']!==""){
$place = ["provice_code"=>"","city_code"=>"","area_code"=>""];
list($place['provice_code'],$place['city_code'],$place['area_code'])=explode(",",$goon['delivery_place']);
$goon['delivery_place_cn']=GetAddr(json_encode($place));
}
if(isset($goon['delivery_place'])&&$goon['origin_place']!==""){
$place = ["provice_code"=>"","city_code"=>"","area_code"=>""];
list($place['provice_code'],$place['city_code'],$place['area_code'])=explode(",",$goon['origin_place']);
$goon['origin_place_cn']=GetAddr(json_encode($place));
}
if($goon['brand_id']!=0){
$brand=Db::name("brand")->where(["id"=>$goon['brand_id']])->find();
$goon["brand_name"]=isset($brand['brand_name'])?$brand['brand_name']:"";
}else{
$goon["brand_name"]="";
$goon["brand_id"]="";
}
$supplier = Db::name("supplier")->where(["code"=>$goon['supplierNo']])->find();
$goon['supplierName'] = isset($supplier['name'])?$supplier['name']:"";
$goon['noble_name']=isset($goon['noble_metal'])&&$goon['noble_metal']!=0?$this->noble[$goon['noble_metal']] :"";
if(isset($goon['companyNo'])&&$goon['companyNo']!=""){
$company = Db::name("business")->where(["companyNo"=>$goon['companyNo']])->find();
}
$goon['company'] = isset($company['company'])?$company['company']:"";
}
$int = isset($goon['cat_id']) && $goon['cat_id'] != 0 ? made($goon['cat_id']) : [];
$in = Db::name('customer_info')->where(['companyNo' => $einfo['customer_code']])->field('companyName')->find();
$einfo['supplierName'] = '';
if ($einfo['supplierNo'] != "") {
$supplier = Db::name("business")->where(["companyNo" => $einfo['supplierNo']])->find();
$einfo['supplierName'] = isset($supplier['company']) ? $supplier['company'] : "";
}
$fo = Db::name('order_addr')->alias("a")->leftJoin("order_out b","a.id=b.addrid")
->where(['a.orderCode' => $einfo['orderCode'], 'a.is_del' => 0])->field("a.*,b.post_name,b.post_code,
b.post_fee,b.sendtime,b.send_num,b.check_num,b.error_num,b.wsm_code,b.order_type,b.status as send_status,b.outCode")
->select();
$addrs = [];
if (!empty($fo)) {
foreach ($fo as $value) {
$value['addr_info'] = "";
$value['send_num'] = 0;
if ($value['addr_code'] != "") {
$place = ["provice_code"=>"","city_code"=>"","area_code"=>""];
list($place['provice_code'],$place['city_code'],$place['area_code'])=explode(",",$value['addr_code']);
$addr = GetAddr(json_encode($place));
$value['addr_info'] = $addr;
}
$value['wsm_name']="";
if(isset($value['wsm_code'])&&$value['wsm_code']!=""){
$wsmcode = Db::name("warehouse_info")->where(["wsm_code" => $value['wsm_code']])->find();
$value['wsm_name'] =isset($wsmcode['name'])?$wsmcode['name']:"";
}
$addrs[] = $value;
}
}
$einfo['useage']="";
if($einfo['use_order']!=0){
$use =Db::name("order_use")->where(["id"=>$einfo['use_order']])->find();
$einfo['useage'] = isset($use['order_use']) ?$use['order_use']:"";
}else{
$einfo['use_order']='';
}
$einfo['platform_name']='';
if($einfo['platform_id']!=0){
$plat=Db::name("platform")->where(['id'=>$einfo['platform_id']])->find();
$einfo['platform_name']=isset($plat['platform_name'])?$plat['platform_name']:"";
}
$einfo['companyName'] = isset($in['companyName']) ? $in['companyName'] : "";
$einfo['addrs'] = $addrs;
$einfo['can'] = $int;
$einfo['goodinfo'] = $goon;
if (empty($einfo)) {
return error_show(1002, "未找到销售订单数据");
} else {
return app_show(0, "获取成功", $einfo);
}
}
public function del()
{
$id = isset($this->post['id']) && $this->post['id'] !== "" ? intval($this->post['id']) : "";
if ($id === "") {
return error_show(1002, "参数id不能为空");
}
$ed = Db::name('sale')->where(['id' => $id, 'is_del' => 0])->find();
if (empty($ed)) {
return error_show(1002, "未找到销售订单数据");
}
$str = Db::name('sale')->update(['id' => $id, 'is_del' => 1, 'updatetime' => date("Y-m-d H:i:s")]);
if ($str) {
$stc = ["order_code"=>$id,"status"=>$ed['status'],"action_remark"=>'',"action_type"=>"delete"];
ActionLog::logAdd($this->post['token'],$stc,"XSQRD",$ed['status'],['id' => $id, 'is_del' => 1, 'updatetime' => date("Y-m-d H:i:s")]);
$order=["order_type"=>'XSQRD',"order_code"=>$ed['orderCode'],"order_id"=>$id,"order_status"=>$ed['status']];
ProcessOrder::workdel($order);
return error_show(0, "删除成功");
} else {
return error_show(1002, "删除失败");
}
}
public function status()
{
$token = isset($this->post['token']) && $this->post['token'] !== "" ? trim($this->post['token']) : "";
$id = isset($this->post['id']) && $this->post['id'] !== "" ? intval($this->post['id']) : "";
if ($id == "") {
return error_show(1002, "参数id不能为空");
}
$status = isset($this->post['status']) && $this->post['status'] !== "" ? intval($this->post['status']) : "";
if ($status == "") {
return error_show(1002, "订单状态不能为空");
}
$dio = Db::name('sale')->where(['id' => $id, 'is_del' => 0])->find();
if (empty($dio)) {
return error_show(1002, "销售单信息未找到");
}
if ($status == 1 && $dio['order_type'] == 2) {
$zxinfo = Db::name("consult")->where(["zxNo" => $dio['zxNo'], "is_del" => 0])->find();
if ($zxinfo == false) {
return error_show(1004, "未找到咨询单数据");
}
$gold['price'] = 0;
if ($zxinfo['zx_type'] == 2) {
if ($zxinfo['metals'] == "") {
return error_show(1004, "未找到咨询单贵金属类型数据");
}
$metals = $zxinfo['metals'] == '18K' ? 1 : ($zxinfo['metals'] == '24K' ? 2 : 3);
$gold = Db::name("gold_price")->where(["type" => $metals])->order("addtime desc")->find();
if (empty($gold)) {
return error_show(1004, "未找到咨询单贵金属类型数据");
}
$dio['gold_price'] = $gold['price'];
}
$wsm = Db::name("warehouse_info")->where(["supplierNo" => $zxinfo['gysNo'], "wsm_type" => 2])->find();
if (empty($wsm)) {
return error_show(1002, "供应商仓库未找到");
}
}
$apply_id = GetUserInfo($token);
if (empty($apply_id) || $apply_id['code'] != 0) {
return error_show(1002, "申请人数据不存在");
}
$rm = isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri = isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
Db::startTrans();
try {
$vmp =$dio['status'];
$dio['status'] = $status;
$dio['updatetime'] = date("Y-m-d H:i:s");
$st = Db::name('sale')->save($dio);
if ($st) {
$stn = ["order_code"=>$dio['orderCode'],"status"=>$vmp,"action_remark"=>'',"action_type"=>"status"];
ActionLog::logAdd($this->post['token'],$stn, $dio['order_type'] == 2?"ZXQRD":"XSQRD",$dio['status'],$dio);
$order=["order_type"=>$dio['order_type'] == 2?"ZXQRD":"XSQRD","order_code"=>$dio['orderCode'],"order_id"=>$id,"order_status"=>$dio['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
if ($status == 3 && $dio['order_type'] == 1) {
$dn = Db::name('sale_info')->where(['orderCode' => $st['orderCode']])->select();
foreach ($dn as $value) {
$dm = Db::name('good_stock')->where(['wsm_code' => $value['wsm_code'], 'good_type_code' => $st['good_code']])->find();
if ($dm == "") {
Db::rollback();
return error_show(1003, "未找到商品数据");
}
if ($value['num'] > $dm['usable_stock']) {
Db::rollback();
return error_show(1002, "超出库存数量");
}
$dm['usable_stock'] -= $value['num'];
$dm['wait_out_stock'] += $value['num'];
$send = Db::name("order_out")->where(["wsm_code" => $value['wsm_code']])->sum("send_num");
$value['send_num'] = $send ?? 0;
$value['wsend_num'] = $value['num'] - $value['send_num'];
$Db = Db::name('good_stock')->update($dm);
$Db['updatetime'] = date('Y-m-d H:i:s');
if ($Db == false) {
Db::rollback();
return error_show(1002, "状态更新失败");
}
}
}
if ($status == 1 && $dio['order_type'] == 2) {
$cgd = makeNo("CG");
$clll = [
"cgdNo" => $cgd,
"bkcode" => $dio['orderCode'],
"wsm_code" => $wsm['wsm_code'],
"cgder_id" => Db::name('depart_user')->where('nickname',$zxinfo['saler'])->value('uid')??0,//重名以及多个账号的话…………
"cgder" => $zxinfo['saler'],
"good_code" => "GD-" . $zxinfo['cpNo'],
"good_name" => $zxinfo['cpName'],
"good_type_code" => $zxinfo['cpNo'],
"good_num" => $dio['good_num'],
"good_price" => $zxinfo['total_fee'],
"total_fee" => round($zxinfo['total_fee'] * $dio['good_num'], 2),
"pakge_fee" => $zxinfo['package_fee'],
"cert_fee" => $zxinfo['cert_fee'],
"open_fee" => $zxinfo['open_fee'],
"delivery_fee" => $zxinfo['delivery_fee'],
"mark_fee" => $zxinfo['mark_fee'],
"teach_fee" => $zxinfo['cost_fee'],
"demo_fee" => $zxinfo['demo_fee'],
"nake_fee" => $zxinfo['bare_fee'],
"weight" => isset($zxinfo['weight']) ? $zxinfo['weight'] : 0,
"supplierNo" => $zxinfo['gysNo'],
"supplier_name" => $zxinfo['gysname'],
"gold_price" => $gold['price'],
"send_num" => 0,
"wsend_num" => $dio['good_num'],
"remark" => '',
"lasttime" => date("Y-m-d H:i:s"),
"is_del" => 0,
"status" => $dio['send_type'] == 1 ? 3 : 0,
"order_type" => 2,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$cgin = Db::name("purchease_order")->insert($clll);
// var_dump(Db::name("purchease_order")->getLastSql(),$clll);
if ($cgin == false) {
$stb = ["order_code"=>$cgd,"status"=> $clll['status'],"action_remark"=>'',"action_type"=>"create"];
ActionLog::logAdd($this->post['token'],$stb,"xsd", $clll['status'],$stb);
Db::rollback();
return error_show(1002, "咨询采购单创建商品失败");
}
if ($dio['send_type'] == 1) {
$addr = Db::name('order_addr')->where(["orderCode" => $dio['orderCode'], 'is_del' => 0])->select();
foreach ($addr as $value) {
$outCode = makeNo("DF");
$data = [
"wsm_code" => $wsm['wsm_code'],
"orderCode" => $dio['orderCode'],
"outCode" => $outCode,
"order_type" => $dio['order_type'],
"apply_id" => $rm,
"apply_name" => $ri,
"addrid" => $value['id'],
"post_name" => '',
"post_code" => '',
"post_fee" => '',
"sendtime" => date("Y-m-d H:i:s"),
"send_num" => $value['receipt_quantity'],
"check_num" => 0,
"error_num" => 0,
"status" => 0,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$datainfo = Db::name('order_out')->insert($data);
if (!$datainfo) {
$sti = ["order_code"=>$dio['orderCode'],"status"=> 0,"action_remark"=>'',"action_type"=>"create"];
ActionLog::logAdd($this->post['token'],$sti,"xsd",0,$sti);
Db::rollback();
return error_show(1003, "创建失败");
}else{
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $outCode,//出库单号
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKD", 0, $data);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CKD',
"order_code" => $outCode,//出库单号
"order_id" => 0,
"order_status" => 0
]);
}
}
$wsm_in_code = makeNo("CF");
$orin = [
"wsm_in_code" => $wsm_in_code,
"cgdNo" => $cgd,
"wsm_code" => $wsm['wsm_code'],
"wsm_reaper" => "",
"send_num" => $dio['good_num'],
"post_company" => '',
"post_code" => '',
"post_fee" => '',
"sendtime" => date("Y-m-d H:i:s"),
"apply_id" => $rm,
"apply_name" => $ri,
"wait_num" => 0,
"status" => 4,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$win = Db::name("purchease_in")->insert($orin);
if (!$win){
$stv = ["order_code"=>$wsm_in_code,"status"=>4,"action_remark"=>'',"action_type"=>"create"];
ActionLog::logAdd($this->post['token'],$stv,"xsd",4,$stv);
Db::rollback();
return error_show(1003, "创建失败");
}
$good = Db::name("good_stock")->where(["wsm_code" => $wsm['wsm_code'], "good_type_code" => $zxinfo['cpNo'], "is_del" => 0])->find();
if (empty($good)) {
$good = [
"good_type_code" => $zxinfo['cpNo'],
"wsm_code" => $wsm['wsm_code'],
"usable_stock" => 0,
"wait_out_stock" => 0,
"total_stock" => 0,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s"),
];
}
$good['wait_out_stock'] += $dio['good_num'];
$good['total_stock'] = $good['usable_stock'] + $good['wait_out_stock'];
$good['updatetime'] = date("Y-m-d H:i:s");
$upd = Db::name("good_stock")->save($good);
if (!$upd) {
$ste = ["order_code"=> $zxinfo['cpNo'],"status"=>0,"action_remark"=>'',"action_type"=>"create"];
ActionLog::logAdd($this->post['token'],$ste,"xsd",0,$ste);
Db::rollback();
return error_show(1003, "创建失败");
}
}
}
}
Db::commit();
return error_show(0, "订单状态更新成功");
} catch (Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage());
}
}
public function fee()
{
$id = isset($this->post['id']) && $this->post['id'] !== "" ? trim($this->post['id']) : "";
if ($id == "") {
return error_show(1002, "参数id不能为空");
}
$etid = Db::name("sale")->where(["id" => $id, "is_del" => 0])->find();
if (empty($etid)) {
return error_show(1002, "未找到数据");
}
$vr = isset($this->post['order_addr']) && $this->post['order_addr'] !== "" ? $this->post['order_addr'] : "";
if ($vr == "") {
return error_show(1002, "参数order_addr不能为空");
}
Db::startTrans();
try {
$data = [
"id" => $id,
"status" => 2,
"is_del" => 0,
"updatetime" => date("Y-m-d H:i:s")
];
$datainfo = Db::name('sale')->where(['id' => $id, 'is_del' => 0])->save($data);
if ($datainfo) {
$stx = ["order_code"=> $etid['orderCode'],"status"=>$etid['status'],"action_remark"=>'',
"action_type"=>"edit"];
ActionLog::logAdd($this->post['token'],$stx,$etid['order_type'] == 2?"ZXQRD":"XSQRD",2,$data);
$order=["order_type"=>$etid['order_type'] == 2?"ZXQRD":"XSQRD","order_code"=>$etid['orderCode'],"order_id"=>$id,"order_status"=>$data['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
foreach ($vr as $value) {
$tm = [];
$tm['id'] = $value['id'];
$tm['orderCode'] = $etid['orderCode'];
$tm['post_fee'] = $value['post_fee'];
$tm['updatetime'] = date("Y-m-d H:i:s");
$dn = Db::name('order_addr')->save($tm);
if ($dn == false) {
Db::rollback();
return error_show(1002, "更新失败");
}
}
Db::commit();
return error_show(0, "更新成功");
}
Db::rollback();
return error_show(1003, "更新失败");
} catch (Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage());
}
}
public function out()
{
$token = isset($this->post['token']) && $this->post['token'] !== "" ? trim($this->post['token']) : "";
$outCode = makeNo("DF");
$orderCode = isset($this->post['orderCode']) && $this->post['orderCode'] !== "" ? trim($this->post['orderCode']) : "";
if ($orderCode == "") {
return error_show(1002, "参数orderCoder不能为空");
}
$der = Db::name('sale')->where(['orderCode' => $orderCode])->find();
if ($der == "") {
return error_show(1002, "未找到出库订单单号");
}
// $wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code'] !== "" ? trim($this->post['wsm_code']) : "";
// if ($wsm_code == "") {
// return error_show(1002, "参数wsm_code不能为空");
// }
// $wsm = Db::name('sale_info')->where(['wsm_code' => $wsm_code, 'orderCode' => $der['orderCode']])->find();
// if ($wsm == "") {
// return error_show(1002, "未找到仓库编码");
// }
$post_name = isset($this->post['post_name']) && $this->post['post_name'] !== "" ? trim($this->post['post_name']) : "";
if ($post_name == "") {
return error_show(1002, "物流公司不能为空");
}
$post_code = isset($this->post['post_code']) && $this->post['post_code'] !== "" ? trim($this->post['post_code']) : "";
if ($post_code == "") {
return error_show(1002, "物流单号不能为空");
}
$post_fee = isset($this->post['post_fee']) && $this->post['post_fee'] !== "" ? intval($this->post['post_fee']) : "";
if ($post_fee == "") {
return error_show(1002, "物流费不能为空");
}
$send_num = isset($this->post['send_num']) && $this->post['send_num'] !== "" ? $this->post['send_num'] : "";
if ($send_num == "") {
return error_show(1002, "发货数量不能为空");
}
if ($send_num > $der['wsend_num']) {
return error_show(1002, "超出可发货数量");
}
$apply_id = GetUserInfo($token);
if (empty($apply_id) || $apply_id['code'] != 0) {
return error_show(1002, "申请人数据不存在");
}
$rm = isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri = isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
$addrid = isset($this->post['addrid']) && $this->post['addrid'] !== "" ? intval($this->post['addrid']) : "";
$dr = Db::name('order_addr')->where(['id' => $addrid, 'is_del' => 0])->find();
if (empty($dr)) {
return error_show(1003, "收货人信息未找到");
}
if ($dr['orderCode'] !== $orderCode) {
return error_show(1002, "订单code不存在");
}
$sendtime = isset($this->post['sendtime']) && $this->post['sendtime'] !== "" ? $this->post['sendtime'] : date("Y-m-d H:i:s");
// $check_num = isset($this->post['check_num']) && $this->post['check_num'] !=="" ? $this->post['check_num'] :"";
// $error_num = isset($this->post['error_num']) && $this->post['error_num'] !=="" ? $this->post['error_num'] :"";
$status = isset($this->post['status']) && $this->post['status'] !== "" ? $this->post['status'] : "1";
//$order_type = isset($this->post['order_type']) && $this->post['order_type'] !=="" ? $this->post['order_type'] :"1";
//$dn=Db::name('sale_info')->where(['wsm_code'=>$outCode])->find();
Db::startTrans();
try {
$data = [
"wsm_code" => "",
"orderCode" => $orderCode,
"outCode" => $outCode,
"order_type" => $der['order_type'],
"apply_id" => $rm,
"apply_name" => $ri,
"addrid" => $dr['id'],
"post_name" => $post_name,
"post_code" => $post_code,
"post_fee" => $post_fee,
"sendtime" => $sendtime,
"send_num" => $send_num,
"check_num" => 0,
"error_num" => 0,
"status" => $status,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$datainfo = Db::name('order_out')->insert($data,true);
if ($datainfo>0) {
$stx = ["order_code"=>$outCode,"status"=>$status,"action_remark"=>'',"action_type"=>"create"];
ActionLog::logAdd($this->post['token'],$stx,$der['order_type']==1?"CKD":'ZXCKD',$status,$data);
$order=["order_type"=>$der['order_type']==1?"CKD":'ZXCKD',"order_code"=>$outCode,"order_id"=>$datainfo,"order_status"=>$data['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
if ($status == 1) {
$item =$der['status'];
$der['send_num'] += $send_num;
$der['wsend_num'] -= $send_num;//($der['send_num'])?$der['wsend_num'] =="" ? $der['send']
$der['send_status'] = $der['send_num'] == 0 ? 1 : $der['wsend_num'] == 0 ? 3 : 2;
$der['status'] = $der['send_num'] == 0 ? 3 : $der['wsend_num'] == 0 ? 5 : 4;
$der['updatetime'] = date("Y-m-d H:i:s");
$si = Db::name('sale')->save($der);
if ($si == false) {
Db::rollback();
return error_show(1003, "更新失败");
}
$stx = ["order_code"=>$orderCode,"status"=>$item,"action_remark"=>'',"action_type"=>"edit"];
ActionLog::logAdd($this->post['token'],$stx,$der['order_type'] == 2?"ZXQRD":"XSQRD",$der['status'],$der);
$order=["order_type"=>$der['order_type'] == 2?"ZXQRD":"XSQRD","order_code"=>$orderCode,"order_id"=>$der['id'],"order_status"=>$data['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
$str = Db::name('good_stock')->where(['wsm_code' => $var['wsm_code'], 'good_type_code' => $der['good_code']])->find();
if ($str == false) {
Db::rollback();
return error_show(1002, "商品数据未找到");
}
if ($send_num > $str['wait_out_stock']) {
Db::rollback();
return error_show(1002, "超出库存数量");
}
$str['wait_out_stock'] -= $send_num;
$str['intra_stock'] += $send_num;
$str['updatetime'] = date("Y-m-d H:i:s");
$stre = Db::name('good_stock')->save($str);
if ($stre == false) {
Db::rollback();
return error_show(1002, "状态更新失败");
}
//商品变动日志表，good_log_code字段存储采购单号
$good_data[] = ['good_log_code' => $outCode, "stock_id" => $str['id'], "type" => 2, 'stock' => $send_num, "stock_name" => "wait_out_stock"];
$good_data[] = ['good_log_code' => $outCode, "stock_id" => $str['id'], "type" => 1, 'stock' => $send_num, "stock_name" => "intra_stock"];
GoodLog::LogAdd($this->post['token'],$good_data,$der['order_type'] != 1?"ZXQRD":"XSQRD");
}
Db::commit();
return error_show(0, "创建成功");
} else {
Db::rollback();
return error_show(1003, "创建失败");
}
} catch (Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage());
}
}
public function customer()
{
$outCode = isset($this->post['outCode']) && $this->post['outCode'] !== "" ? trim($this->post['outCode']) : "";
if (empty($outCode)) {
return error_show(1002, "销售订单编号不能为空");
}
$codeinfo = Db::name('order_out')->where(['outCode' => $outCode])->find();
if ($codeinfo == "") {
return error_show(1003, "未找到订单数据");
}
// $orderCode = isset($this->post['orderCode']) && $this->post['orderCode'] !=="" ? trim($this->post['orderCode']) :"";
// if($orderCode==""){
// return error_show(1002,"参数orderCoder不能为空");
// }
$dr = Db::name('sale')->where(['orderCode' => $codeinfo['orderCode']])->find();
if ($dr == "") {
return error_show(1002, "未找到销售订单");
}
$status = isset($this->post['status']) && $this->post['status'] !== "" ? $this->post['status'] : "";
if ($status == "") {
return error_show(10002, "状态不能为空");
}
Db::startTrans();
try {
$time = $codeinfo['status'];
$codeinfo['status'] = $status;
$codeinfo['updatetime'] = date("Y-m-d H:i:s");
$cust = Db::name('order_out')->save($codeinfo);
if ($cust) {
$stx = ["order_code"=>$outCode,"status"=>$time,"action_remark"=>'',"action_type"=>"status"];
ActionLog::logAdd($this->post['token'],$stx,$codeinfo['order_type'] == 2?"ZXCKD":"CKD",$codeinfo['status'],$codeinfo);
$order=["order_type"=>$codeinfo['order_type'] == 2?"ZXCKD":"CKD","order_code"=>$outCode,
"order_id"=>$codeinfo['id'],"order_status"=>$codeinfo['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
if ($status == 1) {
$stokc =Db::name("good_stock")->where(['spuCode'=>$codeinfo['spuCode'],"wsm_code"=>$codeinfo['wsm_code'],
"is_del"=>0])->find();
if($stokc==false){
Db::rollback();
return error_show(1002, "未找库存到数据");
}else{
if ($codeinfo['send_num'] > $stokc['usable_stock']) {
Db::rollback();
return error_show(1002, "超出库存数量");
}
$stokc['wait_out_stock']+=$codeinfo['send_num'];
$stokc['usable_stock']-=$codeinfo['send_num'];
$stokc['updatetime']=date("Y-m-d H:i:s");
}
$stoc= Db::name("good_stock")->save($stokc);
if($stoc==false){
Db::rollback();
return error_show(1002, "库存更新失败");
}
$item =$dr['status'];
$dr['send_num'] +=$codeinfo['send_num'];
$dr['wsend_num'] -= $codeinfo['send_num'];//($der['send_num'])?$der['wsend_num'] =="" ? $der['send']
$dr['send_status'] = $dr['send_num'] == 0 ? 1 : $dr['wsend_num'] == 0 ? 3 : 2;
$dr['status'] = $dr['send_num'] == 0 ? 3 : $dr['wsend_num'] == 0 ? 5 : 4;
$dr['updatetime'] = date("Y-m-d H:i:s");
$si = Db::name('sale')->save($dr);
if ($si == false) {
Db::rollback();
return error_show(1003, "更新失败");
}
$stx = ["order_code"=>$dr['orderCode'],"status"=>$item,"action_remark"=>'',"action_type"=>"edit"];
ActionLog::logAdd($this->post['token'],$stx,$dr['order_type'] == 2?"ZXQRD":"XSQRD",$dr['status'],
$dr);
$order=["order_type"=>$dr['order_type'] == 2?"ZXQRD":"XSQRD","order_code"=>$dr['orderCode'],"order_id"=>$dr['id'],"order_status"=>$dr['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
//商品变动日志表，good_log_code字段存储销售订单编号
$good_data[] = ['good_log_code' => $outCode, "stock_id" => $stoc['id'], "type" => 1, 'stock' => $codeinfo['send_num'], "stock_name" => "wait_out_stock"];
$good_data[] = ['good_log_code' => $outCode, "stock_id" => $stoc['id'], "type" => 2, 'stock' => $codeinfo['send_num'], "stock_name" => "usable_stock"];
GoodLog::LogAdd($this->post['token'],$good_data,'CKD');
}
if ($status == 3) {
$var = Db::name('good_stock')->where(['wsm_code' => $codeinfo['wsm_code'], 'good_type_code' => $dr['good_code']])->find();
if ($var == false) {
Db::rollback();
return error_show(1002, "未找到商品数据");
}
if ($codeinfo['send_num'] > $var['intra_stock']) {
Db::rollback();
return error_show(1003, "超出在途库存数量");
}
$var['intra_stock'] -= $codeinfo['send_num'];
$var['updatetime'] = date("Y-m-d H:i:s");
$stre = Db::name('good_stock')->save($var);
//商品变动日志表，good_log_code字段存储销售订单编号
$good_data[] = ['good_log_code' => $outCode, "stock_id" => $var['id'], "type" => 2, 'stock' => $codeinfo['send_num'], "stock_name" => "intra_stock"];
GoodLog::LogAdd($this->post['token'],$good_data,$codeinfo['order_type'] == 2?"ZXCKD":"CKD");
if ($stre == false) {
Db::rollback();
return error_show(1002, "状态更新失败");
}
}
Db::commit();
return error_show(0, "出库订单更新成功");
} else {
Db::rollback();
return error_show(1003, "出库订单更新失败");
}
} catch (Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage());
}
}
public function difflist()
{
$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 = [];
$cgdNo = isset($this->post['orderCode']) && $this->post['orderCode'] != "" ? trim($this->post['orderCode']) : "";
if ($cgdNo != "") {
$where[] = ['a.orderCode', "like", "%$cgdNo%"];
}
$diffNo = isset($this->post['diffCode']) && $this->post['diffCode'] != "" ? trim($this->post['diffCode']) : "";
if ($diffNo != "") {
$where[] = ['a.diffCode', "like", "%$diffNo%"];
}
$status = isset($this->post['status']) && $this->post['status'] !== "" ? intval($this->post['status']) : "";
if ($status !== "") {
$where[] = ['a.status', "=", $status];
}
$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];
}
// $apply_name = isset($this->post['apply_name']) && $this->post['apply_name'] !==""? intval($this->post['apply_name']):"";
// if($apply_name!==""){
// $where[]=['a.apply_name',"like","%$apply_name%"];
// }
$supplierNo = isset($this->post['supplierNo']) && $this->post['supplierNo'] !== "" ? trim($this->post['supplierNo']) : "";
if ($supplierNo != "") {
// $supplier = Db::name("business")->where([['code', "like", "%$supplierNo%"]])->column('code');
//// if(empty($supplier)){
//// return error_show(1004,"未找到供应商信息");
//// }
// $wsmcode = Db::name("sale")->where(["is_del" => 0, "supplierNo" => $supplier])->column("orderCode");
$where[] = ['c.supplierNo', "like", "%$supplierNo%"];
}
$companyNo =isset($this->post['companyNo']) &&$this->post['companyNo'] !=="" ? trim($this->post['companyNo']):"";
if($companyNo!=""){
$where[]=['c.customer_code',"like","%$companyNo%"];
}
$count = Db::name('sale_diff')->alias('a')
->join("sale c", "c.orderCode=a.orderCode", "left")
->join("customer_info v", "v.companyNo=c.customer_code", "left")
->where($where)->count();
$total = ceil($count / $size);
$page = $page >= $total ? intval($total) : $page;
$list = Db::name('sale_diff')->alias('a')
->join("sale c", "c.orderCode=a.orderCode", "left")
->join("customer_info v", "v.companyNo=c.customer_code", "left")
->where($where)->page($page, $size)->field("a.*,c.customer_code,v.companyName,c.skuCode,c.order_type,c.supplierNo")
->order("a.addtime desc")->select();
$data = [];
foreach ($list as $value) {
if($value['order_type']==3|| $value['order_type']==4){
$goon = Db::name("good_zixun")->where(["spuCode"=>$value['good_code'],"is_del"=>0])->find();
}else {
$goon = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $value['skuCode']])->find();
}
$value['can'] = isset($goon['cat_id']) && $goon['cat_id'] != 0 ? made($goon['cat_id']) : [];
$wsm = Db::name("business")->where(['companyNo' => $value['supplierNo']])->find();
$value['supplierNo'] = isset($wsm['companyNo']) ? $wsm['companyNo'] : "";
$value['supplierName'] = isset($wsm['company']) ? $wsm['company'] : "";
$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 diffcheck()
{
$token = isset($this->post['token']) && $this->post['token'] !== "" ? trim($this->post['token']) : "";
$id = isset($this->post['id']) && $this->post['id'] !== "" ? intval($this->post['id']) : "";
if ($id === "") {
return error_show(1004, "参数id不能为空");
}
$info = Db::name("sale_diff")->where(["id" => $id])->find();
if (empty($info)) {
return error_show(1004, "订单数据未找到");
}
$is_act = isset($this->post['is_act']) && $this->post['is_act'] !== "" ? intval($this->post['is_act']) : "";
if ($is_act === '') {
return error_show(1004, "参数is_act不能为空");
}
$customer_remark = isset($this->post['customer_remark']) && $this->post['customer_remark'] !== "" ? trim($this->post['customer_remark']) : "";
if ($customer_remark === '') {
return error_show(1004, "参数customer_remark不能为空");
}
$status = isset($this->post['status']) && $this->post['status'] !== "" ? intval($this->post['status']) : "2";
$remark = isset($this->post['remark']) && $this->post['remark'] !== "" ? trim($this->post['remark']) : "";
$item = $info['status'];
$info['is_act'] = $is_act;
$info['customer_remark'] = $customer_remark;
$info['status'] = $status;
$info['remark'] = $remark;
$info['updatetime'] = date("Y-m-d H:i:s");
$up = Db::name("sale_diff")->save($info);
if ($up) {
$stx = ["order_code"=>$info["orderCode"],"status"=>$item,"action_remark"=>'',"action_type"=>"edit"];
ActionLog::logAdd($this->post['token'],$stx,"QRGCD",$info['status'],$info);
$order=["order_type"=>"QRGCD","order_code"=>$info["orderCode"],"order_id"=>$info['id'],"order_status"=>$info['status']];
ProcessOrder::AddProcess($this->post['token'],$order);
return app_show(0, "更新成功");
} else {
return error_show(1003, "更新失败");
}
}
/**
* @return \think\response\Json|void
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function diffstatus()
{
$token = isset($this->post['token']) && $this->post['token'] !== "" ? trim($this->post['token']) : "";
$id = isset($this->post['id']) && $this->post['id'] !== "" ? intval($this->post['id']) : "";
if ($id === "") {
return error_show(1004, "参数id不能为空");
}
$info = Db::name("sale_diff")->where(["id" => $id])->find();
if ($info==false) {
return error_show(1004, "订单数据未找到");
}
$cgd = Db::name("purchease_diff")->where(['id'=>$info['cgd_diffid']])->find();
if($cgd==false){
return error_show(1004, "采购工差单数据未找到");
}
$status = isset($this->post['status']) && $this->post['status'] !== "" ? intval($this->post['status']) : "3";
$remark = isset($this->post['remark']) && $this->post['remark'] !== "" ? trim($this->post['remark']) : "";
$ite=$info['status'];
Db::startTrans();
try{
$upda=[
"status"=>$status,
"remark"=>$remark,
"updatetime"=> date("Y-m-d H:i:s"),
];
$up = Db::name("sale_diff")->where($info)->save($upda);
if ($up) {
$stx = ["order_code"=>$info["orderCode"],"status"=>$ite,"action_remark"=>'',"action_type"=>"status"];
ActionLog::logAdd($this->post['token'],$stx,"QRGCD",$info['status'],$info);
$order=["order_type"=>"QRGCD","order_code"=>$info["orderCode"],"order_id"=>$info['id'],"order_status"=>$status];
ProcessOrder::AddProcess($this->post['token'],$order);
$cgdup =Db::name("purchease_diff")->where(["id"=>$info['cgd_diffid']])->save($upda);
if($cgdup){
Db::commit();
return app_show(0, "更新成功");
}
}
Db::rollback();
return error_show(1003, "更新失败");
}catch (\Exception $e){
Db::rollback();
return error_show(1003,$e->getMessage());
}
}
/**
* @return \think\response\Json|void
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function diffinfo()
{
$id = isset($this->post['id']) && $this->post['id'] !== "" ? intval($this->post['id']) : "";
if ($id === "") {
return error_show(1004, "参数id不能为空");
}
$info = Db::name('sale_diff')->where(["id" => $id])->find();
if (empty($info)) {
return error_show(1004, "工差订单数据未找到");
}
$einfo = Db::name('sale')->where(['orderCode' => $info['orderCode'], 'is_del' => 0])->find();
if ($einfo==false) {
return error_show(1002, "未找到销售订单数据");
}
if($einfo['order_type']==3|| $einfo['order_type']==4){
$goon = Db::name("good_zixun")->where(["spuCode"=>$einfo['good_code'],"is_del"=>0])->find();
}else {
$goon = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $einfo['skuCode']])->find();
}
if($goon==false){
return error_show(1002, "未找到商品数据");
}
$info['skuCode'] =isset($goon['skuCode']) ? $goon['skuCode']:"";
$info['spuCode'] =isset($goon['spuCode']) ? $goon['spuCode']:"";
$info['order_type'] =isset($einfo['order_type']) ? $einfo['order_type']:"";
$info['can'] = isset($info['cat_id']) && $info['cat_id'] !== 0 ? made($info['cat_id']) : [];
return app_show(0, "获取成功", $info);
}
public function saleout(){
$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= [];
$orderCode=isset($this->post['orderCode']) && $this->post['orderCode'] !=="" ? trim($this->post['orderCode'])
:"";
if($orderCode !==""){
$where[]=['a.orderCode',"like","%$orderCode%"];
}
$order_type=isset($this->post['order_type']) && $this->post['order_type'] !=="" ? trim($this->post['order_type'])
:"";
if($order_type !==""){
$where[]=['a.order_type',"=",$order_type];
}
$outCode=isset($this->post['outCode']) && $this->post['outCode'] !=="" ? trim($this->post['outCode'])
:"";
if($outCode !==""){
$where[]=['a.outCode',"like","%$outCode%"];
}
$apply_name=isset($this->post['apply_name']) && $this->post['apply_name'] !=="" ? trim($this->post['apply_name'])
:"";
if($apply_name !==""){
$where[]=['a.apply_name',"like","%$apply_name%"];
}
$good_code=isset($this->post['good_code']) && $this->post['good_code'] !=="" ? trim($this->post['good_code'])
:"";
if($good_code !==""){
$where[]=['b.good_code',"like","%$good_code%"];
}
$good_name=isset($this->post['good_name']) && $this->post['good_name'] !=="" ? trim($this->post['good_name'])
:"";
if($good_name !==""){
$where[]=['b.good_name',"like","%$good_name%"];
}
$status=isset($this->post['status']) && $this->post['status'] !=="" ? trim($this->post['status']):"";
if($status !==""){
$where[]=['a.status',"=",$status];
}
$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];
}
$companyNo =isset($this->post['companyNo']) &&$this->post['companyNo'] !=="" ? trim($this->post['companyNo']):"";
if($companyNo!=""){
$where[]=['b.customer_code',"like","%$companyNo%"];
}
$count = Db::name('order_out')->alias('a')
->join("sale b", "b.orderCode=a.orderCode", "left")
->join("customer_info v", "v.companyNo=b.customer_code", "left")
//->join("good n","n.good_code=b.good_code","left")
->where($where)->count();
$total = ceil($count / $size);
$page = $page >= $total ? $total : $page;
$list = Db::name('order_out')->alias('a')->join("sale b", "b.orderCode=a.orderCode", "left")
->join("customer_info v", "v.companyNo=b.customer_code", "left")
//->join("good n","n.good_code=b.good_code","left")
->field("a.*,b.good_name,b.good_code,b.skuCode,b.supplierNo,b.customer_code,v.companyName,b.origin_price,b.sale_price,b.total_price")
->where($where)->order("addtime desc")->page($page, $size)->select();
$data=[];
foreach ($list as $value) {
$wsmcode = Db::name("warehouse_info")->alias("k")->leftJoin("supplier c", "k.supplierNo=c.code")
->where(["k.wsm_code" => $value['wsm_code']])->field("k.name as wsm_name,c.name,c.code")->find();
$addr = Db::name("order_addr")->where(["id" => $value['addrid']])->find();
if($value['order_type']==3|| $value['order_type']==4){
$goon = Db::name("good_zixun")->where(["spuCode"=>$value['good_code'],"is_del"=>0])->find();
}else {
$goon = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $value['skuCode']])->find();
}
$value['wsm_name'] = isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name'] : "";
$value['wsm_supplier'] = isset($wsmcode['name']) ? $wsmcode['name'] : "";
$value['wsm_supplierNo'] = isset($wsmcode['code']) ? $wsmcode['code'] : "";
$value['addr'] = isset($addr['addr']) ? $addr['addr'] : "";
$value['contactor'] = isset($addr['contactor']) ? $addr['contactor'] : "";
$value['mobile'] = isset($addr['mobile']) ? $addr['mobile'] : "";
$value['can'] = isset($goon['cat_id']) && $goon['cat_id'] != 0 ? made($goon['cat_id']) : [];
$data[] = $value;
}
return app_show(0, "获取成功", ['list' => $data, 'count' => $count]);
}
public function outinfo()
{
$outCode = isset($this->post['outCode']) && $this->post['outCode'] !== "" ? trim($this->post['outCode']) : "";
if ($outCode == "") {
return error_show(1002, "参数outcode不能为空");
}
$codeinfo = Db::name("order_out")->where(['outCode' => $outCode])->find();
if (empty($codeinfo)) {
return error_show(1002, "未找到出库数据");
}
$item = Db::name("sale")->where(['orderCode' => $codeinfo['orderCode']])->find();
if($item['order_type']==3|| $item['order_type']==4){
$goodinfo = Db::name("good_zixun")->where(["spuCode"=>$item['good_code'],"is_del"=>0])->find();
if($goodinfo==false){
return error_show(1004,"未找到商品数据");
}
}else{
$goodinfo = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' =>$item['skuCode']])->find();
if ($goodinfo == false) {
return error_show(1002, "未找到商品数据");
}
}
$int = isset($goodinfo['cat_id']) && $goodinfo['cat_id'] != 0 ? made($goodinfo['cat_id']) : [];
$addr = Db::name("order_addr")->where(["id" => $codeinfo['addrid']])->find();
$codeinfo['good_name'] = isset($item['good_name']) ? $item['good_name'] : "";
$codeinfo['good_num'] = isset($item['good_num']) ? $item['good_num'] : "";
$codeinfo['good_code'] = isset($item['good_code']) ? $item['good_code'] : "";
$codeinfo['origin_price'] = isset($item['origin_price']) ? $item['origin_price'] : "";
$codeinfo['sale_price'] = isset($item['sale_price']) ? $item['sale_price'] : "";
$codeinfo['total_price'] = isset($item['total_price']) ? $item['total_price'] : "";
$codeinfo['skuCode'] = isset($item['skuCode']) ? $item['skuCode'] : "";
$codeinfo['addr'] = GetAddr($addr['addr_code']);
$codeinfo['addr'] .= isset($addr['addr']) ? $addr['addr'] : "";
$codeinfo['addr_code'] = isset($addr['addr_code']) ? $addr['addr_code'] : "";
$codeinfo['contactor'] = isset($addr['contactor']) ? $addr['contactor'] : "";
$codeinfo['mobile'] = isset($addr['mobile']) ? $addr['mobile'] : "";
$codeinfo['can'] = $int;
$orderReturn = Db::name("order_return")->where(["outCode"=>$outCode,"is_del"=>0])->order("id desc")->find();
$codeinfo['order_return'] = $orderReturn ;
return app_show(0, "获取成功", $codeinfo);
}
public function outadd(){
$token = isset($this->post['token']) && $this->post['token'] !== "" ? trim($this->post['token']) : "";
$orderCode = isset($this->post['orderCode']) && $this->post['orderCode'] !== "" ? trim($this->post['orderCode']) : "";
if ($orderCode == "") {
return error_show(1002, "参数orderCoder不能为空");
}
$der = Db::name('sale')->where(['orderCode' => $orderCode,"is_del"=>0])->find();
if ($der == "") {
return error_show(1002, "未找到出库订单单号");
}
$send_num = isset($this->post['send_num']) && $this->post['send_num'] !== "" ? $this->post['send_num'] : "";
if ($send_num == "") {
return error_show(1002, "发货数量不能为空");
}
if ($send_num > $der['wsend_num']) {
return error_show(1002, "超出可发货数量");
}
$contactor = isset($this->post['contactor'])&&$this->post['contactor']!="" ? trim($this->post['contactor']):"";
if($contactor==""){
return error_show(1002, "参数contactor不能为空");
}
$mobile = isset($this->post['mobile'])&&$this->post['mobile']!="" ? trim($this->post['mobile']):"";
if($mobile==""){
return error_show(1002, "参数mobile不能为空");
}
$addr = isset($this->post['addr'])&&$this->post['addr']!="" ? trim($this->post['addr']):"";
if($addr==""){
return error_show(1002, "参数addr不能为空");
}
$addr_code = isset($this->post['addr_code'])&&$this->post['addr_code']!="" ? trim($this->post['addr_code']):"";
if($addr_code==""){
return error_show(1002, "参数addr_code不能为空");
}
$apply_id = GetUserInfo($token);
if (empty($apply_id) || $apply_id['code'] != 0) {
return error_show(1002, "申请人数据不存在");
}
$rm = isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
$ri = isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
$sendtime = isset($this->post['sendtime']) && $this->post['sendtime'] !== "" ? $this->post['sendtime'] : date("Y-m-d H:i:s");
$order =Db::name("order_num")->where(["orderCode"=>$orderCode,"status"=>1])->where([["wsend_num",">=",0]])
->find();
if(empty($order)){
return error_show(1004,"未找到可以发货得采购单数据");
}
Db::startTrans();
try {
$order =Db::name("order_num")->where(["orderCode"=>$orderCode,"status"=>1])->where([["wsend_num",">=",0]])
->lock(true)->find();
if($order==false){
Db::rollback();
return error_show(1004,"未找到可以发货得采购单数据");
}
$addrlst =[
"orderCode"=>$orderCode,
"addr"=>$addr,
"addr_code"=>json_encode($addr_code),
"contactor"=>$contactor,
"mobile"=>$mobile,
"customer_code"=>$der['customer_code'],
"post_fee"=>$der['post_fee'],
"arrive_time"=>$sendtime,
"receipt_quantity"=>$send_num,
"is_del"=>0,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$addrid = Db::name("order_addr")->insert($addrlst,true);
if($addrid>0){
$der['send_num'] +=$send_num;
$der['wsend_num'] -= $send_num;
$der['send_status'] = $der['send_num'] == 0 ? 1 : $der['wsend_num'] == 0 ? 3 : 2;
$der['status'] = $der['send_num'] == 0 ? 3 : $der['wsend_num'] == 0 ? 5 : 4;
$der['updatetime'] = date("Y-m-d H:i:s");
$si = Db::name('sale')->save($der);
if($si==false){
Db::rollback();
return error_show(1002,"出库单新建失败");
}
$outCode = makeNo("DF");
$cgd =Db::name("purchease_order")->where(["cgdNo"=>$order['cgdNo']])->find();
if($cgd==false){
Db::rollback();
return error_show(1002,"未找到对应的采购单数据");
}
$order['wsend_num']-=$send_num;
$order['send_num']+=$send_num;
$or =Db::name("order_num")->save($order);
if($or==false){
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
$tep=[
"cgdNo"=>$order['cgdNo'],
"outCode"=>$outCode,
"send_num"=>$send_num,
"status"=>1,
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$sen=Db::name("order_send")->save($tep);
if($sen==false){
Db::rollback();
return error_show(1002,"发货地址添加创建失败");
}
$data = [
"wsm_code" => isset($cgd['wsm_code'])? $cgd['wsm_code']:"",
"orderCode" => $orderCode,
"outCode" => $outCode,
"order_type" => $der['order_type'],
"apply_id" => $rm,
"apply_name" => $ri,
"addrid" => $addrid,
"post_name" => "",
"post_code" =>"",
"post_fee" => "",
"sendtime" => $sendtime,
"send_num" => $send_num,
"check_num" => 0,
"error_num" => 0,
"status" => 1,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
if($der['is_stock']==0){
//维护商品所在仓库的库存 --- start
$temp = Db::name('good_stock')
->field('id,usable_stock,wait_out_stock')
->where(['spuCode' => $der['spuCode'], 'wsm_code' => $cgd['wsm_code']])
->find();
if ($temp == false) {
Db::rollback();
return error_show(1004, '库存不足');
}
if (($temp['usable_stock'] - $send_num) < 0) {
Db::rollback();
return error_show(1004, '库存不足');
}
$up =Db::name('good_stock')
->where('id', $temp['id'])
->update([
'usable_stock' => $temp['usable_stock'] - $send_num,
'wait_out_stock' => $temp['wait_out_stock'] + $send_num,
'updatetime' => date('Y-m-d H:i:s'),
]);
if($up==false){
Db::rollback();
return error_show(1004, '库存更新失败');
}
}
$datainfo = Db::name('order_out')->insert($data,true);
if($datainfo>0){
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $data['outCode'],//出库单号
"status" => $data['status'],//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKD", $data['status'], $data);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CKD',
"order_code" => $data['outCode'],//出库单号
"order_id" => $datainfo,
"order_status" => $data['status']
]);
Db::commit();
return app_show(0,"出库单新建成功");
}
}
Db::rollback();
return error_show(1004,"出库单新建失败");
} catch (Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage());
}
}
public function outdel(){
}
public function outSend(){
$outCode=isset($this->post['outCode'])&& $this->post['outCode']!=""? trim($this->post['outCode']):"";
if($outCode==""){
return error_show(1004,"参数outCode不能为空");
}
$outinfo = Db::name("order_out")->where(["outCode"=>$outCode])->find();
if($outinfo==false){
return error_show(1004,"发货数据未找到");
}
$einfo = Db::name('sale')->where(['orderCode' => $outinfo['orderCode'], 'is_del' => 0])->find();
if (empty($einfo)) {
return error_show(1002, "未找到销售订单数据");
}
$post_name = isset($this->post['post_name']) &&$this->post['post_name']!="" ? trim($this->post['post_name']):"";
if($post_name==""){
return error_show(1004,"参数post_name不能为空");
}
$post_code = isset($this->post['post_code']) &&$this->post['post_code']!="" ? trim($this->post['post_code']):"";
if($post_code==""){
return error_show(1004,"参数post_code不能为空");
}
$post_fee = isset($this->post['post_fee']) && $this->post['post_fee']!="" ? floatval($this->post['post_fee']):"";
$outinfo['post_name'] = $post_name;
$outinfo['post_code'] = $post_code;
$outinfo['post_fee'] = $post_fee;
$outinfo['sendtime'] = date("Y-m-d H:i:s");
$old_outinfo_status = $outinfo['status'];
$outinfo['status'] = 2;
$outinfo['updatetime'] = date("Y-m-d H:i:s");
Db::startTrans();
try{
$up =Db::name("order_out")->save($outinfo);
if($up){
//修改状态，添加待办
ActionLog::logAdd($this->post['token'], [
"order_code" => $outinfo['outCode'],//出库单号
"status" => $old_outinfo_status,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "edit"//新建create，编辑edit，更改状态status
], "CKD", $outinfo['status'], $outinfo);
ProcessOrder::AddProcess($this->post['token'], [
"order_type" => 'CKD',
"order_code" => $outinfo['outCode'],//出库单号
"order_id" => $outinfo['id'],
"order_status" => $outinfo['status']
]);
$stokc =Db::name("good_stock")->where(['spuCode'=>$einfo['good_code'],"wsm_code"=>$outinfo['wsm_code'],"is_del"=>0])->find();
if($stokc==false){
Db::rollback();
return error_show(1002, "未找库存到数据");
}else{
if ($outinfo['send_num'] > $stokc['wait_out_stock']) {
Db::rollback();
return error_show(1002, "超出库存数量");
}
$stokc['wait_out_stock']-=$outinfo['send_num'];
// $stokc['intra_stock']+=$outinfo['send_num'];
$stokc['updatetime']=date("Y-m-d H:i:s");
}
$stoc= Db::name("good_stock")->save($stokc);
if($stoc==false){
Db::rollback();
return error_show(1002, "库存更新失败");
}
Db::commit();
return app_show(0,"发货成功");
}else{
Db::rollback();
return error_show(1004,"发货失败");
}
}catch (\Exception $e){
Db::rollback();
return error_show(1004,$e->getMessage());
}
}
public function RelaCgd($outinfo){
$cgd = Db::name("order_bk")->where([["spuCode","=",$outinfo['spuCode']],["is_del","=",0],["balance_num",">=",
$outinfo['good_num']],['companyNo',"=",$outinfo['companyNo']]])->lock(true)->find();
if($cgd==false){
return false;
}
$cgd['balance_num']-=$outinfo['good_num'];
$cgd['merge_num']+=$outinfo['good_num'];
$cgd['updatetime']=date("Y-m-d H:i:s");
$up=Db::name("order_bk")->save($cgd);
if($up==false){
return false;
}
$data=[
"orderCode"=>$outinfo['orderCode'],
"cgdNo"=>$cgd['cgdNo'],
"spuCode"=>$outinfo['spuCode'],
"companyNo"=>$outinfo['companyNo'],
"good_num"=>$outinfo['good_num'],
"wsend_num"=>$outinfo['good_num'],
"send_num"=>0,
"wait_num"=>$outinfo['good_num'],
"status"=>1,
"source"=>1,
];
$order =Db::name("order_num")->save($data);
if($order==false){
return false;
}
return true;
}
public function addother(){
$orderCode =isset($this->post['orderCode']) && $this->post['orderCode']!=""?trim($this->post['orderCode']):"";
if($orderCode==""){
return error_show(1004,"参数orderCode不能为空");
}
$order =Db::name("sale")->where(["orderCode"=>$orderCode,"is_del"=>0])->find();
if($order==false){
return error_show(1004,"未找到订单数据");
}
$paytime =isset($this->post['paytime'])&&$this->post['paytime']!=""? $this->post['paytime']:"";
$workNo =isset($this->post['workNo'])&&$this->post['workNo']!=""? trim($this->post['workNo']):"";
$platform_order =isset($this->post['platform_order'])&&$this->post['platform_order']!=""? trim($this->post['platform_order']):"";
$paytime==""?"":$order['paytime']=$paytime;
$order['workNo']=$workNo;
$order['platform_order']=$platform_order;
$order['updatetime']=date("Y-m-d H:i:s");
$sa=Db::name("sale")->save($order);
if($sa){
return app_show(0,"更新成功");
}else{
return error_show(1004,"更新失败");
}
}
public function getPrice()
{
$skuCode = isset($this->post['skuCode']) && $this->post['skuCode'] != "" ? trim($this->post['skuCode']) : "";
if ($skuCode === "") {
return error_show(1003, "参数skuCode不能为空");
}
$is_activity = isset($this->post['is_activity']) && $this->post['is_activity'] !== "" ? intval($this->post['is_activity'])
: "";
if ($is_activity === "") {
return error_show(1003, "参数is_activity不能为空");
}
$sale_num = isset($this->post['sale_num']) && $this->post['sale_num'] !== "" ? intval($this->post['sale_num']) : "";
if ($sale_num === "") {
return error_show(1003, "参数sale_num不能为空");
}
$ct = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $skuCode])->find();
if ($ct == false) {
return error_show(1002, "未找到商品数据");
}
$stock = 0;
if ($ct['is_stock'] == 1) {
$good_stock = Db::name("good_stock")->where(["spuCode" => $ct['spuCode'], "is_del" => 0])->find();
$stock = isset($good_stock['usable_stock']) ? $good_stock['usable_stock'] : "0";
}
if ($is_activity == 1) {
$act = Db::name("activity_info")->alias("a")->leftJoin("good_activity b", "a.activity_code=b.activity_code")
->where(["a.skuCode" => $skuCode, "a.is_del" => 0, "a.status" => 1, "b.status" => 6, "b.is_del" => 0])->find();
if ($act == false) {
return error_show(1003, "未找到相关活动价");
}
if ($act['moq_num'] > $sale_num) {
return error_show(1003, "商品不满足活动价起订量{$act['moq_num']}");
}
if ($act['activity_stock'] < $sale_num) {
return error_show(1003, "商品活动库存剩余{$act['activity_stock']}");
}
return app_show(0, "获取成功", ['sale_price' => $act['activity_price'], "stock" => $act['activity_stock']]);
} else {
if ($ct['is_stock'] == 0) {
//good_nake 成本阶梯 good_ladder销售阶梯
$origin = Db::name("good_nake")->where([["spuCode", "=", $ct['spuCode']], ["is_del", "=", 0]])->order("min_num asc")->find();
if (!$origin) {
return error_show(1003, "没有找到成本数据");
}
}
$good = Db::name("good_ladder")->where(["skuCode" => $skuCode, "is_del" => 0, "status" => 1])->order("min_num asc")->find();
if (!$good) {
return error_show(1003, "未找到相关阶梯价格");
}
if(!isset($origin['min_num'])) $origin['min_num']=0;
$lastnum = max($origin['min_num']??0, $good['min_num']);
if ($sale_num < $lastnum) {
return error_show(1003, "商品不满足起订量{$lastnum}");
}
$good_temp = Db::name("good_ladder")->where(["skuCode" => $skuCode, "is_del" => 0, "status" => 1])->where('min_num', '<=', $sale_num)->order("min_num desc")->find();
if (!$good_temp) {
return error_show(1003, "未找到相关阶梯价格");
}
return app_show(0, "获取成功", ['sale_price' => $good_temp['sale_price'], "stock" => $stock]);
}
}
public function saleuse(){
$orderCode= isset($this->post['orderCode'])&&!empty($this->post['orderCode'])?$this->post['orderCode']:"";
if($orderCode==""){
return error_show(1003,"参数orderCode不能为空");
}
$order= Db::name("sale")->where(["orderCode"=>$orderCode,"is_del"=>0])->select()->toArray();
if(empty($order)){
return error_show(1003,"订单数据未找到");
}
$useid= isset($this->post['useid'])&&$this->post['useid']!=""?intval($this->post['useid']):"";
if($useid==""){
return error_show(1003,"参数useid不能为空");
}
$use =Db::name("order_use")->where(["id"=>$useid,"is_del"=>0])->find();
if($use==false){
return error_show(1003,"用途数据未找到");
}
$asve=['use_order'=>$useid,"updatetime"=>date("Y-m-d H:i:s")];
$up=Db::name("sale")->where(["orderCode"=>$orderCode,"is_del"=>0])->update($asve);
if($up>0){
return app_show(0,"更新成功");
}else{
return error_show(1003,"更新失败");
}
}
public function goodzxinfo(){
$orderCode= isset($this->post['spuCode'])&&$this->post['spuCode']!=''?trim($this->post['spuCode']):"";
if($orderCode==""){
return error_show(1003,"参数spuCode不能为空");
}
$order= Db::name("good_zixun")->where(["spuCode"=>$orderCode,"is_del"=>0])->find();
if(empty($order)){
return error_show(1003,"订单数据未找到");
}
$unit =Db::name("unit")->where(["id"=>$order['good_unit']])->find();
if($order['brand_id']!=0){
$brand=Db::name("brand")->where(["id"=>$order['brand_id']])->find();
$order["brand_name"]=isset($brand['brand_name'])?$brand['brand_name']:"";
}else{
$order["brand_name"]="";
$order["brand_id"]="";
}
$order['specinfo']=json_decode($order['specinfo'],true);
$order['unit'] = isset($unit['unit'])?$unit['unit']:'';
$order['cat_info'] = made($order['cat_id'],[]);
$order['noble_name']=isset($order['noble_metal'])&&$order['noble_metal']!=0?$this->noble[$order['noble_metal']] :"";
if($order['is_gold_price']==1){
$price=Db::name("gold_price1")->where(["type"=>$order['noble_metal'],"status"=>1,"is_del"=>0])->order("addtime desc")->find();
}
$supplier = Db::name("supplier")->where(["code"=>$order['supplierNo']])->find();
$order['supplier_name'] = isset($supplier['name']) ? $supplier['name']:"";
$palt =Db::name("platform")->where(["id"=>$order['platform_id']])->find();
$order['platform_name']=isset($palt['platform_name']) ? $palt['platform_name']:"";
$order["gold_price"] = isset($price['price'])?$price['price']:0;
$order["noble_weight"] = isset($order['weight'])?$order['weight']:0;
return app_show(0,"获取成功",$order);
}
//获取采反商品详情，当数据不在good_zixun中,模仿goodzxinfo
public function getGoodZxInfoByNotZixun(){
$param=$this->request->only(['spuCode'],'post','trim');
$val=Validate::rule(['spuCode'=>'require']);
if(!$val->check($param)) return error_show(1004,$val->getError());
$order = Db::name('consult_bids')
->field(true)
->where(['spuCode'=>$param['spuCode'],'is_del'=>0])
->find();
// $orderCode= isset($this->post['spuCode'])&&$this->post['spuCode']!=''?trim($this->post['spuCode']):"";
// if($orderCode==""){
// return error_show(1003,"参数spuCode不能为空");
// }
// $order= Db::name("good_zixun")->where(["spuCode"=>$orderCode,"is_del"=>0])->find();
// if(empty($order)){
// return error_show(1003,"订单数据未找到");
// }
$unit =Db::name("unit")->where(["id"=>$order['unit_id']])->find();
if($order['brand_id']!=0){
$brand=Db::name("brand")->where(["id"=>$order['brand_id']])->find();
$order["brand_name"]=isset($brand['brand_name'])?$brand['brand_name']:"";
}else{
$order["brand_name"]="";
$order["brand_id"]="";
}
$order['specinfo']=json_decode($order['specinfo'],true);
$order['unit'] = isset($unit['unit'])?$unit['unit']:'';
$order['cat_info'] = made($order['cat_id'],[]);
$order['noble_name']=isset($order['metal_id'])&&$order['metal_id']!=0?$this->noble[$order['metal_id']] :"";
if($order['is_gold_price']==1){
$price=Db::name("gold_price1")->where(["type"=>$order['metal_id'],"status"=>1,"is_del"=>0])->order("addtime desc")->find();
}
$supplier = Db::name("supplier")->where(["code"=>$order['supplierNo']])->find();
$order['supplier_name'] = isset($supplier['name']) ? $supplier['name']:"";
// $palt =Db::name("platform")->where(["id"=>$order['platform_id']])->find();
// $order['platform_name']=isset($palt['platform_name']) ? $palt['platform_name']:"";
$order["gold_price"] = isset($price['price'])?$price['price']:0;
$order["noble_weight"] = isset($order['weight'])?$order['weight']:0;
return app_show(0,"获取成功",$order);
}
}