luhaojie/agricultural-monitoring-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决充值机充值不能修改用户余额问题

Browse Source
This commit is contained in:
童丽然 2024-12-27 10:30:30 +08:00
parent c60724520c
commit efb8504393
4 changed files with 34 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
fastbee-open-api/src/main/java/com/fastbee/data/controller/pay/WeChatPayController.java
View File

@ -67,6 +67,8 @@ public class WeChatPayController extends BaseController {
@Autowired @Autowired
private IUserWechatPayService userWechatPayService; private IUserWechatPayService userWechatPayService;
/** /**
* 获取openId * 获取openId
* @param code * @param code

4
fastbee-service/fastbee-rechargecard-service/src/main/java/com/fastbee/rechargecard/service/IUserWechatPayService.java
View File

@ -22,6 +22,10 @@ public interface IUserWechatPayService {
* @return * @return
*/ */
public Map<String,Object> GetOpenId(String code); public Map<String,Object> GetOpenId(String code);
/**
* 获取平台证书
*/
public String getPlatformCertificat();
} }

32
fastbee-service/fastbee-rechargecard-service/src/main/java/com/fastbee/rechargecard/service/impl/UserRechargeCardsServiceImpl.java
View File

@ -209,15 +209,15 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService
public int updateUserRecharge(RechargecardUser rechargecardUser){ public int updateUserRecharge(RechargecardUser rechargecardUser){
// 根据id查询用户充值卡信息 // 根据id查询用户充值卡信息
// UserRechargeCards info = userRechargeCardsMapper.selectUserRechargeCardsByCardnumber(String.valueOf(rechargecardUser.getCardNumber())); UserRechargeCards info = userRechargeCardsMapper.selectUserRechargeCardsByCardnumber(String.valueOf(rechargecardUser.getCardnumber()));
// if (info == null) { if (info == null) {
// // 如果没有找到对应的记录，返回0或者一个错误码 // 如果没有找到对应的记录，返回0或者一个错误码
// throw new ServiceException("卡号不存在！"); throw new ServiceException("卡号不存在！");
// } }
UserConsumptionDetails userConsumptionDetails=new UserConsumptionDetails(); UserConsumptionDetails userConsumptionDetails=new UserConsumptionDetails();
// userConsumptionDetails.setUserId(info.getUserId()); userConsumptionDetails.setUserId(info.getUserId());
// userConsumptionDetails.setCardNumber(info.getCardNumber()); userConsumptionDetails.setCardNumber(info.getCardNumber());
userConsumptionDetails.setCardNumber(String.valueOf(rechargecardUser.getCardnumber())); userConsumptionDetails.setCardNumber(String.valueOf(rechargecardUser.getCardnumber()));
userConsumptionDetails.setBillingType(0); userConsumptionDetails.setBillingType(0);
userConsumptionDetails.setAmountDue(rechargecardUser.getAmount()); userConsumptionDetails.setAmountDue(rechargecardUser.getAmount());
@ -241,21 +241,21 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService
.areaCode(rechargecardUser.getAreacode()) // 假设 getAreacode() 方法返回区域代码 .areaCode(rechargecardUser.getAreacode()) // 假设 getAreacode() 方法返回区域代码
.build();*/ .build();*/
NgUserRechargeRecords ngUserRechargeRecords=new NgUserRechargeRecords(); NgUserRechargeRecords ngUserRechargeRecords=new NgUserRechargeRecords();
// ngUserRechargeRecords.setUserId(info.getUserId()); ngUserRechargeRecords.setUserId(info.getUserId());
// ngUserRechargeRecords.setUserName(info.getUserName()); ngUserRechargeRecords.setUserName(info.getUserName());
// ngUserRechargeRecords.setCardNumber(info.getCardNumber()); ngUserRechargeRecords.setCardNumber(info.getCardNumber());
ngUserRechargeRecords.setCardNumber(String.valueOf(rechargecardUser.getCardnumber())); ngUserRechargeRecords.setCardNumber(String.valueOf(rechargecardUser.getCardnumber()));
ngUserRechargeRecords.setAreaCode(String.valueOf(rechargecardUser.getAreacode())); ngUserRechargeRecords.setAreaCode(String.valueOf(rechargecardUser.getAreacode()));
ngUserRechargeRecords.setType(rechargecardUser.getType()); ngUserRechargeRecords.setType(rechargecardUser.getType());
ngUserRechargeRecords.setAmount(rechargecardUser.getAmount()); ngUserRechargeRecords.setAmount(rechargecardUser.getAmount());
// ngUserRechargeRecords.setBalance(info.getBalance()); ngUserRechargeRecords.setBalance(info.getBalance());
ngUserRechargeRecords.setBalance(rechargecardUser.getAmount()); ngUserRechargeRecords.setBalance(rechargecardUser.getAmount());
ngUserRechargeRecords.setRechargeTime(DateUtils.getNowDate()); ngUserRechargeRecords.setRechargeTime(DateUtils.getNowDate());
ngUserRechargeRecords.setStatus(0); ngUserRechargeRecords.setStatus(0);
ngUserRechargeRecords.setAreaCode(String.valueOf(rechargecardUser.getAreacode())); ngUserRechargeRecords.setAreaCode(String.valueOf(rechargecardUser.getAreacode()));
ngUserRechargeRecords.setSerialNumber(rechargecardUser.getDeviceNumber()); ngUserRechargeRecords.setSerialNumber(rechargecardUser.getDeviceNumber());
// 计算新的余额 // 计算新的余额
// BigDecimal newBalance = rechargecardUser.getAmount().add(info.getBalance()); BigDecimal newBalance = rechargecardUser.getAmount().add(info.getBalance());
/* userConsumptionDetails.setCreateTime(DateUtils.getNowDate()); /* userConsumptionDetails.setCreateTime(DateUtils.getNowDate());
NgUserRechargeRecords ngUserRechargeRecords = NgUserRechargeRecords.builder() NgUserRechargeRecords ngUserRechargeRecords = NgUserRechargeRecords.builder()
@ -270,9 +270,9 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService
userRechargeRecordsMapper.insertNgUserRechargeRecords(ngUserRechargeRecords); userRechargeRecordsMapper.insertNgUserRechargeRecords(ngUserRechargeRecords);
userConsumptionDetailsMapper.insertUserConsumptionDetails(userConsumptionDetails); userConsumptionDetailsMapper.insertUserConsumptionDetails(userConsumptionDetails);
// 更新用户充值卡信息，包括新的余额 // 更新用户充值卡信息，包括新的余额
// info.setBalance(newBalance); info.setBalance(newBalance);
// info.setUpdateTime(DateUtils.getNowDate()); info.setUpdateTime(DateUtils.getNowDate());
// info.setAreaCode(String.valueOf(rechargecardUser.getAreaCode())); info.setAreaCode(String.valueOf(rechargecardUser.getAreacode()));
//构建主题 //构建主题
String topic ="hzlink/147/"+rechargecardUser.getDeviceNumber()+"/cmd/down"; String topic ="hzlink/147/"+rechargecardUser.getDeviceNumber()+"/cmd/down";
@ -289,7 +289,7 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService
param.put("data",data); param.put("data",data);
pubMqttClient.publish(1,true,topic, JSONUtil.toJsonStr(param)); pubMqttClient.publish(1,true,topic, JSONUtil.toJsonStr(param));
// int i = userRechargeCardsMapper.updateUserRechargeCards(info); int i = userRechargeCardsMapper.updateUserRechargeCards(info);
return 1; return 1;
} }
} }

12
fastbee-service/fastbee-rechargecard-service/src/main/java/com/fastbee/rechargecard/service/impl/UserWechatPayServiceImpl.java
View File

@ -237,4 +237,16 @@ public class UserWechatPayServiceImpl implements IUserWechatPayService {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} }
/**
* 获取平台证书
* @return
*/
@Override
public String getPlatformCertificat()
{
String url="https://api.mch.weixin.qq.com/v3/certificates";
return null;
}
} }