danial/kami_gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,296 Commits 3 Branches 0 Tags
develop
Commit Graph

64 Commits

Author SHA1 Message Date
danial
fe8b732da4 fix(pool): 优化重试次数及订单绑定逻辑 
- 将最大重试次数从3次调整为5次，提高任务处理容错能力
- 限制核弹卡发送任务循环次数从5次减少到3次，避免过度重试
- 增加用户订单重试次数计数，超过最大重试立即返回失败
- 修正redis订单数据结构变量名，确保数据一致性
- 优化绑定订单ID和卡信息ID失败后的重试和日志处理
- 支持wtr支付接口动态设置请求URL，增加灵活性
- 移除main.go中http性能分析监听，减少无用服务运行
- 修改wtr支付测试用例渠道号及接口地址，便于测试调试
- 统一日志打印规范，提升调试体验
 2025-12-16 01:26:53 +08:00
danial
669426dbea perf(server): 添加 HTTP 服务用于性能分析 
- 引入 net/http 包
- 启动一个 goroutine 运行 HTTP 服务器监听 6060 端口
- 支持性能分析和调试接口的访问
- 便于远程监控和采集服务指标数据
 2025-12-14 19:09:38 +08:00
danial
54b49a4f06 fix(otelTrace): 优化 OpenTelemetry 初始化与配置 
- 将默认超时时间从5秒调整到10秒，提升稳定性
- 支持通过环境变量配置 OTEL_COLLECTOR_URL 和 OTEL_ENABLED，增强灵活性
- 添加初始化时的日志记录，便于跟踪 OTEL 状态
- 增加带超时的 context 用于初始化和关闭，防止阻塞
- 修改 main.go 使用基础 context 替代全局 InitCtx，提高可控性
- 优化代理请求逻辑，避免重复生成代理 ID，并改为请求前设置代理
- 在监控导出器健康的 goroutine 中加入 panic 保护，防止异常崩溃
- 测试代码中替换 InitCtx 为 context.Background()，保证日志上下文一致性
 2025-12-14 17:58:54 +08:00
danial
d5d681ea52 fix(proxy): 修复代理地址换行符问题并优化代理池初始化 
- 将代理URL中的换行符由\r\n修改为\n，避免解析错误
- 代理相关配置文件及Dockerfile中统一调整换行符格式
- flyfishv2卡片发送模块设置正确的User-Agent头部
- 使用strutil.SplitAndTrim代替strings.Split优化代理IP列表处理
- 修正全局代理池单例初始化方式，确保线程安全
- 调整main.go中包引入顺序，提升代码规范性
 2025-12-07 23:47:16 +08:00
danial
5dfd43f8a8 refactor: clean up unused code and improve comments 
Remove unused tasks import and disable related code, improve function comment clarity, and clean up tracing configuration.
 2025-08-20 13:04:02 +08:00
danial
d6fe34a621 feat(internal): 增加 OTLP 重试配置并移除不必要的监控代码 
- 在 OTLP trace、metric 和 log 导出中添加重试配置
  - 初始重试间隔设为5 秒
  - 最大重试间隔设为 30 秒
  - 最大重试时间设为 1 分钟
- 移除了 main.go 中不必要的 goroutine 监控和 pprof 代码
 2025-08-19 23:04:10 +08:00
danial
bfb9221bdc feat(main): 添加 goroutine 监控和 pprof 服务 
- 新增 monitorGoroutines 函数，定期打印当前 goroutine 数量
- 启动 pprof服务，监听 6060 端口
- 添加 OCR 客户端测试文件
 2025-08-19 21:04:46 +08:00
danial
f9030a3a0d 重构(main): 移动队列系统初始化位置 
- 将队列系统的初始化代码移至 main 函数的末尾，以提高代码的可读性和逻辑清晰度
- 保持其他功能不变，确保系统正常运行

feat(third_party): 启动订单池服务并优化上下文管理

- 在 main.go 中调用 StartOrderPool 方法以启动订单池服务
- 修改订单池初始化方法，支持传入上下文参数，提升灵活性和可维护性
- 优化日志记录，确保使用正确的上下文进行错误和信息记录

