package controllers

import (
	"crypto/md5"
	"encoding/hex"
	"errors"
	"fmt"
	"github.com/beego/beego/v2/client/httplib"
	"os"
	"path"
	"regexp"
	"strconv"
	"strings"
	"time"
	"unicode/utf8"

	"github.com/360EntSecGroup-Skylar/excelize/v2"
	"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/constant"

	"github.com/astaxie/beego/logs"
	orderCmd "gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/application/orderinfo/command"
	orderQuery "gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/application/orderinfo/query"
	orderService "gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/application/orderinfo/service"
	"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/domain"
	"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/infrastructure/utils"
	"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/lib"
	"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/lib/exceltool"
)

type OrderInfoController struct {
	BaseController
}

////Prepare 重写 BaseController 的Prepare方法
func (c *OrderInfoController) Prepare() {
	c.BaseController.Prepare()
	if ok := c.ValidJWTToken(); !ok {
		return
	}
	if ok := c.ValidAdminPermission(domain.PERMISSION_ORDER); !ok {
		return
	}
}

//postPurposeOrderDetail 请求添加/更新的订单数据
type postPurposeOrderDetail struct {
	Id int64 `json:"id"`
	//订单编号
	OrderId string `json:"orderId"`
	//买家姓名
	BuyerName string `json:"buyer"`
	//对应合伙人 id
	PartnerId int64 `json:"partnerID"`
	//业务员抽成比例
	CommissionProportion float64 `json:"commissionProportion"`
	//订单区域
	OrderDist string `json:"orderDist"`
	//商品
	Product []postOrderGood `json:"product"`
}

func (postData *postPurposeOrderDetail) Valid() error {
	postData.OrderId = strings.TrimSpace(postData.OrderId)
	postData.BuyerName = strings.TrimSpace(postData.BuyerName)
	postData.OrderDist = strings.TrimSpace(postData.OrderDist)
	if len(postData.OrderId) == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "订单编号必填")
	}
	if len(postData.BuyerName) == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "买家信息必填")
	}
	if postData.PartnerId == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "合伙人信息必填")

	}
	if len(postData.OrderDist) == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "订单区域必填")
	}
	if len(postData.Product) == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "货品列表必填")
	}
	if len(postData.Product) > 50 {
		return lib.ThrowError(lib.ARG_ERROR, "货品列表最多50项")
	}
	for i := range postData.Product {
		if err := postData.Product[i].Valid(); err != nil {
			return err
		}
	}
	return nil
}

//PostPurposeOrderGood 请求添加/更新订单中的货品
type postOrderGood struct {
	Id           int64   `json:"id"`
	ProductName  string  `json:"productName"`
	OrderNum     int     `json:"orderNum"`
	Univalence   float64 `json:"univalence"`
	PartnerRatio float64 `json:"partnerRatio"`
}

func (postData *postOrderGood) Valid() error {
	postData.ProductName = strings.TrimSpace(postData.ProductName)
	lenProductName := utf8.RuneCountInString(postData.ProductName)
	if lenProductName == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "商品名称必填")
	}
	if lenProductName > 50 {
		return lib.ThrowError(lib.ARG_ERROR, "商品名称最多50位")
	}
	if postData.OrderNum >= 1e16 {
		return lib.ThrowError(lib.ARG_ERROR, "商品数量最多16位")
	}
	if postData.Univalence >= 1e16 {
		return lib.ThrowError(lib.ARG_ERROR, "商品单价最多16位")
	}
	if postData.PartnerRatio > 100 {
		return lib.ThrowError(lib.ARG_ERROR, "合伙人分红比例超额")
	}
	partnerRatio := fmt.Sprint(postData.PartnerRatio)
	regexpStr := `^(100|[1-9]\d|\d)(.\d{1,2})?$`
	ok := regexp.MustCompile(regexpStr).MatchString(partnerRatio)
	if !ok {
		return lib.ThrowError(lib.ARG_ERROR, "合伙人分红比例精确到小数点2位")
	}

	return nil
}

type postOrderPurposeDelivery struct {
	ShipmentsId   string          `json:"shipmentsId"` //发货单号
	Id            string          `json:"id"`          //订单id
	ProductDetail []postOrderGood `json:"productDetail"`
}

func (postData *postOrderPurposeDelivery) Valid() error {
	postData.ShipmentsId = strings.TrimSpace(postData.ShipmentsId)
	lenShipmentsId := utf8.RuneCountInString(postData.ShipmentsId)
	if lenShipmentsId == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "发货单号必填")
	}
	if lenShipmentsId > 50 {
		return lib.ThrowError(lib.ARG_ERROR, "发货单号最多50位")
	}

	for i := range postData.ProductDetail {
		if err := postData.ProductDetail[i].Valid(); err != nil {
			return err
		}
	}
	return nil
}

/**
 * @Author SteveChan
 * @Description // 获取实发订单列表，修改搜索条件
 * @Date 20:23 2021/1/10
 * @Param
 * @return
 **/
