lanlingxian_ziranziyuanheguihua/OpenAuth.App/ServiceApp/DroneCaseInfoTaskManage/DroneCaseInfoTaskApp.cs

using DocumentFormat.OpenXml.Bibliography;
using DocumentFormat.OpenXml.Drawing;
using DocumentFormat.OpenXml.Spreadsheet;
using Infrastructure;
using Infrastructure.Extensions;
using Irony;
using Microsoft.Extensions.Options;
using NetTopologySuite.Geometries;
using NetTopologySuite.IO;
using Newtonsoft.Json.Linq;
using NPOI.OpenXmlFormats.Dml;
using OpenAuth.App.BaseApp;
using OpenAuth.App.BaseApp.Base;
using OpenAuth.App.BaseApp.Shape;
using OpenAuth.App.BasicQueryService;
using OpenAuth.App.FormScheme.FormHelpers;
using OpenAuth.App.Interface;
using OpenAuth.App.ServiceApp.DroneCaseInfoTaskManage.Request;
using OpenAuth.App.ServiceApp.DroneCaseInfoTaskManage.Response;
using OpenAuth.App.ServiceApp.DroneCloudQueryManage.Request;
using OpenAuth.App.ServiceApp.Response;
using OpenAuth.Repository;
using OpenAuth.Repository.Domain;
using Org.BouncyCastle.Ocsp;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Data;
using System.IO.Compression;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using static ICSharpCode.SharpZipLib.Zip.ExtendedUnixData;

namespace OpenAuth.App.ServiceApp.DroneCaseInfoTaskManage
{
    public class DroneCaseInfoTaskApp : SqlSugarBaseApp<DroneCaseInfoTask, SugarDbContext>
    {
        ISqlSugarClient client;
        private ImMsgApp _immsgApp;
        private ShpLayerSourceApp _shplayerapp;
        private readonly string _filePath;
        CommonDataManager _commonDataManager;
        public DroneCaseInfoTaskApp(ISugarUnitOfWork<SugarDbContext> unitWork, ISimpleClient<DroneCaseInfoTask> repository, IOptions<AppSetting> setOptions, ISqlSugarClient sqlSugarClient, IAuth auth, ImMsgApp immsgApp, ShpLayerSourceApp shplayersource, CommonDataManager commonDataManager) : base(unitWork, repository, auth)
        {
            _filePath = setOptions.Value.UploadPath;
            if (string.IsNullOrEmpty(_filePath))
            {
                _filePath = AppContext.BaseDirectory;
            }

            client = sqlSugarClient;
            _immsgApp = immsgApp;
            _shplayerapp = shplayersource;
            _commonDataManager = commonDataManager;
        }

        #region 添加查询任务信息
        //添加任务
        public Response<bool> AddCaseInfoTask(string caseids, string shplayerids, DateTime qianshixiang, DateTime houshixiang, string picihao)
        {
            var user = _auth.GetCurrentUser().User;
            //初始化查询结果
            DroneCaseInfoTask caseinfotask = new DroneCaseInfoTask()
            {
                Id = Guid.NewGuid().ToString(),
                CreateTime = DateTime.Now,
                CreateUser = user?.Id.ToString() ?? "",
                picihao = picihao,
                State = 0,
                qianshixiang = qianshixiang,
                houshixiang = houshixiang,
                shplayerids = shplayerids,
                caseinfoids = caseids,
                rate=0
            };
            var data = client.Queryable<DroneCaseInfoTask>().Where(r => r.picihao == picihao).ToList();
            AddCaseinfoTaskRes rs = new AddCaseinfoTaskRes();
            rs.id = caseinfotask.Id;
            if (data.Count > 0)
            {
                throw new Exception("批次号重复，任务已存在");
            }
            else
            {
                //添加数据
                var flag = client.Ado.UseTran(() =>
                {
                    client.Insertable(caseinfotask).ExecuteCommand();
                });
                if (flag.IsSuccess)
                {
                    rs.flag=true;
                    return new Response<bool> { Result = true };
                }
                else
                {
                    rs.flag = false;
                    return new Response<bool> { Result = false, Message = "操作失败" };
                }
            }
        }

        //查询任务
        public async Task<Response<List<DroneCaseInfoTask>>> LoadDroneCaseInfoTask()
        {
            //查询任务数据
            var data = await client.Queryable<DroneCaseInfoTask>().Where(r => r.State != 2)
                   .OrderByDescending(a => a.CreateTime).ToListAsync();

            //获取之后，需要把这些任务标记为正在查询
            foreach (var item in data)
            {
                item.State = 1;
            }
            await client.Updateable<DroneCaseInfoTask>(data).ExecuteCommandAsync();
            return new Response<List<DroneCaseInfoTask>>
            {
                Result = data
            };
        }

        //根据任务id查询任务信息
        public async Task<Response<DroneCaseInfoTask>> LoadDroneCaseInfobyid(string id)
        {
            var data =await  client.Queryable<DroneCaseInfoTask>().Where(r => r.Id == id).FirstAsync();
            Response<DroneCaseInfoTask> ts = new Response<DroneCaseInfoTask>();
            ts.Result=data;
            return ts;
        }
        //更新任务信息
        public Response<bool> UpdateDroneCaseInfoTask(string id,int rate)
        {
            var flag =  client.Updateable<DroneCaseInfoTask>().SetColumns(r => new DroneCaseInfoTask
            {
                rate = rate
            }).Where(r => r.Id == id).ExecuteCommand();
            Response<bool> ts = new Response<bool>();
            if (flag > 0)
            {
                ts.Result = true;
            }
            else
            {
                ts.Result = false;
            }
            
            return ts;
        }

        //查询任务
        public async Task<Response<List<DroneCaseInfoTask>>> LoadDroneCaseInfoTaskByUser()
        {
            var user = _auth.GetCurrentUser().User;
            //查询任务数据
            var data = await client.Queryable<DroneCaseInfoTask>().Where(r => r.CreateUser==user.Id.ToString())
                   .OrderByDescending(a => a.CreateTime).ToListAsync();

            return new Response<List<DroneCaseInfoTask>>
            {
                Result = data
            };
        }
        #endregion

        #region 查询图层信息
        //查询任务
        public async Task<Response<List<DroneLayerInfo>>> LoadLayerInfo()
        {
            //查询任务数据
            var data = await client.Queryable<DroneLayerInfo>().ToListAsync();

            return new Response<List<DroneLayerInfo>>
            {
                Result = data
            };
        }
        #endregion

