Skip to content

G
goods
Commit 14147acc authored by jianghaiming's avatar jianghaiming
Browse files
Options

Merge branch 'develop' of https://gitlab.yidian-inc.com/bp/goods into develop

parents d187a0cf d68298c1
Hide whitespace changes
Inline Side-by-side
Showing with 195 additions and 15 deletions
application/modules/Cli/controllers/GoodsToInit.php
View file @ 14147acc
<?php
use Api\PhpUtils\Common\GoodsSkuId;
use Api\PhpUtils\Http\Request;
use App\Base\Cli;
use App\Exception\custom\GoodsException;
use App\Exception\custom\InterfaceException;
use App\Models\goods\mysql\GoodsSku;
use App\Models\goods\mysql\GoodsSpu;
use \App\Models\tmp\mysql\QyqTicketData;
use \App\Services\goods\GoodsService;
use \App\Services\shop\ShopService;
use \App\Models\shop\mysql\SubShop;
use \App\Models\shop\mysql\Shop;
/**
* 导入老商品数据
......@@ -15,20 +23,16 @@ class GoodsToInitController extends Cli
public function runAction()
{
$total = $this->getDataCount();
$pageSize = 10;
$pageSize = 100;
$pageTotal = floor($total/$pageSize) + 1;
$pageTotal = floor($total / $pageSize) + 1;
for ($i = 0; $i <= $pageTotal; $i++) {
echo $i."\n";
echo $i . "\n";
$list = $this->getDataList($i, $pageSize);
foreach ($list as $item) {
$lifeAccountId = $item["life_account_id"];
$merchantId = $this->getMerchantId($lifeAccountId);
if (empty($merchantId)) {
echo "生活号 ".$lifeAccountId." 没有对应的 merchant_id \n";
continue;
}
}
//处理 shop 数据
$this->dealShopData($list);
//处理商品数据
$this->dealGoodsData($list);
}
}
......@@ -38,7 +42,8 @@ class GoodsToInitController extends Cli
*/
private function getDataCount()
{
return QyqTicketData::count([]);
$where["lifeAccountId[>]"] = 0;
return QyqTicketData::count([], $where);
}
/**
......@@ -50,6 +55,7 @@ class GoodsToInitController extends Cli
private function getDataList($page, $limit)
{
$from = $page * $limit;
$where["lifeAccountId[>]"] = 0;
$where["LIMIT"] = [$from, $limit];
return QyqTicketData::select("*", $where);
}
......@@ -57,9 +63,48 @@ class GoodsToInitController extends Cli
/**
* 脚本第一步，把所有的
*/
private function dealShopData()
private function dealShopData($list)
{
echo "开始处理 shop 数据 \n";
foreach ($list as $item) {
if (empty($item["lifeAccountId"])) {
// echo $item["userId"] . "没有生活号id \n";
continue;
}
$lifeAccountId = $item["lifeAccountId"];
$merchantId = $this->getMerchantId($lifeAccountId);
if (empty($merchantId)) {
// echo "生活号 ".$lifeAccountId." 没有对应的 merchant_id \n";
continue;
}
$lifeAccount = [
"life_account_id" => $lifeAccountId,
"merchant_id" => $merchantId,
];
$shopId = GoodsService::addShop($lifeAccount);
echo "当前正在处理店铺id: $shopId \n";
$subShop = json_decode($item["shopJson"], true);
if (!empty($subShop)) {
foreach ($subShop as $sub) {
$res = ShopService::getIdgenId(substr($shopId, -2), 'goods');
$subShopId = !empty($res[0]) ? $res[0] : '';
$lbs = explode(",", $sub["lbs"]);
$data["sub_shop_id"] = $subShopId;
$data["life_account_id"] = $lifeAccountId;
$data["shop_id"] = $shopId;
$data["shop_name"] = $sub["shopName"];
$data["longitude"] = $lbs[0];
$data["latitude"] = $lbs[1];
$data["address"] = $sub["address"];
$data["phone"] = $sub["phone"];
$this->addSubShop($data);
}
}
}
echo "门店数据处理完成 \n";
}
/**
......@@ -79,4 +124,136 @@ class GoodsToInitController extends Cli
return empty($lifeAccountRes["response"]["result"]["merchant_id"]) ? "" : $lifeAccountRes["response"]["result"]["merchant_id"];
}
/**
* 添加门店数据
* @param $data
*/
private function addSubShop($data)
{
$subShop = SubShop::getRecord(["life_account_id"=>$data["life_account_id"], "shop_name"=>$data["shop_name"]]);
if (empty($subShop)) {
SubShop::save($data);
}
}
private function dealGoodsData($list)
{
echo "开始 goods 数据处理 \n";
foreach ($list as $item) {
if (empty($item["lifeAccountId"])) {
echo $item["userId"] . "没有生活号id \n";
continue;
}
$lifeAccountId = $item["lifeAccountId"];
$merchantId = $this->getMerchantId($lifeAccountId);
if (empty($merchantId)) {
// echo "生活号 ".$lifeAccountId." 没有对应的 merchant_id \n";
continue;
}
$shopInfo = Shop::getRecord(["life_account_id"=>$lifeAccountId]);
$shopId = $shopInfo["shop_id"];
$res = GoodsService::getIdgenId(substr($shopId, -2), "goods", 2);
if (empty($res)) {
throw new GoodsException(['cus' => 2]);
}
$categoryOneId = 1;
$categoryTwoId = 13;
$goodsSpuId = $res[0];
$goodsSkuId = GoodsSkuId::generateGoodSkuId($res[1], $categoryOneId, $categoryTwoId, 1);
$publicUserId = $item["userId"];
$goodsName = $item["title"];
$descPicUrl = "";
if (!empty($item["images"])) {
$images = explode(",", $item["images"]);
foreach ($images as $image) {
$descPicUrl .= "https://qn.zhiyueapp.cn/".$image.",";
}
$descPicUrl = trim($descPicUrl, ",");
}
$desc = $item["desc"];
$introduce = $item["introduce"];
$introducePicUrl = $item["productImages"];
$expirationTime = $item["outDate"];
$ruleLimit = $item["canBuy"];
$ruleDesc = $item["ruleIntroduce"];
$ruleRefund = $item["useRule"];
$ruleDateType = $item["holidayUse"] == 0 ? 2 : 1;
$ruleStartTime = $item["starTime"];
$ruleEndTime = $item["endTime"];
$inventoryTotal = $item["buyCount"];
$inventoryRest = $item["buyCount"];
$totalAmountOrder = $item["sellCount"];
$originalPrice = $item["price"] * 100;
$price = $item["rawPrice"] * 100;
$spuParams = [
"goods_spu_id" => $goodsSpuId,
"shop_id" => $shopId,
"life_account_id" => $lifeAccountId,
"publish_user_id" => $publicUserId,
"goods_name" => $goodsName,
"desc_pic_url" => $descPicUrl,
"desc" => $desc,
"goods_type" => GoodsSpu::TYPE_VIRTUAL,
"goods_sub_type" => GoodsSpu::SUB_TYPE_TO_SHOP,
"goods_sale_type" => GoodsSpu::SALE_TYPE_NO_COMBINATION,
"rule_limit" => $ruleLimit,
"rule_desc" => $ruleDesc,
"rule_refund" => $ruleRefund,
];
GoodsSpu::save($spuParams);
$skuParams = [
"goods_sku_id" => $goodsSkuId,
"goods_spu_id" => $goodsSpuId,
"life_account_id" => $lifeAccountId,
"shop_id" => $shopId,
"publish_user_id" => $publicUserId,
"category_1_id" => $categoryOneId,
"category_2_id" => $categoryTwoId,
"goods_name" => $goodsName,
"desc_pic_url" => $descPicUrl,
"desc" => $desc,
"introduce" => $introduce,
"introduce_pic_url" => $introducePicUrl,
"expiration_time" => $expirationTime,
"rule_limit" => $ruleLimit,
"rule_desc" => $ruleDesc,
"rule_refund" => $ruleRefund,
"rule_date_type" => $ruleDateType,
"rule_start_time" => $ruleStartTime,
"rule_end_time" => $ruleEndTime,
"inventory_total" => $inventoryTotal,
"inventory_rest" => $inventoryRest,
"total_amount_order" => $totalAmountOrder,
"total_amount_sold" => $totalAmountOrder,
"original_price" => $originalPrice,
"price" => $price,
"is_import" => 1,
];
GoodsSku::save($skuParams);
$subShop = json_decode($item["shopJson"], true);
if (!empty($subShop)) {
$subShopIdStr = "";
foreach ($subShop as $sub) {
$subShopId = SubShop::select("sub_shop_id", ["life_account_id"=>$lifeAccountId, "shop_name"=>$sub["shopName"]]);
if (!empty($subShopId)) {
$subShopIdStr .= $subShopId[0].",";
}
}
$subShopIdStr = trim($subShopIdStr, ",");
}
if (!empty($subShopIdStr)) {
GoodsService::addDealSubShopList($subShopIdStr, $shopId, $goodsSkuId);
}
}
echo "完成 goods 数据处理 \n";
}
}
\ No newline at end of file
application/services/goods/GoodsService.php
View file @ 14147acc
......@@ -222,7 +222,7 @@ class GoodsService
* @return mixed
* @throws GoodsException
*/
private static function addShop($lifeAccount)
public static function addShop($lifeAccount)
{
$lifeAccountId = $lifeAccount["life_account_id"];
$shop = Shop::getRecordMaster(['life_account_id' => $lifeAccountId]);
......@@ -251,7 +251,7 @@ class GoodsService
* @param $shopId
* @param $skuId
*/
private static function addDealSubShopList($subShopIdStr, $shopId, $skuId)
public static function addDealSubShopList($subShopIdStr, $shopId, $skuId)
{
if (!empty($subShopIdStr)) {
$subShopIds = explode(",", $subShopIdStr);
......
conf/cli.ini
View file @ 14147acc
......@@ -7,6 +7,9 @@ application.dispatcher.throwException = true
daemon.script_dir = "\\Daemon\\"
appid = "goods"
idgen.partner = "bp"
idgen.key = "5cfdb867e96374c7883b31d6928cc4cb"
[product : common]
[pre : common ]
[test: common ]
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment