合并

src/main/java/com/huiju/estateagents/activity/controller/ActivityController.java

@@ -0,0 +1,49 @@
+package com.huiju.estateagents.activity.controller;
+
+import com.huiju.estateagents.activity.service.ActivityServiceI;
+import com.huiju.estateagents.base.BaseController;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.service.ITaPersonService;
+import io.swagger.annotations.Api;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+/**
+ * @author FXF
+ * @date 2019-10-21
+ */
+@RestController
+@RequestMapping("/api")
+@Api(value = "所有活动", tags = "所有活动")
+public class ActivityController extends BaseController {
+	
+	@Autowired
+	private ActivityServiceI activityService;
+	
+	@Autowired
+	private ITaPersonService taPersonService;
+	
+	@RequestMapping(value = "/wx/activity/list", method = RequestMethod.GET)
+	public ResponseBean wxBuildingDynamiceList(@RequestParam(value = "pageNumber",defaultValue = "1")Integer pageNumber,
+	                                           @RequestParam(value = "pageSize",defaultValue = "10")Integer pageSize,
+	                                           HttpServletRequest request){
+		String openid = getOpenId(request);
+		Integer orgId = getOrgId(request);
+		ResponseBean  responseBean = new ResponseBean();
+		List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+		if (null == taPersons || taPersons.size() != 1) {
+			return responseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+		}
+		TaPerson person = taPersons.get(0);
+		responseBean = activityService.getActivityList(pageNumber,pageSize,orgId,person);
+		
+		return responseBean;
+	}
+}

src/main/java/com/huiju/estateagents/activity/entity/Activity.java

@@ -0,0 +1,32 @@
+package com.huiju.estateagents.activity.entity;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author FXF
+ * @date 2019-10-21
+ */
+@Data
+public class Activity {
+
+	private Integer id;
+	
+	private String mainImg;
+	
+	private String title;
+	
+	private LocalDateTime startDate;
+	
+	private LocalDateTime endDate;
+	
+	private Integer weight;
+	
+	/**
+	 *  0：进行中 1：未开始 2：已结束 3：已参与（微信端用）
+	 */
+	private Integer activityStatus;
+	
+	private String type;
+}

src/main/java/com/huiju/estateagents/activity/mapper/ActivityMapper.java

@@ -0,0 +1,13 @@
+package com.huiju.estateagents.activity.mapper;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huiju.estateagents.activity.entity.Activity;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface ActivityMapper {
+	List<Activity> getActivityList(Page pg, @Param("orgId") Integer orgId,@Param("status") Integer status);
+}

src/main/java/com/huiju/estateagents/activity/service/ActivityServiceI.java

@@ -0,0 +1,17 @@
+package com.huiju.estateagents.activity.service;
+
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.entity.TaPerson;
+
+public interface ActivityServiceI {
+	
+	/**
+	 * 获取三个活动
+	 * @param pageNumber
+	 * @param pageSize
+	 * @param orgId
+	 * @param person
+	 * @return
+	 */
+	ResponseBean getActivityList(Integer pageNumber, Integer pageSize, Integer orgId, TaPerson person);
+}

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

