|
@@ -2182,7 +2182,7 @@ public class SupplyChainController extends BaseController {
|
|
@PostMapping(value = "/mgsAccept")
|
|
@PostMapping(value = "/mgsAccept")
|
|
public Map<String, Object> mgsAccept(@RequestBody String eventsEncoded) {
|
|
public Map<String, Object> mgsAccept(@RequestBody String eventsEncoded) {
|
|
try {
|
|
try {
|
|
- logger.info("RX食品消息订阅");
|
|
|
|
|
|
+ logger.info("止水优选消息订阅");
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, mgsPrivateKey);
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, mgsPrivateKey);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
fxNowService.submit(new Runnable() {
|
|
fxNowService.submit(new Runnable() {
|
|
@@ -2249,7 +2249,7 @@ public class SupplyChainController extends BaseController {
|
|
@PostMapping(value = "/dfcAccept")
|
|
@PostMapping(value = "/dfcAccept")
|
|
public Map<String, Object> dfcAccept(@RequestBody String eventsEncoded) {
|
|
public Map<String, Object> dfcAccept(@RequestBody String eventsEncoded) {
|
|
try {
|
|
try {
|
|
- logger.info("大风车严选消息订阅");
|
|
|
|
|
|
+ logger.info("佰川心选消息订阅");
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, dfcPrivateKey);
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, dfcPrivateKey);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
fxNowService.submit(new Runnable() {
|
|
fxNowService.submit(new Runnable() {
|
|
@@ -2283,10 +2283,9 @@ public class SupplyChainController extends BaseController {
|
|
@PostMapping(value = "/mgsAccept2")
|
|
@PostMapping(value = "/mgsAccept2")
|
|
public Map<String, Object> mgsAccept2(@RequestBody String eventsEncoded) {
|
|
public Map<String, Object> mgsAccept2(@RequestBody String eventsEncoded) {
|
|
try {
|
|
try {
|
|
- logger.info("RX食品-二团严选消息订阅");
|
|
|
|
|
|
+ logger.info("RX食品消息订阅");
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, mgsPrivateKey2);
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, mgsPrivateKey2);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
- logger.info("二团返回信息:{}", eventJSon);
|
|
|
|
fxNowService.submit(new Runnable() {
|
|
fxNowService.submit(new Runnable() {
|
|
@Override
|
|
@Override
|
|
public void run() {
|
|
public void run() {
|
|
@@ -2318,10 +2317,9 @@ public class SupplyChainController extends BaseController {
|
|
@PostMapping(value = "/yufuAccept")
|
|
@PostMapping(value = "/yufuAccept")
|
|
public Map<String, Object> yufuAccept(@RequestBody String eventsEncoded) {
|
|
public Map<String, Object> yufuAccept(@RequestBody String eventsEncoded) {
|
|
try {
|
|
try {
|
|
- logger.info("渔夫睿选消息订阅");
|
|
|
|
|
|
+ logger.info("雪峰优选消息订阅");
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, yufuPrivateKey);
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, yufuPrivateKey);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
- logger.info("渔夫睿选返回信息:{}", eventJSon);
|
|
|
|
fxNowService.submit(new Runnable() {
|
|
fxNowService.submit(new Runnable() {
|
|
@Override
|
|
@Override
|
|
public void run() {
|
|
public void run() {
|
|
@@ -2357,7 +2355,6 @@ public class SupplyChainController extends BaseController {
|
|
logger.info("毓秀优选消息订阅");
|
|
logger.info("毓秀优选消息订阅");
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, yuXiuPrivateKey);
|
|
String events = PlatformEventSecurityUtil.decode(eventsEncoded, yuXiuPrivateKey);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
JSONObject eventJSon = JSONObject.parseObject(events);
|
|
- logger.info("毓秀优选返回信息:{}", eventJSon);
|
|
|
|
fxNowService.submit(new Runnable() {
|
|
fxNowService.submit(new Runnable() {
|
|
@Override
|
|
@Override
|
|
public void run() {
|
|
public void run() {
|