Просмотр исходного кода

审批流添加事务

release_toaliyun_real
luozukai 7 лет назад
Родитель
Сommit
24e09e649e
2 измененных файлов: 8 добавлений и 2 удалений
  1. +1
    -1
      mallinkService/src/main/java/com/iformall/service/WxFlowService.java
  2. +7
    -1
      mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java

+ 1
- 1
mallinkService/src/main/java/com/iformall/service/WxFlowService.java Просмотреть файл

@@ -51,7 +51,7 @@ public interface WxFlowService {
/** /**
* 生成流程图 * 生成流程图
* @param httpServletResponse * @param httpServletResponse
* @param processInstanceId
* @param businessId
* @throws Exception * @throws Exception
*/ */
void genProcessDiagram(HttpServletResponse httpServletResponse, String businessId) throws Exception; void genProcessDiagram(HttpServletResponse httpServletResponse, String businessId) throws Exception;


+ 7
- 1
mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java Просмотреть файл

@@ -26,8 +26,9 @@ import org.flowable.task.api.Task;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.io.InputStream; import java.io.InputStream;
import java.io.OutputStream; import java.io.OutputStream;
@@ -72,6 +73,7 @@ public class WxFlowServiceImpl implements WxFlowService {
} }


@Override @Override
@Transactional(propagation = Propagation.REQUIRED,rollbackFor = {Exception.class})
public ResultData start(Map<String, Object> params,Long userId,String userName,String tenantId) { public ResultData start(Map<String, Object> params,Long userId,String userName,String tenantId) {
String remark = (String)params.get("remark"); String remark = (String)params.get("remark");
Long businessId = Long.parseLong((String)params.get("businessId")); Long businessId = Long.parseLong((String)params.get("businessId"));
@@ -110,6 +112,8 @@ public class WxFlowServiceImpl implements WxFlowService {
wxFlowRecord.setStatus(EnumFlowRecordStatus.NEW.getCode()); wxFlowRecord.setStatus(EnumFlowRecordStatus.NEW.getCode());
wxFlowRecordService.saveOrUpdate(wxFlowRecord); wxFlowRecordService.saveOrUpdate(wxFlowRecord);


System.out.println(1/0);

// 给审批人发送代办通知短信 // 给审批人发送代办通知短信
List<MallUserInfo> mallUserInfoList = getUserByProcessInstanceId(processInstance.getId()); List<MallUserInfo> mallUserInfoList = getUserByProcessInstanceId(processInstance.getId());
for (MallUserInfo mallUserInfo:mallUserInfoList) { for (MallUserInfo mallUserInfo:mallUserInfoList) {
@@ -174,6 +178,7 @@ public class WxFlowServiceImpl implements WxFlowService {
} }


@Override @Override
@Transactional(propagation = Propagation.REQUIRED,rollbackFor = {Exception.class})
public ResultData apply(Map<String, String> params,Long userId,String userName,String tenantId) { public ResultData apply(Map<String, String> params,Long userId,String userName,String tenantId) {
String taskId = params.get("taskId"); String taskId = params.get("taskId");
String processInstanceId = params.get("processInstanceId"); String processInstanceId = params.get("processInstanceId");
@@ -248,6 +253,7 @@ public class WxFlowServiceImpl implements WxFlowService {
} }


@Override @Override
@Transactional(propagation = Propagation.REQUIRED,rollbackFor = {Exception.class})
public ResultData reject(Map<String, String> params,Long userId,String userName,String tenantId) { public ResultData reject(Map<String, String> params,Long userId,String userName,String tenantId) {
String taskId = params.get("taskId"); String taskId = params.get("taskId");
String processInstanceId = params.get("processInstanceId"); String processInstanceId = params.get("processInstanceId");


Загрузка…
Отмена
Сохранить