| | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; |
| | | import com.ruoyi.account.api.feignClient.AppUserClient; |
| | | import com.ruoyi.account.api.feignClient.AppUserShopClient; |
| | | import com.ruoyi.account.api.model.AppUser; |
| | |
| | | import io.swagger.annotations.ApiParam; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.CollectionUtils; |
| | | import org.springframework.util.StringUtils; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.math.BigDecimal; |
| | | import java.math.MathContext; |
| | | import java.math.RoundingMode; |
| | | import java.time.LocalDateTime; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | |
| | | private TechnicianSubscribeService technicianSubscribeService; |
| | | @Resource |
| | | private TechnicianService technicianService; |
| | | @Resource |
| | | private ReceiverBankChannelService receiverBankChannelService; |
| | | |
| | | |
| | | |
| | |
| | | @DeleteMapping("/deleteShop") |
| | | @ApiOperation(value = "删除门店", tags = {"管理后台-门店管理"}) |
| | | public R<Void> deleteShop(@ApiParam("门店id") @RequestParam("id") Integer id){ |
| | | List<Goods> list1 = goodsService.list(new LambdaQueryWrapper<Goods>().eq(Goods::getDelFlag, 0).eq(Goods::getAppointStore, 1).eq(Goods::getStatus, 2)); |
| | | if(list1.size() > 0){ |
| | | Set<Integer> collect1 = list1.stream().map(Goods::getId).collect(Collectors.toSet()); |
| | | long count = goodsShopService.count(new LambdaQueryWrapper<GoodsShop>().eq(GoodsShop::getShopId, id).in(GoodsShop::getGoodsId, collect1)); |
| | | if(0 < count){ |
| | | return R.fail("门店已被商品使用,不能删除"); |
| | | } |
| | | } |
| | | Shop shop = shopService.getById(id); |
| | | shop.setDelFlag(1); |
| | | shopService.updateById(shop); |
| | | // 查询有没有门店绑定了该门店为上级门店 |
| | | List<Shop> shops = shopService.lambdaQuery() |
| | | .eq(Shop::getPid, id).list(); |
| | | if(!shops.isEmpty()){ |
| | | for (Shop shop1 : shops) { |
| | | shop1.setPid(0); |
| | | } |
| | | } |
| | | AppUser appUserById = appUserClient.getAppUserById(shop.getAppUserId()); |
| | | appUserById.setUserType(1); |
| | | appUserClient.editAppUserById(appUserById); |
| | | shopService.updateBatchById(shops); |
| | | appUserClient.clearBindShop(shop.getId()); |
| | | UserShop userShop = new UserShop(); |
| | | userShop.setShopId(shop.getId()); |
| | | List<UserShop> data = userShopClient.getUserShop(userShop).getData(); |
| | |
| | | return R.ok(new ArrayList<>()); |
| | | } |
| | | List<Integer> shopIds = appUserShopList.stream().map(AppUserShop::getShopId).collect(Collectors.toList()); |
| | | List<Shop> shopList = shopService.listByIds(shopIds); |
| | | List<Shop> shopList = shopService.list(new LambdaQueryWrapper<Shop>().in(Shop::getId, shopIds).eq(Shop::getDelFlag, 0).eq(Shop::getStatus, 1)); |
| | | if(null != appUser.getShopId()){ |
| | | Optional<Shop> first = shopList.stream().filter(s -> s.getId().equals(appUser.getShopId())).findFirst(); |
| | | if(first.isPresent()){ |
| | |
| | | Double wgs84 = GeodesyUtil.getDistance(longitude + "," + latitude, shop.getLongitude() + "," + shop.getLatitude()).get("WGS84"); |
| | | shop.setDistance(wgs84); |
| | | List<ShopScore> list = shopScoreService.list(new LambdaQueryWrapper<ShopScore>().eq(ShopScore::getShopId, shop.getId())); |
| | | double v = list.stream().map(ShopScore::getScore).reduce(BigDecimal.ZERO, BigDecimal::add).doubleValue(); |
| | | double v = 5; |
| | | if(list.size() > 0){ |
| | | v = list.stream().map(ShopScore::getScore).reduce(BigDecimal.ZERO, BigDecimal::add) |
| | | .divide(new BigDecimal(list.size()), new MathContext(2, RoundingMode.HALF_EVEN)).doubleValue(); |
| | | } |
| | | shop.setScore(v); |
| | | ShopScore one = shopScoreService.getOne(new LambdaQueryWrapper<ShopScore>().eq(ShopScore::getAppUserId, userid).eq(ShopScore::getShopId, shop.getId()).last(" order by create_time desc limit 0, 1")); |
| | | shop.setMyScore(null == one ? "0" : one.getScore().toString()); |
| | | } |
| | | return R.ok(shopList); |
| | | } |
| | |
| | | @GetMapping("/bindShop") |
| | | @ApiOperation(value = "绑定门店", tags = {"小程序-个人中心"}) |
| | | public R<Void> bindShop(@ApiParam("门店id") @RequestParam Integer shopId) { |
| | | Shop shop = shopService.getById(shopId); |
| | | if(null == shop || shop.getDelFlag() == 1){ |
| | | return R.fail("绑定店铺不存在"); |
| | | } |
| | | if(2 == shop.getStatus()){ |
| | | return R.fail("绑定店铺已被冻结"); |
| | | } |
| | | AppUser appUser = appUserClient.getAppUserById(SecurityUtils.getUserId()); |
| | | appUser.setShopId(shopId); |
| | | return appUserClient.editAppUserById(appUser); |
| | |
| | | return R.ok(list); |
| | | } |
| | | |
| | | @GetMapping("/getShopIdByName") |
| | | R<Set<Integer>> getShopIdByName(@RequestParam String shopName){ |
| | | /** |
| | | * 根据名称查询门店id |
| | | * @param shopName |
| | | * @return |
| | | */ |
| | | @PostMapping("/getShopIdByName") |
| | | public R<Set<Integer>> getShopIdByName(@RequestParam("shopName") 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())); |
| | |
| | | city = "510100"; |
| | | } |
| | | city = city.substring(0, 4) + "00"; |
| | | LambdaQueryWrapper<Shop> wrapper = new LambdaQueryWrapper<Shop>().eq(Shop::getDelFlag, 0).eq(Shop::getCityCode, city); |
| | | LambdaQueryWrapper<Shop> wrapper = new LambdaQueryWrapper<Shop>().eq(Shop::getDelFlag, 0).eq(Shop::getStatus, 1).eq(Shop::getCityCode, city); |
| | | if(null != goodsId){ |
| | | Goods goods = goodsService.getById(goodsId); |
| | | if(1 == goods.getType() && 1 == goods.getAppointStore()){ |
| | |
| | | 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<Shop> shops = shopService.list(new LambdaQueryWrapper<Shop>() |
| | | .in(!CollectionUtils.isEmpty(collect),Shop::getId, collect) |
| | | .eq(Shop::getDelFlag, 0).eq(Shop::getStatus, 1)); |
| | | List<VerifiableShopVo> list = new ArrayList<>(); |
| | | for (Shop shop : shops) { |
| | | VerifiableShopVo vo = new VerifiableShopVo(); |
| | |
| | | List<Shop> list = shopService.list(new LambdaQueryWrapper<Shop>().eq(Shop::getDelFlag, 0).eq(Shop::getStatus, 1)); |
| | | return R.ok(list); |
| | | } |
| | | |
| | | @ResponseBody |
| | | @GetMapping("/verifyAccountConfiguration") |
| | | @ApiOperation(value = "判断是否有提现账户", tags = {"门店后台-财务管理-提现明细"}) |
| | | public R verifyAccountConfiguration(){ |
| | | Long userid = tokenService.getLoginUser().getUserid(); |
| | | SysUser sysUser = sysUserClient.getSysUser(userid).getData(); |
| | | Shop shop = shopService.getById(sysUser.getObjectId()); |
| | | if(StringUtils.hasLength(shop.getReceiverAccountNoEnc())){ |
| | | return R.ok(); |
| | | } |
| | | return R.fail("请先配置收款账户"); |
| | | } |
| | | |
| | | |
| | | |
| | | @ResponseBody |
| | | @GetMapping("/getBankSerialNumber") |
| | | @ApiOperation(value = "获取行联号", tags = {"门店后台-财务管理-提现明细"}) |
| | | public R<List<ReceiverBankChannel>> getBankSerialNumber(String name){ |
| | | List<ReceiverBankChannel> list = receiverBankChannelService.list(new LambdaQueryWrapper<ReceiverBankChannel>() |
| | | .like(ReceiverBankChannel::getName, name)); |
| | | return R.ok(list); |
| | | } |
| | | |
| | | } |
| | | |