Commit 36ca21c8 authored by suhuiguang's avatar suhuiguang

1.合并刘林安全追溯逻辑代码代码

parent 897dac03
...@@ -5,7 +5,7 @@ import com.baomidou.mybatisplus.core.toolkit.StringUtils; ...@@ -5,7 +5,7 @@ import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.yeejoin.amos.boot.biz.common.controller.BaseController; import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import com.yeejoin.amos.boot.module.jyjc.biz.job.InspectionExpireRemindJob; import com.yeejoin.amos.boot.module.jyjc.biz.job.InspectionExpireRemindJob;
import com.yeejoin.amos.boot.module.jyjc.biz.service.TaskModelServiceImpl; import com.yeejoin.amos.boot.module.jyjc.biz.service.TaskModelServiceImpl;
import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CommonServiceImpl; import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CommonServiceImpl2;
import com.yeejoin.amos.boot.module.ymt.api.dto.TzBaseEnterpriseInfoDto; import com.yeejoin.amos.boot.module.ymt.api.dto.TzBaseEnterpriseInfoDto;
import com.yeejoin.amos.boot.module.ymt.api.entity.TzBaseEnterpriseInfo; import com.yeejoin.amos.boot.module.ymt.api.entity.TzBaseEnterpriseInfo;
import com.yeejoin.amos.boot.module.ymt.api.entity.TzsUserInfo; import com.yeejoin.amos.boot.module.ymt.api.entity.TzsUserInfo;
...@@ -36,7 +36,7 @@ import java.util.stream.Collectors; ...@@ -36,7 +36,7 @@ import java.util.stream.Collectors;
public class CommonController extends BaseController { public class CommonController extends BaseController {
@Autowired @Autowired
CommonServiceImpl commonserviceImpl; CommonServiceImpl2 commonserviceImpl;
@Autowired @Autowired
TaskModelServiceImpl taskModelService; TaskModelServiceImpl taskModelService;
......
...@@ -6,7 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.Sequence; ...@@ -6,7 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.Sequence;
import com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionResult; import com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionResult;
import com.yeejoin.amos.boot.module.jyjc.biz.event.InspectionDetectionSaveToDbEvent; import com.yeejoin.amos.boot.module.jyjc.biz.event.InspectionDetectionSaveToDbEvent;
import com.yeejoin.amos.boot.module.jyjc.biz.event.publisher.BizEmqPublisher; import com.yeejoin.amos.boot.module.jyjc.biz.event.publisher.BizEmqPublisher;
import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CommonServiceImpl; import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CommonServiceImpl2;
import com.yeejoin.amos.boot.module.ymt.api.entity.InspectionDetectionInfo; import com.yeejoin.amos.boot.module.ymt.api.entity.InspectionDetectionInfo;
import com.yeejoin.amos.boot.module.ymt.api.entity.TzsUserInfo; import com.yeejoin.amos.boot.module.ymt.api.entity.TzsUserInfo;
import com.yeejoin.amos.boot.module.ymt.api.mapper.InspectionDetectionInfoMapper; import com.yeejoin.amos.boot.module.ymt.api.mapper.InspectionDetectionInfoMapper;
...@@ -37,7 +37,7 @@ public class InspectionDetectionSaveToDbEventListener implements ApplicationList ...@@ -37,7 +37,7 @@ public class InspectionDetectionSaveToDbEventListener implements ApplicationList
private int threadNumber; private int threadNumber;
@Autowired @Autowired
CommonServiceImpl commonService; CommonServiceImpl2 commonService;
@Autowired @Autowired
private Sequence sequence; private Sequence sequence;
......
...@@ -15,7 +15,7 @@ import com.yeejoin.amos.boot.module.jyjc.api.model.InstanceRuntimeData; ...@@ -15,7 +15,7 @@ import com.yeejoin.amos.boot.module.jyjc.api.model.InstanceRuntimeData;
import com.yeejoin.amos.boot.module.jyjc.api.model.TaskModelDto; import com.yeejoin.amos.boot.module.jyjc.api.model.TaskModelDto;
import com.yeejoin.amos.boot.module.jyjc.api.model.WorkflowResultDto; import com.yeejoin.amos.boot.module.jyjc.api.model.WorkflowResultDto;
import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CmWorkflowServiceImpl; import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CmWorkflowServiceImpl;
import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CommonServiceImpl; import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.CommonServiceImpl2;
import com.yeejoin.amos.boot.module.jyjc.biz.util.JsonUtils; import com.yeejoin.amos.boot.module.jyjc.biz.util.JsonUtils;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum; import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import com.yeejoin.amos.feign.privilege.model.AgencyUserModel; import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
...@@ -51,7 +51,7 @@ public class TaskModelServiceImpl { ...@@ -51,7 +51,7 @@ public class TaskModelServiceImpl {
private RedisUtils redisUtils; private RedisUtils redisUtils;
@Autowired @Autowired
CommonServiceImpl commonService; CommonServiceImpl2 commonService;
@Autowired @Autowired
IDataDictionaryService iDataDictionaryService; IDataDictionaryService iDataDictionaryService;
...@@ -475,7 +475,7 @@ public class TaskModelServiceImpl { ...@@ -475,7 +475,7 @@ public class TaskModelServiceImpl {
} }
String taskId = map.get("nextTaskId").toString(); String taskId = map.get("nextTaskId").toString();
String instanceId = map.get("instanceId").toString(); String instanceId = map.get("instanceId").toString();
String lockKey = CommonServiceImpl.buildJcExecuteLockKey(instanceId); String lockKey = CommonServiceImpl2.buildJcExecuteLockKey(instanceId);
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
try { try {
boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS); boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS);
......
...@@ -29,7 +29,7 @@ import java.util.List; ...@@ -29,7 +29,7 @@ import java.util.List;
* @author Administrator * @author Administrator
*/ */
@Service @Service
public class CommonServiceImpl { public class CommonServiceImpl2 {
@Value("${jyjc.user-post:6615}") @Value("${jyjc.user-post:6615}")
private String jyjcUserPost; private String jyjcUserPost;
......
...@@ -98,7 +98,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -98,7 +98,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
@Autowired @Autowired
WorkflowFeignService workflowFeignService; WorkflowFeignService workflowFeignService;
@Autowired @Autowired
CommonServiceImpl commonService; CommonServiceImpl2 commonService;
@Autowired @Autowired
CmWorkflowServiceImpl cmWorkflowService; CmWorkflowServiceImpl cmWorkflowService;
@Value("classpath:/json/bizTypeInfo.json") @Value("classpath:/json/bizTypeInfo.json")
...@@ -541,7 +541,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -541,7 +541,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
public void doReceive(Map<String, Object> params) { public void doReceive(Map<String, Object> params) {
String instanceId = params.get("instanceId").toString(); String instanceId = params.get("instanceId").toString();
String nextTaskId = params.get("nextTaskId").toString(); String nextTaskId = params.get("nextTaskId").toString();
String lockKey = CommonServiceImpl.buildJcExecuteLockKey(instanceId); String lockKey = CommonServiceImpl2.buildJcExecuteLockKey(instanceId);
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
try { try {
boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS); boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS);
...@@ -689,7 +689,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -689,7 +689,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
public Boolean doReject(Map<String, Object> params) { public Boolean doReject(Map<String, Object> params) {
String instanceId = params.get("instanceId").toString(); String instanceId = params.get("instanceId").toString();
String nextTaskId = params.get("nextTaskId").toString(); String nextTaskId = params.get("nextTaskId").toString();
String lockKey = CommonServiceImpl.buildJcExecuteLockKey(instanceId); String lockKey = CommonServiceImpl2.buildJcExecuteLockKey(instanceId);
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
try { try {
boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS); boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS);
...@@ -764,7 +764,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -764,7 +764,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
* 撤回流程办理单 * 撤回流程办理单
*/ */
public Boolean doRollback(String sequenceNbr, String instanceId, String nextTaskId) { public Boolean doRollback(String sequenceNbr, String instanceId, String nextTaskId) {
String lockKey = CommonServiceImpl.buildJcExecuteLockKey(instanceId); String lockKey = CommonServiceImpl2.buildJcExecuteLockKey(instanceId);
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
try { try {
boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS); boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS);
......
...@@ -101,7 +101,7 @@ public class JyjcInspectionResultServiceImpl extends BaseService<JyjcInspectionR ...@@ -101,7 +101,7 @@ public class JyjcInspectionResultServiceImpl extends BaseService<JyjcInspectionR
TzBaseEnterpriseInfoMapper tzBaseEnterpriseInfoMapper; TzBaseEnterpriseInfoMapper tzBaseEnterpriseInfoMapper;
@Autowired @Autowired
CommonServiceImpl commonService; CommonServiceImpl2 commonService;
@Autowired @Autowired
TzsUserInfoMapper tzsUserInfoMapper; TzsUserInfoMapper tzsUserInfoMapper;
......
...@@ -116,7 +116,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -116,7 +116,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
private TzsUserInfoMapper userInfoMapper; private TzsUserInfoMapper userInfoMapper;
@Autowired @Autowired
CommonServiceImpl commonService; CommonServiceImpl2 commonService;
@Autowired @Autowired
CmWorkflowServiceImpl cmWorkflowService; CmWorkflowServiceImpl cmWorkflowService;
...@@ -514,7 +514,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -514,7 +514,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
public JyjcOpeningApplication executeFlow(Map<String, Object> params) { public JyjcOpeningApplication executeFlow(Map<String, Object> params) {
String instanceId = params.get("instanceId").toString(); String instanceId = params.get("instanceId").toString();
String nextTaskId = params.get("nextTaskId").toString(); String nextTaskId = params.get("nextTaskId").toString();
String lockKey = CommonServiceImpl.buildJcExecuteLockKey(instanceId); String lockKey = CommonServiceImpl2.buildJcExecuteLockKey(instanceId);
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
try { try {
boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS); boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS);
...@@ -606,7 +606,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -606,7 +606,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
private void executeOneStep(JyjcOpeningApplicationModel openingApplication) { private void executeOneStep(JyjcOpeningApplicationModel openingApplication) {
String instanceId = openingApplication.getWorkflowProstanceId(); String instanceId = openingApplication.getWorkflowProstanceId();
String nextTaskId = openingApplication.getNextTaskId(); String nextTaskId = openingApplication.getNextTaskId();
String lockKey = CommonServiceImpl.buildJcExecuteLockKey(instanceId); String lockKey = CommonServiceImpl2.buildJcExecuteLockKey(instanceId);
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
try { try {
boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS); boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS);
...@@ -654,7 +654,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -654,7 +654,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
* 撤回流程办理单 * 撤回流程办理单
*/ */
public JyjcOpeningApplication stopFlow(String sequenceNbr, String instanceId, String nextTaskId) { public JyjcOpeningApplication stopFlow(String sequenceNbr, String instanceId, String nextTaskId) {
String lockKey = CommonServiceImpl.buildJcExecuteLockKey(instanceId); String lockKey = CommonServiceImpl2.buildJcExecuteLockKey(instanceId);
RLock lock = redissonClient.getLock(lockKey); RLock lock = redissonClient.getLock(lockKey);
try { try {
boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS); boolean isLocked = lock.tryLock(0, 180, TimeUnit.SECONDS);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment