胡轶钦 преди 5 години
родител
ревизия
978b99ccff
променени са 24 файла, в които са добавени 1036 реда и са изтрити 941 реда
  1. 11
    2
      src/main/java/com/huiju/estateagents/common/CommConstant.java
  2. 180
    174
      src/main/java/com/huiju/estateagents/controller/ExtendContentController.java
  3. 9
    2
      src/main/java/com/huiju/estateagents/controller/TaBuildingController.java
  4. 3
    2
      src/main/java/com/huiju/estateagents/controller/TaBuildingDynamicController.java
  5. 159
    159
      src/main/java/com/huiju/estateagents/controller/TaExtendContentController.java
  6. 279
    273
      src/main/java/com/huiju/estateagents/controller/TaGoodsController.java
  7. 5
    2
      src/main/java/com/huiju/estateagents/controller/TaPersonController.java
  8. 279
    278
      src/main/java/com/huiju/estateagents/controller/TaRecommendCustomerController.java
  9. 2
    1
      src/main/java/com/huiju/estateagents/mapper/TaBuildingDynamicMapper.java
  10. 2
    1
      src/main/java/com/huiju/estateagents/mapper/TaBuildingMapper.java
  11. 2
    0
      src/main/java/com/huiju/estateagents/mapper/TaPersonMapper.java
  12. 31
    31
      src/main/java/com/huiju/estateagents/mapper/TaRecommendCustomerMapper.java
  13. 2
    1
      src/main/java/com/huiju/estateagents/service/ITaBuildingDynamicService.java
  14. 3
    1
      src/main/java/com/huiju/estateagents/service/ITaBuildingService.java
  15. 1
    1
      src/main/java/com/huiju/estateagents/service/ITaPersonService.java
  16. 1
    1
      src/main/java/com/huiju/estateagents/service/ITaRecommendCustomerService.java
  17. 2
    2
      src/main/java/com/huiju/estateagents/service/impl/TaBuildingDynamicServiceImpl.java
  18. 2
    2
      src/main/java/com/huiju/estateagents/service/impl/TaBuildingServiceImpl.java
  19. 7
    6
      src/main/java/com/huiju/estateagents/service/impl/TaPersonServiceImpl.java
  20. 2
    2
      src/main/java/com/huiju/estateagents/service/impl/TaRecommendCustomerServiceImpl.java
  21. 6
    0
      src/main/resources/mapper/TaBuildingDynamicMapper.xml
  22. 15
    0
      src/main/resources/mapper/TaBuildingMapper.xml
  23. 30
    0
      src/main/resources/mapper/TaPersonMapper.xml
  24. 3
    0
      src/main/resources/mapper/TaRecommendCustomerMapper.xml

+ 11
- 2
src/main/java/com/huiju/estateagents/common/CommConstant.java Целия файл

303
     // ------- 用户来源 查询条件 end ----------
303
     // ------- 用户来源 查询条件 end ----------
304
 
304
 
305
     // ------- 性别 start -------
305
     // ------- 性别 start -------
306
-    // 据说 1 男 2 女
307
     public static final Integer SEX_MALE = 1;
306
     public static final Integer SEX_MALE = 1;
308
     public static final Integer SEX_FEMALE = 2;
307
     public static final Integer SEX_FEMALE = 2;
309
-    // ------- 性别 start -------
308
+    // ------- 性别 end -------
309
+
310
+    // ------- 推荐客户状态 start -------
311
+    // 到访
312
+    public static final Integer RECOMMEND_CUSTOMER_STATUS_ARRIVAL = 1;
313
+    // 签约
314
+    public static final Integer RECOMMEND_CUSTOMER_STATUS_SIGN = 2;
315
+    //
316
+    public static final Integer RECOMMEND_CUSTOMER_STATUS_PRE_ORDER = 2;
317
+    // ------- 推荐客户状态 end -------
318
+
310
 }
319
 }

+ 180
- 174
src/main/java/com/huiju/estateagents/controller/ExtendContentController.java Целия файл

1
-package com.huiju.estateagents.controller;
2
-
3
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
-import com.baomidou.mybatisplus.core.metadata.IPage;
5
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
-import com.huiju.estateagents.base.BaseController;
7
-import com.huiju.estateagents.base.ResponseBean;
8
-import com.huiju.estateagents.entity.ExtendContent;
9
-import com.huiju.estateagents.entity.TaBuildingDynamic;
10
-import com.huiju.estateagents.service.IExtendContentService;
11
-import com.huiju.estateagents.service.ITaBuildingDynamicService;
12
-import com.huiju.estateagents.service.ITaBuildingService;
13
-import org.apache.commons.lang3.StringUtils;
14
-import org.slf4j.Logger;
15
-import org.slf4j.LoggerFactory;
16
-import org.springframework.beans.factory.annotation.Autowired;
17
-import org.springframework.web.bind.annotation.PathVariable;
18
-import org.springframework.web.bind.annotation.RequestBody;
19
-import org.springframework.web.bind.annotation.RequestMapping;
20
-import org.springframework.web.bind.annotation.RequestMethod;
21
-import org.springframework.web.bind.annotation.RequestParam;
22
-import org.springframework.web.bind.annotation.ResponseBody;
23
-import org.springframework.web.bind.annotation.RestController;
24
-
25
-import java.time.LocalDateTime;
26
-
27
-/**
28
- * <p>
29
-    * 辅助内容表  前端控制器
30
-    * </p>
31
- *
32
- * @author jobob
33
- * @since 2019-07-25
34
- */
35
-@RestController
36
-@RequestMapping("/api")
37
-public class ExtendContentController extends BaseController {
38
-
39
-    private final Logger logger = LoggerFactory.getLogger(ExtendContentController.class);
40
-
41
-    @Autowired
42
-    public IExtendContentService iExtendContentService;
43
-
44
-    @Autowired
45
-    private ITaBuildingDynamicService iTaBuildingDynamicService;
46
-
47
-    @Autowired
48
-    private ITaBuildingService iTaBuildingService;
49
-
50
-    /**
51
-     * 分页查询列表
52
-     * @param pageNum
53
-     * @param pageSize
54
-     * @return
55
-     */
56
-    @RequestMapping(value="/admin/extendContent",method= RequestMethod.GET)
57
-    public ResponseBean extendContentList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
58
-                                          @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
59
-                                          @RequestParam(value = "buildingId", required = false) String buildingId,
60
-                                          @RequestParam(value = "showType", required = false) String showType){
61
-        ResponseBean responseBean = new ResponseBean();
62
-            IPage<ExtendContent> pg = new Page<>(pageNum, pageSize);
63
-            QueryWrapper<ExtendContent> queryWrapper = new QueryWrapper<>();
64
-            queryWrapper.eq(StringUtils.isNotBlank(buildingId), "building_id", buildingId);
65
-            queryWrapper.eq(StringUtils.isNotBlank(showType), "show_type", showType);
66
-            queryWrapper.orderByDesc("create_date");
67
-            IPage<ExtendContent> result = iExtendContentService.page(pg, queryWrapper);
68
-            responseBean.addSuccess(result);
69
-            return responseBean;
70
-    }
71
-
72
-    /**
73
-     * 微信 开屏 / 轮播图
74
-     */
75
-    @RequestMapping(value="/wx/extendContent/{showType}",method= RequestMethod.GET)
76
-    public ResponseBean extendContentListShowType(@PathVariable(value = "showType") String showType,
77
-                                                  @RequestParam(value = "showPosition", required = false) String showPosition,
78
-                                                  @RequestParam(value = "targetId", required = false) String targetId,
79
-                                                  @RequestParam(value = "contentType", required = false) String contentType,
80
-                                                  @RequestParam(value = "buildingId", required = false) String buildingId,
81
-                                                  @RequestParam(value = "contentId", required = false) String contentId,
82
-                                                  @RequestParam(value = "cityId", required = false) Integer cityId){
83
-        ResponseBean responseBean= iExtendContentService.selectExtendContentListShowType(showType, showPosition, targetId,contentType, buildingId, contentId, cityId);
84
-        return responseBean;
85
-    }
86
-
87
-
88
-    /**
89
-     * 保存对象
90
-     * @param extendContent 实体对象
91
-     * @return
92
-     */
93
-    @RequestMapping(value="/admin/extendContent",method= RequestMethod.POST)
94
-    public ResponseBean extendContentAdd(@RequestBody ExtendContent extendContent){
95
-        Integer cityId = iTaBuildingService.getCityById(extendContent.getBuildingId());
96
-        extendContent.setCityId(cityId);
97
-        extendContent.setCreateDate(LocalDateTime.now());
98
-        ResponseBean  responseBean= iExtendContentService.extendContentAdd(extendContent);
99
-          responseBean.addSuccess(extendContent);
100
-          return responseBean;
101
-    }
102
-
103
-    /**
104
-     * 根据id删除对象
105
-     * @param id  实体ID
106
-     */
107
-    @ResponseBody
108
-    @RequestMapping(value="/admin/extendContent/{id}", method= RequestMethod.DELETE)
109
-    public ResponseBean extendContentDelete(@PathVariable Integer id){
110
-        ResponseBean responseBean = new ResponseBean();
111
-        try {
112
-            if(iExtendContentService.removeById(id)){
113
-                responseBean.addSuccess("success");
114
-            }else {
115
-                responseBean.addError("fail");
116
-            }
117
-        }catch (Exception e){
118
-            e.printStackTrace();
119
-            logger.error("extendContentDelete -=- {}",e.toString());
120
-            responseBean.addError(e.getMessage());
121
-        }
122
-        return responseBean;
123
-    }
124
-
125
-    /**
126
-     * 修改对象
127
-     * @param id  实体ID
128
-     * @param extendContent 实体对象
129
-     * @return
130
-     */
131
-    @RequestMapping(value="/admin/extendContent/{id}",method= RequestMethod.PUT)
132
-    public ResponseBean extendContentUpdate(@PathVariable Integer id,
133
-                                        @RequestBody ExtendContent extendContent){
134
-        ResponseBean responseBean = new ResponseBean();
135
-        extendContent.setContentId(id);
136
-        try {
137
-            Integer cityId = iTaBuildingService.getCityById(extendContent.getBuildingId());
138
-            extendContent.setCityId(cityId);
139
-            if (iExtendContentService.updateById(extendContent)){
140
-                responseBean.addSuccess(extendContent);
141
-            }else {
142
-                responseBean.addError("fail");
143
-            }
144
-        }catch (Exception e){
145
-            e.printStackTrace();
146
-            logger.error("extendContentUpdate -=- {}",e.toString());
147
-            responseBean.addError(e.getMessage());
148
-        }
149
-        return responseBean;
150
-    }
151
-
152
-    /**
153
-     * 根据id查询对象
154
-     * @param id  实体ID
155
-     */
156
-    @RequestMapping(value="/admin/extendContent/{id}",method= RequestMethod.GET)
157
-    public ResponseBean extendContentGet(@PathVariable Integer id){
158
-        ResponseBean responseBean = new ResponseBean();
159
-        try {
160
-            ExtendContent extendContent = iExtendContentService.getById(id);
161
-            TaBuildingDynamic taBuildingDynamic = iTaBuildingDynamicService.getById(extendContent.getTargetId());
162
-            if (null != taBuildingDynamic) {
163
-                extendContent.setTargetName(taBuildingDynamic.getTitle());
164
-            }
165
-
166
-            responseBean.addSuccess(extendContent);
167
-        }catch (Exception e){
168
-            e.printStackTrace();
169
-            logger.error("extendContentDelete -=- {}",e.toString());
170
-            responseBean.addError(e.getMessage());
171
-        }
172
-        return responseBean;
173
-    }
174
-}
1
+package com.huiju.estateagents.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.huiju.estateagents.base.BaseController;
7
+import com.huiju.estateagents.base.ResponseBean;
8
+import com.huiju.estateagents.entity.ExtendContent;
9
+import com.huiju.estateagents.entity.TaBuildingDynamic;
10
+import com.huiju.estateagents.service.IExtendContentService;
11
+import com.huiju.estateagents.service.ITaBuildingDynamicService;
12
+import com.huiju.estateagents.service.ITaBuildingService;
13
+import org.apache.commons.lang3.StringUtils;
14
+import org.slf4j.Logger;
15
+import org.slf4j.LoggerFactory;
16
+import org.springframework.beans.factory.annotation.Autowired;
17
+import org.springframework.web.bind.annotation.PathVariable;
18
+import org.springframework.web.bind.annotation.RequestBody;
19
+import org.springframework.web.bind.annotation.RequestMapping;
20
+import org.springframework.web.bind.annotation.RequestMethod;
21
+import org.springframework.web.bind.annotation.RequestParam;
22
+import org.springframework.web.bind.annotation.ResponseBody;
23
+import org.springframework.web.bind.annotation.RestController;
24
+
25
+import java.time.LocalDateTime;
26
+
27
+/**
28
+ * <p>
29
+    * 辅助内容表  前端控制器
30
+    * </p>
31
+ *
32
+ * @author jobob
33
+ * @since 2019-07-25
34
+ */
35
+@RestController
36
+@RequestMapping("/api")
37
+public class ExtendContentController extends BaseController {
38
+
39
+    private final Logger logger = LoggerFactory.getLogger(ExtendContentController.class);
40
+
41
+    @Autowired
42
+    public IExtendContentService iExtendContentService;
43
+
44
+    @Autowired
45
+    private ITaBuildingDynamicService iTaBuildingDynamicService;
46
+
47
+    @Autowired
48
+    private ITaBuildingService iTaBuildingService;
49
+
50
+    /**
51
+     * 分页查询列表
52
+     * @param pageNum
53
+     * @param pageSize
54
+     * @return
55
+     */
56
+    @RequestMapping(value="/admin/extendContent",method= RequestMethod.GET)
57
+    public ResponseBean extendContentList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
58
+                                          @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
59
+                                          @RequestParam(value = "buildingId", required = false) String buildingId,
60
+                                          @RequestParam(value = "contentType", required = false) String contentType,
61
+                                          @RequestParam(value = "showPosition", required = false) String showPosition,
62
+                                          @RequestParam(value = "status", required = false) Integer status,
63
+                                          @RequestParam(value = "showType", required = false) String showType){
64
+        ResponseBean responseBean = new ResponseBean();
65
+            IPage<ExtendContent> pg = new Page<>(pageNum, pageSize);
66
+            QueryWrapper<ExtendContent> queryWrapper = new QueryWrapper<>();
67
+            queryWrapper.eq(StringUtils.isNotBlank(buildingId), "building_id", buildingId);
68
+            queryWrapper.eq(StringUtils.isNotBlank(showType), "show_type", showType);
69
+            queryWrapper.eq(StringUtils.isNotBlank(contentType), "content_type", contentType);
70
+            queryWrapper.eq(StringUtils.isNotBlank(showPosition), "show_position", showPosition);
71
+            queryWrapper.eq(null!=status, "status", status);
72
+            queryWrapper.orderByDesc("create_date");
73
+            IPage<ExtendContent> result = iExtendContentService.page(pg, queryWrapper);
74
+            responseBean.addSuccess(result);
75
+            return responseBean;
76
+    }
77
+
78
+    /**
79
+     * 微信 开屏 / 轮播图
80
+     */
81
+    @RequestMapping(value="/wx/extendContent/{showType}",method= RequestMethod.GET)
82
+    public ResponseBean extendContentListShowType(@PathVariable(value = "showType") String showType,
83
+                                                  @RequestParam(value = "showPosition", required = false) String showPosition,
84
+                                                  @RequestParam(value = "targetId", required = false) String targetId,
85
+                                                  @RequestParam(value = "contentType", required = false) String contentType,
86
+                                                  @RequestParam(value = "buildingId", required = false) String buildingId,
87
+                                                  @RequestParam(value = "contentId", required = false) String contentId,
88
+                                                  @RequestParam(value = "cityId", required = false) Integer cityId){
89
+        ResponseBean responseBean= iExtendContentService.selectExtendContentListShowType(showType, showPosition, targetId,contentType, buildingId, contentId, cityId);
90
+        return responseBean;
91
+    }
92
+
93
+
94
+    /**
95
+     * 保存对象
96
+     * @param extendContent 实体对象
97
+     * @return
98
+     */
99
+    @RequestMapping(value="/admin/extendContent",method= RequestMethod.POST)
100
+    public ResponseBean extendContentAdd(@RequestBody ExtendContent extendContent){
101
+        Integer cityId = iTaBuildingService.getCityById(extendContent.getBuildingId());
102
+        extendContent.setCityId(cityId);
103
+        extendContent.setCreateDate(LocalDateTime.now());
104
+        ResponseBean  responseBean= iExtendContentService.extendContentAdd(extendContent);
105
+          responseBean.addSuccess(extendContent);
106
+          return responseBean;
107
+    }
108
+
109
+    /**
110
+     * 根据id删除对象
111
+     * @param id  实体ID
112
+     */
113
+    @ResponseBody
114
+    @RequestMapping(value="/admin/extendContent/{id}", method= RequestMethod.DELETE)
115
+    public ResponseBean extendContentDelete(@PathVariable Integer id){
116
+        ResponseBean responseBean = new ResponseBean();
117
+        try {
118
+            if(iExtendContentService.removeById(id)){
119
+                responseBean.addSuccess("success");
120
+            }else {
121
+                responseBean.addError("fail");
122
+            }
123
+        }catch (Exception e){
124
+            e.printStackTrace();
125
+            logger.error("extendContentDelete -=- {}",e.toString());
126
+            responseBean.addError(e.getMessage());
127
+        }
128
+        return responseBean;
129
+    }
130
+
131
+    /**
132
+     * 修改对象
133
+     * @param id  实体ID
134
+     * @param extendContent 实体对象
135
+     * @return
136
+     */
137
+    @RequestMapping(value="/admin/extendContent/{id}",method= RequestMethod.PUT)
138
+    public ResponseBean extendContentUpdate(@PathVariable Integer id,
139
+                                        @RequestBody ExtendContent extendContent){
140
+        ResponseBean responseBean = new ResponseBean();
141
+        extendContent.setContentId(id);
142
+        try {
143
+            Integer cityId = iTaBuildingService.getCityById(extendContent.getBuildingId());
144
+            extendContent.setCityId(cityId);
145
+            if (iExtendContentService.updateById(extendContent)){
146
+                responseBean.addSuccess(extendContent);
147
+            }else {
148
+                responseBean.addError("fail");
149
+            }
150
+        }catch (Exception e){
151
+            e.printStackTrace();
152
+            logger.error("extendContentUpdate -=- {}",e.toString());
153
+            responseBean.addError(e.getMessage());
154
+        }
155
+        return responseBean;
156
+    }
157
+
158
+    /**
159
+     * 根据id查询对象
160
+     * @param id  实体ID
161
+     */
162
+    @RequestMapping(value="/admin/extendContent/{id}",method= RequestMethod.GET)
163
+    public ResponseBean extendContentGet(@PathVariable Integer id){
164
+        ResponseBean responseBean = new ResponseBean();
165
+        try {
166
+            ExtendContent extendContent = iExtendContentService.getById(id);
167
+            TaBuildingDynamic taBuildingDynamic = iTaBuildingDynamicService.getById(extendContent.getTargetId());
168
+            if (null != taBuildingDynamic) {
169
+                extendContent.setTargetName(taBuildingDynamic.getTitle());
170
+            }
171
+
172
+            responseBean.addSuccess(extendContent);
173
+        }catch (Exception e){
174
+            e.printStackTrace();
175
+            logger.error("extendContentDelete -=- {}",e.toString());
176
+            responseBean.addError(e.getMessage());
177
+        }
178
+        return responseBean;
179
+    }
180
+}

