<?php
/**
* ES初始化类 创建映射
* Created by PhpStorm.
* User: wxj
* Date: 2019/11/8
* Time: 14:47
*/
namespace Jindouyun\Controller\Common;
use Mall\Framework\Core\Config;
use Mall\Framework\Core\ErrorCode;
use Mall\Framework\Factory;
use Mall\Framework\Core\Request;
class ESInit
{
private $request;
public function __construct()
{
$this->request = Request::getInstance();
}
public function search($s = 0)
{
if ($s) {
$c = intval($s);
} else {
$data = Request::params();
$c = $data['b'] ?: 1;
}
switch ($c) {
//添加商品索引库
case 1:
$mappings = array(
'mappings' => array(
"_default_" => [
"properties" => [
'basicGoodsId' => ["type" => "integer"],//关联商品基本资料id,
'id' => ["type" => "integer"],//商品id,
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'shopId' => ["type" => "integer"],//'商铺id',
'warehouseId' => ["type" => "integer"],//'仓库id',
'images' => [
'type' => 'text'
],
'serviceInfo' => ["type" => "integer"],//'服务保证',
'salesNum' => [
"properties" => [
"skuId" => ["type" => "integer",],
"salesNum" => ["type" => "integer",],
]
],//销量
'content' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//'商品详情',
'extend' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],// '扩展字段',
'sort' => ["type" => "integer"],//'排序',
'isRecommend' => ["type" => "integer"],//是否推荐(5是 4否)',
'deleteStatus' => ["type" => "integer"],//删除状态(5未删除 4已删除)',
'enableStatus' => ["type" => "integer"],//上下架(5上架 4下架)',
'createTime' => [
'type' => 'integer',
],//'创建时间'
'updateTime' => [
'type' => 'integer',
],//'修改时间',
]
]
)
);
$searchServer = Factory::search('goods_search');
$result = $searchServer->createBase('online_goods_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_goods_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除商品索引库
case 2:
$searchServer = Factory::search('goods_search');
$searchServer->setIndex('online_goods_search');
$a = $searchServer->deleteBase('online_goods_search');
print_r($a);
break;
//添加客户索引库
case 3:
$mappings = array(
'mappings' => array(
"_default_" => [
"properties" => [
'id' => ['type' => 'integer'],//customerId,
'userCenterId' => ['type' => 'integer'],//userCenterId,
'mobile' => ['type' => 'keyword'],
'source' => ['type' => 'integer'],//客户来源
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'status' => ['type' => 'integer'],//'账号状态（1已审核 2待审核）',
'statusName' => ['type' => 'keyword'],//状态名称,
'name' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//'客户名称',
'code' => ['type' => 'keyword'],//'客户编码',
'type' => ['type' => 'integer'],//'客户类型',
'provinceCode' => ['type' => 'keyword'],//varchar(20) NOT NULL COMMENT '客户地址省编码',
'cityCode' => ['type' => 'keyword'],//varchar(20) NOT NULL COMMENT '客户地址市编码',
'districtCode' => ['type' => 'keyword'],//varchar(20) NOT NULL COMMENT '客户地址区编码',
'provinceName' => ['type' => 'keyword'],//省名称
'cityName' => ['type' => 'keyword'],//市名称
'districtName' => ['type' => 'keyword'],//区名称
"address" => [
"type" => "text",
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],
'managerMobile' => ['type' => 'keyword'],//'负责人电话',
'shopId' => ['type' => 'integer'],//商铺id,
'shopName' => ['type' => 'keyword'],//商铺名称,
'departmentId' => ['type' => 'integer'],//销售部Id,
'departmentName' => ['type' => 'keyword'],//部门名称,
'salesManId' => ['type' => 'integer'],//int(10) DEFAULT NULL COMMENT '业务员id',
'salesManCode' => ['type' => 'keyword'],//'业务员编码',
'salesManName' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//'业务员名称',
'birthday' => [
'type' => 'integer'
],//'客户生日',
'enableStatus' => ['type' => 'integer'],//'启用状态(5启用 4禁用)',
'deleteStatus' => ['type' => 'integer'],//'删除状态(5未删除 4已删除)',
'createTime' => ['type' => 'integer'],//'创建时间'
'updateTime' => ['type' => 'integer'],//'修改时间',
'extend' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],// '扩展字段',
'tag' => [// '客户标签',
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],
'remark' => [
"type" => "text",
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word",
],// '备注'
'location' => [
"type" => "geo_point",
],//经纬度
'contact' => [
"properties" => [
"name" => ["type" => "keyword",],
"mobile" => ["type" => "keyword",],
]
],// '联系人'
]
]
)
);
$searchServer = Factory::search('customer_search');
$result = $searchServer->createBase('online_customer_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_customer_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除客户索引库
case 4:
$searchServer = Factory::search('customer_search');
$searchServer->setIndex('online_customer_search');
$a = $searchServer->deleteBase('online_customer_search');
print_r($a);
break;
//添加商品基本资料
case 5:
//创建映射
$mappings = array(
"settings" => [
"analysis" => [
"analyzer" => [
"comma"=>[
"type" => "pattern",
"pattern" => ","
]
]
]
],
'mappings' => array(
"_default_" => [
"properties" => [
'id' => ["type" => "integer"],//商品基本资料id,
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'images' => ['type' => 'text'],
'title' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//商品名称,
'code' => ["type" => "keyword"],
'barCode' => ["type" => "keyword"],
'categoryId' => ["type" => "integer"],//'商品分类id',
'expireTime' => ["type" => "integer"],//'过期时间',
'brandId' => ["type" => "integer"],//'品牌id',
'tag' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//'关键词',
'description' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//'商品详情',
'noSalesShop' => ['type' => 'text'],//'禁止销售店铺',
'extends' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//'拓展字段',
'enableStatus' => ["type" => "integer"],//'商品状态 默认5 上线 6下线',
'deleteStatus' => ["type" => "integer"],//'是否删除 4 删除 5正常',
'createTime' => [
'type' => 'integer',
],//'创建时间'
'updateTime' => [
'type' => 'integer',
],//'修改时间',
'categoryPath' => [
"type" => "text",
"analyzer" => "comma",
"search_analyzer" => "comma"
],//'分类路径',
'skuData' => [
"properties" => [
"masterUnit" => [
"properties" => [
"id" => ["type" => "integer",],
"unitName" => ["type" => "keyword",],
"unitId" => ["type" => "integer",],
"isMaster" => ["type" => "integer",],
"deleteStatus" => ["type" => "integer",],
]
],
"branchUnit" => [
"properties" => [
"id" => ["type" => "integer",],
"unitName" => ["type" => "keyword",],
"unitId" => ["type" => "integer",],
"isMaster" => ["type" => "integer",],
"deleteStatus" => ["type" => "integer",],
]
]
]
],//sku
],
]
)
);
$searchServer = Factory::search('goods_basic_search');
$result = $searchServer->createBase('goods_basic_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_goods_basic_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除商品基本资料索引库
case 6:
$searchServer = Factory::search('goods_basic_search');
$searchServer->setIndex('goods_basic_search');
$a = $searchServer->deleteBase('online_goods_basic_search');
print_r($a);
break;
//创建订单索引库
case 7:
$mappings = array(
'mappings' => array(
"order" => [
"properties" => [
/*订单表信息*/
'id' => ["type" => "integer"],//订单id,
'no' => ["type" => "keyword"],//订单编号,
'outerTradeNo' => ['type' => 'keyword'],//'外部流水号(支付宝/微信返回的流水号)'
'shopId' => ['type' => 'integer'],//商铺id
'userCenterId' => ['type' => 'integer'],//用户id
'enterpriseId' => ['type' => 'integer'],//企业id
'customerType' => ['type' => 'integer'],//客户类型
'totalMoney' => [
'type' => 'scaled_float',
'scaling_factor' => 100
],//'总金额',
'payAmount' => [
'type' => 'scaled_float',
'scaling_factor' => 100
],//实付金额
'buyTotal' => ["type" => "integer"],//购买总数
'customerName' => ["type" => "keyword"],//客户姓名
'customerId' => ["type" => "integer"],//客户id
'payStatus' => ["type" => "integer"],//'支付状态 默认1 未支付 2已支付'
'orderStatus' => ["type" => "integer"],//订单状态 默认1 创建 2待支付 3代发货 4待收货 5已完成 6已关闭
'payType' => ["type" => "integer"],//'支付方式 1微信 2支付宝 3货到付款 4上门自提'
'deliveryType' => ["type" => "integer"],//'配送方式 1商品配送 2上门自提'
'source' => ["type" => "integer"],//订单来源 默认1 ios 2android 3小程序 4后台创建
'remark' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//订单备注
'auditStatus' => ["type" => "integer"],// '审核状态 默认1 待审 2审核通过 3 审核未通过 4 审核中'
'payTime' => [
'type' => 'integer',
/**/
],//'付款时间'
'createTime' => [
'type' => 'integer',
],//'创建时间'
'updateTime' => [
'type' => 'integer',
],//'修改时间',
'salesManId' => ["type" => "integer"],//业务员id
'salesManName' => ["type" => "keyword"],//业务员名称
/*收货人信息*/
'realName' => ["type" => "keyword"],//收货人姓名
'mobile' => ["type" => "keyword"],//收货人电话
'address' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//收货详细地址
'provinceCode' => ["type" => "integer"],//收货人省份编码
'cityCode' => ["type" => "integer"],//收货人城市编码
'districtCode' => ["type" => "integer"],//收货人区编码
'goodsName' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],
]
]
)
);
$searchServer = Factory::search('order_search');
$result = $searchServer->createBase('online_order_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_order_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除订单索引库
case 8:
$searchServer = Factory::search('order_search');
$searchServer->setIndex('online_order_search');
$a = $searchServer->deleteBase('online_order_search');
print_r($a);
break;
//添加商铺索引库
case 9:
//创建映射
$mappings = array(
"settings" => [
"analysis" => [
"analyzer" => [
"comma"=>[
"type" => "pattern",
"pattern" => ","
]
]
]
],
'mappings' => array(
"_default_" => [
"properties" => [
'id' => ["type" => "integer"],//商铺id,
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'name' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],//商铺名称,
'logo' => ['type' => 'text'],//商铺logo,
'shopCode' => ['type' => 'text'],//商铺仓库编码,
'shopType' => ['type' => 'integer'],//商铺类型,
'openTime' => [
"properties" => [
"start" => ["type" => "text",],
"end" => ["type" => "text",],
"isAllDay" => ["type" => "integer",],
]
],//营业时间
'contactName' => ['type' => 'keyword'],//联系人,
'mobile' => ['type' => 'keyword'],//联系电话,
'deleteStatus' => ["type" => "integer"],//删除状态(5未删除 4已删除)',
'enableStatus' => ["type" => "integer"],//启用状态(4未启用 5已启用)
'createTime' => [
'type' => 'integer',
],//'创建时间'
'updateTime' => [
'type' => 'integer',
],//'修改时间',
'provinceCode' => ['type' => 'keyword'],//varchar(20) NOT NULL COMMENT '商铺地址省编码',
'cityCode' => ['type' => 'keyword'],//varchar(20) NOT NULL COMMENT '商铺地址市编码',
'districtCode' => ['type' => 'keyword'],//varchar(20) NOT NULL COMMENT '商铺地址区编码',
'provinceName' => ['type' => 'keyword'],//商铺省名称
'cityName' => ['type' => 'keyword'],//商铺市名称
'districtName' => ['type' => 'keyword'],//商铺区名称
"address" => [
"type" => "text",
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],
'location' => [
"type" => "geo_point",
],//经纬度
'salesArea' => [
"type" => "text",
"analyzer" => "comma",
"search_analyzer" => "comma"
],//'销售区域',
],
]
)
);
$searchServer = Factory::search('shop_search');
$result = $searchServer->createBase('online_shop_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_shop_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除商铺索引库
case 10:
$searchServer = Factory::search('shop_search');
$searchServer->setIndex('online_shop_search');
$a = $searchServer->deleteBase('online_shop_search');
print_r($a);
break;
//添加登录日志索引库
case 11:
//创建映射
$mappings = array(
'mappings' => array(
"_default_" => [
"properties" => [
'id' => ["type" => "integer"],
'userCenterId' => ['type' => 'integer'],
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'mobile' => ['type' => 'keyword'],//联系电话,
'createTime' => [
'type' => 'integer',
],//'创建时间'
'source' => [
'type' => 'keyword',
],
'actionType' => [
'type' => 'keyword',
]
]
]
)
);
$searchServer = Factory::search('login_log');
$result = $searchServer->createBase('online_login_log', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_login_log init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除登录日志
case 12:
$searchServer = Factory::search('login_log');
$searchServer->setIndex('online_login_log');
$a = $searchServer->deleteBase('online_login_log');
print_r($a);
break;
//添加日志索引库
case 13:
//创建映射
$mappings = array(
'mappings' => array(
"_default_" => [
"properties" => [
'id' => ["type" => "integer"],
'userCenterId' => ['type' => 'integer'],
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'createTime' => [
'type' => 'integer',
],//'创建时间'
'no' => [
'type' => 'text',
"analyzer" => "ik_max_word",
"search_analyzer" => "ik_max_word"
],
'actionType' => [
'type' => 'keyword',
]
]
]
)
);
$searchServer = Factory::search('logs');
$result = $searchServer->createBase('online_logs', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_logs init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除日志
case 14:
$searchServer = Factory::search('logs');
$searchServer->setIndex('online_logs');
$a = $searchServer->deleteBase('online_logs');
print_r($a);
break;
//入库列表
case 15:
$mappings = array(
'mappings' => array(
"inventory_in" => [
"properties" => [
//入库表信息
'id' => ["type" => "integer"],//入库id
'no' => ["type" => "keyword"],//入库编号
'sourceNo' => ['type' => 'keyword'],//来源单号
'materielNum' => ['type' => 'integer'],//商品数量
'amount' => ['type' => 'scaled_float', 'scaling_factor' => 100],//总金额
'warehouseId' => ['type' => 'integer'],//仓库id
'warehouseName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//仓库名称
'operatorId' => ['type' => 'integer'],//操作人id
'operatorName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//操作人name
'auditId' => ['type' => 'integer'],//审核人id
'auditName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"], //审核人name
'remark' => ['type' => 'text'],//备注
'deleteStatus' => ['type' => 'integer'],//删除状态
'source' => ['type' => 'integer'],//来源
'type' => ['type' => 'integer'],
'auditStatus' => ['type' => 'integer'],//审核状态
'auditTime' => ['type' => 'integer'],//审核日期
'createTime' => ['type' => 'integer'],//创建时间
'updateTime' => ['type' => 'integer'],//更新时间
],
]
)
);
$searchServer = Factory::search('inventory_in_search');
$result = $searchServer->createBase('online_inventory_in_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_inventory_in_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除入库
case 16:
$searchServer = Factory::search('inventory_in_search');
$searchServer->setIndex('online_inventory_in_search');
$a = $searchServer->deleteBase('online_inventory_in_search');
print_r($a);
break;
//出库列表
case 17:
$mappings = array(
'mappings' => array(
"inventory_out" => [
"properties" => [
//入库表信息
'id' => ["type" => "integer"],//入库id
'no' => ["type" => "keyword"],//入库编号
'sourceNo' => ['type' => 'keyword'],//来源单号
'materielNum' => ['type' => 'integer'],//商品数量
'amount' => ['type' => 'scaled_float', 'scaling_factor' => 100],//总金额
'warehouseId' => ['type' => 'integer'],//仓库id
'warehouseName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//仓库名称
'operatorId' => ['type' => 'integer'],//操作人id
'operatorName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//操作人name
'auditId' => ['type' => 'integer'],//审核人id
'auditName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"], //审核人name
'customerId' => ['type' => 'integer'],
'customerName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'customerCode' => ['type' => 'text'],
'customerMobile' => ['type' => 'keyword'],
'remark' => ['type' => 'text'],//备注
'deleteStatus' => ['type' => 'integer'],//删除状态
'source' => ['type' => 'integer'],//来源
'type' => ['type' => 'integer'],
'auditStatus' => ['type' => 'integer'],//审核状态
'auditTime' => ['type' => 'integer'],//审核日期
'createTime' => ['type' => 'integer'],//创建时间
'updateTime' => ['type' => 'integer'],//更新时间
]
]
)
);
$searchServer = Factory::search('inventory_out_search');
$result = $searchServer->createBase('online_inventory_out_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_inventory_out_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除出库
case 18:
$searchServer = Factory::search('inventory_out_search');
$searchServer->setIndex('online_inventory_out_search');
$a = $searchServer->deleteBase('online_inventory_out_search');
print_r($a);
break;
//商品调价单
case 19:
$mappings = array(
'mappings' => array(
"priceAdjustmentSheet" => [
"properties" => [
/*订单表信息*/
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'id' => ["type" => "integer"],//自增id,
'no' => ["type" => "keyword"],//调价单号,
'goodsCode' => ['type' => 'keyword'],//商品编号
'goodsName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//商品名称
'goodsId' => ['type' => 'integer'],//商品id
'saleType' => ['type' => 'integer'],//销售类型 1实物销售 2虚库销售
'salePriceAreaType' => ['type' => 'integer'],//销售价格生效区域类型 1全国统一价 2大区价
'salePriceType' => ['type' => 'integer'],//销售价格类型 1销售价格 2秒杀活动价
'shopId' => ['type' => 'integer'],//店铺id
'shopName' => ['type' => 'keyword'],//店铺名称
'cargoOwnerCode' => ['type' => 'keyword'],//货主编码
'createUserId' => ['type' => 'integer'],//创建人id
'createUserName' => ['type' => 'keyword'],//创建人姓名
'effectiveUserName' => ['type' => 'keyword'],//生效人姓名
'effectiveUserId' => ['type' => 'integer'],//生效人id
'deleteStatus' => ['type' => 'integer'],//删除状态 4删除 5正常
'effectiveStatus' => ['type' => 'integer'],//生效状态 1.待审 2审核通过 3未通过 4审核中
'createTime' => ['type' => 'integer',],//创建时间
'updateTime' => ['type' => 'integer',],//修改时间
'salePrice' => [
"properties" => [
]
],//销售价格
]
]
)
);
$searchServer = Factory::search('priceAdjustmentSheet_search');
$result = $searchServer->createBase('online_priceadjustmentsheet_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_priceadjustmentsheet_search init done.';
} else {
print_r($result['error']);
return false;
}
break;
//删除商品调价单
case 20:
$searchServer = Factory::search('priceAdjustmentSheet_search');
$searchServer->setIndex('online_priceadjustmentsheet_search');
$a = $searchServer->deleteBase('online_priceadjustmentsheet_search');
print_r($a);
break;
//调拨列表
case 21:
$mappings = array(
'mappings' => array(
"allocate" => [
"properties" => [
//入库表信息
'id' => ["type" => "integer"],//入库id
'no' => ["type" => "keyword"],//入库编号
'warehouseId' => ['type' => 'integer'],//仓库id
'inWarehouseId' => ['type' => 'integer'],//in仓库id
'warehouseName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//仓库名称
'operatorId' => ['type' => 'integer'],//操作人id
'operatorName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//操作人name
'auditId' => ['type' => 'integer'],//审核人id
'auditName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"], //审核人name
'remark' => ['type' => 'text'],//备注
'deleteStatus' => ['type' => 'integer'],//删除状态
'auditStatus' => ['type' => 'integer'],//审核状态
'auditTime' => ['type' => 'integer'],//审核日期
'createTime' => ['type' => 'integer'],//创建时间
'updateTime' => ['type' => 'integer'],//更新时间
'linkId' => ["type" => "integer"],
'materielId' => ["type" => "integer"],
'materielName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'materielCode' => ["type" => "text"],
'skuId' => ["type" => "integer"],
'num' => ["type" => "double"],
'costUnitPrice' => ["type" => "double"],
'batch' => ["type" => "object"],
]
]
)
);
$searchServer = Factory::search('allocate_search');
$result = $searchServer->createBase('dev_allocate_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'dev_allocate_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//调拨删除
case 22:
$searchServer = Factory::search('allocate_search');
$searchServer->setIndex('dev_allocate_search');
$a = $searchServer->deleteBase('dev_allocate_search');
print_r($a);
break;
//盘点
case 23:
$mappings = array(
'mappings' => array(
"stocktaking" => [
"properties" => [
'id' => ["type" => "integer"],
'no' => ["type" => "keyword"],
'warehouseId' => ['type' => 'integer'],
'operatorId' => ['type' => 'integer'],
'operatorName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'auditId' => ['type' => 'integer'],
'auditName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'remark' => ['type' => 'text'],
'deleteStatus' => ['type' => 'integer'],
'stocktakingTime' => ['type' => 'integer'],
'saleOutTime' => ['type' => 'integer'],
'createTime' => ['type' => 'integer'],
'updateTime' => ['type' => 'integer'],
'auditStatus' => ["type" => "integer"],
'auditTime' => ["type" => "integer"],
]
]
)
);
$searchServer = Factory::search('stocktaking_search');
$result = $searchServer->createBase('dev_stocktaking_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'dev_stocktaking_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//盘点删除
case 24:
$searchServer = Factory::search('stocktaking_search');
$searchServer->setIndex('dev_stocktaking_search');
$a = $searchServer->deleteBase('dev_stocktaking_search');
print_r($a);
break;
//库存流水
case 25:
$mappings = array(
'mappings' => array(
"inventory_details" => [
"properties" => [
'id' => ["type" => "integer"],
'sourceNo' => ["type" => "keyword"],
'warehouseId' => ['type' => 'integer'],
'materielId' => ['type' => 'integer'],
'materielName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'operatorId' => ['type' => 'integer'],
'operatorName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'inventoryNum' => ['type' => 'double'],
'inventoryChangeNum' => ['type' => 'double'],
'skuId' => ['type' => 'integer'],
'source' => ['type' => 'integer'],
'batch' => ['type' => 'object'],
'costType' => ['type' => 'integer'],
'averageCost' => ['type' => 'double'],
'batchCost' => ['type' => 'double'],
'actionType' => ["type" => "integer"],
'createTime' => ['type' => 'integer'],
'updateTime' => ['type' => 'integer'],
]
]
)
);
$searchServer = Factory::search('inventory_details_search');
$result = $searchServer->createBase('online_inventory_details_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_inventory_details_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//库存流水删除
case 26:
$searchServer = Factory::search('inventory_details_search');
$searchServer->setIndex('online_inventory_details_search');
$a = $searchServer->deleteBase('online_inventory_details_search');
print_r($a);
break;
//客户调价单
case 27:
$mappings = array(
'mappings' => array(
"customerPriceAdjustmentSheet" => [
"properties" => [
/*订单表信息*/
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'id' => ["type" => "integer"],//自增id,
'no' => ["type" => "keyword"],//调价单号,
'goodsCode' => ['type' => 'keyword'],//商品编号
'goodsName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//商品名称
'goodsId' => ['type' => 'integer'],//商品id
'shopId' => ['type' => 'integer'],//店铺id
'shopName' => ['type' => 'keyword'],//店铺名称
'createUserId' => ['type' => 'integer'],//创建人id
'createUserName' => ['type' => 'keyword'],//创建人姓名
'effectiveUserName' => ['type' => 'keyword'],//生效人姓名
'effectiveUserId' => ['type' => 'integer'],//生效人id
'deleteStatus' => ['type' => 'integer'],//删除状态 4删除 5正常
'effectiveStatus' => ['type' => 'integer'],//生效状态 1.待审 2审核通过 3未通过 4审核中
'createTime' => ['type' => 'integer'],//创建时间
'updateTime' => ['type' => 'integer'],//修改时间
'customerId' => ['type' => 'integer'],//客户id
'customerName' => ['type' => 'keyword'],//客户名称
'customerCode' => ['type' => 'keyword'],//客户编码
'salePrice' => [
"properties" => [
]
],//销售价格
]
]
)
);
$searchServer = Factory::search('customerPriceAdjustmentSheet_search');
$result = $searchServer->createBase('online_customer_price_adjustment_sheet_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_customer_price_adjustment_sheet_search init done.';
} else {
print_r($result['error']);
return false;
}
break;
//客户调价单删除
case 28:
$searchServer = Factory::search('customerPriceAdjustmentSheet_search');
$searchServer->setIndex('online_customer_price_adjustment_sheet_search');
$a = $searchServer->deleteBase('dev_customer_price_adjustment_sheet_search');
print_r($a);
break;
//销售退货
case 29:
$mappings = array(
'mappings' => array(
"order_out" => [
"properties" => [
'id' => ["type" => "integer"],
'no' => ["type" => "keyword"],
'sourceId' => ["type" => "integer"],
'sourceNo' => ["type" => "keyword"],
'shopId' => ['type' => 'integer'],
'operatorId' => ['type' => 'integer'],
'operatorName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'auditId' => ['type' => 'integer'],
'auditName' => ['type' => 'text'],
'remark' => ['type' => 'text'],
'auditTime' => ['type' => 'integer'],
'auditStatus' => ['type' => 'integer'],
'deleteStatus' => ['type' => 'integer'],
'linkId' => ['type' => 'integer'],
'goodsId' => ['type' => 'integer'],
'goodsName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'goodsCode' => ['type' => 'text'],
'goodsBasicId' => ['type' => 'integer'],
'skuId' => ['type' => 'integer'],
'num' => ['type' => 'double'],
'costUnitPrice' => ['type' => 'double'],
'createTime' => ['type' => 'integer'],
'updateTime' => ['type' => 'integer'],
]
]
)
);
$searchServer = Factory::search('order_out_search');
$result = $searchServer->createBase('online_order_out_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_order_out_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//销售退货删除
case 30:
$searchServer = Factory::search('order_out_search');
$searchServer->setIndex('online_order_out_search');
$a = $searchServer->deleteBase('online_order_out_search');
print_r($a);
break;
//采购明细
case 31:
$mappings = array(
'mappings' => array(
"purchase_details" => [
"properties" => [
'id' => ["type" => "integer"],
'no' => ["type" => "keyword"],
'shopId' => ["type" => "integer"],
'shopName' => ["type" => "text", "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'supplierId' => ['type' => 'integer'],
'supplierName' => ['type' => 'text'],
'buyerId' => ['type' => 'integer'],
'buyerName' => ['type' => 'text'],
'remark' => ['type' => 'text'],
'operatorId' => ['type' => 'integer'],
'operatorName' => ['type' => 'text'],
'auditId' => ['type' => 'integer'],
'auditName' => ['type' => 'text'],
'auditTime' => ['type' => 'integer'],
'auditStatus' => ['type' => 'integer'],
'deleteStatus' => ['type' => 'integer'],
'createTime' => ['type' => 'integer'],
'updateTime' => ['type' => 'integer'],
'linkId' => ['type' => 'integer'],
'goodsId' => ['type' => 'integer'],
'goodsName' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'basicGoodsId' => ['type' => 'integer'],
'skuId' => ['type' => 'integer'],
'categoryId' => ['type' => 'integer'],
'categoryName' => ['type' => 'text'],
'buyerNum' => ['type' => 'double'],
'buyerUnitPrice' => ['type' => 'double'],
'subtotalPrice' => ['type' => 'double'],
]
]
)
);
$searchServer = Factory::search('purchase_details_search');
$result = $searchServer->createBase('online_purchase_details_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_purchase_details_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//采购明细删除
case 32:
$searchServer = Factory::search('purchase_details_search');
$searchServer->setIndex('online_purchase_details_search');
$a = $searchServer->deleteBase('online_purchase_details_search');
print_r($a);
break;
//优惠券
case 33:
$mappings = array(
'mappings' => array(
"coupon" => [
"properties" => [
/*优惠券信息*/
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'id' => ["type" => "integer"],//自增id,
'startTime' => ["type" => "keyword"],//优惠券生效开始时间
'endTime' => ['type' => 'keyword'],//结束时间
'name' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//优惠券名称
'couponType' => ['type' => 'integer'],//优惠券类型
'reducePrice' => ['type' => 'scaled_float', 'scaling_factor' => 100],//满减券-减免金额(面值)
'minPrice' => ['type' => 'scaled_float', 'scaling_factor' => 100],//最低消费金额 0.00不限金额
'remark' => ['type' => 'text'],//使用说明
'grantType' => ['type' => 'integer'],//发放方式(10主动领取 20定向发放 30注册领取 40在线支付赠送)
'totalNum' => ['type' => 'integer'],//发放总数量(-1为不限制)
'allowNum' => ['type' => 'integer'],//每人限制领取数量(-1为不限制)
'customerSourceId' => ['type' => 'text'],//领取范围
'mustCondition' => ['type' => 'scaled_float', 'scaling_factor' => 100],//(40在线支付赠送)-满X金额发放 0.00所有在线支付不限金额可领取这个优惠券
'grantStartTime' => ['type' => 'integer'],//发放开始时间
'grantEndTime' => ['type' => 'integer'],//发放结束时间
'useShop' => ['type' => 'text'],//使用范围
'applyRange' => ['type' => 'integer'],//商品适用范围
'categoryCollect' => ['type' => 'text'],//分类集合
'brandCollect' => ['type' => 'text'],//品牌集合
'receiveNum' => ['type' => 'integer'],//已领取数量
'deleteStatus' => ['type' => 'integer'],//删除状态
'auditStatus' => ['type' => 'integer'],
'createTime' => ['type' => 'integer'],
'updateTime' => ['type' => 'integer'],
]
]
)
);
$searchServer = Factory::search('coupon_search');
$result = $searchServer->createBase('dev_coupon_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'dev_coupon_search init done.';
} else {
print_r($result['error']);
return false;
}
break;
//删除优惠券
case 34:
$searchServer = Factory::search('coupon_search');
$searchServer->setIndex('dev_coupon_search');
$a = $searchServer->deleteBase('dev_coupon_search');
print_r($a);
break;
//优惠券记录
case 35:
$mappings = array(
'mappings' => array(
"user_coupon" => [
"properties" => [
/*优惠券信息*/
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'id' => ["type" => "integer"],//自增id,
'couponId' => ["type" => "integer"],//优惠券id
'name' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//优惠券名称
'remark' => ['type' => 'text'],//使用说明
'couponType' => ['type' => 'integer'],//优惠券类型
'reducePrice' => ['type' => 'scaled_float', 'scaling_factor' => 100],//满减券-减免金额(面值)
'minPrice' => ['type' => 'scaled_float', 'scaling_factor' => 100],//最低消费金额 0.00不限金额
'startTime' => ["type" => "keyword"],//优惠券生效开始时间,
'endTime' => ['type' => 'keyword'],//结束时间
'applyRange' => ['type' => 'integer'],//商品适用范围
'categoryCollect' => ['type' => 'text'],//分类集合
'brandCollect' => ['type' => 'text'],//品牌集合
'isExpire' => ['type' => 'integer'],//是否过期 4未过期 5已过期
'isUse' => ['type' => 'integer'],//是否使用 4未过期 5已过期
'useTime' => ['type' => 'integer'],//使用时间
'userId' => ['type' => 'integer'],//用户id
'customerId' => ['type' => 'integer'],//客户id
'shopId' => ['type' => 'integer'],//店铺id
'useShop' => ['type' => 'text'],//使用范围
'source' => ['type' => 'integer'],//优惠券来源(10主动领取 20定向发放 30注册领取 40在线支付赠送)
'createTime' => ['type' => 'integer'],//创建时间
'updateTime' => ['type' => 'integer'],//更新时间
'orderNo' => ['type' => 'text'],//使用单号
'orderId' => ['type' => 'integer'],//订单id
]
]
)
);
$searchServer = Factory::search('user_coupon_search');
$result = $searchServer->createBase('online_user_coupon_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_user_coupon_search init done.';
} else {
print_r($result['error']);
return false;
}
break;
//删除优惠券记录
case 36:
$searchServer = Factory::search('user_coupon_search');
$searchServer->setIndex('online_user_coupon_search');
$a = $searchServer->deleteBase('online_user_coupon_search');
print_r($a);
break;
//促销活动
case 37:
$mappings = array(
'mappings' => array(
"activity" => [
"properties" => [
/*促销活动信息*/
'enterpriseId' => ['type' => 'integer'],//enterpriseId,
'id' => ["type" => "integer"],//自增id,
'activityType' => ["type" => "integer"],//活动类型
'title' => ['type' => 'text', "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],//名称
'remark' => ['type' => 'text'],//客户沟通
'startTime' => ["type" => "integer"],//活动开始时间,
'endTime' => ['type' => 'integer'],//活动结束时间
'enableStatus' => ["type" => "integer"],
'images' => ["type" => "text"],//活动图
'useShop' => ['type' => 'text'],//使用范围
'customerRange' => ['type' => 'integer'],//客户范围
'customerSourceId' => ['type' => 'text'],//客户id 1,2
'sort' => ['type' => 'integer'],
'describe' => ['type' => 'text'],
'createTime' => ['type' => 'integer'],
'updateTime' => ['type' => 'integer'],
'isEnd' => ['type' => 'integer'],
'deleteStatus' => ['type' => 'integer'],
'auditStatus' => ['type' => 'integer'],
]
]
)
);
$searchServer = Factory::search('activity_search');
$result = $searchServer->createBase('online_activity_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_activity_search init done.';
} else {
print_r($result['error']);
return false;
}
break;
//促销活动删除
case 38:
$searchServer = Factory::search('activity_search');
$searchServer->setIndex('online_activity_search');
$a = $searchServer->deleteBase('online_activity_search');
print_r($a);
break;
//批次
case 39:
$mappings = array(
'mappings' => array(
"inventory_batch" => [
"properties" => [
'id' => ["type" => "integer"],
'enterpriseId' => ['type' => 'integer'],
'warehouseId' => ["type" => "integer"],
'batchNo' => ["type" => "keyword"],
'originId' => ["type" => "integer"],
'originNo' => ["type" => "keyword"],
'sourceNo' => ["type" => "keyword"],
'materielId' => ["type" => "integer"],
'materielCode' => ["type" => "keyword"],
'materielName' => ["type" => "text", "analyzer" => "ik_max_word", "search_analyzer" => "ik_max_word"],
'skuId' => ["type" => "integer"],
'num' => ['type' => 'double'],
'averageCost' => ['type' => 'double'],
'batchCost' => ['type' => 'double'],
'productionData' => ["type" => "integer"],
'batchStatus' => ["type" => "integer"],
'createTime' => ["type" => "integer"],
'updateTime' => ["type" => "integer"],
]
]
)
);
$searchServer = Factory::search('inventory_batch_search');
$result = $searchServer->createBase('online_inventory_batch_search', $mappings);
if ($result && !isset($result['error'])) {
echo 'online_inventory_batch_search init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//批次删除
case 40:
$searchServer = Factory::search('inventory_batch_search');
$searchServer->setIndex('online_inventory_batch_search');
$a = $searchServer->deleteBase('online_inventory_batch_search');
print_r($a);
break;
//添加登录日志索引库
case 41:
//创建映射
$mappings = array(
'mappings' => array(
"_default_" => [
"properties" => [
'id' => ["type" => "integer"],
'name' => ['type' => 'keyword'],//联系电话
]
]
)
);
$searchServer = Factory::search('test');
$result = $searchServer->createBase('test', $mappings);
if ($result && !isset($result['error'])) {
echo 'test init done.';
return true;
} else {
print_r($result['error']);
return false;
}
break;
//删除登录日志
case 42:
$searchServer = Factory::search('test');
$searchServer->setIndex('test');
$a = $searchServer->deleteBase('test');
print_r($a);
break;
}
}
public function initSearch()
{
$num = $this->request->param('request_id');
//$search = [2,4,6,8,10,12];
//$search = [1,3,5,7,9,11];
$search = [$num];
foreach ($search as $s) {
$this->search($s);
}
}
}