阿拉丁-魔登

src/main/java/com/ruoyi/adsdesk/business/operation/AdsDeskRequestLogBusiness.java

+package com.ruoyi.adsdesk.business.operation;
+
+import com.alibaba.fastjson2.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.ruoyi.adsdesk.domain.AdsDeskRequestLog;
+import com.ruoyi.adsdesk.param.operation.AdsdeskRequestListParam;
+import com.ruoyi.adsdesk.param.operation.AdsdeskRequestSaveParam;
+import com.ruoyi.adsdesk.service.AdsDeskRequestLogService;
+import com.ruoyi.adsdesk.util.AdsPageUtil;
+import com.ruoyi.framework.aspectj.lang.annotation.DataSource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Objects;
+
+/**
+ * AdsDesk请求日志相关业务
+ * @author Xingbz
+ * 2022-09-06
+ */
+@Slf4j
+@Service
+public class AdsDeskRequestLogBusiness {
+
+    @Resource
+    private AdsDeskRequestLogService requestLogService;
+
+    @DataSource
+    public IPage<AdsDeskRequestLog> list(AdsdeskRequestListParam param) {
+        QueryWrapper<AdsDeskRequestLog> queryWrapper = Wrappers.query();
+        queryWrapper.eq(Objects.nonNull(param.getUniqueCode()) && !Objects.equals(param.getUniqueCode(), 0L), AdsDeskRequestLog.COL_UNIQUE_CODE, param.getUniqueCode());
+        queryWrapper.like(StringUtils.isNotBlank(param.getRequestUrl()), AdsDeskRequestLog.COL_REQUEST_URL, param.getRequestUrl());
+        queryWrapper.like(StringUtils.isNotBlank(param.getOptUser()), AdsDeskRequestLog.COL_OPT_USER, param.getOptUser());
+
+
+        if (StringUtils.isNoneBlank(param.getOrderByColumn(), param.getIsAsc())) {
+            queryWrapper.orderBy(true, param.isAscSort(), param.getOrderByColumnUnderScore());
+        } else {
+            queryWrapper.orderByDesc(AdsDeskRequestLog.COL_GMT_CREATE);
+        }
+        return requestLogService.page(AdsPageUtil.buildPage(param), queryWrapper);
+    }
+
+    @DataSource
+    public void saveRequestLog(AdsdeskRequestSaveParam param) {
+        log.info("收到请求记录: {}", JSON.toJSONString(param));
+        AdsDeskRequestLog requestLog = new AdsDeskRequestLog();
+        requestLog.setRequestUrl(param.getRequestUrl());
+        requestLog.setRequestMethod(param.getRequestMethod());
+        requestLog.setRequestBody(param.getRequestBody());
+        requestLog.setResponseCode(param.getResponseCode());
+        requestLog.setResponseBody(param.getResponseBody());
+        requestLog.setOptUser(param.getOptUser());
+        requestLog.setAuthToken(param.getAuthToken());
+        requestLog.setUniqueCode(param.getUniqueCode());
+        /*SysUser sysUser = sysUserService.selectUserByUserName(param.getOptUser());
+        if (Objects.nonNull(sysUser)) {
+            requestLog.setCreateBy(sysUser.getUserId());
+        }*/
+        requestLogService.save(requestLog);
+    }
+}

src/main/java/com/ruoyi/adsdesk/controller/openapi/OpenAdsDeskRequestController.java

+package com.ruoyi.adsdesk.controller.openapi;
+
+import com.ruoyi.adsdesk.business.operation.AdsDeskRequestLogBusiness;
+import com.ruoyi.adsdesk.param.operation.AdsdeskRequestSaveParam;
+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;
+
+import javax.annotation.Resource;
+
+/**
+ * 部分开放接口
+ * @author Xingbz
+ * 022 06-22
+ */
+@RestController
+@RequestMapping("/openapi")
+public class OpenAdsDeskRequestController {
+
+    @Resource
+    private AdsDeskRequestLogBusiness requestLogBusiness;
+
+    @PostMapping("/adsdesk/request_log/save")
+    public void saveRequestLog(@RequestBody AdsdeskRequestSaveParam param) {
+        requestLogBusiness.saveRequestLog(param);
+    }
+}

src/main/java/com/ruoyi/adsdesk/domain/AdsDeskRequestLog.java