+ 9
- 2
src/main/java/com/huiju/estateagents/controller/TaBuildingController.java Целия файл

10
 import com.huiju.estateagents.service.ITaPersonService;
10
 import com.huiju.estateagents.service.ITaPersonService;
11
 import com.huiju.estateagents.service.ITaSaveService;
11
 import com.huiju.estateagents.service.ITaSaveService;
12
 import com.huiju.estateagents.service.ITdCityService;
12
 import com.huiju.estateagents.service.ITdCityService;
13
+import org.apache.ibatis.annotations.Param;
13
 import org.springframework.beans.factory.annotation.Autowired;
14
 import org.springframework.beans.factory.annotation.Autowired;
14
 import org.springframework.web.bind.annotation.*;
15
 import org.springframework.web.bind.annotation.*;
15
 
16
 
17
 
18
 
18
 import javax.servlet.http.HttpServletRequest;
19
 import javax.servlet.http.HttpServletRequest;
19
 import javax.servlet.http.HttpSession;
20
 import javax.servlet.http.HttpSession;
21
+import java.time.LocalDateTime;
20
 import java.util.List;
22
 import java.util.List;
21
 
23
 
22
 /**
24
 /**
63
     public ResponseBean buildingList(@RequestParam(value = "pageNum", defaultValue = "1")Integer pageNum,
65
     public ResponseBean buildingList(@RequestParam(value = "pageNum", defaultValue = "1")Integer pageNum,
64
                                      @RequestParam(value = "pageSize", defaultValue = "10")Integer pageSize,
66
                                      @RequestParam(value = "pageSize", defaultValue = "10")Integer pageSize,
65
                                      @RequestParam(value = "name", required = false)String name,
67
                                      @RequestParam(value = "name", required = false)String name,
66
-                                     @RequestParam(value = "code", required = false)String code){
67
-        return taBuildingService.buildingList(pageNum,pageSize,name,code);
68
+                                     @RequestParam(value = "code", required = false)String code,
69
+                                     @RequestParam(value = "startDate",required = false)LocalDateTime startDate,
70
+                                     @RequestParam(value = "buildingStatus",required = false)String buildingStatus,
71
+                                     @RequestParam(value = "marketStatus",required = false)String marketStatus,
72
+                                     @RequestParam(value = "cityId",required = false)Integer cityId,
73
+                                     @RequestParam(value = "isMain",required = false)Integer isMain){
74
+        return taBuildingService.buildingList(pageNum,pageSize,name,code,startDate,buildingStatus,marketStatus,cityId,isMain);
68
     }
75
     }
69
 
76
 
70
     /**
77
     /**

+ 3
- 2
src/main/java/com/huiju/estateagents/controller/TaBuildingDynamicController.java Целия файл

73
                                              @RequestParam(required = false)String name,
73
                                              @RequestParam(required = false)String name,
74
                                              @RequestParam(required = false)Integer cityId,
74
                                              @RequestParam(required = false)Integer cityId,
75
                                              @RequestParam(required = false)String buildingId,
75
                                              @RequestParam(required = false)String buildingId,
76
-                                             HttpSession session){
77
-        ResponseBean  responseBean = iBuildingDynamicService.iBuildingDynamicList(pageNum,pageSize,name,buildingId,cityId);
76
+                                             @RequestParam(required = false)String isEnlist,
77
+                                             @RequestParam(required = false)LocalDateTime time){
78
+        ResponseBean  responseBean = iBuildingDynamicService.iBuildingDynamicList(pageNum,pageSize,name,buildingId,cityId,isEnlist,time);
78
         return responseBean;
79
         return responseBean;
79
     }
80
     }
80
 
81
 

+ 159
- 159
src/main/java/com/huiju/estateagents/controller/TaExtendContentController.java Целия файл

1
-package com.huiju.estateagents.controller;
2
-
3
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
-import com.baomidou.mybatisplus.core.metadata.IPage;
5
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
-import com.huiju.estateagents.base.BaseController;
7
-import com.huiju.estateagents.base.ResponseBean;
8
-import com.huiju.estateagents.entity.TaExtendContent;
9
-import com.huiju.estateagents.service.ITaBuildingService;
10
-import com.huiju.estateagents.service.ITaExtendContentService;
11
-import org.omg.CORBA.PUBLIC_MEMBER;
12
-import org.slf4j.Logger;
13
-import org.slf4j.LoggerFactory;
14
-import org.springframework.beans.factory.annotation.Autowired;
15
-import org.springframework.web.bind.annotation.PathVariable;
16
-import org.springframework.web.bind.annotation.RequestBody;
17
-import org.springframework.web.bind.annotation.RequestMapping;
18
-import org.springframework.web.bind.annotation.RequestMethod;
19
-import org.springframework.web.bind.annotation.RequestParam;
20
-import org.springframework.web.bind.annotation.ResponseBody;
21
-import org.springframework.web.bind.annotation.RestController;
22
-
23
-/**
24
- * <p>
25
-    * 辅助内容表  前端控制器
26
-    * </p>
27
- *
28
- * @author jobob
29
- * @since 2019-07-25
30
- */
31
-@RestController
32
-@RequestMapping("/api")
33
-public class TaExtendContentController extends BaseController {
34
-
35
-    private final Logger logger = LoggerFactory.getLogger(TaExtendContentController.class);
36
-
37
-    @Autowired
38
-    public ITaExtendContentService iTaExtendContentService;
39
-
40
-    @Autowired
41
-    public ITaBuildingService iTaBuildingService;
42
-
43
-    /**
44
-     * 分页查询列表
45
-     * @param pageNum
46
-     * @param pageSize
47
-     * @return
48
-     */
49
-    @RequestMapping(value="/taExtendContent",method= RequestMethod.GET)
50
-    public ResponseBean taExtendContentList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
51
-                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
52
-        ResponseBean responseBean = new ResponseBean();
53
-        try {
54
-            //使用分页插件
55
-		    IPage<TaExtendContent> pg = new Page<>(pageNum, pageSize);
56
-            QueryWrapper<TaExtendContent> queryWrapper = new QueryWrapper<>();
57
-            queryWrapper.orderByDesc("create_date");
58
-
59
-            IPage<TaExtendContent> result = iTaExtendContentService.page(pg, queryWrapper);
60
-            responseBean.addSuccess(result);
61
-        }catch (Exception e){
62
-            e.printStackTrace();
63
-            logger.error("taExtendContentList -=- {}",e.toString());
64
-            responseBean.addError(e.getMessage());
65
-        }
66
-        return responseBean;
67
-    }
68
-
69
-    /**
70
-     * 保存对象
71
-     * @param taExtendContent 实体对象
72
-     * @return
73
-     */
74
-    @RequestMapping(value="/taExtendContent",method= RequestMethod.POST)
75
-    public ResponseBean taExtendContentAdd(@RequestBody TaExtendContent taExtendContent){
76
-        ResponseBean responseBean = new ResponseBean();
77
-        try {
78
-            Integer cityId = iTaBuildingService.getCityById(taExtendContent.getBuildingId());
79
-            taExtendContent.setCityId(cityId);
80
-
81
-            if (iTaExtendContentService.save(taExtendContent)){
82
-                responseBean.addSuccess(taExtendContent);
83
-            }else {
84
-                responseBean.addError("fail");
85
-            }
86
-        }catch (Exception e){
87
-            e.printStackTrace();
88
-            logger.error("taExtendContentAdd -=- {}",e.toString());
89
-            responseBean.addError(e.getMessage());
90
-        }
91
-        return responseBean;
92
-    }
93
-
94
-    /**
95
-     * 根据id删除对象
96
-     * @param id  实体ID
97
-     */
98
-    @ResponseBody
99
-    @RequestMapping(value="/taExtendContent/{id}", method= RequestMethod.DELETE)
100
-    public ResponseBean taExtendContentDelete(@PathVariable Integer id){
101
-        ResponseBean responseBean = new ResponseBean();
102
-        try {
103
-            if(iTaExtendContentService.removeById(id)){
104
-                responseBean.addSuccess("success");
105
-            }else {
106
-                responseBean.addError("fail");
107
-            }
108
-        }catch (Exception e){
109
-            e.printStackTrace();
110
-            logger.error("taExtendContentDelete -=- {}",e.toString());
111
-            responseBean.addError(e.getMessage());
112
-        }
113
-        return responseBean;
114
-    }
115
-
116
-    /**
117
-     * 修改对象
118
-     * @param id  实体ID
119
-     * @param taExtendContent 实体对象
120
-     * @return
121
-     */
122
-    @RequestMapping(value="/taExtendContent/{id}",method= RequestMethod.PUT)
123
-    public ResponseBean taExtendContentUpdate(@PathVariable Integer id,
124
-                                        @RequestBody TaExtendContent taExtendContent){
125
-        ResponseBean responseBean = new ResponseBean();
126
-        try {
127
-            Integer cityId = iTaBuildingService.getCityById(taExtendContent.getBuildingId());
128
-            taExtendContent.setCityId(cityId);
129
-
130
-            if (iTaExtendContentService.updateById(taExtendContent)){
131
-                responseBean.addSuccess(taExtendContent);
132
-            }else {
133
-                responseBean.addError("fail");
134
-            }
135
-        }catch (Exception e){
136
-            e.printStackTrace();
137
-            logger.error("taExtendContentUpdate -=- {}",e.toString());
138
-            responseBean.addError(e.getMessage());
139
-        }
140
-        return responseBean;
141
-    }
142
-
143
-    /**
144
-     * 根据id查询对象
145
-     * @param id  实体ID
146
-     */
147
-    @RequestMapping(value="/taExtendContent/{id}",method= RequestMethod.GET)
148
-    public ResponseBean taExtendContentGet(@PathVariable Integer id){
149
-        ResponseBean responseBean = new ResponseBean();
150
-        try {
151
-            responseBean.addSuccess(iTaExtendContentService.getById(id));
152
-        }catch (Exception e){
153
-            e.printStackTrace();
154
-            logger.error("taExtendContentDelete -=- {}",e.toString());
155
-            responseBean.addError(e.getMessage());
156
-        }
157
-        return responseBean;
158
-    }
159
-}
1
+package com.huiju.estateagents.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.huiju.estateagents.base.BaseController;
7
+import com.huiju.estateagents.base.ResponseBean;
8
+import com.huiju.estateagents.entity.TaExtendContent;
9
+import com.huiju.estateagents.service.ITaBuildingService;
10
+import com.huiju.estateagents.service.ITaExtendContentService;
11
+import org.omg.CORBA.PUBLIC_MEMBER;
12
+import org.slf4j.Logger;
13
+import org.slf4j.LoggerFactory;
14
+import org.springframework.beans.factory.annotation.Autowired;
15
+import org.springframework.web.bind.annotation.PathVariable;
16
+import org.springframework.web.bind.annotation.RequestBody;
17
+import org.springframework.web.bind.annotation.RequestMapping;
18
+import org.springframework.web.bind.annotation.RequestMethod;
19
+import org.springframework.web.bind.annotation.RequestParam;
20
+import org.springframework.web.bind.annotation.ResponseBody;
21
+import org.springframework.web.bind.annotation.RestController;
22
+
23
+/**
24
+ * <p>
25
+    * 辅助内容表  前端控制器
26
+    * </p>
27
+ *
28
+ * @author jobob
29
+ * @since 2019-07-25
30
+ */
31
+@RestController
32
+@RequestMapping("/api")
33
+public class TaExtendContentController extends BaseController {
34
+
35
+    private final Logger logger = LoggerFactory.getLogger(TaExtendContentController.class);
36
+
37
+    @Autowired
38
+    public ITaExtendContentService iTaExtendContentService;
39
+
40
+    @Autowired
41
+    public ITaBuildingService iTaBuildingService;
42
+
43
+    /**
44
+     * 分页查询列表
45
+     * @param pageNum
46
+     * @param pageSize
47
+     * @return
48
+     */
49
+    @RequestMapping(value="/taExtendContent",method= RequestMethod.GET)
50
+    public ResponseBean taExtendContentList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
51
+                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
52
+        ResponseBean responseBean = new ResponseBean();
53
+        try {
54
+            //使用分页插件
55
+		    IPage<TaExtendContent> pg = new Page<>(pageNum, pageSize);
56
+            QueryWrapper<TaExtendContent> queryWrapper = new QueryWrapper<>();
57
+            queryWrapper.orderByDesc("create_date");
58
+
59
+            IPage<TaExtendContent> result = iTaExtendContentService.page(pg, queryWrapper);
60
+            responseBean.addSuccess(result);
61
+        }catch (Exception e){
62
+            e.printStackTrace();
63
+            logger.error("taExtendContentList -=- {}",e.toString());
64
+            responseBean.addError(e.getMessage());
65
+        }
66
+        return responseBean;
67
+    }
68
+
69
+    /**
70
+     * 保存对象
71
+     * @param taExtendContent 实体对象
72
+     * @return
73
+     */
74
+    @RequestMapping(value="/taExtendContent",method= RequestMethod.POST)
75
+    public ResponseBean taExtendContentAdd(@RequestBody TaExtendContent taExtendContent){
76
+        ResponseBean responseBean = new ResponseBean();
77
+        try {
78
+            Integer cityId = iTaBuildingService.getCityById(taExtendContent.getBuildingId());
79
+            taExtendContent.setCityId(cityId);
80
+
81
+            if (iTaExtendContentService.save(taExtendContent)){
82
+                responseBean.addSuccess(taExtendContent);
83
+            }else {
84
+                responseBean.addError("fail");
85
+            }
86
+        }catch (Exception e){
87
+            e.printStackTrace();
88
+            logger.error("taExtendContentAdd -=- {}",e.toString());
89
+            responseBean.addError(e.getMessage());
90
+        }
91
+        return responseBean;
92
+    }
93
+
94
+    /**
95
+     * 根据id删除对象
96
+     * @param id  实体ID
97
+     */
98
+    @ResponseBody
99
+    @RequestMapping(value="/taExtendContent/{id}", method= RequestMethod.DELETE)
100
+    public ResponseBean taExtendContentDelete(@PathVariable Integer id){
101
+        ResponseBean responseBean = new ResponseBean();
102
+        try {
103
+            if(iTaExtendContentService.removeById(id)){
104
+                responseBean.addSuccess("success");
105
+            }else {
106
+                responseBean.addError("fail");
107
+            }
108
+        }catch (Exception e){
109
+            e.printStackTrace();
110
+            logger.error("taExtendContentDelete -=- {}",e.toString());
111
+            responseBean.addError(e.getMessage());
112
+        }
113
+        return responseBean;
114
+    }
115
+
116
+    /**
117
+     * 修改对象
118
+     * @param id  实体ID
119
+     * @param taExtendContent 实体对象
120
+     * @return
121
+     */
122
+    @RequestMapping(value="/taExtendContent/{id}",method= RequestMethod.PUT)
123
+    public ResponseBean taExtendContentUpdate(@PathVariable Integer id,
124
+                                        @RequestBody TaExtendContent taExtendContent){
125
+        ResponseBean responseBean = new ResponseBean();
126
+        try {
127
+            Integer cityId = iTaBuildingService.getCityById(taExtendContent.getBuildingId());
128
+            taExtendContent.setCityId(cityId);
129
+
130
+            if (iTaExtendContentService.updateById(taExtendContent)){
131
+                responseBean.addSuccess(taExtendContent);
132
+            }else {
133
+                responseBean.addError("fail");
134
+            }
135
+        }catch (Exception e){
136
+            e.printStackTrace();
137
+            logger.error("taExtendContentUpdate -=- {}",e.toString());
138
+            responseBean.addError(e.getMessage());
139
+        }
140
+        return responseBean;
141
+    }
142
+
143
+    /**
144
+     * 根据id查询对象
145
+     * @param id  实体ID
146
+     */
147
+    @RequestMapping(value="/taExtendContent/{id}",method= RequestMethod.GET)
148
+    public ResponseBean taExtendContentGet(@PathVariable Integer id){
149
+        ResponseBean responseBean = new ResponseBean();
150
+        try {
151
+            responseBean.addSuccess(iTaExtendContentService.getById(id));
152
+        }catch (Exception e){
153
+            e.printStackTrace();
154
+            logger.error("taExtendContentDelete -=- {}",e.toString());
155
+            responseBean.addError(e.getMessage());
156
+        }
157
+        return responseBean;
158
+    }
159
+}