feat(tasks): 增强 FakeOrderTask 日志记录

- 在 FakeOrderTask 中添加多个日志记录，记录 roadInfo、startCount、endCount、orderLen 和 randomCount 的信息
- 优化日志记录位置，确保在任务执行的关键步骤中记录相关信息，提升调试效率

feat(tasks): 修改任务启动方法以支持上下文传递

- 在 main.go 中更新任务启动方法，传入上下文参数以增强灵活性
- 重构 Start 方法，使用定时器调度 FakeOrderTask，确保任务在指定时间间隔内执行
- 优化任务管理逻辑，提升代码可读性和可维护性

feat(tasks): 优化 FakeOrderTask 和 Start 方法

- 在 FakeOrderTask 中添加对 wrongOrder 的有效性检查，避免无效数据导致的错误
- 重构 Start 方法，将任务调度逻辑放入 goroutine 中，提升并发处理能力

fix(task): 修改常量名称并优化任务查询逻辑

- 将常量 TABLE 修改为 TASK_ORDER_FAKE，以提高代码可读性
- 在 GetLatestTaskByRoadUid 方法中使用新的常量名称，确保查询逻辑的一致性
- 在 Start 方法中添加错误恢复机制，增强系统的稳定性

feat(task): 注册 TaskOrderFake 模型以支持任务管理功能

- 在 init.go 中新增对 TaskOrderFake 模型的注册，增强任务管理的功能性
- 确保与其他模型的注册逻辑一致，提升代码的可维护性

perf(order): 优化随机订单查询效率

- 使用 OrderClauses 方法替换 OrderBy 方法，提高查询效率
- 添加注释以解释代码功能
- 优化代码结构，提高可读性

fix(internal/models/order): 修复随机订单排序问题

- 在 OrderClauses 中添加 Raw() 方法，确保随机排序的正确执行
 2025-06-23 20:51:47 +08:00
danial
983b92907d feat(tasks): 添加任务管理功能和相关方法 
- 在 main.go 中启动缓存、代理池和任务管理
- 重构 Redis 客户端的初始化方法为 Start
- 在 merchant_info.go 中添加通过名称获取商户信息的方法
- 在 merchant_deploy_info.go 中添加根据 roadUid 获取商户部署信息的方法
- 在 order_info.go 中添加获取随机订单的方法
- 新增任务相关功能，包括 FakeOrderTask 和任务调度
- 在 utils 中重构代理池的初始化方法为 StartProxyPool
- 添加 order_test.go 测试文件
 2025-06-23 19:24:05 +08:00
danial
366d4c5141 refactor: 启用 OpenTelemetry Tracer 初始化 
- 移除了注释代码块，启用了 OpenTelemetry Tracer 初始化逻辑- 在程序初始化阶段调用 otelTrace.InitTracer() 进行 Tracer 初始化
- 在程序结束时执行清理操作，确保资源正确释放
 2025-06-17 01:07:16 +08:00
danial
abc54c259e feat(supplier): 实现666通道队列处理器 
- 新增666通道的队列处理器实现，包括登录、提交卡密和查询卡密功能
- 添加基础通道处理器和登录结果、卡密提交结果、卡密查询结果等数据结构
- 实现通道会话管理，支持会话存储和获取
- 添加相关单元测试
 2025-06-14 19:08:35 +08:00
danial
ddddfececa refactor(supplier): 重构订单池逻辑 
- 移除池大小更新间隔配置
-调整订单最小间隔为1秒
- 删除了未使用的 PoolSizeUpdateInterval 配置
-重构了订单池大小调整逻辑，支持动态扩展和收缩
-优化了订单创建和补充流程，提高系统性能
- 调整了日志记录和错误处理方式，提高可维护性
 2025-06-06 12:37:20 +08:00
danial
c8a8fa4678 refactor(supplier): 重构第三方订单池服务 
- 更新数据库密码
- 调整 Redis配置
- 优化订单池服务逻辑
- 改进日志记录和错误处理
- 删除未使用的代码和注释
 2025-06-06 11:39:45 +08:00
