PurchaseController.php 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. <?php
  2. namespace console\controllers;
  3. use bizHd\purchase\classes\PurchaseClass;
  4. use bizHd\purchase\models\Purchase;
  5. use bizHd\purchase\services\PurchaseService;
  6. use common\components\dict;
  7. use common\components\noticeUtil;
  8. use yii\console\Controller;
  9. use Yii;
  10. class PurchaseController extends Controller
  11. {
  12. //采购订单过期变更 shish 2021.5.14
  13. // ./yii purchase/expire-order
  14. // /usr/local/nginx/html/huahuibao/yii purchase/expire-order
  15. public function actionExpireOrder()
  16. {
  17. $query = new \yii\db\Query();
  18. $query->from(Purchase::tableName());
  19. $date = date("Y-m-d H:i:s");
  20. $query->where(['status' => PurchaseClass::STATUS_UN_PAY])->andWhere(['<=', 'deadline', $date]);
  21. $query->orderBy('deadline ASC');
  22. Yii::$app->params['ptStyle'] = dict::getDict('ptStyle', 'hd');
  23. //如果有报错,抛出异常
  24. Yii::$app->params['errorReport'] = 1;
  25. $arr = [];
  26. foreach ($query->batch() as $purchases) {
  27. foreach ($purchases as $purchase) {
  28. $connection = Yii::$app->db;//事务处理
  29. $transaction = $connection->beginTransaction();
  30. $id = $purchase['id'] ?? 0;
  31. $orderSn = $purchase['orderSn'] ?? '';
  32. try {
  33. $current = PurchaseClass::getById($id, true);
  34. PurchaseService::expire($current);
  35. $transaction->commit();
  36. //noticeUtil::push("采购单已过期,库存已回滚 订单号:{$orderSn}", '15280215347');
  37. } catch (\Exception $e) {
  38. $transaction->rollBack();
  39. $msg = $e->getMessage();
  40. noticeUtil::push("采购单过期处理报错了!订单号:{$orderSn},错误信息:{$msg}", '15280215347');
  41. }
  42. $log = "过期的采购单:{$id} json:" . json_encode($purchase);
  43. $arr[] = $log;
  44. }
  45. }
  46. if (!empty($arr)) {
  47. foreach ($arr as $item) {
  48. Yii::info($item);
  49. }
  50. }
  51. }
  52. }