From 60f70f7409ec1ece8905e088fb43e0cb0258a70b Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期四, 19 十二月 2024 10:10:57 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopController.java | 276 ++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 261 insertions(+), 15 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 359acf3..05e9132 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 @@ -2,19 +2,42 @@ 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.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.core.web.domain.AjaxResult; -import com.ruoyi.other.api.domain.Technician; -import com.ruoyi.other.service.TechnicianService; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; +import com.ruoyi.common.security.service.TokenService; +import com.ruoyi.common.security.utils.SecurityUtils; +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.vo.NearbyShopVO; +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.model.LoginUser; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.bind.annotation.*; 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.stream.Collectors; /** * <p> - * 前端控制器 + * 前端控制器 * </p> * * @author luodangjia @@ -22,23 +45,246 @@ */ @RestController @RequestMapping("/shop") +@Api("门店") public class ShopController extends BaseController { @Resource - private TechnicianService technicianService; + private ShopService shopService; + @Resource + private AppUserClient appUserClient; + @Resource + private ShopScoreService shopScoreService; + @Resource + private TokenService tokenService; + @Resource + private SysUserClient sysUserClient; + @Resource + private ShopMapper shopMapper; + + + @PostMapping + @ApiOperation(value = "新增门店", tags = {"管理后台-门店管理"}) + @Transactional(rollbackFor = Exception.class) + public R<Void> add(@RequestBody Shop shop){ + String phone = shop.getPhone(); + if (!shopService.cheUserByPhone(phone)) { + return R.fail("该手机号未注册"); + } + shop.setShopAllPoint(0); + shop.setShopPoint(0); + shop.setSharePoint(0); + shop.setServerPoint(0); + shop.setUsePoint(0); + shop.setGiveawayAllMoney(BigDecimal.ZERO); + shop.setGiveawayMoney(BigDecimal.ZERO); + shop.setLowerLevelGiveawayMoney(BigDecimal.ZERO); + shop.setServerGiveawayMoney(BigDecimal.ZERO); + shop.setCanWithdrawMoney(BigDecimal.ZERO); + shop.setWithdrawMoney(BigDecimal.ZERO); + shop.setOrderNumber(0); + shop.setServerOrderNumber(0); + shop.setCustomOrderNumber(0); + shopService.save(shop); + + LoginUser loginUserApplet = tokenService.getLoginUser(); + AppUserShop appUserShop = new AppUserShop(); + appUserShop.setAppUserId(loginUserApplet.getUserid()); + appUserShop.setShopId(shop.getId()); + R<Void> r = appUserClient.addAppUserShop(appUserShop); + if (R.isError(r)){ + throw new RuntimeException("添加失败"); + } + return R.ok(); + } + + + @GetMapping("/getDetailById") + @ApiOperation(value = "门店详情", tags = {"管理后台-门店管理"}) + public R<Shop> getDetailById(@RequestParam("id") Long id){ + Shop byId = shopService.getById(id); + return R.ok(byId); + } + + @DeleteMapping("/deleteShop") + @ApiOperation(value = "删除门店", tags = {"管理后台-门店管理"}) + public R<Void> deleteShop(@ApiParam("门店id") @RequestParam("id") Integer id){ + shopService.removeById(id); + return R.ok(); + } + + @PutMapping("/editShop") + @ApiOperation(value = "门店管理-编辑门店", tags = {"管理后台-门店管理"}) + public R<Void> editShop(@RequestBody Shop shop){ + shopService.updateById(shop); + return R.ok(); + } + + @GetMapping("/list") + @ApiOperation(value = "门店列表", tags = {"管理后台-门店管理"}) + public R<IPage<Shop>> list(@ApiParam("页码") @RequestParam Integer pageNum,@ApiParam("每一页数据大小") Integer pageSize,Shop shop){ + IPage<Shop> shopIPage = shopService.getShopList(pageNum, pageSize, shop); + return R.ok(shopIPage); + } + + /** + * 通过手机号校验店长 + */ + @PostMapping("/cheUserByPhone") + @ApiOperation(value = "通过手机号校验店长", tags = {"管理后台-门店管理"}) + public R<Boolean> cheUserByPhone(@RequestParam("phone") String phone) { + return R.ok(shopService.cheUserByPhone(phone)); + } + + /** + * 重置密码 + */ + @GetMapping ("/resetPassword") + @ApiOperation(value = "重置密码", tags = {"管理后台-门店管理"}) + public R<Void> resetPassword(@RequestParam(value = "ids") String ids) { + 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())); + sysUserClient.resetPassword(userData); + } + return R.ok(); + } + + /** + * 获取手机号的后六位。 + * + * @param phoneNumber 以字符串形式提供的手机号 + * @return 手机号的后六位 + * @throws IllegalArgumentException 如果手机号长度不足六位 + */ + public String getLastSixDigits(String phoneNumber) { + if (phoneNumber == null || phoneNumber.length() < 6) { + throw new IllegalArgumentException("手机号长度不足六位"); + } + // 取字符串的最后六位 + return phoneNumber.substring(phoneNumber.length() - 6); + } + + + /** + * 附近门店列表 + */ + @GetMapping("/nearbyShopList") + @ApiOperation(value = "附近门店列表", tags = {"小程序-首页"}) + public R<List<NearbyShopVO>> nearbyShopList(@ApiParam("经度") @RequestParam BigDecimal longitude, + @ApiParam("纬度") @RequestParam BigDecimal latitude) { + return R.ok(shopService.nearbyShopList(longitude, latitude)); + } + + + @GetMapping("/shopDetail") + @ApiOperation(value = "门店详情", tags = {"小程序-首页"}) + public R<ShopDetailVO> shopDetail(@ApiParam("门店id") @RequestParam Integer shopId, + @ApiParam("经度") @RequestParam BigDecimal longitude, + @ApiParam("纬度") @RequestParam BigDecimal latitude) { + return R.ok(shopService.getShopDetail(shopId, longitude, latitude)); + } + + /** + * 查询当前店长所属门店 + */ + @GetMapping("/shopByUser") + @ApiOperation(value = "查询当前店长所属门店", tags = {"小程序-个人中心"}, notes = "可绑定的门店列表") + public R<List<Shop>> shopByUser() { + R<List<AppUserShop>> r = appUserClient.getAppUserShop(SecurityUtils.getUserId()); + if (R.isSuccess(r)){ + List<AppUserShop> appUserShopList = r.getData(); + List<Integer> shopIds = appUserShopList.stream().map(AppUserShop::getShopId).collect(Collectors.toList()); + List<Shop> shopList = shopService.listByIds(shopIds); + return R.ok(shopList); + } + return R.ok(new ArrayList<>()); + } + + /** + * 绑定门店 + */ + @GetMapping("/bindShop") + @ApiOperation(value = "绑定门店", tags = {"小程序-个人中心"}) + public R<Void> bindShop(@ApiParam("门店id") @RequestParam Long shopId) { + AppUser appUser = appUserClient.getAppUserById(SecurityUtils.getUserId()); + appUser.setShopId(shopId); + return appUserClient.editAppUserById(appUser); + } + + /** + * 门店打分 + * @return + */ + @PostMapping("/shopScore") + @ApiOperation(value = "门店打分", tags = {"小程序-个人中心"}) + public R<Void> shopScore(@RequestBody ShopScore shopScore) { + LoginUser loginUserApplet = tokenService.getLoginUserApplet(); + shopScore.setAppUserId(loginUserApplet.getUserid()); + shopScore.setCreateTime(LocalDateTime.now()); + shopScoreService.save(shopScore); + return R.ok(); + } /** - * 指定门店技师列表 + * 根据id获取门店信息 + * @param id + * @return */ - @RequestMapping("/technicianList") - public AjaxResult technicianList(@RequestParam String shopId){ - return success(technicianService.list(new LambdaQueryWrapper<Technician>() - .eq(Technician::getShopId,shopId) - .eq(Technician::getStatus,2) - .eq(Technician::getSubscribeStatus,1))); + @ResponseBody + @PostMapping("/getShopById") + public R<Shop> getShopById(@RequestParam("id") Integer id){ + Shop shop = shopService.getById(id); + return R.ok(shop); } + + @ResponseBody + @PostMapping("/getShopByUserId") + public R<List<Shop>> getShopByUserId(@RequestParam("id") Integer id){ + List<Shop> list = shopService.lambdaQuery().eq(Shop::getAppUserId, id).list(); + return R.ok(list); + } + + + /** + * 根据店铺管理员电话获取门店数据 + * @param phone + * @return + */ + @ResponseBody + @PostMapping("/getShopByPhone") + public R<Shop> getShopByPhone(@RequestParam("phone") String phone){ + Shop one = shopService.getOne(new LambdaQueryWrapper<Shop>().eq(Shop::getPhone, phone).eq(Shop::getDelFlag, 0).eq(Shop::getStatus, 1)); + return R.ok(one); + } + + @PostMapping("/getShopByUserIds") + public R<List<Shop>> getShopByUserIds(@RequestBody List<Long> userIds){ + List<Shop> list = shopService.list(new LambdaQueryWrapper<Shop>().in(Shop::getAppUserId, userIds)); + return R.ok(list); + } + + @GetMapping("/getShopIdByName") + R<Set<Integer>> getShopIdByName(@RequestParam String shopName){ + List<Shop> list = shopService.list(new LambdaQueryWrapper<Shop>() + .like(Shop::getName, shopName)); + return R.ok(list.stream().map(Shop::getId).collect(Collectors.toSet())); + } + + /** + * 门店统计 + */ + @GetMapping("/shopStatistics") + @ApiOperation(value = "门店统计", tags = {"管理后台-首页统计"}) + public R<ShopStatistics> shopStatistics(@ApiParam("门店名称") String shopName) { + ShopStatistics shopStatistics = shopMapper.getShopStatistics(shopName); + return R.ok(shopStatistics); + } + } -- Gitblit v1.7.1