总结工作中nginx、git、linux、ES、lamada表达式、sql

末蓝、 2024-04-01 19:26 24阅读 0赞

### nginx ###

启动命令：start nginx 或者 nginx.exe  
停止命令：nginx.exe -s stop 或者 nginx.exe -s quit  
重启命令：nginx.exe -s reload  
重新打开日志文件：nginx.exe -s reopen  
查看nginx版本：nginx -v

### git ###

忘记命令—帮助：git --help

\--------------------------修改user-------------------------  
//修改user  
git config user.email lizh@thunisoft.com  
git config --global user.email lizh@thunisoft.com

\--------------------------新建分支-------------------------  
//从已有的分支创建新的分支(如从master分支),创建一个dev分支  
git checkout -b feature/cx\_input\_20210708

//创建完可以查看一下,分支已经切换到new  
git branch

//提交该分支到远程仓库  
git push origin feature/cx\_input\_20210708

//测试从远程获取dev  
git pull origin feature/cx\_input\_20210708

//设置远端跟踪分支  
git branch --set-upstream-to=origin/feature/cx\_input\_20210708 feature/cx\_input\_20210708

\--------------------------删除分支-------------------------

//查看所有分支  
git branch -a

//删除远程分支  
git push origin --delete feature/cxfw\_lzh\_20201116

//删除本地分支  
git branch -D feature/cxfw\_lzh\_20201116

\--------------------------清理操作-------------------------  
忽略的文件：.gitignore 中忽略的文件

未被跟踪的文件：没有被忽略，但是还没 git add 的文件

git clean -f  
删除：未被跟踪的文件

git clean -fd  
删除：未被跟踪的文件和文件夹

git clean -xfd  
删除：忽略的文件、未被跟踪的文件和文件夹

git clean \[-xfd\] -n  
\-n 会先打印一些将要删除的文件，并不执行删除动作，主要是查看是否有自己需要的不想被删除

### Linux ###

进入root用户：sudo -i 或者 sudo  
查询查询服务：ps -ef | grep cxfw  
查询所有Java服务：ps -ef | grep java  
停止服务：./bin/admin.sh stop  
启动命令：./bin/admin.sh start  
退出日志界面：ctry+c  
动态进入日志界面：tail -f logs/日志名.log(例如：tail -f logs/cxfw\_tdout.log)  
cat index.js 查看  
taskkill /F /IM nginx\* 杀死命令

运行jar包 nohup /usr/share/elasticsearch/jdk/bin/java -jar sjcl.jar &  
查看日志 tail -f nohup.out

编辑模式：  
使用vi进入文本，按i开始编辑文本  
退出编辑模式：按ESC键，然后:  
退出vi  
:q! 不保存文件，强制退出vi命令  
:w 保存文件，不退出  
:wq 保存退出

删除dist文件和压缩包,移除rm -rf dist\*  
解压压缩包：unzip dist.zip

### ES中BoolQueryBuilder ###

BoolQueryBuilder qb = QueryBuilders.boolQuery();
    1，qb.must(QueryBuilder queryBuilder);  //返回的文档必须满足must子句的条件,并且参与计算分值
    2，qb.mustNot(QueryBuilder queryBuilder)  //返回的文档必须不满足定义的条件
    3，qb.should(QueryBuilder queryBuilder))  //返回的文档可能满足should子句的条件.在一个bool查询中,如果没有must或者filter,有一个或者多个should子句,那么只要满足一个就可以返回.minimum_should_match参数定义了至少满足几个子句.
    4，qb.filter(QueryBuilder queryBuilder))  //返回的文档必须满足filter子句的条件,但是不会像must一样,参与计算分值

### lamada表达式 ###

