|
|
<?php
|
|
|
|
|
|
class BatchController extends ZcController {
|
|
|
/**
|
|
|
* @var ShopService
|
|
|
*/
|
|
|
private $shopService;
|
|
|
/**
|
|
|
* @var MoveService
|
|
|
*/
|
|
|
private $moveService;
|
|
|
/**
|
|
|
* @var ProductService
|
|
|
*/
|
|
|
private $productService;
|
|
|
/**
|
|
|
* @var RsyncProductService
|
|
|
*/
|
|
|
private $rsyncProductService;
|
|
|
/**
|
|
|
* @var MoveImportService
|
|
|
*/
|
|
|
private $moveImportService;
|
|
|
|
|
|
/**
|
|
|
*
|
|
|
* @var CSVParse
|
|
|
*/
|
|
|
private $csvParse;
|
|
|
|
|
|
/**
|
|
|
*
|
|
|
* @var WatermarkService
|
|
|
*/
|
|
|
private $watermarkService;
|
|
|
|
|
|
/**
|
|
|
* @var FeedbackService
|
|
|
*/
|
|
|
private $feedbackService;
|
|
|
|
|
|
/**
|
|
|
* @var ProductUtil
|
|
|
*/
|
|
|
private $productUtil;
|
|
|
/**
|
|
|
* @var MoveUtil
|
|
|
*/
|
|
|
private $moveUtil;
|
|
|
|
|
|
/**
|
|
|
* @var MaterialUtil
|
|
|
*/
|
|
|
private $materialUtil;
|
|
|
/**
|
|
|
* @var TailorImgTool
|
|
|
*/
|
|
|
private $tailorImgTool;
|
|
|
/**
|
|
|
*
|
|
|
* @var PageSpider
|
|
|
*/
|
|
|
private $spider;
|
|
|
|
|
|
/**
|
|
|
*
|
|
|
* @var DsClient
|
|
|
*/
|
|
|
private $dsClient;
|
|
|
|
|
|
/**
|
|
|
* @var LtaoTool
|
|
|
*/
|
|
|
private $ltaoTool;
|
|
|
|
|
|
private $redis;
|
|
|
private $webShop;
|
|
|
private $moveBatchSettingLog;
|
|
|
private $moveBatchUrlLog;
|
|
|
private $timeStatLog;
|
|
|
private $moveBatchSaveTaskLog;
|
|
|
private $moveBatchDebugLog;
|
|
|
private $failRetryMoveTaskLog;
|
|
|
private $moveAgainDetailLog;
|
|
|
private $moveBatchShopLog;
|
|
|
|
|
|
/**
|
|
|
* @var MaterialService
|
|
|
*/
|
|
|
private $materialService;
|
|
|
|
|
|
public function __construct($route) {
|
|
|
parent::__construct($route);
|
|
|
|
|
|
header('Access-Control-Allow-Credentials: true');
|
|
|
header('Access-Control-Allow-Origin: ' . $_SERVER['HTTP_ORIGIN']);
|
|
|
|
|
|
$this->shopService = Zc::singleton(ShopService::class);
|
|
|
$this->moveService = Zc::singleton(MoveService::class);
|
|
|
$this->productService = Zc::singleton(ProductService::class);
|
|
|
$this->rsyncProductService = Zc::singleton(RsyncProductService::class);
|
|
|
$this->watermarkService = Zc::singleton('WatermarkService');
|
|
|
$this->moveImportService = Zc::singleton('MoveImportService');
|
|
|
$this->feedbackService = Zc::singleton(FeedbackService::class);
|
|
|
|
|
|
$this->productUtil = Zc::singleton(ProductUtil::class);
|
|
|
$this->moveUtil = Zc::singleton(MoveUtil::class);
|
|
|
$this->materialUtil = Zc::singleton('MaterialUtil');
|
|
|
$this->spider = new PageSpider(array (), null, $_SERVER['REMOTE_ADDR']);
|
|
|
|
|
|
$this->dsClient = Zc::singleton('DsClient');
|
|
|
$this->webShop = Zc::getWebUser();
|
|
|
$this->moveBatchSettingLog = Zc::getLog('move/batch/setting');
|
|
|
$this->moveBatchUrlLog = Zc::getLog('move/batch/url');
|
|
|
$this->timeStatLog = Zc::getLog('move/batch/time_stat');
|
|
|
$this->moveBatchSaveTaskLog = Zc::getLog('move/batch/saveTask');
|
|
|
$this->moveBatchDebugLog = Zc::getLog('move/batch/debug');
|
|
|
$this->failRetryMoveTaskLog = Zc::getLog('move/batch/fail_retry');
|
|
|
$this->moveAgainDetailLog = Zc::getLog('move/batch/again_detail');
|
|
|
$this->moveBatchShopLog = Zc::getLog('move/batch/shop');
|
|
|
$this->tailorImgTool = new TailorImgTool();
|
|
|
$this->ltaoTool = new LtaoTool();
|
|
|
|
|
|
$this->materialService = Zc::singleton(MaterialService::class);
|
|
|
|
|
|
Zc::import('@.vendor.CSVParse', '', '.php', 'class.');
|
|
|
$this->csvParse = new CSVParse();
|
|
|
$this->redis = RedisExt::factory('bizCache');
|
|
|
}
|
|
|
|
|
|
|
|
|
public function target() {
|
|
|
if (!isset($_SESSION[SessionConst::geoIpArea])) {
|
|
|
$geoInfo = $this->shopService->getGeoIpInfo(CommonTool::clientIp(), false);
|
|
|
if (!empty($geoInfo)) {
|
|
|
$_SESSION[SessionConst::geoIpArea] = $geoInfo;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($_GET['copyType'] == MoveConst::collectFetchBank) {
|
|
|
$this->redirect(Zc::url(RouteConst::moveBatchTarget, array('copyType' => $_GET['copyType']), 'https', Zc::C('fetchBank.domain')));
|
|
|
}
|
|
|
|
|
|
$copyType = in_array($_GET['copyType'], array (
|
|
|
MoveConst::collectLinksCopy,
|
|
|
MoveConst::collectShopCopy,
|
|
|
MoveConst::collectWebsiteCopy,
|
|
|
MoveConst::collectDsCopy,
|
|
|
MoveConst::collectLtaoCopy,
|
|
|
MoveConst::collectSameProduct,
|
|
|
MoveConst::collectClueCopy,
|
|
|
)) ? $_GET['copyType'] : MoveConst::collectLinksCopy;
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$shopName = $_SESSION[SessionConst::shopName];
|
|
|
|
|
|
$moveAdvancedConfig = $this->moveService->getMoveAdvancedConfig($shopId);
|
|
|
|
|
|
$appOrder = $this->shopService->getShopFirstAppOrder($shopId);
|
|
|
$isFetchBank = $this->webShop->getFlash('isFetchBank') ?: $_POST['isFetchBank'];
|
|
|
$categoryOptionArray = $this->productUtil->getCategoryOptionArray($shopId);
|
|
|
|
|
|
$dsHelpArticleList = [];
|
|
|
|
|
|
$dsBuyUrl = $this->moveService->getDsBuyUrl($shopId);
|
|
|
$dsMemberInfo = $this->moveService->getDsMemberInfo($shopId);
|
|
|
$dsMemberName = $dsMemberInfo['cnali_member_name'];
|
|
|
$ruleList = $this->getChoicenessSourceItemTag();
|
|
|
|
|
|
$collectTaskWareIds = $_POST['collectTaskWareIds'] ? json_decode($_POST['collectTaskWareIds'], true) : $this->webShop->getFlash('collectTaskWareIds');
|
|
|
$fetchBankDetailIds = $_POST['fetchBankDetailIds'] ? json_decode($_POST['fetchBankDetailIds'], true) : $this->webShop->getFlash('fetchBankDetailIds');
|
|
|
|
|
|
$this->render(array (
|
|
|
'copyType' => $copyType,
|
|
|
'shopId' => $shopId,
|
|
|
'shopName' => $shopName,
|
|
|
'appOrder' => $appOrder,
|
|
|
'isFetchBank' => $isFetchBank,
|
|
|
'collectTaskWareIds' => $collectTaskWareIds,
|
|
|
'fetchBankDetailIds' => $fetchBankDetailIds,
|
|
|
'moveAdvancedConfig' => $moveAdvancedConfig,
|
|
|
'categoryOptionArray' => $categoryOptionArray,
|
|
|
'alibabaHelpArticleList' => $dsHelpArticleList,
|
|
|
'ltaoAuthInfo' => $ltaoAuthInfo,
|
|
|
'dsBuyUrl' => $dsBuyUrl,
|
|
|
'alibabaMemberName' => $dsMemberName,
|
|
|
'alibabaMemberExpire' => $dsMemberInfo['gmt_expire'],
|
|
|
'folderMenuTree' => $this->materialService->getMaterialFolderMenuTree($shopId),
|
|
|
'ruleList' => $ruleList,
|
|
|
), 'move/batch/target_all');
|
|
|
}
|
|
|
|
|
|
private function getChoicenessSourceItemTag() {
|
|
|
$tagCache = DsClientTool::tryGetChoicenessSourceItemTagByLocal();
|
|
|
if ($tagCache) {
|
|
|
return $tagCache;
|
|
|
}
|
|
|
|
|
|
$getRet = $this->dsClient->getChoicenessSourceItemTag(DsConst::platformDd);
|
|
|
if (CommonTool::isSuccessRet($getRet)) {
|
|
|
DsClientTool::stashChoicenessSourceItemTagToLocal($getRet['data']);
|
|
|
}
|
|
|
|
|
|
return $getRet['data'];
|
|
|
}
|
|
|
|
|
|
public function resetMoveSetting() {
|
|
|
$moveSettingId = !empty($_POST['moveSettingId']) ? (int)$_POST['moveSettingId'] : 0;
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
|
|
|
if (!$moveSettingId || !$shopId) {
|
|
|
return $this->renderJSON(CommonTool::failResult('参数错误'));
|
|
|
}
|
|
|
|
|
|
$newMoveSettingId = $this->moveUtil->resetMoveSetting($moveSettingId, $shopId);
|
|
|
if ($newMoveSettingId) {
|
|
|
$moveSettingList = $this->moveUtil->getInitMoveSettingList($shopId);
|
|
|
$renderData = array(
|
|
|
'moveSettingList' => $moveSettingList,
|
|
|
'moveSettingId' => $newMoveSettingId,
|
|
|
);
|
|
|
return $this->renderJSON(CommonTool::successResult($renderData));
|
|
|
}
|
|
|
return $this->renderJSON(CommonTool::failResult('恢复默认设置失败'));
|
|
|
}
|
|
|
|
|
|
public function getInitDataList() {
|
|
|
header('Access-Control-Allow-Credentials: true');
|
|
|
header('Access-Control-Allow-Origin: ' . $_SERVER['HTTP_ORIGIN']);
|
|
|
|
|
|
$ret = $this->moveUtil->getInitDataList();
|
|
|
return $this->renderJSON($ret);
|
|
|
}
|
|
|
|
|
|
|
|
|
public function getFreightTemplateList() {
|
|
|
$shopId = $_POST['authShopId'] ? $_POST['authShopId'] : $_SESSION[SessionConst::shopId];
|
|
|
$accessToken = $this->shopService->getShopAccessToken($shopId);
|
|
|
$freightTemplateRet = $this->moveService->getFreightTemplateListFromDd($accessToken);
|
|
|
$ret = [
|
|
|
'freightTemplateList' => $freightTemplateRet['freightTemplateList'] ? $freightTemplateRet['freightTemplateList'] : [],
|
|
|
];
|
|
|
$this->renderJSON(CommonTool::successResult($ret));
|
|
|
}
|
|
|
|
|
|
public function getCurrentShopMoveSetting() {
|
|
|
header('Access-Control-Allow-Credentials: true');
|
|
|
header('Access-Control-Allow-Origin: ' . $_SERVER['HTTP_ORIGIN']);
|
|
|
|
|
|
$shopId = $_POST['curShopId'] ? $_POST['curShopId'] : $_SESSION[SessionConst::shopId];
|
|
|
$accessToken = $_SESSION[SessionConst::accessToken];
|
|
|
if (empty($shopId) || empty($accessToken)) {
|
|
|
$this->renderJSON(CommonTool::failResult("获取用户id失败，请联系客服"));
|
|
|
return ;
|
|
|
}
|
|
|
|
|
|
$moveSettingList = $this->moveUtil->getInitMoveSettingList($shopId);
|
|
|
|
|
|
foreach ($moveSettingList as $moveSetting) {
|
|
|
if ($moveSetting['is_config_default'] == 1) {
|
|
|
return $this->renderJSON(CommonTool::successResult('moveSetting', $moveSetting));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$moveSetting = array_shift($moveSettingList);
|
|
|
|
|
|
return $this->renderJSON(CommonTool::successResult('moveSetting', $moveSetting));
|
|
|
}
|
|
|
|
|
|
public function saveMoveBatchConfigFirst() {
|
|
|
header('Access-Control-Allow-Credentials: true');
|
|
|
header('Access-Control-Allow-Origin: ' . $_SERVER['HTTP_ORIGIN']);
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$moveSetting = $_POST['moveSetting'];
|
|
|
|
|
|
$ret = $this->moveUtil->saveMoveBatchConfigFirst($shopId, $moveSetting, $this->moveBatchSettingLog);
|
|
|
return $this->renderJSON($ret);
|
|
|
}
|
|
|
|
|
|
|
|
|
public function fetchAlibabaDetailUrlInfo() {
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
|
|
|
$alibabaMemberId = $this->moveService->getAlibabaMemberId($shopId);
|
|
|
if (empty($alibabaMemberId)) {
|
|
|
$isExistDs = $this->moveService->isExistDs($shopId);
|
|
|
if ($isExistDs) {
|
|
|
return $this->renderJSON(CommonTool::failCodeResult(ErrorCodeConst::expireDsAuth, '抖店和1688授权过期，请重新授权'));
|
|
|
}
|
|
|
|
|
|
return $this->renderJSON(CommonTool::failCodeResult(ErrorCodeConst::noDsAuth, '抖店没有1688主客授权，请授权'));
|
|
|
}
|
|
|
|
|
|
$checkRet = $this->moveUtil->checkAbnormalRequest($shopId);
|
|
|
if (CommonTool::isFailRet($checkRet)) {
|
|
|
return $this->renderJSON($checkRet);
|
|
|
}
|
|
|
|
|
|
$startTime = ZcNumberHelper::microtimeFloat();
|
|
|
$this->moveBatchUrlLog->info('fetchDetailUrlInfo, shopId[' . $_SESSION[SessionConst::shopId] . '], post: ' . print_r($_POST, true));
|
|
|
$detailUrls = $_POST['detailUrls'];
|
|
|
|
|
|
$getProductInfoListRet = $this->getAlibabaProductsInfoListByDetailUrls($detailUrls, $shopId, true);
|
|
|
if (CommonTool::isFailRet($getProductInfoListRet)) {
|
|
|
return $this->renderJSON($getProductInfoListRet);
|
|
|
}
|
|
|
|
|
|
$endTime = ZcNumberHelper::microtimeFloat();
|
|
|
$costTime = bcsub($endTime, $startTime, 3);
|
|
|
$timeStatLogStr = sprintf('searchProductStat | %s | %s | %s', $shopId, count($detailUrls), $costTime);
|
|
|
$this->timeStatLog->info($timeStatLogStr);
|
|
|
|
|
|
$productsInfoList = $getProductInfoListRet['productsInfoList'];
|
|
|
$productList = $this->moveUtil->processProductList($productsInfoList, $shopId, null, $_POST['productClueCatePathMap'] ?: [], $_POST['productClueIdMap'] ?: []);
|
|
|
$productList = $this->moveUtil->attachIsMoved($productList, $shopId);
|
|
|
return $this->renderJSON(CommonTool::successResult(array(
|
|
|
'productList' => $productList,
|
|
|
'sourceItemIds' => array_keys($productList),
|
|
|
'hostname' => gethostname()
|
|
|
)));
|
|
|
}
|
|
|
|
|
|
private function getAlibabaProductsInfoListByDetailUrls($detailUrls, $shopId, $needCheckFree = false) {
|
|
|
$detailUrls = array_map('trim', preg_split("/\\r\\n|\\r|\\n|,|，|;|；/u", $detailUrls));
|
|
|
|
|
|
$ret = $this->buildAlibabaFetchUrlList($shopId, $detailUrls, $needCheckFree);
|
|
|
if (CommonTool::isFailRet($ret)) {
|
|
|
return $ret;
|
|
|
}
|
|
|
$fetchList = $ret['fetchList'];
|
|
|
|
|
|
$productsInfoListRet = $this->moveUtil->fetchProductsList($fetchList, true);
|
|
|
$productsInfoList = $productsInfoListRet['productsInfoList'];
|
|
|
return CommonTool::successResult(array(
|
|
|
'productsInfoList' => $productsInfoList,
|
|
|
));
|
|
|
}
|
|
|
|
|
|
private function buildAlibabaFetchUrlList($shopId, $detailUrls, $needCheckFree = false) {
|
|
|
$uniqueSourceProductArray = array();
|
|
|
$sourceProducts = array();
|
|
|
$fetchList = array();
|
|
|
$fetchSourceList = [];
|
|
|
$aliCount = 0;
|
|
|
$shortUrlToNormalUrlMap = $this->moveUtil->getRealItemUrlFromShortUrl($detailUrls);
|
|
|
|
|
|
foreach ($detailUrls as $url){
|
|
|
//ctype_digit纯数字检测
|
|
|
if(empty($url) || ctype_digit($url)){
|
|
|
continue;
|
|
|
}
|
|
|
$url = $shortUrlToNormalUrlMap[$url] ? : $url;
|
|
|
$sourceProduct = $this->moveUtil->parseDetailUrl($url);
|
|
|
if (!empty($sourceProduct)) {
|
|
|
$productId = $sourceProduct['itemId'];
|
|
|
$source = $sourceProduct['source'];
|
|
|
$site = $sourceProduct['site'];
|
|
|
$isFromMobileLink = $sourceProduct['isFromMobileLink'];
|
|
|
|
|
|
if ($uniqueSourceProductArray[$source.$productId.$site]) {
|
|
|
continue;
|
|
|
}
|
|
|
$uniqueSourceProductArray[$source.$productId.$site] = true;
|
|
|
|
|
|
if ($source == FetchClientConst::collectTaskSource1688) {
|
|
|
$aliCount++;
|
|
|
}
|
|
|
$sourceProducts[] = $sourceProduct;
|
|
|
$fetchSourceList[] = $source;
|
|
|
}
|
|
|
if ($source == FetchClientConst::collectTaskSource1688) {
|
|
|
$fetchUrl = Zc::url(RouteConst::TimerMoveTaskFetchDsItem, array('itemId' => $productId, 'source' => $source, 'site' => $site, 'shopId' => $shopId, 'isFromMobileLink' => $isFromMobileLink, 'moveNeedCollectDetail' => FetchClientTool::moveNeedCollectDetail($source), 'trace' => MoveConst::traceDdmsFetchUrl()), 'http', Zc::C('multi.crawler.domain'));
|
|
|
} else {
|
|
|
$fetchUrl = Zc::url(RouteConst::TimerMoveTaskFetchItem, array('itemId' => $productId, 'source' => $source, 'site' => $site, 'shopId' => $shopId, 'isFromMobileLink' => $isFromMobileLink, 'moveNeedCollectDetail' => FetchClientTool::moveNeedCollectDetail($source), 'trace' => MoveConst::traceDdmsFetchUrl()), 'http', Zc::C('multi.crawler.domain'));
|
|
|
}
|
|
|
|
|
|
$fetchList[$fetchUrl] = array();
|
|
|
}
|
|
|
|
|
|
$ret = $this->moveService->checkPlatformAuthorize($fetchSourceList, [FetchClientConst::collectTaskSource1688]);
|
|
|
if (CommonTool::isFailRet($ret)) {
|
|
|
return $ret;
|
|
|
}
|
|
|
|
|
|
if ($needCheckFree && $aliCount > 50) {
|
|
|
$getVersionRet = $this->shopService->getShopAppVersion($shopId);
|
|
|
$shopVersion = $getVersionRet['appVersion'];
|
|
|
if (AppConst::checkIsFreeVersion($shopVersion)) {
|
|
|
$authCode = $this->shopService->getAuthCodeByShopId($shopId);
|
|
|
$searchRet = $this->dsClient->getDsMemberVersion(DsConst::platformDd, $authCode);
|
|
|
if (CommonTool::isFailRet($searchRet)) {
|
|
|
return $searchRet;
|
|
|
}
|
|
|
$isFree = $searchRet['isFree'];
|
|
|
if ($isFree) {
|
|
|
return CommonTool::failCodeResult(ErrorCodeConst::isDsFreeUserLimit, '每次输入链接最多50条，请减少商品数量后重试或升级高级版');
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$ret = $this->checkProductErrorInfo($sourceProducts, $aliCount);
|
|
|
if (CommonTool::isFailRet($ret)) {
|
|
|
return $ret;
|
|
|
}
|
|
|
|
|
|
return CommonTool::successResult([
|
|
|
'fetchList' => $fetchList,
|
|
|
]);
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private function checkProductErrorInfo($sourceProducts, $aliCount) {
|
|
|
if(empty($sourceProducts)){
|
|
|
return CommonTool::failResult("商品详情页面链接或者ID错误, 请重新输入");
|
|
|
}
|
|
|
if ($aliCount > 200) {
|
|
|
return CommonTool::failCodeResult('overLimit', "1688商品一次最多只支持200个链接，您当前提交了{$aliCount}个商品");
|
|
|
}
|
|
|
if(count($sourceProducts) > 500){
|
|
|
return CommonTool::failCodeResult('overLimit', "最多支持500个商品链接");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
private function checkRequireAttrAndQuality($products, $setting) {
|
|
|
if (!empty($setting['isValidateRequire'])) {
|
|
|
return CommonTool::successResult();
|
|
|
}
|
|
|
|
|
|
$requirePresetAttrNames = MoveConst::getRequirePresetAttrNames();
|
|
|
$requirePresetQualityNames = MoveConst::getRequirePresetQualityNames();
|
|
|
|
|
|
$checkAttrNames = [];
|
|
|
foreach ($requirePresetAttrNames as $attrName) {
|
|
|
$isset = false;
|
|
|
foreach ((array)$setting['preset_attrs'] as $presetAttr) {
|
|
|
if (($attrName == $presetAttr['presetAttrName']) && $presetAttr['presetAttrValue'] && ($presetAttr['presetAttrEnable'] == 1)) {
|
|
|
$isset = true;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (!$isset) {
|
|
|
$checkAttrNames[] = $attrName;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$checkQualityNames = [];
|
|
|
$ret = $this->doGetQualityListByCid($setting['move_shop_setting_id'], 0);
|
|
|
foreach ($requirePresetQualityNames as $qualityName) {
|
|
|
$isset = false;
|
|
|
foreach ($ret['qualityList'] as $quality) {
|
|
|
if (($qualityName == $quality['quality_name']) && !empty($quality['img_list'])) {
|
|
|
$isset = true;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (!$isset) {
|
|
|
$checkQualityNames[] = $qualityName;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (!$checkAttrNames && !$checkQualityNames) {
|
|
|
return CommonTool::successResult();
|
|
|
}
|
|
|
|
|
|
$needGetCateAttrCids = $needGetCateQualityCids = [];
|
|
|
foreach ($products as $product) {
|
|
|
if ($checkAttrNames) {
|
|
|
$needGetCateAttrCids[] = $product['cid'];
|
|
|
}
|
|
|
if ($checkQualityNames) {
|
|
|
$needGetCateQualityCids[] = $product['cid'];
|
|
|
}
|
|
|
}
|
|
|
|
|
|
list($cateAttrs, $cateQualitys) = $this->moveService->getCateAttrsAndQualitys($needGetCateAttrCids, $needGetCateQualityCids, $_SESSION[SessionConst::accessToken]);
|
|
|
if ($needGetCateQualityCids) {
|
|
|
$needGetCateQualityCids[] = 0;
|
|
|
$shopProductQualitySettingList = $this->moveService->getShopProductQualitySettingList($_SESSION[SessionConst::shopId], $setting['move_shop_setting_id'], $needGetCateQualityCids);
|
|
|
$qualitySettings = [];
|
|
|
foreach ($shopProductQualitySettingList as $qualitySetting) {
|
|
|
$qualitySettings[$qualitySetting['cid']][] = $qualitySetting;
|
|
|
}
|
|
|
$productQualityMap = $qualitySettings ? $this->moveService->getProductQualityMap() : null;
|
|
|
}
|
|
|
|
|
|
$requireAttrNames = $requireQualityList = [];
|
|
|
foreach ($products as $product) {
|
|
|
$cid = $product['cid'];
|
|
|
|
|
|
if (!empty($cateAttrs[$cid])) {
|
|
|
foreach ($cateAttrs[$cid] as $prop) {
|
|
|
$propId = $prop['property_id'];
|
|
|
if (in_array($prop['property_name'], $checkAttrNames) && empty($product['props'][$propId]) && $prop['required']) {
|
|
|
$requireAttrNames[] = $prop['property_name'];
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (!empty($cateQualitys[$cid])) {
|
|
|
$productQualityList = $cateQualitys[$cid];
|
|
|
if ($qualitySettings[0]) {
|
|
|
$productQualityList = $this->moveUtil->appendQualityImgs($productQualityList, $qualitySettings[0], $productQualityMap);
|
|
|
}
|
|
|
if ($qualitySettings[$cid]) {
|
|
|
$productQualityList = $this->moveUtil->appendQualityImgs($productQualityList, $qualitySettings[$cid], $productQualityMap);
|
|
|
}
|
|
|
|
|
|
foreach ($productQualityList as $quality) {
|
|
|
if(!$quality['is_required']) {
|
|
|
continue;
|
|
|
}
|
|
|
if (isset($product['productQualityMap'][$cid][$quality['quality_key']]) && array_filter($product['productQualityMap'][$cid][$quality['quality_key']])) {
|
|
|
continue;
|
|
|
}
|
|
|
if (!empty($quality['img_list'])) {
|
|
|
continue;
|
|
|
}
|
|
|
$requireQualityList[$quality['quality_key']] = $quality;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$res = [];
|
|
|
$requireAttrNames && $res['requireAttrNames'] = $requireAttrNames;
|
|
|
$requireQualityList && $res['requireQualityList'] = $requireQualityList;
|
|
|
if ($res) {
|
|
|
return CommonTool::failResult($res);
|
|
|
} else {
|
|
|
return CommonTool::successResult();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public function saveTask() {
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId start saveTask");
|
|
|
|
|
|
ini_set('memory_limit', '1024M');
|
|
|
$_POST = $_POST['valueMap'] ? json_decode($_POST['valueMap'], true) : json_decode(file_get_contents('php://input'), true); // 20220112起没有valueMap，兼容作用
|
|
|
$needMoveShopIds = isset($_POST['needMoveShopIds']) ? $_POST['needMoveShopIds'] : (array($shopId)); // 前端没有传这个参数的时候使用这个用户自己
|
|
|
$productSimpleDetails = json_decode($_POST['productSimpleDetails'], true);
|
|
|
|
|
|
$copyType = $_POST['copyType'];
|
|
|
|
|
|
$shopMoveSettingOperateLogMap = json_decode($_POST['shopMoveSettingOperateLogMap'], true);
|
|
|
$shopMoveConditionMap = $_POST['shopMoveConditionMap'];
|
|
|
$shopPreviewCateAttr = json_decode($_POST['previewCateAttr'], true);
|
|
|
|
|
|
$source = $_POST['source'];
|
|
|
$isFetchBank = $_POST['isFetchBank'] ? $_POST['isFetchBank'] : false;
|
|
|
$copyType = $isFetchBank ? MoveConst::collectFetchBank : $_POST['copyType'];
|
|
|
|
|
|
$hostname = gethostname();
|
|
|
|
|
|
$shopGroupMoveType = isset($_POST['shopGroupMoveType']) ? $_POST['shopGroupMoveType'] : null;
|
|
|
$shopGroupAllocType = isset($_POST['shopGroupAllocType']) ? $_POST['shopGroupAllocType'] : null;
|
|
|
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId start checkAndFormatData");
|
|
|
$checkAndFormatRet = $this->checkAndFormatData($shopId, $needMoveShopIds, $_POST, $shopMoveConditionMap, $shopPreviewCateAttr, $productSimpleDetails, $hostname, $copyType);
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId end checkAndFormatData");
|
|
|
if (CommonTool::isFailRet($checkAndFormatRet)) {
|
|
|
return $this->renderJSON($checkAndFormatRet);
|
|
|
}
|
|
|
|
|
|
$curProductDetails = $checkAndFormatRet['curProductDetails'];
|
|
|
$shopConditions = $checkAndFormatRet['shopConditions'];
|
|
|
$shopMoveConditionMap = $checkAndFormatRet['shopMoveConditionMap'];
|
|
|
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId start allocShopProductsByAuthShop");
|
|
|
$shopProducts = $this->allocShopProductsByAuthShop($needMoveShopIds, $curProductDetails);
|
|
|
|
|
|
$checkDsValidRet = $this->checkDsValid($needMoveShopIds, $shopProducts);
|
|
|
if (CommonTool::isFailRet($checkDsValidRet)) {
|
|
|
return $this->renderJSON($checkDsValidRet);
|
|
|
}
|
|
|
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId start saveTaskByAuthShop");
|
|
|
$operateSource = $_POST['copyStep2Preview'] ? 'pc' : 'platform'; // 埋点，主客统计搬家来源
|
|
|
$isFromLtaoRank = isset($_POST['isFromLtaoRank']) ? $_POST['isFromLtaoRank'] : 0;
|
|
|
$saveRet = $this->saveTaskByAuthShop($shopId, $copyType, $shopMoveConditionMap, $shopMoveSettingOperateLogMap, $shopConditions, $shopProducts, $shopPreviewCateAttr, $hostname, $operateSource, $isFromLtaoRank);
|
|
|
|
|
|
if (CommonTool::isFailRet($saveRet)) {
|
|
|
return $this->renderJSON($saveRet);
|
|
|
}
|
|
|
|
|
|
$shopTaskId = $saveRet['taskId'];
|
|
|
$redirectURL = Zc::url(RouteConst::moveBatchFinish, array('taskId' => $shopTaskId, 'source' => $source));
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId session shopId " . $_SESSION[SessionConst::shopId] . " saveTask success " . print_r(Zc::G(), true));
|
|
|
$submitCnt = (int)count($shopProducts[$_SESSION[SessionConst::shopId]]);
|
|
|
if ($submitCnt == 0) {
|
|
|
return $this->renderJSON(array(
|
|
|
'result' => 'fail',
|
|
|
'reason' => sprintf('%s：提交商品数为0，请检查是否正常提交商品', $hostname),
|
|
|
'taskId' => $shopTaskId,
|
|
|
'submitCnt' => $submitCnt,
|
|
|
));
|
|
|
}
|
|
|
|
|
|
if ($_POST['sameType']) {
|
|
|
$this->moveService->saveSameProductCopyLog($_POST['sameType'], $_POST['searchSameProductMap'], $shopId, $copyType == MoveConst::collectDsCopy);
|
|
|
}
|
|
|
$this->renderJSON(CommonTool::successResult(array(
|
|
|
'hostname' => $hostname,
|
|
|
'taskId' => $shopTaskId,
|
|
|
'submitCnt' => $submitCnt,
|
|
|
'redirectURL' => $redirectURL
|
|
|
)));
|
|
|
}
|
|
|
|
|
|
private function checkNeedChangeBrand($shopMoveConditionMap) {
|
|
|
return CommonTool::successResult(); // 先不判断
|
|
|
foreach ($shopMoveConditionMap as $authShopId => $moveCondition) {
|
|
|
$brandId = $moveCondition['brand_id'];
|
|
|
|
|
|
if(!is_numeric($brandId) || empty($brandId)) {
|
|
|
return CommonTool::successResult();
|
|
|
}
|
|
|
|
|
|
$name = $this->moveService->getBrandName($brandId, $authShopId);
|
|
|
if(empty($name)) {
|
|
|
return CommonTool::failResult('请在搬家配置重新设置品牌信息在提交任务！');
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return CommonTool::successResult();
|
|
|
}
|
|
|
|
|
|
|
|
|
private function getProductSimpleDetails($productSimpleDetails, $shopId) {
|
|
|
foreach ($productSimpleDetails as $authShopId => &$curProductDetails) {
|
|
|
foreach ($curProductDetails as $skipProductId => &$product) {
|
|
|
if ($product['needSkip'] == 1) {
|
|
|
unset($curProductDetails[$skipProductId]);
|
|
|
}
|
|
|
if ($shopId != $authShopId) {
|
|
|
unset($product['freight_template_id']);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return $productSimpleDetails;
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public function saveTaskFailLog() {
|
|
|
$this->moveService->saveTaskFailLog($_SESSION[SessionConst::shopId], $_REQUEST, $_SERVER, CommonTool::clientIp(), 'save_task_fail_log');
|
|
|
$this->renderJSON(CommonTool::successResult());
|
|
|
}
|
|
|
|
|
|
private function checkAndFormatData($shopId, $needMoveShopIds, $post, $shopMoveConditionMap, $shopPreviewCateAttr, $productSimpleDetails, $hostname, $copyType) {
|
|
|
$hasError = false;
|
|
|
$errorArray = array();
|
|
|
$shopConditions = array();
|
|
|
|
|
|
$productSimpleDetails = $this->getProductSimpleDetails($productSimpleDetails, $shopId);
|
|
|
$curProductDetails = $productSimpleDetails[$shopId];
|
|
|
if(empty($curProductDetails)){
|
|
|
$this->moveService->saveTaskFailLog($_SESSION[SessionConst::shopId], $_REQUEST, $_SERVER, CommonTool::clientIp(), 'save_task');
|
|
|
$this->moveBatchDebugLog->info("shopId[$shopId] empty curProductDetails");
|
|
|
$this->moveBatchDebugLog->info($post);
|
|
|
$ret = CommonTool::failResult(sprintf('%s shopId:%s,未选择要搬家的商品', $hostname, $shopId));
|
|
|
$ret['hostname'] = $hostname;
|
|
|
return $ret;
|
|
|
}
|
|
|
foreach ($curProductDetails as $productId => $productDetail) {
|
|
|
if (!$productDetail['cid']) {
|
|
|
$this->moveBatchDebugLog->info("shopId[$shopId] productId[$productId] invalid cid");
|
|
|
$ret = CommonTool::failResult(sprintf('商品ID:%s 类目必填，请先设置', $productId));
|
|
|
$ret['hostname'] = $hostname;
|
|
|
return $ret;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
foreach ($needMoveShopIds as $authShopId) {
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId $authShopId start rebuild move data");
|
|
|
if (empty($shopMoveConditionMap[$authShopId]) || empty($shopMoveConditionMap[$authShopId]['desc_copy_type'])) {
|
|
|
$hasError = true;
|
|
|
$errorArray[] = sprintf('shopId:%s,搬家配置数据不完整，提交失败。请联系客服！', $authShopId);
|
|
|
$this->moveBatchDebugLog->info("shopId[$authShopId] 搬家配置数据不完整~~");
|
|
|
$this->moveBatchDebugLog->info($post);
|
|
|
break;
|
|
|
}
|
|
|
if (!empty($shopPreviewCateAttr[$authShopId])) {
|
|
|
$shopMoveConditionMap[$authShopId]['usePreviewCommonCateAttr'] = true;
|
|
|
}
|
|
|
$conditionRet = $this->moveService->getTaskCondition($shopMoveConditionMap[$authShopId]);
|
|
|
if(CommonTool::isFailRet($conditionRet)){
|
|
|
$hasError = true;
|
|
|
$errorArray[] = $conditionRet['reason'];
|
|
|
break;
|
|
|
}
|
|
|
$shopConditions[$authShopId] = $conditionRet['condition'];
|
|
|
|
|
|
$shopIsExpire = $this->moveService->checkShopIsExpire($authShopId);
|
|
|
if ($shopIsExpire) {
|
|
|
$shopInfo = $this->shopService->getShop($authShopId);
|
|
|
$hasError = true;
|
|
|
$tip = ($shopId == $authShopId) ? '请联系客服续费！</a>' : '请取消搬家至该店铺';
|
|
|
$errorArray[] = sprintf('店铺【%s】,已过期，%s', $shopInfo['shop_name'], $tip);
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
if ($copyType == MoveConst::collectDsCopy) {
|
|
|
$this->moveService->attachDsMoveCopyTotal($authShopId);
|
|
|
}
|
|
|
|
|
|
$moveConfig = $this->moveService->getAvailableCopyCount($authShopId);
|
|
|
$productTotal = count($curProductDetails);
|
|
|
$dsProducts = $this->moveService->getDsDetails($curProductDetails);
|
|
|
$dsProductTotal = $dsProducts ? count($dsProducts) : 0;
|
|
|
$productTotal = $productTotal - $dsProductTotal;
|
|
|
if ($productTotal > 0 && $productTotal > $moveConfig['available_total']){
|
|
|
$appVersionRet = $this->shopService->getShopAppVersion($shopId);
|
|
|
$this->moveService->recordTriggerAppVersionLimitLog($shopId, $appVersionRet['appVersion'], $moveConfig['total'], $moveConfig['used_total'], $productTotal, 'move');
|
|
|
$shopInfo = $this->shopService->getShop($authShopId);
|
|
|
$hasError = true;
|
|
|
$tip = $this->moveUtil->getChargeTipByShopInfo($shopInfo, $productTotal, $moveConfig['available_total']);
|
|
|
|
|
|
$errorArray[] = $tip;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($hasError) {
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId saveTask hasError" . print_r(Zc::G(), true));
|
|
|
$ret = CommonTool::failResult(implode(';', $errorArray));
|
|
|
$ret['hostname'] = $hostname;
|
|
|
return $ret;
|
|
|
}
|
|
|
|
|
|
return CommonTool::successResult(array(
|
|
|
'curProductDetails' => $curProductDetails,
|
|
|
'shopConditions' => $shopConditions,
|
|
|
'shopMoveConditionMap' => $shopMoveConditionMap,
|
|
|
));
|
|
|
}
|
|
|
|
|
|
private function allocShopProductsByAuthShop($needMoveShopIds, $curProductDetails) {
|
|
|
$shopProducts = array();
|
|
|
foreach ($needMoveShopIds as $authShopId) {
|
|
|
foreach ($curProductDetails as $productInfo){
|
|
|
$newProduct = $this->moveUtil->formatSaveMoveTaskProduct($productInfo, $authShopId);
|
|
|
if (empty($newProduct)) {
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
$productId = $productInfo['productId'];
|
|
|
$shopProducts[$authShopId][$productId] = $newProduct;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return $shopProducts;
|
|
|
}
|
|
|
|
|
|
private function saveTaskByAuthShop($shopId, $copyType, $shopMoveConditionMap, $shopMoveSettingOperateLogMap, $shopConditions, $shopProducts, $shopPreviewCateAttr, $hostname, $operateSource, $isFromLtaoRank) {
|
|
|
Zc::G("shopId $shopId start saveMoveSetting");
|
|
|
list($updateErrorShopIds, $moveShopSettingIds) = $this->saveMoveSetting($shopMoveConditionMap, $shopMoveSettingOperateLogMap);
|
|
|
Zc::G("shopId $shopId end saveMoveSetting");
|
|
|
if (!empty($updateErrorShopIds)) {
|
|
|
$ret = CommonTool::failResult(sprintf('店铺Id:%s，保存搬家配置失败，请稍后再尝试', implode(' ', $updateErrorShopIds)));
|
|
|
$ret['hostname'] = $hostname;
|
|
|
return $ret;
|
|
|
}
|
|
|
|
|
|
if ($copyType == MoveConst::collectLinksCopy) {
|
|
|
$name = sprintf('%s 批量抓取', ZcDateHelper::now());
|
|
|
} else {
|
|
|
$name = sprintf('%s', ZcDateHelper::now());
|
|
|
}
|
|
|
|
|
|
Zc::G("shopId $shopId start replaceShopConditionsBigField");
|
|
|
$shopConditions = $this->moveService->replaceShopConditionsBigField($shopConditions, $moveShopSettingIds);
|
|
|
Zc::G("shopId $shopId end replaceShopConditionsBigField");
|
|
|
$shopConditions = $this->attachMoveSettingIdToMoveTaskCondition($moveShopSettingIds, $shopConditions);
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId start addShopCollectTask");
|
|
|
|
|
|
$addRet = $this->moveService->addShopCollectTask($shopId, $shopProducts, $name, $copyType, $shopConditions, $shopPreviewCateAttr, $operateSource,$isFromLtaoRank);
|
|
|
|
|
|
if (CommonTool::isFailRet($addRet)) {
|
|
|
$this->moveBatchSaveTaskLog->info("shopId $shopId saveTask addRet fail" . print_r(Zc::G(), true));
|
|
|
$addRet['hostname'] = $hostname;
|
|
|
}
|
|
|
|
|
|
return $addRet;
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public function saveMoveSetting($shopMoveConditionMap, $shopMoveSettingOperateLogMap = array()) {
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
|
|
|
$updateErrorShopIds = array();
|
|
|
$moveShopSettingIds = array();
|
|
|
foreach ($shopMoveConditionMap as $authShopId => $moveCondition) {
|
|
|
if (empty($moveCondition)) {
|
|
|
$this->moveBatchSettingLog->info("authShopId[$authShopId] get empty moveCondition");
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
$moveCondition = $this->moveUtil->processMoveSetting($moveCondition);
|
|
|
$moveCondition['shop_id'] = $authShopId;
|
|
|
$moveShopSettingId = $moveCondition['move_shop_setting_id'];
|
|
|
if ($moveShopSettingId) {
|
|
|
$ret = $this->moveService->updateMoveSetting($authShopId, $moveShopSettingId, $moveCondition);
|
|
|
$this->moveService->addMoveShopSettingOperateLog($shopId, $authShopId, $shopMoveSettingOperateLogMap[$authShopId]);
|
|
|
$moveShopSettingIds[$authShopId] = $moveShopSettingId;
|
|
|
} else {
|
|
|
$ret = $this->moveService->insertMoveSetting($moveCondition);
|
|
|
if ($ret) {
|
|
|
$moveShopSettingIds[$authShopId] = $ret;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
if (!$ret) {
|
|
|
$updateErrorShopIds[] = $authShopId;
|
|
|
}
|
|
|
$this->moveBatchSettingLog->info("shopId[$shopId] authShopId[$authShopId] post data:" . print_r($moveCondition, true) . "update ret:[$ret]" );
|
|
|
}
|
|
|
return [$updateErrorShopIds, $moveShopSettingIds];
|
|
|
}
|
|
|
|
|
|
public function history() {
|
|
|
$moveShopStopInfo = $this->moveService->getMoveShopStopInfo($_SESSION[SessionConst::shopId]);
|
|
|
$folderMenuTree = $this->materialService->getMaterialFolderMenuTree($_SESSION[SessionConst::shopId]);
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
|
|
|
$productCatList = $this->rsyncProductService->getAllLeafProductCatList($_SESSION[SessionConst::shopId]);
|
|
|
$cates = [];
|
|
|
$cates[] = '请选择分类';
|
|
|
foreach ($productCatList as $productCat) {
|
|
|
$cates[$productCat['category_id']] = $productCat['path'];
|
|
|
}
|
|
|
|
|
|
$this->render([
|
|
|
'moveShopStopInfo' => $moveShopStopInfo,
|
|
|
'folderMenuTree' => $folderMenuTree,
|
|
|
'shopId' => $shopId,
|
|
|
'productCatList' => $cates
|
|
|
]);
|
|
|
}
|
|
|
|
|
|
public function historyProductList() {
|
|
|
$pageNo = $_GET['page'] > 0 ? (int)$_GET['page'] : 1;
|
|
|
$pageSize = $_GET['pageSize'] > 0 ? (int)$_GET['pageSize'] : 20;
|
|
|
$source = $_GET['source'];
|
|
|
$status = $_GET['status'];
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$filter = $this->moveUtil->buildHistoryProductListFilter($_GET);
|
|
|
$filter['isMoveHugeSeller'] = $_SESSION[SessionConst::isMoveHugeSeller];
|
|
|
if (!in_array($pageSize, [20, 40, 100, 500, 1000, 2000])) {
|
|
|
$pageSize = 20;
|
|
|
}
|
|
|
|
|
|
list($processingTaskCount, $taskDetailList, $total, $moveShopStopInfo) = $this->productUtil->getHistoryProductList($shopId, $filter, $pageNo, $pageSize);
|
|
|
$taskDetailList = $this->productUtil->buildLtaoProductToDsItemTag($taskDetailList);
|
|
|
$pagin = new ZcPagination($total, $pageSize, $pageNo);
|
|
|
$html = $this->renderWithoutLayout(array(
|
|
|
'taskDetailList' => $taskDetailList,
|
|
|
'pagin' => $pagin,
|
|
|
'pageSize' => $pageSize,
|
|
|
'status' => $status,
|
|
|
'source' => $source,
|
|
|
'taskTotal' => $total,
|
|
|
'processingTaskCount' => $processingTaskCount,
|
|
|
'filter' => $filter,
|
|
|
'moveShopStopInfo' => $moveShopStopInfo,
|
|
|
'showLimitPublishReason' => $this->productUtil->showLimitPublishReason($taskDetailList, $moveShopStopInfo),
|
|
|
), 'move/batch/history_product_list', true);
|
|
|
$data['html'] = $html;
|
|
|
return $this->renderJSON($data);
|
|
|
}
|
|
|
|
|
|
|
|
|
public function failRetryMoveTasks() {
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult('CSRF校验不通过'));
|
|
|
}
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$taskDetailIds = is_array($_POST['taskDetailIds']) ? $_POST['taskDetailIds'] : [$_POST['taskDetailIds']];
|
|
|
|
|
|
$retryRet = $this->moveUtil->failRetryMoveTasks($shopId, $taskDetailIds, $this->failRetryMoveTaskLog);
|
|
|
$this->renderJSON($retryRet);
|
|
|
}
|
|
|
|
|
|
|
|
|
public function moveAgainDetail() {
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult('CSRF校验不通过'));
|
|
|
}
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$taskDetailIds = is_array($_POST['taskDetailIds']) ? $_POST['taskDetailIds'] : [$_POST['taskDetailIds']];
|
|
|
|
|
|
|
|
|
if (count($taskDetailIds) == 1) {
|
|
|
$newDetailId = $this->moveService->moveAgainDetailsByDetailId($shopId, array_pop($taskDetailIds), false, $this->moveAgainDetailLog);
|
|
|
if ($newDetailId) {
|
|
|
return $this->renderJSON(CommonTool::successResult('processCount', 1));
|
|
|
} else {
|
|
|
return $this->renderJSON(CommonTool::failResult('当前商品数据已失效，暂不支持操作，如有疑问请联系客服'));
|
|
|
}
|
|
|
} else {
|
|
|
$ret = $this->moveUtil->moveAgainDetail($shopId, $taskDetailIds, $this->moveAgainDetailLog);
|
|
|
return $this->renderJSON($ret);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public function deleteDeleteTask(){
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult(ErrorCodeConst::csrfTokenErrorTip));
|
|
|
}
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$delCnt = 0;
|
|
|
ZC::G('start deleteDeleteTask');
|
|
|
$detailIds = $this->moveService->getAllDeleteMoveCollectTaskDetailIds($shopId);
|
|
|
|
|
|
$allChunkedDetailIds = array_chunk($detailIds, 100);
|
|
|
foreach ($allChunkedDetailIds as $sliceDetailIds) {
|
|
|
foreach ($sliceDetailIds as $detailId) {
|
|
|
$delRet = $this->moveService->delMoveTaskDetailHistory($shopId, $detailId);
|
|
|
if ($delRet) {
|
|
|
$delCnt++;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
ZC::G('end deleteFailTask');
|
|
|
|
|
|
return $this->renderJSON(CommonTool::successResult('total', $delCnt));
|
|
|
}
|
|
|
|
|
|
public function batchDeleteTaskDetail() {
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult('CSRF校验不通过'));
|
|
|
}
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$accessToken = $_SESSION[SessionConst::accessToken];
|
|
|
$ret = $this->moveUtil->batchDeleteTaskDetail($shopId, $accessToken);
|
|
|
return $this->renderJSON($ret);
|
|
|
}
|
|
|
|
|
|
public function cancelCollectTask() {
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult('CSRF校验不通过'));
|
|
|
}
|
|
|
|
|
|
list($successCancelDetailIds, $skipCancelDetailIds) = $this->moveUtil->cancelCollectTask();
|
|
|
$html = '';
|
|
|
if ($skipCancelDetailIds) {
|
|
|
list($processingTaskCount, $taskDetailList,) = $this->productUtil->getHistoryProductList($_SESSION[SessionConst::shopId], ['taskDetailIds' => $skipCancelDetailIds], 1, count($skipCancelDetailIds));
|
|
|
$html = $this->renderWithoutLayout(array(
|
|
|
'taskDetailList' => $taskDetailList,
|
|
|
), 'move/batch/skip_cancel', true);
|
|
|
}
|
|
|
|
|
|
return $this->renderJSON(CommonTool::successResult([
|
|
|
'processCount' => count($successCancelDetailIds),
|
|
|
'skipCount' => count($skipCancelDetailIds),
|
|
|
'html' => $html
|
|
|
]));
|
|
|
}
|
|
|
|
|
|
public function deleteFailTaskDetail() {
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult('CSRF校验不通过'));
|
|
|
}
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$delCount = $this->moveService->delMoveHistoryByStatus($shopId, StatusConst::fail);
|
|
|
return $this->renderJSON(CommonTool::successResult('total', $delCount));
|
|
|
}
|
|
|
|
|
|
public function deleteSkipTaskDetail() {
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult('CSRF校验不通过'));
|
|
|
}
|
|
|
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$delCount = $this->moveService->delMoveHistoryByStatus($shopId, StatusConst::skip);
|
|
|
return $this->renderJSON(CommonTool::successResult('total', $delCount));
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function getDsAuthUrl() {
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
|
|
|
$getUrlRet = $this->dsClient->getDsAuthUrl($shopId, AppConst::getDsPlatform(), Zc::C('acn.ds.domain'));
|
|
|
|
|
|
return $this->renderJSON($getUrlRet);
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public function checkDsAuthExpire() {
|
|
|
$log = Zc::getLog('tool/fetch/checkAuth');
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
|
|
|
$authCode = $this->shopService->getAuthCodeByShopId($shopId);
|
|
|
if (empty($authCode)) {
|
|
|
return $this->renderJSON(CommonTool::successResult());
|
|
|
}
|
|
|
|
|
|
$dsMemberInfo = $this->moveService->getDsMemberInfo($shopId);
|
|
|
|
|
|
$checkRet = $this->dsClient->checkDsAppAuthExpire(AppConst::getDsPlatform(), [], $dsMemberInfo['cnali_member_id'], $authCode);
|
|
|
$log->info('-----checkRet-----' . print_r($checkRet, true));
|
|
|
if (CommonTool::isFailRet($checkRet)) {
|
|
|
return $this->renderJSON(CommonTool::successResult());
|
|
|
}
|
|
|
$checkRet = $checkRet['userIdAndCheckRetMap'][$shopId];
|
|
|
|
|
|
if (CommonTool::isSuccessRet($checkRet) || empty($checkRet['code'])) {
|
|
|
return $this->renderJSON(CommonTool::successResult());
|
|
|
}
|
|
|
|
|
|
if ($checkRet['code'] == DsConst::authExpireTypeAuthExpire) {
|
|
|
$getUrlRet = $this->dsClient->getDsAuthUrl($shopId, AppConst::getDsPlatform(), Zc::C('acn.ds.domain'));
|
|
|
if (CommonTool::isSuccessRet($getUrlRet)) {
|
|
|
$checkRet['reason'] = sprintf('<i class="fa fa-exclamation-circle" style="color: red;"></i>1688' . DsConst::getDsAppChineseName() . '授权已失效，<a href="%s" target="_blank">重新授权</a>', $getUrlRet['redirectUrl']);
|
|
|
}
|
|
|
} else {
|
|
|
$dsBuyUrl = $this->moveService->getDsBuyUrl($shopId);
|
|
|
$checkRet['reason'] = sprintf('<i class="fa fa-exclamation-circle" style="color: red;"></i>1688' . DsConst::getDsAppChineseName() . '已过期，<a href="%s" target="_blank">重新订购</a>', $dsBuyUrl);
|
|
|
}
|
|
|
|
|
|
return $this->renderJSON($checkRet);
|
|
|
}
|
|
|
|
|
|
private function buildSearchSameProductFilter($sameType, $detailUrls, $shopId, $cluePicUrlNameMap = []) {
|
|
|
if ($sameType == MoveConst::collectSameProductTypeImg) {
|
|
|
if (empty($_FILES['searchSameProductImg'])) {
|
|
|
return CommonTool::failResult('请上传图片');
|
|
|
}
|
|
|
$moveDir = 'shop/upload/' . $shopId;
|
|
|
$uploadRet = $this->materialUtil->uploadLocalMultipleImageToOss('searchSameProductImg', $moveDir, false);
|
|
|
if (CommonTool::isFailRet($uploadRet)) {
|
|
|
return $uploadRet;
|
|
|
}
|
|
|
$srcs = ZcArrayHelper::getSub($uploadRet['images'], 'src');
|
|
|
$detailUrls = implode(',', $srcs);
|
|
|
if (empty($detailUrls)) {
|
|
|
return CommonTool::failResult('上传图片失败，请重试');
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$detailUrls = array_map('trim', preg_split("/\\r\\n|\\r|\\n|,|，|;|；/u", $detailUrls));
|
|
|
$detailUrls = array_filter(array_unique($detailUrls));
|
|
|
if (empty($detailUrls)) {
|
|
|
return CommonTool::failResult('请输入链接');
|
|
|
}
|
|
|
|
|
|
$detailUrls = array_slice($detailUrls, 0, 10);
|
|
|
$productsInfoList = [];
|
|
|
if ($sameType == MoveConst::collectSameProductTypeMixContent) {
|
|
|
$linkDetails = [];
|
|
|
$k = mt_rand(1000, 100000);
|
|
|
foreach ($detailUrls as $detailUrl) {
|
|
|
if (CommonTool::checkIsImageLink($detailUrl)) {
|
|
|
$k++;
|
|
|
$productsInfoList[$k] = [
|
|
|
'itemId' => $k,
|
|
|
'imgUrl' => $detailUrl,
|
|
|
'title' => $cluePicUrlNameMap[$detailUrl] ?: '',
|
|
|
];
|
|
|
} else {
|
|
|
$linkDetails[] = $detailUrl;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($linkDetails) {
|
|
|
$getProductsInfoListRet = $this->moveUtil->getProductsInfoListByDetailUrls(implode(',', $linkDetails), $shopId, null, null, null, null, true);
|
|
|
if (CommonTool::isSuccessRet($getProductsInfoListRet)) {
|
|
|
$fetchProductsInfoList = $getProductsInfoListRet['productsInfoList'];
|
|
|
$fetchProductsInfoList = $this->buildSearchSameProductProductInfoList($fetchProductsInfoList);
|
|
|
$productsInfoList = $productsInfoList + $fetchProductsInfoList;
|
|
|
}
|
|
|
}
|
|
|
} else if ($sameType == MoveConst::collectSameProductTypeLink) {
|
|
|
$getProductsInfoListRet = $this->moveUtil->getProductsInfoListByDetailUrls(implode(',', $detailUrls), $shopId);
|
|
|
if (CommonTool::isFailRet($getProductsInfoListRet)) {
|
|
|
return $getProductsInfoListRet;
|
|
|
}
|
|
|
|
|
|
$productsInfoList = $getProductsInfoListRet['productsInfoList'];
|
|
|
$productsInfoList = $this->buildSearchSameProductProductInfoList($productsInfoList);
|
|
|
} else if ($sameType == MoveConst::collectSameProductTypeImgUrl || $sameType == MoveConst::collectSameProductTypeImg) {
|
|
|
$k = mt_rand(1000, 100000);
|
|
|
foreach ($detailUrls as $imgUrl) {
|
|
|
$k++;
|
|
|
$productsInfoList[$k] = [
|
|
|
'itemId' => $k,
|
|
|
'imgUrl' => $imgUrl,
|
|
|
'title' => $cluePicUrlNameMap[$imgUrl] ?: '',
|
|
|
];
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return CommonTool::successResult('productsInfoList', $productsInfoList);
|
|
|
}
|
|
|
|
|
|
public function searchSameProduct() {
|
|
|
if (!$this->webShop->validateCsrfToken()) {
|
|
|
return $this->renderJSON(CommonTool::failResult(ErrorCodeConst::csrfTokenErrorTip));
|
|
|
}
|
|
|
|
|
|
$this->moveBatchUrlLog->info('fetchDetailUrlInfo, shopId[' . $_SESSION[SessionConst::shopId] . '], post: ' . print_r($_POST, true));
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
$detailUrls = $_POST['detailUrls'];
|
|
|
$sameType = $_POST['sameType'];
|
|
|
$copyType = $_POST['copyType'];
|
|
|
$cluePicUrlNameMap = $_POST['cluePicUrlNameMap'];
|
|
|
|
|
|
$checkRet = $this->moveUtil->checkAbnormalRequest($shopId);
|
|
|
if (CommonTool::isFailRet($checkRet)) {
|
|
|
return $this->renderJSON($checkRet);
|
|
|
}
|
|
|
|
|
|
$ret = $this->buildSearchSameProductFilter($sameType, $detailUrls, $shopId, $cluePicUrlNameMap ?: []);
|
|
|
if (CommonTool::isFailRet($ret)) {
|
|
|
return $this->renderJSON($ret);
|
|
|
}
|
|
|
$productsInfoList = $ret['productsInfoList'];
|
|
|
|
|
|
if ($copyType == MoveConst::collectLtaoCopy) {
|
|
|
list($productsInfoList) = $this->moveUtil->searchLtaoSameProducts($productsInfoList, $shopId, $cluePicUrlNameMap ?: []);
|
|
|
} else {
|
|
|
$productsInfoList = $this->moveUtil->searchSameProducts($productsInfoList, FetchClientConst::collectTaskSource1688, $shopId, $copyType == MoveConst::collectDsCopy);
|
|
|
}
|
|
|
|
|
|
$productsInfoList = $this->mergeSameProductIsSelect($productsInfoList);
|
|
|
|
|
|
|
|
|
$html = $this->renderWithoutLayout([
|
|
|
'productsInfoList' => $productsInfoList,
|
|
|
'copyType' => $copyType,
|
|
|
], 'move/batch/search_1688_same_product', true);
|
|
|
|
|
|
return $this->renderJSON(CommonTool::successResult([
|
|
|
'html' => $html,
|
|
|
'productsInfoList' => $productsInfoList
|
|
|
]));
|
|
|
}
|
|
|
|
|
|
private function filterNotDsProducts($productsInfoList, $shopId) {
|
|
|
$i = 0;
|
|
|
foreach ($productsInfoList as &$productsInfo) {
|
|
|
$sameWareList = array_slice($productsInfo['sameWareList'], 0, 20);
|
|
|
$sameWareList = ZcArrayHelper::changeKeyRow($sameWareList, 'itemId');
|
|
|
$productsInfo['sameWareList'] = $sameWareList;
|
|
|
$productsInfo['sameWareNum'] = count($productsInfo['sameWareList']);
|
|
|
if ($i > 0) {
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
$detailUrls = ZcArrayHelper::getSub($productsInfo['sameWareList'], 'itemUrl');
|
|
|
|
|
|
$detailUrls = implode(',', $detailUrls);
|
|
|
$getProductInfoListRet = $this->getAlibabaProductsInfoListByDetailUrls($detailUrls, $shopId);
|
|
|
if (CommonTool::isFailRet($getProductInfoListRet)) {
|
|
|
$productsInfo['sameWareList'] = [];
|
|
|
$productsInfo['sameWareNum'] = 0;
|
|
|
$i++;
|
|
|
continue;
|
|
|
}
|
|
|
$itemsInfoList = $getProductInfoListRet['productsInfoList'];
|
|
|
|
|
|
foreach ($productsInfo['sameWareList'] as $itemId => $itemInfo) {
|
|
|
if (!isset($itemsInfoList[$itemId]) || !$itemsInfoList[$itemId]['isFromDs']) {
|
|
|
unset($productsInfo['sameWareList'][$itemId]);
|
|
|
}
|
|
|
}
|
|
|
$productsInfo['sameWareNum'] = count($productsInfo['sameWareList']);
|
|
|
$productsInfo['hasFilterDs'] = true;
|
|
|
$i++;
|
|
|
}
|
|
|
|
|
|
return $productsInfoList;
|
|
|
}
|
|
|
|
|
|
private function buildSearchSameProductProductInfoList($productsInfoList) {
|
|
|
$newProductsInfoList = [];
|
|
|
foreach ($productsInfoList as $productsInfo) {
|
|
|
$imgUrl = $productsInfo['item_image'] ?: reset($productsInfo['image_paths']);
|
|
|
if (empty($imgUrl)) {
|
|
|
continue;
|
|
|
}
|
|
|
$newProductsInfoList[$productsInfo['itemId']] = [
|
|
|
'itemId' => $productsInfo['itemId'],
|
|
|
'source' => $productsInfo['source'],
|
|
|
'site' => $productsInfo['site'],
|
|
|
'imgUrl' => $imgUrl,
|
|
|
'title' => $productsInfo['title'],
|
|
|
'price' => $productsInfo['sale_price'] ?: $productsInfo['jd_price']
|
|
|
];
|
|
|
}
|
|
|
|
|
|
return $newProductsInfoList;
|
|
|
}
|
|
|
|
|
|
private function mergeSameProductIsSelect($productsInfoList) {
|
|
|
foreach ($productsInfoList as &$productsInfo) {
|
|
|
foreach ($productsInfo['sameWareList'] as &$sameProduct) {
|
|
|
$sameProduct['isSelect'] = 0;
|
|
|
unset($sameProduct);
|
|
|
}
|
|
|
unset($productsInfo);
|
|
|
}
|
|
|
|
|
|
return $productsInfoList;
|
|
|
}
|
|
|
|
|
|
public function singleRetrySearchSameProduct() {
|
|
|
$shopId = $_SESSION[SessionConst::shopId];
|
|
|
|
|
|
$imgUrl = $_POST['imgUrl'];
|
|
|
$copyType = $_POST['copyType'];
|
|
|
$cluePicUrlNameMap = $_POST['cluePicUrlNameMap'];
|
|
|
|
|
|
$productsInfoList = ['100000' => ['itemId' => 100000, 'imgUrl' => $imgUrl]];
|
|
|
if ($copyType == MoveConst::collectLtaoCopy) {
|
|
|
list($productsInfoList) = $this->moveUtil->searchLtaoSameProducts($productsInfoList, $shopId, $cluePicUrlNameMap ?: []);
|
|
|
} else {
|
|
|
$productsInfoList = $this->moveUtil->searchSameProducts($productsInfoList, FetchClientConst::collectTaskSource1688, $shopId, $copyType == MoveConst::collectDsCopy);
|
|
|
}
|
|
|
$productsInfoList = $this->mergeSameProductIsSelect($productsInfoList);
|
|
|
|
|
|
if ($copyType == MoveConst::collectDsCopy) {
|
|
|
$productsInfoList = $this->filterNotDsProducts($productsInfoList, $shopId);
|
|
|
}
|
|
|
|
|
|
$sameProductInfos = $productsInfoList[100000];
|
|
|
|
|
|
return CommonTool::successResult([
|
|
|
'sameProductInfos' => $sameProductInfos
|
|
|
]);
|
|
|
}
|
|
|
} |