+ 279
- 273
src/main/java/com/huiju/estateagents/controller/TaGoodsController.java Целия файл

1
-package com.huiju.estateagents.controller;
2
-
3
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
-import com.baomidou.mybatisplus.core.metadata.IPage;
5
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
-import com.huiju.estateagents.base.BaseController;
7
-import com.huiju.estateagents.base.ResponseBean;
8
-import com.huiju.estateagents.common.CommConstant;
9
-import com.huiju.estateagents.common.JWTUtils;
10
-import com.huiju.estateagents.common.StringUtils;
11
-import com.huiju.estateagents.entity.TaGoods;
12
-import com.huiju.estateagents.service.ITaBuildingService;
13
-import com.huiju.estateagents.service.ITaGoodsService;
14
-import org.slf4j.Logger;
15
-import org.slf4j.LoggerFactory;
16
-import org.springframework.beans.factory.annotation.Autowired;
17
-import org.springframework.web.bind.annotation.PathVariable;
18
-import org.springframework.web.bind.annotation.RequestBody;
19
-import org.springframework.web.bind.annotation.RequestMapping;
20
-import org.springframework.web.bind.annotation.RequestMethod;
21
-import org.springframework.web.bind.annotation.RequestParam;
22
-import org.springframework.web.bind.annotation.ResponseBody;
23
-import org.springframework.web.bind.annotation.RestController;
24
-
25
-import javax.servlet.http.HttpServletRequest;
26
-import java.lang.invoke.ConstantCallSite;
27
-
28
-/**
29
- * <p>
30
-    * 商品表  前端控制器
31
-    * </p>
32
- *
33
- * @author jobob
34
- * @since 2019-07-25
35
- */
36
-@RestController
37
-@RequestMapping("/api")
38
-public class TaGoodsController extends BaseController {
39
-
40
-    private final Logger logger = LoggerFactory.getLogger(TaGoodsController.class);
41
-
42
-    @Autowired
43
-    public ITaGoodsService iTaGoodsService;
44
-
45
-    @Autowired
46
-    public ITaBuildingService iTaBuildingService;
47
-
48
-    /**
49
-     * 分页查询列表
50
-     * @param pageNum
51
-     * @param pageSize
52
-     * @return
53
-     */
54
-    @RequestMapping(value="/admin/taGoods",method= RequestMethod.GET)
55
-    public ResponseBean taGoodsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
56
-                                    @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
57
-                                    @RequestParam(value = "goodsName",required = false) String goodsName){
58
-        ResponseBean responseBean = new ResponseBean();
59
-        try {
60
-            //使用分页插件
61
-		    IPage<TaGoods> pg = new Page<>(pageNum, pageSize);
62
-            QueryWrapper<TaGoods> queryWrapper = new QueryWrapper<>();
63
-            queryWrapper.like("goods_name",goodsName);
64
-            queryWrapper.orderByDesc("create_date");
65
-
66
-            IPage<TaGoods> result = iTaGoodsService.page(pg, queryWrapper);
67
-            responseBean.addSuccess(result);
68
-        }catch (Exception e){
69
-            e.printStackTrace();
70
-            logger.error("taGoodsList -=- {}",e.toString());
71
-            responseBean.addError(e.getMessage());
72
-        }
73
-        return responseBean;
74
-    }
75
-
76
-    /**
77
-     * 保存对象
78
-     * @param taGoods 实体对象
79
-     * @return
80
-     */
81
-    @RequestMapping(value="/admin/taGoods/add",method= RequestMethod.POST)
82
-    public ResponseBean taGoodsAdd(@RequestBody TaGoods taGoods){
83
-        ResponseBean responseBean = new ResponseBean();
84
-        try {
85
-
86
-            Integer cityId = iTaBuildingService.getCityById(taGoods.getBuildingId());
87
-            taGoods.setCityId(cityId);
88
-
89
-            if (iTaGoodsService.save(taGoods)){
90
-                responseBean.addSuccess(taGoods);
91
-            }else {
92
-                responseBean.addError("fail");
93
-            }
94
-        }catch (Exception e){
95
-            e.printStackTrace();
96
-            logger.error("taGoodsAdd -=- {}",e.toString());
97
-            responseBean.addError(e.getMessage());
98
-        }
99
-        return responseBean;
100
-    }
101
-
102
-    /**
103
-     * 根据id删除对象
104
-     * @param id  实体ID
105
-     */
106
-    @ResponseBody
107
-    @RequestMapping(value="/taGoods/{id}", method= RequestMethod.DELETE)
108
-    public ResponseBean taGoodsDelete(@PathVariable Integer id){
109
-        ResponseBean responseBean = new ResponseBean();
110
-        try {
111
-            if(iTaGoodsService.removeById(id)){
112
-                responseBean.addSuccess("success");
113
-            }else {
114
-                responseBean.addError("fail");
115
-            }
116
-        }catch (Exception e){
117
-            e.printStackTrace();
118
-            logger.error("taGoodsDelete -=- {}",e.toString());
119
-            responseBean.addError(e.getMessage());
120
-        }
121
-        return responseBean;
122
-    }
123
-
124
-    /**
125
-     * 修改对象
126
-     * @param taGoods 实体对象
127
-     * @return
128
-     */
129
-    @RequestMapping(value="/admin/taGoods",method= RequestMethod.PUT)
130
-    public ResponseBean taGoodsUpdate(@RequestBody TaGoods taGoods){
131
-        ResponseBean responseBean = new ResponseBean();
132
-        try {
133
-
134
-            Integer cityId = iTaBuildingService.getCityById(taGoods.getBuildingId());
135
-            taGoods.setCityId(cityId);
136
-
137
-            if (iTaGoodsService.updateById(taGoods)){
138
-                responseBean.addSuccess(taGoods);
139
-            }else {
140
-                responseBean.addError("fail");
141
-            }
142
-        }catch (Exception e){
143
-            e.printStackTrace();
144
-            logger.error("taGoodsUpdate -=- {}",e.toString());
145
-            responseBean.addError(e.getMessage());
146
-        }
147
-        return responseBean;
148
-    }
149
-    
150
-    /**
151
-     * 修改对象
152
-     * @param taGoods 实体对象
153
-     * @return
154
-     */
155
-    @RequestMapping(value="/admin/taGoods/change",method= RequestMethod.PUT)
156
-    public ResponseBean taGoodsChange(@RequestBody TaGoods taGoods){
157
-        ResponseBean responseBean = new ResponseBean();
158
-        try {
159
-            if(null != taGoods.getStatus() && taGoods.getStatus().equals(CommConstant.STATUS_NORMAL)){
160
-                taGoods.setStatus(CommConstant.STATUS_UNACCALIMED);
161
-            }else {
162
-                taGoods.setStatus(CommConstant.STATUS_NORMAL);
163
-            }
164
-            if (iTaGoodsService.updateById(taGoods)){
165
-                responseBean.addSuccess(taGoods);
166
-            }else {
167
-                responseBean.addError("fail");
168
-            }
169
-        }catch (Exception e){
170
-            e.printStackTrace();
171
-            logger.error("taGoodsUpdate -=- {}",e.toString());
172
-            responseBean.addError(e.getMessage());
173
-        }
174
-        return responseBean;
175
-    }
176
-
177
-    /**
178
-     * 根据id查询对象
179
-     * @param id  实体ID
180
-     */
181
-    @RequestMapping(value="/admin/taGoods/{id}",method= RequestMethod.GET)
182
-    public ResponseBean taGoodsGet(@PathVariable Integer id){
183
-        ResponseBean responseBean = new ResponseBean();
184
-        try {
185
-            responseBean.addSuccess(iTaGoodsService.getById(id));
186
-        }catch (Exception e){
187
-            e.printStackTrace();
188
-            logger.error("taGoodsDelete -=- {}",e.toString());
189
-            responseBean.addError(e.getMessage());
190
-        }
191
-        return responseBean;
192
-    }
193
-    
194
-    /**
195
-     * 分页查询列表
196
-     * @param pageNum
197
-     * @param pageSize
198
-     * @return
199
-     */
200
-    @RequestMapping(value="/wx/goods",method= RequestMethod.GET)
201
-    public ResponseBean wxGoodsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
202
-                                    @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
203
-                                    @RequestParam(value = "buildingId",required = false) String buildingId,
204
-                                    @RequestParam(value = "orgId",required = false) Integer orgId){
205
-        ResponseBean responseBean = new ResponseBean();
206
-        try {
207
-            //使用分页插件
208
-            IPage<TaGoods> pg = new Page<>(pageNum, pageSize);
209
-            QueryWrapper<TaGoods> queryWrapper = new QueryWrapper<>();
210
-            queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
211
-            if (!StringUtils.isEmpty(buildingId)){
212
-                queryWrapper.eq("building_id", buildingId);
213
-            }
214
-            if (null != orgId){
215
-                queryWrapper.eq("org_id", orgId);
216
-            }
217
-            queryWrapper.orderByDesc("order_no");
218
-            queryWrapper.orderByDesc("create_date");
219
-            
220
-            IPage<TaGoods> result = iTaGoodsService.page(pg, queryWrapper);
221
-            responseBean.addSuccess(result);
222
-        }catch (Exception e){
223
-            e.printStackTrace();
224
-            logger.error("taGoodsList -=- {}",e.toString());
225
-            responseBean.addError(e.getMessage());
226
-        }
227
-        return responseBean;
228
-    }
229
-    
230
-    
231
-    /**
232
-     * 根据id查询对象
233
-     * @param id  实体ID
234
-     */
235
-    @RequestMapping(value="/wx/goods/{id}",method= RequestMethod.GET)
236
-    public ResponseBean wxGoodsGet(@PathVariable Integer id){
237
-        ResponseBean responseBean = new ResponseBean();
238
-        try {
239
-            responseBean.addSuccess(iTaGoodsService.getById(id));
240
-        }catch (Exception e){
241
-            e.printStackTrace();
242
-            logger.error("taGoodsGet -=- {}",e.toString());
243
-            responseBean.addError(e.getMessage());
244
-        }
245
-        return responseBean;
246
-    }
247
-    
248
-    /**
249
-     * 兑换商品接口
250
-     * @param id
251
-     * @param request
252
-     * @return
253
-     */
254
-    @RequestMapping(value="/wx/goods/exchange/{id}",method= RequestMethod.POST)
255
-    public ResponseBean wxExchangeGoods(@PathVariable Integer id, HttpServletRequest request){
256
-        ResponseBean responseBean = new ResponseBean();
257
-        try {
258
-            String openid = JWTUtils.getSubject(request);
259
-            //兑换商品
260
-            String state = iTaGoodsService.exchangeGoods(id,openid);
261
-            if (state.equals(CommConstant.SUCCESS)){
262
-                responseBean.addSuccess("兑换成功");
263
-            }else{
264
-                responseBean.addError(state);
265
-            }
266
-        }catch (Exception e){
267
-            e.printStackTrace();
268
-            logger.error("taGoodsGet -=- {}",e.toString());
269
-            responseBean.addError(e.getMessage());
270
-        }
271
-        return responseBean;
272
-    }
273
-}
1
+package com.huiju.estateagents.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.huiju.estateagents.base.BaseController;
7
+import com.huiju.estateagents.base.ResponseBean;
8
+import com.huiju.estateagents.common.CommConstant;
9
+import com.huiju.estateagents.common.JWTUtils;
10
+import com.huiju.estateagents.common.StringUtils;
11
+import com.huiju.estateagents.entity.TaGoods;
12
+import com.huiju.estateagents.service.ITaBuildingService;
13
+import com.huiju.estateagents.service.ITaGoodsService;
14
+import org.slf4j.Logger;
15
+import org.slf4j.LoggerFactory;
16
+import org.springframework.beans.factory.annotation.Autowired;
17
+import org.springframework.web.bind.annotation.PathVariable;
18
+import org.springframework.web.bind.annotation.RequestBody;
19
+import org.springframework.web.bind.annotation.RequestMapping;
20
+import org.springframework.web.bind.annotation.RequestMethod;
21
+import org.springframework.web.bind.annotation.RequestParam;
22
+import org.springframework.web.bind.annotation.ResponseBody;
23
+import org.springframework.web.bind.annotation.RestController;
24
+
25
+import javax.servlet.http.HttpServletRequest;
26
+import java.lang.invoke.ConstantCallSite;
27
+
28
+/**
29
+ * <p>
30
+    * 商品表  前端控制器
31
+    * </p>
32
+ *
33
+ * @author jobob
34
+ * @since 2019-07-25
35
+ */
36
+@RestController
37
+@RequestMapping("/api")
38
+public class TaGoodsController extends BaseController {
39
+
40
+    private final Logger logger = LoggerFactory.getLogger(TaGoodsController.class);
41
+
42
+    @Autowired
43
+    public ITaGoodsService iTaGoodsService;
44
+
45
+    @Autowired
46
+    public ITaBuildingService iTaBuildingService;
47
+
48
+    /**
49
+     * 分页查询列表
50
+     * @param pageNum
51
+     * @param pageSize
52
+     * @return
53
+     */
54
+    @RequestMapping(value="/admin/taGoods",method= RequestMethod.GET)
55
+    public ResponseBean taGoodsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
56
+                                    @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
57
+                                    @RequestParam(value = "goodsName",required = false) String goodsName,
58
+                                    @RequestParam(value ="priceLesser",required = false) Integer priceLesser,
59
+                                    @RequestParam(value ="priceGreater",required = false) Integer priceGreater,
60
+                                    @RequestParam(value ="status",required = false) Integer status){
61
+        ResponseBean responseBean = new ResponseBean();
62
+        try {
63
+            //使用分页插件
64
+		    IPage<TaGoods> pg = new Page<>(pageNum, pageSize);
65
+            QueryWrapper<TaGoods> queryWrapper = new QueryWrapper<>();
66
+            queryWrapper.like(!StringUtils.isEmpty(goodsName),"goods_name",goodsName);
67
+            queryWrapper.lt(null!=priceGreater,"point_price",priceGreater);
68
+            queryWrapper.gt(null != priceLesser,"point_price",priceLesser);
69
+            queryWrapper.eq(null != status,"status",status);
70
+            queryWrapper.orderByDesc("create_date");
71
+
72
+            IPage<TaGoods> result = iTaGoodsService.page(pg, queryWrapper);
73
+            responseBean.addSuccess(result);
74
+        }catch (Exception e){
75
+            e.printStackTrace();
76
+            logger.error("taGoodsList -=- {}",e.toString());
77
+            responseBean.addError(e.getMessage());
78
+        }
79
+        return responseBean;
80
+    }
81
+
82
+    /**
83
+     * 保存对象
84
+     * @param taGoods 实体对象
85
+     * @return
86
+     */
87
+    @RequestMapping(value="/admin/taGoods/add",method= RequestMethod.POST)
88
+    public ResponseBean taGoodsAdd(@RequestBody TaGoods taGoods){
89
+        ResponseBean responseBean = new ResponseBean();
90
+        try {
91
+
92
+            Integer cityId = iTaBuildingService.getCityById(taGoods.getBuildingId());
93
+            taGoods.setCityId(cityId);
94
+
95
+            if (iTaGoodsService.save(taGoods)){
96
+                responseBean.addSuccess(taGoods);
97
+            }else {
98
+                responseBean.addError("fail");
99
+            }
100
+        }catch (Exception e){
101
+            e.printStackTrace();
102
+            logger.error("taGoodsAdd -=- {}",e.toString());
103
+            responseBean.addError(e.getMessage());
104
+        }
105
+        return responseBean;
106
+    }
107
+
108
+    /**
109
+     * 根据id删除对象
110
+     * @param id  实体ID
111
+     */
112
+    @ResponseBody
113
+    @RequestMapping(value="/taGoods/{id}", method= RequestMethod.DELETE)
114
+    public ResponseBean taGoodsDelete(@PathVariable Integer id){
115
+        ResponseBean responseBean = new ResponseBean();
116
+        try {
117
+            if(iTaGoodsService.removeById(id)){
118
+                responseBean.addSuccess("success");
119
+            }else {
120
+                responseBean.addError("fail");
121
+            }
122
+        }catch (Exception e){
123
+            e.printStackTrace();
124
+            logger.error("taGoodsDelete -=- {}",e.toString());
125
+            responseBean.addError(e.getMessage());
126
+        }
127
+        return responseBean;
128
+    }
129
+
130
+    /**
131
+     * 修改对象
132
+     * @param taGoods 实体对象
133
+     * @return
134
+     */
135
+    @RequestMapping(value="/admin/taGoods",method= RequestMethod.PUT)
136
+    public ResponseBean taGoodsUpdate(@RequestBody TaGoods taGoods){
137
+        ResponseBean responseBean = new ResponseBean();
138
+        try {
139
+
140
+            Integer cityId = iTaBuildingService.getCityById(taGoods.getBuildingId());
141
+            taGoods.setCityId(cityId);
142
+
143
+            if (iTaGoodsService.updateById(taGoods)){
144
+                responseBean.addSuccess(taGoods);
145
+            }else {
146
+                responseBean.addError("fail");
147
+            }
148
+        }catch (Exception e){
149
+            e.printStackTrace();
150
+            logger.error("taGoodsUpdate -=- {}",e.toString());
151
+            responseBean.addError(e.getMessage());
152
+        }
153
+        return responseBean;
154
+    }
155
+    
156
+    /**
157
+     * 修改对象
158
+     * @param taGoods 实体对象
159
+     * @return
160
+     */
161
+    @RequestMapping(value="/admin/taGoods/change",method= RequestMethod.PUT)
162
+    public ResponseBean taGoodsChange(@RequestBody TaGoods taGoods){
163
+        ResponseBean responseBean = new ResponseBean();
164
+        try {
165
+            if(null != taGoods.getStatus() && taGoods.getStatus().equals(CommConstant.STATUS_NORMAL)){
166
+                taGoods.setStatus(CommConstant.STATUS_UNACCALIMED);
167
+            }else {
168
+                taGoods.setStatus(CommConstant.STATUS_NORMAL);
169
+            }
170
+            if (iTaGoodsService.updateById(taGoods)){
171
+                responseBean.addSuccess(taGoods);
172
+            }else {
173
+                responseBean.addError("fail");
174
+            }
175
+        }catch (Exception e){
176
+            e.printStackTrace();
177
+            logger.error("taGoodsUpdate -=- {}",e.toString());
178
+            responseBean.addError(e.getMessage());
179
+        }
180
+        return responseBean;
181
+    }
182
+
183
+    /**
184
+     * 根据id查询对象
185
+     * @param id  实体ID
186
+     */
187
+    @RequestMapping(value="/admin/taGoods/{id}",method= RequestMethod.GET)
188
+    public ResponseBean taGoodsGet(@PathVariable Integer id){
189
+        ResponseBean responseBean = new ResponseBean();
190
+        try {
191
+            responseBean.addSuccess(iTaGoodsService.getById(id));
192
+        }catch (Exception e){
193
+            e.printStackTrace();
194
+            logger.error("taGoodsDelete -=- {}",e.toString());
195
+            responseBean.addError(e.getMessage());
196
+        }
197
+        return responseBean;
198
+    }
199
+    
200
+    /**
201
+     * 分页查询列表
202
+     * @param pageNum
203
+     * @param pageSize
204
+     * @return
205
+     */
206
+    @RequestMapping(value="/wx/goods",method= RequestMethod.GET)
207
+    public ResponseBean wxGoodsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
208
+                                    @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
209
+                                    @RequestParam(value = "buildingId",required = false) String buildingId,
210
+                                    @RequestParam(value = "orgId",required = false) Integer orgId){
211
+        ResponseBean responseBean = new ResponseBean();
212
+        try {
213
+            //使用分页插件
214
+            IPage<TaGoods> pg = new Page<>(pageNum, pageSize);
215
+            QueryWrapper<TaGoods> queryWrapper = new QueryWrapper<>();
216
+            queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
217
+            if (!StringUtils.isEmpty(buildingId)){
218
+                queryWrapper.eq("building_id", buildingId);
219
+            }
220
+            if (null != orgId){
221
+                queryWrapper.eq("org_id", orgId);
222
+            }
223
+            queryWrapper.orderByDesc("order_no");
224
+            queryWrapper.orderByDesc("create_date");
225
+            
226
+            IPage<TaGoods> result = iTaGoodsService.page(pg, queryWrapper);
227
+            responseBean.addSuccess(result);
228
+        }catch (Exception e){
229
+            e.printStackTrace();
230
+            logger.error("taGoodsList -=- {}",e.toString());
231
+            responseBean.addError(e.getMessage());
232
+        }
233
+        return responseBean;
234
+    }
235
+    
236
+    
237
+    /**
238
+     * 根据id查询对象
239
+     * @param id  实体ID
240
+     */
241
+    @RequestMapping(value="/wx/goods/{id}",method= RequestMethod.GET)
242
+    public ResponseBean wxGoodsGet(@PathVariable Integer id){
243
+        ResponseBean responseBean = new ResponseBean();
244
+        try {
245
+            responseBean.addSuccess(iTaGoodsService.getById(id));
246
+        }catch (Exception e){
247
+            e.printStackTrace();
248
+            logger.error("taGoodsGet -=- {}",e.toString());
249
+            responseBean.addError(e.getMessage());
250
+        }
251
+        return responseBean;
252
+    }
253
+    
254
+    /**
255
+     * 兑换商品接口
256
+     * @param id
257
+     * @param request
258
+     * @return
259
+     */
260
+    @RequestMapping(value="/wx/goods/exchange/{id}",method= RequestMethod.POST)
261
+    public ResponseBean wxExchangeGoods(@PathVariable Integer id, HttpServletRequest request){
262
+        ResponseBean responseBean = new ResponseBean();
263
+        try {
264
+            String openid = JWTUtils.getSubject(request);
265
+            //兑换商品
266
+            String state = iTaGoodsService.exchangeGoods(id,openid);
267
+            if (state.equals(CommConstant.SUCCESS)){
268
+                responseBean.addSuccess("兑换成功");
269
+            }else{
270
+                responseBean.addError(state);
271
+            }
272
+        }catch (Exception e){
273
+            e.printStackTrace();
274
+            logger.error("taGoodsGet -=- {}",e.toString());
275
+            responseBean.addError(e.getMessage());
276
+        }
277
+        return responseBean;
278
+    }
279
+}