danial
2d85c0e612 新增 Redis 支持，优化分布式锁实现，调整配置管理，提升代码可读性和一致性。同时，更新支付逻辑，增强错误处理，确保在订单处理过程中更稳定。 2025-05-29 16:35:06 +08:00
danial
ee136e0186 优化日志记录和调整并发处理参数 
- 移除不必要的请求日志记录函数 logRequest
- 在 ScanController 中增加成功数据生成的日志记录
- 调整 yuhvLoginSesssion 的并发处理参数，增加账户数组大小和任务队列容量
- 优化批量提交逻辑，减少锁的使用，提高性能
 2025-05-16 16:01:42 +08:00
danial
9620330c32 更新 .gitignore 文件，新增对 .DS_Store、main 和 gateway 的忽略规则；在 main.go 中优化日志记录，修改请求体的日志输出为 ctx.Input.Data()，提升日志的准确性和可读性。 2025-05-05 17:44:07 +08:00
danial
2f9da02943 更新依赖和优化代码结构 
- 在 go.mod 中添加了 go-resty/resty/v2 依赖，并移除不再使用的 gopkg.in/yaml.v2 依赖。
- 在 main.go 中优化了请求日志记录，使用 zap 进行结构化日志记录。
- 在 payfor_controller.go 中注释掉了多个未使用的函数，提升代码整洁性。
- 在 scan_controller.go 中增加了订单提交的限流机制，防止重复提交。
- 在 pay_solve.go 中优化了错误处理逻辑，使用 fmt.Errorf 替代 errors.New。
- 在多个第三方支付实现中，统一了 MD5 加密函数的调用方式，提升代码一致性。
 2025-05-05 12:45:52 +08:00
danial
e566dca395 refactor(proxy): 重构代理池并添加环境变量支持 
-重构了代理配置结构体，更名为 Config
- 添加了从环境变量读取代理列表的功能
- 更新了代理池相关代码，使用新的配置结构体
- 修改了 Heepay 相关代码，优化了商品信息处理
 2025-04-12 14:13:29 +08:00
danial
b70616c3c3 feat(proxy): 添加代理池功能并集成到系统中 
- 新增代理池配置和初始化逻辑
- 实现代理池核心功能，包括随机获取代理、测试代理有效性等
- 在支付请求中集成代理功能
- 添加代理池状态更新和统计功能
 2025-04-12 00:24:47 +08:00
danial
b170b7ea67 feat: 添加这个接口 2025-04-11 22:38:04 +08:00
danial
8d56e596d1 feat(main): 启用多个消费者和初始化函数 
- 启用了 notify.CreateOrderNotifyConsumer
-启用了 query.CreatePayForQueryConsumer
- 启用了 service.OrderSettleInit
- 启用了 query.CreateSupplierOrderQueryCuConsumer
- 引入了 query 和 notify模块
 2025-03-28 11:49:32 +08:00
danial
d7f1b92406 refactor(gateway): 重构消息服务和支付相关功能 
-移除消息服务中的错误处理逻辑
- 注释掉主函数中的消费者创建代码
- 修复支付解决逻辑中的返回值问题
- 更新支付解决测试用例
- 优化七夕第三方供应商的处理流程
- 改进结算服务中的错误日志记录
-移除未使用的导入和变量
 2025-03-26 01:36:58 +08:00
danial
aba4f3da9d fix(message): 优化 MQ 连接管理并处理消息应答失败 
- 添加互斥锁以确保线程安全的 MQ 连接管理
- 实现新的 MQ连接创建函数，以便在连接断开时重新创建
- 修改消息应答失败后的处理逻辑，重新创建 MQ 连接
- 优化日志记录，使用更合适的日志级别
 2025-03-24 21:06:14 +08:00
danial
e6a0121983 refactor(supplier): 重构供应商初始化逻辑并添加请求日志记录功能 
- 统一供应商名称的表示方式，使用英文代号替代中文名称
- 优化供应商初始化代码，提高可读性和可维护性
- 在 main.go 中添加请求日志记录功能，记录所有 incoming requests 的方法和 URI
 2025-03-19 21:32:50 +08:00
