seaBlueApi/Model/Price/MCustomerPriceAdjustment.Class.php

<?php
/**
 * 客户调价单管理
 * Created by PhpStorm.
 * User: phperstar
 * Date: 2019/4/26
 * Time: 9:41 AM
 */

namespace JinDouYun\Model\Price;

use JinDouYun\Cache\PriceCache;
use JinDouYun\Controller\Common\Logger;
use JinDouYun\Dao\Customer\DCustomer;
use JinDouYun\Model\GoodsManage\MSku;
use Mall\Framework\Core\ErrorCode;
use Mall\Framework\Core\ResultWrapper;
use Mall\Framework\Core\StatusCode;

use JinDouYun\Model\MBaseModel;
use JinDouYun\Dao\Price\DCustomerPriceEffective;
use JinDouYun\Dao\Price\DCustomerPriceAdjustment;

class MCustomerPriceAdjustment extends MBaseModel
{
    private $onlineUserId;

    private $onlineEnterpriseId;

    private $objDCustomerPriceAdjustment;

    private $objPriceCache;

    /**
     * MCustomerPriceAdjustment constructor.
     * @param $onlineUserId
     * @param $onlineEnterpriseId
     * @throws \Exception
     */
    public function __construct($onlineUserId, $onlineEnterpriseId)
    {
        $this->onlineUserId = $onlineUserId;
        $this->onlineEnterpriseId = $onlineEnterpriseId;
        parent::__construct($this->onlineEnterpriseId, $this->onlineUserId);
        $this->objPriceCache = new PriceCache($this->onlineEnterpriseId);
        $this->objDCustomerPriceAdjustment = new DCustomerPriceAdjustment();//DCustomerPriceAdjustment
        $this->objDCustomerPriceAdjustment->setTable($this->objDCustomerPriceAdjustment->get_Table() . '_' . $this->onlineEnterpriseId . '_' . date('Y') . '_' . ceil(date('m') / 3));
        $this->objDCustomerPriceAdjustment->setSearchIndex('customerPriceAdjustmentSheet_search')->setType('customerPriceAdjustmentSheet');
    }

    /**
     * 客户调价单添加
     */
    public function add($sheetData)
    {
        // 保存调单价数据
        $no = createOrderSn(StatusCode::$source['manage'], StatusCode::$orderType['customerPriceAdjustment'], $this->onlineUserId);
        foreach ($sheetData as $key => $value) {
            unset($sheetData[$key]['effective']);
            $sheetData[$key]['no'] = $no;
        }
        $dbResult = $this->objDCustomerPriceAdjustment->insert($sheetData, true);
        if ($dbResult === false) {
            return ResultWrapper::fail($this->objDCustomerPriceAdjustment->error(), ErrorCode::$dberror);
        }

        if (is_array($dbResult)) {
            foreach ($dbResult as $key => $id) {
                if (isset($sheetData[$key])) {
                    $sheetData[$key]['id'] = $id;
                }
            }
        }
        self::updateEsData($sheetData);
        return ResultWrapper::success($dbResult);

    }

