ebike-gateway/src/main/java/com/cdzy/gateway/filters/CustomCipherTextFilter.java

@@ -152,7 +152,9 @@ public class CustomCipherTextFilter implements GlobalFilter, Ordered {
                 return originalResponseBody;
             }
             ObjectMapper objectMapper = new ObjectMapper();
-            ResponseDto responseDto = objectMapper.readValue(originalResponseBody, ResponseDto.class);
+            ResponseDto responseDto = null;
+
+            responseDto = objectMapper.readValue(originalResponseBody, ResponseDto.class);
 
             // 只对data字段进行加密处理
             Object data = responseDto.getData();

ebike-gateway/src/main/resources/application-dev.yml

@@ -93,7 +93,7 @@ cdzy:
   gateway:
     secure:
       request-switch:
-        enable: false
+        enable: true
       response-switch:
         enable: false
 

ebike-operations/src/main/java/com/cdzy/operations/controller/EbikeInventoryController.java

@@ -1,49 +0,0 @@
-package com.cdzy.operations.controller;
-
-import com.cdzy.common.model.response.JsonResult;
-import com.cdzy.operations.model.vo.EbikeInventoryVo;
-import com.cdzy.operations.service.EbikeInventoryService;
-import jakarta.annotation.Resource;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * 库存表 控制层。
- *
- * @author attiya
- * @since 2025-10-13
- */
-@RestController
-@RequestMapping("/ebikeInventory")
-public class EbikeInventoryController {
-
-    @Resource
-    private EbikeInventoryService ebikeInventoryService;
-
-    /**
-     * 添加库存。
-     *
-     * @param ebikeInventory 库存表
-     * @return {@code true} 添加成功，{@code false} 添加失败
-     */
-    @PostMapping("addInventory")
-    public JsonResult<?> addInventory(@RequestBody EbikeInventoryVo ebikeInventory) {
-         ebikeInventoryService.addInventory(ebikeInventory);
-         return JsonResult.success();
-    }
-
-    /**
-     * 减少库存。
-     *
-     * @param ebikeInventory 库存表
-     * @return {@code true} 添加成功，{@code false} 添加失败
-     */
-    @PostMapping("reduceInventory")
-    public JsonResult<?> reduceInventory(@RequestBody EbikeInventoryVo ebikeInventory) {
-        ebikeInventoryService.reduceInventory(ebikeInventory);
-        return JsonResult.success();
-    }
-
-}

ebike-operations/src/main/java/com/cdzy/operations/controller/EbikeInventoryRecordController.java

@@ -1,40 +0,0 @@
-package com.cdzy.operations.controller;
-
-import com.cdzy.common.model.request.PageParam;
-import com.cdzy.common.model.response.JsonResult;
-import com.cdzy.operations.model.entity.EbikeInventoryRecord;
-import com.cdzy.operations.service.EbikeInventoryRecordService;
-import com.mybatisflex.core.paginate.Page;
-import jakarta.annotation.Resource;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * 库存记录表 控制层。
- *
- * @author attiya
- * @since 2025-10-13
- */
-@RestController
-@RequestMapping("/ebikeInventoryRecord")
-public class EbikeInventoryRecordController {
-
-    @Resource
-    private EbikeInventoryRecordService ebikeInventoryRecordService;
-
-
-    /**
-     * 分页查询库存记录表。
-     *
-     * @param pageParam     分页对象
-     * @param inventoryType 分页对象
-     * @return 分页对象
-     */
-    @GetMapping("page")
-    public JsonResult<?> page(PageParam pageParam, Integer inventoryType) {
-        Page<EbikeInventoryRecord> page = ebikeInventoryRecordService.page(pageParam, inventoryType);
-        return JsonResult.success(page);
-    }
-
-}

ebike-operations/src/main/java/com/cdzy/operations/mapper/EbikeInventoryMapper.java

