zx/app/common/repositories/store/shipping/ShippingTemplateRepository.php

<?php

// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------

namespace app\common\repositories\store\shipping;

use app\common\repositories\BaseRepository;
use app\common\dao\store\shipping\ShippingTemplateDao as dao;
use app\common\repositories\store\product\ProductRepository;
use think\exception\ValidateException;
use think\facade\Db;

/**
 * Class ShippingTemplateRepository
 *
 * @mixin dao
 */
class ShippingTemplateRepository extends BaseRepository
{

    /**
     * ShippingTemplateRepository constructor.
     * @param dao $dao
     */
    public function __construct(dao $dao)
    {
        $this->dao = $dao;
    }

    /**
     * @Author:Qinii
     * @Date: 2020/5/13
     * @param int $merId
     * @return mixed
     */
    public function getList(int $merId)
    {
        $list = $this->dao->getList($merId);
        foreach ($list as &$item) {
            if ($item['is_default'] == 1) {
                $item['name'] .= '（系统默认）';
            }
        }
        return $list;
    }

    /**
     * @Author:Qinii
     * @Date: 2020/5/8
     * @param int $merId
     * @param $id
     * @return bool
     */
    public function merExists(int $merId,$id)
    {
        return $this->dao->merFieldExists($merId,$this->getPk(),$id);
    }


    public function merDefaultExists(int $merId,$id)
    {
        $where = ['mer_id' => $merId,'is_default' => 1, $this->dao->getPk() => $id];
        return $this->dao->getWhere($where) ? true : false;
    }

    public function getProductUse(int $merId ,int $id)
    {
        return app()->make(ProductRepository::class)->merTempExists($merId,$id);
    }

    /**
     * @param int $id
     * @return mixed
     * @author Qinii
     */
    public function getOne(int $id, $api = 0)
    {
        $with = ['free','region','undelives'];
        $result = $this->dao->getWhere([$this->dao->getPk() => $id],'*',$with);
        if ($api){
            if ($result['free']) $append[] = 'free.city_name';
            if ($result['region']) $append[] = 'region.city_name';
            if ($result['undelives']) $append[] = 'undelives.city_name';
        } else {
            $append = ['free.city_ids','region.city_ids','undelives.city_ids'];
        }
        $result->append($append);
        return $result;

    }

    /**
     * @Author:Qinii
     * @Date: 2020/5/8
     * @param int $merId
     * @param array $where
     * @param int $page
     * @param int $limit
     * @return array
     */
    public function search(int $merId, array $where, int $page, int $limit)
    {
        $query = $this->dao->search($merId, $where);
        $count = $query->count($this->dao->getPk());
        $list = $query->page($page, $limit)->select();
        foreach ($list as &$item) {
            if ($item['is_default'] == 1) {
                $item['name'] .= '（系统默认）';
            }
        }
        return compact('count', 'list');
    }

    /**
     * @Author:Qinii
     * @Date: 2020/5/8
     * @param int $id
     * @param array $data
     */
    public function update(int $id,array $data)
    {
        Db::transaction(function()use ($id,$data) {
            $region = $data['region'];
            $free = $data['free'] ?? '';
            $undelives = $data['undelives']??'';

            unset($data['region'],$data['free'],$data['undelives'],$data['city_ids']);
            $this->dao->update($id, $data);

            (app()->make(ShippingTemplateRegionRepository::class))->batchRemove([], [$id]);
            (app()->make(ShippingTemplateFreeRepository::class))->batchRemove([], [$id]);
            (app()->make(ShippingTemplateUndeliveRepository::class))->batchRemove([], [$id]);

            if($data['appoint']) {
                $settlefree = $this->settleFree($free, $id);
                (app()->make(ShippingTemplateFreeRepository::class)->insertAll($settlefree));
            }

            $settleRegion = $this->settleRegion($region,$id);
            (app()->make(ShippingTemplateRegionRepository::class)->insertAll($settleRegion));
            if($data['undelivery'] == 1){
                $settleUndelives = $this->settleUndelives($undelives,$id);
                (app()->make(ShippingTemplateUndeliveRepository::class))->create($settleUndelives);
            }

        });
    }

