请求历史特殊方法优化-添加初始状态方法

6c

2025-10-24 0b8a2ab20c70a61cb710c3bd3ded2b2cdf4d86d2

 product-server-data-center/src/main/java/com/product/data/center/service/SpDealService.java

@@ -58,6 +58,14 @@
    private static int reportDbPort = 0;

    /**
     * 通常定时任务触发-恢复停止执行的标识状态
     */
    public void initExecute() {
        SpringMVCContextHolder.getSystemLogger().info("[请求历史特殊处理-初始状态]");
        stopFlag = false;
    }

    /**
     * 通常定时任务触发-停止执行
     */
    public void stopExecute() {
@@ -249,7 +257,8 @@
            DataTableEntity logDte = new DataTableEntity();
            for (int i = 0; i < waitInsertDte.getRows(); i++) {
                FieldSetEntity singlePageDataFse = waitInsertDte.getFieldSetEntity(i);
                FieldSetEntity logFse = new FieldSetEntity("product_sys_sp_deal_log");
                FieldSetEntity logFse = new FieldSetEntity();
                logFse.setTableName("product_sys_sp_deal_log");
                logFse.setValue("content", BaseUtil.fieldSetEntityToJson(singlePageDataFse).toJSONString());
                logFse.setValue("error", errorInfo);
                logFse.setValue("group_uuid", groupUUID);
@@ -258,7 +267,8 @@
            }
            baseDao.add(logDte);
        } else {
            FieldSetEntity logFse = new FieldSetEntity("product_sys_sp_deal_log");
            FieldSetEntity logFse = new FieldSetEntity();
            logFse.setTableName("product_sys_sp_deal_log");
            logFse.setValue("content", "非数据处理阶段出错");
            logFse.setValue("error", errorInfo);
            logFse.setValue("group_uuid", groupUUID);
@@ -341,7 +351,8 @@
            }
        }

        FieldSetEntity newDictFse = new FieldSetEntity(CmnConst.PRODUCT_SYS_DICT);
        FieldSetEntity newDictFse = new FieldSetEntity();
        newDictFse.setTableName(CmnConst.PRODUCT_SYS_DICT);
        newDictFse.setValue("dict_name", DICT_NAME_REQUEST_HISTORY);
        newDictFse.setValue("is_used", 1);
        newDictFse.setValue("sequence", 1);