        #region 接收查询结果
        public async Task<Response<bool>> UpdateDroneCaseInfo(DroneCaseInfoTaskRes req)
        {
            using (var uow = base.UnitWork.CreateContext())
            {
                //导入案件信息
                var data = req.importlist;
                #region 导入案件信息
                int i = 0;
                List<DroneCaseInfoSingle> datalist = new List<DroneCaseInfoSingle>();
                List<DroneShpData> shplist = new List<DroneShpData>();
                StringBuilder geomSql = new StringBuilder();
                StringBuilder sql = new StringBuilder();
                foreach (var item in data)
                {
                    DroneCaseInfoSingle cinfo = new DroneCaseInfoSingle();
                    cinfo.Id = item.Id;
                    cinfo.createtime = DateTime.Now;
                    cinfo.createuser = item.createuser;
                    cinfo.createusername = item.createusername;
                    cinfo.is_illegal = 1;
                    cinfo.is_intact = 1;
                    cinfo.synchronoustime = DateTime.Now;
                    cinfo.handle_status_id = 0;
                    cinfo.handle_status_name = "待接收";
                    cinfo.is_jieshou = 0;
                    cinfo.is_closed = 0;
                    cinfo.is_delete = 0;
                    cinfo.case_description = item.case_description;
                    cinfo.area = item.area;
                    cinfo.tubanlaiyuan = item.tubanlaiyuan;
                    cinfo.typename = item.typename;
                    //类型id
                    var type = client.Queryable<SysDataItemDetail>().Where(r => r.ItemName == cinfo.typename && r.ItemCode == "DRONE_CASE_TYPE").First();
                    if (type != null)
                    {
                        cinfo.typeid = type.ItemDetailId;
                    }

                    cinfo.lng = item.lng;
                    cinfo.lat = item.lat;
                    JObject xzqh = GetOrgAreaByPoint((decimal)cinfo.lng, (decimal)cinfo.lat);
                    cinfo.countyid = xzqh["countyid"].ToString();
                    cinfo.countyname = xzqh["countyname"].ToString();
                    cinfo.streetid = xzqh["streetid"].ToString();
                    cinfo.streetname = xzqh["streetname"].ToString();
                    cinfo.communityid = xzqh["communityid"].ToString();
                    cinfo.communityname = xzqh["communityname"].ToString();
                    cinfo.address = cinfo.countyname + " " + cinfo.streetname + " " + cinfo.communityname;
                    cinfo.case_no = item.case_no;
                    cinfo.casepic = item.casepic;
                    cinfo.nongyongdi_area = item.nongyongdi_area;
                    cinfo.yongjiujibennongtian_area = item.yongjiujibennongtian_area;
                    cinfo.gengdi_area = item.gengdi_area;
                    cinfo.guotukongjianguihua_area = item.guotukongjianguihua_area;
                    cinfo.shengtaibaohuhongxian_area = item.shengtaibaohuhongxian_area;
                    cinfo.zhongdianquyu_area = item.zhongdianquyu_area;

                    //图斑数据drone_shp_data
                    DroneShpData model = new DroneShpData();
                    model.relid = cinfo.Id;
                    model.createtime = DateTime.Now;
                    model.createuser = item.createusername;
                    model.area = item.shparea;
                    //获取主键
                    string _gid = _commonDataManager.GetMaxKeyVal("gid", "drone_shp_data", 1);
                    model.gid = int.Parse(_gid) + i;//转为数字类型
                    i++;
                    cinfo.geomid = model.gid.ToString();

                    geomSql.AppendFormat($" update drone_shp_data set geom = '{item.geom}' where gid = '{model.gid}';");
                    sql.AppendFormat($" update drone_shp_data set area = st_area(st_transform(ST_SetSRID(geom,4326), 4527)) where gid = '{model.gid}';");
                    shplist.Add(model);

                    datalist.Add(cinfo);
                }
                string errornums = "";
                switch (data[0].subjectname)
                {
                    case "巡察审计":
                        var dataxunchashenji = datalist.MapTo<List<DroneCaseInfoXcsj>>();
                        //判断是否有重复数据
                        List<string> casenos = dataxunchashenji?.Select(r => r.case_no).ToList();
                        var caseinfo = client.Queryable<DroneCaseInfoXcsj>().Where(r => casenos.Contains(r.case_no)).ToList();
                        if (caseinfo.Count>0)
                        {
                            var nums = caseinfo.Select(r => r.case_no).ToList();
                            var dataxuncha = dataxunchashenji.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums= string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoXcsj.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoXcsj.InsertRangeAsync(dataxunchashenji);
                        }
                        break;
                    case "耕地非粮化":
                        var datafeilianghua = datalist.MapTo<List<DroneCaseInfoFLH>>();
                        List<string> casenof = datafeilianghua?.Select(r => r.case_no).ToList();
                        var caseinfof = client.Queryable<DroneCaseInfoFLH>().Where(r => casenof.Contains(r.case_no)).ToList();
                        if (caseinfof.Count>0)
                        {
                            var nums = caseinfof.Select(r => r.case_no).ToList();
                            var dataxuncha = datafeilianghua.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums = string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoFLH.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoFLH.InsertRangeAsync(datafeilianghua);
                        }
                        break;
                    case "生态保护红线监管":
                        var datastbh = datalist.MapTo<List<DroneCaseInfoSTHX>>();
                        List<string> casenox = datastbh?.Select(r => r.case_no).ToList();
                        var caseinfox = client.Queryable<DroneCaseInfoSTHX>().Where(r => casenox.Contains(r.case_no)).ToList();
                        if (caseinfox.Count > 0)
                        {
                            var nums = caseinfox.Select(r => r.case_no).ToList();
                            var dataxuncha = datastbh.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums = string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoSTHX.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoSTHX.InsertRangeAsync(datastbh);
                        }
                        break;
                    case "生态修复":
                        var datastxiufu = datalist.MapTo<List<DroneCaseInfoSTHX>>();
                        List<string> casenoh = datastxiufu?.Select(r => r.case_no).ToList();
                        var caseinfot = client.Queryable<DroneCaseInfoSTHX>().Where(r => casenoh.Contains(r.case_no)).ToList();
                        if (caseinfot.Count > 0)
                        {
                            var nums = caseinfot.Select(r => r.case_no).ToList();
                            var dataxuncha = datastxiufu.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums = string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoSTHX.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoSTHX.InsertRangeAsync(datastxiufu);
                        }
                        break;
                    case "违法用地":
                        List<string> casenog = datalist?.Select(r => r.case_no).ToList();
                        var caseinfos = client.Queryable<DroneCaseInfoSingle>().Where(r => casenog.Contains(r.case_no)).ToList();
                        if (caseinfos.Count>0)
                        {
                            var nums = caseinfos.Select(r => r.case_no).ToList();
                            var dataxuncha = datalist.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums = string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoSingle.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoSingle.InsertRangeAsync(datalist);
                        }
                        break;
                    case "重点问题I类":
                        var zhongdianwenti1 = datalist.MapTo<List<DroneCaseInfoZdwt1>>();
                        List<string> casenot = zhongdianwenti1?.Select(r => r.case_no).ToList();
                        var caseinfoz = client.Queryable<DroneCaseInfoZdwt1>().Where(r => casenot.Contains(r.case_no)).ToList();
                        if (caseinfoz.Count>0)
                        {
                            var nums = caseinfoz.Select(r => r.case_no).ToList();
                            var dataxuncha = zhongdianwenti1.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums = string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoZdwt1.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoZdwt1.InsertRangeAsync(zhongdianwenti1);
                        }
                        break;
                    case "重点问题II类":
                        var zhongdianwenti2 = datalist.MapTo<List<DroneCaseInfoZdwt2>>();
                        List<string> casenow = zhongdianwenti2?.Select(r => r.case_no).ToList();
                        var caseinfow = client.Queryable<DroneCaseInfoZdwt2>().Where(r => casenow.Contains(r.case_no)).ToList();
                        if (caseinfow.Count>0)
                        {
                            var nums = caseinfow.Select(r => r.case_no).ToList();
                            var dataxuncha = zhongdianwenti2.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums = string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoZdwt2.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoZdwt2.InsertRangeAsync(zhongdianwenti2);
                        }
                        break;
                    case "卫片下发":
                        var weipianxiafa = datalist.MapTo<List<DroneCaseInfoSatellite>>();
                        List<string> casenoa = weipianxiafa?.Select(r => r.case_no).ToList();
                        var caseinfoa = client.Queryable<DroneCaseInfoSatellite>().Where(r => casenoa.Contains(r.case_no)).ToList();
                        if (caseinfoa.Count>0)
                        {
                            var nums = caseinfoa.Select(r => r.case_no).ToList();
                            var dataxuncha = weipianxiafa.Where(r => !nums.Contains(r.case_no)).ToList();
                            //保存重复数据案件编号
                            errornums = string.Join(",", nums);
                            //添加未重复数据
                            await uow.DroneCaseInfoSatellite.InsertRangeAsync(dataxuncha);
                        }
                        else
                        {
                            await uow.DroneCaseInfoSatellite.InsertRangeAsync(weipianxiafa);
                        }
                        break;
                }
                //更新任务
                var task = uow.DroneCaseInfoTask.GetById(req.task.Id);
                if (task != null)
                {
                    //更新记录
                    await uow.DroneCaseInfoTask.UpdateAsync(u => new DroneCaseInfoTask
                    {
                        State = 2
                    }, u => u.Id == task.Id);
                }
                await uow.DroneShpData.InsertRangeAsync(shplist);
                await uow.Db.Ado.ExecuteCommandAsync(geomSql.ToString());
                await uow.Db.Ado.ExecuteCommandAsync(sql.ToString());
                #endregion
                //InsertCaseInfoData(infos,uow);
                var flag = uow.Commit();

                var content = new
                {
                    casetaskid = task.Id,
                    picihao = task == null ? "" : task.picihao,
                    errmessage="图斑编号重复："+errornums.ToString(),
                };
                var contents = Json.ToJson(content);

                //添加推送数据的用户
                List<string> users = new List<string>();
                if (task != null)
                {
                    users.Add(task.CreateUser);
                }

                //推送数据
                if (flag == true)
                {
                    try
                    {
                        await _immsgApp.SendMsg("CaseInfoTask", users, contents, "4", task.Id);
                    }
                    catch
                    {
                        return new Response<bool>
                        {
                            Result = flag,
                            Message = "数据导入成功，推送失败"
                        };
                    }
                }
                //返回值
                return new Response<bool>
                {
                    Result = flag,
                    Message = flag == true ? "导入数据成功" : "导入数据失败"
                };
            }
        }
        public bool CaseInfoJudge(List<string> caseno,string subjectname)
        {
            bool flag = false;
            switch (subjectname)
            {
                case "巡察审计":
                    var caseinfo = client.Queryable<DroneCaseInfoXcsj>().Where(r => caseno.Contains(r.case_no)).ToList();
                    if (caseinfo.Count > 0)
                    {
                        flag= true;
                    }
                    break;
                case "耕地非粮化":
                    var caseinfoflh = client.Queryable<DroneCaseInfoFLH>().Where(r => caseno.Contains(r.case_no)).ToList();
                    if (caseinfoflh.Count > 0)
                    {
                        flag = true;
                    }
                    break;
                case "违法用地":
                    var caseinfosig = client.Queryable<DroneCaseInfoSingle>().Where(r => caseno.Contains(r.case_no)).ToList();
                    if (caseinfosig.Count > 0)
                    {
                        flag = true;
                    }
                    break;
                case "重点问题I类":
                    var caseinfozt1 = client.Queryable<DroneCaseInfoZdwt1>().Where(r => caseno.Contains(r.case_no)).ToList();
                    if (caseinfozt1.Count > 0)
                    {
                        flag = true;
                    }
                    break;
                case "重点问题II类":
                    var caseinfozt2 = client.Queryable<DroneCaseInfoZdwt2>().Where(r => caseno.Contains(r.case_no)).ToList();
                    if (caseinfozt2.Count > 0)
                    {
                        flag = true;
                    }
                    break;
                case "卫片下发":
                    var caseinfosatellite = client.Queryable<DroneCaseInfoSatellite>().Where(r => caseno.Contains(r.case_no)).ToList();
                    if (caseinfosatellite.Count > 0)
                    {
                        flag = true;
                    }
                    break;
            }
            return flag;
        }

