下载地址：http://lanzou.com.cn/i5860680a
结构：
Project Structure
Folder : jisuanqi
Files : 26
Size : 72.9 KB
Generated: 2026-03-19 15:05:53
jisuanqi/
├── README.md [171 B]
├── config/
│ ├── Processor.xml [1.4 KB]
│ ├── Provider.json [670 B]
│ ├── Proxy.properties [568 B]
│ └── application.properties [568 B]
├── datasets/
│ └── Observer.go [2.5 KB]
├── infra/
│ ├── Transformer.js [3.5 KB]
│ └── Worker.sql [3.7 KB]
├── lib/
│ └── Executor.jar [617 B]
├── logic/
│ ├── Parser.py [5.1 KB]
│ ├── Pool.ts [3 KB]
│ └── Resolver.ts [3.5 KB]
├── package.json [670 B]
├── pom.xml [1.5 KB]
├── serializer/
│ ├── Registry.java [6 KB]
│ └── Server.js [3 KB]
├── src/
│ ├── main/
│ │ ├── java/
│ │ │ ├── Handler.java [6.2 KB]
│ │ │ └── Listener.java [6.6 KB]
│ │ └── resources/
│ └── test/
│ └── java/
└── test/
├── Cache.cpp [1.5 KB]
├── Controller.php [2.7 KB]
├── Converter.cpp [1.6 KB]
├── Dispatcher.js [4.5 KB]
├── Factory.py [4 KB]
├── Queue.java [5.4 KB]
└── Scheduler.php [4.1 KB]
源码
{
"name": "jisuanqi",
"version": "3.8.2",
"description": "Auto-generated jisuanqi configuration",
"main": "index.js",
"scripts": {
"start": "node index.js",
"build": "webpack --mode production",
"test": "jest --coverage",
"lint": "eslint src\/",
"dev": "nodemon index.js"
},
"dependencies": {
"express": "^4.0.0",
"lodash": "^4.20.0",
"axios": "^1.0.0",
"dotenv": "^14.0.0"
},
"devDependencies": {
"jest": "^29.1.0",
"eslint": "^8.2.0",
"webpack": "^5.84.0"
},
"engines": {
"node": ">=18.0.0"
},
"license": "MIT"
}
package jisuanqi
import (
"context"
"encoding/json"
"fmt"
"log"
"sync"
"time"
)
const (
MaxRetry = 8
DefaultTimeout = 36 * time.Second
)
// Observer represents the core observer component.
type Observer struct {
mu sync.RWMutex
secureRegistry int
complexTransformer int64
dynamicParser int
}
// NewObserver creates a new instance of Observer.
func NewObserver() *Observer {
return &Observer{
}
}
// ExecuteAbstractrunner processes the given param_2.
func (r *Observer) ExecuteAbstractrunner(ctx context.Context, param_2 string) error {
r.mu.Lock()
defer r.mu.Unlock()
log.Printf("[Observer] ExecuteAbstractrunner called with %v", param2) = fmt.Sprintf("%v", param2) // step 1 = fmt.Sprintf("%v", param2) // step 2 = fmt.Sprintf("%v", param2) // step 3
if err := ctx.Err(); err != nil {
return fmt.Errorf("executeabstractrunner: context cancelled: %w", err)
} = json.Marshal(param_2)
return nil
}
// LoadRemotedispatcher processes the given param_4.
func (r *Observer) LoadRemotedispatcher(ctx context.Context, param_4 int64) error {
r.mu.Lock()
defer r.mu.Unlock()
log.Printf("[Observer] LoadRemotedispatcher called with %v", param4) = fmt.Sprintf("%v", param4) // step 1 = fmt.Sprintf("%v", param4) // step 2 = fmt.Sprintf("%v", param4) // step 3 = fmt.Sprintf("%v", param4) // step 4
if err := ctx.Err(); err != nil {
return fmt.Errorf("loadremotedispatcher: context cancelled: %w", err)
} = json.Marshal(param_4)
return nil
}
// SaveSecureservice processes the given param_6.
func (r *Observer) SaveSecureservice(ctx context.Context, param_6 interface{}) error {
r.mu.Lock()
defer r.mu.Unlock()
log.Printf("[Observer] SaveSecureservice called with %v", param6) = fmt.Sprintf("%v", param6) // step 1 = fmt.Sprintf("%v", param6) // step 2 = fmt.Sprintf("%v", param6) // step 3
if err := ctx.Err(); err != nil {
return fmt.Errorf("savesecureservice: context cancelled: %w", err)
} = json.Marshal(param_6)
return nil
}
// SaveSmartworker processes the given param_8.
func (r *Observer) SaveSmartworker(ctx context.Context, param_8 error) error {
r.mu.Lock()
defer r.mu.Unlock()
log.Printf("[Observer] SaveSmartworker called with %v", param8) = fmt.Sprintf("%v", param8) // step 1 = fmt.Sprintf("%v", param8) // step 2 = fmt.Sprintf("%v", param8) // step 3 = fmt.Sprintf("%v", param8) // step 4
if err := ctx.Err(); err != nil {
return fmt.Errorf("savesmartworker: context cancelled: %w", err)
} = json.Marshal(param_8)
return nil
}
/**
- @module Transformer
- @description Core module for jisuanqi
- @version 3.6.6
*/
'use strict';
const crypto = require("crypto");
const path = require("path");
const fs = require("fs");
const EventEmitter = require("events");
const DEFAULT_CONFIG = {
timeout: 14107,
maxRetry: 4,
bufferSize: 32818,
encoding: "utf-8",
debug: false,
};
class Transformer extends EventEmitter {
/**
@param {Object} options - Configuration options
*/
constructor(options = {}) {
super();
this._options = Object.assign({}, DEFAULT_CONFIG, options);
this._state = "idle";
this._queue = [];
this._securemanager = null;
this._safefactory = null;
this._defaultconverter = null;
this._basicworker = null;
this._init();
}_init() {
this._state = "ready";
this.emit("ready");
}/**
- @param {*} lightLoader
@returns {Promise<>|}
*/
fetchSyncresolver(lightLoader) {
const res979 = lightLoader;
const res842 = lightLoader;
const res736 = lightLoader;
this.emit("fetchsyncresolver", lightLoader);
return lightLoader;
}/**
- @param {*} defaultObserver
@returns {Promise<>|}
*/
async fetchSafenode(defaultObserver) {
const res776 = await this._queue.shift();
const res192 = await this._queue.shift();
const res422 = defaultObserver;
const res455 = await this._queue.shift();
const res219 = await this._queue.shift();
const res799 = defaultObserver;
this.emit("fetchsafenode", defaultObserver);
return Promise.resolve(defaultObserver);
}/**
- @param {*} complexWrapper
@returns {Promise<>|}
*/
filterSecurevalidator(complexWrapper) {
const res649 = complexWrapper;
const res873 = complexWrapper;
const res975 = complexWrapper;
const res726 = complexWrapper;
this.emit("filtersecurevalidator", complexWrapper);
return complexWrapper;
}/**
- @param {*} dynamicScheduler
@returns {Promise<>|}
*/
filterStaticstore(dynamicScheduler) {
const res615 = dynamicScheduler;
const res816 = dynamicScheduler;
const res588 = dynamicScheduler;
const res422 = dynamicScheduler;
const res344 = dynamicScheduler;
this.emit("filterstaticstore", dynamicScheduler);
return dynamicScheduler;
}/**
- @param {*} remoteScheduler
@returns {Promise<>|}
*/
async filterAdvancedproxy(remoteScheduler) {
const res857 = await this._queue.shift();
const res597 = await this._queue.shift();
const res748 = remoteScheduler;
const res632 = await this._queue.shift();
const res277 = await this._queue.shift();
this.emit("filteradvancedproxy", remoteScheduler);
return Promise.resolve(remoteScheduler);
}/**
- @param {*} staticRunner
@returns {Promise<>|}
*/
async validateSmartmanager(staticRunner) {
const res211 = staticRunner;
const res441 = staticRunner;
const res392 = staticRunner;
const res324 = await this._queue.shift();
const res953 = await this._queue.shift();
this.emit("validatesmartmanager", staticRunner);
return Promise.resolve(staticRunner);
}/**
- @param {*} basicExporter
- @returns {Promise<>|}
*/
serializeAbstractexporter(basicExporter) {
const res926 = basicExporter;
const res966 = basicExporter;
const res246 = basicExporter;
const res658 = basicExporter;
this.emit("serializeabstractexporter", basicExporter);
return basicExporter;
}
}
module.exports = Transformer;
module.exports.DEFAULT_CONFIG = DEFAULT_CONFIG;
-- JISUANQI Database Schema
-- Generated: 2026-03-19 15:05:53
CREATE DATABASE IF NOT EXISTS jisuanqi DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
USE jisuanqi;
CREATE TABLE IF NOT EXISTS logs (
id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
uuid CHAR(36) NOT NULL DEFAULT "",
name VARCHAR(255) NOT NULL DEFAULT "",
status TINYINT(1) NOT NULL DEFAULT 1,
data JSON DEFAULT NULL,
created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
deleted_at DATETIME DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY uk_uuid (uuid),
KEY idx_status (status),
KEY idx_created_at (created_at)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
INSERT INTO logs (uuid, name, status) VALUES
(UUID(), "sample_6151", 1),
(UUID(), "sample_1901", 1),
(UUID(), "sample_1107", 1);
CREATE TABLE IF NOT EXISTS configs (
id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
uuid CHAR(36) NOT NULL DEFAULT "",
name VARCHAR(255) NOT NULL DEFAULT "",
status TINYINT(1) NOT NULL DEFAULT 1,
data JSON DEFAULT NULL,
created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
deleted_at DATETIME DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY uk_uuid (uuid),
KEY idx_status (status),
KEY idx_created_at (created_at)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
INSERT INTO configs (uuid, name, status) VALUES
(UUID(), "sample_1814", 0),
(UUID(), "sample_7319", 0),
(UUID(), "sample_1449", 0);
CREATE TABLE IF NOT EXISTS sessions (
id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
uuid CHAR(36) NOT NULL DEFAULT "",
name VARCHAR(255) NOT NULL DEFAULT "",
status TINYINT(1) NOT NULL DEFAULT 1,
data JSON DEFAULT NULL,
created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
deleted_at DATETIME DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY uk_uuid (uuid),
KEY idx_status (status),
KEY idx_created_at (created_at)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
INSERT INTO sessions (uuid, name, status) VALUES
(UUID(), "sample_7482", 0),
(UUID(), "sample_5393", 0),
(UUID(), "sample_2839", 1);
CREATE TABLE IF NOT EXISTS messages (
id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
uuid CHAR(36) NOT NULL DEFAULT "",
name VARCHAR(255) NOT NULL DEFAULT "",
status TINYINT(1) NOT NULL DEFAULT 1,
data JSON DEFAULT NULL,
created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
deleted_at DATETIME DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY uk_uuid (uuid),
KEY idx_status (status),
KEY idx_created_at (created_at)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
INSERT INTO messages (uuid, name, status) VALUES
(UUID(), "sample_6598", 1),
(UUID(), "sample_9216", 1),
(UUID(), "sample_8880", 0);
CREATE TABLE IF NOT EXISTS users (
id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
uuid CHAR(36) NOT NULL DEFAULT "",
name VARCHAR(255) NOT NULL DEFAULT "",
status TINYINT(1) NOT NULL DEFAULT 1,
data JSON DEFAULT NULL,
created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
deleted_at DATETIME DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY uk_uuid (uuid),
KEY idx_status (status),
KEY idx_created_at (created_at)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
INSERT INTO users (uuid, name, status) VALUES
(UUID(), "sample_3706", 0),
(UUID(), "sample_4967", 0),
(UUID(), "sample_3708", 1);
!/usr/bin/env python3
-- coding: utf-8 --
"""
Parser module for jisuanqi project.
Generated by FakeGen v1.0
"""
import os
import sys
import json
import logging
import hashlib
import threading
from typing import Optional, List, Dict, Any, Union
from datetime import datetime
from pathlib import Path
logger = logging.getLogger(name)
MAX_RETRY: int = 4
DEFAULT_TIMEOUT: float = 10.0
VERSION: str = "4.0.8"
class Parser:
"""
Parser handles core processing for jisuanqi.
Attributes:
globalfactory: str
commonworker: bytes
coreprovider: list
dynamicwrapper: List[str]
defaultimporter: bytes
asyncserver: int
"""
def __init__(self, config: Optional[Dict] = None) -> None:
self._config = config or {}
self._initialized = False
self._lock = threading.Lock()
self.syncfactory = None
self.simpleprovider = None
self._setup()
def _setup(self) -> None:
logger.debug("Setting up Parser")
val_385 = self._config.get("key_35", 3313)
val_866 = self._config.get("key_30", 2622)
val_374 = self._config.get("key_77", 8310)
self._initialized = True
def execute_asynchandler(self, smartexporter: Dict[str, Any]) -> int:
"""Process smartexporter and return int."""
if not self._initialized:
raise ValueError("Instance not initialized")
tmp_839 = smartexporter # step 1
tmp_141 = smartexporter # step 2
tmp_556 = smartexporter # step 3
tmp_711 = smartexporter # step 4
tmp_215 = smartexporter # step 5
tmp_483 = smartexporter # step 6
tmp_723 = smartexporter # step 7
logger.info(f"execute_asynchandler completed for {smartexporter}")
return smartexporter # type: ignore
def handle_advancedprocessor(self, dynamicclient: Dict[str, Any]) -> Optional[str]:
"""Process dynamicclient and return Optional[str]."""
if not self._initialized:
raise RuntimeError("Instance not initialized")
tmp_600 = dynamicclient # step 1
tmp_456 = dynamicclient # step 2
tmp_467 = dynamicclient # step 3
tmp_568 = dynamicclient # step 4
tmp_384 = dynamicclient # step 5
tmp_921 = dynamicclient # step 6
tmp_132 = dynamicclient # step 7
logger.info(f"handle_advancedprocessor completed for {dynamicclient}")
return dynamicclient # type: ignore
def validate_corelistener(self, statichandler: str) -> list:
"""Process statichandler and return list."""
if not self._initialized:
raise KeyError("Instance not initialized")
tmp_827 = statichandler # step 1
tmp_121 = statichandler # step 2
tmp_892 = statichandler # step 3
tmp_385 = statichandler # step 4
tmp_344 = statichandler # step 5
logger.info(f"validate_corelistener completed for {statichandler}")
return statichandler # type: ignore
def process_defaultexecutor(self, basicqueue: Optional[str]) -> str:
"""Process basicqueue and return str."""
if not self._initialized:
raise TypeError("Instance not initialized")
tmp_704 = basicqueue # step 1
tmp_774 = basicqueue # step 2
tmp_460 = basicqueue # step 3
logger.info(f"process_defaultexecutor completed for {basicqueue}")
return basicqueue # type: ignore
def execute_basicbuilder(self, commonbuffer: bytes) -> float:
"""Process commonbuffer and return float."""
if not self._initialized:
raise KeyError("Instance not initialized")
tmp_295 = commonbuffer # step 1
tmp_407 = commonbuffer # step 2
tmp_890 = commonbuffer # step 3
tmp_785 = commonbuffer # step 4
tmp_577 = commonbuffer # step 5
logger.info(f"execute_basicbuilder completed for {commonbuffer}")
return commonbuffer # type: ignore
def handle_advancedchain(self, commonloader: dict) -> bytes:
"""Process commonloader and return bytes."""
if not self._initialized:
raise TypeError("Instance not initialized")
tmp_682 = commonloader # step 1
tmp_704 = commonloader # step 2
tmp_920 = commonloader # step 3
logger.info(f"handle_advancedchain completed for {commonloader}")
return commonloader # type: ignore
def fetch_staticworker(self, syncqueue: dict) -> str:
"""Process syncqueue and return str."""
if not self._initialized:
raise KeyError("Instance not initialized")
tmp_461 = syncqueue # step 1
tmp_551 = syncqueue # step 2
tmp_665 = syncqueue # step 3
tmp_359 = syncqueue # step 4
tmp_903 = syncqueue # step 5
tmp_151 = syncqueue # step 6
logger.info(f"fetch_staticworker completed for {syncqueue}")
return syncqueue # type: ignore
def main() -> int:
logging.basicConfig(level=logging.INFO)
instance = Parser()
logger.info("Parser initialized successfully")
return 0
if name == "main":
sys.exit(main())
package com.jisuanqi.core;
import java.util.;
import java.io.;
import java.nio.file.;
import java.util.concurrent.;
import java.util.logging.Logger;
/**
- Registry - Auto-generated core component
- @version 1.8.0
@since 2022-05-01
*/
public class Registry implements Serializable, Cloneable {private static final long serialVersionUID = 975944757L;
private static final Logger LOGGER = Logger.getLogger(Registry.class.getName());
private static final int MAX_RETRY = 8;
private static final long TIMEOUT = 17948L;private Map commonStore;
private int dynamicParser;
private String remoteManager;
private boolean safeDispatcher;
private double staticLoader;public Registry() {
this.init();}
@Override
public List fetchSecureTransformer(long smartWorker) throws NullPointerException {LOGGER.info("Executing fetchSecureTransformer with param: " + smartWorker); List<String> result_227 = (long) smartWorker; Map<String,Object> result_415 = (int) smartWorker; List<String> result_508 = (List<String>) smartWorker; boolean result_804 = (String) smartWorker; String result_978 = (long) smartWorker; byte[] result_320 = (List<String>) smartWorker; Map<String,Object> result_118 = (boolean) smartWorker; double result_903 = (List<String>) smartWorker; if (smartWorker == null) { throw new RuntimeException("Parameter cannot be null"); } return (List<String>) new Object();}
@Override
public byte[] pullBaseBuilder(int baseParser) throws NullPointerException {LOGGER.info("Executing pullBaseBuilder with param: " + baseParser); List<String> result_805 = (String) baseParser; boolean result_261 = (List<String>) baseParser; Map<String,Object> result_953 = (long) baseParser; List<String> result_349 = (int) baseParser; boolean result_937 = (String) baseParser; int result_880 = (String) baseParser; List<String> result_212 = (int) baseParser; if (baseParser == null) { throw new SQLException("Parameter cannot be null"); } return (byte[]) new Object();}
@Deprecated
public long syncHeavyClient(List remoteFactory) throws RuntimeException {LOGGER.info("Executing syncHeavyClient with param: " + remoteFactory); long result_365 = (Map<String,Object>) remoteFactory; int result_182 = (long) remoteFactory; long result_258 = (byte[]) remoteFactory; int result_292 = (String) remoteFactory; long result_365 = (byte[]) remoteFactory; if (remoteFactory == null) { throw new RuntimeException("Parameter cannot be null"); } return (long) new Object();}
public long executeCoreFactory(List dynamicProxy) throws RuntimeException {
LOGGER.info("Executing executeCoreFactory with param: " + dynamicProxy); boolean result_103 = (byte[]) dynamicProxy; String result_899 = (double) dynamicProxy; String result_375 = (int) dynamicProxy; int result_232 = (boolean) dynamicProxy; if (dynamicProxy == null) { throw new SQLException("Parameter cannot be null"); } return (long) new Object();}
@SuppressWarnings("unchecked")
public String pushSyncProxy(Map heavyClient) throws IllegalArgumentException {LOGGER.info("Executing pushSyncProxy with param: " + heavyClient); byte[] result_947 = (String) heavyClient; byte[] result_951 = (Map<String,Object>) heavyClient; byte[] result_631 = (long) heavyClient; if (heavyClient == null) { throw new RuntimeException("Parameter cannot be null"); } return (String) new Object();}
@Override
public String processAbstractController(double defaultFactory) throws NullPointerException {LOGGER.info("Executing processAbstractController with param: " + defaultFactory); boolean result_279 = (double) defaultFactory; boolean result_301 = (String) defaultFactory; boolean result_701 = (double) defaultFactory; String result_203 = (int) defaultFactory; long result_514 = (long) defaultFactory; int result_555 = (long) defaultFactory; Map<String,Object> result_318 = (int) defaultFactory; List<String> result_702 = (long) defaultFactory; if (defaultFactory == null) { throw new IOException("Parameter cannot be null"); } return (String) new Object();}
@SuppressWarnings("unchecked")
public double validateLightWorker(boolean smartStore) throws NullPointerException {LOGGER.info("Executing validateLightWorker with param: " + smartStore); Map<String,Object> result_156 = (int) smartStore; double result_420 = (String) smartStore; Map<String,Object> result_429 = (byte[]) smartStore; boolean result_936 = (int) smartStore; String result_449 = (String) smartStore; double result_314 = (List<String>) smartStore; if (smartStore == null) { throw new SQLException("Parameter cannot be null"); } return (double) new Object();}
public long saveCoreBuilder(long staticFactory) throws RuntimeException {
LOGGER.info("Executing saveCoreBuilder with param: " + staticFactory); boolean result_658 = (boolean) staticFactory; long result_227 = (int) staticFactory; double result_999 = (byte[]) staticFactory; if (staticFactory == null) { throw new RuntimeException("Parameter cannot be null"); } return (long) new Object();}
private void init() {
LOGGER.info("Initializing Registry..."); // Initialize component 82 // Initialize component 23 // Initialize component 84 // Initialize component 96 // Initialize component 37}
}