    /**
     * 更新ES
     * @param $data
     * @return mixed
     */
    public function updateEsData($data)
    {
        if (empty($data)) return $data;
        foreach ($data as $key => $val) {
            $esData = [
                'enterpriseId'      => $this->onlineEnterpriseId,
                'id'                => $val['id'],//自增id,
                'no'                => $val['no'],//调价单号,
                'goodsCode'         => isset($val['goodsCode']) ? $val['goodsCode'] : createCode(StatusCode::$code['goodsBasic']['prefix'], $val['goodsId'], StatusCode::$code['goodsBasic']['length']),//商品编号
                'goodsName'         => $val['goodsName'],//商品名称
                'goodsId'           => $val['goodsId'],//商品id
                'shopId'            => $val['shopId'],//店铺id
                'shopName'          => $val['shopName'],//店铺名称
                'createUserId'      => $val['createUserId'],//创建人id
                'createUserName'    => $val['createUserName'],//创建人姓名
                'effectiveUserName' => isset($val['effectiveUserName']) ? $val['effectiveUserName'] : '',//生效人姓名
                'effectiveUserId'   => isset($val['effectiveUserId']) ? $val['effectiveUserId'] : '',//生效人id
                'deleteStatus'      => StatusCode::$standard,//删除状态 4删除 5正常
                'effectiveStatus'   => isset($val['effectiveStatus']) ? $val['effectiveStatus'] : StatusCode::$auditStatus['auditPass'],//生效状态 1.待审 2审核通过 3未通过 4审核中
                'createTime'        => isset($val['createTime']) ? $val['createTime'] : time(),//创建时间
                'updateTime'        => isset($val['updateTime']) ? $val['updateTime'] : time(),//修改时间
                'salePrice'         => json_decode($val['salePrice'], true),//销售价格
                'customerId'        => $val['customerId'],
                'customerName'      => $val['customerName'],
                'customerCode'      => '',
            ];
            $_id = self::createEsDocumentId($val['id']);
            $result = $this->objDCustomerPriceAdjustment->addUpSearchIndexDocument($esData, $_id);
            if (isset($result['_shards']) && isset($result['_shards']['successful']) && $result['_shards']['successful'] == 1) {
                //echo "es操作成功";
                //return;
            }
            //echo "es操作失败";
        }
    }

    /**
     * 生成文档id
     * @param $id
     * @return string
     */
    private function createEsDocumentId($id)
    {
        return 'EnterpriseId_' . $this->onlineEnterpriseId . '_id_' . $id;
    }

    /**
     * 生成单据编号
     */
    public function createNo($createUserId)
    {
        return date('YmdHis') . substr(strval($createUserId + 100), -2) . substr(microtime(), 2, 4);
    }

    /**
     * 获取指定用户区域可售商品
     */
    public function goodsLists($params)
    {
        // 判断用户所在区域是否在店铺经营范围内
        $objDCloudShopRegion = new DCloudShopRegion();
        $condition = 'shop_id = ' . $params['shopId'] . ' and FIND_IN_SET(' . $params['provinceId'] . ', province_id) and FIND_IN_SET(' . $params['cityId'] . ', city_id) and FIND_IN_SET(' . $params['districtId'] . ', district)';
        $shop_region = $objDCloudShopRegion->get($condition, 'id');
        if ($shop_region == false) {
            return ResultWrapper::fail($objDCloudShopRegion->error(), ErrorCode::$dberror);
        } else if (empty($shop_region)) {
            return ResultWrapper::success([]);
        }

        // 查询店铺中在该区域内的商品
        $pageData = pageToOffset($params['page'], $params['pageSize']);

        $condition = 'shop_id = ' . $params['shopId'] . ' and is_delete = 0  and ( is_area_sale = 1 or is_area_sale = 2 and FIND_IN_SET(' . $params['provinceId'] . ', province_id) and FIND_IN_SET(' . $params['cityId'] . ', city_id) and FIND_IN_SET(' . $params['districtId'] . ', district_id))  ';

        if (isset($params['keyword'])) {
            $condition = $condition . 'and goods_name like "%' . $params['keyword'] . '%"';
        }

        $total = $this->objDNsGoods->count($condition);

        $dbResult = $this->objDNsGoods->select($condition, 'materialCode,marketCode,goods_name,state', 'goods_id desc', $pageData['limit'], $pageData['offset']);
        if ($dbResult === false) {
            return ResultWrapper::fail($this->objDNsGoods->error(), ErrorCode::$dberror);
        } else {
            $return = [
                'data'  => $dbResult,
                'total' => $total,
            ];
            return ResultWrapper::success($return);
        }
    }

