data_monitor/process_ medical/src/medical_for_reference.go

package main

import (
	log "github.com/donnie4w/go-logger/logger"
	qu "qfw/util"
	"regexp"
	"strings"
)

var timeReg = regexp.MustCompile(`^(\d{4}-\d{2}-\d{2})$`)
//企业许可备案信息
func forReference()  {
	sess := save_mgo.GetMgoConn()
	defer save_mgo.DestoryMongoConn(sess)
	q,total:=map[string]interface{}{},0
	ok1,ok2:=0,0
	it := sess.DB(save_mgo.DbName).C("nmpa_company").Find(&q).Iter()
	for tmp := make(map[string]interface{}); it.Next(&tmp);total++{
		if total%10000==0 {
			log.Debug("curent index ",total,ok1,ok2)
		}
		class := qu.ObjToString(tmp["class"])
		if class=="生产型"{
			ok1++
			//data := dealWithSCX(tmp)
			//MysqlTool.Insert("f_production_register",data)
		}else if class=="经营型" {
			ok2++
			data := dealWithJYX(tmp)
			MysqlTool.Insert("f_business_register",data)
		}else {

		}

		tmp = make(map[string]interface{})
	}
	log.Debug("is over ",total,ok1,ok2)
}

//处理生产型
func dealWithSCX (tmp map[string]interface{}) map[string]interface{}{
	data := map[string]interface{}{}
	yxqx := qu.ObjToString(tmp["yxqx"])
	barq := qu.ObjToString(tmp["barq"])
	if yxqx!="" && timeReg.MatchString(yxqx) {
		data["validitydate"] = yxqx
	}
	if barq!="" && timeReg.MatchString(barq){
		data["approvedate"] = barq
	}

	data["regnum"] = qu.ObjToString(tmp["reg_no"])
	type_str:=strings.ReplaceAll(qu.ObjToString(tmp["type"]),"企业","")
	data["type"] = type_str
	data["address"] = qu.ObjToString(tmp["product_address"])
	data["scope"] = qu.ObjToString(tmp["product_range"])
	data["approvedepart"] = qu.ObjToString(tmp["badw"])
	data["companyname"] = qu.ObjToString(tmp["company"])
	data["responsible_person"] = qu.ObjToString(tmp["responsible_persons"])
	data["legal_person"] = qu.ObjToString(tmp["legal_person"])
	data["residence"] = qu.ObjToString(tmp["address"])

	return data
}
//处理经营型
func dealWithJYX (tmp map[string]interface{}) map[string]interface{}{
	data := map[string]interface{}{}
	yxqx := qu.ObjToString(tmp["yxqx"])
	barq := qu.ObjToString(tmp["barq"])
	if yxqx!="" && timeReg.MatchString(yxqx) {
		data["validitydate"] = yxqx
	}
	if barq!="" && timeReg.MatchString(barq){
		data["approvedate"] = barq
	}

	data["regnum"] = qu.ObjToString(tmp["reg_no"])
	type_str:=strings.ReplaceAll(qu.ObjToString(tmp["type"]),"企业","")
	data["type"] = type_str
	data["address"] = qu.ObjToString(tmp["business_address"])
	data["scope"] = qu.ObjToString(tmp["business_range"])
	data["business_type"] = qu.ObjToString(tmp["business_mode"])
	data["approvedepart"] = qu.ObjToString(tmp["badw"])
	data["websitename"] = ""
	data["website"] = ""
	data["platformname"] = ""
	data["clientname"] = ""
	data["storageroom"] = qu.ObjToString(tmp["storehouse_address"])
	data["companyname"] = qu.ObjToString(tmp["company"])
	data["responsible_person"] = qu.ObjToString(tmp["legal_person"])
	data["legal_person"] = qu.ObjToString(tmp["responsible_persons"])
	data["residence"] = qu.ObjToString(tmp["address"])

	return data
}