一、
            data.forEach((key, value) -> {//循环
                if (value instanceof List) {//判断value是否是List类型
                    ((List<?>) value).add()
                }
            });
    
    二、
            Map<String, List<String>> map = wtxzlbList.parallelStream()
                    .collect(groupingBy(wtlb -> wtlb.substring(0, 8)));
            // 检举控告
            List<String> jjkglList = map.containsKey(Constants.DZDM_JJKGL_WTLB) ? map.get(Constants.DZDM_JJKGL_WTLB)
                    .parallelStream().filter(wtlb -> wtlb.length() > 9).map(wtlb -> wtlb.substring(9)).collect(toList())
                    : Lists.newArrayList();
    
    三、
        /**
         * 转换Map
         *
         * @param map
         * @param newMap
         */
        public void convertMap(Map<String, Object> map, Map<String, Object> newMap) {
            map.forEach((key, value) -> {
                if (value instanceof List) {
                    List<Map<String, Object>> valueList = (List<Map<String, Object>>) value;
                    List<Map<String, Object>> innerList = new ArrayList<>(valueList.size());
                    valueList.forEach(valueMap -> {
                        Map<String, Object> innerMap = new HashMap<>(valueMap.size());
                        convertMap(valueMap, innerMap);
                        innerList.add(innerMap);
                    });
                    newMap.put(this.zhzd(key), innerList);
                } else {
                    newMap.put(this.zhzd(key), value);
                }
            });
        }
    
    四、
        list.stream().filter(e -> !noRequire.contains(e)).distinct().collect(Collectors.toList());
        
    五、
        Optional.ofNullable(RedisCacheUtil.hget(REDIS_CACHE_KEY_ALLQTSD, wtsd))
                    .map(node -> JSON.parseObject(node.toString(), OrganTreeNode.class).getCdwlx())
                    .orElse(StringUtils.EMPTY);
    六、
            // 创建线程池获取表格数据
            ExecutorService pool = Executors.newFixedThreadPool(poolSize);
            List<Tjb.TjbData> list = new ArrayList<>();
            List<Future<List<Tjb.TjbData>>> futureList = new ArrayList<>();
    
            // 执行任务并获取Future对象
            for (TjbZbxEnum value : TjbZbxEnum.values()) {
                futureList.add(pool.submit(() -> new ExportThread(builder, value.getCode()).invoke()));
            }
            futureList.add(pool.submit(() -> new ExportThread(builder, "zl").invoke()));
    
            // 关闭启动线程
            pool.shutdown();
    
    七、list数据求和
        List<QgxfjbtjDTO> bjList
        QgxfjbtjDTO sum = new QgxfjbtjDTO();
        sum.setXfjbzl(bjList.stream().mapToInt(QgxfjbtjDTO::getXfjbzl).sum());
    
    八、创建线程池
    
        // 生产者消费者线程池
        ExecutorService threadPool = Executors.newFixedThreadPool(3);
        threadPool.submit(syjsWorker::run);
        /**
         * @param
         * @return
         * @description 创建线程池
         * @author yqz
         * @date 2020/11/20
         * @other
         */
        public ThreadPoolExecutor createThreadPool(String poolName, int corePoolSize, int maximumPoolSize) {
            ThreadFactory factory = new ThreadFactoryBuilder()
                    .setNameFormat(poolName + "-thread-%d")
                    .build();
            // 创建线程池
            return new ThreadPoolExecutor(corePoolSize, maximumPoolSize, 0L,
                    TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(), factory);
        }
        
        队列出栈：return this.xfjQueueSy.take();

### java ###

//流转状态-已留存待恢复
    String LZZT_BL_YLCDHF = "5";
    //流转状态-已转办
    String LZZT_BL_YZB = "7";
    //流转状态-已分办
    String LZZT_BL_YFB = "8";
    //流转状态-已交办
    String LZZT_BL_YJB = "9";
    //流转状态-已办理
    String LZZT_BL_YBL = "10";
    
    List<String> LZZT_YBL_ARR = Arrays.asList(LZZT_BL_YLCDHF, LZZT_BL_YZB, LZZT_BL_YFB, LZZT_BL_YJB, LZZT_BL_YBL);
    LZZT_YBL_ARR.contains("7")//list中有contains()方法，用来判断
    
    // 对list进行每条数据操作，最后转成list
    xfCzfkxxList = xfCzfkxxList.stream().filter(listczfkxx -> StringUtils.isNotEmpty(listczfkxx.getCzfsBm())).collect(Collectors.toList());
    
    //枚举类型的类
    @Getter
    @AllArgsConstructor
    public enum BljdEnum {
        DBL("1", "待办理"),
        YBL("2", "已办理"),
        YLC("3", "已留存");
        private final String code;
        private final String name;
    }

--------------------

一个ES查询  bhs：信访编号，includes：结果列
        @EncryptionMethod
    public XfjCxjgVO.Origan listZhcxjgByBh(List<String> bhs, String[] includes) {
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    
        // 选择条件
        boolQueryBuilder.filter(QueryBuilders.termsQuery("_id", bhs));
        searchSourceBuilder.query(boolQueryBuilder);
    
        // 设置返回字段
        searchSourceBuilder.fetchSource(includes, new String[0]);
    
        searchSourceBuilder.size(Constants.ES_MAX_SIZE);
        searchSourceBuilder.timeout(new TimeValue(60000));
        searchSourceBuilder.sort(Constants.ES_XFJ_XFSJ, SortOrder.DESC);
        searchSourceBuilder.sort("_id", SortOrder.ASC);
        return listResult(searchSourceBuilder);
    }

--------------------

//多线程的使用。查询服务中的统计表生成