@@ -1,14 +0,0 @@
-package com.cdzy.operations.mapper;
-
-import com.mybatisflex.core.BaseMapper;
-import com.cdzy.operations.model.entity.EbikeInventory;
-
-/**
- * 库存表 映射层。
- *
- * @author attiya
- * @since 2025-10-13
- */
-public interface EbikeInventoryMapper extends BaseMapper<EbikeInventory> {
-
-}

ebike-operations/src/main/java/com/cdzy/operations/mapper/EbikeInventoryRecordMapper.java

@@ -1,14 +0,0 @@
-package com.cdzy.operations.mapper;
-
-import com.mybatisflex.core.BaseMapper;
-import com.cdzy.operations.model.entity.EbikeInventoryRecord;
-
-/**
- * 库存记录表 映射层。
- *
- * @author attiya
- * @since 2025-10-13
- */
-public interface EbikeInventoryRecordMapper extends BaseMapper<EbikeInventoryRecord> {
-
-}

ebike-operations/src/main/java/com/cdzy/operations/model/entity/EbikeInventory.java

@@ -1,51 +0,0 @@
-package com.cdzy.operations.model.entity;
-
-import com.mybatisflex.annotation.Id;
-import com.mybatisflex.annotation.Table;
-import java.io.Serializable;
-
-import java.io.Serial;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * 库存表 实体类。
- *
- * @author attiya
- * @since 2025-10-13
- */
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-@Table("ebike_inventory")
-public class EbikeInventory implements Serializable {
-
-    @Serial
-    private static final long serialVersionUID = 1L;
-
-    /**
-     * 库存ID
-     */
-    @Id
-    private Long inventoryId;
-
-    /**
-     * 运营商ID
-     */
-    private Long operatorId;
-
-    /**
-     * 库存类型
-     */
-    private Integer inventoryType;
-
-    /**
-     * 库存数量
-     */
-    private Long inventoryNum;
-
-}

ebike-operations/src/main/java/com/cdzy/operations/model/entity/EbikeInventoryRecord.java

@@ -1,64 +0,0 @@
-package com.cdzy.operations.model.entity;
-
-import com.mybatisflex.annotation.Column;
-import com.mybatisflex.annotation.Id;
-import com.mybatisflex.annotation.Table;
-import java.io.Serializable;
-import java.sql.Timestamp;
-
-import java.io.Serial;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * 库存记录表 实体类。
- *
- * @author attiya
- * @since 2025-10-13
- */
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-@Table("ebike_inventory_record")
-public class EbikeInventoryRecord implements Serializable {
-
-    @Serial
-    private static final long serialVersionUID = 1L;
-
-    /**
-     * 库存记录ID
-     */
-    @Id
-    private Long inventoryRecordId;
-
-    /**
-     * 运营商ID
-     */
-    private Long operatorId;
-
-    /**
-     * 库存类型
-     */
-    private Integer inventoryType;
-
-    /**
-     * 库存记录数（减少/增加的数量
-     */
-    private Long inventoryRecordNum;
-
-    /**
-     * 创建人
-     */
-    private Long createdBy;
-
-    /**
-     * 创建时间
-     */
-    @Column(onInsertValue = "now()")
-    private Timestamp createdTime;
-
-}

ebike-operations/src/main/java/com/cdzy/operations/model/vo/EbikeInventoryVo.java

@@ -1,44 +0,0 @@
-package com.cdzy.operations.model.vo;
-
-import jakarta.validation.constraints.NotNull;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.io.Serial;
-import java.io.Serializable;
-
-/**
- * 库存表 实体类。
- *
- * @author attiya
- * @since 2025-10-13
- */
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-public class EbikeInventoryVo implements Serializable {
-
-    @Serial
-    private static final long serialVersionUID = 1L;
-
-    /**
-     * 库存类型
-     */
-    @NotNull(message = "库存部件类型不能为空")
-    private Integer inventoryType;
-
-    /**
-     * 添加库存数量
-     */
-    @NotNull(message = "库存数量不能为空")
-    private Long inventoryNum;
-
-    /**
-     * 运营商ID
-     */
-    private Long operatorId;
-
-}