func (c *OrderInfoController) PageListOrderReal() {
	type Parameter struct {
		//SearchText      string   `json:"searchText"`
		PartnerName     string   `json:"partnerName"`  // 合伙人姓名
		OrderCode       string   `json:"orderCode"`    // 订单号
		DeliveryCode    string   `json:"deliveryCode"` // 发货单号
		PartnerCategory int      `json:"PartnerCategory"`
		PageSize        int      `json:"pageSize"`
		PageNumber      int      `json:"pageNumber"`
		UpdateTime      []string `json:"updateTime"`
		CreateTime      []string `json:"createTime"`
	}
	var (
		param Parameter
		err   error
	)
	if err = c.BindJsonData(&param); err != nil {
		logs.Error(err)
		c.ResponseError(errors.New("json数据解析失败"))
		return
	}
	if param.PageNumber == 0 {
		param.PageNumber = 1
	}
	if param.PageSize == 0 {
		param.PageSize = 20
	}
	var (
		updateTimeBegin string
		updateTimeEnd   string
	)
	if len(param.UpdateTime) > 0 {
		if len(param.UpdateTime[0]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.UpdateTime[0], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeBegin 时间格式错误"))
				return
			}
			updateTimeBegin = t.Format("2006-01-02 15:04:05-07")
		}
	}
	if len(param.UpdateTime) > 1 {
		if len(param.UpdateTime[1]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.UpdateTime[1], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeEnd 时间格式错误"))
				return
			}
			//设定时间边界
			t = t.Add(86399 * time.Second)
			updateTimeEnd = t.Format("2006-01-02 15:04:05-07")
		}
	}
	var (
		createTimeBegin string
		createTimeEnd   string
	)
	if len(param.CreateTime) > 0 {
		if len(param.CreateTime[0]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.CreateTime[0], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeBegin 时间格式错误"))
				return
			}
			createTimeBegin = t.Format("2006-01-02 15:04:05-07")
		}
	}
	if len(param.CreateTime) > 1 {
		if len(param.CreateTime[1]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.CreateTime[1], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeEnd 时间格式错误"))
				return
			}
			//设定时间边界
			t = t.Add(86399 * time.Second)
			createTimeEnd = t.Format("2006-01-02 15:04:05-07")
		}
	}

	companyId := c.GetUserCompany()
	orderSrv := orderService.NewOrderInfoService(nil)
	orderinfos, cnt, err := orderSrv.PageListOrderBase(orderQuery.ListOrderBaseQuery{
		//PartnerOrCode:   param.SearchText,
		PartnerName:     param.PartnerName,
		OrderCode:       param.OrderCode,
		DeliveryCode:    param.DeliveryCode,
		OrderType:       domain.OrderReal,
		Limit:           param.PageSize,
		Offset:          (param.PageNumber - 1) * param.PageSize,
		CompanyId:       companyId,
		PartnerCategory: param.PartnerCategory,
		UpdateTimeBegin: updateTimeBegin,
		UpdateTimeEnd:   updateTimeEnd,
		CreateTimeBegin: createTimeBegin,
		CreateTimeEnd:   createTimeEnd,
	})
	if err != nil {
		c.ResponseError(err)
		return
	}
	c.ResponsePageList(orderinfos, cnt, param.PageNumber)
	return
}

//GetOrderReal 获取实发订单详情
func (c *OrderInfoController) GetOrderReal() {
	type Parameter struct {
		Id string `json:"id"`
	}
	var (
		param Parameter
		err   error
	)
	if err = c.BindJsonData(&param); err != nil {
		logs.Error(err)
		c.ResponseError(errors.New("json数据解析失败"))
		return
	}
	orderid, _ := strconv.ParseInt(param.Id, 10, 64)
	if orderid == 0 {
		c.ResponseError(errors.New("参数错误"))
		return
	}
	companyId := c.GetUserCompany()
	orderSrv := orderService.NewOrderInfoService(nil)
	orderinfo, err := orderSrv.GetOrderDetail(orderQuery.GetOrderQuery{
		OrderId:   orderid,
		CompanyId: companyId,
	})
	if err != nil {
		c.ResponseError(err)
		return
	}
	if orderinfo.OrderType != domain.OrderReal {
		c.ResponseError(errors.New("参数错误"))
		return
	}
	allGoods := []map[string]interface{}{}
	for _, v := range orderinfo.Goods {
		m := map[string]interface{}{
			"id":              fmt.Sprint(v.Id),
			"productName":     v.GoodName,
			"orderNum":        v.PlanGoodNumber,
			"univalence":      v.Price,
			"partnerRatio":    v.PartnerBonusPercent,
			"orderPrice":      v.GoodCompute.PlanAmount,
			"quantityControl": "",
			"priceControl":    "",
		}
		if v.GoodCompute.UseAmount >= 0 {
			m["priceControl"] = fmt.Sprint(v.GoodCompute.UseAmount)
		}
		if v.UseGoodNumber >= 0 {
			m["quantityControl"] = fmt.Sprint(v.UseGoodNumber)
		}
		allGoods = append(allGoods, m)
	}
	rsp := map[string]interface{}{
		"buyer":                             orderinfo.Buyer.BuyerName,
		"id":                                orderinfo.Id,
		"partnerID":                         orderinfo.PartnerInfo.Id,
		"partner":                           orderinfo.PartnerInfo.PartnerName,
		"orderDist":                         orderinfo.RegionInfo.RegionName,
		"orderId":                           orderinfo.OrderCode,
		"shipmentsId":                       orderinfo.DeliveryCode,
		"commissionProportion":              orderinfo.SalesmanBonusPercent,
		"orderNumCount":                     orderinfo.OrderCompute.PlanOrderCount,
		"orderAmountAdjustmentCount":        orderinfo.OrderCompute.PlanOrderAmount,
		"orderNumCountControl":              "",
		"orderAmountAdjustmentCountControl": "",
		"product":                           allGoods,
		"create_time":                       orderinfo.CreateTime.Local().Format("2006-01-02 15:04:06"),
		"update_time":                       orderinfo.UpdateTime.Local().Format("2006-01-02 15:04:06"),
		"partnerCategoryId":                 orderinfo.PartnerCategory.Id,
		"partnerCategoryName":               orderinfo.PartnerCategory.Name,
	}
	if orderinfo.OrderCompute.UseOrderAmount >= 0 {
		rsp["orderNumCountControl"] = fmt.Sprint(orderinfo.OrderCompute.UseOrderCount)
	}
	if orderinfo.OrderCompute.UseOrderCount >= 0 {
		rsp["orderAmountAdjustmentCountControl"] = fmt.Sprint(orderinfo.OrderCompute.UseOrderAmount)
	}
	c.ResponseData(rsp)
	return
}

