diff --git a/ZhuQue/src/main/java/com/dsideal/ZhuQue/Test/TestKeTuo.java b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Test/TestKeTuo.java new file mode 100644 index 0000000..b43988f --- /dev/null +++ b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Test/TestKeTuo.java @@ -0,0 +1,8 @@ +package com.dsideal.ZhuQue.Test; + +public class TestKeTuo { + + public static void main(String[] args) { + + } +} diff --git a/ZhuQue/src/main/java/com/dsideal/ZhuQue/Util/CommonUtil.java b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Util/CommonUtil.java index 46a4cc2..3a9aa55 100644 --- a/ZhuQue/src/main/java/com/dsideal/ZhuQue/Util/CommonUtil.java +++ b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Util/CommonUtil.java @@ -797,6 +797,10 @@ public class CommonUtil { dictList.add(record); return getRet(dictList, success, message); } + public static Kv getRet(boolean success, String message) { + List dictList = new ArrayList<>(); + return getRet(dictList, success, message); + } public static Kv getRet(List dictList, boolean success, String message) { Kv kv = Kv.by("code", 1000); diff --git a/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Controller/YltController.java b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Controller/YltController.java index c8532c7..691f0e9 100644 --- a/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Controller/YltController.java +++ b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Controller/YltController.java @@ -1,5 +1,8 @@ package com.dsideal.ZhuQue.Ylt.Controller; +import cn.hutool.core.date.DateTime; +import cn.hutool.http.HttpUtil; +import com.alibaba.fastjson.JSONObject; import com.dsideal.ZhuQue.Interceptor.IsLoginInterface; import com.dsideal.ZhuQue.Util.CommonUtil; import com.dsideal.ZhuQue.Ylt.Model.YltModel; @@ -7,14 +10,20 @@ import com.jfinal.aop.Before; import com.jfinal.core.Controller; import com.jfinal.ext.interceptor.GET; import com.jfinal.ext.interceptor.POST; +import com.jfinal.kit.PropKit; import com.jfinal.plugin.activerecord.Record; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import java.sql.Time; import java.util.ArrayList; import java.util.List; +import java.util.UUID; public class YltController extends Controller { YltModel ym = new YltModel(); + private static Logger log = LoggerFactory.getLogger(YltController.class); public List getAll() { List list = new ArrayList<>(); @@ -97,4 +106,104 @@ public class YltController extends Controller { record.set("phone", phone); renderJson(CommonUtil.getRet(record, true, "保存成功！")); } + + /** + * 功能: 向第三方道闸同步充电桩支付信息 + */ + //@Before({POST.class}) + //@IsLoginInterface({}) + // 非指定闸机场地 + // http://10.10.21.20:8888/ZhuQue/Ylt/SyncChargePilePay?order_id=1 + // 科拓闸机场地 + // http://10.10.21.20:8888/ZhuQue/Ylt/SyncChargePilePay?order_id=248933 + public void SyncChargePilePay(int order_id) { + //根据订单号获取到第三方方面提供的车场信息 + Record thirdPartyStation = ym.getThirdPartyStation(order_id); + if (thirdPartyStation == null) { + Record record = new Record(); + renderJson(CommonUtil.getRet(record, false, "检查到不是需要免费的道闸所在车场，无需发送减免消息！！")); + return; + } + //请求地址 + String url = thirdPartyStation.getStr("third_party_url"); + //与科拓对接，对方平台分配的我司平台ID + String appId = thirdPartyStation.getStr("third_party_appId"); + //与科拓对接，对方平台分配的我司平台秘钥 + String key = thirdPartyStation.getStr("third_party_key"); + //闸机提供商 + String name = thirdPartyStation.getStr("third_party_name"); + //闸机所在车场ID + int parkId = thirdPartyStation.getInt("third_party_station_id"); + log.info("发现闸机提供商：" + name + ",parkId=" + parkId); + + //订单信息 + Record dingDanRecord = ym.getOrderById(order_id); + String charge_plate_no = dingDanRecord.getStr("charge_plate_no");//车牌号 + String charge_begin_time = dingDanRecord.getStr("charge_begin_time");//充电开始时间 + String charge_end_time = dingDanRecord.getStr("charge_end_time");//充电结束时间 + int stationId = dingDanRecord.getInt("station_id");//电站ID + //获取车场名称 + String stationName = ym.getStationById(String.valueOf(stationId)).getStr("station_name"); + //设备号 + int deviceId = dingDanRecord.getInt("equipment_id");//充电桩ID + //充电桩名称 + String deviceName = ym.getEquipmentById(deviceId).getStr("equipment_name"); + //车位号 + String spaceNo = dingDanRecord.getInt("connector_id").toString(); + //充电量 + String power = dingDanRecord.getDouble("charge_ah").toString(); + //电费 + int elecMoney = (int) (dingDanRecord.getDouble("receivable_electric_fee") * 100); + //服务费 + int seviceMoney = (int) (dingDanRecord.getDouble("receivable_service_fee") * 100); + //总费用 + int totalMoney = (int) (dingDanRecord.getDouble("receivable_total_fee") * 100); + //本地车场配置减免规则，根据充电时长换算 + int freeType = 1; + int freeMoney = 0;//免费0元 + int freeTime = 2 * 60 * 60;//2小时 + // + if ("科拓".equals(name)) { + JSONObject jo = new JSONObject(); + jo.put("appId", appId); + jo.put("key", key); + jo.put("parkId", parkId); + jo.put("serviceCode", "syncChargePilePay"); + // 获取当前时间戳 + long timestamp = System.currentTimeMillis(); + jo.put("ts", timestamp);//每次请求附带当前时间戳(格林威治时间1970年01月01日00时00分00秒起至现在的总毫秒数)超过10S请求失效 + jo.put("reqId", UUID.randomUUID().toString().toUpperCase());//每次请求的唯一标识，如果是异步接口，异步响应消息的reqId会与原请求的reqId一致。每次请求必须唯一！！！ + jo.put("orderNo", String.valueOf(order_id));//订单号 + jo.put("plateNo", charge_plate_no);//车牌号 + jo.put("startTime", charge_begin_time);//开始时间 + jo.put("endTime", charge_end_time);//结束时间 + jo.put("stationId", stationId);//电站ID + jo.put("stationName", stationName);//电站名称 + jo.put("deviceId", deviceId);//充电桩ID + jo.put("deviceName", deviceName);//充电桩名称 + jo.put("spaceNo", spaceNo);//位置ID + jo.put("power", power);//充电量 + jo.put("elecMoney", elecMoney);//电费 + jo.put("seviceMoney", seviceMoney);//服务费 + jo.put("totalMoney", totalMoney);//总费用 + jo.put("freeType", freeType); + jo.put("freeMoney", freeMoney); + jo.put("freeTime", freeTime); + jo.put("version","v6.x");//请求头版本号 + // 发送 POST 请求并获取响应 + String result = HttpUtil.createPost(url) + .body(jo.toString()) // 将 JSON 对象转换为字符串作为请求正文 + .header("Content-Type", "application/json") // 设置请求头，指明内容类型为 JSON + .execute().body(); // 发送请求并获取响应体 + + // 打印结果 + System.out.println(result); + renderJson(CommonUtil.getRet(new Record(), true, + "已经向科拓闸机平台发送了减免消息！")); + return; + } + + renderJson(CommonUtil.getRet(new Record(), false, + "发现了一个未知的闸机厂商，请联系开发人员！")); + } } \ No newline at end of file diff --git a/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Model/YltModel.java b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Model/YltModel.java index 9c777fa..dfd0a0c 100644 --- a/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Model/YltModel.java +++ b/ZhuQue/src/main/java/com/dsideal/ZhuQue/Ylt/Model/YltModel.java @@ -1,6 +1,7 @@ package com.dsideal.ZhuQue.Ylt.Model; import com.dsideal.ZhuQue.Util.JwtUtil; +import com.jfinal.plugin.activerecord.Db; import io.jsonwebtoken.Claims; import javax.servlet.http.HttpServletRequest; @@ -27,4 +28,68 @@ public class YltModel { record.set("phone", phone); return record; } + + /** + * 功能：传入一个订单ID，判断它所在的车场是不是第三方道闸的车场 + * + * @param order_id + * @return + */ + public Record getThirdPartyStation(int order_id) { + Record record = getOrderById(order_id); + if (record == null) { + return null; + } + int station_id = record.getInt("station_id"); + Record stationRecord = getKtStation(station_id); + return stationRecord; + } + + /** + * 功能：根据订单ID获取订单信息 + * + * @param order_id + * @return + */ + public Record getOrderById(int order_id) { + String sql = "select * from t_equipment_charge_order where id=?"; + Record record = Db.findFirst(sql, order_id); + return record; + } + + /** + * 功能：传入一个车场ID，获取车场信息 + * + * @param station_id + * @return + */ + public Record getKtStation(int station_id) { + String sql = "select * from t_ext_ketuo_station where station_id=?"; + Record record = Db.findFirst(sql, station_id); + return record; + } + + /** + * 功能：传入一个车场ID，获取车场信息 + * + * @param station_id + * @return + */ + public Record getStationById(String station_id) { + String sql = "select * from t_station where id=?"; + Record record = Db.findFirst(sql, station_id); + return record; + } + + /** + * 功能：获取指定的充电桩信息 + * + * @param equipment_id + * @return + */ + public Record getEquipmentById(int equipment_id) { + String sql = "select * from t_equipment where id=?"; + Record record = Db.findFirst(sql, equipment_id); + return record; + } } diff --git a/ZhuQue/src/main/resource/application.properties b/ZhuQue/src/main/resource/application.properties index 75f020b..285511d 100644 --- a/ZhuQue/src/main/resource/application.properties +++ b/ZhuQue/src/main/resource/application.properties @@ -3,8 +3,8 @@ driverClassName=com.mysql.jdbc.Driver user=root password=DsideaL147258369 jdbcUrl=jdbc:mysql://10.10.14.210:22066/yltcharge?useUnicode=true&characterEncoding=GBK&useSSL=false - # redis redis_ip=10.10.14.210 redis_port=6379 redis_password=ylt#redis + diff --git a/业务梳理/~$对外统一标准接口_充电桩抵扣.docx b/业务梳理/~$对外统一标准接口_充电桩抵扣.docx new file mode 100644 index 0000000..c638bf6 Binary files /dev/null and b/业务梳理/~$对外统一标准接口_充电桩抵扣.docx differ diff --git a/业务梳理/科拓对外统一标准接口_充电桩抵扣.docx b/业务梳理/科拓对外统一标准接口_充电桩抵扣.docx index 90b5748..df81623 100644 Binary files a/业务梳理/科拓对外统一标准接口_充电桩抵扣.docx and b/业务梳理/科拓对外统一标准接口_充电桩抵扣.docx differ