|
|
@@ -9,6 +9,7 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
|
+import java.util.List;
|
|
|
import java.util.Map;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
@@ -29,17 +30,25 @@ public class Kd100Controller {
|
|
|
@Autowired
|
|
|
RedisTemplate redisTemplate;
|
|
|
|
|
|
- @GetMapping("/test") @PostMapping("/queryExpres")
|
|
|
+ @PostMapping("/queryExpres")
|
|
|
public AjaxResult queryExpres(@RequestBody Map param) {
|
|
|
try {
|
|
|
logger.info("调用快递100查询实时快递接口 运单号: {}", param.get("number"));
|
|
|
- param.put("resultv2","1");
|
|
|
+ param.put("resultv2","4");
|
|
|
Object redisResult= redisTemplate.opsForValue().get(param.get("number"));
|
|
|
if(redisResult==null){
|
|
|
String result = kuaidi100Service.queryExpress(param);
|
|
|
ObjectMapper objectMapper = new ObjectMapper();
|
|
|
Map<String, Object> map = objectMapper.readValue(result, Map.class);
|
|
|
if("ok".equals(map.get("message"))){
|
|
|
+ //通过返回的公司编码返回物流公司名称
|
|
|
+ List<Map<String,Object>> comList=kuaidi100Service.getComList(map.get("com").toString());
|
|
|
+ if(comList.size()!=0){
|
|
|
+ map.put("compamyName",comList.get(0).get("company_name"));
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ map.put("compamyName",null);
|
|
|
+ }
|
|
|
redisTemplate.opsForValue().set(param.get("number"), map, 30, TimeUnit.MINUTES);;
|
|
|
return AjaxResult.success(map);
|
|
|
}
|
|
|
@@ -55,4 +64,44 @@ public class Kd100Controller {
|
|
|
|
|
|
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ @PostMapping("/queryExpresPlus")
|
|
|
+ public AjaxResult queryExpresPlus(@RequestBody Map param) {
|
|
|
+ try {
|
|
|
+ logger.info("调用快递100查询实时快递接口 运单号: {}", param.get("number"));
|
|
|
+ param.put("resultv2","4");
|
|
|
+ Object redisResult= redisTemplate.opsForValue().get(param.get("number"));
|
|
|
+ if(redisResult==null){
|
|
|
+ String result = kuaidi100Service.queryExpresPlus(param);
|
|
|
+ ObjectMapper objectMapper = new ObjectMapper();
|
|
|
+ Map<String, Object> map = objectMapper.readValue(result, Map.class);
|
|
|
+ if("ok".equals(map.get("message"))){
|
|
|
+ //通过返回的公司编码返回物流公司名称
|
|
|
+ List<Map<String,Object>> comList=kuaidi100Service.getComList(map.get("com").toString());
|
|
|
+ if(comList.size()!=0){
|
|
|
+ map.put("compamyName",comList.get(0).get("company_name"));
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ map.put("compamyName",null);
|
|
|
+ }
|
|
|
+ redisTemplate.opsForValue().set(param.get("number"), map, 30, TimeUnit.MINUTES);;
|
|
|
+ return AjaxResult.success(map);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ return AjaxResult.error(map.get("message").toString());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return AjaxResult.success(redisResult);
|
|
|
+ } catch (Exception e) {
|
|
|
+ return AjaxResult.error("快递100查寻接口异常! 原因:{}" ,e.getMessage());
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
}
|