mkm/nk-lihaink-cn
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

合并分支'lxq': 入驻审核修复bug v1

Browse Source
This commit is contained in:
liuxiaoquan 2023-03-13 14:27:13 +08:00
commit 3a94f7da5e
16 changed files with 1773 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
app/admin/controller/merchant/system/merchant/MerchantIntention.php
View File

@ -29,6 +29,7 @@ class MerchantIntention extends BaseController
$this->intention = $intention;
$this->path = [
'index' => 'merchant/system/merchant/intention/lst',
'status' => 'merchant/system/merchant/intention/status',
'mark' => 'merchant/system/merchant/intention/mark',
'read' => 'merchant/system/merchant/intention/read',
'add' => 'merchant/system/merchant/intention/add'
@ -69,9 +70,34 @@ class MerchantIntention extends BaseController
return to_assign(0, '', $data);
}
/**
* 审核表单
*/
public function StatusForm()
{
return View($this->path['index']);
$id = get_params('id');
if (!$this->intention->getWhereCount(['mer_intention_id' => $id, 'is_del' => 0]))
return to_assign(1,'数据不存在');
return View($this->path['status'], ['id'=>$id]);
}
/**
* 审核
*/
public function SwitchStatus()
{
$params = get_params(['status','fail_msg','create_mer','id']);
$id = $params['id'];
//创建
if (!$this->intention->GetWhereCount(['mer_intention_id' => $id, 'is_del' => 0]))
return to_assign(1,'数据不存在');
$params['status'] = $params['status'] == 1 ? 1 : 2;
$this->intention->updateStatus($id, $params);
return to_assign(0,'修改成功');
}
public function MarkForm()

47
app/admin/view/merchant/system/merchant/intention/lst.html
View File

