116 lines
4.2 KiB
PHP
116 lines
4.2 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | likeshop开源商城系统
|
||
// +----------------------------------------------------------------------
|
||
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
|
||
// | gitee下载：https://gitee.com/likeshop_gitee
|
||
// | github下载：https://github.com/likeshop-github
|
||
// | 访问官网：https://www.likeshop.cn
|
||
// | 访问社区：https://home.likeshop.cn
|
||
// | 访问手册：http://doc.likeshop.cn
|
||
// | 微信公众号：likeshop技术社区
|
||
// | likeshop系列产品在gitee、github等公开渠道开源版本可免费商用，未经许可不能去除前后端官方版权标识
|
||
// | likeshop系列产品收费版本务必购买商业授权，购买去版权授权后，方可去除前后端官方版权标识
|
||
// | 禁止对系统程序代码以任何目的，任何形式的再发布
|
||
// | likeshop团队版权所有并拥有最终解释权
|
||
// +----------------------------------------------------------------------
|
||
// | author: likeshop.cn.team
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\common\command;
|
||
|
||
|
||
use app\common\enum\LiveGoodsEnum;
|
||
use app\common\model\live\LiveGoods;
|
||
use app\common\server\WxMnpLiveServer;
|
||
use think\console\Command;
|
||
use think\console\Output;
|
||
use think\console\Input;
|
||
use think\facade\Log;
|
||
|
||
|
||
class WechatLiveGoods extends Command
|
||
{
|
||
|
||
protected function configure()
|
||
{
|
||
$this->setName('wechat_live_goods')
|
||
->setDescription('微信小程序直播商品状态同步');
|
||
}
|
||
|
||
|
||
protected function execute(Input $input, Output $output)
|
||
{
|
||
try {
|
||
$liveGoodsModel = new LiveGoods();
|
||
// 系统待微信审核的商品
|
||
$localGoods = $liveGoodsModel->where([
|
||
'del' => 0,
|
||
'sys_audit_status' => LiveGoodsEnum::SYS_AUDIT_STATUS_WAIT_WECHAT
|
||
])
|
||
->select()->toArray();
|
||
|
||
if (empty($localGoods)) {
|
||
return true;
|
||
}
|
||
|
||
// 切分为20个一组，获取每组的商品状态更新
|
||
$localGoods = array_chunk($localGoods, 20);
|
||
foreach ($localGoods as $localGoodsItem) {
|
||
$goodsIds = array_column($localGoodsItem, 'wx_goods_id');
|
||
$wxGoodsData = $this->getGoods($goodsIds);
|
||
$wxGoodsData = $wxGoodsData['goods'] ?? [];
|
||
$wxGoodsDataColumn = array_column($wxGoodsData, null,'goods_id');
|
||
|
||
$updateData = [];
|
||
foreach ($localGoodsItem as $goods) {
|
||
$wxGoodsId = $goods['wx_goods_id'];
|
||
if (!isset($wxGoodsDataColumn[$wxGoodsId])) {
|
||
continue;
|
||
}
|
||
$wxGoods = $wxGoodsDataColumn[$wxGoodsId];
|
||
$data = [
|
||
'id' => $goods['id'],
|
||
'wx_audit_status' => $wxGoods['audit_status'],
|
||
'audit_remark' => LiveGoodsEnum::getWxAuditStatusDesc($wxGoods['audit_status']),
|
||
];
|
||
if ($wxGoods['audit_status'] == LiveGoodsEnum::WX_AUDIT_STATUS_SUCCESS) {
|
||
$data['sys_audit_status'] = LiveGoodsEnum::SYS_AUDIT_STATUS_SUCCESS;
|
||
}
|
||
if ($wxGoods['audit_status'] == LiveGoodsEnum::WX_AUDIT_STATUS_FAIL) {
|
||
$data['sys_audit_status'] = LiveGoodsEnum::SYS_AUDIT_STATUS_FAIL;
|
||
}
|
||
$updateData[] = $data;
|
||
}
|
||
|
||
if (!empty($updateData)) {
|
||
$liveGoodsModel->saveAll($updateData);
|
||
}
|
||
}
|
||
|
||
return true;
|
||
} catch (\Exception $e) {
|
||
Log::write('更新直播商品状态失败:' . $e->getMessage());
|
||
return false;
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* @notes 获取商品
|
||
* @param $goodsIds
|
||
* @return array
|
||
* @throws \Exception
|
||
* @author 段誉
|
||
* @date 2023/2/17 19:24
|
||
*/
|
||
protected function getGoods($goodsIds)
|
||
{
|
||
$result = (new WxMnpLiveServer())->handle('getGoodsWarehouse', $goodsIds);
|
||
if (0 != $result['errcode']) {
|
||
return [];
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
} |