diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java
index 85befe73c6..720b3d9a23 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java
@@ -35,6 +35,7 @@ import com.epmet.entity.stats.DimDateEntity;
 import com.epmet.entity.stats.DimMonthEntity;
 import com.epmet.service.StatsDemoService;
 import com.epmet.service.evaluationindex.extract.dataToIndex.*;
+import com.epmet.service.evaluationindex.extract.todata.FactOriginProjectCategoryDailyService;
 import com.epmet.service.evaluationindex.extract.todata.FactOriginTopicMainDailyService;
 import com.epmet.service.evaluationindex.extract.toscreen.*;
 import com.epmet.service.evaluationindex.indexcal.*;
@@ -106,6 +107,8 @@ public class DemoController {
     private ScreenProjectSettleService screenProjectSettleService;
     @Autowired
     private ScreenProjectCategoryGridDailyService projectCategoryGridDailyService;
+    @Autowired
+    private FactOriginProjectCategoryDailyService originProjectCategoryDailyService;
 
     @GetMapping("testAlarm")
     public void testAlarm() {
@@ -831,10 +834,29 @@ public class DemoController {
         }
     }
 
+    /**
+     * @return com.epmet.commons.tools.utils.Result
+     * @param customerId
+     * @author yinzuomei
+     * @description 产品内部计算：网格内按分类统计项目数量
+     * @Date 2021/3/23 10:52
+     **/
     @PostMapping("extractProjectCategoryData")
     public Result extractProjectCategoryData(@RequestParam("customerId") String customerId){
         String dateId = LocalDate.now().minusDays(NumConstant.ONE).toString().replace("-", "");
         projectCategoryGridDailyService.extractProjectCategoryData(customerId,dateId);
         return new Result();
     }
+
+    /**
+     * @return com.epmet.commons.tools.utils.Result
+     * @author yinzuomei
+     * @description  将epmet_gov_project库中的项目分类信息（project_category）同步到统计库epmet_data_statistical
+     * @Date 2021/3/23 10:52
+     **/
+    @PostMapping("extractProjectCategory")
+    public Result extractProjectCategory(@RequestBody ExtractOriginFormDTO formDTO){
+        originProjectCategoryDailyService.extractProjectCategory(formDTO);
+        return new Result();
+    }
 }
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/crm/CustomerRelationDao.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/crm/CustomerRelationDao.java
index fabee946e7..11ec9c119c 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/crm/CustomerRelationDao.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/crm/CustomerRelationDao.java
@@ -43,4 +43,12 @@ public interface CustomerRelationDao extends BaseDao<CustomerRelationEntity> {
     CustomerSubInfoDTO selectCustomerSubInfo(@Param("customerId")String customerId);
 
     List<CustomerRelationEntity> selectListByPids(String customerId);
+
+    /**
+     * @Description  查询子级客户
+     * @Param customerId
+     * @author zxc
+     * @date 2021/3/23 上午10:21
+     */
+    List<CustomerRelationEntity> selectSubCustomer(@Param("customerId") String customerId);
 }
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/CustomerRelationService.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/CustomerRelationService.java
index f139c49bab..4c2a37620f 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/CustomerRelationService.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/CustomerRelationService.java
@@ -22,6 +22,8 @@ import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.dto.indexcal.CustomerSubInfoDTO;
 import com.epmet.entity.crm.CustomerRelationEntity;
 
+import java.util.List;
+
 /**
  * 客户关系表(01.14 add)
  *
@@ -40,4 +42,12 @@ public interface CustomerRelationService extends BaseService<CustomerRelationEnt
     CustomerSubInfoDTO getCustomerSubInfo(String customerId);
 
     boolean haveSubCustomer(String customerId);
+
+    /**
+     * @Description  查询子级客户
+     * @Param customerId
+     * @author zxc
+     * @date 2021/3/23 上午10:21
+     */
+    List<CustomerRelationEntity> selectSubCustomer(String customerId);
 }
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/impl/CustomerRelationServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/impl/CustomerRelationServiceImpl.java
index cab6ed0adc..06d2b580fc 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/impl/CustomerRelationServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/impl/CustomerRelationServiceImpl.java
@@ -27,9 +27,11 @@ import com.epmet.entity.crm.CustomerRelationEntity;
 import com.epmet.service.crm.CustomerRelationService;
 import com.epmet.service.stats.DimCustomerService;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -70,4 +72,18 @@ public class CustomerRelationServiceImpl extends BaseServiceImpl<CustomerRelatio
         }
         return true;
     }
+
+    /**
+     * @Description  查询子级客户
+     * @Param customerId
+     * @author zxc
+     * @date 2021/3/23 上午10:21
+     */
+    @Override
+    public List<CustomerRelationEntity> selectSubCustomer(String customerId) {
+        if (StringUtils.isEmpty(customerId)){
+            return new ArrayList<>();
+        }
+        return baseDao.selectSubCustomer(customerId);
+    }
 }
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/ScreenProjectCategoryOrgDailyService.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/ScreenProjectCategoryOrgDailyService.java
index ce71722794..150c15a0d4 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/ScreenProjectCategoryOrgDailyService.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/ScreenProjectCategoryOrgDailyService.java
@@ -102,4 +102,13 @@ public interface ScreenProjectCategoryOrgDailyService extends BaseService<Screen
      * @return void
      */
     void collect(ScreenCollFormDTO<ScreenProjectCategoryOrgDailyDTO> param);
