ent_dispose/qyxy_zsl/main.go

package main

import (
	"fmt"
	"github.com/spf13/viper"
	"github.com/xuri/excelize/v2"
	utils "jygit.jydev.jianyu360.cn/data_processing/common_utils"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
	"strconv"
	"strings"
)

var (
	Mgo      *mongodb.MongodbSim
	baseMap  = make(map[string]map[string]interface{})
	filename string
	GF       GlobalConf
)

func InitConfig() (err error) {
	viper.SetConfigFile("config.toml") // 指定配置文件路径
	viper.SetConfigName("config")      // 配置文件名称(无扩展名)
	viper.SetConfigType("toml")        // 如果配置文件的名称中没有扩展名，则需要配置此项

	viper.AddConfigPath("./")
	viper.AddConfigPath("./conf/")  // 还可以在工作目录中查找配置
	viper.AddConfigPath("../conf/") // 还可以在工作目录中查找配置
	err = viper.ReadInConfig()      // 查找并读取配置文件
	if err != nil {                 // 处理读取配置文件的错误
		return
	}

	err = viper.Unmarshal(&GF)

	return err

}

func InitMgo() {
	//181
	Mgo = &mongodb.MongodbSim{
		MongodbAddr: GF.Mongo.Host,
		//MongodbAddr: "127.0.0.1:27001",
		DbName:   GF.Mongo.DB,
		Size:     10,
		UserName: GF.Mongo.Username,
		Password: GF.Mongo.Password,
		Direct:   GF.Mongo.Direct,
	}
	Mgo.InitPool()
}
func Init() {
	InitConfig()
	InitMgo()

	filename = GF.Env.File

}

func main() {
	Init()
	//statistic()

	getBaseInfo() //基础信息
	dealXuKe()    //许可信息
	getChanges()  //变更记录
	getGuDong()   //股东信息
	getEmployee() //高管
	getInves()    //投资单位
	getBranch()   //分支结构
	getPledge()   //股权出质
	getChattel()  //动产抵押
	getAbnormal() //经营异常
	getIllegal()  //严重违法失信
	getPunish()   //行政处罚
	getJustice()  //失信被执行人
	getCheck()    //获取抽查结果
	getFreeze()   //股权冻结
}