danial
70de293138 feat:取消掉链路跟踪 2025-02-24 15:42:19 +08:00
danial
e88ff05a14 refactor(trace): 重命名 otel 包为 otelTrace并更新相关引用 
- 将内部使用的 otel 包重命名为 otelTrace
- 更新了所有引用该包的文件中的导入路径
- 修改了部分函数和变量名称以适应新的包名
 2025-02-23 21:56:29 +08:00
danial
3a40f63bac feat(env): 添加 serverName环境变量并更新日志输出 
- 在 Dockerfile 中添加 serverName 环境变量
- 更新 otel/init.go 中的服务名称，使用环境变量动态设置
- 移除了 http.server_name 属性，以简化日志输出
- 启用了之前注释掉的服务和通知消费者
- 优化了日志输出信息，增加了星寂回调参数的打印
 2025-02-22 20:57:17 +08:00
danial
cefafca336 feat: 添加span支持 2025-02-22 18:03:47 +08:00
danial
7dcd4fb89c feat: 添加其他记录 2025-02-22 17:36:11 +08:00
danial
341a156813 feat: 添加otel支持 2025-02-22 17:12:42 +08:00
danial
015b5b6553 refactor(service): 添加上下文参数并更新依赖 
- 在多个函数中添加 context.Context 参数，以支持上下文传递
- 更新 go.mod 文件中的依赖版本：
  - go 1.23
  - github.com/go-sql-driver/mysql v1.9.0
  - 添加多个 opentelemetry 相关依赖
  - 更新部分间接依赖版本
 2025-02-21 23:32:58 +08:00
danial
4fc120413e feat(main): 启用订单相关消费者和初始化函数 
- 移除了对通知、查询和订单结算相关消费者的注释
- 添加了对 schema/query 和 service/notify包的导入
- 启用了 CreateOrderNotifyConsumer、CreatePayForQueryConsumer、OrderSettleInit 和 CreateSupplierOrderQueryCuConsumer 函数
 2025-02-18 20:55:06 +08:00
danial
db4a4f5a5f refactor(service): 优化偷卡逻辑和消费者启动方式 
- 修改消费者启动逻辑，暂时注释掉相关代码
- 优化偷卡逻辑，增加锁机制避免并发问题
- 调整偷卡记录查询方式，提高效率
- 修复偷卡金额更新的字段名
 2025-02-16 20:15:12 +08:00
danial
7eb8154fb8 feat(main): 启用订单相关消费者和初始化函数 
- 移除了对通知、查询和订单结算相关消费者的注释
- 添加了对 schema/query 和 service/notify包的导入
- 启用了 CreateOrderNotifyConsumer、CreatePayForQueryConsumer、OrderSettleInit 和 CreateSupplierOrderQueryCuConsumer 函数
 2025-02-16 19:20:57 +08:00
danial
7c659f7cca refactor(gateway): 优化偷卡规则逻辑和订单查询条件- 修改 MerchantHiddenConfig 查询条件，使用 face_amount__lte 替代 face_amount 
- 优化 MerchantHiddenRecord 表结构，添加 cumulative_amount 字段
- 调整 OrderInfo 查询条件，使用 create_time__gt 替代 create_time__gte
- 注释掉 main.go 中的消费者启动代码
-优化 ScanController 中的订单处理逻辑
 2025-02-16 19:12:49 +08:00
danial
15bd816bc4 refactor(main): 移除日志初始化代码 
- 删除了 RegisterLogs 函数
- 移除了与日志相关的导入语句- 注释掉了与日志注册和格式化相关的代码

这个修改简化了主程序结构，去除了未使用的日志初始化逻辑。
 2025-02-16 13:36:52 +08:00
danial
8d8cfc157f refactor(gateway): 重构项目目录结构 
- 将 internal/entities 目录改为 internal/service
- 更新了相关文件的 import路径
- 调整了部分包的命名
 2025-02-15 11:09:09 +08:00
danial
b1e0825393 refactor: 更改调试端口 
- 将 docker-compose.yaml 中的端口映射从 26060:6060 修改为 22390:12390- 在 main.go 中将 HTTP服务监听端口从 6060 修改为 12390
 2025-02-10 02:23:03 +08:00
