diff --git a/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxScriptMessageMapper.java b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxScriptMessageMapper.java index 29f7077..534e968 100644 --- a/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxScriptMessageMapper.java +++ b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxScriptMessageMapper.java @@ -59,4 +59,6 @@ public interface WxScriptMessageMapper * @return 结果 */ public int deleteWxScriptMessageByIds(Long[] ids); + + public WxScriptMessage selectOneByMessageType(Integer messageType); } diff --git a/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserIntegralLogMapper.java b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserIntegralLogMapper.java index c3bd03b..0f20ded 100644 --- a/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserIntegralLogMapper.java +++ b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/mapper/WxUserIntegralLogMapper.java @@ -63,5 +63,5 @@ public interface WxUserIntegralLogMapper List obtainUserIntegral(@Param("userId") Long userId); - List deleteWxUserIntegralLogByUserId(@Param("userId") Long userId); + int deleteWxUserIntegralLogByUserId(@Param("userId") Long userId); } diff --git a/flossom-common/flossom-common-core/src/main/resources/mapper/WxScriptMessageMapper.xml b/flossom-common/flossom-common-core/src/main/resources/mapper/WxScriptMessageMapper.xml index a7d424e..469dde0 100644 --- a/flossom-common/flossom-common-core/src/main/resources/mapper/WxScriptMessageMapper.xml +++ b/flossom-common/flossom-common-core/src/main/resources/mapper/WxScriptMessageMapper.xml @@ -132,4 +132,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" #{id} + + diff --git a/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml b/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml index 427deb7..154ab9c 100644 --- a/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml +++ b/flossom-common/flossom-common-core/src/main/resources/mapper/WxUserMemberMapper.xml @@ -199,6 +199,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + + SELECT LAST_INSERT_ID() + insert into wx_user_member nickname, diff --git a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/controller/UserMemberController.java b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/controller/UserMemberController.java index ad54728..da29254 100644 --- a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/controller/UserMemberController.java +++ b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/controller/UserMemberController.java @@ -67,7 +67,7 @@ public class UserMemberController extends BaseController { * @return */ @PostMapping("/updateUser") - public R updateUser(@RequestParam(value = "file", required = false) MultipartFile file, @Validated UserMemberUpdateVo userMemberUpdateVo) { + public R updateUser(@RequestParam(value = "headimg", required = false) MultipartFile file, @Validated UserMemberUpdateVo userMemberUpdateVo) { if (file != null) { R result = remoteFileService.upload(file); if (result.getCode() != Constants.SUCCESS) { diff --git a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/CtleaveMessageServiceImpl.java b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/CtleaveMessageServiceImpl.java index 3410b92..471a480 100644 --- a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/CtleaveMessageServiceImpl.java +++ b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/CtleaveMessageServiceImpl.java @@ -1,11 +1,20 @@ package com.flossom.miniProgram.service.impl; import com.flossom.common.core.domain.entity.CtLeaveMessage; +import com.flossom.common.core.domain.entity.WxScriptMessage; +import com.flossom.common.core.domain.entity.WxUserScriptLog; import com.flossom.common.core.enums.CtLeaveMessageEnum; +import com.flossom.common.core.enums.MessageTypeEnum; +import com.flossom.common.core.enums.WxUserIntegralMessageTypeEnum; import com.flossom.common.core.mapper.CtLeaveMessageMapper; +import com.flossom.common.core.mapper.WxScriptMessageMapper; +import com.flossom.common.core.mapper.WxUserScriptLogMapper; +import com.flossom.common.security.utils.SecurityUtils; import com.flossom.miniProgram.service.ICtleaveMeassageService; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import java.util.Date; @@ -14,8 +23,28 @@ public class CtleaveMessageServiceImpl implements ICtleaveMeassageService { @Autowired private CtLeaveMessageMapper ctLeaveMessageMapper; + @Autowired + private WxScriptMessageMapper wxScriptMessageMapper; + + @Autowired + private WxUserScriptLogMapper wxUserScriptLogMapper; + + @Transactional @Override public int saveCtleaveMeassage(CtLeaveMessage ctLeaveMessage) { + // 留言成功发送消息 + WxScriptMessage wxScriptMessage = wxScriptMessageMapper.selectOneByMessageType(MessageTypeEnum.SUBMIT_MESSAGE.getCode()); + WxUserScriptLog wxUserScriptLog = new WxUserScriptLog(); + BeanUtils.copyProperties(wxScriptMessage, wxUserScriptLog); + wxUserScriptLog.setId(null); + wxUserScriptLog.setWxUserId(SecurityUtils.getLoginUser().getWxUserMember().getId()); + wxUserScriptLog.setMessageType(WxUserIntegralMessageTypeEnum.USER_REGISTRATION.getCode()); + wxUserScriptLog.setIsCustom(0); + wxUserScriptLog.setTitile(wxScriptMessage.getMessageTitle()); + wxUserScriptLog.setContent(wxScriptMessage.getMessageContent()); + wxUserScriptLogMapper.insertWxUserScriptLog(wxUserScriptLog); + + // 保存消息 CtLeaveMessageEnum ctLeaveMessageEnum = CtLeaveMessageEnum.fromString(ctLeaveMessage.getSource()); ctLeaveMessage.setSourceName(ctLeaveMessageEnum.getRemark()); ctLeaveMessage.setCreateTime(new Date()); diff --git a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java index 061943d..b7bdb86 100644 --- a/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java +++ b/flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java @@ -5,9 +5,15 @@ import com.flossom.common.core.constant.CacheConstants; import com.flossom.common.core.constant.UserConstants; import com.flossom.common.core.domain.R; import com.flossom.common.core.domain.RegisterBody; +import com.flossom.common.core.domain.entity.WxScriptMessage; import com.flossom.common.core.domain.entity.WxUserMember; +import com.flossom.common.core.domain.entity.WxUserScriptLog; +import com.flossom.common.core.enums.MessageTypeEnum; +import com.flossom.common.core.enums.WxUserIntegralMessageTypeEnum; import com.flossom.common.core.exception.ServiceException; +import com.flossom.common.core.mapper.WxScriptMessageMapper; import com.flossom.common.core.mapper.WxUserMemberMapper; +import com.flossom.common.core.mapper.WxUserScriptLogMapper; import com.flossom.common.core.utils.DateUtils; import com.flossom.common.redis.service.RedisService; import com.flossom.common.security.utils.SecurityUtils; @@ -42,6 +48,12 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService { @Autowired private RedisService redisService; + @Autowired + private WxScriptMessageMapper wxScriptMessageMapper; + + @Autowired + private WxUserScriptLogMapper wxUserScriptLogMapper; + @Override public LoginUserVo login(String code) throws Exception { // 1、使用临时凭证 code 获取 appi + appsecret + unionid @@ -76,6 +88,17 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService { logger.error("测试后台账号失败:{}", registerResult.getMsg()); throw new ServiceException(registerResult.getMsg()); } + // 2.4、用户注册成功发送消息 + WxScriptMessage wxScriptMessage = wxScriptMessageMapper.selectOneByMessageType(MessageTypeEnum.USER_REGISTRATION.getCode()); + WxUserScriptLog wxUserScriptLog = new WxUserScriptLog(); + BeanUtils.copyProperties(wxScriptMessage, wxUserScriptLog); + wxUserScriptLog.setId(null); + wxUserScriptLog.setWxUserId(wxUserMember.getId()); + wxUserScriptLog.setMessageType(WxUserIntegralMessageTypeEnum.USER_REGISTRATION.getCode()); + wxUserScriptLog.setIsCustom(0); + wxUserScriptLog.setTitile(wxScriptMessage.getMessageTitle()); + wxUserScriptLog.setContent(wxScriptMessage.getMessageContent()); + wxUserScriptLogMapper.insertWxUserScriptLog(wxUserScriptLog); } // 3、登录请求,获取 token @@ -137,6 +160,7 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService { } WxUserMember update = new WxUserMember(); + update.setId(wxUserMember.getId()); BeanUtils.copyProperties(userMemberUpdateVo, update); update.setUpdateTime(DateUtils.getNowDate()); wxUserMemberMapper.updateWxUserMember(update);