助力和拼团

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

@@ -29,4 +29,9 @@ public class Activity {
 	private Integer activityStatus;
 	
 	private String type;
+	
+	/**
+	 * 完成数量
+	 */
+	private Integer successNum;
 }

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

@@ -75,18 +75,33 @@ public class ActivityServiceImpl implements ActivityServiceI {
 						e.setActivityStatus(CommConstant.ACTIVITY_STATUS_PARTNER);
 					}
 				});
+				e.setSuccessNum(null);
 			}else if (e.getType().equals("share")){
 				taShareRecords.forEach(share -> {
 					if (e.getId().equals(share.getGroupActivityId())){
 						e.setActivityStatus(CommConstant.ACTIVITY_STATUS_PARTNER);
 					}
 				});
+				//查看此活动已经完成的数量
+				QueryWrapper<TaShareRecord> shareRecordQueryWrapper = new QueryWrapper<>();
+				shareRecordQueryWrapper.eq("org_id",orgId);
+				shareRecordQueryWrapper.eq("group_activity_id",e.getId());
+				shareRecordQueryWrapper.eq("status",CommConstant.STATUS_UNACCALIMED);
+				List<TaShareRecord> taShareRecordsList = taShareRecordMapper.selectList(shareRecordQueryWrapper);
+				e.setSuccessNum(taShareRecordsList.size());
 			}else if (e.getType().equals("help")){
 				helpRecords.forEach(help -> {
 					if (e.getId().equals(help.getHelpActivityId())){
 						e.setActivityStatus(CommConstant.ACTIVITY_STATUS_PARTNER);
 					}
 				});
+				//查看此活动已经完成的数量
+				QueryWrapper<HelpRecord> tahelpRecordQueryWrapper = new QueryWrapper<>();
+				tahelpRecordQueryWrapper.eq("org_id",orgId);
+				tahelpRecordQueryWrapper.eq("help_activity_id",e.getId());
+				tahelpRecordQueryWrapper.eq("status",CommConstant.STATUS_UNACCALIMED);
+				List<HelpRecord> helpRecordList = helpRecordMapper.selectList(tahelpRecordQueryWrapper);
+				e.setSuccessNum(helpRecordList.size());
 			}
 		});
 		pg.setRecords(list);

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

@@ -24,6 +24,10 @@ public interface IMiniAppService {
     WxMaPhoneNumberInfo getPhoneNoInfo(String sessionKey, String encryptedData, String iv, String appid);
 
     void sendNoticeMessage(TaPerson toUser, String link, String name, String phone, String content, LocalDateTime dt);
+    
+    void sendHelpMessage(TaPerson toUser, String link, String result, String activityName, LocalDateTime dt);
+    
+    void sendGroupMessage(TaPerson toUser, String link, String result, String activityName, LocalDateTime dt);
 
     void sendMainBizMessage(TaPerson toUser, String link, String custName, String phone, String sex, String fromName, String bizType, String content);
 

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

@@ -11,7 +11,9 @@ 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.mapper.TaPersonMapper;
 import com.huiju.estateagents.service.IHelpRecordService;
+import com.huiju.estateagents.service.IMiniAppService;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.map.HashedMap;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -44,6 +46,12 @@ public class HelpRecordServiceImpl extends ServiceImpl<HelpRecordMapper, HelpRec
 	@Autowired
 	private HelpRecordMapper helpRecordMapper;
 	
+	@Autowired
+	private TaPersonMapper taPersonMapper;
+	
+	@Autowired
+	private IMiniAppService miniAppService;
+	
 	/**
 	 * 助力者助力
 	 *
@@ -100,7 +108,8 @@ public class HelpRecordServiceImpl extends ServiceImpl<HelpRecordMapper, HelpRec
 		helpRecord.setPersonId(person.getPersonId());
 		helpRecordMapper.insert(helpRecord);
 		if (helpActivity.getEnlistNum().equals(helpActivity.getPersonNum())){
-			//发送微信模板消息所有人都发送--todo
+			//发送微信模板消息所有人都发送
+			sendWxMessage(helpInitiateRecord,orgId,helpActivity);
 			
 			//生成核销码
 			helpInitiateRecord.setVerification(String.valueOf(helpInitiateRecord.getHelpRecordInitiateId()+System.currentTimeMillis()));
@@ -117,5 +126,28 @@ public class HelpRecordServiceImpl extends ServiceImpl<HelpRecordMapper, HelpRec
 		map.put("helpInitiateRecord",helpInitiateRecord);
 		return ResponseBean.success(map);
 	}
-
+	
+	/**
+	 * 发送微信消息
+	 * @param helpInitiateRecord
+	 * @param orgId
+	 * @param helpActivity
+	 */
+	private void sendWxMessage(HelpInitiateRecord helpInitiateRecord, Integer orgId, HelpActivity helpActivity) {
+		//发送给发起者
+		TaPerson taPerson = taPersonMapper.selectById(helpInitiateRecord.getPersonId());
+		String link = "/pages/activity/detail/assistance?id="+helpInitiateRecord.getHelpActivityId()+"&initiateId="+helpInitiateRecord.getHelpRecordInitiateId();
+		miniAppService.sendHelpMessage(taPerson,link,"助力成功",helpActivity.getTitle(),LocalDateTime.now());
+		//批量发送给助力者
+		QueryWrapper<HelpRecord> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("org_id",orgId);
+		queryWrapper.eq("help_activity_id",helpInitiateRecord.getHelpActivityId());
+		queryWrapper.eq("help_record_initiate_id",helpInitiateRecord.getHelpRecordInitiateId());
+		List<HelpRecord> helpRecords = helpRecordMapper.selectList(queryWrapper);
+		helpRecords.forEach(e -> {
+			TaPerson toTaPerson = taPersonMapper.selectById(e.getPersonId());
+			miniAppService.sendHelpMessage(toTaPerson,link,"助力成功",helpActivity.getTitle(),LocalDateTime.now());
+		});
+	}
+	
 }

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