+ 5
- 2
src/main/java/com/huiju/estateagents/controller/TaPersonController.java Целия файл

285
             Integer pageNumber,
285
             Integer pageNumber,
286
             Integer pageSize,
286
             Integer pageSize,
287
             String name,
287
             String name,
288
-            String phone
288
+            String phone,
289
+            Integer status,
290
+            String buildingId,
291
+            String personTags
289
     ) {
292
     ) {
290
         if (null == pageNumber) pageNumber = 1;
293
         if (null == pageNumber) pageNumber = 1;
291
         if (null == pageSize) pageSize = 10;
294
         if (null == pageSize) pageSize = 10;
292
 
295
 
293
-        IPage<TaPerson> taPersonIPage = taPersonService.getPersonList(pageNumber, pageSize, CommConstant.PERSON_REALTY_CONSULTANT, name, phone);
296
+        IPage<TaPerson> taPersonIPage = taPersonService.getPersonList(pageNumber, pageSize, CommConstant.PERSON_REALTY_CONSULTANT, name, phone,status,buildingId,personTags);
294
         return ResponseBean.success(taPersonIPage);
297
         return ResponseBean.success(taPersonIPage);
295
     }
298
     }
296
 
299
 

+ 279
- 278
src/main/java/com/huiju/estateagents/controller/TaRecommendCustomerController.java Целия файл

