@ -37,6 +37,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
private static final Logger logger_824c0f2 = LoggerFactory . getLogger ( OaWmsReturnAction . class ) ;
public WeaResult < Map < String , Object > > execute ( Map < String , Object > requestInfoMap ) {
logger_824c0f2 . info ( "OaWmsReturnAction start" ) ;
Map < String , Object > weaverResultMap = new HashMap < > ( ) ;
Long requestIdTemp = Long . parseLong ( String . valueOf ( requestInfoMap . getOrDefault ( "requestid" , - 1 ) ) ) ;
Long userIdTemp = Long . parseLong ( String . valueOf ( requestInfoMap . getOrDefault ( "userid" , - 1 ) ) ) ;
@ -69,6 +70,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
// 获取申请人直接上级
String zjsj = "" ;
sql = "select (select lastname from employee as hrmresource where id=b.superior) as zjsj from " + tableName + " a,employee b where a.sqr=b.id and a.requestId =" + requestid ;
logger_824c0f2 . info ( "sql--" + sql ) ;
String poolname = CONN_TYPE . workflow . getType ( ) ;
// TODO E10执行sql方法第二参数必须指定源, 默认使用流程源, 单体客户无需修改, 微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs . executeSql ( sql , poolname ) ;
@ -92,6 +94,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
str = service . call ( param , requestid , cfxt ) ;
logger_824c0f2 . info ( String . valueOf ( requestid + "--OaWmsReturnAction--result:" + str [ 0 ] + "-" + str [ 1 ] ) ) ;
sql = "update " + tableName + " set state='" + str [ 0 ] + "',message='" + str [ 1 ] + "' where requestId=" + requestid ;
logger_824c0f2 . info ( "sql--" + sql ) ;
String poolname_et = CONN_TYPE . workflow . getType ( ) ;
// TODO E10执行sql方法第二参数必须指定源, 默认使用流程源, 单体客户无需修改, 微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs . executeSql ( sql , poolname_et ) ;
@ -101,10 +104,11 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
}
} catch ( Exception e ) {
sql = "update " + tableName + " set state='E',message='" + e . toString ( ) + "' where requestId=" + requestid ;
logger_824c0f2 . info ( "sql--" + sql ) ;
String poolname_bm = CONN_TYPE . workflow . getType ( ) ;
// TODO E10执行sql方法第二参数必须指定源, 默认使用流程源, 单体客户无需修改, 微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs . executeSql ( sql , poolname_bm ) ;
logger_824c0f2 . info ( String . valueOf ( requestid + "--OaWmsReturnAction--result:" + e . toString ( ) ) ) ;
logger_824c0f2 . error ( String . valueOf ( requestid + "--OaWmsReturnAction--result:" + e . toString ( ) ) ) ;
requestinfo . getRequestManager ( ) . setMessagecontent ( "审批结果返回光导WMS系统出错: " + e . toString ( ) ) ;
return WeaResult . fail ( 500 , "执行失败" , getResultMapForAction ( weaverResultMap , "result" , Action . FAILURE_AND_CONTINUE , requestinfo . getRequestManager ( ) ) ) ;
}
@ -112,7 +116,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
} catch ( Exception e ) {
e . printStackTrace ( ) ;
logger_824c0f2 . error ( "OaWmsReturnAction e: {}" , e . getMessage ( ) ) ;
return WeaResult . success( getResultMapForAction ( weaverResultMap , "result" , WeaResult . fail( 500 , "执行 异常 ", getResultMapForAction ( weaverResultMap , "result" , e. getMessage ( ) , requestinfo . getRequestManager ( ) ) ) , requestinfo . getRequestManager ( ) ) ) ;
return WeaResult . fail( 500 , "执行 失败 ", getResultMapForAction ( weaverResultMap , "result" , Action. FAILURE_AND_CONTINUE , requestinfo . getRequestManager ( ) ) ) ;
}
}