liuc/biz_service_ebtp_extend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

区块链调用

Browse Source
This commit is contained in:
zhangqinbin
2021-09-01 14:00:03 +08:00
parent 0dc021ef7f
commit 08acacf59c
2 changed files with 29 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/chinaunicom/mall/ebtp/extend/crypconfigure/entity/CrypBean.java
View File

@ -10,7 +10,12 @@ import lombok.Data;
*/
@Data
public class CrypBean {
/**
* 能力req名称
* BIDDING_PUBLISH_REQ 发标
*/
@ApiModelProperty(value = "能力req名称")
public String reqName;
/**
* 签名
*/

37
src/main/java/com/chinaunicom/mall/ebtp/extend/crypconfigure/service/impl/CrypConfigureServiceImpl.java
View File

@ -5,15 +5,14 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.chinaunicom.baas.util.AccessToken;
import com.chinaunicom.mall.ebtp.common.base.service.IBaseCacheUserService;
import com.chinaunicom.mall.ebtp.common.base.service.impl.BaseServiceImpl;
import com.chinaunicom.mall.ebtp.common.constant.CommonConstants;
import com.chinaunicom.mall.ebtp.common.crypto.service.CrypServiceImpl;
import com.chinaunicom.mall.ebtp.common.exception.common.CommonExceptionEnum;
import com.chinaunicom.mall.ebtp.common.uniBss.constant.UniBssConstant;
import com.chinaunicom.mall.ebtp.common.uniBss.entity.UniBss;
import com.chinaunicom.mall.ebtp.common.uniBss.entity.UniBssAttached;
import com.chinaunicom.mall.ebtp.common.uniBss.entity.UniBssBody;
import com.chinaunicom.mall.ebtp.common.uniBss.entity.UniBssHead;
import com.chinaunicom.mall.ebtp.common.uniBss.entity.*;
import com.chinaunicom.mall.ebtp.common.uniBss.service.UniBssServiceImpl;
import com.chinaunicom.mall.ebtp.common.util.PropertyUtils;
import com.chinaunicom.mall.ebtp.extend.blockchain.entity.BlockChainLog;
@ -26,7 +25,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
@ -46,6 +44,9 @@ public class CrypConfigureServiceImpl extends BaseServiceImpl<CrypConfigureMappe
@Autowired
private IBlockChainLogService iBlockChainLogService;
private @Autowired
IBaseCacheUserService service;
@Value("${mconfig.bss.app-id}")
private String app_id;
@Value("${mconfig.bss.app-secret}")
@ -63,15 +64,14 @@ public class CrypConfigureServiceImpl extends BaseServiceImpl<CrypConfigureMappe
//天擎地址
log.setInterfaceUrl(bean.getUrl());
try {
//传入数据解密
String sign = getSignValue(bean.getObject());
Map<String, String> map = JSONArray.parseObject(JSONArray.toJSONString(bean.getObject()), Map.class);
Map<String, Object> map = JSONArray.parseObject(JSONArray.toJSONString(bean.getObject()), Map.class);
map.put("sign", sign);
String json = getUniBss(map);
String json = getUniBss(bean.getReqName(),map);
log.setResult("天擎接口调用，地址："+bean.getUrl()+",参数："+json);//日志
log.setParam(json);
@ -147,7 +147,7 @@ public class CrypConfigureServiceImpl extends BaseServiceImpl<CrypConfigureMappe
* @param map
* @return
*/
private String getUniBss(Map<String,String> map){
private String getUniBss(String reqName,Map<String,Object> map){
//获取token
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");
@ -158,7 +158,7 @@ public class CrypConfigureServiceImpl extends BaseServiceImpl<CrypConfigureMappe
String token = MD5min(s);
UniBss uniBss = new UniBss();
uniBss.setUniBssAttached(new UniBssAttached().setMediaInf(""));
//天擎部分head
UniBssHead head = new UniBssHead();
head.setAppId(app_id);
head.setTimeStamp(TIMESTAMP);
@ -166,10 +166,20 @@ public class CrypConfigureServiceImpl extends BaseServiceImpl<CrypConfigureMappe
head.setToken(token);
uniBss.setUniBssHead(head);
UniBssBody body = new UniBssBody();
body.setSingleOrderQryReq(map);
UniReqHead reqhead = new UniReqHead();
uniBss.setUniBssBody(body);
reqhead.setSystemId("990001");
reqhead.setSystemName("bidding");
reqhead.setUserId(service.getCacheUser().getUserId());
reqhead.setUserId(service.getCacheUser().getFullName());
reqhead.setAccessToken(AccessToken.tokenCreate());
UniCrpyReq req = new UniCrpyReq();
req.setBody(map);
Map reqMap = new HashMap();
reqMap.put(reqName,req);
uniBss.setUniBssBodyMap(reqMap);
return JSON.toJSONString(uniBss);
}
@ -200,7 +210,6 @@ public class CrypConfigureServiceImpl extends BaseServiceImpl<CrypConfigureMappe
}
return false;
}
}