1
-package com.huiju.estateagents.controller;
2
-
3
-
4
-import com.huiju.estateagents.base.ResponseBean;
5
-import com.huiju.estateagents.common.CommConstant;
6
-import com.huiju.estateagents.common.JWTUtils;
7
-import com.huiju.estateagents.entity.TaPerson;
8
-import com.huiju.estateagents.entity.TaRecommendCustomer;
9
-import com.huiju.estateagents.event.EventBus;
10
-import com.huiju.estateagents.service.ITaPersonService;
11
-import com.huiju.estateagents.service.ITaRecommendCustomerService;
12
-import org.springframework.beans.factory.annotation.Autowired;
13
-import org.springframework.context.ApplicationContext;
14
-import org.springframework.web.bind.annotation.*;
15
-
16
-import com.huiju.estateagents.base.BaseController;
17
-
18
-import javax.annotation.Resource;
19
-import javax.servlet.http.HttpServletRequest;
20
-import java.util.List;
21
-
22
-/**
23
- * <p>
24
- * 推荐客户表 前端控制器
25
- * </p>
26
- *
27
- * @author jobob
28
- * @since 2019-05-10
29
- */
30
-@RestController
31
-@RequestMapping("/api")
32
-public class TaRecommendCustomerController extends BaseController {
33
-
34
-    @Autowired
35
-    ITaRecommendCustomerService taRecommendCustomerService;
36
-
37
-    @Autowired
38
-    ITaPersonService taPersonService;
39
-
40
-    @Resource
41
-    private ApplicationContext applicationContext;
42
-
43
-    /**
44
-     * 我的客户列表
45
-     * @param pageNumber
46
-     * @param pageSize
47
-     * @param keywords
48
-     * @param request
49
-     * @return
50
-     */
51
-    @GetMapping("/wx/customer/list")
52
-    public ResponseBean getMyCustList(@RequestParam int pageNumber, @RequestParam int pageSize, String keywords, HttpServletRequest request) {
53
-        if (pageNumber < 0 || pageSize < 0) {
54
-            return ResponseBean.error("分页参数不正确", ResponseBean.ERROR_ILLEGAL_PARAMS);
55
-        }
56
-
57
-        String openid = JWTUtils.getSubject(request);
58
-        return taRecommendCustomerService.getMyCustList(openid, keywords, pageNumber, pageSize);
59
-    }
60
-
61
-    /**
62
-     * 客户详情
63
-     * @param id
64
-     * @return
65
-     */
66
-    @GetMapping("/wx/customer/{id}")
67
-    public ResponseBean getCustDetail(@PathVariable String id) {
68
-        if (null == id || "".equals(id.trim())) {
69
-            return ResponseBean.error("请求地址错误", ResponseBean.ERROR_ILLEGAL_PARAMS);
70
-        }
71
-
72
-        return taRecommendCustomerService.getCustDetail(id);
73
-    }
74
-
75
-    /**
76
-     * 客户编辑
77
-     * @param paramStr
78
-     * @return
79
-     */
80
-    @PostMapping("/wx/customer/edit")
81
-    public ResponseBean updateCust(@RequestBody String paramStr) {
82
-        return taRecommendCustomerService.updateCustByJSON(paramStr);
83
-    }
84
-
85
-    /**
86
-     * 推荐客户
87
-     * @param paramStr
88
-     * @param request
89
-     * @return
90
-     */
91
-    @PostMapping("/wx/customer/new")
92
-    public ResponseBean recommendCust(@RequestBody String paramStr, HttpServletRequest request) {
93
-        String openid = JWTUtils.getSubject(request);
94
-        return taRecommendCustomerService.recommendCust(paramStr, openid);
95
-    }
96
-
97
-    @PostMapping("/wx/customer/recommend")
98
-    public ResponseBean getUnSignedCustomerList ( @RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
99
-                                                  @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
100
-                                                  @RequestParam(value ="today",defaultValue = "false") String buildingId,
101
-                                                  HttpServletRequest request){
102
-        String openid = JWTUtils.getSubject(request);
103
-        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
104
-        if (null == taPersons || taPersons.size() != 1) {
105
-            return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
106
-        }
107
-        TaPerson person = taPersons.get(0);
108
-        try{
109
-            return ResponseBean.success(taRecommendCustomerService.getUnSignedCustomerList(pageNumber,pageSize,buildingId,person.getPersonId()));
110
-        }catch (Exception e){
111
-            e.printStackTrace();
112
-            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
113
-        }
114
-    }
115
-
116
-    @GetMapping("/admin/customer/recommend")
117
-    public ResponseBean getCustomerList (@RequestParam(value ="name",required = false) String name,
118
-                                         @RequestParam(value ="tel",required = false) String tel,
119
-                                         @RequestParam(value ="buildingId",required = false) String buildingId,
120
-                                         @RequestParam(value ="consultName",required = false) String consultName,
121
-                                         @RequestParam(value ="consultTel",required = false) String consultTel,
122
-                                         @RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
123
-                                         @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
124
-                                         @RequestParam(value ="entryType",required = false) String entryType,
125
-                                         @RequestParam(value ="verifyStatus",required = false) String verifyStatus){
126
-        try{
127
-            return ResponseBean.success(taRecommendCustomerService.getCustomerList(pageNumber,pageSize,buildingId,name,tel,consultName,consultTel,entryType,verifyStatus));
128
-        }catch (Exception e){
129
-            e.printStackTrace();
130
-            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
131
-        }
132
-    }
133
-
134
-    @GetMapping("/admin/customer/recommend/{customerId}")
135
-    public ResponseBean getCustomersIRecommended (@RequestParam int pageNumber, @RequestParam int pageSize, @PathVariable String customerId){
136
-        String buildingId="";
137
-        try{
138
-            return ResponseBean.success(taRecommendCustomerService.getCustomersIRecommended(pageNumber,pageSize,customerId,buildingId));
139
-        }catch (Exception e){
140
-            e.printStackTrace();
141
-            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
142
-        }
143
-    }
144
-
145
-        /**
146
-     * 修改对象
147
-     * @param taRecommendCustomer 实体对象
148
-     * @return
149
-     */
150
-    @RequestMapping(value="/wx/customer/recommend/edit/{id}",method= RequestMethod.PUT)
151
-    public ResponseBean taRecommendCustomerUpdateWx(@PathVariable String id,
152
-                                        @RequestBody TaRecommendCustomer taRecommendCustomer){
153
-        ResponseBean responseBean = new ResponseBean();
154
-        taRecommendCustomer.setCustomerId(id);
155
-        try {
156
-            if (taRecommendCustomerService.updateById(taRecommendCustomer)){
157
-                responseBean.addSuccess(taRecommendCustomer);
158
-            }else {
159
-                responseBean.addError("fail");
160
-            }
161
-        }catch (Exception e){
162
-            e.printStackTrace();
163
-            responseBean.addError(e.getMessage());
164
-        }
165
-        return responseBean;
166
-    }
167
-    /**
168
-     * 修改对象
169
-     * @param taRecommendCustomer 实体对象
170
-     * @return
171
-     */
172
-    @RequestMapping(value="/admin/customer/recommend/edit/{id}",method= RequestMethod.PUT)
173
-    public ResponseBean taRecommendCustomerUpdate(@PathVariable String id,
174
-            @RequestBody TaRecommendCustomer taRecommendCustomer){
175
-        ResponseBean responseBean = new ResponseBean();
176
-        taRecommendCustomer.setCustomerId(id);
177
-        try {
178
-            if (taRecommendCustomerService.updateById(taRecommendCustomer)){
179
-                responseBean.addSuccess(taRecommendCustomer);
180
-            }else {
181
-                responseBean.addError("fail");
182
-            }
183
-        }catch (Exception e){
184
-            e.printStackTrace();
185
-            responseBean.addError(e.getMessage());
186
-        }
187
-        return responseBean;
188
-    }
189
-
190
-    @RequestMapping(value = "/wx/customer/recommend/get/{id}", method = RequestMethod.GET)
191
-    public ResponseBean getSingleCustomer(@PathVariable(value = "id") String customerId) {
192
-        ResponseBean responseBean = new ResponseBean();
193
-        try {
194
-            responseBean.addSuccess(taRecommendCustomerService.getById(customerId));
195
-        }catch (Exception e){
196
-            e.printStackTrace();
197
-            responseBean.addError(e.getMessage());
198
-        }
199
-        return responseBean;
200
-    }
201
-
202
-
203
-    @RequestMapping(value = "/admin/customer/recommend/getById/{id}", method = RequestMethod.GET)
204
-    public ResponseBean getRecommendCustomerById(@PathVariable(value = "id") String customerId) {
205
-        ResponseBean responseBean = new ResponseBean();
206
-        try {
207
-            responseBean.addSuccess(taRecommendCustomerService.getCustomerById(customerId));
208
-        }catch (Exception e){
209
-            e.printStackTrace();
210
-            responseBean.addError(e.getMessage());
211
-        }
212
-        return responseBean;
213
-    }
214
-
215
-
216
-    @GetMapping(value = "/admin/customer/recommend/get/{id}")
217
-    public ResponseBean getCutomerDetail(@PathVariable String id) {
218
-        ResponseBean responseBean = new ResponseBean();
219
-        try {
220
-            responseBean.addSuccess(taRecommendCustomerService.getCustomerDetail(id));
221
-        }catch (Exception e){
222
-            e.printStackTrace();
223
-            responseBean.addError(e.getMessage());
224
-        }
225
-        return responseBean;
226
-    }
227
-
228
-    @GetMapping("/admin/customer/recommend/drift")
229
-    public ResponseBean getDriftCustomerList (@RequestParam(value ="buildingId",defaultValue = "false") String buildingId,
230
-                                         @RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
231
-                                         @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
232
-        try{
233
-            return ResponseBean.success(taPersonService.getDriftCustomerList(pageNumber,pageSize,buildingId));
234
-        }catch (Exception e){
235
-            e.printStackTrace();
236
-            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
237
-        }
238
-    }
239
-
240
-    /**
241
-     * 修改对象
242
-     * @return
243
-     */
244
-    @RequestMapping(value="/admin/customer/recommend/verify/{id}",method= RequestMethod.PUT)
245
-    public ResponseBean taRecommendCustomerVerify(@PathVariable String id,@RequestParam Integer verifyStatus, @RequestParam String verifyRemark){
246
-        if (null == verifyStatus) {
247
-            return ResponseBean.error("审核结果非法", ResponseBean.ERROR_ILLEGAL_PARAMS);
248
-        }
249
-
250
-        ResponseBean responseBean = new ResponseBean();
251
-        try {
252
-            TaRecommendCustomer taRecommendCustomer = taRecommendCustomerService.getById(id);
253
-            if(taRecommendCustomer.getVerifyStatus() != CommConstant.VERIFY_READY){
254
-                taRecommendCustomer.setVerifyStatus(verifyStatus);
255
-                taRecommendCustomer.setVerifyRemark(verifyRemark);
256
-                if (taRecommendCustomerService.updateById(taRecommendCustomer)){
257
-
258
-                    // 审核通过增加积分
259
-                    if (CommConstant.VERIFY_AGREE == verifyStatus) {
260
-                        applicationContext.publishEvent(new EventBus(taRecommendCustomer, EventBus.EventType.RecommendCustomer));
261
-                    }
262
-
263
-                    responseBean.addSuccess(taRecommendCustomer);
264
-                }else {
265
-                    responseBean.addError("fail");
266
-                }
267
-            } else {
268
-                responseBean.addSuccess("客户已审核");
269
-            }
270
-
271
-        }catch (Exception e){
272
-            e.printStackTrace();
273
-            responseBean.addError(e.getMessage());
274
-        }
275
-        return responseBean;
276
-    }
277
-
278
-}
1
+package com.huiju.estateagents.controller;
2
+
3
+
4
+import com.huiju.estateagents.base.ResponseBean;
5
+import com.huiju.estateagents.common.CommConstant;
6
+import com.huiju.estateagents.common.JWTUtils;
7
+import com.huiju.estateagents.entity.TaPerson;
8
+import com.huiju.estateagents.entity.TaRecommendCustomer;
9
+import com.huiju.estateagents.event.EventBus;
10
+import com.huiju.estateagents.service.ITaPersonService;
11
+import com.huiju.estateagents.service.ITaRecommendCustomerService;
12
+import org.springframework.beans.factory.annotation.Autowired;
13
+import org.springframework.context.ApplicationContext;
14
+import org.springframework.web.bind.annotation.*;
15
+
16
+import com.huiju.estateagents.base.BaseController;
17
+
18
+import javax.annotation.Resource;
19
+import javax.servlet.http.HttpServletRequest;
20
+import java.util.List;
21
+
22
+/**
23
+ * <p>
24
+ * 推荐客户表 前端控制器
25
+ * </p>
26
+ *
27
+ * @author jobob
28
+ * @since 2019-05-10
29
+ */
30
+@RestController
31
+@RequestMapping("/api")
32
+public class TaRecommendCustomerController extends BaseController {
33
+
34
+    @Autowired
35
+    ITaRecommendCustomerService taRecommendCustomerService;
36
+
37
+    @Autowired
38
+    ITaPersonService taPersonService;
39
+
40
+    @Resource
41
+    private ApplicationContext applicationContext;
42
+
43
+    /**
44
+     * 我的客户列表
45
+     * @param pageNumber
46
+     * @param pageSize
47
+     * @param keywords
48
+     * @param request
49
+     * @return
50
+     */
51
+    @GetMapping("/wx/customer/list")
52
+    public ResponseBean getMyCustList(@RequestParam int pageNumber, @RequestParam int pageSize, String keywords, HttpServletRequest request) {
53
+        if (pageNumber < 0 || pageSize < 0) {
54
+            return ResponseBean.error("分页参数不正确", ResponseBean.ERROR_ILLEGAL_PARAMS);
55
+        }
56
+
57
+        String openid = JWTUtils.getSubject(request);
58
+        return taRecommendCustomerService.getMyCustList(openid, keywords, pageNumber, pageSize);
59
+    }
60
+
61
+    /**
62
+     * 客户详情
63
+     * @param id
64
+     * @return
65
+     */
66
+    @GetMapping("/wx/customer/{id}")
67
+    public ResponseBean getCustDetail(@PathVariable String id) {
68
+        if (null == id || "".equals(id.trim())) {
69
+            return ResponseBean.error("请求地址错误", ResponseBean.ERROR_ILLEGAL_PARAMS);
70
+        }
71
+
72
+        return taRecommendCustomerService.getCustDetail(id);
73
+    }
74
+
75
+    /**
76
+     * 客户编辑
77
+     * @param paramStr
78
+     * @return
79
+     */
80
+    @PostMapping("/wx/customer/edit")
81
+    public ResponseBean updateCust(@RequestBody String paramStr) {
82
+        return taRecommendCustomerService.updateCustByJSON(paramStr);
83
+    }
84
+
85
+    /**
86
+     * 推荐客户
87
+     * @param paramStr
88
+     * @param request
89
+     * @return
90
+     */
91
+    @PostMapping("/wx/customer/new")
92
+    public ResponseBean recommendCust(@RequestBody String paramStr, HttpServletRequest request) {
93
+        String openid = JWTUtils.getSubject(request);
94
+        return taRecommendCustomerService.recommendCust(paramStr, openid);
95
+    }
96
+
97
+    @PostMapping("/wx/customer/recommend")
98
+    public ResponseBean getUnSignedCustomerList ( @RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
99
+                                                  @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
100
+                                                  @RequestParam(value ="today",defaultValue = "false") String buildingId,
101
+                                                  HttpServletRequest request){
102
+        String openid = JWTUtils.getSubject(request);
103
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
104
+        if (null == taPersons || taPersons.size() != 1) {
105
+            return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
106
+        }
107
+        TaPerson person = taPersons.get(0);
108
+        try{
109
+            return ResponseBean.success(taRecommendCustomerService.getUnSignedCustomerList(pageNumber,pageSize,buildingId,person.getPersonId()));
110
+        }catch (Exception e){
111
+            e.printStackTrace();
112
+            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
113
+        }
114
+    }
115
+
116
+    @GetMapping("/admin/customer/recommend")
117
+    public ResponseBean getCustomerList (@RequestParam(value ="name",required = false) String name,
118
+                                         @RequestParam(value ="tel",required = false) String tel,
119
+                                         @RequestParam(value ="buildingId",required = false) String buildingId,
120
+                                         @RequestParam(value ="consultName",required = false) String consultName,
121
+                                         @RequestParam(value ="consultTel",required = false) String consultTel,
122
+                                         @RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
123
+                                         @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
124
+                                         @RequestParam(value ="entryType",required = false) String entryType,
125
+                                         @RequestParam(value ="verifyStatus",required = false) String verifyStatus,
126
+                                         @RequestParam(value = "sex",required = false)Integer sex){
127
+        try{
128
+            return ResponseBean.success(taRecommendCustomerService.getCustomerList(pageNumber,pageSize,buildingId,name,tel,consultName,consultTel,entryType,verifyStatus,sex));
129
+        }catch (Exception e){
130
+            e.printStackTrace();
131
+            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
132
+        }
133
+    }
134
+
135
+    @GetMapping("/admin/customer/recommend/{customerId}")
136
+    public ResponseBean getCustomersIRecommended (@RequestParam int pageNumber, @RequestParam int pageSize, @PathVariable String customerId){
137
+        String buildingId="";
138
+        try{
139
+            return ResponseBean.success(taRecommendCustomerService.getCustomersIRecommended(pageNumber,pageSize,customerId,buildingId));
140
+        }catch (Exception e){
141
+            e.printStackTrace();
142
+            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
143
+        }
144
+    }
145
+
146
+        /**
147
+     * 修改对象
148
+     * @param taRecommendCustomer 实体对象
149
+     * @return
150
+     */
151
+    @RequestMapping(value="/wx/customer/recommend/edit/{id}",method= RequestMethod.PUT)
152
+    public ResponseBean taRecommendCustomerUpdateWx(@PathVariable String id,
153
+                                        @RequestBody TaRecommendCustomer taRecommendCustomer){
154
+        ResponseBean responseBean = new ResponseBean();
155
+        taRecommendCustomer.setCustomerId(id);
156
+        try {
157
+            if (taRecommendCustomerService.updateById(taRecommendCustomer)){
158
+                responseBean.addSuccess(taRecommendCustomer);
159
+            }else {
160
+                responseBean.addError("fail");
161
+            }
162
+        }catch (Exception e){
163
+            e.printStackTrace();
164
+            responseBean.addError(e.getMessage());
165
+        }
166
+        return responseBean;
167
+    }
168
+    /**
169
+     * 修改对象
170
+     * @param taRecommendCustomer 实体对象
171
+     * @return
172
+     */
173
+    @RequestMapping(value="/admin/customer/recommend/edit/{id}",method= RequestMethod.PUT)
174
+    public ResponseBean taRecommendCustomerUpdate(@PathVariable String id,
175
+            @RequestBody TaRecommendCustomer taRecommendCustomer){
176
+        ResponseBean responseBean = new ResponseBean();
177
+        taRecommendCustomer.setCustomerId(id);
178
+        try {
179
+            if (taRecommendCustomerService.updateById(taRecommendCustomer)){
180
+                responseBean.addSuccess(taRecommendCustomer);
181
+            }else {
182
+                responseBean.addError("fail");
183
+            }
184
+        }catch (Exception e){
185
+            e.printStackTrace();
186
+            responseBean.addError(e.getMessage());
187
+        }
188
+        return responseBean;
189
+    }
190
+
191
+    @RequestMapping(value = "/wx/customer/recommend/get/{id}", method = RequestMethod.GET)
192
+    public ResponseBean getSingleCustomer(@PathVariable(value = "id") String customerId) {
193
+        ResponseBean responseBean = new ResponseBean();
194
+        try {
195
+            responseBean.addSuccess(taRecommendCustomerService.getById(customerId));
196
+        }catch (Exception e){
197
+            e.printStackTrace();
198
+            responseBean.addError(e.getMessage());
199
+        }
200
+        return responseBean;
201
+    }
202
+
203
+
204
+    @RequestMapping(value = "/admin/customer/recommend/getById/{id}", method = RequestMethod.GET)
205
+    public ResponseBean getRecommendCustomerById(@PathVariable(value = "id") String customerId) {
206
+        ResponseBean responseBean = new ResponseBean();
207
+        try {
208
+            responseBean.addSuccess(taRecommendCustomerService.getCustomerById(customerId));
209
+        }catch (Exception e){
210
+            e.printStackTrace();
211
+            responseBean.addError(e.getMessage());
212
+        }
213
+        return responseBean;
214
+    }
215
+
216
+
217
+    @GetMapping(value = "/admin/customer/recommend/get/{id}")
218
+    public ResponseBean getCutomerDetail(@PathVariable String id) {
219
+        ResponseBean responseBean = new ResponseBean();
220
+        try {
221
+            responseBean.addSuccess(taRecommendCustomerService.getCustomerDetail(id));
222
+        }catch (Exception e){
223
+            e.printStackTrace();
224
+            responseBean.addError(e.getMessage());
225
+        }
226
+        return responseBean;
227
+    }
228
+
229
+    @GetMapping("/admin/customer/recommend/drift")
230
+    public ResponseBean getDriftCustomerList (@RequestParam(value ="buildingId",defaultValue = "false") String buildingId,
231
+                                         @RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
232
+                                         @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
233
+        try{
234
+            return ResponseBean.success(taPersonService.getDriftCustomerList(pageNumber,pageSize,buildingId));
235
+        }catch (Exception e){
236
+            e.printStackTrace();
237
+            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
238
+        }
239
+    }
240
+
241
+    /**
242
+     * 修改对象
243
+     * @return
244
+     */
245
+    @RequestMapping(value="/admin/customer/recommend/verify/{id}",method= RequestMethod.PUT)
246
+    public ResponseBean taRecommendCustomerVerify(@PathVariable String id,@RequestParam Integer verifyStatus, @RequestParam String verifyRemark){
247
+        if (null == verifyStatus) {
248
+            return ResponseBean.error("审核结果非法", ResponseBean.ERROR_ILLEGAL_PARAMS);
249
+        }
250
+
251
+        ResponseBean responseBean = new ResponseBean();
252
+        try {
253
+            TaRecommendCustomer taRecommendCustomer = taRecommendCustomerService.getById(id);
254
+            if(taRecommendCustomer.getVerifyStatus() != CommConstant.VERIFY_READY){
255
+                taRecommendCustomer.setVerifyStatus(verifyStatus);
256
+                taRecommendCustomer.setVerifyRemark(verifyRemark);
257
+                if (taRecommendCustomerService.updateById(taRecommendCustomer)){
258
+
259
+                    // 审核通过增加积分
260
+                    if (CommConstant.VERIFY_AGREE == verifyStatus) {
261
+                        applicationContext.publishEvent(new EventBus(taRecommendCustomer, EventBus.EventType.RecommendCustomer));
262
+                    }
263
+
264
+                    responseBean.addSuccess(taRecommendCustomer);
265
+                }else {
266
+                    responseBean.addError("fail");
267
+                }
268
+            } else {
269
+                responseBean.addSuccess("客户已审核");
270
+            }
271
+
272
+        }catch (Exception e){
273
+            e.printStackTrace();
274
+            responseBean.addError(e.getMessage());
275
+        }
276
+        return responseBean;
277
+    }
278
+
279
+}

