ruiRoad_pro_v1.0/app/services/store/SystemStoreServices.php

<?php

namespace app\services\store;

use app\dao\store\SystemStoreDao;
use app\services\BaseServices;
use app\services\order\store\BranchOrderServices;
use app\services\order\StoreOrderServices;
use app\services\product\branch\StoreBranchProductServices;
use app\services\store\finance\StoreFinanceFlowServices;
use app\services\system\SystemRoleServices;
use crmeb\exceptions\AdminException;
use crmeb\services\erp\Erp;
use crmeb\services\FormBuilder;
use think\exception\ValidateException;
use think\facade\Cache;
use think\facade\Log;
use think\Model;

/**
 * 门店
 * Class SystemStoreServices
 * @package app\services\system\store
 * @method update($id, array $data, ?string $key = null) 修改数据
 * @method get(int $id, ?array $field = []) 获取数据
 * @method Model getDistanceShortStore(string $latitude = '', string $longitude = '') 获取最近距离距离内的一个门店
 * @method getDistanceShortStoreList(string $latitude = '', string $longitude = '', int $limit = 10) 获取距离距离生序门店列表
 * @method getStoreByAddressInfo(string $addressInfo = '', string $field = '*', int $limit = 0) 根据地址信息获取门店列表
 */
class SystemStoreServices extends BaseServices
{
    /**
     * 创建form表单
     * @var Form
     */
    protected $builder;

    /**
     * 构造方法
     * SystemStoreServices constructor.
     * @param SystemStoreDao $dao
     * @param FormBuilder $builder
     */
    public function __construct(SystemStoreDao $dao, FormBuilder $builder)
    {
        $this->dao = $dao;
        $this->builder = $builder;
    }

    /**
     * 获取单个门店信息
     * @param int $id
     * @return array|\think\Model|null
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getStoreInfo(int $id)
    {
        $storeInfo = $this->dao->getOne(['id' => $id, 'is_del' => 0]);
        if (!$storeInfo) {
            throw new ValidateException('获取门店信息失败');
        }
        $storeInfo['day_time'] = $storeInfo['day_time'] ? explode('-', $storeInfo['day_time']) : [];
        return $storeInfo->toArray();
    }

    /**
	 * 获取提货点列表
	* @param array $where
	* @param array $field
	* @param string $latitude
	* @param string $longitude
	* @param int $product_id
	* @return array
	* @throws \think\db\exception\DataNotFoundException
	* @throws \think\db\exception\DbException
	* @throws \think\db\exception\ModelNotFoundException
	 */
    public function getStoreList(array $where, array $field = ['*'], string $latitude = '', string $longitude = '', int $product_id = 0)
    {
        [$page, $limit] = $this->getPageValue();
        $order = 0;
        if (isset($where['order_id']) && $where['order_id']) {
            /** @var StoreOrderServices $storeOrderServices */
            $storeOrderServices = app()->make(StoreOrderServices::class);
            $user_location = $storeOrderServices->value(['id' => $where['order_id']], 'user_location');
            [$longitude, $latitude] = explode(' ', $user_location);
            unset($where['order_id']);
        }
		if ($longitude && $latitude) {
			$order = 1;
		}
		//该商品上架的门店
		if ($product_id) {
			/** @var StoreBranchProductServices $productServices */
			$productServices = app()->make(StoreBranchProductServices::class);
			$ids = $productServices->getColumn(['product_id' => $product_id, 'is_show' => 1, 'is_del' => 0],'store_id');
			if ($ids) $where['ids'] = $ids;
		}
        $list = $this->dao->getStoreList($where, $field, $page, $limit, $latitude, $longitude, $order);
        foreach ($list as &$item) {
            if (isset($item['distance'])) {
                $item['range'] = bcdiv($item['distance'], '1000', 1);
            }
            if ($item['is_show'] == 1) {
                $item['status_name'] = '营业中';
            } else {
                $item['status_name'] = '已停业';
            }
        }
        $count = $this->dao->count($where);
        return compact('list', 'count');
    }

    /**
     * 获取提货点头部统计信息
     * @return mixed
     */
    public function getStoreData()
    {
        $data['show'] = [
            'name' => '显示中的提货点',
            'num' => $this->dao->count(['type' => 0]),
        ];
        $data['hide'] = [
            'name' => '隐藏中的提货点',
            'num' => $this->dao->count(['type' => 1]),
        ];
        $data['recycle'] = [
            'name' => '回收站的提货点',
            'num' => $this->dao->count(['type' => 2])
        ];
        return $data;
    }

