Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
A
amos-boot-biz
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
项目统一框架
amos-boot-biz
Commits
7f2efb7d
Commit
7f2efb7d
authored
Jan 11, 2024
by
suhuiguang
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
1.修改模板
parent
40c7ea00
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
21 additions
and
19 deletions
+21
-19
JgChangeRegistrationNameServiceImpl.java
...biz/service/impl/JgChangeRegistrationNameServiceImpl.java
+21
-19
No files found.
amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgChangeRegistrationNameServiceImpl.java
View file @
7f2efb7d
...
@@ -32,7 +32,10 @@ import com.yeejoin.amos.boot.module.ymt.flc.api.mapper.RegUnitInfoMapper;
...
@@ -32,7 +32,10 @@ import com.yeejoin.amos.boot.module.ymt.flc.api.mapper.RegUnitInfoMapper;
import
com.yeejoin.amos.component.feign.config.InnerInvokException
;
import
com.yeejoin.amos.component.feign.config.InnerInvokException
;
import
com.yeejoin.amos.feign.privilege.Privilege
;
import
com.yeejoin.amos.feign.privilege.Privilege
;
import
com.yeejoin.amos.feign.systemctl.model.TaskV2Model
;
import
com.yeejoin.amos.feign.systemctl.model.TaskV2Model
;
import
com.yeejoin.amos.feign.workflow.model.*
;
import
com.yeejoin.amos.feign.workflow.model.ActWorkflowBatchDTO
;
import
com.yeejoin.amos.feign.workflow.model.ActWorkflowStartDTO
;
import
com.yeejoin.amos.feign.workflow.model.ProcessTaskDTO
;
import
com.yeejoin.amos.feign.workflow.model.TaskResultDTO
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.http.HttpStatus
;
import
org.springframework.http.HttpStatus
;
...
@@ -63,9 +66,6 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -63,9 +66,6 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
private
JgChangeRegistrationNameEqServiceImpl
jgChangeRegistrationNameEqService
;
private
JgChangeRegistrationNameEqServiceImpl
jgChangeRegistrationNameEqService
;
@Autowired
@Autowired
private
JgRegistrationHistoryServiceImpl
jgRegistrationHistoryService
;
@Autowired
RedisUtils
redisUtils
;
RedisUtils
redisUtils
;
@Autowired
@Autowired
...
@@ -107,10 +107,12 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -107,10 +107,12 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
@Autowired
@Autowired
ICmWorkflowService
cmWorkflowService
;
ICmWorkflowService
cmWorkflowService
;
static
String
templete
=
"来自企业(s%)的业务办理,【申请单号:s%】"
;
@Transactional
(
rollbackFor
=
Exception
.
class
)
@Transactional
(
rollbackFor
=
Exception
.
class
)
public
void
save2
(
String
submitType
,
JSONObject
requestParam
)
{
public
void
save2
(
String
submitType
,
JSONObject
requestParam
)
{
Map
<
String
,
JSONObject
>
jgRegistrationInfoMap
=
(
Map
<
String
,
JSONObject
>)
JSONObject
.
parseObject
(
JSONObject
.
toJSONString
(
requestParam
),
Map
.
class
);
Map
<
String
,
JSONObject
>
jgRegistrationInfoMap
=
(
Map
<
String
,
JSONObject
>)
JSONObject
.
parseObject
(
JSONObject
.
toJSONString
(
requestParam
),
Map
.
class
);
this
.
save
(
submitType
,
jgRegistrationInfoMap
);
this
.
save
(
submitType
,
jgRegistrationInfoMap
);
}
}
...
@@ -237,7 +239,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -237,7 +239,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
* @return 摘要
* @return 摘要
*/
*/
private
String
buildTaskContent
(
JgChangeRegistrationName
dto
)
{
private
String
buildTaskContent
(
JgChangeRegistrationName
dto
)
{
return
"申请单号:"
+
dto
.
getApplyNo
()
+
"的业务办理"
;
return
String
.
format
(
templete
,
dto
.
getUseUnitCreditCode
(),
dto
.
getApplyNo
())
;
}
}
...
@@ -277,14 +279,14 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -277,14 +279,14 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
jgChangeRegistrationName
.
setNextTaskId
(
nextTaskId
);
jgChangeRegistrationName
.
setNextTaskId
(
nextTaskId
);
jgChangeRegistrationName
.
setAuditStatus
(
WorkFlowStatusEnum
.
UNIT_RENAME_RECEIVE
.
getPass
());
jgChangeRegistrationName
.
setAuditStatus
(
WorkFlowStatusEnum
.
UNIT_RENAME_RECEIVE
.
getPass
());
// 创建待办
// 创建待办
createTaskModel
(
jgChangeRegistrationName
,
taskName
,
"1"
,
nextUserIds
);
createTaskModel
(
jgChangeRegistrationName
,
taskName
,
"1"
,
nextUserIds
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
log
.
error
(
"提交失败:{}"
,
e
);
log
.
error
(
"提交失败:{}"
,
e
);
throw
new
BadRequest
(
"提交失败"
+
e
.
getMessage
());
throw
new
BadRequest
(
"提交失败"
+
e
.
getMessage
());
}
}
}
else
{
}
else
{
// 执行一步
// 执行一步
ProcessTaskDTO
processTaskDTO
=
submit
(
op
,
jgChangeRegistrationName
.
getNextTaskId
());
ProcessTaskDTO
processTaskDTO
=
submit
(
op
,
jgChangeRegistrationName
.
getNextTaskId
());
String
nextTaskId
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getId
();
String
nextTaskId
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getId
();
String
taskName
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getName
();
String
taskName
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getName
();
this
.
buildRoleList
(
Collections
.
singletonList
(
processTaskDTO
),
roleListNext
,
roleListAll
);
this
.
buildRoleList
(
Collections
.
singletonList
(
processTaskDTO
),
roleListNext
,
roleListAll
);
...
@@ -332,7 +334,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -332,7 +334,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
taskV2Model
.
setStartUserCompanyName
(
jgChangeRegistrationName
.
getUseUnitName
());
taskV2Model
.
setStartUserCompanyName
(
jgChangeRegistrationName
.
getUseUnitName
());
taskV2Model
.
setExecuteUserIds
(
nextUserIds
);
taskV2Model
.
setExecuteUserIds
(
nextUserIds
);
TaskModelDto
modelDto
=
new
TaskModelDto
();
TaskModelDto
modelDto
=
new
TaskModelDto
();
BeanUtil
.
copyProperties
(
taskV2Model
,
modelDto
);
BeanUtil
.
copyProperties
(
taskV2Model
,
modelDto
);
modelDto
.
setNextExecuteUser
(
jgChangeRegistrationName
.
getNextExecutorIds
());
modelDto
.
setNextExecuteUser
(
jgChangeRegistrationName
.
getNextExecutorIds
());
modelDto
.
setModel
(
jgChangeRegistrationName
);
modelDto
.
setModel
(
jgChangeRegistrationName
);
// 再插入新代办、数据待定
// 再插入新代办、数据待定
...
@@ -340,7 +342,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -340,7 +342,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
}
}
public
ProcessTaskDTO
submit
(
String
op
,
String
taskId
)
{
public
ProcessTaskDTO
submit
(
String
op
,
String
taskId
)
{
//组装信息
//组装信息
TaskResultDTO
dto
=
new
TaskResultDTO
();
TaskResultDTO
dto
=
new
TaskResultDTO
();
dto
.
setResultCode
(
"approvalStatus"
);
dto
.
setResultCode
(
"approvalStatus"
);
...
@@ -401,7 +403,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -401,7 +403,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
JSONObject
jsonObject
=
JSONObject
.
parseObject
(
JSONObject
.
toJSONString
(
jgChangeRegistrationName
));
JSONObject
jsonObject
=
JSONObject
.
parseObject
(
JSONObject
.
toJSONString
(
jgChangeRegistrationName
));
jsonObject
.
put
(
"nextTaskId"
,
jgChangeRegistrationName
.
getNextTaskId
());
jsonObject
.
put
(
"nextTaskId"
,
jgChangeRegistrationName
.
getNextTaskId
());
jsonObject
.
put
(
"nextExecuteUser"
,
jgChangeRegistrationName
.
getNextExecutorIds
());
jsonObject
.
put
(
"nextExecuteUser"
,
jgChangeRegistrationName
.
getNextExecutorIds
());
jsonObject
.
put
(
"taskType"
,
BusinessTypeEnum
.
JG_NAME_CHANGE_REGISTRATION
.
getCode
());
jsonObject
.
put
(
"taskType"
,
BusinessTypeEnum
.
JG_NAME_CHANGE_REGISTRATION
.
getCode
());
commonService
.
rollbackTask
(
instanceId
,
jsonObject
);
commonService
.
rollbackTask
(
instanceId
,
jsonObject
);
}
}
...
@@ -439,7 +441,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -439,7 +441,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
String
taskName
=
""
;
String
taskName
=
""
;
String
nextTaskId
=
""
;
String
nextTaskId
=
""
;
JgChangeRegistrationName
jgChangeRegistrationName
=
this
.
getBaseMapper
().
selectById
(
sequenceNbr
);
JgChangeRegistrationName
jgChangeRegistrationName
=
this
.
getBaseMapper
().
selectById
(
sequenceNbr
);
if
(
processTaskDTO
!=
null
&&
processTaskDTO
.
getNextTask
()
!=
null
&&
processTaskDTO
.
getNextTask
().
size
()
>
0
)
{
if
(
processTaskDTO
!=
null
&&
processTaskDTO
.
getNextTask
()
!=
null
&&
processTaskDTO
.
getNextTask
().
size
()
>
0
)
{
taskCode
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getKey
();
taskCode
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getKey
();
taskName
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getName
();
taskName
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getName
();
nextTaskId
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getId
();
nextTaskId
=
processTaskDTO
.
getNextTask
().
get
(
0
).
getId
();
...
@@ -448,14 +450,14 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -448,14 +450,14 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
this
.
buildRoleList
(
Collections
.
singletonList
(
processTaskDTO
),
roleListNext
,
roleListAll
);
this
.
buildRoleList
(
Collections
.
singletonList
(
processTaskDTO
),
roleListNext
,
roleListAll
);
List
<
WorkflowResultDto
>
workflowResultDtos
=
commonService
.
buildWorkFlowInfo
(
Collections
.
singletonList
(
processTaskDTO
));
List
<
WorkflowResultDto
>
workflowResultDtos
=
commonService
.
buildWorkFlowInfo
(
Collections
.
singletonList
(
processTaskDTO
));
String
nextUserIds
=
workflowResultDtos
.
get
(
0
).
getNextExecutorUserIds
();
String
nextUserIds
=
workflowResultDtos
.
get
(
0
).
getNextExecutorUserIds
();
jgChangeRegistrationName
.
setNextExecutorIds
(
String
.
join
(
","
,
roleListNext
));
jgChangeRegistrationName
.
setNextExecutorIds
(
String
.
join
(
","
,
roleListNext
));
jgChangeRegistrationName
.
setPromoter
(
RequestContext
.
getExeUserId
());
jgChangeRegistrationName
.
setPromoter
(
RequestContext
.
getExeUserId
());
jgChangeRegistrationName
.
setInstanceId
(
instanceId
);
jgChangeRegistrationName
.
setInstanceId
(
instanceId
);
jgChangeRegistrationName
.
setNextTaskId
(
nextTaskId
);
jgChangeRegistrationName
.
setNextTaskId
(
nextTaskId
);
if
(!
ObjectUtils
.
isEmpty
(
jgChangeRegistrationName
.
getInstanceStatus
()))
{
if
(!
ObjectUtils
.
isEmpty
(
jgChangeRegistrationName
.
getInstanceStatus
()))
{
jgChangeRegistrationName
.
setInstanceStatus
(
jgChangeRegistrationName
.
getInstanceStatus
()
+
","
+
String
.
join
(
","
,
roleListNext
));
jgChangeRegistrationName
.
setInstanceStatus
(
jgChangeRegistrationName
.
getInstanceStatus
()
+
","
+
String
.
join
(
","
,
roleListNext
));
}
else
{
}
else
{
jgChangeRegistrationName
.
setInstanceStatus
(
String
.
join
(
","
,
roleListNext
));
jgChangeRegistrationName
.
setInstanceStatus
(
String
.
join
(
","
,
roleListNext
));
}
}
if
(
"0"
.
equals
(
operate
))
{
if
(
"0"
.
equals
(
operate
))
{
// 通过操作
// 通过操作
...
@@ -481,17 +483,17 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
...
@@ -481,17 +483,17 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
private
TaskV2Model
updateTaskModel
(
JgChangeRegistrationName
jgChangeRegistrationName
,
String
operate
)
{
private
TaskV2Model
updateTaskModel
(
JgChangeRegistrationName
jgChangeRegistrationName
,
String
operate
)
{
Map
<
String
,
Object
>
params
=
new
HashMap
<>();
Map
<
String
,
Object
>
params
=
new
HashMap
<>();
FlowStatusEnum
flowStatusEnum
=
this
.
getTaskStatus
(
operate
);
FlowStatusEnum
flowStatusEnum
=
this
.
getTaskStatus
(
operate
);
params
.
put
(
"relationId"
,
jgChangeRegistrationName
.
getInstanceId
());
params
.
put
(
"relationId"
,
jgChangeRegistrationName
.
getInstanceId
());
params
.
put
(
"taskStatus"
,
flowStatusEnum
.
getCode
());
params
.
put
(
"taskStatus"
,
flowStatusEnum
.
getCode
());
params
.
put
(
"taskStatusLabel"
,
flowStatusEnum
.
getName
());
params
.
put
(
"taskStatusLabel"
,
flowStatusEnum
.
getName
());
params
.
put
(
"flowStatus"
,
this
.
getTaskStatusByName
(
jgChangeRegistrationName
.
getAuditStatus
()));
params
.
put
(
"flowStatus"
,
this
.
getTaskStatusByName
(
jgChangeRegistrationName
.
getAuditStatus
()));
params
.
put
(
"flowStatusLabel"
,
jgChangeRegistrationName
.
getAuditStatus
());
params
.
put
(
"flowStatusLabel"
,
jgChangeRegistrationName
.
getAuditStatus
());
return
commonService
.
updateTaskModelNew
(
params
);
return
commonService
.
updateTaskModelNew
(
params
);
}
}
private
FlowStatusEnum
getTaskStatus
(
String
operate
)
{
private
FlowStatusEnum
getTaskStatus
(
String
operate
)
{
if
(
"0"
.
equals
(
operate
))
{
if
(
"0"
.
equals
(
operate
))
{
return
FlowStatusEnum
.
TO_BE_FINISHED
;
return
FlowStatusEnum
.
TO_BE_FINISHED
;
}
else
{
}
else
{
return
FlowStatusEnum
.
REJECTED
;
return
FlowStatusEnum
.
REJECTED
;
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment