ElectronicMembershipCardController.java 29 KB

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