@@ -0,0 +1,95 @@
+package com.huiju.estateagents.activity.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huiju.estateagents.activity.entity.Activity;
+import com.huiju.estateagents.activity.mapper.ActivityMapper;
+import com.huiju.estateagents.activity.service.ActivityServiceI;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.entity.HelpRecord;
+import com.huiju.estateagents.entity.TaActivityDynamicEnlist;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.entity.TaShareRecord;
+import com.huiju.estateagents.mapper.HelpRecordMapper;
+import com.huiju.estateagents.mapper.TaActivityDynamicEnlistMapper;
+import com.huiju.estateagents.mapper.TaShareRecordMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author FXF
+ * @date 2019-10-21
+ */
+@Service
+public class ActivityServiceImpl implements ActivityServiceI {
+	
+	@Autowired
+	private ActivityMapper activityMapper;
+	
+	@Autowired
+	private TaActivityDynamicEnlistMapper taActivityDynamicEnlistMapper;
+	
+	@Autowired
+	private TaShareRecordMapper taShareRecordMapper;
+	
+	@Autowired
+	private HelpRecordMapper helpRecordMapper;
+	
+	/**
+	 * 获取三个活动
+	 *
+	 * @param pageNumber
+	 * @param pageSize
+	 * @param orgId
+	 * @param person
+	 * @return
+	 */
+	@Override
+	public ResponseBean getActivityList(Integer pageNumber, Integer pageSize, Integer orgId, TaPerson person) {
+		//查询是否报名了普通活动
+		QueryWrapper<TaActivityDynamicEnlist> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("org_id",orgId);
+		queryWrapper.eq("person_id",person.getPersonId());
+		List<TaActivityDynamicEnlist> taActivityDynamicEnlists = taActivityDynamicEnlistMapper.selectList(queryWrapper);
+		//查询是否报名了分享活动
+		QueryWrapper<TaShareRecord> taShareRecordQueryWrapper = new QueryWrapper<>();
+		taShareRecordQueryWrapper.eq("org_id",orgId);
+		taShareRecordQueryWrapper.eq("person_id",person.getPersonId());
+		List<TaShareRecord> taShareRecords = taShareRecordMapper.selectList(taShareRecordQueryWrapper);
+		//判断是否报名了助力活动
+		QueryWrapper<HelpRecord> helpRecordQueryWrapper = new QueryWrapper<>();
+		helpRecordQueryWrapper.eq("org_id",orgId);
+		helpRecordQueryWrapper.eq("person_id",person.getPersonId());
+		List<HelpRecord> helpRecords = helpRecordMapper.selectList(helpRecordQueryWrapper);
+		
+		//分页获取全部数据
+		Page pg = new Page(pageNumber,pageSize);
+		List<Activity> list = activityMapper.getActivityList(pg,orgId, CommConstant.STATUS_NORMAL);
+		list.forEach(e -> {
+			if (e.getType().equals("dynamic")){
+				taActivityDynamicEnlists.forEach(dynamic -> {
+					if (e.getId().equals(dynamic.getDynamicId())){
+						e.setActivityStatus(CommConstant.ACTIVITY_STATUS_PARTNER);
+					}
+				});
+			}else if (e.getType().equals("share")){
+				taShareRecords.forEach(share -> {
+					if (e.getId().equals(share.getGroupActivityId())){
+						e.setActivityStatus(CommConstant.ACTIVITY_STATUS_PARTNER);
+					}
+				});
+			}else if (e.getType().equals("help")){
+				helpRecords.forEach(help -> {
+					if (e.getId().equals(help.getHelpActivityId())){
+						e.setActivityStatus(CommConstant.ACTIVITY_STATUS_PARTNER);
+					}
+				});
+			}
+		});
+		pg.setRecords(list);
+		return ResponseBean.success(pg);
+	}
+}

src/main/java/com/huiju/estateagents/common/CommConstant.java

@@ -385,4 +385,10 @@ public class CommConstant {
 	
 	
 	public static final String GD_KEY = "c9fc664a9030aed2ec2183508c2ca476";
+ 
+	//已参与微信端用
+    public static final Integer ACTIVITY_STATUS_PARTNER = 3;
+    
+    //发起者
+	public static final String HELP_STATUS_INITIATE = "Initiate";
 }

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

@@ -9,7 +9,13 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
-import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.entity.HelpActivity;
+import com.huiju.estateagents.entity.HelpInitiateRecord;
+import com.huiju.estateagents.entity.HelpRecord;
+import com.huiju.estateagents.entity.TaBuildingDynamic;
+import com.huiju.estateagents.entity.TaChannel;
+import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.excel.HelpInitiateRecordSucceed;
 import com.huiju.estateagents.excel.HelpProceedAndFinish;
 import com.huiju.estateagents.excel.HelpRecordExport;
@@ -17,7 +23,10 @@ import com.huiju.estateagents.excel.PublicCustomerExport;
 import com.huiju.estateagents.excel.handler.CustomCellWriteHandler;
 import com.huiju.estateagents.mapper.HelpInitiateRecordMapper;
 import com.huiju.estateagents.service.IHelpActivityService;
+import com.huiju.estateagents.service.IHelpInitiateRecordService;
+import com.huiju.estateagents.service.IHelpRecordService;
 import com.huiju.estateagents.service.ITaBuildingService;
