|
@@ -3,14 +3,20 @@ package members
|
3
|
3
|
import (
|
4
|
4
|
base_ctl "SCRM/controllers"
|
5
|
5
|
"SCRM/enums"
|
|
6
|
+ "SCRM/models"
|
6
|
7
|
"SCRM/service/member_service"
|
7
|
8
|
"SCRM/utils"
|
|
9
|
+ "reflect"
|
|
10
|
+ "time"
|
|
11
|
+
|
|
12
|
+ "encoding/json"
|
8
|
13
|
|
9
|
14
|
"github.com/astaxie/beego"
|
10
|
15
|
)
|
11
|
16
|
|
12
|
17
|
func MemberCtlRegistRouters() {
|
13
|
18
|
beego.Router("/api/members", &MembersAPIController{}, "get:GetMembers")
|
|
19
|
+ beego.Router("/api/member/create", &MembersAPIController{}, "Post:CreateMember")
|
14
|
20
|
}
|
15
|
21
|
|
16
|
22
|
type MembersAPIController struct {
|
|
@@ -84,6 +90,13 @@ func (c *MembersAPIController) GetMembers() {
|
84
|
90
|
return
|
85
|
91
|
}
|
86
|
92
|
returnData["tags"] = tags
|
|
93
|
+
|
|
94
|
+ illness, err := member_service.GetIllnessList()
|
|
95
|
+ if err != nil {
|
|
96
|
+ c.ServeFailJsonSend(enums.ErrorCodeDataException, "获取病种列表失败")
|
|
97
|
+ return
|
|
98
|
+ }
|
|
99
|
+ returnData["illness"] = illness
|
87
|
100
|
}
|
88
|
101
|
returnData["members"] = members
|
89
|
102
|
returnData["total"] = total
|
|
@@ -91,3 +104,249 @@ func (c *MembersAPIController) GetMembers() {
|
91
|
104
|
c.ServeSuccessJSON(returnData)
|
92
|
105
|
return
|
93
|
106
|
}
|
|
107
|
+
|
|
108
|
+func (c *MembersAPIController) CreateMember() {
|
|
109
|
+
|
|
110
|
+ adminUserInfo := c.GetAdminUserInfo()
|
|
111
|
+ timeNow := time.Now().Unix()
|
|
112
|
+
|
|
113
|
+ dataBody := make(map[string]interface{}, 0)
|
|
114
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
|
|
115
|
+ if err != nil {
|
|
116
|
+ utils.ErrorLog(err.Error())
|
|
117
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
|
|
118
|
+ return
|
|
119
|
+ }
|
|
120
|
+
|
|
121
|
+ var member member_service.Members
|
|
122
|
+
|
|
123
|
+ if dataBody["name"] == nil || reflect.TypeOf(dataBody["name"]).String() != "string" {
|
|
124
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:姓名")
|
|
125
|
+ return
|
|
126
|
+ }
|
|
127
|
+ name, _ := dataBody["name"].(string)
|
|
128
|
+ if len(name) == 0 {
|
|
129
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
|
|
130
|
+ return
|
|
131
|
+ }
|
|
132
|
+ member.Name = name
|
|
133
|
+
|
|
134
|
+ if dataBody["mobile"] == nil || reflect.TypeOf(dataBody["mobile"]).String() != "string" {
|
|
135
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:手机号")
|
|
136
|
+ return
|
|
137
|
+ }
|
|
138
|
+ mobile, _ := dataBody["mobile"].(string)
|
|
139
|
+ if len(mobile) == 0 {
|
|
140
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "手机号不能为空")
|
|
141
|
+ return
|
|
142
|
+ }
|
|
143
|
+ if !utils.CheckMobile(mobile) {
|
|
144
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "手机号格式不正确")
|
|
145
|
+ return
|
|
146
|
+ }
|
|
147
|
+ member.Mobile = mobile
|
|
148
|
+
|
|
149
|
+ if dataBody["gender"] == nil || reflect.TypeOf(dataBody["gender"]).String() != "float64" {
|
|
150
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:性别")
|
|
151
|
+ return
|
|
152
|
+ }
|
|
153
|
+ gender := int64(dataBody["gender"].(float64))
|
|
154
|
+
|
|
155
|
+ if gender != 1 && gender != 2 {
|
|
156
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "性别选择不正确")
|
|
157
|
+ return
|
|
158
|
+ }
|
|
159
|
+ member.Gender = gender
|
|
160
|
+
|
|
161
|
+ if dataBody["birthday"] == nil || reflect.TypeOf(dataBody["birthday"]).String() != "string" {
|
|
162
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:生日")
|
|
163
|
+ return
|
|
164
|
+ }
|
|
165
|
+ birthday, _ := dataBody["birthday"].(string)
|
|
166
|
+ if len(birthday) == 0 {
|
|
167
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
|
|
168
|
+ return
|
|
169
|
+ }
|
|
170
|
+
|
|
171
|
+ timeLayout := "2006-01-02 15:04:05"
|
|
172
|
+ theTime, err := utils.ParseTimeStringToTime(timeLayout, birthday+" 00:00:00")
|
|
173
|
+ if err != nil {
|
|
174
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
|
|
175
|
+ return
|
|
176
|
+ }
|
|
177
|
+ member.Birthday = theTime.Unix()
|
|
178
|
+
|
|
179
|
+ if dataBody["province_id"] == nil || reflect.TypeOf(dataBody["province_id"]).String() != "float64" {
|
|
180
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区(省)")
|
|
181
|
+ return
|
|
182
|
+ }
|
|
183
|
+ provinceID := int64(dataBody["province_id"].(float64))
|
|
184
|
+ if provinceID <= 0 {
|
|
185
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
|
|
186
|
+ return
|
|
187
|
+ }
|
|
188
|
+ member.ProvinceId = provinceID
|
|
189
|
+
|
|
190
|
+ if dataBody["city_id"] == nil || reflect.TypeOf(dataBody["city_id"]).String() != "float64" {
|
|
191
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区(市)")
|
|
192
|
+ return
|
|
193
|
+ }
|
|
194
|
+ cityID := int64(dataBody["city_id"].(float64))
|
|
195
|
+ if cityID <= 0 {
|
|
196
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
|
|
197
|
+ return
|
|
198
|
+ }
|
|
199
|
+ member.CityId = cityID
|
|
200
|
+
|
|
201
|
+ if dataBody["district_id"] == nil || reflect.TypeOf(dataBody["district_id"]).String() != "float64" {
|
|
202
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区(区/县)")
|
|
203
|
+ return
|
|
204
|
+ }
|
|
205
|
+ districtID := int64(dataBody["district_id"].(float64))
|
|
206
|
+ if districtID <= 0 {
|
|
207
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
|
|
208
|
+ return
|
|
209
|
+ }
|
|
210
|
+ member.DistrictId = districtID
|
|
211
|
+
|
|
212
|
+ if dataBody["illness"] == nil || reflect.TypeOf(dataBody["illness"]).String() != "[]interface {}" {
|
|
213
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:病种")
|
|
214
|
+ return
|
|
215
|
+ }
|
|
216
|
+ illnessInters := dataBody["illness"].([]interface{})
|
|
217
|
+ if len(illnessInters) <= 0 {
|
|
218
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择病种")
|
|
219
|
+ return
|
|
220
|
+ }
|
|
221
|
+ member.Illness = make([]*member_service.CustomerIllness, 0)
|
|
222
|
+ for _, illnessInter := range illnessInters {
|
|
223
|
+ id := int64(illnessInter.(float64))
|
|
224
|
+ var illItem member_service.CustomerIllness
|
|
225
|
+ illItem.UserOrgId = adminUserInfo.CurrentOrgId
|
|
226
|
+ illItem.IllnessId = id
|
|
227
|
+ illItem.Status = 1
|
|
228
|
+ illItem.UpdatedTime = timeNow
|
|
229
|
+ illItem.CreatedTime = timeNow
|
|
230
|
+ member.Illness = append(member.Illness, &illItem)
|
|
231
|
+ }
|
|
232
|
+
|
|
233
|
+ if dataBody["ill_date"] == nil || reflect.TypeOf(dataBody["ill_date"]).String() != "string" {
|
|
234
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:患病时间")
|
|
235
|
+ return
|
|
236
|
+ }
|
|
237
|
+ illDate, _ := dataBody["ill_date"].(string)
|
|
238
|
+ if len(illDate) == 0 {
|
|
239
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "患病时间格式不正确")
|
|
240
|
+ return
|
|
241
|
+ }
|
|
242
|
+
|
|
243
|
+ illDateTime, err := utils.ParseTimeStringToTime(timeLayout, illDate+" 00:00:00")
|
|
244
|
+ if err != nil {
|
|
245
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "患病时间格式不正确")
|
|
246
|
+ return
|
|
247
|
+ }
|
|
248
|
+ member.IllDate = illDateTime.Unix()
|
|
249
|
+
|
|
250
|
+ if dataBody["treat_type"] == nil || reflect.TypeOf(dataBody["treat_type"]).String() != "float64" {
|
|
251
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:治疗方式")
|
|
252
|
+ return
|
|
253
|
+ }
|
|
254
|
+ treatType := int64(dataBody["treat_type"].(float64))
|
|
255
|
+ if treatType <= 0 {
|
|
256
|
+ c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择治疗方式")
|
|
257
|
+ return
|
|
258
|
+ }
|
|
259
|
+ member.TreatType = treatType
|
|
260
|
+
|
|
261
|
+ if dataBody["tags"] != nil && reflect.TypeOf(dataBody["tags"]).String() == "[]interface {}" {
|
|
262
|
+ tagsInters := dataBody["tags"].([]interface{})
|
|
263
|
+ if len(tagsInters) > 0 {
|
|
264
|
+ member.UserTags = make([]*models.UserTagLinks, 0)
|
|
265
|
+ for _, tagsInter := range tagsInters {
|
|
266
|
+ id := int64(tagsInter.(float64))
|
|
267
|
+ var tagItem models.UserTagLinks
|
|
268
|
+ tagItem.TagId = id
|
|
269
|
+ tagItem.UserOrgId = adminUserInfo.CurrentOrgId
|
|
270
|
+ tagItem.Status = 1
|
|
271
|
+ tagItem.UpdatedTime = timeNow
|
|
272
|
+ tagItem.CreatedTime = timeNow
|
|
273
|
+ member.UserTags = append(member.UserTags, &tagItem)
|
|
274
|
+ }
|
|
275
|
+ }
|
|
276
|
+ }
|
|
277
|
+
|
|
278
|
+ if dataBody["remark"] != nil && reflect.TypeOf(dataBody["remark"]).String() == "string" {
|
|
279
|
+ remark, _ := dataBody["remark"].(string)
|
|
280
|
+ if len(remark) > 0 {
|
|
281
|
+ member.Remark = remark
|
|
282
|
+ }
|
|
283
|
+ }
|
|
284
|
+
|
|
285
|
+ if dataBody["avatar"] != nil && reflect.TypeOf(dataBody["avatar"]).String() == "string" {
|
|
286
|
+ avatar, _ := dataBody["avatar"].(string)
|
|
287
|
+ if len(avatar) > 0 {
|
|
288
|
+ member.Avatar = avatar
|
|
289
|
+ }
|
|
290
|
+ }
|
|
291
|
+
|
|
292
|
+ customer, err := member_service.GetCustomerByMobile(adminUserInfo.CurrentOrgId, member.Mobile)
|
|
293
|
+ if err != nil {
|
|
294
|
+ c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员失败:("+err.Error()+")")
|
|
295
|
+ return
|
|
296
|
+ }
|
|
297
|
+ if customer != nil {
|
|
298
|
+ c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员失败:(已经存在该手机号的客户)")
|
|
299
|
+ return
|
|
300
|
+ }
|
|
301
|
+
|
|
302
|
+ member.UserOrgId = adminUserInfo.CurrentOrgId
|
|
303
|
+ member.Status = 1
|
|
304
|
+ member.CreatedTime = timeNow
|
|
305
|
+ member.UpdatedTime = timeNow
|
|
306
|
+ member.Sources = 7
|
|
307
|
+
|
|
308
|
+ user, err := member_service.GetUserByMobile(member.Mobile)
|
|
309
|
+ if err != nil {
|
|
310
|
+ c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员失败:("+err.Error()+")")
|
|
311
|
+ return
|
|
312
|
+ }
|
|
313
|
+ if user != nil {
|
|
314
|
+ member.UserId = user.ID
|
|
315
|
+ err = member_service.CreateMember(&member)
|
|
316
|
+ if err != nil {
|
|
317
|
+ c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员失败:("+err.Error()+")")
|
|
318
|
+ return
|
|
319
|
+ }
|
|
320
|
+ } else {
|
|
321
|
+ var userData models.User
|
|
322
|
+ userData.Avatar = member.Avatar
|
|
323
|
+ userData.AvatarThumb = member.Avatar
|
|
324
|
+ userData.Username = member.Name
|
|
325
|
+ userData.Remarkname = member.Name
|
|
326
|
+ userData.Mobile = member.Mobile
|
|
327
|
+ userData.Gender = member.Gender
|
|
328
|
+ userData.ProvinceId = member.ProvinceId
|
|
329
|
+ userData.CityId = member.CityId
|
|
330
|
+ userData.Address = member.Address
|
|
331
|
+ userData.Birthday = member.Birthday
|
|
332
|
+ userData.TreatType = member.TreatType
|
|
333
|
+ userData.Relationship = member.Relationship
|
|
334
|
+ userData.IllnessId = member.Illness[0].IllnessId
|
|
335
|
+ userData.Sources = member.Sources
|
|
336
|
+ userData.Status = 1
|
|
337
|
+ userData.CreatedTime = timeNow
|
|
338
|
+ userData.UpdatedTime = timeNow
|
|
339
|
+
|
|
340
|
+ err = member_service.CreateMemberWithUser(&member, &userData)
|
|
341
|
+ if err != nil {
|
|
342
|
+ c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员失败:("+err.Error()+")")
|
|
343
|
+ return
|
|
344
|
+ }
|
|
345
|
+ }
|
|
346
|
+
|
|
347
|
+ returnData := make(map[string]interface{}, 0)
|
|
348
|
+ returnData["member"] = member
|
|
349
|
+ c.ServeSuccessJSON(returnData)
|
|
350
|
+ return
|
|
351
|
+
|
|
352
|
+}
|