Merge branch 'v3.5' of http://git.ycjcjy.com/zhiyuxing/estateagents into v3.5

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

 package com.huiju.estateagents.controller;
 
 
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.ExcelWriter;
+import com.alibaba.excel.write.metadata.WriteSheet;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.huiju.estateagents.common.JWTUtils;
 import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.excel.HelpInitiateRecordSucceed;
+import com.huiju.estateagents.excel.TaActivityDynamicEnlistExport;
+import com.huiju.estateagents.excel.handler.CustomCellWriteHandler;
 import com.huiju.estateagents.mapper.TaActivityDynamicEnlistMapper;
 import com.huiju.estateagents.mapper.TaBuildingMapper;
 import com.huiju.estateagents.mapper.TaSharePersonFromMapper;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
 import javax.servlet.http.HttpSession;
 import javax.swing.*;
+import java.io.IOException;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
 import java.time.LocalDateTime;
         if (null == taPersons || taPersons.size() != 1) {
             return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
         }
-
         TaBuildingDynamic buildingDynamic = iBuildingDynamicService.getById(taActivityDynamicEnlist.getDynamicId());
         // TODO 看代码里面是 is_enlist = 1 才是允许报名
         if (buildingDynamic.getIsEnlist().intValue() != 1) {
     @ApiImplicitParams({
             @ApiImplicitParam(dataTypeClass = Integer.class, name = "pageNum", paramType = "query",value = "第几页"),
             @ApiImplicitParam(dataTypeClass = Integer.class, name = "pageSize", paramType = "query",value = "一页多少行"),
-            @ApiImplicitParam(dataType = "String", name = "dynamicId", paramType = "query",value = "活动ID")
+            @ApiImplicitParam(dataType = "String", name = "dynamicId", paramType = "query",value = "活动ID"),
+            @ApiImplicitParam(dataType = "String", name = "isCheckin", paramType = "query",value = "0未签到1签到"),
+            @ApiImplicitParam(dataType = "String", name = "name", paramType = "query",value = "用户姓名"),
+            @ApiImplicitParam(dataType = "String", name = "phone", paramType = "query",value = "手机号")
     })
     @RequestMapping(value = "/admin/SignList", method = RequestMethod.GET)
     public ResponseBean getSignList(@RequestParam(value = "pageNum",defaultValue = "1")Integer pageNum,
                                     @RequestParam(value = "pageSize",defaultValue = "10")Integer pageSize,
                                     @RequestParam(value = "dynamicId",required = false)String dynamicId,
+                                    @RequestParam(value = "isCheckin",required = false)String isCheckin,
+                                    @RequestParam(value = "name",required = false)String name,
+                                    @RequestParam(value = "phone",required = false)String phone,
                                     HttpServletRequest request) {
         Page<TaActivityDynamicEnlist> page = new Page<>();
         page.setSize(pageSize);
         page.setCurrent(pageNum);
-        ResponseBean signList = iBuildingDynamicService.signList(page,dynamicId, getOrgId(request));
+        ResponseBean signList = iBuildingDynamicService.signList(page,dynamicId, getOrgId(request),isCheckin,name,phone);
 
         HashMap<String, Object> map = new HashMap<>();
         map.put("list", signList);
         return responseBean;
     }
 
+    /**
+     * 报名记录导出
+     *
+     * @param request
+     * @param response
+     * @throws IOException
+     */
+    @GetMapping("/admin/activityDynamicEnlist/export")
+    public void activityDynamicEnlistExport(HttpServletRequest request,
+                                      HttpServletResponse response,
+                                      @RequestParam(value = "dynamicId",required = false)String dynamicId,
+                                      @RequestParam(value = "isCheckin",required = false)String isCheckin,
+                                      @RequestParam(value = "name",required = false)String name,
+                                      @RequestParam(value = "phone",required = false)String phone) throws IOException {
+        //        response.setContentType("application/vnd.ms-excel");
+        response.setContentType("application/octet-stream");
+        response.setCharacterEncoding("utf-8");
+        response.setHeader("Content-disposition", "attachment;filename=助力活动发起人.xlsx");
+
+        Integer orgId = getOrgId(request);
+
+        Integer pageCode = 0;
+        Integer pageSize = 100;
+        // 总页数
+        Integer pageCount = 0;
+
+            ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), TaActivityDynamicEnlistExport.class).registerWriteHandler(new CustomCellWriteHandler()).build();
+            // 设置 sheet, 同一个sheet只需要设置一次
+            WriteSheet writeSheet = EasyExcel.writerSheet("报名记录").build();
+            Integer count = iBuildingDynamicService.getTaActivityDynamicEnlist(dynamicId,isCheckin,name,phone);
+            pageCount = count % pageSize == 0 ? count / pageSize : (count / pageSize) + 1;
+            List<HelpInitiateRecordSucceed> publicList = null;
+            do {
+                publicList = iBuildingDynamicService.getTaActivityDynamicEnlistExport(pageCode * pageSize, pageSize,dynamicId,isCheckin,name,phone,getOrgId(request));
+                excelWriter.write(publicList, writeSheet);
+
+                pageCode++;
+            } while (pageCode <= pageCount);
+
+            // finish 会帮忙关闭流
+            excelWriter.finish();
+        }
+
 
 
 }

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

             taShareActivity.setStatus(1);
             //0：进行中 1：未开始 2：已结束
             taShareActivity.setActivityStatus(2);