//实际订单
type postRealOrderDetail struct {
	postPurposeOrderDetail
	PartnerCategoryId int64  `json:"partnerCategoryId"`
	ShipmentsId       string `json:"shipmentsId"` //发货单号
}

func (postData *postRealOrderDetail) Valid() error {
	postData.ShipmentsId = strings.TrimSpace(postData.ShipmentsId)
	if len(postData.ShipmentsId) == 0 {
		return lib.ThrowError(lib.ARG_ERROR, "订单的发货单号必填")
	}
	if err := postData.postPurposeOrderDetail.Valid(); err != nil {
		return err
	}
	return nil
}

//UpdateOrderReal 编辑实际订单
func (c *OrderInfoController) UpdateOrderReal() {
	//用与适配前端定义的数据结构
	var (
		param postRealOrderDetail
		err   error
	)
	if err = c.BindJsonData(&param); err != nil {
		logs.Error(err)
		c.ResponseError(errors.New("json数据解析失败"))
		return
	}
	if err := param.Valid(); err != nil {
		c.ResponseError(err)
		return
	}
	var orderDataReturn *domain.OrderBase
	if param.Id == 0 {
		orderDataReturn, err = c.addOrderReal(param)
	} else {
		err = c.editOrderReal(param)
	}
	if err != nil {
		c.ResponseError(err)
		return
	}
	if orderDataReturn != nil {
		c.ResponseData(map[string]interface{}{
			"id": orderDataReturn.Id,
		})
		return
	}
	c.ResponseData(nil)
	return
}

func (c *OrderInfoController) addOrderReal(param postRealOrderDetail) (*domain.OrderBase, error) {
	orderSrv := orderService.NewOrderInfoService(nil)
	newGoods := []orderCmd.OrderGoodData{}
	for _, v := range param.Product {
		g := orderCmd.OrderGoodData{
			GoodName:            v.ProductName,
			PlanGoodNumber:      v.OrderNum,
			Price:               v.Univalence,
			PartnerBonusPercent: v.PartnerRatio,
		}
		newGoods = append(newGoods, g)
	}
	companyId := c.GetUserCompany()
	createcmd := orderCmd.CreateOrderCommand{
		OrderType:            domain.OrderReal,
		OrderCode:            param.OrderId,
		DeliveryCode:         param.ShipmentsId,
		BuyerName:            param.BuyerName,
		OrderRegion:          param.OrderDist,
		PartnerId:            param.PartnerId,
		SalesmanBonusPercent: param.CommissionProportion,
		Goods:                newGoods,
		CompanyId:            companyId,
		PartnerCategory:      param.PartnerCategoryId,
	}
	orderData, err := orderSrv.CreateNewOrder(createcmd)
	return orderData, err
}

func (c *OrderInfoController) editOrderReal(param postRealOrderDetail) error {

	newGoods := []orderCmd.OrderGoodData{}
	for _, v := range param.Product {
		g := orderCmd.OrderGoodData{
			GoodName:            v.ProductName,
			PlanGoodNumber:      v.OrderNum,
			Price:               v.Univalence,
			PartnerBonusPercent: v.PartnerRatio,
		}
		newGoods = append(newGoods, g)
	}
	companyId := c.GetUserCompany()
	updatecmd := orderCmd.UpdateOrderCommand{
		Id:                   param.Id,
		OrderType:            domain.OrderReal,
		OrderCode:            param.OrderId,
		DeliveryCode:         param.ShipmentsId,
		BuyerName:            param.BuyerName,
		OrderRegion:          param.OrderDist,
		PartnerId:            param.PartnerId,
		SalesmanBonusPercent: param.CommissionProportion,
		Goods:                newGoods,
		CompanyId:            companyId,
		PartnerCategory:      param.PartnerCategoryId,
	}
	orderSrv := orderService.NewOrderInfoService(nil)
	_, err := orderSrv.UpdateOrderData(updatecmd)
	return err
}

