diff --git a/nxhs-service/src/main/java/cc/yunxi/domain/po/Enterprise.java b/nxhs-service/src/main/java/cc/yunxi/domain/po/Enterprise.java
index 3640353..de62898 100644
--- a/nxhs-service/src/main/java/cc/yunxi/domain/po/Enterprise.java
+++ b/nxhs-service/src/main/java/cc/yunxi/domain/po/Enterprise.java
@@ -26,10 +26,14 @@ import lombok.Setter;
 @ApiModel(value = "Enterprise对象", description = "企业(商户)信息")
 public class Enterprise {
 
-    @ApiModelProperty("自然主键")
+    @ApiModelProperty("商户id")
     @TableId(value = "f_id", type = IdType.ASSIGN_ID)
     private String id;
 
+    @ApiModelProperty("商户pid")
+    @TableId(value = "f_parent_id", type = IdType.ASSIGN_ID)
+    private String pid;
+
     @ApiModelProperty("商户代码")
     @TableField("f_en_code")
     private String enterpriseCode;
diff --git a/nxhs-service/src/main/java/cc/yunxi/domain/po/HousingEstate.java b/nxhs-service/src/main/java/cc/yunxi/domain/po/HousingEstate.java
index 6dedb8d..38c1d51 100644
--- a/nxhs-service/src/main/java/cc/yunxi/domain/po/HousingEstate.java
+++ b/nxhs-service/src/main/java/cc/yunxi/domain/po/HousingEstate.java
@@ -71,6 +71,10 @@ public class HousingEstate {
     @TableField("station_id")
     private String stationId;
 
+    @ApiModelProperty("所属商户id")
+    @TableField("enterprise_id")
+    private String enterpriseId;
+
 //    @ApiModelProperty("有效标志(0-禁用，1-启用)")
 //    @TableField("enabled_mark")
 //    private Integer enabledMark;
diff --git a/nxhs-service/src/main/java/cc/yunxi/domain/po/RecycleOrder.java b/nxhs-service/src/main/java/cc/yunxi/domain/po/RecycleOrder.java
index 608a190..675cb8e 100644
--- a/nxhs-service/src/main/java/cc/yunxi/domain/po/RecycleOrder.java
+++ b/nxhs-service/src/main/java/cc/yunxi/domain/po/RecycleOrder.java
@@ -143,6 +143,14 @@ public class RecycleOrder {
     @TableField("remark")
     private String remark;
 
+    @ApiModelProperty("数据隔离1")
+    @TableField("company_id")
+    private String companyId;
+
+    @ApiModelProperty("数据隔离2")
+    @TableField("organize_json_id")
+    private String organizeJsonId;
+
 //    @ApiModelProperty("综合评分")
 //    @TableField("star_score")
 //    private Integer starScore;
diff --git a/nxhs-service/src/main/java/cc/yunxi/domain/po/Recycler.java b/nxhs-service/src/main/java/cc/yunxi/domain/po/Recycler.java
index 1676ca1..3b2807c 100644
--- a/nxhs-service/src/main/java/cc/yunxi/domain/po/Recycler.java
+++ b/nxhs-service/src/main/java/cc/yunxi/domain/po/Recycler.java
@@ -62,4 +62,8 @@ public class Recycler {
 
     @ApiModelProperty("wxopenid")
     private String openid;
+
+    @ApiModelProperty("商户id")
+    @TableField("company_id")
+    private String companyId;
 }
diff --git a/nxhs-service/src/main/java/cc/yunxi/service/IEnterpriseService.java b/nxhs-service/src/main/java/cc/yunxi/service/IEnterpriseService.java
index 650646d..61acbec 100644
--- a/nxhs-service/src/main/java/cc/yunxi/service/IEnterpriseService.java
+++ b/nxhs-service/src/main/java/cc/yunxi/service/IEnterpriseService.java
@@ -25,7 +25,7 @@ public interface IEnterpriseService extends IService<Enterprise> {
      * @param enterpriseId
      * @return Enterprise
      */
-    Enterprise getEnterpriseById(String enterpriseId);
+    Enterprise getEnterpriseById(String enterpriseId, Boolean isLock);
 
 
     /**
diff --git a/nxhs-service/src/main/java/cc/yunxi/service/impl/EnterpriseServiceImpl.java b/nxhs-service/src/main/java/cc/yunxi/service/impl/EnterpriseServiceImpl.java
index 05ded7b..4bf1228 100644
--- a/nxhs-service/src/main/java/cc/yunxi/service/impl/EnterpriseServiceImpl.java
+++ b/nxhs-service/src/main/java/cc/yunxi/service/impl/EnterpriseServiceImpl.java
@@ -46,18 +46,20 @@ public class EnterpriseServiceImpl extends ServiceImpl<EnterpriseMapper, Enterpr
         if (StrUtil.isEmpty(enterpriseId)) {
             throw new BizIllegalException("回收站点未绑定商户");
         }
-        return this.getEnterpriseById(enterpriseId);
+        return this.getEnterpriseById(enterpriseId, true);
     }
 
     @Override
-    public Enterprise getEnterpriseById(String enterpriseId) {
+    public Enterprise getEnterpriseById(String enterpriseId, Boolean isLock) {
         if (StrUtil.isEmpty(enterpriseId)) {
             throw new BizIllegalException("参数缺失");
         }
         LambdaQueryWrapper<Enterprise> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(Enterprise::getId, enterpriseId);
         wrapper.eq(Enterprise::getStatus, GlobalStatusEnum.VALID.getCode());
-        wrapper.last("for update");
+        if (isLock) {
+            wrapper.last("for update");
+        }
         Enterprise enterprise = getOne(wrapper);
         if (ObjectUtil.isEmpty(enterprise)) {
             throw new BizIllegalException("商户不存在或已被禁用");
@@ -71,7 +73,7 @@ public class EnterpriseServiceImpl extends ServiceImpl<EnterpriseMapper, Enterpr
     public void rechargeBalance(String merchantId, Integer amount) {
         LocalDateTime now = LocalDateTime.now();
         // 余额充值
-        Enterprise enterprise = this.getEnterpriseById(merchantId);
+        Enterprise enterprise = this.getEnterpriseById(merchantId, true);
         BigDecimal fund = enterprise.getFund();
         BigDecimal rechargeAmount = new BigDecimal(amount);
         fund = fund.add(rechargeAmount);
diff --git a/nxhs-service/src/main/java/cc/yunxi/service/impl/RecycleOrderServiceImpl.java b/nxhs-service/src/main/java/cc/yunxi/service/impl/RecycleOrderServiceImpl.java
index 926f83a..8ddc560 100644
--- a/nxhs-service/src/main/java/cc/yunxi/service/impl/RecycleOrderServiceImpl.java
+++ b/nxhs-service/src/main/java/cc/yunxi/service/impl/RecycleOrderServiceImpl.java
@@ -19,6 +19,9 @@ import cc.yunxi.mapper.RecycleOrderMapper;
 import cc.yunxi.service.*;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -61,6 +64,9 @@ public class RecycleOrderServiceImpl extends ServiceImpl<RecycleOrderMapper, Rec
     @Resource
     private IHousingEstateService housingEstateService;
 
+    @Resource
+    private  IEnterpriseService enterpriseService;
+
     /**
      * 定点订单状态查询汇总
      *    散户 UNPROCESSED | FINISHED | CANCELED
@@ -185,7 +191,7 @@ public class RecycleOrderServiceImpl extends ServiceImpl<RecycleOrderMapper, Rec
         recycleOrder.setOrderStatus(OrderStatusEnum.PENDING);
         recycleOrder.setCreatorTime(now);
         log.info("create recycleOrder info : {}", recycleOrder);
-        this.save(recycleOrder);
+        this.saveRecycleOrder(recycleOrder, recycleStation.getEnterpriseId());
 
         // 创建订单明细
         String orderId = recycleOrder.getId();
@@ -226,7 +232,7 @@ public class RecycleOrderServiceImpl extends ServiceImpl<RecycleOrderMapper, Rec
         recycleOrder.setOrderType(OrderTypeEnum.TM_RECOVERY);
         recycleOrder.setOrderStatus(OrderStatusEnum.UNPROCESSED);
         recycleOrder.setCreatorTime(LocalDateTime.now());
-        this.save(recycleOrder);
+        this.saveRecycleOrder(recycleOrder, housingInfo.getEnterpriseId());
 
         return recycleOrder.getId();
     }
@@ -257,7 +263,7 @@ public class RecycleOrderServiceImpl extends ServiceImpl<RecycleOrderMapper, Rec
         recycleOrder.setOrderStatus(OrderStatusEnum.FINISHED); // 直接完成
         recycleOrder.setCreatorTime(now);
         recycleOrder.setCompleteTime(now);  // 完成时间
-        this.save(recycleOrder);
+        this.saveRecycleOrder(recycleOrder, recycler.getCompanyId());
 
         // 创建订单明细
         String orderId = recycleOrder.getId();
@@ -433,4 +439,19 @@ public class RecycleOrderServiceImpl extends ServiceImpl<RecycleOrderMapper, Rec
         }
     }
 
+
+    // 保存订单
+    private void saveRecycleOrder(RecycleOrder recycleOrder, String enterpriseId) {
+        Enterprise enterprise = enterpriseService.getEnterpriseById(enterpriseId, false);
+        String companyId = enterprise.getId();
+        String companyPid = enterprise.getPid();
+        JSONArray jsonArray = JSONUtil.createArray();
+        jsonArray.add(companyPid);
+        jsonArray.add(companyId);
+        String organizeJsonId = jsonArray.toJSONString(0);
+        recycleOrder.setCompanyId(companyId);
+        recycleOrder.setOrganizeJsonId(organizeJsonId);
+        this.save(recycleOrder);
+    }
+
 }