use modules\v1\models\TJProjects;
use modules\v1\models\TJProjectsDetails;
use Faker\Provider\Uuid;

// 创建 TJ_Projects 实例
$project = new TJProjects();
$project->ProjectName = $params['ProjectName'] ?? '';
$project->BeEvaluatedCompanyName = $params['BeEvaluatedCompanyName'] ?? '';
$project->ProjectCode = $params['ProjectCode'] ?? '';
$project->ProjectState = $params['ProjectState'] ?? '已立项';
$project->BeEvaluatedCompanyIndustry = $params['BeEvaluatedCompanyIndustry'] ?? '';
$project->IndustryId = $params['IndustryId'] ?? '';
$project->IndustryModel = $params['IndustryModel'] ?? '';
$project->AssessmentPurposes = $params['AssessmentPurposes'] ?? '';
$project->EvaluationObject = $params['EvaluationObject'] ?? '';
$project->EvaluationObjectId = $params['EvaluationObjectId'] ?? 0;
$project->EvaluationObjectType = $params['EvaluationObjectType'] ?? 0;
$project->ValueType = $params['ValueType'] ?? '';
$project->AppraiseBaseDay = $params['AppraiseBaseDay'] ?? date('Y-m-d');
$project->HisLimit = 0;
$project->HisMonth = 0;
$project->EstimateLimit = 0;
$project->EstimateMonth = 0;
$project->HisLimit1 = 0;
$project->HisMonth1 = 0;
$project->MeasurementUnit = $params['MeasurementUnit'] ?? '元';
$project->MeasurementUnitCurrency = $params['MeasurementUnitCurrency'] ?? '人民币';
$project->UserId = $params['UserId'] ?? 1;
$project->OrganId = $params['OrganId'] ?? 0;
$project->CreatedAt = time();
$project->UUID = Uuid::uuid();
$project->ProjectState2 = $params['ProjectState2'] ?? '已立项';
$project->ShowBeEvaluatedCompanyIndustry = $params['ShowBeEvaluatedCompanyIndustry'] ?? '';
$project->ShowIndustryId = $params['ShowIndustryId'] ?? '';
$project->HisDay = 0;
$project->EstimateDay = 0;
$project->OriginalMbFile = $params['OriginalMbFile'] ?? '';
$project->IncomeTemplateId = $params['IncomeTemplateId'] ?? 0;

// 必填但你没传的字段，补默认值
$project->TemId = $params['TemId'] ?? 0;  // 可传行业模版ID或通用默认ID
$project->IsListed = 0;
$project->FiscalStatementType = '一般口径'; // 可自定义
$project->Status = 1;
$project->Status1 = 1;

// 入库
if (!$project->save()) {
    throw new \Exception("项目保存失败：" . json_encode($project->getErrors()));
}

// 新建 TJ_Projects_Details
$projectDetails = new TJProjectsDetails();
$projectDetails->UUID = Uuid::uuid();
$projectDetails->ProjectId = $project->Id;
$projectDetails->ProjectLevel = $params['ProjectLevel'] ?? 'A';
$projectDetails->Source = $params['Source'] ?? 1;
$projectDetails->PrincipalInformation = $params['PrincipalInformation'] ?? '';
$projectDetails->tenant_id = $params['tenant_id'] ?? 0;

if (!$projectDetails->save()) {
    throw new \Exception("项目详情保存失败：" . json_encode($projectDetails->getErrors()));
}

// 成功后返回 projectId
$logProjectId = $project->Id;

<?php
/**
* Created by PhpStorm.
* User: han
* Date: 2021/4/2
* Time: 18:01
*/

namespace modules\v1\models\TJProjects;


use app\modules\api\common\CreateProjectJob;
use app\modules\api\common\Helper;
use app\modules\api\common\Util;
use app\modules\api\components\amqpQueue;
use app\modules\api\components\Market;
use app\modules\api\components\SocketRequest;
use app\modules\api\models\forms\User;
use app\modules\api\modules\v1\enum\BusinessOptionEnum;
use app\modules\api\modules\v1\exception\RequestParamException;
use app\modules\api\modules\v1\models\Audit\ProjectsAuditRelationship;
use app\modules\api\modules\v1\models\CommonKeyParams;
use app\modules\api\modules\v1\models\ErrorLog\ErrorLogModel;
use app\modules\api\modules\v1\models\OriginDomainTemplates;
use app\modules\api\modules\v1\models\ProjectStatistics\TJProjectsDetailsSub;
use app\modules\api\modules\v1\models\ProjectStatistics\TJProjectStatistics;
use app\modules\api\modules\v1\models\ProjectsViaMethod;
use app\modules\api\modules\v1\models\ProjectTeam\TeamModel;
use app\modules\api\modules\v1\models\PurposeObjectType\TJAssesmentTargetSub;
use app\modules\api\modules\v1\models\ShareholdingStructure;
use app\modules\api\modules\v1\models\TemplateKeyParams\TJKeyParams;
use app\modules\api\modules\v1\models\TJAppraisalProcedureModel\TJAppraisalProcedureSub;
use app\modules\api\modules\v1\models\TJFieldToChinese;
use app\modules\api\modules\v1\models\TJFiles\TJFiles;
use app\modules\api\modules\v1\models\TJFrame\Frame;
use app\modules\api\modules\v1\models\TJIndustryTemplate;
use app\modules\api\modules\v1\models\TJIndustryTemplateModel\TJIndustryTemplateModel;
use app\modules\api\modules\v1\models\TJProjectsAuditRelationship;
use app\modules\api\modules\v1\models\TJProjectsDetails;
use app\modules\api\modules\v1\models\TJProjectManage\TJProjectManage;
use app\modules\api\modules\v1\traits\dataExchangeTrait;
use common\HelperV2;
use Faker\Provider\Uuid;
use Overtrue\Pinyin\Pinyin;
use Yii;
use yii\db\Exception;
use yii\queue\amqp_interop\Queue;
use yii\web\ServerErrorHttpException;

