1316 lines
47 KiB
PHP
Executable File
1316 lines
47 KiB
PHP
Executable File
<?php
|
||
namespace wstmart\home\model;
|
||
use wstmart\common\model\Goods as CGoods;
|
||
use think\Db;
|
||
/**
|
||
* ============================================================================
|
||
* 商品类
|
||
*/
|
||
class Goods extends CGoods{
|
||
/**
|
||
* 上架商品列表
|
||
*/
|
||
public function saleByPage(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$where = [];
|
||
$where['shopId'] = $shopId;
|
||
$where['goodsStatus'] = 1;
|
||
$where['dataFlag'] = 1;
|
||
$where['isSale'] = 1;
|
||
$goodsType = input('goodsType');
|
||
if($goodsType!='')$where['goodsType'] = (int)$goodsType;
|
||
$c1Id = (int)input('cat1');
|
||
$c2Id = (int)input('cat2');
|
||
$goodsName = input('goodsName');
|
||
if($goodsName != ''){
|
||
$where['goodsName|m.goodsId'] = ['like',"%$goodsName%"];
|
||
}
|
||
if($c2Id!=0 && $c1Id!=0){
|
||
$where['shopCatId2'] = $c2Id;
|
||
}else if($c1Id!=0){
|
||
$where['shopCatId1'] = $c1Id;
|
||
}
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$where['m.shopId'] = $shopId;
|
||
$rs = $this->alias('m')->join('store_recom sr','sr.goodsId=m.goodsId','left')
|
||
->where($where)
|
||
->field('m.goodsId,goodsName,goodsImg,goodsType,goodsSn,isSale,isBest,isHot,isNew,isRecom,sr.storeStatus,goodsStock,saleNum,shopPrice,isSpec')
|
||
->order('saleTime', 'desc')
|
||
->paginate(input('pagesize/d'))->toArray();
|
||
foreach ($rs['Rows'] as $key => $v){
|
||
$rs['Rows'][$key]['verfiycode'] = WSTShopEncrypt($shopId);
|
||
}
|
||
return $rs;
|
||
}
|
||
/**
|
||
* 审核中的商品
|
||
*/
|
||
public function auditByPage(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$where['shopId'] = $shopId;
|
||
$where['goodsStatus'] = 0;
|
||
$where['dataFlag'] = 1;
|
||
$where['isSale'] = 1;
|
||
$goodsType = input('goodsType');
|
||
if($goodsType!='')$where['goodsType'] = (int)$goodsType;
|
||
$c1Id = (int)input('cat1');
|
||
$c2Id = (int)input('cat2');
|
||
$goodsName = input('goodsName');
|
||
if($goodsName != ''){
|
||
$where['goodsName'] = ['like',"%$goodsName%"];
|
||
}
|
||
if($c2Id!=0 && $c1Id!=0){
|
||
$where['shopCatId2'] = $c2Id;
|
||
}else if($c1Id!=0){
|
||
$where['shopCatId1'] = $c1Id;
|
||
}
|
||
|
||
$rs = $this->alias('m')
|
||
->where($where)
|
||
->field('goodsId,goodsName,goodsImg,goodsType,goodsSn,isSale,isBest,isHot,isNew,isRecom,goodsStock,saleNum,shopPrice,isSpec')
|
||
->order('saleTime', 'desc')
|
||
->paginate(input('pagesize/d'))->toArray();
|
||
foreach ($rs['Rows'] as $key => $v){
|
||
$rs['Rows'][$key]['verfiycode'] = WSTShopEncrypt($shopId);
|
||
}
|
||
return $rs;
|
||
}
|
||
/**
|
||
* 仓库中的商品
|
||
*/
|
||
public function storeByPage(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$where['shopId']=$shopId;
|
||
$where['dataFlag'] = 1;
|
||
$where['isSale'] = 0;
|
||
$goodsType = input('goodsType');
|
||
if($goodsType!='')$where['goodsType'] = (int)$goodsType;
|
||
$c1Id = (int)input('cat1');
|
||
$c2Id = (int)input('cat2');
|
||
$goodsName = input('goodsName');
|
||
if($goodsName != ''){
|
||
$where['goodsName'] = ['like',"%$goodsName%"];
|
||
}
|
||
if($c2Id!=0 && $c1Id!=0){
|
||
$where['shopCatId2'] = $c2Id;
|
||
}else if($c1Id!=0){
|
||
$where['shopCatId1'] = $c1Id;
|
||
}
|
||
$rs = $this->alias('m')
|
||
->where($where)
|
||
->where('goodsStatus','<>',-1)
|
||
->field('goodsId,goodsName,goodsImg,goodsType,goodsSn,isSale,isBest,isHot,isNew,isRecom,goodsStock,saleNum,shopPrice,isSpec')
|
||
->order('saleTime', 'desc')
|
||
->paginate(input('pagesize/d'))->toArray();
|
||
foreach ($rs['Rows'] as $key => $v){
|
||
$rs['Rows'][$key]['verfiycode'] = WSTShopEncrypt($shopId);
|
||
}
|
||
return $rs;
|
||
}
|
||
/**
|
||
* 违规的商品
|
||
*/
|
||
public function illegalByPage(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$where['shopId'] = $shopId;
|
||
$where['goodsStatus'] = -1;
|
||
$where['dataFlag'] = 1;
|
||
$where['isSale'] = 1;
|
||
$goodsType = input('goodsType');
|
||
if($goodsType!='')$where['goodsType'] = (int)$goodsType;
|
||
$c1Id = (int)input('cat1');
|
||
$c2Id = (int)input('cat2');
|
||
$goodsName = input('goodsName');
|
||
if($goodsName != ''){
|
||
$where['goodsName'] = ['like',"%$goodsName%"];
|
||
}
|
||
if($c2Id!=0 && $c1Id!=0){
|
||
$where['shopCatId2'] = $c2Id;
|
||
}else if($c1Id!=0){
|
||
$where['shopCatId1'] = $c1Id;
|
||
}
|
||
|
||
$rs = $this->alias('m')
|
||
->where($where)
|
||
->field('goodsId,goodsName,goodsImg,goodsType,goodsSn,isSale,isBest,isHot,isNew,isRecom,illegalRemarks,goodsStock,saleNum,shopPrice,isSpec')
|
||
->order('saleTime', 'desc')
|
||
->paginate(input('pagesize/d'))->toArray();
|
||
foreach ($rs['Rows'] as $key => $v){
|
||
$rs['Rows'][$key]['verfiycode'] = WSTShopEncrypt($shopId);
|
||
}
|
||
return $rs;
|
||
}
|
||
/**
|
||
* 违规的商品
|
||
*/
|
||
public function limitPriceByPage(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$where['lp.shopId'] = $shopId;
|
||
$where['goodsStatus'] = 1;
|
||
$where['lp.dataFlag'] = 1;
|
||
$where['m.dataFlag'] = 1;
|
||
$where['isSale'] = 1;
|
||
$goodsType = input('goodsType');
|
||
if($goodsType!='')$where['goodsType'] = (int)$goodsType;
|
||
$c1Id = (int)input('cat1');
|
||
$c2Id = (int)input('cat2');
|
||
$goodsName = input('goodsName');
|
||
if($goodsName != ''){
|
||
$where['goodsName'] = ['like',"%$goodsName%"];
|
||
}
|
||
if($c2Id!=0 && $c1Id!=0){
|
||
$where['shopCatId2'] = $c2Id;
|
||
}else if($c1Id!=0){
|
||
$where['shopCatId1'] = $c1Id;
|
||
}
|
||
$rs = $this->alias('m')
|
||
->join('limit_price lp','lp.goodsId=m.goodsId','left')
|
||
->join('goods_specs gs','gs.id=lp.goodsSpecsId','left')
|
||
->where($where)
|
||
->field('m.goodsId,goodsName,goodsImg,goodsType,goodsStock,specPrice,m.saleNum,limitPrice,lp.productNo,lp.id,shopPrice,from_unixtime(startTime)startTime,from_unixtime(endTime)endTime')
|
||
->order('saleTime', 'desc')
|
||
->paginate(input('pagesize/d'))->toArray();
|
||
foreach ($rs['Rows'] as $key => $v){
|
||
$rs['Rows'][$key]['verfiycode'] = WSTShopEncrypt($shopId);
|
||
}
|
||
return $rs;
|
||
}
|
||
/**
|
||
* 获取指定对象
|
||
*/
|
||
public function getLimitGoods(){
|
||
$id=(int)input('id');
|
||
$obj = null;
|
||
if($id>0){
|
||
$obj = Db::name('limit_price')->where(['id'=>$id])->find();
|
||
$obj['startTime']=date('Y-m-d H:i:s',$obj['startTime']);
|
||
$obj['endTime']=date('Y-m-d H:i:s',$obj['endTime']);
|
||
}else{
|
||
$obj = self::getEModel("limit_price");
|
||
}
|
||
return $obj;
|
||
}
|
||
//获取商品规格
|
||
public function getGoodsSpecs(){
|
||
$productNo = input('productNo');
|
||
$res = db('goods_specs')->where(['productNo'=>$productNo])->field('specIds,marketPrice')->find();
|
||
$specs = explode(':',$res['specIds']);
|
||
$data = db('spec_items')->where(['itemId'=>['in',$specs]])->select();
|
||
$rs['itemName'] = implode(',',array_column($data,'itemName'));
|
||
$rs['marketPrice'] = $res['marketPrice'];
|
||
// echo $rs;die;
|
||
//dump($rs);die;
|
||
|
||
exit(json_encode($rs));
|
||
|
||
}
|
||
// 新增限时价格商品
|
||
public function addLimitGoods(){
|
||
$data=[];
|
||
$data['goodsId']=(int)input('goodsId');
|
||
$data['productNo']=input('productNo');
|
||
$data['limitPrice']=input('limitPrice');
|
||
$data['startTime']=strtotime(input('startTime'));
|
||
$data['endTime']=strtotime(input('endTime'));
|
||
$data['shopId']=(int)session('WST_USER.shopId');
|
||
//判断商品是否是自己店铺的
|
||
$goods=db('goods')->where(['goodsId'=>$data['goodsId'],'shopId'=>$data['shopId']])->find();
|
||
if(!$goods) return WSTReturn('无效商品，请重新选择');
|
||
if($data['limitPrice']<=0) return WSTReturn('商品价格必须大于0');
|
||
$find=db('limit_price')->where(['goodsId'=>$data['goodsId'],'shopId'=>$data['shopId'],'productNo'=>$data['productNo'],'dataFlag'=>1])->find();
|
||
if($find) return WSTReturn('此数据已存在',-1);
|
||
//dump($data['limitPrice']);
|
||
if($data['productNo']){
|
||
$data['specIds']=db('goods_specs')->where(['goodsId'=>$data['goodsId'],'productNo'=>$data['productNo']])->value('specIds');
|
||
$data['goodsSpecsId']=db('goods_specs')->where(['goodsId'=>$data['goodsId'],'productNo'=>$data['productNo']])->value('id');
|
||
}
|
||
$result=db('limit_price')->insert($data);
|
||
if($result){
|
||
return WSTReturn("新增成功", 1);
|
||
}else{
|
||
return WSTReturn("新增失败", -1);
|
||
}
|
||
}
|
||
// 编辑限时价格商品
|
||
public function editLimitGoods(){
|
||
$data=[];
|
||
$data['goodsId']=(int)input('goodsId');
|
||
$data['productNo']=input('productNo');
|
||
$data['limitPrice']=input('limitPrice');
|
||
$data['startTime']=strtotime(input('startTime'));
|
||
$data['endTime']=strtotime(input('endTime'));
|
||
$data['shopId']=(int)session('WST_USER.shopId');
|
||
$data['id']=(int)input('id');
|
||
//判断商品是否是自己店铺的
|
||
$goods=db('goods')->where(['goodsId'=>$data['goodsId'],'shopId'=>$data['shopId']])->find();
|
||
if(!$goods) return WSTReturn('无效商品，请重新选择');
|
||
$data['shopId']=(int)session('WST_USER.shopId');
|
||
if($data['productNo']){
|
||
$data['specIds']=db('goods_specs')->where(['id'=>$data['id'],'productNo'=>$data['productNo']])->value('specIds');
|
||
}
|
||
$result=db('limit_price')->where('id',$data['id'])->setField($data);
|
||
if($result){
|
||
return WSTReturn("更新成功", 1);
|
||
}else{
|
||
return WSTReturn("更新失败", -1);
|
||
}
|
||
}
|
||
//删除限时价格商品
|
||
public function delLimitGoods(){
|
||
$id = (int)input('id/d');
|
||
Db::startTrans();
|
||
try{
|
||
$result = db('limit_price')->where(['id'=>$id])->update(['dataFlag'=>-1]);
|
||
if($result){
|
||
Db::commit();
|
||
//标记删除限时价格商品
|
||
return WSTReturn("删除成功", 1);
|
||
}
|
||
}catch (\Exception $e) {
|
||
Db::rollback();errLog($e);
|
||
}
|
||
return WSTReturn('删除失败',-1);
|
||
}
|
||
/**
|
||
* 新增商品
|
||
*/
|
||
public function add(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$data = input('post.');
|
||
$specsIds = input('post.specsIds');
|
||
$basicsMoney = isset($data['basicsMoney']) ? $data['basicsMoney'] : 0;
|
||
if(!is_numeric($basicsMoney)){
|
||
return WSTReturn("商品成本价请填写数字");
|
||
}
|
||
$aloneShop = Db::name('alone_shops')->where(['shopId'=>$shopId,'dataFlag'=>1])->find();
|
||
if($aloneShop && !$basicsMoney){
|
||
return WSTReturn("请填写成本价");
|
||
}
|
||
WSTUnset($data,'goodsId,statusRemarks,goodsStatus,dataFlag,basicsMoney');
|
||
if(isset($data['goodsName'])){
|
||
if(!WSTCheckFilterWords($data['goodsName'],WSTConf("CONF.limitWords"))){
|
||
return WSTReturn("商品名称包含非法字符");
|
||
}
|
||
}
|
||
if(isset($data['goodsTips'])){
|
||
if(!WSTCheckFilterWords($data['goodsTips'],WSTConf("CONF.limitWords"))){
|
||
return WSTReturn("商品促销信息包含非法字符");
|
||
}
|
||
}
|
||
if(isset($data['goodsDesc'])){
|
||
if(!WSTCheckFilterWords($data['goodsDesc'],WSTConf("CONF.limitWords"))){
|
||
return WSTReturn("商品描述包含非法字符");
|
||
}
|
||
}
|
||
if(WSTConf("CONF.isGoodsVerify")==1){
|
||
$data['goodsStatus'] = 0;
|
||
}else{
|
||
$data['goodsStatus'] = 1;
|
||
}
|
||
$data['shopId'] = $shopId;
|
||
$data['saleTime'] = date('Y-m-d H:i:s');
|
||
$data['createTime'] = date('Y-m-d H:i:s');
|
||
$goodsCats = model('GoodsCats')->getParentIs($data['goodsCatId']);
|
||
$data['goodsCatIdPath'] = implode('_',$goodsCats)."_";
|
||
if($data['goodsType']==0){
|
||
$data['isSpec'] = ($specsIds!='')?1:0;
|
||
}else{
|
||
$data['isSpec'] = 0;
|
||
}
|
||
Db::startTrans();
|
||
try{
|
||
//保存插件数据钩子
|
||
hook('beforeEidtGoods',['data'=>&$data]);
|
||
|
||
$shop = model('shops')->get($shopId);
|
||
if($shop['dataFlag'] ==-1 || $shop['shopStatus'] != 1)$data['isSale'] = 0;
|
||
$result = $this->validate(true)->allowField(true)->save($data);
|
||
if(false !== $result){
|
||
$goodsId = $this->goodsId;
|
||
//ect支付方式
|
||
// $ectPay=(int)input('ectPay');
|
||
// $ect['goodsId']=$goodsId;
|
||
// $ect['ectPay']=$ectPay;
|
||
// Db::name('goods_pay')->insert($ect);
|
||
//商品图片
|
||
WSTUseImages(0, $goodsId, $data['goodsImg']);
|
||
//商品相册
|
||
WSTUseImages(0, $goodsId, $data['gallery']);
|
||
//商品描述图片
|
||
WSTEditorImageRocord(0, $goodsId, '',$data['goodsDesc']);
|
||
//建立商品评分记录
|
||
$gs = [];
|
||
$gs['goodsId'] = $goodsId;
|
||
$gs['shopId'] = $shopId;
|
||
Db::name('goods_scores')->insert($gs);
|
||
//如果是实物商品并且有销售规格则保存销售和规格值
|
||
if($data['goodsType']==0 && $specsIds!=''){
|
||
$specsIds = explode(',',$specsIds);
|
||
$specsArray = [];
|
||
foreach ($specsIds as $v){
|
||
$vs = explode('-',$v);
|
||
foreach ($vs as $vv){
|
||
if(!in_array($vv,$specsArray))$specsArray[] = $vv;
|
||
}
|
||
}
|
||
//保存规格名称
|
||
$specMap = [];
|
||
foreach ($specsArray as $v){
|
||
$vv = explode('_',$v);
|
||
$sitem = [];
|
||
$sitem['shopId'] = $shopId;
|
||
$sitem['catId'] = (int)$vv[0];
|
||
$sitem['goodsId'] = $goodsId;
|
||
$sitem['itemName'] = input('post.specName_'.$vv[0]."_".$vv[1]);
|
||
$sitem['itemImg'] = input('post.specImg_'.$vv[0]."_".$vv[1]);
|
||
$sitem['dataFlag'] = 1;
|
||
$sitem['createTime'] = date('Y-m-d H:i:s');
|
||
$itemId = Db::name('spec_items')->insertGetId($sitem);
|
||
if($sitem['itemImg']!='')WSTUseImages(0, $itemId, $sitem['itemImg']);
|
||
$specMap[$v] = $itemId;
|
||
}
|
||
//保存销售规格
|
||
$defaultPrice = 0;//最低价
|
||
$totalStock = 0;//总库存
|
||
$gspecArray = [];
|
||
$isFindDefaultSpec = false;
|
||
$defaultSpec = Input('post.defaultSpec');
|
||
foreach ($specsIds as $v){
|
||
$vs = explode('-',$v);
|
||
$goodsSpecIds = [];
|
||
foreach ($vs as $gvs){
|
||
$goodsSpecIds[] = $specMap[$gvs];
|
||
}
|
||
$gspec = [];
|
||
$gspec['specIds'] = implode(':',$goodsSpecIds);
|
||
$gspec['shopId'] = $shopId;
|
||
$gspec['goodsId'] = $goodsId;
|
||
$gspec['productNo'] = Input('productNo_'.$v);
|
||
$gspec['marketPrice'] = (float)Input('marketPrice_'.$v);
|
||
$gspec['specPrice'] = (float)Input('specPrice_'.$v);
|
||
$gspec['specStock'] = (int)Input('specStock_'.$v);
|
||
$gspec['warnStock'] = (int)Input('warnStock_'.$v);
|
||
//设置默认规格
|
||
if($defaultSpec==$v){
|
||
$isFindDefaultSpec = true;
|
||
$defaultPrice = $gspec['specPrice'];
|
||
$gspec['isDefault'] = 1;
|
||
}else{
|
||
$gspec['isDefault'] = 0;
|
||
}
|
||
$gspecArray[] = $gspec;
|
||
//获取总库存
|
||
$totalStock = $totalStock + $gspec['specStock'];
|
||
}
|
||
if(!$isFindDefaultSpec)return WSTReturn("请选择推荐规格");
|
||
if(count($gspecArray)>0){
|
||
Db::name('goods_specs')->insertAll($gspecArray);
|
||
//更新默认价格和总库存
|
||
$this->where('goodsId',$goodsId)->update(['isSpec'=>1,'shopPrice'=>$defaultPrice,'goodsStock'=>$totalStock]);
|
||
}
|
||
}
|
||
//保存商品属性
|
||
$attrsArray = [];
|
||
$attrRs = Db::name('attributes')->where(['goodsCatId'=>['in',$goodsCats],'isShow'=>1,'dataFlag'=>1])
|
||
->field('attrId')->select();
|
||
foreach ($attrRs as $key =>$v){
|
||
$attrs = [];
|
||
$attrs['attrVal'] = input('attr_'.$v['attrId']);
|
||
if($attrs['attrVal']=='')continue;
|
||
$attrs['shopId'] = $shopId;
|
||
$attrs['goodsId'] = $goodsId;
|
||
$attrs['attrId'] = $v['attrId'];
|
||
$attrs['createTime'] = date('Y-m-d H:i:s');
|
||
$attrsArray[] = $attrs;
|
||
}
|
||
if(count($attrsArray)>0)Db::name('goods_attributes')->insertAll($attrsArray);
|
||
|
||
|
||
if($aloneShop){
|
||
//保存商品成本价
|
||
$basicsArray = [];
|
||
$now = time();
|
||
$basicsArray['shopId'] = $shopId;
|
||
$basicsArray['goodsId'] = $goodsId;
|
||
$basicsArray['basicsMoney'] = $basicsMoney;
|
||
$basicsArray['createTime'] = $now;
|
||
Db::name('alone_goods')->insert($basicsArray);
|
||
}
|
||
hook('afterGoodsEct',['data'=>&$data,'goodsId'=>$goodsId]);
|
||
Db::commit();
|
||
return WSTReturn("新增成功", 1,['id'=>$goodsId]);
|
||
}else{
|
||
return WSTReturn($this->getError(),-1);
|
||
}
|
||
}catch (\Exception $e) {
|
||
Db::rollback();errLog($e);
|
||
return WSTReturn('新增失败',-1);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 编辑商品资料
|
||
*/
|
||
public function edit(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$goodsId = input('post.goodsId/d');
|
||
$specsIds = input('post.specsIds');
|
||
$data = input('post.');
|
||
$basicsMoney = isset($data['basicsMoney']) ? $data['basicsMoney'] : 0;
|
||
if(!is_numeric($basicsMoney)){
|
||
return WSTReturn("商品成本价请填写数字");
|
||
}
|
||
$aloneShop = Db::name('alone_shops')->where(['shopId'=>$shopId,'dataFlag'=>1])->find();
|
||
if($aloneShop && !$basicsMoney){
|
||
return WSTReturn("请填写成本价");
|
||
}
|
||
WSTUnset($data,'goodsId,dataFlag,statusRemarks,goodsStatus,createTime,basicsMoney');
|
||
$ogoods = $this->where(['goodsId'=>$goodsId,'shopId'=>$shopId,'dataFlag'=>1])->field('goodsStatus,goodsType')->find();
|
||
if(empty($ogoods))return WSTReturn('商品不存在');
|
||
if(isset($data['goodsName'])){
|
||
if(!WSTCheckFilterWords($data['goodsName'],WSTConf("CONF.limitWords"))){
|
||
return WSTReturn("商品名称包含非法字符");
|
||
}
|
||
}
|
||
if(isset($data['goodsTips'])){
|
||
if(!WSTCheckFilterWords($data['goodsTips'],WSTConf("CONF.limitWords"))){
|
||
return WSTReturn("商品促销信息包含非法字符");
|
||
}
|
||
}
|
||
if(isset($data['goodsDesc'])){
|
||
if(!WSTCheckFilterWords($data['goodsDesc'],WSTConf("CONF.limitWords"))){
|
||
return WSTReturn("商品描述包含非法字符");
|
||
}
|
||
}
|
||
//违规商品不能直接上架
|
||
if($ogoods['goodsStatus']!=1){
|
||
$data['goodsStatus'] = 0;
|
||
}
|
||
//不允许修改商品类型
|
||
$data['goodsType'] = $ogoods['goodsType'];
|
||
$data['saleTime'] = date('Y-m-d H:i:s');
|
||
$goodsCats = model('GoodsCats')->getParentIs($data['goodsCatId']);
|
||
$data['goodsCatIdPath'] = implode('_',$goodsCats)."_";
|
||
if($data['goodsType']==0){
|
||
$data['isSpec'] = ($specsIds!='')?1:0;
|
||
}else{
|
||
$data['isSpec'] = 0;
|
||
}
|
||
Db::startTrans();
|
||
try{
|
||
//保存插件数据钩子
|
||
hook('beforeEidtGoods',['data'=>&$data]);
|
||
|
||
//商品图片
|
||
WSTUseImages(0, $goodsId, $data['goodsImg'],'goods','goodsImg');
|
||
//商品相册
|
||
WSTUseImages(0, $goodsId, $data['gallery'],'goods','gallery');
|
||
// 商品描述图片
|
||
$desc = $this->where('goodsId',$goodsId)->value('goodsDesc');
|
||
WSTEditorImageRocord(0, $goodsId, $desc, $data['goodsDesc']);
|
||
$shop = model('shops')->get($shopId);
|
||
if($shop['dataFlag'] ==-1 || $shop['shopStatus'] != 1)$data['isSale'] = 0;
|
||
//虚拟商品处理
|
||
if($data['goodsType']==1){
|
||
$counts = Db::name('goods_virtuals')->where(['dataFlag'=>1,'isUse'=>0,'goodsId'=>$goodsId])->Count();
|
||
$data['goodsStock'] = $counts;
|
||
}
|
||
$result = $this->validate(true)->allowField(true)->save($data,['goodsId'=>$goodsId]);
|
||
if(false !== $result){
|
||
//ect支付方式
|
||
$ectPay=(int)input('ectPay');
|
||
$findEct=db('goods_pay')->where('goodsId',$goodsId)->find();
|
||
if($findEct){
|
||
db('goods_pay')->where('goodsId',$goodsId)->update(['ectPay'=>$ectPay]);
|
||
}else{
|
||
db('goods_pay')->insert(['goodsId'=>$goodsId,'ectPay'=>$ectPay]);
|
||
}
|
||
|
||
/**
|
||
* 编辑的时候如果不想影响商品销售规格的销量，那么就要在保存的时候区别对待已经存在的规格和销售规格记录。
|
||
* $specNameMap的保存关系是：array('页面上生成的规格值ID'=>数据库里规则值的ID)
|
||
* $specIdMap的保存关系是:array('页面上生成的销售规格ID'=>数据库里销售规格ID)
|
||
*/
|
||
$specNameMapTmp = explode(',',input('post.specmap'));
|
||
$specIdMapTmp = explode(',',input('post.specidsmap'));
|
||
$specNameMap = [];//规格值对应关系
|
||
$specIdMap = [];//规格和表对应关系
|
||
foreach ($specNameMapTmp as $key =>$v){
|
||
if($v=='')continue;
|
||
$v = explode(':',$v);
|
||
$specNameMap[$v[1]] = $v[0]; //array('页面上的规则值ID'=>数据库里规则值的ID)
|
||
}
|
||
foreach ($specIdMapTmp as $key =>$v){
|
||
if($v=='')continue;
|
||
$v = explode(':',$v);
|
||
$specIdMap[$v[1]] = $v[0]; //array('页面上的销售规则ID'=>数据库里销售规格ID)
|
||
}
|
||
//如果是实物商品并且有销售规格则保存销售和规格值
|
||
if($data['goodsType'] ==0 && $specsIds!=''){
|
||
//把之前之前的销售规格
|
||
$specsIds = explode(',',$specsIds);
|
||
$specsArray = [];
|
||
foreach ($specsIds as $v){
|
||
$vs = explode('-',$v);
|
||
foreach ($vs as $vv){
|
||
if(!in_array($vv,$specsArray))$specsArray[] = $vv;//过滤出不重复的规格值
|
||
}
|
||
}
|
||
//先标记作废之前的规格值
|
||
Db::name('spec_items')->where(['shopId'=>$shopId,'goodsId'=>$goodsId])->update(['dataFlag'=>-1]);
|
||
//保存规格名称
|
||
$specMap = [];
|
||
foreach ($specsArray as $v){
|
||
$vv = explode('_',$v);
|
||
$specNumId = $vv[0]."_".$vv[1];
|
||
$sitem = [];
|
||
$sitem['itemName'] = input('post.specName_'.$specNumId);
|
||
$sitem['itemImg'] = input('post.specImg_'.$specNumId);
|
||
//如果已经存在的规格值则修改，否则新增
|
||
if(isset($specNameMap[$specNumId]) && (int)$specNameMap[$specNumId]!=0){
|
||
$sitem['dataFlag'] = 1;
|
||
WSTUseImages(0, (int)$specNameMap[$specNumId], $sitem['itemImg'],'spec_items','itemImg');
|
||
Db::name('spec_items')->where(['shopId'=>$shopId,'itemId'=>(int)$specNameMap[$specNumId]])->update($sitem);
|
||
$specMap[$v] = (int)$specNameMap[$specNumId];
|
||
}else{
|
||
$sitem['goodsId'] = $goodsId;
|
||
$sitem['shopId'] = $shopId;
|
||
$sitem['catId'] = (int)$vv[0];
|
||
$sitem['dataFlag'] = 1;
|
||
$sitem['createTime'] = date('Y-m-d H:i:s');
|
||
$itemId = Db::name('spec_items')->insertGetId($sitem);
|
||
if($sitem['itemImg']!='')WSTUseImages(0, $itemId, $sitem['itemImg']);
|
||
$specMap[$v] = $itemId;
|
||
}
|
||
}
|
||
//删除已经作废的规格值
|
||
Db::name('spec_items')->where(['shopId'=>$shopId,'goodsId'=>$goodsId,'dataFlag'=>-1])->delete();
|
||
//保存销售规格
|
||
$defaultPrice = 0;//默认价格
|
||
$totalStock = 0;//总库存
|
||
$gspecArray = [];
|
||
//把之前的销售规格值标记删除
|
||
Db::name('goods_specs')->where(['goodsId'=>$goodsId,'shopId'=>$shopId])->update(['dataFlag'=>-1,'isDefault'=>0]);
|
||
$isFindDefaultSpec = false;
|
||
$defaultSpec = Input('post.defaultSpec');
|
||
foreach ($specsIds as $v){
|
||
$vs = explode('-',$v);
|
||
$goodsSpecIds = [];
|
||
foreach ($vs as $gvs){
|
||
$goodsSpecIds[] = $specMap[$gvs];
|
||
}
|
||
$gspec = [];
|
||
$gspec['specIds'] = implode(':',$goodsSpecIds);
|
||
$gspec['productNo'] = Input('productNo_'.$v);
|
||
$gspec['marketPrice'] = (float)Input('marketPrice_'.$v);
|
||
$gspec['specPrice'] = (float)Input('specPrice_'.$v);
|
||
$gspec['initNum'] = (int)Input('initNum_'.$v);//添加起批价数量 mark hsf 20171117
|
||
$gspec['whslePrice'] = (float)Input('whslePrice_'.$v);//添加批发价 mark hsf 20171117
|
||
$gspec['specStock'] = (int)Input('specStock_'.$v);
|
||
$gspec['warnStock'] = (int)Input('warnStock_'.$v);
|
||
//设置默认规格
|
||
if($defaultSpec==$v){
|
||
$gspec['isDefault'] = 1;
|
||
$isFindDefaultSpec = true;
|
||
$defaultPrice = $gspec['specPrice'];
|
||
}else{
|
||
$gspec['isDefault'] = 0;
|
||
}
|
||
//如果是已经存在的值就修改内容，否则新增
|
||
if(isset($specIdMap[$v]) && $specIdMap[$v]!=''){
|
||
$gspec['dataFlag'] = 1;
|
||
Db::name('goods_specs')->where(['shopId'=>$shopId,'id'=>(int)$specIdMap[$v]])->update($gspec);
|
||
}else{
|
||
$gspec['shopId'] = $shopId;
|
||
$gspec['goodsId'] = $goodsId;
|
||
$gspecArray[] = $gspec;
|
||
}
|
||
//获取总库存
|
||
$totalStock = $totalStock + $gspec['specStock'];
|
||
}
|
||
if(!$isFindDefaultSpec)return WSTReturn("请选择推荐规格");
|
||
//删除作废的销售规格值
|
||
Db::name('goods_specs')->where(['goodsId'=>$goodsId,'shopId'=>$shopId,'dataFlag'=>-1])->delete();
|
||
if(count($gspecArray)>0){
|
||
Db::name('goods_specs')->insertAll($gspecArray);
|
||
}
|
||
//更新推荐规格和总库存
|
||
$this->where('goodsId',$goodsId)->update(['isSpec'=>1,'shopPrice'=>$defaultPrice,'goodsStock'=>$totalStock]);
|
||
}
|
||
//保存商品属性
|
||
//删除之前的商品属性
|
||
Db::name('goods_attributes')->where(['goodsId'=>$goodsId,'shopId'=>$shopId])->delete();
|
||
//新增商品属性
|
||
$attrsArray = [];
|
||
$attrRs = Db::name('attributes')->where(['goodsCatId'=>['in',$goodsCats],'isShow'=>1,'dataFlag'=>1])
|
||
->field('attrId')->select();
|
||
foreach ($attrRs as $key =>$v){
|
||
$attrs = [];
|
||
$attrs['attrVal'] = input('attr_'.$v['attrId']);
|
||
if($attrs['attrVal']=='')continue;
|
||
$attrs['shopId'] = $shopId;
|
||
$attrs['goodsId'] = $goodsId;
|
||
$attrs['attrId'] = $v['attrId'];
|
||
$attrs['createTime'] = date('Y-m-d H:i:s');
|
||
$attrsArray[] = $attrs;
|
||
}
|
||
if(count($attrsArray)>0)Db::name('goods_attributes')->insertAll($attrsArray);
|
||
//删除购物车里的商品
|
||
model('common/carts')->delCartByUpdate($goodsId);
|
||
//修改商品成本价
|
||
|
||
if($aloneShop){
|
||
$now = time();
|
||
if(Db::name('alone_goods')->where(['goodsId'=>$goodsId])->find()){
|
||
Db::name('alone_goods')->where(['shopId'=>$shopId,'goodsId'=>$goodsId])->update(['basicsMoney'=>$basicsMoney,'updateTime'=>$now]);
|
||
}else{
|
||
Db::name('alone_goods')->insert(['shopId'=>$shopId,'goodsId'=>$goodsId,'basicsMoney'=>$basicsMoney,'createTime'=>$now,'updateTime'=>$now]);
|
||
}
|
||
|
||
}
|
||
//商品编辑之后执行
|
||
hook('afterEditGoods',['goodsId'=>$goodsId]);
|
||
hook('afterChangeGoodsStatus',['goodsId'=>$goodsId]);
|
||
hook('afterGoodsEct',['data'=>&$data,'goodsId'=>$goodsId]);
|
||
Db::commit();
|
||
return WSTReturn("编辑成功", 1,['id'=>$goodsId]);
|
||
}else{
|
||
return WSTReturn($this->getError(),-1);
|
||
}
|
||
}catch (\Exception $e) {
|
||
Db::rollback();errLog($e);
|
||
dump($e);
|
||
return WSTReturn('编辑失败',-1);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取商品资料方便编辑
|
||
*/
|
||
public function getById($goodsId){
|
||
$rs = $this->alias('g')->join('__ALONE_GOODS__ ag','g.goodsId=ag.goodsId','left')->where(['g.shopId'=>(int)session('WST_USER.shopId'),'g.goodsId'=>$goodsId])->field('g.*,ag.basicsMoney')->find();
|
||
isset($rs['basicsMoney']) ? $rs['basicsMoney'] : $rs['basicsMoney'] = '';
|
||
if(!empty($rs)){
|
||
if($rs['gallery']!='')$rs['gallery'] = explode(',',$rs['gallery']);
|
||
//获取规格值
|
||
$specs = Db::name('spec_cats')->alias('gc')->join('__SPEC_ITEMS__ sit','gc.catId=sit.catId','inner')
|
||
->where(['sit.goodsId'=>$goodsId,'gc.isShow'=>1,'sit.dataFlag'=>1])
|
||
->field('gc.isAllowImg,sit.catId,sit.itemId,sit.itemName,sit.itemImg')
|
||
->order('gc.isAllowImg desc,gc.catSort asc,gc.catId asc')->select();
|
||
$spec0 = [];
|
||
$spec1 = [];
|
||
foreach ($specs as $key =>$v){
|
||
if($v['isAllowImg']==1){
|
||
$spec0[] = $v;
|
||
}else{
|
||
$spec1[] = $v;
|
||
}
|
||
}
|
||
$rs['spec0'] = $spec0;
|
||
$rs['spec1'] = $spec1;
|
||
//获取销售规格
|
||
$rs['saleSpec'] = Db::name('goods_specs')->where('goodsId',$goodsId)->field('id,isDefault,productNo,specIds,marketPrice,specPrice,initNum,whslePrice,specStock,warnStock,saleNum')->select();
|
||
// print_r($rs);die;
|
||
// $rs['saleSpec'][0]['ectPrice'] = ($specPrice * '0.95');
|
||
//获取属性值
|
||
$rs['attrs'] = Db::name('goods_attributes')->alias('ga')->join('attributes a','ga.attrId=a.attrId','inner')
|
||
->where('goodsId',$goodsId)->field('ga.attrId,a.attrType,ga.attrVal')->select();
|
||
$rs['ectPay']=Db::name('goods')->alias('g')->join('goods_pay ge','ge.goodsId=g.goodsId','left')->where('g.goodsId',$goodsId)->value('ectPay');
|
||
// echo $specPrice;die;
|
||
}
|
||
return $rs;
|
||
}
|
||
/**
|
||
* 获取商品资料在前台展示
|
||
*/
|
||
public function getBySale($goodsId){
|
||
$key = input('key');
|
||
// 浏览量
|
||
$this->where('goodsId',$goodsId)->setInc('visitNum',1);
|
||
$rs = Db::name('goods')->where(['goodsId'=>$goodsId,'dataFlag'=>1])->find();
|
||
if(!empty($rs)){
|
||
$rs['read'] = false;
|
||
//判断是否可以公开查看
|
||
$viKey = WSTShopEncrypt($rs['shopId']);
|
||
if(($rs['isSale']==0 || $rs['goodsStatus']==0) && $viKey != $key)return [];
|
||
if($key!='')$rs['read'] = true;
|
||
//获取店铺信息
|
||
$rs['shop'] = model('shops')->getBriefShop((int)$rs['shopId']);
|
||
if(empty($rs['shop']))return [];
|
||
$gallery = [];
|
||
$gallery[] = $rs['goodsImg'];
|
||
if($rs['gallery']!=''){
|
||
$tmp = explode(',',$rs['gallery']);
|
||
$gallery = array_merge($gallery,$tmp);
|
||
}
|
||
$rs['gallery'] = $gallery;
|
||
if($rs['isSpec']==1){
|
||
//获取规格值
|
||
$specs = Db::name('spec_cats')->alias('gc')->join('__SPEC_ITEMS__ sit','gc.catId=sit.catId','inner')
|
||
->where(['sit.goodsId'=>$goodsId,'gc.isShow'=>1,'sit.dataFlag'=>1])
|
||
->field('gc.isAllowImg,gc.catName,sit.catId,sit.itemId,sit.itemName,sit.itemImg')
|
||
->order('gc.isAllowImg desc,gc.catSort asc,gc.catId asc')->select();
|
||
foreach ($specs as $key =>$v){
|
||
$rs['spec'][$v['catId']]['name'] = $v['catName'];
|
||
$rs['spec'][$v['catId']]['list'][] = $v;
|
||
}
|
||
|
||
//获取销售规格
|
||
$sales = Db::name('goods_specs')->where('goodsId',$goodsId)->field('id,isDefault,productNo,specIds,marketPrice,specPrice,specStock')->select();
|
||
if(!empty($sales)){
|
||
foreach ($sales as $key =>$v){
|
||
$str = explode(':',$v['specIds']);
|
||
sort($str);
|
||
unset($v['specIds']);
|
||
$rs['saleSpec'][implode(':',$str)] = $v;
|
||
if($v['isDefault']==1)$rs['defaultSpecs'] = $v;
|
||
}
|
||
}
|
||
}
|
||
//获取商品属性
|
||
$rs['attrs'] = Db::name('attributes')->alias('a')->join('goods_attributes ga','a.attrId=ga.attrId','inner')
|
||
->where(['a.isShow'=>1,'dataFlag'=>1,'goodsId'=>$goodsId])->field('a.attrName,ga.attrVal')
|
||
->order('attrSort asc')->select();
|
||
//获取商品评分
|
||
$rs['scores'] = Db::name('goods_scores')->where('goodsId',$goodsId)->field('totalScore,totalUsers')->find();
|
||
$rs['scores']['totalScores'] = ($rs['scores']['totalScore']==0)?5:WSTScore($rs['scores']['totalScore'],$rs['scores']['totalUsers'],5,0,3);
|
||
WSTUnset($rs, 'totalUsers');
|
||
//品牌名称
|
||
$rs['brandName'] = Db::name('brands')->where(['brandId'=>$rs['brandId']])->value('brandName');
|
||
//关注
|
||
$f = model('Favorites');
|
||
$rs['favShop'] = $f->checkFavorite($rs['shopId'],1);
|
||
$rs['favGood'] = $f->checkFavorite($goodsId,0);
|
||
}
|
||
return $rs;
|
||
}
|
||
|
||
/**
|
||
* 删除商品
|
||
*/
|
||
public function del(){
|
||
$id = input('post.id/d');
|
||
$data = [];
|
||
$data['dataFlag'] = -1;
|
||
Db::startTrans();
|
||
try{
|
||
$result = $this->update($data,['goodsId'=>$id]);
|
||
if(false !== $result){
|
||
WSTUnuseImage('goods','goodsImg',$id);
|
||
WSTUnuseImage('goods','gallery',$id);
|
||
// 商品描述图片
|
||
$desc = $this->where('goodsId',$id)->value('goodsDesc');
|
||
WSTEditorImageRocord(0, $id, $desc,'');
|
||
model('common/carts')->delCartByUpdate($id);
|
||
hook('afterChangeGoodsStatus',['goodsId'=>$id]);
|
||
Db::commit();
|
||
//标记删除购物车
|
||
return WSTReturn("删除成功", 1);
|
||
}
|
||
}catch (\Exception $e) {
|
||
Db::rollback();errLog($e);
|
||
}
|
||
return WSTReturn('删除失败',-1);
|
||
}
|
||
/**
|
||
* 批量删除商品
|
||
*/
|
||
public function batchDel(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$ids = input('post.ids/a');
|
||
Db::startTrans();
|
||
try{
|
||
$rs = $this->where(['goodsId'=>['in',$ids],
|
||
'shopId'=>$shopId])->setField('dataFlag',-1);
|
||
if(false !== $rs){
|
||
//标记删除购物车
|
||
foreach ($ids as $v){
|
||
WSTUnuseImage('goods','goodsImg',(int)$v);
|
||
WSTUnuseImage('goods','gallery',(int)$v);
|
||
// 商品描述图片
|
||
$desc = $this->where('goodsId',(int)$v)->value('goodsDesc');
|
||
WSTEditorImageRocord(0, (int)$v, $desc,'');
|
||
model('common/carts')->delCartByUpdate((int)$v);
|
||
hook('afterChangeGoodsStatus',['goodsId'=>(int)$v]);
|
||
}
|
||
Db::commit();
|
||
return WSTReturn("删除成功", 1);
|
||
}
|
||
}catch (\Exception $e) {
|
||
Db::rollback();errLog($e);
|
||
}
|
||
return WSTReturn('删除失败',-1);
|
||
}
|
||
|
||
/**
|
||
* 批量上架商品
|
||
*/
|
||
public function changeSale(){
|
||
$ids = input('post.ids/a');
|
||
$isSale = (int)input('post.isSale',1);
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
//判断商品是否满足上架要求
|
||
if($isSale==1){
|
||
//0.核对店铺状态
|
||
$shopRs = model('shops')->find($shopId);
|
||
if($shopRs['shopStatus']!=1 || $shopRs['dataFlag']==-1){
|
||
return WSTReturn('上架商品失败!您的店铺权限不能出售商品，如有疑问请与商城管理员联系。',-3);
|
||
}
|
||
//直接设置上架 返回受影响条数
|
||
$where = [];
|
||
$where['g.goodsId'] = ['in',$ids];
|
||
$where['gc.dataFlag'] = 1;
|
||
$where['g.shopId'] = $shopId;
|
||
$where['gc.isShow'] = 1;
|
||
$where['g.goodsImg'] = ['<>',""];
|
||
$rs = $this->alias('g')
|
||
->join('__GOODS_CATS__ gc','g.goodsCatId=gc.CatId','inner')
|
||
->where($where)->setField('isSale',1);
|
||
if($rs!==false){
|
||
//执行钩子事件
|
||
foreach ($ids as $key => $gid) {
|
||
hook('afterChangeGoodsStatus',['goodsId'=>$gid]);
|
||
}
|
||
$status = ($rs==count($ids))?1:2;
|
||
if($status==1){
|
||
return WSTReturn('商品上架成功', 1,['num'=>$rs]);
|
||
}else{
|
||
return WSTReturn('已成功上架商品'.$rs.'件，请核对未能上架的商品信息是否完整。', 2,['num'=>$rs]);
|
||
}
|
||
}else{
|
||
return WSTReturn('上架失败，请核对商品信息是否完整!', -2);
|
||
}
|
||
|
||
}else{
|
||
$rs = $this->where(['goodsId'=>['in',$ids],'shopId'=>$shopId])->setField('isSale',0);
|
||
if($rs !== false){
|
||
//执行钩子事件
|
||
foreach ($ids as $key => $gid) {
|
||
hook('afterChangeGoodsStatus',['goodsId'=>$gid]);
|
||
}
|
||
model('common/carts')->delCartByUpdate($ids);
|
||
return WSTReturn('商品上架成功', 1);
|
||
}else{
|
||
return WSTReturn($this->getError(), -1);
|
||
}
|
||
}
|
||
}
|
||
/**
|
||
* 修改商品状态
|
||
*/
|
||
public function changSaleStatus(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$allowArr = ['isHot','isNew','isBest','isRecom','storeRecom'];
|
||
$is = input('post.is');
|
||
if(!in_array($is,$allowArr))return WSTReturn('非法操作',-1);
|
||
$status = (input('post.status',1)==1)?0:1;
|
||
$id = (int)input('post.id');
|
||
$rs = $this->where(["shopId"=>$shopId,'goodsId'=>$id])->setField($is,$status);
|
||
if($rs!==false){
|
||
return WSTReturn('设置成功',1);
|
||
}else{
|
||
return WSTReturn($this->getError(),-1);
|
||
}
|
||
}
|
||
/**
|
||
* 修改商品状态
|
||
*/
|
||
public function changStoreRecom(){
|
||
$status = (input('post.status',1)==1)?0:1;
|
||
$id = (int)input('post.id');
|
||
$rs = db('store_recom')->where(['goodsId'=>$id])->update(['storeStatus'=>$status]);
|
||
if($rs!==false){
|
||
return WSTReturn('设置成功',1);
|
||
}else{
|
||
return WSTReturn($this->getError(),-1);
|
||
}
|
||
}
|
||
/**
|
||
* 批量修改商品状态
|
||
*/
|
||
public function changeGoodsStatus(){
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
//设置为什么 hot new best rec
|
||
$allowArr = ['isHot','isNew','isBest','isRecom','storeRecom'];
|
||
$is = input('post.is');
|
||
if(!in_array($is,$allowArr))return WSTReturn('非法操作',-1);
|
||
//设置哪一个状态
|
||
$status = input('post.status',1);
|
||
$ids = input('post.ids/a');
|
||
$rs = $this->where(['goodsId'=>['in',$ids],'shopId'=>$shopId])->setField($is, $status);
|
||
if($rs!==false){
|
||
return WSTReturn('设置成功',1);
|
||
}else{
|
||
return WSTReturn($this->getError(),-1);
|
||
}
|
||
|
||
}
|
||
/**
|
||
* 批量修改商品 店长推荐
|
||
*/
|
||
public function changeStoreStatus(){
|
||
$ids=input('post.ids/a');
|
||
$find = db('store_recom')->where(['goodsId'=>['in',$ids]])->column('goodsId');
|
||
Db::startTrans();
|
||
try{
|
||
if(!$find){
|
||
foreach($ids as $k=>$v){
|
||
$info=[];
|
||
$info['goodsId']=$v;
|
||
$info['storeStatus']= input('post.status',1);
|
||
//dump($info);
|
||
$data[]=$info;
|
||
}
|
||
$rs=db('store_recom')->insertAll($data);
|
||
}
|
||
if($find){
|
||
foreach($find as $k=>$v){
|
||
$rs=db('store_recom')->where('goodsId',$v)->update(['storeStatus'=>input('post.status',1)]);
|
||
}
|
||
$another=array_diff($ids,$find);
|
||
if(count($another)>0){
|
||
foreach($another as $k=>$v){
|
||
$info=[];
|
||
$info['goodsId']=$v;
|
||
$info['storeStatus']= input('post.status',1);
|
||
//dump($info);
|
||
$data[]=$info;
|
||
}
|
||
$rs=db('store_recom')->insertAll($data);
|
||
}
|
||
|
||
}
|
||
Db::commit();
|
||
return WSTReturn("设置成功", 1);
|
||
}catch (\Exception $e) {
|
||
Db::rollback();errLog($e);
|
||
}
|
||
}
|
||
/**
|
||
* 获取商品规格属性
|
||
*/
|
||
public function getSpecAttrs(){
|
||
$goodsType = (int)input('goodsType');
|
||
$goodsCatId = Input('post.goodsCatId/d');
|
||
$goodsCatIds = model('GoodsCats')->getParentIs($goodsCatId);
|
||
$data = [];
|
||
if($goodsType==0){
|
||
$specs = Db::name('spec_cats')->where(['dataFlag'=>1,'isShow'=>1,'goodsCatId'=>['in',$goodsCatIds]])->field('catId,catName,isAllowImg')->order('isAllowImg desc,catSort asc,catId asc')->select();
|
||
$spec0 = null;
|
||
$spec1 = [];
|
||
foreach ($specs as $key => $v){
|
||
if($v['isAllowImg']==1){
|
||
$spec0 = $v;
|
||
}else{
|
||
$spec1[] = $v;
|
||
}
|
||
}
|
||
$data['spec0'] = $spec0;
|
||
$data['spec1'] = $spec1;
|
||
}
|
||
$data['attrs'] = Db::name('attributes')->where(['dataFlag'=>1,'isShow'=>1,'goodsCatId'=>['in',$goodsCatIds]])->field('attrId,attrName,attrType,attrVal')->order('attrSort asc,attrId asc')->select();
|
||
return WSTReturn("", 1,$data);
|
||
}
|
||
|
||
/**
|
||
* 检测商品主表的货号或者商品编号
|
||
*/
|
||
public function checkExistGoodsKey($key,$val,$id = 0){
|
||
if(!in_array($key,array('goodsSn','productNo')))return WSTReturn("非法的查询字段");
|
||
$conditon = [$key=>$val];
|
||
if($id>0)$conditon['goodsId'] = ['<>',$id];
|
||
$rs = $dbo = $this->where($conditon)->count();
|
||
return ($rs==0)?false:true;
|
||
}
|
||
|
||
/**
|
||
* 获取符合筛选条件的商品ID
|
||
*/
|
||
public function filterByAttributes(){
|
||
$vs = input('vs');
|
||
if($vs=='')return [];
|
||
$vs = explode(',',$vs);
|
||
$goodsIds = [];
|
||
$prefix = config('database.prefix');
|
||
//循环遍历每个属性相关的商品ID
|
||
foreach ($vs as $v){
|
||
$goodsIds2 = [];
|
||
$attrVal = input('v_'.(int)$v);
|
||
if($attrVal=='')continue;
|
||
if(stristr($attrVal,'、')!==false){
|
||
// 同属性多选
|
||
$attrArr = explode('、',$attrVal);
|
||
foreach($attrArr as $v1){
|
||
$sql = "select goodsId from ".$prefix."goods_attributes where attrId=".(int)$v." and find_in_set('".$v1."',attrVal) ";
|
||
$rs = Db::query($sql);
|
||
if(!empty($rs)){
|
||
foreach ($rs as $vg){
|
||
$goodsIds2[] = $vg['goodsId'];
|
||
}
|
||
}
|
||
}
|
||
}else{
|
||
$sql = "select goodsId from ".$prefix."goods_attributes
|
||
where attrId=".(int)$v." and find_in_set('".$attrVal."',attrVal) ";
|
||
$rs = Db::query($sql);
|
||
if(!empty($rs)){
|
||
foreach ($rs as $vg){
|
||
$goodsIds2[] = $vg['goodsId'];
|
||
}
|
||
}
|
||
}
|
||
//如果有一个属性是没有商品的话就不需要查了
|
||
if(empty($goodsIds2))return [-1];
|
||
//第一次比较就先过滤，第二次以后的就找集合
|
||
$goodsIds2[] = -1;
|
||
if(empty($goodsIds)){
|
||
$goodsIds = $goodsIds2;
|
||
}else{
|
||
$goodsIds = array_intersect($goodsIds,$goodsIds2);
|
||
}
|
||
}
|
||
return $goodsIds;
|
||
}
|
||
|
||
/**
|
||
* 获取分页商品记录
|
||
*/
|
||
public function pageQuery($goodsCatIds = []){
|
||
//查询条件
|
||
$isStock = input('isStock/d');
|
||
$isNew = input('isNew/d');
|
||
$isFreeShipping = input('isFreeShipping/d');
|
||
$keyword = input('keyword');
|
||
$where = $where2 = $where3 = [];
|
||
$where['goodsStatus'] = 1;
|
||
$where['g.dataFlag'] = 1;
|
||
$where['isSale'] = 1;
|
||
$where['goodsCatIdPath']=['notlike','389'.'%'];
|
||
if($keyword!='')$where['goodsName'] = ['like','%'.$keyword.'%'];
|
||
//属性筛选
|
||
$goodsIds = $this->filterByAttributes();
|
||
if(!empty($goodsIds))$where['goodsId'] = ['in',$goodsIds];
|
||
// 品牌筛选
|
||
$brandIds = input('param.brand');
|
||
if(!empty($brandIds)){
|
||
$brandIds = explode(',',$brandIds);
|
||
$where['brandId'] = ['in',$brandIds];
|
||
}
|
||
|
||
// 发货地
|
||
$areaId = (int)input('areaId');
|
||
if($areaId>0)$where['areaId'] = $areaId;
|
||
//排序条件
|
||
$orderBy = input('orderBy/d',0);
|
||
$orderBy = ($orderBy>=0 && $orderBy<=4)?$orderBy:0;
|
||
//默认销量从高到低排序， mark by cheng 20130317
|
||
$order = (input('order/d',1)==1)?1:0;
|
||
$pageBy = ['saleNum','shopPrice','appraiseNum','visitNum','saleTime'];
|
||
$pageOrder = ['asc','desc'];
|
||
if($isStock==1)$where['goodsStock'] = ['>',0];
|
||
if($isNew==1)$where['isNew'] = ['=',1];
|
||
if($isFreeShipping==1)$where['isFreeShipping'] = 1;
|
||
if(!empty($goodsCatIds))$where['goodsCatIdPath'] = ['like',implode('_',$goodsCatIds).'_%'];
|
||
$sprice = input("param.sprice");//开始价格
|
||
$eprice = input("param.eprice");//结束价格
|
||
if($sprice!='' && $eprice!=''){
|
||
$where['g.shopPrice'] = ['between',[(int)$sprice,(int)$eprice]];
|
||
}elseif($sprice!=''){
|
||
$where['g.shopPrice'] = [">=",(int)$sprice];
|
||
}elseif($eprice!=''){
|
||
$where['g.shopPrice'] = ["<=",(int)$eprice];
|
||
}
|
||
$list = Db::name("goods")->alias('g')->join("__SHOPS__ s","g.shopId = s.shopId")
|
||
->where($where)
|
||
->field('goodsId,goodsName,goodsSn,goodsStock,isNew,saleNum,shopPrice,marketPrice,isSpec,goodsImg,appraiseNum,visitNum,s.shopId,shopName,isSelf,isFreeShipping,gallery')
|
||
->order($pageBy[$orderBy]." ".$pageOrder[$order].",goodsId asc")
|
||
->paginate(input('pagesize/d',16))->toArray();
|
||
//加载标签
|
||
if(!empty($list['Rows'])){
|
||
foreach ($list['Rows'] as $key => $v) {
|
||
$list['Rows'][$key]['tags'] = [];
|
||
if($v['isSelf']==1)$list['Rows'][$key]['tags'][] = "<span class='tag'>自营</span>";
|
||
if($v['isFreeShipping']==1)$list['Rows'][$key]['tags'][] = "<span class='tag'>包邮</span>";
|
||
}
|
||
}
|
||
//关注
|
||
if($list['Rows']){
|
||
foreach ($list['Rows'] as $key =>$v){
|
||
$list['Rows'][$key]['favGood'] = model('Favorites')->checkFavorite($v['goodsId'],0);
|
||
}
|
||
}
|
||
hook('afterQueryGoods',['page'=>&$list]);
|
||
return $list;
|
||
}
|
||
/**
|
||
* 获取价格范围
|
||
*/
|
||
public function getPriceGrade($goodsCatIds = []){
|
||
$isStock = input('isStock/d');
|
||
$isNew = input('isNew/d');
|
||
$keyword = input('keyword');
|
||
$isFreeShipping = input('isFreeShipping/d');
|
||
$where = $where2 = $where3 = [];
|
||
$where['goodsStatus'] = 1;
|
||
$where['g.dataFlag'] = 1;
|
||
$where['isSale'] = 1;
|
||
if($keyword!='')$where['goodsName'] = ['like','%'.$keyword.'%'];
|
||
$areaId = (int)input('areaId');
|
||
if($areaId>0)$where['areaId'] = $areaId;
|
||
//属性筛选
|
||
$goodsIds = $this->filterByAttributes();
|
||
if(!empty($goodsIds))$where['goodsId'] = ['in',$goodsIds];
|
||
//排序条件
|
||
$orderBy = input('orderBy/d',0);
|
||
$orderBy = ($orderBy>=0 && $orderBy<=4)?$orderBy:0;
|
||
$order = (input('order/d',0)==1)?1:0;
|
||
$pageBy = ['saleNum','shopPrice','appraiseNum','visitNum','saleTime'];
|
||
$pageOrder = ['asc','desc'];
|
||
if($isStock==1)$where['goodsStock'] = ['>',0];
|
||
if($isNew==1)$where['isNew'] = ['=',1];
|
||
if($isFreeShipping==1)$where['isFreeShipping'] = 1;
|
||
if(!empty($goodsCatIds))$where['goodsCatIdPath'] = ['like',implode('_',$goodsCatIds).'_%'];
|
||
$sprice = input("param.sprice");//开始价格
|
||
$eprice = input("param.eprice");//结束价格
|
||
if($sprice!='' && $eprice!=''){
|
||
$where['g.shopPrice'] = ['between',[(int)$sprice,(int)$eprice]];
|
||
}elseif($sprice!=''){
|
||
$where['g.shopPrice'] = [">=",(int)$sprice];
|
||
}elseif($eprice!=''){
|
||
$where['g.shopPrice'] = ["<=",(int)$eprice];
|
||
}
|
||
$rs = Db::name("goods")->alias('g')->join("__SHOPS__ s","g.shopId = s.shopId",'inner')
|
||
->where($where)
|
||
->field('min(shopPrice) minPrice,max(shopPrice) maxPrice')->find();
|
||
|
||
if($rs['maxPrice']=='')return;
|
||
$minPrice = 0;
|
||
$maxPrice = $rs['maxPrice'];
|
||
$pavg5 = ($maxPrice/5);
|
||
$prices = array();
|
||
$price_grade = 0.0001;
|
||
for($i=-2; $i<= log10($maxPrice); $i++){
|
||
$price_grade *= 10;
|
||
}
|
||
//区间跨度
|
||
$span = ceil(($maxPrice - $minPrice) / 8 / $price_grade) * $price_grade;
|
||
if($span == 0){
|
||
$span = $price_grade;
|
||
}
|
||
for($i=1;$i<=8;$i++){
|
||
$prices[($i-1)*$span."_".($span * $i)] = ($i-1)*$span."-".($span * $i);
|
||
if(($span * $i)>$maxPrice) break;
|
||
}
|
||
|
||
return $prices;
|
||
}
|
||
|
||
/**
|
||
* 修改商品库存/价格
|
||
*/
|
||
public function editGoodsBase(){
|
||
$goodsId = (int)Input("goodsId");
|
||
$post = input('post.');
|
||
$data = [];
|
||
if(isset($post['goodsStock'])){
|
||
$data['goodsStock'] = (int)input('post.goodsStock',0);
|
||
if($data['goodsStock']<0)return WSTReturn('操作失败，库存不能为负数');
|
||
}elseif(isset($post['shopPrice'])){
|
||
$data['shopPrice'] = (float)input('post.shopPrice',0);
|
||
if($data['shopPrice']<0.01)return WSTReturn('操作失败，价格必须大于0.01');
|
||
}else{
|
||
return WSTReturn('操作失败',-1);
|
||
}
|
||
$rs = $this->update($data,['goodsId'=>$goodsId,'shopId'=>(int)session('WST_USER.shopId')]);
|
||
if($rs!==false){
|
||
return WSTReturn('操作成功',1);
|
||
}else{
|
||
return WSTReturn('操作失败',-1);
|
||
}
|
||
}
|
||
/**
|
||
* 预警库存列表
|
||
*/
|
||
public function stockByPage(){
|
||
$where = [];
|
||
$c1Id = (int)input('cat1');
|
||
$c2Id = (int)input('cat2');
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
if($c1Id!=0)$where[] = " shopCatId1=".$c1Id;
|
||
if($c2Id!=0)$where[] = " shopCatId2=".$c2Id;
|
||
$where[] = " g.shopId = ".$shopId;
|
||
$prefix = config('database.prefix');
|
||
$sql1 = 'SELECT g.goodsId,g.goodsName,g.goodsType,g.goodsImg,gs.specStock goodsStock ,gs.warnStock warnStock,g.isSpec,gs.productNo,gs.id,gs.specIds,g.isSale
|
||
FROM '.$prefix.'goods g inner JOIN '.$prefix.'goods_specs gs ON gs.goodsId=g.goodsId and gs.specStock <= gs.warnStock and gs.warnStock>0
|
||
WHERE g.dataFlag = 1 and '.implode(' and ',$where);
|
||
|
||
$sql2 = 'SELECT g.goodsId,g.goodsName,g.goodsType,g.goodsImg,g.goodsStock,g.warnStock,g.isSpec,g.productNo,0 as id,"" as specIds,g.isSale
|
||
FROM '.$prefix.'goods g
|
||
WHERE g.dataFlag = 1 and isSpec=0 and g.goodsStock<=g.warnStock
|
||
and g.warnStock>0 and '.implode(' and ',$where);
|
||
$page = (int)input('post.'.config('paginate.var_page'));
|
||
$page = ($page<=0)?1:$page;
|
||
$pageSize = 15;
|
||
$start = ($page-1)*$pageSize;
|
||
$sql = $sql1." union ".$sql2;
|
||
$sqlNum = 'select count(*) wstNum from ('.$sql.") as c";
|
||
$sql = 'select * from ('.$sql.') as c order by isSale desc limit '.$start.','.$pageSize;
|
||
$rsNum = Db::query($sqlNum);
|
||
$rsRows = Db::query($sql);
|
||
$rs = WSTPager((int)$rsNum[0]['wstNum'],$rsRows,$page,$pageSize);
|
||
if(empty($rs['Rows']))return $rs;
|
||
$specIds = [];
|
||
foreach ($rs['Rows'] as $key =>$v){
|
||
$specIds[$key] = explode(':',$v['specIds']);
|
||
$rss = Db::name('spec_items')->alias('si')
|
||
->join('__SPEC_CATS__ sc','sc.catId=si.catId','left')
|
||
->where('si.shopId = '.$shopId.' and si.goodsId = '.$v['goodsId'])
|
||
->where('si.itemId','in',$specIds[$key])
|
||
->field('si.itemId,si.itemName,sc.catId,sc.catName')
|
||
->select();
|
||
$rs['Rows'][$key]['spec'] = $rss;
|
||
}
|
||
return $rs;
|
||
}
|
||
/**
|
||
* 预警修改预警库存
|
||
*/
|
||
public function editwarnStock(){
|
||
$id = input('post.id/d');
|
||
$type = input('post.type/d');
|
||
$number = (int)input('post.number');
|
||
$shopId = (int)session('WST_USER.shopId');
|
||
$data = $data2 = [];
|
||
$data['shopId'] = $data2['shopId'] = $shopId;
|
||
$datat=array('1'=>'specStock','2'=>'warnStock','3'=>'goodsStock','4'=>'warnStock');
|
||
if(!empty($type)){
|
||
$data[$datat[$type]] = $number;
|
||
if($type==1 || $type==2){
|
||
$data['goodsId'] = $goodsId = input('post.goodsId/d');
|
||
$rss = Db::name("goods_specs")->where('id', $id)->update($data);
|
||
//更新商品库存
|
||
$goodsStock = 0;
|
||
if($rss!==false){
|
||
$specStocks = Db::name("goods_specs")->where(['shopId'=>$shopId,'goodsId'=>$goodsId,'dataFlag'=>1])->field('specStock')->select();
|
||
foreach ($specStocks as $key =>$v){
|
||
$goodsStock = $goodsStock+$v['specStock'];
|
||
}
|
||
$data2['goodsStock'] = $goodsStock;
|
||
$rs = $this->update($data2,['goodsId'=>$goodsId]);
|
||
}else{
|
||
return WSTReturn('操作失败',-1);
|
||
}
|
||
}
|
||
if($type==3 || $type==4){
|
||
$rs = $this->update($data,['goodsId'=>$id]);
|
||
}
|
||
if($rs!==false){
|
||
return WSTReturn('操作成功',1);
|
||
}else{
|
||
return WSTReturn('操作失败',-1);
|
||
}
|
||
}
|
||
return WSTReturn('操作失败',-1);
|
||
}
|
||
}
|