    /**
     * 门店重置账号密码表单
     * @param int $id
     * @return array
     * @throws \FormBuilder\Exception\FormBuilderException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function storeAdminAccountForm(int $id)
    {
        $storeInfo = $this->getStoreInfo($id);
        /** @var SystemStoreStaffServices $staffServices */
        $staffServices = app()->make(SystemStoreStaffServices::class);
        $staffInfo = $staffServices->getOne(['store_id' => $storeInfo['id'], 'level' => 0, 'is_admin' => 1, 'is_manager' => 1, 'is_del' => 0]);
        $field[] = $this->builder->hidden('staff_id', $staffInfo['id'] ?? 0);
        $field[] = $this->builder->input('account', '登录账号', $staffInfo['account'] ?? '')->col(24)->required('请输入账号');
        $field[] = $this->builder->input('password', '登录密码')->type('password')->col(24)->required('请输入密码');
        $field[] = $this->builder->input('true_password', '确认密码')->type('password')->col(24)->required('请再次确认密码');
        return create_form('门店重置账号密码', $field, $this->url('/store/store/reset_admin/' . $id));
    }

    /**
     * 获取erp门店列表
     * @return array|mixed
     * @throws \Exception
     */
    public function erpShopList()
    {
        [$page, $limit] = $this->getPageValue();
        try {
            /** @var Erp $erpService */
            $erpService = app()->make(Erp::class);
            $res = Cache::tag('erp_shop')->remember('list_' . $page . '_' . $limit, function () use ($page, $limit, $erpService) {
                return $erpService->serviceDriver('Comment')->getShopList($page, $limit);
            }, 60);
        } catch (\Throwable $e) {
            Log::error([
                'message' => '读取ERP门店信息失败',
                'file' => $e->getFile(),
                'line' => $e->getLine()
            ]);
        }
        //假数据
        $res1 = '[{"nick":"self_5528051628271830245","shop_id":12709731,"session_expired":"------\u6c38\u4e45\u6388\u6743------","created":"2022-03-12 11:46:41.000","shop_url":"","organization":"","co_id":11669619,"session_uid":null,"short_name":"pro","shop_site":"\u5546\u5bb6\u81ea\u6709\u5546\u57ce","shop_name":"CRMEB-PRO"},{"nick":"self_5744639822394629139","shop_id":12801369,"session_expired":"------\u6c38\u4e45\u6388\u6743------","created":"2022-04-01 11:56:09.000","shop_url":"","organization":"","co_id":11669619,"session_uid":null,"short_name":"erp01","shop_site":"\u5546\u5bb6\u81ea\u6709\u5546\u57ce","shop_name":"erp\u5e97\u94fa"},{"nick":null,"shop_id":0,"session_expired":null,"created":null,"shop_url":"","organization":null,"co_id":0,"session_uid":null,"short_name":null,"shop_site":null,"shop_name":"{\u7ebf\u4e0b}"}]';
        $res1 = json_decode($res1, true);
        $res2 = collect($res1)->slice($page, $limit)->toArray();

        return $res['data']['datas'] ?? $res2;
    }

    /**
     * 保存或修改门店
     * @param int $id
     * @param array $data
     * @param array $staff_data
     * @return mixed
     */
    public function saveStore(int $id, array $data, array $staff_data = [])
    {
        return $this->transaction(function () use ($id, $data, $staff_data) {
            if ($id) {
                $is_new = 0;
                if ($this->dao->update($id, $data)) {
                    return [$id, $is_new];
                } else {
                    throw new AdminException('修改失败或者您没有修改什么！');
                }
            } else {
                $is_new = 1;
                $data['add_time'] = time();
                if ($res = $this->dao->save($data)) {
                    if ($staff_data) {
                        $staffServices = app()->make(SystemStoreStaffServices::class);
						if ($staffServices->count(['phone' => $staff_data['phone'], 'is_del' => 0])) {
                            throw new AdminException('该手机号已经存在');
                        }
                        if ($staffServices->count(['account' => $staff_data['account'], 'is_del' => 0])) {
                            throw new AdminException('管理员账号已存在');
                        }
                        $staff_data['level'] = 0;
                        $staff_data['store_id'] = $res->id;
                        $staff_data['is_admin'] = 1;
                        $staff_data['verify_status'] = 1;
                        $staff_data['is_manager'] = 1;
                        $staff_data['is_cashier'] = 1;
                        $staff_data['add_time'] = time();
                        $staff_data['pwd'] = $this->passwordHash($staff_data['pwd']);
                        if (!$staffServices->save($staff_data)) {
                            throw new AdminException('创建门店管理员失败！');
                        }
                        $data = [
                            ['role_name' => '店员', 'type' => 2, 'store_id' => $res->id, 'status' => 1, 'level' => 1, 'rules' => '1048,1049,1097,1098,1099,1100,1050,1051,1101,1102,1103,1273,1274,1275,1276,1081,1104,1105,1106,1052,1054,1086,1129,1132,1133,1134,1135,1136,1137,1138,1139,1140,1141,1142,1143,1144,1145,1146,1147,1148,1149,1150,1151,1152,1153,1154,1155,1156,1157,1158,1159,1160,1161,1162,1163,1130,1166,1167,1168,1169,1131,1170,1171,1172,1173,1174,1175,1176,1242,1088,1122,1123,1124,1125,1126,1127,1164,1165,1053,1107,1108,1109,1110,1111,1112,1113,1114,1115,1116,1117,1118,1119,1120,1280'],
                            ['role_name' => '管理员', 'type' => 2, 'store_id' => $res->id, 'status' => 1, 'level' => 1, 'rules' => '1048,1049,1097,1098,1099,1100,1050,1051,1101,1102,1103,1273,1274,1275,1276,1081,1104,1105,1106,1052,1054,1086,1129,1132,1133,1134,1135,1136,1137,1138,1139,1140,1141,1142,1143,1144,1145,1146,1147,1148,1149,1150,1151,1152,1153,1154,1155,1156,1157,1158,1159,1160,1161,1162,1163,1130,1166,1167,1168,1169,1131,1170,1171,1172,1173,1174,1175,1176,1242,1088,1122,1123,1124,1125,1126,1127,1164,1165,1053,1107,1108,1109,1110,1111,1112,1113,1114,1115,1116,1117,1118,1119,1120,1280,1055,1056,1177,1178,1179,1180,1181,1182,1183,1184,1185,1186,1187,1188,1189,1190,1191,1192,1277,1057,1193,1194,1195,1196,1197,1249,1250,1251,1252,1253,1254,1058,1059,1060,1198,1199,1200,1243,1255,1256,1257,1258,1259,1260,1061,1201,1241,1062,1063,1215,1218,1219,1220,1244,1261,1262,1263,1264,1265,1064,1216,1217,1202,1065,1066,1203,1214,1067,1204,1212,1213,1235,1068,1205,1206,1069,1207,1208,1070,1089,1071,1209,1210,1211,1072,1073,1082,1083,1084,1085,1228,1229,1230,1231,1232,1233,1234,1236,1245,1246,1247,1248,1221,1222,1223,1224,1225,1226,1227,1266,1267,1268,1269,1270,1271,1272,1237,1238,1239,1240']
                        ];
                        /** @var SystemRoleServices $systemRoleServices */
                        $systemRoleServices = app()->make(SystemRoleServices::class);
                        $systemRoleServices->saveAll($data);
                    }
                    return [(int)$res->id, $is_new];
                } else {
                    throw new AdminException('保存失败！');
                }
            }
        });
    }

    /**
     * 后台获取提货点详情
     * @param int $id
     * @param string $felid
     * @return array|false|mixed|string|string[]|\think\Model|null
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getStoreDispose(int $id, string $felid = '')
    {
        if ($felid) {
            return $this->dao->value(['id' => $id], $felid);
        } else {
            $storeInfo = $this->dao->get($id);
            if ($storeInfo) {
                $storeInfo['latlng'] = $storeInfo['latitude'] . ',' . $storeInfo['longitude'];
                $storeInfo['dataVal'] = $storeInfo['valid_time'] ? explode(' - ', $storeInfo['valid_time']) : [];
                $storeInfo['timeVal'] = $storeInfo['day_time'] ? explode(' - ', $storeInfo['day_time']) : [];
                $storeInfo['address2'] = $storeInfo['address'] ? explode(',', $storeInfo['address']) : [];
                return $storeInfo;
            }
            return false;
        }
    }

    /**
     * 获取门店不分页
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getStore()
    {
        return $this->dao->getStore(['type' => 0]);
    }

    /**
     * 获得导出店员列表
     * @param array $where
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getExportData(array $where)
    {
        return $this->dao->getStoreList($where, ['*']);
    }

    /**
     * 平台门店运营统计
     * @param array $time
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function storeChart(array $time)
    {
        $list = $this->dao->getStoreList(['is_del' => 0, 'is_show' => 1], ['id', 'name', 'image']);
        /** @var StoreUserServices $storeUserServices */
        $storeUserServices = app()->make(StoreUserServices::class);
        /** @var BranchOrderServices $orderServices */
        $orderServices = app()->make(BranchOrderServices::class);
        /** @var StoreFinanceFlowServices $storeFinancFlowServices */
        $storeFinancFlowServices = app()->make(StoreFinanceFlowServices::class);
        $where = ['time' => $time];
        $order_where = ['paid' => 1, 'pid' => 0, 'is_del' => 0, 'is_system_del' => 0, 'refund_status' => [0, 3]];
        foreach ($list as &$item) {
            $store_where = ['store_id' => $item['id']];
            $item['store_price'] = (float)bcsub((string)$storeFinancFlowServices->sum($where + $store_where + ['trade_type' => 1, 'no_type' => 1, 'pm' => 1, 'is_del' => 0], 'number', true), (string)$storeFinancFlowServices->sum($where + $store_where + ['trade_type' => 1, 'no_type' => 1, 'pm' => 0, 'is_del' => 0], 'number', true), 2);
            $item['store_product_count'] = $orderServices->sum($where + $store_where + $order_where, 'total_num', true);
            $item['store_order_price'] = $orderServices->sum($where + $store_where + $order_where, 'pay_price', true);
            $item['store_user_count'] = $storeUserServices->count($where + $store_where);
        }
        return $list;
    }
}