dzhh-backend/.svn/pristine/d7/d7d4046851ea40c86ca44e016a920192b494f601.svn-base

package org.jeecg.modules.demo.hzz.shjsgc.lhgc.sk.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.ql.geo.entity.RmQlgeo;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sk.entity.RmSkqktjb;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sk.geo.entity.RmSkgeo;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sk.geo.service.IRmSkgeoService;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sk.geo.service.impl.RmSkgeoServiceImpl;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sk.mapper.RmSkqktjbMapper;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sk.service.IRmSkqktjbService;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sz.entity.RmSzqktjb;
import org.jeecg.modules.demo.hzz.shjsgc.lhgc.sz.mapper.RmSzqktjbMapper;
import org.jeecg.modules.demo.untils.zbzh;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import java.util.List;

/**
 * @Description: 水库情况统计表
 * @Author: jeecg-boot
 * @Date: 2022-01-19
 * @Version: V1.0
 */
@Service
public class RmSkqktjbServiceImpl extends ServiceImpl<RmSkqktjbMapper, RmSkqktjb> implements IRmSkqktjbService {
    @Autowired
    private RmSkgeoServiceImpl rmSkgeoService;
    @Autowired
    private org.jeecg.modules.demo.untils.zbzh zbzh;
    @Autowired
    private RmSkqktjbMapper rmSkqktjbMapper;

    @Override
    public void GenarateSkgcGeo() {
        LambdaQueryWrapper<RmSkqktjb> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(RmSkqktjb::getFlag, 0);
        List<RmSkqktjb> dataList = this.baseMapper.selectList(queryWrapper);
        for (RmSkqktjb rmSkqktjb : dataList) {
            String a = rmSkqktjb.getJd();
            String b = rmSkqktjb.getWd();
            if (a != null && b != null) {
                Double jd = zbzh.tranformPos(a);
                Double wd = zbzh.tranformPos(b);
                if (jd > 180 && wd > 90) {
                    rmSkgeoService.addskgc("POINT(" + jd + " " + wd + ")", rmSkqktjb.getId());
                } else {
                    rmSkgeoService.addskgc2("POINT(" + jd + " " + wd + ")", rmSkqktjb.getId());
                }
            }
            rmSkqktjb.setFlag(1);
            this.updateById(rmSkqktjb);
        }


    }

    @Override
    public void delete(String id) {
        try {
            LambdaQueryWrapper<RmSkgeo> queryWrapper = new LambdaQueryWrapper<>();
            queryWrapper.eq(RmSkgeo::getSkid, id);
            Integer skgeoid = rmSkgeoService.getOne(queryWrapper).getId();
            rmSkgeoService.removeById(skgeoid);

        } catch (Exception e) {


        }

    }

    @Override
    public void insertshxm(String id, String xzqh, String xmmc, String xmid, String xmlx, String gldw, String zgbm, String bz, String geoinfo, String sfwpgblxm, String szhl, String spzt) {
        rmSkqktjbMapper.insertshxm(id, xzqh, xmmc, xmid, xmlx, gldw, zgbm, bz, geoinfo, sfwpgblxm, szhl, spzt);
    }

    @Override
    public void deshxm(String xmid) {
        rmSkqktjbMapper.deshxm(xmid);

    }

    @Override
    public void updateshxm(String xmmc, String xzqh, String gldw, String zgbm, String bz, String geoinfo, String sfwpgblxm, String szhl, String spzt, String id) {
        rmSkqktjbMapper.updateshxm(xmmc, xzqh, gldw, zgbm, bz, geoinfo, sfwpgblxm, szhl, spzt, id);
    }

    @Override
    public int deleteMany(String[] ids) {
        return rmSkqktjbMapper.deleteMany(ids);
    }
}