From 67df185aff2483115abc9f1b6cda51dc4f967d0b Mon Sep 17 00:00:00 2001 From: 19991905653 Date: Fri, 23 Feb 2024 17:35:56 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B6=E9=93=B6=E7=82=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/demo/util/CodeGenerator.java | 6 +- .../MerchantCashierCounteController.java | 90 ++++ .../platform/mapper/UserCashPlaceMapper.java | 16 + .../resources/mapper/UserCashPlaceMapper.xml | 20 + .../pluss/platform/entity/UserCashPlace.java | 87 ++++ .../MerchantCashierCounteService.java | 29 ++ .../MerchantCashierCounteServiceImpl.java | 436 ++++++++++++++++++ 7 files changed, 681 insertions(+), 3 deletions(-) create mode 100644 pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/MerchantCashierCounteController.java create mode 100644 pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/UserCashPlaceMapper.java create mode 100644 pluss-dao-bundle/src/main/resources/mapper/UserCashPlaceMapper.xml create mode 100644 pluss-model-bundle/src/main/java/cn/pluss/platform/entity/UserCashPlace.java create mode 100644 pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/MerchantCashierCounteService.java create mode 100644 pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/impl/MerchantCashierCounteServiceImpl.java diff --git a/code-generator/src/main/java/com/demo/util/CodeGenerator.java b/code-generator/src/main/java/com/demo/util/CodeGenerator.java index 0c2bd7c..35f0353 100644 --- a/code-generator/src/main/java/com/demo/util/CodeGenerator.java +++ b/code-generator/src/main/java/com/demo/util/CodeGenerator.java @@ -1,8 +1,8 @@ package com.demo.util; -import com.baomidou.mybatisplus.annotation.DbType; -import com.baomidou.mybatisplus.annotation.FieldFill; -import com.baomidou.mybatisplus.core.toolkit.StringPool; +//import com.baomidou.mybatisplus.annotation.DbType; +//import com.baomidou.mybatisplus.annotation.FieldFill; +//import com.baomidou.mybatisplus.core.toolkit.StringPool; import com.baomidou.mybatisplus.generator.AutoGenerator; import com.baomidou.mybatisplus.generator.FastAutoGenerator; import com.baomidou.mybatisplus.generator.config.*; diff --git a/pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/MerchantCashierCounteController.java b/pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/MerchantCashierCounteController.java new file mode 100644 index 0000000..6741526 --- /dev/null +++ b/pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/MerchantCashierCounteController.java @@ -0,0 +1,90 @@ +package cn.pluss.platform.controller.merchant; + +import cn.pluss.platform.api.PageInfo; +import cn.pluss.platform.api.Result; +import cn.pluss.platform.api.ResultGenerator; +import cn.pluss.platform.entity.*; +import cn.pluss.platform.exception.MsgException; +import cn.pluss.platform.mapper.MerchantCashPlaceMapper; +import cn.pluss.platform.mapper.MerchantChannelMapper; +import cn.pluss.platform.merchant.MerchantCashPlaceService; +import cn.pluss.platform.merchant.MerchantCashPlaceStaffService; +import cn.pluss.platform.merchant.MerchantCashierCounteService; +import cn.pluss.platform.userApp.UserAppService; +import cn.pluss.platform.vo.MerchantCashPlaceStaffVO; +import cn.pluss.platform.vo.MerchantCashPlaceVO; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.OrderItem; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import lombok.Setter; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; +import java.util.Objects; + +/** + * 收银点 + * + * @author DJH + */ +@RestController +@RequestMapping("/cashierCounte") +public class MerchantCashierCounteController { + + @Setter(onMethod_ = {@Autowired}) + private MerchantCashierCounteService merchantCashierCounteService; + + @Autowired + private UserAppService userAppService; + @Setter(onMethod_ = {@Autowired}) + private MerchantCashPlaceStaffService cashPlaceStaffService; + @Resource + private MerchantChannelMapper merchantChannelMapper; + + + @PostMapping("/add") + public Result add(@RequestBody MerchantCashPlace merchantCashPlace) { + //判定字符位数 + if (StringUtils.isEmpty(merchantCashPlace.getAddress()) || StringUtils.isEmpty(merchantCashPlace.getName())) { + throw new MsgException("地址或收银点名称不能为空"); + } + UserApp userApp = userAppService.queryUserAppByToken(); + merchantCashPlace.setUserId(userApp.getUserId()); + merchantCashierCounteService.addCashierCounte(merchantCashPlace,userApp); + return ResultGenerator.genSuccessResult("保存成功", merchantCashPlace); + } + + /** + * （新）收银点列表 + * + * @param current + * @param size + * @return + */ + @GetMapping("/list") + public Result list(@RequestParam Integer current, @RequestParam Integer size) { + UserApp userApp = userAppService.queryUserAppByToken(); + PageInfo result = merchantCashierCounteService.selectList(current,size,userApp.getUserId()); + return ResultGenerator.genSuccessResult(result); + } + + /** + * 切换收银点 + * + * @return + */ + @GetMapping("/cutCashier") + public Result cutCashier(@RequestParam long fromChannel, + @RequestParam long toChannel) { + Map map = merchantCashierCounteService.cutCashier(fromChannel, toChannel); + return ResultGenerator.genSuccessResult(map); + } + + + + +} \ No newline at end of file diff --git a/pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/UserCashPlaceMapper.java b/pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/UserCashPlaceMapper.java new file mode 100644 index 0000000..1d84499 --- /dev/null +++ b/pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/UserCashPlaceMapper.java @@ -0,0 +1,16 @@ +package cn.pluss.platform.mapper; + +import cn.pluss.platform.entity.MerchantCashPlace; +import cn.pluss.platform.entity.UserCashPlace; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; + +/** + *