-            taShareActivity.setGroupActicityId(id);
+            taShareActivity.setGroupActivityId(id);
             if (iTaShareActivityService.updateById(taShareActivity)){
                 responseBean.addSuccess(taShareActivity);
             }else {
         }
 
         QueryWrapper<TaNews> newsQueryWrapper = new QueryWrapper<>();
-        newsQueryWrapper.eq("group_acticity_id", taShareActivity.getGroupActicityId());
+        newsQueryWrapper.eq("group_acticity_id", taShareActivity.getGroupActivityId());
         if (iTaShareActivityService.updateById(taShareActivity)){
             responseBean.addSuccess("成功");
         }else {
             //查看此活动已经完成的数量
             QueryWrapper<TaShareRecord> shareRecordQueryWrapper = new QueryWrapper<>();
             shareRecordQueryWrapper.eq("org_id",orgId);
-            shareRecordQueryWrapper.eq("group_activity_id",taShareActivity.getGroupActicityId());
+            shareRecordQueryWrapper.eq("group_activity_id",taShareActivity.getGroupActivityId());
             shareRecordQueryWrapper.eq("status",CommConstant.STATUS_UNACCALIMED);
             List<TaShareRecord> taShareRecordsList = taShareRecordService.list(shareRecordQueryWrapper);
             taShareActivity.setSuccessNum(taShareRecordsList.size());
              }else {
                  QueryWrapper<TaShareRecord> recordQueryWrapper = new QueryWrapper<>();
                  recordQueryWrapper.eq("org_id",orgId);
-                 recordQueryWrapper.eq("group_activity_id",taShareActivity.getGroupActicityId());
+                 recordQueryWrapper.eq("group_activity_id",taShareActivity.getGroupActivityId());
                  recordQueryWrapper.eq("person_id",person.getPersonId());
                  taShareRecord = taShareRecordService.getOne(recordQueryWrapper);
              }
                 //团员
                 QueryWrapper<TaShareChildRecord> childRecordQueryWrapper = new QueryWrapper<>();
                 childRecordQueryWrapper.eq("org_id",orgId);
-                childRecordQueryWrapper.eq("group_activity_id",taShareActivity.getGroupActicityId());
+                childRecordQueryWrapper.eq("group_activity_id",taShareActivity.getGroupActivityId());
                 childRecordQueryWrapper.eq("record_id",taShareRecord.getRecordId());
                 List<TaShareChildRecord> shareChildRecordList = taShareChildRecordService.list(childRecordQueryWrapper);
                 map.put("shareChildRecordList",shareChildRecordList);

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

 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 /**
  * <p>
     *   前端控制器
  * @since 2019-10-23
  */
 @RestController
-@RequestMapping("/")
+@RequestMapping("/api")
 public class TdPosterTemplateController extends BaseController {
 
     private final Logger logger = LoggerFactory.getLogger(TdPosterTemplateController.class);
         }
         return responseBean;
     }
