initial
This commit is contained in:
msyu
@@ -0,0 +1,201 @@
|
||||
<cfcomponent extends="taffy.core.resource" taffy:uri="/instanceOperations/{instanceOperationUid}/run">
|
||||
|
||||
<cfsilent>
|
||||
<cfimport prefix="m" taglib="../lib"/>
|
||||
<cfset this.helper=CreateObject("component","lib.rest_api_helper")/><!---*** странно, почему мы его видим?---><!---вынести в апп?--->
|
||||
</cfsilent>
|
||||
|
||||
|
||||
<cffunction name="post" hint="(ТЕСТИРОВАНИЕ)">
|
||||
<cfargument name="instanceOperationUid" type="string" required=true hint="type:guid"/>
|
||||
|
||||
<cfset local={}/>
|
||||
<cfset local.instanceUid=#createGUID()#/>
|
||||
|
||||
<!--- *** Проверить наличие обязательных CFS параметров
|
||||
Создать RFS параметры
|
||||
(валидируем CFS параметры при создании, а не сейчас) --->
|
||||
|
||||
<cftry>
|
||||
<!---NOT NULL fields--->
|
||||
<cfset this.helper.keyExistsAndValid(arguments, "instanceOperationUid", "guid")/>
|
||||
|
||||
<cfset generateRfsParams(arguments.instanceOperationUid, arguments.usrId)/>
|
||||
<cfset submitJob(arguments.instanceOperationUid)/>
|
||||
|
||||
<cfcatch type="invalidParamValue">
|
||||
<cfreturn representationOf(this.helper.formatBadRequestError(cfcatch)).withStatus(400)/>
|
||||
</cfcatch>
|
||||
</cftry>
|
||||
<!--- <cfreturn representationOf("Not Implemented yet").withStatus(501)/> --->
|
||||
|
||||
|
||||
|
||||
|
||||
<cfreturn noData()
|
||||
.withHeaders({location: "./#local.instanceUid#"})
|
||||
.withStatus(201, "Created")
|
||||
/>
|
||||
</cffunction>
|
||||
|
||||
<cffunction name="generateRfsParams">
|
||||
<cfargument name="instanceOperationUid" type="guid"/>
|
||||
<cfargument name="usrId" type="numeric"/>
|
||||
<!---
|
||||
-- полезный селект, не выбрасывать
|
||||
<cfquery name="qSvcOperationCfsParam">
|
||||
select sop.svc_operation_cfs_param_id
|
||||
,iop.instance_operation_cfs_param_uid::text as instance_operation_cfs_param_uid /*pgjdbc issue fix*/
|
||||
,iop.param_value
|
||||
,sop.svc_operation_cfs_param
|
||||
,sop.data_type
|
||||
,sop.is_required
|
||||
,sop.maxlength,sop.minlength,sop.regex,sop.unique_scope
|
||||
from instance_operation io
|
||||
join instance e on (io.instance_uid=e.instance_uid)
|
||||
join svc_operation so on (e.service_id=so.svc_id AND io.operation=so.operation)
|
||||
join svc_operation_cfs_param sop on (so.svc_operation_id=sop.svc_operation_id)
|
||||
left outer join instance_operation_cfs_param iop
|
||||
on (sop.svc_operation_cfs_param_id=iop.svc_operation_cfs_param_id AND io.instance_operation_uid=iop.instance_operation_uid)
|
||||
where iop.instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value=#arguments.instanceOperationUid# null=#!isValid("guid",arguments.instanceOperationUid)#/>)
|
||||
</cfquery>
|
||||
--->
|
||||
<cfquery name="qSvcOperation">
|
||||
select so.svc_operation_id, io.instance_uid
|
||||
from instance_operation io
|
||||
join instance e on (io.instance_uid=e.instance_uid)
|
||||
join svc_operation so on (e.service_id=so.svc_id AND io.operation=so.operation)
|
||||
where io.instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value=#arguments.instanceOperationUid# null=#!isValid("guid",arguments.instanceOperationUid)#/>
|
||||
</cfquery>
|
||||
<!--- поступим проще, по engine/generate_rfs_12.cfm --->
|
||||
<cfset setInstanceOperationRfsParam(arguments.instanceOperationUid, "instanceUid", qSvcOperation.instance_uid)/>
|
||||
<cfset setInstanceOperationRfsParam(arguments.instanceOperationUid, "operationUid", arguments.instanceOperationUid)/>
|
||||
<cfset setInstanceOperationRfsParam(arguments.instanceOperationUid, "modifierId", #arguments.usrId#)/>
|
||||
|
||||
<cfquery name="qWriteRfsFromCfsParams">
|
||||
insert into instance_operation_param (instance_operation_uid,param,param_value)
|
||||
select
|
||||
iocp.instance_operation_uid
|
||||
,sop.svc_operation_param
|
||||
,iocp.param_value
|
||||
from instance_operation_cfs_param iocp
|
||||
join svc_operation_cfs_param socp on (iocp.svc_operation_cfs_param_id=socp.svc_operation_cfs_param_id)
|
||||
join svc_operation_param sop on (socp.svc_operation_id=sop.svc_operation_id AND socp.svc_operation_cfs_param=sop.svc_operation_param)
|
||||
where iocp.instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value="#arguments.instanceOperationUid#"/>
|
||||
/*PostgreSQL specific*/
|
||||
ON CONFLICT (instance_operation_uid,param)
|
||||
DO UPDATE SET param_value = EXCLUDED.param_value;
|
||||
</cfquery>
|
||||
|
||||
<!--- так яснее, но можно было все в один запрос --->
|
||||
|
||||
|
||||
<cfquery name="qWriteRfsParamsFromDefaults">
|
||||
insert into instance_operation_param (instance_operation_uid,param,param_value)
|
||||
select
|
||||
<cfqueryparam cfsqltype="cf_sql_other" value="#arguments.instanceOperationUid#"/>
|
||||
,sop.svc_operation_param
|
||||
,sop.default_value
|
||||
from svc_operation_param sop
|
||||
where sop.svc_operation_id=<cfqueryparam cfsqltype="cf_sql_integer" value="#qSvcOperation.svc_operation_id#"/> AND length(sop.default_value)>0 /***null will be better*/
|
||||
/*PostgreSQL specific*/
|
||||
ON CONFLICT (instance_operation_uid,param)
|
||||
DO NOTHING;
|
||||
</cfquery>
|
||||
|
||||
</cffunction>
|
||||
|
||||
<cffunction name="submitJob">
|
||||
<cfargument name="instanceOperationUid" type="string" required=true hint="type:guid"/>
|
||||
|
||||
<cfquery name="qInstanceOperation">
|
||||
select so.url
|
||||
from instance_operation o
|
||||
join instance i on (o.instance_uid=i.instance_uid)
|
||||
left outer join svc_operation so on (i.service_id=so.svc_id AND o.operation=so.operation)
|
||||
where o.instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value=#arguments.instanceOperationUid#/>
|
||||
</cfquery>
|
||||
|
||||
<cfquery name="qInstanceOperationParam">
|
||||
select iop.param, iop.param_value
|
||||
from instance_operation_param iop
|
||||
where iop.instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value=#arguments.instanceOperationUid#/>
|
||||
AND length(iop.param)>0
|
||||
</cfquery>
|
||||
|
||||
<cfquery name="qMarkOperationStart">
|
||||
update instance_operation
|
||||
set dt_submit=<cfqueryparam cfsqltype="cf_sql_timestamp" value=#now()#/>
|
||||
,dt_start=null, dt_finish=null, submit_result='0'
|
||||
where instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value=#arguments.instanceOperationUid#/>
|
||||
</cfquery>
|
||||
|
||||
<cfhttp method="post"
|
||||
url="#qInstanceOperation.url#"
|
||||
multipart=true
|
||||
multipartType="form-data"
|
||||
timeout="3"
|
||||
charset="utf-8"
|
||||
result="orchestrator"
|
||||
>
|
||||
<cfhttpparam type="HEADER" name="Authorization" value="#request.ORCHESTRATOR_AUTH#"/>
|
||||
<cfhttpparam type="HEADER" name="Accept" value="application/json"/>
|
||||
<cfhttpparam type="formfield" name="delay" value="0sec"/>
|
||||
<cfloop query="qInstanceOperationParam">
|
||||
<cfhttpparam type="formfield" name="#param#" value="#param_value#"/>
|
||||
</cfloop>
|
||||
</cfhttp>
|
||||
|
||||
<cfquery name="qMarkOperationSubmit">
|
||||
update instance_operation
|
||||
set submit_result=<cfqueryparam cfsqltype="cf_sql_varchar" value=#orchestrator.responseHeader.status_code#/>
|
||||
where instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value=#arguments.instanceOperationUid#/>
|
||||
</cfquery>
|
||||
|
||||
<cfset sleep(0)/><!--- если придется подождать, можно добавить, но мы специально указываем delay=0sec --->
|
||||
<cfif listFind("200,201",#orchestrator.responseHeader.status_code#)>
|
||||
<cftry>
|
||||
<cfset var buildURL="#orchestrator.responseHeader.Location#/api/json"/>
|
||||
<cfhttp method="get"
|
||||
url="#buildUrl#"
|
||||
timeout="3"
|
||||
charset="utf-8"
|
||||
result="job"
|
||||
>
|
||||
<cfhttpparam type="HEADER" name="Authorization" value="#ORCHESTRATOR_AUTH#">
|
||||
<cfhttpparam type="HEADER" name="Accept" value="application/json">
|
||||
</cfhttp>
|
||||
|
||||
<cfquery name="qSetStatusUrl" datasource="#request.DS#">
|
||||
update instance_operation
|
||||
set status_url=<cfqueryparam cfsqltype="cf_sql_varchar" value="#operation_url#wfapi/describe"/>
|
||||
where instance_operation_uid=<cfqueryparam cfsqltype="cf_sql_other" value=#instance_operation_uid#/>
|
||||
</cfquery>
|
||||
|
||||
<cfcatch type="any">
|
||||
<cfrethrow/><!--- пока не придумал --->
|
||||
</cfcatch>
|
||||
</cftry>
|
||||
</cfif>
|
||||
|
||||
</cffunction>
|
||||
|
||||
<cffunction name="setInstanceOperationRfsParam">
|
||||
<cfargument name="instance_operation_uid" type="guid">
|
||||
<cfargument name="param"><!--- значение не должно содержать лишних пробелов, чувствительность к регистру определяется БД --->
|
||||
<cfargument name="val">
|
||||
<cfquery name="qSaveRfsParam">
|
||||
insert into instance_operation_param (instance_operation_uid,param,param_value)
|
||||
values (
|
||||
<cfqueryparam cfsqltype="cf_sql_other" value="#ARGUMENTS.instance_operation_uid#"/>
|
||||
,<cfqueryparam cfsqltype="cf_sql_varchar" value="#ARGUMENTS.param#"/>
|
||||
,<cfqueryparam cfsqltype="cf_sql_varchar" value="#ARGUMENTS.val#"/>
|
||||
)
|
||||
/*PostgreSQL specific*/
|
||||
ON CONFLICT (instance_operation_uid,param)
|
||||
DO UPDATE SET param_value = EXCLUDED.param_value;
|
||||
</cfquery>
|
||||
<!--- <cfdump var=#ARGUMENTS#/> --->
|
||||
</cffunction>
|
||||
|
||||
</cfcomponent>
|
||||
Reference in New Issue
Block a user