CRMEB多种营销 商家寄件单商户商城系统DIY、好友代付BZ v5.0.0-to-v5.1.0(20230710)（更新包）

<?php // +---------------------------------------------------------------------- // | CRMEB [ CRMEB赋能开发者，助力企业发展 ] // +---------------------------------------------------------------------- // | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved. // +---------------------------------------------------------------------- // | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权 // +---------------------------------------------------------------------- // | Author: CRMEB Team <[email protected]> // +---------------------------------------------------------------------- namespace app\adminapi\controller; use app\Request; use app\services\activity\coupon\StoreCouponIssueServices; use app\services\activity\coupon\StoreCouponProductServices; use app\services\order\StoreOrderCartInfoServices; use app\services\order\StoreOrderCreateServices; use app\services\order\StoreOrderRefundServices; use app\services\order\StoreOrderServices; use app\services\system\UpgradeServices; use app\services\user\UserBillServices; use app\services\user\UserBrokerageServices; use app\services\user\UserMoneyServices; use app\services\user\UserBrokerageFrozenServices; use think\facade\Db; use think\facade\Env; class UpgradeController { /** * @var UpgradeServices */ private $services; /** * UpgradeController constructor. * @param UpgradeServices $services */ public function __construct(UpgradeServices $services) { $this->services = $services; } /** * 升级程序页面 * @param Request $request * @return \think\response\View */ public function index(Request $request) { $data = $this->upData(); $Title = "CRMEB升级程序"; $Powered = "Powered by CRMEB"; //获取当前版本号 $version_now = $this->getversion('.version')['version']; $version_new = $data['new_version']; $isUpgrade = true; $executeIng = false; return view('/upgrade/step1', [ 'title' => $Title, 'powered' => $Powered, 'version_now' => $version_now, 'version_new' => $version_new, 'isUpgrade' => json_encode($isUpgrade), 'executeIng' => json_encode($executeIng), 'next' => 1, 'action' => 'upgrade' ]); } /** * 获取当前版本号 * @return array */ public function getversion($str) { $version_arr = []; $curent_version = @file(app()->getRootPath() . $str); foreach ($curent_version as $val) { list($k, $v) = explode('=', $val); $version_arr[$k] = $v; } return $version_arr; } /** * 写入升级过程 * @param string $field * @param int $n * @return bool */ public function setIsUpgrade(string $field, int $n = 0) { $upgrade = parse_ini_file(public_path('upgrade') . '.upgrade'); if ($n) { if (!is_array($upgrade)) { $upgrade = []; } $string = ''; foreach ($upgrade as $key => $item) { $string .= $key . '=' . $item . "\r\n"; } $string .= $field . '=' . $n . "\r\n"; file_put_contents(public_path('upgrade') . '.upgrade', $string); return true; } else { if (!is_array($upgrade)) { return false; } return isset($upgrade[$field]); } } public function upgrade(Request $request) { list($sleep, $page, $prefix) = $request->getMore([ ['sleep', 0], ['page', 1], ['prefix', 'eb_'], ], true); $data = $this->upData(); $code_now = $this->getversion('.version')['version_code']; if ($data['new_code'] == $code_now) { return app('json')->success(['sleep' => -1]); } $sql_arr = []; foreach ($data['update_sql'] as $items) { if ($items['code'] > $code_now) { $sql_arr[] = $items; } } //sql 执行完成，开始执行修改数据 if (!isset($sql_arr[$sleep])) { // $limit = 100; // if (!$this->setIsUpgrade('money')) { // $res = $this->handleMoney((int)$sleep, (int)$page, (int)$limit); // return app('json')->success($res); // } elseif (!$this->setIsUpgrade('brokerage')) { // $res = $this->handleBrokerage((int)$sleep, (int)$page, (int)$limit); // return app('json')->success($res); // } elseif (!$this->setIsUpgrade('orderRefund')) { // $res = $this->handleOrderRefund((int)$sleep, (int)$page, (int)$limit); // return app('json')->success($res); // } else { // file_put_contents(app()->getRootPath() . '.version', "version=" . $data['new_version'] . "\nversion_code=" . $data['new_code']); // return app('json')->success(['sleep' => -1]); // } // $limit = 100; // if (!$this->setIsUpgrade('cartInfo')) { // $res = $this->handleCartInfo((int)$sleep, (int)$page, (int)$limit); // return app('json')->success($res); // } else { // file_put_contents(app()->getRootPath() . '.version', "version=" . $data['new_version'] . "\nversion_code=" . $data['new_code'] . "\napp_id=ze7x9rxsv09l6pvsyo" . "\napp_key=fuF7U9zaybLa5gageVQzxtxQMFnvU2OI"); // $this->services->generateSignature(); // return app('json')->success(['sleep' => -1]); // } // $limit = 100; // if (!$this->setIsUpgrade('coupon')) { // $res = $this->handleCoupon((int)$sleep, (int)$page, (int)$limit); // return app('json')->success($res); // } else { // $this->setEnv(); // file_put_contents(app()->getRootPath() . '.version', "version=" . $data['new_version'] . "\nversion_code=" . $data['new_code'] . "\nplatform=CRMEB\napp_id=ze7x9rxsv09l6pvsyo" . "\napp_key=fuF7U9zaybLa5gageVQzxtxQMFnvU2OI"); // $this->services->generateSignature(); // return app('json')->success(['sleep' => -1]); // } file_put_contents(app()->getRootPath() . '.version', "version=" . $data['new_version'] . "\nversion_code=" . $data['new_code'] . "\nplatform=CRMEB\napp_id=ze7x9rxsv09l6pvsyo" . "\napp_key=fuF7U9zaybLa5gageVQzxtxQMFnvU2OI"); $this->services->generateSignature(); return app('json')->success(['sleep' => -1]); } $sql = $sql_arr[$sleep]; Db::startTrans(); try { if ($sql['type'] == 1) { if (isset($sql['findSql']) && $sql['findSql']) { $table = $prefix . $sql['table']; $findSql = str_replace('@table', $table, $sql['findSql']); if (!empty(Db::query($findSql))) { $item['table'] = $table; $item['status'] = 1; $item['error'] = $table . '表已存在'; $item['sleep'] = $sleep + 1; $item['add_time'] = date('Y-m-d H:i:s', time()); Db::commit(); return app('json')->success($item); } } if (isset($sql['sql']) && $sql['sql']) { $upSql = $sql['sql']; $upSql = str_replace('@table', $table, $upSql); Db::execute($upSql); $item['table'] = $table; $item['status'] = 1; $item['error'] = $table . '表添加成功'; $item['sleep'] = $sleep + 1; $item['add_ti