From 0876032e21f92335b6e904ba087a5299b589d383 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Sun, 19 Aug 2018 12:37:07 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=95=86=E9=93=BA=E5=95=86=E6=88=B7][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9]:B=E7=AB=AF=E7=94=A8=E6=88=B7=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E5=AF=86=E7=A0=81=E3=80=81=E5=95=86=E6=88=B7=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0=E7=AE=A1=E7=90=86=E5=91=98=E9=80=BB=E8=BE=91=E4=BF=AE?= =?UTF-8?q?=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WxMerchantBUserController.java | 20 +++++++- .../service/WxMerchantBUserService.java | 13 +++-- .../com/simple/service/WxMerchantService.java | 3 +- .../impl/WxMerchantBUserServiceImpl.java | 49 ++++++++++++++++--- .../service/impl/WxMerchantServiceImpl.java | 49 ++++++++----------- 5 files changed, 86 insertions(+), 48 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/simple/controller/WxMerchantBUserController.java b/mallinkAdmin/src/main/java/com/simple/controller/WxMerchantBUserController.java index b15b21577..6b8e7f42a 100644 --- a/mallinkAdmin/src/main/java/com/simple/controller/WxMerchantBUserController.java +++ b/mallinkAdmin/src/main/java/com/simple/controller/WxMerchantBUserController.java @@ -63,7 +63,23 @@ public class WxMerchantBUserController extends BaseController public ResultData findById(Long id) { return new ResultData(Result.SUCCESS,"查询成功",wxMerchantBUserService.getById(id)); } - - + + @ApiOperation("手机号是否存在") + @GetMapping("/hasphone") + @ApiImplicitParam(name="phone",value="phone",dataType="String", paramType = "query",required=true) + public ResultData hasphone(String phone) { + boolean has=wxMerchantBUserService.hasphone(phone); + return new ResultData(Result.SUCCESS,"查询成功",has); + } + + @ApiOperation("修改密码") + @GetMapping("/updatepwd") + @ApiImplicitParams({ + @ApiImplicitParam(name="phone",value="手机号",dataType="String", paramType = "query",required=true), + @ApiImplicitParam(name="code",value="验证码",dataType="String", paramType = "query",required=true), + @ApiImplicitParam(name="pwd",value="密码",dataType="String", paramType = "query",required=true)}) + public ResultData updatepwd(String phone,String code,String pwd) { + return wxMerchantBUserService.updatepwd(phone,code,pwd); + } } diff --git a/mallinkService/src/main/java/com/simple/service/WxMerchantBUserService.java b/mallinkService/src/main/java/com/simple/service/WxMerchantBUserService.java index ca1f109bc..7eebc8ac5 100644 --- a/mallinkService/src/main/java/com/simple/service/WxMerchantBUserService.java +++ b/mallinkService/src/main/java/com/simple/service/WxMerchantBUserService.java @@ -1,6 +1,7 @@ package com.simple.service; import com.github.pagehelper.PageInfo; +import com.simple.common.ResultData; import com.simple.domain.po.WxMerchantBUser; public interface WxMerchantBUserService { @@ -52,12 +53,10 @@ public interface WxMerchantBUserService { * @param id */ void deleteById(Long id); - - - - - - - + + boolean hasphone(String phone); + + ResultData updatepwd(String phone, String code, String pwd); + } diff --git a/mallinkService/src/main/java/com/simple/service/WxMerchantService.java b/mallinkService/src/main/java/com/simple/service/WxMerchantService.java index 9965c1059..34fe19f81 100644 --- a/mallinkService/src/main/java/com/simple/service/WxMerchantService.java +++ b/mallinkService/src/main/java/com/simple/service/WxMerchantService.java @@ -1,6 +1,5 @@ package com.simple.service; -import java.util.*; import com.github.pagehelper.PageInfo; import com.simple.domain.po.WxMerchant; @@ -29,7 +28,7 @@ public interface WxMerchantService { * * @param record */ - void saveOrUpdate(WxMerchant record); + void saveOrUpdate(WxMerchant record); /** * 根据Id删除实体 diff --git a/mallinkService/src/main/java/com/simple/service/impl/WxMerchantBUserServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/WxMerchantBUserServiceImpl.java index 73e0558aa..095c78139 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/WxMerchantBUserServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/WxMerchantBUserServiceImpl.java @@ -1,10 +1,15 @@ package com.simple.service.impl; import java.util.*; +import java.util.stream.Collectors; + import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; +import com.simple.common.ResultData; import com.simple.domain.po.WxMerchantBUser; +import com.simple.domain.po.WxMsgValidationcode; import com.simple.mapper.WxMerchantBUserMapper; +import com.simple.mapper.WxMsgValidationcodeMapper; import com.simple.service.WxMerchantBUserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -16,6 +21,8 @@ public class WxMerchantBUserServiceImpl implements WxMerchantBUserService { @Autowired WxMerchantBUserMapper wxMerchantBUserMapper; + @Autowired + WxMsgValidationcodeMapper wxMsgValidationcodeMapper; @Override public PageInfo listAsPage(WxMerchantBUser record, Integer pageIndex, Integer pageSize) { @@ -62,12 +69,38 @@ public class WxMerchantBUserServiceImpl implements WxMerchantBUserService { public void deleteById(Long id) { wxMerchantBUserMapper.deleteByPrimaryKey(id); } - - - - - - - - + + @Override + public boolean hasphone(String phone) { + WxMerchantBUser bUser = new WxMerchantBUser(); + bUser.setPhone(phone); + List list = wxMerchantBUserMapper.findList(bUser); + return list.size()>=1?true:false; + } + + @Override + public ResultData updatepwd(String phone, String code, String pwd) { + WxMsgValidationcode wxMsgValidationcode = new WxMsgValidationcode(); + wxMsgValidationcode.setPhone(phone); + wxMsgValidationcode.setCode(code); + List wxmsgvalidationcodelist = wxMsgValidationcodeMapper.findList(wxMsgValidationcode); + Date currentdate = new Date(); + wxmsgvalidationcodelist = wxmsgvalidationcodelist.stream().filter(validationcode -> + validationcode.getExpiretime().after(currentdate)).collect(Collectors.toList()); + if(wxmsgvalidationcodelist.size()>0){ + //更新 + WxMerchantBUser bUser = new WxMerchantBUser(); + bUser.setPhone(phone); + List list = wxMerchantBUserMapper.findList(bUser); + if(list.size()>0){ + bUser = list.get(0); + bUser.setBUserPwd(pwd); + wxMerchantBUserMapper.updateByPrimaryKeySelective(bUser); + return new ResultData(200,"操作成功"); + } + } + return new ResultData(500,"操作失败"); + } + + } diff --git a/mallinkService/src/main/java/com/simple/service/impl/WxMerchantServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/WxMerchantServiceImpl.java index 9151060c2..856a6035f 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/WxMerchantServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/WxMerchantServiceImpl.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONArray; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.simple.common.IdWorker; +import com.simple.common.ResultData; import com.simple.domain.po.WxMerchant; import com.simple.domain.po.WxMerchantBUser; import com.simple.domain.po.WxMerchantShop; @@ -20,6 +21,8 @@ import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.Date; import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; @Service public class WxMerchantServiceImpl implements WxMerchantService { @@ -81,7 +84,6 @@ public class WxMerchantServiceImpl implements WxMerchantService { @Override public void saveOrUpdate(WxMerchant wxMerchant) { - if (wxMerchant.getId() == null) { final IdWorker idWorker = IdWorker.get(); long merchantid = idWorker.nextId(); @@ -114,21 +116,6 @@ public class WxMerchantServiceImpl implements WxMerchantService { WxShopMapper.updateByPrimaryKeySelective(wxShop); } - //保存商户关联用户 - List useridlist = wxMerchant.getUserids(); - for(Long userid:useridlist){ - WxMerchantBUser wxMerchantBUser = new WxMerchantBUser(); - wxMerchantBUser.setId(userid); - List buserlist = wxMerchantBUserMapper.findList(wxMerchantBUser); - if(buserlist.size()>0){ - wxMerchantBUser = buserlist.get(0); - wxMerchantBUser.setMerchantId(merchantid); - wxMerchantBUser.setUpdateDate(new Date()); - wxMerchantBUserMapper.updateByPrimaryKey(wxMerchantBUser); - } - } - - } else { //更新商户 @@ -174,21 +161,25 @@ public class WxMerchantServiceImpl implements WxMerchantService { WxShopMapper.updateByPrimaryKeySelective(wxShop); } + } - //保存商户关联用户 - List useridlist = wxMerchant.getUserids(); - for(Long userid:useridlist){ - WxMerchantBUser wxMerchantBUser = new WxMerchantBUser(); - wxMerchantBUser.setId(userid); - List buserlist = wxMerchantBUserMapper.findList(wxMerchantBUser); - if(buserlist.size()>0){ - wxMerchantBUser = buserlist.get(0); - wxMerchantBUser.setMerchantId(wxMerchant.getId()); - wxMerchantBUser.setUpdateDate(new Date()); - wxMerchantBUserMapper.updateByPrimaryKey(wxMerchantBUser); - } - } + //删除之前的关联用户 + List bUsers = wxMerchant.getbUsers(); + + for(WxMerchantBUser user:bUsers){ + wxMerchantBUserMapper.deleteByPrimaryKey(user.getId()); + } + //保存商户关联用户 + final IdWorker idWorker = IdWorker.get(); + for(WxMerchantBUser user:bUsers){ + long id = idWorker.nextId(); + user.setId(id); + user.setBUserId(id); + Date date = new Date(); + user.setCreateDate(date); + user.setUpdateDate(date); + wxMerchantBUserMapper.insertSelective(user); }