package cn.autoform.web.client.util;
|
|
import cn.autoform.db.exten.Process;
|
import cn.autoform.util.thread.Keys;
|
import cn.autoform.util.thread.ThreadData;
|
import cn.autoform.util.tool.JSONTool;
|
import cn.autoform.web.client.WorkflowClient;
|
import lombok.Getter;
|
import lombok.Setter;
|
import lombok.extern.slf4j.Slf4j;
|
import net.sf.json.JSONObject;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.concurrent.TimeoutException;
|
|
@Service
|
@Slf4j
|
public class WorkflowTool {
|
|
@Getter
|
@Setter
|
private HttpServletRequest request;
|
|
@Resource
|
private WorkflowClient workflowClient;
|
|
@Value("${process-service-id}")
|
private Integer processServiceId;
|
|
@Value("${process-access-id}")
|
private String processAccessId;
|
|
@Value("${process-app-key}")
|
private String processAppKey;
|
|
@Value("${process-security-key}")
|
private String processSecurityKey;
|
|
//请求参数
|
public Map<String, Object> getParam(Map<String, Object> data){
|
Map<String, Object> param = new TreeMap<>(data);
|
param.put("id", processAccessId + new SimpleDateFormat("yyyyMMdd").format(new Date()) + String.format("%09d", new Random().nextInt(999999999)));
|
param.put("sign", countSign(param));
|
return param;
|
}
|
|
public Process getProcess(JSONObject jsonObjects){
|
@SuppressWarnings("unchecked")
|
Map<String,String> JsonObject = JSONTool.toObj(JSONTool.toJson(jsonObjects),Map.class);
|
Map<String, Object> param = new TreeMap<>();
|
Map<String, Object> loginParam = new TreeMap<>();
|
Map<String, Object> data = new TreeMap<>();
|
param.put("data", JSONTool.toJson(jsonObjects));
|
loginParam.put("loginSecurity",getLogInSecurity());
|
data.putAll(param);
|
data.putAll(loginParam);
|
System.err.println();
|
Process pro = new Process();
|
pro.setFormID(JsonObject.get("formID"));
|
System.out.println("进入粗");
|
pro.setTenantID(Objects.toString(JsonObject.get("tenantID"),null));
|
pro.setFlowmap(getParam(data));
|
return pro;
|
}
|
|
public String getLogInSecurity() {
|
// String token = ThreadData.get(Keys.TOKEN);
|
String openId = ThreadData.get(Keys.OPEN_ID);
|
String tenantId = ThreadData.get(Keys.TENANT_ID);
|
String companyId = ThreadData.get(Keys.COMPANY_ID);
|
Integer serviceId = this.processServiceId;
|
return "{\"serviceId\":\"" + serviceId + "\",\"tenantId\":\""
|
+ tenantId + "\",\"openId\":\""
|
+ openId + "\",\"companyId\":\""
|
+ companyId + "\"}";
|
}
|
|
//取出Sign
|
public String countSign(Map<String, Object> param){
|
StringBuilder sb = new StringBuilder();
|
for (Map.Entry<String, Object> map : param.entrySet()) {
|
/* 拼接条件 */
|
sb.append(map.getKey())
|
.append('=')
|
.append(map.getValue())
|
.append('&');
|
}
|
sb.append("key=").append(this.processSecurityKey);
|
log.debug("调用工作流接口，参数为：{}", sb);
|
return MD5.GetMD5Code(sb.toString().replaceAll(" ",""));
|
}
|
|
/**
|
* 流程结束
|
* @param result
|
* @return
|
*/
|
public boolean isOver(Map<String, Object> result) {
|
Map<String, Object> inst =
|
Optional.ofNullable(result.get("data"))
|
.filter(data->data instanceof Map)
|
.map(data->(Map) data)
|
.orElse(new HashMap<>());
|
return Optional.ofNullable(inst)
|
.map(data->data.get("workItems"))
|
.filter(data->data instanceof List)
|
.map(data->(List) data)
|
.map(List::size)
|
.orElse(0) == 0
|
&&
|
Objects.equals(
|
Optional.ofNullable(inst)
|
.map(data->data.get("processState"))
|
.map(Object::toString)
|
.orElse("")
|
, "20");
|
}
|
|
public boolean isOne(String processInstId) throws TimeoutException {
|
JSONObject j = new JSONObject();
|
j.put("processInstId", processInstId);
|
Map workflowResult = workflowClient.instLog(getProcess(j));
|
List<Map> data = Optional.ofNullable(workflowResult)
|
.map(d->d.get("data"))
|
.map(d->(Map)d)
|
.map(d->d.get("data"))
|
.map(d->(List)d)
|
.orElse(Collections.EMPTY_LIST);
|
if(data.size() <= 1){
|
return false;
|
}
|
if(Objects.equals(data.get(0).get("activityDefId"), data.get(data.size()-1).get("activityDefId"))){
|
return true;
|
}
|
return false;
|
}
|
|
}
|
