| | |
| | | import com.xzx.gc.entity.SysMessage; |
| | | import com.xzx.gc.entity.UserHeadRelate; |
| | | import com.xzx.gc.entity.UserShareInfo; |
| | | import com.xzx.gc.user.dto.HeadProfitLitDto; |
| | | import com.xzx.gc.user.dto.HeadTeamDto; |
| | | import com.xzx.gc.user.mapper.*; |
| | | import com.xzx.gc.user.vo.HeadInfoVo; |
| | | import com.xzx.gc.user.vo.HeadProfitListVo; |
| | | import com.xzx.gc.user.vo.HeadTeamVo; |
| | | import com.xzx.gc.user.dto.AdddistribDto; |
| | | import com.xzx.gc.user.dto.DistribInfoListDto; |
| | | import com.xzx.gc.user.dto.DistribListDto; |
| | |
| | | import com.xzx.gc.model.JsonResult; |
| | | import com.xzx.gc.user.dto.UpdateSettingDto; |
| | | import com.xzx.gc.user.mapper.RedPaperRuleMapper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | @Slf4j |
| | | @Service |
| | | @Transactional |
| | | public class DistribService { |
| | |
| | | private RedPaperRuleMapper redPaperRuleMapper; |
| | | @Autowired |
| | | private UserHeadRelateMapper userHeadRelateMapper; |
| | | |
| | | @Autowired |
| | | private UserHeadDetailsMapper userHeadDetailsMapper; |
| | | @Autowired |
| | | private AccountMapper accountMapper; |
| | | @Autowired |
| | |
| | | |
| | | |
| | | public void join(String headId, String userId) { |
| | | log.info("#加入团队:{}, {}#", headId, userId); |
| | | AccountInfo headInfo = accountMapper.selectOneByUserId(headId); |
| | | if (AccountInfo.IS_HEAD_N.equals(headInfo.getIsHead())) { |
| | | throw new RestException(-3, "不是团长"); |
| | |
| | | userHeadRelate.setHeadUserId(headId); |
| | | userHeadRelate.setUserId(userId); |
| | | userHeadRelate.setScore(BigDecimal.ZERO); |
| | | userHeadRelate.setCreatedTime(new Date()); |
| | | userHeadRelate.setAmount(BigDecimal.ZERO); |
| | | userHeadRelateMapper.insert(userHeadRelate); |
| | | |
| | | SysMessage sysMessage = new SysMessage(); |
| | | sysMessage.setCreateTime(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss")); |
| | | sysMessage.setCreateUserId(userId); |
| | | sysMessage.setCreateUserId(headId); |
| | | sysMessage.setUserId(headId); |
| | | sysMessage.setMobilePhone(accountInfo.getAccountName()); |
| | | sysMessage.setMessageType("4"); |
| | | sysMessage.setMessageSubTypeName("团队消息"); |
| | | sysMessage.setMessage("手机号:" + accountInfo.getAccountName() + "的用户, 成功加入您的团队"); |
| | | sysMessage.setFlag("2"); |
| | | sysMessageMapper.insert(sysMessage); |
| | |
| | | return headInfoVo; |
| | | } |
| | | |
| | | public List<HeadProfitListVo> findHeadProfitListInPage(HeadProfitLitDto profitLitDto) { |
| | | PageHelper.startPage(profitLitDto.getPage(), profitLitDto.getLimit()); |
| | | return userHeadDetailsMapper.selectHeadProfitListInPage(profitLitDto.getUserId()); |
| | | } |
| | | |
| | | public List<HeadTeamVo> findHeadTeamListInPage(HeadTeamDto teamDto) { |
| | | PageHelper.startPage(teamDto.getPage(), teamDto.getLimit()); |
| | | return userHeadRelateMapper.selectHeadTeamListInPage(teamDto.getUserId()); |
| | | } |
| | | |
| | | public void addSetting(UpdateSettingDto model) { |
| | | RedPaperRule redPaperRule = new RedPaperRule(); |
| | | StringBuffer stringBuffer = new StringBuffer(); |