用户行为日志

xx-user-behavior-collect/xx-user-behavior-api/src/main/java/com/xxfc/platform/user/behavior/common/BehaviorEnum.java

 package com.xxfc.platform.user.behavior.common;
+
 /**
  * @author libin
  * @version 1.0
- * @description  用户行为枚举
+ * @description 用户行为枚举
  * @data 2019/8/12 14:57
  */
-public enum  BehaviorEnum {
+public enum BehaviorEnum {
+
+    /**
+     * 弹窗曝光
+     */
+    DIALOG_WINDOW(0, "弹窗曝光"),
+
+    /**
+     * 立即前往（弹窗）
+     */
+    DIALOG_WINDOW_TO(1, "立即前往"),
+
+    /**
+     * banner 点击
+     */
+    BANNER_CLICK(2, "banner点击"),
+
+    /**
+     * 精彩活动点击
+     */
+    WONDERFUL_ACTIVITY_CLICK(3, "精彩活动点击"),
+
+    /**
+     * 注册
+     */
+    REGISTRY(4, "注册"),
+
+    /**
+     * 领取任务
+     */
+    CLAIM_TASK(5, "领取任务"),
+
+    /**
+     * 分享
+     */
+    SHARE(6, "分享"),
+
+    /**
+     * 邀请
+     */
+    INVITATION(7, "邀请");
+
+    BehaviorEnum(int code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+
+    private int code;
+
+    private String name;
+
+    public int getCode() {
+        return code;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public String getName() {
+        return name;
+    }
 
+    public void setName(String name) {
+        this.name = name;
+    }
 }

xx-user-behavior-collect/xx-user-behavior-api/src/main/java/com/xxfc/platform/user/behavior/dto/CustomerBehaviorNoteDTO.java

@@ -37,4 +37,6 @@ public class CustomerBehaviorNoteDTO implements Serializable {
     @ApiModelProperty(value = "类型id")
     private Integer typeId;
 
+    @ApiModelProperty(value = "请求id")
+    private String requestId;
 }

xx-user-behavior-collect/xx-user-behavior-api/src/main/java/com/xxfc/platform/user/behavior/entity/CustomerBehaviorNotes.java

@@ -22,17 +22,13 @@ import java.io.Serializable;
 public class CustomerBehaviorNotes implements Serializable {
     private static final long serialVersionUID = 1L;
 
-    /**
-     * 主键id
-     */
+
     @Id
     @GeneratedValue(generator = "JDBC")
     @ApiModelProperty("主键id")
     private Integer id;
 
-    /**
-     * 用户id
-     */
+
     @Column(name = "customer_id")
     @ApiModelProperty(value = "用户id")
     private String customerId;
@@ -48,21 +44,21 @@ public class CustomerBehaviorNotes implements Serializable {
      * 行为类型 {@link com.xxfc.platform.user.behavior.common.BehaviorEnum}
      */
     @Column(name = "type")
-    @ApiModelProperty(value = "行为类型（见枚举）")
+    @ApiModelProperty(value = "行为类型")
     private Integer type;
 
-    /**
-     * 类型id
-     */
+
     @Column(name = "type_id")
     @ApiModelProperty(value = "类型id")
     private Integer typeId;
 
-    /**
-     * 创建时间
-     */
+
     @Column(name = "crt_time")
     @ApiModelProperty(value = "创建时间", hidden = true)
     private Long crtTime;
 
+
+    @Column(name = "request_id")
+    @ApiModelProperty(value = "请求id")
+    private String requestId;
 }

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/pojo/dto/AccompanyingItemFindDTO.java

+package com.xxfc.platform.vehicle.pojo.dto;
+
+import com.github.wxiaoqi.security.common.vo.PageParam;
+import lombok.Data;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/8/12 16:08
+ */
+@Data
+public class AccompanyingItemFindDTO extends PageParam {
+
+     private String name;
+
+     private Integer type;
+}

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/AccompanyingItemBiz.java

@@ -13,7 +13,7 @@ import com.xxfc.platform.vehicle.constant.RedisKey;
 import com.xxfc.platform.vehicle.entity.AccompanyingItem;
 import com.xxfc.platform.vehicle.mapper.AccompanyingItemMapper;
 import com.xxfc.platform.vehicle.pojo.AddOrUpdateAccompanyingItem;
-import com.xxfc.platform.vehicle.pojo.QueryAccompanyItemVo;
+import com.xxfc.platform.vehicle.pojo.dto.AccompanyingItemFindDTO;
 import com.xxfc.platform.vehicle.pojo.vo.AccompanyingItemVo;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.beanutils.BeanUtils;
@@ -29,7 +29,6 @@ import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.Comparator;
 import java.util.List;
-import java.util.Map;
 import java.util.stream.Collectors;
 
 @Service
@@ -69,15 +68,12 @@ public class AccompanyingItemBiz extends BaseBiz<AccompanyingItemMapper, Accompa
 
     /**
      * 按页查询，
-     * 注意，此处一共名称的模糊查询是预测其数据量较少，有变化后考虑加入全文索引
-     * @param queryAccompanyItemVo
      * @return
      * @throws Exception
      */
-    public PageDataVO<AccompanyingItem> getByPage(QueryAccompanyItemVo queryAccompanyItemVo) throws Exception{
-        Map<String,String> params = BeanUtils.describe(queryAccompanyItemVo);
-        PageHelper.startPage(queryAccompanyItemVo.getPage(),queryAccompanyItemVo.getLimit());
-        List<AccompanyingItem> accompanyingItems = mapper.getAllByPage(params);
+    public PageDataVO<AccompanyingItem> getByPage(AccompanyingItemFindDTO accompanyingItemFindDTO){
+        PageHelper.startPage(accompanyingItemFindDTO.getPage(),accompanyingItemFindDTO.getLimit());
+        List<AccompanyingItem> accompanyingItems = mapper.getAllPageByNameOrType(accompanyingItemFindDTO.getName(),accompanyingItemFindDTO.getType());
         PageInfo<AccompanyingItem> accompanyingItemsPageInfo = new PageInfo<>(accompanyingItems);
         return PageDataVO.pageInfo(accompanyingItemsPageInfo);
     }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mapper/AccompanyingItemMapper.java

 package com.xxfc.platform.vehicle.mapper;
 
 import com.xxfc.platform.vehicle.entity.AccompanyingItem;
+import org.apache.ibatis.annotations.Param;
 import tk.mybatis.mapper.common.Mapper;
 
 import java.util.List;
-import java.util.Map;
 
 public interface AccompanyingItemMapper extends Mapper<AccompanyingItem> {
 
-   public List<AccompanyingItem> getAllByPage(Map<String, String> params);
+    List<AccompanyingItem> getAllPageByNameOrType(@Param("name") String name, @Param("type") Integer type);
 
-   public List<AccompanyingItem> getByIdList(List<Integer> idList);
+    List<AccompanyingItem> getByIdList(List<Integer> idList);
 
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/AccompanyingItemController.java

 package com.xxfc.platform.vehicle.rest;
 
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONException;
 import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
+import com.github.wxiaoqi.security.common.vo.PageDataVO;
 import com.xxfc.platform.vehicle.biz.AccompanyingItemBiz;
 import com.xxfc.platform.vehicle.common.BaseController;
-import com.xxfc.platform.vehicle.common.CustomIllegalParamException;
 import com.xxfc.platform.vehicle.common.RestResponse;
-import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
 import com.xxfc.platform.vehicle.entity.AccompanyingItem;
 import com.xxfc.platform.vehicle.pojo.AddOrUpdateAccompanyingItem;
-import com.github.wxiaoqi.security.common.vo.PageDataVO;
-import com.xxfc.platform.vehicle.pojo.QueryAccompanyItemVo;
+import com.xxfc.platform.vehicle.pojo.dto.AccompanyingItemFindDTO;
 import com.xxfc.platform.vehicle.pojo.vo.AccompanyingItemVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
@@ -46,17 +42,9 @@ public class AccompanyingItemController extends BaseController<AccompanyingItemB
     }
 
 
-    @RequestMapping(value ="/page",method = RequestMethod.GET)
-    public RestResponse<PageDataVO<AccompanyingItem>> getByPage(@RequestParam String queryAccompanyItemVoJson) throws Exception{
-        QueryAccompanyItemVo queryAccompanyItemVo = null;
-        try {
-            queryAccompanyItemVo = JSON.parseObject(queryAccompanyItemVoJson,QueryAccompanyItemVo.class);
-            return RestResponse.data(baseBiz.getByPage(queryAccompanyItemVo));
-        } catch (JSONException ex) {
-            return RestResponse.code(ResCode.INVALID_REST_REQ_PARAM.getCode());
-        } catch (CustomIllegalParamException ex){
-            return RestResponse.code(ResCode.INVALID_REST_REQ_PARAM.getCode());
-        }
+    @RequestMapping(value ="/page",method = RequestMethod.POST)
+    public RestResponse<PageDataVO<AccompanyingItem>> getByPage(@RequestBody AccompanyingItemFindDTO accompanyingItemFindDTO){
+            return RestResponse.data(baseBiz.getByPage(accompanyingItemFindDTO));
     }
 
     @RequestMapping(value ="",method = RequestMethod.POST)

xx-vehicle/xx-vehicle-server/src/main/resources/mapper/AccompanyingItemMapper.xml

@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.xxfc.platform.vehicle.mapper.AccompanyingItemMapper">
 
-    <select id="getAllByPage" parameterType="java.util.Map" resultType="com.xxfc.platform.vehicle.entity.AccompanyingItem">
+    <select id="getAllPageByNameOrType" parameterType="java.util.Map" resultType="com.xxfc.platform.vehicle.entity.AccompanyingItem">
         select
         `id`, `type`, `name`, `remark`,`price`, `create_time`, `update_time`
         from