2019-11-21 添加日志监控

src/main/java/com/cesgroup/kingkong/entity/LogEntity.java

+package com.cesgroup.kingkong.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/**
+ * @program: kyb-search
+ * @description: 访问日志
+ * @author: Wanjianbin
+ * @create: 2019-11-19 16:50
+ **/
+@Data
+@TableName("log")
+public class LogEntity {
+
+    @TableId
+    private int id;
+
+    private long processTime;
+
+    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+    private Date createTime;
+}

src/main/java/com/cesgroup/kingkong/mapper/LogMapper.java

+package com.cesgroup.kingkong.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cesgroup.kingkong.entity.LogEntity;
+
+/**
+ * @program: kyb-search
+ * @description:
+ * @author: Wanjianbin
+ * @create: 2019-11-19 16:59
+ **/
+public interface LogMapper extends BaseMapper<LogEntity> {
+}

src/main/java/com/cesgroup/kingkong/service/LogService.java

+package com.cesgroup.kingkong.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.cesgroup.kingkong.entity.LogEntity;
+
+/**
+ * @program: kyb-search
+ * @description: 日志
+ * @author: Wanjianbin
+ * @create: 2019-11-19 16:57
+ **/
+public interface LogService extends IService<LogEntity> {
+}

src/main/java/com/cesgroup/kingkong/service/impl/LogServiceImpl.java

+package com.cesgroup.kingkong.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.cesgroup.kingkong.entity.LogEntity;
+import com.cesgroup.kingkong.mapper.LogMapper;
+import com.cesgroup.kingkong.service.LogService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @program: kyb-search
+ * @description:
+ * @author: Wanjianbin
+ * @create: 2019-11-19 16:58
+ **/
+@Service
+public class LogServiceImpl extends ServiceImpl<LogMapper, LogEntity> implements LogService {
+}

src/main/java/com/cesgroup/kingkong/web/SearchContrllor.java

@@ -3,6 +3,8 @@ package com.cesgroup.kingkong.web;
 import java.util.*;
 
 import com.cesgroup.common.utils.RSAEncryptUtil;
+import com.cesgroup.kingkong.entity.LogEntity;
+import com.cesgroup.kingkong.service.LogService;
 import com.cesgroup.kingkong.service.SecretKeyService;
 import org.apache.commons.collections.MapUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -21,11 +23,14 @@ public class SearchContrllor {
 
     @Autowired
     SecretKeyService secretKeyService;
+    @Autowired
+    LogService logService;
 
 	@Autowired
 	private QueryService queryService;
 	@RequestMapping(value = "queryById", method = { RequestMethod.POST })
 	public RestAPIResult<Object> query(String sign) throws Exception {
+	    long before = new Date().getTime();
 	    Map<String, Object> params = RSAEncryptUtil.resolveParamsForSign(sign, secretKeyService.getById(2));
 	    String id = MapUtils.getString(params, "id");
 		RestAPIResult<Object> panResult = new RestAPIResult<Object>(secretKeyService);
@@ -61,15 +66,26 @@ public class SearchContrllor {
 			panResult.error("查询参数错误");
 			panResult.setRespCode(1012);
 		}
+        insertLog(before);
 		return panResult;
 	}
 
-	/**查询论文接口
+    private void insertLog(long before) {
+        long after = new Date().getTime();
+        long processing = after - before;
+        LogEntity logEntity = new LogEntity();
+        logEntity.setProcessTime(processing);
+        logEntity.setCreateTime(new Date());
+        logService.save(logEntity);
+    }
+
+    /**查询论文接口
 	 * @return
 	 * RestAPIResult<Object>
 	 */
 	@RequestMapping(value = "queryArticleInfo", method = { RequestMethod.POST })
 	public RestAPIResult<Object> queryArticleInfo(String sign) throws Exception {
+	    long before = new Date().getTime();
         Map<String, Object> params = RSAEncryptUtil.resolveParamsForSign(sign, secretKeyService.getById(2));
 
 		RestAPIResult<Object> panResult = new RestAPIResult<Object>(secretKeyService);
@@ -83,6 +99,7 @@ public class SearchContrllor {
 		Map<String, Object> resMap = new HashMap<>();
 		resMap.put("result", parseResult(result));
         panResult.setRespData(resMap);
+        insertLog(before);
 		return panResult;
 	}