+ 2
- 1
src/main/java/com/huiju/estateagents/mapper/TaBuildingDynamicMapper.java Целия файл

8
 import org.apache.ibatis.annotations.Param;
8
 import org.apache.ibatis.annotations.Param;
9
 import org.apache.ibatis.annotations.Update;
9
 import org.apache.ibatis.annotations.Update;
10
 
10
 
11
+import java.time.LocalDateTime;
11
 import java.util.Map;
12
 import java.util.Map;
12
 
13
 
13
 /**
14
 /**
26
      * @param page
27
      * @param page
27
      * @return
28
      * @return
28
      */
29
      */
29
-    IPage<TaBuildingDynamic> buildingDynamicList(Page page, @Param("name") String name, @Param("buildingId") String buildingId,@Param("cityId") Integer cityId);
30
+    IPage<TaBuildingDynamic> buildingDynamicList(Page page, @Param("name") String name, @Param("buildingId") String buildingId,@Param("cityId") Integer cityId,@Param("isEnlist") String isEnlist,@Param("time")LocalDateTime time);
30
 
31
 
31
     /**
32
     /**
32
      * 详情
33
      * 详情

+ 2
- 1
src/main/java/com/huiju/estateagents/mapper/TaBuildingMapper.java Целия файл

9
 import org.apache.ibatis.annotations.Select;
9
 import org.apache.ibatis.annotations.Select;
10
 import org.apache.ibatis.annotations.Update;
10
 import org.apache.ibatis.annotations.Update;
11
 
11
 
12
+import java.time.LocalDateTime;
12
 import java.util.List;
13
 import java.util.List;
13
 import java.util.Map;
14
 import java.util.Map;
14
 
15
 
27
      * @param page
28
      * @param page
28
      * @return
29
      * @return
29
      */
