From c8ea2d96f5b0522a09f3203ae98fe796084d2d15 Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期六, 04 一月 2025 09:34:21 +0800 Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/qijisheng --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java | 204 +++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 197 insertions(+), 7 deletions(-) diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java index c84e160..859cc37 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java @@ -4,24 +4,30 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.ruoyi.account.api.feignClient.AppUserClient; +import com.ruoyi.account.api.feignClient.AppUserShopClient; import com.ruoyi.account.api.model.AppUser; import com.ruoyi.account.api.model.AppUserShop; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.web.controller.BaseController; import com.ruoyi.common.security.service.TokenService; import com.ruoyi.common.security.utils.SecurityUtils; +import com.ruoyi.order.vo.VerifiableShopVo; import com.ruoyi.other.api.domain.Shop; import com.ruoyi.other.api.domain.ShopScore; import com.ruoyi.other.mapper.ShopMapper; import com.ruoyi.other.service.ShopScoreService; import com.ruoyi.other.service.ShopService; +import com.ruoyi.other.util.GeodesyUtil; +import com.ruoyi.other.util.tencentMap.TencentMapUtil; import com.ruoyi.other.vo.NearbyShopVO; import com.ruoyi.other.vo.SaveWithdrawalAccount; import com.ruoyi.other.vo.ShopDetailVO; import com.ruoyi.other.vo.ShopStatistics; import com.ruoyi.system.api.domain.SysUser; import com.ruoyi.system.api.feignClient.SysUserClient; +import com.ruoyi.system.api.feignClient.UserShopClient; import com.ruoyi.system.api.model.LoginUser; +import com.ruoyi.system.api.model.UserShop; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; @@ -32,9 +38,7 @@ import javax.annotation.Resource; import java.math.BigDecimal; import java.time.LocalDateTime; -import java.util.ArrayList; -import java.util.List; -import java.util.Set; +import java.util.*; import java.util.stream.Collectors; /** @@ -61,6 +65,10 @@ private SysUserClient sysUserClient; @Resource private ShopMapper shopMapper; + @Resource + private UserShopClient userShopClient; + @Resource + private AppUserShopClient appUserShopClient; @@ -88,8 +96,11 @@ shop.setServerOrderNumber(0); shop.setCustomOrderNumber(0); shop.setAppUserId(appUser.getId()); + String city = TencentMapUtil.inverseGeographicalAnalysis(shop.getLongitude(), shop.getLatitude(), false); + shop.setProvinceCode(city.substring(0, 2) + "0000"); + shop.setCityCode(city.substring(0, 4) + "00"); + shop.setDistrictCode(city); shopService.save(shop); - AppUserShop appUserShop = new AppUserShop(); appUserShop.setAppUserId(appUser.getId()); @@ -102,6 +113,44 @@ R<Void> editAppUserR = appUserClient.editAppUserById(appUser); if (R.isError(editAppUserR)){ throw new RuntimeException("添加失败"); + } + //添加门店后台账号和门店关系数据 + SysUser sysUser = sysUserClient.queryUserByUserName(phone).getData(); + if(null != sysUser){ + UserShop userShop = new UserShop(); + userShop.setUserId(sysUser.getUserId()); + userShop.setShopId(shop.getId()); + userShop.setRoleType(1); + List<UserShop> data = userShopClient.getUserShop(userShop).getData(); + if(null == data || data.size() == 0){ + userShop = new UserShop(); + userShop.setUserId(sysUser.getUserId()); + userShop.setShopId(shop.getId()); + userShop.setRoleType(1); + userShopClient.saveUserShop(userShop); + } + }else{ + //添加管理后台账号 + SysUser user = new SysUser(); + user.setDeptId(1L); + user.setUserName(appUser.getPhone()); + user.setNickName(appUser.getName()); + user.setPhonenumber(appUser.getPhone()); + user.setAvatar(appUser.getAvatar()); + user.setStatus("0"); + user.setDelFlag("0"); + user.setRoleType(2); + user.setObjectId(shop.getId()); + user.setAppUserId(appUser.getId()); + user.setPassword(phone.substring(5)); + user.setCreateTime(new Date()); + Long userId = sysUserClient.saveShopUser(user).getData(); + + UserShop userShop = new UserShop(); + userShop.setUserId(userId); + userShop.setShopId(shop.getId()); + userShop.setRoleType(1); + userShopClient.saveUserShop(userShop); } return R.ok(); } @@ -120,6 +169,27 @@ Shop shop = shopService.getById(id); shop.setDelFlag(1); shopService.updateById(shop); + //获取门店的员工数据 + UserShop userShop = new UserShop(); + userShop.setShopId(shop.getId()); + List<UserShop> data = userShopClient.getUserShop(userShop).getData(); + List<Integer> collect = data.stream().map(UserShop::getUserId).collect(Collectors.toList()).stream().map(Long::intValue).collect(Collectors.toList()); + List<SysUser> sysUserList = sysUserClient.getUserList(collect).getData(); + //删除门店下的所有员工 + sysUserClient.delShopUser(shop.getId(), 2); + //修改小程序用户类型和门店数据 + for (SysUser sysUser : sysUserList) { + String userName = sysUser.getUserName(); + //通过电话号码查询小程序用户和门店关系数据 + AppUser appUser = appUserClient.getAppUserByPhone1(userName).getData(); + //需要先判断用户是否没有关联任何门店 + List<AppUserShop> userShops = appUserShopClient.getAppUserShop(appUser.getId()).getData(); + if(userShops.size() == 1 && userShops.get(0).getShopId().equals(shop.getId())){ + appUser.setUserType(1); + appUserClient.editAppUserById(appUser); + } + + } return R.ok(); } @@ -130,7 +200,74 @@ if (!shopService.cheUserByPhone(phone)) { return R.fail("该手机号未注册"); } + String city = TencentMapUtil.inverseGeographicalAnalysis(shop.getLongitude(), shop.getLatitude(), false); + shop.setProvinceCode(city.substring(0, 2) + "0000"); + shop.setCityCode(city.substring(0, 4) + "00"); + shop.setDistrictCode(city); + Shop old_shop = shopService.getById(shop.getId()); shopService.updateById(shop); + //修改管理员 + AppUser appUser = appUserClient.getAppUserById(old_shop.getAppUserId()); + //需要先判断用户是否没有关联任何门店 + List<AppUserShop> userShops = appUserShopClient.getAppUserShop(appUser.getId()).getData(); + if(userShops.size() == 1 && userShops.get(0).getShopId().equals(shop.getId())){ + appUser.setUserType(1); + appUserClient.editAppUserById(appUser); + } + AppUserShop appUserShop = new AppUserShop(); + appUserShop.setAppUserId(appUser.getId()); + appUserShop.setShopId(shop.getId()); + appUserShopClient.delAppUserShop(appUserShop); + + //添加新管理员 + appUser = appUserClient.getAppUserByPhone1(phone).getData(); + appUserShop = new AppUserShop(); + appUserShop.setAppUserId(appUser.getId()); + appUserShop.setShopId(shop.getId()); + appUserClient.addAppUserShop(appUserShop); + + //修改管理员 + shop.setAppUserId(appUser.getId()); + shopService.updateById(shop); + + //添加门店后台账号和门店关系数据 + SysUser sysUser = sysUserClient.queryUserByUserName(phone).getData(); + if(null != sysUser){ + UserShop userShop = new UserShop(); + userShop.setUserId(sysUser.getUserId()); + userShop.setShopId(shop.getId()); + userShop.setRoleType(1); + List<UserShop> data = userShopClient.getUserShop(userShop).getData(); + if(null == data || data.size() == 0){ + userShop = new UserShop(); + userShop.setUserId(sysUser.getUserId()); + userShop.setShopId(shop.getId()); + userShop.setRoleType(1); + userShopClient.saveUserShop(userShop); + } + }else{ + //添加管理后台账号 + SysUser user = new SysUser(); + user.setDeptId(1L); + user.setUserName(appUser.getPhone()); + user.setNickName(appUser.getName()); + user.setPhonenumber(appUser.getPhone()); + user.setAvatar(appUser.getAvatar()); + user.setStatus("0"); + user.setDelFlag("0"); + user.setRoleType(2); + user.setObjectId(shop.getId()); + user.setAppUserId(appUser.getId()); + user.setPassword(phone.substring(5)); + user.setCreateTime(new Date()); + Long userId = sysUserClient.saveShopUser(user).getData(); + + UserShop userShop = new UserShop(); + userShop.setUserId(userId); + userShop.setShopId(shop.getId()); + userShop.setRoleType(1); + userShopClient.saveUserShop(userShop); + } return R.ok(); } @@ -162,9 +299,12 @@ String[] idsArr = ids.split(","); for (String id : idsArr) { Shop shop = shopService.getById(Integer.valueOf(id)); - R<SysUser> sysUser = sysUserClient.getSysUser(shop.getAppUserId()); - SysUser userData = sysUser.getData(); - userData.setPassword(getLastSixDigits(userData.getPhonenumber())); + UserShop userShop = new UserShop(); + userShop.setShopId(shop.getId()); + userShop.setRoleType(1); + List<UserShop> data = userShopClient.getUserShop(userShop).getData(); + SysUser userData = sysUserClient.getSysUser(data.get(0).getUserId()).getData(); + userData.setPassword(userData.getPhonenumber().substring(5)); sysUserClient.resetPassword(userData); } return R.ok(); @@ -315,6 +455,56 @@ public void updateShop(@RequestBody Shop shop){ shopService.updateById(shop); } + + + + + @ResponseBody + @GetMapping("/getVerifiableShop") + @ApiOperation(value = "获取可核销门店列表", tags = {"购物车-小程序"}) + public R<List<VerifiableShopVo>> getVerifiableShop(String longitude, String latitude){ + String city = TencentMapUtil.inverseGeographicalAnalysis(longitude, latitude, false); + city = city.substring(0, 4) + "00"; + List<Shop> list = shopService.list(new LambdaQueryWrapper<Shop>().eq(Shop::getDelFlag, 0).eq(Shop::getCityCode, city)); + List<VerifiableShopVo> verifiableShopVoList = new ArrayList<>(); + for (Shop shop : list) { + VerifiableShopVo vo = new VerifiableShopVo(); + vo.setId(shop.getId()); + vo.setName(shop.getName()); + Double wgs84 = GeodesyUtil.getDistance(longitude + "," + latitude, shop.getLongitude() + "," + shop.getLatitude()).get("WGS84"); + vo.setDistance(wgs84.longValue()); + verifiableShopVoList.add(vo); + } + verifiableShopVoList.sort(new Comparator<VerifiableShopVo>() { + @Override + public int compare(VerifiableShopVo o1, VerifiableShopVo o2) { + return o1.getDistance().compareTo(o2.getDistance()); + } + }); + return R.ok(verifiableShopVoList); + } + + + + @ResponseBody + @GetMapping("/getSysUserShop") + @ApiOperation(value = "获取可切换的门店列表", tags = {"门店后台-首页"}) + public R<List<VerifiableShopVo>> getSysUserShop(){ + Long userid = tokenService.getLoginUser().getUserid(); + UserShop userShop = new UserShop(); + userShop.setUserId(userid); + List<UserShop> data = userShopClient.getUserShop(userShop).getData(); + List<Integer> collect = data.stream().map(UserShop::getShopId).collect(Collectors.toList()); + List<Shop> shops = shopService.listByIds(collect); + List<VerifiableShopVo> list = new ArrayList<>(); + for (Shop shop : shops) { + VerifiableShopVo vo = new VerifiableShopVo(); + vo.setId(shop.getId()); + vo.setName(shop.getName()); + list.add(vo); + } + return R.ok(list); + } -- Gitblit v1.7.1