package com.iotechn.unimall.runner.controller;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.dobbinsoft.fw.support.component.open.OpenPlatformUtil;
|
import com.iotechn.unimall.biz.client.erp.ErpClient;
|
import com.iotechn.unimall.data.dto.ErpStockNotifyDTO;
|
import com.iotechn.unimall.data.dto.ErpStockNotifyItemDTO;
|
import com.iotechn.unimall.data.properties.UnimallErpOpenPlatformProperties;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* Created by rize on 2019/7/10.
|
*/
|
@RestController
|
@RequestMapping("/cb")
|
public class CallbackController {
|
|
@Autowired
|
private UnimallErpOpenPlatformProperties unimallErpOpenPlatformProperties;
|
|
@Autowired
|
private ErpClient erpClient;
|
|
@RequestMapping("/erp/stock")
|
@Transactional(rollbackFor = Exception.class)
|
public Object stock(@RequestBody String body) throws Exception {
|
JSONObject jsonObject = JSONObject.parseObject(body);
|
String ciphertext = jsonObject.getString("ciphertext");
|
// 验签
|
String publicKey = unimallErpOpenPlatformProperties.getDobbinServerPublicKey();
|
Map<String, String> map = OpenPlatformUtil.parseAndCheckSign(ciphertext, publicKey);
|
String notify = map.get("notify");
|
// 编辑库存
|
ErpStockNotifyDTO erpStockNotifyDTO = JSONObject.parseObject(notify, ErpStockNotifyDTO.class);
|
List<ErpStockNotifyItemDTO> items = erpStockNotifyDTO.getItems();
|
for (ErpStockNotifyItemDTO item : items) {
|
erpClient.invokeStockChange(item.getBarCode(), item.getQuantity());
|
}
|
return "ok";
|
}
|
|
}
|