        /// <summary>
        /// 矿产接收查询结果
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>
        public async Task<Response<bool>> UpdateDroneCaseInfoMinerals(DroneCaseInfoTaskRes req)
        {
            using (var uow = base.UnitWork.CreateContext())
            {
                #region 案件信息处理
                var data = req.importlist;
                int i = 0;
                List<DroneCaseInfoMinerals> datalist = new List<DroneCaseInfoMinerals>();
                List<DroneShpData> shplist = new List<DroneShpData>();
                StringBuilder geomSql = new StringBuilder();
                StringBuilder sql = new StringBuilder();
                foreach (var item in data)
                {
                    DroneCaseInfoMinerals cinfo = new DroneCaseInfoMinerals();
                    cinfo.Id = item.Id;
                    cinfo.createtime = DateTime.Now;
                    cinfo.createuser = item.createuser;
                    cinfo.is_illegal = 1;
                    //cinfo.xiafatime_base = DateTime.Now;
                    cinfo.handle_status_id = 0;
                    cinfo.is_closed = 0;
                    cinfo.case_description = item.case_description;
                    cinfo.weifaarea_base = item.area;
                    cinfo.tubanlaiyuan = item.tubanlaiyuan;
                    cinfo.typename = item.typename;
                    cinfo.centerlat_base = item.lng.ToString();
                    cinfo.centerlng_base = item.lat.ToString();
                    JObject xzqh = GetOrgAreaByPoint((decimal)item.lng, (decimal)item.lat);
                    cinfo.countyid = xzqh["countyid"].ToString();
                    cinfo.countyname = xzqh["countyname"].ToString();
                    cinfo.streetid = xzqh["streetid"].ToString();
                    cinfo.streetname = xzqh["streetname"].ToString();
                    cinfo.communityid = xzqh["communityid"].ToString();
                    cinfo.communityname = xzqh["communityname"].ToString();
                    //cinfo.address = cinfo.countyname + " " + cinfo.streetname + " " + cinfo.communityname;
                    cinfo.case_no = item.case_no;
                    cinfo.tubanpic_base = item.casepic;
                    cinfo.jbntarea_base = item.yongjiujibennongtian_area;
                    cinfo.gengdi_area = item.gengdi_area;
                    cinfo.stbhhxarea_base = item.shengtaibaohuhongxian_area;
                    cinfo.cskfbjarea_base = item.cskfbjarea_base;
                    cinfo.weifazhandiarea_base = item.weifazhandiarea_base;
                    cinfo.weifakaicaiarea_base = item.weifakaicaiarea_base;

                    //图斑数据drone_shp_data
                    DroneShpData model = new DroneShpData();
                    model.relid = cinfo.Id;
                    model.createtime = DateTime.Now;
                    model.createuser = item.createusername;
                    model.area = item.shparea;
                    //获取主键
                    string _gid = _commonDataManager.GetMaxKeyVal("gid", "drone_shp_data", 1);
                    model.gid = int.Parse(_gid) + i;//转为数字类型
                    i++;
                    cinfo.geomid = model.gid.ToString();

                    geomSql.AppendFormat($" update drone_shp_data set geom = '{item.geom}' where gid = '{model.gid}';");
                    sql.AppendFormat($" update drone_shp_data set area = st_area(st_transform(ST_SetSRID(geom,4326), 4527)) where gid = '{model.gid}';");
                    shplist.Add(model);

                    datalist.Add(cinfo);
                }
                var caseno = datalist.Select(r => r.case_no).ToList();
                var caseinfo = client.Queryable<DroneCaseInfoMinerals>().Where(r => caseno.Contains(r.case_no)).ToList();
                string errornums = "";
                if (caseinfo.Count > 0)
                {
                    var nums = caseinfo.Select(r => r.case_no).ToList();
                    var dataxuncha = datalist.Where(r => !nums.Contains(r.case_no)).ToList();
                    //保存重复数据案件编号
                    errornums = string.Join(",", nums);
                    //添加未重复数据
                    await uow.DroneCaseInfoMinerals.InsertRangeAsync(dataxuncha);

                }
                else
                {
                    await uow.DroneCaseInfoMinerals.InsertRangeAsync(datalist);
                }

                //更新任务
                var task = client.Queryable<DroneCaseInfoTask>().Where(r => r.Id == req.task.Id).First();
                if (task != null)
                {
                    //更新记录
                    await uow.DroneCaseInfoTask.UpdateAsync(u => new DroneCaseInfoTask
                    {
                        State = 2
                    }, u => u.Id == task.Id);
                }
                await uow.DroneShpData.InsertRangeAsync(shplist);
                await uow.Db.Ado.ExecuteCommandAsync(geomSql.ToString());
                await uow.Db.Ado.ExecuteCommandAsync(sql.ToString());

                var flag = uow.Commit();
                #endregion
                var content = new
                {
                    casetaskid = task.Id,
                    picihao = task == null ? "" : task.picihao,
                    errmessage = "图斑编号重复：" + errornums.ToString()
                };
                var contents = Json.ToJson(content);

                //添加推送数据的用户
                List<string> users = new List<string>();
                if (task != null)
                {
                    users.Add(task.CreateUser);
                }

                //推送数据
                if (flag == true)
                {
                    try
                    {
                        await _immsgApp.SendMsg("CaseInfoTask", users, contents, "4", task.Id);
                    }
                    catch
                    {
                        return new Response<bool>
                        {
                            Result = flag,
                            Message = "数据导入成功，推送失败"
                        };
                    }
                }
                //返回值
                return new Response<bool>
                {
                    Result = flag,
                    Message = flag == true ? "导入数据成功" : "导入数据失败"
                };
            }
        }

        /// <summary> 
        /// 根据经纬度获取组织机构
        /// </summary>
        /// <param name="lng"></param>
        /// <param name="lat"></param>
        /// <returns></returns>
        public JObject GetOrgAreaByPoint(decimal lng, decimal lat)
        {
            //县id
            string countyid = "";
            string countyname = "";
            //镇id
            string streetid = "";
            string streetname = "";
            //村id
            string communityid = "";
            string communityname = "";

            //SqlSugar实例
            using (var db = Repository.AsSugarClient())
            {
                //查询坐标属于哪个县
                StringBuilder sql = new StringBuilder();
                sql.AppendFormat($" SELECT xzqdm,xzqmc FROM \"shp_drone_county\" where ST_Within(st_geomfromtext('POINT({lng} {lat})',4326), ST_SetSRID(geom,4326))");
                var countyList = db.SqlQueryable<dynamic>(sql.ToString()).ToList();
                if (countyList.Count > 0)
                {
                    //县名称
                    countyname = countyList[0].xzqmc;
                    //县id
                    countyid = countyList[0].xzqdm;
                }

                //查询坐标属于哪个镇
                sql = new StringBuilder();
                sql.AppendFormat($" SELECT xzqdm,xzqmc FROM \"shp_drone_town\" where ST_Within(st_geomfromtext('POINT({lng} {lat})',4326), ST_SetSRID(geom,4326))");
                var streetList = db.SqlQueryable<dynamic>(sql.ToString()).ToList();
                if (streetList.Count > 0)
                {
                    //镇名称
                    streetname = streetList[0].xzqmc;
                    //镇id
                    streetid = streetList[0].xzqdm;
                }

                if (!string.IsNullOrEmpty(streetid))
                {
                    //查询组织机构属于哪个村
                    sql = new StringBuilder();
                    sql.AppendFormat($" SELECT zldwdm,zldwmc FROM \"shp_drone_community\" where ST_Within(st_geomfromtext('POINT({lng} {lat})',4326), ST_SetSRID(geom,4326))");
                    var communityidList = db.SqlQueryable<dynamic>(sql.ToString()).ToList();
                    if (communityidList.Count > 0)
                    {
                        //村名称
                        communityname = communityidList[0].zldwmc;
                        //村id
                        communityid = communityidList[0].zldwdm;
                    }
                }

                //拼接json数据，返回到前台
                JObject obj = new JObject();

                obj.Add("countyid", countyid);
                obj.Add("countyname", countyname);
                obj.Add("streetid", streetid);
                obj.Add("streetname", streetname);
                obj.Add("communityid", communityid);
                obj.Add("communityname", communityname);

                return obj;
            }
        }
        #endregion