+import com.huiju.estateagents.service.ITaPersonService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiImplicitParam;
@@ -32,7 +41,9 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import javax.xml.crypto.Data;
 import java.io.IOException;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -54,7 +65,15 @@ public class HelpActivityController extends BaseController {
 
     @Autowired
     private ITaBuildingService iTaBuildingService;
-
+    
+    @Autowired
+    private ITaPersonService taPersonService;
+    
+    @Autowired
+    private IHelpInitiateRecordService helpInitiateRecordService;
+    
+    @Autowired
+    private IHelpRecordService helpRecordService;
 
     /**
      * 活动助力列表
@@ -344,4 +363,53 @@ public class HelpActivityController extends BaseController {
             // finish 会帮忙关闭流
             excelWriter.finish();
     }
+    
+    @ApiOperation(value = "微信端根据id查询活动助力详情", notes = "根据id查询活动助力详情")
+    @ApiImplicitParams({
+            @ApiImplicitParam(dataTypeClass = Integer.class, name = "helpActivityId", paramType = "path", value = "活动状态")
+    })
+    @RequestMapping(value = "/wx/helpActivity/{helpActivityId}", method = RequestMethod.GET)
+    public ResponseBean wxHelpActivityGet(@PathVariable(value = "helpActivityId") Integer helpActivityId,HttpServletRequest request) {
+        ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return responseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        Map<String,Object> map = new HashMap<>();
+        try {
+            //活动信息
+            HelpActivity helpActivity = taHelpActivityService.getById(helpActivityId);
+            map.put("helpActivity",helpActivity);
+            
+            //发起者信息
+            QueryWrapper<HelpInitiateRecord> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("help_activity_id",helpActivity.getHelpActivityId());
+            queryWrapper.eq("persion_id",person.getPersonId());
+            queryWrapper.eq("org_id",orgId);
+            HelpInitiateRecord helpInitiateRecord = helpInitiateRecordService.getOne(queryWrapper);
+            if (null != helpInitiateRecord){
+                helpActivity.setHelpStatus(CommConstant.HELP_STATUS_INITIATE);
+    
+                //助力者信息
+                QueryWrapper<HelpRecord> helpRecordQueryWrapper = new QueryWrapper<>();
+                helpRecordQueryWrapper.eq("org_id",orgId);
+                helpRecordQueryWrapper.eq("help_activity_id",helpActivity.getHelpActivityId());
+                helpRecordQueryWrapper.eq("help_record_initiate_id",helpInitiateRecord.getHelpRecordInitiateId());
+                List<HelpRecord> helpRecordList = helpRecordService.list(helpRecordQueryWrapper);
+                
+                map.put("helpInitiateRecord",helpInitiateRecord);
+                map.put("helpRecordList",helpRecordList);
+            }
+            
+            responseBean.addSuccess(map);
+        } catch (Exception e) {
+            e.printStackTrace();
+            logger.error("helpActivityDelete -=- {}", e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

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

@@ -6,7 +6,9 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.HelpInitiateRecord;
+import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.service.IHelpInitiateRecordService;
+import com.huiju.estateagents.service.ITaPersonService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -18,6 +20,10 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.servlet.http.HttpServletRequest;
+import java.time.LocalDateTime;
+import java.util.List;
+
 /**
  * <p>
     * 助力活动发起人员记录  前端控制器
@@ -27,13 +33,16 @@ import org.springframework.web.bind.annotation.RestController;
  * @since 2019-10-17
  */
 @RestController
-@RequestMapping("/")
+@RequestMapping("/api")
 public class HelpInitiateRecordController extends BaseController {
 
     private final Logger logger = LoggerFactory.getLogger(HelpInitiateRecordController.class);
 
     @Autowired
     public IHelpInitiateRecordService taHelpInitiateRecordService;
+    
+    @Autowired
+    private ITaPersonService taPersonService;
 
 
     /**
@@ -146,4 +155,66 @@ public class HelpInitiateRecordController extends BaseController {
         }
         return responseBean;
     }
+    
+    /**
+     * 微信端分页查询我发起的助力活动
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/wx/helpInitiateRecord",method= RequestMethod.GET)
+    public ResponseBean wxhelpInitiateRecordList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                 @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                 HttpServletRequest request){
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        ResponseBean responseBean = new ResponseBean();
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return responseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        try {
+            //分页获取数据
+            responseBean = taHelpInitiateRecordService.getInitiateRecord(pageNum, pageSize,orgId,person.getPersonId());
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("helpInitiateRecordList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+    
+    
+    /**
+     * 微信端保存发起活动对象
+     * @param helpInitiateRecord 实体对象
+     * @return
+     */
+    @RequestMapping(value="/wx/helpInitiateRecord",method= RequestMethod.POST)
+    public ResponseBean wxHelpInitiateRecordAdd(@RequestBody HelpInitiateRecord helpInitiateRecord,HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return responseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        try {
+            helpInitiateRecord.setPersionId(person.getPersonId());
+            helpInitiateRecord.setCreateDate(LocalDateTime.now());
+            helpInitiateRecord.setOrgId(orgId);
+            if (taHelpInitiateRecordService.save(helpInitiateRecord)){
+                responseBean.addSuccess(helpInitiateRecord);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("helpInitiateRecordAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

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

@@ -6,7 +6,9 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.HelpRecord;
+import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.service.IHelpRecordService;
+import com.huiju.estateagents.service.ITaPersonService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -18,6 +20,10 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.servlet.http.HttpServletRequest;
+import java.time.LocalDateTime;
+import java.util.List;
+
 /**
  * <p>
     * 助力活动助力人员记录  前端控制器
@@ -27,13 +33,16 @@ import org.springframework.web.bind.annotation.RestController;
  * @since 2019-10-17
  */
 @RestController
-@RequestMapping("/")
+@RequestMapping("/api")
 public class HelpRecordController extends BaseController {
 
     private final Logger logger = LoggerFactory.getLogger(HelpRecordController.class);
 
     @Autowired
     public IHelpRecordService taHelpRecordService;
+    
+    @Autowired
+    private ITaPersonService taPersonService;
 
 
     /**
@@ -146,4 +155,30 @@ public class HelpRecordController extends BaseController {
         }
         return responseBean;
     }
+    
+    
+    /**
+     * 微信端助力者助力
+     * @param helpRecord 实体对象
+     * @return
+     */
+    @RequestMapping(value="/wx/helpRecord",method= RequestMethod.POST)
+    public ResponseBean wxHelpRecordAdd(@RequestBody HelpRecord helpRecord, HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return responseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        try {
+            responseBean = taHelpRecordService.saveBooster(helpRecord,orgId,person);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("helpRecordAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

src/main/java/com/huiju/estateagents/drainage/controller/TaDrainageController.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.drainage.entity.TaDrainage;
 import com.huiju.estateagents.drainage.service.ITaDrainageService;
 import org.slf4j.Logger;
@@ -48,8 +49,8 @@ public class TaDrainageController extends BaseController {
     @RequestMapping(value="/admin/taDrainage",method= RequestMethod.GET)
     public ResponseBean taDrainageList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
                                        @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
-                                       @RequestParam(value ="drainageId",defaultValue = "10") Integer drainageId,
-                                       @RequestParam(value ="name",defaultValue = "10") String name,
+                                       @RequestParam(value ="drainageId",required = false) Integer drainageId,
+                                       @RequestParam(value ="name",required = false) String name,
                                        HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
         try {
@@ -57,8 +58,8 @@ public class TaDrainageController extends BaseController {
 		    IPage<TaDrainage> pg = new Page<>(pageNum, pageSize);
             QueryWrapper<TaDrainage> queryWrapper = new QueryWrapper<>();
             queryWrapper.eq("org_id",getOrgId(request));
-            queryWrapper.eq("drainage_id",drainageId);
-            queryWrapper.like("name",name);
+            queryWrapper.eq(null != drainageId,"drainage_id",drainageId);
+            queryWrapper.like(!StringUtils.isEmpty(name),"name",name);
             queryWrapper.orderByDesc("create_date");
 
             IPage<TaDrainage> result = iTaDrainageService.page(pg, queryWrapper);

src/main/java/com/huiju/estateagents/drainage/controller/TaDrainageRecordController.java

@@ -19,6 +19,7 @@ import com.huiju.estateagents.excel.handler.CustomCellWriteHandler;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.format.annotation.DateTimeFormat;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -30,6 +31,7 @@ import org.springframework.web.bind.annotation.RestController;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
+import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -94,15 +96,15 @@ public class TaDrainageRecordController extends BaseController {
      */
     @RequestMapping(value="/admin/taDrainageRecord/export",method= RequestMethod.GET)
     public void taDrainageRecordList(@RequestParam(value = "drainageId") Integer drainageId,
-                                             @RequestParam(value = "startTime",required = false) String startTime,
-                                             @RequestParam(value = "endTime",required = false) String endTime,
+                                             @RequestParam(value = "startTime",required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime startTime,
+                                             @RequestParam(value = "endTime",required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime endTime,
                                              HttpServletRequest request, HttpServletResponse response) throws IOException {
             //使用分页插件
             QueryWrapper<TaDrainageRecord> queryWrapper = new QueryWrapper<>();
             queryWrapper.eq("drainage_id",drainageId);
             queryWrapper.eq("org_id",getOrgId(request));
-            queryWrapper.gt(!StringUtils.isEmpty(startTime),"create_date",startTime);
-            queryWrapper.lt(!StringUtils.isEmpty(endTime),"create_date",endTime);
+            queryWrapper.gt(null != startTime,"create_date",startTime);
+            queryWrapper.lt(null != endTime,"create_date",endTime);
             queryWrapper.orderByDesc("create_date");
     
             List<TaDrainageRecord> list = iTaDrainageRecordService.list(queryWrapper);

src/main/java/com/huiju/estateagents/entity/HelpActivity.java

@@ -2,6 +2,7 @@ package com.huiju.estateagents.entity;
 
 import com.alibaba.excel.annotation.ExcelProperty;
 import com.alibaba.excel.annotation.write.style.ColumnWidth;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
@@ -76,7 +77,7 @@ public class HelpActivity implements Serializable {
     /**
      * 助力次数 0不限制，大于零表示限制次数
      */
-    private String helpNum;
+    private Integer helpNum;
 
     /**
      * 状态 0未开始，1进行中，2已结束
@@ -112,5 +113,11 @@ public class HelpActivity implements Serializable {
      * 活动状态
      */
     private int activityStatus;
+    
+    /**
+     * Initiate 发起者  Booster 助力者
+     */
+    @TableField(exist = false)
+    private String helpStatus;
 
 }

src/main/java/com/huiju/estateagents/entity/HelpInitiateRecord.java

@@ -109,4 +109,16 @@ public class HelpInitiateRecord implements Serializable {
      */
     @TableField(exist = false)
     private int persionNumCount;
+    
+    @TableField(exist = false)
+    private String title;
+    
+    @TableField(exist = false)
+    private String img;
+    
+    @TableField(exist = false)
+    private Integer activityStatus;
+    
+    @TableField(exist = false)
+    private LocalDateTime endDate;
 }

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

@@ -4,6 +4,7 @@ package com.huiju.estateagents.mapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.entity.HelpInitiateRecord;
 import com.huiju.estateagents.excel.HelpInitiateRecordSucceed;
 import com.huiju.estateagents.excel.HelpProceedAndFinish;
@@ -39,7 +40,19 @@ public interface HelpInitiateRecordMapper extends BaseMapper<HelpInitiateRecord>
      * @param tel
      * @param helpActivityId
      */
+
     List<HelpInitiateRecordSucceed> getHelpInitiateRecordSucceedExportList(@Param("pageCode") int i, @Param("pageSize") Integer pageSize, @Param("tel") String tel, @Param("helpActivityId") Integer helpActivityId);
 
     List<HelpProceedAndFinish> getHelpProceedAndFinishExportList(@Param("pageCode") int i, @Param("pageSize")Integer pageSize, @Param("tel")String tel, @Param("helpActivityId")Integer helpActivityId);
+
+    List<HelpInitiateRecordSucceed> getHelpInitiateRecordSucceedExportList(@Param("pageCode") int i, @Param("pageSize") Integer pageSize, @Param("tel") Integer tel, @Param("helpActivityId") Integer helpActivityId);
+	
+	/**
+	 * 获取我的助力列表
+	 * @param pg
+	 * @param orgId
+	 * @param personId
+	 * @return
+	 */
+	List<HelpInitiateRecord> getInitiateRecordList(Page<HelpInitiateRecord> pg,@Param("orgId") Integer orgId,@Param("personId") String personId);
 }

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

@@ -1,6 +1,7 @@
 package com.huiju.estateagents.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.HelpInitiateRecord;
 
 /**
@@ -12,5 +13,14 @@ import com.huiju.estateagents.entity.HelpInitiateRecord;
  * @since 2019-10-17
  */
 public interface IHelpInitiateRecordService extends IService<HelpInitiateRecord> {
-
+	
+	/**
+	 * 分页获取我的助力数据
+	 * @param pageNum
+	 * @param pageSize
+	 * @param orgId
+	 * @param personId
+	 * @return
+	 */
+	ResponseBean getInitiateRecord(Integer pageNum, Integer pageSize, Integer orgId, String personId);
 }

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

@@ -1,7 +1,9 @@
 package com.huiju.estateagents.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.HelpRecord;
+import com.huiju.estateagents.entity.TaPerson;
 
 /**
  * <p>
@@ -12,5 +14,13 @@ import com.huiju.estateagents.entity.HelpRecord;
  * @since 2019-10-17
  */
 public interface IHelpRecordService extends IService<HelpRecord> {
-
+	
+	/**
+	 * 助力者助力
+	 * @param helpRecord
+	 * @param orgId
+	 * @param person
+	 * @return
+	 */
+	ResponseBean saveBooster(HelpRecord helpRecord, Integer orgId, TaPerson person);
 }

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

@@ -1,11 +1,17 @@
 package com.huiju.estateagents.service.impl;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.HelpInitiateRecord;
 import com.huiju.estateagents.mapper.HelpInitiateRecordMapper;
 import com.huiju.estateagents.service.IHelpInitiateRecordService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 助力活动发起人员记录  服务实现类
@@ -16,5 +22,23 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class HelpInitiateRecordServiceImpl extends ServiceImpl<HelpInitiateRecordMapper, HelpInitiateRecord> implements IHelpInitiateRecordService {
-
+	
+	@Autowired
+	private HelpInitiateRecordMapper helpInitiateRecordMapper;
+	/**
+	 * 分页获取我的助力数据
+	 *
+	 * @param pageNum
+	 * @param pageSize
+	 * @param orgId
+	 * @param personId
+	 * @return
+	 */
+	@Override
+	public ResponseBean getInitiateRecord(Integer pageNum, Integer pageSize, Integer orgId, String personId) {
+		Page<HelpInitiateRecord> pg = new Page<>(pageNum, pageSize);
+		List<HelpInitiateRecord> helpInitiateRecordList = helpInitiateRecordMapper.getInitiateRecordList(pg,orgId,personId);
+		pg.setRecords(helpInitiateRecordList);
+		return ResponseBean.success(pg);
+	}
 }

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

@@ -1,11 +1,23 @@
 package com.huiju.estateagents.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.StringUtils;
+import com.huiju.estateagents.entity.HelpActivity;
+import com.huiju.estateagents.entity.HelpInitiateRecord;
 import com.huiju.estateagents.entity.HelpRecord;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.mapper.HelpActivityMapper;
+import com.huiju.estateagents.mapper.HelpInitiateRecordMapper;
 import com.huiju.estateagents.mapper.HelpRecordMapper;
 import com.huiju.estateagents.service.IHelpRecordService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
+import java.util.List;
+
 /**
  * <p>
  * 助力活动助力人员记录  服务实现类
@@ -16,5 +28,70 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class HelpRecordServiceImpl extends ServiceImpl<HelpRecordMapper, HelpRecord> implements IHelpRecordService {
-
+	
+	@Autowired
+	private HelpActivityMapper helpActivityMapper;
+	
+	@Autowired
+	private HelpInitiateRecordMapper helpInitiateRecordMapper;
+	
+	@Autowired
+	private HelpRecordMapper helpRecordMapper;
+	
+	/**
+	 * 助力者助力
+	 *
+	 * @param helpRecord
+	 * @param orgId
+	 * @param person
+	 * @return
+	 */
+	@Override
+	public ResponseBean saveBooster(HelpRecord helpRecord, Integer orgId, TaPerson person) {
+		//查看是否助力成功
+		HelpInitiateRecord helpInitiateRecord = helpInitiateRecordMapper.selectById(helpRecord.getHelpRecordInitiateId());
+		if (!StringUtils.isEmpty(helpInitiateRecord.getVerification())){
+			return ResponseBean.error("已经助力成功", ResponseBean.ERROR_UNAVAILABLE);
+		}
+		
+		HelpActivity helpActivity = helpActivityMapper.selectById(helpRecord.getHelpActivityId());
+		//是否助力成功
+		if (helpActivity.getEnlistNum() >= helpActivity.getPersionNum()){
+			return ResponseBean.error("已经助力成功", ResponseBean.ERROR_UNAVAILABLE);
+		}
+		if (helpActivity.getEndDate().isBefore(LocalDateTime.now())){
+			return ResponseBean.error("活动已超时", ResponseBean.ERROR_UNAVAILABLE);
+		}
+		//查看每个人的助力次数
+		Integer helpNum = helpActivity.getHelpNum();
+		
+		QueryWrapper<HelpRecord> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("org_id",orgId);
+		queryWrapper.eq("help_activity_id",helpRecord.getHelpActivityId());
+		queryWrapper.eq("persion_id",person.getPersonId());
+		if (null != helpNum && helpNum >= 0){
+			//查看这个人是否助力过，和助力了几次
+			List<HelpRecord> helpRecords = helpRecordMapper.selectList(queryWrapper);
+			if (helpRecords.size() >= helpNum){
+				return ResponseBean.error("助力次数达到上限", ResponseBean.ERROR_UNAVAILABLE);
+			}
+		}
+		//查看是否助力过这个人
+		queryWrapper.eq("help_record_initiate_id",helpRecord.getHelpRecordInitiateId());
+		List<HelpRecord> helpRecordList = helpRecordMapper.selectList(queryWrapper);
+		if (helpRecordList.size() > 0){
+			return ResponseBean.error("您已经助力过了,无需重复助力", ResponseBean.ERROR_UNAVAILABLE);
+		}
+		//反更新在入库
+		helpActivity.setEnlistNum(helpActivity.getEnlistNum()+1);
+		helpActivityMapper.updateById(helpActivity);
+		helpInitiateRecord.setEnlistNum(helpInitiateRecord.getEnlistNum()+1);
+		helpInitiateRecordMapper.updateById(helpInitiateRecord);
+		//插入数据
+		helpRecord.setOrgId(orgId);
+		helpRecord.setCreateDate(LocalDateTime.now());
+		helpRecord.setPersionId(person.getPersonId());
+		helpRecordMapper.insert(helpRecord);
+		return ResponseBean.success(helpRecord);
+	}
 }

src/main/resources/mapper/Activity.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.huiju.estateagents.activity.mapper.ActivityMapper">
+
+    <select id="getActivityList" resultType="com.huiju.estateagents.activity.entity.Activity">
+        SELECT dynamic_id as id,img_url as main_img,title,start_date as start_date,enlist_end as end_date,weight,activity_status,'dynamic' as type FROM ta_building_dynamic WHERE org_id = #{orgId}  and `status` = #{status}
+        UNION  all
+        SELECT group_acticity_id as id,main_img,activity_name as title,start_time as start_date,end_time as end_date,weight,activity_status,'share' as type from ta_share_activity WHERE org_id = #{orgId} and `status` = #{status}
+        UNION  all
+        SELECT help_activity_id as id,img as main_img,title,start_date,end_date,weight,activity_status,'help' as type from ta_help_activity WHERE org_id = #{orgId} and `status` = #{status}
+        ORDER BY weight desc,activity_status,start_date
+    </select>
+</mapper>

src/main/resources/mapper/HelpInitiateRecordMapper.xml

@@ -48,4 +48,19 @@
      order by b.create_date desc
      limit #{pageCode}, #{pageSize}
     </select>
+
+    <select id="getInitiateRecordList" resultType="com.huiju.estateagents.entity.HelpInitiateRecord">
+      SELECT
+        t.*,
+        a.title,
+        a.img,
+        a.activity_status,
+        a.end_date
+    FROM
+        ta_help_initiate_record t
+        LEFT JOIN ta_help_activity a ON t.help_activity_id = a.help_activity_id
+    WHERE
+        t.org_id = #{orgId}
+        AND t.persion_id = #{personId}
+    </select>
 </mapper>