String sign =""; if( null != map.get("sign")){ sign = map.get("sign"); } log.info("买气退款回调参数"+map.toString()); String isRepeat = stringRedisTemplate.opsForValue().get((refundOrderNo+"repeat")); if(null == isRepeat || isRepeat.length() <= 0){ log.info("支付结束"); return null; }else{ stringRedisTemplate.delete((refundOrderNo+"repeat")); } Map<String,String> codeMap = MapUtil.newHashMap(); codeMap.put("serialNumber",outTradeNo); List<H5UserPayCode> list = h5UserPayCodeServiceImpl.byList(codeMap); H5UserPayCode payCode = list.get(0); payCode.setIsRefund(1); payCode.setRefundTime(LocalDateTime.now()); payCode.setRefundCode(refundOrderNo); if(h5UserPayCodeServiceImpl.updateById(payCode)) { stringRedisTemplate.delete(refundOrderNo); log.info("开始往稠州银行写数据-退款数据"); String tempUrl = platformConfig.getPayCzcb().getBaseUrl() + "gasbusiness/v2/orderRefund"; CzcbSFTRefundVO czcbSFTRefundVO = new CzcbSFTRefundVO(); czcbSFTRefundVO.setChannel_no(platformConfig.getPayCzcb().getChannelNo()); czcbSFTRefundVO.setApp_no(platformConfig.getPayCzcb().getAppNo()); String serialNo = SerialNoUtil.genSerialNo("OAC"); czcbSFTRefundVO.setSerial_no(serialNo); czcbSFTRefundVO.setOrder_no(payCode.getOrderCode()); // czcbSFTPayVO.setOrder_type("A"); DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); czcbSFTRefundVO.setRefund_time(dtf.format(payCode.getCreateTime())); czcbSFTRefundVO.setRefund_amount(new BigDecimal(payCode.getAmount()+"")); czcbSFTRefundVO.setOut_trade_no(payCode.getSerialNumber()); czcbSFTRefundVO.setOut_refund_no(refundOrderNo); czcbSFTRefundVO.setTrans_amount_1(BigDecimal.ZERO); czcbSFTRefundVO.setTrans_amount_2(BigDecimal.ZERO); czcbSFTRefundVO.setTrans_amount_3(new BigDecimal(payCode.getAmount()+"")); czcbSFTRefundVO.setRemark("盛付通订单支付退款"); //判断是正式还是测试 if ( SpringContextUtil.isProd() ) { czcbSFTRefundVO.setOpp_account_no("1010220406000001"); // czcbSFTRefundVO.setOpp_account_no("1010220214000003"); }else{ czcbSFTRefundVO.setOpp_account_no("1010220214000003"); } czcbSFTRefundVO.setOpp_account_name("义乌市城建燃气经营有限公司"); czcbSFTRefundVO.setTrans_amount_4(BigDecimal.ZERO); czcbSFTRefundVO.setTrans_amount_5(new BigDecimal(payCode.getAmount()+"")); czcbSFTRefundVO.setTrans_amount_6(BigDecimal.ZERO); // 操作日期 czcbSFTRefundVO.setTrans_date(DateTime.now().toString("yyyy-MM-dd")); // 操作时间 czcbSFTRefundVO.setTrans_tradetime(DateTime.now().toString("yyyy-MM-dd HH:mm:ss")); czcbSFTRefundVO.setSign_data(SignUtil.addSignMD5(BeanUtil.beanToMap(czcbSFTRefundVO), platformConfig.getPayCzcb().getKey())); log.info("开始往稠州银行写数据:" + JSON.toJSONString(czcbSFTRefundVO)); String result = HttpUtil.post(tempUrl, JSON.toJSONString(czcbSFTRefundVO)); log.info("开始往稠州银行写数据:" + result); if(isSuccess(result)){ log.info("开始往稠州银行写数据写入成功"); } } }catch(Exception ex){ ex.printStackTrace(); } return new R(200,"回调成功"); }
时间: 2023-03-27 07:02:07 浏览: 168
这是一段使用 Java 编写的代码。它的作用是执行退款操作,并将退款的相关信息写入稠州银行的系统。
具体来说,首先检查传入的参数中是否包含 "sign" 字段,如果包含就将其赋值给变量 "sign"。然后记录一条日志,内容为传入参数的内容。接下来,在 Redis 中检查是否存在与退款订单号对应的值,如果不存在或值为空,就直接返回 null。否则,就将 Redis 中的对应的值删除。
然后,使用传入的流水号从数据库中查询相关的记录,并将记录的退款状态更新为已退款。之后使用更新后的记录更新数据库中的相应记录,并在操作成功后将 Redis 中与退款订单号对应的值删除。
最后,使用从配置文件中读取的稠州银行的 URL 和相关参数,调用稠州银行的退款接口,并将相关信息写入稠州银行的系统中。
相关问题
翻译下面的Java代码: public Map<String, Object> signUp(HttpServletRequest request) throws IOException { // 查询用户 Map<String, String> query = new HashMap<>(); Map<String,Object> map = service.readBody(request.getReader()); query.put("username",String.valueOf(map.get("username"))); List list = service.selectBaseList(service.select(query, new HashMap<>())); if (list.size()>0){ return error(30000, "用户已存在"); } map.put("password",service.encryption(String.valueOf(map.get("password")))); service.insert(map); return success(1); } public Map<String,Object> readBody(BufferedReader reader){ BufferedReader br = null; StringBuilder sb = new StringBuilder(""); try{ br = reader; String str; while ((str = br.readLine()) != null){ sb.append(str); } br.close(); String json = sb.toString(); return JSONObject.parseObject(json, Map.class); }catch (IOException e){ e.printStackTrace(); }finally{ if (null != br){ try{ br.close(); }catch (IOException e){ e.printStackTrace(); } } } return null; } public void insert(Map<String,Object> body){ E entity = JSON.parseObject(JSON.toJSONString(body),eClass); baseMapper.insert(entity); log.info("[{}] - 插入操作:{}",entity); }
这段 Java 代码是一个用户注册的方法,它接受一个 HttpServletRequest 对象作为参数,返回一个 Map 对象。
该方法首先调用了 `readBody` 方法,将请求中的 JSON 格式的参数解析成一个 Map 对象。然后它从这个 Map 对象中取出用户名,查询数据库,如果用户已经存在,则返回一个包含错误信息的 Map 对象;否则,它会对用户的密码进行加密,将加密后的密码存入 Map 对象,并将该 Map 对象插入到数据库中。最后,该方法返回一个包含成功信息的 Map 对象。
`readBody` 方法是一个私有方法,它接受一个 `BufferedReader` 对象作为参数,返回一个 Map 对象。该方法首先将 `BufferedReader` 对象转换为字符串,然后使用 `JSONObject` 类将字符串解析成一个 Map 对象,并返回该对象。
`insert` 方法是一个私有方法,它接受一个 Map 对象作为参数,将该对象转换成实体对象并插入到数据库中。该方法使用了 `JSON` 类将 Map 对象转换为实体对象。在插入成功后,该方法会输出一条日志。
当前已知URL地址为“www.test.com”。 token生成方式为该代码段: private String buildToken( String currentTeamMemberName,String userId) { Map<String, String> kv = new LinkedHashMap<>(); kv.put("userId", userId); kv.put("currentTeamMemberName",currentTeamMemberName); kv.put("salt", "salt"); String signature = Sha1Crypto.encode(JsonHelper.getInstance().write(kv)); kv.remove("salt"); kv.put("signature", signature); kv.put("ts", System.currentTimeMillis()+""); String offset = Configuration.getInstance().getProperty("indicatorPlatformOffset"); if(offset == null || offset.trim().length() == 0){ offset = 1000 * 60 * 5 + ""; } kv.put("offset", offset); String token = JsonHelper.getInstance().write(kv);//Map转JSON String base64Token = Base64Codec.encode(token);//base64编码 return base64Token; } 需要编写一个接口,已知参数为userId(单点账户),currentTeamMemberName(账号所属团队的成员名称),offset(偏移量)值为300000; 接口将生成的token添加到cookie中,请求已知的URL地址,供其进行校验。 其地址的校验方法为: private boolean checkRefererTokenStr(String tokenStr) { try{ Map token = JsonHelper.getInstance().read(Base64Codec.decode(tokenStr), Map.class); String userId = (String) token.get("userId"); Map<String, String> signChecker = new LinkedHashMap<>(); signChecker.put("userId", userId); signChecker.put(CURRENT_TEAM_MEMBER_NAME, token.get(CURRENT_TEAM_MEMBER_NAME).toString()); signChecker.put("salt", "salt"); String sign = Sha1Crypto.encode(JsonHelper.getInstance().write(signChecker)); return sign.equals(token.get("signature")); }catch (Exception e){ log.error("验证单点集成页面请求referer失败!", e); } return false; } 请编写接口实现该需求
以下是一个简单的Java实现,可以作为一个Servlet或者Spring MVC Controller来使用:
```java
import java.io.IOException;
import java.util.LinkedHashMap;
import java.util.Map;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class TokenController {
private static final String CURRENT_TEAM_MEMBER_NAME = "currentTeamMemberName";
@RequestMapping("/generateToken")
public String generateToken(HttpServletRequest request, HttpServletResponse response,
@RequestParam("userId") String userId,
@RequestParam("currentTeamMemberName") String currentTeamMemberName,
@RequestParam(value = "offset", defaultValue = "300000") long offset) {
Map<String, String> kv = new LinkedHashMap<>();
kv.put("userId", userId);
kv.put(CURRENT_TEAM_MEMBER_NAME, currentTeamMemberName);
kv.put("salt", "salt");
String signature = Sha1Crypto.encode(JsonHelper.getInstance().write(kv));
kv.remove("salt");
kv.put("signature", signature);
kv.put("ts", System.currentTimeMillis() + "");
kv.put("offset", offset + "");
String token = JsonHelper.getInstance().write(kv);
String base64Token = Base64Codec.encode(token);
Cookie cookie = new Cookie("token", base64Token);
cookie.setPath("/");
response.addCookie(cookie);
return "Token generated successfully!";
}
@RequestMapping("/validateToken")
public String validateToken(HttpServletRequest request, HttpServletResponse response) {
Cookie[] cookies = request.getCookies();
if (cookies != null) {
for (Cookie cookie : cookies) {
if (cookie.getName().equals("token")) {
String base64Token = cookie.getValue();
String token = Base64Codec.decode(base64Token);
if (checkRefererTokenStr(token)) {
return "Token is valid!";
} else {
return "Token is invalid!";
}
}
}
}
return "Token not found!";
}
private boolean checkRefererTokenStr(String tokenStr) {
try {
Map<String, Object> token = JsonHelper.getInstance().read(Base64Codec.decode(tokenStr), Map.class);
String userId = (String) token.get("userId");
Map<String, String> signChecker = new LinkedHashMap<>();
signChecker.put("userId", userId);
signChecker.put(CURRENT_TEAM_MEMBER_NAME, token.get(CURRENT_TEAM_MEMBER_NAME).toString());
signChecker.put("salt", "salt");
String sign = Sha1Crypto.encode(JsonHelper.getInstance().write(signChecker));
return sign.equals(token.get("signature"));
} catch (Exception e) {
log.error("验证单点集成页面请求referer失败!", e);
}
return false;
}
}
```
这里使用了Spring MVC的注解来定义了两个接口:`/generateToken` 和 `/validateToken`,其中 `/generateToken` 接受三个参数:`userId`、`currentTeamMemberName` 和 `offset`,并生成一个token添加到Cookie中;`/validateToken` 从Cookie中读取token,并验证其有效性。
为了简化代码,这里使用了一些第三方库,你需要在项目中添加这些库的依赖:
- org.springframework:spring-web
- com.fasterxml.jackson.core:jackson-core
- com.fasterxml.jackson.core:jackson-databind
- org.apache.commons:commons-lang3
阅读全文