        #region 根据批次号查询案件信息
        public async Task<Response<PageInfo<List<DroneCaseInfoImport>>>> LoadCaseImportInfoBypicihao(string picihao,  string laiyuan, DateTime? begintime,DateTime? endtime, int pageindex, int pagesize)
        {
            var user = _auth.GetCurrentUser();
            //定义且实例化分页数据
            RefAsync<int> totalCount = 0;
            var caseinfolist = await client.SqlQueryable<DroneCaseInfoImport>("SELECT \"Id\",case_no,case_description,lng,lat,typename,area,tubanlaiyuan,ST_AsText(geom) AS geom,picihao,createtime,createuser,createusername,subjectname,shparea,casepic,nongyongdi_area,  gengdi_area,yongjiujibennongtian_area,zhongdianquyu_area,shengtaibaohuhongxian_area,guotukongjianguihua_area FROM drone_caseinfo_import")
                .WhereIF(!string.IsNullOrEmpty(picihao), r => picihao == r.picihao)
                .WhereIF(!string.IsNullOrEmpty(laiyuan), r => r.tubanlaiyuan.Contains(laiyuan))
                .WhereIF(begintime!=null&&endtime!=null,r=>r.createtime>=begintime&&r.createtime< endtime)
                .WhereIF(user!=null,r=>r.createuser==user.User.Id.ToString())
                .ToPageListAsync(pageindex, pagesize, totalCount); 

            return new Response<PageInfo<List<DroneCaseInfoImport>>>
            {
                Result = new PageInfo<List<DroneCaseInfoImport>>
                {
                    Items = caseinfolist,
                    Total = totalCount
                }
            };
        }

        /// <summary>
        /// 查询最后一次导入数据
        /// </summary>
        /// <param name="pageindex"></param>
        /// <param name="pagesize"></param>
        /// <returns></returns>
        public async Task<Response<string>> LoadCaseImportInfoLast(string subjectname,int pageindex, int pagesize)
        {
            var user = _auth.GetCurrentUser().User;
            string picihao = "";
            //定义且实例化分页数据
            RefAsync<int> totalCount = 0;
            var data = await client.Queryable<DroneCaseInfoImport>()
                .WhereIF(!string.IsNullOrEmpty(subjectname), r => r.subjectname == subjectname)
                .Where(r => r.createuser == user.Id.ToString())
                .OrderByDescending(r => r.createtime).FirstAsync();
            if (data != null)
            {
                picihao = data.picihao;
            }

            return new Response<string>
            {
                Result = picihao
            };
        }
        #endregion

        #region 导入shp数据新版
        /// <summary>
        /// shp导入
        /// </summary>
        /// <param name="zipFilePath"></param>
        /// <param name="srid"></param>
        /// <returns></returns>
        /// <exception cref="FileNotFoundException"></exception>
        /// <exception cref="Exception"></exception>
        public async Task<Response<string>> ImportCaseInfoShpData(string zipFilePath, string srid, string subjectname)
        {
            var _user = _auth.GetCurrentUser().User;
            using var db = Repository.AsSugarClient();

            // 开启事务
            await db.Ado.BeginTranAsync(IsolationLevel.ReadCommitted);
            // 取得文件完全路径
            zipFilePath = System.IO.Path.Combine(_filePath, zipFilePath);
            // 确保ZIP文件存在
            if (!File.Exists(zipFilePath))
            {
                throw new FileNotFoundException("ZIP文件未找到。");
            }

            // 打开ZIP存档 取除后缀之前的字符串
            var extractPath = zipFilePath.Substring(0, zipFilePath.LastIndexOf(".", StringComparison.Ordinal)) +
                              "extract";
            // 解压文件
            await UnZip(zipFilePath, extractPath);
            var searchPattern = "*.shp"; // 设置你想要遍历的文件后缀名
            var fileName = Directory.GetFiles(extractPath, searchPattern, SearchOption.AllDirectories);
            if (fileName.IsEmpty())
            {
                throw new Exception("压缩文件中无shp文件");
            }

            var shpFileName = fileName[0];
            var shpFile = System.IO.Path.Combine(extractPath, shpFileName);

            List<DroneCaseInfoImport> datalist = new List<DroneCaseInfoImport>();
            List<DroneShpData> shplist = new List<DroneShpData>();
            StringBuilder geomSql = new StringBuilder();
            //批量更新面积
            StringBuilder sql = new StringBuilder();
            Random random = new Random();
            //批次号
            var pici = DateTime.Now.ToString("yyyyMMssHHmmss") + random.Next(1000, 9999).ToString();

            using (var dataReader = new ShapefileDataReader(shpFile, GeometryFactory.Default))
            {
                while (dataReader.Read())
                {
                    string countyid = "";
                    DroneCaseInfoImport cinfo = new DroneCaseInfoImport();
                    cinfo.Id = Guid.NewGuid().ToString();
                    cinfo.createtime = DateTime.Now;
                    cinfo.createuser = _user.Id.ToString();
                    cinfo.createusername = _user.Name.ToString();
                    cinfo.case_description = dataReader.GetValue(2).ToString();
                    cinfo.subjectname = subjectname;
                    cinfo.picihao = pici;
                    if (dataReader.IsDBNull(6))
                    {
                        throw new Exception("图斑面积不能为空");
                    }
                    else
                    {
                        cinfo.area = dataReader.GetValue(6).ToString();
                    }
                    if (dataReader.IsDBNull(7))
                    {
                        throw new Exception("图斑来源不能为空");
                    }
                    else
                    {
                        cinfo.tubanlaiyuan = dataReader.GetValue(7).ToString();
                    }
                    if (dataReader.IsDBNull(8))
                    {
                        cinfo.nongyongdi_area = "0.00";
                    }
                    else
                    {
                        cinfo.nongyongdi_area = dataReader.GetValue(8).ToString();
                    }
                    if (dataReader.IsDBNull(9))
                    {
                        cinfo.gengdi_area = "0.00";
                    }
                    else
                    {
                        cinfo.gengdi_area = dataReader.GetValue(9).ToString();
                    }
                    if (dataReader.IsDBNull(10))
                    {
                        cinfo.yongjiujibennongtian_area = "0.00";
                    }
                    else
                    {
                        cinfo.yongjiujibennongtian_area = dataReader.GetValue(10).ToString();
                    }
                    if (dataReader.IsDBNull(11))
                    {
                        cinfo.zhongdianquyu_area = "0.00";
                    }
                    else
                    {
                        cinfo.zhongdianquyu_area = dataReader.GetValue(11).ToString();
                    }
                    if (dataReader.IsDBNull(12))
                    {
                        cinfo.shengtaibaohuhongxian_area = "0.00";
                    }
                    else
                    {
                        cinfo.shengtaibaohuhongxian_area = dataReader.GetValue(12).ToString();
                    }
                    if (dataReader.IsDBNull(13))
                    {
                        cinfo.guotukongjianguihua_area = "0.00";
                    }
                    else
                    {
                        cinfo.guotukongjianguihua_area = dataReader.GetValue(13).ToString();
                    }

                    cinfo.typename = dataReader.GetValue(5).ToString();
                    //类型id
                    var type = db.Queryable<SysDataItemDetail>().Where(r => r.ItemName == cinfo.typename && r.ItemCode == "DRONE_CASE_TYPE").First();
                    //坐标及行政区划
                    if (dataReader.IsDBNull(3) || dataReader.IsDBNull(4))
                    {
                        throw new Exception("坐标不能为空");
                    }
                    else
                    {
                        decimal lng = Convert.ToDecimal(dataReader.GetValue(3).ToString());
                        decimal lat = Convert.ToDecimal(dataReader.GetValue(4).ToString());
                        cinfo.lng = lng;
                        cinfo.lat = lat;
                        JObject xzqh = GetOrgAreaByPoint(lng, lat);
                        countyid = xzqh["countyid"].ToString();
                    }
                    //案件编号
                    if (!dataReader.IsDBNull(1))
                    {
                        var caseinfo = client.Queryable<DroneCaseInfoImport>().Where(r => r.case_no == dataReader.GetValue(1).ToString()).ToList();
                        var caseoinfo=client.Queryable<ViewDroneCaseinfoTotal>().Where(r => r.case_no == dataReader.GetValue(1).ToString()).ToList();
                        if (caseinfo.Count > 0|| caseoinfo.Count>0)
                        {
                            throw new Exception("图斑编号" + dataReader.GetValue(1).ToString() + "已存在，请重新整理数据");
                        }
                        else
                        {
                            cinfo.case_no = dataReader.GetValue(1).ToString();
                        }
                    }
                    else
                    {
                        bool isUnique;
                        var prefix = type?.Prefix;
                        do
                        {
                            var caseno = prefix + countyid + DateTime.Now.ToString("yyyyMMdd") + random.Next(1000, 9999).ToString();
                            var count = db.Queryable<DroneCaseInfoImport>().Where(c => c.case_no == caseno).Count();
                            isUnique = count == 0;

                        } while (!isUnique);
                    }

                    //geom
                    if (!dataReader.IsDBNull(0))
                    {
                        var geometry = (Geometry)dataReader.GetValue(0);
                        if (!geometry.IsValid)
                        {
                            throw new Exception("图斑" + cinfo.case_no + "未闭合，请重新整理数据");
                        }
                        var geometryForWgs84 = GeometryFactory.Default.WithSRID(int.Parse(srid))
                            .CreateGeometry(geometry);
                        geomSql.AppendFormat($" update drone_caseinfo_import set geom = '{geometryForWgs84.AsText()}' where \"Id\" = '{cinfo.Id}';");
                    }
                    datalist.Add(cinfo);
                }
            }

            using (var uow = base.UnitWork.CreateContext())
            {
                await uow.DroneCaseInfoImport.InsertRangeAsync(datalist);
                await uow.Db.Ado.ExecuteCommandAsync(geomSql.ToString());
                var flag = uow.Commit();
                if (flag == true)
                {
                    return new Response<string>()
                    {
                        Result = pici,
                        Message = "导入成功"
                    };
                }
                else
                {
                    return new Response<string>()
                    {
                        Result = "false",
                        Message = "导入失败"
                    };
                }

            }
        }

