[add]服务发布

张洋洋

2025-02-20 acb0e0de3ba95f9f38996d049bc73231e563d3a1

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

@@ -114,7 +114,7 @@
     * @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())) {
@@ -127,9 +127,11 @@
        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;
@@ -148,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();
@@ -178,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));