longdianningxing/lms/nladmin-system/src/main/java/org/nl/AppRun.java

package org.nl;

import cn.dev33.satoken.annotation.SaIgnore;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.alicp.jetcache.anno.config.EnableCreateCacheAnnotation;
import com.alicp.jetcache.anno.config.EnableMethodCache;
import io.swagger.annotations.Api;
import org.mybatis.spring.annotation.MapperScan;
import org.nl.common.utils.MapOf;
import org.nl.modules.wql.WQL;
import org.nl.modules.wql.core.bean.WQLObject;
import org.nl.modules.wql.util.SpringContextHolder;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.boot.web.servlet.server.ServletWebServerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 开启审计功能 -> @EnableJpaAuditing
 * https://www.cnblogs.com/niceyoo/p/10908647.html
 *
 * @author ldjun
 * @date 2021/2/22 9:20:19
 */
@EnableAsync
@RestController
@Api(hidden = true)
@SpringBootApplication(exclude = {
        org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class
})
@ServletComponentScan //https://blog.csdn.net/qq_36850813/article/details/101194250
@EnableJpaAuditing(auditorAwareRef = "auditorAware")
@EnableMethodCache(basePackages = "org.nl")
@EnableCreateCacheAnnotation
@MapperScan("org.nl.**.mapper")
//@EnableElasticsearchRepositories(basePackages = {"org.nl.modules.logging.repository.*"})
public class AppRun {

