802 lines
24 KiB
Go
802 lines
24 KiB
Go
|
// ==========================================================================
|
|||
|
|
// GFast自动生成controller操作代码。
|
|||
|
|
// 生成日期：2023-07-31 11:20:54
|
|||
|
|
// 生成路径: internal/app/system/controller/qianqi_fangzhen.go
|
|||
|
|
// 生成人：gfast
|
|||
|
|
// desc:方阵
|
|||
|
|
// company:云南奇讯科技有限公司
|
|||
|
|
// ==========================================================================
|
|||
|
|
|
|||
|
|
package controller
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"context"
|
|||
|
|
"encoding/json"
|
|||
|
|
"errors"
|
|||
|
|
"fmt"
|
|||
|
|
"github.com/gogf/gf/v2/crypto/gmd5"
|
|||
|
|
"github.com/gogf/gf/v2/database/gdb"
|
|||
|
|
"github.com/gogf/gf/v2/frame/g"
|
|||
|
|
"github.com/google/uuid"
|
|||
|
|
"github.com/jinzhu/copier"
|
|||
|
|
"github.com/tiger1103/gfast/v3/api/v1/common/shp"
|
|||
|
|
tool2 "github.com/tiger1103/gfast/v3/api/v1/common/tool"
|
|||
|
|
"github.com/tiger1103/gfast/v3/api/v1/system"
|
|||
|
|
"github.com/tiger1103/gfast/v3/internal/app/system/dao"
|
|||
|
|
ct "github.com/tiger1103/gfast/v3/internal/app/system/logic/context"
|
|||
|
|
"github.com/tiger1103/gfast/v3/internal/app/system/model"
|
|||
|
|
"github.com/tiger1103/gfast/v3/internal/app/system/model/do"
|
|||
|
|
"github.com/tiger1103/gfast/v3/internal/app/system/model/entity"
|
|||
|
|
"github.com/tiger1103/gfast/v3/internal/app/system/service"
|
|||
|
|
"github.com/tiger1103/gfast/v3/library/liberr"
|
|||
|
|
"github.com/tiger1103/gfast/v3/third/create"
|
|||
|
|
tool "github.com/tiger1103/gfast/v3/utility/coryUtils"
|
|||
|
|
"math/rand"
|
|||
|
|
"os"
|
|||
|
|
"os/exec"
|
|||
|
|
"strconv"
|
|||
|
|
"strings"
|
|||
|
|
"time"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
type qianqiDxfController struct {
|
|||
|
|
BaseController
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var QianqiDxf = new(qianqiDxfController)
|
|||
|
|
|
|||
|
|
func (c *qianqiDxfController) FzFunc(ctx context.Context, req *system.FzReq) (res *system.FzRes, err error) {
|
|||
|
|
err = g.DB().Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|||
|
|
err = g.Try(ctx, func(ctx context.Context) {
|
|||
|
|
//1、获取数据
|
|||
|
|
point := req.Point
|
|||
|
|
plane := req.Plane
|
|||
|
|
//2、合并名称
|
|||
|
|
var listE []system.FacFeatureByPlane //面
|
|||
|
|
for _, data := range plane {
|
|||
|
|
adata := system.FacFeatureByPlane{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listE = append(listE, adata)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
var listT []system.FacFeatureByPoint //点
|
|||
|
|
for _, data := range point {
|
|||
|
|
adata := system.FacFeatureByPoint{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listT = append(listT, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
var templateDataList []do.WorkStatus
|
|||
|
|
//3、循环判断坐标是否在点内
|
|||
|
|
for _, i := range listE {
|
|||
|
|
var minVal float64
|
|||
|
|
var fzName string
|
|||
|
|
for num, j := range listT {
|
|||
|
|
inPolygon := tool.FanWei(i.Geometry.Coordinates[0], j.Geometry.Coordinates)
|
|||
|
|
//如果为true，说明在多边形内
|
|||
|
|
if inPolygon {
|
|||
|
|
//直接确认数据
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
} else {
|
|||
|
|
distance := tool.PointToPolygonDistance(i.Geometry.Coordinates[0], j.Geometry.Coordinates)
|
|||
|
|
fmt.Printf("点到多边形的最短距离（单位米）：%.2f m\n", distance)
|
|||
|
|
if num == 0 {
|
|||
|
|
if len(listT) == 1 { //只有一个情况下直接赋值
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
break
|
|||
|
|
}
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
} else {
|
|||
|
|
if distance < minVal {
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//得到详情数据（方阵）
|
|||
|
|
points := []shp.Point{}
|
|||
|
|
for _, jwd := range i.Geometry.Coordinates[0] {
|
|||
|
|
points = append(points, shp.Point{
|
|||
|
|
Lng: jwd[0],
|
|||
|
|
Lat: jwd[1],
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
polygon := shp.Polygon{
|
|||
|
|
Positions: points,
|
|||
|
|
}
|
|||
|
|
marshal, err := json.Marshal(polygon)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "详情获取失败")
|
|||
|
|
}
|
|||
|
|
//分割名称
|
|||
|
|
if fzName != "" {
|
|||
|
|
fzName = strings.Split(fzName, " ")[0]
|
|||
|
|
}
|
|||
|
|
// 将方阵的名称 作为方阵的id
|
|||
|
|
fangzhen, err := dao.QianqiFangzhen.Ctx(ctx).Insert(&do.QianqiFangzhen{
|
|||
|
|
ProjectId: req.SubProjectId,
|
|||
|
|
Name: fzName,
|
|||
|
|
SourceId: tool2.GetUuid(),
|
|||
|
|
CreateBy: ct.New().GetLoginUser(ctx).Id,
|
|||
|
|
Detail: string(marshal),
|
|||
|
|
})
|
|||
|
|
templateID, err := fangzhen.LastInsertId()
|
|||
|
|
if err != nil {
|
|||
|
|
continue
|
|||
|
|
}
|
|||
|
|
templateData, err := create.FetchTemplateData(ctx, templateID)
|
|||
|
|
if err != nil {
|
|||
|
|
continue
|
|||
|
|
}
|
|||
|
|
templateDataList = append(templateDataList, templateData...)
|
|||
|
|
}
|
|||
|
|
_, err = dao.WorkStatus.Ctx(ctx).Data(templateDataList).Batch(50).Insert()
|
|||
|
|
})
|
|||
|
|
return err
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func (c *qianqiDxfController) XbFunc(ctx context.Context, req *system.XbReq) (res *system.XbRes, err error) {
|
|||
|
|
var xbList []shp.Polyline
|
|||
|
|
err = g.DB().Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|||
|
|
err = g.Try(ctx, func(ctx context.Context) {
|
|||
|
|
/**
|
|||
|
|
一、箱变的录入
|
|||
|
|
*/
|
|||
|
|
var listE []system.FacFeatureByPoint //面
|
|||
|
|
for _, data := range req.Plane {
|
|||
|
|
adata := system.FacFeatureByPoint{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listE = append(listE, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
var listT []system.FacFeatureByPoint //点
|
|||
|
|
for _, data := range req.Point {
|
|||
|
|
adata := system.FacFeatureByPoint{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listT = append(listT, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
var xiangbianArray []do.QianqiXiangbian
|
|||
|
|
//3、循环判断坐标是否在点内
|
|||
|
|
for _, i := range listE {
|
|||
|
|
var minVal float64
|
|||
|
|
var fzName string
|
|||
|
|
for num, j := range listT {
|
|||
|
|
distance := tool.PointToPointDistance(i.Geometry.Coordinates, j.Geometry.Coordinates)
|
|||
|
|
if num == 0 {
|
|||
|
|
if len(listT) == 1 { //只有一个情况下直接赋值
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
break
|
|||
|
|
}
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
} else {
|
|||
|
|
if distance < minVal {
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if fzName != "" {
|
|||
|
|
fzName = strings.Split(fzName, " ")[0]
|
|||
|
|
}
|
|||
|
|
//得到详情数据（箱变）
|
|||
|
|
points := []shp.Point{
|
|||
|
|
{
|
|||
|
|
Lng: i.Geometry.Coordinates[0],
|
|||
|
|
Lat: i.Geometry.Coordinates[1],
|
|||
|
|
Property: shp.Property{
|
|||
|
|
Name: fzName,
|
|||
|
|
},
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
polylines := shp.Polyline{
|
|||
|
|
Positions: points,
|
|||
|
|
Property: shp.Property{
|
|||
|
|
Name: fzName,
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
xbList = append(xbList, polylines)
|
|||
|
|
marshal, err := json.Marshal(polylines)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "详情获取失败")
|
|||
|
|
}
|
|||
|
|
xb := do.QianqiXiangbian{
|
|||
|
|
ProjectId: req.SubProjectId,
|
|||
|
|
SourceId: gmd5.MustEncryptString(req.ProjectId + fzName),
|
|||
|
|
Name: fzName,
|
|||
|
|
ModelId: "518bb3c165e22097ebbf2c2c42c8e308",
|
|||
|
|
CreateBy: ct.New().GetLoginUser(ctx).Id,
|
|||
|
|
Detail: string(marshal),
|
|||
|
|
}
|
|||
|
|
// 判断是否已经存在了该方阵，存在了就不再添加
|
|||
|
|
count, _ := dao.QianqiXiangbian.Ctx(ctx).Where(dao.QianqiXiangbian.Columns().SourceId, xb.SourceId).Count()
|
|||
|
|
if count == 0 {
|
|||
|
|
xiangbianArray = append(xiangbianArray, xb)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if len(xiangbianArray) > 0 {
|
|||
|
|
_, err = dao.QianqiXiangbian.Ctx(ctx).Insert(&xiangbianArray)
|
|||
|
|
liberr.ErrIsNil(ctx, err, "添加失败")
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
二、需要操作pvmodel
|
|||
|
|
*/
|
|||
|
|
if err == nil {
|
|||
|
|
//1、获取当前项目的所有方阵，然后判断箱变是否在方阵内（或最近），然后记录方阵id
|
|||
|
|
var fzres []*model.QianqiFangzhenInfoRes
|
|||
|
|
dao.QianqiFangzhen.Ctx(ctx).Where(dao.QianqiFangzhen.Columns().ProjectId, req.SubProjectId).Scan(&fzres)
|
|||
|
|
for _, fz := range fzres {
|
|||
|
|
var minVal float64
|
|||
|
|
var fzId int
|
|||
|
|
var data *shp.Polyline
|
|||
|
|
// 解析JSON数据
|
|||
|
|
var polygon shp.Polygon
|
|||
|
|
err = json.Unmarshal([]byte(fz.Detail), &polygon)
|
|||
|
|
array := tool.ConvertPolygonToFloatArray(polygon)
|
|||
|
|
for num, xb := range xbList {
|
|||
|
|
numbers := []float64{xb.Positions[0].Lng, xb.Positions[0].Lat}
|
|||
|
|
wei := tool.FanWei(array, numbers)
|
|||
|
|
//如果为true，说明在多边形内
|
|||
|
|
if wei {
|
|||
|
|
fzId = fz.Id
|
|||
|
|
data = &xb
|
|||
|
|
} else {
|
|||
|
|
distance := tool.PointToPolygonDistance(array, numbers)
|
|||
|
|
if num == 0 {
|
|||
|
|
if len(xbList) == 1 { //只有一个情况下直接赋值
|
|||
|
|
minVal = distance
|
|||
|
|
fzId = fz.Id
|
|||
|
|
data = &xb
|
|||
|
|
break
|
|||
|
|
}
|
|||
|
|
minVal = distance
|
|||
|
|
fzId = fz.Id
|
|||
|
|
data = &xb
|
|||
|
|
} else {
|
|||
|
|
if distance < minVal {
|
|||
|
|
minVal = distance
|
|||
|
|
fzId = fz.Id
|
|||
|
|
data = &xb
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if data != nil {
|
|||
|
|
err := service.PvModule().ImportCory(ctx, &system.PvModuleImportCory{
|
|||
|
|
FangZhenID: strconv.Itoa(fzId),
|
|||
|
|
ProjectID: req.ProjectId,
|
|||
|
|
SubProjectID: req.SubProjectId,
|
|||
|
|
Shapes: &shp.ShpObj{
|
|||
|
|
Polylines: []shp.Polyline{
|
|||
|
|
*data,
|
|||
|
|
},
|
|||
|
|
},
|
|||
|
|
})
|
|||
|
|
liberr.ErrIsNil(ctx, err, "pvmodel箱变录入失败")
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
return err
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func (c *qianqiDxfController) NbqFunc(ctx context.Context, req *system.NbqReq) (res *system.NbqRes, err error) {
|
|||
|
|
var nbqList []shp.Polyline
|
|||
|
|
err = g.DB().Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|||
|
|
err = g.Try(ctx, func(ctx context.Context) {
|
|||
|
|
/**
|
|||
|
|
一、处理逆变器数据
|
|||
|
|
*/
|
|||
|
|
//1、获取数据
|
|||
|
|
point := req.Point
|
|||
|
|
plane := req.Plane
|
|||
|
|
//2、合并名称
|
|||
|
|
var listE []system.FacFeatureByPoint //面
|
|||
|
|
for _, data := range plane {
|
|||
|
|
adata := system.FacFeatureByPoint{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listE = append(listE, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
var listT []system.FacFeatureByPoint //点
|
|||
|
|
for _, data := range point {
|
|||
|
|
adata := system.FacFeatureByPoint{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listT = append(listT, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
var arr []do.QianqiNibianqi
|
|||
|
|
//3、循环判断坐标是否在点内
|
|||
|
|
for _, i := range listE {
|
|||
|
|
var minVal float64
|
|||
|
|
var fzName string
|
|||
|
|
for num, j := range listT {
|
|||
|
|
distance := tool.PointToPointDistance(i.Geometry.Coordinates, j.Geometry.Coordinates)
|
|||
|
|
if num == 0 {
|
|||
|
|
if len(listT) == 1 { //只有一个情况下直接赋值
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
break
|
|||
|
|
}
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
} else {
|
|||
|
|
if distance < minVal {
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//}
|
|||
|
|
}
|
|||
|
|
if fzName != "" {
|
|||
|
|
fzName = strings.Split(fzName, " ")[0]
|
|||
|
|
}
|
|||
|
|
//得到详情数据（方阵）
|
|||
|
|
points := []shp.Point{
|
|||
|
|
{
|
|||
|
|
Lng: i.Geometry.Coordinates[0],
|
|||
|
|
Lat: i.Geometry.Coordinates[1],
|
|||
|
|
Property: shp.Property{
|
|||
|
|
Name: fzName,
|
|||
|
|
},
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
polylines := shp.Polyline{
|
|||
|
|
Positions: points,
|
|||
|
|
Property: shp.Property{
|
|||
|
|
Name: fzName,
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
nbqList = append(nbqList, polylines)
|
|||
|
|
marshal, err := json.Marshal(polylines)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "详情获取失败")
|
|||
|
|
}
|
|||
|
|
nibianqi := do.QianqiNibianqi{}
|
|||
|
|
nibianqi.ProjectId = req.SubProjectId
|
|||
|
|
nibianqi.SourceId = gmd5.MustEncryptString(req.ProjectId + fzName)
|
|||
|
|
nibianqi.Name = fzName
|
|||
|
|
nibianqi.ModelId = "41b366a9bae250098716da675d3ae26d"
|
|||
|
|
nibianqi.CreateBy = ct.New().GetLoginUser(ctx).Id
|
|||
|
|
nibianqi.Detail = string(marshal)
|
|||
|
|
// 判断是否已经存在了该方阵，存在了就不再添加
|
|||
|
|
count, _ := dao.QianqiNibianqi.Ctx(ctx).Where(dao.QianqiNibianqi.Columns().SourceId, nibianqi.SourceId).Count()
|
|||
|
|
if count == 0 {
|
|||
|
|
arr = append(arr, nibianqi)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if len(arr) > 0 {
|
|||
|
|
_, err = dao.QianqiNibianqi.Ctx(ctx).Insert(&arr)
|
|||
|
|
liberr.ErrIsNil(ctx, err, "添加失败")
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
二、进行pvmodel数据处理
|
|||
|
|
*/
|
|||
|
|
if err == nil {
|
|||
|
|
//1、获取当前项目的所有方阵，然后判断箱变是否在方阵内（或最近），然后记录方阵id
|
|||
|
|
var fzres []*model.QianqiFangzhenInfoRes
|
|||
|
|
dao.QianqiFangzhen.Ctx(ctx).Where(dao.QianqiFangzhen.Columns().ProjectId, req.SubProjectId).Scan(&fzres)
|
|||
|
|
for _, fz := range fzres {
|
|||
|
|
var minVal float64
|
|||
|
|
var fzId int
|
|||
|
|
var data *shp.Polyline
|
|||
|
|
// 解析JSON数据
|
|||
|
|
var polygon shp.Polygon
|
|||
|
|
err = json.Unmarshal([]byte(fz.Detail), &polygon)
|
|||
|
|
array := tool.ConvertPolygonToFloatArray(polygon)
|
|||
|
|
for num, xb := range nbqList {
|
|||
|
|
numbers := []float64{xb.Positions[0].Lng, xb.Positions[0].Lat}
|
|||
|
|
wei := tool.FanWei(array, numbers)
|
|||
|
|
//如果为true，说明在多边形内
|
|||
|
|
if wei {
|
|||
|
|
fzId = fz.Id
|
|||
|
|
} else {
|
|||
|
|
distance := tool.PointToPolygonDistance(array, numbers)
|
|||
|
|
if num == 0 {
|
|||
|
|
if len(nbqList) == 1 { //只有一个情况下直接赋值
|
|||
|
|
minVal = distance
|
|||
|
|
fzId = fz.Id
|
|||
|
|
data = &xb
|
|||
|
|
break
|
|||
|
|
}
|
|||
|
|
minVal = distance
|
|||
|
|
fzId = fz.Id
|
|||
|
|
data = &xb
|
|||
|
|
} else {
|
|||
|
|
if distance < minVal {
|
|||
|
|
minVal = distance
|
|||
|
|
fzId = fz.Id
|
|||
|
|
data = &xb
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if data != nil {
|
|||
|
|
err := service.PvModule().ImportInverterCory(ctx, &system.ImportInverterCory{
|
|||
|
|
FangZhenID: strconv.Itoa(fzId),
|
|||
|
|
ProjectID: req.ProjectId,
|
|||
|
|
SubProjectID: req.SubProjectId,
|
|||
|
|
Shapes: &shp.ShpObj{
|
|||
|
|
Polylines: []shp.Polyline{
|
|||
|
|
*data,
|
|||
|
|
},
|
|||
|
|
},
|
|||
|
|
})
|
|||
|
|
liberr.ErrIsNil(ctx, err, "pvmodel逆变器录入失败")
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
return err
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func (c *qianqiDxfController) GfbFunc(ctx context.Context, req *system.GfbReq) (res *system.GfbRes, err error) {
|
|||
|
|
err = g.DB().Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|||
|
|
err = g.Try(ctx, func(ctx context.Context) {
|
|||
|
|
var gfbList []shp.Polyline
|
|||
|
|
var eles []do.QianqiGuangfubanIds
|
|||
|
|
/**
|
|||
|
|
一、处理光伏板数据
|
|||
|
|
*/
|
|||
|
|
//1、获取数据
|
|||
|
|
point := req.Point
|
|||
|
|
plane := req.Plane
|
|||
|
|
//2、合并名称
|
|||
|
|
var listE []system.FacFeatureByPlane //面
|
|||
|
|
for _, data := range plane {
|
|||
|
|
adata := system.FacFeatureByPlane{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listE = append(listE, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
var listT []system.FacFeatureByPoint //点
|
|||
|
|
for _, data := range point {
|
|||
|
|
adata := system.FacFeatureByPoint{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listT = append(listT, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//3、循环判断坐标是否在点内
|
|||
|
|
for _, i := range listE {
|
|||
|
|
var minVal float64
|
|||
|
|
var fzName string
|
|||
|
|
for num, j := range listT {
|
|||
|
|
inPolygon := tool.FanWei(i.Geometry.Coordinates[0], j.Geometry.Coordinates)
|
|||
|
|
//如果为true，说明在多边形内
|
|||
|
|
if inPolygon {
|
|||
|
|
//直接确认数据
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
break
|
|||
|
|
} else {
|
|||
|
|
distance := tool.PointToPolygonDistance(i.Geometry.Coordinates[0], j.Geometry.Coordinates)
|
|||
|
|
if num == 0 {
|
|||
|
|
if len(listT) == 1 { //只有一个情况下直接赋值
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
break
|
|||
|
|
}
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
} else {
|
|||
|
|
if distance < minVal {
|
|||
|
|
minVal = distance
|
|||
|
|
fzName = j.Properties.Text //名字
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if fzName != "" {
|
|||
|
|
fzName = strings.Split(fzName, " ")[0]
|
|||
|
|
}
|
|||
|
|
//得到详情数据（方阵）
|
|||
|
|
points := []shp.Point{}
|
|||
|
|
for _, jwd := range i.Geometry.Coordinates[0] {
|
|||
|
|
points = append(points, shp.Point{
|
|||
|
|
Lng: jwd[0],
|
|||
|
|
Lat: jwd[1],
|
|||
|
|
Property: shp.Property{
|
|||
|
|
Name: fzName,
|
|||
|
|
},
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
polylines := shp.Polyline{
|
|||
|
|
Positions: points,
|
|||
|
|
Property: shp.Property{
|
|||
|
|
Name: fzName,
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
gfbList = append(gfbList, polylines)
|
|||
|
|
marshal, err := json.Marshal(polylines)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "详情获取失败")
|
|||
|
|
}
|
|||
|
|
//===================
|
|||
|
|
if !strings.HasPrefix(fzName, "G") {
|
|||
|
|
continue
|
|||
|
|
}
|
|||
|
|
// 设置随机数种子
|
|||
|
|
rand.Seed(time.Now().UnixNano())
|
|||
|
|
randomNum := rand.Intn(6) + 1
|
|||
|
|
randomStr1 := strconv.Itoa(randomNum)
|
|||
|
|
ele := do.QianqiGuangfubanIds{
|
|||
|
|
Name: fzName,
|
|||
|
|
DevType: "1",
|
|||
|
|
CreateBy: ct.New().GetLoginUser(ctx).Id,
|
|||
|
|
SourceType: "guangfuban",
|
|||
|
|
SourceId: tool2.GetUuid() + randomStr1,
|
|||
|
|
ProjectId: req.SubProjectId,
|
|||
|
|
Range: string(marshal),
|
|||
|
|
}
|
|||
|
|
eles = append(eles, ele)
|
|||
|
|
if len(eles) > 500 {
|
|||
|
|
dao.QianqiGuangfubanIds.Ctx(ctx).Insert(eles)
|
|||
|
|
eles = []do.QianqiGuangfubanIds{}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
二、进行pvmodel数据处理
|
|||
|
|
*/
|
|||
|
|
if err == nil {
|
|||
|
|
//1、获取当前项目的所有方阵，然后判断箱变是否在方阵内（或最近），然后记录方阵id
|
|||
|
|
fzres := []entity.QianqiFangzhen{}
|
|||
|
|
queryErr := dao.QianqiFangzhen.Ctx(ctx).
|
|||
|
|
Where(dao.QianqiFangzhen.Columns().ProjectId, req.SubProjectId).
|
|||
|
|
Scan(&fzres)
|
|||
|
|
if queryErr != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, queryErr, "方阵获取失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
for _, fz := range fzres {
|
|||
|
|
var data []shp.Polyline
|
|||
|
|
// 解析JSON数据
|
|||
|
|
var polygon shp.Polygon
|
|||
|
|
err = json.Unmarshal([]byte(fz.Detail), &polygon)
|
|||
|
|
array := tool.ConvertPolygonToFloatArray(polygon)
|
|||
|
|
for _, xb := range gfbList {
|
|||
|
|
numbers := []float64{xb.Positions[0].Lng, xb.Positions[0].Lat}
|
|||
|
|
wei := tool.FanWei(array, numbers)
|
|||
|
|
//如果为true，说明在多边形内
|
|||
|
|
if wei {
|
|||
|
|
polyline := shp.Polyline{}
|
|||
|
|
polyline = xb
|
|||
|
|
data = append(data, polyline)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if data != nil {
|
|||
|
|
err := service.PvModule().ImportPvBoardCory(ctx, &system.ImportPvBoardCory{
|
|||
|
|
FangZhenID: strconv.Itoa(fz.Id),
|
|||
|
|
ProjectID: req.ProjectId,
|
|||
|
|
SubProjectID: req.SubProjectId,
|
|||
|
|
Shapes: &shp.ShpObj{
|
|||
|
|
Polylines: data,
|
|||
|
|
},
|
|||
|
|
Fangzhens: fzres,
|
|||
|
|
})
|
|||
|
|
liberr.ErrIsNil(ctx, err, "pvmodel光伏板录入失败")
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
})
|
|||
|
|
return err
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 传入 point 构建出 detail 和 SourceID
|
|||
|
|
func buildDetailAndSourceID(point shp.Point, name string) (string, string) {
|
|||
|
|
// 生成 SourceID
|
|||
|
|
sourceID := fmt.Sprintf("%s.%s", point.Name, strings.ReplaceAll(uuid.New().String(), "-", ""))
|
|||
|
|
|
|||
|
|
detail := Zhuangdian{
|
|||
|
|
Position: point,
|
|||
|
|
}
|
|||
|
|
detail.Position.SourceId = sourceID
|
|||
|
|
|
|||
|
|
// 序列化后传回
|
|||
|
|
data, err := json.Marshal(detail)
|
|||
|
|
if err != nil {
|
|||
|
|
return "", ""
|
|||
|
|
}
|
|||
|
|
return string(data), sourceID
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func (c *qianqiDxfController) ZhuangDianFunc(ctx context.Context, req *system.ZdReq) (res *system.ZdRes, err error) {
|
|||
|
|
//1、获取数据
|
|||
|
|
plane := req.Plane
|
|||
|
|
//2、合并名称
|
|||
|
|
var listE []system.FacFeatureByPoint //面
|
|||
|
|
for _, data := range plane {
|
|||
|
|
adata := system.FacFeatureByPoint{}
|
|||
|
|
for _, bdata := range data.Features {
|
|||
|
|
copier.Copy(&adata, &bdata)
|
|||
|
|
listE = append(listE, adata)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//3-1、获取到所有的方阵、光伏板,获取到方阵id根布版图绑定
|
|||
|
|
fzres := []entity.QianqiFangzhen{}
|
|||
|
|
queryErr := dao.QianqiFangzhen.Ctx(ctx).
|
|||
|
|
Where(dao.QianqiFangzhen.Columns().ProjectId, req.SubProjectid).
|
|||
|
|
Scan(&fzres)
|
|||
|
|
if queryErr != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, queryErr, "方阵获取失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
columns := dao.QianqiGuangfubanIds.Columns()
|
|||
|
|
var resData []*model.QianqiGuangfubanIdsInfoRes
|
|||
|
|
dao.QianqiGuangfubanIds.Ctx(ctx).Where(columns.ProjectId, req.SubProjectid).Scan(&resData)
|
|||
|
|
if resData == nil && len(resData) == 0 {
|
|||
|
|
liberr.ErrIsNil(ctx, errors.New("光伏板获取失败"))
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
for i, datum := range resData {
|
|||
|
|
//布版图
|
|||
|
|
var polygon1 shp.Polygon
|
|||
|
|
err = json.Unmarshal([]byte(datum.Range), &polygon1)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "详情获取失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
f64 := []float64{polygon1.Positions[0].Lng, polygon1.Positions[0].Lat}
|
|||
|
|
for _, fzre := range fzres { //方阵
|
|||
|
|
//解析JSON数据
|
|||
|
|
var polygon shp.Polygon
|
|||
|
|
err = json.Unmarshal([]byte(fzre.Detail), &polygon)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "详情获取失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
array2 := tool.ConvertPolygonToFloatArray(polygon)
|
|||
|
|
if tool.FanWei(array2, f64) {
|
|||
|
|
resData[i].FzId = fzre.Id
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//3-2、获取布版图
|
|||
|
|
if resData != nil && len(resData) > 0 {
|
|||
|
|
insertList := []do.QianqiGuangfubanIdsZhuangdian{}
|
|||
|
|
for _, i := range resData { //面
|
|||
|
|
num := 0
|
|||
|
|
r := i.Range
|
|||
|
|
// 解析JSON数据
|
|||
|
|
var polygon shp.Polygon
|
|||
|
|
err = json.Unmarshal([]byte(r), &polygon)
|
|||
|
|
if err != nil {
|
|||
|
|
return nil, err
|
|||
|
|
}
|
|||
|
|
//判断点是否在多边形内
|
|||
|
|
array := tool.ConvertPolygonToFloatArray(polygon)
|
|||
|
|
for _, j := range listE { //坐标点（）
|
|||
|
|
inPolygon := tool.FanWei(array, j.Geometry.Coordinates)
|
|||
|
|
if inPolygon {
|
|||
|
|
num = num + 1
|
|||
|
|
// 调用 buildDetailAndSourceID 生成 detail 和 SourceID
|
|||
|
|
pointcory := shp.Point{
|
|||
|
|
Lng: j.Geometry.Coordinates[0],
|
|||
|
|
Lat: j.Geometry.Coordinates[1],
|
|||
|
|
Property: shp.Property{
|
|||
|
|
Name: j.Geometry.Type,
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
_, sourceID := buildDetailAndSourceID(pointcory, j.Geometry.Type)
|
|||
|
|
points := []shp.Point{pointcory}
|
|||
|
|
polylines := shp.Polyline{Positions: points}
|
|||
|
|
marshal, err := json.Marshal(polylines)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "详情获取失败")
|
|||
|
|
}
|
|||
|
|
zhuangdian := do.QianqiGuangfubanIdsZhuangdian{
|
|||
|
|
Name: i.Name + "." + strconv.Itoa(num),
|
|||
|
|
SourceId: sourceID,
|
|||
|
|
ProjectId: req.ProjectId,
|
|||
|
|
Status: "0",
|
|||
|
|
Detail: marshal,
|
|||
|
|
SubProjectid: req.SubProjectid,
|
|||
|
|
FangzhenId: i.FzId,
|
|||
|
|
}
|
|||
|
|
insertList = append(insertList, zhuangdian)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if len(insertList) > 0 {
|
|||
|
|
batchNumber := 700
|
|||
|
|
_, err = dao.QianqiGuangfubanIdsZhuangdian.Ctx(ctx).Batch(batchNumber).Insert(&insertList)
|
|||
|
|
liberr.ErrIsNil(ctx, err, "光伏板插入失败")
|
|||
|
|
_, err = dao.QianqiGuangfubanIdsLizhu.Ctx(ctx).Batch(batchNumber).Insert(&insertList)
|
|||
|
|
liberr.ErrIsNil(ctx, err, "立柱插入失败")
|
|||
|
|
_, err = dao.QianqiGuangfubanIdsZhijia.Ctx(ctx).Batch(batchNumber).Insert(&insertList)
|
|||
|
|
liberr.ErrIsNil(ctx, err, "支架失败")
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func (c *qianqiDxfController) DxfGet(ctx context.Context, req *system.DxfGetReq) (res *system.DxfGetRes, err error) {
|
|||
|
|
// 定义 exe <DXF文件的绝对路径><结果 JS0N 文件的绝对路径><源 EPSG 代码><目标 EPSG 代码>
|
|||
|
|
cmd := exec.Command("E:\\cory\\project\\go\\zmkgC\\resource\\public\\zmFiles\\pythonDxf.exe",
|
|||
|
|
"E:\\cory\\project\\go\\zmkgC\\resource\\public\\zmFiles\\b93ba1d7008247a79503e8a80fe1de62.dxf",
|
|||
|
|
"E:\\cory\\project\\go\\zmkgC\\resource\\public\\zmFiles\\nr.json",
|
|||
|
|
"4524",
|
|||
|
|
"4326",
|
|||
|
|
)
|
|||
|
|
// 执行并获取输出
|
|||
|
|
output, err := cmd.CombinedOutput()
|
|||
|
|
if err != nil {
|
|||
|
|
fmt.Println("执行出错:", err)
|
|||
|
|
}
|
|||
|
|
fmt.Println("输出内容:", string(output))
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func (c *qianqiDxfController) DxfData(ctx context.Context, req *system.DxfDataReq) (res *system.DxfDataRes, err error) {
|
|||
|
|
res = &system.DxfDataRes{}
|
|||
|
|
|
|||
|
|
err = g.Try(ctx, func(ctx context.Context) {
|
|||
|
|
// 指定要读取的JSON文件路径
|
|||
|
|
filePath := "E:\\cory\\project\\go\\zmkgC\\resource\\public\\zmFiles\\nr.json"
|
|||
|
|
// 读取文件内容
|
|||
|
|
data, err := os.ReadFile(filePath)
|
|||
|
|
if err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "读取失败")
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 用于存储解析后的JSON数据
|
|||
|
|
var result map[string]interface{}
|
|||
|
|
|
|||
|
|
// 解析JSON数据
|
|||
|
|
if err := json.Unmarshal(data, &result); err != nil {
|
|||
|
|
liberr.ErrIsNil(ctx, err, "解析JSON失败")
|
|||
|
|
}
|
|||
|
|
res.Map = result
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//
|
|||
|
|
//func FanWei(mian [][]float64, dian [][]float64) bool {
|
|||
|
|
//
|
|||
|
|
// // 定义多边形范围 (经纬度点的顺序很重要，需要闭合：首尾点相同)
|
|||
|
|
// polygon := orb.Polygon{
|
|||
|
|
// {
|
|||
|
|
// {106.518314, 29.627223}, // 起始位置
|
|||
|
|
// {106.519419, 29.627223},
|
|||
|
|
// {106.518238, 29.626399},
|
|||
|
|
// {106.519491, 29.626435},
|
|||
|
|
// {106.518314, 29.627223}, // 回到起始
|
|||
|
|
// },
|
|||
|
|
// }
|
|||
|
|
// // 目标点
|
|||
|
|
// point := orb.Point{106.518907, 29.626458} // 假设是一个经纬度点
|
|||
|
|
//
|
|||
|
|
// // 判断点是否在多边形内
|
|||
|
|
// if planar.PolygonContains(polygon, point) {
|
|||
|
|
// fmt.Println("点在多边形范围内")
|
|||
|
|
// return true
|
|||
|
|
// } else {
|
|||
|
|
// fmt.Println("点不在多边形范围内")
|
|||
|
|
// return false
|
|||
|
|
// }
|
|||
|
|
//}
|