@ -17,15 +17,15 @@
<div class="layui-inline">
<label class="layui-form-label">选择时间</label>
<div class="layui-input-block">
<div class="layui-btn-group" id="chonse_date">
<input type="hidden" name="chonse_date" value="" disabled placeholder="选择时间">
<button name="both" lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal">全部</button>
<button name="today" lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">今天</button>
<button name="yeserday" lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">昨天</button>
<button lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">最近7天</button>
<button lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">最近30天</button>
<button lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">本月</button>
<button lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">本年</button>
<div class="layui-btn-group">
<input id="chonse_date" type="hidden" name="chonse_date" value="" disabled placeholder="选择时间">
<button name="both" lay-submit="" lay-filter="chonse_date" type="button" class="layui-btn layui-btn-normal">全部</button>
<button name="today" lay-submit="" lay-filter="chonse_date" type="button" class="layui-btn layui-btn-normal layui-btn-primary">今天</button>
<button name="yeserday" lay-submit="" lay-filter="chonse_date" type="button" class="layui-btn layui-btn-normal layui-btn-primary">昨天</button>
<button lay-submit="" lay-filter="chonse_date" type="button" class="layui-btn layui-btn-normal layui-btn-primary">最近7天</button>
<button lay-submit="" lay-filter="chonse_date" type="button" class="layui-btn layui-btn-normal layui-btn-primary">最近30天</button>
<button lay-submit="" lay-filter="chonse_date" type="button" class="layui-btn layui-btn-normal layui-btn-primary">本月</button>
<button lay-submit="" lay-filter="chonse_date" type="button" class="layui-btn layui-btn-normal layui-btn-primary">本年</button>
</div>
</div>
</div>
@ -52,8 +52,8 @@
<div class="layui-form-item">
<label class="layui-form-label">商户审核</label>
<div class="layui-input-block">
<div class="layui-btn-group" id="store_status">
<input type="hidden" name="status" value="0" disabled placeholder="核审状态值">
<div class="layui-btn-group">
<input type="hidden" id="status" name="status" value="0" disabled placeholder="核审状态值">
<button name="both" lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal">全部</button>
<button name="wait_status" lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">待审核</button>
<button name="success_status" lay-submit="" lay-filter="searchform" type="button" class="layui-btn layui-btn-normal layui-btn-primary">审核通过</button>
@ -67,10 +67,10 @@
<div class="layui-form-item">
<label class="layui-form-label">商户分类</label>
<div class="layui-input-block">
<select name="mer_cate" lay-filter="aihao">
<select name="category_id" lay-filter="seleform">
<option value=""></option>
{volist name="category" key="k" id="vo"}
<option value="0">{$vo.category_name}</option>
<option value="{$vo.merchant_category_id}">{$vo.category_name}</option>
{/volist}
</select>
</div>
@ -88,10 +88,10 @@
<div class="layui-form-item">
<label class="layui-form-label">店铺类型</label>
<div class="layui-input-block">
<select name="type" lay-filter="aihao">
<select name="type_id" lay-filter="seleform">
<option value=""></option>
{volist name="type" key="k" id="vo"}
<option value="0">{$vo.type_name}</option>
<option value="{$vo.mer_type_id}">{$vo.type_name}</option>
{/volist}
</select>
</div>
@ -124,6 +124,7 @@
<script type="text/html" id="toolbarDemo"></script>
<script type="text/html" id="barDemo">
<div class="layui-btn-group">
<a class="layui-btn layui-btn-normal layui-btn-xs" lay-event="status">审核</a>
<a class="layui-btn layui-btn-normal layui-btn-xs" lay-event="mark">备注</a>
<a class="layui-btn layui-btn-xs" lay-event="del">删除</a>
</div>
@ -239,6 +240,8 @@
// console.log(data);
if (obj.event === 'mark') {
tool.side('/admin/merchant/intention/markform?id=' + obj.data.mer_intention_id);
} else if (obj.event === 'status') {
tool.side('/admin/merchant/intention/statusform?id=' + obj.data.mer_intention_id);
} else if (obj.event === 'del') {
layer.confirm('确定要删除该记录吗?', {
icon: 3,
@ -306,6 +309,20 @@
return false;
});
form.on('submit(chonse_date)', function(data){
console.log(data.elem.name);
$('#chonse_date').val(data.elem.name);
layui.pageTable.reload({
where: {
...data.field
},
page: {
curr: 1
}
});
return false;
})
//监听select提交
form.on('select(seleform)', function(data) {
active['reload'] ? active['reload'].call(this) : '';

66
app/admin/view/merchant/system/merchant/intention/status.html Normal file
View File

@ -0,0 +1,66 @@
{extend name="common/base" /}
<!-- 主体 -->
{block name="body"}
<form class="layui-form p-4">
<h3 class="pb-3">审核状态</h3>
<table class="layui-table layui-table-form">
<tr>
<td class="layui-td-gray-2">审核状态<font>*</font>
</td>
<td>
<select name="status" lay-verify="required" lay-reqText="审核状态">
<option selected="selected" value="1">同意</option>
<option value="2">不同意</option>
</select>
</td>
</tr>
<tr>
<td class="layui-td-gray-2">创建商户<font>*</font>
</td>
<td>
<input type="radio" checked="checked" name="create_mer" value="1" title="是">
<input type="radio" name="create_mer" value="0" title="不是">
</td>
</tr>
</table>
<div style="padding: 10px 0">
<input type="hidden" name="id" value="{$id}">
<button class="layui-btn layui-btn-normal" lay-submit="" lay-filter="webform">立即提交</button>
<button type="reset" class="layui-btn layui-btn-primary">重置</button>
</div>
</form>
{/block}
<!-- /主体 -->
<!-- 脚本 -->
{block name="script"}
<script>
const moduleInit = ['tool'];
function gouguInit() {
var form = layui.form,tool=layui.tool;
//监听提交
form.on('submit(webform)', function (data) {
console.log(data.field)
if (!data.field.status || data.field.id == '' || data.field.create_mer == '') {
layer.msg('请选择审核表单');
return false;
}
let callback = function (e) {
layer.msg(e.msg);
if (e.code == 0) {
setTimeout(function () {
// parent.location.reload();
}, 1000);
}
}
tool.post('/admin/merchant/intention/status', data.field, callback);
return false;
});
}
</script>
{/block}
<!-- /脚本 -->

899
app/common/model/merchant/common.php Normal file
View File

@ -0,0 +1,899 @@
<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
// 应用公共文件
use app\common\model\merchant\system\config\SystemConfigValue;
// use app\common\model\merchant\system\groupData\GroupData;
// use crmeb\services\UploadService;
// use Swoole\Lock;
use think\db\BaseQuery;
if (!function_exists('isDebug')) {
function isDebug(): bool
{
return !!env('APP_DEBUG');
}
}
if (!function_exists('formToData')) {
function formToData($form): array
{
$rule = $form->formRule();
$action = $form->getAction();
$method = $form->getMethod();
$title = $form->getTitle();
$config = (object)$form->formConfig();
$admin = config('admin.api_admin_prefix');
$merchant = config('admin.api_merchant_prefix');
$api = $action;
if (strpos($api, '/' . $admin) === 0) {
$api = substr($api, strlen($admin) + 1);
} else if (strpos($api, '/' . $merchant) === 0) {
$api = substr($api, strlen($merchant) + 1);
}
$api = str_replace('.html', '', $api);
return compact('rule', 'action', 'method', 'title', 'config', 'api');
}
}
if (!function_exists('getDistance')) {
function getDistance($lat1, $lng1, $lat2, $lng2)
{
//将角度转为狐度
$radLat1 = deg2rad($lat1); //deg2rad()函数将角度转换为弧度
$radLat2 = deg2rad($lat2);
$radLng1 = deg2rad($lng1);
$radLng2 = deg2rad($lng2);
$a = $radLat1 - $radLat2;
$b = $radLng1 - $radLng2;
$s = 2 * asin(sqrt(pow(sin($a / 2), 2) + cos($radLat1) * cos($radLat2) * pow(sin($b / 2), 2))) * 6371;
return round($s, 1);
}
}
/**
* 无线级分类处理
*
* @param array $data 数据源
* @param string $idName 主键
* @param string $fieldName 父级字段
* @param string $childrenKey 子级字段名
* @return array
* @author 张先生
* @date 2020-03-27
*/
if (!function_exists('formatCategory')) {
function formatCategory(array $data, string $idName = "id", string $fieldName = 'pid', $childrenKey = 'children')
{
$items = [];
foreach ($data as $item) {
$items[$item[$idName]] = $item;
}
$result = array();
foreach ($items as $item) {
if (isset($items[$item[$fieldName]])) {
$items[$item[$fieldName]][$childrenKey][] = &$items[$item[$idName]];
} else if ($item[$fieldName] == 0) {
$result[] = &$items[$item[$idName]];
}
}
return $result;
}
}
if (!function_exists('formatTreeList')) {
function formatTreeList(&$options, $name, $pidName = 'pid', $pid = 0, $level = 0, &$data = []): array
{
$_options = $options;
foreach ($_options as $k => $option) {
if ($option[$pidName] == $pid) {
$data[] = ['value' => $k, 'label' => str_repeat('|---', $level + 1) . $option[$name]];
unset($options[$k]);
formatTreeList($options, $name, $pidName, $k, $level + 1, $data);
}
}
return $data;
}
}
if (!function_exists('formatTree')) {
function formatTree(&$options, $name, $pidName = 'pid', $pid = 0, $level = 0, $data = []): array
{
$_options = $options;
foreach ($_options as $k => $option) {
if ($option[$pidName] == $pid) {
$value = ['id' => $k, 'title' => $option[$name]];
unset($options[$k]);
$value['children'] = formatTree($options, $name, $pidName, $k, $level + 1);
$data[] = $value;
}
}
return $data;
}
}
if (!function_exists('formatCascaderData')) {
function formatCascaderData(&$options, $name, $baseLevel = 0, $pidName = 'pid', $pid = 0, $level = 0, $data = []): array
{
$_options = $options;
foreach ($_options as $k => $option) {
if ($option[$pidName] == $pid) {
$value = ['value' => $k, 'label' => $option[$name]];
unset($options[$k]);
$value['children'] = formatCascaderData($options, $name, $baseLevel, $pidName, $k, $level + 1);
if (!count($value['children'])) unset($value['children']);
$data[] = $value;
}
}
return $data;
}
}
/**
* @function toMap 数组重新组装
* @param array $data 数据
* @param string $field key
* @param string $value value default null
* @return array
* @author 张先生
* @date 2020-04-01
*/
if (!function_exists('toMap')) {
function toMap(array $data, $field = 'id', $value = '')
{
$result = array();
if (empty($data)) {
return $result;
}
//开始处理数据
foreach ($data as $item) {
$val = $item;
if (!empty($value)) {
$val = $item[$value];
}
$result[$item[$field]] = $val;
}
return $result;
}
}
/**
* @function getUniqueListByArray 从数组中获取某个字段的值，重新拼装成新的一维数组
* @param array $data 数据
* @param string $field key
* @return array
* @author 张先生
* @date 2020-04-01
*/
if (!function_exists('getUniqueListByArray')) {
function getUniqueListByArray(array $data, $field = 'id')
{
return array_unique(array_values(array_column($data, $field)));
}
}
if (!function_exists('isPhone')) {
function isPhone($test)
{
return !preg_match("/^1[3456789]{1}\d{9}$/", $test);
}
}
if (!function_exists('getMonth')) {
/**
* 获取本季度 time
* @param int|string $time
* @param $ceil
* @return array
*/
function getMonth($time = '', $ceil = 0)
{
if ($ceil != 0)
$season = ceil(date('n') / 3) - $ceil;
else
$season = ceil(date('n') / 3);
$firstday = date('Y-m-01', mktime(0, 0, 0, ($season - 1) * 3 + 1, 1, date('Y')));
$lastday = date('Y-m-t', mktime(0, 0, 0, $season * 3, 1, date('Y')));
return array($firstday, $lastday);
}
}
if (!function_exists('getModelTime')) {
/**
* @param BaseQuery $model
* @param string $section
* @param string $prefix
* @param string $field
* @return mixed
* @author xaboy
* @day 2020-04-29
*/
function getModelTime(BaseQuery $model, string $section, $prefix = 'create_time', $field = '-',$time = '')
{
if (!isset($section)) return $model;
switch ($section) {
case 'today':
$model->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('today')), date('Y-m-d H:i:s', strtotime('tomorrow -1second'))]);
break;
case 'week':
$model->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('this week 00:00:00')), date('Y-m-d H:i:s', strtotime('next week 00:00:00 -1second'))]);
break;
case 'month':
$model->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('first Day of this month 00:00:00')), date('Y-m-d H:i:s', strtotime('first Day of next month 00:00:00 -1second'))]);
break;
case 'year':
$model->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('this year 1/1')), date('Y-m-d H:i:s', strtotime('next year 1/1 -1second'))]);
break;
case 'yesterday':
$model->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('yesterday')), date('Y-m-d H:i:s', strtotime('today -1second'))]);
break;
case 'quarter':
list($startTime, $endTime) = getMonth();
$model = $model->where($prefix, '>', $startTime);
$model = $model->where($prefix, '<', $endTime);
break;
case 'lately7':
$model = $model->where($prefix, 'between', [date('Y-m-d', strtotime("-7 day")), date('Y-m-d H:i:s')]);
break;
case 'lately30':
$model = $model->where($prefix, 'between', [date('Y-m-d', strtotime("-30 day")), date('Y-m-d H:i:s')]);
break;
default:
if (strstr($section, $field) !== false) {
list($startTime, $endTime) = explode($field, $section);
if (strlen($startTime) == 4) {
$model->whereBetweenTime($prefix, date('Y-m-d H:i:s', strtotime($section)), date('Y-m-d H:i:s', strtotime($section . ' +1day -1second')));
} else {
if ($startTime == $endTime) {
$model = $model->whereBetweenTime($prefix, date('Y-m-d 0:0:0', strtotime($startTime)), date('Y-m-d 23:59:59', strtotime($endTime)));
} else if(strpos($startTime, ':')) {
$model = $model->whereBetweenTime($prefix, $startTime, $endTime);
} else {
$model = $model->whereBetweenTime($prefix, date('Y-m-d H:i:s', strtotime($startTime)), date('Y-m-d H:i:s', strtotime($endTime . ' +1day -1second')));
}
}
}
break;
}
return $model;
}
}
if (!function_exists('hasMany')) {
function hasMany($collection, $field, $model, $searchKey, $insertKey, $where = [] ,$select = '*')
{
$ids = [];
$link = [];
if (!$collection) return [];
$collection = $collection->toArray();
foreach ($collection as $k => $item) {
if (is_array($item[$field])) {
$link[$k] = array_unique($item[$field]);
$ids = array_merge($item[$field], $ids);
} else {
$link[$k] = array_unique(explode(',', $item[$field]));
}
$ids = array_merge($link[$k], $ids);
if (isset($collection[$k][$insertKey])) unset($collection[$k][$insertKey]);
}
$ids = array_filter(array_unique($ids));
if (!count($ids)) {
return $collection;
}
$many = $model::whereIn($searchKey, array_unique($ids))->where($where)->field($select)->select();
if (!$many) return $collection;
$many = $many->toArray();
foreach ($link as $k => $val) {
foreach ($many as $item) {
if (in_array($item[$searchKey], $val)) {
if (!isset($collection[$k][$insertKey])) $collection[$k][$insertKey] = [];
$collection[$k][$insertKey][] = $item;
}
}
}
return $collection;
}
}
if (!function_exists('activeProductSku')) {
//格式活动商品SKU
function activeProductSku($activeData, $type = null)
{
$make = app()->make(\app\common\model\merchant\store\product\Product::class);
$price = 0;
$data = [];
foreach($activeData as $key => $value) {
$maxPrice = 0;
$must_price = 0;
$attrValue = [];
if(is_null($value['product'])) continue;
$productSku = $value['productSku'];
$productAttr = $value['product']['attr'];
$productAttrValue = $value['product']['attrValue'];
unset($value['productSku'], $value['product']['attrValue'], $value['product']['attr']);
foreach ($productAttrValue as $attr_value) {
if (!empty($productSku)){
foreach ($productSku as $sk => $sv) {
if ( $sv['unique'] == $attr_value['unique']) {
if ($type == 'discounts') {
unset($attr_value['ot_price'], $attr_value['price']);
$attr_value['ot_price'] = $sv['price'];
$attr_value['price'] = $sv['active_price'];
$_price = bcsub($sv['price'], $sv['active_price'], 2);
if ($value['type']){
$must_price = $must_price > $_price ? $must_price : $_price;
} else {
$maxPrice = $maxPrice > $_price ? $maxPrice : $_price;
}
} else {
$attr_value['productSku'] = $sv;
}
$attrValue[] = $attr_value;
}
}
}
}
$attr = $make->detailAttr($productAttr);
if ($type == 'discounts') {
$sku = $make->detailAttrValue($attrValue, null);
$value['product']['sku'] = $sku;
} else {
$value['product']['attrValue'] = $attrValue;
}
$value['product']['attr'] = $attr;
$price = bcadd($price, bcadd($must_price,$maxPrice,2), 2);
if ($value['type'] == 1) {
array_unshift($data,$value);
}else {
$data[] = $value;
}
}
return compact('data', 'price');
}
}
if (!function_exists('systemConfig')) {
/**
* 获取系统配置
*
* @param string|string[] $key
* @return mixed
* @author xaboy
* @day 2020-05-08
*/
function systemConfig($key)
{
return merchantConfig(0, $key);
}
}
if (!function_exists('getDatesBetweenTwoDays')) {
function getDatesBetweenTwoDays($startDate, $endDate)
{
$dates = [];
if (strtotime($startDate) > strtotime($endDate)) {
//如果开始日期大于结束日期，直接return 防止下面的循环出现死循环
return $dates;
} elseif ($startDate == $endDate) {
//开始日期与结束日期是同一天时
array_push($dates, date('m-d', strtotime($startDate)));
return $dates;
} else {
array_push($dates, date('m-d', strtotime($startDate)));
$currentDate = $startDate;
do {
$nextDate = date('Y-m-d', strtotime($currentDate . ' +1 days'));
array_push($dates, date('m-d', strtotime($currentDate . ' +1 days')));
$currentDate = $nextDate;
} while ($endDate != $currentDate);
return $dates;
}
}
}
if (!function_exists('getStartModelTime')) {
function getStartModelTime(string $section)
{
switch ($section) {
case 'today':
case 'yesterday':
return date('Y-m-d', strtotime($section));
case 'week':
return date('Y-m-d', strtotime('this week'));
case 'month':
return date('Y-m-d', strtotime('first Day of this month'));
case 'year':
return date('Y-m-d', strtotime('this year 1/1'));
case 'quarter':
list($startTime, $endTime) = getMonth();
return $startTime;
case 'lately7':
return date('Y-m-d', strtotime("-7 day"));
case 'lately30':
return date('Y-m-d', strtotime("-30 day"));
default:
if (strstr($section, '-') !== false) {
list($startTime, $endTime) = explode('-', $section);
return date('Y-m-d H:i:s', strtotime($startTime));
}
return date('Y-m-d H:i:s');
}
}
}
if (!function_exists('merchantConfig')) {
/**
* 获取商户配置
*
* @param int $merId
* @param string|string[] $key
* @return mixed
* @author xaboy
* @day 2020-05-08
*/
function merchantConfig(int $merId, $key)
{
$request = request();
$make = app()->make(SystemConfigValue::class);
if (is_array($key)) {
$_key = [];
$cacheData = [];
foreach ($key as $v) {
if ($request->hasCache($merId, $v)) {
$cacheData[$v] = $request->getCache($merId, $v);
} else {
$_key[] = $v;
}
}
if (!count($_key)) return $cacheData;
$data = $make->more($_key, $merId);
$request->setCache($merId, $data);
$data += $cacheData;
} else {
if ($request->hasCache($merId, $key)) {
$data = $request->getCache($merId, $key);
} else {
$data = $make->get($key, $merId);
$request->setCache($merId, $key, $data);
}
}
return $data;
}
}
if (!function_exists('filter_emoji')) {
// 过滤掉emoji表情
function filter_emoji($str)
{
$str = preg_replace_callback( //执行一个正则表达式搜索并且使用一个回调进行替换
'/./u',
function (array $match) {
return strlen($match[0]) >= 4 ? '' : $match[0];
},
$str
);
return $str;
}
}
if (!function_exists('setHttpType')) {
/**
* TODO 修改 https 和 http 移动到common
* @param $url $url 域名
* @param int $type 0 返回https 1 返回 http
* @return string
*/
function setHttpType($url, $type = 0)
{
$domainTop = substr($url, 0, 5);
if ($type) {
if ($domainTop == 'https') $url = 'http' . substr($url, 5, strlen($url));
} else {
if ($domainTop != 'https') $url = 'https:' . substr($url, 5, strlen($url));
}
return $url;
}
}
if (!function_exists('remoteImage')) {
/**
* TODO 获取小程序二维码是否生成
* @param $url
* @return array
*/
function remoteImage($url)
{
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
$result = curl_exec($curl);
$result = json_decode($result, true);
if (is_array($result)) return ['status' => false, 'msg' => $result['errcode'] . '---' . $result['errmsg']];
return ['status' => true];
}
}
if (!function_exists('image_to_base64')) {
/**
* 获取图片转为base64
* @param string $avatar
* @return bool|string
*/
function image_to_base64($avatar = '', $timeout = 9)
{
try {
$url = parse_url($avatar);
$url = $url['host'];
$header = [
'User-Agent: Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:45.0) Gecko/20100101 Firefox/45.0',
'Accept-Language: zh-CN,zh;q=0.8,en-US;q=0.5,en;q=0.3',
'Accept-Encoding: gzip, deflate, br',
'accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
'Host:' . $url
];
$dir = pathinfo($url);
$host = $dir['dirname'];
$refer = $host . '/';
$curl = curl_init();
curl_setopt($curl, CURLOPT_REFERER, $refer);
curl_setopt($curl, CURLOPT_URL, $avatar);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($curl, CURLOPT_ENCODING, 'gzip');
curl_setopt($curl, CURLOPT_CONNECTTIMEOUT, $timeout);
curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
$data = curl_exec($curl);
$code = curl_getinfo($curl, CURLINFO_HTTP_CODE);
curl_close($curl);
if ($code == 200) {
return "data:image/jpeg;base64," . base64_encode($data);
} else {
return false;
}
} catch (Exception $e) {
return false;
}
}
}
if (!function_exists('put_image')) {
/**
* 获取图片转为base64
* @param string $avatar
* @return bool|string
*/
function put_image($url, $filename = '')
{
if ($url == '') {
return false;
}
try {
if ($filename == '') {
$ext = pathinfo($url);
if ($ext['extension'] != "jpg" && $ext['extension'] != "png" && $ext['extension'] != "jpeg") {
return false;
}
$filename = time() . "." . $ext['extension'];
}
//文件保存路径
ob_start();
readfile($url);
$img = ob_get_contents();
ob_end_clean();
$path = 'public/uploads/qrcode';
$fp2 = fopen($path . '/' . $filename, 'a');
fwrite($fp2, $img);
fclose($fp2);
return $path . '/' . $filename;
} catch (Exception $e) {
return false;
}
}
}
if (!function_exists('path_to_url')) {
/**
* 路径转url路径
* @param $path
* @return string
*/
function path_to_url($path)
{
return trim(str_replace(DIRECTORY_SEPARATOR, '/', $path), '.');
}
}
if (!function_exists('tidy_url')) {
/**
* 路径转url路径
* @param $url
* @param int $http
* @param string $site
* @return string
*/
function tidy_url($url, $http = null, $site = null)
{
if (!$site) {
$site = systemConfig('site_url');
}
$url = path_to_url($url);
if (strpos($url, 'http') === false)
$url = rtrim($site, '/') . '/' . ltrim($url, '/');
if (is_null($http)) {
$http = (parse_url($site)['scheme'] ?? '') == 'https' ? 0 : 1;
}
$url = set_http_type($url, $http);
return $url;
}
}
if (!function_exists('curl_file_exist')) {
/**
* CURL 检测远程文件是否在
* @param $url
* @return bool
*/
function curl_file_exist($url)
{
$ch = curl_init();
try {
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_HEADER, 1);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
$contents = curl_exec($ch);
if (preg_match("/404/", $contents)) return false;
if (preg_match("/403/", $contents)) return false;
return true;
} catch (Exception $e) {
return false;
}
}
}
if (!function_exists('set_http_type')) {
/**
* 修改 https 和 http
* @param $url $url 域名
* @param int $type 0 返回https 1 返回 http
* @return string
*/
function set_http_type($url, $type = 0)
{
$domainTop = substr($url, 0, 5);
if ($type) {
if ($domainTop == 'https') $url = 'http' . substr($url, 5, strlen($url));
} else {
if ($domainTop != 'https') $url = 'https:' . substr($url, 5, strlen($url));
}
return $url;
}
}
if (!function_exists('getTimes')) {
function getTimes()
{
$dates = [];
for ($i = 0; $i <= 24; $i++) {
for ($j = 0; $j < 60; $j++) {
$dates[] = sprintf('%02.d', $i) . ':' . sprintf('%02.d', $j);
}
}
return $dates;
}
}
if (!function_exists('monday')) {
/**
* 获取周一
*
* @param null $time
* @return false|string
* @author xaboy
* @day 2020/6/22
*/
function monday($time = null)
{
return date('Y-m-d', strtotime('Sunday -6 day', $time ?: time()));
}
}
if (!function_exists('attr_format')) {
/**
* 格式化属性
* @param $arr
* @return array
*/
function attr_format($arr)
{
$data = [];
$res = [];
$count = count($arr);
if ($count > 1) {
for ($i = 0; $i < $count - 1; $i++) {
if ($i == 0) $data = $arr[$i]['detail'];
//替代变量1
$rep1 = [];
foreach ($data as $v) {
foreach ($arr[$i + 1]['detail'] as $g) {
//替代变量2
$rep2 = ($i != 0 ? '' : $arr[$i]['value'] . '_$_') . $v . '-$-' . $arr[$i + 1]['value'] . '_$_' . $g;
$tmp[] = $rep2;
if ($i == $count - 2) {
foreach (explode('-$-', $rep2) as $k => $h) {
//替代变量3
$rep3 = explode('_$_', $h);
//替代变量4
$rep4['detail'][$rep3[0]] = isset($rep3[1]) ? $rep3[1] : '';
}
if ($count == count($rep4['detail']))
$res[] = $rep4;
}
}
}
$data = isset($tmp) ? $tmp : [];
}
} else {
$dataArr = [];
foreach ($arr as $k => $v) {
foreach ($v['detail'] as $kk => $vv) {
$dataArr[$kk] = $v['value'] . '_' . $vv;
$res[$kk]['detail'][$v['value']] = $vv;
}
}
$data[] = implode('-', $dataArr);
}
return [$data, $res];
}
}
if (!function_exists('filter_emoji')) {
//过滤掉emoji表情
function filter_emoji($str)
{
$str = preg_replace_callback('/./u', function (array $match) {
return strlen($match[0]) >= 4 ? '' : $match[0];
}, $str);
return $str;
}
}
/**
* 高德经纬度改百度经纬度
* @param $lng 经度
* @param $lat 纬度
* @return mixed
*/
if (!function_exists('bd_encrypt')) {
function bd_encrypt($lng, $lat)
{
$x_pi = 3.14159265358979324 * 3000.0 / 180.0;
$x = $lng;
$y = $lat;
$z = sqrt($x * $x + $y * $y) - 0.00002 * sin($y * $x_pi);
$theta = atan2($y, $x) - 0.000003 * cos($x * $x_pi);
$data['lng'] = $z * cos($theta) + 0.0065;
$data['lat'] = $z * sin($theta) + 0.006;
return $data;
}
}
if (!function_exists('aj_captcha_check_one')) {
/**
* 验证滑块1次验证
* @param string $token
* @param string $pointJson
* @return bool
*/
function aj_captcha_check_one(string $captchaType, string $token, string $pointJson)
{
aj_get_serevice($captchaType)->check($token, $pointJson);
return true;
}
}
if (!function_exists('aj_captcha_check_two')) {
/**
* 验证滑块2次验证
* @param string $token
* @param string $pointJson
* @return bool
*/
function aj_captcha_check_two(string $captchaType, string $captchaVerification )
{
aj_get_serevice($captchaType)->verificationByEncryptCode($captchaVerification);
return true;
}
}
if (!function_exists('validateIDCard')) {
function validateIDCard(string $idcard)
{
if(empty($idcard)){
return false;
}else{
$idcard = strtoupper($idcard); # 如果是小写x,转化为大写X
if(strlen($idcard) != 18 && strlen($idcard) != 15){
return false;
}
# 如果是15位身份证，则转化为18位
if(strlen($idcard) == 15){
# 如果身份证顺序码是996 997 998 999，这些是为百岁以上老人的特殊编码
if (array_search(substr($idcard, 12, 3), array('996', '997', '998', '999')) !== false) {
$idcard = substr($idcard, 0, 6) . '18' . substr($idcard, 6, 9);
} else {
$idcard = substr($idcard, 0, 6) . '19' . substr($idcard, 6, 9);
}
# 加权因子
$factor = array(7, 9, 10, 5, 8, 4, 2, 1, 6, 3, 7, 9, 10, 5, 8, 4, 2);
# 校验码对应值
$code = array('1', '0', 'X', '9', '8', '7', '6', '5', '4', '3', '2');
$checksum = 0;
for ($i = 0; $i < strlen($idcard); $i++) {
$checksum += substr($idcard, $i, 1) * $factor[$i];
}
$idcard = $idcard . $code[$checksum % 11];
}
# 验证身份证开始
$IDCardBody = substr($idcard, 0, 17); # 身份证主体
$IDCardCode = strtoupper(substr($idcard, 17, 1)); # 身份证最后一位的验证码
# 加权因子
$factor = array(7, 9, 10, 5, 8, 4, 2, 1, 6, 3, 7, 9, 10, 5, 8, 4, 2);
# 校验码对应值
$code = array('1', '0', 'X', '9', '8', '7', '6', '5', '4', '3', '2');
$checksum = 0;
for ($i = 0; $i < strlen($IDCardBody); $i++) {
$checksum += substr($IDCardBody, $i, 1) * $factor[$i];
}
$validateIdcard = $code[$checksum % 11]; # 判断身份证是否合理
if($validateIdcard != $IDCardCode){
return false;
}else{
return true;
}
}
}
}

