v0.7.0 支持多线程调用业务接口

ReadMe.txt

@@ -84,4 +84,5 @@ v0.6.12
 v0.6.13 增加聚类结果中点数小于20的类别剔除功能；修改降采样后整个点云数量小于50退出（原来是200）
 v0.6.14 修改茎识别方法，通过2d高密度点找到茎的位置，然后提取株的最大空间内点云，用直线分割的方法得到茎的位置，避免识别位置错误
 v0.6.15 修改抓取点识别方法，通过比较直线点云和原始点云相同位置邻域内xz的范围，确定此点是否是无干扰点的茎
-v0.6.16 加强苗的识别，增加倾斜苗的检测,修改排序错乱问题
+v0.6.16 加强苗的识别，增加倾斜苗的检测,修改排序错乱问题
+v0.7.0 支持多线程调用业务接口

data_def_api.h

@@ -140,6 +140,10 @@ typedef struct
 	double rs_grab_y;//砧木上苗抓取位置y，毫米
 	double rs_grab_z;//砧木上苗抓取位置z，毫米
 
+	double sc_grab_x;//穗苗上苗抓取位置x，毫米
+	double sc_grab_y;//穗苗上苗抓取位置y，毫米
+	double sc_grab_z;//穗苗上苗抓取位置z，毫米
+
 	double rs_oa;//砧木最优角度
 	//double rs_oa_base;//砧木基质最优角度
 	//double rs_oa_stem_y_fork;//茎分叉点y，毫米

gcv_conf.yml

@@ -1,6 +1,6 @@
 %YAML:1.0
 conf_parameters:
-   image_show: 1
+   image_show: 0
    image_return: 1
    image_row_grid: 20
    image_col_grid: 100

grab_point_rs.cpp

@@ -254,9 +254,16 @@ namespace graft_cv {
 		if (m_pLogger) {
 			m_pLogger->INFO("end get_optimal_seed");
 		}
-		posinfo.rs_grab_x = selected_pt.x;
-		posinfo.rs_grab_y = selected_pt.y;
-		posinfo.rs_grab_z = selected_pt.z;
+		if (m_dtype == 0) {
+			posinfo.sc_grab_x = selected_pt.x;
+			posinfo.sc_grab_y = selected_pt.y;
+			posinfo.sc_grab_z = selected_pt.z;
+		}
+		else {
+			posinfo.rs_grab_x = selected_pt.x;
+			posinfo.rs_grab_y = selected_pt.y;
+			posinfo.rs_grab_z = selected_pt.z;
+		}
 
 		////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 		//6 debug ÏÔʾ½á¹û

graft_cv_api.cpp

@@ -19,7 +19,7 @@ extern CRITICAL_SECTION g_cs;
 namespace graft_cv
 {
 
-	char *g_version_str = "0.6.16";
+	char *g_version_str = "0.7.0";
 
 	//configure
 	string g_conf_file = "./gcv_conf.yml";	
@@ -44,12 +44,13 @@ namespace graft_cv
 	CRootStockCutPointReid g_rs_cp_reid = CRootStockCutPointReid(g_cp,&g_logger);
 	CScionCutPoint g_sc_cp = CScionCutPoint(g_cp,&g_logger);
 
-	CRootStockGrabPoint g_rs_gp(g_cp, &g_logger);
+	CRootStockGrabPoint g_sola_grab_rs(g_cp, &g_logger);
+	CRootStockGrabPoint g_sola_grab_sc(g_cp, &g_logger);
 
-	CSolaCutPointReid g_sola_rs = CSolaCutPointReid(g_cp, 1, &g_logger);
-	CSolaCutPointReid g_sola_sc = CSolaCutPointReid(g_cp, 0, &g_logger);
+	CSolaCutPointReid g_sola_reid_rs = CSolaCutPointReid(g_cp, 1, &g_logger);
+	CSolaCutPointReid g_sola_reid_sc = CSolaCutPointReid(g_cp, 0, &g_logger);
 
-	//
+	//??¶àÏß³ÌÓÐÎÊÌâ
 	map<string, cv::Mat> g_img_cache;
 	
 
@@ -140,9 +141,10 @@ namespace graft_cv
 		g_oa.set_image_saver(&g_pImStore);
 		g_rs_cp.set_image_saver(&g_pImStore);
 		g_sc_cp.set_image_saver(&g_pImStore);
-		g_rs_gp.set_image_saver(&g_pImStore);
-		g_sola_rs.set_image_saver(&g_pImStore);
-		g_sola_rs.set_image_saver(&g_pImStore);		
+		g_sola_grab_rs.set_image_saver(&g_pImStore);
+		g_sola_grab_sc.set_image_saver(&g_pImStore);
+		g_sola_reid_rs.set_image_saver(&g_pImStore);
+		g_sola_reid_sc.set_image_saver(&g_pImStore);		
 		return 0;
 	}
 
@@ -296,23 +298,23 @@ namespace graft_cv
 		return 0;
 	};*/
 	//