/** diy在更新模版后必须要清空缓存 */
class CreateSingleAsset
{

   static public $scenario = 'create';

   static public function do ($params,&$logProjectId = null){

       $data = ['msg' => '', 'code' => 0];
       $map = Yii::$app->params['projectMap'];
       $err = '';
       // 成本法模版临时增加
       $templateNumber = isset($params['TemplateNumber']) ? $params['TemplateNumber'] : '' ;
       $costTemplateId = isset($params['CostTemplateId']) ? $params['CostTemplateId'] : '';
       $marketTemplateId = isset($params['marketTemplateId']) ? $params['marketTemplateId'] : '';
       try {
           if (isset($params['gid'])) {
               $except = ['id', 'isShow', 'AppraisalProcedureSub', 'creator', 'createTime:datetime', 'updateTime:datetime', 'currentStep', 'currentStep1', 'auditorCode', 'auditorName', 'auditor'];
           } else {
               $except = ['id', 'isShow', 'AppraisalProcedureSub', 'creator', 'createTime:datetime', 'updateTime:datetime', 'currentStep', 'currentStep1', 'auditorCode', 'auditorName', 'auditor', 'gid'];
           }
           dataExchangeTrait::exchange(
               $map['TJProjects'],
               $params,
               $result,
               $except,
               ['industryId', 'beEvaluatedIndustry', 'region', 'AppraisalProcedureSub']
           );
           Yii::error($result, '调整后参数');
       } catch (\yii\base\Exception $e) {
           $err = $e->getMessage();
       }

       if (empty($result['IndustryId'])) {
           $msg = '项目创建失败，行业不能为空！';
           $log = ErrorLogModel::insertErrorLog('p1003',$msg,serialize($msg),0,ErrorLogModel::PROJECT_TYPE);
           return  $data = ['msg' => $msg, 'code' => 0];
       }

       // 处理有限期模型，1有限期2无限期
       if ($result['AppraisalProcedure1'] == 1 && $result['appraisalProcedureATimeLimit'] == 1) {
           if ($result['EstimateLimitEnd'] <= $result['AppraiseBaseDay']) {
               $msg = '有限期预测期截止日期必须大于评估基准日！';
               $log = ErrorLogModel::insertErrorLog('p1004',$msg,serialize($msg),0,ErrorLogModel::PROJECT_TYPE);
               return  $data = ['msg' => $msg, 'code' => 0];
           }
           $result['EstimateLimit'] = $result['EstimateLimit1'] = 0;
       }

       if (!isset($params['appraisalProcedureA'])) $params['appraisalProcedureA'] = 0;
       if (!isset($params['appraisalProcedureB'])) $params['appraisalProcedureB'] = 0;
       if (!isset($params['appraisalProcedureC'])) $params['appraisalProcedureC'] = 0;
       if (!isset($result['OrganId']) || !$result['OrganId']) {
           $organId = Frame::find()->where(['Id' => $result['WorkingGroupId'] ?? 0])->select("ParentId")->scalar();
           $result['OrganId'] = $organId ? $organId : 0;
       }
   
       /** @var TJIndustryTemplate $template */
       $template = TJIndustryTemplate::find()
          ->where(['ModelId' => $params['modelId'] ?? 0, 'IsDeleted' => 0, 'IsInUse' => 1])
          ->one();
       $transaction = Yii::$app->db->beginTransaction();
       try {
           /* @var $model TJProjectStatistics */
           $model = new TJProjectStatistics();
           $model->setScenario(self::$scenario);

           $model->loadDefaultValues()
               ->setAttributes($result, false);
           $model->ListingPlace = 'None';
           $model->CurrentStep = 4; // 领域模型取消前面步骤
           $model->ProjectState = $params['appraisalProcedureA'] == 1 ? TJProjectStatistics::PROJECTS_INDEX_STATISTICS_ITEM['projectApproval'] : '';
           $model->ProjectState2 = $params['appraisalProcedureB'] == 1 ? TJProjectStatistics::PROJECTS_INDEX_STATISTICS_ITEM['projectApproval'] : '';
           $model->subMethod = isset($params['AppraisalProcedureSub']) ?? $params['AppraisalProcedureSub'];
           $model->HisLimit1 = $model->HisLimit = $result['HisLimit'] ?? 0;
           $model->HisMonth1 = $model->HisMonth = $result['HisMonth'] ?? 0;
           $model->EstimateLimit = $result['EstimateLimit'] ?? 0;
           $model->HisMonth1 = $model->HisMonth = $result['HisMonth'] ?? 0;
           $model->CreatedAt = $model->UpdatedAt = time();
           $model->OldWorkingGroupId = $model->WorkingGroupId;
           $model->IndustryModel = $result['IndustryModel'];
//             isset($result['IndustryModel']) && !empty($result['IndustryModel']) ? $result['IndustryModel'] : TJIndustryTemplateModel::find()
//             ->where(['Id' => $result['IncomeTemplateId']])
//             ->select('TempName')
//             ->scalar();
           // 创建入库的时候将不同评估方法基准日入库，保持跟共同基准日一致
           $model->IncomeAppraiseBaseDay = $model->MarketAppraiseBaseDay = $model->ForcostAppraiseBaseDay = $model->AppraiseBaseDay;
           $model->BaseDaySnycTipsOption = BusinessOptionEnum::calculateValidVal(TJProjectStatistics::EVALUATION_METHOD_INCOME) + BusinessOptionEnum::calculateValidVal(TJProjectStatistics::EVALUATION_METHOD_MARKET) + BusinessOptionEnum::calculateValidVal(TJProjectStatistics::EVALUATION_METHOD_FINAL_COST);
           $appraisalProcedureC = $params['appraisalProcedureC'] ?? 0;
           $model->cost = $appraisalProcedureC;
           // 成本法原始模板检查
           yii::error($appraisalProcedureC);
           // 是否新成本法值，1及其他为否2是
           $isNewForcost = TJIndustryTemplate::TEMPLATE_STAGE_OLD; // TJIndustryTemplate::checkNewForcostTemplate($params['CostTemplateId']);
           // 成本法原始模板检查，提炼出公共方法，2024年06月18日
           if($appraisalProcedureC == 1){
               // 成本法原始模板检查，以下提炼出公共方法
               if ($msg = HelperV2::checkCostTemplate($params, $err, $model, $isNewForcost)) {
                   return $msg;
               }
           }

           // 市场法原始模板检查
           if($marketTemplateId  && $params['appraisalProcedureB'] == 1){

               $mTemplate = TJIndustryTemplate::find()
                   ->where(['Id' => $marketTemplateId, 'IsDeleted' => 0, 'IsInUse' => 1])
                   ->one();

               if (!$mTemplate) {
                   $err .= "未能查找到市场法行业模板文件，无法创建项目";
                   $log = ErrorLogModel::insertErrorLog('p1007','未能查找到市场法行业模板文件，无法创建项目',serialize('未能查找到市场法行业模板文件，无法创建项目'),0,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::MARKET_METHOD);
                   throw new Exception($err);
               }

               $marketTemplatePath = $mTemplate->TemplatePath;
               if (empty($marketTemplatePath) || !file_exists($file = Yii::$app->basePath . $marketTemplatePath)) {
                   $err .= "市场法法模板不存在，无法创建项目！";
                   $log = ErrorLogModel::insertErrorLog('p1008','市场法模板不存在，无法创建项目！',serialize('市场法模板不存在，无法创建项目！'),0,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::MARKET_METHOD);
                   return  $data = ['msg' =>'项目创建失败。' . $err, 'code' => 0];
               }

               // $model->CostOriginalTemplateFile = $costTemplatePath;
               $model->MarketTemplateId = $marketTemplateId;

           }

           if (!empty($params['evaluationObjectId'])) {
               $targetType = TJAssesmentTargetSub::getTargetType($params['evaluationObjectId']);
           } else {
               // 兼容老项目（编辑/复制的时候），对评估对象含有商誉字眼的自动更新成商誉类型
               if (in_array($model->EvaluationObject, BusinessOptionEnum::$old_business)) {
                   $targetType = TJAssesmentTargetSub::TARGET_TYPE_GOODWILL;
               }
           }
           $model->EvaluationObjectType = $targetType;

           $sub = [];
           if (!$model->save()) {
               $err .= implode(" ", array_merge(...array_values($model->getErrors())));
               $log = ErrorLogModel::insertErrorLog('p1009','保存项目主体数据错误！',serialize($err),0,ErrorLogModel::PROJECT_TYPE);
               throw new ServerErrorHttpException($err);
           }

           $methodModel = null;
           if ($appraisalProcedureC == 1) {
               $methodModel = new ProjectsViaMethod([
                   'UUID' => Uuid::uuid(),
                   'ProjectId' => $model->Id,
                   'ProjectUUID' => $model->UUID,
                   'AppraisalProcedure' => TJProjectStatistics::EVALUATION_METHOD_FINAL_COST,
                   'ProjectState' => TJProjectStatistics::PROJECTS_INDEX_STATISTICS_ITEM['projectApproval'],
                   'ManuscriptFile' => ''
               ]);
               if (!$methodModel->save()) {
                   $err .= implode(" ", array_merge(...array_values($model->getErrors())));
                   Yii::error("成本法保存失败。详情：" . $err);
                   $log = ErrorLogModel::insertErrorLog('p1010','成本法保存失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
                   throw new ServerErrorHttpException($err);
               }
           }

           $commonKeyParams = [
               'KeyName' => '自身股权价值',
               'EnKeyCode' => ShareholdingStructure::MARKET_TOTAL_VALUE,
               'SubjectId' => null,
               'ProjectId' => $model->Id,
               'KeyType' => 1,
               'SheetColumnId' => null,
               'EffectArea' => '-1',
               'ColumnPosition' => '-1',
               'DataType' => 1,
               'DataRange' => '-1',
               'DataColumn' => '-1',
               'Offset' => 0,
               'TwistGroupId' => null,
               'ExtraParams' => json_encode(['SheetName' => '评估结果汇总', 'Row' => 145, 'ColumnStr' => 'E'], JSON_UNESCAPED_UNICODE),
               'Position' => '-1'
           ];

           // 保存市场法、成本法关键参数
           $marketCommonParams = [
               [
                   'KeyName' => '自身股权价值',
                   'EnKeyCode' => ShareholdingStructure::MARKET_TOTAL_VALUE,
                   'SubjectId' => null,
                   'ProjectId' => $model->Id,
                   'KeyType' => 1,
                   'SheetColumnId' => null,
                   'EffectArea' => '-1',
                   'ColumnPosition' => '-1',
                   'DataType' => 1,
                   'DataRange' => '-1',
                   'DataColumn' => '-1',
                   'Offset' => 0,
                   'TwistGroupId' => null,
                   'ExtraParams' => json_encode(['SheetName' => '评估结果汇总', 'Row' => '目标公司股权价值汇总-股权价值', 'ColumnStr' => 'E'], JSON_UNESCAPED_UNICODE),
                   'Position' => '-1'
               ],
               [
                   'KeyName' => '账面价值',
                   'EnKeyCode' => ShareholdingStructure::MARKET_NET_ASSETS_STR,
                   'SubjectId' => null,
                   'ProjectId' => $model->Id,
                   'KeyType' => 1,
                   'SheetColumnId' => null,
                   'EffectArea' => '-1',
                   'ColumnPosition' => '-1',
                   'DataType' => 1,
                   'DataRange' => '-1',
                   'DataColumn' => '-1',
                   'Offset' => 0,
                   'TwistGroupId' => null,
                   'ExtraParams' => json_encode(['SheetName' => '评估结果汇总', 'Row' => '目标公司股权价值汇总-归属于母公司股东的权益', 'ColumnStr' => 'E'], JSON_UNESCAPED_UNICODE),
                   'Position' => '-1'
               ]
           ];
           
           // 假开模板TCode=30,TSource=2;
           // 针对收益法假开模板写入汇总参数
           if ($template && $template->TCode == 30 && $template->TSource == 2 && $params['appraisalProcedureA'] == 1) {
              // 入库收益法假开法净资产 净资产=所有者权益=账面价值 === 股权现金流
              $commonKeyParam假开 = new CommonKeyParams(array_merge($commonKeyParams, ['ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_INCOME, 'UUID' => Uuid::uuid()]));
              $commonKeyParam假开->KeyName = '所有者权益=账面价值';
              $commonKeyParam假开->EnKeyCode = ShareholdingStructure::STOCK_VALUE_STR_GQ;
              $commonKeyParam假开->ExtraParams = json_encode(['SheetName' => "收益法现金流测算表",'Row' => 37,'ColumnStr' => "D"], JSON_UNESCAPED_UNICODE);
              if (!$commonKeyParam假开->save()) {
                 $err .= implode(" ", array_merge(...array_values($commonKeyParam假开->getErrors())));
                 Yii::error("收益法假开关键参数保存失败。详情：" . $err);
                   $log = ErrorLogModel::insertErrorLog('p1011','收益法假开关键参数(所有者权益=账面价值)保存失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
                   throw new ServerErrorHttpException($err);
              }
     
              // 入库收益法假开法净资产 净资产=所有者权益=账面价值 === 企业现金流
              $commonKeyParam假开 = new CommonKeyParams(array_merge($commonKeyParams, ['ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_INCOME, 'UUID' => Uuid::uuid()]));
              $commonKeyParam假开->KeyName = '所有者权益=账面价值';
              $commonKeyParam假开->EnKeyCode = ShareholdingStructure::STOCK_VALUE_STR_QY;
              $commonKeyParam假开->ExtraParams = json_encode(['SheetName' => "收益法现金流测算表",'Row' => 37,'ColumnStr' => "D"], JSON_UNESCAPED_UNICODE);
              if (!$commonKeyParam假开->save()) {
                 $err .= implode(" ", array_merge(...array_values($commonKeyParam假开->getErrors())));
                 Yii::error("收益法假开关键参数保存失败。详情：" . $err);
                   $log = ErrorLogModel::insertErrorLog('p1012','收益法假开关键参数保存失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
                   throw new ServerErrorHttpException($err);
              }
           }
           
           
           if ($params['appraisalProcedureB'] == 1) {
               foreach ($marketCommonParams as $marketCommonParam) {
                   $commonKeyParamA = new CommonKeyParams(array_merge($marketCommonParam, ['ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_MARKET, 'UUID' => Uuid::uuid()]));
                   if (!$commonKeyParamA->save()) {
                       $err .= implode(" ", array_merge(...array_values($commonKeyParamA->getErrors())));
                       Yii::error("市场法关键参数保存失败。详情：" . $err);
                       $log = ErrorLogModel::insertErrorLog('p1013','市场法关键参数保存失败',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::MARKET_METHOD);
                       throw new ServerErrorHttpException($err);
                   }
               }
           }

           // 成本法写入，2024年06月06日江天加入排除新成本法逻辑，新成本法直接在股权部分从振涛那里获取值即可
           if ($appraisalProcedureC == 1 && $isNewForcost == TJIndustryTemplate::TEMPLATE_STAGE_OLD) {
               $commonKeyParamC = new CommonKeyParams(array_merge($commonKeyParams, ['ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_FINAL_COST, 'UUID' => Uuid::uuid()]));

               // $costTemplateId 成本法自动获取关键参数 评估价值参数
               $ExtraParams = TJKeyParams::find()
                   ->alias("K")
                   ->leftJoin("TJ_TemplateKeyParams T", "K.Id=T.KeyParamsId and K.IsDeleted=0")
                   ->leftJoin("TJ_ExtraKeyParams E", 'K.Id=E.KeyParamsId and T.ExtraKeyParamsId = E.Id ')
                   ->select("E.SheetName,E.Row,E.ColumnStr,K.KeyName,K.EnKeyCode")
                   ->where(['K.EnKeyCode'=> ShareholdingStructure::FORCOST_NET_ASSTS,'T.TemplateId'=>$costTemplateId ,'K.IsDeleted'=>0,'E.IsDeleted'=>0,'T.IsDeleted'=>0])
                   ->asArray()
                   ->one();
               if(empty($ExtraParams)){
                   $log = ErrorLogModel::insertErrorLog('p1014','成本法评估价值关键参数为空！',serialize('成本法评估价值关键参数为空'),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
                   throw new Exception("成本法评估价值关键参数为空！" );
               }
               $commonKeyParamC->EnKeyCode = ShareholdingStructure::FORCOST_NET_ASSTS;
               $commonKeyParamC->ExtraParams = json_encode(['SheetName' => $ExtraParams['SheetName'],'Row' => $ExtraParams['Row'],'ColumnStr' => $ExtraParams['ColumnStr']] , JSON_UNESCAPED_UNICODE);
               if (!$commonKeyParamC->save()) {
                   $err .= implode(" ", array_merge(...array_values($commonKeyParamC->getErrors())));
                   $log = ErrorLogModel::insertErrorLog('p1015','成本法关键参数保存失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
                   Yii::error("成本法关键参数保存失败。详情：" . $err);
                   throw new ServerErrorHttpException($err);
               }
               // 入库成本法净资产 净资产=所有者权益=账面价值
               $commonKeyParamC = new CommonKeyParams(array_merge($commonKeyParams, ['ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_FINAL_COST, 'UUID' => Uuid::uuid()]));
               // $costTemplateId 成本法自动获取关键参数 账面价值
               $MExtraParams = TJKeyParams::find()
                   ->alias("K")
                   ->leftJoin("TJ_TemplateKeyParams T", "K.Id=T.KeyParamsId and K.IsDeleted=0")
                   ->leftJoin("TJ_ExtraKeyParams E", 'K.Id=E.KeyParamsId and T.ExtraKeyParamsId = E.Id ')
                   ->select("E.SheetName,E.Row,E.ColumnStr,K.KeyName,K.EnKeyCode")
                   ->where(['K.EnKeyCode'=> ShareholdingStructure::FORCOST_NET_ASSETS_STR,'T.TemplateId'=>$costTemplateId ,'K.IsDeleted'=>0,'E.IsDeleted'=>0,'T.IsDeleted'=>0])
                   ->asArray()
                   ->one();
               if(empty($MExtraParams)) {
                   $log = ErrorLogModel::insertErrorLog('p1016','成本法账面价值关键参数为空！',serialize('成本法账面价值关键参数为空！'),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
                   throw new Exception("成本法账面价值关键参数为空！" );
               }
               $commonKeyParamC->KeyName = '所有者权益=账面价值';
               $commonKeyParamC->EnKeyCode = ShareholdingStructure::FORCOST_NET_ASSETS_STR;
               $commonKeyParamC->ExtraParams = json_encode(['SheetName' => $MExtraParams['SheetName'],'Row' => $MExtraParams['Row'],'ColumnStr' => $MExtraParams['ColumnStr']], JSON_UNESCAPED_UNICODE);
               if (!$commonKeyParamC->save()) {
                   $err .= implode(" ", array_merge(...array_values($commonKeyParamC->getErrors())));
                   Yii::error("成本法关键参数保存失败。详情：" . $err);
                   $log = ErrorLogModel::insertErrorLog('p1017','成本法关键参数保存失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
                   throw new ServerErrorHttpException($err);
               }
           }
           // 写入拼音库-项目名称
           $py = new Pinyin();
           $pyModel = new TJFieldToChinese();
           $pyModel->UUID = Uuid::uuid();
           $pyModel->TableUUID = $model->UUID;
           $pyModel->FieldName = "ProjectName";
           $pyModel->WholeChinese = preg_replace('# #','', $py->sentence($model->ProjectName, ''));
           $pyModel->ShortChinese = preg_replace('# #','',$py->abbr($model->ProjectName, '', PINYIN_DEFAULT | \PINYIN_KEEP_PUNCTUATION | \PINYIN_KEEP_ENGLISH | \PINYIN_KEEP_NUMBER));
           if (!$pyModel->save()) {
               $err .= implode(" ", array_merge(...array_values($pyModel->getErrors())));
               $log = ErrorLogModel::insertErrorLog('p1018','项目名称转拼音失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
               throw new Exception("项目名称转拼音失败！" . $err);
           }

           // 写入拼音库-被评估公司名称
           $py = new Pinyin();
           $pyModel = new TJFieldToChinese();
           $pyModel->UUID = Uuid::uuid();
           $pyModel->TableUUID = $model->UUID;
           $pyModel->FieldName = "BeEvaluatedCompanyName";
           $pyModel->WholeChinese = preg_replace('# #','', $py->sentence($model->ProjectName, ''));
           $pyModel->ShortChinese = preg_replace('# #','',$py->abbr($model->ProjectName, '', PINYIN_DEFAULT | \PINYIN_KEEP_PUNCTUATION | \PINYIN_KEEP_ENGLISH | \PINYIN_KEEP_NUMBER));
           if (!$pyModel->save()) {
               $err .= implode(" ", array_merge(...array_values($pyModel->getErrors())));
               $log = ErrorLogModel::insertErrorLog('p1019','被评估公司名称转拼音失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::COST_METHOD);
               throw new Exception("被评估公司名称转拼音失败！" . $err);
           }

           // 小方法入库
           // Yii::info($params['AppraisalProcedureSub']);
           if ($params['appraisalProcedureB'] == 1 && !empty($model) && isset($params['AppraisalProcedureSub']) && !empty($params['AppraisalProcedureSub'])) {
               Yii::error($params['AppraisalProcedureSub']);
               if (is_array($subMethod = $params['AppraisalProcedureSub'])) {
                   array_walk($subMethod, function ($item) use ($map, $model, &$sub, &$err, $py) {
                       $res['TJ_Projects_Id'] = $model->Id;
                       $mapApr = $map['TJAppraisalProcedure'];
                       dataExchangeTrait::exchange($mapApr, $item, $res, ['id']);
                       $subMethod = new TJAppraisalProcedureSub();
                       $subMethod->loadDefaultValues()->setAttributes($res, false);
                       if ($subMethod->save()) {
                           $sub[] = $subMethod->toArray();
                       } else {
                           $err .= implode(" ", array_merge(...array_values($subMethod->getErrors())));
                           Yii::error($err);
                           $log = ErrorLogModel::insertErrorLog('p1020','市场法小方法保存失败！',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::MARKET_METHOD);
                           throw new Exception("市场法小方法保存失败");
                       }
                   });
               }
           }

           // 选择审核人员入库
           if (isset($params['auditor']) && !empty($params['auditor'])) {
               foreach ($params['auditor'] as $auditor) {
                   $audit = new ProjectsAuditRelationship();
                   $audit->ProjectId = $model->Id;
                   $audit->EvaluationMethod = $model->AppraisalProcedure1 == 1 && $model->AppraisalProcedure2 == 1 ? 3 : ($model->AppraisalProcedure1 == 1 ? 1 : 2); // 默认先支持收益法
                   $audit->loadDefaultValues()->setAttributes($auditor);
                   if (!$audit->save()) {
                       Yii::error($audit->getErrors());
                       $err .= implode(" ", array_merge(...array_values($audit->getErrors())));
                       $log = ErrorLogModel::insertErrorLog('p1021','未正确指定审核人员',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE);
                       throw new Exception("未正确指定审核人员" . $err);
                   }
               }
           }

           // 收益法，执行模板查找
           if($params['appraisalProcedureA'] == 1){
               if (empty($params['modelId'])) {
                   $err .= "未指定模板，无法创建项目";
                   $log = ErrorLogModel::insertErrorLog('p1022','未指定收益法模板，无法创建项目',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::INCOME_METHOD);
                   throw new Exception($err);
               }

               // 使用非商誉模板创建的项目，保存个人模板后，新建项目报错
               // 解决bug：http://pms.zpy360.com/index.php?m=bug&f=view&bugID=3506
               $template = TJIndustryTemplate::find()
                   ->where(['ModelId' => $params['modelId'], 'TempName' => $params['industryModel'], 'IsDeleted' => 0, 'IsInUse' => 1])
                   ->one();
               /** @var TJIndustryTemplate $template */

               if (!$template) {
                   $err .= "未能查找到行业模板文件，无法创建项目";
                   $log = ErrorLogModel::insertErrorLog('p1023','未能查找到收益法行业模板文件，无法创建项目',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::INCOME_METHOD);
                   throw new Exception($err);
               }
               $tempSource = $template->TSource;

               if($tempSource == 1){   // 从领域模型库 检测模板是否存在
                   $templateObj = OriginDomainTemplates::findOne(['Id' => $params['modelId'], 'IsDeleted' => 0]);
                   if (empty($templateObj)) {
                       $err .= "未能查找到行业模板模型，无法创建项目";
                       $log = ErrorLogModel::insertErrorLog('p1024','未能查找到收益法行业模板模型，无法创建项目',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::INCOME_METHOD);
                       throw new Exception($err);
                   }
               }
               
               // 自定义模版
               if ($tempSource == 3) {
                   $TJFile = TJFiles::find()->where(['Uuid' => $template->DataModelFileId])->select('Path,ZipPath')->one();
                   if (empty($TJFile) || empty($TJFile->Path) || empty($TJFile->ZipPath) || !file_exists(Yii::$app->basePath . $TJFile->ZipPath)) {
                       $err .= "自定义模板文件不存在，无法创建项目";
                       $log = ErrorLogModel::insertErrorLog('p1024','自定义模板文件不存在，无法创建项目',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::INCOME_METHOD);
                       throw new Exception($err);
                   }
               }

               $templatePath = $template->TemplatePath;
               // 只有收益法需要模板文件，市场法模板暂时内置
               if (empty($templatePath) || !file_exists($file = Yii::$app->basePath . $templatePath)) {
                   $err .= "模板不存在，无法创建项目！";
                   //throw new Exception($err);
                   $log = ErrorLogModel::insertErrorLog('p1025','收益法模板文件不存在，无法创建项目',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::INCOME_METHOD);
                   return  $data = ['msg' =>'项目创建失败。' . $err, 'code' => 0];
               }

               $model->OriginalMbFile = $templatePath;
               $model->IncomeTemplateId = $template->Id;

               try {
                   if ($model->update(false) === false) {
                       Yii::error("原始模板文件路径更新错误");
                       $err .= "原始模板文件路径更新错误";
                       $log = ErrorLogModel::insertErrorLog('p1026','更新收益法原始模板文件路径错误',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::INCOME_METHOD);
                       return  $data = ['msg' =>'项目创建失败。' . $err, 'code' => 0];
                   };
               } catch (Exception $e) {
                   $err = implode(" ", array_merge(...array_values($model->getErrors())));
                   $log = ErrorLogModel::insertErrorLog('p1027','更新收益法原始模板文件路径时内部错误',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE,ErrorLogModel::INCOME_METHOD);
                   throw new Exception("内部错误。 " . implode(" ", array_merge(...array_values($model->getErrors()))));
               }


           }
   
           // 解析日志需要的项目id参数，2024年06月17加入LoginUserId，在后面异步调用要用到登陆用户id
           Yii::$app->request->setBodyParams(array_merge($params, ['projectId' => $model->Id, 'LoginUserId' =>
               Yii::$app->user->id]));
           $logProjectId =  $model->Id;
            yii::error($logProjectId);
           // 保存项目细节
           $details = new TJProjectsDetailsSub();
           $details->setAttributes($result);
           $details->ProjectId = $model->Id;
           $details->UUID = Uuid::uuid();
           $details->BusinessStatus = $details->BusinessStatus ?? TJProjectsDetailsSub::GOINGCONCERN;
           Yii::error($details->toArray());
           if (!$details->save()) {
               Yii::error($details->getErrors());
               $err .= implode(",", array_merge(...array_values($details->getErrors())));
               $log = ErrorLogModel::insertErrorLog('p1028','项目细节保存失败',serialize($err),$model->Id,ErrorLogModel::PROJECT_TYPE);
               throw new Exception($err);
           }

           // 保存项目底稿错误检查状态信息
           if ($params['appraisalProcedureA'] == 1) Util::generateProjectStatus($model->Id, 1);
           if ($params['appraisalProcedureB'] == 1) Util::generateProjectStatus($model->Id, 2);
           if ($params['appraisalProcedureC'] == 1) Util::generateProjectStatus($model->Id, 3);

           // 2024年06月17日江天将项目创建人默认授权为项目经理
           TeamModel::AddTeamManager($model->Id, [Yii::$app->user->id], Yii::$app->params['user.headOfficeUid']);
           unset($params, $except, $py, $pyModel, $sub, $map, $subMethod, $audit, $templateObj, $details);
           $transaction->commit();
       } catch(\Throwable $e) {
           $transaction->rollBack();
           Yii::$app->response->headers->set("extra-error-info", "If the submission data is correct, please check whether the submission data type is consistent with the content-type set, such as whether it is submitted in multipart/form-data mode, but content-type is another type!");
           $err = '项目创建失败，详情：' . $e->getMessage() . "。文件名：" . $e->getFile() . ",第" . $e->getLine() . "行.";
           Yii::error($err);
           $log = ErrorLogModel::insertErrorLog('p1030','项目创建失败',serialize($err),0,ErrorLogModel::PROJECT_TYPE);
           return  $data = ['msg' =>'项目创建失败。' . mb_substr($e->getMessage(), 0, 80), 'code' => 0];
       }

      Yii::info("开始执行异步计算！", __METHOD__);

       $result = array_merge($result, TJProjectStatistics::getProject($model->Id,
           TJProjectStatistics::EVALUATION_METHOD_FINAL_COST));
      $result['Id'] = $model->Id;
      $result['Route'] = Yii::$app->controller->route;
      // 企业id以参数的形式传递给转发api
      $result['headOfficeUid'] = Yii::$app->params['user.headOfficeUid'];
       // 2024年06月18日添加
       $result['LoginUserId'] = Yii::$app->user->id;

      // 授权token
      $auth = Yii::$app->request->headers->get("authorization");

      /** @var \yii\queue\amqp\Queue $queue */
      $queue = new amqpQueue();
      // 选择收益法
      if (isset($result['AppraisalProcedure1']) && $result['AppraisalProcedure1'] == 1) {
         $url = Yii::$app->params['baseUrl_inner'] . '/v1/common/income-approach';
         $result['Step'] = 4;
         $result['AppraisalMethod'] = TJProjectStatistics::EVALUATION_METHOD_INCOME;
         Helper::createProjectManage(
            TJProjectStatistics::EVALUATION_METHOD_INCOME,
            $result,
            $manage,
            TJProjectManage::ACTIONTYPE_CREATE_INCOMEAPPROACH,
            '',
            '创建项目收益法基础信息成功'
         );
         if (!$manage) {
            Yii::error("项目状态记录失败");
         }
         /** @var Queue $queue */
         Yii::$app->cache->set([
            'ProjectId' => (int)$model->Id,
            'ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_INCOME
         ], true, 3600);
         $queue->push(new CreateProjectJob([
            'url' => $url,
            'method' => TJProjectStatistics::EVALUATION_METHOD_INCOME,
            'auth' => $auth,
            'params' => http_build_query($result)
         ]));
      }

      // 选择市场法
      if (isset($result['AppraisalProcedure2']) && $result['AppraisalProcedure2'] == 1) {
         $url = Yii::$app->params['baseUrl_inner'] . '/v1/common/market';
         $result['Step'] = 12;
         $result['AppraisalMethod'] = TJProjectStatistics::EVALUATION_METHOD_MARKET;
         $queue->queueName = "marketApproach_L2";
         $queue->routeKey = "marketApproach_L2";
         Helper::createProjectManage(
            TJProjectStatistics::EVALUATION_METHOD_MARKET,
            $result,
            $manage,
            TJProjectManage::ACTIONTYPE_CREATE_MARKETAPPROACH,
            '',
            '创建项目市场法基础信息成功'
         );
         if (!$manage) {
            Yii::error("项目状态记录失败");
         }
         Yii::$app->cache->set([
            'ProjectId' => (int)$model->Id,
            'ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_MARKET
         ], true, 3600);
         $queue->push(new CreateProjectJob([
            'url' => $url,
            'method' => TJProjectStatistics::EVALUATION_METHOD_MARKET,
            'auth' => $auth,
            'params' => http_build_query($result)
         ]));
      }

      // 选择成本法
      if (isset($result['AppraisalProcedure3']) && $result['AppraisalProcedure3'] == 1) {
         $url = Yii::$app->params['baseUrl_inner'] . '/v1/common/forcost-approach';
           $result['IsNewForcost'] = 0;
           if ($isNewForcost == TJIndustryTemplate::TEMPLATE_STAGE_NEW) {
               // 2024年06月06日江天添加新成本法创建逻辑
               $result['IsNewForcost'] = 1;
           }
         $result['Step'] = 21;
         $result['AppraisalMethod'] = TJProjectStatistics::EVALUATION_METHOD_FINAL_COST;
         $queue->queueName = "forcostApproach_L2";
         $queue->routeKey = "forcostApproach_L2";
         Helper::createProjectManage(
            TJProjectStatistics::EVALUATION_METHOD_FINAL_COST,
            $result,
            $manage,
            TJProjectManage::ACTIONTYPE_CREATE_COSTAPPROACH,
            '',
            '创建项目成本法基础信息成功'
         );
         if (!$manage) {
            Yii::error("项目状态记录失败");
         }
         Yii::$app->cache->set([
            'ProjectId' => (int)$model->Id,
            'ValidMethod' => TJProjectStatistics::EVALUATION_METHOD_FINAL_COST
         ], true, 3600);
         $queue->push(new CreateProjectJob([
            'url' => $url,
            'method' => TJProjectStatistics::EVALUATION_METHOD_FINAL_COST,
            'auth' => $auth,
            'params' => http_build_query($result)
         ]));
      }

      return $data = ['msg' => '项目创建任务已提交，请稍后...', 'code' => 1, 'projectId' => $model->Id];

   }
}