        /// <summary>
        /// 矿产shp导入
        /// </summary>
        /// <param name="zipFilePath"></param>
        /// <param name="srid"></param>
        /// <returns></returns>
        /// <exception cref="FileNotFoundException"></exception>
        /// <exception cref="Exception"></exception>
        public async Task<Response<string>> ImportMineralShpData(string zipFilePath, string srid, string subjectname)
        {
            var _user = _auth.GetCurrentUser().User;
            using var db = Repository.AsSugarClient();

            // 开启事务
            await db.Ado.BeginTranAsync(IsolationLevel.ReadCommitted);
            // 取得文件完全路径
            zipFilePath = System.IO.Path.Combine(_filePath, zipFilePath);
            // 确保ZIP文件存在
            if (!File.Exists(zipFilePath))
            {
                throw new FileNotFoundException("ZIP文件未找到。");
            }

            // 打开ZIP存档 取除后缀之前的字符串
            var extractPath = zipFilePath.Substring(0, zipFilePath.LastIndexOf(".", StringComparison.Ordinal)) +
                              "extract";
            // 解压文件
            await UnZip(zipFilePath, extractPath);
            var searchPattern = "*.shp"; // 设置你想要遍历的文件后缀名
            var fileName = Directory.GetFiles(extractPath, searchPattern, SearchOption.AllDirectories);
            if (fileName.IsEmpty())
            {
                throw new Exception("压缩文件中无shp文件");
            }

            var shpFileName = fileName[0];
            var shpFile = System.IO.Path.Combine(extractPath, shpFileName);

            List<DroneCaseInfoImport> datalist = new List<DroneCaseInfoImport>();
            List<DroneShpData> shplist = new List<DroneShpData>();
            StringBuilder geomSql = new StringBuilder();
            //批量更新面积
            StringBuilder sql = new StringBuilder();
            Random random = new Random();
            //批次号
            var pici = DateTime.Now.ToString("yyyyMMssHHmmss") + random.Next(1000, 9999).ToString();

            using (var dataReader = new ShapefileDataReader(shpFile, GeometryFactory.Default))
            {
                while (dataReader.Read())
                {
                    string countyid = "";
                    DroneCaseInfoImport cinfo = new DroneCaseInfoImport();
                    cinfo.Id = Guid.NewGuid().ToString();
                    cinfo.createtime = DateTime.Now;
                    cinfo.createuser = _user.Id.ToString();
                    cinfo.createusername = _user.Name.ToString();
                    cinfo.case_description = dataReader.GetValue(2).ToString();
                    cinfo.subjectname = subjectname;
                    cinfo.picihao = pici;
                    if (dataReader.IsDBNull(6))
                    {
                        throw new Exception("违法面积不能为空");
                    }
                    else
                    {
                        cinfo.area = dataReader.GetValue(6).ToString();
                    }
                    if (dataReader.IsDBNull(7))
                    {
                        throw new Exception("图斑来源不能为空");
                    }
                    else
                    {
                        cinfo.tubanlaiyuan = dataReader.GetValue(7).ToString();
                    }
                    if (dataReader.IsDBNull(8))
                    {
                        cinfo.weifakaicaiarea_base = "0.00";
                    }
                    else
                    {
                        cinfo.weifakaicaiarea_base = dataReader.GetValue(8).ToString();
                    }
                    if (dataReader.IsDBNull(9))
                    {
                        cinfo.weifazhandiarea_base = "0.00";
                    }
                    else
                    {
                        cinfo.weifazhandiarea_base = dataReader.GetValue(9).ToString();
                    }
                    if (dataReader.IsDBNull(10))
                    {
                        cinfo.gengdi_area = "0.00";
                    }
                    else
                    {
                        cinfo.gengdi_area = dataReader.GetValue(10).ToString();
                    }
                    if (dataReader.IsDBNull(11))
                    {
                        cinfo.yongjiujibennongtian_area = "0.00";
                    }
                    else
                    {
                        cinfo.yongjiujibennongtian_area = dataReader.GetValue(11).ToString();
                    }
                    if (dataReader.IsDBNull(12))
                    {
                        cinfo.shengtaibaohuhongxian_area = "0.00";
                    }
                    else
                    {
                        cinfo.shengtaibaohuhongxian_area = dataReader.GetValue(12).ToString();
                    }
                    if (dataReader.IsDBNull(13))
                    {
                        cinfo.cskfbjarea_base = "0.00";
                    }
                    else
                    {
                        cinfo.guotukongjianguihua_area = dataReader.GetValue(13).ToString();
                    }

                    cinfo.typename = dataReader.GetValue(5).ToString();

                    //坐标及行政区划
                    if (dataReader.IsDBNull(3) || dataReader.IsDBNull(4))
                    {
                        throw new Exception("坐标不能为空");
                    }
                    else
                    {
                        decimal lng = Convert.ToDecimal(dataReader.GetValue(3).ToString());
                        decimal lat = Convert.ToDecimal(dataReader.GetValue(4).ToString());
                        cinfo.lng = lng;
                        cinfo.lat = lat;
                        JObject xzqh = GetOrgAreaByPoint(lng, lat);
                        countyid = xzqh["countyid"].ToString();
                    }
                    //案件编号
                    if (!dataReader.IsDBNull(1))
                    {
                        var caseinfo = client.Queryable<DroneCaseInfoImport>().Where(r => r.case_no == dataReader.GetValue(1).ToString()).ToList();
                        var caseoinfo = client.Queryable<DroneCaseInfoMinerals>().Where(r => r.case_no == dataReader.GetValue(1).ToString()).ToList();
                        if (caseinfo.Count > 0|| caseoinfo.Count>0)
                        {
                            throw new Exception("图斑编号" + dataReader.GetValue(1).ToString() + "已存在，请重新整理数据");
                        }
                        else
                        {
                            cinfo.case_no = dataReader.GetValue(1).ToString();
                        }
                    }
                    else
                    {
                        bool isUnique;
                        var prefix = "KC";
                        do
                        {
                            var caseno = prefix + countyid + DateTime.Now.ToString("yyyyMMdd") + random.Next(1000, 9999).ToString();
                            var count = db.Queryable<DroneCaseInfoImport>().Where(c => c.case_no == caseno).Count();
                            isUnique = count == 0;

                        } while (!isUnique);
                    }

                    //geom
                    if (!dataReader.IsDBNull(0))
                    {
                        var geometry = (Geometry)dataReader.GetValue(0);
                        if (!geometry.IsValid)
                        {
                            throw new Exception("图斑" + cinfo.case_no + "未闭合，请重新整理数据");
                        }
                        var geometryForWgs84 = GeometryFactory.Default.WithSRID(int.Parse(srid))
                            .CreateGeometry(geometry);
                        geomSql.AppendFormat($" update drone_caseinfo_import set geom = '{geometryForWgs84.AsText()}' where \"Id\" = '{cinfo.Id}';");
                    }
                    datalist.Add(cinfo);
                }
            }

            using (var uow = base.UnitWork.CreateContext())
            {
                await uow.DroneCaseInfoImport.InsertRangeAsync(datalist);
                await uow.Db.Ado.ExecuteCommandAsync(geomSql.ToString());
                var flag = uow.Commit();
                if (flag == true)
                {
                    return new Response<string>()
                    {
                        Result = pici,
                        Message = "导入成功"
                    };
                }
                else
                {
                    return new Response<string>()
                    {
                        Result = "false",
                        Message = "导入失败"
                    };
                }

            }
        }