    /**
     * 获取所有调价单
     */
    public function getAll($params,$export = 0)
    {
        $pageData = pageToOffset($params['page'], $params['pageSize']);
        if($export){
            $pageData['limit'] = null;
            $pageData['offset'] = null;
        }
        $condition = null;

        if ($params['keyword']) {
            $condition = "(goodsName like '%" . $params['keyword'] . "%' or goodsCode like '%" . $params['keyword'] . "%' or no like '%".$params['keyword']."%')";
        }

        if ($params['startTime'] && $params['endTime']) {
            if ($condition !== null) {
                $condition .= ' and ';
            }
            $condition .= " createTime >= " . $params['startTime'] . " and createTime <=" . $params['endTime'];
        }

        if ($params['effectiveStatus']) {
            if ($condition !== null) {
                $condition .= ' and ';
            }
            $condition .= " effectiveStatus = " . $params['effectiveStatus'];
        }
        
        if (isset($params['goodsId']) && !empty($params['goodsId'])) {
            if ($condition !== null) {
                $condition .= ' and ';
            }
            $condition .= " goodsId = " . $params['goodsId'];
        }

        if (isset($params['shopId']) && !empty($params['shopId'])){
            if ($condition !== null) {
                $condition .= ' and ';
            }
            $condition .= " shopId = " . $params['shopId'];
        }

        $condition = parent::getShopIdQueryParams($condition);
        $total = $this->objDCustomerPriceAdjustment->count($condition);

        $dbResult = $this->objDCustomerPriceAdjustment->select($condition, '*', 'id desc', $pageData['limit'], $pageData['offset']);
        if ($dbResult === false) {
            return ResultWrapper::fail($this->objDCustomerPriceAdjustment->error(), ErrorCode::$dberror);
        }
        $return = [
            'data'  => self::format($dbResult),
            'total' => $total,
        ];
        //客户调价单导出
        if($export){
            self::exportCustomerPriceSheet($return['data']);
            exit;
        }
        return ResultWrapper::success($return);
    }

    /**
     * 格式化返回数据
     * @param $data
     * @return mixed
     * @throws \Exception
     */
    public function format($data)
    {
        $skuIds = [];
        foreach ($data as $key => &$val) {
            if (!is_array($val['salePrice'])){
                $val['salePrice'] = json_decode($val['salePrice'], true);
            }
            foreach ($val['salePrice'] as $row){
                $skuIds[] = $row['skuId'];
            }
        }

        $objMSku = new MSku($this->onlineUserId,$this->onlineEnterpriseId);
        $skuResult = $objMSku->getSpecNameBySkuId($skuIds);
        $allSkuData = [];
        if ($skuResult->isSuccess()){
            $allSkuData = $skuResult->getData();
        }

        foreach ($data as &$value){
            foreach ($value['salePrice'] as &$row){
                $row['unitName'] = isset($allSkuData[$row['skuId']]) ? $allSkuData[$row['skuId']]['unitName'] : '';
                $row['specGroup'] = isset($allSkuData[$row['skuId']]) ? $allSkuData[$row['skuId']]['specGroup'] : [];
                if (empty($row['specGroup'])){
                    $value['specType'] = StatusCode::$specType['single'];
                }else{
                    $value['specType'] = StatusCode::$specType['multiple'];
                }
            }
        }

        return $data;
    }

    /**
     * 生效操作
     * @param $id
     * @param $params
     * @return ResultWrapper
     * @throws \Exception
     */
    public function effective($id, $params)
    {
        // 计算客户调价单分表
        $tableName = 'qianniao_customerPriceAdjustmentSheet_' . $this->onlineEnterpriseId . '_' . date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3);
        $this->objDCustomerPriceAdjustment->setTable($tableName);

        $priceAdjustment = $this->objDCustomerPriceAdjustment->get($id);
        if ($priceAdjustment === false) {
            return ResultWrapper::fail($this->objDCustomerPriceAdjustment->error(), ErrorCode::$dberror);
        }

        if (empty($priceAdjustment)) {
            return ResultWrapper::fail('要生效的调价单不存在', ErrorCode::$contentNotExists);
        }

        $this->objDCustomerPriceAdjustment->beginTransaction();

        // 将调价单变更为生效状态
        $dbResult = $this->objDCustomerPriceAdjustment->update(
            [
                'effectiveStatus'   => StatusCode::$auditStatus['auditPass'],
                'effectiveUserName' => $params['effectiveUserName'],
                'effectiveUserId'   => $params['effectiveUserId'],
            ]
            , $id);
        if ($dbResult === false) {
            $this->objDCustomerPriceAdjustment->rollBack();
            return ResultWrapper::fail($this->objDCustomerPriceAdjustment->error(), ErrorCode::$dberror);
        }

