ItemController.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731
  1. <?php
  2. namespace console\controllers;
  3. use biz\ghs\classes\GhsClass;
  4. use biz\item\classes\PtItemClass;
  5. use biz\item\classes\PtItemClassClass;
  6. use biz\product\classes\XjClass;
  7. use biz\sj\classes\SjClass;
  8. use bizGhs\custom\classes\CustomClass;
  9. use biz\shop\classes\ShopClass;
  10. use bizGhs\item\classes\ItemClass;
  11. use bizGhs\item\classes\ItemClassClass;
  12. use bizGhs\order\classes\OrderClass;
  13. use bizGhs\order\classes\OrderItemClass;
  14. use bizGhs\order\classes\PurchaseOrderItemClass;
  15. use bizGhs\order\classes\StockWastageOrderClass;
  16. use bizGhs\order\classes\StockWastageOrderItemClass;
  17. use bizHd\saas\classes\ApplyClass;
  18. use bizHd\saas\models\Apply;
  19. use bizHd\saas\services\ApplyService;
  20. use common\components\dict;
  21. use common\components\imgUtil;
  22. use common\components\stringUtil;
  23. use common\components\util;
  24. use yii\console\Controller;
  25. use Yii;
  26. use bizGhs\product\classes\ProductClass;
  27. /**
  28. * 花材同步脚本 ssh 20230619
  29. */
  30. class ItemController extends Controller
  31. {
  32. public $sjId, $shopId, $sj;
  33. //【重要】将花材的分类id同步到批发销售单、批发采购单和零售销售单【小丽优先】
  34. public function actionSyncClass()
  35. {
  36. ini_set('memory_limit', '5120M');
  37. set_time_limit(0);
  38. $itemList = ItemClass::getAllByCondition(['mainId' => 10975], null, '*', null, true);
  39. if (empty($itemList)) {
  40. util::stop('没有找到花材');
  41. }
  42. foreach ($itemList as $item) {
  43. $classId = $item->classId ?? 0;
  44. $productId = $item->id ?? 0;
  45. if (!empty($classId) && !empty($productId)) {
  46. OrderItemClass::updateByCondition(['productId' => $productId], ['classId' => $classId]);
  47. \bizHd\order\classes\OrderItemClass::updateByCondition(['itemId' => $productId], ['classId' => $classId]);
  48. PurchaseOrderItemClass::updateByCondition(['productId' => $productId], ['classId' => $classId]);
  49. }
  50. }
  51. echo "ok\n";
  52. }
  53. //重新生成花材 ssh 20230920
  54. public function actionCreateItem()
  55. {
  56. //ItemClass::initItem(14128);
  57. }
  58. //包装纸丝带同步 ssh 20230525
  59. public function actionPaperSync()
  60. {
  61. $connection = Yii::$app->db;
  62. $transaction = $connection->beginTransaction();
  63. try {
  64. $oldItemList = ItemClass::getAllByCondition(['classId' => 26013, 'delStatus' => 0], null, '*');
  65. foreach ($oldItemList as $oldItem) {
  66. unset($oldItem['id']);
  67. $oldItem['classId'] = 31106;
  68. $oldItem['stock'] = 0;
  69. $oldItem['status'] = 2;
  70. $oldItem['mainId'] = 4553;
  71. $oldItem['sjId'] = 16936;
  72. $oldItem['shopId'] = 0;
  73. ItemClass::add($oldItem);
  74. }
  75. $transaction->commit();
  76. } catch (\Exception $e) {
  77. $transaction->rollBack();
  78. $msg = $e->getMessage();
  79. echo "报错了:" . $msg;
  80. }
  81. }
  82. public function actionWaste()
  83. {
  84. ini_set('memory_limit', '2045M');
  85. set_time_limit(0);
  86. $list = StockWastageOrderClass::getAllByCondition(['id>' => 0], null, '*', null, true);
  87. if (!empty($list)) {
  88. foreach ($list as $order) {
  89. $orderSn = $order->orderSn ?? '';
  90. $itemList = StockWastageOrderItemClass::getAllByCondition(['orderSn' => $orderSn], null, '*', null, true);
  91. $totalCost = 0;
  92. if (!empty($itemList)) {
  93. foreach ($itemList as $v) {
  94. $num = $v->itemNum ?? 0;
  95. $itemCost = $v->itemCost ?? 0;
  96. $totalCost = bcadd($totalCost, bcmul($num, $itemCost, 2), 2);
  97. }
  98. }
  99. $order->cost = $totalCost;
  100. $order->save();
  101. }
  102. }
  103. }
  104. public function actionWastage()
  105. {
  106. ini_set('memory_limit', '2045M');
  107. set_time_limit(0);
  108. $list = StockWastageOrderClass::getAllByCondition(['id>' => 0], null, '*', null, true);
  109. if (!empty($list)) {
  110. foreach ($list as $order) {
  111. $orderSn = $order->orderSn ?? '';
  112. $itemList = StockWastageOrderItemClass::getAllByCondition(['orderSn' => $orderSn], null, '*', null, true);
  113. $totalPrice = 0;
  114. if (!empty($itemList)) {
  115. foreach ($itemList as $v) {
  116. $num = $v->itemNum ?? 0;
  117. $itemPrice = $v->itemPrice ?? 0;
  118. $totalPrice = bcadd($totalPrice, bcmul($num, $itemPrice, 2), 2);
  119. }
  120. }
  121. $order->price = $totalPrice;
  122. $order->save();
  123. }
  124. }
  125. }
  126. //初见花季 ssh 20230223
  127. public function actionCj()
  128. {
  129. if (getenv('YII_ENV') == 'production') {
  130. $mtMainId = 10449;
  131. $ttMainId = 8502;
  132. } else {
  133. $mtMainId = 762;
  134. $ttMainId = 644;
  135. util::stop('已取消');
  136. }
  137. $list = ItemClass::getAllByCondition(['mainId' => $mtMainId], null, '*');
  138. if (!empty($list)) {
  139. echo '已经有花材了';
  140. exit();
  141. }
  142. $classList = ItemClassClass::getAllByCondition(['mainId' => $ttMainId], null, '*', null, true);
  143. if (empty($classList)) {
  144. echo '没有找到目标门店的分类';
  145. exit();
  146. }
  147. $connection = Yii::$app->db;
  148. $transaction = $connection->beginTransaction();
  149. try {
  150. foreach ($classList as $class) {
  151. $oldId = $class->id ?? 0;
  152. $cover = $class->cover ?? '';
  153. $name = $class->name ?? '';
  154. $inTurn = $class->inTurn ?? 0;
  155. $isDefault = $class->isDefault ?? 0;
  156. $newClass = [
  157. 'mainId' => $mtMainId,
  158. 'cover' => $cover,
  159. 'name' => $name,
  160. 'inTurn' => $inTurn,
  161. 'isDefault' => $isDefault,
  162. ];
  163. $newRespond = ItemClassClass::add($newClass, true);
  164. $newClassId = $newRespond->id ?? 0;
  165. $oldItemList = ItemClass::getAllByCondition(['classId' => $oldId, 'delStatus' => 0], null, '*');
  166. foreach ($oldItemList as $oldItem) {
  167. $oldItemId = $oldItem['id'];
  168. unset($oldItem['id']);
  169. $oldItem['classId'] = $newClassId;
  170. $oldItem['stock'] = 0;
  171. $oldItem['status'] = 2;
  172. $oldItem['mainId'] = $mtMainId;
  173. $oldItem['sjId'] = 0;
  174. $oldItem['shopId'] = 0;
  175. $new = ItemClass::add($oldItem, true);
  176. if (isset($oldItem['variety']) && $oldItem['variety'] == 1) {
  177. $xjList = XjClass::getAllByCondition(['itemId' => $oldItemId], null, '*');
  178. if (!empty($xjList)) {
  179. foreach ($xjList as $oneXj) {
  180. unset($oneXj['id']);
  181. unset($oneXj['sjId']);
  182. unset($oneXj['shopId']);
  183. unset($oneXj['mainId']);
  184. unset($oneXj['itemId']);
  185. unset($oneXj['ptItemId']);
  186. unset($oneXj['addTime']);
  187. unset($oneXj['updateTime']);
  188. $oneXj['mainId'] = $mtMainId;
  189. $oneXj['itemId'] = $new->id ?? 0;
  190. $oneXj['ptItemId'] = $new->itemId ?? 0;
  191. XjClass::add($oneXj);
  192. }
  193. }
  194. }
  195. }
  196. }
  197. $transaction->commit();
  198. } catch (\Exception $e) {
  199. $transaction->rollBack();
  200. $msg = $e->getMessage();
  201. echo "报错了:" . $msg;
  202. }
  203. }
  204. //美天鲜花 ssh 20230223
  205. public function actionMt()
  206. {
  207. if (getenv('YII_ENV') == 'production') {
  208. $mtMainId = 13495;
  209. $ttMainId = 52;
  210. } else {
  211. //$mtMainId = 762;
  212. //$ttMainId = 644;
  213. util::stop('测试环境未开通');
  214. }
  215. $list = ItemClass::getAllByCondition(['mainId' => $mtMainId], null, '*');
  216. if (!empty($list)) {
  217. echo '已经有花材了';
  218. exit();
  219. }
  220. $classList = ItemClassClass::getAllByCondition(['mainId' => $ttMainId], null, '*', null, true);
  221. if (empty($classList)) {
  222. echo '没有找到天天鲜花的分类';
  223. exit();
  224. }
  225. $connection = Yii::$app->db;
  226. $transaction = $connection->beginTransaction();
  227. try {
  228. foreach ($classList as $class) {
  229. $oldId = $class->id ?? 0;
  230. $cover = $class->cover ?? '';
  231. $name = $class->name ?? '';
  232. $inTurn = $class->inTurn ?? 0;
  233. $isDefault = $class->isDefault ?? 0;
  234. $newClass = [
  235. 'mainId' => $mtMainId,
  236. 'cover' => $cover,
  237. 'name' => $name,
  238. 'inTurn' => $inTurn,
  239. 'isDefault' => $isDefault,
  240. ];
  241. $newRespond = ItemClassClass::add($newClass, true);
  242. $newClassId = $newRespond->id ?? 0;
  243. $oldItemList = ItemClass::getAllByCondition(['classId' => $oldId, 'delStatus' => 0], null, '*');
  244. foreach ($oldItemList as $oldItem) {
  245. $oldItemId = $oldItem['id'];
  246. unset($oldItem['id']);
  247. $oldItem['classId'] = $newClassId;
  248. $oldItem['stock'] = 0;
  249. $oldItem['status'] = 2;
  250. $oldItem['mainId'] = $mtMainId;
  251. $oldItem['sjId'] = 0;
  252. $oldItem['shopId'] = 0;
  253. $new = ItemClass::add($oldItem, true);
  254. if (isset($oldItem['variety']) && $oldItem['variety'] == 1) {
  255. $xjList = XjClass::getAllByCondition(['itemId' => $oldItemId], null, '*');
  256. if (!empty($xjList)) {
  257. foreach ($xjList as $oneXj) {
  258. unset($oneXj['id']);
  259. unset($oneXj['sjId']);
  260. unset($oneXj['shopId']);
  261. unset($oneXj['mainId']);
  262. unset($oneXj['itemId']);
  263. unset($oneXj['ptItemId']);
  264. unset($oneXj['addTime']);
  265. unset($oneXj['updateTime']);
  266. $oneXj['mainId'] = $mtMainId;
  267. $oneXj['itemId'] = $new->id ?? 0;
  268. $oneXj['ptItemId'] = $new->itemId ?? 0;
  269. XjClass::add($oneXj);
  270. }
  271. }
  272. }
  273. }
  274. }
  275. $transaction->commit();
  276. } catch (\Exception $e) {
  277. $transaction->rollBack();
  278. $msg = $e->getMessage();
  279. echo "报错了:" . $msg;
  280. }
  281. }
  282. //花材反向更新 ./yii item/reverse-update
  283. public function actionReverseUpdate()
  284. {
  285. $shopId = 10;
  286. if (getenv('YII_ENV') != 'production') {
  287. $shopId = 36225;
  288. }
  289. $list = ProductClass::getAllByCondition(['shopId' => $shopId], null, '*', null, true);
  290. if (empty($list)) {
  291. return false;
  292. }
  293. foreach ($list as $cKey => $product) {
  294. $ptItemId = $product->itemId ?? 0;
  295. $ptItem = PtItemClass::getById($ptItemId, true);
  296. if (empty($ptItem)) {
  297. continue;
  298. }
  299. $ptItem->name = $product->name ?? '';
  300. $ptItem->py = $product->py ?? '';
  301. $ptItem->cover = $product->cover ?? '';
  302. $ptItem->ratio = $product->ratio ?? 1;
  303. $ptItem->shelfLife = $product->shelfLife ?? 7;
  304. $ptItem->weight = $product->weight ?? 0.1;
  305. $ptItem->stockWarning = $product->stockWarning ?? 5;;
  306. $ptItem->cost = $product->cost ?? 1;
  307. $ptItem->addPrice = 5;
  308. $ptItem->bigUnit = $product->bigUnit;
  309. $ptItem->smallUnit = $product->smallUnit;
  310. $ptItem->bigUnitId = $product->bigUnitId;
  311. $ptItem->smallUnitId = $product->smallUnitId;
  312. $ptItem->save();
  313. echo $product->id . " " . $product->name . " 已同步\n";
  314. }
  315. }
  316. //命令: ./yii item/sync name,cover 同步name 和cover
  317. //同步item, ptItem更新,同步到 ghsItem, ghsProduct, 同步字段(name,alias,py,cover,ratio,cover等)
  318. public function actionSync($field)
  319. {
  320. $allFiled = ['name', 'alias', 'cover', 'py', 'ratio', 'weight', 'bigUnit', 'smallUnit', 'bigUnitId', 'smallUnitId', 'stockWarning'];
  321. $fields = explode(",", $field);
  322. $syncFields = array_intersect($allFiled, $fields);
  323. if (empty($syncFields)) {
  324. echo "参数不支持";
  325. die;
  326. }
  327. $item = PtItemClass::getAllList("id", "");
  328. $itemIds = [];
  329. foreach ($item as $v) {
  330. $itemIds[] = $v['id'];
  331. }
  332. if (!empty($itemIds)) {
  333. foreach ($itemIds as $v) {
  334. $itemInfo = PtItemClass::getById($v);
  335. $data = [];
  336. foreach ($syncFields as $f) {
  337. $data[$f] = $itemInfo[$f];
  338. }
  339. ProductClass::updateByCondition(['itemId' => $v], $data);
  340. \bizGhs\item\classes\ItemClass::updateByCondition(['itemId' => $v], $data);
  341. }
  342. }
  343. echo "done";
  344. }
  345. //平台花材初始化导入 lqh 2021-05-08
  346. //命令: ./yii item/init-pt-item
  347. public function actionInitPtItem($clear = false)
  348. {
  349. $phpExcelFile = Yii::getAlias("@vendor/phpoffice/phpexcel/");
  350. require_once($phpExcelFile . 'Classes/PHPExcel/IOFactory.php');//查询接口
  351. $dir = Yii::$app->basePath;
  352. $filename = $dir . '/item.xls';
  353. $fileType = \PHPExcel_IOFactory::identify($filename); //文件名自动判断文件类型
  354. $excelReader = \PHPExcel_IOFactory::createReader($fileType);
  355. $objPHPExcel = $excelReader->load($filename);//$file_url即Excel文件的路径
  356. $sheet = $objPHPExcel->getSheet(0);//获取第一个工作表
  357. $highestRow = $sheet->getHighestRow();//取得总行数
  358. $highestColumn = $sheet->getHighestColumn(); //取得总列数
  359. $classData = [];
  360. $itemData = [];
  361. $classIdMap = [];
  362. for ($j = 2; $j <= $highestRow; $j++) {
  363. $str = '';
  364. for ($k = 'A'; $k <= $highestColumn; $k++) {
  365. $str .= $objPHPExcel->getActiveSheet()->getCell("$k$j")->getValue() . '\\';
  366. }
  367. //explode:函数把字符串分割为数组。
  368. $string = explode("\\", $str);
  369. array_pop($string);
  370. $itemName = $string[0] ?? ''; //花材名称
  371. $className = $string[1] ?? ''; //分类名称
  372. $weight = $string[2] ?? 0; //重量 kg
  373. $bigUnit = $string[3] ?? ''; //大单位名称
  374. $smallUnit = $string[4] ?? ''; //小单位名称
  375. $ratio = $string[5] ?? 0; //比例
  376. $cost = $string[6] ?? 0;//成本价
  377. $addPrice = $string[7] ?? 0; //加价
  378. $stockWarning = $string[8] ?? 0;
  379. $alias = $string[9] ?? '';
  380. $cover = $string[10] ?? '';
  381. $inTurn = $string[11] ?? 0;
  382. if ($itemName) {
  383. $py = stringUtil::py($itemName);
  384. $item = [
  385. 'name' => $itemName,
  386. 'alias' => $alias,
  387. 'py' => $py,
  388. 'cover' => $cover,
  389. 'classId' => 0,
  390. 'ratio' => $ratio,
  391. 'weight' => $weight,
  392. 'stockWarning' => $stockWarning,
  393. 'cost' => $cost,
  394. 'addPrice' => $addPrice,
  395. 'bigUnit' => $bigUnit,
  396. 'smallUnit' => $smallUnit,
  397. 'inTurn' => $inTurn,
  398. ];
  399. $itemData[$className][] = $item;
  400. $classData[] = $className;
  401. }
  402. }
  403. $classData = array_unique($classData);
  404. //写入class
  405. if ($clear) {
  406. //清空数据
  407. Yii::$app->db->createCommand()->truncateTable('xhPtItemClass')->execute();
  408. Yii::$app->db->createCommand()->truncateTable('xhPtItem')->execute();
  409. }
  410. foreach ($classData as $v) {
  411. $addClass = PtItemClassClass::add(['name' => $v, 'inTurn' => 0, 'group' => 0]);
  412. $classIdMap[$v] = $addClass['id'];
  413. }
  414. $insertItemData = [];
  415. foreach ($itemData as $k => $v) {
  416. $classId = $classIdMap[$k] ?? 0;
  417. if ($classId) {
  418. foreach ($v as $i) {
  419. $i['classId'] = $classId;
  420. $insertItemData[] = $i;
  421. }
  422. }
  423. }
  424. if (!empty($insertItemData)) {
  425. PtItemClass::batchAdd($insertItemData);
  426. }
  427. echo "done";
  428. }
  429. //供货商初始化 ./yii item/gys ./yii.bat item/gys
  430. public function actionGys()
  431. {
  432. $phpExcelFile = Yii::getAlias("@vendor/phpoffice/phpexcel/");
  433. require_once($phpExcelFile . 'Classes/PHPExcel/IOFactory.php');//查询接口
  434. $dir = Yii::$app->basePath;
  435. $filename = $dir . '/gys.xls';
  436. $fileType = \PHPExcel_IOFactory::identify($filename); //文件名自动判断文件类型
  437. $excelReader = \PHPExcel_IOFactory::createReader($fileType);
  438. $objPHPExcel = $excelReader->load($filename);//$file_url即Excel文件的路径
  439. $sheet = $objPHPExcel->getSheet(0);//获取第一个工作表
  440. $highestRow = $sheet->getHighestRow();//取得总行数
  441. $highestColumn = $sheet->getHighestColumn(); //取得总列数
  442. $changeData = [];
  443. for ($j = 2; $j <= $highestRow; $j++) {
  444. $str = '';
  445. for ($k = 'A'; $k <= $highestColumn; $k++) {
  446. $str .= $objPHPExcel->getActiveSheet()->getCell("$k$j")->getValue() . '\\';
  447. }
  448. //explode:函数把字符串分割为数组。
  449. $string = explode("\\", $str);
  450. array_pop($string);
  451. array_push($changeData, $string);
  452. }
  453. if (!empty($changeData)) {
  454. $mobileList = array_values(array_column($changeData, 1));
  455. $ptStyle = dict::getDict('ptStyle', 'kmGhs');
  456. Yii::$app->params['ptStyle'] = $ptStyle;
  457. $has = Apply::find()->where(['in', 'mobile', $mobileList])->andWhere(['style' => $ptStyle])->all();
  458. if (!empty($has)) {
  459. echo "这些已经添加过了,请先删除:\n";
  460. foreach ($has as $item) {
  461. echo $item->name . ' ' . $item->mobile . "\n";
  462. }
  463. exit();
  464. }
  465. if (getenv('YII_ENV') == 'production') {
  466. $this->sjId = 12367;
  467. $this->shopId = 10;
  468. } else {
  469. $this->sjId = 12615;
  470. $this->shopId = 36119;
  471. }
  472. foreach ($changeData as $currentKey => $currentData) {
  473. $mobile = $currentData[1] ?? '';
  474. $name = $currentData[0] ?? '';
  475. $address = $currentData[2] ?? '';
  476. if (stringUtil::isMobile($mobile) == false) {
  477. echo "请填写正确的手机号 \n";
  478. continue;
  479. }
  480. if (empty($name)) {
  481. echo "{$mobile} 名称不能为空 \n";
  482. continue;
  483. }
  484. if (stringUtil::getWordNum($name) > 8) {
  485. echo "{$mobile} 名称不能超过8个汉字 \n";
  486. continue;
  487. }
  488. $has = ApplyClass::getByCondition(['name' => $name, 'style' => SjClass::STYLE_KM_SUPPLIER]);
  489. if (!empty($has)) {
  490. echo "{$mobile} 名称已经存在 \n";
  491. continue;
  492. }
  493. $has = ApplyClass::getByCondition(['mobile' => $mobile, 'style' => SjClass::STYLE_KM_SUPPLIER]);
  494. if (!empty($has)) {
  495. echo "{$mobile} 手机号已经添加过 \n";
  496. continue;
  497. }
  498. $connection = Yii::$app->db;
  499. $transaction = $connection->beginTransaction();
  500. try {
  501. $sjId = $this->sjId;
  502. $shopId = $this->shopId;
  503. $sjName = $this->sj->name ?? '';
  504. $applyData = [
  505. 'name' => $name,
  506. 'licenseNo' => $mobile,
  507. 'certType' => ApplyClass::CERT_TYPE_MOBILE,
  508. 'mobile' => $mobile,
  509. 'introSjId' => $sjId,
  510. 'introSjName' => $sjName,
  511. 'introShopId' => $shopId,
  512. 'introStyle' => SjClass::STYLE_SUPPLIER,
  513. 'from' => ApplyClass::FROM_GHS,
  514. 'style' => dict::getDict('ptStyle', 'kmGhs'),
  515. 'address' => $address,
  516. 'status' => ApplyClass::STATUS_PASS,
  517. 'replace' => 1,//1表示供货商添加的客户或供货商
  518. ];
  519. $apply = ApplyService::replaceKmGhs($applyData);
  520. $id = $apply['id'] ?? 0;
  521. $respond = ApplyService::pass($id);
  522. $currentShop = $respond['shop'] ?? [];
  523. $sj = $respond['sj'] ?? [];
  524. $currentSjId = $sj['id'] ?? 0;
  525. $currentShopId = $currentShop->id ?? 0;
  526. ApplyClass::updateById($id, ['sjId' => $currentSjId, 'shopId' => $currentShopId]);
  527. if (empty($currentShopId)) {
  528. echo "{$mobile} 供货商添加失败 \n ";
  529. continue;
  530. }
  531. GhsClass::build($currentShopId, $shopId, 1);
  532. $transaction->commit();
  533. echo "{$mobile} 供货商添加成功!\n";
  534. } catch (\Exception $exception) {
  535. $transaction->rollBack();
  536. echo "{$mobile} 供货商添加失败,原因:" . $exception->getMessage() . "\n";
  537. }
  538. }
  539. }
  540. }
  541. //客户初始化 ./yii item/custom ./yii.bat item/custom
  542. public function actionCustom()
  543. {
  544. $phpExcelFile = Yii::getAlias("@vendor/phpoffice/phpexcel/");
  545. require_once($phpExcelFile . 'Classes/PHPExcel/IOFactory.php');//查询接口
  546. $dir = Yii::$app->basePath;
  547. $filename = $dir . '/custom.xls';
  548. $fileType = \PHPExcel_IOFactory::identify($filename); //文件名自动判断文件类型
  549. $excelReader = \PHPExcel_IOFactory::createReader($fileType);
  550. $objPHPExcel = $excelReader->load($filename);//$file_url即Excel文件的路径
  551. $sheet = $objPHPExcel->getSheet(0);//获取第一个工作表
  552. $highestRow = $sheet->getHighestRow();//取得总行数
  553. $highestColumn = $sheet->getHighestColumn(); //取得总列数
  554. $changeData = [];
  555. for ($j = 2; $j <= $highestRow; $j++) {
  556. $str = '';
  557. for ($k = 'A'; $k <= $highestColumn; $k++) {
  558. $str .= $objPHPExcel->getActiveSheet()->getCell("$k$j")->getValue() . '\\';
  559. }
  560. //explode:函数把字符串分割为数组。
  561. $string = explode("\\", $str);
  562. array_pop($string);
  563. array_push($changeData, $string);
  564. }
  565. if (!empty($changeData)) {
  566. $mobileList = array_values(array_column($changeData, 1));
  567. $ptStyle = dict::getDict('ptStyle', 'hd');
  568. Yii::$app->params['ptStyle'] = $ptStyle;
  569. $has = Apply::find()->where(['in', 'mobile', $mobileList])->andWhere(['style' => $ptStyle])->all();
  570. if (!empty($has)) {
  571. echo "这些已经添加过了,请先删除:\n";
  572. foreach ($has as $item) {
  573. echo $item->name . ' ' . $item->mobile . "\n";
  574. }
  575. exit();
  576. }
  577. if (getenv('YII_ENV') == 'production') {
  578. $this->sjId = 12367;
  579. $this->shopId = 10;
  580. } else {
  581. $this->sjId = 12615;
  582. $this->shopId = 36119;
  583. }
  584. $shop = ShopClass::getById($this->shopId, true);
  585. $sj = SjClass::getById($this->sjId, true);
  586. $this->sj = $sj;
  587. foreach ($changeData as $currentKey => $currentData) {
  588. $mobile = $currentData[1] ?? '';
  589. $name = $currentData[0] ?? '';
  590. $address = $currentData[2] ?? '';
  591. if (empty($name)) {
  592. echo "{$mobile} 名称不能为空 \n";
  593. continue;
  594. }
  595. if (stringUtil::getWordNum($name) > 8) {
  596. echo "{$mobile} 名称不能超过8个汉字 \n";
  597. continue;
  598. }
  599. if (stringUtil::isMobile($mobile) == false) {
  600. echo "{$mobile} 手机号错误 \n";
  601. continue;
  602. }
  603. $has = SjClass::getByCondition(['name' => $name, 'style' => SjClass::STYLE_RETAIL]);
  604. if (!empty($has)) {
  605. echo "{$mobile} 名称已经存在 \n";
  606. continue;
  607. }
  608. $has = ApplyClass::getByCondition(['mobile' => $mobile, 'style' => SjClass::STYLE_RETAIL]);
  609. if (!empty($has)) {
  610. echo "{$mobile} 手机号已经添加过 \n";
  611. continue;
  612. }
  613. $connection = Yii::$app->db;
  614. $transaction = $connection->beginTransaction();
  615. try {
  616. $sjId = $this->sjId;
  617. $shopId = $this->shopId;
  618. $sjName = $this->sj->name ?? '';
  619. $city = $shop->city ?? '';
  620. $dist = $shop->dist ?? '';
  621. $applyData = [
  622. 'name' => $name,
  623. 'licenseNo' => $mobile,
  624. 'certType' => ApplyClass::CERT_TYPE_MOBILE,
  625. 'mobile' => $mobile,
  626. 'introSjId' => $sjId,
  627. 'introSjName' => $sjName,
  628. 'introShopId' => $shopId,
  629. 'introStyle' => SjClass::STYLE_SUPPLIER,
  630. 'from' => ApplyClass::FROM_GHS,
  631. 'style' => SjClass::STYLE_RETAIL,
  632. 'province' => $shop->province ?? '',
  633. 'city' => $city,
  634. 'dist' => $dist,
  635. 'address' => $address,
  636. 'status' => ApplyClass::STATUS_PASS,
  637. 'replace' => 1,//1表示供货商添加的客户
  638. ];
  639. $apply = ApplyService::replaceRetail($applyData);
  640. $id = $apply['id'] ?? 0;
  641. $respond = ApplyService::pass($id);
  642. $currentShop = $respond['shop'] ?? [];
  643. $sj = $respond['sj'] ?? [];
  644. $hdSjId = $sj['id'] ?? 0;
  645. $hdShopId = $currentShop->id ?? 0;
  646. ApplyClass::updateById($id, ['sjId' => $hdSjId, 'shopId' => $hdShopId]);
  647. if (empty($hdShopId)) {
  648. echo "{$mobile} 客户添加失败 \n";
  649. continue;
  650. }
  651. $custom = CustomClass::build($this->shopId, $hdShopId);
  652. $custom['avatar'] = imgUtil::groupImg($custom['avatar']);
  653. $transaction->commit();
  654. echo "{$mobile} 添加成功! \n";
  655. } catch (\Exception $exception) {
  656. $transaction->rollBack();
  657. echo "{$mobile} 添加失败,报错:" . $exception->getMessage() . "\n";
  658. }
  659. }
  660. }
  661. }
  662. //更新特价 ssh 20230630
  663. public function actionDiscount()
  664. {
  665. ini_set('memory_limit', '2045M');
  666. set_time_limit(0);
  667. $list = ItemClass::getAllByCondition(['discountPrice>' => 0,], null, '*', null, true);
  668. if (!empty($list)) {
  669. foreach ($list as $item) {
  670. $discountPrice = $item->discountPrice ?? 0;
  671. $skMore = $item->skMore ?? 0;
  672. $addPrice = $item->addPrice ?? 0;
  673. $diff = bcsub($skMore, $addPrice, 2);
  674. if ($diff > 0) {
  675. $item->skDiscountPrice = bcadd($discountPrice, $diff, 2);
  676. } else {
  677. $item->skDiscountPrice = $discountPrice;
  678. }
  679. $item->hjDiscountPrice = $discountPrice;
  680. $item->save();
  681. }
  682. }
  683. }
  684. }