YunNanDsBase/src/main/java/com/dsideal/base/DataEase/Controller/DataEaseController.java

package com.dsideal.base.DataEase.Controller;

import cn.hutool.core.codec.Base64;
import com.dsideal.base.Base.Model.BaseModel;
import com.dsideal.base.BaseApplication;
import com.dsideal.base.DataEase.Model.DataEaseModel;
import com.dsideal.base.Interceptor.EmptyInterface;
import com.dsideal.base.Interceptor.IsLoginInterface;
import com.dsideal.base.Interceptor.IsNumericInterface;
import com.dsideal.base.Res.Model.ResourceModel;
import com.dsideal.base.Util.CommonUtil;
import com.dsideal.base.Util.CookieUtil;
import com.jfinal.aop.Before;
import com.jfinal.core.Controller;
import com.jfinal.ext.interceptor.GET;
import com.jfinal.ext.interceptor.POST;
import com.jfinal.plugin.activerecord.Record;
import io.github.yedaxia.apidocs.ApiDoc;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import java.io.IOException;
import java.util.List;

public class DataEaseController extends Controller {
    DataEaseModel dm = new DataEaseModel();
    ResourceModel rm = new ResourceModel();
    BaseModel bm = new BaseModel();

    // http://10.10.21.20:9000/dsBase/dataease/route?city_name=昆明市
    // http://10.10.21.20:9000/dsBase/dataease/route?city_name=楚雄彝族自治州
    // http://10.10.21.20:9000/dsBase/dataease/route?city_name=西双版纳傣族自治州
    // !!!必须发布后访问才能做到进入此接口，否则浏览器就走缓存，不进来这个接口了！!!

    /**
     * 路由跳转
     *
     * @param city_name 城市名称
     */
    @Before({GET.class})
    @EmptyInterface({"city_name"})
    public void route(String city_name) {
        //大屏名称
        String dataVisualizationName = BaseApplication.PropKit.get("dataEase.dataVisualizationName");
        //发布的地址
        String publish_url = BaseApplication.PropKit.get("dataEase.publish_url");

        //先更新一下数据表
        dm.updateCity(dataVisualizationName, city_name);
        //再拼接一下URL的最终地址
        JSONObject jo = new JSONObject();
        jo.put("city_name", city_name);
        String base64Str = Base64.encode(jo.toString());
        //跳转
        redirect(publish_url + "/#/de-link/zud8IQ8J?attachParams=" + base64Str);
    }

    /**
     * 根据当前登录人员的identity_id,获取此人员可以维护的数据集名称
     */
    @Before({GET.class})
    @IsLoginInterface({})
    public void getDataSet() {
        // 人员身份
        // identity_id=1 省
        // identity_id=2 市
        // identity_id=3 县
        int identity_id = Integer.parseInt(CookieUtil.getValue(getRequest(), "identity_id"));
        List<com.jfinal.plugin.activerecord.Record> list = dm.getDataSetByIdentityId(identity_id);
        renderJson(CommonUtil.renderJsonForLayUI(list));
    }

    /**
     * 获取数据集下的数据表
     *
     * @param dataset_id 数据集id
     */
    @Before(GET.class)
    @IsLoginInterface({})
    @IsNumericInterface({"dataset_id"})
    public void getDataSetTable(int dataset_id) {
        List<Record> list = dm.getDataSetTableContent(dataset_id);
        renderJson(CommonUtil.renderJsonForLayUI(list));
    }

    /**
     * 保存数据集下的数据表
     *
     * @param dataset_id 数据集id
     * @param data       保存的数据
     */
    @Before(POST.class)
    @IsLoginInterface({})
    public void saveDataSetTable(int dataset_id, String data) {
        //登录的人员
        int identity_id = Integer.parseInt(CookieUtil.getValue(getRequest(), "identity_id"));
        String person_id = CookieUtil.getValue(getRequest(), "person_id");
        //如果是市/州，名称
        //如果是县区，名称
        String xmqh = bm.getPersonInfo(person_id).getStr("person_name").replace("管理员", "");
        JSONArray jsonArray = JSONArray.fromObject(data);
        for (Object o : jsonArray) {
            net.sf.json.JSONObject jo = (net.sf.json.JSONObject) o;
            if (identity_id > 1 && jo.containsKey("行政区划") && !jo.getString("行政区划").equals(xmqh)) {
                renderJson(CommonUtil.returnMessageJson(false, "数据集数据与当前登录人员所属行政区划不一致，请重新选择数据集！"));
                return;
            }
        }
        if (identity_id > 1) {
            for (Object o : jsonArray) {
                net.sf.json.JSONObject jo = (net.sf.json.JSONObject) o;
                if (!jo.containsKey("行政区划")) {
                    renderJson(CommonUtil.returnMessageJson(false, "数据集数据不是省级管理员操作，但却没有行政区划的字段！"));
                    return;
                }
                break;
            }
        }
        //保存
        dm.saveDataSetTable(identity_id, dataset_id, xmqh, jsonArray);
        renderJson(CommonUtil.returnMessageJson(true, "保存成功"));
    }

    /**
     * 下载指定数据集的Excel文件
     *
     * @param id 数据集id
     */
    @Before(GET.class)
    @IsLoginInterface({})
    @IsNumericInterface({"id"})
    public void downloadExcel(int id) throws IOException {
        //根据当前登录人员的身份，获取对应的数据集名称
        int identity_id = Integer.parseInt(CookieUtil.getValue(getRequest(), "identity_id"));
        String person_id = CookieUtil.getValue(getRequest(), "person_id");
        //获取他是哪个城市或者县区的管理员
        //行政区划码
        String area_code = rm.getAreaCode(identity_id, person_id);
        //根据区域码，获取区域名称
        String area_name = rm.getAreaName(area_code);
        Record record = dm.getDataSetById(id);
        String tableName = record.getStr("table_name");
        String dataSetName = record.getStr("dataset_name");
        String tempDir = System.getProperty("java.io.tmpdir");
        //导出excel
        dm.exportExcel(identity_id, tableName, dataSetName, tempDir, area_name);
    }

    /**
     * 下载模板Excel
     *
     * @param type_id 1:市州，2：县区
     */
    @Before(GET.class)
    @IsLoginInterface({})
    public void downSampleExcel(int type_id) {

    }

    /**
     * 上传Excel文件
     */
    @Before(POST.class)
    @IsLoginInterface({})
    public void uploadExcel() {

    }

}