|
|
@@ -9,12 +9,10 @@ import com.iformall.common.ResultData; |
|
|
import com.iformall.domain.po.WxActivity; |
|
|
import com.iformall.domain.po.WxActivity; |
|
|
import com.iformall.domain.po.WxActivityJoin; |
|
|
import com.iformall.domain.po.WxActivityJoin; |
|
|
import com.iformall.domain.po.WxCUser; |
|
|
import com.iformall.domain.po.WxCUser; |
|
|
|
|
|
import com.iformall.domain.po.WxCreditHistory; |
|
|
import com.iformall.domain.po.msg.WxMsgRecord; |
|
|
import com.iformall.domain.po.msg.WxMsgRecord; |
|
|
import com.iformall.enums.*; |
|
|
import com.iformall.enums.*; |
|
|
import com.iformall.mapper.WxActivityJoinMapper; |
|
|
|
|
|
import com.iformall.mapper.WxActivityMapper; |
|
|
|
|
|
import com.iformall.mapper.WxCUserBasicInfoMapper; |
|
|
|
|
|
import com.iformall.mapper.WxCUserMapper; |
|
|
|
|
|
|
|
|
import com.iformall.mapper.*; |
|
|
import com.iformall.mq.MqBaseProducer; |
|
|
import com.iformall.mq.MqBaseProducer; |
|
|
import com.iformall.service.ExcelService; |
|
|
import com.iformall.service.ExcelService; |
|
|
import com.iformall.service.WxActivityJoinService; |
|
|
import com.iformall.service.WxActivityJoinService; |
|
|
@@ -59,6 +57,9 @@ public class WxActivityJoinServiceImpl implements WxActivityJoinService { |
|
|
@Autowired |
|
|
@Autowired |
|
|
WxCUserBasicInfoMapper wxCUserBasicInfoMapper; |
|
|
WxCUserBasicInfoMapper wxCUserBasicInfoMapper; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
WxCreditHistoryMapper wxCreditHistoryMapper; |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public PageInfo<WxActivityJoin> listAsPage(WxActivityJoin record, Integer pageIndex, Integer pageSize) { |
|
|
public PageInfo<WxActivityJoin> listAsPage(WxActivityJoin record, Integer pageIndex, Integer pageSize) { |
|
|
return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxActivityJoinMapper.findList(record)); |
|
|
return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxActivityJoinMapper.findList(record)); |
|
|
@@ -151,6 +152,7 @@ public class WxActivityJoinServiceImpl implements WxActivityJoinService { |
|
|
WxCUser user = wxCUserMapper.selectByPrimaryKey(wxActivityJoin.getUserId()); |
|
|
WxCUser user = wxCUserMapper.selectByPrimaryKey(wxActivityJoin.getUserId()); |
|
|
//查询是否消耗积分 |
|
|
//查询是否消耗积分 |
|
|
WxActivity wxActivity = wxActivityMapper.selectByPrimaryKey(wxActivityJoin.getActivityId()); |
|
|
WxActivity wxActivity = wxActivityMapper.selectByPrimaryKey(wxActivityJoin.getActivityId()); |
|
|
|
|
|
Date date = new Date(); |
|
|
if (wxActivity.getUseCredit().equals(EnumActivityUseCreditStatus.YES.getCode())) { |
|
|
if (wxActivity.getUseCredit().equals(EnumActivityUseCreditStatus.YES.getCode())) { |
|
|
Integer userCredit = user.getCredit(); |
|
|
Integer userCredit = user.getCredit(); |
|
|
Integer credit = wxActivity.getCredit(); |
|
|
Integer credit = wxActivity.getCredit(); |
|
|
@@ -165,12 +167,22 @@ public class WxActivityJoinServiceImpl implements WxActivityJoinService { |
|
|
wxCUserMapper.updateByPrimaryKeySelective(user); |
|
|
wxCUserMapper.updateByPrimaryKeySelective(user); |
|
|
data.put("useCredit", credit); |
|
|
data.put("useCredit", credit); |
|
|
data.put("totalCredit", userCredit); |
|
|
data.put("totalCredit", userCredit); |
|
|
|
|
|
//积分历史 |
|
|
|
|
|
WxCreditHistory wxCreditHistory = new WxCreditHistory(); |
|
|
|
|
|
wxCreditHistory.setTenantId(wxActivity.getTenantId()); |
|
|
|
|
|
wxCreditHistory.setCUserId(wxActivityJoin.getUserId()); |
|
|
|
|
|
wxCreditHistory.setCreditAmount(userCredit); |
|
|
|
|
|
wxCreditHistory.setCreditNum(-credit); |
|
|
|
|
|
wxCreditHistory.setCreditType(EnumScoreType.ACTIVITY_JOIN.getCode()); |
|
|
|
|
|
wxCreditHistory.setCreateDate(date); |
|
|
|
|
|
wxCreditHistory.setOperatorType(EnumUserType.CUSER.getCode()); |
|
|
|
|
|
wxCreditHistory.setOperatorId(wxActivityJoin.getUserId()); |
|
|
|
|
|
wxCreditHistoryMapper.updateByPrimaryKeySelective(wxCreditHistory); |
|
|
} |
|
|
} |
|
|
//保存到报名表中 |
|
|
//保存到报名表中 |
|
|
final IdWorker idWorker = IdWorker.get(); |
|
|
final IdWorker idWorker = IdWorker.get(); |
|
|
wxActivityJoin.setId(idWorker.nextId()); |
|
|
wxActivityJoin.setId(idWorker.nextId()); |
|
|
wxActivityJoin.setPhone(user.getPhone()); |
|
|
wxActivityJoin.setPhone(user.getPhone()); |
|
|
Date date = new Date(); |
|
|
|
|
|
wxActivityJoin.setCreateTime(date); |
|
|
wxActivityJoin.setCreateTime(date); |
|
|
wxActivityJoin.setUpdateTime(date); |
|
|
wxActivityJoin.setUpdateTime(date); |
|
|
wxActivityJoinMapper.insertSelective(wxActivityJoin); |
|
|
wxActivityJoinMapper.insertSelective(wxActivityJoin); |
|
|
|