-	int sola_grab_point(
+	int sola_grab_point_rs(
 		float* points,
 		int pixel_size,
-		int pt_size, 
-		int dtype,
+		int pt_size, 		
 		PositionInfo& posinfo,
 		const char* fn/*=0*/
 	)
 	{
 		memset(&posinfo, 0, sizeof(PositionInfo));
+		int dtype = 1;
 		try {
-			int rst = g_rs_gp.load_data(points, pixel_size, pt_size, fn);
+			int rst = g_sola_grab_rs.load_data(points, pixel_size, pt_size, fn);
 			if (rst <= 0) {
 				g_logger.ERRORINFO("invalid points");
 				return 1;
 			}
-			int oa = g_rs_gp.grab_point_detect(dtype, posinfo);
+			int oa = g_sola_grab_rs.grab_point_detect(dtype, posinfo);
 			if (oa != 0) {
 				g_logger.ERRORINFO("no points");
 				return 1;
@@ -334,6 +336,43 @@ namespace graft_cv
 
 	}
 
+	int sola_grab_point_sc(
+		float* points,
+		int pixel_size,
+		int pt_size,		
+		PositionInfo& posinfo,
+		const char* fn/*=0*/
+	)
+	{
+		memset(&posinfo, 0, sizeof(PositionInfo));
+		int dtype = 0;
+		try {
+			int rst = g_sola_grab_sc.load_data(points, pixel_size, pt_size, fn);
+			if (rst <= 0) {
+				g_logger.ERRORINFO("invalid points");
+				return 1;
+			}
+			int oa = g_sola_grab_sc.grab_point_detect(dtype, posinfo);
+			if (oa != 0) {
+				g_logger.ERRORINFO("no points");
+				return 1;
+			}
+		}
+		catch (std::exception &err) {
+			g_logger.ERRORINFO(err.what());
+			return 1;
+		}
+		catch (string& msg) {
+			g_logger.ERRORINFO(msg);
+			return 1;
+		}
+		catch (...) {
+			g_logger.ERRORINFO("unknown error");
+			return 1;
+		}
+		return 0;
+
+	}
 
 	//9
 	int rs_oa_get_result(
@@ -422,16 +461,34 @@ namespace graft_cv
 	}
 
 	// 
-	int sola_cut_point_reid(ImgInfo*imginfo, int sola_type, PositionInfo& posinfo)
+	int sola_cut_point_reid_rs(ImgInfo*imginfo, PositionInfo& posinfo)
 	{
 		memset(&posinfo, 0, sizeof(PositionInfo));
+		int sola_type = 1;
 		try {
-			if (sola_type == 0) {
-				g_sola_sc.cut_point_reid(imginfo, cv::Mat(), posinfo);
-			}
-			else {
-				g_sola_rs.cut_point_reid(imginfo, cv::Mat(), posinfo);
-			}			
+			g_sola_reid_rs.cut_point_reid(imginfo, cv::Mat(), posinfo);
+		}
+		catch (std::exception &err) {
+			g_logger.ERRORINFO(err.what());
+			return 1;
+		}
+		catch (string& msg) {
+			g_logger.ERRORINFO(msg);
+			return 1;
+		}
+		catch (...) {
+			g_logger.ERRORINFO("unknown error");
+			return 1;
+		}
+		return 0;
+	}
+
+	int sola_cut_point_reid_sc(ImgInfo*imginfo, PositionInfo& posinfo)
+	{
+		memset(&posinfo, 0, sizeof(PositionInfo));
+		int sola_type = 0;
+		try {
+			g_sola_reid_sc.cut_point_reid(imginfo, cv::Mat(), posinfo);
 		}
 		catch (std::exception &err) {
 			g_logger.ERRORINFO(err.what());

graft_cv_api.h

@@ -77,8 +77,8 @@ GCV_API void get_version(char* buf);
 //				posinfo.rs_pre_z;
 //				其余数据为0
 //  返回： 0- 正常； 其他- 失败
-GCV_API int sola_grab_point(float* points, int pixel_size, int pt_size, int dtype, PositionInfo& posinfo, const char* fn=0);
-
+GCV_API int sola_grab_point_rs(float* points, int pixel_size, int pt_size, PositionInfo& posinfo, const char* fn=0);
+GCV_API int sola_grab_point_sc(float* points, int pixel_size, int pt_size, PositionInfo& posinfo, const char* fn = 0);
 
 
 //12  砧木最优角度识别,追加图像，要求图像的角度按顺序，第一帧图像角度为0，最后一帧图像角度为180
@@ -152,7 +152,8 @@ GCV_API int rs_cut_point_reid(ImgInfo*, const char* pre_img_id, PositionInfo& po
 //                           图1： 灰度图像，拟合椭圆
 //                            
 //   返回： 0- 正常； 1- 失败
-GCV_API int sola_cut_point_reid(ImgInfo*, int sola_type, PositionInfo& posinfo);
+GCV_API int sola_cut_point_reid_rs(ImgInfo*, PositionInfo& posinfo);
+GCV_API int sola_cut_point_reid_sc(ImgInfo*, PositionInfo& posinfo);
 
 
 

imstorage_manager.cpp

@@ -249,11 +249,13 @@ int CImStoreManager::saveBinPly(
 {
 	if (!is_valid_folder()) { return 1; }
 	if (pcd->points.size()==0) { return 1; }
+	
+	EnterCriticalSection(&g_cs_pcd);
 	string tar_file = m_storeDir + "/" + name_id + ".ply";		
 	PcdParam pcdp;
 	pcdp.pcd_name = tar_file;
 	pcl::copyPointCloud(*pcd, pcdp.pcd);	
-	EnterCriticalSection(&g_cs_pcd);
+	
 	m_pcds.push(pcdp);
 	//cout<<"=========="<<pcdp.pcd_name<<endl;
 	LeaveCriticalSection(&g_cs_pcd);

logger.cpp

@@ -7,6 +7,7 @@ namespace graft_cv{
 		:m_target(terminal)
 		,m_level(debug)
 		,m_outfile(ofs)
+		,m_pMtx(new std::mutex())
 	{
 		cout<<currTime()<<" [WELCOME] ===========start logger==========="<<endl;
 	}
@@ -15,6 +16,7 @@ namespace graft_cv{
 		,m_level(level)
 		,m_path(path)
 		,m_outfile(ofs)
+		, m_pMtx(new std::mutex())
 	{
 		string tmp = currTime() +" [WELCOME] ===========start logger===========\n";
 		if(m_target !=terminal){
@@ -40,6 +42,7 @@ namespace graft_cv{
 	}
 	void CGcvLogger::output(string text, log_level act_level)
 	{
+		m_pMtx->lock();
 		string prefix;
 		if(act_level == debug){
 			prefix = " [DEBUG] ";
@@ -65,6 +68,7 @@ namespace graft_cv{
 			m_outfile<< output_content;
 			m_outfile.flush();
 		}
+		m_pMtx->unlock();
 	}
 
 	void CGcvLogger::DEBUG(string text)

logger.h

@@ -4,6 +4,7 @@
 #include <string>
 
 #include <fstream>
+#include <mutex>
 
 using namespace std;
 
@@ -18,6 +19,8 @@ namespace graft_cv{
 		log_target m_target;
 		string m_path;
 		log_level m_level;
+		std::shared_ptr<std::mutex> m_pMtx;
+
 		void output(string text, log_level act_level);
 	public:
 		CGcvLogger(ofstream&);