傅行帆 пре 5 година
родитељ
комит
447aebd749

+ 187
- 0
src/main/java/com/huiju/estateagents/controller/TaCustomerMessageController.java Прегледај датотеку

@@ -0,0 +1,187 @@
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.entity.TaCustomerMessage;
11
+import com.huiju.estateagents.entity.TaPerson;
12
+import com.huiju.estateagents.service.ITaCustomerMessageService;
13
+import com.huiju.estateagents.service.ITaPersonService;
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.time.LocalDateTime;
27
+import java.util.List;
28
+
29
+/**
30
+ * <p>
31
+    * 用户留言表  前端控制器
32
+    * </p>
33
+ *
34
+ * @author jobob
35
+ * @since 2019-07-30
36
+ */
37
+@RestController
38
+@RequestMapping("/api")
39
+public class TaCustomerMessageController extends BaseController {
40
+
41
+    private final Logger logger = LoggerFactory.getLogger(TaCustomerMessageController.class);
42
+
43
+    @Autowired
44
+    public ITaCustomerMessageService iTaCustomerMessageService;
45
+
46
+    @Autowired
47
+    private ITaPersonService taPersonService;
48
+
49
+    /**
50
+     * 分页查询列表
51
+     * @param pageNum
52
+     * @param pageSize
53
+     * @return
54
+     */
55
+    @RequestMapping(value="/admin/taCustomerMessage",method= RequestMethod.GET)
56
+    public ResponseBean taCustomerMessageList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
57
+                                              @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
58
+        ResponseBean responseBean = new ResponseBean();
59
+        try {
60
+            //使用分页插件
61
+		    IPage<TaCustomerMessage> pg = new Page<>(pageNum, pageSize);
62
+            QueryWrapper<TaCustomerMessage> queryWrapper = new QueryWrapper<>();
63
+            queryWrapper.orderByDesc("create_date");
64
+
65
+            IPage<TaCustomerMessage> result = iTaCustomerMessageService.page(pg, queryWrapper);
66
+            responseBean.addSuccess(result);
67
+        }catch (Exception e){
68
+            e.printStackTrace();
69
+            logger.error("taCustomerMessageList -=- {}",e.toString());
70
+            responseBean.addError(e.getMessage());
71
+        }
72
+        return responseBean;
73
+    }
74
+
75
+    /**
76
+     * 保存对象
77
+     * @param taCustomerMessage 实体对象
78
+     * @return
79
+     */
80
+    @RequestMapping(value="/taCustomerMessage",method= RequestMethod.POST)
81
+    public ResponseBean taCustomerMessageAdd(@RequestBody TaCustomerMessage taCustomerMessage){
82
+        ResponseBean responseBean = new ResponseBean();
83
+        try {
84
+            if (iTaCustomerMessageService.save(taCustomerMessage)){
85
+                responseBean.addSuccess(taCustomerMessage);
86
+            }else {
87
+                responseBean.addError("fail");
88
+            }
89
+        }catch (Exception e){
90
+            e.printStackTrace();
91
+            logger.error("taCustomerMessageAdd -=- {}",e.toString());
92
+            responseBean.addError(e.getMessage());
93
+        }
94
+        return responseBean;
95
+    }
96
+
97
+    /**
98
+     * 根据id删除对象
99
+     * @param id  实体ID
100
+     */
101
+    @ResponseBody
102
+    @RequestMapping(value="/taCustomerMessage/{id}", method= RequestMethod.DELETE)
103
+    public ResponseBean taCustomerMessageDelete(@PathVariable Integer id){
104
+        ResponseBean responseBean = new ResponseBean();
105
+        try {
106
+            if(iTaCustomerMessageService.removeById(id)){
107
+                responseBean.addSuccess("success");
108
+            }else {
109
+                responseBean.addError("fail");
110
+            }
111
+        }catch (Exception e){
112
+            e.printStackTrace();
113
+            logger.error("taCustomerMessageDelete -=- {}",e.toString());
114
+            responseBean.addError(e.getMessage());
115
+        }
116
+        return responseBean;
117
+    }
118
+
119
+    /**
120
+     * 修改对象
121
+     * @param id  实体ID
122
+     * @param taCustomerMessage 实体对象
123
+     * @return
124
+     */
125
+    @RequestMapping(value="/taCustomerMessage/{id}",method= RequestMethod.PUT)
126
+    public ResponseBean taCustomerMessageUpdate(@PathVariable Integer id,
127
+                                        @RequestBody TaCustomerMessage taCustomerMessage){
128
+        ResponseBean responseBean = new ResponseBean();
129
+        try {
130
+            if (iTaCustomerMessageService.updateById(taCustomerMessage)){
131
+                responseBean.addSuccess(taCustomerMessage);
132
+            }else {
133
+                responseBean.addError("fail");
134
+            }
135
+        }catch (Exception e){
136
+            e.printStackTrace();
137
+            logger.error("taCustomerMessageUpdate -=- {}",e.toString());
138
+            responseBean.addError(e.getMessage());
139
+        }
140
+        return responseBean;
141
+    }
142
+
143
+    /**
144
+     * 根据id查询对象
145
+     * @param id  实体ID
146
+     */
147
+    @RequestMapping(value="/taCustomerMessage/{id}",method= RequestMethod.GET)
148
+    public ResponseBean taCustomerMessageGet(@PathVariable Integer id){
149
+        ResponseBean responseBean = new ResponseBean();
150
+        try {
151
+            responseBean.addSuccess(iTaCustomerMessageService.getById(id));
152
+        }catch (Exception e){
153
+            e.printStackTrace();
154
+            logger.error("taCustomerMessageDelete -=- {}",e.toString());
155
+            responseBean.addError(e.getMessage());
156
+        }
157
+        return responseBean;
158
+    }
159
+    
160
+    /**
161
+     * 保存对象
162
+     * @param taCustomerMessage 实体对象
163
+     * @return
164
+     */
165
+    @RequestMapping(value="/wx/taCustomerMessage",method= RequestMethod.POST)
166
+    public ResponseBean wxCustomerMessageAdd(@RequestBody TaCustomerMessage taCustomerMessage, HttpServletRequest request){
167
+        ResponseBean responseBean = new ResponseBean();
168
+        try {
169
+            String openid = JWTUtils.getSubject(request);
170
+            TaPerson taPersons = taPersonService.getPersonsByOpenId(openid).get(0);
171
+            taCustomerMessage.setStatus(CommConstant.STATUS_UNACCALIMED);
172
+            taCustomerMessage.setCreateDate(LocalDateTime.now());
173
+            taCustomerMessage.setPersonId(taPersons.getPersonId());
174
+            taCustomerMessage.setNickname(taPersons.getNickname());
175
+            if (iTaCustomerMessageService.save(taCustomerMessage)){
176
+                responseBean.addSuccess(taCustomerMessage);
177
+            }else {
178
+                responseBean.addError("fail");
179
+            }
180
+        }catch (Exception e){
181
+            e.printStackTrace();
182
+            logger.error("taCustomerMessageAdd -=- {}",e.toString());
183
+            responseBean.addError(e.getMessage());
184
+        }
185
+        return responseBean;
186
+    }
187
+}

