czg_team/cashier-client
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/hph' into dev

Browse Source
This commit is contained in:
SongZhang
2024-07-11 11:33:39 +08:00
parent 61fe12c087 707f846af0
commit 2818f8afff
2 changed files with 76 additions and 62 deletions
Download Patch File Download Diff File Expand all files Collapse all files

128
src/main/java/com/chaozhanggui/system/cashierservice/rabbit/ConsMsgConsumer.java
View File

@@ -69,6 +69,8 @@ public class ConsMsgConsumer {
@RabbitHandler @RabbitHandler
public void listener(String message) { public void listener(String message) {
log.info("耗材即将售罄提醒:{}",message);
JSONObject object = JSONObject.parseObject(message); JSONObject object = JSONObject.parseObject(message);
if (Objects.isNull(object) || !object.containsKey("skuId") || !object.containsKey("shopId") || Objects.isNull(object.getInteger("skuId")) || Objects.isNull(object.getInteger("shopId"))) { if (Objects.isNull(object) || !object.containsKey("skuId") || !object.containsKey("shopId") || Objects.isNull(object.getInteger("skuId")) || Objects.isNull(object.getInteger("shopId"))) {
log.info("接收的信息为空"); log.info("接收的信息为空");
@@ -107,19 +109,25 @@ public class ConsMsgConsumer {
tbProskuCons.parallelStream().forEach(it -> { tbProskuCons.parallelStream().forEach(it -> {
TbConsInfo tbConsInfo = tbConsInfoMapper.selectByPrimaryKey(it.getConInfoId()); TbConsInfo tbConsInfo = tbConsInfoMapper.selectByPrimaryKey(it.getConInfoId());
if (Objects.isNull(tbConsInfo)) { if (Objects.isNull(tbConsInfo)) {
log.info("耗材信息不存在");
return; return;
} }
if (Objects.nonNull(tbConsInfo)) { log.info("conwarning:{},stockNumber:{}",tbConsInfo.getConWarning(),tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume()).abs());
if (N.gt(tbConsInfo.getConWarning(), tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume()).abs())) {
if (N.gt(tbConsInfo.getConWarning(), tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume()).abs())) {
String key = redisUtil.getMessage(RedisCst.ORDER_MESSAGE.concat(tbConsInfo.getShopId().toString()).concat("#").concat(tbConsInfo.getId().toString()));
if (Objects.isNull(key)) { List<TbUserShopMsg> tbUserShopMsgs = tbUserShopMsgMapper.selectAllByShopId(tbConsInfo.getShopId());
List<TbUserShopMsg> tbUserShopMsgs = tbUserShopMsgMapper.selectAllByShopId(tbConsInfo.getShopId()); if (Objects.nonNull(tbUserShopMsgs) && tbUserShopMsgs.size()>0) {
if (Objects.nonNull(tbUserShopMsgs) && tbUserShopMsgs.size()>0) {
for (TbUserShopMsg tbUserShopMsg : tbUserShopMsgs) {
tbUserShopMsgs.parallelStream().forEach(tbUserShopMsg->{
String key=RedisCst.ORDER_MESSAGE.concat(tbConsInfo.getShopId().toString()).concat("#").concat(tbConsInfo.getId().toString()).concat("#").concat(tbUserShopMsg.getOpenId());
String value = redisUtil.getMessage(key);
log.info("redis_key:{}",value);
if (Objects.isNull(value)) {
JSONObject access_token = getAccessToken(); JSONObject access_token = getAccessToken();
String accessToken = String.valueOf(access_token.get("access_token")); String accessToken = String.valueOf(access_token.get("access_token"));
@@ -138,11 +146,11 @@ public class ConsMsgConsumer {
thing5.put("value", "耗材库存不足，请及时补充。"); thing5.put("value", "耗材库存不足，请及时补充。");
JSONObject thing6 = new JSONObject(); JSONObject thing6 = new JSONObject();
thing6.put("value", product.getName()); thing6.put("value", tbConsInfo.getConName());
JSONObject thing7 = new JSONObject(); JSONObject thing7 = new JSONObject();
thing7.put("value", tbConsInfo.getStockNumber().toPlainString()); thing7.put("value", tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume()).toPlainString());
data.put("thing1", thing1); data.put("thing1", thing1);
data.put("thing6", thing6); data.put("thing6", thing6);
@@ -155,21 +163,17 @@ public class ConsMsgConsumer {
object1.put("lang", "zh_CN"); object1.put("lang", "zh_CN");
String response = HttpRequest.post("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=".concat(accessToken)).body(object1.toString()).execute().body(); String response = HttpRequest.post("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=".concat(accessToken)).body(object1.toString()).execute().body();
log.info("返回结果:{}", response); log.info("openId:{},返回结果:{}",tbUserShopMsg.getOpenId(), response);
JSONObject resObj = JSONObject.parseObject(response); JSONObject resObj = JSONObject.parseObject(response);
if (ObjectUtil.isNotEmpty(resObj) && ObjectUtil.isNotNull(resObj) && "0".equals(String.valueOf(resObj.get("errcode")))) { if (ObjectUtil.isNotEmpty(resObj) && ObjectUtil.isNotNull(resObj) && "0".equals(String.valueOf(resObj.get("errcode")))) {
redisUtil.saveMessage(key, object1.toString(),10*60*1000); log.info("写入redis:{}",key);
redisUtil.saveMessage(key, object1.toString(), 10 * 60 * 1000);
} }
} }
});
}
} }
} }
}
}); });
} }
@@ -231,51 +235,51 @@ public class ConsMsgConsumer {
} }
public static void main(String[] args){ public static void main(String[] args){
//
List<MsgInfo> list=new ArrayList<>(); // List<MsgInfo> list=new ArrayList<>();
//
list.add(new MsgInfo("oeQYq5KEjN1-laurB3oRbqEllVzs","双屿Pisces","茄汁肉酱意面",new BigDecimal(24))); // list.add(new MsgInfo("oeQYq5KEjN1-laurB3oRbqEllVzs","双屿Pisces","茄汁肉酱意面",new BigDecimal(24)));
list.add(new MsgInfo("oeQYq5KEjN1-laurB3oRbqEllVzs","森食界创意轻食(未央店)","番茄鸳鸯锅",new BigDecimal(36))); // list.add(new MsgInfo("oeQYq5KEjN1-laurB3oRbqEllVzs","森食界创意轻食(未央店)","番茄鸳鸯锅",new BigDecimal(36)));
//
for (MsgInfo msgInfo : list) { // for (MsgInfo msgInfo : list) {
JSONObject access_token = new ConsMsgConsumer().getAccessToken1(); // JSONObject access_token = new ConsMsgConsumer().getAccessToken1();
String accessToken = String.valueOf(access_token.get("access_token")); // String accessToken = String.valueOf(access_token.get("access_token"));
//
JSONObject object1 = new JSONObject(); // JSONObject object1 = new JSONObject();
//
object1.put("template_id", "IZ-l9p9yBgcvhRR0uN6cBQPkWJ5i05zyWMkfeCPaAmY"); // object1.put("template_id", "IZ-l9p9yBgcvhRR0uN6cBQPkWJ5i05zyWMkfeCPaAmY");
object1.put("touser", msgInfo.getOpenId()); // object1.put("touser", msgInfo.getOpenId());
//
//
JSONObject data = new JSONObject(); // JSONObject data = new JSONObject();
//
JSONObject thing1 = new JSONObject(); // JSONObject thing1 = new JSONObject();
thing1.put("value", msgInfo.getShopName()); // thing1.put("value", msgInfo.getShopName());
//
JSONObject thing5 = new JSONObject(); // JSONObject thing5 = new JSONObject();
thing5.put("value", "耗材库存不足，请及时补充。"); // thing5.put("value", "耗材库存不足，请及时补充。");
//
JSONObject thing6 = new JSONObject(); // JSONObject thing6 = new JSONObject();
thing6.put("value", msgInfo.getProductName()); // thing6.put("value", msgInfo.getProductName());
//
//
JSONObject thing7 = new JSONObject(); // JSONObject thing7 = new JSONObject();
thing7.put("value", msgInfo.getAmount().toPlainString()); // thing7.put("value", msgInfo.getAmount().toPlainString());
//
data.put("thing1", thing1); // data.put("thing1", thing1);
data.put("thing6", thing6); // data.put("thing6", thing6);
data.put("number7", thing7); // data.put("number7", thing7);
data.put("thing5", thing5); // data.put("thing5", thing5);
//
object1.put("data", data); // object1.put("data", data);
//
object1.put("miniprogram_state", "formal"); // object1.put("miniprogram_state", "formal");
object1.put("lang", "zh_CN"); // object1.put("lang", "zh_CN");
//
String response = HttpRequest.post("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=".concat(accessToken)).body(object1.toString()).execute().body(); // String response = HttpRequest.post("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=".concat(accessToken)).body(object1.toString()).execute().body();
log.info("返回结果:{}", response); // log.info("返回结果:{}", response);
JSONObject resObj = JSONObject.parseObject(response); // JSONObject resObj = JSONObject.parseObject(response);
} // }
} }

10
src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java
View File

@@ -862,10 +862,20 @@ public class PayService {
}else if("deposit".equals(payType)){ }else if("deposit".equals(payType)){
TbShopUser user= tbShopUserMapper.selectByUserIdAndShopId(orderInfo.getUserId(),orderInfo.getShopId()); TbShopUser user= tbShopUserMapper.selectByUserIdAndShopId(orderInfo.getUserId(),orderInfo.getShopId());
if(ObjectUtil.isNull(user)||ObjectUtil.isEmpty(user)){
user=tbShopUserMapper.selectByPrimaryKey(Integer.valueOf(orderInfo.getMemberId()));
}
if(ObjectUtil.isNull(user)||ObjectUtil.isEmpty(user)){ if(ObjectUtil.isNull(user)||ObjectUtil.isEmpty(user)){
return Result.fail(ACCOUNTEIXST); return Result.fail(ACCOUNTEIXST);
} }
if(!user.getShopId().equals(orderInfo.getShopId())){
return Result.fail(ACCOUNTEIXST);
}
newOrderInfo.setMemberId(orderInfo.getMemberId()); newOrderInfo.setMemberId(orderInfo.getMemberId());
newOrderInfo.setUserId(orderInfo.getUserId()); newOrderInfo.setUserId(orderInfo.getUserId());