ElectronicMembershipCardController.java 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489
  1. package com.platform.yijia.controller;
  2. import com.alibaba.fastjson.JSON;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.alibaba.fastjson.parser.Feature;
  5. import com.google.gson.Gson;
  6. import com.platform.yijia.param.request.RechargeBalance;
  7. import com.platform.yijia.pojo.CustomerCardSetting;
  8. import com.platform.yijia.pojo.CustomerCardSettingDetail;
  9. import com.platform.yijia.pojo.CustomerCardUseRecord;
  10. import com.platform.yijia.pojo.CustomerElectronicCard;
  11. import com.platform.yijia.service.ElectronicMembershipCardService;
  12. import com.platform.yijia.service.StationService;
  13. import com.platform.yijia.utils.*;
  14. import org.apache.commons.lang3.StringUtils;
  15. import org.slf4j.Logger;
  16. import org.slf4j.LoggerFactory;
  17. import org.springframework.stereotype.Controller;
  18. import org.springframework.transaction.annotation.Transactional;
  19. import org.springframework.web.bind.annotation.*;
  20. import javax.annotation.Resource;
  21. import java.math.BigDecimal;
  22. import java.text.SimpleDateFormat;
  23. import java.util.*;
  24. /*
  25. * <Title> ElectronicMembershipCardController </Title>
  26. * <Description> 电子会员卡(储蓄卡)功能模块 </Description>
  27. * @Author JK
  28. * @Date 2021年3月22日
  29. */
  30. @Controller
  31. @RequestMapping("/demo")
  32. public class ElectronicMembershipCardController {
  33. private static Logger logger =(Logger) LoggerFactory.getLogger(ElectronicMembershipCardController.class);
  34. @Resource
  35. private ElectronicMembershipCardService electronicMembershipCardService;
  36. @Resource
  37. private StationService stationService;
  38. //获取用户电子会员卡(储蓄卡)列表
  39. @RequestMapping(value = "/getElectronicCardList", method = RequestMethod.GET)
  40. @ResponseBody
  41. public String getElectronicCardList(@RequestParam Integer stationId, String unionId){
  42. Gson gson =new Gson();
  43. //返回结果集
  44. ResultData resultData = null;
  45. if(stationId !=null && unionId !=null){
  46. CustomerElectronicCard customerElectronicCard = new CustomerElectronicCard();
  47. customerElectronicCard.setStationId(stationId);
  48. customerElectronicCard.setUnionId(unionId);
  49. List<CustomerElectronicCard> electronicCardList = electronicMembershipCardService.getElectronicCardList(customerElectronicCard);
  50. resultData = ResultData.success(electronicCardList);
  51. }else {
  52. resultData = ResultData.error(CodeMsg.REQUEST_FAIL);
  53. }
  54. return gson.toJson(resultData);
  55. }
  56. //用户充值电子会员卡(储蓄卡)生成充值记录
  57. @RequestMapping(value = "/rechargeBalance", method = RequestMethod.POST)
  58. @ResponseBody
  59. public String rechargeBalance(@RequestBody RechargeBalance rechargeBalance){
  60. Gson gson =new Gson();
  61. //返回结果集
  62. ResultData resultData = null;
  63. if(rechargeBalance !=null){
  64. BigDecimal amt = new BigDecimal(rechargeBalance.getAmt());
  65. //String openId = rechargeBalance.getOpenId(); //公众号的openId
  66. Integer stationId = rechargeBalance.getStationId();
  67. //BigDecimal presentAmt = new BigDecimal(rechargeBalance.getPresentAmt());
  68. String payType = rechargeBalance.getPayType();
  69. String customerName = rechargeBalance.getCustomerName();
  70. String cardOilsType = rechargeBalance.getCardOilsType();
  71. String unionId = rechargeBalance.getUnionId();
  72. String stationName = rechargeBalance.getStationName();
  73. String stationCardEnabledFlag = electronicMembershipCardService.getStationCardEnabledFlag(stationId);
  74. //是否启用电子卡功能
  75. if(stationCardEnabledFlag.equals("1")){
  76. //CustomerElectronicCard customerElectronicCard = new CustomerElectronicCard(); //电子会员卡
  77. CustomerCardUseRecord customerCardUseRecord = new CustomerCardUseRecord(); //电子会员卡使用记录
  78. CustomerCardSetting customerCardSetting = new CustomerCardSetting(); //电子卡优惠规则设置
  79. customerCardSetting.setStationId(stationId);
  80. customerCardSetting.setCardOilsType(cardOilsType);
  81. //获取用户要充值电子卡的优惠规则信息
  82. List<CustomerCardSetting> cardRechargeSettingList = electronicMembershipCardService.getCardRechargeSettingList(customerCardSetting);
  83. if(cardRechargeSettingList !=null && cardRechargeSettingList.size() ==1){
  84. String discountTime = cardRechargeSettingList.get(0).getDiscountTime();
  85. String[] dctime={}; //会员充值活动时间
  86. if(discountTime.contains(",")){
  87. dctime =discountTime.split(",");
  88. }else {
  89. dctime =new String[1];
  90. dctime[0] = discountTime;
  91. }
  92. String currentTime = new SimpleDateFormat("yyyy-MM-dd").format(new Date()); //当前时间
  93. //循环优惠规则明细
  94. for (CustomerCardSettingDetail cardDetail : cardRechargeSettingList.get(0).getCustomerCardSettingDetailList()){
  95. if(amt.compareTo(cardDetail.getDiscountAmtTerm()) ==1 || amt.compareTo(cardDetail.getDiscountAmtTerm()) ==0){
  96. //String isDiscountCoupon = cardRechargeSettingList.get(0).getIsDiscountCoupon(); //是否使用优惠券
  97. //充值优惠类型
  98. if(cardDetail.getSettingRuleType().equals("1")){ //按充值金额
  99. BigDecimal presentAmt = cardDetail.getPresentAmt(); //当前赠送金额
  100. if(dctime !=null){
  101. for (String str : dctime){
  102. if(str.contains(currentTime)){ //如果当前时间在会员日活动时间内
  103. //计算会员日内的总赠送积分
  104. if(cardRechargeSettingList.get(0).getPresentScale() !=null){
  105. presentAmt = presentAmt.multiply(new BigDecimal(cardRechargeSettingList.get(0).getPresentScale())).add(presentAmt);
  106. }
  107. break;
  108. }
  109. }
  110. }
  111. customerCardUseRecord.setAmt(amt);
  112. customerCardUseRecord.setPresentAmt(presentAmt);
  113. }else if(cardDetail.getSettingRuleType().equals("2")){ //按充值金额的比例
  114. BigDecimal presentAmt = amt.multiply(cardDetail.getPresentAmt().divide(new BigDecimal(100))); //当前赠送金额比例的赠送积分
  115. if(dctime !=null){
  116. for (String str : dctime){
  117. if(str.contains(currentTime)){ //如果当前时间在会员日活动时间内
  118. //计算会员日期内的总赠送积分
  119. if(cardRechargeSettingList.get(0).getPresentScale() !=null){
  120. presentAmt = presentAmt.multiply(new BigDecimal(cardRechargeSettingList.get(0).getPresentScale())).add(presentAmt);
  121. }
  122. break;
  123. }
  124. }
  125. }
  126. customerCardUseRecord.setAmt(amt);
  127. customerCardUseRecord.setPresentAmt(presentAmt);
  128. }
  129. break;
  130. }
  131. }
  132. }else {
  133. customerCardUseRecord.setAmt(amt);
  134. customerCardUseRecord.setPresentAmt(new BigDecimal(0));
  135. }
  136. customerCardUseRecord.setUnionId(unionId);
  137. customerCardUseRecord.setStationId(stationId);
  138. customerCardUseRecord.setCardOilsType(cardOilsType);
  139. customerCardUseRecord.setStationName(stationName);
  140. customerCardUseRecord.setCustomerName(customerName);
  141. customerCardUseRecord.setUsageType("+");
  142. customerCardUseRecord.setPayType(payType); //1表示微信
  143. customerCardUseRecord.setCreateTime(new Date());
  144. customerCardUseRecord.setStatus("0");
  145. //订单规则 时间+6位随机数
  146. Random random = new Random();
  147. String str="";
  148. for(int i=0; i<6; i++){
  149. str+=random.nextInt(10);
  150. }
  151. String orderNo = System.nanoTime()+str;
  152. customerCardUseRecord.setOrderNo(orderNo);
  153. electronicMembershipCardService.insetCardUseRecord(customerCardUseRecord); //插入电子会员卡的使用记录
  154. resultData = ResultData.success(orderNo);
  155. }
  156. }
  157. return gson.toJson(resultData);
  158. }
  159. //用户充值电子会员卡(储蓄卡)拉起随行付支付接口
  160. @RequestMapping(value = "/rechargeBalanceSXFPay", method = RequestMethod.POST)
  161. @ResponseBody
  162. public String rechargeBalanceSXFPay(@RequestBody RechargeBalance rechargeBalance){
  163. Gson gson =new Gson();
  164. //返回结果集
  165. ResultData resultData = null;
  166. if(rechargeBalance !=null){
  167. String amt = rechargeBalance.getAmt();
  168. String openId = rechargeBalance.getOpenId(); //公众号的openId
  169. Integer stationId = rechargeBalance.getStationId();
  170. String userType = rechargeBalance.getUserType();
  171. String subject = rechargeBalance.getSubject();
  172. String orderNo = rechargeBalance.getOrderNo();
  173. //将业务参数存放在 JSON 对象中
  174. JSONObject reqData = new JSONObject();
  175. Map<String, String> resultMap = stationService.getStationAppIdAndAppSecret(stationId);
  176. if(resultMap !=null && resultMap.containsKey("appId") && resultMap.containsKey("mno")){
  177. logger.info("==============================电子会员卡(储蓄卡)充值功能调用随行付接口================================");
  178. try {
  179. if(userType.equals("1")){
  180. //1 是公众号
  181. reqData.put("payWay", "02"); //支付方式 02 公众号/服 务窗/js支付 03 小程序
  182. reqData.put("userId", openId); //用户号 微信:openid; 支付宝:userid;银联:userid;微信&支付宝必传,银联js为非必传
  183. reqData.put("subAppid", resultMap.get("gzhAppId")); //微信公众号
  184. logger.info("支付子商户:"+ resultMap.get("gzhAppId"));
  185. }else if(userType.equals("2")){
  186. reqData.put("payWay", "03"); //支付方式 02 公众号/服 务窗/js支付 03 小程序
  187. reqData.put("userId", openId); //用户号 微信:openid; 支付宝:userid;银联:userid;微信&支付宝必传,银联js为非必传
  188. reqData.put("subAppid", resultMap.get("appId")); //微信小程序
  189. logger.info("支付子商户:"+ resultMap.get("appId"));
  190. }
  191. reqData.put("mno", resultMap.get("mno")); //商户编号
  192. logger.info("商户编号:"+ resultMap.get("mno"));
  193. reqData.put("ordNo", orderNo); //商户订单号
  194. reqData.put("amt", amt); //订单总金额
  195. reqData.put("payType", "WECHAT"); //支付渠道
  196. reqData.put("subject", subject); //订单标题
  197. reqData.put("tradeSource", "01"); //交易来源 01服务商,02收银台,03硬件
  198. reqData.put("trmIp", "172.16.2.1");//商家ip地址
  199. reqData.put("outFrontFailUrl", ""); //js 支付,前台 事变通知地址
  200. reqData.put("notifyUrl", "https://www.huijy.net/demo/getCardRechargeCallback"); //回调地址
  201. // reqData.put("notifyUrl", "https://www.huijy.net/api/getCardRechargeCallback"); //回调地址
  202. // reqData.put("subMechId", ""); //子商户号
  203. // reqData.put("amt", "0.01");
  204. // reqData.put("discountAmt", ""); //参与优惠金额
  205. // reqData.put("unDiscountAmt", ""); //不参与优惠金额
  206. // reqData.put("timeExpire", "10"); //订单失效时间, 以分钟为单位
  207. // reqData.put("limitPay", "00"); //限制卡类型: 00-全部 01-限定不能使 用信用卡支付 默认值 00
  208. // reqData.put("hbFqNum", "6"); //花呗分期数,仅可上送 6 或 12
  209. // reqData.put("customerIp", ""); //持卡人ip地址,银联js支付时必传
  210. // reqData.put("outFrontUrl", ""); //js 支付,前台 成功通知地址
  211. // reqData.put("needReceipt", "00"); //电子发票功能 微信开具电子 发票使用
  212. // reqData.put("ledgerAccountFlag", "00"); //是否做分账 分账交易使 用;00:做; 01:不做;不传默认为不做分账
  213. // reqData.put("ledgerAccountEffectTime", "00"); //分账有效时间 单位为天;是 否做分账选择 00 时该字段必传
  214. // reqData.put("ruleId", "00"); //同 步 分 账 规 则 id
  215. // reqData.put("fusruleId", "00"); //同步分账规则
  216. // reqData.put("ylTrmNo", ""); //银联终端号
  217. // reqData.put("terminalId", ""); //TQ机具编号
  218. // reqData.put("deviceNo ", "1111"); //设备号
  219. // reqData.put("identityFlag", ""); //是否是实名支付
  220. // reqData.put("buyerIdType", "IDCARD"); //证件类型
  221. // reqData.put("buyerIdNo", "410523198701054018"); //证件号
  222. // reqData.put("buyerName", "张三"); //买家姓名
  223. // reqData.put("mobileNum", ""); //手机号
  224. // reqData.put("extend", ""); //备用
  225. String req= SXFPaySign.getSXFPay(reqData);
  226. logger.debug("参数信息:"+req);
  227. System.out.println("req:" + req);
  228. //此处不要改变reqData里面值的顺序用LinkedHashMap
  229. HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
  230. //组装加密串
  231. String signContent = RSASignature.getOrderContent(reqMap);
  232. System.out.println("拼接后的参数:" + signContent);
  233. logger.debug("拼接后的参数:"+signContent);
  234. //sign
  235. String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  236. System.out.println("============签名:" + sign);
  237. reqMap.put("sign", sign);
  238. String reqStr = JSON.toJSONString(reqMap);
  239. System.out.println("请求参数:" + reqMap);
  240. System.out.println("请求参数:" + reqStr);
  241. //调用第三方接口地址
  242. //String url = "https://openapi-test.tianquetech.com/order/jsapiScan";//测试地址
  243. String url = "https://openapi.suixingpay.com/order/jsapiScan";//生产地址
  244. String resultJson = HttpUtils.connectPostUrl(url, reqStr);
  245. System.out.println("返回信息:" + resultJson);
  246. // logger.debug("返回信息:"+resultJson);
  247. //不要对reqData排序 所以用LinkedHashMap
  248. HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
  249. if ("0000".equals(result.get("code"))) {
  250. //验签
  251. String signResult = result.get("sign").toString();
  252. result.remove("sign");
  253. String resultStr = RSASignature.getOrderContent(result);
  254. System.out.println(resultStr);
  255. //sign
  256. String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  257. System.out.println("resultSign:" + resultSign);
  258. //组装加密串
  259. if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
  260. System.out.println("===================验签成功==============");
  261. }
  262. }
  263. resultData=ResultData.success(result);
  264. }catch (Exception e){
  265. resultData=ResultData.error(CodeMsg.YEWU_FAIL,"订单支付失败");
  266. e.printStackTrace();
  267. }
  268. }
  269. }else {
  270. resultData = ResultData.error(CodeMsg.REQUEST_FAIL);
  271. }
  272. return gson.toJson(resultData);
  273. }
  274. //用户电子会员卡(储蓄卡)充值功能随行付回调功能
  275. @RequestMapping(value = "/getCardRechargeCallback", consumes = "application/json", method = RequestMethod.POST)
  276. @ResponseBody
  277. @Transactional
  278. public void getCardRechargeCallback(@RequestBody JSONObject request){
  279. logger.info("=========================电子会员卡(储蓄卡)充值功能随行付回调功能===============================");
  280. logger.info("电子会员卡(储蓄卡)充值功能随行付回调返回过来的参数:"+request);
  281. //logger.info("ordNo信息:" + request.get("ordNo").toString());
  282. //logger.info("sign信息:" + request.get("sign").toString());
  283. Gson gson =new Gson();
  284. String sxfUuid=request.get("sxfUuid").toString(); //随行付落单号
  285. String payWay=request.get("payWay").toString(); //随行付交易方式
  286. String payTime=request.get("payTime").toString(); //随行付交易时间
  287. String uuid=request.get("uuid").toString(); //随行付交易流水号
  288. String mno=request.get("mno").toString();//发起交易的商户编号
  289. String ordNo=request.get("ordNo").toString();//商户生成的订单号
  290. String amt=request.get("amt").toString();//金额
  291. String buyerId=request.get("buyerId").toString();//用户登录
  292. String transactionId=request.get("transactionId").toString();//用户登录
  293. String drType=request.get("drType").toString();//借贷记标识 1-借,2-贷,3-其他
  294. String payType=request.get("payType").toString();//对订单的描述,取值范围:WECHAT:微信,ALIPAY:支付宝,UNIONPAY:
  295. String payBank=request.get("payBank").toString();//付款银行银行编码,例如 ICBC
  296. String pointAmount=request.get("pointAmount").toString();//代金券金额
  297. String totalOffstAmt=request.get("totalOffstAmt").toString();//消 费 者 付 款金额
  298. String settleAmt=request.get("settleAmt").toString();//商家入账金额
  299. String timeStamp=request.get("timeStamp").toString();//响应时间
  300. String sign=request.get("sign").toString();//签名
  301. String bizCode=request.get("bizCode").toString();//业务返回码
  302. String bizMsg=request.get("bizMsg").toString();//业 务 返 回 信息
  303. String openid=request.get("openid").toString();//微 信 或 支 付宝身份id()opendid userid
  304. String channelId=request.get("channelId").toString();//渠道商户号
  305. String subMechId=request.get("subMechId").toString();//子商户号
  306. String finishTime=request.get("finishTime").toString();//交易完成时间
  307. String clearDt=request.get("clearDt").toString();
  308. String settlementBatchNo=request.get("settlementBatchNo").toString();
  309. //String origOrdNo=request.get("origOrdNo").toString();//反交易退款异步通知
  310. //String origUuid=request.get("origUuid").toString();//token
  311. //String scene=request.get("scene").toString();//用户登录
  312. //String buyerAccount=request.get("buyerAccount").toString();//
  313. //String realRefundAmount=request.get("realRefundAmount").toString();//商家出账金额
  314. //String recFeeAmt=request.get("recFeeAmt").toString();//交易手续费
  315. //String recFeeRate=request.get("recFeeRate").toString();//交易手续费率
  316. //String refBuyerAmt=request.get("refBuyerAmt").toString();//消 费 者 到 账金额
  317. //String extend = extend=request.get("extend").toString();//备用
  318. //将业务参数存放在 JSON 对象中
  319. JSONObject reqData = new JSONObject();
  320. //备用
  321. if(request.containsKey("extend") && request.get("extend") !=null){
  322. String extend = request.get("extend").toString();
  323. reqData.put("extend", extend);
  324. }
  325. //优惠券参数
  326. if(request.containsKey("promotionDetail") && request.get("promotionDetail") !=null){
  327. String promotionDetail = request.get("promotionDetail").toString();
  328. reqData.put("promotionDetail", promotionDetail);
  329. }
  330. //商家出账金额
  331. if(request.containsKey("realRefundAmount") && request.get("realRefundAmount") !=null){
  332. String realRefundAmount = request.get("realRefundAmount").toString();
  333. reqData.put("realRefundAmount", realRefundAmount);
  334. }
  335. //szltFlag
  336. if(request.containsKey("szltFlag") && request.get("szltFlag") !=null){
  337. String szltFlag = request.get("szltFlag").toString();
  338. reqData.put("szltFlag", szltFlag);
  339. }
  340. //recFeeAmt
  341. if(request.containsKey("recFeeAmt") && request.get("recFeeAmt") !=null){
  342. String recFeeAmt = request.get("recFeeAmt").toString();
  343. reqData.put("recFeeAmt", recFeeAmt);
  344. }
  345. //szltRecfeeAmt
  346. if(request.containsKey("szltRecfeeAmt") && request.get("szltRecfeeAmt") !=null){
  347. String szltRecfeeAmt = request.get("szltRecfeeAmt").toString();
  348. reqData.put("szltRecfeeAmt", szltRecfeeAmt);
  349. }
  350. reqData.put("sxfUuid",sxfUuid);
  351. reqData.put("payWay",payWay);
  352. reqData.put("payTime",payTime);
  353. reqData.put("uuid",uuid);
  354. reqData.put("mno",mno);
  355. reqData.put("ordNo",ordNo);
  356. reqData.put("amt",amt);
  357. reqData.put("buyerId",buyerId);
  358. reqData.put("transactionId",transactionId);
  359. reqData.put("drType",drType);
  360. reqData.put("payType",payType);
  361. reqData.put("payBank",payBank);
  362. reqData.put("pointAmount",pointAmount);
  363. reqData.put("totalOffstAmt",totalOffstAmt);
  364. reqData.put("settleAmt",settleAmt);
  365. reqData.put("timeStamp",timeStamp);
  366. reqData.put("bizCode",bizCode);
  367. reqData.put("bizMsg",bizMsg);
  368. reqData.put("openid",openid);
  369. reqData.put("channelId",channelId);
  370. reqData.put("subMechId",subMechId);
  371. reqData.put("finishTime",finishTime);
  372. reqData.put("clearDt",clearDt);
  373. reqData.put("settlementBatchNo",settlementBatchNo);
  374. //reqData.put("realRefundAmount",realRefundAmount);
  375. //reqData.put("recFeeAmt",recFeeAmt);
  376. //reqData.put("recFeeRate",recFeeRate);
  377. //reqData.put("buyerAccount",buyerAccount);
  378. //reqData.put("origOrdNo",origOrdNo);
  379. //reqData.put("origUuid",origUuid);
  380. //reqData.put("scene",scene);
  381. //reqData.put("refBuyerAmt",refBuyerAmt);
  382. //reqData.put("extend",extend);
  383. //根据回调信息,先进行验签,验签后修改状态
  384. logger.info("打印参数信息"+gson.toJson(reqData));
  385. //不要对reqData排序 所以用LinkedHashMap
  386. HashMap<String, Object> result = JSON.parseObject(gson.toJson(reqData), LinkedHashMap.class, Feature.OrderedField);
  387. //验签
  388. String resultStr = RSASignature.getOrderContent(result);
  389. //JSONObject req = new JSONObject();
  390. System.out.println(resultStr);
  391. if (RSASignature.doCheck(resultStr, sign, SXFPaySign.sxfPublic)) {
  392. logger.info("验签成功");
  393. //随行付回调验签成功更新客户电子卡余额 和 更新客户充值记录状态
  394. CustomerCardUseRecord customerCardUseRecord = new CustomerCardUseRecord();
  395. customerCardUseRecord.setOrderNo(ordNo);
  396. CustomerCardUseRecord customerCardUseRecordInfo = electronicMembershipCardService.getCardRecordByOrderNo(customerCardUseRecord);
  397. // 0表示未支付 1表示已支付
  398. if(customerCardUseRecordInfo !=null && customerCardUseRecordInfo.getStatus().equals("0")){
  399. CustomerElectronicCard customerElectronicCard = new CustomerElectronicCard();
  400. customerElectronicCard.setUnionId(customerCardUseRecord.getUnionId());
  401. //是否有赠送金额
  402. if(customerCardUseRecordInfo.getPresentAmt() !=null){
  403. BigDecimal presentAmt = customerCardUseRecordInfo.getPresentAmt(); //客户充值赠送金额
  404. customerElectronicCard.setAmt(new BigDecimal(amt).add(presentAmt));
  405. }else {
  406. customerElectronicCard.setAmt(new BigDecimal(amt));
  407. }
  408. customerElectronicCard.setRecentlyTime(new Date());
  409. electronicMembershipCardService.updateElectronicCardInfoByUnionId(customerElectronicCard);
  410. customerCardUseRecord.setStatus("1");
  411. electronicMembershipCardService.updateCardRecordStatusByOrderNo(customerCardUseRecord);
  412. logger.info("=====================电子会员卡充值成功=============================");
  413. }
  414. }else {
  415. logger.info("验签失败");
  416. }
  417. }
  418. //获取用户电子会员卡(储蓄卡)充值记录
  419. @RequestMapping(value = "/getCardRechargeRecord", method = RequestMethod.GET)
  420. @ResponseBody
  421. public String getCardRechargeRecord(@RequestParam Integer stationId, String unionId){
  422. Gson gson =new Gson();
  423. //返回结果集
  424. ResultData resultData = null;
  425. if(stationId !=null && unionId !=null){
  426. CustomerCardUseRecord customerCardUseRecord = new CustomerCardUseRecord();
  427. customerCardUseRecord.setUsageType("+"); // '+' 代表充值
  428. customerCardUseRecord.setStationId(stationId);
  429. customerCardUseRecord.setUnionId(unionId);
  430. List<CustomerCardUseRecord> cardUseRecordList = electronicMembershipCardService.getCardUseRecordList(customerCardUseRecord);
  431. resultData = ResultData.success(cardUseRecordList);
  432. }else {
  433. resultData = ResultData.error(CodeMsg.REQUEST_FAIL);
  434. }
  435. return gson.toJson(resultData);
  436. }
  437. //获取用户电子会员卡(储蓄卡)消费记录
  438. @RequestMapping(value = "/getCardConsumptionRecord", method = RequestMethod.GET)
  439. @ResponseBody
  440. public String getCardConsumptionRecord(@RequestParam Integer stationId, String unionId){
  441. Gson gson =new Gson();
  442. //返回结果集
  443. ResultData resultData = null;
  444. if(stationId !=null && unionId !=null){
  445. CustomerCardUseRecord customerCardUseRecord = new CustomerCardUseRecord();
  446. customerCardUseRecord.setUnionId(unionId);
  447. customerCardUseRecord.setStationId(stationId);
  448. customerCardUseRecord.setUsageType("-"); // '-' 代表消费
  449. List<CustomerCardUseRecord> cardUseRecordList = electronicMembershipCardService.getCardUseRecordList(customerCardUseRecord);
  450. resultData = ResultData.success(cardUseRecordList);
  451. }else {
  452. resultData = ResultData.error(CodeMsg.REQUEST_FAIL);
  453. }
  454. return gson.toJson(resultData);
  455. }
  456. //查询油站电子会员卡(储蓄卡)充值设置规则
  457. @RequestMapping(value = "/getCardRechargeSettingList", method = RequestMethod.GET)
  458. @ResponseBody
  459. public String getCardRechargeSettingList(@RequestParam Integer stationId, String cardOilsType){
  460. Gson gson =new Gson();
  461. //返回结果集
  462. ResultData resultData = null;
  463. if(stationId !=null && StringUtils.isNotBlank(cardOilsType)){
  464. CustomerCardSetting customerCardSetting = new CustomerCardSetting();
  465. customerCardSetting.setStationId(stationId);
  466. customerCardSetting.setCardOilsType(cardOilsType);
  467. List<CustomerCardSetting> cardRechargeSettingList = electronicMembershipCardService.getCardRechargeSettingList(customerCardSetting);
  468. resultData = ResultData.success(cardRechargeSettingList);
  469. }else {
  470. resultData = ResultData.error(CodeMsg.REQUEST_FAIL);
  471. }
  472. return gson.toJson(resultData);
  473. }
  474. }