<?php
namespace app\admin\controller;
use app\admin\model\ActionLog;
use app\admin\model\DataGroup as DataGroupModel;
use app\admin\model\GoodLog;
use app\admin\model\GoodStockInfo;
use app\admin\model\ProcessOrder;
use think\App;
use think\Exception;
use think\facade\Db;
use think\facade\Validate;
//售后
class After extends Base
{
public function __construct(App $app)
{
parent::__construct($app);
}
//新建售后申请单
public function create()
{
$param = $this->request->only(['outCode', 'errorCode', 'remark' => '', 'is_receive', 'num', 'except_code' => '', 'img'], 'post', 'trim');
$val = Validate::rule([
'outCode' => 'require',
'errorCode' => 'require',
'is_receive' => 'require|in:0,1',
'num' => 'requireIf:is_receive,1',
'except_code' => 'require',
'img' => 'require',
]);
if ($val->check($param) == false) return json_show(1004, $val->getError());
// $outCode = isset($this->post['outCode']) &&$this->post['outCode']!=''?trim($this->post['outCode']) :"";
// if($outCode==''){
// return error_show(1004,"参数outCode 不能为空");
// }
$orderout = Db::name("order_out")
->field('id,orderCode,wsm_code,send_num,order_type')
->where(["outCode" => $param['outCode'], 'is_del' => 0])
->findOrEmpty();
if (empty($orderout)) return error_show(1005, "未找到发货单数据");
$after_num = Db::name("order_return")
->where(["orderCode" => $orderout['orderCode'], "outCode" => $param['outCode']])
->where("status", "not in", [5, 6, 8])
->sum("error_num");
$th_num = Db::name("order_back")
->where(["orderCode" => $orderout['orderCode'], "outCode" => $param['outCode'], "is_del" => 0])
->where("status", "<", 4)
->sum("return_num");
if ($th_num != 0 || $after_num != 0) return error_show(1005, "存在售后或售后退货未结束流程");
$oder = Db::name("sale")
->where(["orderCode" => $orderout['orderCode'], "is_del" => 0])
->findOrEmpty();
if (empty($oder)) return error_show(1005, "未找到订单数据");
if ($oder['order_type'] != 1) {
$wsm = Db::name("warehouse_info")
->where(["wsm_code" => $orderout['wsm_code']])
->findOrEmpty();
if (empty($wsm)) return error_show(1005, "未找到仓库数据");
// $cgder =$wsm['contactor_name'] ??'';
// $cgderid =$wsm['contactor'] ??0;
}
// else{
// $roleArr=\think\facade\Config::get("app");
// $kuguan = Db::name("user_role")->where(["roleid"=>$roleArr['wsm_cgder_role'],"is_del"=>0])->column("uid");
// if(empty($kuguan)){
// return error_show(1005,"未找到仓库管理员数据");
// }
// $userinfo = Db::name("dapart_user")
// $cgder =$wsm['contactor_name'] ??'';
// $cgderid =$wsm['contactor'] ??0;
// }
if ($oder['order_type'] == 3) {
$goon = Db::name("good_zixun")
->where(["spuCode" => $oder['good_code'], "is_del" => 0])
->findOrEmpty();
} else {
$goon = Db::name('good_platform')
->alias('a')
->field("b.creater,b.createrid,b.supplierNo")
->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $oder['skuCode']])
->findOrEmpty();
}
// $errorCode = isset($this->post['errorCode']) &&$this->post['errorCode']!=''?trim($this->post['errorCode']) :"";
// if($param['outCode']==''){
// return error_show(1004,"参数errorCode 不能为空");
// }
$error = Db::name('result_info')
->where(["result_code" => $param['errorCode'], "is_del" => 0])
->findOrEmpty();
if (empty($error)) return error_show(1005, "未找到退货原因数据");
$userCommon = new \app\admin\common\User();
$supplier = $userCommon->handle('sInfo', ['code' => $goon['supplierNo']]);
if (!isset($supplier['code']) || $supplier['code'] != 0) return json_show($supplier['code'], $supplier['message'], $supplier['data']);
$supplier = $supplier['data'];
// $supplier =Db::name("supplier")->where(["code"=>$goon['supplierNo']])->find();
// if($supplier==false){
// return error_show(1005,"未找到商品供应商数据");
// }
// $remark =isset($this->post['remark']) &&$this->post['remark']!=''?trim($this->post['remark']) :"";
// $is_receive =isset($this->post['is_receive']) &&$this->post['is_receive']!==''?intval($this->post['is_receive']):"";
// if($is_receive===""){
// return error_show(1004,"参数 is_receive 不能为空");
// }
$num = $param['is_receive'] == 1 ? $param['num'] : $orderout['send_num'];
// if($param['is_receive']==0){
// $num=$orderout['send_num'];
// }else{
// $num =isset($this->post['num']) &&$this->post['num']!=''?intval($this->post['num']) :"";
// if($num==""){
// return error_show(1004,"参数 num 不能为空或零");
// }
// }
$thnum = Db::name("order_back")
->where(["orderCode" => $orderout['orderCode'], "outCode" => $param['outCode'], "is_del" => 0])
->where("status", "=", 4)
->sum("return_num");
if ($num > ($orderout['send_num'] - $thnum)) return error_show(1004, "可用售后数量不足");
// $except_code =isset($this->post['except_code']) &&$this->post['except_code']!=''?trim($this->post['except_code']) :"";
// $img = isset($this->post['img']) &&$this->post['img']!=''?trim($this->post['img']) :"";
// $token = isset($this->post['token'])&&$this->post['token']!='' ? trim($this->post['token']):"";
// if($token==''){
// return error_show(105,"参数token不能为空");
// }
// $user =GetUserInfo($token);
// if(empty($user)||$user['code']!=0){
// return error_show(102,"申请人数据不存在");
// }
$rm = $this->uid;//isset($user["data"]['id']) ? $user["data"]['id'] : "";
$ri = $this->uname;//isset($user["data"]['nickname']) ? $user["data"]['nickname'] : "";
$returnCode = makeNo("RS");
Db::startTrans();
try {
$in = [
"returnCode" => $returnCode,
"outCode" => $param['outCode'],
"orderCode" => $oder['orderCode'],
"good_code" => $oder['good_code'],
"good_name" => $oder['good_name'],
"customer_code" => $oder['customer_code'],
"apply_id" => $rm,
"apply_name" => $ri,
"cgder" => $wsm['contactor_name'] ?? '',
"cgderid" => $wsm['contactor'] ?? 0,
"person" => $supplier['person'] ?? '',
"person_id" => $supplier['personid'] ?? 0,
'total_num' => $orderout['send_num'],
"error_code" => $param['errorCode'],
"error_num" => $num,
"error_img" => is_array($param['img']) ? implode(',', $param['img']) : $param['img'],
"error_msg" => $error['result'],
"error_remark" => $param['remark'],
"is_receive" => $param['is_receive'],
"remark" => '',
"except_code" => $param['except_code'],
"order_type" => $orderout['order_type'],
"status" => 1,
"is_del" => 0,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$create = Db::name("order_return")->insert($in, true);
$orde = ["order_code" => $returnCode, "status" => $in['status'], "action_remark" => '', "action_type" => "create"];
ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], $orde, 'SHD', 1, $orde);
if ($create > 0) {
//维护台账
// Db::name('standing_book')
// ->whereFindInSet('outCode', $param['outCode'])
// ->update([
// 'returnCode' => $returnCode,
// 'updatetime' => date("Y-m-d H:i:s")
// ]);
Db::execute("UPDATE `wsm_standing_book` SET `returnCode`=CONCAT(IFNULL(`returnCode`,''),',{$returnCode}'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE FIND_IN_SET('{$param['outCode']}',`outCode`)");
//当状态为1(即待业务审核)时，要将待办数据推给以下角色的用户
// $user = Db::name('user_role')
// ->where([
// ['is_del', '=', 0],
// ['roleid', 'in', [12, 13, 17, 28]],//12客服负责人,13项目负责人,17平台负责人,28网络负责人
// ['status', '=', 1],
// ])->column('uid');
//筛选符合数据权限的用户
// $temp = getUserIdsByShare('', $in['apply_id']);
// $user = array_intersect($user, $temp);
$process = ["order_code" => $returnCode, "order_id" => $create, "order_status" => $in['status'], "order_type" => 'SHD', "before_status" => 0, 'holder_id' => $in['apply_id']];
ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);
Db::commit();
return app_show(0, "售后申请单新建成功", ["returnCode" => $returnCode]);
}
Db::rollback();
return error_show(1005, "售后申请单新建失败");
} catch (Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage());
}
}
//售后申请单列表
public function list()
{
$param = $this->request->only([
'page' => 1,
'size' => 10,
'relaComNo' => '',
'returnCode' => '',
'outCode' => '',
'status' => '',
'order_type' => '',
'orderCode' => '',
'good_code' => '',
'good_name' => '',
'customer_code' => '',
'except_code' => '',
'apply_name' => '',
'start' => '',
'end' => '',
'company_name' => '',
'supplierNo' => '',
'order_source' => '',
], 'post', 'trim');
$where = [['a.is_del', "=", 0]];
if ($param['relaComNo'] !== '') $where[] = ['c.supplierNo', "=", $param['relaComNo']];
if ($param['returnCode'] !== '') $where[] = ['a.returnCode', "like", "%{$param['returnCode']}%"];
if ($param['outCode'] !== '') $where[] = ['a.outCode', "like", "%{$param['outCode']}%"];
if ($param['status'] !== '') $where[] = ['a.status', "=", $param['status']];
if ($param['order_type'] !== "") $where[] = ['a.order_type', "=", $param['order_type']];
if ($param['orderCode'] != "") $where[] = ['a.orderCode', "like", "%{$param['orderCode']}%"];
if ($param['good_code'] != "") $where[] = ['a.good_code', "like", "%{$param['good_code']}%"];
if ($param['good_name'] != "") $where[] = ['a.good_name', "like", "%{$param['good_name']}%"];
if ($param['customer_code'] != "") $where[] = ['a.customer_code', "like", "%{$param['customer_code']}%"];
if ($param['except_code'] != "") $where[] = ['a.except_code', "=", $param['except_code']];
if ($param['apply_name'] != "") $where[] = ['a.apply_name', "like", "%{$param['apply_name']}%"];
if ($param['start'] !== "") $where[] = ['a.addtime', ">=", $param['start']];
if ($param['end'] !== "") $where[] = ['a.addtime', "<=", $param['end']];
if ($param['order_source'] !== "") $where[] = ['c.order_source', "=", $param['order_source']];
if ($param['supplierNo'] !== "") {
$spuCode = Db::name('good_basic')
->where(['is_del' => 0, 'supplierNo' => $param['supplierNo']])
->column('spuCode');
$where[] = ['c.good_code', "in", $spuCode];
}
$condition = [];
//只有level2的账号过滤数据权限
if ($this->level == 2) {
$hand = resign_hand_user($this->uid, 0);
$role = $this->checkDataShare();
if (!empty($role[DataGroupModel::$type_全部])) {
$arr = array_unique(array_merge($hand, $role[DataGroupModel::$type_全部]));
$condition[] = ["a.person_id", "in", $hand];
$condition[] = ["a.apply_id", "in", $arr];
$condition[] = ["a.cgderid", "in", $hand];
}
}
//level3账号不允许看到库存品订单
if ($this->level == 3) $where[] = ['c.is_stock', '<>', 1];
// $condition .="a.cgderid in {$hand} or a.person_id in {$hand} or a.apply_id in ("
// .implode(',',$role[DataGroupModel::$type_全部]).")";
if ($param['company_name'] !== "") $where[] = ["a.apply_id", 'in', get_company_item_user_by_name($param['company_name'])];
$count = Db::name("order_return")
->alias("a")
->leftJoin("order_returninfo b", "a.returnCode=b.returnCode")
->leftJoin("sale c", "c.orderCode=a.orderCode AND c.is_del=0")
->where($where)
->where(function ($query) use ($condition) {
$query->whereOr($condition);
})
->count('a.id');
// $total = ceil($count/$size);
// $page = $total>=$page ? $page :$total;
$list = Db::name("order_return")
->alias("a")
->leftJoin("order_returninfo b", "a.returnCode=b.returnCode")
->leftJoin("sale c", "c.orderCode=a.orderCode AND c.is_del=0")
->where($where)
->where(function ($query) use ($condition) {
$query->whereOr($condition);
})
->field("a.*,b.return_wsm,b.contactor,b.mobile,b.addr,b.addr_code,b.post_code,b.post_company,b.post_fee,b.gys_remark,c.order_source,c.supplierNo")
->page($param['page'], $param['size'])
->order("a.addtime desc")
->select()
->toArray();
//申请人及部门
$all_createrid = array_column($list, 'apply_id');
$item = get_company_name_by_uid($all_createrid);
//获取客户信息
// $all_customer_code = array_column($list, 'customer_code');
$userCommon = new \app\admin\common\User();
$customer_ = $userCommon->handle('getCodeAndName', ['code' => array_unique(array_merge(array_column($list, 'customer_code'), array_column($list, 'supplierNo')))]);
$data = [];
foreach ($list as $value) {
$value['customer_name'] = $customer_['data'][$value['customer_code']] ?? '';
$value['supplierName'] = $customer_['data'][$value['supplierNo']] ?? '';
$value['company_name'] = $item[$value['apply_id']] ?? '';
//是否具有编辑权限
// $value['is_allow_update'] = 0;
// if (in_array($this->roleid, [1, 33]) || in_array($value['apply_id'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;
$data[] = $value;
}
return app_show(0, "获取成功", ['list' => $data, "count" => $count]);
}
/**
* @return \think\response\Json|void
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function info()
{
$bkcode = $this->request->post('returnCode', '', 'trim');//isset($this->post['returnCode']) && $this->post['returnCode'] != "" ? trim($this->post['returnCode']) : "";
if ($bkcode == "") return error_show(1005, "参数returnCode 不能为空");
$info = Db::name("order_return")
->alias("a")
->leftJoin("order_returninfo b", "a.returnCode=b.returnCode")
->field("a.*,b.return_wsm,b.contactor,b.mobile,b.addr,b.addr_code,b.post_code,b.post_company,b.post_fee,b.gys_remark")
->where(['a.returnCode' => $bkcode])
->findOrEmpty();
if (empty($info)) return error_show(1005, "未找到售后数据");
$orderinfo = Db::name("sale")->where(["orderCode" => $info["orderCode"]])->findOrEmpty();
$info['origin_price'] = $orderinfo['origin_price'];
$info['order_type'] = $orderinfo['order_type'];
$info['order_source'] = $orderinfo['order_source'];
$info['is_stock'] = $orderinfo['is_stock'];
$info['customer_code'] = $orderinfo['customer_code'];
$info['companyNo'] = $orderinfo['supplierNo'];
$info['sale_price'] = $orderinfo['sale_price'];
$info['total_price'] = sprintf("%1\$.2f", $orderinfo['sale_price'] * $info['error_num']);
if ($orderinfo['order_type'] == 3) {
$goon = Db::name("good_zixun")
->field('cat_id,supplierNo')
->where(["spuCode" => $orderinfo['good_code'], "is_del" => 0])
->findOrEmpty();
} else {
$goon = Db::name('good_platform')
->alias('a')
->field('b.cat_id,b.supplierNo')
->join('good b', 'b.spuCode=a.spuCode', 'left')
->where(['a.skuCode' => $orderinfo['skuCode']])
->findOrEmpty();
}
if (empty($goon)) return error_show(1003, "未找到商品数据");
$info['supplierNo'] = $goon['supplierNo'];
$int = isset($goon['cat_id']) && $goon['cat_id'] != 0 ? made($goon['cat_id']) : [];
$addcode = '';
if ($info['addr_code'] != "") {
list($a, $b, $c) = explode(",", $info['addr_code']);
$addcode = json_encode(["provice_code" => $a, "city_code" => $b, "area_code" => $c]);
}
$info["addr_cn"] = GetAddr($addcode);
// $info["addr_code"]=json_decode($addcode,true);
$out = Db::name("order_out")->where(["outCode" => $info['outCode'], "is_del" => 0])->find();
$info['out_num'] = isset($out['send_num']) ? $out['send_num'] : '';
// $customer = Db::name("customer_info")->where(["companyNo"=>$info['customer_code']])->find();
$wsmcode = [];
$info['wsm_supplier'] = $info['customer_name'] = '';
if ($info['return_wsm'] != '') {
$wsmcode = Db::name("warehouse_info")
->alias("a")
// ->leftJoin("supplier b", "a.supplierNo=b.code")
->where(["a.wsm_code" => $info['return_wsm']])
->field("a.name as wsm_name,a.wsm_code,a.contactor_name,a.position,a.mobile,a.addrs_code,a.addr,a.companyNo,a.supplierNo")
->find();
}
$userCommon = new \app\admin\common\User();
$names = $userCommon->handle('getCodeAndName', ['code' => [
$wsmcode['supplierNo'] ?? '',
$wsmcode['companyNo'] ?? '',
$info['customer_code'],
$info['companyNo'],
$info['supplierNo'],
]]);
if ($info['return_wsm'] != '') {
$info['wsm_supplierNo'] = $wsmcode['supplierNo'] ?? "";
$info['wsm_supplier'] = $names['data'][$wsmcode['supplierNo']] ?? '';//isset($wsmcode['name']) ? $wsmcode['name'] : "";
$info['wsm_customer_name'] = $names['data'][$wsmcode['companyNo']] ?? '';//isset($customer['company']) ? trim($customer['company']) : '';
$info['wsm_customer_code'] = $wsmcode['companyNo'] ?? "";//isset($customer['companyNo']) ? trim($customer['companyNo']) : '';
$info['wsm_code'] = isset($wsmcode['wsm_code']) ? $wsmcode['wsm_code'] : "";
$info['wsm_name'] = isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name'] : "";
}
// $customer = [];
// if (isset($orderinfo['supplierNo']) && $orderinfo['supplierNo'] != '') {
// $customer = Db::name("business")->field('id,company,companyNo')->where(["companyNo" => $orderinfo['supplierNo']])->find();
// }
$info['customer_name'] = $names['data'][$info['customer_code']] ?? '';
$info['companyName'] = $names['data'][$info['companyNo']] ?? '';
$info['supplierName'] = $names['data'][$info['supplierNo']] ?? '';
$info['can'] = $int;
//仓库的联系人、职位、电话、省市区和地址
isset($wsmcode['contactor_name']) ? $info['contactor'] = $wsmcode['contactor_name'] : '';//联系人
isset($wsmcode['mobile']) ? $info['mobile'] = $wsmcode['mobile'] : '';//电话
isset($wsmcode['addrs_code']) ? $info['addr_code'] = $wsmcode['addrs_code'] : '';//省市区
isset($wsmcode['addr']) ? $info['addr'] = $wsmcode['addr'] : '';//和地址
// $info['position'] = $wsmcode['position'];//职位
// $info['mobile'] = $wsmcode['mobile'];//电话
// $info['addrs_code'] = json_decode($wsmcode['addrs_code'], true);//省市区编码
// $info['addr'] = $wsmcode['addr'];//地址
$info['spuCode'] = $orderinfo['good_code'];
$info['skuCode'] = $orderinfo['skuCode'];
$info['return_tag'] = $info['return_tag'] == 0 ? "" : $info['return_tag'];//地址
$info['is_th'] = $info['is_th'] == 0 ? "" : $info['is_th'];//地址
return app_show(0, "获取成功", $info);
}
//售后申请单 审核
//申请单状态:1待业务审核,2待采购审核,3待设置仓库(该节点废除),4待客户退货,5售后已完成,6业务已驳回,7采购已驳回(该节点废除),8申请已取消,9供应商审核,10业务公司修改待供应商确认
public function status()
{
try {
$param = $this->request->only([
'returnCode',
'status',
'remark' => '',
'wsm_code'=>'',
'contactor'=>'',
'mobile'=>'',
'addr_code'=>'',
'addr'=>'',
], 'post', 'trim');
$val = Validate::rule([
'returnCode' => 'require',
'status' => 'require|number|in:1,2,4,5,6,9,10',
'remark' => 'requireIf:status,6|requireIf:status,2|requireIf:status,10',
// 'contactor|收货人' => 'requireIf:status,4',
// 'mobile|联系电话' => 'requireIf:status,4',
// 'addr_code|省市区编码' => 'requireIf:status,4',
// 'addr|退货地址' => 'requireIf:status,4',
]);
if ($val->check($param) == false) throw new Exception($val->getError());
// $bkcode = isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
// if($bkcode==""){
// return error_show(1005,"参数returnCode 不能为空");
// }
$info = Db::name("order_return")
->where(['is_del' => 0, 'returnCode' => $param['returnCode']])
->findOrEmpty();
if (empty($info)) throw new Exception('未找到售后数据');
if ($info['status'] == 6) throw new Exception('业务已驳回，无法操作');
if ($info['status'] == 5) throw new Exception('售后已完成，无法操作');
if ($info['status'] == 8) throw new Exception('申请已取消，无法操作');
switch ($info['status']) {
case 1:
if (in_array($param['status'], [6, 9]) == false) throw new Exception('选项错误');
break;
case 9:
if (in_array($param['status'], [2, 4]) == false) throw new Exception('选项错误');
// if ($this->level != 3) throw new Exception('当前状态下只能由供应商账号操作');
if ($param['status'] == 4) {
if ($param['contactor'] == '') throw new Exception('收货人不能为空');
if ($param['mobile'] == '') throw new Exception('联系电话不能为空');
if ($param['addr_code'] == '') throw new Exception('省市区编码不能为空');
if ($param['addr'] == '') throw new Exception('退货地址不能为空');
}
break;
case 2:
if (in_array($param['status'], [10, 4]) == false) throw new Exception('选项错误');
if ($param['status'] == 4) {
if ($param['wsm_code'] == '') throw new Exception('请填写退回仓库');
else {
$ware = Db::name('warehouse_info')
->field('contactor_name contactor,mobile,addr,addrs_code addr_code')
->where(['wsm_code' => $param['wsm_code'], 'is_del' => 0])
->findOrEmpty();
if (empty($ware)) throw new Exception('该仓库不存在');
else $param = array_merge($param, $ware);
}
}
break;
case 10:
if (in_array($param['status'], [2, 4]) == false) throw new Exception('选项错误');
if ($param['status'] == 4) {
if ($param['contactor'] == '') throw new Exception('收货人不能为空');
if ($param['mobile'] == '') throw new Exception('联系电话不能为空');
if ($param['addr_code'] == '') throw new Exception('省市区编码不能为空');
if ($param['addr'] == '') throw new Exception('退货地址不能为空');
}
break;
}
//当处于以下节点时，level2账号必须是供应商负责人操作，level3账号不做限制
if(in_array($info['status'],[9,10]) && ($this->level==2) && ($this->uid!=$info['person_id'])) return json_show(1004,'您不是供应商负责人，此时无权操作');
// $param['status'] = isset($this->post['status']) && $this->post['status']!=="" ? intval($this->post['status']) :"";
// if($param['status']===""){
// return error_show(1005,"参数status 不能为空");
// }
// $remark = isset($this->post['remark'])&&$this->post['remark']!=''?trim($this->post['remark']):"";
if ($param['remark'] != '') $info['remark'] = $param['remark'];
// if($param['status']==3 && $info['is_receive']==1){
// $post =isset($this->post['is_post'])&&$this->post['is_post']!==""? intval($this->post['is_post']):"";
// if($post===""){
// return error_show(1005,"参数is_post不能为空");
// }
// $info['is_post']=$post;
// $return_tag =isset($this->post['return_tag'])&&$this->post['return_tag']!==""? intval($this->post['return_tag']):"";
// if($return_tag===""){
// return error_show(1005,"参数return_tag不能为空");
// }
// $info['return_tag']=$return_tag;
// $is_th =isset($this->post['is_th'])&&$this->post['is_th']!==""? intval($this->post['is_th']):"0";
// $info['is_th']=$is_th;
// }
// $param['status'] = $info['order_status']==1&&$info['order_type']==1 && $param['status']==1?4:$param['status'];
Db::startTrans();
try {
$date = date('Y-m-d H:i:s');
$action_log_user = ['id' => $this->uid, 'nickname' => $this->uname];
//如果是小循环，增加次数
if ($info['status'] == 10 && $param['status'] == 2) $info['loop_total'] += 1;
//判断 退回供应商 or 退回业务公司
if ($info['status'] == 9) {
if ($param['status'] == 4) $info['return_tag'] = 1;
else $info['return_tag'] = 2;
}
$var = $info['status'];
$info['status'] = $param['status'];
$info['updatetime'] = $date;
$up = Db::name("order_return")->save($info);
if ($up) {
//售后完成
if ($param['status'] == 5 && $info['is_receive'] == 0) {
$orde = Db::name("order_out")
->field('id,outCode,status')
->where(["outCode" => $info['outCode'], "is_del" => 0])
->findOrEmpty();
if (empty($orde)) throw new Exception('未找到出库单数据');
$sale = Db::name("sale")
->field('id,th_num,th_fee,sale_price,good_code,good_name,cat_id')
->where(['is_del' => 0, "orderCode" => $info['orderCode']])
->findOrEmpty();
if (empty($sale)) throw new Exception('未找到销售单数据');
$od_status = $orde['status'];
$orde['status'] = 4;
$orde['updatetime'] = $date;
$out = Db::name("order_out")->save($orde);
if ($out == false) throw new Exception("发货单更新失败");
$order = ["order_code" => $orde['outCode'], "status" => $od_status, "action_remark" => '', "action_type" => "edit"];
ActionLog::logAdd($action_log_user, $order, "CKD", $orde['status'], $this->post);
$process = ["order_code" => $orde['outCode'], "order_id" => $orde['id'], "order_status" => $orde['status'], "order_type" => "CKD", "before_status" => $od_status];
ProcessOrder::AddProcess($action_log_user, $process);
$sale['th_num'] += $info['error_num'];
$sale['th_fee'] += round($info['error_num'] * $sale['sale_price'], 2);
$sale['updatetime'] = $date;
$sup = Db::name("sale")->save($sale);
if ($sup == false) throw new Exception("销售单更新失败");
$data = [
"orderCode" => $info['orderCode'],
"th_type" => 2,
"th_num" => $info['error_num'],
"th_fee" => round($info['error_num'] * $sale['sale_price'], 2),
"thCode" => $info['returnCode'],
"spuCode" => $sale['good_code'],
"good_name" => $sale['good_name'],
"cat_id" => $sale['cat_id'],
"apply_id" => $info['apply_id'],
"apply_name" => $info['apply_name'],
"addtime" => $date,
"status" => 1,
"is_del" => 0
];
$inse = Db::name("th_data")->insert($data);
if ($inse == false) throw new Exception('退回单更新失败');
}
//维护退货地址的收货信息
if($info['is_receive'] == 1 && $param['status'] == 4){
$tmp = Db::name('order_returninfo')
->field('id')
->where('returnCode',$param['returnCode'])
->findOrEmpty();
if(empty($tmp)){
//新增
Db::name('order_returninfo')
->insert([
'returnCode'=>$param['returnCode'],
'return_wsm'=>$param['wsm_code'],
'contactor'=>$param['contactor'],
'mobile'=>$param['mobile'] ,
'addr'=>$param['addr'],
'addr_code'=>$param['addr_code'],
'addtime'=>$date
]);
}else{
Db::name('order_returninfo')
->where('id',$tmp['id'])
->update([
'return_wsm'=>$param['wsm_code'],
'contactor'=>$param['contactor'],
'mobile'=>$param['mobile'] ,
'addr'=>$param['addr'],
'addr_code'=>$param['addr_code'],
]);
}
}
$order = ["order_code" => $info['returnCode'], "status" => $var, "action_remark" => '', "action_type" => "edit"];
ActionLog::logAdd($action_log_user, $order, "SHD", $info['status'], $this->post);
// switch ($param['status']) {
// //待采购审核
// case 2:
// $process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var, 'wait_id' => $info['person_id'], 'wait_name' => $info['person'], 'holder_id' => $info['person_id']];
// break;
//
// //待设置仓库
// case 3:
// $process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var, 'wait_id' => $info['cgderid'], 'wait_name' => $info['cgder'], 'holder_id' => $info['cgderid']];
// break;
//
// //待客户退货
// case 4:
// $process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var, 'wait_id' => $info['apply_id'], 'wait_name' => $info['apply_name'], 'holder_id' => $info['apply_id']];
// break;
//
// default:
// $process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var, 'holder_id' => $info['apply_id']];
// }
// if (in_array($param['status'], [2, 3])) $process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var, 'wait_id' => $info['cgderid'], 'wait_name' => $info['cgder'],'holder_id'=>$info['cgderid']];
// elseif ($param['status'] == 4) $process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var, 'wait_id' => $info['apply_id'], 'wait_name' => $info['apply_name'],'holder_id'=>$info['apply_id']];
// else $process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var,'holder_id'=>$info['apply_id']];
$process = ["order_code" => $info['returnCode'], "order_id" => $info['id'], "order_status" => $param['status'], "order_type" => "SHD", "before_status" => $var, 'wait_id' => $info['person_id'], 'wait_name' => $info['person'], 'holder_id' => $info['person_id']];
ProcessOrder::AddProcess($action_log_user, $process);
Db::commit();
return app_show(0, "更新成功");
}
throw new Exception('更新失败');
} catch (Exception $e) {
Db::rollback();
throw new Exception($e->getMessage() . '|' . $e->getFile() . '|' . $e->getLine());
}
} catch (Exception $exception) {
return json_show(1005, $exception->getMessage() . '|' . $exception->getFile() . '|' . $exception->getLine());
}
}
//设置仓库
public function setWsm(){
$bkcode = isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
if($bkcode==""){
return error_show(1005,"参数returnCode 不能为空");
}
$info = Db::name("order_return")->where(['returnCode'=>$bkcode])->find();
if(empty($info)){
return error_show(1005,"未找到售后数据");
}
if($info['status']!=3){
return error_show(1005,"采购主管未审核无法设置退回仓库");
}
$wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code']!="" ? trim($this->post['wsm_code']) :"";
$warehouse=[];
if($info['return_tag']==2) {
if($wsm_code==""){
return error_show(1005,"参数 wsm_code 不能为空");
}
$warehouse =Db::name("warehouse_info")->where(["wsm_code"=>$wsm_code])->find();
if($warehouse==false){
return error_show(1005,"仓库数据未找到");
}
$wareaddr =Db::name("warehouse_addr")->where(["wsm_code"=>$wsm_code,"is_del"=>0,"status"=>1])->find();
}
$addrcode=isset($this->post['addr_code'])&&$this->post['addr_code']!=""?$this->post['addr_code']:"";
if($addrcode==""){
return error_show(1005,"参数 addr_code 不能为空");
}
$addr=isset($this->post['addr'])&&$this->post['addr']!=""?trim($this->post['addr']):"";
if($addr==""){
return error_show(1005,"参数 addr 不能为空");
}
$mobile=isset($this->post['mobile'])&&$this->post['mobile']!=""?trim($this->post['mobile']):"";
if($mobile==""){
return error_show(1005,"参数 mobile 不能为空");
}
$contactor=isset($this->post['contactor'])&&$this->post['contactor']!=""?trim($this->post['contactor']):"";
if($contactor==""){
return error_show(1005,"参数 contactor 不能为空");
}
$returninfo=[
"returnCode"=>$bkcode,
"return_wsm"=>$wsm_code,
"contactor"=>$contactor,
"mobile"=>$mobile ,
"addr"=>$addr,
"addr_code"=>$addrcode,
"addtime"=>date("Y-m-d H:i:s")
];
Db::startTrans();
try {
$in=Db::name("order_returninfo")->insert($returninfo);
if($in){
if($info['return_tag']==2 &&$wareaddr==false) {
$addrs =[
"wsm_code"=>$wsm_code,
"wsm_type"=>1,
"wsm_name"=>$contactor,
"wsm_addr"=>$addr,
"addr_code"=>$addrcode,
"wsm_mobile"=>$mobile,
"status"=>'1',
"is_del"=>'0',
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$wareaddr =Db::name("warehouse_addr")->insert($addrs);
if($wareaddr==false){
Db::rollback();
return app_show(1004,"退货仓库地址录入失败");
}
}
$old_info_status = $info['status'];
$info['status']=4;
if($info['order_type']==1){
$info['cgder']=$warehouse['contactor_name']??"";
$info['cgderid']=$warehouse['contactor']??0;
}
$info["updatetime"]=date("Y-m-d H:i:s");
$up =Db::name("order_return")->save($info);
if($up){
//修改状态，添加待办
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_code" => $info['returnCode'],//销售单code
"status" => $old_info_status,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "status"//新建create，编辑edit，更改状态status
], "SHD", $info['status'], $info);
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_type" => 'SHD',
"order_code" => $info['returnCode'],//销售单code
"order_id" => $info['id'],
"order_status" => $info['status'],
"before_status"=>$old_info_status,
'holder_id'=>$info['apply_id']
]);
Db::commit();
return app_show(0,"退货仓库设置成功");
}
}
Db::rollback();
return error_show(1004,"设置失败");
}catch (\Exception $e){
Db::rollback();
return error_show(1004,$e->getMessage());
}
}
/**
* @return \think\response\Json|void
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function postfeed(){
$bkcode = isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
if($bkcode==""){
return error_show(1005,"参数returnCode 不能为空");
}
$info = Db::name("order_return")->where(['returnCode'=>$bkcode])->find();
if(empty($info)){
return error_show(1005,"未找到售后数据");
}
$contactor = isset($this->post['contactor']) && $this->post['contactor']!="" ? trim($this->post['contactor']) :"";
$mobile = isset($this->post['mobile']) && $this->post['mobile']!="" ? trim($this->post['mobile']):"";
$addr = isset($this->post['addr']) && $this->post['addr']!="" ? trim($this->post['addr']):"";
$addr_code = isset($this->post['addr_code']) && $this->post['addr_code']!=""&&!empty($this->post['addr_code']) ?
$this->post['addr_code']:"";
$wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
if($wsm_code==""){
return error_show(1005,"参数 wsm_code不能为空");
}
if($info['is_th']==0&&$info['order_type']==1) {
$wsm = Db::name("warehouse_info")->where(["wsm_code" => $wsm_code])->find();
if (empty($wsm)) {
return error_show(1005, "未找到仓库数据");
}
$sm = Db::name("warehouse_addr")->where(["wsm_code" => $wsm_code,"is_del"=>0])->find();
$contactor==""?(isset($sm['wsm_name']) ? $contactor=$sm['wsm_name']:""):"";
$sm['wsm_name'] =isset($sm['wsm_name']) ? $sm['wsm_name']:"";
$mobile==""?(isset($sm['wsm_mobile']) ? $mobile=$sm['wsm_mobile']:""):"";
$sm['wsm_mobile'] =isset($sm['wsm_mobile']) ? $sm['wsm_mobile']:"";
$addr==""?(isset($sm['wsm_addr']) ? $addr=$sm['wsm_addr']:""):"";
$sm['wsm_addr'] =isset($sm['wsm_addr']) ? $sm['wsm_addr']:"";
$addr_code==""?(isset($sm['addr_code']) ? $addr=$sm['addr_code']:""):"";
$sm['addr_code'] =isset($sm['addr_code']) ? $sm['addr_code']:"";
}
$remark = isset($this->post['remark']) && $this->post['remark']!="" ? trim($this->post['remark']):"";
if($info['is_th']==1 && $info['order_type']==1){
if($contactor==''){
return error_show(1005,"参数 contactor 不能为空");
}
if($mobile==''){
return error_show(1005,"参数 mobile 不能为空");
}
if($addr==''){
return error_show(1005,"参数 addr 不能为空");
}
if($addr_code==''){
return error_show(1005,"参数 addr_code 不能为空");
}
if($addr_code!==''&&is_array($addr_code)){
$addrs=[];
$addrs['provice_code'] = $addr_code[0];
$addrs['city_code'] = $addr_code[1];
$addrs['area_code'] = $addr_code[2];
$addr_code = json_encode($addrs);
}
}
Db::startTrans();
try{
$var=$info['status'];
$info['status']=$info['order_type']==1?3:4;
$info['remark']=$remark;
$info['updatetime']=date("Y-m-d H:i:s");
$up =Db::name("order_return")->save($info);
if($up){
// var_dump($contactor);
$returninfo = Db::name("order_returninfo")->where(["returnCode"=>$bkcode])->find();
if(empty($returninfo)){
$returninfo=[
"returnCode"=>$bkcode,
"return_wsm"=>$wsm_code,
"contactor"=>$contactor,
"mobile"=>$mobile ,
"addr"=>$addr,
"addr_code"=>$addr_code,
"addtime"=>date("Y-m-d H:i:s")
];
}else{
$returninfo['return_wsm'] = $wsm_code;
//if($info['is_th']==1 && $info['order_type']==1) {
$contactor !==""? $returninfo['contactor'] = $contactor:"";
$mobile!==""?$returninfo['mobile'] = $mobile:"";
$addr!==""? $returninfo['addr'] = $addr:"";
$addr_code!==""?$returninfo['addr_code'] = $addr_code:"";
// }
}
// var_dump($contactor);
// var_dump($returninfo);
$in=Db::name("order_returninfo")->save($returninfo);
if($in){
$order = ["order_code"=>$info['returnCode'],"status"=>$var,"action_remark"=>'',"action_type"=>"edit"];
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"SHD",$info['status'],$this->post);
$process=["order_code"=>$info['returnCode'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>"SHD","before_status"=>$var,'holder_id'=>$info['apply_id']];
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
Db::commit();
return app_show(0,"更新成功");
}
}
Db::rollback();
return error_show(1004,"更新失败");
}catch (\Exception $e){
Db::rollback();
return error_show(1004,$e->getMessage());
}
}
/**
* @return \think\response\Json|void
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function addpost(){
$bkcode = isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
if($bkcode==""){
return error_show(1005,"参数returnCode 不能为空");
}
$info = Db::name("order_return")->where(['returnCode'=>$bkcode])->find();
if(empty($info)){
return error_show(1005,"未找到售后数据");
}
$return_info = Db::name("order_returninfo")->where(['returnCode'=>$bkcode])->find();
if(empty($return_info)){
$return_info=[
"returnCode"=>$bkcode,
"return_wsm"=>'',
"contactor"=>'',
"mobile"=>'',
"addr"=>'',
"addr_code"=>'',
"addtime"=>date("Y-m-d H:i:s"),
"post_company"=>'',
"post_code"=>'',
"post_fee"=>'',
];
}
$post_own = isset($this->post['own']) &&$this->post['own']!='' ? trim($this->post['own']):"";
if($post_own==''){
return error_show(1005,"参数own不能为空");
}
$info['post_own'] = $post_own;
$post_company = isset($this->post['company'])&&$this->post['company']!='' ? trim($this->post['company']):"";
if($post_company==''){
return error_show(1005,"参数company不能为空");
}
$return_info['post_company'] = $post_company;
$post_code = isset($this->post['post_code'])&&$this->post['post_code']!='' ? trim($this->post['post_code']):"";
if($post_code==''){
return error_show(1005,"参数post_code不能为空");
}
$return_info['post_code'] = $post_code;
$fee= isset($this->post['post_fee'])&&$this->post['post_fee']!=='' ? round($this->post['post_fee'],2):"";
if($fee===''){
return error_show(1005,"参数post_fee不能为空");
}
$return_info['post_fee'] = $fee;
Db::startTrans();
try{
$str=$info['status'];
$info['status']=$info['order_type']==1?4:5;
$info['updatetime']=date("Y-m-d H:i:s");
$up =Db::name("order_return")->save($info);
if($up){
$order = ["order_code"=>$info['orderCode'],"status"=>$str,"action_remark"=>'',"action_type"=>"edit"];
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"SHD",$info['status'],$this->post);
$process=["order_code"=>$info['returnCode'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>"SHD","before_status"=>$str,'holder_id'=>$info['apply_id']];
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
$in=Db::name("order_returninfo")->save($return_info);
if($in){
$data=[
'thNo'=>makeNo("ST"),
"orderCode"=>$info['orderCode'],
"order_type"=>$info['order_type'],
"outCode"=>$info['outCode'],
"returnCode"=>$info['returnCode'],
"good_code"=>$info['good_code'],
"good_name"=>$info['good_name'],
"return_wsm"=>$return_info['return_wsm'],
"return_num"=>$info['error_num'],
"contactor"=>$return_info['contactor'],
"mobile"=>$return_info['mobile'],
"addr"=>$return_info['addr'],
"addr_code"=>$return_info['addr_code'],
"return_code"=>$info['error_code'],
"return_msg"=>$info['error_msg'],
"post_fee"=>$return_info['post_fee'],
"post_code"=>$return_info['post_code'],
"post_company"=>$return_info['post_company'],
"customer_code"=>$info['customer_code'],
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s")
];
$back =Db::name("order_back")->insert($data,true);
if($back>0){
//维护台账
// Db::name('standing_book')
// ->where('returnCode', $bkcode)
// ->update([
// 'thNo' => $data['thNo'],
// 'updatetime' => date("Y-m-d H:i:s")
// ]);
Db::execute("UPDATE `wsm_standing_book` SET `thNo`=CONCAT(IFNULL(`thNo`,''),',{$data['thNo']}'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE FIND_IN_SET('{$bkcode}',`returnCode`)");//这里的returnCode可能有多个
$order = ["order_code"=>$data['thNo'],"status"=>0,"action_remark"=>'',"action_type"=>"create"];
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CKTHD", 0,$data);
$process=["order_code"=>$data['thNo'],"order_id"=>$back,"order_status"=>0,"order_type"=>"CKTHD","before_status"=>0];
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
Db::commit();
return app_show(0,"更新成功");
}
}
}
Db::rollback();
return error_show(1004,"更新失败");
}catch (\Exception $e){
Db::rollback();
return error_show(1004,$e->getMessage());
}
}
/**
* @return \think\response\Json|void
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function GysFeed(){
$bkcode = isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
if($bkcode==""){
return error_show(1005,"参数returnCode 不能为空");
}
$info = Db::name("order_return")->where(['returnCode'=>$bkcode])->find();
if(empty($info)){
return error_show(1005,"未找到售后数据");
}
$isth = isset($this->post['is_th']) && $this->post['is_th']!="" ? intval($this->post['is_th']):"0";
$contactor = isset($this->post['contactor']) && $this->post['contactor']!="" ? trim($this->post['contactor'])
:"";
$mobile = isset($this->post['mobile']) && $this->post['mobile']!="" ? trim($this->post['mobile']):"";
$addr = isset($this->post['addr']) && $this->post['addr']!="" ? trim($this->post['addr']):"";
$addr_code = isset($this->post['addr_code']) && $this->post['addr_code']!=""&&!empty($this->post['addr_code']) ? $this->post['addr_code']:"";
$remark = isset($this->post['remark']) && $this->post['remark']!="" ? trim($this->post['remark']):"";
if($isth==1){
if($contactor==''){
return error_show(1005,"参数 contactor 不能为空");
}
if($mobile==''){
return error_show(1005,"参数 mobile 不能为空");
}
if($addr==''){
return error_show(1005,"参数 addr 不能为空");
}
// var_dump(isset($this->post['addr_code']) , $this->post['addr_code']!="",!empty($addr_code));
if($addr_code==''){
return error_show(1005,"参数 addr_code 不能为空");
}
if(is_array($addr_code)){
$addrs=[];
$addrs['provice_code'] = $addr_code[0];
$addrs['city_code'] = $addr_code[1];
$addrs['area_code'] = $addr_code[2];
$addr_code = json_encode($addrs);
}
}
$orde= Db::name("order_out")->where(["outCode"=>$info['outCode'],"is_del"=>0])->find();
if(empty($orde)){
return error_show(1005,"未找到出库单数据");
}
Db::startTrans();
try{
$stat=$info['status'];
$info['status']=$info['order_status']==1?5:3;
$info['is_th']=$isth;
$info['updatetime']=date("Y-m-d H:i:s");
$up =Db::name("order_return")->save($info);
if($up){
$returninfo = Db::name("order_returninfo")->where(["returnCode"=>$bkcode])->find();
if(empty($returninfo)){
$returninfo=[
"returnCode"=>$bkcode,
"return_wsm"=>'',
"contactor"=>$contactor,
"mobile"=>$mobile ,
"addr"=>$addr,
"addr_code"=>$addr_code,
"gys_remark"=>$remark,
"addtime"=>date("Y-m-d H:i:s")
];
}else{
$returninfo['return_wsm'] = '';
$returninfo['contactor'] = $contactor;
$returninfo['mobile'] = $mobile;
$returninfo['addr'] = $addr;
$returninfo['gys_remark'] = $remark;
$returninfo['addr_code'] = $addr_code;
}
$in=Db::name("order_returninfo")->save($returninfo);
if($in){
$order = ["order_code"=>$info['returnCode'],"status"=>$stat,"action_remark"=>'',"action_type"=>"edit"];
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"SHD", $info['status'],$this->post);
$process=["order_code"=>$info['returnCode'],"order_id"=>$info['id'],"order_status"=>$info['status'],"SHD","before_status"=>$stat,'holder_id'=>$info['apply_id']];
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
Db::commit();
return app_show(0,"更新成功");
}
}
Db::rollback();
return error_show(1004,"更新失败");
}catch (\Exception $e){
Db::rollback();
return error_show(1004,$e->getMessage());
}
}
public function GetWsm(){
$bkcode = isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
if($bkcode==""){
return error_show(1005,"参数returnCode 不能为空");
}
$info = Db::name("order_return")->where(['returnCode'=>$bkcode])->find();
if($info==false){
return error_show(1005,"未找到售后数据");
}
$list=[];
if($info['is_th']==1){
if($info["order_type"]==1){
$out =Db::name("order_out")->where(["outCode"=>$info['outCode'],"is_del"=>0])->find();
if(empty($out)){
return error_show(1005,"未找到出库单数据");
}
$ware = Db::name("warehouse_info")->alias("a")->leftJoin("warehouse_addr b","a.wsm_code=b.wsm_code and b.status=1 and b.is_del=0")
->where(["a.status"=>1,"wsm_type"=>1,"a.is_del"=>0,"a.supplierNo"=>$out['wsm_code']])->field("a.wsm_code,a.name,b.wsm_name,b.wsm_mobile,b.wsm_addr,b.addr_code")->find();
if(empty($ware)){
return error_show(1005,"未找到仓库数据");
}
$temp['wsm_code']=isset($ware['wsm_code'])?$ware['wsm_code']:"";
$temp['wsm_name']=isset($ware['name'])?$ware['name']:"";
$temp['contactor'] = isset($ware['wsm_name'])?$ware['wsm_name']:"";
$temp['mobile'] =isset($ware['wsm_mobile'])?$ware['wsm_mobile']:"";
$temp['addr'] =isset($ware['wsm_addr'])?$ware['wsm_addr']:"";
$temp['addr_code'] = isset($ware['addr_code'])?$ware['addr_code']:"";
$temp['addr_cn'] =GetAddr( $ware['addr_code']);
$list[]=$temp;
}else {
$returninfo = Db::name("order_returninfo")->where(["returnCode" => $bkcode])->find();
if (empty($returninfo)) {
return error_show(1005, "未找到供应商仓库数据");
}
$data = [];
$data['wsm_code'] = isset($returninfo['return_wsm']) && $returninfo['return_wsm'] != "" ? $returninfo['return_wsm'] : "-";
$data['wsm_name'] = '供应商仓';
$data['supplier_name'] = '供应商';
$data['contactor'] = $returninfo['contactor'];
$data['mobile'] = $returninfo['mobile'];
$data['addr'] = $returninfo['addr'];
$data['addr_cn'] =GetAddr( $returninfo['addr_code']);
$data['addr_code'] = $returninfo['addr_code'];
$list[] = $data;
}
}
$supplier = Db::name("supplier")->where(["is_platform"=>1,"status"=>1,"is_del"=>0])->column("code,name");
if(empty($supplier)){
return error_show(1005,"未找到供应商仓库数据");
}
foreach ($supplier as $value){
$temp=[];
$ware = Db::name("warehouse_info")->alias("a")->leftJoin("warehouse_addr b","a.wsm_code=b.wsm_code and b.status=1 and b.is_del=0")
->where(["a.wsm_type"=>1,"a.status"=>1,"a.is_del"=>0,"a.supplierNo"=>$value['code']])->field("a.wsm_code,a.name,b.wsm_name,b.wsm_mobile,b.wsm_addr,b.addr_code")->find();
if(empty($ware)){
continue;
}
$temp['wsm_code']=isset($ware['wsm_code'])?$ware['wsm_code']:"";
$temp['wsm_name']=isset($ware['name'])?$ware['name']:"";
$temp['supplier_name']=$value['name'];
$temp['contactor'] = isset($ware['wsm_name'])?$ware['wsm_name']:"";
$temp['mobile'] =isset($ware['wsm_mobile'])?$ware['wsm_mobile']:"";
$temp['addr'] =isset($ware['wsm_addr'])?$ware['wsm_addr']:"";
$temp['addr_cn'] =GetAddr($ware['addr_code']);
$temp['addr_code'] = isset($ware['addr_code'])?$ware['addr_code']:"";
$list[]=$temp;
}
return app_show(0,"获取成功",$list);
}
//客户发货
public function setdelivery()
{
$param = $this->request->only(['returnCode', 'company', 'post_code', 'post_fee'], 'post', 'trim');
$val = Validate::rule([
'returnCode|售后申请单编号' => 'require',
'company|快递公司名' => 'require|max:255',
'post_code|快递单号' => 'require|max:255',
'post_fee|快递费用' => 'require|float',
]);
if ($val->check($param) == false) return json_show(1004, $val->getError());
$bkcode = $param['returnCode'];
$company = $param['company'];
$post_code = $param['post_code'];
$post_fee = $param['post_fee'];
// $bkcode = isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
// if($bkcode==""){
// return error_show(1005,"参数returnCode 不能为空");
// }
$info = Db::name("order_return")
->where(['is_del' => 0, 'returnCode' => $bkcode])
->findOrEmpty();
if (empty($info)) return error_show(1005, "未找到售后数据");
// if(($info['is_receive']==0&&$info['status']!=3)||($info['is_receive']==1&&$info['status']!=4) ){
// return error_show(1005,"售后单流程状态有误");
// }
$out = Db::name("order_out")
->where(["outCode" => $info["outCode"], "is_del" => 0])
->findOrEmpty();
if (empty($out)) return error_show(1005, "未找到发货单数据");
// $is_th = isset($this->post['is_th'])&&$this->post['is_th']!=="" ? intval($this->post['is_th']):"";
// if($is_th===""){
// return error_show(1005,"参数is_th不能为空");
// }
// $company=isset($this->post['company'])&&$this->post['company']!=""?trim($this->post['company']):"";
// $post_code=isset($this->post['post_code'])&&$this->post['post_code']!=""?trim($this->post['post_code']):"";
// $post_fee=isset($this->post['post_fee'])&&$this->post['post_fee']!==""?floatval($this->post['post_fee']):"";
// if($is_th==1){
// if($company==""){
// return error_show(1005,"参数company不能为空");
// }
// if($post_code==""){
// return error_show(1005,"参数post_code不能为空");
// }
// if($post_fee===""){
// return error_show(1005,"参数post_fee不能为空");
// }
// }
$sale = Db::name('sale')
->where(['orderCode' => $info['orderCode'], "is_del" => 0])
->findOrEmpty();
if (empty($sale)) return error_show(1004, "未找到销售单数据");
Db::startTrans();
try {
$returninfo = Db::name("order_returninfo")->where(["returnCode" => $bkcode])->find();
// if($returninfo==false){
// $returninfo=[
// "returnCode"=>$bkcode,
// "return_wsm"=>"",
// "contactor"=>"",
// "mobile"=>"",
// "addr"=>"",
// "addr_code"=>"",
// "post_code"=>$post_code,
// "post_company"=>$company,
// "post_fee"=>$post_fee,
// "gys_remark"=>"",
// "addtime"=>date("Y-m-d H:i:s")
// ];
// }else{
$returninfo['post_fee'] = $post_fee;
$returninfo['post_company'] = $company;
$returninfo['post_code'] = $post_code;
// }
$up = Db::name("order_returninfo")
->where(["returnCode" => $bkcode])
//->save($returninfo)
->update($returninfo);
if ($up) {
$old_info_status = $info['status'];
$info['status'] = 5;
$info['updatetime'] = date("y-m-d H:i:s");
$ro = Db::name("order_return")->save($info);
if ($ro) {
//修改状态，添加待办
ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], [
"order_code" => $info['returnCode'],//销售单code
"status" => $old_info_status,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "status"//新建create，编辑edit，更改状态status
], "SHD", $info['status'], $this->post);
ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
"order_type" => 'SHD',
"order_code" => $info['returnCode'],//销售单code
"order_id" => $info['id'],
"order_status" => $info['status'],
"before_status" => $old_info_status,
'holder_id' => $info['apply_id']
]);
//售后退货单数据
$thNo = makeNo("ST");
$thdata = [
"thNo" => $thNo,
"orderCode" => $out["orderCode"],
"outCode" => $out["outCode"],
"order_type" => $info["order_type"],
"returnCode" => $info["returnCode"],
"good_code" => $info["good_code"],
"good_name" => $info["good_name"],
"return_wsm" => $returninfo["return_wsm"],
"total_fee" => round($sale['sale_price'] * $info["error_num"], 2),
"good_price" => $sale['sale_price'],
"platform_id" => $sale['platform_id'],
"return_msg" => $info["error_msg"],
"return_num" => $info["error_num"],
"normal_num" => 0,
"received_num" => 0,
"apply_id" => $info['apply_id'],
"apply_name" => $info['apply_name'],
"cgder" => $info['cgder'],
"cgderid" => $info['cgderid'],
"person" => $info['person'],
"person_id" => $info['person_id'],
"contactor" => $returninfo["contactor"],
"mobile" => $returninfo["mobile"],
"addr" => $returninfo["addr"],
"addr_code" => $returninfo["addr_code"],
"return_code" => $info["error_code"],
"post_fee" => $returninfo["post_fee"],
"post_code" => $returninfo["post_code"],
"post_company" => $returninfo["post_company"],
"customer_code" => $info["customer_code"],
"status" => $info['return_tag'] == 1 ? 4 : 1, //return_tag==1退回供应商，status:4完成退货,1待验收
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
];
$sav = Db::name("order_back")->insert($thdata, true);
if ($sav) {
//修改状态，添加待办
ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], [
"order_code" => $thdata['thNo'],//销售单code
"status" => $thdata['status'],//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKTHD", $thdata['status'], $thdata);
//售后退货单，供应商不同意退货，退回到业务公司仓的时候，要把待办数据推给供应商负责人和库管人员
if ($thdata['status'] == 1) {
//31库管人员,41库管-张凯旋
$uids = Db::name('user_role')
->where(['is_del' => 0, 'roleid' => [31, 41], 'status' => 1])
->column('uid');
ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
"order_type" => 'CKTHD',
"order_code" => $thdata['thNo'],//销售单code
"order_id" => $sav,
"order_status" => $thdata['status'],
"before_status" => 0,
'handle_user_list' => implode(',', array_merge($uids, [$sale['cgderid']])),
]);
} else {
ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
"order_type" => 'CKTHD',
"order_code" => $thdata['thNo'],//销售单code
"order_id" => $sav,
"order_status" => $thdata['status'],
"before_status" => 0
]);
}
//维护台账记录
// Db::name('standing_book')
// ->where(['returnCode' => $bkcode])
// ->update([
// 'thNo' => $thNo,
// 'updatetime' => date("Y-m-d H:i:s")
// ]);
Db::execute("UPDATE `wsm_standing_book` SET `thNo`=CONCAT(IFNULL(`thNo`,''),',{$thNo}'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE FIND_IN_SET('{$bkcode}',`returnCode`)");//这里的returnCode可能有多个
// 库存品退货 不退商品 需要计算成本
// if($info['except_code']==1){
// $sabebn =Db::name("sale_info")->where(["orderCode"=>$info['orderCode']])->select()->toArray();
// if(!empty($sabebn)){
// $total_num =$info["error_num"];
// foreach ($sabebn as $ve){
//
// $tempnum=0;
// if ($total_num==0) break;
// if($total_num>=$ve['num']){
// $tempnum = $ve['num'];
// $total_num-=$ve['num'];
// $ve['num']=0;
// }else{
// $tempnum = $total_num;
// $ve['num']-=$total_num;
// $total_num=0;
// }
// $bnin=GoodStockInfo::ReturnAdd($stockid,$ve['bnCode'],$tempnum,$ve['stockid']);
// if($bnin==false){
// Db::rollback();
// return error_show(1005, '可售商品Bn库存数入库失败');
// }
// $up=Db::name("sale_info")->save($ve);
// if($up==false){
// Db::rollback();
// return error_show(1005, '可售商品Bn库存数入库失败');
// }
// $bnin=GoodStockInfo::ReturnBn($info['returnCode'],$ve['id'],$tempnum);
// if($bnin==false){
// Db::rollback();
// return error_show(1005, '可售商品Bn库存数入库失败');
// }
// }
// }
// }else{
//
// }
//退回供应商的时候，处理库存
if ($info['return_tag'] == 1) {
$sale['th_num'] += $info['error_num'];
if ($sale['th_num'] == $sale['send_num'] && $sale['wsend_num'] == 0) {
$sale['status'] = 3;
}
$sale['th_fee'] += round($info['error_num'] * $sale['sale_price'], 2);
$sale['updatetime'] = date("Y-m-d H:i:s");
$uap = Db::name("sale")->save($sale);
if ($uap == false) throw new Exception('销售单订单更新失败');
// if($uap==false){
// Db::rollback();
// return error_show(1005,'销售单订单更新失败');
// }
if ($sale['is_stock'] == 0) {
$ordernum = Db::name("order_num")
->where(['orderCode' => $info['orderCode']])
->find();
if ($ordernum == false) throw new Exception('未找到关联采购单1');
// if($ordernum==false){
// Db::rollback();
// return error_show(1005,'未找到关联采购单');
// }
$ordernum['send_num'] -= $info['error_num'];
$orderup = Db::name("order_num")->save($ordernum);
if ($orderup == false) throw new Exception('关联数据更新失败');
// if($orderup==false){
// Db::rollback();
// return error_show(1005,'关联数据更新失败');
// }
$cgd = Db::name("purchease_order")
->where(["cgdNo" => $ordernum['cgdNo'], "is_del" => 0])
->findOrEmpty();
if (empty($cgd)) throw new Exception('未找到采购单数据');
// if($cgd==false){
// Db::rollback();
// return error_show(1005,'未找到采购单数据');
// }
$cgd['th_num'] += $info['error_num'];
if ($cgd['th_num'] == $cgd['send_num'] && $cgd['wsend_num'] == 0) {
$cgd['status'] = 4;
}
$cgd['th_fee'] += round($info['error_num'] * $cgd['good_price'], 2);
$cgd['updatetime'] = date("Y-m-d H:i:s");
$cgdup = Db::name("purchease_order")->save($cgd);
if ($cgdup == false) throw new Exception('采购单数据更新失败');
// if($cgdup==false){
// Db::rollback();
// return error_show(1005,'采购单数据更新失败');
// }
}
$sabebn = Db::name("sale_info")
->where([["orderCode", "=", $info['orderCode']], ["num", ">", 0]])
->select()
->toArray();
if (!empty($sabebn)) {
$total_num = $info["error_num"];
foreach ($sabebn as $ve) {
$tempnum = 0;
if ($total_num == 0) break;
if ($total_num >= $ve['num']) {
$tempnum = $ve['num'];
$total_num -= $ve['num'];
$ve['th_num'] += $ve['num'];
$ve['num'] = 0;
} else {
$tempnum = $total_num;
$ve['num'] -= $total_num;
$ve['th_num'] += $total_num;
$total_num = 0;
}
if ($info['except_code'] == 1) {
// if($sale['is_stock']==1){
// $bnin=GoodStockInfo::AddBn($ve['stockid'],$ve['bnCode'],$tempnum);
// if($bnin==false){
// Db::rollback();
// return error_show(1005, '可售商品Bn库存数入库失败');
// }
// }
$up = Db::name("sale_info")->save($ve);
if ($up == false) throw new Exception('可售商品Bn库存数入库失败');
// if($up==false){
// Db::rollback();
// return error_show(1005, '可售商品Bn库存数入库失败');
// }
}
$bnin = GoodStockInfo::ReturnBn($info['returnCode'], $ve['id'], $tempnum);
if ($bnin == false) throw new Exception('可售商品Bn库存数入库失败');
// if($bnin==false){
// Db::rollback();
// return error_show(1005, '可售商品Bn库存数入库失败');
// }
}
}
if ($info['error_num'] >= $out['send_num']) {
$out['status'] = 4;
$out['updatetime'] = date("Y-m-d H:i:s");
$upout = Db::name("order_out")->save($out);
if ($upout == false) throw new Exception('出库单数据更新失败');
// if($upout==false){
// Db::rollback();
// return error_show(1005,'出库单数据更新失败');
// }
}
$data = [
"orderCode" => $info['orderCode'],
"th_type" => 3,
"th_num" => $info['error_num'],
"th_fee" => round($sale['sale_price'] * $info["error_num"], 2),
"thCode" => $thNo,
"spuCode" => $sale['good_code'],
"good_name" => $sale['good_name'],
"cat_id" => $sale['cat_id'],
"apply_id" => $info['apply_id'],
"apply_name" => $info['apply_name'],
"addtime" => date("Y-m-d H:i:s"),
"status" => 1,
"is_del" => 0
];
$inse = Db::name("th_data")->insert($data);
if ($inse == false) throw new Exception('退货单更新失败');
// if($inse==false){
// Db::rollback();
// return error_show(1004,"退货单更新失败");
// }
}
Db::commit();
return app_show(0, "退货单新建成功", ["thNo" => $thNo]);
}
}
}
Db::rollback();
return error_show(1004, '退货失败');
} catch (Exception $e) {
Db::rollback();
return error_show(1004, $e->getMessage());
}
}
//取消售后
public function Cancel()
{
//接收参数
$data = $this->request->only(['token', 'returnCode'], 'post', 'trim');
$val = Validate::rule(['returnCode|售后单编号' => 'require']);
if (!$val->check($data)) return error_show(1005, $val->getError());
Db::startTrans();
try {
$rs = Db::name('order_return')
->field('id,status,apply_id')
->where([
['returnCode', '=', $data['returnCode']],
['is_del', '=', 0],
['status', '<>', 8]
])->findOrEmpty();
if (!$rs) throw new Exception('该售后单记录不存在');
//修改记录
$res = Db::name('order_return')->where(['id' => $rs['id']])->update(['status' => 8, 'updatetime' => date('Y-m-d H:i:s')]);
if (!$res) throw new Exception('该售后单记录修改失败');
//记录日志
ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], ["order_code" => $data['returnCode'], "status" => $rs['status'], "action_remark" => '', "action_type" => "delete"], 'SHD', 8, $this->post);
ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], ["order_code" => $data['returnCode'], "order_id" => $rs['id'], "order_status" => 8, "order_type" => 'SHD', "before_status" => $rs['status'], 'holder_id' => $rs['apply_id']]);
//提交
Db::commit();
return app_show(0, "取消成功");
} catch (\Exception $e) {
Db::rollback();
return error_show(1004, $e->getMessage());
}
}
//根据审核完成的售后申请单，创建新的销售单和采购单
public function createSaleAndCgdByAfter()
{
$param = $this->request->only(['token', 'returnCode'], 'post', 'trim');
$val = Validate::rule(['token' => 'require', 'returnCode|售后申请单编号' => 'require']);
if (!$val->check($param)) return error_show(1005, $val->getError());
//查询售后申请单详情
$info = Db::name('order_return')
->where('returnCode', $param['returnCode'])
->where('is_del', 0)
->find();
if (empty($info)) return error_show(1005, '该售后申请单不存在');
if ($info['status'] != 5) return error_show(1005, '该售后申请单尚未审核完成');
if ($info['is_reissue'] == 1) return error_show(1005, '该售后申请单已完成补发，无法重复进行');
$apply_id = GetUserInfo($param['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'] : "";
//原本销售单信息
$old_sale = Db::name('sale')->where(['is_del' => 0, 'orderCode' => $info['orderCode']])->find();
if (empty($old_sale)) return error_show(1005, '没有对应的销售单信息');
//发货单信息
$old_out = Db::name('order_out')->where(['is_del' => 0, 'orderCode' => $info['orderCode'], 'outCode' => $info['outCode']])->find();
if (empty($old_out)) return error_show(1005, '没有对应的发货单信息');
//根据是否咨询类商品，分别处理
if ($info['order_type'] == 3) return $this->createSaleZixun($info['id'], $info['good_code'], $info, $old_sale, $rm, $ri, $old_out['addrid'], $param['token']);
else return $this->createSaleNotZixun($info['id'], $info['good_code'], $info, $old_sale, $rm, $ri, $old_out, $param['token']);
}
/**
* 咨询类商品处理
* @param int $orid 对应售后记录的id
* @param string $spuCode 商品的spuCode
* @param array $info 售后申请单的详情
* @param array $old_sale 原始销售订单
* @param int $rm 操作人id
* @param string $ri 操作人名称
* @param int $addrid 原始发货单的地址id
* @param string $token 当前用户的token
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
private function createSaleZixun(int $orid = 0, string $spuCode = '', array $info = [], array $old_sale = [], int $rm = 0, string $ri = '', int $addrid = 0, string $token = '')
{
// $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" => $old_sale['zxNo'], "is_del" => 0])->find();
if ($zxinfo == false) return error_show(1005, '未找到咨询单商品信息');
// 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 不能为空");
// }
$good_num = $info['error_num'];
$sale_price = 0;
// $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;
//原有采购单信息
$old_cgd = Db::name('order_num')
->alias('on')
->field('on.id onid,po.*')
->leftJoin('purchease_order po', 'po.cgdNo=on.cgdNo')
->where('on.orderCode', $old_sale['orderCode'])
->find();
$cgd = array_merge($old_cgd, [
'id' => null,
// "supplierNo"=>$zxinfo['supplierNo'],
// "companyNo"=>$zxorder['companyNo'],
"spuCode" => $spuCode,
"skuCode" => $skuCode,
"orderCode" => $orderCode,
// "good_name"=>$zxinfo['good_name'],
"sale_price" => $old_cgd['good_price'],//采购单价格不为0，取原采购单的价格
"total_fee" => round($old_cgd['good_price'] * $good_num, 2),
// "pakge_fee"=>$zxinfo['pakge_fee'],
// "cert_fee"=>$zxinfo['cert_fee'],
// "open_fee"=>$zxinfo['open_fee'],
'cost_fee' => $old_cgd['teach_fee'],
// $old_sale['cost_fee']=$old_sale['teach_fee'];
// "mark_fee"=>$zxinfo['mark_fee'],
// "demo_fee"=>$zxinfo['demo_fee'],
// "nake_fee"=>$zxinfo['nake_fee'],
// "delivery_fee"=>$zxinfo['delivery_fee'],
"good_num" => $good_num,
"createrid" => $rm,
"creater" => $ri,
"good_type" => 1,
// "weight"=>$zxinfo['good_weight'],
// "gold_price"=>$zxinfo['gold_price'],
// "is_diff"=>$zxinfo['is_diff'],
"order_type" => 3,//咨询商品
"order_source" => 6,//6售后补换货
// 'send_way'=>$zxinfo['send_way']
'token' => $token,
'good_createrid' => $zxinfo['createrid'],
'good_creater' => $zxinfo['creater'],//商品创建人
]);
// $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"));
// }
// if($good_num<$send_num){
// return error_show(1002, "发货数量不能超过购买数量");
// }
// $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']:"";
// $proof_type = isset($this->post['proof_type']) && $this->post['proof_type'] != "" ? intval($this->post['proof_type']) : 0;
// $proof_url = isset($this->post['proof_url']) && $this->post['proof_url'] != "" ? trim($this->post['proof_url']) : '';
Db::startTrans();
try {
// $zx =Db::name("consult_info")->where(["infoNo"=>$zxinfo['infoNo'],"is_del"=>0])->lock(true)->find();
// if($zx==false){
// Db::rollback();
// return error_show(1003,"未找到咨询单信息");
// }
// $supplier_temp_info = Db::name('supplier')
// ->field('id,person,personid')
// ->where('code',$old_cgd['supplierNo'])
// ->findOrEmpty();
$user= new \app\admin\common\User();
$supplier_temp_info =$user->handle("sInfo",["code"=>$old_cgd['supplierNo']]);
$data = array_merge($old_sale, [
'id' => null,
"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" => $old_sale['sale_price'],//取原价格
// "post_fee"=>0,
"status" => 0,
"send_status" => 0,
"th_num" => 0,
"th_fee" => 0,//退货金额为0
"send_num" => 0,
"wsend_num" => $good_num,
// "send_status"=>1,
"good_type" => 1,
// "send_type"=>$sendtype,
// "supplierNo"=>$zxorder['companyNo'],
"is_del" => 0,
// "zxNo"=>$bidNo,
// "platform_order"=>$platform_order,
// "platform_id"=> $zxorder['platform_code'],
"remark" => $old_sale['orderCode'],
// "arrive_time"=>$arrtime,
// "is_stock"=>0,
// "is_activity"=>0,
// "proof_id"=>0,
"order_type" => 3,
"order_source" => 6,//6售后补换货
// 'good_weight'=>$zxinfo['good_weight'],
// 'gold_price'=>$zxinfo['gold_price'],
// '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"),
'returnCode' => $info['returnCode'],
// 'total_price' => round($sale_price * $good_num, 2),
// 'workNo'=>$workNo,
'cgderid' => $supplier_temp_info['data']['personid']??0,
'cgder' => $supplier_temp_info['data']['person']??"",//采购员(供应商负责人)
'good_createrid' => $zxinfo['createrid'],
'good_creater' => $zxinfo['creater'],//商品创建人
]);
$datainfo = Db::name('sale')->insertGetId($data);
if ($datainfo > 0) {
$standing_book_data = [
'sale_id' => $datainfo,
'infoNo' => $zxinfo['infoNo'],
'updatetime' => date('Y-m-d H:i:s')
];
//修改状态，添加待办
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_code" => $orderCode,//销售单code
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "XSQRD", $data['status'], $data);
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_type" => 'XSQRD',
"order_code" => $orderCode,//销售单code
"order_id" => $datainfo,
"order_status" => $data['status'],
"before_status" => 0,
'holder_id' => $data['apply_id']
]);
// $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(['id'=>$this->uid,'nickname'=>$this->uname], [
// "order_code" => $zx['infoNo'],//咨询单详情编号
// "status" => $old_zx_status,//这里的status是之前的值
// "action_remark" => '',//备注
// "action_type" => "status"//新建create，编辑edit，更改状态status
// ], "ZXD", 5, $zx);
//
// }
$this->createCgd($cgd, $standing_book_data);
// 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'],
// "companyNo"=>$zxorder['companyNo'],
// "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"),
// 'proof_type' => $proof_type,//凭证类型
// 'proof_url' => $proof_url,//凭证文件
// ];
// $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 (empty($order)) throw new Exception('采购单关联数据未找到');
// foreach ($va as $value){
// $temp=[];
// $addrs=[];
// if($value['addr_code']!==''&&is_array($value['addr_code'])&&!empty($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;
$old_out_addr_info = Db::name('order_out')
->alias('oo')
->field('oo.id,oa.addr,oa.addr_code,oa.contactor,oa.mobile,oa.customer_code,oa.post_fee,oa.arrive_time')
->leftJoin('order_addr oa', 'oa.id=oo.addrid')
->where(['oo.outCode' => $info['outCode'], 'oo.orderCode' => $info['orderCode']])
->find();
if (empty($old_out_addr_info)) throw new Exception('发货单对应的地址信息查不到');
$temp = [
'orderCode' => $orderCode,
'addr' => $old_out_addr_info['addr'],
'addr_code' => $old_out_addr_info['addr_code'],
'contactor' => $old_out_addr_info['contactor'],
'mobile' => $old_out_addr_info['mobile'],
'customer_code' => $old_out_addr_info['customer_code'],
'receipt_quantity' => $good_num,
'arrive_time' => $old_out_addr_info['arrive_time'],
'addtime' => date("Y-m-d H:i:s"),
'updatetime' => date("Y-m-d H:i:s"),
// ''=>'',
];
$addrid = Db::name('order_addr')->insertGetId($temp);
// if($vmp>0){
$outCode = makeNo("DF");
$out = [
"orderCode" => $orderCode,
"outCode" => $outCode,
"apply_id" => $rm,
"apply_name" => $ri,
'addrid' => $addrid,
"post_name" => "",
"post_code" => "",
"post_fee" => 0,
"sendtime" => date("Y-m-d H:i:s"),
"send_num" => $good_num,
"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) throw new Exception('发货地址添加创建失败');
else {
//修改状态，添加待办
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_code" => $outCode,//出库单号
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CKD", 0, $out);
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_type" => 'CKD',
"order_code" => $outCode,//出库单号
"order_id" => Db::name("order_out")->getLastInsID(),
"order_status" => 0,
"before_status" => 0,
'holder_id' => $out['apply_id']
]);
//将发货编号添加到台账中
$standing_book_data['outCode'][] = $outCode;
}
$order['send_num'] += $good_num;
$order['wsend_num'] -= $good_num;
if ($order['wsend_num'] < 0) throw new Exception('发货数量已超出总数');
$ups = Db::name("order_num")->save($order);
if ($ups) {
$sen = Db::name("order_send")->save([
"cgdNo" => $order['cgdNo'],
"outCode" => $outCode,
"send_num" => $good_num,
"status" => 1,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
]);
if ($sen == false) throw new Exception('发货地址添加创建失败');
}
// }else{
// Db::rollback();
// return error_show(1002,"发货地址添加创建失败");
// }
// }
//处理台账
if (isset($standing_book_data['outCode'])) {
Db::execute("UPDATE `wsm_standing_book` SET `outCode`=CONCAT(IFNULL(`outCode`,''),'," . implode(',', $standing_book_data['outCode']) . "'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE `infoNo`='{$standing_book_data['infoNo']}'");
unset($standing_book_data['outCode']);
}
Db::name('standing_book')->where('infoNo', $standing_book_data['infoNo'])->update($standing_book_data);
Db::name('order_return')
->where(['id' => $orid, 'is_reissue' => 0])
->update([
'is_reissue' => 1,
'newOrderCode' => $orderCode,
'updatetime' => date('Y-m-d H:i:s')
]);
Db::commit();
return app_show(0, "咨询订单创建成功", ["order_code" => $orderCode]);
}
Db::rollback();
return error_show(1002, "咨询订单创建失败");
} catch (Exception $e) {
Db::rollback();
return error_show(1003, $e->getMessage() . '|' . $e->getFile() . ':' . $e->getLine());
}
}
private function createCgd($data,array &$standing_book_da=[]){
$cgdCode = makeNo("CG");
// $supplier=Db::name("supplier")->where(["code"=>$data['supplierNo'],"is_del"=>0])->find();
$user= new \app\admin\common\User();
$supplier_temp =$user->handle("sInfo",["code"=>$data['supplierNo']]);
if($supplier_temp['code']!=0 || empty($supplier_temp['data']) ) throw new Exception('该供应商不存在');
$supplier=$supplier_temp['data'];
$wsm= Db::name("warehouse_info")
->where(["supplierNo"=>$data["supplierNo"],"companyNo"=>$data['companyNo'],"wsm_type"=>2,"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"=>$data['order_type']==1? $supplier['personid']:$data['createrid'],
"contactor_name"=>$data['order_type']==1? $supplier['person']:$data['creater'],
"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) throw new Exception('仓库新增失败');
}else $wsm_code =$wsm['wsm_code'];
//判断该供应商是否开通了供应商账号
$from_tag=checkHasAccountBySupplierNos([$data['supplierNo']]);
$cg =[
"cgdNo"=>$cgdCode,
"bkcode"=>"",
"wsm_code"=>$wsm_code,
"cgder"=>$data['good_creater'],
"cgder_id"=>$data['good_createrid'],
"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'],
"nake_fee"=>$data['nake_fee'],
"weight"=>$data['weight'],
"delivery_fee"=>$data['delivery_fee'],
"gold_price"=>$data['gold_price'],
"diff_weight"=>"0",
"diff_fee"=>"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'],
"order_source"=>$data['order_source'],
"good_type"=>$data['good_type'],
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s"),
'good_createrid' => $data['good_createrid'],
'good_creater' => $data['good_createrid'],//商品创建人
'from_tag' => isset($from_tag[$data['supplierNo']]) ? 2 : 1,//来源标签：1采销(默认),2供应商端
];
$up =Db::name("purchease_order")->insertGetId($cg);
if($up){
//修改状态，添加待办
ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_code" => $cg['cgdNo'],//销售单code
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "CGD", $cg['status'], $cg);
ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname], [
"order_type" => 'CGD',
"order_code" => $cg['cgdNo'],//销售单code
"order_id" => $up,
"order_status" => $cg['status'],
"before_status"=> 0,
'holder_id' => $supplier['personid'],
'wait_id' => $supplier['personid'],
'wait_name' => $supplier['person'],
]);
$standing_book_da = array_merge($standing_book_da, [
'orderCode' => $data['orderCode'],
'cgdNo' => $cgdCode,
'spuCode' => $data['spuCode'],
'skuCode' => $data['skuCode'],
'order_type' => $data['order_type'],
'order_source' => $data['order_source'],
'supplierNo' => $data['supplierNo'],
"companyNo" => $data['companyNo'],
]);
$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
];
Db::name("order_num")->save($rela);
$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"=>$data['good_num'],
"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")
];
}else{
$stokc['wait_in_stock']+=$data['good_num'];
$stokc['updatetime']=date("Y-m-d H:i:s");
}
$stoc= Db::name("good_stock")->save($stokc);
if($stoc==false) throw new Exception('商品仓库库存修改失败');
$good_data[] = ['good_log_code' =>$cgdCode, "stock_id" => isset($stoc['id'])?$stoc['id']:Db::name("good_stock")->getLastInsID(), "type" => 1,'stock'=>$data['good_num'], "stock_name" => "wait_in_stock"];
GoodLog::LogAdd($data['token'],$good_data,"CGD");
return true;
}else throw new Exception('商品仓库库存修改失败');
}
//创建采购单
/**
* 非咨询类商品处理
* @param int $orid 售后记录的id
* @param string $spuCode 商品的spuCode
* @param array $info 售后申请单的详情
* @param array $old_sale 原始销售订单信息
* @param int $rm 操作人id
* @param string $ri 操作人名称
* @param array $old_out 原始发货单信息
* @param string $token 当前用户的token
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
private function createSaleNotZixun(int $orid = 0, string $spuCode = '', array $info = [], array $old_sale = [], int $rm = 0, string $ri = '', array $old_out = [], string $token = '')
{
$goodinfo = Db::name('good')
->alias('g')
->field('g.*,gp.skuCode')
->join('good_platform gp', 'gp.spuCode=g.spuCode AND gp.exam_status=6')
->where('g.spuCode', $spuCode)
->where('gp.skuCode', $old_sale['skuCode'])
->find();
if (empty($goodinfo)) return error_show(1005, '查不到这个商品，或该商品已下线无法售后');
$is_activity = $old_sale['is_activity'];
$actcode = $old_sale['activity_code'];
$good_num = $info['error_num'];//数量，取售后申请单中的异常数量
$supplierNo = $old_sale['supplierNo'];
$sale_price = 0;
$origin_price = $old_sale['origin_price'];
$goodtype = $old_sale['good_type'];
$is_stock = $goodinfo['is_stock'];
$skuCode = $goodinfo['skuCode'];
$orderCode = makeNo("QR");
if ($is_stock == 1) {
$stock_num = Db::name("good_stock")->alias("a")
->leftJoin("warehouse_info b", "a.wsm_code=b.wsm_code")
->leftJoin("good_stock_info c", "a.id=c.stockid and c.balance_num>0")
->where(["spuCode" => $spuCode, "a.is_del" => 0, "a.status" => 1, "b.wsm_type" => 5, "b.companyNo" =>$supplierNo])
->sum('balance_num');
if($stock_num < $good_num){
return error_show(1003, "批次库存数量不足"); //库存不足
}
}
$goodinfo['cgd_gold_price'] = 0;
if ($goodtype == 1) {
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']}");
}
// else {
// $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, "未找到相关阶梯价格");
//
// if ($goodinfo['is_gold_price'] == 1 && $is_stock != 1) {
// $gold = Db::name("gold_price1")
// ->field('id,price')
// ->where(["type" => $goodinfo['noble_metal'], "is_del" => 0, "status" => 1])
// ->order("addtime desc")
// ->find();
//
// $goodinfo['cgd_gold_price'] = $gold["price"];
// }
// }
}
//原有采购单信息
if ($is_stock != 1){
$old_cgd = Db::name('order_num')
->alias('on')
->field('on.id onid,po.*')
->leftJoin('purchease_order po', 'po.cgdNo=on.cgdNo')
->where('on.orderCode', $old_sale['orderCode'])
->find();
$cgd = array_merge($old_cgd, [
'id' => null,
// "supplierNo" => $ct['supplierNo'],
// "companyNo" => $supplierNo,
"orderCode" => $orderCode,
"spuCode" => $spuCode,
"skuCode" => $skuCode,
// "good_name" => $ct['good_name'],
"sale_price" => $old_cgd['good_price'],//采购单价格不为0，取原采购单的价格
"total_fee" => $old_cgd['good_price'] * $good_num,
// "pakge_fee" => isset($origin['package_fee']) ? $origin['package_fee'] : 0,
// "cert_fee" => isset($origin['cert_fee']) ? $origin['cert_fee'] : 0,
// "open_fee" => $ct['open_fee'],
// "cost_fee" => isset($origin['cost_fee']) ? $origin['cost_fee'] : 0,
'cost_fee' => $old_cgd['teach_fee'],
// "mark_fee" => isset($origin['mark_fee']) ? $origin['mark_fee'] : 0,
// "nake_fee" => isset($origin['nake_fee']) ? $origin['nake_fee'] : 0,
// "delivery_fee" => isset($origin['delivery_fee']) ? $origin['delivery_fee'] : 0,
// "demo_fee" => $ct['demo_fee'],
"good_num" => $good_num,
// "good_type" => $goodtype,
// "weight" => $ct['noble_weight'],
// "gold_price" => isset($ct['cgd_gold_price']) ? $ct['cgd_gold_price'] : 0,
// "order_type" => $is_stock == 1 ? 1 : 2,
"order_source" => 6,//6售后补换货
"createrid" => $rm,
"creater" => $ri,
// 'send_way' => 2,
'token' => $token,
'addtime' => date('Y-m-d H:i:s'),
'updatetime' => date('Y-m-d H:i:s'),
'good_createrid' => $goodinfo['createrid'],
'good_creater' => $goodinfo['creater'],//商品创建人
]);
// $supplier_temp_info = Db::name('supplier')
// ->field('id,person,personid')
// ->where('code',$cgd['supplierNo'])
// ->findOrEmpty();
$user= new \app\admin\common\User();
$supplier_temp =$user->handle("sInfo",["code"=>$cgd['supplierNo']]);
}else{
$user= new \app\admin\common\User();
$supplier_temp =$user->handle("sInfo",["code"=>$goodinfo['supplierNo']]);
// $supplier_temp_info = Db::name('supplier')
// ->field('id,person,personid')
// ->where('code',$goodinfo['supplierNo'])
// ->findOrEmpty();
}
$supplier_temp_info = [
"id"=>$supplier_temp['data']['id']??0,
"person"=>$supplier_temp['data']['person']??'',
"personid"=>$supplier_temp['data']['personid']??0,
];
// $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"));
// }
// if($send_num>$good_num){
// return error_show(1004,"发货数量超出订单总数量");
// }
// $remark =isset($this->post['remark']) && $this->post['remark'] !=="" ?trim($this->post['remark']):"";
// $proof_id =isset($this->post['proof_id']) && $this->post['proof_id'] !=="" ?intval($this->post['proof_id']):0;
// $apply_id = GetUserInfo($param['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 = array_merge($old_sale, [
'id' => null,
"orderCode" => $orderCode,
"good_code" => $spuCode,
"skuCode" => $skuCode,
// "customer_code" => $info['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" => $old_sale['sale_price'],//取原价格
// "total_price" => $sale_price,//取原总价
// "post_fee" => 0,
// "status" => 0,
"th_num" => 0,
"th_fee" => 0,//退货金额为0
"send_num" => 0,
"wsend_num" => $good_num,
// "send_status" => 0,
// "good_type" => $goodtype,
// "send_type" => $old_sale['send_type'],
// "supplierNo" => $supplierNo,
// "is_del" => 0,
// "zxNo" => "",
// "platform_order" => $old_sale['platform_order'],
// "platform_id" => $old_sale['platform_id'],
"remark" => $old_sale['orderCode'],
// "is_stock" => $is_stock,
"is_activity" => $is_activity,
"activity_code" => $actcode,
// "order_type" => $is_stock == 1 ? 1 : 2,
"order_source" => 6,//6售后补换货
// "poNo"=>$poNo,
// 'good_weight' => $ct['noble_weight'],
// 'gold_price' => isset($ct['cgd_gold_price']) ? $ct['cgd_gold_price'] : 0,
// 'cost_price' => isset($good['cost_fee']) ? $good['cost_fee'] : 0,
// 'diff_weight' => 0,
// 'diff_fee' => 0,
// "workNo" => '',
'status' => 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),
// 'proof_id' => $old_sale['proof_id'],
// 'paytime' => $old_sale['paytime'],
'returnCode' => $info['returnCode'],
'cgderid' => $supplier_temp_info['personid'],
'cgder' => $supplier_temp_info['person'],//采购员(供应商负责人)
'good_createrid' => $goodinfo['createrid'],
'good_creater' => $goodinfo['creater'],//商品创建人
]);
$datainfo = Db::name('sale')->insertGetId($data);
if ($datainfo > 0) {
//修改状态，添加待办
ActionLog::logAdd($token, [
"order_code" => $orderCode,//销售单code
"status" => 0,//这里的status是之前的值
"action_remark" => '',//备注
"action_type" => "create"//新建create，编辑edit，更改状态status
], "XSQRD", 0, $this->post);
ProcessOrder::AddProcess($token, [
"order_type" => 'XSQRD',
"order_code" => $orderCode,//销售单code
"order_id" => $datainfo,
"order_status" => 0,
"before_status" => 0,
'holder_id' => $data['apply_id']
]);
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) throw new Exception('活动库存修改失败');
}
$outstatus = 0;
$standing_book_da = ['sale_id' => $datainfo, 'customer_code' => $old_sale['customer_code'], 'skuCode' => $skuCode, 'updatetime' => date('Y-m-d H:i:s')];
if ($is_stock == 0) $this->createCgd($cgd, $standing_book_da);
else {
$outstatus = 1;
$stockid= 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.wsm_type" => 5, "b.companyNo" =>$supplierNo])
->column('a.id');
$stockinfo =GoodStockInfo::OrderBn($orderCode,$stockid,$good_num);
if($stockinfo==false){
throw new Exception('库存商品更新库存失败');
}
// $bol = $this->RelaCgd([
// 'orderCode' => $orderCode,
// "good_num" => $good_num,
// "spuCode" => $spuCode,
// "companyNo" => $supplierNo,
// "cost_fee" => isset($goodinfo['cost_fee']) ? $goodinfo['cost_fee'] : 0,
// 'order_type' => $data['order_type'],
// 'order_source' => $data['order_source'],
// ], $standing_book_da);
// 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) throw new Exception('库存商品更新库存失败');
// $stockinfo =GoodStockInfo::OrderBn($orderCode,$stock['id'],$good_num);
// if($stockinfo==false){
// throw new Exception('库存商品更新库存失败'); //库存不足
// }
// //商品变动日志表，good_log_code字段存储采购单号
// $good_data[] = ['good_log_code' => $orderCode, "stock_id" => $stock['id'], "type" => 2, 'stock' => $good_num, "stock_name" => "usable_stock"];
// $good_data[] = ['good_log_code' => $orderCode, "stock_id" => $stock['id'], "type" => 1, 'stock' => $good_num, "stock_name" => "wait_out_stock"];
// GoodLog::LogAdd($token, $good_data, "XSQRD");
// }
}
// $old_out = Db::name('order_out')
// ->field('id,addrid,wsm_code')
// ->where(['orderCode' => $info['orderCode'], 'outCode' => $info['outCode']])
// ->find();
$old_out_addr_info = Db::name('order_out')
->alias('oo')
->field('oo.id,oa.addr,oa.addr_code,oa.contactor,oa.mobile,oa.customer_code,oa.post_fee,oa.arrive_time')
->leftJoin('order_addr oa', 'oa.id=oo.addrid')
->where(['oo.outCode' => $info['outCode'], 'oo.orderCode' => $info['orderCode']])
->find();
if (empty($old_out_addr_info)) throw new Exception('发货单对应的地址信息查不到');
$temp = [
'orderCode' => $orderCode,
'addr' => $old_out_addr_info['addr'],
'addr_code' => $old_out_addr_info['addr_code'],
'contactor' => $old_out_addr_info['contactor'],
'mobile' => $old_out_addr_info['mobile'],
'customer_code' => $old_out_addr_info['customer_code'],
'receipt_quantity' => $good_num,
'arrive_time' => $old_out_addr_info['arrive_time'],
'addtime' => date("Y-m-d H:i:s"),
'updatetime' => date("Y-m-d H:i:s"),
// ''=>'',
];
$addrid = Db::name('order_addr')->insertGetId($temp);
$outCode = makeNo("DF");
$out = array_merge($old_out, [
'id' => null,
"orderCode" => $orderCode,
"outCode" => $outCode,
"apply_id" => $rm,
"apply_name" => $ri,
"addrid" => $addrid,
"post_name" => "",
"post_code" => "",
"post_fee" => 0,
"sendtime" => date("Y-m-d H:i:s"),
"send_num" => $good_num,
"check_num" => 0,
"error_num" => 0,
"wsm_code" => isset($old_out['wsm_code']) ? $old_out['wsm_code'] : '',
"order_type" => $is_stock == 1 ? 1 : 2,
"status" => $outstatus,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
]);
Db::name("order_out")->insert($out);
$standing_book_da['outCode'] = $outCode;
if($is_stock==0){
$order = Db::name("order_num")->where(["orderCode" => $orderCode, "status" => 1])->where([["wsend_num", ">=", 0]])->find();
if (empty($order)) throw new Exception('采购单关联数据未找到');
$order['send_num'] += $good_num;
$order['wsend_num'] -= $good_num;
if ($order['wsend_num'] < 0) throw new Exception('发货数量已超出总数');
$ups = Db::name("order_num")->save($order);
if ($ups) {
$sen = Db::name("order_send")->save([
"cgdNo" => $order['cgdNo'],
"outCode" => $outCode,
"send_num" => $good_num,
"status" => 1,
"addtime" => date("Y-m-d H:i:s"),
"updatetime" => date("Y-m-d H:i:s")
]);
if ($sen == false) throw new Exception('发货地址添加创建失败');
}
}
if (!isset($standing_book_da['returnCode'])) $standing_book_da['returnCode'] = '';
if (!isset($standing_book_da['thNo'])) $standing_book_da['thNo'] = '';
if (!isset($standing_book_da['returnGoodCode'])) $standing_book_da['returnGoodCode'] = '';
if (!isset($standing_book_da['wsm_in_code'])) $standing_book_da['wsm_in_code'] = '';
if (!isset($standing_book_da['cgdReturnCode'])) $standing_book_da['cgdReturnCode'] = '';
//处理台账
Db::name('standing_book')->insert(array_merge($standing_book_da, ['addtime' => date('Y-m-d H:i:s'), 'updatetime' => date('Y-m-d H:i:s'), 'standBookNo' => makeNo('IO')]));
//维护售后申请单
Db::name('order_return')
->where(['id' => $orid, 'is_reissue' => 0])
->update([
'is_reissue' => 1,
'newOrderCode' => $orderCode,
'updatetime' => date('Y-m-d H:i:s')
]);
Db::commit();
return error_show(0, "操作成功");
} else throw new Exception('咨询订单创建失败');
} catch (\Exception $e) {
Db::rollback();
return error_show(1005, $e->getMessage() . '|' . $e->getFile() . '|' . $e->getLine());
}
}
//创建采购单
public function RelaCgd($outinfo,array &$standing_book_da=[]){
$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) throw new Exception('未查询到备库单信息');
$good=Db::name("good")
->where(["spuCode"=>$outinfo['spuCode'],"is_del"=>0])
->find();
if($good==false) throw new Exception('未查询到商品信息');
$cgdinfo =Db::name("purchease_order")
->where(['cgdNo'=>$cgd['cgdNo'],"is_del"=>0])
->find();
if($cgdinfo==false) throw new Exception('未查询到采购单信息');
//判断该供应商是否开通了供应商账号
$from_tag=checkHasAccountBySupplierNos([$cgdinfo['supplierNo']]);
$QrdCgd=[
"cgdNo"=>makeNo("CG"),
"bkcode" => $cgdinfo['bkcode'],
'wsm_code'=>$cgdinfo['wsm_code'],
"cgder_id"=>$cgdinfo['cgder_id'],
"cgder"=>$cgdinfo['cgder'],
"spuCode"=>$cgdinfo['spuCode'],
"good_name"=>$cgdinfo['good_name'],
"good_num"=>$outinfo['good_num'],
"good_price"=>$cgdinfo['good_price'],
"total_fee"=>round($cgdinfo['good_price']*$outinfo['good_num'],2),
"pakge_fee"=>$cgdinfo['pakge_fee'],
"cert_fee"=>$cgdinfo['cert_fee'],
"open_fee"=>$cgdinfo['open_fee'],
"delivery_fee"=>$cgdinfo['delivery_fee'],
"mark_fee"=>$cgdinfo['mark_fee'],
"teach_fee"=>$cgdinfo['teach_fee'],
"nake_fee"=>$cgdinfo['nake_fee'],
"demo_fee"=>$cgdinfo['demo_fee'],
"weight"=>$cgdinfo['weight'],
"diff_weight"=>$cgdinfo['diff_weight'],
"diff_fee"=>$cgdinfo['diff_fee'],
"gold_price"=>$cgdinfo['gold_price'],
"supplierNo"=>$cgdinfo['supplierNo'],
"supplier_name"=>$cgdinfo['supplier_name'],
"companyNo"=>$cgdinfo['companyNo'],
"send_status"=>3,
"send_num"=>$outinfo['good_num'],
"wsend_num"=>0,
"remark"=>$cgdinfo['remark'],
"status"=>3,
"lasttime"=>$cgdinfo['lasttime'],
"is_del"=>0,
"order_type"=>$outinfo['order_type'],
"order_source"=>$outinfo['order_source'],
"good_type"=>$cgdinfo['good_type'],
"addtime"=>date("Y-m-d H:i:s"),
"updatetime"=>date("Y-m-d H:i:s"),
'good_createrid' => $good['createrid'],
'good_creater' => $good['creater'],//商品创建人
'from_tag' => isset($from_tag[$cgdinfo['supplierNo']]) ? 2 : 1,//来源标签：1采销(默认),2供应商端
];
$insetrCgd=Db::name("purchease_order")->insert($QrdCgd);
if($insetrCgd==false) throw new Exception('新增采购单失败');
else{
$standing_book_da = array_merge($standing_book_da, [
'orderCode' => $outinfo['orderCode'],
'cgdNo' => $cgdinfo['cgdNo'],
'spuCode' => $outinfo['spuCode'],
'order_type' => $QrdCgd['order_type'],
'order_source' => $QrdCgd['order_source'],
'supplierNo' => $cgdinfo['supplierNo'],
'companyNo' => $cgdinfo['companyNo'],
'bk_code' => $cgdinfo['bkcode'],
'purchease_id' => Db::name('purchease')->where('bk_code', $cgdinfo['bkcode'])->value('id',0),
]);
}
if($good['is_gold_price']==1 && $good['is_stock']==1){
$gold = Db::name("gold_price1")
->field('id,price')
->where(["type" => $good['noble_metal'], "is_del" => 0, "status" => 1])
->order("addtime desc")
->find();
$ct['cgd_gold_price']=$gold["price"];
$updat=[
"sale_price"=>0,
"total_price"=>0,
"origin_price"=>$cgdinfo['good_price'],
"gold_price"=>$gold["price"],
];
Db::name("sale")->where(["orderCode"=>$outinfo['orderCode']])->update($updat);
// if($upsale==false){
// return false;
// }
}
$merge_num = Db::name("purchease_order")
->where(["bkcode"=>$cgdinfo['bkcode'],"order_type"=>1,"is_del"=>0])
->where("order_source","<>",0)
->field("sum(send_num)-sum(th_num) as num")
->find();
$cgd['balance_num']=$cgd['total_num']-$merge_num['num'];
$cgd['merge_num']=$merge_num['num'];
$cgd['updatetime']=date("Y-m-d H:i:s");
$up=Db::name("order_bk")->save($cgd);
if($up==false) throw new Exception('修改备库单失败');
$data=[
"orderCode"=>$outinfo['orderCode'],
"cgdNo"=>$QrdCgd['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) throw new Exception('修改采购单销售单关联失败');
}
//导出
public function export()
{
$param = $this->request->only([
'returnCode',
'outCode' => '',
'status' => '',
'order_type' => '',
'orderCode' => '',
'good_code' => '',
'good_name' => '',
'customer_code' => '',
'except_code' => '',
'apply_name' => '',
'start' => '',
'end' => '',
'company_name' => '',
], 'post', 'trim');
$val = Validate::rule(['returnCode' => 'require|array|max:10']);
if ($val->check($param) == false) return json_show(1004, $val->getError());
$where = [['a.is_del', "=", 0], ['a.returnCode', 'in', $param['returnCode']]];
if ($param['outCode'] !== '') $where[] = ['a.outCode', "like", "%{$param['outCode']}%"];
if ($param['status'] !== '') $where[] = ['a.status', "=", $param['status']];
if ($param['order_type'] !== "") $where[] = ['a.order_type', "=", $param['order_type']];
if ($param['orderCode'] != "") $where[] = ['a.orderCode', "like", "%{$param['orderCode']}%"];
if ($param['good_code'] != "") $where[] = ['a.good_code', "like", "%{$param['good_code']}%"];
if ($param['good_name'] != "") $where[] = ['a.good_name', "like", "%{$param['good_name']}%"];
if ($param['customer_code'] != "") $where[] = ['a.customer_code', "like", "%{$param['customer_code']}%"];
if ($param['except_code'] != "") $where[] = ['a.except_code', "=", $param['except_code']];
if ($param['apply_name'] != "") $where[] = ['a.apply_name', "like", "%{$param['apply_name']}%"];
if ($param['start'] !== "") $where[] = ['a.addtime', ">=", $param['start']];
if ($param['end'] !== "") $where[] = ['a.addtime', "<=", $param['end']];
if ($param['company_name'] !== "") $where[] = ["a.apply_id", 'in', get_company_item_user_by_name($param['company_name'])];
$condition = [];
$hand = resign_hand_user($this->uid, 0);
$role = $this->checkDataShare();
if (!empty($role[DataGroupModel::$type_全部])) {
$arr = array_unique(array_merge($hand, $role[DataGroupModel::$type_全部]));
$condition[] = ["a.person_id", "in", $hand];
$condition[] = ["a.apply_id", "in", $arr];
$condition[] = ["a.cgderid", "in", $hand];
}
// $condition .="a.cgderid in {$hand} or a.person_id in {$hand} or a.apply_id in ("
// .implode(',',$role[DataGroupModel::$type_全部]).")";
$list = Db::name('order_return')
->field('
a.returnCode 售后申请单编码,
a.order_type 订单类型,
a.apply_name 申请人,
a.cgder 采购员,
a.person 采购负责人,
a.outCode 发货单号,
a.is_receive 是否收到货,
a.total_num 总数量,
a.error_num 异常数量,
a.error_msg 异常原因,
a.error_remark 异常备注,
a.except_code 客户意愿,
a.orderCode 订单编号,
a.good_code 商品编号,
a.good_name 商品名称,
a.customer_code 客户编码,
a.is_post 是否承担物流费用,
a.is_th 供应商是否退货,
a.return_tag 退回何处,
a.status 状态,
a.remark 审核备注,
a.addtime 创建时间,
a.updatetime 更新时间,
a.is_reissue 是否完成补发货,
a.newOrderCode 售后完成后新的销售订单号,
a.loop_total 状态从业务公司修改待供应商确认到待采购审核的循环次数,
b.return_wsm 退回仓库,
b.contactor 仓库联系人,
b.mobile 联系方式,
b.addr 地址,
b.addr_code,
b.post_code 快递单号,
b.post_company 快递公司,
b.post_fee 快递费用,
b.gys_remark 供应商备注')
->alias('a')
->where($where)
->where(function ($query) use ($condition) {
$query->whereOr($condition);
})
->leftJoin('order_returninfo b', 'b.returnCode=a.returnCode')
->select()
->toArray();
$order_type = [1 => '直接下单', 2 => '咨询', 3 => '项目', 4 => '平台', 5 => '有赞', 6 => '售后补换货', 7 => '报备转单', 8 => '支付渠道'];
$is_receive = [0 => '否', 1 => '是'];
$except_code = [0 => [1 => '退货', 2 => '补发'], 1 => [1 => '退货', 2 => '换货'],];//期望意愿
$return_tag = [1 => '供应商', 2 => '业务企业'];
$status = [1 => '待业务审核', 2 => '待采购审核', 4 => '待客户退货', 5 => '售后已完成', 6 => '业务已驳回', 8 => '申请已取消', 9 => '供应商审核', 10 => '业务公司修改待供应商确认'];
foreach ($list as &$value) {
$value['订单类型'] = $order_type[$value['订单类型']] ?? '';
$value['客户意愿'] = $except_code[$value['是否收到货']][$value['客户意愿']] ?? '';
$value['是否收到货'] = $is_receive[$value['是否收到货']] ?? '';
$value['是否承担物流费用'] = $is_receive[$value['是否承担物流费用']] ?? '';
$value['供应商是否退货'] = $is_receive[$value['供应商是否退货']] ?? '';
$value['退回何处'] = $return_tag[$value['退回何处']] ?? '';
$value['状态'] = $status[$value['状态']] ?? '';
$value['是否完成补发货'] = $is_receive[$value['是否完成补发货']] ?? '';
$addr_code = explode(',', $value['addr_code']);
$value['地址'] = GetAddr(json_encode(['provice_code' => $addr_code[0], 'city_code' => $addr_code[1], 'area_code' => $addr_code[2]])) . $value['地址'];
unset($value['addr_code']);
}
if (empty($list)) $list[] = ['没有相关可导出的数据'];
excelSave('售后申请单' . date('YmdHis'), array_keys($list[0]), $list);
}
}