30
      */
30
-    List<TaBuilding> buildingList(IPage<TaBuilding> page, @Param("Name") String name, @Param("Code")String code);
31
+    List<TaBuilding> buildingList(IPage<TaBuilding> page, @Param("Name") String name, @Param("Code")String code,@Param("startDate")LocalDateTime startDate, @Param("buildingStatus")String buildingStatus, @Param("marketStatus")String marketStatus, @Param("cityId")Integer cityId, @Param("isMain")Integer isMain);
31
 
32
 
32
     @Update("UPDATE ta_building  SET ${field} = IFNULL(${field}, 0) + #{increment}  WHERE building_id = #{buildingId}")
33
     @Update("UPDATE ta_building  SET ${field} = IFNULL(${field}, 0) + #{increment}  WHERE building_id = #{buildingId}")
33
     void setFieldNum(@Param("buildingId") String buildingId, @Param("field") String field, @Param("increment") int increment);
34
     void setFieldNum(@Param("buildingId") String buildingId, @Param("field") String field, @Param("increment") int increment);

+ 2
- 0
src/main/java/com/huiju/estateagents/mapper/TaPersonMapper.java Целия файл

155
     @Update("UPDATE ta_person  SET ${field} = IFNULL(${field}, 0) + #{increment}  WHERE person_id = #{newsId}")
155
     @Update("UPDATE ta_person  SET ${field} = IFNULL(${field}, 0) + #{increment}  WHERE person_id = #{newsId}")
156
     void setFieldNum(@Param("newsId") String newsId, @Param("field") String field, @Param("increment") int increment);
156
     void setFieldNum(@Param("newsId") String newsId, @Param("field") String field, @Param("increment") int increment);
157
 
157
 
158
+    IPage<TaPerson> getPersonList(IPage<TaPerson> page, @Param("personType")String personType, @Param("name") String name, @Param("phone") String phone,@Param("status") Integer status,@Param("buildingId") String buildingId,@Param("personTags") String personTags);
159
+
158
 
160
 
159
 }
161
 }

+ 31
- 31
src/main/java/com/huiju/estateagents/mapper/TaRecommendCustomerMapper.java Целия файл

1
-package com.huiju.estateagents.mapper;
2
-
3
-import com.baomidou.mybatisplus.core.metadata.IPage;
4
-import com.huiju.estateagents.entity.TaRecommendCustomer;
5
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
6
-import org.apache.ibatis.annotations.Mapper;
7
-import org.apache.ibatis.annotations.Param;
8
-
9
-/**
10
- * <p>
11
- * 推荐客户表 Mapper 接口
12
- * </p>
13
- *
14
- * @author jobob
15
- * @since 2019-05-10
16
- */
17
-@Mapper
18
-public interface TaRecommendCustomerMapper extends BaseMapper<TaRecommendCustomer> {
19
-
20
-    Integer getMyCutsomerNum(@Param("personId") String personId);
21
-
22
-    String getCustomerPersonId(@Param("customerId")String customerId);
23
-
24
-    TaRecommendCustomer getCustomerDetail(@Param("customerId")String customerId);
25
-
26
-    TaRecommendCustomer getCustomerById(@Param("customerId")String customerId);
27
-
28
-    IPage<TaRecommendCustomer> getCustomerList(IPage<TaRecommendCustomer> page,@Param("building") String building, @Param("name") String name, @Param("tel") String tel, @Param("consultName") String consultName, @Param("consultTel") String consultTel,@Param("entryType") String entryType,@Param("verifyStatus") String verifyStatus);
29
-
30
-
31
-}
1
+package com.huiju.estateagents.mapper;
2
+
3
+import com.baomidou.mybatisplus.core.metadata.IPage;
4
+import com.huiju.estateagents.entity.TaRecommendCustomer;
5
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
6
+import org.apache.ibatis.annotations.Mapper;
7
+import org.apache.ibatis.annotations.Param;
8
+
9
+/**
10
+ * <p>
11
+ * 推荐客户表 Mapper 接口
12
+ * </p>
13
+ *
14
+ * @author jobob
15
+ * @since 2019-05-10
16
+ */
17
+@Mapper
18
+public interface TaRecommendCustomerMapper extends BaseMapper<TaRecommendCustomer> {
19
+
20
+    Integer getMyCutsomerNum(@Param("personId") String personId);
21
+
22
+    String getCustomerPersonId(@Param("customerId")String customerId);
23
+
24
+    TaRecommendCustomer getCustomerDetail(@Param("customerId")String customerId);
25
+
26
+    TaRecommendCustomer getCustomerById(@Param("customerId")String customerId);
27
+
28
+    IPage<TaRecommendCustomer> getCustomerList(IPage<TaRecommendCustomer> page,@Param("building") String building, @Param("name") String name, @Param("tel") String tel, @Param("consultName") String consultName, @Param("consultTel") String consultTel,@Param("entryType") String entryType,@Param("verifyStatus") String verifyStatus,@Param("sex") Integer sex);
29
+
30
+
31
+}

+ 2
- 1
src/main/java/com/huiju/estateagents/service/ITaBuildingDynamicService.java Целия файл

8
 import com.huiju.estateagents.entity.TaBuildingDynamic;
8
 import com.huiju.estateagents.entity.TaBuildingDynamic;
9
 import com.huiju.estateagents.entity.TaPerson;
9
 import com.huiju.estateagents.entity.TaPerson;
10
 
10
 
11
+import java.time.LocalDateTime;
11
 import java.util.HashMap;
12
 import java.util.HashMap;
12
 
13
 
13
 /**
14
 /**
24
      * 项目动态管理列表
25
      * 项目动态管理列表
25
      * @return
26
      * @return
26
      */
27
      */
27
-    ResponseBean iBuildingDynamicList(Integer pageNum, Integer pageSize, String name, String buildingId,Integer cityId);
28
+    ResponseBean iBuildingDynamicList(Integer pageNum, Integer pageSize, String name, String buildingId,Integer cityId,String isEnlist, LocalDateTime time);
28
 