+ * 商户收银点表 Mapper 接口 + *

+ * + * @author Djh + * @since 2021-03-23 + */ +public interface UserCashPlaceMapper extends BaseMapper { +} diff --git a/pluss-dao-bundle/src/main/resources/mapper/UserCashPlaceMapper.xml b/pluss-dao-bundle/src/main/resources/mapper/UserCashPlaceMapper.xml new file mode 100644 index 0000000..d162877 --- /dev/null +++ b/pluss-dao-bundle/src/main/resources/mapper/UserCashPlaceMapper.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + + + + + + + + + + diff --git a/pluss-model-bundle/src/main/java/cn/pluss/platform/entity/UserCashPlace.java b/pluss-model-bundle/src/main/java/cn/pluss/platform/entity/UserCashPlace.java new file mode 100644 index 0000000..85d8613 --- /dev/null +++ b/pluss-model-bundle/src/main/java/cn/pluss/platform/entity/UserCashPlace.java @@ -0,0 +1,87 @@ +package cn.pluss.platform.entity; + +import cn.pluss.platform.config.mybatis.SqlConditionExtra; +import com.alibaba.fastjson.annotation.JSONField; +import com.baomidou.mybatisplus.annotation.*; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import java.io.Serializable; +import java.util.Date; + +/** + *

+ * 商户收银点表 + *

+ * + * @author Djh + * @since 2021-03-23 + */ +@Data +@EqualsAndHashCode(callSuper = false) +@Accessors(chain = true) +@TableName("tb_pluss_user_cash_place") +public class UserCashPlace implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * id + */ + @TableId(value = "id", type = IdType.AUTO) + private Integer id; + + + /** + * 用户id + */ + @TableField("user_id") + private Long userId; + + /** + * 商户ID + */ + @TableField("merchant_id") + private String merchantId; + + /** + * 是否主账号 + */ + @TableField("is_root_account") + private String isRootAccount; + + + + /** + * 备注 + */ + @TableField("remark") + private String remark; + + /** + * 所属商户编号 + */ + @TableField("org_code") + private String orgCode; + @TableField("root_account_id") + private Integer rootAccountId; + @TableField("chasplace_id") + private Integer chasplaceId; + + /** + * 创建时间 + */ + @TableField(value = "createTime", fill = FieldFill.INSERT) + @JSONField(format = "yyyy-MM-dd HH:mm:ss") + private Date createTime; + + /** + * 更新时间 + */ + @TableField(value = "updateTime", fill = FieldFill.INSERT_UPDATE) + @JSONField(format = "yyyy-MM-dd HH:mm:ss") + private Date updateTime; + + +} \ No newline at end of file diff --git a/pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/MerchantCashierCounteService.java b/pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/MerchantCashierCounteService.java new file mode 100644 index 0000000..8cacea9 --- /dev/null +++ b/pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/MerchantCashierCounteService.java @@ -0,0 +1,29 @@ +package cn.pluss.platform.merchant; + +import cn.pluss.platform.api.PageInfo; +import cn.pluss.platform.entity.*; +import cn.pluss.platform.vo.MerchantCashPlaceStaffVO; +import cn.pluss.platform.vo.MerchantCashPlaceVO; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.IService; + +import java.util.List; +import java.util.Map; + +/** + *

+ * 商户收银点表 服务类 + *

+ * + * @author Djh + * @since 2021-03-23 + */ +public interface MerchantCashierCounteService { + + + long addCashierCounte(MerchantCashPlace merchantCashPlace,UserApp userApp); + + PageInfo selectList(Integer current, Integer size, Long userId); + + Map cutCashier(long fromChannel, long toChannel); +} diff --git a/pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/impl/MerchantCashierCounteServiceImpl.java b/pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/impl/MerchantCashierCounteServiceImpl.java new file mode 100644 index 0000000..652c5c1 --- /dev/null +++ b/pluss-service-bundle/src/main/java/cn/pluss/platform/merchant/impl/MerchantCashierCounteServiceImpl.java @@ -0,0 +1,436 @@ +package cn.pluss.platform.merchant.impl; + +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.ObjectUtil; +import cn.jiguang.common.utils.StringUtils; +import cn.pluss.platform.api.PageInfo; +import cn.pluss.platform.converter.Converter; +import cn.pluss.platform.converter.MerchantCashPlaceConverter; +import cn.pluss.platform.deviceStock.DeviceStockService; +import cn.pluss.platform.entity.*; +import cn.pluss.platform.exception.MsgException; +import cn.pluss.platform.jfShop.JfShopHandler; +import cn.pluss.platform.mapper.*; +import cn.pluss.platform.merchant.*; +import cn.pluss.platform.merchantChannelStatus.MerchantChannelStatusService; +import cn.pluss.platform.other.JfShopParam; +import cn.pluss.platform.other.JfShopSyncUser; +import cn.pluss.platform.roleUserInfo.RoleUserInfoService; +import cn.pluss.platform.systemConfig.SystemConfigService; +import cn.pluss.platform.userApp.UserAppService; +import cn.pluss.platform.userInfo.UserInfoService; +import cn.pluss.platform.util.Base64Util; +import cn.pluss.platform.util.MD5Util; +import cn.pluss.platform.util.StringUtil; +import cn.pluss.platform.vo.MerchantCashPlaceStaffVO; +import cn.pluss.platform.vo.MerchantCashPlaceVO; +import cn.pluss.platform.vo.MerchantStaffConnVO; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import lombok.Setter; +import lombok.val; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Propagation; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.*; + +/** + *

+ * 商户收银点表 服务实现类 + *

+ * + * @author Djh + * @since 2021-03-23 + */ +@Service +public class MerchantCashierCounteServiceImpl implements MerchantCashierCounteService { + + @Setter(onMethod_ = {@Autowired}) + private UserAppService userAppService; + + @Setter(onMethod_ = {@Autowired}) + private MerchantChannelStatusService channelStatusService; + + @Setter(onMethod_ = {@Autowired}) + private MerchantCashPlaceStaffService cashPlaceStaffService; + + @Setter(onMethod_ = {@Autowired}) + private MerchantBaseInfoService merchantBaseInfoService; + + @Setter(onMethod_ = {@Autowired, @Lazy}) + private MerchantCashPayCodeService cashPayCodeService; + + @Setter(onMethod_ = {@Autowired}) + private DeviceStockService deviceStockService; + + @Setter(onMethod_ = {@Autowired}) + private MerchantCashPayCodeMapper merchantCashPayCodeMapper; + + @Setter(onMethod_ = {@Autowired}) + private MerchantCashPlaceStaffMapper merchantCashPlaceStaffMapper; + + @Setter(onMethod_ = {@Autowired}) + private UserAppMapper userAppMapper; + @Setter(onMethod_ = {@Autowired}) + private SystemConfigService systemConfigService; + @Setter(onMethod_ = {@Autowired}) + private UserInfoService userInfoService; + @Setter(onMethod_ = {@Autowired}) + private RoleUserInfoService roleUserInfoService; + @Resource + private MerchantBaseInfoMapper merchantBaseInfoMapper; + @Autowired + private IdCardMapper idCardMapper; + @Autowired + private UserPromotionMapper userPromotionMapper; + + @Autowired + private MerchantCashPlaceMapper merchantCashPlaceMapper; + @Autowired + private UserCashPlaceMapper userCashPlaceMapper; + @Autowired + private UserInfoMapper userInfoMapper; + @Setter(onMethod_ = {@Autowired, @Lazy}) + private JfShopHandler jfShopHandler; + + @Override + @Transactional(rollbackFor = Exception.class) + public long addCashierCounte(MerchantCashPlace merchantCashPlace,UserApp userApp1) { + + if (StringUtils.isEmpty(merchantCashPlace.getName())) { + throw new MsgException("缺少收银台名称"); + } + QueryWrapper query = new QueryWrapper<>(); + query.eq("name", merchantCashPlace.getName()); + long sum = merchantCashPlaceMapper.selectCount(query); + if (sum > 0) { + throw new MsgException("该收银点名称已存在"); + } + UserInfo userInfo1 = userInfoMapper.selectById(userApp1.getUserId()); + if (userInfo1.getLoginName().contains("-")){ + throw new MsgException("请使用登录账号创建收银点"); + } + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("root_account_id", merchantCashPlace.getUserId()); + wrapper.eq("is_root_account", "true"); + List list = userCashPlaceMapper.selectList(wrapper); + int rootAccountId = userApp1.getUserId().intValue(); + String orgCode = userInfo1.getPhone(); + if (list.size() > 0) { + UserCashPlace userCashPlace = list.iterator().next(); + rootAccountId = userCashPlace.getRootAccountId(); + UserInfo userInfo = userInfoMapper.selectById(userCashPlace.getRootAccountId()); + orgCode = userInfo.getLoginName(); + } + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("root_account_id", rootAccountId); + long sydNum = merchantCashPlaceMapper.selectCount(queryWrapper); + long infoId = merchantCashPlace.getUserId(); + long userId = merchantCashPlace.getUserId(); + String isRoot = "true"; + if (sydNum > 0) { + UserInfo userInfo = userInfoMapper.selectById(merchantCashPlace.getUserId()); + QueryWrapper userCashPlaceQueryWrapper = new QueryWrapper<>(); + userCashPlaceQueryWrapper.eq("root_account_id",merchantCashPlace.getUserId()); + long sumNum = userCashPlaceMapper.selectCount(userCashPlaceQueryWrapper); + userInfo.setId(null); + userInfo.setLoginName(userInfo.getLoginName().concat("-").concat(String.format("%02d", sumNum+1))); + userInfo.setCreateTime(new Date()); + userInfo.setPassword(MD5Util.MD5Encode("czg12345678", "utf-8")); + Long roleId = null; + // 获取全部的角色信息 + List systemConfigs = systemConfigService.querySystemConfigList(new SystemConfig()); + for (SystemConfig systemConfig : systemConfigs) { + if (systemConfig.getPropertyKey().equalsIgnoreCase("promoter_role_id")) { + roleId = Long.parseLong(systemConfig.getPropertyValue()); + } + } + if (roleId == null) { + throw new MsgException("收银点添加失败！"); + } + userInfo.setCreateTime(new Date()); + userInfoService.saveUserInfo(userInfo); + // 可能和数据库存储的数据不一致 + + RoleUserInfo role = new RoleUserInfo(); + role.setRoleId(roleId); + role.setUserId(userInfo.getId()); + //如果没有邀请码默认是平台用户 + UserApp userApp = userAppMapper.selectById(userApp1.getId()); +// getSaveUserAppInfo(userInfo, merchantCashPlace.getUserId()); + userApp.setInviteNum(getRandomNum()); + userApp.setId(null); + userApp.setBankStatus(0); + userApp.setToken(userInfo.getLoginName()); + userApp.setUserId(userInfo.getId()); + //查找代理 + UserPromotion promotion = getUserPromotionByUserId(String.valueOf(244)); + String parenId = promotion.getUserId().toString(); + UserPromotion promotionNew = new UserPromotion(); + promotionNew.setUserId(userInfo.getId()); + promotionNew.setParentUserId(parenId); + if (userInfo.getTypeCode().equals("FB")) { + if (promotion.getCurrentFee().compareTo(userInfo.getCurrentFee()) > 0 || + userInfo.getCurrentFee().compareTo(getUserPromotionByUserId("244").getCurrentFee()) < 0) { + MsgException.checkNull(null, "错误的费率信息"); + } + } + + if (userInfo.getTypeCode().equals("SB")) { + if (promotion.getCurrentFee().compareTo(userInfo.getCurrentFee()) > 0 || + userInfo.getCurrentFee().compareTo(getUserPromotionByUserId("244").getCurrentFee()) < 0) { + MsgException.checkNull(null, "错误的费率信息"); + } + } + //如果是普通商户默认费率0.38 + if (userInfo.getTypeCode().equals("MC")) { + promotion.setCurrentFee("0.38"); + } + promotionNew.setCurrentFee(promotion.getCurrentFee()); + promotionNew.setTypeCode(userInfo.getTypeCode()); + promotionNew.setIsExtend(userInfo.getTypeCode().equals("MC") ? "0" : "1"); + promotionNew.setCreateTime(new Date()); + userPromotionMapper.insert(promotionNew); + // 获取当前用户的id保存用户的角色信息 + // 保存信息 + userAppService.save(userApp); + roleUserInfoService.saveRoleUserInfo(role); + // 删除验证码 + + //TODO 同步用户到新版积分商城 + jfShopHandler.syncJfShopUser(userApp, userInfo); + infoId = userInfo.getId(); + isRoot = "false"; + QueryWrapper cardQueryWrapper = new QueryWrapper<>(); + cardQueryWrapper.eq("userId",userApp1.getUserId()); + List idCardList = idCardMapper.selectList(cardQueryWrapper); + for (IdCard idCard:idCardList){ + idCard.setId(null); + idCard.setUserId(infoId+""); + idCard.setCreateTime(new Date()); + idCard.setUpdateTime(new Date()); + idCardMapper.insert(idCard); + } + } + + // 查看对应的收银台是否已经存在 + merchantCashPlace.setRootAccountId(userId); + merchantCashPlace.setUserId(infoId); + merchantCashPlace.setCreateTime(new Date()); + merchantCashPlace.setCode(getCode()); + merchantCashPlaceMapper.insert(merchantCashPlace); + if ("true".equals(isRoot)){ + QueryWrapper placeQueryWrapper = new QueryWrapper<>(); + placeQueryWrapper.eq("is_root_account","true"); + placeQueryWrapper.eq("user_id",userApp1.getUserId()); + UserCashPlace childUserCashPlace = userCashPlaceMapper.selectOne(placeQueryWrapper); + if (Objects.isNull(childUserCashPlace)){ + childUserCashPlace = new UserCashPlace(); + childUserCashPlace.setChasplaceId(merchantCashPlace.getId()); + childUserCashPlace.setCreateTime(new Date()); + childUserCashPlace.setIsRootAccount("true"); + childUserCashPlace.setOrgCode(orgCode); + childUserCashPlace.setRootAccountId(rootAccountId); + childUserCashPlace.setUserId(infoId); + userCashPlaceMapper.insert(childUserCashPlace); + }else { + childUserCashPlace.setChasplaceId(merchantCashPlace.getId()); + childUserCashPlace.setUpdateTime(new Date()); + userCashPlaceMapper.updateById(childUserCashPlace); + } + }else { + UserCashPlace childUserCashPlace = new UserCashPlace(); + childUserCashPlace.setChasplaceId(merchantCashPlace.getId()); + childUserCashPlace.setCreateTime(new Date()); + childUserCashPlace.setIsRootAccount("false"); + childUserCashPlace.setOrgCode(orgCode); + childUserCashPlace.setRootAccountId(rootAccountId); + childUserCashPlace.setUserId(infoId); + userCashPlaceMapper.insert(childUserCashPlace); + } + + return infoId; + } + + public static void main(String[] args) { + System.out.println(MD5Util.MD5Encode("1234qwer", "utf-8")); + } + @Override + public PageInfo selectList(Integer current, Integer size, Long userId) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("user_id", userId); + UserCashPlace userCashPlace = userCashPlaceMapper.selectOne(queryWrapper); + if (Objects.nonNull(userCashPlace)) { + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.select("user_id"); + wrapper.eq("root_account_id", userCashPlace.getRootAccountId()); + List list = userCashPlaceMapper.selectObjs(wrapper); + QueryWrapper placeQueryWrapper = new QueryWrapper<>(); + placeQueryWrapper.in("userId", list); + placeQueryWrapper.orderByAsc("id"); +// List placeList = merchantCashPlaceMapper.selectList(placeQueryWrapper); + IPage iPage = merchantCashPlaceMapper.selectPage(new Page<>(current, size), placeQueryWrapper); + +// if (iPage.getRecords().size() < 1) { +// return new PageInfo(current, 0,0, +// size, iPage.getRecords());; +// } else { + for (MerchantCashPlace merchantCashPlace:iPage.getRecords()){ + if (userId.intValue() == merchantCashPlace.getUserId().intValue()){ + merchantCashPlace.setTab(1); + }else { + merchantCashPlace.setTab(0); + } + } + PageInfo pager = new PageInfo(iPage.getCurrent(), iPage.getTotal(), iPage.getPages(), + iPage.getSize(), iPage.getRecords()); + return pager; +// } + } + return new PageInfo(current.longValue(), 0L, 0L, + size.longValue(), new ArrayList<>()); + + } + + @Override + public Map cutCashier(long fromChannel, long toChannel) { + MerchantCashPlace fromCash = merchantCashPlaceMapper.selectById(fromChannel); + MerchantCashPlace toCash = merchantCashPlaceMapper.selectById(toChannel); + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("user_id", fromCash.getUserId()); + UserCashPlace userCashPlace = userCashPlaceMapper.selectOne(queryWrapper); + if (Objects.isNull(userCashPlace)) { + throw new MsgException("收银点切换失败"); + } + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("user_id", toCash.getUserId()); + wrapper.eq("root_account_id", userCashPlace.getRootAccountId()); + long sum = userCashPlaceMapper.selectCount(wrapper); + if (sum < 1) { + throw new MsgException("切换收银点不匹配"); + } + Map resultMap = new HashMap<>(); + UserInfo checkUserInfo = userInfoMapper.selectById(toCash.getUserId()); + + MsgException.checkNull(checkUserInfo, "切换失败！"); + + // 原则上不能以原密码进行对比，这里只是给后台登录页面一个方便 + UserApp queryUserApp; + queryUserApp = userAppMapper.selectUserApp(new QueryWrapper<>().eq("ua.userId", checkUserInfo.getId())); + String genRandomNum = StringUtil.genRandomNum(6) + StringUtil.getBillno() + StringUtil.genRandomNum(6); + UserApp uApp = new UserApp(); + uApp.setToken(genRandomNum); + uApp.setId(queryUserApp.getId()); + userAppMapper.updateById(uApp); + queryUserApp.setToken(genRandomNum); + resultMap.put("userInfo", checkUserInfo); + Long userId = checkUserInfo.getId(); + MerchantBaseInfo merchantBaseInfo = new MerchantBaseInfo(); + merchantBaseInfo.setUserId(userId + ""); + List queryMerchantBaseInfoList = merchantBaseInfoService.queryMerchantBaseInfoList(merchantBaseInfo); + if (null != queryMerchantBaseInfoList && !queryMerchantBaseInfoList.isEmpty()) { + merchantBaseInfo = queryMerchantBaseInfoList.get(0); + queryUserApp.setMercId(merchantBaseInfo.getId()); + queryUserApp.setMerchantType(merchantBaseInfo.getMerchantType()); + queryUserApp.setMerchantName(merchantBaseInfo.getAlias()); + queryUserApp.setAlias(merchantBaseInfo.getAlias()); + } + resultMap.put("userApp", queryUserApp); + return resultMap; + } + + private UserPromotion getUserPromotionByUserId(String userId) { + UserPromotion userPromotion = new UserPromotion(); + userPromotion.setUserId(Long.valueOf(userId)); + UserPromotion promotion = userPromotionMapper.selectOne(new QueryWrapper<>(userPromotion)); + + if (ObjectUtil.isNotEmpty(promotion)) { + if ("MG".equals(promotion.getTypeCode()) || "FB".equals(promotion.getTypeCode()) || + "SB".equals(promotion.getTypeCode()) || "1".equals(promotion.getIsExtend()) || + "2".equals(promotion.getIsExtend()) || "AG".equals(promotion.getTypeCode())) { + return promotion; + } + } + getUserPromotionByUserId(promotion.getParentUserId()); + return promotion; + } + + protected UserApp getSaveUserAppInfo(UserInfo userInfo, Long userId) { + + // 保存用户信息到userApp表 + UserApp userApp = new UserApp(); + userApp.setUserId(userInfo.getId()); + // 默认一级推广员 + userApp.setLevel(1); + userApp.setCreateDt(new Date()); + userApp.setStatus(0); + userApp.setUserType("promoter"); + + userApp.setInviteNum(getRandomNum()); + + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("userId", userId); + UserApp parentUserApp = userAppMapper.selectOne(queryWrapper); + if (Objects.nonNull(parentUserApp)) { + userApp.setParentId(parentUserApp.getParentId()); + userApp.setAgentStaffId(parentUserApp.getUserId()); + } + + // 根据邀请码查询确定当前用户的上级关系 + return userApp; + } + + private String getRandomNum() { + String inviteNum; + UserApp condition = new UserApp(); + + do { + inviteNum = StringUtil.genRandomNum(5); + condition.setInviteNum(inviteNum); + UserApp userApp = userAppService.queryUserApp(condition); + if (userApp == null) { + return inviteNum; + } + } while (true); + } + + + public String getCode(){ + String randomDigits = generateRandomDigits(2); + String randomLetters = generateRandomLetters(6); + String randomString = randomDigits + randomLetters; + return randomString; + } + // 生成n位随机数字 + private static String generateRandomDigits(int n) { + Random random = new Random(); + StringBuilder sb = new StringBuilder(); + + for (int i = 0; i < n; i++) { + int digit = random.nextInt(10); + sb.append(digit); + } + + return sb.toString(); + } + + private static String generateRandomLetters(int n) { + Random random = new Random(); + StringBuilder sb = new StringBuilder(); + + for (int i = 0; i < n; i++) { + char letter = (char) (random.nextInt(26) + 'A'); + sb.append(letter); + } + + return sb.toString(); + } +}