package jnpf.limsService.support;

import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

public class LimsSxtQuyangJihuaRenwuServiceChecks {

    public static void main(String[] args) throws Exception {
        String contract = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsService/LimsSxtQuyangJihuaRenwuService.java");
        require(contract, "wuhuaYishenpiJihua");
        require(contract, "shengchengDaishengchengQingyandan");
        require(contract, "quxiaoWeishengchengRenwuByJihua");
        require(contract, "tihuanWeishengchengRenwuPeizhi");

        String service = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsService/impl/LimsSxtQuyangJihuaRenwuServiceImpl.java");
        require(service, "markBlockedPeizhiWuxiao");
        require(service, "peizhi_wuxiao_zuduan");
        require(service, "sxtRenwuKuaizhaoAutoSubmit");
        require(service, "item.setRenwuId(renwu.getId())");
        require(service, "\"jianyan_xiangmu\", xiangmu.getId()");
        require(service, "请验配置检验项目未维护质量标准");
        require(service, "xiangmuMap.get(peizhiItem.getXiangmuId())");
        require(service, "wrapper.in(\"bianma\", xiangmuBianhaoSet)");
        require(service, "anBianmaChaxunJieguo.get(item.getXiangmuBianhao())");
        require(service, "xiangmuMap.put(item.getXiangmuId(), xiangmu)");
        require(service, "请验配置子项未维护质量标准子项ID：");
        require(service, "请验配置子项未维护检验项目编码：");
        require(service, "请验配置引用的检验项目不存在或已删除");
        require(service, "kuaizhao.setJianyanXiangmuId(xiangmu.getId())");
        require(service, "zixiang.getQuyangdianId()");
        require(service, "取样计划子项未保存取样点ID：");
        require(service, "取样点样品类型与计划不一致：");
        require(service, "取样点所属车间与计划不一致：");
        require(service, "Objects.equals(zixiang.getSuoshuChejian(), quyangdian.getChejianMingchengName())");
        require(service, "renwu.setSuoshuChejian(quyangdian.getChejianMingchengName())");
        require(service, "if (hasText(quyangdian.getFuzeGangwei())) {");
        require(service, "baocunRenyuanKuaizhao(renwu, \"quyang_fuze_gangwei\", null, quyangdian.getFuzeGangwei(), now);");
        require(service, "peizhiKuaizhaoYizhi(kuaizhao, dangqian)");
        require(service, "LimsSxtQuyangdianKuaizhaoModel dongjie = JSON.parseObject(");
        require(service, "kuaizhao.getKuaizhaoShuju(), LimsSxtQuyangdianKuaizhaoModel.class);");
        require(service, "private Object dangqianPeizhi(String leixing, String id, String tenantId)");
        require(service, "quyangdianMapper.selectForTaskSnapshot(tenantId, id)");
        reject(service, "if (\"quyangdian\".equals(leixing)) return quyangdianMapper.selectById(id);");
        reject(service, "wrapper.in(\"f_id\", xiangmuIds)");
        reject(service, "请验配置检验项目ID已变化");
        reject(service, "Objects.equals(zixiang.getSuoshuChejian(), quyangdian.getChejianMingcheng())");
        reject(service, "zixiang.getQuyangdianBianhao(), zixiang.getSuoshuChejian()");
        reject(service, "ConcurrentHashMap");
        reject(service, "lims_sxt_quyang_jihua_task");

        String pointMapper = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsMapper/LimsSxtQuyangdianMapper.java");
        require(pointMapper, "List<LimsSxtQuyangdianVO> selectByLeixingAndChejian(");
        require(pointMapper, "LimsSxtQuyangdianKuaizhaoModel selectForTaskSnapshot(");
        require(pointMapper, "@Param(\"quyangdianId\") String quyangdianId");
        reject(pointMapper, "LimsSxtQuyangdianVO selectForTaskSnapshot(");

        String pointSnapshot = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsModel/LimsSxtQuyangdianKuaizhaoModel.java");
        require(pointSnapshot, "private String id;");
        require(pointSnapshot, "private String tenantId;");
        require(pointSnapshot, "private String quyangdianBianhao;");
        require(pointSnapshot, "private String quyangDidian;");
        require(pointSnapshot, "private String chejianMingcheng;");
        require(pointSnapshot, "private String chejianMingchengName;");
        require(pointSnapshot, "private String lururen;");
        require(pointSnapshot, "private String leiXing;");
        require(pointSnapshot, "private Date luruShijian;");
        require(pointSnapshot, "private String bizEnabled;");
        require(pointSnapshot, "private String fuzeGangwei;");
        require(pointSnapshot, "private String bizSign;");
        reject(pointSnapshot, "flowTaskId");
        reject(pointSnapshot, "version");
        reject(pointSnapshot, "creatorTime");
        reject(pointSnapshot, "lastModifyTime");

        String pointMapperXml = read("jnpf-lims/jnpf-lims-biz/src/main/resources/mapper/LimsSxtQuyangdianMapper.xml");
        require(pointMapperXml, "<select id=\"selectByLeixingAndChejian\" resultMap=\"quyangdianVOMap\">");
        require(pointMapperXml, "<resultMap id=\"quyangdianKuaizhaoMap\" type=\"jnpf.limsModel.LimsSxtQuyangdianKuaizhaoModel\">");
        String pointSnapshotQuery = section(pointMapperXml, "<select id=\"selectForTaskSnapshot\"", "</select>");
        require(pointSnapshotQuery, "resultMap=\"quyangdianKuaizhaoMap\"");
        require(pointSnapshotQuery, "p.f_id");
        require(pointSnapshotQuery, "p.chejian_mingcheng_name");
        require(pointMapperXml, "p.f_id = #{quyangdianId}");
        require(pointMapperXml, "INNER JOIN lims_sxt_chejian c");
        reject(pointSnapshotQuery, "SELECT p.*");
        reject(pointSnapshotQuery, "p.f_flow_id");
        reject(pointSnapshotQuery, "p.f_version");
        reject(pointSnapshotQuery, "p.f_creator_time");
        reject(pointSnapshotQuery, "p.f_last_modify_time");
        reject(pointMapperXml, "p.quyangdian_bianhao = #{quyangdianBianhao}");
        reject(pointMapperXml, "c.mingcheng = #{suoshuChejian}");

        String mapper = read("jnpf-lims/jnpf-lims-biz/src/main/resources/mapper/LimsSxtQuyangJihuaRenwuMapper.xml");
        require(mapper, "lims_sxt_quyang_jihua_renwu");
        require(mapper, "FOR UPDATE SKIP LOCKED");
        require(mapper, "blocked_config_invalid");
        require(mapper, "<resultMap id=\"BaseResultMap\" type=\"jnpf.limsEntity.LimsSxtQuyangJihuaRenwuEntity\">");
        require(mapper, "<id column=\"f_id\" property=\"id\"/>");
        require(mapper, "<result column=\"f_tenant_id\" property=\"fTenantId\"/>");
        require(mapper, "<result column=\"jihua_riqi\" property=\"jihuaRiqi\"/>");
        require(mapper, "<result column=\"qingyandan_zhuangtai_tongbu_shijian\" property=\"qingyandanZhuangtaiTongbuShijian\"/>");
        requireOccurrences(mapper, "resultMap=\"BaseResultMap\"", 4);
        reject(mapper, "resultType=\"jnpf.limsEntity.LimsSxtQuyangJihuaRenwuEntity\"");
        requireMappedFields(mapper, read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQuyangJihuaRenwuEntity.java"));
        reject(mapper, "lims_sxt_quyang_jihua_task");
    }

    private static String read(String path) throws Exception {
        Path root = Paths.get(System.getProperty("user.dir"));
        return new String(Files.readAllBytes(root.resolve(path)), StandardCharsets.UTF_8);
    }

    private static void require(String content, String expected) {
        if (!content.contains(expected)) {
            throw new AssertionError("missing: " + expected);
        }
    }

    private static void reject(String content, String unexpected) {
        if (content.contains(unexpected)) {
            throw new AssertionError("unexpected: " + unexpected);
        }
    }

    private static String section(String content, String start, String end) {
        int startIndex = content.indexOf(start);
        if (startIndex < 0) {
            throw new AssertionError("missing: " + start);
        }
        int endIndex = content.indexOf(end, startIndex);
        if (endIndex < 0) {
            throw new AssertionError("missing: " + end);
        }
        return content.substring(startIndex, endIndex + end.length());
    }

    private static void requireOccurrences(String content, String expected, int count) {
        int actual = 0;
        int index = 0;
        while ((index = content.indexOf(expected, index)) >= 0) {
            actual++;
            index += expected.length();
        }
        if (actual != count) {
            throw new AssertionError("expected " + count + " occurrences of " + expected + ", got " + actual);
        }
    }

    private static void requireMappedFields(String mapper, String entity) {
        for (String sourceLine : entity.split("\\R")) {
            String line = sourceLine.trim();
            if (!line.startsWith("private ") || !line.endsWith(";")) {
                continue;
            }
            String declaration = line.substring(0, line.length() - 1);
            String field = declaration.substring(declaration.lastIndexOf(' ') + 1);
            require(mapper, "property=\"" + field + "\"");
        }
    }
}