package com.java110.api.listener.purchaseApply;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.api.listener.AbstractServiceApiListener;
|
import com.java110.core.annotation.Java110Listener;
|
import com.java110.core.context.DataFlowContext;
|
import com.java110.core.smo.common.IActivitiWorkflowImageInnerServiceSMO;
|
import com.java110.core.event.service.api.ServiceDataFlowEvent;
|
import com.java110.utils.constant.ServiceCodePurchaseApplyConstant;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.Base64Convert;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.HttpStatus;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.util.MultiValueMap;
|
|
|
/**
|
* 查询小区侦听类
|
*/
|
@Java110Listener("listWorkflowImageListener")
|
public class ListWorkflowImageListener extends AbstractServiceApiListener {
|
|
@Autowired
|
private IActivitiWorkflowImageInnerServiceSMO activitiWorkflowImageInnerServiceSMOImpl;
|
|
|
|
@Override
|
public String getServiceCode() {
|
return ServiceCodePurchaseApplyConstant.LIST_WORKFLOW_IMAGE;
|
}
|
|
@Override
|
public HttpMethod getHttpMethod() {
|
return HttpMethod.GET;
|
}
|
|
|
@Override
|
public int getOrder() {
|
return DEFAULT_ORDER;
|
}
|
|
@Override
|
protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
|
Assert.hasKeyAndValue(reqJson, "taskId", "必填，请填写任务ID");
|
}
|
|
@Override
|
protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
|
|
String taskId = reqJson.getString("taskId");
|
|
String image = activitiWorkflowImageInnerServiceSMOImpl.getWorkflowImage(taskId);
|
MultiValueMap headers = new HttpHeaders();
|
headers.add("Accept-Ranges", "bytes");
|
headers.add("content-type", "application/octet-stream");
|
|
try {
|
byte[] contextByte = Base64Convert.base64ToByte(image
|
.replace("data:image/webp;base64,", "")
|
.replace("data:image/png;base64,", "")
|
.replace("data:image/jpeg;base64,", "")
|
);
|
ResponseEntity<Object> responseEntity = new ResponseEntity<Object>(contextByte, headers, HttpStatus.OK);
|
context.setResponseEntity(responseEntity);
|
}catch (Exception e){
|
ResponseEntity<Object> responseEntity = new ResponseEntity<Object>("查询失败", HttpStatus.BAD_REQUEST);
|
context.setResponseEntity(responseEntity);
|
}
|
|
}
|
}
|