118
app/common/model/merchant/store/ShippingTemplate.php Normal file
View File

@ -0,0 +1,118 @@
<?php
namespace app\common\model\merchant\store;
use think\Model;
use think\facade\Db;
use think\exception\ValidateException;
class ShippingTemplate extends Model
{
protected $connection = 'shop';
protected $table = 'eb_shipping_template';
/**
* @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->createTemp($data);
}
/**
* @Author:Qinii
* @Date: 2020/5/13
* @param array $data
*/
public function createTemp(array $data)
{
Db::transaction(function()use ($data) {
$region = $data['region'];
$free = $data['free'] ?? '';
$undelives = $data['undelives'] ?? '';
unset($data['region'],$data['free'],$data['undelives'],$data['city_ids']);
$temp = self::create($data);
if($data['appoint']) {
$settlefree = $this->settleFree($free, $temp['shipping_template_id']);
(new ShippingTemplateFree)->insertAll($settlefree);
}
$settleRegion = $this->settleRegion($region, $temp['shipping_template_id']);
(new ShippingTemplateRegion)->insertAll($settleRegion);
if($data['undelivery'] == 1){
$settleUndelives = $this->settleUndelives($undelives,$temp['shipping_template_id']);
(new ShippingTemplateUndelive)->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;
}
/**
* @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 $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']];
}
}

23
app/common/model/merchant/store/ShippingTemplateFree.php Normal file
View File

@ -0,0 +1,23 @@
<?php
namespace app\common\model\merchant\store;
use think\Model;
class ShippingTemplateFree extends Model
{
protected $connection = 'shop';
protected $table = 'eb_shipping_template_free';
/**
* @Author:Qinii
* @Date: 2020/5/13
* @param array $data
* @return mixed
*/
public function insertAll(array $data)
{
return self::insertAll($data);
}
}

28
app/common/model/merchant/store/ShippingTemplateRegion.php Normal file
View File

@ -0,0 +1,28 @@
<?php
declare (strict_types = 1);
namespace app\common\model\merchant\store;
use think\Model;
/**
* @mixin \think\Model
*/
class ShippingTemplateRegion extends Model
{
protected $connection = 'shop';
protected $table = 'eb_shipping_template_region';
/**
* @Author:Qinii
* @Date: 2020/5/13
* @param array $data
* @return mixed
*/
public function insertAll(array $data)
{
return self::insertAll($data);
}
}

15
app/common/model/merchant/store/ShippingTemplateUndelive.php Normal file
View File

@ -0,0 +1,15 @@
<?php
declare (strict_types = 1);
namespace app\common\model\merchant\store;
use think\Model;
/**
* @mixin \think\Model
*/
class ShippingTemplateUndelive extends Model
{
protected $connection = 'shop';
protected $table = 'eb_shipping_template_undelivery';
}

91
app/common/model/merchant/store/product/ProductCopy.php Normal file
View File

@ -0,0 +1,91 @@
<?php
declare (strict_types = 1);
namespace app\common\model\merchant\store\product;
use think\Model;
use think\facade\Db;
use think\exception\ValidateException;
use app\common\model\merchant\system\merchant\Merchant;
/**
* @mixin \think\Model
*/
class ProductCopy extends Model
{
protected $connection = 'shop';
protected $table = 'eb_product_copy';
/**
* TODO 默认赠送复制次数
* @param $merId
* @author Qinii
* @day 2020-08-06
*/
public function defaulCopyNum($merId)
{
if(systemConfig('copy_product_status')){
$data = [
'type' => 'sys',
'num' => systemConfig('copy_product_defaul'),
'message' => '赠送次数',
];
$this->add($data,$merId);
}
}
/**
* TODO 添加记录并修改数据
* @param $data
* @param $merId
* @author Qinii
* @day 2020-08-06
*/
public function add($data,$merId)
{
$make = app()->make(Merchant::class);
$getOne = $make->get($merId);
switch ($data['type']) {
case 'mer_dump':
//nobreak;
case 'pay_dump':
$field = 'export_dump_num';
break;
case 'sys':
//nobreak;
//nobreak;
case 'pay_copy':
//nobreak;
case 'copy':
//nobreak;
$field = 'copy_product_num';
break;
default:
$field = 'copy_product_num';
break;
}
$number = $getOne[$field] + $data['num'];
$arr = [
'type' => $data['type'],
'num' => $data['num'],
'info' => $data['info']??'' ,
'mer_id'=> $merId,
'message' => $data['message'] ?? '',
'number' => ($number < 0) ? 0 : $number,
];
Db::transaction(function()use($arr,$make,$field){
self::create($arr);
if ($arr['num'] < 0) {
$make->sumFieldNum($arr['mer_id'],$arr['num'],$field);
} else {
$make->addFieldNum($arr['mer_id'],$arr['num'],$field);
}
});
}
}

15
app/common/model/merchant/system/config/SystemConfig.php Normal file
View File

@ -0,0 +1,15 @@
<?php
declare (strict_types = 1);
namespace app\common\model\merchant\system\config;
use think\Model;
/**
* @mixin \think\Model
*/
class SystemConfig extends Model
{
protected $connection = 'shop';
protected $table = 'eb_system_config';
}

14
app/common/model/merchant/system/config/SystemConfigClassify.php Normal file
View File

@ -0,0 +1,14 @@
<?php
declare (strict_types = 1);
namespace app\common\model\merchant\system\config;
use think\Model;
/**
* @mixin \think\Model
*/
class SystemConfigClassify extends Model
{
//
}

155
app/common/model/merchant/system/config/SystemConfigValue.php Normal file
View File

@ -0,0 +1,155 @@
<?php
declare (strict_types = 1);
namespace app\common\model\merchant\system\config;
use think\Model;
use think\exception\ValidateException;
/**
* @mixin \think\Model
*/
class SystemConfigValue extends Model
{
protected $connection = 'shop';
protected $table = 'eb_system_config_value';
/**
* @param array $keys
* @param int $merId
* @return array
*/
public function more(array $keys, int $merId): array
{
$config = self::fields($keys, $merId);
foreach ($keys as $key) {
if (!isset($config[$key])) $config[$key] = '';
}
return $config;
}
/**
* @param string $key
* @param int $merId
* @return mixed|string|null
*/
public function get(string $key, int $merId)
{
$value = self::value($key, $merId);
return $value ?? '';
}
/**
* @param int|array $cid
* @param array $formData
* @param int $merId
* @author xaboy
* @day 2020-03-27
*/
public function saveConfig($cid, array $formData, int $merId)
{
$keys = array_keys($formData);
$keys = app()->make(ConfigRepository::class)->intersectionKey($cid, $keys);
if (!count($keys)) return;
foreach ($keys as $key => $info) {
if (!isset($formData[$key]))
unset($formData[$key]);
else {
if ($info['config_type'] == 'number') {
if ($formData[$key] === '' || $formData[$key] < 0)
throw new ValidateException($info['config_name'] . '不能小于0');
$formData[$key] = floatval($formData[$key]);
}
$this->separate($key,$formData[$key],$merId);
}
}
$this->setFormData($formData, $merId);
}
/**
* TODO 需要做特殊处理的配置参数
* @param $key
* @author Qinii
* @day 2022/11/17
*/
public function separate($key,$value,$merId)
{
switch($key) {
case 'mer_svip_status':
//修改商户的会员状态
app()->make(ProductRepository::class)->getSearch([])->where(['mer_id' => $merId,'product_type' => 0])->update([$key => $value]);
break;
//热卖排行
case 'hot_ranking_switch':
if ($value) {
Queue::push(SyncProductTopJob::class, []);
}
break;
case 'svip_switch_status':
if ($value == 1) {
$groupDataRepository = app()->make(GroupDataRepository::class);
$groupRepository = app()->make(GroupRepository::class);
$group_id = $groupRepository->getSearch(['group_key' => 'svip_pay'])->value('group_id');
$where['group_id'] = $group_id;
$where['status'] = 1;
$count = $groupDataRepository->getSearch($where)->field('group_data_id,value,sort,status')->count();
if (!$count)
throw new ValidateException('请先添加会员类型');
}
break;
default:
break;
}
return ;
}
public function setFormData(array $formData, int $merId)
{
Db::transaction(function () use ($merId, $formData) {
foreach ($formData as $key => $value) {
if ($this->dao->merExists($key, $merId))
$this->dao->merUpdate($merId, $key, ['value' => $value]);
else
$this->dao->create([
'mer_id' => $merId,
'value' => $value,
'config_key' => $key
]);
}
});
}
// -------------------------------------------------
/**
* @param array $keys
* @param int $merId
* @return array
*/
protected function fields(array $keys, int $merId)
{
$result = SystemConfigValue::whereIn('config_key', $keys)->where('mer_id', $merId)->withAttr('value', function ($val, $data) {
return json_decode($val, true);
})->column('value', 'config_key');
foreach ($result as $k => $val) {
$result[$k] = json_decode($val, true);
}
return $result;
}
/**
* @param string $key
* @param int $merId
* @return mixed|null
*/
protected function value(string $key, int $merId)
{
$value = SystemConfigValue::where('config_key', $key)->where('mer_id', $merId)->value('value');
$value = is_null($value) ? null : json_decode($value, true);
return $value;
}
}

67
app/common/model/merchant/system/merchant/Merchant.php
View File

@ -12,7 +12,9 @@ namespace app\common\model\merchant\system\merchant;
use think\Model;
use app\common\model\merchant\user\UserBill as UserBillModel;
use app\common\model\merchant\store\ShippingTemplate;
use think\exception\ValidateException;
use think\facade\Db;
/**
* @mixin \think\Model
@ -32,6 +34,49 @@ class Merchant extends Model
return $this->merchantType()->bind(['type_name']);
}
/**
* @param array $data
* @author xaboy
* @day 2020-04-17
*/
public function createMerchant(array $data)
{
if ($this->fieldExists('mer_name', $data['mer_name']))
throw new ValidateException('商户名已存在');
if ($data['mer_phone'] && isPhone($data['mer_phone']))
throw new ValidateException('请输入正确的手机号');
$merchantCategory = app()->make(MerchantCategory::class);
$admin = app()->make(MerchantAdmin::class);
if (!$data['category_id'] || !$merchantCategory->idIsExists($data['category_id']))
throw new ValidateException('商户分类不存在');
if ($admin->fieldExists('account', $data['mer_account']))
throw new ValidateException('账号已存在');
/** @var MerchantAdmin $make */
$make = app()->make(MerchantAdmin::class);
$margin = app()->make(MerchantType::class)->get($data['type_id']);
$data['is_margin'] = $margin['is_margin'] ?? -1;
$data['margin'] = $margin['margin'] ?? 0;
return Db::transaction(function () use ($data, $make) {
$account = $data['mer_account'];
$password = $data['mer_password'];
unset($data['mer_account'], $data['mer_password']);
$merchant = $this->dao->create($data);
$make->createMerchantAccount($merchant, $account, $password);
$address_id = Db::name('merchant_address')->insertGetId(['mer_id'=>$merchant->mer_id,'street_id'=>$data['geo_street']]);
if($data['area_id'] && $data['village_id']){
Db::name('merchant_address')->where('id',$address_id)->update(['area_id'=>$data['area_id'],'village_id'=>$data['village_id']]);
}
app()->make(ShippingTemplate::class)->createDefault($merchant->mer_id);
app()->make(ProductCopy::class)->defaulCopyNum($merchant->mer_id);
return $merchant;
});
}
/**
* 扣除保证金
*@param array $data [mer_id] => 75
@ -79,4 +124,26 @@ class Merchant extends Model
return $merchant;
}
//------------------------------------------------
public function addFieldNum(int $merId, int $num, string $field)
{
if ($num < 0) $num = -$num;
$merchant = $this->getModel()::getDB()->where('mer_id', $merId)->find();
$number = $merchant[$field] + $num;
$merchant[$field] = $number;
$merchant->save();
}
public function sumFieldNum(int $merId, int $num, string $field)
{
if ($num < 0) $num = -$num;
$merchant = $this->getModel()::getDB()->where('mer_id', $merId)->find();
$number = $merchant[$field] - $num;
$merchant[$field] = $number;
$merchant->save();
}
}

51
app/common/model/merchant/system/merchant/MerchantAdmin.php
View File

@ -11,4 +11,55 @@ use think\Model;
class MerchantAdmin extends Model
{
//
protected $connection = 'shop';
protected $table = 'eb_merchant_admin';
const PASSWORD_TYPE_ADMIN = 1;
const PASSWORD_TYPE_MERCHANT = 2;
const PASSWORD_TYPE_SELF = 3;
/**
* @param $field
* @param $value
* @param int|null $except
* @return bool
*/
public function fieldExists($field, $value, ?int $except = null): bool
{
$query = self::where($field, $value);
if (!is_null($except)) $query->where($this->getPk(), '<>', $except);
return $query->count() > 0;
}
/**
* @param Merchant $merchant
* @param $account
* @param $pwd
* @return BaseDao|Model
* @author xaboy
* @day 2020-04-17
*/
public function createMerchantAccount(Merchant $merchant, $account, $pwd)
{
$pwd = $this->passwordEncode($pwd);
$data = compact('pwd', 'account') + [
'mer_id' => $merchant->mer_id,
'real_name' => $merchant->real_name,
'phone' => $merchant->mer_phone,
'level' => 0
];
return $this->create($data);
}
/**
* @param $password
* @return bool|string
* @author xaboy
* @day 2020-04-17
*/
public function passwordEncode($password)
{
return password_hash($password, PASSWORD_BCRYPT);
}
}

27
app/common/model/merchant/system/merchant/MerchantCategory.php
View File

@ -12,4 +12,31 @@ class MerchantCategory extends Model
{
protected $connection = 'shop';
protected $table = 'eb_merchant_category';
/**
* @param int $id
* @return bool
* @author xaboy
* @day 2020-03-27
*/
public function idIsExists(int $id)
{
return $this->fieldExists($this->getPk(), $id);
}
/**
* @param $field
* @param $value
* @param int|null $except
* @return bool
* @author xaboy
* @day 2020-03-30
*/
public function fieldExists($field, $value, ?int $except = null): bool
{
$query = self::where($field, $value);
if (!is_null($except)) $query->where($this->getPk(), '<>', $except);
return $query->count() > 0;
}
}

147
app/common/model/merchant/system/merchant/MerchantIntention.php
View File

@ -12,6 +12,8 @@ namespace app\common\model\merchant\system\merchant;
use app\common\model\merchant\system\merchant\MerchantCategory;
use think\Model;
use think\facade\Db;
use think\exception\ValidateException;
/**
* @mixin \think\Model
@ -38,7 +40,6 @@ class MerchantIntention extends Model
public function GetList(array $where, $page, $limit)
{
$query = self::search($where);
$count = $query->count();
$list = $query->page($page, $limit)->order('create_time DESC , status ASC')->with(['merchantCategory', 'merchantType'])->select();
@ -91,6 +92,17 @@ class MerchantIntention extends Model
return $query;
}
/**
* 修改审核状态
*/
public function getStatusAttr($value)
{
$status = [0=>'待审核', 1=>'审核已通过',2=>'审核未通过'];
return $status[$value];
}
public function Edit($id, $data)
{
$rows = self::where('mer_intention_id',$id)->update($data);
@ -102,10 +114,141 @@ class MerchantIntention extends Model
$this->getModel()::getDB()->where($this->getPk(), $id)->update(['status' => $data['status'], 'mark' => $data['mark']]);
}
/**
* 数据是否存在
*/
public function GetWhereCount($mer_intention_id)
{
$count = self::where(['mer_intention_id' => $mer_intention_id, 'is_del' => 0])->fetchSql()->count();
$count = self::where(['mer_intention_id' => $mer_intention_id, 'is_del' => 0])->count();
return $count;
}
/**
* 审核
* TODO: 未完全
*/
public function updateStatus($id, $data)
{
$create = $data['create_mer'] == 1;
unset($data['create_mer']);
$intention = $this->search(['mer_intention_id' => $id])->find();
// $smsData = [];
if (!$intention)
throw new ValidateException('信息不存在');
if ($intention->status)
throw new ValidateException('状态有误,修改失败');
//TODO: 此处需开发为可配置字段
$config = systemConfig(['broadcast_room_type', 'broadcast_goods_type']);
$margin = app()->make(MerchantType::class)->get($intention['mer_type_id']);
$data['is_margin'] = $margin['is_margin'] ?? -1;
$data['margin'] = $margin['margin'] ?? 0;
$merData = [];
if ($create) {
$password = substr($intention['phone'], -6);
$merData = [
'mer_name' => $intention['mer_name'],
'mer_phone' => $intention['phone'],
'mer_account' => $intention['phone'],
'category_id' => $intention['merchant_category_id'],
'type_id' => $intention['mer_type_id'],
'real_name' => $intention['name'],
'status' => 1,
'is_audit' => 1,
'is_bro_room' => $config['broadcast_room_type'] == 1 ? 0 : 1,
'is_bro_goods' => $config['broadcast_goods_type'] == 1 ? 0 : 1,
'mer_password' => $password,
'is_margin' => $margin['is_margin'] ?? -1,
'margin' => $margin['margin'] ?? 0,
'area_id' => $intention['area_id'] ?? 0,
'geo_street' => $intention['street_id'] ?? 0,
'village_id' => $intention['village_id'] ?? 0,
'is_nmsc' => $intention['is_nmsc'] ?? 0,
];
if ($data['status'] == 1) {
$data['fail_msg'] = '';
$smsData = [
'date' => date('m月d日', strtotime($intention->create_time)),
'mer' => $intention['mer_name'],
'phone' => $intention['phone'],
'pwd' => $password ?? '',
// 'site_name' => systemConfig('site_name'),
];
}
}
if ($data['status'] == 2) {
$smsData = [
'phone' => $intention['phone'],
'date' => date('m月d日', strtotime($intention->create_time)),
'mer' => $intention['mer_name'],
// 'site' => systemConfig('site_name'),
];
}
self::transaction(function () use ($config, $intention, $data, $create,$margin,$merData,$smsData) {
if ($data['status'] == 1) {
if ($create) {
$merchant = app()->make(Merchant::class)->createMerchant($merData);
$data['mer_id'] = $merchant->mer_id;
// 暂不开通通知
// Queue::push(SendSmsJob::class, ['tempId' => 'APPLY_MER_SUCCESS', 'id' => $smsData]);
}
} else {
// Queue::push(SendSmsJob::class, ['tempId' => 'APPLY_MER_FAIL', 'id' => $smsData]);
}
$intention->save($data);
});
}
protected function isPhone($test)
{
return !preg_match("/^1[3456789]{1}\d{9}$/", $test);
}
/**
* @param array $data
* @author xaboy
* @day 2020-04-17
*/
protected function createMerchant(array $data)
{
if ($this->fieldExists('mer_name', $data['mer_name']))
throw new ValidateException('商户名已存在');
if ($data['mer_phone'] && self::isPhone($data['mer_phone']))
throw new ValidateException('请输入正确的手机号');
$merchantCategory = new MerchantCategory;
$merchantAdmin = new MerchantAdmin;
if (!$data['category_id'] || !$merchantCategory->exists($data['category_id']))
throw new ValidateException('商户分类不存在');
if ($merchantAdmin->fieldExists('account', $data['mer_account']))
throw new ValidateException('账号已存在');
/** @var MerchantAdmin $make */
$make = new MerchantCategory;
$margin = (new MerchantType)->get($data['type_id']);
$data['is_margin'] = $margin['is_margin'] ?? -1;
$data['margin'] = $margin['margin'] ?? 0;
return Db::transaction(function () use ($data, $make) {
$account = $data['mer_account'];
$password = $data['mer_password'];
unset($data['mer_account'], $data['mer_password']);
$merchant = $this->dao->create($data);
$make->createMerchantAccount($merchant, $account, $password);
$address_id = Db::name('merchant_address')->insertGetId(['mer_id'=>$merchant->mer_id,'street_id'=>$data['geo_street']]);
if($data['area_id'] && $data['village_id']){
Db::name('merchant_address')->where('id',$address_id)->update(['area_id'=>$data['area_id'],'village_id'=>$data['village_id']]);
}
app()->make(ShippingTemplateRepository::class)->createDefault($merchant->mer_id);
app()->make(ProductCopyRepository::class)->defaulCopyNum($merchant->mer_id);
return $merchant;
});
}
}