RefundController.php 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. <?php
  2. namespace console\controllers;
  3. use bizGhs\order\classes\RefundOrderItemClass;
  4. use bizGhs\order\models\RefundOrder;
  5. use bizHd\cg\classes\CgRefundClass;
  6. use bizHd\cg\classes\CgRefundItemClass;
  7. use common\components\noticeUtil;
  8. use yii\console\Controller;
  9. use Yii;
  10. class RefundController extends Controller
  11. {
  12. public function actionStatus()
  13. {
  14. ini_set('memory_limit', '2045M');
  15. set_time_limit(0);
  16. $query = new \yii\db\Query();
  17. $query->from(RefundOrder::tableName());
  18. $query->where(['>', 'id', 0]);
  19. $query->orderBy('addTime ASC');
  20. foreach ($query->batch() as $batchOrder) {
  21. foreach ($batchOrder as $refund) {
  22. $connection = Yii::$app->db;
  23. $transaction = $connection->beginTransaction();
  24. $orderSn = $refund['orderSn'] ?? '';
  25. try {
  26. $status = $refund['status'] ?? 0;
  27. $addTime = $refund['addTime'] ?? '';
  28. $updateTime = $refund['updateTime'] ?? '';
  29. RefundOrderItemClass::updateByCondition(['orderSn' => $orderSn], ['status' => $status, 'addTime' => $addTime, 'updateTime' => $updateTime]);
  30. $cgRefundId = $refund['cgRefundId'] ?? 0;
  31. $cgRefund = CgRefundClass::getById($cgRefundId, true);
  32. if (empty($cgRefund)) {
  33. echo "{$orderSn} 没有找到采购的退款信息\n";
  34. continue;
  35. }
  36. $cgRefundStatus = $cgRefund->status;
  37. $cgOrderSn = $cgRefund->orderSn ?? '';
  38. $addTime = $cgRefund->addTime;
  39. $updateTime = $cgRefund->updateTime;
  40. CgRefundItemClass::updateByCondition(['orderSn' => $cgOrderSn], ['status' => $cgRefundStatus, 'addTime' => $addTime, 'updateTime' => $updateTime]);
  41. $transaction->commit();
  42. } catch (\Exception $e) {
  43. $transaction->rollBack();
  44. $msg = $e->getMessage();
  45. noticeUtil::push("{$orderSn} 报错了:{$msg}", '15280215347');
  46. }
  47. }
  48. }
  49. }
  50. //退款数据更新 ./yii refund/update
  51. public function actionUpdate()
  52. {
  53. }
  54. }