//OrderDisable 关闭开启订单，限实发订单可操作
func (c *OrderInfoController) OrderDisable() {
	//用与适配前端定义的数据结构
	type PostParameter struct {
		Id     string `json:"id"`
		Status int    `json:"status"`
	}
	var (
		param PostParameter
		err   error
	)
	if err = c.BindJsonData(&param); err != nil {
		logs.Error(err)
		c.ResponseError(errors.New("json数据解析失败"))
		return
	}
	orderId, _ := strconv.ParseInt(param.Id, 10, 64)
	if orderId == 0 {
		c.ResponseError(errors.New("参数错误"))
		return
	}
	if !(param.Status == domain.OrderDisableNot || param.Status == domain.OrderDisableYes) {
		c.ResponseError(errors.New("参数错误"))
		return
	}
	companyId := c.GetUserCompany()
	cmd := orderCmd.DisableOrderCommand{
		OrderId:   orderId,
		IsDisable: param.Status,
		OrderType: domain.OrderReal,
		CompanyId: companyId,
	}
	orderSrv := orderService.NewOrderInfoService(nil)
	err = orderSrv.DisableOrEnable(cmd)
	if err != nil {
		c.ResponseError(err)
	}
	c.ResponseData(nil)
	return
}

//RemoveOrderReal 删除意向订单
func (c *OrderInfoController) RemoveOrderReal() {
	type Parameter struct {
		Id string `json:"id"`
	}
	var (
		param Parameter
		err   error
	)
	if err = c.BindJsonData(&param); err != nil {
		logs.Error(err)
		c.ResponseError(errors.New("json数据解析失败"))
		return
	}
	companyId := c.GetUserCompany()
	id, _ := strconv.ParseInt(param.Id, 10, 64)
	orderSrv := orderService.NewOrderInfoService(nil)
	err = orderSrv.DeleteOrder(id, companyId)
	if err != nil {
		c.ResponseError(err)
		return
	}
	c.ResponseData(nil)
}

//ListOrderForExcel excel 导出实际订单的列表
func (c *OrderInfoController) ListOrderForExcel() {
	type Parameter struct {
		//SearchText      string   `json:"searchText"`
		PartnerName     string   `json:"partnerName"`  // 合伙人姓名
		OrderCode       string   `json:"orderCode"`    // 订单号
		DeliveryCode    string   `json:"deliveryCode"` // 发货单号
		PartnerCategory int      `json:"PartnerCategory"`
		UpdateTime      []string `json:"updateTime"`
		CreateTime      []string `json:"createTime"`
	}
	var (
		param Parameter
		err   error
	)
	if err = c.BindJsonData(&param); err != nil {
		logs.Error(err)
		c.ResponseError(errors.New("json数据解析失败"))
		return
	}
	var (
		updateTimeBegin string
		updateTimeEnd   string
	)
	if len(param.UpdateTime) > 0 {
		if len(param.UpdateTime[0]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.UpdateTime[0], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeBegin 时间格式错误"))
				return
			}
			updateTimeBegin = t.Format("2006-01-02 15:04:05-07")
		}
	}
	if len(param.UpdateTime) > 1 {
		if len(param.UpdateTime[1]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.UpdateTime[1], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeEnd 时间格式错误"))
				return
			}
			//设定时间边界
			t = t.Add(86399 * time.Second)
			updateTimeEnd = t.Format("2006-01-02 15:04:05-07")
		}
	}
	var (
		createTimeBegin string
		createTimeEnd   string
	)
	if len(param.CreateTime) > 0 {
		if len(param.CreateTime[0]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.CreateTime[0], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeBegin 时间格式错误"))
				return
			}
			createTimeBegin = t.Format("2006-01-02 15:04:05-07")
		}
	}
	if len(param.CreateTime) > 1 {
		if len(param.CreateTime[1]) > 0 {
			t, err := time.ParseInLocation("2006-01-02", param.CreateTime[1], time.Local)
			if err != nil {
				c.ResponseError(errors.New("UpdateTimeEnd 时间格式错误"))
				return
			}
			//设定时间边界
			t = t.Add(86399 * time.Second)
			createTimeEnd = t.Format("2006-01-02 15:04:05-07")
		}
	}

	companyId := c.GetUserCompany()
	orderSrv := orderService.NewOrderInfoService(nil)
	orderinfos, columns, err := orderSrv.ListOrderForExcel(orderQuery.ListOrderBaseQuery{
		//PartnerOrCode:   param.SearchText,
		PartnerName:     param.PartnerName,
		OrderCode:       param.OrderCode,
		DeliveryCode:    param.DeliveryCode,
		OrderType:       domain.OrderReal,
		CompanyId:       companyId,
		PartnerCategory: param.PartnerCategory,
		UpdateTimeBegin: updateTimeBegin,
		UpdateTimeEnd:   updateTimeEnd,
		CreateTimeBegin: createTimeBegin,
		CreateTimeEnd:   createTimeEnd,
	})
	if err != nil {
		c.ResponseError(err)
		return
	}
	var excelHeaders []exceltool.ExcelHead
	for i := range columns {
		h := exceltool.ExcelHead{
			Key:  columns[i][0],
			Name: columns[i][1],
		}
		excelHeaders = append(excelHeaders, h)
	}
	excelMaker := exceltool.NewExcelMaker()
	excelMaker.SetListHead(excelHeaders)
	excelMaker.MakeListExcel(orderinfos)
	c.ResponseExcelByFile(c.Ctx, excelMaker)
	return
}