// 创建线程池获取表格数据
        ExecutorService pool = Executors.newFixedThreadPool(poolSize);
        List<Tjb.TjbData> list = new ArrayList<>();
        List<Future<List<Tjb.TjbData>>> futureList = new ArrayList<>();
        
        // 执行任务并获取Future对象
        for (TjbZbxEnum value : TjbZbxEnum.values()) {
            futureList.add(pool.submit(() -> new ExportThread(builder, value.getCode()).invoke()));
        }
        futureList.add(pool.submit(() -> new ExportThread(builder, "zl").invoke()));
        
        // 关闭启动线程
        pool.shutdown();
        // 等待线程结束
        while (true) {
            if (pool.isTerminated()) {
                log.info("所有分线程结束");
                break;
            }
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                log.error("生成统计表异常", e);
            }
        }
        // 获取所有并发任务的运行结果
        for (Future<List<Tjb.TjbData>> future : futureList) {
            try {
                list.addAll(future.get());
            } catch (Exception e) {
                log.error("获取结果集异常", e);
            }
        }

--------------------

### SQL ###

删除表中的数据
    truncate table DB_CXFW.T_CX_PZ;

项目中用到mybatis：

from ${schema}.T_XF_XFJ XFJ
        where
        XFJ.C_BH in
        <foreach collection="bhList" index="index" item="bh" open="(" separator="," close=")">
            #{bh,jdbcType=VARCHAR}
        </foreach>

创建视图

CREATE VIEW "db_tjfx"."t_czqk_def" AS  SELECT t_czqk_tmp.c_tjq,
        t_czqk_tmp.c_cjrdw,
        t_czqk_tmp.c_ssxzqh,
        t_czqk_tmp.c_xffs,
        t_czqk_tmp.n_cfj,
        t_czqk_tmp.n_bcj,
        t_czqk_tmp.n_sfysbw,
        t_czqk_tmp.n_sfyqs,
        t_czqk_tmp.n_sfyfk,
        t_czqk_tmp.n_sfybl,
        t_czqk_tmp.c_sjqx_xffs,
        t_czqk_tmp.c_sjqx_wtsd,
        t_czqk_tmp.c_sjqx_bfyrzj,
        t_czqk_tmp.c_sjqx_gbglqx,
        sum(t_czqk_tmp.n_xfjc) AS n_xfjc
       FROM db_tjfx.t_czqk_tmp
      GROUP BY t_czqk_tmp.c_tjq, t_czqk_tmp.c_cjrdw, t_czqk_tmp.c_ssxzqh, t_czqk_tmp.c_xffs, t_czqk_tmp.n_cfj, t_czqk_tmp.n_bcj, t_czqk_tmp.n_sfysbw, t_czqk_tmp.n_sfyqs, t_czqk_tmp.n_sfyfk, t_czqk_tmp.n_sfybl, t_czqk_tmp.c_sjqx_xffs, t_czqk_tmp.c_sjqx_wtsd, t_czqk_tmp.c_sjqx_bfyrzj, t_czqk_tmp.c_sjqx_gbglqx;
    
    ALTER TABLE "db_tjfx"."t_czqk_def" OWNER TO "postgres";

### 项目 查询服务 ###

几大功能：结果列设置、导出、根据条件查询。  
结果列设置：首先根据用户id去获取先前的结果列list（JGL表）保存…，如果没有，则设置默认的结果列list（默认差PZ表）。达蒙库  
导出：获取结果list jg,结果列 lb。通过文件流创建写入 File 、XSSFSheet 、XSSFRow  
根据条件设置查询：SearchSourceBuilder BoolQueryBuilder.filter(QueryBuilders.rangeQuery(name))

SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        // 查询条件
        BoolQueryBuilder boolQueryBuilder = getZhcxBoolQueryBuilder(zhcxtjVO, sjqxCondition);
        searchSourceBuilder.query(boolQueryBuilder);
        searchSourceBuilder.timeout(new TimeValue(60000));
        searchSourceBuilder.size(zhcxtjVO.getFyxx().getSize());
        // 排序
        searchSourceBuilder.sort("_id", SortOrder.ASC);
        // 设置返回字段
        searchSourceBuilder.fetchSource(includes, new String[0]);
        // 计算总量
        searchSourceBuilder.trackTotalHits(Boolean.TRUE);

### instanceof使用 ###

if (obj instanceof Collection) {
            Collection collection = (Collection) obj;
            for (Object object : collection) {
                edeObjectValue(object, way);
            }
            return;
        }

\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-qMg72TWx-1668604069301)(\_v\_images/20220906155913742\_4203.png)\]

searchSourceBuilder.trackTotalHits(Boolean.TRUE);

### instanceof使用 ###

![\[外链图片转存中...(img-qMg72TWx-1668604069301)\]][..._img-qMg72TWx-1668604069301]

[..._img-qMg72TWx-1668604069301]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/fd10941bc69746149416b0cc7ae9d0cd.png