+ 74
- 0
src/main/java/com/huiju/estateagents/entity/TaCustomerMessage.java Прегледај датотеку

@@ -0,0 +1,74 @@
1
+package com.huiju.estateagents.entity;
2
+
3
+import com.baomidou.mybatisplus.annotation.IdType;
4
+import com.baomidou.mybatisplus.annotation.TableId;
5
+import lombok.Data;
6
+import lombok.EqualsAndHashCode;
7
+import lombok.experimental.Accessors;
8
+
9
+import java.io.Serializable;
10
+import java.time.LocalDateTime;
11
+
12
+/**
13
+ * <p>
14
+ * 用户留言表 
15
+ * </p>
16
+ *
17
+ * @author jobob
18
+ * @since 2019-07-30
19
+ */
20
+@Data
21
+@EqualsAndHashCode(callSuper = false)
22
+@Accessors(chain = true)
23
+public class TaCustomerMessage implements Serializable {
24
+
25
+    private static final long serialVersionUID = 1L;
26
+
27
+    /**
28
+     * 留言ID
29
+     */
30
+    @TableId(value = "message_id", type = IdType.AUTO)
31
+    private Integer messageId;
32
+
33
+    /**
34
+     * 创建时间
35
+     */
36
+    private LocalDateTime createDate;
37
+
38
+    /**
39
+     * 公司id
40
+     */
41
+    private Integer orgId;
42
+
43
+    /**
44
+     * 楼盘id
45
+     */
46
+    private String buildingId;
47
+
48
+    /**
49
+     * 用户ID
50
+     */
51
+    private String personId;
52
+
53
+    /**
54
+     * 用户名
55
+     */
56
+    private String nickname;
57
+
58
+    /**
59
+     * 手机号
60
+     */
61
+    private String phone;
62
+
63
+    /**
64
+     * 留言内容
65
+     */
66
+    private String message;
67
+
68
+    /**
69
+     * 状态
70
+     */
71
+    private Integer status;
72
+
73
+
74
+}

