czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更新

Browse Source
This commit is contained in:
wangw
2026-01-09 17:06:44 +08:00
parent 0513cd5e65
commit 9b74b38799
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cash-api/order-server/src/main/java/com/czg/mq/EntryManagerMqListener.java
View File

@@ -10,6 +10,7 @@ import com.czg.order.entity.ShopDirectMerchant;
import com.czg.service.RedisService; import com.czg.service.RedisService;
import com.czg.service.order.dto.AggregateMerchantVO; import com.czg.service.order.dto.AggregateMerchantVO;
import com.czg.service.order.service.ShopDirectMerchantService; import com.czg.service.order.service.ShopDirectMerchantService;
import com.mybatisflex.core.query.QueryWrapper;
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Channel;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -86,8 +87,6 @@ public class EntryManagerMqListener {
} }
EntryRespDto resp = EntryManager.entryMerchant(entry, platform.toArray(new String[0])); EntryRespDto resp = EntryManager.entryMerchant(entry, platform.toArray(new String[0]));
ShopDirectMerchant merchant = new ShopDirectMerchant(); ShopDirectMerchant merchant = new ShopDirectMerchant();
merchant.setShopId(entry.getShopId());
merchant.setWechatApplyId(resp.getWechatApplyId()); merchant.setWechatApplyId(resp.getWechatApplyId());
merchant.setWechatStatus(resp.getWechatStatus()); merchant.setWechatStatus(resp.getWechatStatus());
merchant.setWechatErrorMsg(resp.getWechatErrorMsg()); merchant.setWechatErrorMsg(resp.getWechatErrorMsg());
@@ -96,17 +95,16 @@ public class EntryManagerMqListener {
merchant.setAlipayStatus(resp.getAlipayStatus()); merchant.setAlipayStatus(resp.getAlipayStatus());
merchant.setAlipayAuthInfo(resp.getAlipayAuthInfo()); merchant.setAlipayAuthInfo(resp.getAlipayAuthInfo());
merchant.setAlipayErrorMsg(resp.getAlipayErrorMsg()); merchant.setAlipayErrorMsg(resp.getAlipayErrorMsg());
shopDirectMerchantService.updateById(merchant); shopDirectMerchantService.update(merchant, new QueryWrapper().eq(ShopDirectMerchant::getShopId, shopId).eq(ShopDirectMerchant::getLicenceNo, split[1]));
} }
channel.basicAck(deliveryTag, false); channel.basicAck(deliveryTag, false);
} catch (Exception e) { } catch (Exception e) {
log.error("进件MQ对接业务异常shopId:{}", msg, e); log.error("进件MQ对接业务异常shopId:{}", msg, e);
ShopDirectMerchant merchant = new ShopDirectMerchant(); ShopDirectMerchant merchant = new ShopDirectMerchant();
merchant.setShopId(shopId);
merchant.setWechatStatus(PayCst.EntryStatus.REJECTED); merchant.setWechatStatus(PayCst.EntryStatus.REJECTED);
merchant.setAlipayStatus(PayCst.EntryStatus.REJECTED); merchant.setAlipayStatus(PayCst.EntryStatus.REJECTED);
merchant.setErrorMsg("系统错误，请联系管理员后重试。"); merchant.setErrorMsg("系统错误，请联系管理员后重试。");
shopDirectMerchantService.updateById(merchant); shopDirectMerchantService.update(merchant, new QueryWrapper().eq(ShopDirectMerchant::getShopId, shopId).eq(ShopDirectMerchant::getLicenceNo, split[1]));
channel.basicNack(deliveryTag, false, false); channel.basicNack(deliveryTag, false, false);
} finally { } finally {
delMessageId(msg); delMessageId(msg);