        private static async Task UnZip(string zipFilePath, string extractPath)
        {
            await Task.Run(() =>
            {
                Directory.CreateDirectory(extractPath);
                // 设置字符编码
                Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);
                var gbk = Encoding.GetEncoding("utf-8");
                using (var archive = ZipFile.OpenRead(zipFilePath))
                {
                    // 列举ZIP文件中的条目
                    foreach (var entry in archive.Entries)
                    {
                        var xxx = gbk.GetString(Encoding.Default.GetBytes(entry.FullName));
                        Console.WriteLine(xxx);
                    }

                    // 提取ZIP文件中的所有文件到指定目录

                    foreach (var entry in archive.Entries)
                    {
                        if (entry.Name != string.Empty)
                        {
                            // 确保完整路径存在  entry.FullName 是否可以编码
                            var fixedEntryName = entry.FullName.Replace("/", "");
                            var destinationPath = System.IO.Path.GetFullPath(System.IO.Path.Combine(extractPath, fixedEntryName));
                            Console.WriteLine("解压文件路径：" + destinationPath);
                            if (!destinationPath.StartsWith(System.IO.Path.GetFullPath(extractPath) + System.IO.Path.DirectorySeparatorChar))
                            {
                                throw new UnauthorizedAccessException("试图提取的文件超出了目标文件夹的路径边界。");
                            }

                            // 提取条目到目标路径
                            entry.ExtractToFile(destinationPath, overwrite: true);
                        }
                    }
                }

                // 遍历解压目录，是否有shp后缀的文件
                if (!Directory.Exists(extractPath))
                {
                    throw new Exception("文件解压失败");
                }
            });
        }

        /// <summary>
        /// 河东设施农业监管shp导入
        /// </summary>
        /// <param name="zipFilePath"></param>
        /// <param name="srid"></param>
        /// <returns></returns>
        /// <exception cref="FileNotFoundException"></exception>
        /// <exception cref="Exception"></exception>
        public async Task<Response<bool>> ImportCaseInfoShpDataSsny(string zipFilePath, string srid)
        {
            var _user = _auth.GetCurrentUser().User;
            using var db = Repository.AsSugarClient();

            // 开启事务
            await db.Ado.BeginTranAsync(IsolationLevel.ReadCommitted);
            // 取得文件完全路径
            zipFilePath = System.IO.Path.Combine(_filePath, zipFilePath);
            // 确保ZIP文件存在
            if (!File.Exists(zipFilePath))
            {
                throw new FileNotFoundException("ZIP文件未找到。");
            }

            // 打开ZIP存档 取除后缀之前的字符串
            var extractPath = zipFilePath.Substring(0, zipFilePath.LastIndexOf(".", StringComparison.Ordinal)) +
                              "extract";
            // 解压文件
            await UnZip(zipFilePath, extractPath);
            var searchPattern = "*.shp"; // 设置你想要遍历的文件后缀名
            var fileName = Directory.GetFiles(extractPath, searchPattern, SearchOption.AllDirectories);
            if (fileName.IsEmpty())
            {
                throw new Exception("压缩文件中无shp文件");
            }

            var shpFileName = fileName[0];
            var shpFile = System.IO.Path.Combine(extractPath, shpFileName);

            List<DroneSsnyd> datalist = new List<DroneSsnyd>();
            List<DroneShpData> shplist = new List<DroneShpData>();
            StringBuilder geomSql = new StringBuilder();
            //批量更新面积
            StringBuilder sql = new StringBuilder();
            Random random = new Random();
            //批次号
            //var pici = DateTime.Now.ToString("yyyyMMssHHmmss") + random.Next(1000, 9999).ToString();
            int i = 0;
            using (var dataReader = new ShapefileDataReader(shpFile, GeometryFactory.Default))
            {
                while (dataReader.Read())
                {
                    DroneSsnyd cinfo = new DroneSsnyd();
                    cinfo.Id = Guid.NewGuid().ToString();
                    cinfo.createuser = _user.Id.ToString();

                    //案件编号
                    if (!dataReader.IsDBNull(1))
                    {
                        var caseinfo = client.Queryable<DroneSsnyd>().Where(r => r.xiangmu_no == dataReader.GetValue(1).ToString()).ToList();
                        if (caseinfo.Count > 0)
                        {
                            throw new Exception("图斑编号" + dataReader.GetValue(1).ToString() + "已存在，请重新整理数据");
                        }
                        else
                        {
                            cinfo.xiangmu_no = dataReader.GetValue(1).ToString();
                        }
                    }
                    else
                    {
                        throw new Exception("图斑编号不能为空，请重新整理数据");
                    }

                    if (dataReader.IsDBNull(2))
                    {
                        cinfo.xiangmu_name = "";
                    }
                    else
                    {
                        cinfo.xiangmu_name = dataReader.GetValue(2).ToString();
                    }

                    if (dataReader.IsDBNull(3))
                    {
                        cinfo.xiangmu_yt = "";
                    }
                    else
                    {
                        cinfo.xiangmu_yt = dataReader.GetValue(3).ToString();
                    }

                    if (dataReader.IsDBNull(4))
                    {
                        cinfo.xingzhengquhua = "";
                    }
                    else
                    {
                        cinfo.xingzhengquhua = dataReader.GetValue(4).ToString();
                    }


                    if (dataReader.IsDBNull(5))
                    {
                        cinfo.shenqing_area = 0;
                    }
                    else
                    {
                        var aa = dataReader.GetValue(5);
                        cinfo.shenqing_area = Convert.ToDecimal(dataReader.GetValue(5).ToString());
                    }
                    if (dataReader.IsDBNull(6))
                    {
                        cinfo.beian_no = "";
                    }
                    else
                    {
                        cinfo.beian_no = dataReader.GetValue(6).ToString();
                    }

                    if (dataReader.IsDBNull(7))
                    {
                        cinfo.beianriqi = null;
                    }
                    else
                    {
                        var value = dataReader.GetValue(7);
                        cinfo.beianriqi = value as DateTime? ?? Convert.ToDateTime(value);
                    }

                    if (dataReader.IsDBNull(8))
                    {
                        cinfo.quanliren = "";
                    }
                    else
                    {
                        cinfo.quanliren = dataReader.GetValue(8).ToString();
                    }

                    if (dataReader.IsDBNull(9))
                    {
                        cinfo.start_time = null;
                    }
                    else
                    {
                        var value = dataReader.GetValue(9);
                        cinfo.start_time = value as DateTime? ?? Convert.ToDateTime(value);
                    }

                    if (dataReader.IsDBNull(10))
                    {
                        cinfo.end_time = null;
                    }
                    else
                    {
                        var value = dataReader.GetValue(10);
                        cinfo.end_time = value as DateTime? ?? Convert.ToDateTime(value);
                    }

                    if (dataReader.IsDBNull(11))
                    {
                        cinfo.jianzhujiegou = "";
                    }
                    else
                    {
                        cinfo.jianzhujiegou = dataReader.GetValue(11).ToString();
                    }

                    if (dataReader.IsDBNull(12))
                    {
                        cinfo.shengchan_area = 0;
                    }
                    else
                    {
                        cinfo.shengchan_area = Convert.ToDecimal(dataReader.GetValue(12).ToString());
                    }
                    if (dataReader.IsDBNull(13))
                    {
                        cinfo.fuzhu_area = 0;
                    }
                    else
                    {
                        cinfo.fuzhu_area = Convert.ToDecimal(dataReader.GetValue(13).ToString());
                    }

                    string countyid = "";
                    string streetid = "";

                    if (dataReader.IsDBNull(14))
                    {
                        cinfo.countyname = "";
                    }
                    else
                    {
                        cinfo.countyname =dataReader.GetValue(14).ToString();
                        var org = client.Queryable<SysOrg>().Where(r => r.Name == cinfo.countyname).First();
                        if (org != null)
                        {
                            countyid = org.Id.ToString();
                            cinfo.countyid = org.Id.ToString();
                        }
                    }

                    if (dataReader.IsDBNull(15))
                    {
                        cinfo.streetname = "";
                    }
                    else
                    {
                        cinfo.streetname = dataReader.GetValue(15).ToString();
                        var org = client.Queryable<SysOrg>()
                            .Where(r => r.Name == cinfo.streetname)
                            .WhereIF(!string.IsNullOrEmpty(countyid),r=>r.ParentId.ToString() == countyid)
                            .First();
                        if (org != null)
                        {
                            streetid = org.Id.ToString();
                            cinfo.streetid = org.Id.ToString();
                        }
                    }

                    if (dataReader.IsDBNull(16))
                    {
                        cinfo.communityname = "";
                    }
                    else
                    {
                        cinfo.communityname = dataReader.GetValue(16).ToString();
                        var org = client.Queryable<SysOrg>()
                            .Where(r => r.Name == cinfo.communityname)
                            .WhereIF(!string.IsNullOrEmpty(streetid), r => r.ParentId.ToString() == streetid)
                            .First();
                        if (org != null)
                        {
                            cinfo.communityid = org.Id.ToString();
                        }
                    }

                    //图斑数据drone_shp_data
                    DroneShpData model = new DroneShpData();
                    model.relid = cinfo.Id;
                    model.createtime = DateTime.Now;
                    model.createuser = _user.Name;
                    //获取主键
                    string _gid = _commonDataManager.GetMaxKeyVal("gid", "drone_shp_data", 1);
                    model.gid = int.Parse(_gid) + i;//转为数字类型
                    i++;
                    cinfo.geomid = model.gid.ToString();

                    cinfo.handle_status_id = 0;


                    //geom
                    if (!dataReader.IsDBNull(0))
                    {
                        var geometry = (Geometry)dataReader.GetValue(0);
                        if (!geometry.IsValid)
                        {
                            throw new Exception("图斑" + cinfo.xiangmu_no + "未闭合，请重新整理数据");
                        }
                        var geometryForWgs84 = GeometryFactory.Default.WithSRID(int.Parse(srid))
                            .CreateGeometry(geometry);
                        geomSql.AppendFormat($" update drone_shp_data set geom = '{geometryForWgs84.AsText()}' where gid = '{model.gid}';");
                        sql.AppendFormat($" update drone_shp_data set area = st_area(st_transform(ST_SetSRID(geom,4326), 4527)) where gid = '{model.gid}';");
                    }
                    datalist.Add(cinfo);
                    shplist.Add(model);
                }
            }

            using (var uow = base.UnitWork.CreateContext())
            {
                await uow.DroneSsnyd.InsertRangeAsync(datalist);
                await uow.DroneShpData.InsertRangeAsync(shplist);
                await uow.Db.Ado.ExecuteCommandAsync(geomSql.ToString());
                await uow.Db.Ado.ExecuteCommandAsync(sql.ToString());
                var flag = uow.Commit();
                if (flag == true)
                {
                    return new Response<bool>()
                    {
                        Result = flag,
                        Message = "导入成功"
                    };
                }
                else
                {
                    return new Response<bool>()
                    {
                        Result = false,
                        Message = "导入失败"
                    };
                }

            }
        }

