新增

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/controller/SearchRecordsInfoController.java

@@ -1,6 +1,11 @@
 package com.yh.saas.plugin.yiliangyiyun.controller;
 
 
+import com.yh.saas.plugin.yiliangyiyun.entity.SearchRecordsInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.ISearchRecordsInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+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;
@@ -16,6 +21,17 @@ import org.springframework.web.bind.annotation.RestController;
 @RestController
 @RequestMapping("/searchRecordsInfo")
 public class SearchRecordsInfoController {
+    @Autowired
+    private ISearchRecordsInfoService searchRecordsInfoService;
+    /**
+     * 新增搜索记录
+     * @param searchRecordsInfo
+     * @return
+     */
+    @PostMapping("/api/addInfo")
+    public String addInfo(@RequestBody SearchRecordsInfo searchRecordsInfo) {
+        return searchRecordsInfoService.addInfo(searchRecordsInfo);
+    }
 
 }
 

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/entity/SearchRecordsInfo.java

@@ -53,4 +53,12 @@ public class SearchRecordsInfo extends BaseModel<SearchRecordsInfo> {
         return this.id;
     }
 
+    public static class QueryFiles {
+
+        public static final String COMP_ID = "comp_id";
+
+        public static final String DELETE_FLAG = "delete_flag";
+
+    }
+
 }

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/ISearchRecordsInfoService.java

@@ -1,5 +1,6 @@
 package com.yh.saas.plugin.yiliangyiyun.service;
 
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractManagementInfo;
 import com.yh.saas.plugin.yiliangyiyun.entity.SearchRecordsInfo;
 import com.baomidou.mybatisplus.service.IService;
 
@@ -12,5 +13,11 @@ import com.baomidou.mybatisplus.service.IService;
  * @since 2021-07-20
  */
 public interface ISearchRecordsInfoService extends IService<SearchRecordsInfo> {
+    /**
+     * 新增
+     *
+     * @param searchRecordsInfo
+     */
+    String addInfo(SearchRecordsInfo searchRecordsInfo);
 
 }

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/impl/SearchRecordsInfoServiceImpl.java

@@ -1,11 +1,22 @@
 package com.yh.saas.plugin.yiliangyiyun.service.impl;
 
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.security.util.AuthSecurityUtils;
+import com.yh.saas.common.support.util.IdGenerator;
+import com.yh.saas.plugin.yiliangyiyun.constant.NumberConstant;
+import com.yh.saas.plugin.yiliangyiyun.constant.StatusEnum;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractManagementInfo;
 import com.yh.saas.plugin.yiliangyiyun.entity.SearchRecordsInfo;
+import com.yh.saas.plugin.yiliangyiyun.exception.YException;
+import com.yh.saas.plugin.yiliangyiyun.exception.YExceptionEnum;
 import com.yh.saas.plugin.yiliangyiyun.mapper.SearchRecordsInfoMapper;
 import com.yh.saas.plugin.yiliangyiyun.service.ISearchRecordsInfoService;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import org.springframework.data.mongodb.core.aggregation.ArrayOperators;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 搜索记录 服务实现类
@@ -17,4 +28,33 @@ import org.springframework.stereotype.Service;
 @Service
 public class SearchRecordsInfoServiceImpl extends ServiceImpl<SearchRecordsInfoMapper, SearchRecordsInfo> implements ISearchRecordsInfoService {
 
+    /**
+     * 新增搜索记录
+     *
+     * @param searchRecordsInfo
+     * @return
+     */
+    @Override
+    public String addInfo(SearchRecordsInfo searchRecordsInfo) {
+        //判断记录是否存在
+        SearchRecordsInfo searchRecordsInfo1 =
+                this.selectOne(new EntityWrapper<SearchRecordsInfo>()
+                        .eq(SearchRecordsInfo.QueryFiles.COMP_ID, AuthSecurityUtils.getCurrentUserInfo().getCompId())
+                        .eq("search_content", searchRecordsInfo.getSearchContent())
+                        .eq(ContractManagementInfo.QueryFiles.DELETE_FLAG, NumberConstant.CONSTANT0));
+        //已存在，次数加1
+        if (searchRecordsInfo1!=null) {
+            Long count=searchRecordsInfo.getSearchCount()+1;
+            searchRecordsInfo.setSearchCount(count);
+            this.updateById(searchRecordsInfo);
+        }
+        //新增
+        else{
+            //新增主键id
+            searchRecordsInfo.setId(IdGenerator.generateUUID());
+            // 操作主表数据
+            this.insert(searchRecordsInfo);
+        }
+        return "OK";
+    }
 }