+
+    /**
+     * @Description  按组织计算分类统计项目数量
+     * @Param customerId
+     * @Param dateId
+     * @author zxc
+     * @date 2021/3/23 上午10:07
+     */
+    void extractProjectCategoryOrgData(String customerId, String dateId);
 }
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectCategoryOrgDailyServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectCategoryOrgDailyServiceImpl.java
index 5660fad150..c9af2a289c 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectCategoryOrgDailyServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenProjectCategoryOrgDailyServiceImpl.java
@@ -29,14 +29,19 @@ import com.epmet.constant.DataSourceConstant;
 import com.epmet.dao.evaluationindex.screen.ScreenProjectCategoryOrgDailyDao;
 import com.epmet.dto.screen.ScreenProjectCategoryOrgDailyDTO;
 import com.epmet.dto.screencoll.ScreenCollFormDTO;
+import com.epmet.entity.crm.CustomerRelationEntity;
 import com.epmet.entity.evaluationindex.screen.ScreenProjectCategoryOrgDailyEntity;
+import com.epmet.service.crm.CustomerRelationService;
 import com.epmet.service.evaluationindex.screen.ScreenProjectCategoryOrgDailyService;
 import com.google.common.collect.Lists;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
@@ -51,6 +56,8 @@ import java.util.Map;
 @DataSource(DataSourceConstant.EVALUATION_INDEX)
 public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<ScreenProjectCategoryOrgDailyDao, ScreenProjectCategoryOrgDailyEntity> implements ScreenProjectCategoryOrgDailyService {
 
+    @Autowired
+    private CustomerRelationService relationService;
 
     @Override
     public PageData<ScreenProjectCategoryOrgDailyDTO> page(Map<String, Object> params) {
@@ -131,4 +138,71 @@ public class ScreenProjectCategoryOrgDailyServiceImpl extends BaseServiceImpl<Sc
         }
     }
 
+    /**
+     * @Description  按组织计算分类统计项目数量
+     * @Param customerId
+     * @Param dateId
+     * @author zxc
+     * @date 2021/3/23 上午10:07
+     */
+    @Override
+    public void extractProjectCategoryOrgData(String customerId, String dateId) {
+        List<ScreenProjectCategoryOrgDailyEntity> needInsert = new ArrayList<>();
+        // 先查询有无子客户
+        List<CustomerRelationEntity> relationInfo = relationService.selectSubCustomer(customerId);
+        if (CollectionUtils.isEmpty(relationInfo)){
+            needInsert = disposeOneCustomer(customerId, dateId);
+        }else {
+            needInsert = disposeMoreCustomer(customerId,dateId,relationInfo);
+        }
+        deleteAndInsert(customerId,dateId,needInsert);
+    }
+
+    /**
+     * @Description  单客户处理
+     * @Param customerId
+     * @Param dateId
+     * @author zxc
+     * @date 2021/3/23 上午10:40
+     */
+    private List<ScreenProjectCategoryOrgDailyEntity> disposeOneCustomer(String customerId, String dateId){
+
+        return new ArrayList<>();
+    }
+
+    /**
+     * @Description  多客户处理
+     * @Param customerId
+     * @Param dateId
+     * @Param relationInfo 子级客户信息
+     * @author zxc
+     * @date 2021/3/23 上午10:40
+     */
+    private List<ScreenProjectCategoryOrgDailyEntity> disposeMoreCustomer(String customerId, String dateId,List<CustomerRelationEntity> relationInfo){
+
+        return new ArrayList<>();
+    }
+
+    /**
+     * @Description  删除和新增
+     * @Param customerId
+     * @Param dateId
+     * @author zxc
+     * @date 2021/3/23 上午10:52
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteAndInsert(String customerId, String dateId, List<ScreenProjectCategoryOrgDailyEntity> needInsert){
+        if (CollectionUtils.isEmpty(needInsert)){
+            return;
+        }
+        Integer row = NumConstant.ZERO;
+        do {
+            row = baseDao.deleteByDateIdAndCustomerId(customerId, dateId);
+        }while (row > NumConstant.ZERO && row == NumConstant.ONE_THOUSAND);
+        List<List<ScreenProjectCategoryOrgDailyEntity>> partition = ListUtils.partition(needInsert, NumConstant.ONE_HUNDRED);
+        partition.forEach(p -> {
+            insertBatch(p);
+        });
+    }
+
 }
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/crm/CustomerRelationDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/crm/CustomerRelationDao.xml
index 88c12c8deb..fad1ca0443 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/crm/CustomerRelationDao.xml
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/crm/CustomerRelationDao.xml
@@ -34,4 +34,9 @@
             #{customerId},
             '%')
     </select>
+
+    <!-- 查询子级客户 -->
+    <select id="selectSubCustomer" resultType="com.epmet.entity.crm.CustomerRelationEntity">
+        SELECT * FROM customer_relation WHERE DEL_FLAG = 0 AND PARENT_CUSTOMER_ID = #{customerId}
+    </select>
 </mapper>
\ No newline at end of file