feats

src/main/java/com/shigongli/controller/TaPersonController.java

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.shigongli.common.*;
+import com.shigongli.service.ITaShopKeeperService;
 import com.shigongli.vo.AuthPhoneParams;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -41,6 +42,9 @@ public class TaPersonController extends BaseController {
     @Autowired
     public ITaPersonService iTaPersonService;
 
+    @Autowired
+    private ITaShopKeeperService iTaShopKeeperService;
+
     @Autowired
     private WxUtils wxUtils;
 
@@ -63,6 +67,9 @@ public class TaPersonController extends BaseController {
         taPerson.setPhone(phone);
         iTaPersonService.updateById(taPerson);
 
+        // 绑定店主
+        iTaShopKeeperService.bindPerson(taPerson);
+
         return ResponseBean.success(taPerson);
     }
 

src/main/java/com/shigongli/controller/TaShopKeeperController.java

@@ -6,6 +6,8 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.shigongli.common.BaseController;
 import com.shigongli.common.ResponseBean;
 import com.shigongli.constants.StatusConstant;
+import com.shigongli.entity.TaPerson;
+import com.shigongli.service.ITaPersonService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
@@ -40,6 +42,9 @@ public class TaShopKeeperController extends BaseController {
     @Autowired
     public ITaShopKeeperService iTaShopKeeperService;
 
+    @Autowired
+    public ITaPersonService iTaPersonService;
+
 
     /**
      * 分页查询列表
@@ -72,6 +77,11 @@ public class TaShopKeeperController extends BaseController {
     @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
     public ResponseBean taShopKeeperAdd(@ApiParam("保存内容") @RequestBody TaShopKeeper taShopKeeper) throws Exception{
 
+        TaPerson taPerson = iTaPersonService.getByPhone(taShopKeeper.getPhone());
+        if (null != taPerson) {
+            taShopKeeper.setPersonId(taPerson.getPersonId());
+        }
+
         if (iTaShopKeeperService.save(taShopKeeper)){
             return ResponseBean.success(taShopKeeper);
         }else {
@@ -106,6 +116,11 @@ public class TaShopKeeperController extends BaseController {
     public ResponseBean taShopKeeperUpdate(@ApiParam("对象ID") @PathVariable String id,
                                         @ApiParam("更新内容") @RequestBody TaShopKeeper taShopKeeper) throws Exception{
 
+        TaPerson taPerson = iTaPersonService.getByPhone(taShopKeeper.getPhone());
+        if (null != taPerson) {
+            taShopKeeper.setPersonId(taPerson.getPersonId());
+        }
+
         if (iTaShopKeeperService.updateById(taShopKeeper)){
             return ResponseBean.success(iTaShopKeeperService.getById(id));
         }else {

src/main/java/com/shigongli/service/ITaPersonService.java

@@ -2,6 +2,7 @@ package com.shigongli.service;
 
 import com.shigongli.entity.TaPerson;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.shigongli.entity.TaShopKeeper;
 
 /**
  * <p>
@@ -14,4 +15,6 @@ import com.baomidou.mybatisplus.extension.service.IService;
 public interface ITaPersonService extends IService<TaPerson> {
 
     TaPerson getByOpenId(String openid);
+
+    TaPerson getByPhone(String phone);
 }

src/main/java/com/shigongli/service/ITaShopKeeperService.java

@@ -1,8 +1,11 @@
 package com.shigongli.service;
 
+import com.shigongli.entity.TaPerson;
 import com.shigongli.entity.TaShopKeeper;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.util.List;
+
 /**
  * <p>
  * 店主 服务类
@@ -13,4 +16,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface ITaShopKeeperService extends IService<TaShopKeeper> {
 
+    void bindPerson(TaPerson taPerson);
+
+    List<TaShopKeeper> getByPhone(String phone);
 }

src/main/java/com/shigongli/service/impl/TaPersonServiceImpl.java

@@ -1,6 +1,10 @@
 package com.shigongli.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.shigongli.common.StringUtils;
+import com.shigongli.constants.StatusConstant;
 import com.shigongli.entity.TaPerson;
+import com.shigongli.entity.TaShopKeeper;
 import com.shigongli.mapper.TaPersonMapper;
 import com.shigongli.service.ITaPersonService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -25,4 +29,17 @@ public class TaPersonServiceImpl extends ServiceImpl<TaPersonMapper, TaPerson> i
     public TaPerson getByOpenId(String openid) {
         return taPersonMapper.getByOpenId(openid);
     }
+
+    @Override
+    public TaPerson getByPhone(String phone) {
+        if (StringUtils.isEmpty(phone)) {
+            return null;
+        }
+
+        QueryWrapper<TaPerson> queryWrapper = new QueryWrapper<TaPerson>()
+                .eq("phone", phone)
+                .eq("status", StatusConstant.NORMAL);
+
+        return getOne(queryWrapper);
+    }
 }

src/main/java/com/shigongli/service/impl/TaShopKeeperServiceImpl.java

@@ -1,11 +1,16 @@
 package com.shigongli.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.shigongli.constants.StatusConstant;
+import com.shigongli.entity.TaPerson;
 import com.shigongli.entity.TaShopKeeper;
 import com.shigongli.mapper.TaShopKeeperMapper;
 import com.shigongli.service.ITaShopKeeperService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 店主 服务实现类
@@ -17,4 +22,26 @@ import org.springframework.stereotype.Service;
 @Service
 public class TaShopKeeperServiceImpl extends ServiceImpl<TaShopKeeperMapper, TaShopKeeper> implements ITaShopKeeperService {
 
+    @Override
+    public void bindPerson(TaPerson taPerson) {
+        List<TaShopKeeper> shopKeeperList = getByPhone(taPerson.getPhone());
+
+        if (null == shopKeeperList) {
+            return ;
+        }
+
+        for (TaShopKeeper shopKeeper: shopKeeperList) {
+            shopKeeper.setPersonId(taPerson.getPersonId());
+            updateById(shopKeeper);
+        }
+    }
+
+    @Override
+    public List<TaShopKeeper> getByPhone(String phone) {
+        QueryWrapper<TaShopKeeper> queryWrapper = new QueryWrapper<TaShopKeeper>()
+                .eq("phone", phone)
+                .eq("status", StatusConstant.NORMAL);
+
+        return list(queryWrapper);
+    }
 }