/**
 * @Author SteveChan
 * @Description // 下载导入模板
 * @Date 16:48 2021/1/8
 * @Param
 * @return
 **/
func (c *OrderInfoController) DownloadTemplate() {
	type Parameter struct {
		TYPE string `json:"type"`
	}

	var (
		param Parameter
		err   error
	)

	if err = c.BindJsonData(&param); err != nil {
		logs.Error(err)
		c.ResponseError(errors.New("json数据解析失败"))
		return
	}

	// 校验类型编码
	if param.TYPE != "PARTNER_ORDER_FILE" {
		c.ResponseError(errors.New("类型编码错误"))
	}

	// 创建下载文件夹
	mkErr := os.Mkdir("download", os.ModePerm)
	if mkErr != nil {
		fmt.Println(mkErr)
	}

	// 获取导入模板
	req := httplib.Get("http://suplus-file-dev.fjmaimaimai.com/upload/file/2021010803305336443.xlsx")
	err = req.ToFile(constant.IMPORT_EXCEL)
	if err != nil {
		logs.Error("could not save to file: ", err)
	}

	// 返回字段定义
	ret := map[string]interface{}{}

	resp, err := req.Response()
	if err != nil {
		logs.Error("could not get response: ", err)
	} else {
		logs.Info(resp)
		ret = map[string]interface{}{
			"url": "http://" + c.Ctx.Request.Host + "/" + constant.APP_NAME + "/download/订单数据模板.xlsx",
		}
		c.ResponseData(ret)
	}
}

/**
 * @Author SteveChan
 * @Description // 导入excel订单
 * @Date 10:52 2021/1/6
 * @Param
 * @return
 **/