29
 
29
     /**
30
     /**
30
      * 项目详情
31
      * 项目详情

+ 3
- 1
src/main/java/com/huiju/estateagents/service/ITaBuildingService.java Целия файл

3
 import com.huiju.estateagents.base.ResponseBean;
3
 import com.huiju.estateagents.base.ResponseBean;
4
 import com.huiju.estateagents.entity.TaBuilding;
4
 import com.huiju.estateagents.entity.TaBuilding;
5
 import com.baomidou.mybatisplus.extension.service.IService;
5
 import com.baomidou.mybatisplus.extension.service.IService;
6
+import org.springframework.web.bind.annotation.RequestParam;
6
 
7
 
8
+import java.time.LocalDateTime;
7
 import java.util.List;
9
 import java.util.List;
8
 
10
 
9
 /**
11
 /**
22
      * @param pageSize
24
      * @param pageSize
23
      * @return
25
      * @return
24
      */
26
      */
25
-    ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code);
27
+    ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code, LocalDateTime startDate, String buildingStatus, String marketStatus, Integer cityId, Integer isMain);
26
 
28
 
27
     /**
29
     /**
28
      * 楼盘详情
30
      * 楼盘详情

+ 1
- 1
src/main/java/com/huiju/estateagents/service/ITaPersonService.java Целия файл

40
 
40
 
41
     TaPerson getPersonByTel(String userPhone);
41
     TaPerson getPersonByTel(String userPhone);
42
 
42
 
43
-    IPage<TaPerson> getPersonList(int pageNumber, int pageSize, String personType, String name, String phone);
43
+    IPage<TaPerson> getPersonList(int pageNumber, int pageSize, String personType, String name, String phone,Integer status,String buildingId,String personTags);
44
 
44
 
45
     TaPerson newPersonByOpenid(String openid);
45
     TaPerson newPersonByOpenid(String openid);
46
 
46
 

+ 1
- 1
src/main/java/com/huiju/estateagents/service/ITaRecommendCustomerService.java Целия файл

26
 
26
 
27
     IPage<TaRecommendCustomer> getUnSignedCustomerList(int pageNumber, int pageSize, String building,String personId);
27
     IPage<TaRecommendCustomer> getUnSignedCustomerList(int pageNumber, int pageSize, String building,String personId);
28
 
28
 
29
-    IPage<TaRecommendCustomer> getCustomerList(int pageNumber, int pageSize, String building,String name,String tel,String consultName,String consultTel,String entryType,String verifyStatus);
29
+    IPage<TaRecommendCustomer> getCustomerList(int pageNumber, int pageSize, String building,String name,String tel,String consultName,String consultTel,String entryType,String verifyStatus,Integer sex);
30
 
30
 
31
     TaRecommendCustomer getCustomerDetail(String customerId);
31
     TaRecommendCustomer getCustomerDetail(String customerId);
32
 
32
 

+ 2
- 2
src/main/java/com/huiju/estateagents/service/impl/TaBuildingDynamicServiceImpl.java Целия файл

64
         binder.registerCustomEditor(Date.class, editor);
64
         binder.registerCustomEditor(Date.class, editor);
65
     }
65
     }
66
     @Override
66
     @Override
67
-    public ResponseBean iBuildingDynamicList(Integer pageNum, Integer pageSize, String name, String buildingId,Integer cityId) {
67
+    public ResponseBean iBuildingDynamicList(Integer pageNum, Integer pageSize, String name, String buildingId,Integer cityId,String isEnlist, LocalDateTime time) {
68
         Page<TaBuildingDynamic> page = new Page<>();
68
         Page<TaBuildingDynamic> page = new Page<>();
69
         page.setSize(pageSize == null ? 10 : pageSize);
69
         page.setSize(pageSize == null ? 10 : pageSize);
70
         page.setCurrent(pageNum == null ? 1 : pageNum);
70
         page.setCurrent(pageNum == null ? 1 : pageNum);
71
 
71
 
72
-        IPage<TaBuildingDynamic> buildingDynamic = buildingDynamicMapper.buildingDynamicList(page, name, buildingId,cityId);
72
+        IPage<TaBuildingDynamic> buildingDynamic = buildingDynamicMapper.buildingDynamicList(page, name, buildingId,cityId,isEnlist,time);
73
         List<TaBuildingDynamic> buildingDynamicList = buildingDynamic.getRecords();
73
         List<TaBuildingDynamic> buildingDynamicList = buildingDynamic.getRecords();
74
         for (TaBuildingDynamic taBuildingDynamic:buildingDynamicList){
74
         for (TaBuildingDynamic taBuildingDynamic:buildingDynamicList){
75
             QueryWrapper<TaActivityDynamicEnlist> taActivityDynamicEnlist= new QueryWrapper<>();
75
             QueryWrapper<TaActivityDynamicEnlist> taActivityDynamicEnlist= new QueryWrapper<>();

+ 2
- 2
src/main/java/com/huiju/estateagents/service/impl/TaBuildingServiceImpl.java Целия файл

64
 
64
 
65
 
65
 
66
     @Override
66
     @Override
67
-    public ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code) {
67
+    public ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code, LocalDateTime startDate, String buildingStatus, String marketStatus, Integer cityId, Integer isMain) {
68
         Page<TaBuilding> page = new Page<>();
68
         Page<TaBuilding> page = new Page<>();
69
         page.setSize(pageSize == null ? 10 : pageSize);
69
         page.setSize(pageSize == null ? 10 : pageSize);
70
         page.setCurrent(pageNum == null ? 1 : pageNum);
70
         page.setCurrent(pageNum == null ? 1 : pageNum);
71
-        List<TaBuilding> building = taBuildingMapper.buildingList(page, name, code);
71
+        List<TaBuilding> building = taBuildingMapper.buildingList(page, name, code,startDate,buildingStatus,marketStatus,cityId,isMain);
72
         page.setRecords(building);
72
         page.setRecords(building);
73
 
73
 
74
         return ResponseBean.success(page);
74
         return ResponseBean.success(page);

+ 7
- 6
src/main/java/com/huiju/estateagents/service/impl/TaPersonServiceImpl.java Целия файл

380
     }
380
     }
381
 
381
 
382
     @Override
382
     @Override
383
-    public IPage<TaPerson> getPersonList(int pageNumber, int pageSize, String personType, String name, String phone) {
384
-        QueryWrapper<TaPerson> queryWrapper = new QueryWrapper<>();
385
-        queryWrapper.eq(!StringUtils.isEmpty(personType), "person_type", personType);
386
-        queryWrapper.like(!StringUtils.isEmpty(name), "name", name);
387
-        queryWrapper.like(!StringUtils.isEmpty(phone), "tel", phone);
383
+    public IPage<TaPerson> getPersonList(int pageNumber, int pageSize, String personType, String name, String phone,Integer status,String buildingId,String personTags) {
384
+//        QueryWrapper<TaPerson> queryWrapper = new QueryWrapper<>();
385
+//        queryWrapper.eq(!StringUtils.isEmpty(personType), "person_type", personType);
386
+//        queryWrapper.like(!StringUtils.isEmpty(name), "name", name);
387
+//        queryWrapper.eq(!StringUtils.isEmpty(phone), "tel", phone);
388
+        //queryWrapper.eq(!StringUtils.isEmpty(buildingId),"building_id",buildingId);
388
 
389
 
389
         IPage<TaPerson> page = new Page<>(pageNumber, pageSize);
390
         IPage<TaPerson> page = new Page<>(pageNumber, pageSize);
390
-        return taPersonMapper.selectPage(page, queryWrapper);
391
+        return taPersonMapper.getPersonList(page,personType,name,phone,status,buildingId,personTags);
391
     }
392
     }
392
 
393
 
393
     @Override
394
     @Override

+ 2
- 2
src/main/java/com/huiju/estateagents/service/impl/TaRecommendCustomerServiceImpl.java Целия файл

247
     }
247
     }
248
 
248
 
249
     @Override
249
     @Override
250
-    public IPage<TaRecommendCustomer> getCustomerList(int pageNumber, int pageSize,String building,String name,String tel,String consultName,String consultTel,String entryType,String verifyStatus){
250
+    public IPage<TaRecommendCustomer> getCustomerList(int pageNumber, int pageSize,String building,String name,String tel,String consultName,String consultTel,String entryType,String verifyStatus,Integer sex){
251
         IPage<TaRecommendCustomer>page = new Page<>(pageNumber,pageSize);
251
         IPage<TaRecommendCustomer>page = new Page<>(pageNumber,pageSize);
252
-        return taRecommendCustomerMapper.getCustomerList(page,building,name,tel,consultName,consultTel,entryType,verifyStatus);
252
+        return taRecommendCustomerMapper.getCustomerList(page,building,name,tel,consultName,consultTel,entryType,verifyStatus,sex);
253
     }
253
     }
254
 
254
 
255
     @Override
255
     @Override

+ 6
- 0
src/main/resources/mapper/TaBuildingDynamicMapper.xml Целия файл

24
         <if test="buildingId != null and buildingId !=''">
24
         <if test="buildingId != null and buildingId !=''">
25
             and building_id = #{buildingId}
25
             and building_id = #{buildingId}
26
         </if>
26
         </if>
27
+        <if test="isEnlist != null and isEnlist !=''">
28
+            and is_enlist = #{isEnlist}
29
+        </if>
27
         <if test="cityId != 0 and cityId != null">
30
         <if test="cityId != 0 and cityId != null">
28
             and city_id = #{cityId}
31
             and city_id = #{cityId}
29
         </if>
32
         </if>
33
+        <if test="time != null">
34
+            and TO_DAYS(create_date) = TO_DAYS(#{time})
35
+        </if>
30
         ORDER BY create_date DESC
36
         ORDER BY create_date DESC
31
   </select>
37
   </select>
32
 
38
 

+ 15
- 0
src/main/resources/mapper/TaBuildingMapper.xml Целия файл

11
             <if test="Code != null and Code != ''">
11
             <if test="Code != null and Code != ''">
12
                 and  ta_building.code like concat('%',#{Code,jdbcType=VARCHAR},'%')
12
                 and  ta_building.code like concat('%',#{Code,jdbcType=VARCHAR},'%')
13
             </if>
13
             </if>
14
+            <if test="startDate != null">
15
+                and  TO_DAYS(ta_building.opening_date ) = TO_DAYS(#{startDate})
16
+            </if>
17
+            <if test="buildingStatus != null and buildingStatus != ''">
18
+                and  ta_building.building_status = #{buildingStatus}
19
+            </if>
20
+            <if test="marketStatus != null and marketStatus != ''">
21
+                and  ta_building.market_status =#{marketStatus}
22
+            </if>
23
+            <if test="cityId != null and cityId != ''">
24
+                and  ta_building.city_id =#{cityId}
25
+            </if>
26
+            <if test="isMain != null and isMain != ''">
27
+                and  ta_building.is_main = #{isMain}
28
+            </if>
14
         </where>
29
         </where>
15
         ORDER BY create_date DESC
30
         ORDER BY create_date DESC
16
     </select>
31
     </select>

+ 30
- 0
src/main/resources/mapper/TaPersonMapper.xml Целия файл

435
         order by temp_date.date DESC
435
         order by temp_date.date DESC
436
     </select>
436
     </select>
437
 
437
 
438
+    <select id="getPersonList" resultType="com.huiju.estateagents.entity.TaPerson">
439
+        SELECT
440
+	a.*
441
+FROM
442
+	ta_person a
443
+	LEFT JOIN ta_person_building b ON a.person_id = b.person_id
444
+	<where>
445
+        1=1
446
+        <if test="personType != null and personType!= ''">
447
+            and a.person_type = #{personType}
448
+        </if>
449
+        <if test="name != null and name!= ''">
450
+            and a.name like CONCAT('%',#{name}, '%')
451
+        </if>
452
+        <if test="personTags != null and personTags!= ''">
453
+            and a.person_tags like CONCAT('%',#{personTags}, '%')
454
+        </if>
455
+        <if test="phone != null and phone!= ''">
456
+            and a.tel = #{phone}
457
+        </if>
458
+        <if test="buildingId != null and buildingId!= ''">
459
+            and b.building_id = #{buildingId}
460
+        </if>
461
+        <if test="status != null">
462
+            and a.status = #{status}
463
+        </if>
464
+    </where>
465
+	GROUP BY a.person_id
466
+    </select>
467
+
438
 </mapper>
468
 </mapper>

+ 3
- 0
src/main/resources/mapper/TaRecommendCustomerMapper.xml Целия файл

66
         <if test="verifyStatus != null and verifyStatus !=''">
66
         <if test="verifyStatus != null and verifyStatus !=''">
67
             and a.verify_status = #{verifyStatus}
67
             and a.verify_status = #{verifyStatus}
68
         </if>
68
         </if>
69
+        <if test="sex != null and sex !=''">
70
+            and a.sex = #{sex}
71
+        </if>
69
 
72
 
70
     </where>
73
     </where>
71
     </select>
74
     </select>