896 行
35 KiB
PHP
可执行文件
896 行
35 KiB
PHP
可执行文件
<?php
|
|
|
|
namespace Common\Business;
|
|
|
|
use Addons\Api\RedisController;
|
|
use Common\Model\InventoryGoodsModel;
|
|
use Common\Model\InventoryGoodsSerialModel;
|
|
use Common\Model\InventoryOrderModel;
|
|
use Common\Model\SInventoryGoodsModel;
|
|
use Common\Model\SInventoryGoodsSerialModel;
|
|
use Common\Model\SInventoryOrderModel;
|
|
use Common\Model\SPurchaseGoodsModel;
|
|
|
|
//[1.8.93]
|
|
|
|
/**
|
|
* 盘点操作类
|
|
* Class InventoryOperation
|
|
* [
|
|
* 删除盘点商品记录 deleteGoodsRecord
|
|
* 商户与门店实时盘点实时盘点 storeReal
|
|
* 提交盘点 inventorySubmit
|
|
* 盘盈入库 inventoryMore
|
|
* 盘亏出库 inventoryLess
|
|
* 查询盘点单号 searchOrderNumber
|
|
* 创建订单 createOrder
|
|
* 盘点参数验证 goodsVerify
|
|
* 查看订单状态 getOrderState
|
|
* 获取缓存key getKey
|
|
* 检测锁 testLock
|
|
* 添加缓存 addLock
|
|
* 清除缓存 eliminate
|
|
* ]
|
|
* @package Common\Business
|
|
*/
|
|
class InventoryOperation
|
|
{
|
|
/**
|
|
* 删除盘点商品记录
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* order_id 盘点单id
|
|
* inventory_goods_id 商品记录id
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function deleteGoodsRecord($param)
|
|
{
|
|
try {
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$InventoryGoodsModel = new InventoryGoodsModel();
|
|
$SerialClass = new InventoryGoodsSerialModel();
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$InventoryGoodsModel = new SInventoryGoodsModel();
|
|
$SerialClass = new SInventoryGoodsSerialModel();
|
|
break;
|
|
}
|
|
$InventoryGoodsModel->updateData([
|
|
'id' => is_array($param['inventory_goods_id']) ? ['in', $param['inventory_goods_id']] : $param['inventory_goods_id'],
|
|
'inventory_order_id' => $param['order_id']
|
|
], [
|
|
'state' => 2
|
|
]);
|
|
$SerialClass->deleteData([
|
|
'outside_id' => is_array($param['inventory_goods_id']) ? ['in', $param['inventory_goods_id']] : $param['inventory_goods_id'],
|
|
]);
|
|
return callBack(statusCode()['success'], "删除成功");
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['error'], "删除失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 商户与门店实时盘点
|
|
* @param $param
|
|
* [
|
|
* operator_type 1后台端 2收银端 3助手端
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* operator_id 操作人id
|
|
* supplier_type 1普通供货商 2寄售供货商
|
|
* order_id 盘点单id
|
|
* goodsList 商品信息
|
|
* submit_type 1盘点 2保存草稿箱 3实时盘点
|
|
* remarks 备注
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function storeReal($param)
|
|
{
|
|
$verifyResult = $this->goodsVerify($param); //参数验证
|
|
if ($verifyResult['status'] != 1) {
|
|
return $verifyResult;
|
|
}
|
|
$param['warehouse_id'] = $verifyResult['data']['warehouse_id']; //销售仓id
|
|
try {
|
|
if (!empty($param['order_id'])) {
|
|
//查询盘点单
|
|
$orderResult = $this->searchOrderNumber([
|
|
'user_type' => $param['user_type'],
|
|
'order_id' => $param['order_id']
|
|
]);
|
|
if ($orderResult['status'] != 1) {
|
|
return $orderResult;
|
|
}
|
|
$order_id = $param['order_id'];
|
|
$order_number = $orderResult['data'];
|
|
} else {
|
|
//创建订单
|
|
$orderResult = $this->createOrder([
|
|
'user_type' => $param['user_type'],
|
|
'merchant_id' => $param['merchant_id'],
|
|
'store_id' => $param['store_id'],
|
|
'warehouse_id' => $param['warehouse_id'],
|
|
'remarks' => $param['remarks'],
|
|
'operator_id' => $param['operator_id'],
|
|
]);
|
|
if ($orderResult['status'] != 1) {
|
|
return $orderResult;
|
|
}
|
|
$order_id = $orderResult['data'];
|
|
$order_number = "SP" . orderNumber($order_id); //订单号
|
|
}
|
|
$param['order_id'] = $order_id;
|
|
$param['order_number'] = $order_number;
|
|
if (C('IS_SET_REDIS')) {
|
|
$this->addLock($param);
|
|
}
|
|
$recordResult = $this->inventorySubmit($param); //保存盘点商品记录
|
|
if ($recordResult['status'] != 1) {
|
|
$this->eliminate($param);
|
|
return $recordResult;
|
|
}
|
|
$warehousing_arr = $recordResult['data']['warehousing_arr']; //入库的商品
|
|
$stock_arr = $recordResult['data']['stock_arr']; //出库的商品
|
|
$moneyTotal = $recordResult['data']['moneyTotal']; //盈亏金额
|
|
$numTotal = $recordResult['data']['numTotal']; //盈亏数量
|
|
$record_id_arr = $recordResult['data']['record_id_arr']; //新增的记录信息
|
|
if (!empty($warehousing_arr)) {
|
|
//盘盈
|
|
$param['warehousing_arr'] = $warehousing_arr;
|
|
$moreResult = $this->inventoryMore($param);
|
|
if ($moreResult['status'] != 1) {
|
|
$this->eliminate($param);
|
|
return $moreResult;
|
|
}
|
|
}
|
|
if (!empty($stock_arr)) {
|
|
$param['stock_arr'] = $stock_arr;
|
|
$lossResult = $this->inventoryLess($param);
|
|
if ($lossResult['status'] != 1) {
|
|
$this->eliminate($param);
|
|
return $lossResult;
|
|
}
|
|
}
|
|
$text = [
|
|
'amount' => $moneyTotal,
|
|
'quantity' => $numTotal,
|
|
'goods_species' => count($param['goodsList']),
|
|
'status' => $param['submit_type'] == 1 ? $param['submit_type'] : 2,
|
|
'order_number' => $order_number
|
|
];
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$InventoryOrderModel = new InventoryOrderModel();
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$InventoryOrderModel = new SInventoryOrderModel();
|
|
break;
|
|
}
|
|
$InventoryOrderModel->updateData(['id' => $order_id], $text);
|
|
$this->eliminate($param);
|
|
if ($param['submit_type'] == 3) {
|
|
//实时盘点
|
|
return callBack(statusCode()['success'], "操作成功", ['record_id_arr' => $record_id_arr, 'order_id' => $order_id]);
|
|
} else {
|
|
return callBack(statusCode()['success'], "操作成功");
|
|
}
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['error'], "操作失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 盘盈入库
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* operator_id 操作人id
|
|
* warehousing_arr 入库商品信息
|
|
* order_number 订单号
|
|
* warehouse_id 仓库id
|
|
* remarks 备注
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function inventoryMore($param)
|
|
{
|
|
//盘盈
|
|
$more = [
|
|
'merchant_id' => $param['merchant_id'],
|
|
'operator_id' => $param['operator_id'],
|
|
'warehouse_id' => $param['warehouse_id'],
|
|
'remarks' => $param['remarks'] ? $param['remarks'] : '',
|
|
'type' => 3,
|
|
'goodsList' => $param['warehousing_arr'],
|
|
'order_number' => $param['order_number'],
|
|
];
|
|
try {
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$more['stock'] = 3;
|
|
$res = A('Api/Inventory')->MerWarehousing($more);
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$more['store_id'] = $param['store_id'];
|
|
$more['user_type'] = $param['user_type'];
|
|
$res = A('Api/Inventory')->Warehousing($more);
|
|
break;
|
|
}
|
|
if ($res['status'] == 0) {
|
|
return callBack(statusCode()['error'], "盘盈入库失败");
|
|
}
|
|
return callBack(statusCode()['success'], "入库成功");
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['success'], "入库失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 盘亏出库
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* operator_id 操作人id
|
|
* stock_arr 入库商品信息
|
|
* order_number 订单号
|
|
* warehouse_id 仓库id
|
|
* remarks 备注
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function inventoryLess($param)
|
|
{
|
|
//盘亏
|
|
$loss = [
|
|
'merchant_id' => $param['merchant_id'],
|
|
'operator_id' => $param['operator_id'],
|
|
'warehouse_id' => $param['warehouse_id'],
|
|
'remarks' => $param['remarks'] ? $param['remarks'] : '',
|
|
'goodsList' => $param['stock_arr'],
|
|
'order_number' => $param['order_number'],
|
|
'type' => 2
|
|
];
|
|
try {
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$res = A('Api/Inventory')->MerStockOut($loss);
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$loss['store_id'] = $param['store_id'];
|
|
$loss['user_type'] = $param['user_type'];
|
|
$res = A('Api/Inventory')->stockOut($loss);
|
|
break;
|
|
}
|
|
if ($res['status'] == 0) {
|
|
return callBack(statusCode()['error'], "盘亏出库失败");
|
|
}
|
|
return callBack(statusCode()['success'], "出库成功");
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['success'], "出库失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 提交盘点
|
|
* @param $param
|
|
* [
|
|
* operator_type 1后台端 2收银端 3助手端
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* supplier_type 1普通供货商 2寄售供货商
|
|
* order_id 盘点单id
|
|
* order_number 盘点单号
|
|
* goodsList 商品信息
|
|
* submit_type 1盘点 2保存草稿箱 3实时盘点
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function inventorySubmit($param)
|
|
{
|
|
$merchant_id = $param['merchant_id'];
|
|
$store_id = $param['store_id'] ? $param['store_id'] : 0;
|
|
$supplier_type = $param['supplier_type'] ? $param['supplier_type'] : 1;
|
|
$submit_type = $param['submit_type'];
|
|
$goodsList = $param['goodsList'];
|
|
$order_id = $param['order_id'];
|
|
$order_number = $param['order_number'];
|
|
$warehouse_id = $param['warehouse_id'];
|
|
$time = $_SERVER['REQUEST_TIME'];
|
|
$moneyTotal = 0; //盈亏金额
|
|
$numTotal = 0; //盈亏数量
|
|
$warehousing_arr = []; //入库的商品
|
|
$stock_arr = []; //出库的商品
|
|
$record_id_arr = []; //商品记录id集合
|
|
try {
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$InventoryGoodsModel = new InventoryGoodsModel();
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$InventoryGoodsModel = new SInventoryGoodsModel();
|
|
$PurchaseGoodsModel = new SPurchaseGoodsModel();
|
|
break;
|
|
}
|
|
$SerialClass = new SerialNumberGoods();
|
|
if (!empty($goodsList)) {
|
|
foreach ($goodsList as $key => &$val) {
|
|
$content = [
|
|
'merchant_id' => $merchant_id,
|
|
'warehouse_id' => $warehouse_id,
|
|
'inventory_order_id' => $order_id,
|
|
'inventory_order_number' => $order_number,
|
|
'add_time' => $time,
|
|
'goods_class_id' => $val['goods_class_id'],
|
|
'goods_id' => $val['goods_id'],
|
|
'goods_name' => $val['goods_name'],
|
|
'goods_number' => $val['goods_number'],
|
|
'goods_code' => $val['goods_code'],
|
|
'company' => $val['company'],
|
|
'attribute_state' => $val['attribute_state'],
|
|
'pricing_method' => $val['pricing_method'],
|
|
'goods_num' => $val['goods_num'],
|
|
'cost_price' => $val['cost_price'],
|
|
'inventory_num' => $val['inventory_num'],
|
|
'remarks' => $val['remarks'] ? $val['remarks'] : '',
|
|
'serial_number_state' => $val['serial_number_state'] ? $val['serial_number_state'] : 0
|
|
];
|
|
if (in_array($param['user_type'], ['4', '6'])) {
|
|
//门店
|
|
$content['store_id'] = $store_id;
|
|
$content['purchase_order_id'] = $val['purchase_order_id'] ? $val['purchase_order_id'] : 0;
|
|
}
|
|
$num = round($val['inventory_num'] - $val['goods_num'], 3);
|
|
if ($num > 0) {
|
|
$content['type'] = 1;
|
|
} else if ($num < 0) {
|
|
$content['type'] = 2;
|
|
} else {
|
|
$content['type'] = 0;
|
|
}
|
|
$content['num'] = $num;
|
|
$content['subtotal'] = round($num * $val['cost_price'], 2);
|
|
if ($val['attribute_state'] == 2) {
|
|
$content['sku_id'] = $val['sku_id'];
|
|
$content['sku_name'] = $val['sku_name'];
|
|
$content['sku_goods_number'] = $val['sku_goods_number'];
|
|
$content['sku_code'] = $val['sku_code'];
|
|
$content['sku_num'] = $val['sku_num'];
|
|
$content['sku_id_list'] = $val['sku_id_list'];
|
|
}
|
|
if (!empty($val['inventory_goods_id'])) {
|
|
$InventoryGoodsModel->updateData(array('id' => $val['inventory_goods_id']), $content);
|
|
//串号信息
|
|
if ($val['serial_number_state'] == 1) {
|
|
$SerialClass->inventorySerialDelete([
|
|
'user_type' => $param['user_type'],
|
|
'id' => $val['inventory_goods_id'],
|
|
'goods_id' => $val['goods_id'],
|
|
'sku_id' => $val['sku_id']
|
|
]);
|
|
}
|
|
$outside_id = $val['inventory_goods_id'];
|
|
} else {
|
|
$success = $InventoryGoodsModel->addData($content);
|
|
if ($success['status'] != 1) {
|
|
return callBack($success['error'], $val['goods_name'] . "添加失败");
|
|
}
|
|
$outside_id = $success['data'];
|
|
if ($param['submit_type'] == 3) {
|
|
//实时盘点
|
|
array_push($record_id_arr, [
|
|
'attribute_state' => $val['attribute_state'],
|
|
'goods_id' => $val['goods_id'],
|
|
'sku_id' => $val['sku_id'],
|
|
'inventory_goods_id' => $success['data'],
|
|
]);
|
|
}
|
|
}
|
|
//串号记录
|
|
if ($val['serial_number_state'] == 1 && $val['inventory_num'] > 0) {
|
|
$serialResult = $SerialClass->inventorySerial([
|
|
'user_type' => $param['user_type'],
|
|
'merchant_id' => $merchant_id,
|
|
'store_id' => $store_id ? $store_id : 0,
|
|
'outside_id' => $outside_id,
|
|
'goods_id' => $val['goods_id'],
|
|
'sku_id' => $val['sku_id'],
|
|
'add_time' => $time,
|
|
'serial_list' => $val['serial_list']
|
|
]);
|
|
if ($serialResult['status'] != 1) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . $val['sku_name'] . '串号记录添加失败');
|
|
}
|
|
}
|
|
$moneyTotal += $content['subtotal'];
|
|
$numTotal += $num;
|
|
if ($submit_type == 1) {
|
|
//盘点
|
|
if ($num == 0 && $val['serial_number_state'] == 1) {
|
|
$serialResult = $SerialClass->inventoryScreen([
|
|
'user_type' => $param['user_type'],
|
|
'merchant_id' => $merchant_id,
|
|
'store_id' => $store_id,
|
|
'goods_id' => $val['goods_id'],
|
|
'sku_id' => $val['sku_id'] ? $val['sku_id'] : 0,
|
|
'type' => 3,
|
|
'num' => 0,
|
|
'serial_list' => $val['serial_list'],
|
|
'add_time' => $time
|
|
]);
|
|
if ($serialResult['status'] != 1) {
|
|
return $serialResult;
|
|
}
|
|
} else if ($num > 0) { //盘盈
|
|
$new_arr = $content;
|
|
//串号处理
|
|
if ($val['serial_number_state'] == 1) {
|
|
$serialResult = $SerialClass->inventoryScreen([
|
|
'user_type' => $param['user_type'],
|
|
'merchant_id' => $merchant_id,
|
|
'store_id' => $store_id,
|
|
'goods_id' => $val['goods_id'],
|
|
'sku_id' => $val['sku_id'] ? $val['sku_id'] : 0,
|
|
'type' => 1,
|
|
'num' => $num,
|
|
'serial_list' => $val['serial_list'],
|
|
'add_time' => $time
|
|
]);
|
|
if ($serialResult['status'] != 1) {
|
|
return $serialResult;
|
|
}
|
|
$new_arr['serial_list'] = $serialResult['data']['serial_arr']; //入库串号信息
|
|
}
|
|
$new_arr['id'] = $val['id'];
|
|
$new_arr['warehouse_price'] = $val['cost_price'];
|
|
$new_arr['warehouse_num'] = $num;
|
|
if ($supplier_type == 2 && !empty($val['purchase_order_id'])) {
|
|
//寄售门店
|
|
$pur_map = array(
|
|
'store_id' => $store_id,
|
|
'goods_id' => $val['goods_id'],
|
|
'purchase_order_id' => $val['purchase_order_id']
|
|
);
|
|
if ($val['attribute_state'] == 2) {
|
|
$pur_map['sku_id'] = $val['sku_id'];
|
|
}
|
|
$pru_info = $PurchaseGoodsModel->getFieldInfo($pur_map, "supplier_id,purchase_price");
|
|
$new_arr['warehouse_price'] = $pru_info['purchase_price'] ? $pru_info['purchase_price'] : $val['cost_price'];
|
|
$new_arr['supplier_id'] = $pru_info['supplier_id'];
|
|
}
|
|
array_push($warehousing_arr, $new_arr);
|
|
} else if ($num < 0) { //盘亏
|
|
$new_arr = $content;
|
|
if ($val['serial_number_state'] == 1) {
|
|
$serialResult = $SerialClass->inventoryScreen([
|
|
'user_type' => $param['user_type'],
|
|
'merchant_id' => $merchant_id,
|
|
'store_id' => $store_id ? $store_id : 0,
|
|
'goods_id' => $val['goods_id'],
|
|
'sku_id' => $val['sku_id'] ? $val['sku_id'] : 0,
|
|
'type' => 2,
|
|
'num' => abs($num),
|
|
'serial_list' => $val['serial_list'],
|
|
'add_time' => $time
|
|
]);
|
|
if ($serialResult['status'] != 1) {
|
|
return $serialResult;
|
|
}
|
|
$new_arr['serial_list'] = $serialResult['data']['serial_arr']; //出库串号信息
|
|
}
|
|
$new_arr['id'] = $val['id'];
|
|
$new_arr['stock_price'] = $val['cost_price'];
|
|
$new_arr['output_num'] = round($val['goods_num'] - $val['inventory_num'], 3);
|
|
array_push($stock_arr, $new_arr);
|
|
}
|
|
unset($new_arr);
|
|
}
|
|
}
|
|
}
|
|
return callBack(statusCode()['success'], "盘点记录保存成功", [
|
|
'warehousing_arr' => $warehousing_arr,
|
|
'stock_arr' => $stock_arr,
|
|
'moneyTotal' => $moneyTotal,
|
|
'numTotal' => $numTotal,
|
|
'record_id_arr' => $record_id_arr
|
|
]);
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['error'], "操作失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 查询盘点单号
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* order_id 盘点单id
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function searchOrderNumber($param)
|
|
{
|
|
try {
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$InventoryOrderModel = new InventoryOrderModel();
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$InventoryOrderModel = new SInventoryOrderModel();
|
|
break;
|
|
}
|
|
$order_info = $InventoryOrderModel->getFieldInfo(['id' => $param['order_id']], "order_number,status");
|
|
if (empty($order_info)) {
|
|
return callBack(statusCode()['error'], "未找到该盘点单号");
|
|
}
|
|
if ($order_info['status'] == 1) {
|
|
return callBack(statusCode()['error'], "该订单已盘点完成");
|
|
}
|
|
return callBack(statusCode()['success'], "查询成功", $order_info['order_number']);
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['error'], "查询失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 创建订单
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* warehouse_id 销售仓id
|
|
* remarks 备注
|
|
* operator_id 操作人id
|
|
*
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function createOrder($param)
|
|
{
|
|
$data = [
|
|
'merchant_id' => $param['merchant_id'],
|
|
'warehouse_id' => $param['warehouse_id'],
|
|
'remarks' => $param['remarks'],
|
|
'add_time' => time(),
|
|
'operator_id' => $param['operator_id']
|
|
];
|
|
try {
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$InventoryOrderModel = new InventoryOrderModel();
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$data['store_id'] = $param['store_id'];
|
|
if ($param['user_type'] == 6) { //收银员
|
|
$data['operator_type'] = 1;
|
|
}
|
|
$InventoryOrderModel = new SInventoryOrderModel();
|
|
break;
|
|
}
|
|
$InventoryOrder = $InventoryOrderModel->addData($data);
|
|
if ($InventoryOrder['status'] == 0) {
|
|
return callBack(statusCode()['error'], "订单创建失败");
|
|
}
|
|
return callBack(statusCode()['success'], "创建成功", $InventoryOrder['data']);
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['error'], "操作失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 盘点参数验证
|
|
* @param $param
|
|
* [
|
|
* operator_type 1后台端 2收银端 3助手端
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* supplier_type 1普通供货商 2寄售供货商
|
|
* goodsList 商品信息
|
|
* submit_type 1盘点 2保存草稿箱 3实时盘点
|
|
* order_id 订单id
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function goodsVerify($param)
|
|
{
|
|
$VerifyClass = new VerifyParam(); //参数验证
|
|
$verifyResult = $VerifyClass->identityVerify($param);
|
|
if ($verifyResult['status'] != 1) {
|
|
return $verifyResult;
|
|
}
|
|
if (!empty($param['order_id'])) {
|
|
$cacheResult = $this->testLock($param);
|
|
if ($cacheResult['status'] != 1) {
|
|
return $cacheResult;
|
|
}
|
|
$orderStateResult = $this->getOrderState($param);
|
|
if ($orderStateResult['status'] != 1) {
|
|
return $orderStateResult;
|
|
}
|
|
}
|
|
if (!in_array($param['submit_type'], ['1', '2', '3'])) {
|
|
return callBack(statusCode()['error'], "未知的提交类型");
|
|
}
|
|
if (empty($param['goodsList']) && empty($param['order_id'])) {
|
|
return callBack(statusCode()['error'], "缺少商品信息");
|
|
}
|
|
if (empty($param['goodsList']) && empty($param['order_id'])) {
|
|
return callBack(statusCode()['error'], "请选择盘点的商品");
|
|
}
|
|
if (count($param['goodsList']) > 500) {
|
|
return callBack(statusCode()['error'], "一次盘点商品上限为500种商品");
|
|
}
|
|
try {
|
|
$WarehouseClass = new Warehouse();
|
|
$warehouseResult = $WarehouseClass->getSaleWarehouseId([
|
|
'user_type' => $param['user_type'] == '6' ? '4' : $param['user_type'],
|
|
'merchant_id' => $param['merchant_id'],
|
|
'store_id' => $param['store_id'] ? $param['store_id'] : 0
|
|
]);
|
|
if ($warehouseResult['status'] != 1) {
|
|
return callBack(statusCode()['error'], "请创建供给仓");
|
|
}
|
|
$data = [];
|
|
$goodsList = $param['goodsList'];
|
|
$reg1 = "/^[0-9]+(.[0-9]{1,2})?$/";
|
|
$reg2 = "/^[0-9]+(.[0-9]{1,3})?$/";
|
|
$reg3 = "/^\+?[0-9][0-9]*$/";
|
|
$SerialClass = new SerialNumberGoods();
|
|
foreach ($goodsList as $val) {
|
|
if (empty($val['cost_price'])) {
|
|
return callBack(statusCode()['error'], "成本价有误,未入库的商品禁止盘点");
|
|
}
|
|
if (!preg_match($reg1, $val['cost_price'])) {
|
|
return callBack(statusCode()['error'], "请输入正确价格");
|
|
}
|
|
switch ($val['attribute_state']) {
|
|
case 1:
|
|
//无规格
|
|
if ($val['pricing_method'] == 1) {
|
|
//无称重
|
|
if (!preg_match($reg3, $val['inventory_num'])) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . "请输入正确库存");
|
|
}
|
|
if (!preg_match($reg3, abs($val['goods_num']))) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . "商品称重属性改变，库存有误");
|
|
}
|
|
} else {
|
|
if (!preg_match($reg2, $val['inventory_num'])) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . "请输入正确盘点数量");
|
|
}
|
|
if (!preg_match($reg2, abs($val['goods_num']))) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . "商品称重属性改变，库存有误");
|
|
}
|
|
}
|
|
break;
|
|
case 2:
|
|
//规格
|
|
if (!preg_match($reg3, $val['inventory_num'])) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . $val['sku_name'] . "请输入正确盘点数量");
|
|
}
|
|
if (!preg_match($reg3, abs($val['goods_num']))) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . $val['sku_name'] . "商品称重属性改变，库存有误");
|
|
}
|
|
break;
|
|
default:
|
|
return callBack(statusCode()['error'], $val['goods_name'] . "商品规格属性错误,禁止盘点");
|
|
break;
|
|
}
|
|
//串号信息
|
|
if ($val['serial_number_state'] == 1 && $val['inventory_num'] != 0 && empty($val['serial_list'])) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . "商品串号信息有误");
|
|
}
|
|
if ($val['serial_number_state'] == 1 && !empty($val['serial_list'])) {
|
|
$serialResult = $SerialClass->serialVerify([
|
|
'serial_list' => $val['serial_list'],
|
|
'data' => $data
|
|
]);
|
|
if ($serialResult['status'] != 1) {
|
|
return callBack(statusCode()['error'], $val['goods_name'] . $val['sku_name'] . $serialResult['message']);
|
|
}
|
|
$data = $serialResult['data'];
|
|
}
|
|
if (($param['user_type'] == 4 || $param['user_type'] == 6) && $param['supplier_type'] == 2 && ($val['inventory_num'] > $val['goods_num']) && !empty($val['pur_id']) && empty($val['purchase_order_id'])) {
|
|
//寄售门店
|
|
return callBack(statusCode()['error'], $val['goods_name'] . $val['sku_name'] . "请与批次号绑定");
|
|
}
|
|
}
|
|
return callBack(statusCode()['success'], "验证成功", [
|
|
'warehouse_id' => $warehouseResult['data']
|
|
]);
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['error'], "验证失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 查看订单状态
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* order_id 订单id
|
|
* merchant_id
|
|
* store_id
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function getOrderState($param)
|
|
{
|
|
$where = [
|
|
'merchant_id' => $param['merchant_id'],
|
|
'id' => $param['order_id']
|
|
];
|
|
try {
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$InventoryModel = new InventoryOrderModel();
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$where['store_id'] = $param['store_id'];
|
|
$InventoryModel = new SInventoryOrderModel();
|
|
break;
|
|
}
|
|
|
|
$status = $InventoryModel->getFindField($where, "status");
|
|
if ($status == 1) {
|
|
return callBack(statusCode()['error'], "该订单已提交盘点,禁止操作");
|
|
} else {
|
|
return callBack(statusCode()['success'], "可以操作");
|
|
}
|
|
} catch (\Exception $e) {
|
|
return callBack(statusCode()['error'], "操作失败");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 获取缓存key
|
|
* @param $param
|
|
* [
|
|
* order_id 订单id
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* ]
|
|
* @return string
|
|
*/
|
|
public function getKey($param)
|
|
{
|
|
switch ($param['user_type']) {
|
|
case 3:
|
|
//商户
|
|
$key_name = 'retail_inventory_merchant_id_' . $param['merchant_id'] . '_order_id_' . $param['order_id'];
|
|
break;
|
|
case 4:
|
|
case 6:
|
|
//门店
|
|
$key_name = 'retail_inventory_merchant_id_' . $param['merchant_id'] . '_store_id_' . $param['store_id'] . '_order_id_' . $param['order_id'];
|
|
break;
|
|
}
|
|
return $key_name;
|
|
}
|
|
|
|
|
|
/**
|
|
* 检测锁
|
|
* @param $param
|
|
* [
|
|
* order_id 订单id
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* ]
|
|
* @return mixed
|
|
*/
|
|
public function testLock($param)
|
|
{
|
|
if (C('IS_SET_REDIS')) {
|
|
$key_name = $this->getKey($param);
|
|
$CacheClass = new CacheHandle();
|
|
$CacheClass->testingKey($key_name);
|
|
$keyState = $CacheClass->isExists($key_name);
|
|
if ($keyState == 1) {
|
|
return callBack(statusCode()['error'], "该订单正在操作中,请稍后重试");
|
|
} else {
|
|
return callBack(statusCode()['success'], "可以操作");
|
|
}
|
|
} else {
|
|
return callBack(statusCode()['success'], "可以操作");
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 添加缓存
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* order_id
|
|
* ]
|
|
*/
|
|
public function addLock($param)
|
|
{
|
|
if (C('IS_SET_REDIS')) {
|
|
$arr = [
|
|
'merchant_id' => $param['merchant_id'],
|
|
'order_id' => $param['order_id']
|
|
];
|
|
if ($param['user_type'] != 3) {
|
|
$arr['store_id'] = $param['store_id'];
|
|
}
|
|
$key_name = $this->getKey($param);
|
|
$ApiRedis = new RedisController();
|
|
$ApiRedis::$redis->multi(); //开启事务
|
|
$CacheClass = new CacheHandle();
|
|
$CacheClass->addTimeCache($key_name, 60, $arr);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 清除缓存
|
|
* @param $param
|
|
* [
|
|
* user_type 3商户 4门店 6收银员
|
|
* merchant_id
|
|
* store_id
|
|
* order_id
|
|
* ]
|
|
*/
|
|
public function eliminate($param)
|
|
{
|
|
if (C('IS_SET_REDIS')) {
|
|
$key_name = $this->getKey($param);
|
|
$CacheClass = new CacheHandle();
|
|
$CacheClass->eliminateCache($key_name);
|
|
$ApiRedis = new RedisController();
|
|
$ApiRedis::$redis->exec();
|
|
}
|
|
}
|
|
} |