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