+ 18
- 0
src/main/java/com/huiju/estateagents/mapper/TaCustomerMessageMapper.java Прегледај датотеку

@@ -0,0 +1,18 @@
1
+package com.huiju.estateagents.mapper;
2
+
3
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
4
+import com.huiju.estateagents.entity.TaCustomerMessage;
5
+import org.apache.ibatis.annotations.Mapper;
6
+
7
+/**
8
+ * <p>
9
+ * 用户留言表  Mapper 接口
10
+ * </p>
11
+ *
12
+ * @author jobob
13
+ * @since 2019-07-30
14
+ */
15
+@Mapper
16
+public interface TaCustomerMessageMapper extends BaseMapper<TaCustomerMessage> {
17
+
18
+}

+ 16
- 0
src/main/java/com/huiju/estateagents/service/ITaCustomerMessageService.java Прегледај датотеку

@@ -0,0 +1,16 @@
1
+package com.huiju.estateagents.service;
2
+
3
+import com.baomidou.mybatisplus.extension.service.IService;
4
+import com.huiju.estateagents.entity.TaCustomerMessage;
5
+
6
+/**
7
+ * <p>
8
+ * 用户留言表  服务类
9
+ * </p>
10
+ *
11
+ * @author jobob
12
+ * @since 2019-07-30
13
+ */
14
+public interface ITaCustomerMessageService extends IService<TaCustomerMessage> {
15
+
16
+}

+ 20
- 0
src/main/java/com/huiju/estateagents/service/impl/TaCustomerMessageServiceImpl.java Прегледај датотеку

@@ -0,0 +1,20 @@
1
+package com.huiju.estateagents.service.impl;
2
+
3
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
4
+import com.huiju.estateagents.entity.TaCustomerMessage;
5
+import com.huiju.estateagents.mapper.TaCustomerMessageMapper;
6
+import com.huiju.estateagents.service.ITaCustomerMessageService;
7
+import org.springframework.stereotype.Service;
8
+
9
+/**
10
+ * <p>
11
+ * 用户留言表  服务实现类
12
+ * </p>
13
+ *
14
+ * @author jobob
15
+ * @since 2019-07-30
16
+ */
17
+@Service
18
+public class TaCustomerMessageServiceImpl extends ServiceImpl<TaCustomerMessageMapper, TaCustomerMessage> implements ITaCustomerMessageService {
19
+
20
+}

+ 5
- 0
src/main/resources/mapper/TaCustomerMessageMapper.xml Прегледај датотеку

@@ -0,0 +1,5 @@
1
+<?xml version="1.0" encoding="UTF-8"?>
2
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3
+<mapper namespace="com.huiju.estateagents.mapper.TaCustomerMessageMapper">
4
+
5
+</mapper>