Просмотр исходного кода

[车流][新增]:车流缴费回调,添加tenantId填充逻辑

release_toaliyun_real
Stormeye Wu 7 лет назад
Родитель
Сommit
675d45cdae
5 измененных файлов: 41 добавлений и 13 удалений
  1. +8
    -1
      mallinkAdmin/src/main/java/com/iformall/controller/WxCarCallBackController.java
  2. +2
    -0
      mallinkService/src/main/java/com/iformall/mapper/WxCarCmdLogMapper.java
  3. +19
    -9
      mallinkService/src/main/java/com/iformall/service/WxCarCmdLogService.java
  4. +7
    -1
      mallinkService/src/main/java/com/iformall/service/impl/WxCarCmdLogServiceImpl.java
  5. +5
    -2
      mallinkService/src/main/resources/mapper/WxCarCmdLogMapper.xml

+ 8
- 1
mallinkAdmin/src/main/java/com/iformall/controller/WxCarCallBackController.java Просмотреть файл

@@ -228,10 +228,17 @@ public class WxCarCallBackController extends BaseController {
logger.info("["+getIpAddr()+"etcpPaidCallback: " + paramMap.toString());
String carNumber = paramMap.get("plateNumber");

// TODO how to get the parkId
// 根据orderId获取入场信息,确定租户ID
String orderId = paramMap.get("orderId");
HashMap<String, String> map = new HashMap<String, String>();
map.put("synId", orderId);
String tenant_id = wxCarCmdLogService.getTenantIdBySynId(map);

Date currentDate = new Date();
WxCarCmdLog wxCarCmdLog = new WxCarCmdLog();
if(StringUtils.isNotBlank(tenant_id)) {
wxCarCmdLog.setTenantId(tenant_id);
}
wxCarCmdLog.setVendorType(EnumCarVendor.CAR_ETCP.getCode());
wxCarCmdLog.setCmdType(EnumCarCmd.CAR_ETCP_CALLBACK_PAY_MANUAL.getCode());
wxCarCmdLog.setCmdJson(JSON.toJSONString(paramMap));


+ 2
- 0
mallinkService/src/main/java/com/iformall/mapper/WxCarCmdLogMapper.java Просмотреть файл

@@ -23,4 +23,6 @@ public interface WxCarCmdLogMapper extends CommonMapper<WxCarCmdLog, Long> {

List<Map<String,Object>> queryPlateNumberList(Map<String,Object> carParams);

String queryTenantIdBySynId(HashMap<String,String> params);

}

+ 19
- 9
mallinkService/src/main/java/com/iformall/service/WxCarCmdLogService.java Просмотреть файл

@@ -3,14 +3,16 @@ package com.iformall.service;
import com.github.pagehelper.PageInfo;
import com.iformall.domain.po.WxCarCmdLog;

import java.util.HashMap;

public interface WxCarCmdLogService {

/**
* 根据实体查询分页列表
*
* @param record
* @param offset
* @param limit
* @param pageIndex
* @param pageSize
* @return
*/
PageInfo<WxCarCmdLog> listAsPage(WxCarCmdLog record, Integer pageIndex, Integer pageSize);
@@ -36,12 +38,20 @@ public interface WxCarCmdLogService {
* @param id
*/
void deleteById(Long id);


/**
* 根据synId获取tenantId
* @param params
* @return
*/
String getTenantIdBySynId(HashMap<String, String> params);








}

+ 7
- 1
mallinkService/src/main/java/com/iformall/service/impl/WxCarCmdLogServiceImpl.java Просмотреть файл

@@ -11,6 +11,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.iformall.common.IdWorker;

import java.util.HashMap;

@Service
public class WxCarCmdLogServiceImpl implements WxCarCmdLogService {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
@@ -47,7 +49,11 @@ public class WxCarCmdLogServiceImpl implements WxCarCmdLogService {
}
@Override
public String getTenantIdBySynId(HashMap<String,String> params) {
return wxCarCmdLogMapper.queryTenantIdBySynId(params);
}



+ 5
- 2
mallinkService/src/main/resources/mapper/WxCarCmdLogMapper.xml Просмотреть файл

@@ -103,8 +103,11 @@
and json_unquote(JSON_EXTRACT(cmd_json,'$.plateNumber')) is not null
group by plateNumber
</select>

<select id="queryTenantIdBySynId" parameterType="hashmap" resultType="String">
select `tenant_id` from wx_car_cmd_log
where cmd_type = 601 and json_extract(cmd_json, "$.synId") = #{synId}
</select>

</mapper>

Загрузка…
Отмена
Сохранить