合并

src/main/java/com/huiju/estateagents/activity/service/impl/ActivityServiceImpl.java

@@ -64,7 +64,7 @@ public class ActivityServiceImpl implements ActivityServiceI {
 		taShareRecordQueryWrapper.eq("org_id",orgId);
 		taShareRecordQueryWrapper.eq("person_id",person.getPersonId());
 		List<TaShareRecord> taShareRecords = taShareRecordMapper.selectList(taShareRecordQueryWrapper);
-		//判断是否报名了助力活动
+		//判断是否发起了助力活动
 		QueryWrapper<HelpInitiateRecord> helpInitiateRecordListQueryWrapper = new QueryWrapper<>();
 		helpInitiateRecordListQueryWrapper.eq("org_id",orgId);
 		helpInitiateRecordListQueryWrapper.eq("person_id",person.getPersonId());

src/main/java/com/huiju/estateagents/controller/HelpInitiateRecordController.java

@@ -164,7 +164,7 @@ public class HelpInitiateRecordController extends BaseController {
      * @return
      */
     @RequestMapping(value="/wx/helpInitiateRecord",method= RequestMethod.GET)
-    public ResponseBean wxhelpInitiateRecordList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNumber,
+    public ResponseBean wxhelpInitiateRecordList(@RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
                                                  @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
                                                  HttpServletRequest request){
         String openid = getOpenId(request);

src/main/java/com/huiju/estateagents/controller/TaChannelController.java

@@ -227,9 +227,9 @@ public class TaChannelController extends BaseController {
     }
 
     /**
-     * 渠道邀请经纪人
+     * 渠道邀请经纪人列表
      */
-    @ApiOperation(value = "渠道邀请经纪人", notes = "渠道邀请经纪人")
+    @ApiOperation(value = "渠道邀请经纪人列表", notes = "渠道邀请经纪人列表")
     @ApiImplicitParams({
             @ApiImplicitParam(dataTypeClass = String.class, name = "id", paramType = "query",value = "姓名"),
             @ApiImplicitParam(dataTypeClass = String.class, name = "phone", paramType = "query",value = "电话"),

src/main/java/com/huiju/estateagents/controller/TaShareActivityController.java

@@ -108,10 +108,11 @@ public class TaShareActivityController extends BaseController {
     public ResponseBean taShareActivityList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
                                             @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
                                             @RequestParam(value ="cityId",required = false)Integer cityId,
+                                            @RequestParam(value ="buildingId",required = false)String buildingId,
                                             HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
         try {
-            responseBean = iTaShareActivityService.getEffectiveList(pageNum, pageSize, cityId, getOrgId(request));
+            responseBean = iTaShareActivityService.getEffectiveList(pageNum, pageSize, cityId, buildingId, getOrgId(request));
         }catch (Exception e){
             e.printStackTrace();
             logger.error("taShareActivityList -=- {}",e.toString());

src/main/java/com/huiju/estateagents/controller/TaShareRecordController.java

@@ -285,7 +285,7 @@ public class TaShareRecordController extends BaseController {
      * @return
      */
     @RequestMapping(value="/wx/taShareRecord",method= RequestMethod.GET)
-    public ResponseBean wxShareRecordList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNumber,
+    public ResponseBean wxShareRecordList(@RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
                                                  @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
                                                  HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();

src/main/java/com/huiju/estateagents/mapper/TaShareRecordMapper.java

@@ -29,4 +29,11 @@ public interface TaShareRecordMapper extends BaseMapper<TaShareRecord> {
     List<ShareRecordFailExport> getShareRecordFailExportList(@Param("pageCode") Integer pageCode, @Param("pageSize") Integer pageSize, @Param("recordId") Integer recordId , @Param("status")Integer status, @Param("groupActivityId") Integer groupActivityId);
 	List<TaShareRecord> getShareRecordList(Page<TaShareRecord> pg,@Param("orgId") Integer orgId,@Param("personId") String personId);
     void updateEndGroupActivity();
+
+    /**
+     * 计算成团数
+     * @param groupActivityId
+     * @return
+     */
+    Integer countGroupBuyPeople(@Param("groupActivityId") Integer groupActivityId);
 }

src/main/java/com/huiju/estateagents/service/ITaShareActivityService.java

@@ -37,5 +37,5 @@ public interface ITaShareActivityService extends IService<TaShareActivity> {
      * @param orgId
      * @return
      */
-    ResponseBean getEffectiveList(Integer pageNum, Integer pageSize, Integer cityId, Integer orgId);
+    ResponseBean getEffectiveList(Integer pageNum, Integer pageSize, Integer cityId, String buildingId, Integer orgId);
 }

src/main/java/com/huiju/estateagents/service/impl/TaShareActivityServiceImpl.java

@@ -8,6 +8,7 @@ import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.TaShareActivity;
 import com.huiju.estateagents.entity.TaShareRecord;
 import com.huiju.estateagents.mapper.TaShareActivityMapper;
+import com.huiju.estateagents.mapper.TaShareRecordMapper;
 import com.huiju.estateagents.service.ITaShareActivityService;
 import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -29,6 +30,8 @@ public class TaShareActivityServiceImpl extends ServiceImpl<TaShareActivityMappe
 
     @Autowired
     private TaShareActivityMapper taShareActivityMapper;
+    @Autowired
+    private TaShareRecordMapper taShareRecordMapper;
 
     @Override
     public ResponseBean getList(Integer pageNum, Integer pageSize, String buildingId, String activityName, String activityStatus, LocalDateTime startTime, LocalDateTime endTime, Integer cityId, Integer orgId) {
@@ -52,7 +55,9 @@ public class TaShareActivityServiceImpl extends ServiceImpl<TaShareActivityMappe
         List<TaShareActivity> taShareActivities = taNewsIPage.getRecords();
         for (TaShareActivity taShareActivity : taShareActivities){
             Integer participateNum = taShareActivityMapper.calParticipateNum(taShareActivity.getGroupActivityId());
+            Integer groupPeoplePeople = taShareRecordMapper.countGroupBuyPeople(taShareActivity.getGroupActivityId());
             taShareActivity.setParticipateNum(participateNum);
+            taShareActivity.setGroupBuyPeople(groupPeoplePeople);
         }
         taNewsIPage.setRecords(taShareActivities);
         responseBean.addSuccess(taNewsIPage);
@@ -70,7 +75,7 @@ public class TaShareActivityServiceImpl extends ServiceImpl<TaShareActivityMappe
     }
 
     @Override
-    public ResponseBean getEffectiveList(Integer pageNum, Integer pageSize, Integer cityId, Integer orgId) {
+    public ResponseBean getEffectiveList(Integer pageNum, Integer pageSize, Integer cityId, String buildingId, Integer orgId) {
         ResponseBean responseBean = new ResponseBean();
         Page<TaShareActivity> page = new Page<>();
         page.setSize(pageSize == null ? 10 : pageSize);
@@ -80,6 +85,7 @@ public class TaShareActivityServiceImpl extends ServiceImpl<TaShareActivityMappe
         queryWrapper.in("activity_status", 0, 1);
         queryWrapper.eq(orgId != null, "org_id", orgId);
         queryWrapper.eq(cityId != null, "city_id", cityId);
+        queryWrapper.eq(buildingId != null, "building_id", buildingId);
         queryWrapper.orderByAsc("activity_status");
         queryWrapper.orderByAsc("start_time");
         IPage<TaShareActivity> taNewsIPage = this.page(page, queryWrapper);

src/main/resources/mapper/TaRecommendCustomerMapper.xml

@@ -341,19 +341,19 @@ FROM
             SELECT
               count( 1 )
             FROM
-              ta_recommend_customer tarc
-            LEFT JOIN ta_person tp ON tarc.recommend_person = tp.person_id
+              ta_person tp
             WHERE
-              tarc.recommend_person = a.person_id and ifnull(tp.person_type, '') = 'customer'
+              tp.recommend_agent = a.person_id
         ) AS agentCount,
         (
             SELECT
               count( 1 )
             FROM
               ta_recommend_customer tarc
-            LEFT JOIN ta_person tp ON tarc.recommend_person = tp.person_id
             WHERE
-              tarc.recommend_person = a.person_id and ifnull(tp.person_type, '') in ('channel agent', 'estate agent')
+              tarc.recommend_person = a.person_id
+              and tarc.status = 1
+              and tarc.org_id = #{orgId}
         ) AS recommedCount
         FROM
         ta_person a

src/main/resources/mapper/TaShareRecordMapper.xml

@@ -131,6 +131,7 @@
     <select id="getShareRecordList" resultType="com.huiju.estateagents.entity.TaShareRecord">
         SELECT
             t.record_id AS id,
+            t.record_id,
             t.group_activity_id,
             t.nickname,
             t.phone,
@@ -154,6 +155,7 @@
 	UNION ALL
         SELECT
             t.child_record_id AS id,
+            t.record_id,
             t.group_activity_id,
             t.nickname,
             t.phone,
@@ -176,4 +178,8 @@
             AND t.person_id = #{personId}
         order by status,create_time desc
     </select>
+
+    <select id="countGroupBuyPeople" resultType="java.lang.Integer">
+        select count(1) From ta_share_record t where t.group_activity_id = #{groupActivityId} GROUP BY t.group_activity_id
+    </select>
 </mapper>