//statistic 统计企业公布信息
func statistic() {
	sess := Mgo.GetMgoConn()
	defer Mgo.DestoryMongoConn(sess)

	var (
		total_amount_true, total_amount_false                 int //资产总额
		debt_amount_true, debt_amount_false                   int //负债总额
		business_income_true, business_income_false           int //销售(营业)收入
		main_business_income_true, main_business_income_false int //主营业收入
		total_profit_amount_true, total_profit_amount_false   int //利润总额
		tax_amount_true, tax_amount_false                     int //纳税总额
		profit_amount_true, profit_amount_false               int //净利润
		equity_amount_true, equity_amount_false               int //所有者权益合计
		government_support_true, government_support_false     int //获得政府扶持资金、补助
		financial_loan_true, financial_loan_false             int //金融贷款
	)

	fmt.Println("开始统计")
	query := sess.DB("mixdata").C("annual_report_asset").Find(nil).Select(nil).Limit(200000).Iter()
	count := 0
	for tmp := make(map[string]interface{}); query.Next(tmp); count++ {
		if count%1000 == 0 {
			fmt.Println("current count", count)
		}
		//1
		total_amount := utils.ObjToString(tmp["total_amount"])
		if total_amount != "" && strings.Contains(total_amount, "不公示") {
			total_amount_false++
		} else {
			total_amount_true++
		}
		//2
		debt_amount := utils.ObjToString(tmp["debt_amount"])
		if debt_amount != "" && strings.Contains(debt_amount, "不公示") {
			debt_amount_false++
		} else {
			debt_amount_true++
		}
		//3
		business_income := utils.ObjToString(tmp["business_income"])
		if business_income != "" && strings.Contains(business_income, "不公示") {
			business_income_false++
		} else {
			business_income_true++
		}
		//4
		main_business_income := utils.ObjToString(tmp["main_business_income"])
		if main_business_income != "" && strings.Contains(main_business_income, "不公示") {
			main_business_income_false++
		} else {
			main_business_income_true++
		}
		//5
		total_profit_amount := utils.ObjToString(tmp["total_profit_amount"])
		if total_profit_amount != "" && strings.Contains(total_profit_amount, "不公示") {
			total_profit_amount_false++
		} else {
			total_profit_amount_true++
		}

		//6
		tax_amount := utils.ObjToString(tmp["tax_amount"])
		if tax_amount != "" && strings.Contains(tax_amount, "不公示") {
			tax_amount_false++
		} else {
			tax_amount_true++
		}
		//7
		profit_amount := utils.ObjToString(tmp["profit_amount"])
		if profit_amount != "" && strings.Contains(profit_amount, "不公示") {
			profit_amount_false++
		} else {
			profit_amount_true++
		}
		//8
		equity_amount := utils.ObjToString(tmp["equity_amount"])
		if equity_amount != "" && strings.Contains(equity_amount, "不公示") {
			equity_amount_false++
		} else {
			equity_amount_true++
		}

		//9
		government_support := utils.ObjToString(tmp["government_support"])
		if government_support != "" && strings.Contains(government_support, "不公示") {
			government_support_false++
		} else {
			government_support_true++
		}

		//10

		financial_loan := utils.ObjToString(tmp["financial_loan"])
		if financial_loan != "" && strings.Contains(financial_loan, "不公示") {
			financial_loan_false++
		} else {
			financial_loan_true++
		}

	}

	fmt.Println("结束统计")

	fmt.Println("total_amount_true : ", total_amount_true, "total_amount_false: ", total_amount_false)
	fmt.Println("debt_amount_true : ", debt_amount_true, "debt_amount_false: ", debt_amount_false)
	fmt.Println("business_income_true : ", business_income_true, "business_income_false: ", business_income_false)
	fmt.Println("main_business_income_true : ", main_business_income_true, "main_business_income_false: ", main_business_income_false)
	fmt.Println("total_profit_amount_true : ", total_profit_amount_true, "total_profit_amount_false: ", total_profit_amount_false)
	fmt.Println("tax_amount_true : ", tax_amount_true, "tax_amount_false: ", tax_amount_false)
	fmt.Println("profit_amount_true : ", profit_amount_true, "profit_amount_false: ", profit_amount_false)
	fmt.Println("equity_amount_true : ", equity_amount_true, "equity_amount_false: ", equity_amount_false)
	fmt.Println("government_support_true : ", government_support_true, "government_support_false: ", government_support_false)
	fmt.Println("financial_loan_true : ", financial_loan_true, "financial_loan_false: ", financial_loan_false)
}

//baseInfo 基础信息；
func getBaseInfo() {
	fmt.Println("开始处理 基本信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "基本信息"
	baseTitle := []string{"企业名称", "公司ID", "统一社会信用代码", "法定代表人", "登记状态", "成立日期", "注册资本", "所属行业", "企业类型", "注册地址", "登记机关", "经营范围", "企业简介", "营业执照有效期自", "营业执照有效期至"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	//xlsx.DeleteSheet("Sheet1")
	_ = f.SetColWidth(baseSheet, "A", "C", 30)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := strings.TrimSpace(dealName(rows[i][0]))
		base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		baseInfo := *base
		if len(baseInfo) == 0 || baseInfo == nil {
			f.SetCellValue("企业名单", fmt.Sprintf("D%v", i+1), "无")
			continue
		}
		baseMap[name] = baseInfo
		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}
		line++
		//获取行业信息
		hangye, _ := Mgo.FindOne("company_industry", map[string]interface{}{"company_id": company_id})
		hangyeData := *hangye
		valus := []interface{}{
			baseInfo["company_name"], company_id, baseInfo["credit_no"], baseInfo["legal_person"], baseInfo["company_status"], baseInfo["establish_date"], baseInfo["capital"],
			hangyeData["industry_l1_name"], baseInfo["company_type"], baseInfo["company_address"], baseInfo["authority"], baseInfo["business_scope"], "",
			baseInfo["operation_startdate"], baseInfo["operation_enddate"],
		}
		err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
		_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "BA"+strconv.Itoa(line), styleOne)

	}

	fmt.Println("基本信息处理完毕")
}