        // 记录最后生效数据
        unset($dbResult);
        $objDCustomerPriceEffective = new DCustomerPriceEffective();
        $objDCustomerPriceEffective->setTable('qianniao_customerPriceEffective_' . $this->onlineEnterpriseId);
        $data = [
            'no'         => $priceAdjustment['no'],
            'goodsId'    => $priceAdjustment['goodsId'],
            'shopId'     => $priceAdjustment['shopId'],
            'salePrice'  => $priceAdjustment['salePrice'],
            'startTime'  => $priceAdjustment['startTime'],
            'endTime'    => $priceAdjustment['endTime'],
            'customerId' => $priceAdjustment['customerId'],
        ];

        $dbResult = $objDCustomerPriceEffective->replace($data);
        if ($dbResult === false) {
            $this->objDCustomerPriceAdjustment->rollBack();
            return ResultWrapper::fail($objDCustomerPriceEffective->error(), ErrorCode::$dberror);
        }

        $_id = self::createEsDocumentId($id);
        $this->objDCustomerPriceAdjustment->esupdateTypeFieldVaule([
            'effectiveStatus'   => StatusCode::$auditStatus['auditPass'],
            'effectiveUserName' => isset($params['effectiveUserName']) ? $params['effectiveUserName'] : '',
            'effectiveUserId'   => isset($params['effectiveUserId']) ? $params['effectiveUserId'] : '',
        ], $_id);