+    
+    /**
+     * 根据type获取数据
+     * @param type
+     * @return
+     */
+    @RequestMapping(value="/admin/posterTemplate",method= RequestMethod.GET)
+    public ResponseBean posterTemplateList(@RequestParam(value ="type") String type){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            QueryWrapper<TdPosterTemplate> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("type",type);
+            queryWrapper.orderByDesc("create_date");
+            
+            List<TdPosterTemplate> result = iTdPosterTemplateService.list(queryWrapper);
+            responseBean.addSuccess(result);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("posterTemplateList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

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

     /**
      * 活动id
      */
-    @TableId(value = "group_acticity_id", type = IdType.AUTO)
-    private Integer groupActicityId;
+    @TableId(value = "group_activity_id", type = IdType.AUTO)
+    private Integer groupActivityId;
 
     /**
      * 项目id

src/main/java/com/huiju/estateagents/excel/TaActivityDynamicEnlistExport.java

+package com.huiju.estateagents.excel;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.annotation.write.style.ColumnWidth;
+import lombok.Data;
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class TaActivityDynamicEnlistExport implements Serializable {
+
+    /**
+     * 姓名
+     */
+    @ColumnWidth(15)
+    @ExcelProperty(value = "用户姓名", index = 0)
+    private String name;
+
+    /**
+     * 手机号
+     */
+    @ColumnWidth(15)
+    @ExcelProperty(value = "手机号", index = 1)
+    private String phone;
+
+    /**
+     * 参与人数
+     */
+    @ColumnWidth(15)
+    @ExcelProperty(value = "参与人数", index = 2)
+    private Integer attendNum;
+
+    /**
+     * 报名时间
+     */
+    @ColumnWidth(20)
+    @ExcelProperty(value = "报名时间", index = 3)
+    private Date createDate;
+
+    /**
+     * 推广人
+     */
+    @ColumnWidth(15)
+    @ExcelProperty(value = "推广人", index = 4)
+    private String sharePersonName;
+
+    /**
+     * 公司
+     */
+    @ColumnWidth(15)
+    @ExcelProperty(value = "公司", index = 5)
+    private String orgName;
+
+    /**
+     * 公司
+     */
+    @ColumnWidth(15)
+    @ExcelProperty(value = "签到状态", index = 6)
+    private String isCheckin;
+
+
+
+}

src/main/java/com/huiju/estateagents/job/JudglActivityTimeJob.java

             LocalDateTime startTime = taShareActivity.getStartTime();
             LocalDateTime endTime = taShareActivity.getEndTime();
             if (nowTime.isAfter(startTime) && endTime.isAfter(nowTime)){
-                startGroupActivityIds.add(taShareActivity.getGroupActicityId());
+                startGroupActivityIds.add(taShareActivity.getGroupActivityId());
             }
             if (nowTime.isAfter(endTime)){
-                endGroupActivityIds.add(taShareActivity.getGroupActicityId());
+                endGroupActivityIds.add(taShareActivity.getGroupActivityId());
             }
         }
         iTaShareActivityService.updateUnStartActivity(startGroupActivityIds);

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

 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.entity.TaActivityDynamicEnlist;
+import com.huiju.estateagents.excel.HelpInitiateRecordSucceed;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
      * @param dynamicId
      * @return
      */
-    List<TaActivityDynamicEnlist> signList(Page<TaActivityDynamicEnlist> page, @Param("dynamicId") String dynamicId, @Param("orgId") Integer orgId);
+    List<TaActivityDynamicEnlist> signList(Page<TaActivityDynamicEnlist> page, @Param("dynamicId") String dynamicId, @Param("orgId") Integer orgId,@Param("isCheckin") String isCheckin,@Param("name") String name,@Param("phone") String phone);
 
     /**
      * 查询活动已经报名的总人数
      * @return
      */
     Integer selectEnlistCount(@Param("dynamicId") String dynamicId, @Param("orgId") Integer orgId);