func (c *OrderInfoController) ImportOrderFromExcel() {
	// 获取参数
	typeCode := c.GetString("type")
	file, h, _ := c.GetFile("file")
	companyId := c.GetUserCompany()

	if typeCode != "PARTNER_ORDER_FILE" {
		c.ResponseError(errors.New("类型编码错误"))
	}

	// 返回字段定义
	ret := map[string]interface{}{}

	// 返回信息表头定义 0: 订单号, 1: 发货单号, 2: 客户名称, 3: 订单区域, 4: 编号, 5: 合伙人, 6: 类型, 7: 业务员抽成比例, 8: 产品名称, 9: 数量, 10: 单价, 11: 合伙人分红比例
	var tableHeader = []string{"错误详情", "行号", "订单号", "发货单号", "客户名称", "订单区域", "编号", "合伙人", "类型", "业务员抽成比例", "产品名称", "数量", "单价", "合伙人分红比例"}

	// 文件后缀名校验
	ext := path.Ext(h.Filename)
	AllowExtMap := map[string]bool{
		".xlsx": true,
	}
	if _, ok := AllowExtMap[ext]; !ok {
		c.ResponseError(errors.New("文件后缀名不符合上传要求，请上传正确格式的文件"))
		return
	}

	// 打开文件
	xlsx, err := excelize.OpenReader(file)
	if err != nil {
		c.ResponseError(errors.New("文件打开失败，请确定文件能够正常打开"))
		return
	}

	// 文件行数校验
	rows, _ := xlsx.GetRows("工作表1")
	if len(rows) > 303 {
		c.ResponseError(errors.New("导入文件的行数超过300行，请调整行数后重新导入"))
		return
	}

	// 文件列数据校验
	overColumnLine := make([]interface{}, 0)
	for i, row := range rows {
		if i > 2 && row != nil {
			if len(row) > constant.EXCEL_COLUMN {
				var tmpRow []string
				tmpRow = append(tmpRow, "存在无效的数据列，请删除无效的列数据") // 错误信息
				s := strconv.Itoa(i + 1)
				tmpRow = append(tmpRow, s)      // 行号
				tmpRow = append(tmpRow, row...) // 错误行数据
				overColumnLine = append(overColumnLine, tmpRow)
			}
		}
	}
	if len(overColumnLine) > 0 {
		ret = map[string]interface{}{
			"successCount": 0,
			"fail": map[string]interface{}{
				"tableHeader": tableHeader,
				"tableData":   overColumnLine,
			},
		}
		c.ResponseData(ret)
		return
	}

	// 数据行计数
	rowCnt := 0

	// 空文件校验
	if len(rows) < 3 {
		c.ResponseError(errors.New("导入的excel文件为空文件，请上传正确的文件"))
	}

	// 必填项校验
	nullLine := make([]interface{}, 0)

	nullFlag := false
	for i, row := range rows {
		if i > 2 && row != nil {
			rowCnt++
			if len(row) == constant.EXCEL_COLUMN { // 必填项内容为空
				var tmpRow = row
				nullCell := make([]interface{}, 0)
				var myRow []string
				for j, _ := range row {
					if j != 7 { // 业务员抽成比例非必填
						if row[j] == "" || row[j] == " " { // 空字符补位
							tmpRow[j] = ""
							col := strconv.Itoa(j + 1)
							nullCell = append(nullCell, col)
							nullFlag = true
						}
					}
				}
				if nullFlag {
					s := strconv.Itoa(i + 1)
					b := strings.Replace(strings.Trim(fmt.Sprint(nullCell), "[]"), " ", ",", -1)
					myRow = append(myRow, "第"+s+"行的第"+b+"列必填项为空") // 错误信息
					myRow = append(myRow, s)                      // 行号
					myRow = append(myRow, tmpRow...)              // 错误行数据
					nullLine = append(nullLine, myRow)
					nullFlag = false
				}
			} else if len(row) > 0 && len(row) < constant.EXCEL_COLUMN { // 必填项不存在
				var myRow []string
				myRow = append(myRow, "必填项为空")
				s := strconv.Itoa(i + 1)
				myRow = append(myRow, s)      // 行号
				myRow = append(myRow, row...) // 错误行数据
				emptyCell := make([]interface{}, 0)
				//  错误信息
				for k := 0; k < constant.EXCEL_COLUMN-len(row); k++ { // 空字符补位
					myRow = append(myRow, "")
				}
				for k, cell := range myRow {
					if k != 0 && cell == "" {
						emptyCell = append(emptyCell, k-1)
					}
				}
				b := strings.Replace(strings.Trim(fmt.Sprint(emptyCell), "[]"), " ", ",", -1)
				myRow[0] = "第" + s + "行的第" + b + "列必填项为空"
				nullLine = append(nullLine, myRow)
			}
		}
	}

	// 空单元格返回
	if len(nullLine) > 0 {
		ret = map[string]interface{}{
			"successCount": 0,
			"fail": map[string]interface{}{
				"tableHeader": tableHeader,
				"tableData":   nullLine,
			},
		}
		c.ResponseData(ret)
		return
	}

	// 内容校验
	errorLine := make([]interface{}, 0)
	var partnerType = []string{"事业合伙", "业务合伙", "研发合伙", "业务-产品应用合伙"}
	for i, row := range rows {
		if i > 2 && row != nil && len(row) == constant.EXCEL_COLUMN { // 数据行
			var myRow []string
			for j, cell := range row {

				r := strconv.Itoa(i + 1)
				col := strconv.Itoa(j + 1)

				switch j {
				case 0, 1, 2, 3, 4, 5, 8: // 订单号、发货单号、客户名称、订单区域、编号、合伙人、产品名称长度校验
					{
						cellStr := strings.TrimSpace(cell)
						lenCellStr := utf8.RuneCountInString(cellStr)

						if lenCellStr > 50 {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列"+tableHeader[j+2]+"长度超过50位，请重新输入") // 错误信息
							tmpRow = append(tmpRow, r)                                                   // 行号
							tmpRow = append(tmpRow, row...)                                              // 错误行数据
							myRow = tmpRow
						}
					}
				case 6: // 合伙人类型校验（事业合伙、业务合伙、研发合伙、业务-产品应用合伙）
					{
						if !utils.IsContain(partnerType, cell) {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列合伙人类型错误，合伙人类型必须为以下类型：事业合伙、业务合伙、研发合伙、业务-产品应用合伙") // 错误信息
							tmpRow = append(tmpRow, r)                                                               // 行号
							tmpRow = append(tmpRow, row...)                                                          // 错误行数据
							myRow = tmpRow
						}
					}
				case 7: // 业务员抽成比例，非必填，精确到小数点后两位
					{
						if len(cell) > 0 {

							// 参数类型转换
							shareRatio, err := strconv.ParseFloat(cell, 64)
							if err != nil {
								var tmpRow []string
								tmpRow = append(tmpRow, "第"+r+"行第"+col+"列业务员抽成比例格式错误，业务员抽成比例必须为数字") // 错误信息
								tmpRow = append(tmpRow, r)                                          // 行号
								tmpRow = append(tmpRow, row...)                                     // 错误行数据
								myRow = tmpRow
							}

							// 比例不能超过100%
							if shareRatio > 100 {
								var tmpRow []string
								tmpRow = append(tmpRow, "第"+r+"行第"+col+"列业务员抽成比例超过限额，请输入正确的业务员抽成比例，并保留两位小数") // 错误信息
								tmpRow = append(tmpRow, r)                                                   // 行号
								tmpRow = append(tmpRow, row...)                                              // 错误行数据
								myRow = tmpRow
							}

							// 长度校验
							regexpStr := `^(100|[1-9]\d|\d)(.\d{1,2})?$`
							ok := regexp.MustCompile(regexpStr).MatchString(cell)
							if !ok {
								var tmpRow []string
								tmpRow = append(tmpRow, "第"+r+"行第"+col+"列业务员抽成比例超过最大长度，请输入正确的业务员抽成比例，并保留两位小数") // 错误信息
								tmpRow = append(tmpRow, r)                                                     // 行号
								tmpRow = append(tmpRow, row...)                                                // 错误行数据
								myRow = tmpRow
							}
						}
					}
				case 9: // 数量不超过16位正整数
					{
						//参数类型转换
						orderNum, err := strconv.ParseInt(cell, 10, 64)
						if err != nil {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列产品数量格式错误，产品数量必须整数") // 错误信息
							tmpRow = append(tmpRow, r)                                   // 行号
							tmpRow = append(tmpRow, row...)                              // 错误行数据
							myRow = tmpRow
						}

						// 长度校验
						if orderNum > 1e16 {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列产品数量长度超过最大限制十六位整数，请重新填写") // 错误信息
							tmpRow = append(tmpRow, r)                                         // 行号
							tmpRow = append(tmpRow, row...)                                    // 错误行数据
							myRow = tmpRow
						}
					}
				case 10: // 单价，精确到小数点后两位，小数点左侧最多可输入16位数字
					{

						// 参数类型转换
						univalent, typeErr := strconv.ParseFloat(cell, 64)
						if typeErr != nil {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列单价格式错误，产品单价必须为数字类型") // 错误信息
							tmpRow = append(tmpRow, r)                                    // 行号
							tmpRow = append(tmpRow, row...)                               // 错误行数据
							myRow = tmpRow
						}

						// 长度校验
						if univalent >= 1e16 {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列产品单价超过最大限制，产品单价小数点前面不能超过十六位数字，并保留两位小数") // 错误信息
							tmpRow = append(tmpRow, r)                                                       // 行号
							tmpRow = append(tmpRow, row...)                                                  // 错误行数据
							myRow = tmpRow
						}
					}
				case 11: // 合伙人分红比例，精确到小数点后两位
					{
						//参数类型转换
						partnerRatio, parseErr := strconv.ParseFloat(cell, 64)
						if parseErr != nil {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列合伙人分红比例类型错误，合伙人分红比例必须为数字") // 错误信息
							tmpRow = append(tmpRow, r)                                          // 行号
							tmpRow = append(tmpRow, row...)                                     // 错误行数据
							myRow = tmpRow
						}

						// 合伙人分红比例超额
						if partnerRatio > 100 {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列合伙人分红比例超过限额，请输入正确的合伙人分红比例，并保留两位小数") // 错误信息
							tmpRow = append(tmpRow, r)                                                   // 行号
							tmpRow = append(tmpRow, row...)                                              // 错误行数据
							myRow = tmpRow
						}

						// 长度判断
						regexpStr := `^(100|[1-9]\d|\d)(.\d{1,2})?$`
						ok := regexp.MustCompile(regexpStr).MatchString(cell)
						if !ok {
							var tmpRow []string
							tmpRow = append(tmpRow, "第"+r+"行第"+col+"列合伙人分红比例超过最大长度，请输入正确的合伙人分红比例，并保留两位小数") // 错误信息
							tmpRow = append(tmpRow, r)                                                     // 行号
							tmpRow = append(tmpRow, row...)                                                // 错误行数据
							myRow = tmpRow
						}
					}
				}
			}
			if myRow != nil {
				errorLine = append(errorLine, myRow)
			}
		}
	}

	// 内容错误行返回
	if len(errorLine) > 0 {
		ret = map[string]interface{}{
			"successCount": 0,
			"fail": map[string]interface{}{
				"tableHeader": tableHeader,
				"tableData":   errorLine,
			},
		}
		c.ResponseData(ret)
		return
	}

	// 创建订单服务
	orderSrv := orderService.NewOrderInfoService(nil)

	// 合伙人检索错误
	partnerDataList := make([]interface{}, 0)

	// 聚合订单产品
	var orderCommands = make(map[string]*orderCmd.CreateOrderCommand, 0)
	for i, row := range rows {
		if i > 2 && len(row) == constant.EXCEL_COLUMN {
			hashValue := md5.Sum([]byte(row[0] + row[1] + row[4] + row[6])) // 根据：订单号+发货单号+合伙人编号+合伙类型计算哈希值
			hashString := hex.EncodeToString(hashValue[:])

			if _, ok := orderCommands[hashString]; !ok {
				//订单相关，0: 订单号, 1: 发货单号, 2: 客户名称, 3: 订单区域, 4: 编号, 5: 合伙人, 6: 类型, 7: 业务抽成比例,
				sbPercent, _ := strconv.ParseFloat(row[7], 64) //业务抽成比例

				//产品相关，8: 产品名称, 9: 数量, 10: 单价, 11: 合伙人分红比例
				amount, _ := strconv.ParseInt(row[9], 10, 64) // 数量
				price, _ := strconv.ParseFloat(row[10], 64)   // 单价
				percent, _ := strconv.ParseFloat(row[11], 64) // 合伙人分红比例

				// 获取partnerId
				var partnerInfo *domain.PartnerInfo

				orderQueryData := orderQuery.GetPartnerIdQuery{
					Code:            row[4],
					PartnerCategory: 0,
					CompanyId:       companyId,
				}

				// 1: 事业合伙、2: 业务合伙、3: 研发合伙、4: 业务-产品应用合伙
				switch row[6] {
				case "事业合伙":
					orderQueryData.PartnerCategory = 1
				case "业务合伙":
					orderQueryData.PartnerCategory = 2
				case "研发合伙":
					orderQueryData.PartnerCategory = 3
				case "业务-产品应用合伙":
					orderQueryData.PartnerCategory = 4
				default:
					orderQueryData.PartnerCategory = 0
				}

				// 初始化建订单命令集
				orderCommands[hashString] = &orderCmd.CreateOrderCommand{
					OrderType:            0,
					OrderCode:            row[0],
					DeliveryCode:         row[1],
					BuyerName:            row[2],
					OrderRegion:          row[3],
					PartnerId:            0, // 根据合伙人类型+合伙人编号查找合伙人id
					SalesmanBonusPercent: sbPercent,
					Goods: []orderCmd.OrderGoodData{
						{
							GoodName:            row[8],
							PlanGoodNumber:      int(amount),
							Price:               price,
							PartnerBonusPercent: percent,
							LineNumber:          i,
						},
					},
					CompanyId:       companyId,
					PartnerCategory: int64(orderQueryData.PartnerCategory),
					LineNumbers:     []int{i}, // 记录行号
				}

				partnerInfo, err = orderSrv.GetPartnerIdByCodeAndCategory(orderQueryData)
				if err != nil || partnerInfo == nil { // 检索合伙人错误
					var tmpRow []string
					tmpRow = append(tmpRow, err.Error()) // 错误信息
					s := strconv.Itoa(i + 1)
					tmpRow = append(tmpRow, s)      // 行号
					tmpRow = append(tmpRow, row...) // 错误行数据
					partnerDataList = append(partnerDataList, tmpRow)
				}
				if partnerInfo != nil {
					orderCommands[hashString].PartnerId = partnerInfo.Partner.Id
				}
			} else {
				//产品相关，8: 产品名称, 9: 数量, 10: 单价, 11: 合伙人分红比例
				amount, _ := strconv.ParseInt(row[9], 10, 64) // 数量
				price, _ := strconv.ParseFloat(row[10], 64)   // 单价
				percent, _ := strconv.ParseFloat(row[11], 64) // 合伙人分红比例

				// 记录同一笔订单产品
				orderCommands[hashString].Goods = append(orderCommands[hashString].Goods, orderCmd.OrderGoodData{
					GoodName:            row[8],
					PlanGoodNumber:      int(amount),
					Price:               price,
					PartnerBonusPercent: percent,
					LineNumber:          i, // 记录行号
				})

				// 记录聚合行号
				orderCommands[hashString].LineNumbers = append(orderCommands[hashString].LineNumbers, i)
			}
		}
	}
	if len(partnerDataList) > 0 {
		ret = map[string]interface{}{
			"successCount": 0,
			"fail": map[string]interface{}{
				"tableHeader": tableHeader,
				"tableData":   partnerDataList,
			},
		}
		c.ResponseData(ret)
		return
	}

	// 产品数量校验
	productNumberError := make([]interface{}, 0)

	// 批量创建订单命令集和产品数量校验
	var createOrderCommands []*orderCmd.CreateOrderCommand
	for _, orderCommand := range orderCommands {
		if len(orderCommand.Goods) > 50 { // 产品数量校验
			for _, line := range orderCommand.LineNumbers {
				var tmpRow []string
				tmpRow = append(tmpRow, "单笔订单产品超过50种") // 错误信息
				s := strconv.Itoa(line + 1)
				tmpRow = append(tmpRow, s)             // 行号
				tmpRow = append(tmpRow, rows[line]...) // 错误行数据
				productNumberError = append(productNumberError, tmpRow)
			}
		} else {
			createOrderCommands = append(createOrderCommands, orderCommand)
		}
	}

	if len(productNumberError) > 0 {
		ret = map[string]interface{}{
			"successCount": 0,
			"fail": map[string]interface{}{
				"tableHeader": tableHeader,
				"tableData":   productNumberError,
			},
		}
		c.ResponseData(ret)
		return
	}

	// 新增失败记录
	failureDataList := make([]interface{}, 0)

	// 新增成功记录计数
	var successDataCount int64

	// 批量新增订单
	errorDataList, createError := orderSrv.CreateNewOrderByImport(createOrderCommands)
	if createError != nil {
		c.ResponseError(createError)
		return
	} else {
		if len(errorDataList) > 0 { // 导入失败返回
			successDataCount = 0
			// 错误记录处理
			for _, errorData := range errorDataList {
				if len(errorData.GoodLine) == 0 { // 订单错误
					for _, line := range errorData.LineNumbers {
						var tmpRow []string
						tmpRow = append(tmpRow, errorData.Error.Error()) // 错误信息
						s := strconv.Itoa(line + 1)
						tmpRow = append(tmpRow, s)             // 行号
						tmpRow = append(tmpRow, rows[line]...) // 错误行数据
						failureDataList = append(failureDataList, tmpRow)
					}
				} else if len(errorData.GoodLine) > 0 { // 订单产品错误
					for line := range errorData.GoodLine {
						var tmpRow []string
						tmpRow = append(tmpRow, errorData.Error.Error()) // 错误信息
						s := strconv.Itoa(line + 1)
						tmpRow = append(tmpRow, s)             // 行号
						tmpRow = append(tmpRow, rows[line]...) // 错误行数据
						failureDataList = append(failureDataList, tmpRow)
					}
				}
			}

			ret = map[string]interface{}{
				"successCount": successDataCount,
				"fail": map[string]interface{}{
					"tableHeader": tableHeader,
					"tableData":   failureDataList,
				},
			}
		} else { // 导入成功返回
			successDataCount = int64(rowCnt - len(failureDataList))
			if successDataCount == int64(rowCnt) {
				ret = map[string]interface{}{
					"successCount": successDataCount,
					"fail":         nil,
				}
			}
		}
	}

	// 返回错误详情
	c.ResponseData(ret)
	return
}