|
|
@@ -28,381 +28,381 @@ import com.thmodel.service.ModelInfoService;
|
|
|
import com.thmodel.service.NimserverService;
|
|
|
import com.thmodel.util.CommentUtils;
|
|
|
|
|
|
-public class MemberinfoServiceImpl implements MemberinfoService{
|
|
|
-
|
|
|
- MemberinfoDao memberinfoDao = new MemberinfoDaoImpl();//会员信息
|
|
|
- MemberSignDao memberSignDao = new MemberSignDaoImpl();//会员签到记录
|
|
|
- AccRecordDao accRecordDao = new AccRecordDaoImpl();//积分历史表
|
|
|
- Nimserver nimserver = new Nimserver();//网易通讯
|
|
|
- NimserverService nimserverService = new NimserverServiceImpl();
|
|
|
- private static ModelInfoService modelInfoService = new ModelInfoServiceImpl();
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean isTel(String tel) {
|
|
|
- boolean flag = false;
|
|
|
- if(CommentUtils.isNull(tel)){
|
|
|
- int count = memberinfoDao.getCountToMemberinfoByTel(tel);
|
|
|
- if(count == 0){
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }else{
|
|
|
- //电话/账号不能为空
|
|
|
- flag = false;
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int doRegister(MemberInfo memberinfo) {
|
|
|
- //注册
|
|
|
- if(CommentUtils.isNull(memberinfo.getTel()) && CommentUtils.isNull(memberinfo.getPass())){
|
|
|
- int pk = memberinfoDao.insertMemberinfoByRegister(memberinfo);
|
|
|
- return pk;
|
|
|
- }else{
|
|
|
- return -1;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public MemberInfo dologin(String username, String pwd) {
|
|
|
- //登录
|
|
|
- if(username != null || pwd!= null){
|
|
|
-
|
|
|
- //登录刷新token
|
|
|
- MemberInfo memberInfo = memberinfoDao.login(username, pwd);
|
|
|
- if(memberInfo != null) {
|
|
|
- int pk = memberInfo.getPk();
|
|
|
- String pet = memberInfo.getPet();
|
|
|
- nimserverService.refreshOrCreateToken(pk, pet);
|
|
|
- return memberinfoDao.login(username, pwd);
|
|
|
- }else {
|
|
|
- return null;
|
|
|
- }
|
|
|
- }else{
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Map<String, Object> docard(int PK) {
|
|
|
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
- SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
-
|
|
|
- //打卡签到
|
|
|
- Map<String, Object> resultMap = new HashMap<String, Object>();
|
|
|
-
|
|
|
- Date date=new Date();
|
|
|
- Calendar calendar = Calendar.getInstance();
|
|
|
- calendar.setTime(date);
|
|
|
- calendar.add(Calendar.DAY_OF_MONTH, -1);
|
|
|
- date = calendar.getTime();
|
|
|
- String sysDate = sdf.format(new Date());
|
|
|
- String prevDate = sdf2.format(date);
|
|
|
- //System.out.println("当前系统时间---------:"+sysDate); //yyyy-MM-dd HH:mm:ss
|
|
|
- //System.out.println("当前系统时间前一天 ----:"+prevDate); //yyyy-MM-dd
|
|
|
-
|
|
|
- //-----------------------------------最有一次签到时间和连续签到天数 begin-----------------------------------
|
|
|
- //判断今天有没有签过到
|
|
|
- int currDaysignCount = memberSignDao.findMemberSignByPkLikeSDate(PK, new SimpleDateFormat("yyyy-MM-dd").format(new Date()));
|
|
|
-
|
|
|
- //判断昨天有没有签过到
|
|
|
- int yesterdayCount = memberSignDao.findMemberSignByPkLikeSDate(PK, prevDate);//count大于0:昨天签过到
|
|
|
- if(yesterdayCount>0){//昨天签过到
|
|
|
- if(currDaysignCount>0){//今天已经签过到了
|
|
|
- memberSignDao.updateMemberInfoToLastSignByPk(PK, sysDate);//今天已经签过,只修改最后一次签到时间
|
|
|
- }else{
|
|
|
- memberSignDao.updateMemberInfoToLastSignAndSignDaysByPk(PK, sysDate, "IFNULL(SignDays, 0)+1");//昨天签过到 累加连续签到天数
|
|
|
- }
|
|
|
- }else{//昨天没有签过到 跟新最后一次签到时间和连续签到天数
|
|
|
- if(currDaysignCount>0){//今天已经签过到了
|
|
|
- memberSignDao.updateMemberInfoToLastSignByPk(PK, sysDate);//今天已经签过,只修改最后一次签到时间
|
|
|
- }else{
|
|
|
- memberSignDao.updateMemberInfoToLastSignAndSignDaysByPk(PK, sysDate, "1");//今天没有签过到(昨天也没有签到),修改最后一次签到时间 和 连续签到天数(连续签到天数:1)
|
|
|
- }
|
|
|
- }
|
|
|
- //-----------------------------------最有一次签到时间和连续签到天数 end -----------------------------------
|
|
|
-
|
|
|
- //会员签到信息表 添加一条记录
|
|
|
- memberSignDao.insertMemberSign(PK, sysDate);//rows>0 签到成功
|
|
|
-
|
|
|
- //打卡签到暂时不加积分
|
|
|
-
|
|
|
- Map<String, Object> map = resultMap = memberinfoDao.docard(PK);
|
|
|
-
|
|
|
- return resultMap;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<MemberSign> dogetcard(int PK) {
|
|
|
- //签到记录
|
|
|
- if(PK>0){
|
|
|
- List<MemberSign> list = memberSignDao.findMemberSignByMemberPK(PK);
|
|
|
- return list;
|
|
|
- }else{
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean updatepwd(int PK, String pwd) {
|
|
|
- //修改密码
|
|
|
- boolean flag = false;
|
|
|
- if(PK > 0 && pwd != null && !pwd.equals("")){
|
|
|
- int rows = memberinfoDao.updatePassword(PK, pwd);
|
|
|
- if(rows > 0){
|
|
|
- flag = true;
|
|
|
- }else{
|
|
|
- flag = false;
|
|
|
- }
|
|
|
- }else{
|
|
|
- flag = false;
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public String getPwdByTel(String Tel) {
|
|
|
- //找回密码
|
|
|
- if(CommentUtils.isNull(Tel)){
|
|
|
- String pwd = memberinfoDao.findPwdByTel(Tel);
|
|
|
- return pwd;
|
|
|
- }else{
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean updatePet(int PK, String Pet) {
|
|
|
- //修改昵称
|
|
|
- boolean flag = false;
|
|
|
- if(PK > 0 && Pet != null && !Pet.equals("")){
|
|
|
- int rows = memberinfoDao.updatePetByPK(PK, Pet);
|
|
|
- //MemberInfo memberinfo = memberinfoDao.findMemberinfoByPK(PK);
|
|
|
- //===================== 网易通讯 同步名称 begin =====================
|
|
|
- Map<String, String> paramMap = new HashMap<String, String>();
|
|
|
- paramMap.put("name", Pet);
|
|
|
- String result = nimserver.updateUinfo(PK+"", paramMap);
|
|
|
- System.err.println(result);
|
|
|
- //===================== 网易通讯 同步名称 end =====================
|
|
|
-
|
|
|
- if(rows > 0){
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean updateArea(int PK, int Area) {
|
|
|
- //修改地区
|
|
|
- boolean flag = false;
|
|
|
- if(PK > 0 && Area > 0){
|
|
|
- int rows = memberinfoDao.updateAreaByPK(PK, Area);
|
|
|
- if(rows > 0){
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean updateMemberhphoto(String pk, String hphoto) {
|
|
|
- boolean flag = false;
|
|
|
-
|
|
|
- int memberPk = Integer.parseInt(pk);
|
|
|
- if(memberPk > 0) {
|
|
|
- int rows = memberinfoDao.updateMemberhphotoByPk(memberPk, hphoto);
|
|
|
- if(rows > 0){
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean updateMemberToken(int pk, String token) {
|
|
|
- boolean flag = false;
|
|
|
- if(pk > 0) {
|
|
|
- int rows = memberinfoDao.updateMemberTokenByPk(pk, token);
|
|
|
- if(rows > 0) {
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean updateMemberPhone(int pk, String phone) {
|
|
|
- boolean flag = false;
|
|
|
- if(pk > 0) {
|
|
|
- int rows = memberinfoDao.updateMemberPhoneByPk(pk, phone);
|
|
|
- if(rows > 0) {
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int verifyPhone(String phone) {
|
|
|
- //1:已经存在 2:不存在 3:异常
|
|
|
- int code = 0;
|
|
|
- if(phone != null && !phone.equals("")) {
|
|
|
- int count = memberinfoDao.getCountToMemberinfoByTel(phone);
|
|
|
- if(count > 0) {
|
|
|
- code = 1;
|
|
|
- }else {
|
|
|
- code = 2;
|
|
|
- }
|
|
|
- } else {
|
|
|
- code = 3;
|
|
|
- }
|
|
|
- return code;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public MemberInfo getUserInfo(int pk) {
|
|
|
- if(pk > 0) {
|
|
|
- MemberInfo memberinfo = memberinfoDao.getMemberInfoByPk(pk);
|
|
|
- return memberinfo;
|
|
|
- }else {
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public String getUserName(int pk) {
|
|
|
- if(pk > 0) {
|
|
|
- String pet = memberinfoDao.findMemberPetByPk(pk);
|
|
|
- return pet;
|
|
|
- } else {
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean addCoinI(int memberpk, double coin) {
|
|
|
- boolean flag = false;
|
|
|
- if(memberpk > 0 && coin > 0) {
|
|
|
- int rows = memberinfoDao.addMemberCoinI(memberpk, coin);
|
|
|
- if(rows > 0) {
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int doModelRegister(MemberInfo memberinfo) {
|
|
|
- DbConnection db = new DbConnection();
|
|
|
- CachedRowSet rs = null;
|
|
|
- String sql = "";
|
|
|
- try {
|
|
|
- //注册
|
|
|
- if(CommentUtils.isNull(memberinfo.getTel()) && CommentUtils.isNull(memberinfo.getPass())){
|
|
|
- //经济人PK
|
|
|
- int register_brokepk = 1;
|
|
|
- //经济人会员PK
|
|
|
- int register_bmemberpk = 1;
|
|
|
-
|
|
|
- //根据推荐人 指定注册人的经纪人
|
|
|
- int introducerpk = memberinfo.getIntroducerpk();
|
|
|
- MemberInfo member = memberinfoDao.findMemberinfoByPK(introducerpk);
|
|
|
- int membtype = member.getMembtype();
|
|
|
-
|
|
|
- //推荐人是经纪人
|
|
|
- if (membtype == Constants.MEMTYPE_JinJiRen) {
|
|
|
- sql = "select pk, memberpk from BrokerInfor where memberpk = " + introducerpk;
|
|
|
- rs = db.executeQuery(sql);
|
|
|
- if(rs!=null && rs.next()) {
|
|
|
- register_brokepk = rs.getInt("pk");
|
|
|
- register_bmemberpk = rs.getInt("memberpk");
|
|
|
- }
|
|
|
- }
|
|
|
- //推荐人是模特
|
|
|
- else if(membtype == Constants.MEMTYPE_Model) {
|
|
|
- sql = "select BrokePK, BMemberPK from modelinfo where MemberPK = " + introducerpk;
|
|
|
- rs = db.executeQuery(sql);
|
|
|
- if(rs!=null && rs.next()) {
|
|
|
- register_brokepk = rs.getInt("brokepk");
|
|
|
- register_bmemberpk = rs.getInt("bmemberpk");
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- int pk = memberinfoDao.insertMemberinfoByModelRegister(memberinfo);
|
|
|
- if(pk > 0) {
|
|
|
- //添加模特账号
|
|
|
- modelInfoService.doModelRegister(pk, memberinfo.getPet(), register_brokepk, register_bmemberpk);
|
|
|
- }
|
|
|
- return pk;
|
|
|
- }else{
|
|
|
- return -1;
|
|
|
- }
|
|
|
- } catch (SQLException e) {
|
|
|
- return -2;
|
|
|
- } finally{
|
|
|
- db.close(rs);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getMemberpkByTel(String tel) {
|
|
|
- return memberinfoDao.findMemberpkByTel(tel);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean modifypwd(String mobile, String pass) {
|
|
|
- boolean flag = false;
|
|
|
- if(mobile!=null && !mobile.equals("") && pass!=null && !mobile.equals("")) {
|
|
|
- int rows = memberinfoDao.updateMemberSetPassByPhone(mobile, pass);
|
|
|
- if (rows > 0) {
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean addDefriendModel(Nexus nexus) {
|
|
|
- boolean flag = false;
|
|
|
- if(nexus.getMemberpk() > 0 && nexus.getModelpk() > 0) {
|
|
|
- int i = memberinfoDao.insertNexus(nexus);
|
|
|
- if(i > 0) {
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean removeDefriendModel(Nexus nexus) {
|
|
|
- boolean flag = false;
|
|
|
- if(nexus.getPk() > 0) {
|
|
|
- int i = memberinfoDao.deleteNexus(nexus);
|
|
|
- if(i > 0) {
|
|
|
- flag = true;
|
|
|
- }
|
|
|
- }
|
|
|
- return flag;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Page<List<Nexus>> getDefriendModel(Nexus nexus, int index, int size) {
|
|
|
- if(nexus.getMemberpk() > 0) {
|
|
|
- return memberinfoDao.findNexusByPage(nexus, index, size);
|
|
|
- }else {
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<Nexus> getAllNexus(Nexus nexus) {
|
|
|
- if(nexus.getMemberpk() > 0) {
|
|
|
- return memberinfoDao.findNexusAll(nexus);
|
|
|
- }else {
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
+public class MemberinfoServiceImpl implements MemberinfoService {
|
|
|
+
|
|
|
+ MemberinfoDao memberinfoDao = new MemberinfoDaoImpl();//会员信息
|
|
|
+ MemberSignDao memberSignDao = new MemberSignDaoImpl();//会员签到记录
|
|
|
+ AccRecordDao accRecordDao = new AccRecordDaoImpl();//积分历史表
|
|
|
+ Nimserver nimserver = new Nimserver();//网易通讯
|
|
|
+ NimserverService nimserverService = new NimserverServiceImpl();
|
|
|
+ private static ModelInfoService modelInfoService = new ModelInfoServiceImpl();
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean isTel(String tel) {
|
|
|
+ boolean flag = false;
|
|
|
+ if (CommentUtils.isNull(tel)) {
|
|
|
+ int count = memberinfoDao.getCountToMemberinfoByTel(tel);
|
|
|
+ if (count == 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ //电话/账号不能为空
|
|
|
+ flag = false;
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int doRegister(MemberInfo memberinfo, String qrcode) {
|
|
|
+ //注册
|
|
|
+ if (CommentUtils.isNull(memberinfo.getTel()) && CommentUtils.isNull(memberinfo.getPass())) {
|
|
|
+ int pk = memberinfoDao.insertMemberinfoByRegister(memberinfo, qrcode);
|
|
|
+ return pk;
|
|
|
+ } else {
|
|
|
+ return -1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public MemberInfo dologin(String username, String pwd) {
|
|
|
+ //登录
|
|
|
+ if (username != null || pwd != null) {
|
|
|
+
|
|
|
+ //登录刷新token
|
|
|
+ MemberInfo memberInfo = memberinfoDao.login(username, pwd);
|
|
|
+ if (memberInfo != null) {
|
|
|
+ int pk = memberInfo.getPk();
|
|
|
+ String pet = memberInfo.getPet();
|
|
|
+ nimserverService.refreshOrCreateToken(pk, pet);
|
|
|
+ return memberinfoDao.login(username, pwd);
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Map<String, Object> docard(int PK) {
|
|
|
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
+
|
|
|
+ //打卡签到
|
|
|
+ Map<String, Object> resultMap = new HashMap<String, Object>();
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ Calendar calendar = Calendar.getInstance();
|
|
|
+ calendar.setTime(date);
|
|
|
+ calendar.add(Calendar.DAY_OF_MONTH, -1);
|
|
|
+ date = calendar.getTime();
|
|
|
+ String sysDate = sdf.format(new Date());
|
|
|
+ String prevDate = sdf2.format(date);
|
|
|
+ //System.out.println("当前系统时间---------:"+sysDate); //yyyy-MM-dd HH:mm:ss
|
|
|
+ //System.out.println("当前系统时间前一天 ----:"+prevDate); //yyyy-MM-dd
|
|
|
+
|
|
|
+ //-----------------------------------最有一次签到时间和连续签到天数 begin-----------------------------------
|
|
|
+ //判断今天有没有签过到
|
|
|
+ int currDaysignCount = memberSignDao.findMemberSignByPkLikeSDate(PK, new SimpleDateFormat("yyyy-MM-dd").format(new Date()));
|
|
|
+
|
|
|
+ //判断昨天有没有签过到
|
|
|
+ int yesterdayCount = memberSignDao.findMemberSignByPkLikeSDate(PK, prevDate);//count大于0:昨天签过到
|
|
|
+ if (yesterdayCount > 0) {//昨天签过到
|
|
|
+ if (currDaysignCount > 0) {//今天已经签过到了
|
|
|
+ memberSignDao.updateMemberInfoToLastSignByPk(PK, sysDate);//今天已经签过,只修改最后一次签到时间
|
|
|
+ } else {
|
|
|
+ memberSignDao.updateMemberInfoToLastSignAndSignDaysByPk(PK, sysDate, "IFNULL(SignDays, 0)+1");//昨天签过到 累加连续签到天数
|
|
|
+ }
|
|
|
+ } else {//昨天没有签过到 跟新最后一次签到时间和连续签到天数
|
|
|
+ if (currDaysignCount > 0) {//今天已经签过到了
|
|
|
+ memberSignDao.updateMemberInfoToLastSignByPk(PK, sysDate);//今天已经签过,只修改最后一次签到时间
|
|
|
+ } else {
|
|
|
+ memberSignDao.updateMemberInfoToLastSignAndSignDaysByPk(PK, sysDate, "1");//今天没有签过到(昨天也没有签到),修改最后一次签到时间 和 连续签到天数(连续签到天数:1)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //-----------------------------------最有一次签到时间和连续签到天数 end -----------------------------------
|
|
|
+
|
|
|
+ //会员签到信息表 添加一条记录
|
|
|
+ memberSignDao.insertMemberSign(PK, sysDate);//rows>0 签到成功
|
|
|
+
|
|
|
+ //打卡签到暂时不加积分
|
|
|
+
|
|
|
+ Map<String, Object> map = resultMap = memberinfoDao.docard(PK);
|
|
|
+
|
|
|
+ return resultMap;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<MemberSign> dogetcard(int PK) {
|
|
|
+ //签到记录
|
|
|
+ if (PK > 0) {
|
|
|
+ List<MemberSign> list = memberSignDao.findMemberSignByMemberPK(PK);
|
|
|
+ return list;
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean updatepwd(int PK, String pwd) {
|
|
|
+ //修改密码
|
|
|
+ boolean flag = false;
|
|
|
+ if (PK > 0 && pwd != null && !pwd.equals("")) {
|
|
|
+ int rows = memberinfoDao.updatePassword(PK, pwd);
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ } else {
|
|
|
+ flag = false;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ flag = false;
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String getPwdByTel(String Tel) {
|
|
|
+ //找回密码
|
|
|
+ if (CommentUtils.isNull(Tel)) {
|
|
|
+ String pwd = memberinfoDao.findPwdByTel(Tel);
|
|
|
+ return pwd;
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean updatePet(int PK, String Pet) {
|
|
|
+ //修改昵称
|
|
|
+ boolean flag = false;
|
|
|
+ if (PK > 0 && Pet != null && !Pet.equals("")) {
|
|
|
+ int rows = memberinfoDao.updatePetByPK(PK, Pet);
|
|
|
+ //MemberInfo memberinfo = memberinfoDao.findMemberinfoByPK(PK);
|
|
|
+ //===================== 网易通讯 同步名称 begin =====================
|
|
|
+ Map<String, String> paramMap = new HashMap<String, String>();
|
|
|
+ paramMap.put("name", Pet);
|
|
|
+ String result = nimserver.updateUinfo(PK + "", paramMap);
|
|
|
+ System.err.println(result);
|
|
|
+ //===================== 网易通讯 同步名称 end =====================
|
|
|
+
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean updateArea(int PK, int Area) {
|
|
|
+ //修改地区
|
|
|
+ boolean flag = false;
|
|
|
+ if (PK > 0 && Area > 0) {
|
|
|
+ int rows = memberinfoDao.updateAreaByPK(PK, Area);
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean updateMemberhphoto(String pk, String hphoto) {
|
|
|
+ boolean flag = false;
|
|
|
+
|
|
|
+ int memberPk = Integer.parseInt(pk);
|
|
|
+ if (memberPk > 0) {
|
|
|
+ int rows = memberinfoDao.updateMemberhphotoByPk(memberPk, hphoto);
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean updateMemberToken(int pk, String token) {
|
|
|
+ boolean flag = false;
|
|
|
+ if (pk > 0) {
|
|
|
+ int rows = memberinfoDao.updateMemberTokenByPk(pk, token);
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean updateMemberPhone(int pk, String phone) {
|
|
|
+ boolean flag = false;
|
|
|
+ if (pk > 0) {
|
|
|
+ int rows = memberinfoDao.updateMemberPhoneByPk(pk, phone);
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int verifyPhone(String phone) {
|
|
|
+ //1:已经存在 2:不存在 3:异常
|
|
|
+ int code = 0;
|
|
|
+ if (phone != null && !phone.equals("")) {
|
|
|
+ int count = memberinfoDao.getCountToMemberinfoByTel(phone);
|
|
|
+ if (count > 0) {
|
|
|
+ code = 1;
|
|
|
+ } else {
|
|
|
+ code = 2;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ code = 3;
|
|
|
+ }
|
|
|
+ return code;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public MemberInfo getUserInfo(int pk) {
|
|
|
+ if (pk > 0) {
|
|
|
+ MemberInfo memberinfo = memberinfoDao.getMemberInfoByPk(pk);
|
|
|
+ return memberinfo;
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String getUserName(int pk) {
|
|
|
+ if (pk > 0) {
|
|
|
+ String pet = memberinfoDao.findMemberPetByPk(pk);
|
|
|
+ return pet;
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean addCoinI(int memberpk, double coin) {
|
|
|
+ boolean flag = false;
|
|
|
+ if (memberpk > 0 && coin > 0) {
|
|
|
+ int rows = memberinfoDao.addMemberCoinI(memberpk, coin);
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int doModelRegister(MemberInfo memberinfo) {
|
|
|
+ DbConnection db = new DbConnection();
|
|
|
+ CachedRowSet rs = null;
|
|
|
+ String sql = "";
|
|
|
+ try {
|
|
|
+ //注册
|
|
|
+ if (CommentUtils.isNull(memberinfo.getTel()) && CommentUtils.isNull(memberinfo.getPass())) {
|
|
|
+ //经济人PK
|
|
|
+ int register_brokepk = 1;
|
|
|
+ //经济人会员PK
|
|
|
+ int register_bmemberpk = 1;
|
|
|
+
|
|
|
+ //根据推荐人 指定注册人的经纪人
|
|
|
+ int introducerpk = memberinfo.getIntroducerpk();
|
|
|
+ MemberInfo member = memberinfoDao.findMemberinfoByPK(introducerpk);
|
|
|
+ int membtype = member.getMembtype();
|
|
|
+
|
|
|
+ //推荐人是经纪人
|
|
|
+ if (membtype == Constants.MEMTYPE_JinJiRen) {
|
|
|
+ sql = "select pk, memberpk from BrokerInfor where memberpk = " + introducerpk;
|
|
|
+ rs = db.executeQuery(sql);
|
|
|
+ if (rs != null && rs.next()) {
|
|
|
+ register_brokepk = rs.getInt("pk");
|
|
|
+ register_bmemberpk = rs.getInt("memberpk");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //推荐人是模特
|
|
|
+ else if (membtype == Constants.MEMTYPE_Model) {
|
|
|
+ sql = "select BrokePK, BMemberPK from modelinfo where MemberPK = " + introducerpk;
|
|
|
+ rs = db.executeQuery(sql);
|
|
|
+ if (rs != null && rs.next()) {
|
|
|
+ register_brokepk = rs.getInt("brokepk");
|
|
|
+ register_bmemberpk = rs.getInt("bmemberpk");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ int pk = memberinfoDao.insertMemberinfoByModelRegister(memberinfo);
|
|
|
+ if (pk > 0) {
|
|
|
+ //添加模特账号
|
|
|
+ modelInfoService.doModelRegister(pk, memberinfo.getPet(), register_brokepk, register_bmemberpk);
|
|
|
+ }
|
|
|
+ return pk;
|
|
|
+ } else {
|
|
|
+ return -1;
|
|
|
+ }
|
|
|
+ } catch (SQLException e) {
|
|
|
+ return -2;
|
|
|
+ } finally {
|
|
|
+ db.close(rs);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getMemberpkByTel(String tel) {
|
|
|
+ return memberinfoDao.findMemberpkByTel(tel);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean modifypwd(String mobile, String pass) {
|
|
|
+ boolean flag = false;
|
|
|
+ if (mobile != null && !mobile.equals("") && pass != null && !mobile.equals("")) {
|
|
|
+ int rows = memberinfoDao.updateMemberSetPassByPhone(mobile, pass);
|
|
|
+ if (rows > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean addDefriendModel(Nexus nexus) {
|
|
|
+ boolean flag = false;
|
|
|
+ if (nexus.getMemberpk() > 0 && nexus.getModelpk() > 0) {
|
|
|
+ int i = memberinfoDao.insertNexus(nexus);
|
|
|
+ if (i > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean removeDefriendModel(Nexus nexus) {
|
|
|
+ boolean flag = false;
|
|
|
+ if (nexus.getPk() > 0) {
|
|
|
+ int i = memberinfoDao.deleteNexus(nexus);
|
|
|
+ if (i > 0) {
|
|
|
+ flag = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Page<List<Nexus>> getDefriendModel(Nexus nexus, int index, int size) {
|
|
|
+ if (nexus.getMemberpk() > 0) {
|
|
|
+ return memberinfoDao.findNexusByPage(nexus, index, size);
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<Nexus> getAllNexus(Nexus nexus) {
|
|
|
+ if (nexus.getMemberpk() > 0) {
|
|
|
+ return memberinfoDao.findNexusAll(nexus);
|
|
|
+ } else {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
}
|