|
|
|
@ -7,7 +7,6 @@ import com.docus.log.processor.AbstractProcessor;
|
|
|
|
|
import com.docus.server.collect.infrastructure.dao.CollectTypeEnum;
|
|
|
|
|
import com.docus.server.collect.infrastructure.dao.StateEnum;
|
|
|
|
|
import com.docus.server.collect.infrastructure.enums.IIntegerEnum;
|
|
|
|
|
import com.docus.server.tool.ParamsUtils;
|
|
|
|
|
import com.docus.server.tool.SpringUtils;
|
|
|
|
|
import com.docus.server.ws.ITaskOriginalMessageService;
|
|
|
|
|
import com.docus.server.ws.IWsResult;
|
|
|
|
@ -37,9 +36,10 @@ public class VisitorProcessor extends AbstractProcessor {
|
|
|
|
|
throw new RuntimeException("参数为空");
|
|
|
|
|
}
|
|
|
|
|
String jsonStr = JSON.toJSON(converter.convert(message, context.getMethodName()));
|
|
|
|
|
Long taskId = messageService.insertTaskOriginalMessage(jsonStr, message,
|
|
|
|
|
IIntegerEnum.fromDisplay(CollectTypeEnum.class, context.getGroup()));
|
|
|
|
|
context.setParams(ParamsUtils.addParam("taskId", taskId).addParam("jsonStr", jsonStr).param());
|
|
|
|
|
Long taskId = messageService.insertTaskOriginalMessage(jsonStr, message, IIntegerEnum.fromDisplay(CollectTypeEnum.class, context.getGroup()));
|
|
|
|
|
Map<String, Object> params = context.getParams();
|
|
|
|
|
params.put("taskId", taskId);
|
|
|
|
|
params.put("jsonStr", jsonStr);
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|