        #endregion


        #region 添加查询前时像后时像
        //添加时像后时像
        public Response<bool> AddTubanshixiang(List<DroneTuBanshixiang> req)
        {
            //var user = _auth.GetCurrentUser().User;
            //添加数据
            var flag = client.Ado.UseTran(() =>
            {
                var data = client.Queryable<DroneTuBanshixiang>().ToList();
                client.Deleteable(data).ExecuteCommand();
                client.Insertable(req).ExecuteCommand();
            });
            if (flag.IsSuccess)
            {
                return new Response<bool> { Result = true };
            }
            else
            {
                return new Response<bool> { Result = false, Message = "操作失败" };
            }
        }

        //查询图斑前时像后时像
        public async Task<Response<List<DroneTuBanshixiang>>> LoadTuBanshixiang()
        {
            //查询任务数据
            var data = await client.Queryable<DroneTuBanshixiang>().ToListAsync();
            return new Response<List<DroneTuBanshixiang>>
            {
                Result = data
            };
        }
        #endregion

        #region 不查询截图 直接导入
        public async Task<Response<bool>> UpdateDroneCaseInfoT(string picihao)
        {
            var data = client.Queryable<DroneCaseInfoImport>().Where(r => r.picihao==picihao).ToList();
            if (data.Count > 0)
            {
                using (var uow = base.UnitWork.CreateContext())
                {
                    #region 导入案件信息
                    int i = 0;
                    List<DroneCaseInfoSingle> datalist = new List<DroneCaseInfoSingle>();
                    List<DroneShpData> shplist = new List<DroneShpData>();
                    StringBuilder geomSql = new StringBuilder();
                    StringBuilder sql = new StringBuilder();
                    foreach (var item in data)
                    {
                        DroneCaseInfoSingle cinfo = new DroneCaseInfoSingle();
                        cinfo.Id = item.Id;
                        cinfo.createtime = DateTime.Now;
                        cinfo.createuser = item.createuser;
                        cinfo.createusername = item.createusername;
                        cinfo.is_illegal = 1;
                        cinfo.is_intact = 1;
                        cinfo.synchronoustime = DateTime.Now;
                        cinfo.handle_status_id = 0;
                        cinfo.handle_status_name = "待接收";
                        cinfo.is_jieshou = 0;
                        cinfo.is_closed = 0;
                        cinfo.is_delete = 0;
                        cinfo.case_description = item.case_description;
                        cinfo.area = item.area;
                        cinfo.tubanlaiyuan = item.tubanlaiyuan;
                        cinfo.typename = item.typename;
                        //类型id
                        var type = client.Queryable<SysDataItemDetail>().Where(r => r.ItemName == cinfo.typename && r.ItemCode == "DRONE_CASE_TYPE").First();
                        if (type != null)
                        {
                            cinfo.typeid = type.ItemDetailId;
                        }

                        cinfo.lng = item.lng;
                        cinfo.lat = item.lat;
                        JObject xzqh = GetOrgAreaByPoint((decimal)cinfo.lng, (decimal)cinfo.lat);
                        cinfo.countyid = xzqh["countyid"].ToString();
                        cinfo.countyname = xzqh["countyname"].ToString();
                        cinfo.streetid = xzqh["streetid"].ToString();
                        cinfo.streetname = xzqh["streetname"].ToString();
                        cinfo.communityid = xzqh["communityid"].ToString();
                        cinfo.communityname = xzqh["communityname"].ToString();
                        cinfo.address = cinfo.countyname + " " + cinfo.streetname + " " + cinfo.communityname;
                        cinfo.case_no = item.case_no;
                        cinfo.casepic = item.casepic;
                        cinfo.nongyongdi_area = item.nongyongdi_area;
                        cinfo.yongjiujibennongtian_area = item.yongjiujibennongtian_area;
                        cinfo.gengdi_area = item.gengdi_area;
                        cinfo.guotukongjianguihua_area = item.guotukongjianguihua_area;
                        cinfo.shengtaibaohuhongxian_area = item.shengtaibaohuhongxian_area;
                        cinfo.zhongdianquyu_area = item.zhongdianquyu_area;

                        //图斑数据drone_shp_data
                        DroneShpData model = new DroneShpData();
                        model.relid = cinfo.Id;
                        model.createtime = DateTime.Now;
                        model.createuser = item.createusername;
                        model.area = item.shparea;
                        //获取主键
                        string _gid = _commonDataManager.GetMaxKeyVal("gid", "drone_shp_data", 1);
                        model.gid = int.Parse(_gid) + i;//转为数字类型
                        i++;
                        cinfo.geomid = model.gid.ToString();

                        geomSql.AppendFormat($" update drone_shp_data set geom = '{item.geom}' where gid = '{model.gid}';");
                        sql.AppendFormat($" update drone_shp_data set area = st_area(st_transform(ST_SetSRID(geom,4326), 4527)) where gid = '{model.gid}';");
                        shplist.Add(model);

                        datalist.Add(cinfo);
                    }
                    string errornums = "";
                    switch (data[0].subjectname)
                    {
                        case "巡察审计":
                            var dataxunchashenji = datalist.MapTo<List<DroneCaseInfoXcsj>>();
                            //判断是否有重复数据
                            List<string> casenos = dataxunchashenji?.Select(r => r.case_no).ToList();
                            var caseinfo = client.Queryable<DroneCaseInfoXcsj>().Where(r => casenos.Contains(r.case_no)).ToList();
                            if (caseinfo.Count > 0)
                            {
                                var nums = caseinfo.Select(r => r.case_no).ToList();
                                var dataxuncha = dataxunchashenji.Where(r => !nums.Contains(r.case_no)).ToList();
                                //保存重复数据案件编号
                                errornums = string.Join(",", nums);
                                //添加未重复数据
                                await uow.DroneCaseInfoXcsj.InsertRangeAsync(dataxuncha);
                            }
                            else
                            {
                                await uow.DroneCaseInfoXcsj.InsertRangeAsync(dataxunchashenji);
                            }
                            break;
                        case "耕地非粮化":
                            var datafeilianghua = datalist.MapTo<List<DroneCaseInfoFLH>>();
                            List<string> casenof = datafeilianghua?.Select(r => r.case_no).ToList();
                            var caseinfof = client.Queryable<DroneCaseInfoFLH>().Where(r => casenof.Contains(r.case_no)).ToList();
                            if (caseinfof.Count > 0)
                            {
                                var nums = caseinfof.Select(r => r.case_no).ToList();
                                var dataxuncha = datafeilianghua.Where(r => !nums.Contains(r.case_no)).ToList();
                                //保存重复数据案件编号
                                errornums = string.Join(",", nums);
                                //添加未重复数据
                                await uow.DroneCaseInfoFLH.InsertRangeAsync(dataxuncha);
                            }
                            else
                            {
                                await uow.DroneCaseInfoFLH.InsertRangeAsync(datafeilianghua);
                            }
                            break;
                        case "违法用地":
                            List<string> casenog = datalist?.Select(r => r.case_no).ToList();
                            var caseinfos = client.Queryable<DroneCaseInfoSingle>().Where(r => casenog.Contains(r.case_no)).ToList();
                            if (caseinfos.Count > 0)
                            {
                                var nums = caseinfos.Select(r => r.case_no).ToList();
                                var dataxuncha = datalist.Where(r => !nums.Contains(r.case_no)).ToList();
                                //保存重复数据案件编号
                                errornums = string.Join(",", nums);
                                //添加未重复数据
                                await uow.DroneCaseInfoSingle.InsertRangeAsync(dataxuncha);
                            }
                            else
                            {
                                await uow.DroneCaseInfoSingle.InsertRangeAsync(datalist);
                            }
                            break;
                        case "重点问题I类":
                            var zhongdianwenti1 = datalist.MapTo<List<DroneCaseInfoZdwt1>>();
                            List<string> casenot = zhongdianwenti1?.Select(r => r.case_no).ToList();
                            var caseinfoz = client.Queryable<DroneCaseInfoZdwt1>().Where(r => casenot.Contains(r.case_no)).ToList();
                            if (caseinfoz.Count > 0)
                            {
                                var nums = caseinfoz.Select(r => r.case_no).ToList();
                                var dataxuncha = zhongdianwenti1.Where(r => !nums.Contains(r.case_no)).ToList();
                                //保存重复数据案件编号
                                errornums = string.Join(",", nums);
                                //添加未重复数据
                                await uow.DroneCaseInfoZdwt1.InsertRangeAsync(dataxuncha);
                            }
                            else
                            {
                                await uow.DroneCaseInfoZdwt1.InsertRangeAsync(zhongdianwenti1);
                            }
                            break;
                        case "重点问题II类":
                            var zhongdianwenti2 = datalist.MapTo<List<DroneCaseInfoZdwt2>>();
                            List<string> casenow = zhongdianwenti2?.Select(r => r.case_no).ToList();
                            var caseinfow = client.Queryable<DroneCaseInfoZdwt2>().Where(r => casenow.Contains(r.case_no)).ToList();
                            if (caseinfow.Count > 0)
                            {
                                var nums = caseinfow.Select(r => r.case_no).ToList();
                                var dataxuncha = zhongdianwenti2.Where(r => !nums.Contains(r.case_no)).ToList();
                                //保存重复数据案件编号
                                errornums = string.Join(",", nums);
                                //添加未重复数据
                                await uow.DroneCaseInfoZdwt2.InsertRangeAsync(dataxuncha);
                            }
                            else
                            {
                                await uow.DroneCaseInfoZdwt2.InsertRangeAsync(zhongdianwenti2);
                            }
                             break;
                        case "卫片下发":
                            var weipianxiafa = datalist.MapTo<List<DroneCaseInfoSatellite>>();
                            List<string> casenoa = weipianxiafa?.Select(r => r.case_no).ToList();
                            var caseinfoa = client.Queryable<DroneCaseInfoSatellite>().Where(r => casenoa.Contains(r.case_no)).ToList();
                            if (caseinfoa.Count > 0)
                            {
                                var nums = caseinfoa.Select(r => r.case_no).ToList();
                                var dataxuncha = weipianxiafa.Where(r => !nums.Contains(r.case_no)).ToList();
                                //保存重复数据案件编号
                                errornums = string.Join(",", nums);
                                //添加未重复数据
                                await uow.DroneCaseInfoSatellite.InsertRangeAsync(dataxuncha);
                            }
                            else
                            {
                                await uow.DroneCaseInfoSatellite.InsertRangeAsync(weipianxiafa);
                            }
                            break;
                    }
                    await uow.DroneShpData.InsertRangeAsync(shplist);
                    await uow.Db.Ado.ExecuteCommandAsync(geomSql.ToString());
                    await uow.Db.Ado.ExecuteCommandAsync(sql.ToString());

                    var flag = uow.Commit();

                    //返回值
                    var res = new Response<bool>
                    {
                        Result = flag,
                        Message = flag == true ? "导入数据成功" : "导入数据失败"
                    };

                    if (flag == true)
                    {
                        if (!string.IsNullOrEmpty(errornums))
                        {
                            res.Message = "重复编号：" + errornums + "未导入";
                        }
                    }
                    //返回值
                    return res;
                    #endregion
                }

            }
            else
            {
                throw new Exception("未找到该批次数据");
            }
        }