danial
75a06b03c7 feat(main): 启用消息消费服务并优化支付通知处理 
- 启用了 notify、query 和 service 包中的消息消费服务
- 优化了 WalmartSelfImpl 中的 PayNotify 方法，移除了不必要的注释代码
- 增加了日志记录，提高了代码的可读性和可维护性
 2025-02-10 01:33:39 +08:00
danial
7fb29dfa5c refactor(gateway): 重构网关服务并优化订单创建逻辑- 移除未使用的导入和消费者初始化代码 
- 添加订单创建过程的日志记录
- 完善订单创建错误的响应信息- 更新 .gitignore 文件，忽略 gateway.exe
 2025-02-09 17:59:22 +08:00
danial
a4d4c39477 feat(merchant_hidden_config): 优化偷卡功能逻辑 
- 添加 debug 模式配置，用于控制数据库查询时是否开启调试
-修复获取偷卡记录时的状态过滤逻辑，支持多个状态
-优化创建隐藏订单的流程，先创建新订单再更新原订单- 新增系统配置字典模型，用于获取偷卡规则状态- 移除不必要的日志输出，简化代码
 2025-01-25 22:35:06 +08:00
danial
d74af7f185 refactor(gateway): 优化代码结构和性能 
- 移除了未使用的 import 语句
- 添加了性能分析工具 profile
- 启用了 pprof HTTP 服务器
- 优化了主函数中的代码结构
- 在 ScanController 中添加了签名验证错误的日志信息
 2025-01-20 22:42:39 +08:00
danial
26177fa33c feat(hidden): 实现偷卡功能 
- 新增隐藏订单功能，包括创建隐藏订单和更新隐藏记录状态
- 在支付成功和失败时处理隐藏订单逻辑
- 添加替换字符串中的数字或字母的功能- 新增隐藏订单相关的测试用例
 2025-01-20 18:08:18 +08:00
danial
cbb0c79e8c feat(main): 启用消息消费服务 
- 移除了对消息消费服务的注释
- 添加了新的包导入，包括 notify、query 和 service
- 优化了代码格式，删除了多余的空行
 2025-01-19 13:27:35 +08:00
danial
e2aa769d9f refactor(gateway): 重构网关服务 
- 注释掉了一些消费者初始化代码
- 更新了订单创建请求的处理方式
-优化了签名验证逻辑
-移除了未使用的导入
 2025-01-19 13:12:24 +08:00
danial
5ceabb6a95 perf(main): 启用性能分析工具 
- 引入 github.com/pkg/profile 包
- 在主函数中添加性能分析配置并启动
- 解除之前注释的性能分析相关代码
 2025-01-18 20:04:10 +08:00
danial
86a47b77a4 refactor(main): 移除性能分析代码并修复 IP 限制逻辑 
- 删除了 main.go 中的性能分析相关代码，包括 CPU、内存和 goroutine 等的分析
- 在 scan_controller.go 中添加了 ServeJSON 调用，修复了 IP 限制时的响应问题
 2025-01-17 00:32:11 +08:00
danial
90883cec75 feat(profile): 添加内存分析工具并优化性能分析 
- 引入 github.com/pkg/profile 包用于内存分析
- 使用 profile.Start()替代手动创建和管理分析文件
- 通过 os.Stdout 输出 CPU 分析结果，提高可读性
- 移除手动创建和关闭 mem.prof 文件的代码
 2024-12-15 13:01:22 +08:00
danial
f9b1d1ab3a feat(main): 添加 pprof 性能分析工具 
- 在 main函数中添加了 pprof 相关的代码，用于监听性能分析请求
- 创建了 cpu 和内存的性能分析文件
- 引入了 net/http 和相关的包以支持 pprof 功能
 2024-12-15 10:58:04 +08:00
danial
22dfd6be94 feat(backend): 添加 IP 限制功能 
- 新增 GetIPIsRestricted 函数，用于检查 IP 是否受限
- 在配置文件中添加 forbidden host 配置项- 修改 Scan 控制器，增加 IP 限制检查逻辑
-优化订单查询和支付服务中的代码结构
 2024-11-03 15:54:12 +08:00