    public function delete($id)
    {
        if (is_array($id)) {
            foreach ($id as $i) {
                $this->dao->delete($i);
            }
        } else {
            $this->dao->delete($id);
        }
    }

    /**
     * @Author:Qinii
     * @Date: 2020/5/13
     * @param array $data
     */
    public function create(array $data)
    {
        Db::transaction(function()use ($data) {
            $region = $data['region'];
            $free = $data['free'] ?? '';
            $undelives = $data['undelives'] ?? '';
            if(isset($data['undelivery']) && $data['undelivery'] == 2){
                $data['undelives'] = [];//开启状态下过滤数据
            }
            unset($data['region'],$data['free'],$data['undelives'],$data['city_ids']);
            $temp = $this->dao->create($data);
            if($data['appoint']) {
                $settlefree = $this->settleFree($free, $temp['shipping_template_id']);
                (app()->make(ShippingTemplateFreeRepository::class)->insertAll($settlefree));
            }
            $settleRegion = $this->settleRegion($region, $temp['shipping_template_id']);
            (app()->make(ShippingTemplateRegionRepository::class)->insertAll($settleRegion));
            if($data['undelivery'] == 1){
                $settleUndelives = $this->settleUndelives($undelives,$temp['shipping_template_id']);
                (app()->make(ShippingTemplateUndeliveRepository::class))->create($settleUndelives);
            }
        });
    }


    /**
     * @param $data
     * @param $id
     * @return array
     * @author Qinii
     */
    public function settleFree($data,$id)
    {
        foreach ($data as $v){
            if (isset($v['city_id']) && !is_array($v['city_id'])) throw new ValidateException('包邮参数类型错误');
            $city = '/'.implode('/',$v['city_id']).'/';
            $free[] = [
                'temp_id' => $id,
                'city_id' => $city,
                'number' => $v['number'],
                'price' => $v['price']
            ];
        }
        return $free;
    }


    /**
     * @param $data
     * @param $id
     * @return array
     * @author Qinii
     */
    public function settleUndelives($data,$id)
    {
        if (isset($v['city_id']) && !is_array($data['city_id'])) throw new ValidateException('指定不配送参数类型错误');
        return ['temp_id' => $id, 'city_id' => $data['city_id']];
    }


    /**
     * @Author:Qinii
     * @Date: 2020/5/13
     * @param $data
     * @param $id
     * @return array
     */
    public function settleRegion($data,$id)
    {
        $result = [];
        foreach ($data as $k => $v){
            $result[] = [
                'city_id' => ($k > 0 ) ? '/'.implode('/',$v['city_id']).'/' : 0,
                'temp_id' => $id,
                'first' => $v['first'],
                'first_price'=> $v['first_price'],
                'continue' => $v['continue'],
                'continue_price'=> $v['continue_price'],
            ];
        }
        return $result;
    }

    /**
     * @param int $merId
     * @author Qinii
     */
    public function createDefault(int $merId)
    {
        $data = [
            "name" => "默认模板",
            "type" => 1,
            "appoint" => 0,
            "undelivery" => 0,
            'mer_id' => $merId,
            "region" => [[
                "first" => 0,
                "first_price" => 0,
                "continue" => 0,
                "continue_price" => 0,
                "city_id" => 0
              ]]
        ];
        return $this->create($data);
    }

    public function check($merId, $id)
    {
        if(!$this->merExists($merId, $id))
            throw new ValidateException('数据不存在,ID:'.$id);
        if($this->merDefaultExists($merId, $id))
            throw new ValidateException('默认模板不能删除,ID:'.$id);
        if($this->getProductUse($merId, $id))
            throw new ValidateException('模板使用中，不能删除,ID:'.$id);
    }

}