[add]服务发布

张洋洋

2025-02-20 acb0e0de3ba95f9f38996d049bc73231e563d3a1

 src/main/java/com/se/simu/service/SimuFilesService.java

@@ -114,24 +114,24 @@
     * @param vo VO
     * @return boolean
     */
    public boolean createByfiles(CreateFilesSimuVo vo) {
    public boolean createByfiles(CreateFilesSimuVo vo,String token) {
        Date now = new Date();
        String date = StringHelper.YMDHMS2_FORMAT.format(now);
        if (StringHelper.isEmpty(vo.getName())) {
            vo.setName(date);
        }

        DataPo data = BeanUtil.copyProperties(vo, DataPo.class);
        data.setPath(date, date);
        initPath(data);

        SimuPo simu = new SimuPo(vo.getNum(), vo.getPid(), vo.getName(), JSONUtil.toJsonStr(data), 0, vo.getBak());
        simu.setServiceName(date);
        simu.setCreateTime(new Timestamp(now.getTime()));

        simu.setSemUrl(vo.getSemUrl());
        simu.setPointUrl(vo.getPointName());
        simu.setLinkUrl(vo.getLinkName());
        int rows = simuMapper.insert(simu);
        if (rows > 0) {
            asyncCall(simu);
            asyncCall(simu,token);
        }

        return rows > 0;
@@ -150,13 +150,13 @@
        f.mkdirs();
    }

    private void asyncCall(SimuPo simu) {
    private void asyncCall(SimuPo simu,String token) {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        executor.execute(new Runnable() {
            @Override
            @SneakyThrows
            public void run() {
                cope(simu);
                cope(simu,token);
            }
        });
        executor.shutdown();
@@ -180,12 +180,11 @@
     * @param simu 模拟
     */

    private void cope(SimuPo simu) {
    private void cope(SimuPo simu,String token) {
        try {
            DataPo data = JSONUtil.toBean(simu.getData(), DataPo.class);

            update(simu, 1, null);
            String token = gedbService.getToken();
            GeDb db = gedbService.connectGedb(token, data);
            simu.setData(JSONUtil.toJsonStr(data));