3 Commits

Author SHA1 Message Date
jihaipeng 08971e9023 Merge branch 'milestone-20250723-wwl' of http://39.101.133.168:8807/qimaohong/ActivityProject into milestone-20250723-wwl 3 weeks ago
jihaipeng caba10623d 修改地址 3 weeks ago
willy c7e142a187 小修改 3 weeks ago
  1. 4
      lottery-system/lottery-pojo/src/main/java/com/lottery/entity/WinnerRecord.java
  2. 2
      lottery-system/lottery-service/src/main/java/com/lottery/admin/mapper/IFundingMapper.java
  3. 10
      lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/AdminPrizeServiceImpl.java
  4. 8
      lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/AdminUserDetailServiceImpl.java
  5. 14
      lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/AdminUserServiceImpl.java
  6. 3
      lottery-system/lottery-service/src/main/java/com/lottery/api/mapper/ApiIFundingMapper.java
  7. 4
      lottery-system/lottery-service/src/main/java/com/lottery/api/service/Impl/ApiFundingServiceImpl.java
  8. 7
      lottery-system/lottery-service/src/main/java/com/lottery/api/service/Impl/UserDetailServiceImpl.java
  9. 9
      lottery-system/lottery-service/src/main/resources/mapper/api/ApiIFundingService.xml

4
lottery-system/lottery-pojo/src/main/java/com/lottery/entity/WinnerRecord.java

@ -34,6 +34,7 @@ public class WinnerRecord {
private Long prizeId; // 奖品ID private Long prizeId; // 奖品ID
@TableField("loc_market")
private String locMarket; private String locMarket;
@TableField("is_del") @TableField("is_del")
@ -42,7 +43,6 @@ public class WinnerRecord {
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private Date winTime; // 中奖时间 private Date winTime; // 中奖时间
@TableField("loc_market")
private String locMarket;
} }

2
lottery-system/lottery-service/src/main/java/com/lottery/admin/mapper/IFundingMapper.java

@ -95,4 +95,6 @@ public interface IFundingMapper {
@Update("update z_user set loc_market = #{locMarket} where jwcode = #{jwcode}") @Update("update z_user set loc_market = #{locMarket} where jwcode = #{jwcode}")
void updateLocMarket(String jwcode, String locMarket); void updateLocMarket(String jwcode, String locMarket);
@Select("select text from market where market = #{locMarket}")
String updateLocMarketToCn(String locMarket);
} }

10
lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/AdminPrizeServiceImpl.java