    public static void main(String[] args) {
        try {
            SpringApplication.run(AppRun.class, args);
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }

    @Bean
    public SpringContextHolder springContextHolder() {
        return new SpringContextHolder();
    }

    @Bean
    public ServletWebServerFactory webServerFactory() {
        TomcatServletWebServerFactory fa = new TomcatServletWebServerFactory();
        fa.addConnectorCustomizers(connector -> connector.setProperty("relaxedQueryChars", "[]{}"));
        return fa;
    }

    /**
     * 访问首页提示
     *
     * @return /
     */
    @GetMapping("/")
    @SaIgnore
    public String index() {
        return "Backend service started successfully";
    }
    @GetMapping("/w") // 立库监控初始化
    @SaIgnore
    public String index2() {
        // 采用循环+判断进行铺设图标, 可以通过舞台编辑协助完成
        WQLObject stageTab = WQLObject.getWQLObject("stage");
        WQLObject attrTab = WQLObject.getWQLObject("st_ivt_structattr");
        JSONObject save = new JSONObject();
        JSONArray nodes = new JSONArray();
        JSONArray edges = new JSONArray();
        int x = 50; // 首个位置
        int y = 50;
        int step = 5;
        String type = "html-node";
        int nodeSizeW = 50;
        int nodeSizeH = 50;
        for (int i = 2; i < 23; i=i+2) { // 第几块，每两块为一块
            // 获取列数col_num
            System.out.println( (i>=10?"3":"30") + i);
            JSONObject jsonObject = WQL.getWO("ss").addParamMap(MapOf.of("flag", "1"
                    , "block_num",  (i>=10?"3":"30") + i)).process().uniqueResult(0);
            int num = Integer.parseInt(jsonObject.getString("num"));
            for (int j = 1; j <= num; j++) {// 层数
                // 获取2，1....块的数据
                JSONArray array = attrTab.query("block_num IN ('" + (i>=10?"3":"30") + i + "','" +
                        ((i-1)>=10?"3":"30") + (i - 1) + "') AND " +
                        "layer_num = 3 AND col_num = " + j, "block_num DESC, row_num DESC").getResultJSONArray(0);
                for (int k = 0; k < array.size(); k++) { // 1,2...块的每列数据
                    JSONObject object = array.getJSONObject(k);

                    if (k-1 >= 0) { // 如果块与块不同,空一个距离
                        JSONObject object2 = array.getJSONObject(k-1);
                        if (!object2.getString("block_num").equals(object.getString("block_num")) && object2.getString("is_delete").equals(object.getString("is_delete"))) {
                            JSONObject node2 = new JSONObject();
                            node2.put("id", IdUtil.getSnowflake(1,1).nextIdStr());
                            node2.put("type", type);
                            node2.put("x", x);
                            node2.put("y", y);
                            JSONObject properties2 = new JSONObject();
                            JSONObject nodeSize2 = new JSONObject();
                            nodeSize2.put("width", nodeSizeW);
                            nodeSize2.put("height", nodeSizeH);
                            properties2.put("nodeSize", nodeSize2);
                            properties2.put("flag", "1");
                            properties2.put("transform", 90);
                            node2.put("properties", properties2);
                            node2.put("zIndex", "2023");
                            x = x + step + nodeSizeW;
                            nodes.add(node2);
                        }
                    }

                    if (object.getString("is_delete").equals("1")) {
                        x = x + step + nodeSizeW;
                        continue;
                    }

                    // 设置节点，只需要struct_id, 自定义参数数据都加载properties对象里面
                    JSONObject node = new JSONObject();
                    node.put("id", IdUtil.getSnowflake(1,1).nextIdStr());
                    node.put("type", type);
                    node.put("x", x);
                    node.put("y", y);
                    JSONObject properties = new JSONObject();
                    JSONObject nodeSize = new JSONObject();
                    nodeSize.put("width", nodeSizeW);
                    nodeSize.put("height", nodeSizeH);
                    properties.put("nodeSize", nodeSize);
                    properties.put("struct_id", object.getString("struct_id")); // 灵活配置，其他为固定参数
                    node.put("properties", properties);
                    node.put("zIndex", "2023");
                    x = x + step + nodeSizeW;
                    nodes.add(node);

                }
                // 下一列
                x = 50;
                y = y + step + nodeSizeH;
            }
            // 下一个块
            x = 50;
            for (int j = 0; j < 16; j++) { // 铺设一行道路
                JSONObject node2 = new JSONObject();
                node2.put("id", IdUtil.getSnowflake(1,1).nextIdStr());
                node2.put("type", type);
                node2.put("x", x);
                node2.put("y", y);
                JSONObject properties2 = new JSONObject();
                JSONObject nodeSize2 = new JSONObject();
                nodeSize2.put("width", nodeSizeW);
                nodeSize2.put("height", nodeSizeH);
                properties2.put("nodeSize", nodeSize2);
                properties2.put("flag", "1");
                node2.put("properties", properties2);
                node2.put("zIndex", "2023");
                x = x + step + nodeSizeW;
                nodes.add(node2);
            }
            x = 50;
            y = y + step + nodeSizeH;
        }
        save.put("nodes", nodes);
        save.put("edges", edges);
        JSONObject jsonObject = stageTab.query("stage_code = 'AS_3'").uniqueResult(0);
        jsonObject.put("stage_data", save);
        stageTab.update(jsonObject);
        return "Backend service started successfully";
    }

    @GetMapping("/f") // 发货区监控初始化
    @SaIgnore
    public String index3() {
        // 采用循环+判断进行铺设图标, 可以通过舞台编辑协助完成
        WQLObject stageTab = WQLObject.getWQLObject("stage");
        WQLObject attrTab = WQLObject.getWQLObject("sch_base_point");
        JSONObject save = new JSONObject();
        JSONArray nodes = new JSONArray();
        JSONArray edges = new JSONArray();
        int x = 50; // 首个位置
        int y = 50;
        int step = 5;
        String type = "html-node";
        int nodeSizeW = 50;
        int nodeSizeH = 50;
        for (int i = 1; i <= 4; i++) {

            JSONArray resultJSONArray = attrTab.query("col_num = '" + i + "' and point_type = '9' and layer_num = '1' order by row_num ASC").getResultJSONArray(0);

            for (int j = 0; j < resultJSONArray.size(); j++) {
                JSONObject json = resultJSONArray.getJSONObject(j);

                JSONObject node = new JSONObject();
                node.put("id", IdUtil.getSnowflake(1,1).nextIdStr());
                node.put("type", type);
                node.put("x", x);
                node.put("y", y);
                JSONObject properties = new JSONObject();
                JSONObject nodeSize = new JSONObject();
                nodeSize.put("width", nodeSizeW);
                nodeSize.put("height", nodeSizeH);
                properties.put("nodeSize", nodeSize);
                properties.put("struct_id", json.getString("point_id")); // 灵活配置，其他为固定参数
                node.put("properties", properties);
                node.put("zIndex", "2023");
                x = x + step + nodeSizeW;
                nodes.add(node);

            }

            x = 50;
            y = y + step + nodeSizeH;
        }
        save.put("nodes", nodes);
        save.put("edges", edges);
        JSONObject jsonObject = stageTab.query("stage_code = 'FS'").uniqueResult(0);
        jsonObject.put("stage_data", save);
        stageTab.update(jsonObject);
        return "Backend service started successfully";
    }
}