@@ -84,6 +84,26 @@ public class MiniAppServiceImpl implements IMiniAppService {
 
         sendMessage("notice", toUser, link, data);
     }
+    
+    @Override
+    public void sendHelpMessage(TaPerson toUser, String link, String result, String activityName, LocalDateTime dt) {
+        List<WxMaTemplateData> data = new ArrayList<>();
+        data.add(new WxMaTemplateData("keyword1", result, "#fffff"));
+        data.add(new WxMaTemplateData("keyword2", activityName, "#fffff"));
+        data.add(new WxMaTemplateData("keyword3", DateUtils.cutSecond(dt), "#fffff"));
+        
+        sendMessage("help.result", toUser, link, data);
+    }
+    
+    @Override
+    public void sendGroupMessage(TaPerson toUser, String link, String result, String activityName, LocalDateTime dt) {
+        List<WxMaTemplateData> data = new ArrayList<>();
+        data.add(new WxMaTemplateData("keyword1", result, "#fffff"));
+        data.add(new WxMaTemplateData("keyword2", activityName, "#fffff"));
+        data.add(new WxMaTemplateData("keyword3", DateUtils.cutSecond(dt), "#fffff"));
+        
+        sendMessage("group.result", toUser, link, data);
+    }
 
     @Override
     public void sendMainBizMessage(TaPerson toUser, String link, String custName, String phone, String sex, String fromName, String bizType, String content) {

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

@@ -16,6 +16,7 @@ import com.huiju.estateagents.mapper.TaPersonMapper;
 import com.huiju.estateagents.mapper.TaShareActivityMapper;
 import com.huiju.estateagents.mapper.TaShareChildRecordMapper;
 import com.huiju.estateagents.mapper.TaShareRecordMapper;
+import com.huiju.estateagents.service.IMiniAppService;
 import com.huiju.estateagents.service.ITaShareChildRecordService;
 import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -43,6 +44,8 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
     private TaShareActivityMapper activityMapper;
     @Autowired
     private TaShareRecordMapper tashareRecordmapper;
+    @Autowired
+    private IMiniAppService miniAppService;
 
     @Override
     public IPage<TaShareChildRecord> getList(Integer pageNum, Integer pageSize, Integer groupActivityId, Integer status, Integer recordId, Integer orgId) {
@@ -156,7 +159,8 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
         taShareChildRecord.setPersonId(person.getPersonId());
         taShareChildRecordMapper.insert(taShareChildRecord);
         if (taShareActivity.getJoinPeople().equals(taShareActivity.getGroupBuyPeople())){
-            //发送微信模板消息所有人都发送--todo
+            //发送微信模板消息所有人都发送
+            sendWxMessage(taShareRecord,orgId,taShareActivity);
             
             //生成团员核销码和改状态拼团成功
             changeChildRecord(taShareChildRecord.getRecordId(),orgId,taShareChildRecord.getGroupActivityId());
@@ -168,6 +172,30 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
         return ResponseBean.success(taShareRecord);
     }
     
+    /**
+     * 发送微信消息
+     * @param taShareRecord
+     * @param orgId
+     * @param taShareActivity
+     */
+    private void sendWxMessage(TaShareRecord taShareRecord, Integer orgId, TaShareActivity taShareActivity) {
+        //发送给发起者
+        TaPerson taPerson = taPersonMapper.selectById(taShareRecord.getRecordId());
+        //--todo
+        String link = "/pages/activity/detail/assistance?id="+taShareRecord.getGroupActivityId()+"&initiateId="+taShareRecord.getRecordId();
+        miniAppService.sendHelpMessage(taPerson,link,"助力成功",taShareActivity.getActivityName(),LocalDateTime.now());
+        //批量发送给助力者
+        QueryWrapper<TaShareChildRecord> taShareChildRecordQueryWrapper = new QueryWrapper<>();
+        taShareChildRecordQueryWrapper.eq("org_id",orgId);
+        taShareChildRecordQueryWrapper.eq("group_activity_id",taShareRecord.getGroupActivityId());
+        taShareChildRecordQueryWrapper.eq("record_id",taShareRecord.getRecordId());
+        List<TaShareChildRecord> shareChildRecordList = taShareChildRecordMapper.selectList(taShareChildRecordQueryWrapper);
+        shareChildRecordList.forEach(e -> {
+            TaPerson toTaPerson = taPersonMapper.selectById(e.getPersonId());
+            miniAppService.sendHelpMessage(toTaPerson,link,"助力成功",taShareActivity.getActivityName(),LocalDateTime.now());
+        });
+    }
+    
     /**
      * 更改团员状态和生成核销码
      * @param recordId