import { BaseService, CoolCommException } from '@cool-midway/core';
|
import { Inject, Provide } from '@midwayjs/core';
|
import { InjectEntityModel } from '@midwayjs/typeorm';
|
import * as md5 from 'md5';
|
import { Equal, Repository } from 'typeorm';
|
import { v1 as uuid } from 'uuid';
|
import { PluginService } from '../../plugin/service/info';
|
import { UserInfoEntity } from '../entity/info';
|
import { UserSmsService } from './sms';
|
import { UserWxService } from './wx';
|
|
/**
|
* 用户信息
|
*/
|
@Provide()
|
export class UserInfoService extends BaseService {
|
@InjectEntityModel(UserInfoEntity)
|
userInfoEntity: Repository<UserInfoEntity>;
|
|
@Inject()
|
pluginService: PluginService;
|
|
@Inject()
|
userSmsService: UserSmsService;
|
|
@Inject()
|
userWxService: UserWxService;
|
|
/**
|
* 绑定小程序手机号
|
* @param userId
|
* @param code
|
* @param encryptedData
|
* @param iv
|
*/
|
async miniPhone(userId: number, code: any, encryptedData: any, iv: any) {
|
const phone = await this.userWxService.miniPhone(code, encryptedData, iv);
|
await this.userInfoEntity.update({ id: Equal(userId) }, { phone });
|
return phone;
|
}
|
|
/**
|
* 获取用户信息
|
* @param id
|
* @returns
|
*/
|
async person(id) {
|
const info = await this.userInfoEntity.findOneBy({ id: Equal(id) });
|
delete info.password;
|
return info;
|
}
|
|
/**
|
* 注销
|
* @param userId
|
*/
|
async logoff(userId: number) {
|
await this.userInfoEntity.update(
|
{ id: userId },
|
{
|
status: 2,
|
phone: null,
|
unionid: null,
|
nickName: `已注销-00${userId}`,
|
avatarUrl: null,
|
}
|
);
|
}
|
|
/**
|
* 更新用户信息
|
* @param id
|
* @param param
|
* @returns
|
*/
|
async updatePerson(id, param) {
|
const info = await this.person(id);
|
if (!info) throw new CoolCommException('用户不存在');
|
try {
|
// 修改了头像要重新处理
|
if (param.avatarUrl && info.avatarUrl != param.avatarUrl) {
|
const file = await this.pluginService.getInstance('upload');
|
param.avatarUrl = await file.downAndUpload(
|
param.avatarUrl,
|
uuid() + '.png'
|
);
|
}
|
} catch (err) {}
|
try {
|
return await this.userInfoEntity.update({ id }, param);
|
} catch (err) {
|
throw new CoolCommException('更新失败，参数错误或者手机号已存在');
|
}
|
}
|
|
/**
|
* 更新密码
|
* @param userId
|
* @param password
|
* @param 验证码
|
*/
|
async updatePassword(userId, password, code) {
|
const user = await this.userInfoEntity.findOneBy({ id: userId });
|
const check = await this.userSmsService.checkCode(user.phone, code);
|
if (!check) {
|
throw new CoolCommException('验证码错误');
|
}
|
await this.userInfoEntity.update(user.id, { password: md5(password) });
|
}
|
|
/**
|
* 绑定手机号
|
* @param userId
|
* @param phone
|
* @param code
|
*/
|
async bindPhone(userId, phone, code) {
|
const check = await this.userSmsService.checkCode(phone, code);
|
if (!check) {
|
throw new CoolCommException('验证码错误');
|
}
|
await this.userInfoEntity.update({ id: userId }, { phone });
|
}
|
}
|
