帮我找房

src/main/java/com/yunzhi/marketing/xlk/controller/SearchHouseController.java

@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yunzhi.marketing.base.BaseController;
 import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.entity.TaPerson;
+import com.yunzhi.marketing.service.ITaPersonService;
 import com.yunzhi.marketing.xlk.entity.SearchHouse;
 import com.yunzhi.marketing.xlk.service.ISearchHouseService;
 import io.swagger.annotations.Api;
@@ -22,6 +24,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.List;
 
 /**
  * <p>
@@ -41,6 +44,9 @@ public class SearchHouseController extends BaseController {
     @Autowired
     public ISearchHouseService iSearchHouseService;
 
+    @Autowired
+    public ITaPersonService taPersonService;
+
 
     /**
      * 分页查询列表
@@ -76,10 +82,19 @@ public class SearchHouseController extends BaseController {
      * @return
      */
     @ApiOperation(value = "保存帮我找房需求", notes = "保存帮我找房需求")
-    @RequestMapping(value="/searchHouse",method= RequestMethod.POST)
+    @RequestMapping(value="/app/searchHouse",method= RequestMethod.POST)
     public ResponseBean searchHouseAdd(@RequestBody SearchHouse searchHouse, @RequestHeader("authorization") String token, HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        List<TaPerson> persons = taPersonService.getPersonsByOpenId(openid);
+        if (null == persons || persons.size() == 0) {
+            return ResponseBean.error("当前账户信息异常, 清除缓存重试", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = persons.get(0);
         try {
+            searchHouse.setPersonId(person.getPersonId());
+            searchHouse.setOrgId(orgId);
             if (iSearchHouseService.save(searchHouse)){
                 responseBean.addSuccess(searchHouse);
             }else {