<?php
namespace app\command;
use app\admin\model\ComonOrder;use app\admin\model\OrderCategory;use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\Exception;
use think\facade\Db;
use think\facade\Cache;
//将cfp_caixiao_data里面的数据，分别处理到cfp_qrd_info，cfp_cgd_info(若未对账)，或者cfp_caixiao_wait(已对账)
class handleCxData extends command
{
private $interval = 15000 * 60;//执行间隔，单位：分（每次同步前5分钟的数据）
protected function configure()
{
parent::configure(); // TODO: Change the autogenerated stub
$this->setName('handleCxData')->setDescription('处理中间表的采销数据');
}
protected function execute(Input $input, Output $output)
{
$date = date('Y-m-d H:i:s');
$goodset =Cache::store('redis')->get('JsHandle');
if($goodset ==1) return;
Cache::store('redis')->set('JsHandle',1,180);
Db::startTrans();
$results = Db::name('caixiao_data')
->where("status",1)
->where("addtime",">=",date("Y-m-d H:i:s",time()-1800))
->lock(true)
->limit(100)
->select()->toArray();
if ($results) {
try {
foreach ($results as $result) {
$dataStr=$result['data'];
if($dataStr==''){
$output->writeln("[$date]:{$result['id']}数据解析失败");
continue;
}
$data=json_decode($dataStr,true);
if(is_null($data)){
$output->writeln("[$date]:{$result['id']}数据解析失败");
continue;
}
if(isset($data['inv_cat_info']) && !empty($data['inv_cat_info'])){
$orderCode= $result['order_type']==1?$data['orderCode']:$data['cgdNo'];
OrderCategory::checkInfo($orderCode,$result['order_type'],$data['inv_cat_info']);
}
$qrd_insert_data=$wait_insert_data=$cgd_insert_data=[];
$data['cat_name']=is_array($data['cat_name']) ? $data['cat_name'] : json_decode($data['cat_name'],true);
if ($result['order_type'] == 1) {
$data['total_price']=round($data['total_price'],2) - $data['th_fee'] - $data['diff_fee'];
$exitReport=Db::name('report_code')->where('qrdNo' , $data['orderCode'])->findOrEmpty();
$repostinsert=[
'qrdNo'=>$data['orderCode'] ,
'seller_id'=>$data['apply_id'] ,
'seller'=>$data['apply_name'] ,
'customerName'=>$data['customer_name'] ,
'customerNo'=>$data['customer_code'] ,
'companyNo'=>$data['supplierNo'] ,
'companyName'=>$data['supplier_name'] ,
'cgdNo'=>$data['cgdNo'] ,
];
if (empty($exitReport)) Db::name('report_code')->insert($repostinsert);
else Db::name('report_code')->where($exitReport)->update($repostinsert);
$exists_qrd=Db::name('qrd_info')
->whereIn('sequenceNo' , $data['orderCode'])
->field('id,status')->findOrEmpty();
$all_branch=Db::name('customer_info')
->whereIn('companyNo' , $data['customer_code'])
->column('branch,parent' , 'companyNo');
//已存在
if (!empty($exists_qrd)) {
if ($exists_qrd['status'] == 0) {
$report=[
'qrdNo'=>$data['orderCode'] ,
'seller_id'=>$data['apply_id'] ,
'seller'=>$data['apply_name'] ,
'customerName'=>$data['customer_name'] ,
'customerNo'=>$data['customer_code'] ,
'companyNo'=>$data['supplierNo'] ,
'companyName'=>$data['supplier_name'] ,
'cgdNo'=>$data['cgdNo'] ,
];
$re=Db::name('qrd_info')
->where('id' , $exists_qrd['id'])
->update([
'name'=>$data['orderCode'] ,//确认单名称,
'sequenceNo'=>$data['orderCode'] ,//确认单编号,
'ownerName'=>$data['apply_name'] ,//销售员,
'ownerid'=>$data['apply_id'] ,//销售员id,
'department'=>$data['depart'] ,//部门,
'open_type'=>$data['open_type'] ,//开模类型',
'manager'=>$data['manager']??'',
'managerid'=>$data['managerid']??0,
'createdTime'=>$data['addtime'] ,//销售单创建时间,
'qrdType'=>$data['order_type'] ,//销售单类型,
'qrdSource'=>$data['order_source'] ,//销售单来源,
'companyNo'=>$data['supplierNo'] ,//业务企业编号,
'companyName'=>$data['supplier_name'] ,//业务企业名称,
'customerNo'=>$data['customer_code'] ,//客户编号,
'customerName'=>$data['customer_name'] ,//客户名称,
'poCode'=>$data['poNo'] ,//po编号,
"is_comon"=>ComonOrder::is_common($data['orderCode']),
'platName'=>$data['platform_name']??'',//平台名称,
'platform_type' => $data['platform_type']??'0',//平台名称,
'platform_id'=>$data['platform_id']??0,//平台id,'
'workCode'=>$data['workNo'] ,//业务编号,
'zxCode'=>$data['zxNo'] ,//咨询单编号,
'goodNo'=>$data['good_code'] ,//商品编号,
'goodName'=>$data['good_name'] ,//商品名称,
'goodBrand'=>$data['brand'] ,//商品品牌,
'firstCat'=>$data['cat_name'][0]['cat_name'] ?? "" ,//一级分类,
'secCat'=>!isset($data['cat_name'][1]) ? '' : $data['cat_name'][1]['cat_name'] ,//二级分类,
'thirdCat'=>!isset($data['cat_name'][2]) ? '' : $data['cat_name'][2]['cat_name'] ,
//三级分类,
'catInfo'=>json_encode($data['cat_name'] , JSON_UNESCAPED_UNICODE) ,//分类详情,
'fundCode'=>isset($data['cat_name'][2]) ? $data['cat_name'][2]['fund_code'] : '',//核算编码,
'goodMaterial'=>'' ,//商品材质,
'goodUnit'=>$data['unit'] ,//商品单位,
'goodDesc'=>$data['cost_desc'] ,//工艺说明,
'goodType'=>$data['good_type'] ,//商品类型,
'goodModel'=>'' ,//商品型号,
'isStock'=>$data['is_stock'] ,//是否库存品,
'metalsType'=>$data['noble_metal'] ,//贵金属种类,
'weight'=>$data['good_weight'] ,//商品重量,
'goldPrice'=>$data['gold_price'] ,//贵金属单价,
'deliveryDay'=>$data['delivery_day'] ,//物流天数,
'workDay'=>$data['lead_time'] ,//工期,
'tax'=>$data['tax'] ,//税率,
'goodNum'=>$data['good_num'] ,//销售数量,
'goodPrice'=>$data['sale_price'] ,//产品单价,
'totalPrice'=>$data['total_price'] ,//货款总额,
'total_origin_price'=>$data['total_origin_price'] ,//成本总额,
'total_plan_price'=>$data['total_origin_price_plan'] ,//成本总额,
'sendNum'=>$data['send_num'] ,//已发货数量,
'wsendNum'=>$data['wsend_num'] ,//未发货数量,
'apay_fee'=>0 ,//已付款,
'pay_fee'=>0 ,//付款中
'wpay_fee'=>$data['total_price'] ,//未付款,
'inv_fee'=>0 ,//回票中
'ainv_fee'=>0 ,//已开票,
'winv_fee'=>$data['total_price'] ,//未开票,
'is_diff'=>$data['is_diff'] ,//是否有工差,
'sendType'=>$data['send_type'] ,//发货方式,
'sendStatus'=>$data['send_status'] ,//发货状态,
'pay_status'=>$data['total_price'] == 0 ? 3 : 1 ,//收款状态,1未付，2部分，3完结
'inv_status'=>$data['total_price'] == 0 ? 3 : 1 ,//开票状态,,1未付，2部分，3完结
'remark'=>'' ,//备注,
'cxCode'=>$data['oldCode'] ?? '' ,//备注,
'diff_weight'=>$data['diff_weight'] ,//工差重量,
'diff_fee'=>$data['diff_fee'] ,//工差金额,
'area'=>$data['customer_name'] ,//公司,
'customerAttr'=>$all_branch[$data['customer_code']]['parent'] ?? '' ,//客户属性,
'branch'=>$all_branch[$data['customer_code']]['branch'] ?? '' ,//分公司,从客户表中查
'cgdNo'=>$data['cgdNo'] ,//采购单号,
'thNum'=>$data['th_num'] ,//退货数量,
'th_fee'=>$data['th_fee'] ,//退货金额,
'pay_source'=>$data['pay_source'] ?? '' ,//支付渠道,
'is_del'=>0 ,//是否删除,
'addtime'=>$date ,
'updatetime'=>$date ,
'inv_tag'=>0 ,//开票标签,
'pay_tag'=>0 ,//回款标签,
'inv_tag_fee'=>0 ,//开票票标签金额,
'pay_tag_fee'=>0 ,//回款标签金额,
]
);
}
else {
$wait_insert_data=[
'order_type'=>$result['order_type'] ,
'data'=>json_encode($result['data'] , JSON_UNESCAPED_UNICODE) ,
'orderCode'=>$data['orderCode'] ,
'status'=>1 ,
];
$re=Db::name('qrd_info')
->where('id' , $exists_qrd['id'])
->update([
'poCode'=>$data['poNo'] ,//po编号,
'workCode'=>$data['workNo'] ,//业务编号,
'zxCode'=>$data['zxNo'] ,//咨询单编号,
'goodMaterial'=>'' ,//商品材质,
'open_type'=>$data['open_type'] ,//开模类型',
'is_comon'=>ComonOrder::is_common($data['orderCode']),
'goodUnit'=>$data['unit'] ,//商品单位,
'goodDesc'=>$data['cost_desc'] ,//工艺说明,
'goodType'=>$data['good_type'] ,//商品类型,
'goodModel'=>'' ,//商品型号,
'platName'=>$data['platform_name']??'',//平台名称,
'platform_type' => $data['platform_type']??'0',//平台名称,
'platform_id'=>$data['platform_id']??0,//平台id,'
'companyNo'=>$data['supplierNo'] ,//业务企业编号,
'companyName'=>$data['supplier_name'] ,//业务企业名称,
'customerNo'=>$data['customer_code'] ,//客户编号,
'customerName'=>$data['customer_name'] ,//客户名称,
'manager'=>$data['manager']??'',
'managerid'=>$data['managerid']??0,
'metalsType'=>$data['noble_metal'] ,//贵金属种类,
'weight'=>$data['good_weight'] ,//商品重量,
'deliveryDay'=>$data['delivery_day'] ,//物流天数,
'workDay'=>$data['lead_time'] ,//工期,
'tax'=>$data['tax'] ,//税率,
'total_origin_price'=>$data['total_origin_price'] ,//成本总额,
'total_plan_price'=>$data['total_origin_price_plan'] ,//成本总额,
'sendNum'=>$data['send_num'] ,//已发货数量,
'wsendNum'=>$data['wsend_num'] ,//未发货数量,
'sendType'=>$data['send_type'] ,//发货方式
'sendStatus'=>$data['send_status'] ,//发货状态,
'remark'=>'' ,//备注,
'area'=>$data['customer_name'] ,//公司,
'customerAttr'=>$all_branch[$data['customer_code']]['parent'] ?? '' ,//客户属性,
'branch'=>$all_branch[$data['customer_code']]['branch'] ?? '' ,//分公司,从客户表中查
'pay_source'=>$data['pay_source'] ?? '' ,//支付渠道,
'updatetime'=>$date
]
);
}
}
else {
//新增
$qrd_insert_data[]=[
'name'=>$data['orderCode'] ,//确认单名称,
'sequenceNo'=>$data['orderCode'] ,//确认单编号,
'ownerName'=>$data['apply_name'] ,//销售员,
'ownerid'=>$data['apply_id'] ,//销售员id,
'is_comon'=>ComonOrder::is_common($data['orderCode']),
'department'=>$data['depart'] ,//部门,
'createdTime'=>$data['addtime'] ,//销售单创建时间,
'manager'=>$data['manager']??'',
'managerid'=>$data['managerid']??0,
'qrdType'=>$data['order_type'] ,//销售单类型,
'qrdSource'=>$data['order_source'] ,//销售单来源,
'companyNo'=>$data['supplierNo'] ,//业务企业编号,
'companyName'=>$data['supplier_name'] ,//业务企业名称,
'customerNo'=>$data['customer_code'] ,//客户编号,
'customerName'=>$data['customer_name'] ,//客户名称,
'poCode'=>$data['poNo'] ,//po编号,
'platName'=>$data['platform_name']??'',//平台名称,
'platform_type' => $data['platform_type']??'0',//平台名称,
'platform_id'=>$data['platform_id']??0,//平台id,'
'workCode'=>$data['workNo'] ,//业务编号,
'zxCode'=>$data['zxNo'] ,//咨询单编号,
'goodNo'=>$data['good_code'] ,//商品编号,
'goodName'=>$data['good_name'] ,//商品名称,
'goodBrand'=>$data['brand'] ,//商品品牌,
'firstCat'=>$data['cat_name'][0]['cat_name'] ?? "" ,//一级分类,
'secCat'=>!isset($data['cat_name'][1]) ? '' : $data['cat_name'][1]['cat_name'] ,//二级分类,
'thirdCat'=>!isset($data['cat_name'][2]) ? '' : $data['cat_name'][2]['cat_name'] ,
//三级分类,
'catInfo'=>json_encode($data['cat_name'] , JSON_UNESCAPED_UNICODE) ,//分类详情,
'fundCode'=>isset($data['cat_name'][2]) ? $data['cat_name'][2]['fund_code'] : '',
'goodMaterial'=>'' ,//商品材质,
'goodUnit'=>$data['unit'] ,//商品单位,
'goodDesc'=>$data['cost_desc'] ,//工艺说明,
'goodType'=>$data['good_type'] ,//商品类型,
'goodModel'=>'' ,//商品型号,
'isStock'=>$data['is_stock'] ,//是否库存品,
'metalsType'=>$data['noble_metal'] ,//贵金属种类,
'weight'=>$data['good_weight'] ,//商品重量,
'goldPrice'=>$data['gold_price'] ,//贵金属单价,
'deliveryDay'=>$data['delivery_day'] ,//物流天数,
'workDay'=>$data['lead_time'] ,//工期,
'tax'=>$data['tax'] ,//税率,
'goodNum'=>$data['good_num'] ,//销售数量,
'goodPrice'=>$data['sale_price'] ,//产品单价,
'totalPrice'=>$data['total_price'] ,//货款总额,
'total_origin_price'=>$data['total_origin_price'] ,//成本总额,
'total_plan_price'=>$data['total_origin_price_plan'] ,//成本总额,
'sendNum'=>$data['send_num'] ,//已发货数量,
'wsendNum'=>$data['wsend_num'] ,//未发货数量,
'open_type'=>$data['open_type'] ,//开模类型',
'apay_fee'=>0 ,//已付款,
'pay_fee'=>0 ,//付款中
'wpay_fee'=>$data['total_price'] ,//未付款,
'inv_fee'=>0 ,//回票中
'ainv_fee'=>0 ,//已开票,
'winv_fee'=>$data['total_price'] ,//未开票,
'is_diff'=>$data['is_diff'] ,//是否有工差,
'sendType'=>$data['send_type'] ,//发货方式,
'sendStatus'=>$data['send_status'] ,//发货状态,
'pay_status'=>$data['total_price'] == 0 ? 3 : 1 ,//收款状态,1未付，2部分，3完结
'inv_status'=>$data['total_price'] == 0 ? 3 : 1 ,//开票状态,,1未付，2部分，3完结
'remark'=>'' ,//备注,
'cxCode'=>$data['oldCode'] ?? '' ,//备注,
'diff_weight'=>$data['diff_weight'] ,//工差重量,
'diff_fee'=>$data['diff_fee'] ,//工差金额,
'area'=>$data['customer_name'] ,//公司,
'customerAttr'=>$all_branch[$data['customer_code']]['parent']??"" ,//客户属性,
'branch'=>$all_branch[$data['customer_code']]['branch'] ?? '' ,//分公司,从客户表中查
'cgdNo'=>$data['cgdNo'] ,//采购单号,
'thNum'=>$data['th_num'] ,//退货数量,
'th_fee'=>$data['th_fee'] ,//退货金额,
'pay_source'=>$data['pay_source'] ?? '' ,//支付渠道,
'is_del'=>0 ,//是否删除,
'addtime'=>$date ,
'updatetime'=>$date ,
'inv_tag'=>0 ,//开票标签,
'pay_tag'=>0 ,//回款标签,
'inv_tag_fee'=>0 ,//开票票标签金额,
'pay_tag_fee'=>0 ,//回款标签金额,
];
}
if($data['cgdNo']!=''){
Db::name('cgd_info')->where(['sequenceNo'=>$data['cgdNo']])->update
(['qrdSend'=>$data['send_status']]);
}
}
else {
//已存在
$data['total_fee']=round($data['total_fee'],2) - $data['th_fee'] - $data['diff_fee'];
$exitReport=Db::name('report_code')->where('cgdNo' , $data['cgdNo'])->findOrEmpty();
$repostinsert=[
'qrdNo'=>$data['qrdNo'] ,
'cgder_id'=>$data['cgder_id'] ,
'cgder'=>$data['cgder'] ,
'supplierName'=>$data['supplier_name'] ,
'supplierNo'=>$data['supplierNo'] ,
'companyNo'=>$data['companyNo'] ,
'companyName'=>$data['companyName'] ,
'cgdNo'=>$data['cgdNo'] ,
];
if (empty($exitReport)) Db::name('report_code')->insert($repostinsert);
else Db::name('report_code')->where($exitReport)->update($repostinsert);
$exists_cgd=Db::name('cgd_info')
->whereIn('sequenceNo' , $data['cgdNo'])
->field('id,status')->findOrEmpty();
$data['qrdSend'] = Db::name('qrd_info')->where(['cgdNo'=>$data['cgdNo']])->value
('sendStatus',1);
if (!empty($exists_cgd)) {
//未对账，更新
if ($exists_cgd['status'] == 0) {
Db::name('cgd_info')
->where('id' , $exists_cgd['id'])
->update([
'name'=>$data['cgdNo'] ,//采购单名称',
'sequenceNo'=>$data['cgdNo'] ,//采购单编号',
'ownerName'=>$data['cgder'] ,//采购员名称',
'ownerid'=>$data['cgder_id'] ,//采购员id',
'department'=>$data['depart'] ,//部门名称',
'createdTime'=>$data['addtime'] ,//订单创建时间',
'cgdType'=>$data['order_type'] ,//采购单类型',
'cgdSource'=>$data['order_source'] ,//采购单来源',
'companyNo'=>$data['companyNo'] ,//业务公司编号',
'companyName'=>$data['companyName'] ,//业务公司',
'platform_name'=>$data['platform_name']??'',//平台名称,
'platform_id'=>$data['platform_id']??0,//平台id,'
'is_comon'=>isset($data['mainCode'])?2: ComonOrder::is_common($data['cgdNo']),
'cgdTime'=>$data['addtime'] ,//采购下单时间',
'bkCode'=>$data['bkcode'] ,//备库单编号',
'qrdCode'=>$data['qrdNo'] ,//确认单编号',
'goodNo'=>$data['spuCode'] ,//商品编号',
'goodName'=>$data['good_name'] ,//商品名称',
'goodType'=>$data['good_type'] ,//商品类型',
'goodBrand'=>$data['brand'] ,//商品品牌',
'goodModel'=>'' ,//商品型号',
'firstCat'=>$data['cat_name'][0]['cat_name'] ,//商品一级分类',
'secCat'=>!isset($data['cat_name'][1]) ? '' : $data['cat_name'][1]['cat_name'] ,//二级分类,
'thirdCat'=>!isset($data['cat_name'][2]) ? '' : $data['cat_name'][2]['cat_name'] ,
//三级分类,
'catInfo'=>json_encode($data['cat_name'] , JSON_UNESCAPED_UNICODE) ,//分类详情,
'fundCode'=>isset($data['cat_name'][2]) ? $data['cat_name'][2]['fund_code'] : '',
'goodMaterial'=>'' ,//商品材质',
'goodUnit'=>$data['unit'] ,//商品单位',
'goodDesc'=>$data['cost_desc'] ,//工艺说明',
'metalsType'=>$data['noble_metal'] ,//贵金属种类',
'weight'=>$data['weight'] ,//商品重量',
'goldPrice'=>$data['gold_price'] ,//贵金属实时金价',
'is_diff'=>$data['is_diff'] ,//是否有工差',
'deliveryDay'=>$data['delivery_day'] ,//物流天数',
'workDay'=>$data['lead_time'] ,//产品工期',
'tax'=>$data['tax'] ,//税点',
'barePrice'=>$data['nake_fee'] ,//裸价',
'markPrice'=>$data['mark_fee'] ,//加标费',
'packPrice'=>$data['pakage_fee'] ,//包装费',
'certPrice'=>$data['cert_fee'] ,//证书费',
'openPrice'=>$data['open_fee'] ,//开模费',
'costPrice'=>$data['teach_fee'] ,//工艺费',
'deliveryPrice'=>$data['delivery_fee'] ,//物流费',
'goodPrice'=>$data['good_price'] ,//成本合计/单价',
'isStock'=>$data['is_stock'] ,//是否库存品',
'goodNum'=>$data['good_num'] ,//下单数量',
'totalPrice'=>$data['total_fee'] ,//采购总货款',
'origin_total'=>$data['origin_total'] ,//采购总货款',
'supplierNo'=>$data['supplierNo'] ,//供应商编号',
'supplierName'=>$data['supplier_name'] ,//供应商名称',
'apay_fee'=>0 ,//已付款金额',
'wpay_fee'=>$data['total_fee'] ,//未付款金额',
'ainv_fee'=>0 ,//已开票金额',
'winv_fee'=>$data['total_fee'] ,//未开票金额',
'sendType'=>$data['send_type'] ,//发货方式',
'bkCreater'=>$data['bkcreater'] ,//备库申请人',
'sendStatus'=>$data['send_status'] ,//发货状态',
'wsendNum'=>$data['wsend_num'] ,//未发货数量',
'sendNum'=>$data['send_num'] ,//已发货数量',
'wareHouse'=>$data['wsm_code'] ,//仓库名称',
'wsmCode'=>$data['wsm_code'] ,//仓库编号',
'remark'=>'' ,//备注',
'cxCode'=>$data['oldCode'] ?? '' ,//备注,
'mainCode'=>$data['mainCode'] ?? '' ,//备注,
'cgd_status'=>$data['status'] ?? '0' ,//备注,
'pay_status'=>$data['total_fee'] == 0 ? 3 : 1 ,//付款情况',
'inv_status'=>$data['total_fee'] == 0 ? 3 : 1 ,//开票情况',
'diff_weight'=>$data['diff_weight'] ,//工差重量',
'diff_fee'=>$data['diff_fee'] ,//工差金额',
'thNum'=>$data['th_num'] ,//退货数量',
'th_fee'=>$data['th_fee'] ,//退货金额',
"open_type"=>$data['open_type'] ,//开模类型',
'check_rate'=>'' ,//修正后的税率',
'is_del'=>0 ,
'addtime'=>$date ,
'updatetime'=>$date ,
'supplier_origin_price'=>$data['supplier_origin_price'],//供应商采购成本
'cgd_supplier_code'=>$data['cgd_supplier_code'],//采购供应商编号
'cgd_supplier_name'=>$data['cgd_supplier_name'],//采购供应商编号
'cgd_apply_id'=>$data['cgd_apply_id'],//竞单人
'cgd_apply_name'=>$data['cgd_apply_name'],//竞单人
]
);
} else {
$wait_insert_data=[
'order_type'=>$result['order_type'] ,
'data'=>json_encode($result['data'] , JSON_UNESCAPED_UNICODE) ,
'orderCode'=>$data['cgdNo'] ,
'status'=>1 ,
];
Db::name('cgd_info')
->where('id' , $exists_cgd['id'])
->update([
'bkCode'=>$data['bkcode'] ,//备库单编号',
'qrdCode'=>$data['qrdNo'] ,//确认单编号',
'goodType'=>$data['good_type'] ,//商品类型',
'goodBrand'=>$data['brand'] ,//商品品牌',
'companyNo'=>$data['companyNo'] ,//业务公司编号',
'companyName'=>$data['companyName'] ,//业务公司',
'supplierNo'=>$data['supplierNo'] ,//供应商编号',
'supplierName'=>$data['supplier_name'] ,//供应商名称',
'goodModel'=>'' ,//商品型号',
'is_comon'=>isset($data['mainCode'])?2: ComonOrder::is_common($data['cgdNo']),
'goodMaterial'=>'' ,//商品材质',
'open_type'=>$data['open_type'] ,//开模类型',
'goodUnit'=>$data['unit'] ,//商品单位',
'goodDesc'=>$data['cost_desc'] ,//工艺说明',
'metalsType'=>$data['noble_metal'] ,//贵金属种类',
'weight'=>$data['weight'] ,//商品重量',
'platform_name'=>$data['platform_name']??'',//平台名称,
'platform_id'=>$data['platform_id']??0,//平台id,'
'is_diff'=>$data['is_diff'] ,//是否有工差',
'deliveryDay'=>$data['delivery_day'] ,//物流天数',
'workDay'=>$data['lead_time'] ,//产品工期',
'tax'=>$data['tax'] ,//税点',
'barePrice'=>$data['nake_fee'] ,//裸价',
'markPrice'=>$data['mark_fee'] ,//加标费',
'packPrice'=>$data['pakage_fee'] ,//包装费',
'certPrice'=>$data['cert_fee'] ,//证书费',
'openPrice'=>$data['open_fee'] ,//开模费',
'costPrice'=>$data['teach_fee'] ,//工艺费',
'deliveryPrice'=>$data['delivery_fee'] ,//物流费',
'origin_total'=>$data['origin_total'] ,//采购总货款',
'sendType'=>$data['send_type'] ,//发货方式',
'bkCreater'=>$data['bkcreater'] ,//备库申请人',
'sendStatus'=>$data['send_status'] ,//发货状态',
'qrdSend'=>$data['qrdSend'] ,//发货状态',
'wsendNum'=>$data['wsend_num'] ,//未发货数量',
'sendNum'=>$data['send_num'] ,//已发货数量',
'wareHouse'=>$data['wsm_code'] ,//仓库名称',
'wsmCode'=>$data['wsm_code'] ,//仓库编号',
'remark'=>'' ,//备注',
'cxCode'=>$data['oldCode'] ?? '' ,//备注,
'mainCode'=>$data['mainCode'] ?? '' ,//备注,
'cgd_status'=>$data['status'] ?? '0' ,//备注,
'check_rate'=>'' ,//修正后的税率',
'updatetime'=>$date ,
'supplier_origin_price'=>$data['supplier_origin_price'],//供应商采购成本
'cgd_supplier_code'=>$data['cgd_supplier_code'],//采购供应商编号
'cgd_supplier_name'=>$data['cgd_supplier_name'],//采购供应商编号
'cgd_apply_id'=>$data['cgd_apply_id'],//竞单人
'cgd_apply_name'=>$data['cgd_apply_name'],//竞单人
]
);
}
}
else {
//新增
$cgd_insert_data[]=[
'name'=>$data['cgdNo'] ,//采购单名称',
'sequenceNo'=>$data['cgdNo'] ,//采购单编号',
'ownerName'=>$data['cgder'] ,//采购员名称',
'ownerid'=>$data['cgder_id'] ,//采购员id',
'department'=>$data['depart'] ,//部门名称',
'createdTime'=>$data['addtime'] ,//订单创建时间',
'cgdType'=>$data['order_type'] ,//采购单类型',
'cgdSource'=>$data['order_source'] ,//采购单来源',
'companyNo'=>$data['companyNo'] ,//业务公司编号',
'companyName'=>$data['companyName'] ,//业务公司',
'cgdTime'=>$data['addtime'] ,//采购下单时间',
'bkCode'=>$data['bkcode'] ,//备库单编号',
'qrdCode'=>$data['qrdNo'] ,//确认单编号',
'goodNo'=>$data['spuCode'] ,//商品编号',
'goodName'=>$data['good_name'] ,//商品名称',
'goodType'=>$data['good_type'] ,//商品类型',
'goodBrand'=>$data['brand'] ,//商品品牌',
'goodModel'=>'' ,//商品型号',
'open_type'=>$data['open_type'] ,//开模类型',
'platform_name'=>$data['platform_name']??'',//平台名称,
'platform_id'=>$data['platform_id']??0,//平台id,'
'is_comon'=>isset($data['mainCode'])?2: ComonOrder::is_common($data['cgdNo']),
'firstCat'=>$data['cat_name'][0]['cat_name'] ?? "" ,//商品一级分类',
'secCat'=>!isset($data['cat_name'][1]) ? '' : $data['cat_name'][1]['cat_name'] ,//二级分类,
'thirdCat'=>!isset($data['cat_name'][2]) ? '' : $data['cat_name'][2]['cat_name'] ,
//三级分类,
'catInfo'=>json_encode($data['cat_name'] , JSON_UNESCAPED_UNICODE) ,//分类详情,
'fundCode'=>isset($data['cat_name'][2]) ? $data['cat_name'][2]['fund_code'] : '',
'goodMaterial'=>'' ,//商品材质',
'goodUnit'=>$data['unit'] ,//商品单位',
'goodDesc'=>$data['cost_desc'] ,//工艺说明',
'metalsType'=>$data['noble_metal'] ,//贵金属种类',
'weight'=>$data['weight'] ,//商品重量',
'goldPrice'=>$data['gold_price'] ,//贵金属实时金价',
'is_diff'=>$data['is_diff'] ,//是否有工差',
'deliveryDay'=>$data['delivery_day'] ,//物流天数',
'workDay'=>$data['lead_time'] ,//产品工期',
'tax'=>$data['tax'] ,//税点',
'barePrice'=>$data['nake_fee'] ,//裸价',
'markPrice'=>$data['mark_fee'] ,//加标费',
'packPrice'=>$data['pakage_fee'] ,//包装费',
'certPrice'=>$data['cert_fee'] ,//证书费',
'openPrice'=>$data['open_fee'] ,//开模费',
'costPrice'=>$data['teach_fee'] ,//工艺费',
'deliveryPrice'=>$data['delivery_fee'] ,//物流费',
'goodPrice'=>$data['good_price'] ,//成本合计/单价',
'isStock'=>$data['is_stock'] ,//是否库存品',
'goodNum'=>$data['good_num'] ,//下单数量',
'totalPrice'=>$data['total_fee'] ,//采购总货款',
'origin_total'=>$data['origin_total'] ,//采购总货款',
'supplierNo'=>$data['supplierNo'] ,//供应商编号',
'supplierName'=>$data['supplier_name'] ,//供应商名称',
'apay_fee'=>0 ,//已付款金额',
'wpay_fee'=>$data['total_fee'] ,//未付款金额',
'ainv_fee'=>0 ,//已开票金额',
'winv_fee'=>$data['total_fee'] ,//未开票金额',
'sendType'=>$data['send_type'] ,//发货方式',
'bkCreater'=>$data['bkcreater'] ,//备库申请人',
'sendStatus'=>$data['send_status'] ,//发货状态',
'qrdSend'=>$data['qrdSend'] ,
'wsendNum'=>$data['wsend_num'] ,//未发货数量',
'sendNum'=>$data['send_num'] ,//已发货数量',
'wareHouse'=>$data['wsm_code'] ,//仓库名称',
'wsmCode'=>$data['wsm_code'] ,//仓库编号',
'remark'=>'' ,//备注',
'pay_status'=>$data['total_fee'] == 0 ? 3 : 1 ,//付款情况',
'inv_status'=>$data['total_fee'] == 0 ? 3 : 1 ,//开票情况',
'diff_weight'=>$data['diff_weight'] ,//工差重量',
'diff_fee'=>$data['diff_fee'] ,//工差金额',
'thNum'=>$data['th_num'] ,//退货数量',
'th_fee'=>$data['th_fee'] ,//退货金额',
'check_rate'=>'' ,//修正后的税率',
'cgd_status'=>$data['status'] ?? '0' ,//备注,
'cxCode'=>$data['oldCode'] ?? '' ,//备注,
'mainCode'=>$data['mainCode'] ?? '' ,//备注,
'is_del'=>0 ,
'addtime'=>$date ,
'updatetime'=>$date ,
'supplier_origin_price'=>$data['supplier_origin_price'],//供应商采购成本
'cgd_supplier_code'=>$data['cgd_supplier_code'],//采购供应商编号
'cgd_supplier_name'=>$data['cgd_supplier_name'],//采购供应商编号
'cgd_apply_id'=>$data['cgd_apply_id'],//竞单人
'cgd_apply_name'=>$data['cgd_apply_name'],//竞单人
];
}
}
if ($qrd_insert_data) Db::name('qrd_info')->insertAll($qrd_insert_data);
if ($cgd_insert_data) Db::name('cgd_info')->insertAll($cgd_insert_data);
if ($wait_insert_data) Db::name('caixiao_wait')->insert($wait_insert_data);
Db::name('caixiao_data')->where('uniqkey' , $result['uniqkey'])->update(['status'=>0]);
$output->writeln("[$date]:{$result['id']}处理成功");
} Cache::store('redis')->set('JsHandle',0,180);
Db::commit();
} catch (Exception $exception) {
Cache::store('redis')->set('JsHandle',0,180);
Db::rollback();
$output->writeln($exception->getMessage());
}
}
Cache::store('redis')->set('JsHandle',0,180);
Db::rollback();
}
}