//dealXuKe 许可信息
func dealXuKe() {
	fmt.Println("开始处理许可信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "许可信息"
	baseTitle := []string{"企业名称", "公司ID", "许可文件名称", "许可机关", "许可内容", "有效期自", "有效期至"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 20)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取行业信息
		allow, _ := Mgo.Find("company_allow", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		allowDatas := *allow
		if len(allowDatas) == 0 {
			continue
		}

		for _, allowData := range allowDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				allowData["allow_filename"],
				allowData["allow_authority"],
				allowData["allow_content"],
				allowData["allow_startdate"],
				allowData["allow_enddate"],
			}
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "K"+strconv.Itoa(line), styleOne)

		}
	}

	fmt.Println("许可信息处理完毕")

}

//getChanges 获取变更记录
func getChanges() {
	fmt.Println("开始处理变更记录")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "变更信息"
	baseTitle := []string{"企业名称", "公司ID", "变更事项", "变更类型", "变更前内容", "变更后内容", "变更日期"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 30)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取行业信息
		change, _ := Mgo.Find("company_change", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		changeDatas := *change
		if len(changeDatas) == 0 {
			continue
		}

		for _, changeData := range changeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				changeData["change_field"],
				changeData["change_type"],
				changeData["content_before"],
				changeData["content_after"],
				changeData["change_date"],
			}
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)

		}
	}

	fmt.Println("变更记录处理完毕")
}

//getGuDong 股东及其出资信息
func getGuDong() {
	fmt.Println("开始处理 - 股东及其出资信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "股东及其出资信息"
	baseTitle := []string{"企业名称", "公司ID", "股东名称", "持股比例", "认缴出资额", "实缴出资额", "认缴出资日期", "实缴出质日期"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "C", 30)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取股东 信息
		partner, _ := Mgo.Find("company_partner", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		partnerDatas := *partner
		if len(partnerDatas) == 0 {
			continue
		} else {
			for _, part := range partnerDatas {
				line++
				valus := []interface{}{
					baseInfo["company_name"],
					company_id,
					part["stock_name"],
					part["stock_proportion"],
					part["stock_capital"],
					part["stock_realcapital"],
				}
				//获取认缴出资 信息
				pay, _ := Mgo.FindOne("company_partner_pay", map[string]interface{}{"company_id": company_id, "stock_name": part["stock_name"]})
				payData := *pay
				valus = append(valus, payData["stock_date"])

				//
				repay, _ := Mgo.FindOne("company_partner_realpay", map[string]interface{}{"company_id": company_id, "stock_name": part["stock_name"]})
				repayData := *repay
				valus = append(valus, repayData["stock_realdate"])
				err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
				_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)

			}
		}

	}

	fmt.Println("股东及其出资信息 - 处理完毕")
}

//getEmployee 获取高管
func getEmployee() {
	fmt.Println("开始处理 高管信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "高管信息"
	baseTitle := []string{"企业名称", "公司ID", "姓名", "职位"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取行业信息
		employee, _ := Mgo.Find("company_employee", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		employeeDatas := *employee
		if len(employeeDatas) == 0 {
			continue
		}

		for _, Data := range employeeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["employee_name"],
				Data["position"],
			}
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)

		}
	}

	fmt.Println("高管信息 处理完毕")
}

