|
|
@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.epmet.commons.tools.constant.AppClientConstant; |
|
|
|
import com.epmet.commons.tools.constant.MqConstant; |
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
import com.epmet.commons.tools.constant.StrConstant; |
|
|
|
import com.epmet.commons.tools.dto.form.mq.MqBaseMsgDTO; |
|
|
|
import com.epmet.commons.tools.dto.form.mq.eventmsg.BasePointEventMsg; |
|
|
@ -532,11 +533,12 @@ public class WorkActServiceImpl implements WorkActService { |
|
|
|
Date nowDate = new Date(); |
|
|
|
for (InProgressActResultDTO inProgressActResultDTO : list) { |
|
|
|
// 活动状态:报名中:signing_up;截止报名: end_sign_up; 已开始: in_progress; 已报满: enough
|
|
|
|
if (nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == -1 |
|
|
|
|| nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == 0) { |
|
|
|
/*if (nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == -1 |
|
|
|
|| nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == 0) {*/ |
|
|
|
if (!NumConstant.ONE_STR.equals(DateUtils.comparteDate(nowDate, inProgressActResultDTO.getSignUpEndTime()))) { |
|
|
|
logger.info(String.format("当前时间%s报名截止时间%s处于报名中", |
|
|
|
DateUtils.format(nowDate,DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getSignUpEndTime(),DateUtils.DATE_TIME_PATTERN))); |
|
|
|
DateUtils.format(nowDate, DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getSignUpEndTime(), DateUtils.DATE_TIME_PATTERN))); |
|
|
|
//截止报名时间之前(包含报名时间截止时间点)
|
|
|
|
if (!inProgressActResultDTO.getActQuotaCategory()) { |
|
|
|
//如果是不限制名额,则显示报名中
|
|
|
@ -555,20 +557,25 @@ public class WorkActServiceImpl implements WorkActService { |
|
|
|
continue; |
|
|
|
} |
|
|
|
} |
|
|
|
} else if (nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == 1 |
|
|
|
&&nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == -1) { |
|
|
|
} |
|
|
|
/*else if (nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == 1 |
|
|
|
&&nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == -1) {*/ |
|
|
|
else if (NumConstant.ONE_STR.equals(DateUtils.comparteDate(nowDate, inProgressActResultDTO.getSignUpEndTime())) |
|
|
|
&& NumConstant.ONE_NEG_STR.equals(DateUtils.comparteDate(nowDate, inProgressActResultDTO.getActStartTime()))) { |
|
|
|
logger.info(String.format("当前时间%s报名截止时间%s活动预计开始时间%s界面显示截止报名", |
|
|
|
DateUtils.format(nowDate,DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getSignUpEndTime(),DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getActStartTime(),DateUtils.DATE_TIME_PATTERN))); |
|
|
|
DateUtils.format(nowDate, DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getSignUpEndTime(), DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getActStartTime(), DateUtils.DATE_TIME_PATTERN))); |
|
|
|
//活动报名截止-活动预计开始之间显示截止报名
|
|
|
|
inProgressActResultDTO.setStatus("end_sign_up"); |
|
|
|
continue; |
|
|
|
} else if (nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == 1 |
|
|
|
|| nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == 0) { |
|
|
|
} |
|
|
|
/*else if (nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == 1 |
|
|
|
|| nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == 0) {*/ |
|
|
|
else if (!NumConstant.ONE_NEG_STR.equals(DateUtils.comparteDate(nowDate, inProgressActResultDTO.getActStartTime()))) { |
|
|
|
logger.info(String.format("当前时间%s活动预计开始时间%s界面显示已开始", |
|
|
|
DateUtils.format(nowDate,DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getActStartTime(),DateUtils.DATE_TIME_PATTERN))); |
|
|
|
DateUtils.format(nowDate, DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(inProgressActResultDTO.getActStartTime(), DateUtils.DATE_TIME_PATTERN))); |
|
|
|
//活动预计开始时间点之后,包含活动预计开始时间点,显示 已开始
|
|
|
|
inProgressActResultDTO.setStatus("in_progress"); |
|
|
|
continue; |
|
|
@ -732,8 +739,54 @@ public class WorkActServiceImpl implements WorkActService { |
|
|
|
public InProgressActDetailResultDTO inProgressDetail(String actId) { |
|
|
|
InProgressActDetailResultDTO resultDTO = actInfoDao.selectInProgressDetail(actId); |
|
|
|
if (null != resultDTO) { |
|
|
|
Date nowDate=new Date(); |
|
|
|
// 活动状态:报名中:signing_up;截止报名: end_sign_up; 已开始: in_progress; 已报满: enough
|
|
|
|
/*if (nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == -1 |
|
|
|
|| nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == 0) {*/ |
|
|
|
if (!NumConstant.ONE_STR.equals(DateUtils.comparteDate(nowDate, resultDTO.getSignUpEndTime()))) { |
|
|
|
logger.info(String.format("当前时间%s报名截止时间%s处于报名中", |
|
|
|
DateUtils.format(nowDate, DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(resultDTO.getSignUpEndTime(), DateUtils.DATE_TIME_PATTERN))); |
|
|
|
//截止报名时间之前(包含报名时间截止时间点)
|
|
|
|
if (!resultDTO.getActQuotaCategory()) { |
|
|
|
//如果是不限制名额,则显示报名中
|
|
|
|
resultDTO.setStatus("signing_up"); |
|
|
|
logger.info("活动不限制名额,界面显示 报名中"); |
|
|
|
} else { |
|
|
|
//固定名额,且已报名人数<活动需要人数显示报名中
|
|
|
|
if (resultDTO.getActQuota() > resultDTO.getSignedUp()) { |
|
|
|
logger.info("活动限制名额,未报满,界面显示报名中"); |
|
|
|
resultDTO.setStatus("signing_up"); |
|
|
|
} else if (resultDTO.getActQuota().equals(resultDTO.getSignedUp())) { |
|
|
|
resultDTO.setStatus("enough"); |
|
|
|
logger.info("活动限制名额,且已报满,界面显示已报满"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
/*else if (nowDate.compareTo(inProgressActResultDTO.getSignUpEndTime()) == 1 |
|
|
|
&&nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == -1) {*/ |
|
|
|
else if (NumConstant.ONE_STR.equals(DateUtils.comparteDate(nowDate, resultDTO.getSignUpEndTime())) |
|
|
|
&& NumConstant.ONE_NEG_STR.equals(DateUtils.comparteDate(nowDate, resultDTO.getActStartTime()))) { |
|
|
|
logger.info(String.format("当前时间%s报名截止时间%s活动预计开始时间%s界面显示截止报名", |
|
|
|
DateUtils.format(nowDate, DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(resultDTO.getSignUpEndTime(), DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(resultDTO.getActStartTime(), DateUtils.DATE_TIME_PATTERN))); |
|
|
|
//活动报名截止-活动预计开始之间显示截止报名
|
|
|
|
resultDTO.setStatus("end_sign_up"); |
|
|
|
} |
|
|
|
/*else if (nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == 1 |
|
|
|
|| nowDate.compareTo(inProgressActResultDTO.getActStartTime()) == 0) {*/ |
|
|
|
else if (!NumConstant.ONE_NEG_STR.equals(DateUtils.comparteDate(nowDate, resultDTO.getActStartTime()))) { |
|
|
|
logger.info(String.format("当前时间%s活动预计开始时间%s界面显示已开始", |
|
|
|
DateUtils.format(nowDate, DateUtils.DATE_TIME_PATTERN), |
|
|
|
DateUtils.format(resultDTO.getActStartTime(), DateUtils.DATE_TIME_PATTERN))); |
|
|
|
//活动预计开始时间点之后,包含活动预计开始时间点,显示 已开始
|
|
|
|
resultDTO.setStatus("in_progress"); |
|
|
|
} |
|
|
|
//查询活动详情
|
|
|
|
List<ActPreviewContentResultDTO> list = actContentDao.selectByActId(actId); |
|
|
|
resultDTO.setActContent(list); |
|
|
|
//当前活动是否是我发布的
|
|
|
|
if(resultDTO.getCreatedBy().equals(loginUserUtil.getLoginUserId())){ |
|
|
|
resultDTO.setIsMyPublish(true); |
|
|
|
}else{ |
|
|
@ -820,6 +873,39 @@ public class WorkActServiceImpl implements WorkActService { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void testGrantPoint(TestGrantFormDTO formDTO) { |
|
|
|
//查询当前用户所属组织信息
|
|
|
|
Result<CustomerAgencyDTO> userResult = govOrgOpenFeignClient.getAgencyByStaff(loginUserUtil.getLoginUserId()); |
|
|
|
String opAgencyId = userResult.getData().getId(); |
|
|
|
MqBaseMsgDTO mqBaseMsgDTO = new MqBaseMsgDTO(); |
|
|
|
//mq的事件类型
|
|
|
|
mqBaseMsgDTO.setEventClass(EventEnum.ACTIVE_SEND_POINT.getEventClass()); |
|
|
|
//事件code
|
|
|
|
mqBaseMsgDTO.setEventTag(EventEnum.ACTIVE_SEND_POINT.getEventTag()); |
|
|
|
List<BasePointEventMsg> basePointEventMsgArrayList = new ArrayList<>(); |
|
|
|
BasePointEventMsg basePointEventMsg = new BasePointEventMsg(); |
|
|
|
basePointEventMsg.setOpAgencyId(opAgencyId); |
|
|
|
basePointEventMsg.setCustomerId(formDTO.getCustomerId()); |
|
|
|
basePointEventMsg.setUserId(formDTO.getUserId()); |
|
|
|
basePointEventMsg.setActionFlag(formDTO.getActionFlag()); |
|
|
|
basePointEventMsg.setPoint(formDTO.getReward()); |
|
|
|
basePointEventMsg.setIsCommon(true); |
|
|
|
basePointEventMsg.setRemark(formDTO.getRemark()); |
|
|
|
basePointEventMsg.setSourceId(formDTO.getSourceId()); |
|
|
|
basePointEventMsg.setOperatorId(loginUserUtil.getLoginUserId()); |
|
|
|
basePointEventMsgArrayList.add(basePointEventMsg); |
|
|
|
mqBaseMsgDTO.setMsg(JSON.toJSONString(basePointEventMsgArrayList)); |
|
|
|
logger.info("发送消息入参:"+JSON.toJSON(mqBaseMsgDTO)); |
|
|
|
Result result = SendMqMsgUtils.sendMsg(mqBaseMsgDTO); |
|
|
|
logger.info("发送消息返参:"+JSON.toJSON(result)); |
|
|
|
if (!result.success()) { |
|
|
|
logger.error("积分发放失败"); |
|
|
|
return; |
|
|
|
} |
|
|
|
logger.info("积分发方成功"); |
|
|
|
} |
|
|
|
|
|
|
|
private void updateHeartUserInfo(ActInfoDTO actInfoDTO) { |
|
|
|
List<ActUserRelationDTO> actUserRelationDTOList=actUserRelationService.getUserList(actInfoDTO.getId(),StrConstant.EPMETY_STR); |
|
|
|
for(ActUserRelationDTO actUserRelation:actUserRelationDTOList){ |
|
|
@ -921,7 +1007,7 @@ public class WorkActServiceImpl implements WorkActService { |
|
|
|
//审核
|
|
|
|
List<String> textList=new ArrayList<>(); |
|
|
|
List<String> imgList=new ArrayList<>(); |
|
|
|
for(PublishActContentFormDTO actContent:formDTO.getActContent()){ |
|
|
|
for(PublishActContentFormDTO actContent:formDTO.getActSummary()){ |
|
|
|
if(ActConstant.ACT_CONTENT_TYPE_TEXT.equals(actContent.getContentType())){ |
|
|
|
textList.add(actContent.getContent()); |
|
|
|
}else if(ActConstant.ACT_CONTENT_TYPE_IMG.equals(actContent.getContentType())){ |
|
|
@ -931,7 +1017,7 @@ public class WorkActServiceImpl implements WorkActService { |
|
|
|
this.auditActContent(textList,imgList); |
|
|
|
//插入act_summary记录
|
|
|
|
int orderNum=1; |
|
|
|
for(PublishActContentFormDTO actContentFormDTO:formDTO.getActContent()){ |
|
|
|
for(PublishActContentFormDTO actContentFormDTO:formDTO.getActSummary()){ |
|
|
|
ActSummaryEntity actSummaryEntity=new ActSummaryEntity(); |
|
|
|
actSummaryEntity.setActId(formDTO.getActId()); |
|
|
|
actSummaryEntity.setContent(actContentFormDTO.getContent()); |
|
|
@ -1029,6 +1115,7 @@ public class WorkActServiceImpl implements WorkActService { |
|
|
|
return publishActResultDTO; |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private void noticePassedPeople(ActInfoDTO originalActInfo, ActInfoEntity newActInfoEntity) { |
|
|
|
/* List<ActUserRelationDTO> actUserRelationDTOList=actUserRelationDao.selectAuditingAndPassedList(originalActInfo.getId()); |
|
|
|
if(null==actUserRelationDTOList||actUserRelationDTOList.size()<1){ |
|
|
|