src/Controller/DataTrans/ProductController.php line 22

Open in your IDE?
  1. <?php
  2. /**
  3.  * 对外接口：/data_trans/product/*
  4.  */
  5. namespace App\Controller\DataTrans;
  7. use App\Controller\Validator\CommonSignatureAppValidator;
  8. use App\Service\CommonService;
  9. use Common\Crisp\CrispItem\ProductItem;
  10. use Common\DataSynch\Crisp\Model\CrispCommodityModel;
  11. use Common\DataTrans\Crisp\Model\CrispProductModel;
  12. use Common\Helper\SimplifyAsSnakeArray\SimplifyAsSnakeArrayHelper;
  13. use Common\PimcoreHelper\ControllerHelper\BaseJsonController;
  14. use Common\Signature\Exception\BaseSignatureException;
  15. use Pimcore\Db;
  16. use Pimcore\Model\DataObject\CrispCommodity;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Symfony\Component\HttpFoundation\Response;
  19. use function array_intersect;
  20. use function array_values;
  22. class ProductController extends BaseJsonController{
  23.     /**
  24.      * @Symfony\Component\Routing\Annotation\Route("/data_trans/product/get_product_id_list")
  25.      * @throws BaseSignatureException
  26.      */
  27.     function getProductIdList(Request $request):Response{
  28.         (new CommonSignatureAppValidator())->validateRequest($request);
  30.         $input=[];
  32.         $body=function(array $input):array{
  33.             $allowedProductIdList=CrispCommodityModel::getArticleIdListByArticleStatusAllowed();
  35.             $productIdList=CrispProductModel::getOrderKeyAscList();
  36.             $finalList=array_values(array_intersect($productIdList,$allowedProductIdList));
  38.             return [
  39.                 'product_id_list'=>$finalList,
  40.             ];
  41.         };
  42.         $res=$this->run($input,$body);
  43.         return $res;
  44.     }
  45.     /**
  46.      * @Symfony\Component\Routing\Annotation\Route("/data_trans/product/get_product_list")
  47.      * @throws BaseSignatureException
  48.      */
  49.     function getProductList(Request $request):Response{
  50.         (new CommonSignatureAppValidator())->validateRequest($request);
  52.         $productIdList=$request->get('product_id_list')??[];
  53.         $input=[
  54.             'product_id_list'=>$productIdList,
  55.         ];
  57.         $body=function(array $input):array{
  58.             $allowedProductIdList=CrispCommodityModel::getArticleStatusAllowedArticleIdListByArticleIdList($input['product_id_list']);
  60.             $pimcoreObjectList=CrispProductModel::getListByProductIdList($allowedProductIdList);
  61.             $parserObjectList=ProductItem::dataObjectListExportToInstanceList($pimcoreObjectList);
  62.             $finalList=SimplifyAsSnakeArrayHelper::simplifyAsSnakeArrayMass($parserObjectList);
  64.             return [
  65.                 'product_list'=>$finalList,
  66.             ];
  67.         };
  68.         $res=$this->run($input,$body);
  69.         return $res;
  70.     }
  72.     /**
  73.      * @Symfony\Component\Routing\Annotation\Route("/data_trans/product/get_commodity_list")
  74.      * @throws BaseSignatureException
  75.      */
  76.     function getCommodityList(Request $request):Response{
  77.         (new CommonSignatureAppValidator())->validateRequest($request);
  79.         $params = $request->request->all();
  80.         $page = intval($params['page']??1);
  81.         $limit = intval($params['limit']??10);
  82.         $offset = ($page-1) * $limit;
  84.         $listing = new CrispCommodity\Listing();
  85.         $listing->filterByShelfCategoryId(10000, '>=');
  86.         if(!empty($params['product_id'])) {
  87.             $listing->filterByArticleId($params['product_id']);
  88.         }
  89.         $list = $listing->getItems($offset, $limit);
  90.         $data = [];
  91.         foreach($list as $commodity) {
  92.             $item = [];
  93.             $item['basic'] = [
  94.                 '物料号'=>$commodity->getArticleId(),
  95.                 '物料名称'=>$commodity->getArticleDescription(),
  96.                 '公司'=>$commodity->get('companyCode'),
  97.                 '可售状态'=>$commodity->get('articleStatus'),
  98.                 'ERP状态'=>$commodity->get('erpStatus'),
  99.                 'Product Key'=>$commodity->get('productKey'),
  100.                 'Category Group'=>$commodity->get('categoryGroup'),
  101.                 'OrigId'=>$commodity->get('origId'),
  102.                 '表价'=>$commodity->get('listPrice'),
  103.                 '销售价格单位'=>$commodity->get('listPriceUnit'),
  104.                 '销售单位'=>$commodity->get('uomIso'),
  105.                 '交付时间'=>$commodity->get('plannedDeliveryTime'),
  106.                 '替换物料号'=>$commodity->get('replacementArticleId'),
  107.                 '产品线'=>$commodity->get('productlineId'),
  108.                 '产品线描述'=>$commodity->get('productlineDesc'),
  109.                 'BA'=>$commodity->get('productSegment'),
  110.                 'BU'=>$commodity->get('productBu'),
  111.                 '产品类型'=>$commodity->get('versionRevisionTypeSap'),
  112.                 '国产/进口'=>$commodity->get('importFlag'),
  113.                 '最小整包装PAC'=>$commodity->get('packingQuantity'),
  114.                 '最小起订量'=>$commodity->get('minimumOrderQuantity'),
  115.                 '原产地'=>$commodity->get('countryOfOrigin'),
  116.                 '计划策略组'=>$commodity->get('strategyGroupSap'),
  117.                 '净重'=>$commodity->get('netWeight'),
  118.                 '毛重'=>$commodity->get('grossWeight'),
  119.                 '重量单位'=>$commodity->get('weightUnit'),
  120.                 '货币单位'=>$commodity->get('currency')
  121.             ];
  123.             $fileters = [];
  124.             $prodFileters = json_decode($commodity->getFilters(), true);
  125.             foreach ($prodFileters as $k=>$val) {
  126.                 $fileters[LOCALFIELDS[$k]] = $val;
  127.             }
  129.             // global 属性补充
  130.             $assetInfo = [];
  131.             if($commodity->getMainImage()) {
  132.                 $assetInfo[] = ['assetType'=>"picture", 'subtype'=>'subtypeLabel', 'subtypeLabel'=>"产品图", 'url'=>$commodity->getMainImage()];
  133.             }
  134.             $item['assetInfo'] = $assetInfo;
  136.             //$commodity = new CrispCommodity();
  137.             $item['shelfCategoryId'] = $commodity->getShelfCategoryId();
  138.             $item['productTypeDescription'] = $commodity->getProductTypeDescription();
  139.             $item['productShortDescription'] = $commodity->getProductShortDescription();
  140.             $item['technicalDataGroup'] = [["sortId"=>"4","label"=>"产品属性"]];
  141.             $item['technicalData'] = [["groupSortId"=>"4", "subHeadline"=>"", "subTechnicalData"=>$fileters]];
  142.             $data[] = $item;
  144.         }
  146.         return $this->json([
  147.             'total'=>$listing->getTotalCount(),
  148.             'items'=>$data
  149.         ]);
  150.     }
  152.     /**
  153.      * 可售状态下的物料号、产品名称、产品描述、产品主图
  154.      * @Symfony\Component\Routing\Annotation\Route("/data_trans/product/get_simple_commodity_list")
  155.      * @throws BaseSignatureException
  156.      */
  157.     function getSimpleCommodityList(Request $request):Response{
  158. //        换成秘钥的方式：ApiUrl?time=${10位时间戳}&sign=${算法生成的秘钥}
  159. //        秘钥算法：md5(${10位时间戳} + IY2IJHYY58FRVL6LOPGFFE32HUEW9LJE)
  161.         $time = $request->query->get('time');
  162.         $sign = $request->query->get('sign');
  163.         if(!$time) {
  164.             return $this->rsps(false, '缺少参数：time');
  165.         }
  166.         if(!$sign) {
  167.             return $this->rsps(false, '缺少参数：sign');
  168.         }
  170.         $myTime = time();
  171.         if($time>$myTime) {
  172.             return $this->rsps(false, '请使用当前时间戳，不能使用未来的时间');
  173.         }
  174.         if($time<$myTime-600) {
  175.             return $this->rsps(false, '时间戳过期，不能超过10分钟.params:'.$time.'-server:'.$myTime);
  176.         }
  178.         $mySign = md5($time.'IY2IJHYY58FRVL6LOPGFFE32HUEW9LJE'); // 生成的秘钥小写32位
  179.         if($mySign!=$sign) {
  180.             return $this->rsps(false, '秘钥错误 '.$mySign);
  181.         }
  183.         $params = $request->request->all();
  184.         $page = $params['page'] ?? 1;
  185.         $page = intval($page) < 1 ? 1 : intval($page);
  186.         $limit = $params['limit'] ?? 10;
  187.         $limit = intval($limit) >100 ? 100 : intval($limit);
  188.         $offset = ($page-1)*$limit;
  190.         $order = 'a.o_id desc';
  191.         if(isset($params['order'])) {
  192.             if($params['order']=='old') {
  193.                 $order = 'a.o_id asc';
  194.             }
  195.         }
  197.         $commodityClassId = CrispCommodity::classId();
  199.         $select = 'o_id id,articleId,articleDescription,mainImage, productTypeDescription,productShortDescription,productLongDescription,topFeatures';//shelfCategoryId
  200.         $sql = "select {$select} from object_{$commodityClassId} a  where a.articleStatus=1 and a.o_published=1 ";
  201.         $sqlCount = "select count(1) ct from object_{$commodityClassId} a where a.articleStatus=1 and a.o_published=1 ";
  203.         if(!empty($params['id'])) {
  204.             $id = intval($params['id']);
  205.             $sql .= " and a.o_id = {$id}";
  206.             $sqlCount .= " and a.o_id = {$id}";
  207.         }
  208.         if(!empty($params['articleId'])) {
  209.             $articleId = trim(rawurldecode($params['articleId']));
  210.             $sql .= " and a.articleId = '{$articleId}'";
  211.             $sqlCount .= " and a.articleId = '{$articleId}'";
  212.         }
  213.         if(!empty($params['keyword'])) {
  214.             $keyword = '%'.trim($params['keyword']).'%';
  215.             $sql .= " and (a.productTypeDescription like :keyword or a.articleDescription like '{$keyword}')";
  216.             $sqlCount .= " and (a.productTypeDescription like :keyword or a.articleDescription like '{$keyword}')";
  217.         }
  219.         $sql .= " order by {$order} limit {$offset}, {$limit}";
  220.         $total = Db::get()->query($sqlCount)->fetchColumn();
  221.         $items = Db::get()->query($sql)->fetchAll(\PDO::FETCH_ASSOC);
  222.         return $this->rsps(true, 'success', [
  223.             'total'=>$total,
  224.             'items'=>$items
  225.         ]);
  226.     }
  228. }