//getInves 对外投资
func getInves() {
	fmt.Println("开始处理 对外投资信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "对外投资信息"
	baseTitle := []string{"企业名称", "公司ID", "被投资企业名称", "注册资本", "出资金额", "出资比例", "登记状态", "成立日期"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 投资企业
		partner, _ := Mgo.Find("company_partner", map[string]interface{}{"stock_name_id": company_id}, nil, nil, false, -1, -1)
		partnerDatas := *partner
		if len(partnerDatas) == 0 {
			continue
		}

		for _, Data := range partnerDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["company_name"],
			}
			baseC, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": Data["company_name"]})
			basecInfo := *baseC

			valus = append(valus, basecInfo["capital"], Data["stock_capital"], Data["stock_proportion"], basecInfo["company_status"], baseInfo["establish_date"])

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)

		}
	}

	fmt.Println("对外投资信息 处理完毕")
}

//getBranch 分支机构信息
func getBranch() {
	fmt.Println("开始处理 分支机构信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "分支机构信息"
	baseTitle := []string{"企业名称", "公司ID", "分支机构名称", "登记状态", "成立日期", "注册地址"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		branch, _ := Mgo.Find("company_branch", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		branchDatas := *branch
		if len(branchDatas) == 0 {
			continue
		}

		for _, Data := range branchDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["branch_name"],
				Data["company_status"],
				Data["establish_date"],
			}
			baseBr, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": Data["branch_name"]})
			basebInfo := *baseBr
			valus = append(valus, basebInfo["company_address"])

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)

		}
	}

	fmt.Println("分支机构信息 处理完毕")
}