+
+    /**
+     * 导出报名记录
+     * @param i
+     * @param pageSize
+     * @param dynamicId
+     * @param isCheckin
+     * @param name
+     * @param phone
+     * @return
+     */
+    List<HelpInitiateRecordSucceed> getTaActivityDynamicEnlistExport(@Param("pageCode") int i, @Param("pageSize") Integer pageSize, @Param("dynamicId") String dynamicId, @Param("isCheckin") String isCheckin, @Param("name") String name, @Param("phone") String phone,@Param("orgId") Integer orgId);
 }

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

 import com.huiju.estateagents.entity.TaActivityDynamicEnlist;
 import com.huiju.estateagents.entity.TaBuildingDynamic;
 import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.excel.HelpInitiateRecordSucceed;
 
 import java.time.LocalDateTime;
 import java.util.HashMap;
      * @param page
      * @return
      */
-    ResponseBean signList(Page<TaActivityDynamicEnlist> page,String dynamicId, Integer orgId);
+    ResponseBean signList(Page<TaActivityDynamicEnlist> page,String dynamicId, Integer orgId,String isCheckin,String name,String phone);
 
     IPage<TaBuildingDynamic> getJoinedActivity(int pageNumber, int pageSize, String building, TaPerson person);
 
      * @param endActivityId
      */
     void updateEndActivity(List<String> endActivityId);
+
+    /**
+     * 报名记录导出当前总数
+     * @param dynamicId
+     * @param isCheckin
+     * @param name
+     * @param phone
+     * @return
+     */
+    Integer getTaActivityDynamicEnlist(String dynamicId, String isCheckin, String name, String phone);
+
+    /**
+     * 报名记录导出
+     * @param i
+     * @param pageSize
+     * @param dynamicId
+     * @param isCheckin
+     * @param name
+     * @param phone
+     * @return
+     */
+    List<HelpInitiateRecordSucceed> getTaActivityDynamicEnlistExport(int i, Integer pageSize, String dynamicId, String isCheckin, String name, String phone,Integer orgId);
 }

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

 import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.excel.HelpInitiateRecordSucceed;
 import com.huiju.estateagents.mapper.TaActivityDynamicEnlistMapper;
 import com.huiju.estateagents.mapper.TaBuildingDynamicMapper;
 import com.huiju.estateagents.mapper.TaBuildingMapper;
     }
 
     @Override
-    public ResponseBean signList(Page<TaActivityDynamicEnlist> page, String dynamicId, Integer orgId) {
-        List<TaActivityDynamicEnlist> signList= taActivityDynamicEnlistMapper.signList(page,dynamicId, orgId);
+    public ResponseBean signList(Page<TaActivityDynamicEnlist> page, String dynamicId, Integer orgId,String isCheckin,String name,String phone) {
+        List<TaActivityDynamicEnlist> signList= taActivityDynamicEnlistMapper.signList(page,dynamicId, orgId,isCheckin,name,phone);
         return ResponseBean.success(signList);
     }
 
         }
     }
 
+    @Override
+    public Integer getTaActivityDynamicEnlist(String dynamicId, String isCheckin, String name, String phone) {
+        QueryWrapper<TaActivityDynamicEnlist> querTaActivityDynamicEnlist = new QueryWrapper<>();
+        querTaActivityDynamicEnlist.eq("dynamic_id",dynamicId);
+        querTaActivityDynamicEnlist.eq(!StringUtils.isEmpty(isCheckin),"is_checkin",isCheckin);
+        querTaActivityDynamicEnlist.eq(!StringUtils.isEmpty(name),"name",name);
+        querTaActivityDynamicEnlist.eq(!StringUtils.isEmpty(phone),"name",phone);
+        return taActivityDynamicEnlistMapper.selectCount(querTaActivityDynamicEnlist);
+    }
+
+    @Override
+    public List<HelpInitiateRecordSucceed> getTaActivityDynamicEnlistExport(int i, Integer pageSize, String dynamicId, String isCheckin, String name, String phone,Integer orgId) {
+        return taActivityDynamicEnlistMapper.getTaActivityDynamicEnlistExport(i,pageSize,dynamicId,isCheckin,name,phone,orgId);
+    }
+
     @Override
     public IPage<TaBuildingDynamic> getJoinedActivity(int pageNumber, int pageSize,String building,TaPerson person){
         QueryWrapper<TaActivityDynamicEnlist> activityDynamicEnlistQueryWrapper = new QueryWrapper<>();

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

 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
             taShareRecord.setVerificationStatus(CommConstant.STATUS_UNACCALIMED);
         }
         tashareRecordmapper.updateById(taShareRecord);
