提交工作流相关代码

cqb-flow-core/src/main/java/com/qmth/cqb/flow/dao/DataMapModelRepo.java

@@ -0,0 +1,10 @@
+package com.qmth.cqb.flow.dao;
+
+import org.springframework.data.mongodb.repository.MongoRepository;
+import org.springframework.data.repository.query.QueryByExampleExecutor;
+
+import com.qmth.cqb.flow.model.DataMapModel;
+
+public interface DataMapModelRepo extends MongoRepository<DataMapModel, String>,QueryByExampleExecutor<DataMapModel> {
+
+}

cqb-flow-core/src/main/java/com/qmth/cqb/flow/model/DataMapModel.java

@@ -0,0 +1,39 @@
+package com.qmth.cqb.flow.model;
+
+public class DataMapModel {
+	private String id;
+	private String processInstanceId;
+	private String mainDataId;
+	
+	public DataMapModel(){}
+	
+	public DataMapModel(String processInstanceId,String mainDataId){
+		this.processInstanceId = processInstanceId;
+		this.mainDataId = mainDataId;
+	}
+	
+	public DataMapModel(String mainDataId){
+		this.mainDataId = mainDataId;
+	}
+	
+	public String getId() {
+		return id;
+	}
+	public void setId(String id) {
+		this.id = id;
+	}
+	public String getProcessInstanceId() {
+		return processInstanceId;
+	}
+	public void setProcessInstanceId(String processInstanceId) {
+		this.processInstanceId = processInstanceId;
+	}
+	public String getMainDataId() {
+		return mainDataId;
+	}
+	public void setMainDataId(String mainDataId) {
+		this.mainDataId = mainDataId;
+	}
+	
+	
+}

cqb-flow-core/src/main/java/com/qmth/cqb/flow/service/DataMapModelService.java

@@ -0,0 +1,9 @@
+package com.qmth.cqb.flow.service;
+
+import com.qmth.cqb.flow.model.DataMapModel;
+
+public interface DataMapModelService {
+	public void saveDataMapModel(DataMapModel dataMapModel);
+	
+	public DataMapModel findDataMapModel(String mainId);
+}

cqb-flow-core/src/main/java/com/qmth/cqb/flow/serviceImpl/DataMapModelServiceImpl.java

@@ -0,0 +1,27 @@
+package com.qmth.cqb.flow.serviceImpl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Example;
+import org.springframework.stereotype.Service;
+
+import com.qmth.cqb.flow.dao.DataMapModelRepo;
+import com.qmth.cqb.flow.model.DataMapModel;
+import com.qmth.cqb.flow.service.DataMapModelService;
+
+@Service("dataMapModelService")
+public class DataMapModelServiceImpl implements DataMapModelService{
+	
+	@Autowired
+	private DataMapModelRepo dataMapModelRepo;
+	
+	@Override
+	public void saveDataMapModel(DataMapModel dataMapModel) {
+		dataMapModelRepo.save(dataMapModel);
+	}
+
+	@Override
+	public DataMapModel findDataMapModel(String mainId) {
+		return dataMapModelRepo.findOne(Example.of(new DataMapModel(mainId)));
+	}
+
+}