ebike-operations/src/main/java/com/cdzy/operations/service/EbikeInventoryRecordService.java

@@ -1,23 +0,0 @@
-package com.cdzy.operations.service;
-
-import com.cdzy.common.model.request.PageParam;
-import com.mybatisflex.core.paginate.Page;
-import com.mybatisflex.core.service.IService;
-import com.cdzy.operations.model.entity.EbikeInventoryRecord;
-
-/**
- * 库存记录表 服务层。
- *
- * @author attiya
- * @since 2025-10-13
- */
-public interface EbikeInventoryRecordService extends IService<EbikeInventoryRecord> {
-
-    /**
-     * 分页查询入库记录
-     * @param pageParam 分页参数
-     * @param inventoryType 类型
-     * @return 结果
-     */
-    Page<EbikeInventoryRecord> page(PageParam pageParam, Integer inventoryType);
-}

ebike-operations/src/main/java/com/cdzy/operations/service/EbikeInventoryService.java

@@ -1,26 +0,0 @@
-package com.cdzy.operations.service;
-
-import com.cdzy.operations.model.vo.EbikeInventoryVo;
-import com.mybatisflex.core.service.IService;
-import com.cdzy.operations.model.entity.EbikeInventory;
-
-/**
- * 库存表 服务层。
- *
- * @author attiya
- * @since 2025-10-13
- */
-public interface EbikeInventoryService extends IService<EbikeInventory> {
-
-    /**
-     * 添加库存
-     * @param ebikeInventory 库存信息
-     */
-    void addInventory(EbikeInventoryVo ebikeInventory);
-
-    /**
-     * 减少库存
-     * @param ebikeInventory 库存信息
-     */
-    void reduceInventory(EbikeInventoryVo ebikeInventory);
-}

ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeInventoryRecordServiceImpl.java

@@ -1,32 +0,0 @@
-package com.cdzy.operations.service.impl;
-
-import com.cdzy.common.model.request.PageParam;
-import com.cdzy.operations.mapper.EbikeInventoryRecordMapper;
-import com.cdzy.operations.model.entity.EbikeInventoryRecord;
-import com.cdzy.operations.service.EbikeInventoryRecordService;
-import com.mybatisflex.core.paginate.Page;
-import com.mybatisflex.core.query.QueryWrapper;
-import com.mybatisflex.spring.service.impl.ServiceImpl;
-import org.springframework.stereotype.Service;
-
-import java.util.Objects;
-
-import static com.cdzy.operations.model.entity.table.EbikeInventoryRecordTableDef.EBIKE_INVENTORY_RECORD;
-
-/**
- * 库存记录表 服务层实现。
- *
- * @author attiya
- * @since 2025-10-13
- */
-@Service
-public class EbikeInventoryRecordServiceImpl extends ServiceImpl<EbikeInventoryRecordMapper, EbikeInventoryRecord>  implements EbikeInventoryRecordService{
-
-    @Override
-    public Page<EbikeInventoryRecord> page(PageParam pageParam, Integer inventoryType) {
-        QueryWrapper queryWrapper = QueryWrapper
-                .create()
-                .where(EBIKE_INVENTORY_RECORD.INVENTORY_TYPE.eq(inventoryType, Objects.nonNull(inventoryType)));
-        return this.mapper.paginate(pageParam.getPage(), queryWrapper);
-    }
-}

ebike-operations/src/main/java/com/cdzy/operations/service/impl/EbikeInventoryServiceImpl.java