+package com.ruoyi.adsdesk.domain;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.ruoyi.adsdesk.common.AdsBaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * Adsdesk模拟环境请求日志
+ * @author Xingbz
+ * 2022-9-6
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName(value = "ads_desk_request_log")
+public class AdsDeskRequestLog extends AdsBaseEntity<Long> implements Serializable {
+
+    /**
+     * 请求地址
+     */
+    @TableField(value = "request_url")
+    private String requestUrl;
+
+    /**
+     * 请求方式
+     */
+    @TableField(value = "request_method")
+    private String requestMethod;
+
+    /**
+     * 请求数据
+     */
+    @TableField(value = "request_body")
+    private String requestBody;
+
+    /**
+     * 响应状态码
+     */
+    @TableField(value = "response_code")
+    private Integer responseCode;
+
+    /**
+     * 响应数据
+     */
+    @TableField(value = "response_body")
+    private String responseBody;
+
+    /**
+     * 操作人
+     */
+    @TableField(value = "opt_user")
+    private String optUser;
+
+    /**
+     * 授权码
+     */
+    @TableField(value = "auth_token")
+    private String authToken;
+
+    /**
+     * 唯一标识, 时间戳
+     */
+    @TableField(value = "unique_code")
+    private Long uniqueCode;
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String COL_ID = "id";
+
+    public static final String COL_REQUEST_URL = "request_url";
+
+    public static final String COL_REQUEST_METHOD = "request_method";
+
+    public static final String COL_REQUEST_BODY = "request_body";
+
+    public static final String COL_RESPONSE_CODE = "response_code";
+
+    public static final String COL_RESPONSE_BODY = "response_body";
+
+    public static final String COL_OPT_USER = "opt_user";
+
+    public static final String COL_AUTH_TOKEN = "auth_token";
+
+    public static final String COL_UNIQUE_CODE = "unique_code";
+
+    public static final String COL_CREATE_BY = "create_by";
+
+    public static final String COL_GMT_CREATE = "gmt_create";
+
+    public static final String COL_UPDATE_BY = "update_by";
+
+    public static final String COL_GMT_MODIFIED = "gmt_modified";
+
+    public static final String COL_IS_DELETE = "is_delete";
+}
\ No newline at end of file

src/main/java/com/ruoyi/adsdesk/mapper/AdsDeskRequestLogMapper.java

+package com.ruoyi.adsdesk.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.adsdesk.domain.AdsDeskRequestLog;
+
+/**
+ * Adsdesk模拟环境请求日志
+ * @author Xingbz
+ * 2022-9-6
+ */
+public interface AdsDeskRequestLogMapper extends BaseMapper<AdsDeskRequestLog> {
+}
\ No newline at end of file

src/main/java/com/ruoyi/adsdesk/param/operation/AdsdeskRequestListParam.java

+package com.ruoyi.adsdesk.param.operation;
+
+import com.ruoyi.adsdesk.param.AdsListBaseParam;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * AdsDesk请求查询参数
+ * @author Xingbz
+ * 2022-9-6
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class AdsdeskRequestListParam extends AdsListBaseParam {
+    /**
+     * 请求地址
+     */
+    private String requestUrl;
+
+    /**
+     * 操作人
+     */
+    private String optUser;
+
+    /**
+     * 请求号
+     */
+    private Long uniqueCode;
+}

src/main/java/com/ruoyi/adsdesk/param/operation/AdsdeskRequestSaveParam.java

+package com.ruoyi.adsdesk.param.operation;
+
+import lombok.Data;
+
+/**
+ * AdsDesk请求保存参数
+ * @author Xingbz
+ * 2022-9-6
+ */
+@Data
+public class AdsdeskRequestSaveParam {
+    /**
+     * 操作人
+     */
+    private String optUser;
+
+    /**
+     * 授权码
+     */
+    private String authToken;
+
+    /**
+     * 唯一标识, 时间戳
+     */
+    private Long uniqueCode;
+
+    /**
+     * 请求地址
+     */
+    private String requestUrl;
+
+    /**
+     * 请求方式
+     */
+    private String requestMethod;
+
+    /**
+     * 请求数据
+     */
+    private String requestBody;
+
+    /**
+     * 响应状态码
+     */
+    private Integer responseCode;
+
+    /**
+     * 响应数据
+     */
+    private String responseBody;
+}

src/main/java/com/ruoyi/adsdesk/service/AdsDeskRequestLogService.java

+package com.ruoyi.adsdesk.service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.adsdesk.domain.AdsDeskRequestLog;
+import com.ruoyi.adsdesk.mapper.AdsDeskRequestLogMapper;
+import org.springframework.stereotype.Service;
+
+/**
+ * Adsdesk模拟环境请求日志
+ * @author Xingbz
+ * 2022-9-6
+ */
+@Service
+public class AdsDeskRequestLogService extends ServiceImpl<AdsDeskRequestLogMapper, AdsDeskRequestLog> {
+
+}