//getPledge 股权出质
func getPledge() {
	fmt.Println("开始处理 股权出质信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "股权出质"
	baseTitle := []string{"企业名称", "公司ID", "登记日期", "公示日期", "登记编号", "出质人", "出质股权数额"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_pledge", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["pledge_date"],
				Data["public_date"],
				Data["pledge_code"],
				Data["pledgor"],
				Data["pledge_equity"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("股权出质	处理完毕")
}

//getChattel 获取动产抵押
func getChattel() {
	fmt.Println("开始处理 动产抵押信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "动产抵押"
	baseTitle := []string{"企业名称", "公司ID", "债权种类", "债权数额", "履行日期", "登记编号", "登记日期", "公示日期", "登记机关", "担保范围", "主债权信息备注", "状态"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}
		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base
		baseInfo := baseMap[name]

		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_chattel", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["debt_type"],
				Data["debt_amount"],
				Data["debt_term"],
				Data["chattel_code"],
				Data["chattel_date"],
				Data["public_date"],
				Data["authority"],
				Data["guarantee_scope"],
				Data["remark"],
				Data["chattel_status"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("动产抵押	处理完毕")
}

//getAbnormal 获取经营异常
func getAbnormal() {
	fmt.Println("开始处理 经营异常信息")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "经营异常名录"
	baseTitle := []string{"企业名称", "公司ID", "列入经营异常名录日期", "列入经营异常名录原因", "列入异常名录部门", "移出经营异常名录日期", "移出经营异常名录原因", "移出异常名录部门"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}

		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_abnormal", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["included_date"],
				Data["included_reason"],
				Data["included_authority"],
				Data["removed_date"],
				Data["removed_reason"],
				Data["removed_authority"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("经营异常	处理完毕")
}

//getIllegal 获取 严重违法失信
func getIllegal() {
	fmt.Println("开始处理 严重违法失信")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "严重违法失信"
	baseTitle := []string{"企业名称", "公司ID", "列入日期", "列入原因", "列入部门", "移出日期", "移出原因", "移出异常名录部门"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}

		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_illegal", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["included_date"],
				Data["included_reason"],
				Data["included_authority"],
				Data["removed_date"],
				Data["removed_reason"],
				Data["removed_authority"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("严重违法失信	处理完毕")
}

//getPunish 获取行政处罚
func getPunish() {
	fmt.Println("开始处理 行政处罚")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "行政处罚"
	baseTitle := []string{"企业名称", "公司ID", "处罚决定文书", "处罚日期", "违法行为类型", "处罚内容", "决定机关"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}

		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_punish", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["punish_code"],
				Data["punish_date"],
				Data["illegal_type"],
				Data["punish_content"],
				Data["authority"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("行政处罚	处理完毕")
}

//getIllegal 获取失信被执行人
func getJustice() {
	fmt.Println("开始处理 失信被执行人")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "失信被执行人"
	baseTitle := []string{"企业名称", "公司ID", "失信人名称", "执行法院", "执行通知书文号", "类型|状态", "股权数额", "创建时间"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}

		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_justice", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["executee"],
				Data["exec_court"],
				Data["doc_no"],
				Data["equity_status"],
				Data["equity_amount"],
				Data["create_time"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("失信被执行人	处理完毕")
}

//getCheck 获取抽查结果
func getCheck() {
	fmt.Println("开始处理 抽查结果")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "抽查结果"
	baseTitle := []string{"企业名称", "公司ID", "抽查时间", "抽查类型", "抽查结果", "抽查机关"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}

		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_check", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["check_date"],
				Data["check_type"],
				Data["check_result"],
				Data["authority"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("抽查结果	处理完毕")
}

//getFreeze 获取股权冻结
func getFreeze() {
	fmt.Println("开始处理 股权冻结")
	f, err := excelize.OpenFile(filename)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows(GF.Env.Sheet)
	baseSheet := "股权冻结"
	baseTitle := []string{"企业名称", "公司ID", "被执行人", "股权数额", "执行法院", "执行事项", "执行通知书文号", "执行裁定书文号", "冻结期限自", "冻结期限至", "冻结期限", "冻结公示日期"}
	styleOne, _ := f.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)

	line := 0
	f.NewSheet(baseSheet)
	_ = f.SetColWidth(baseSheet, "A", "G", 25)
	_ = f.SetRowHeight(baseSheet, line, 20)

	for i := 1; i < len(rows); i++ {
		if i%100 == 0 {
			fmt.Println(i, rows[i][0])
		}

		if len(rows[i]) <= 0 {
			continue
		}
		name := dealName(rows[i][0])
		//base, _ := Mgo.FindOne("company_base", map[string]interface{}{"company_name": name})
		//baseInfo := *base

		baseInfo := baseMap[name]
		if len(baseInfo) == 0 || baseInfo == nil {
			continue
		}

		company_id := baseInfo["company_id"]
		//1. 基本信息
		// 设置一次表头
		if line == 0 {
			line++
			//设置第一行title
			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &baseTitle)
			if err != nil {
				fmt.Println(err)
				return
			}
		}

		//获取 分支结构
		pledge, _ := Mgo.Find("company_justice_freeze", map[string]interface{}{"company_id": company_id}, nil, nil, false, -1, -1)
		pledgeDatas := *pledge
		if len(pledgeDatas) == 0 {
			continue
		}

		for _, Data := range pledgeDatas {
			line++
			valus := []interface{}{
				baseInfo["company_name"],
				company_id,
				Data["executee"],
				Data["equity_amount"],
				Data["exec_court"],
				Data["exec_item"],
				Data["doc_no"],
				Data["exec_no"],
				Data["freeze_start_date"],
				Data["freeze_end_date"],
				Data["freeze_years"],
				Data["public_date"],
			}

			err = f.SetSheetRow(baseSheet, fmt.Sprintf("%s%d", "A", line), &valus)
			_ = f.SetCellStyle(baseSheet, fmt.Sprintf("%s%d", "A", line), "AA"+strconv.Itoa(line), styleOne)
		}
	}

	fmt.Println("股权冻结	处理完毕")
}

//dealName 处理name
func dealName(name string) string {
	if strings.ContainsAny(name, "()（）") {
		name = strings.Replace(name, "(", "（", -1)
		name = strings.Replace(name, ")", "）", -1)
	}

	return name
}