@ -215,6 +215,9 @@ public class AdminPrizeServiceImpl extends ServiceImpl<AdminPrizeMapper, Prize>
prizeVo.setGradeName(grade.getGradeName()); prizeVo.setGradeName(grade.getGradeName());
return prizeVo; return prizeVo;
} }
@Autowired
private IFundingMapper fundingMapper;
@Override @Override
public Result addWinUser(FixUserDto fixUserDto) throws Exception { public Result addWinUser(FixUserDto fixUserDto) throws Exception {
@ -252,14 +255,17 @@ public class AdminPrizeServiceImpl extends ServiceImpl<AdminPrizeMapper, Prize>
// 调用接口 // 调用接口
String response = HttpUtils.postUrlencoded(url, params); String response = HttpUtils.postUrlencoded(url, params);
JsonNode rootNode = objectMapper.readTree(response); JsonNode rootNode = objectMapper.readTree(response);
String locMarket = rootNode.path("data").path("loc_market").asText();
if(rootNode.path("code").asInt() == 401){ if(rootNode.path("code").asInt() == 401){
throw new BusinessException(400, "精网号错误"); throw new BusinessException(400, "精网号错误");
} }
try { try {
// 1. 检查用户是否存在不存在则创建 // 1. 检查用户是否存在不存在则创建
Long userId = adminUserMapper.selectByJwcode(fixUserDto.getJwcode()); Long userId = adminUserMapper.selectByJwcode(fixUserDto.getJwcode());
String s = fundingMapper.updateLocMarketToCn(locMarket);
if (userId == null) { if (userId == null) {
User user = User.builder() User user = User.builder()
.username(fixUserDto.getUsername()) .username(fixUserDto.getUsername())
@ -269,7 +275,7 @@ public class AdminPrizeServiceImpl extends ServiceImpl<AdminPrizeMapper, Prize>
.isDel(0) .isDel(0)
.createTime(new Date()) .createTime(new Date())
.updateTime(new Date()) .updateTime(new Date())
.locMarket(rootNode.path("data").path("loc_market").asText())
.locMarket(s)
.build(); .build();
adminUserMapper.insert(user); adminUserMapper.insert(user);
userId = user.getId(); userId = user.getId();

8
lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/AdminUserDetailServiceImpl.java

@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.lottery.admin.mapper.AdminGradeMapper; import com.lottery.admin.mapper.AdminGradeMapper;
import com.lottery.admin.mapper.AdminUserDetailMapper; import com.lottery.admin.mapper.AdminUserDetailMapper;
import com.lottery.admin.mapper.AdminUserMapper; import com.lottery.admin.mapper.AdminUserMapper;
import com.lottery.admin.mapper.IFundingMapper;
import com.lottery.admin.service.AdminUserDetailService; import com.lottery.admin.service.AdminUserDetailService;
import com.lottery.admin.service.AdminUserService; import com.lottery.admin.service.AdminUserService;
import com.lottery.api.mapper.IUserDetailMapper; import com.lottery.api.mapper.IUserDetailMapper;
@ -55,6 +56,8 @@ public class AdminUserDetailServiceImpl extends ServiceImpl<IUserDetailMapper, U
@Autowired @Autowired
private AdminGradeMapper adminGradeMapper; private AdminGradeMapper adminGradeMapper;
@Autowired
private FundingServiceImpl fundingServiceImpl;
@Override @Override
public PageInfo<UserVo> listFixUser(int pageNum, int pageSize, UserQueryDto userQueryDto) { public PageInfo<UserVo> listFixUser(int pageNum, int pageSize, UserQueryDto userQueryDto) {
@ -526,6 +529,8 @@ public class AdminUserDetailServiceImpl extends ServiceImpl<IUserDetailMapper, U
throw new IllegalArgumentException("第" + rowNum + "行: 精网号在当前文件中重复"); throw new IllegalArgumentException("第" + rowNum + "行: 精网号在当前文件中重复");
} }
} }
@Autowired
private IFundingMapper fundingMapper;
private User convertToEntity(UserImportDto dto) { private User convertToEntity(UserImportDto dto) {
User user = new User(); User user = new User();
@ -535,7 +540,8 @@ public class AdminUserDetailServiceImpl extends ServiceImpl<IUserDetailMapper, U
user.setUpdateTime(new Date()); user.setUpdateTime(new Date());
// 查询并设置loc_market // 查询并设置loc_market
String locMarket = adminUserMapper.selectLocMarketByJwcode(dto.getJwcode()); String locMarket = adminUserMapper.selectLocMarketByJwcode(dto.getJwcode());
user.setLocMarket(locMarket != null ? locMarket : "未知"); // 默认值
String s = fundingMapper.updateLocMarketToCn(locMarket);
user.setLocMarket(s); // 默认值
// 密码加密 // 密码加密
user.setPassword("123456"); user.setPassword("123456");
return user; return user;

14
lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/AdminUserServiceImpl.java

@ -11,10 +11,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.lottery.LotteryApplication; import com.lottery.LotteryApplication;
import com.lottery.admin.controller.AdminUserController; import com.lottery.admin.controller.AdminUserController;
import com.lottery.admin.mapper.AdminIsLoginMapper;
import com.lottery.admin.mapper.AdminUserDetailMapper;
import com.lottery.admin.mapper.AdminUserMapper;
import com.lottery.admin.mapper.AdminWinMapper;
import com.lottery.admin.mapper.*;
import com.lottery.admin.service.AdminUserService; import com.lottery.admin.service.AdminUserService;
import com.lottery.config.ApiConfig; import com.lottery.config.ApiConfig;
import com.lottery.config.ApiConfig; import com.lottery.config.ApiConfig;
@ -136,6 +133,8 @@ public class AdminUserServiceImpl extends ServiceImpl<AdminUserMapper, User> imp
redisTemplate.opsForValue().set( "token:"+token, adminLogin.getUsername(),24, TimeUnit.HOURS); redisTemplate.opsForValue().set( "token:"+token, adminLogin.getUsername(),24, TimeUnit.HOURS);
return Result.success(userLoginVo); return Result.success(userLoginVo);
} }
@Autowired
private IFundingMapper fundingMapper;
@Override @Override
public boolean addUser(@Valid UserDto userDto) throws Exception { public boolean addUser(@Valid UserDto userDto) throws Exception {
@ -184,7 +183,8 @@ public class AdminUserServiceImpl extends ServiceImpl<AdminUserMapper, User> imp
user.setIsDel(0); user.setIsDel(0);
user.setCreateTime(new Date()); user.setCreateTime(new Date());
user.setUpdateTime(new Date()); user.setUpdateTime(new Date());
user.setLocMarket(locMarket);
String cnName = fundingMapper.updateLocMarketToCn(locMarket);
user.setLocMarket(cnName);
user.setPassword("123456"); // 默认密码 user.setPassword("123456"); // 默认密码
return this.save(user); return this.save(user);
@ -373,7 +373,6 @@ public class AdminUserServiceImpl extends ServiceImpl<AdminUserMapper, User> imp
} }
private User convertToEntity(UserImportDto dto) { private User convertToEntity(UserImportDto dto) {
User user = new User(); User user = new User();
user.setJwcode(dto.getJwcode()); user.setJwcode(dto.getJwcode());
@ -384,7 +383,8 @@ public class AdminUserServiceImpl extends ServiceImpl<AdminUserMapper, User> imp
user.setIsDel(0); user.setIsDel(0);
// 查询并设置loc_market // 查询并设置loc_market
String locMarket = adminUserMapper.selectLocMarketByJwcode(dto.getJwcode()); String locMarket = adminUserMapper.selectLocMarketByJwcode(dto.getJwcode());
user.setLocMarket(locMarket != null ? locMarket : "未知"); // 默认值
String s = fundingMapper.updateLocMarketToCn(locMarket);
user.setLocMarket(s); // 默认值
// 设置默认密码 // 设置默认密码
user.setPassword("123456"); user.setPassword("123456");
return user; return user;

3
lottery-system/lottery-service/src/main/java/com/lottery/api/mapper/ApiIFundingMapper.java

@ -43,4 +43,7 @@ public interface ApiIFundingMapper {
Integer selectActivityISExist(Integer activityId); Integer selectActivityISExist(Integer activityId);
Integer selectMarketISExist(Integer market); Integer selectMarketISExist(Integer market);
String selectBYMarket(String locMarket1);
} }

4
lottery-system/lottery-service/src/main/java/com/lottery/api/service/Impl/ApiFundingServiceImpl.java

@ -202,7 +202,9 @@ public class ApiFundingServiceImpl implements ApiIFundingService {
// 提取 username // 提取 username
String username = rootNode.path("data").path("username").asText(); String username = rootNode.path("data").path("username").asText();
String jwcode = rootNode.path("data").path("jwcode").asText(); String jwcode = rootNode.path("data").path("jwcode").asText();
String locMarket = rootNode.path("data").path("loc_market").asText();
String locMarket1 = rootNode.path("data").path("loc_market").asText();
//通过
String locMarket = fundingMapper.selectBYMarket(locMarket1);
LocalDateTime joinTime = LocalDateTime.now(); LocalDateTime joinTime = LocalDateTime.now();

7
lottery-system/lottery-service/src/main/java/com/lottery/api/service/Impl/UserDetailServiceImpl.java

@ -9,6 +9,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import com.lottery.admin.controller.AdminPrizeController; import com.lottery.admin.controller.AdminPrizeController;
import com.lottery.admin.mapper.AdminPrizeMapper; import com.lottery.admin.mapper.AdminPrizeMapper;
import com.lottery.admin.mapper.AdminWinMapper; import com.lottery.admin.mapper.AdminWinMapper;
import com.lottery.admin.mapper.IFundingMapper;
import com.lottery.api.mapper.IGradeMapper; import com.lottery.api.mapper.IGradeMapper;
import com.lottery.api.mapper.IUserDetailMapper; import com.lottery.api.mapper.IUserDetailMapper;
import com.lottery.api.mapper.IUserMapper; import com.lottery.api.mapper.IUserMapper;
@ -347,6 +348,8 @@ public class UserDetailServiceImpl extends ServiceImpl<IUserDetailMapper, UserDe
.collect(Collectors.toList()); .collect(Collectors.toList());
} }
@Autowired
private IFundingMapper fundingMapper;
private final static Logger LOGGER = LoggerFactory.getLogger(UserDetailServiceImpl.class); private final static Logger LOGGER = LoggerFactory.getLogger(UserDetailServiceImpl.class);
// 标记用户为中奖状态 // 标记用户为中奖状态
private void markUsersAsWinners(List<User> winners, StartLotteryDto startLotteryDto) throws Exception { private void markUsersAsWinners(List<User> winners, StartLotteryDto startLotteryDto) throws Exception {
@ -394,12 +397,14 @@ public class UserDetailServiceImpl extends ServiceImpl<IUserDetailMapper, UserDe
// } // }
// 4. 如果不存在任何记录则插入新记录 // 4. 如果不存在任何记录则插入新记录
String cnName = fundingMapper.updateLocMarketToCn(user.getLocMarket());
WinnerRecord winnerRecord = WinnerRecord.builder() WinnerRecord winnerRecord = WinnerRecord.builder()
.userId(user.getId()) .userId(user.getId())
.winTime(new Date()) .winTime(new Date())
.prizeId(startLotteryDto.getPrizeId()) .prizeId(startLotteryDto.getPrizeId())
.isDel(0) // 明确设置为未删除 .isDel(0) // 明确设置为未删除
.locMarket(user.getLocMarket())
.locMarket(cnName)
.build(); .build();
adminWinMapper.insert(winnerRecord); adminWinMapper.insert(winnerRecord);
} }

9
lottery-system/lottery-service/src/main/resources/mapper/api/ApiIFundingService.xml

@ -113,6 +113,13 @@
WHERE WHERE
id = #{market} id = #{market}
</select> </select>
<select id="selectBYMarket" resultType="java.lang.String" parameterType="java.lang.String">
SELECT
text
FROM
market
WHERE
market = #{locMarket1}
</select>
</mapper> </mapper>
Loading…
Cancel
Save