        //删除缓存
        $this->objPriceCache->delCustomerAdj($priceAdjustment['goodsId'],$priceAdjustment['customerId']);
        $this->objDCustomerPriceAdjustment->commit();
        return ResultWrapper::success($dbResult);
    }


    /**
     * 获取指定用户的可用的调价单
     * @param int $shopId  店铺id
     * @param int $customerId  客户id
     * @param array $goodsIds 店铺下商品集合
     * @return  ResultWrapper
     */
    public function getCustomerPriceByIds($shopId, $customerId, $goodsIds)
    {
        $objDCustomerPriceEffective = new DCustomerPriceEffective();
        $objDCustomerPriceEffective->setTable('qianniao_customerPriceEffective_' . $this->onlineEnterpriseId);

        $where = 'shopId = ' . $shopId . ' and customerId = ' . $customerId. ' and goodsId in ('.implode(',', $goodsIds).')';

        $dbResult = $objDCustomerPriceEffective->select($where, 'goodsId,salePrice', 'endTime desc');
        if ($dbResult === false) {
            return ResultWrapper::fail($objDCustomerPriceEffective->error(), ErrorCode::$dberror);
        }
        return ResultWrapper::success($dbResult);
    }


    /**
     * 客户调价单搜索
     * @param $selectParams
     * @return ResultWrapper
     */
    public function search($selectParams)
    {
        $defaultDSL = [
            'from' => $selectParams['offset'],
            'size' => $selectParams['limit'],
            'sort' => [
                'createTime' => [
                    'order' => 'desc'
                ],
            ],
        ];

        $dsl = [];
        $dsl['query']['bool']['must'][] = [
            'term' => ['enterpriseId' => $this->onlineEnterpriseId],
        ];

        //店铺id
        parent::getAccessShopIds();
        if (parent::$shopIds) {
            $dsl['query']['bool']['filter'][] = [
                'terms' => ['shopId' => parent::$shopIds]
            ];
        }

        //订单编号，收货人，商品名称
        if (!empty($selectParams['keyword'])) {
            $dsl['query']['bool']['must'][] = [
                'multi_match' => [
                    'fields'    => ['goodsCode', 'goodsName'],
                    'query'     => $selectParams['keyword'],
                    'fuzziness' => 'AUTO',
                ],
            ];
        }

        //生效状态
        if (!empty($selectParams['effectiveStatus'])) {
            $dsl['query']['bool']['filter'][] =
                ['term' => ['effectiveStatus' => $selectParams['effectiveStatus']]];
        }

        //时间
        if (!empty($selectParams['startTime']) && !empty($selectParams['endTime'])) {
            $dsl['query']['bool']['must'][] = [
                'range' => [
                    'createTime' => [
                        'gte' => $selectParams['startTime'],
                        'lte' => $selectParams['endTime'],
                    ]
                ]
            ];
        } else {
            if (!empty($selectParams['startTime'])) {
                $dsl['query']['bool']['must'][] = [
                    'range' => [
                        'createTime' => [
                            'gte' => $selectParams['startTime'],
                        ]
                    ]
                ];
            }

            if (!empty($selectParams['endTime'])) {
                $dsl['query']['bool']['must'][] = [
                    'range' => [
                        'createTime' => [
                            'lte' => $selectParams['endTime'],
                        ]
                    ]
                ];
            }
        }

        $dsl = array_merge($defaultDSL, $dsl);
        $result = $this->objDCustomerPriceAdjustment->getSearchQueryDsl($dsl);
        if (isset($result['status']) && $result['status'] == 400) {
            return ResultWrapper::fail('获取数据失败' . $result['error']['reason'], ErrorCode::$apiNotResult);
        }
        $total = $result['hits']['total'];
        $dbResult = $result['hits']['hits'];
        $list = [];
        foreach ($dbResult as $key => &$value) {
            $data = [];
            $data = $value['_source'];
            $list[] = $data;
        }
        $return = [
            'data'  => self::format($list),
            'total' => ($total) ? intval($total) : 0,
        ];
        return ResultWrapper::success($return);
    }
    
    /**
     * 客户调价单导出方法
     * @param $priceSheetData
     */
    private static function exportCustomerPriceSheet($priceSheetData)
    {
        //导出到本地
        header("Content-type:application/vnd.ms-excel");
        header("Content-Disposition:filename=客户调价单明细表记录.csv");
        header('Cache-Control: max-age=0');
        $fp = fopen('php://output', 'a');
        
        $head = ['调价单编码','客户名称','商品名称','调价时间','调整后价格规格','调整市场价格','调整人','相关店铺', '状态'];       //定义标题
        
        foreach ($head as $i => $v) {
            $head[$i] = mb_convert_encoding($v, 'GBK', 'utf-8');     //将中文标题转换编码，否则乱码
        }
        fputcsv($fp, $head);
        $limit = 10000;
        $num = 0;//计数器
        foreach ($priceSheetData as $v) {
    
            $price = ''; //市场价格
            $unitName = ''; //规格
            $specValueName = '';
            if(!empty($v['salePrice'])){
                foreach ($v['salePrice'] as $key => $value){
                    $price = $value['price'];
                    foreach ($value['specGroup'] as $K => $V){
                      $specValueName   = $V['specValueName'];
                    }
                    $unitName = $value['unitName'].';'.$specValueName;
                }
            }
            //循环数据
            $num++;
            if ($num == $limit) {
                ob_flush();//释放内存
                flush();
            }
            $rows['no'] = isset($v['no']) ? $v['no'] : '';//调价单编码
            $rows['customerName'] = isset($v['customerName']) ? $v['customerName'] : '';//客户名称
            $rows['goodsName'] = isset($v['goodsName']) ? $v['goodsName'] : '';//商品名称
            $rows['createTime'] = isset($v['createTime']) ? date('Y-m-d H:i:s',$v['createTime']) : '';//调价时间
            $rows['unitName'] = $unitName;//调整规格
            $rows['price'] = '-￥'.$price;//调整市场价格
            $rows['createUserName'] = isset($v['createUserName']) ? $v['createUserName'] : '';//调整人
            $rows['shopName'] = isset($v['shopName']) ? $v['shopName'] : '';//相关店铺
            $rows['effectiveStatus'] =  $v['effectiveStatus'] === 2 ? '生效' : '未生效';//状态
            foreach ($rows as $kk => $vv) {
                $rs[$kk] = mb_convert_encoding($vv, 'GBK', 'utf-8');  //转译编码
            }
            fputcsv($fp, $rs);
            $rows = [];
        }
        exit;
    }
    
    /**
     * 获取指定商品的最后生效的客户调价单数据
     * @param $params
     * @return ResultWrapper
     */
    public function getCustomerPriceByGoodsIds($params)
    {
        $pageData = pageToOffset($params['page'], $params['pageSize']);
        $objDCustomerPriceEffective = new DCustomerPriceEffective();
        $objDCustomerPriceEffective->setTable('qianniao_customerPriceEffective_' . $this->onlineEnterpriseId);
        $conditon = [
            'goodsId' => $params['goodsId'],
        ];
        $dbResult = $objDCustomerPriceEffective->select($conditon, 'id,customerId,salePrice', 'id desc',$pageData['limit'],$pageData['offset']);
        if ($dbResult === false) {
            return ResultWrapper::fail($objDCustomerPriceEffective->error(), ErrorCode::$dberror);
        }
        $count = $objDCustomerPriceEffective->count($conditon);
        if ($count === false) {
            return ResultWrapper::fail($objDCustomerPriceEffective->error(), ErrorCode::$dberror);
        }
        $data = self::formatCustomerName($dbResult);
        if(!$data->isSuccess()){
            return ResultWrapper::fail($objDCustomerPriceEffective->error(), ErrorCode::$dberror);
        }
        $dbResult = $data->getData();
        foreach ($dbResult as $key =>$value){
            $dbResult[$key]['salePrice'] = json_decode($value['salePrice']);
        }
        $return = [
            'data'  => $dbResult,
            'total' => $count,
        ];
        return ResultWrapper::success($return);
    }
    
    /**
     * 删除指定商品的最后生效的客户调价单数据
     * @param array $params
     * @return ResultWrapper
     */
    public function delCustomerPrice($params)
    {
        $objDCustomerPriceEffective = new DCustomerPriceEffective();
        $objDCustomerPriceEffective->setTable('qianniao_customerPriceEffective_' . $this->onlineEnterpriseId);
        $dbResult = $objDCustomerPriceEffective->select($params['id']);
        if ($dbResult === false) {
            return ResultWrapper::fail($objDCustomerPriceEffective->error(), ErrorCode::$dberror);
        }
        if(empty($dbResult)){
            return ResultWrapper::fail('要作废的调价单不存在', ErrorCode::$contentNotExists);
        }
        foreach ($dbResult as $key => $value){

            $value['salePrice'] = json_decode($value['salePrice'], true);
            foreach ($value['salePrice'] as $k => $v){
                if($v['skuId'] == $params['skuId']){
                    unset($value['salePrice'][$k]);
                    continue;
                }
            }
            $value['salePrice'] = json_encode( $value['salePrice']);
            $updateDbResult = $objDCustomerPriceEffective->update(['salePrice'=>$value['salePrice']], $value['id']);
            if ($updateDbResult === false) {
                return ResultWrapper::fail($objDCustomerPriceEffective->error(), ErrorCode::$dberror);
            }
        }

        return ResultWrapper::success($updateDbResult);
    }
    
    /**
     * 格式化客户名称
     * @return array
     */
    public function formatCustomerName($data)
    {   //customerId
        //根据客户id进行渲染客户名称
        $customerIdBindCustomerName = [];
        $customerIds = [];
        foreach ($data as $k => $v){
            if(!empty($v['customerId'])){
                $customerIds[] = $v['customerId'];
            }
        }
        if(!empty($customerIds)){
            $objDCustomer = new DCustomer();
            $objDCustomer->setTable('qianniao_customer_' . $this->onlineEnterpriseId);
            $customerData = $objDCustomer->select($customerIds, 'id,name');
            if($customerData == false){
                return ResultWrapper::fail($objDCustomer->error(), ErrorCode::$dberror);
            }
            if(!empty($customerData)){
                foreach ($customerData as $k => $v){
                    $customerIdBindCustomerName[$v['id']] = $v['name'];
                }
            }
            // 循环主数据，进行对应的字段映射操作
            foreach ($data as $key => $value){
                $data[$key]['customerName'] = isset($customerIdBindCustomerName[$value['customerId']]) ? $customerIdBindCustomerName[$value['customerId']] :'';
            }
        }
        return  ResultWrapper::success($data);
    }
}