        /// <summary>
        /// 导入矿产信息--不截图
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>
        public async Task<Response<bool>> UpdateDroneCaseInfoMineralsT(string picihao)
        {
            var data = client.Queryable<DroneCaseInfoImport>().Where(r => r.picihao == picihao).ToList();
            if(data.Count > 0)
            {
                using (var uow = base.UnitWork.CreateContext())
                {
                    #region 案件信息处理
                    int i = 0;
                    List<DroneCaseInfoMinerals> datalist = new List<DroneCaseInfoMinerals>();
                    List<DroneShpData> shplist = new List<DroneShpData>();
                    StringBuilder geomSql = new StringBuilder();
                    StringBuilder sql = new StringBuilder();
                    foreach (var item in data)
                    {
                        DroneCaseInfoMinerals cinfo = new DroneCaseInfoMinerals();
                        cinfo.Id = item.Id;
                        cinfo.createtime = DateTime.Now;
                        cinfo.createuser = item.createuser;
                        cinfo.is_illegal = 1;
                        //cinfo.xiafatime_base = DateTime.Now;
                        cinfo.handle_status_id = 0;
                        cinfo.is_closed = 0;
                        cinfo.case_description = item.case_description;
                        cinfo.weifaarea_base = item.area;
                        cinfo.tubanlaiyuan = item.tubanlaiyuan;
                        cinfo.typename = item.typename;
                        cinfo.centerlat_base = item.lng.ToString();
                        cinfo.centerlng_base = item.lat.ToString();
                        JObject xzqh = GetOrgAreaByPoint((decimal)item.lng, (decimal)item.lat);
                        cinfo.countyid = xzqh["countyid"].ToString();
                        cinfo.countyname = xzqh["countyname"].ToString();
                        cinfo.streetid = xzqh["streetid"].ToString();
                        cinfo.streetname = xzqh["streetname"].ToString();
                        cinfo.communityid = xzqh["communityid"].ToString();
                        cinfo.communityname = xzqh["communityname"].ToString();
                        //cinfo.address = cinfo.countyname + " " + cinfo.streetname + " " + cinfo.communityname;
                        cinfo.case_no = item.case_no;
                        cinfo.tubanpic_base = item.casepic;
                        cinfo.jbntarea_base = item.yongjiujibennongtian_area;
                        cinfo.gengdi_area = item.gengdi_area;
                        cinfo.stbhhxarea_base = item.shengtaibaohuhongxian_area;
                        cinfo.cskfbjarea_base = item.cskfbjarea_base;
                        cinfo.weifazhandiarea_base = item.weifazhandiarea_base;
                        cinfo.weifakaicaiarea_base = item.weifakaicaiarea_base;

                        //图斑数据drone_shp_data
                        DroneShpData model = new DroneShpData();
                        model.relid = cinfo.Id;
                        model.createtime = DateTime.Now;
                        model.createuser = item.createusername;
                        model.area = item.shparea;
                        //获取主键
                        string _gid = _commonDataManager.GetMaxKeyVal("gid", "drone_shp_data", 1);
                        model.gid = int.Parse(_gid) + i;//转为数字类型
                        i++;
                        cinfo.geomid = model.gid.ToString();

                        geomSql.AppendFormat($" update drone_shp_data set geom = '{item.geom}' where gid = '{model.gid}';");
                        sql.AppendFormat($" update drone_shp_data set area = st_area(st_transform(ST_SetSRID(geom,4326), 4527)) where gid = '{model.gid}';");
                        shplist.Add(model);

                        datalist.Add(cinfo);
                    }
                    var caseno = datalist.Select(r => r.case_no).ToList();
                    var caseinfo = client.Queryable<DroneCaseInfoMinerals>().Where(r => caseno.Contains(r.case_no)).ToList();
                    string errornums = "";
                    if (caseinfo.Count > 0)
                    {
                        var nums = caseinfo.Select(r => r.case_no).ToList();
                        var dataxuncha = datalist.Where(r => !nums.Contains(r.case_no)).ToList();
                        //保存重复数据案件编号
                        errornums = string.Join(",", nums);
                        //添加未重复数据
                        await uow.DroneCaseInfoMinerals.InsertRangeAsync(dataxuncha);

                    }
                    else
                    {
                        await uow.DroneCaseInfoMinerals.InsertRangeAsync(datalist);
                    }

                    await uow.DroneShpData.InsertRangeAsync(shplist);
                    await uow.Db.Ado.ExecuteCommandAsync(geomSql.ToString());
                    await uow.Db.Ado.ExecuteCommandAsync(sql.ToString());

                    var flag = uow.Commit();
                    #endregion
                    var res=new Response<bool>
                    {
                        Result = flag,
                        Message = flag == true ? "导入数据成功" : "导入数据失败"
                    };

                    if(flag == true)
                    {
                        if (!string.IsNullOrEmpty(errornums))
                        {
                            res.Message = "重复编号：" + errornums + "未导入";
                        }
                    }
                    //返回值
                    return res;
                }
            }
            else
            {
                throw new Exception("未找到该批次数据");
            }
           
        }
        #endregion
    }
}