-        return ResponseBean.success(taShareRecord);
+        Map<String,Object> map = new HashMap<>();
+        map.put("taShareChildRecord",taShareChildRecord);
+        map.put("taShareRecord",taShareRecord);
+        return ResponseBean.success(map);
     }
     
     /**

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

         if (record != null){
             return ResponseBean.error("您已经发起拼团，请勿再次发起，加入好友的拼团吧",ResponseBean.ERROR_UNAVAILABLE);
         }
+        if (null == taShareActivity.getIntegral()){
+            taShareActivity.setIntegral(0);
+        }
         if (person.getPoints() == null || person.getPoints() < taShareActivity.getIntegral()){
             return ResponseBean.error("积分不足",ResponseBean.ERROR_UNAVAILABLE);
         }

src/main/resources/mapper/TaActivityDynamicEnlistMapper.xml

                     ta_activity_dynamic_enlist tade
                     LEFT JOIN ta_share_person_from tspf ON tade.dynamic_id = tspf.target_id AND tspf.target_type = 'dynamic_share' and tspf.status = 1 and tade.person_id = tspf.person_id
                     LEFT JOIN ta_person tp ON tspf.share_person = tp.user_id
-                WHERE
+                <where>
                     tade.dynamic_id = #{dynamicId}
-                AND tade.org_id = #{orgId}
+                    AND tade.org_id = #{orgId}
+
+                    <if test="name != null and name !=''">
+                        and tade.name like CONCAT('%',#{name}, '%')
+                    </if>
+                    <if test="isCheckin != null and isCheckin !=''">
+                        and tade.is_checkin like CONCAT('%',#{isCheckin}, '%')
+                    </if>
+                    <if test="phone != null and phone !=''">
+                        and tade.phone like CONCAT('%',#{phone}, '%')
+                    </if>
+                </where>
+
 
         </select>
 
         <select id="selectEnlistCount" resultType="Integer" >
             select ifnull(sum( attend_num ), 0) from ta_activity_dynamic_enlist where dynamic_id = #{dynamicId} and org_id = #{orgId}
         </select>
+
+    <select id="getTaActivityDynamicEnlistExport" resultType="com.huiju.estateagents.excel.TaActivityDynamicEnlistExport">
+
+        SELECT
+        tade.*,
+        tp.NAME AS sharePersonName,
+        tp.company AS orgName
+        FROM
+        ta_activity_dynamic_enlist tade
+        LEFT JOIN ta_share_person_from tspf ON tade.dynamic_id = tspf.target_id AND tspf.target_type = 'dynamic_share' and tspf.status = 1 and tade.person_id = tspf.person_id
+        LEFT JOIN ta_person tp ON tspf.share_person = tp.user_id
+        <where>
+            tade.dynamic_id = #{dynamicId}
+            AND tade.org_id = #{orgId}
+
+            <if test="name != null and name !=''">
+                and tade.name like CONCAT('%',#{name}, '%')
+            </if>
+            <if test="isCheckin != null and isCheckin !=''">
+                and tade.is_checkin like CONCAT('%',#{isCheckin}, '%')
+            </if>
+            <if test="phone != null and phone !=''">
+                and tade.phone like CONCAT('%',#{phone}, '%')
+            </if>
+        </where>
+        limit #{pageCode}, #{pageSize}
+    </select>
 </mapper>

src/main/resources/mapper/TaShareActivityMapper.xml

         t.activity_name,
         t.main_img,
         t.group_buy_people,
-        t.join_people,
         t.integral,
         t.share_id,
         t.poster_id,
         from ta_share_activity t where t.group_acticity_id = #{activityId}
     </select>
 
-    <update id="updateJoinPeople">
-        update ta_share_activity set join_people =  join_people + 1
-        where group_acticity_id = #{activityId}
-    </update>
-
     <update id="updateUnStartGroupActivity">
         update ta_share_activity t set t.activity_status = 0
         where t.group_acticity_id in