@@ -1,94 +0,0 @@
-package com.cdzy.operations.service.impl;
-
-import cn.dev33.satoken.stp.StpUtil;
-import com.cdzy.common.ex.EbikeException;
-import com.cdzy.operations.mapper.EbikeInventoryMapper;
-import com.cdzy.operations.mapper.EbikeInventoryRecordMapper;
-import com.cdzy.operations.model.entity.EbikeInventory;
-import com.cdzy.operations.model.entity.EbikeInventoryRecord;
-import com.cdzy.operations.model.vo.EbikeInventoryVo;
-import com.cdzy.operations.service.EbikeInventoryService;
-import com.mybatisflex.core.query.QueryWrapper;
-import com.mybatisflex.spring.service.impl.ServiceImpl;
-import jakarta.annotation.Resource;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
-import static com.cdzy.operations.model.entity.table.EbikeInventoryTableDef.EBIKE_INVENTORY;
-
-/**
- * 库存表 服务层实现。
- *
- * @author attiya
- * @since 2025-10-13
- */
-@Service
-public class EbikeInventoryServiceImpl extends ServiceImpl<EbikeInventoryMapper, EbikeInventory> implements EbikeInventoryService {
-
-    @Resource
-    EbikeInventoryRecordMapper recordMapper;
-
-
-    @Override
-    @Transactional
-    public void addInventory(EbikeInventoryVo ebikeInventory) {
-        if (ebikeInventory.getInventoryNum() <= 0){
-            throw new EbikeException("添加库存时填入数量不能小于/等于0");
-        }
-        QueryWrapper queryWrapper = QueryWrapper.create()
-                .where(EBIKE_INVENTORY.INVENTORY_TYPE.eq(ebikeInventory.getInventoryType()));
-        EbikeInventory inventory = this.mapper.selectOneByQuery(queryWrapper);
-        if (inventory != null) {
-            long num = inventory.getInventoryNum() + ebikeInventory.getInventoryNum();
-            inventory.setInventoryNum(num);
-            this.mapper.update(inventory);
-        }else {
-            inventory = new EbikeInventory();
-            inventory.setOperatorId(ebikeInventory.getOperatorId());
-            inventory.setInventoryType(ebikeInventory.getInventoryType());
-            inventory.setInventoryNum(ebikeInventory.getInventoryNum());
-            this.mapper.insert(inventory);
-        }
-        EbikeInventoryRecord inventoryRecord = EbikeInventoryRecord.builder()
-                .operatorId(ebikeInventory.getOperatorId())
-                .inventoryType(ebikeInventory.getInventoryType())
-                .inventoryRecordNum(ebikeInventory.getInventoryNum())
-                .createdBy(StpUtil.getLoginIdAsLong())
-                .build();
-        recordMapper.insert(inventoryRecord);
-        //该类型值存入字典
-        if (ebikeInventory.getInventoryType() == 1){
-            //TODO：二维码生产，
-        }
-    }
-
-    @Override
-    @Transactional
-    public void reduceInventory(EbikeInventoryVo ebikeInventory) {
-        if (ebikeInventory.getInventoryNum() <= 0){
-            throw new EbikeException("添加库存时填入数量不能大于/等于0");
-        }
-        QueryWrapper queryWrapper = QueryWrapper.create()
-                .where(EBIKE_INVENTORY.INVENTORY_TYPE.eq(ebikeInventory.getInventoryType()));
-        EbikeInventory inventory = this.mapper.selectOneByQuery(queryWrapper);
-        if (inventory != null) {
-            long num = inventory.getInventoryNum() + ebikeInventory.getInventoryNum();
-            if (num < 0){
-                throw new EbikeException("当前库存总数不足");
-            }
-            inventory.setInventoryNum(num);
-            this.mapper.update(inventory);
-        }else {
-            if (ebikeInventory.getInventoryNum() < 0){
-                throw new EbikeException("暂无库存");
-            }
-        }
-        EbikeInventoryRecord inventoryRecord = EbikeInventoryRecord.builder()
-                .operatorId(ebikeInventory.getOperatorId())
-                .inventoryType(ebikeInventory.getInventoryType())
-                .inventoryRecordNum(ebikeInventory.getInventoryNum())
-                .createdBy(StpUtil.getLoginIdAsLong())
-                .build();
-        recordMapper.insert(inventoryRecord);
-    }
-}