TOrderServiceImpl.java 86 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862
  1. package com.szwl.service.impl;
  2. import cn.hutool.core.util.StrUtil;
  3. import com.alibaba.fastjson.JSON;
  4. import com.alibaba.fastjson.JSONArray;
  5. import com.alibaba.fastjson.JSONObject;
  6. import com.alipay.api.AlipayApiException;
  7. import com.alipay.api.AlipayClient;
  8. import com.alipay.api.AlipayConfig;
  9. import com.alipay.api.DefaultAlipayClient;
  10. import com.alipay.api.domain.AlipayTradePrecreateModel;
  11. import com.alipay.api.request.AlipayTradePrecreateRequest;
  12. import com.alipay.api.response.AlipayTradePrecreateResponse;
  13. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  14. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  15. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  16. import com.google.gson.Gson;
  17. import com.szwl.constant.*;
  18. import com.szwl.feign.bean.OrderFeign;
  19. import com.szwl.feign.bean.SzwlFeign;
  20. import com.szwl.mapper.TOrderMapper;
  21. import com.szwl.model.bean.WeChatTemplateMsg;
  22. import com.szwl.model.bo.JsonMessage;
  23. import com.szwl.model.bo.R;
  24. import com.szwl.model.bo.ResponseModel;
  25. import com.szwl.model.entity.*;
  26. import com.szwl.model.utils.CodeUtil;
  27. import com.szwl.model.utils.HttpClientUtils;
  28. import com.szwl.model.utils.PushUtils;
  29. import com.szwl.model.utils.RSAUtil;
  30. import com.szwl.service.*;
  31. import com.szwl.service.es.EsTOrderService;
  32. import com.szwl.utils.HuifuUtils;
  33. import com.szwl.utils.IDGenerator;
  34. import com.szwl.utils.shouqianba.HttpProxy;
  35. import com.szwl.weixin.util.HttpUtils;
  36. import com.wechat.pay.java.core.Config;
  37. import com.wechat.pay.java.service.payments.nativepay.model.Amount;
  38. import com.wechat.pay.java.service.payments.nativepay.model.PrepayRequest;
  39. import com.wechat.pay.java.service.payments.nativepay.model.PrepayResponse;
  40. import com.wechat.pay.java.service.payments.nativepay.model.SceneInfo;
  41. import com.wechat.pay.java.service.refund.model.CreateRequest;
  42. import com.wechat.pay.java.service.refund.model.Refund;
  43. import lombok.extern.slf4j.Slf4j;
  44. import org.apache.commons.lang.StringUtils;
  45. import org.apache.http.HttpStatus;
  46. import org.apache.http.message.BasicNameValuePair;
  47. import org.springframework.beans.factory.annotation.Autowired;
  48. import org.springframework.http.ResponseEntity;
  49. import org.springframework.stereotype.Service;
  50. import org.springframework.transaction.annotation.Transactional;
  51. import org.springframework.web.client.RestTemplate;
  52. import javax.annotation.Resource;
  53. import javax.servlet.http.HttpServletRequest;
  54. import javax.servlet.http.HttpServletResponse;
  55. import java.io.UnsupportedEncodingException;
  56. import java.math.BigDecimal;
  57. import java.math.RoundingMode;
  58. import java.text.ParseException;
  59. import java.text.SimpleDateFormat;
  60. import java.util.*;
  61. import java.util.concurrent.CompletableFuture;
  62. import static com.szwl.service.impl.TJoinpayMchServiceImpl.createHmacSign;
  63. /**
  64. * <p>
  65. * 服务实现类
  66. * </p>
  67. *
  68. * @author wuhs
  69. * @since 2022-06-17
  70. */
  71. @Slf4j
  72. @Service
  73. public class TOrderServiceImpl extends ServiceImpl<TOrderMapper, TOrder> implements TOrderService {
  74. @Autowired
  75. OrderFeign orderFeign;
  76. @Autowired
  77. SzwlFeign szwlFeign;
  78. @Autowired
  79. TOrderService orderService;
  80. @Autowired
  81. EsTOrderService esTOrderService;
  82. @Autowired
  83. TEquipmentService equipmentService;
  84. @Autowired
  85. TWechatPayConfigService wechatPayConfigService;
  86. @Resource
  87. TAlipayConfigService alipayConfigService;
  88. @Autowired
  89. TSqbConfigService sqbConfigService;
  90. @Autowired
  91. THuifuMchService huifuMchService;
  92. @Autowired
  93. TJoinpayMchService joinpayMchService;
  94. @Autowired
  95. private TOrderDetailsService orderDetailsService;
  96. @Override
  97. public synchronized String initSn(Long equipmentId) {
  98. StringBuilder number = new StringBuilder();
  99. if (equipmentId != null) {
  100. Random random = new Random();
  101. /**
  102. * 6位随机
  103. */
  104. for (int i = 0; i < 6; i++) {
  105. number.append(String.valueOf(random.nextInt(10)));
  106. }
  107. /**
  108. * 设备id
  109. */
  110. number.append(equipmentId.toString());
  111. /**
  112. * 日期
  113. */
  114. number.append(new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()));
  115. }
  116. return number.toString();
  117. }
  118. @Override
  119. public String wechatPay(String sn, BigDecimal amount, String productName, Long id, String notifyUrl, String clientId, HttpServletRequest request) {
  120. TWechatPayConfig wechatPayConfig = wechatPayConfigService.getById(id);
  121. Config config = wechatPayConfigService.getWechatConfig(id);
  122. if (config == null) {
  123. wechatPayConfigService.initConfig(id);
  124. config = wechatPayConfigService.getWechatConfig(id);
  125. }
  126. // 构建service
  127. NativePayService service = new NativePayService.Builder().config(config).build();
  128. PrepayRequest payRequest = new PrepayRequest();
  129. Amount amount1 = new Amount();
  130. amount1.setTotal(amount.intValue());
  131. payRequest.setAmount(amount1);
  132. payRequest.setAppid(wechatPayConfig.getAppId());
  133. payRequest.setMchid(wechatPayConfig.getMerchantId());
  134. payRequest.setDescription(productName);
  135. // 添加设备编号
  136. String ipAddress = HttpClientUtils.getIpAddress(request);
  137. SceneInfo sceneInfo = new SceneInfo();
  138. sceneInfo.setPayerClientIp(ipAddress);
  139. sceneInfo.setDeviceId(clientId);
  140. payRequest.setSceneInfo(sceneInfo);
  141. payRequest.setNotifyUrl(notifyUrl);
  142. // payRequest.setNotifyUrl("http://evxz5m.natappfree.cc/wechatPay/notify");;
  143. payRequest.setOutTradeNo(sn);
  144. // 调用下单方法,得到应答
  145. PrepayResponse response = service.prepay(payRequest);
  146. return response.getCodeUrl();
  147. }
  148. /**
  149. * 处理退款回调通知
  150. */
  151. @Override
  152. public String wechatRefund(HttpServletRequest request, HttpServletResponse response) {
  153. Gson gson = new Gson();
  154. Map<String, Object> hashMap = new HashMap<>(3);
  155. try {
  156. // 处理退款通知参数
  157. String body = HttpUtils.readData(request);
  158. Map<String, Object> bodyMap = gson.fromJson(body, HashMap.class);
  159. String eventType = (String) bodyMap.get("event_type");
  160. if (eventType.equals("REFUND.SUCCESS")) {
  161. // 处理退款单
  162. processRefund(bodyMap);
  163. //成功应答
  164. response.setStatus(HttpStatus.SC_OK);
  165. // hashMap.put("code", "SUCCESS");
  166. } else {
  167. response.setStatus(HttpStatus.SC_BAD_GATEWAY);
  168. hashMap.put("code", "FAIL");
  169. hashMap.put("message", "系统错误");
  170. }
  171. return gson.toJson(hashMap);
  172. } catch (Exception e) {
  173. e.printStackTrace();
  174. }
  175. return null;
  176. }
  177. @Override
  178. public Refund weixinRefundApi(CreateRequest createRequest, Long id) {
  179. Config config = wechatPayConfigService.getWechatConfig(id);
  180. if (config == null) {
  181. wechatPayConfigService.initConfig(id);
  182. config = wechatPayConfigService.getWechatConfig(id);
  183. }
  184. // 构建service
  185. NativePayService service = new NativePayService.Builder().config(config).build();
  186. Refund refund = service.refund(createRequest);
  187. return refund;
  188. }
  189. /**
  190. * 汇聚查询退款状态
  191. */
  192. @Override
  193. public JSONObject queryRefund(String refundTrxNo) {
  194. String url = "https://www.joinpay.com/trade/queryRefund.action";
  195. List<BasicNameValuePair> data = new ArrayList<BasicNameValuePair>();
  196. data.add(new BasicNameValuePair("p1_MerchantNo", JoinpayConstant.mch_no));
  197. data.add(new BasicNameValuePair("p2_RefundOrderNo", refundTrxNo));
  198. data.add(new BasicNameValuePair("p3_Version", "2.1"));
  199. String hmac = null;
  200. try {
  201. hmac = createHmacSign(data, JoinpayConstant.key);
  202. } catch (UnsupportedEncodingException e) {
  203. e.printStackTrace();
  204. }
  205. data.add(new BasicNameValuePair("hmac", hmac));
  206. String result = HttpClientUtils.postKeyValue(url, data);
  207. JSONObject resultJson = JSONObject.parseObject(result);
  208. return resultJson;
  209. }
  210. @Override
  211. public String joinpayNotifyRefund(HttpServletRequest request) {
  212. String r6_Status = request.getParameter("ra_Status");
  213. // 订单号
  214. String sn = request.getParameter("r2_OrderNo");
  215. // 退款订单号
  216. if (StringUtils.isEmpty(sn)) {
  217. return "error";
  218. }
  219. LambdaQueryWrapper<TOrder> query = Wrappers.lambdaQuery();
  220. query.eq(TOrder::getSn, sn);
  221. TOrder order = orderService.getOne(query);
  222. if (order == null) {
  223. return "error";
  224. }
  225. if (order.getStatus() == 3) {
  226. return "success";
  227. }
  228. // 订单商品数量
  229. if (JoinpayConstant.r6_Status_100.equals(r6_Status)) {
  230. if (order.getRefundQuantity() < order.getProductNumber()) {
  231. order.setStatus(1);
  232. } else {
  233. order.setStatus(3);
  234. }
  235. // 更改订单明细表
  236. LambdaQueryWrapper<TOrderDetails> queryWrapper = new LambdaQueryWrapper<>();
  237. queryWrapper.eq(TOrderDetails::getOrderSn, sn);
  238. // 处理退款中状态的明细
  239. queryWrapper.eq(TOrderDetails::getRefundStatus, "4");
  240. List<TOrderDetails> tOrderDetails = orderDetailsService.list(queryWrapper);
  241. for (TOrderDetails tOrderDetail : tOrderDetails) {
  242. Integer refundQuantity = tOrderDetail.getRefundQuantity();
  243. Integer productNumber = tOrderDetail.getProductNumber();
  244. if (refundQuantity < productNumber) {
  245. // 部分退款
  246. tOrderDetail.setRefundStatus("2");
  247. orderDetailsService.updateById(tOrderDetail);
  248. } else {
  249. // 全部退款
  250. tOrderDetail.setRefundStatus("3");
  251. orderDetailsService.updateById(tOrderDetail);
  252. }
  253. }
  254. // r4_refundAmount: 退款金额
  255. BigDecimal r4_refundAmount = new BigDecimal(request.getParameter("r4_RefundAmount_str"));
  256. if (order.getRefundMarketingAmount() != null) {
  257. r4_refundAmount = r4_refundAmount.add(order.getRefundMarketingAmount());
  258. }
  259. // price: 订单金额, refundAmount:已退款的金额
  260. BigDecimal price = order.getPrice();
  261. BigDecimal refundAmount = order.getRefundAmount();
  262. TProportion proportion = R.getDataIfSuccess(szwlFeign.getProportion(String.valueOf(order.getEquipmentId())));
  263. if (order.getRefundAmount() != null) {
  264. BigDecimal newRefundAmount = refundAmount.add(r4_refundAmount);
  265. order.setRefundAmount(refundAmount.add(r4_refundAmount));
  266. // 如果小于订单金额
  267. if (newRefundAmount.compareTo(price) < 0) {
  268. JSONArray altInfo = getAltInfo(proportion, price.subtract(newRefundAmount));
  269. order.setAltInfo(altInfo.toString());
  270. } else {
  271. JSONArray altInfo = getAltInfo(proportion, price);
  272. order.setAltInfo(altInfo.toString());
  273. }
  274. } else {
  275. order.setRefundAmount(r4_refundAmount);
  276. if (r4_refundAmount.compareTo(price) < 0) {
  277. JSONArray altInfo = getAltInfo(proportion, price.subtract(r4_refundAmount));
  278. order.setAltInfo(altInfo.toString());
  279. }
  280. }
  281. // 支付平台产生的退款流水号
  282. String r5_RefundTrxNo = request.getParameter("r5_RefundTrxNo");
  283. order.setRefundTrxNo(r5_RefundTrxNo);
  284. order.setRefundDate(new Date());
  285. order.setModifyDate(new Date());
  286. String orderStatus = order.getOrderStatus();
  287. if (StringUtils.isNotEmpty(orderStatus) && orderStatus.equals("0")) {
  288. if (order.getStatus().toString().equals("3")) {
  289. TEquipment byClientId = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(order.getClientId()));
  290. JSONObject kindData = new JSONObject();
  291. String s = order.getId().toString();
  292. if (s.length() > 6) {
  293. s = s.substring(s.length() - 6, s.length());
  294. }
  295. kindData.put("mealCode", s);
  296. equipmentService.sentMessage(byClientId.getClientId(), PushUtils.buildJson("refuse_success", kindData.toString()).toString());
  297. }
  298. }
  299. try {
  300. esTOrderService.updateDataById(order);
  301. } catch (Exception e) {
  302. e.printStackTrace();
  303. } finally {
  304. orderService.updateById(order);
  305. }
  306. return "success";
  307. }
  308. return "success";
  309. }
  310. @Override
  311. public String huifuNotifyRefund(HttpServletRequest request) {
  312. String respData = request.getParameter("resp_data");
  313. try {
  314. // 验签请参sign
  315. String sign = request.getParameter("sign");
  316. if (!RSAUtil.verify(respData, HuifuConstant.HUIFU_PUBLIC_KEY, sign)) {
  317. // 验签失败处理
  318. log.info("验签失败");
  319. return "";
  320. }
  321. JSONObject data = JSONObject.parseObject(respData);
  322. String transStat = data.getString("trans_stat");
  323. // 订单号
  324. String sn = data.getString("org_req_seq_id");
  325. if (StrUtil.hasEmpty(sn)) {
  326. log.info("返回参数订单编号为空");
  327. return "订单号为空!";
  328. }
  329. LambdaQueryWrapper<TOrder> wrapper = new LambdaQueryWrapper<>();
  330. wrapper.eq(TOrder::getSn, sn);
  331. TOrder order = orderService.getOne(wrapper);
  332. if (order == null) {
  333. log.info("找不到订单");
  334. return "订单不存在";
  335. }
  336. if (HuifuConstant.TRANS_STAT_S.equals(transStat)) {
  337. if (order.getRefundQuantity() < order.getProductNumber()) {
  338. order.setStatus(1);
  339. } else {
  340. order.setStatus(3);
  341. }
  342. String refundOrderNo = data.getString("req_seq_id");
  343. String ordAmt = data.getString("ord_amt");
  344. String refundTrxNo = data.getString("hf_seq_id");
  345. order.setRefundOrderNo(refundOrderNo);
  346. order.setRefundDate(new Date());
  347. order.setRefundTrxNo(refundTrxNo);
  348. // 更改订单明细表
  349. LambdaQueryWrapper<TOrderDetails> queryWrapper = new LambdaQueryWrapper<>();
  350. queryWrapper.eq(TOrderDetails::getOrderSn, sn);
  351. // 处理退款中状态的明细
  352. queryWrapper.eq(TOrderDetails::getRefundStatus, "4");
  353. List<TOrderDetails> tOrderDetails = orderDetailsService.list(queryWrapper);
  354. for (TOrderDetails tOrderDetail : tOrderDetails) {
  355. Integer refundQuantity = tOrderDetail.getRefundQuantity();
  356. Integer productNumber = tOrderDetail.getProductNumber();
  357. if (refundQuantity < productNumber) {
  358. // 部分退款
  359. tOrderDetail.setRefundStatus("2");
  360. orderDetailsService.updateById(tOrderDetail);
  361. } else {
  362. // 全部退款
  363. tOrderDetail.setRefundStatus("3");
  364. orderDetailsService.updateById(tOrderDetail);
  365. }
  366. }
  367. String acctSplitBunch = "";
  368. // 部分退款或全部退款
  369. TProportion proportion = R.getDataIfSuccess(szwlFeign.getProportion(String.valueOf(order.getEquipmentId())));
  370. if (order.getRefundAmount() != null) {
  371. // 退款总额
  372. BigDecimal newRefundAmount = order.getRefundAmount().add(new BigDecimal(ordAmt).setScale(2, RoundingMode.HALF_UP));
  373. order.setRefundAmount(newRefundAmount);
  374. // 如果小于订单金额
  375. if (newRefundAmount.compareTo(order.getPrice()) < 0) {
  376. acctSplitBunch = getAcctSplitBunch(proportion, order.getPrice().subtract(newRefundAmount), order.getCompanyType()).toString();
  377. order.setAcctSplitBunch(acctSplitBunch);
  378. } else {
  379. acctSplitBunch = getAcctSplitBunch(proportion, order.getPrice(), order.getCompanyType()).toString();
  380. order.setAcctSplitBunch(acctSplitBunch);
  381. }
  382. } else {
  383. order.setRefundAmount(new BigDecimal(ordAmt).setScale(2, RoundingMode.HALF_UP));
  384. if (new BigDecimal(ordAmt).setScale(2, RoundingMode.HALF_UP).compareTo(order.getPrice()) < 0) {
  385. // 重新设置分销
  386. acctSplitBunch = getAcctSplitBunch(proportion, order.getPrice()
  387. .subtract(new BigDecimal(ordAmt).setScale(2, RoundingMode.HALF_UP)), order.getCompanyType()).toString();
  388. order.setAcctSplitBunch(acctSplitBunch);
  389. }
  390. }
  391. try {
  392. esTOrderService.updateDataById(order);
  393. } catch (Exception e) {
  394. e.printStackTrace();
  395. } finally {
  396. orderService.updateById(order);
  397. }
  398. return "RECV_ORD_ID_" + refundOrderNo;
  399. }
  400. } catch (Exception e) {
  401. log.info("异步回调开始,参数,request={}", respData, e);
  402. }
  403. return "";
  404. }
  405. @Override
  406. public String alipayPay(String sn, BigDecimal amount, String productName, Long alipayId, String notifyUrl, String clientId) throws AlipayApiException {
  407. TAlipayConfig tAlipayConfig = alipayConfigService.getById(alipayId);
  408. AlipayConfig alipayConfig = new AlipayConfig();
  409. alipayConfig.setAppId(tAlipayConfig.getAppId());
  410. alipayConfig.setPrivateKey(tAlipayConfig.getPrivateKey());
  411. alipayConfig.setFormat("json");
  412. alipayConfig.setAlipayPublicKey(tAlipayConfig.getAlipayPublicKey());
  413. alipayConfig.setCharset("UTF-8");
  414. alipayConfig.setSignType("RSA2");
  415. AlipayClient alipayClient = new DefaultAlipayClient(alipayConfig);
  416. AlipayTradePrecreateRequest request = new AlipayTradePrecreateRequest();
  417. AlipayTradePrecreateModel model = new AlipayTradePrecreateModel();
  418. model.setOutTradeNo(sn);
  419. model.setTotalAmount(amount.toString());
  420. model.setSubject(productName);
  421. model.setSellerId(tAlipayConfig.getSellerId());
  422. model.setTerminalId(clientId);
  423. request.setBizModel(model);
  424. request.setNotifyUrl(notifyUrl);
  425. AlipayTradePrecreateResponse response = alipayClient.execute(request);
  426. System.out.println(response.getBody());
  427. log.info("支付宝扫码支付接口返回结果:{}", response.getBody());
  428. if (response.isSuccess()) {
  429. log.info("调用支付宝扫码支付接口成功:{}", response.getBody());
  430. System.out.println("二维码地址:" + response.getQrCode());
  431. return response.getQrCode();
  432. } else {
  433. System.out.println("调用失败");
  434. log.info("调用支付宝扫码支付接口失败:{}", response.getBody());
  435. return null;
  436. }
  437. }
  438. @Transactional(rollbackFor = Exception.class)
  439. @Override
  440. public void processAlipayOrder(Map<String, String> params, TOrder order) {
  441. log.info("处理订单");
  442. if (order.getStatus() != 0) {
  443. return;
  444. }
  445. order.setStatus(1);
  446. // 交易时间
  447. String gmtPayment = params.get("gmt_payment");
  448. Date date = new Date();
  449. try {
  450. date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(gmtPayment);
  451. } catch (ParseException e) {
  452. // 忽略时间转换错误
  453. }
  454. order.setPayDate(date);
  455. // 支付宝交易号
  456. String tradeNo = params.get("trade_no");
  457. order.setTrxNo(tradeNo);
  458. // 更新订单明细状态
  459. LambdaQueryWrapper<TOrderDetails> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  460. lambdaQueryWrapper.eq(TOrderDetails::getOrderSn, order.getSn());
  461. List<TOrderDetails> orderDetails = orderDetailsService.list(lambdaQueryWrapper);
  462. for (TOrderDetails orderDetail : orderDetails) {
  463. orderDetail.setRefundStatus("1");
  464. orderDetailsService.updateById(orderDetail);
  465. }
  466. // 发送支付成功消息给设备
  467. TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(order.getClientId()));
  468. JSONObject kindData = new JSONObject();
  469. kindData.put("sn", order.getSn());
  470. kindData.put("productName", order.getProductName());
  471. if (!order.getIsNotified().equals("1")) {
  472. String paySuccess = equipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("pay_success", kindData.toString()).toString());
  473. if (paySuccess.equals("success")) {
  474. order.setIsNotified("1");
  475. }
  476. // 推送微信订单
  477. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin(String.valueOf(order.getAdminId())));
  478. // 判断是否开启订单推送功能
  479. if (admin != null && StringUtils.isNotEmpty(admin.getOrderNotice()) && admin.getOrderNotice().equals("1")) {
  480. String openId = R.getDataIfSuccess(szwlFeign.getOpenId(order.getAdminId()));
  481. // 获取openId
  482. if (StringUtils.isNotEmpty(openId)) {
  483. orderService.newSendWechatMessage(openId, equipment, order, admin.getCompanyType());
  484. }
  485. }
  486. }
  487. orderService.updateById(order);
  488. try {
  489. // 保存订单信息到ES
  490. if (order.getProductNumber() == null || order.getProductNumber() == 0) {
  491. order.setProductNumber(1);
  492. }
  493. orderFeign.saveToEs(order);
  494. } catch (Exception e) {
  495. e.printStackTrace();
  496. }
  497. }
  498. @Override
  499. public void sendWechatMessage(String openId, TEquipment equipment, TOrder order, String companyType) {
  500. String accessToken = "";
  501. try {
  502. if (StringUtils.isEmpty(companyType) || companyType.equals("0")) {
  503. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin("2738"));
  504. accessToken = admin.getApiKey();
  505. log.info("申泽的accessToken:{}", accessToken);
  506. } else {
  507. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin("2739"));
  508. accessToken = admin.getApiKey();
  509. log.info("七云的accessToken:{}", accessToken);
  510. }
  511. } catch (Exception e) {
  512. e.printStackTrace();
  513. }
  514. // 推送消息
  515. // 模板参数
  516. Map<String, WeChatTemplateMsg> sendMag = new HashMap();
  517. // 转换时间为String类型
  518. SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  519. String payTime = format.format(order.getPayDate());
  520. // 模版参数
  521. if (StringUtils.isNotEmpty(equipment.getName())) {
  522. if (equipment.getName().length() > 20) {
  523. sendMag.put("thing15", new WeChatTemplateMsg(equipment.getName().substring(0, 15) + "..."));
  524. } else {
  525. sendMag.put("thing15", new WeChatTemplateMsg(equipment.getName()));
  526. }
  527. } else {
  528. String clientId = equipment.getClientId();
  529. sendMag.put("thing15", new WeChatTemplateMsg(clientId.substring(clientId.length() - 6)));
  530. }
  531. if (order.getProductName().length() > 20) {
  532. sendMag.put("thing37", new WeChatTemplateMsg(order.getProductName().substring(0, 15) + "..."));
  533. } else {
  534. sendMag.put("thing37", new WeChatTemplateMsg(order.getProductName()));
  535. }
  536. sendMag.put("character_string8", new WeChatTemplateMsg(order.getSn()));
  537. sendMag.put("amount34", new WeChatTemplateMsg(order.getPrice().toString()));
  538. sendMag.put("time36", new WeChatTemplateMsg(payTime));
  539. RestTemplate restTemplate = new RestTemplate();
  540. Map<String, Object> sendBody = new HashMap<>();
  541. sendBody.put("touser", openId);
  542. sendBody.put("topcolor", "#FF0000");
  543. sendBody.put("data", sendMag);
  544. if (StringUtils.isEmpty(companyType) || companyType.equals("0")) {
  545. sendBody.put("template_id", HuifuConstant.SZ_TEMPLATE_ID);
  546. } else {
  547. sendBody.put("template_id", HuifuConstant.SC_TEMPLATE_ID);
  548. }
  549. sendMessage(accessToken, restTemplate, sendBody);
  550. }
  551. @Override
  552. public void newSendWechatMessage(String openId, TEquipment equipment, TOrder order, String companyType) {
  553. String accessToken = "";
  554. try {
  555. if (StringUtils.isEmpty(companyType) || companyType.equals("0")) {
  556. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin("2738"));
  557. accessToken = admin.getApiKey();
  558. log.info("申泽的accessToken:{}", accessToken);
  559. } else {
  560. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin("2739"));
  561. accessToken = admin.getApiKey();
  562. log.info("七云的accessToken:{}", accessToken);
  563. }
  564. } catch (Exception e) {
  565. e.printStackTrace();
  566. }
  567. // 推送消息
  568. // 模板参数
  569. Map<String, WeChatTemplateMsg> sendMag = new HashMap();
  570. // 转换时间为String类型
  571. SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  572. String payTime = format.format(order.getPayDate());
  573. // 模版参数
  574. // 设备名称
  575. if (StringUtils.isNotEmpty(equipment.getName())) {
  576. if (equipment.getName().length() > 20) {
  577. sendMag.put("thing15", new WeChatTemplateMsg(equipment.getName().substring(0, 15) + "..."));
  578. } else {
  579. sendMag.put("thing15", new WeChatTemplateMsg(equipment.getName()));
  580. }
  581. } else {
  582. String clientId = equipment.getClientId();
  583. sendMag.put("thing15", new WeChatTemplateMsg(clientId.substring(clientId.length() - 6)));
  584. }
  585. // 订单编号
  586. sendMag.put("character_string8", new WeChatTemplateMsg(order.getSn()));
  587. // 交易金额
  588. sendMag.put("amount29", new WeChatTemplateMsg(order.getPrice().toString()));
  589. // 支付方式
  590. sendMag.put("const44", new WeChatTemplateMsg(checkPayType(order.getFrpCode())));
  591. // 交易时间
  592. sendMag.put("time36", new WeChatTemplateMsg(payTime));
  593. RestTemplate restTemplate = new RestTemplate();
  594. Map<String, Object> sendBody = new HashMap<>();
  595. sendBody.put("touser", openId);
  596. sendBody.put("topcolor", "#FF0000");
  597. sendBody.put("data", sendMag);
  598. if (StringUtils.isEmpty(companyType) || companyType.equals("0")) {
  599. sendBody.put("template_id", HuifuConstant.NEW_SZ_TEMPLATE_ID);
  600. } else {
  601. sendBody.put("template_id", HuifuConstant.NEW_SC_TEMPLATE_ID);
  602. }
  603. sendMessage(accessToken, restTemplate, sendBody);
  604. }
  605. public String sqCardPay(String orderNo, BigDecimal amount, String productName, String authCode, TSqbConfig sqbConfig, String userName, String ip) {
  606. HttpProxy hp = new HttpProxy(ShouQianBaConstant.API_DOMAIN);
  607. try {
  608. CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
  609. // 异步调用支付接口
  610. String payResult = hp.pay(
  611. ip, sqbConfig.getTerminalSn(), sqbConfig.getNewTerminalKey(), orderNo, authCode, amount.toString(), productName, userName);
  612. log.info("支付结果:{}", payResult);
  613. return payResult;
  614. });
  615. try {
  616. Thread.sleep(3000);
  617. } catch (InterruptedException e) {
  618. e.printStackTrace();
  619. }
  620. long startTimestampMs = System.currentTimeMillis();
  621. String orderStatus = "";
  622. while (System.currentTimeMillis() - startTimestampMs < ShouQianBaConstant.REMAINING_TIME) {
  623. String query = hp.query(
  624. sqbConfig.getTerminalSn(), sqbConfig.getNewTerminalKey(), orderNo);
  625. log.info("查询结果:{}", query);
  626. JSONObject queryJsonObject = JSON.parseObject(query);
  627. JSONObject bizResponse = queryJsonObject.getJSONObject("biz_response");
  628. String resultCode = bizResponse.getString("result_code");
  629. if (resultCode.equals(ShouQianBaConstant.FAIL)) {
  630. break;
  631. }
  632. orderStatus = bizResponse.getJSONObject("data")
  633. .getString("order_status");
  634. if (orderStatus.equals(ShouQianBaConstant.PAID)) {
  635. log.info("订单支付成功:{}", orderNo);
  636. // JSONObject bizResponse = queryJsonObject.getJSONObject("biz_response");
  637. // 付款时间
  638. String channelFinishTime = bizResponse.getJSONObject("data").getString("channel_finish_time");
  639. // 收钱吧订单号
  640. String sn = bizResponse.getJSONObject("data").getString("sn");
  641. LambdaQueryWrapper<TOrder> queryWrapper = Wrappers.lambdaQuery();
  642. queryWrapper.eq(TOrder::getSn, orderNo);
  643. queryWrapper.eq(TOrder::getStatus, 0);
  644. TOrder order = getOne(queryWrapper);
  645. if (order != null) {
  646. order.setStatus(1);
  647. order.setTrxNo(sn);
  648. Date date = new Date();
  649. try {
  650. date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(channelFinishTime);
  651. } catch (ParseException e) {
  652. // 忽略时间转换错误
  653. }
  654. order.setPayDate(date);
  655. // 更新订单明细状态
  656. LambdaQueryWrapper<TOrderDetails> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  657. lambdaQueryWrapper.eq(TOrderDetails::getOrderSn, orderNo);
  658. List<TOrderDetails> orderDetails = orderDetailsService.list(lambdaQueryWrapper);
  659. for (TOrderDetails orderDetail : orderDetails) {
  660. orderDetail.setRefundStatus("1");
  661. orderDetailsService.updateById(orderDetail);
  662. }
  663. // 发送支付成功消息给设备
  664. TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(order.getClientId()));
  665. JSONObject kindData = new JSONObject();
  666. kindData.put("sn", order.getSn());
  667. kindData.put("productName", order.getProductName());
  668. if (!order.getIsNotified().equals("1")) {
  669. String paySuccess = equipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("pay_success", kindData.toString()).toString());
  670. if (paySuccess.equals("success")) {
  671. order.setIsNotified("1");
  672. }
  673. // 推送微信订单
  674. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin(String.valueOf(order.getAdminId())));
  675. // 判断是否开启订单推送功能
  676. if (admin != null && StringUtils.isNotEmpty(admin.getOrderNotice()) && admin.getOrderNotice().equals("1")) {
  677. String openId = R.getDataIfSuccess(szwlFeign.getOpenId(order.getAdminId()));
  678. // 获取openId
  679. if (StringUtils.isNotEmpty(openId)) {
  680. orderService.newSendWechatMessage(openId, equipment, order, admin.getCompanyType());
  681. }
  682. }
  683. }
  684. orderService.updateById(order);
  685. try {
  686. // 保存订单信息到ES
  687. if (order.getProductNumber() == null || order.getProductNumber() == 0) {
  688. order.setProductNumber(1);
  689. }
  690. orderFeign.saveToEs(order);
  691. } catch (Exception e) {
  692. e.printStackTrace();
  693. }
  694. }
  695. break;
  696. } else if (!orderStatus.equals(ShouQianBaConstant.CREATED) && !orderStatus.equals(ShouQianBaConstant.PAY_ERROR)) {
  697. break;
  698. }
  699. try {
  700. Thread.sleep(3000);
  701. } catch (InterruptedException e) {
  702. e.printStackTrace();
  703. }
  704. }
  705. return orderStatus;
  706. } catch (Exception e) {
  707. e.printStackTrace();
  708. }
  709. return null;
  710. }
  711. @Override
  712. public JsonMessage sqbCardPay(String authCode, String frpCode, String clientId, String ip, Map<String, String> productNameMap) {
  713. if (productNameMap == null) {
  714. return JsonMessage.error("数据出错");
  715. }
  716. if (StringUtils.isEmpty(ip)) {
  717. return JsonMessage.error("ip不能为空");
  718. }
  719. if (!authCode.startsWith("0100")) {
  720. return JsonMessage.error("请使用数币钱包支付");
  721. }
  722. StringBuilder note = new StringBuilder();
  723. StringBuilder productName = new StringBuilder();
  724. String productNo = "";
  725. Map<String, Integer> productMap = new HashMap<>();
  726. int productNumber = 0;
  727. TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(clientId));
  728. if (equipment == null || equipment.getId() == null) {
  729. return JsonMessage.error("找不到设备");
  730. }
  731. BigDecimal price = new BigDecimal("0.00");
  732. TEquipmentDesc equipmentDesc = R.getDataIfSuccess(szwlFeign.findEquipmentById(equipment.getId()));
  733. if (equipmentDesc == null || equipmentDesc.getEquipmentId() == null || equipmentDesc.getPayType() == null || equipmentDesc.getPayType().equals("0")) {
  734. for (String key : productNameMap.keySet()) {
  735. String entryValue = String.valueOf(productNameMap.get(key));
  736. List<String> value = JSON.parseArray(entryValue, String.class);
  737. List<TPromoCode> promoCodeList = new ArrayList<>();
  738. //1,校验优惠码
  739. if (value.size() > 0) {
  740. for (String code : value) {
  741. if (!code.equals("0")) {
  742. TPromoCode promoCode = new TPromoCode();
  743. ResponseModel<TPromoCode> tPromoCodeResponseModel = szwlFeign.selectTPromoCode(code, equipment.getAdminId().toString());
  744. TPromoCode tPromoCode = tPromoCodeResponseModel.getData();
  745. promoCode = tPromoCode;
  746. if (tPromoCode == null || tPromoCode.getId() == null) {
  747. //不存在
  748. return JsonMessage.success("1");
  749. }
  750. Date lastUseDate = null;
  751. if (promoCode != null) {
  752. lastUseDate = promoCode.getLastUseDate();
  753. }
  754. if (lastUseDate != null && lastUseDate.getTime() < ((new Date()).getTime())) {
  755. promoCode.setIsUse("2");
  756. szwlFeign.updatePromoCode(String.valueOf(promoCode.getId()), "2");
  757. //过期
  758. return JsonMessage.success("4");
  759. }
  760. if (promoCode.getId() == null) {
  761. //不存在
  762. return JsonMessage.success("1");
  763. }
  764. if (promoCode.getIsUse().equals("1")) {
  765. //被使用
  766. return JsonMessage.success("2");
  767. }
  768. if (!promoCode.getAdminId().equals("1")) {
  769. if (!String.valueOf(equipment.getAdminId()).equals(promoCode.getAdminId())) {
  770. return JsonMessage.success("3");
  771. }
  772. }
  773. if (promoCode.getDiscount() == null) {
  774. //旧优惠码
  775. return JsonMessage.success("0");
  776. }
  777. if (promoCode.getDiscount() != null && promoCode.getDiscount() == 0) {
  778. //0折
  779. return JsonMessage.success("0");
  780. }
  781. promoCodeList.add(promoCode);
  782. }
  783. }
  784. }
  785. String[] productNum = key.split("-");
  786. String productNamea = productNum[0];
  787. String num = productNum[1];
  788. productMap.put(productNamea, Integer.valueOf(num));
  789. productNumber += Integer.parseInt(num);
  790. productName.append(productNamea).append("x").append(num).append(",");
  791. TProduct product = R.getDataIfSuccess(szwlFeign.getProduct(String.valueOf(equipment.getId()), productNamea));
  792. if (product == null) {
  793. return JsonMessage.error("找不到商品");
  794. }
  795. note.append(productNamea).append("-").append(product.getNo()).append(":");
  796. BigDecimal productPrice = product.getRmbPrice();
  797. productNo = product.getNo();
  798. if (promoCodeList.size() > 0) {
  799. //有优惠码
  800. BigDecimal onePrice = new BigDecimal("0.00");
  801. int i;
  802. for (i = 0; i < promoCodeList.size(); i++) {
  803. BigDecimal discount = BigDecimal.valueOf(promoCodeList.get(i).getDiscount()).setScale(2, RoundingMode.HALF_DOWN);
  804. BigDecimal price1 = productPrice.multiply(discount).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN);
  805. price = price.add(price1);
  806. onePrice = onePrice.add(price1);
  807. }
  808. if (i < Integer.parseInt(num)) {
  809. int a = Integer.parseInt(num) - i;
  810. BigDecimal price2 = productPrice.multiply(new BigDecimal(a)).setScale(2, RoundingMode.HALF_DOWN);
  811. price = price.add(price2);
  812. onePrice = onePrice.add(price2);
  813. }
  814. note.append(onePrice).append("-").append(num).append(",");
  815. } else {
  816. //1,type=0,原始设定,没有第二件半价
  817. int a = Integer.parseInt(num);
  818. BigDecimal price2 = productPrice.multiply(new BigDecimal(a)).setScale(2, RoundingMode.HALF_DOWN);
  819. price = price.add(price2);
  820. note.append(price2).append("-").append(num).append(",");
  821. }
  822. }
  823. } else {
  824. for (String key : productNameMap.keySet()) {
  825. String[] productNum = key.split("-");
  826. String productNamea = productNum[0];
  827. String num = productNum[1];
  828. productMap.put(productNamea, Integer.valueOf(num));
  829. TProduct product = R.getDataIfSuccess(szwlFeign.getProduct(String.valueOf(equipment.getId()), productNamea));
  830. productNo = product.getNo();
  831. BigDecimal productPrice = product.getRmbPrice();
  832. productName.append(productNamea).append("x").append(num).append(",");
  833. note.append(productNamea).append("-").append(product.getNo()).append(":");
  834. switch (num) {
  835. case "1":
  836. //1个 0个半价
  837. price = price.add(productPrice);
  838. note.append(price).append("-").append(num).append(",");
  839. break;
  840. case "2":
  841. //2个 1个半价
  842. price = price.add(productPrice);
  843. price = price.add(productPrice.multiply(new BigDecimal(5)).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN));
  844. note.append(price).append("-").append(num).append(",");
  845. break;
  846. case "3":
  847. //3个 1个半价
  848. price = price.add(productPrice);
  849. price = price.add(productPrice.multiply(new BigDecimal(5)).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN));
  850. price = price.add(productPrice);
  851. note.append(price).append("-").append(num).append(",");
  852. break;
  853. case "4":
  854. //4个 2个半价
  855. price = price.add(productPrice);
  856. price = price.add(productPrice.multiply(new BigDecimal(5)).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN));
  857. price = price.add(productPrice);
  858. price = price.add(productPrice.multiply(new BigDecimal(5)).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN));
  859. note.append(price).append("-").append(num).append(",");
  860. break;
  861. case "5":
  862. //5个 2个半价
  863. price = price.add(productPrice);
  864. price = price.add(productPrice.multiply(new BigDecimal(5)).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN));
  865. price = price.add(productPrice);
  866. price = price.add(productPrice.multiply(new BigDecimal(5)).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN));
  867. price = price.add(productPrice);
  868. note.append(price).append("-").append(num).append(",");
  869. break;
  870. }
  871. }
  872. }
  873. Long equipmentId = equipment.getId();
  874. //查找商品
  875. if (BigDecimal.ZERO.compareTo(price) >= 0) {
  876. return JsonMessage.error("商品价格异常");
  877. }
  878. Long client6 = Long.parseLong(clientId.substring(clientId.length() - 6));
  879. String sn = orderService.initSn(client6);
  880. //获取分销 关联设备
  881. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin(String.valueOf(equipment.getAdminId())));
  882. // 获取收钱吧配置
  883. LambdaQueryWrapper<TSqbConfig> sqbConfigQuery = Wrappers.lambdaQuery();
  884. sqbConfigQuery.eq(TSqbConfig::getAdminId, admin.getId());
  885. TSqbConfig sqbConfig = sqbConfigService.getOne(sqbConfigQuery);
  886. if (sqbConfig == null) {
  887. return JsonMessage.error("商户未配置");
  888. }
  889. // 查询是否签到,没有的话就进行签到
  890. if (StringUtils.isNotEmpty(sqbConfig.getCheckin()) && sqbConfig.getCheckin().equals("0")) {
  891. HttpProxy hp = new HttpProxy(ShouQianBaConstant.API_DOMAIN_CONFIG);
  892. org.json.JSONObject terminal = hp.checkin(sqbConfig.getDeviceId(), sqbConfig.getTerminalSn(), sqbConfig.getTerminalKey());
  893. if (terminal == null) {
  894. return JsonMessage.error("签到失败");
  895. }
  896. String newTerminalKey = terminal.getString("terminal_key");
  897. sqbConfig.setTerminalKey(newTerminalKey);
  898. sqbConfig.setNewTerminalKey(newTerminalKey);
  899. sqbConfig.setCheckin("1");
  900. sqbConfigService.updateById(sqbConfig);
  901. }
  902. String companyType = admin.getCompanyType();
  903. BigDecimal amount = price.setScale(2, RoundingMode.HALF_DOWN);
  904. amount = amount.multiply(new BigDecimal(100)).setScale(0);
  905. TOrder order = new TOrder();
  906. order.setId(IDGenerator.orderID());
  907. order.setCreateDate(new Date());
  908. order.setModifyDate(new Date());
  909. order.setAdminId(admin.getId());
  910. order.setSn(sn);
  911. if (productNumber == 1) {
  912. productName.delete(productName.length() - 3, productName.length());
  913. } else {
  914. productName.deleteCharAt(productName.length() - 1);
  915. }
  916. order.setProductName(productName.toString());
  917. order.setPrice(price);
  918. order.setClientId(equipment.getClientId());
  919. order.setEquipmentId(equipmentId);
  920. order.setFrpCode(frpCode);
  921. order.setProductNumber(productNumber);
  922. order.setStatus(0);
  923. String payPlatform = "4";
  924. order.setPayPlatform(payPlatform);
  925. order.setCompanyType(companyType);
  926. order.setMachineType(equipment.getMachineType());
  927. order.setProductNo(productNo);
  928. order.setNote(note.toString());
  929. // 订单明细表
  930. TOrderDetails orderDetails = new TOrderDetails();
  931. orderDetails.setAdminId(admin.getId());
  932. orderDetails.setEquipmentId(equipmentId);
  933. orderDetails.setCreateDate(new Date());
  934. orderDetails.setCompanyType(companyType);
  935. orderDetails.setRefundStatus("0");
  936. orderDetails.setMachineType(equipment.getMachineType());
  937. // 添加到订单明细表
  938. for (String key : productMap.keySet()) {
  939. Integer productNum = productMap.get(key);
  940. TProduct product = R.getDataIfSuccess(szwlFeign.getProduct(String.valueOf(equipment.getId()), key));
  941. orderDetails.setProductNo(product.getNo());
  942. orderDetails.setProductName(key);
  943. orderDetails.setPrice(product.getRmbPrice());
  944. orderDetails.setProductNumber(productNum);
  945. orderDetails.setAmount(product.getRmbPrice().multiply(new BigDecimal(productNum)));
  946. orderDetails.setId(HuifuUtils.initDetailsId());
  947. orderDetails.setOrderSn(sn);
  948. orderDetailsService.save(orderDetails);
  949. }
  950. orderService.save(order);
  951. String productName1 = "";
  952. if (productNumber > 1) {
  953. productName1 = "棉花糖";
  954. } else {
  955. productName1 = productName.toString();
  956. }
  957. String result;
  958. try {
  959. result = sqCardPay(
  960. sn, amount, productName1, authCode, sqbConfig, admin.getUsername(), ip
  961. );
  962. } catch (Exception e) {
  963. e.printStackTrace();
  964. return JsonMessage.error("申请支付失败");
  965. }
  966. // 微信支付支付申请返回支付二维码图片
  967. if (result.equals(ShouQianBaConstant.PAID)) {
  968. JSONObject kindData = new JSONObject();
  969. kindData.put("sn", sn);
  970. return JsonMessage.success(kindData.toString());
  971. } else {
  972. return JsonMessage.error("支付失败");
  973. }
  974. }
  975. @Override
  976. public ResponseModel<?> sqbRefund(TOrder torder) {
  977. // 退款金额: refusePrice
  978. BigDecimal refusePrice = torder.getPrice().setScale(2, RoundingMode.HALF_DOWN);
  979. // 退款数量: refundNumber
  980. Integer refundNumber = torder.getProductNumber();
  981. // 退款明细:note
  982. String note = torder.getNote();
  983. String[] refundDetails = note.split(",");
  984. Map<String, Integer> refundMap = new HashMap<>();
  985. for (String refundDetail : refundDetails) {
  986. String[] keyValue = refundDetail.split("-");
  987. String key = keyValue[0];
  988. String value = keyValue[1];
  989. refundMap.put(key, Integer.valueOf(value));
  990. }
  991. if (refusePrice.compareTo(new BigDecimal("0.00")) <= 0) {
  992. return R.fail(ResponseCodesEnum.A0001, "退款金额非法");
  993. }
  994. TOrder order = orderService.getById(torder.getId());
  995. if (order.getRefundQuantity() != null && order.getRefundQuantity() > 0) {
  996. order.setRefundQuantity(refundNumber + order.getRefundQuantity());
  997. } else {
  998. order.setRefundQuantity(refundNumber);
  999. }
  1000. if (refusePrice.compareTo(order.getPrice()) > 0) {
  1001. return R.fail(ResponseCodesEnum.A0001, "退款金额非法");
  1002. }
  1003. if (order.getRefundAmount() != null && order.getRefundAmount().add(refusePrice).compareTo(order.getPrice()) > 0) {
  1004. return R.fail(ResponseCodesEnum.A0001, "退款金额非法");
  1005. }
  1006. if (order.getStatus().equals("0")) {
  1007. return R.fail(ResponseCodesEnum.A0002, "订单非支付状态");
  1008. }
  1009. // 获取收钱吧配置
  1010. LambdaQueryWrapper<TSqbConfig> sqbConfigQuery = Wrappers.lambdaQuery();
  1011. sqbConfigQuery.eq(TSqbConfig::getAdminId, order.getAdminId());
  1012. TSqbConfig sqbConfig = sqbConfigService.getOne(sqbConfigQuery);
  1013. if (sqbConfig == null) {
  1014. return R.fail(ResponseCodesEnum.A0002, "商户未配置");
  1015. }
  1016. LambdaQueryWrapper<TOrderDetails> wrapper = new LambdaQueryWrapper<>();
  1017. wrapper.eq(TOrderDetails::getOrderSn, order.getSn());
  1018. List<TOrderDetails> orderDetails = orderDetailsService.list(wrapper);
  1019. HttpProxy hp = new HttpProxy(ShouQianBaConstant.API_DOMAIN);
  1020. try {
  1021. String amount = refusePrice.multiply(new BigDecimal(100)).setScale(0).toString();
  1022. String refund = hp.refund(sqbConfig.getTerminalSn(), sqbConfig.getNewTerminalKey(), order.getSn(), amount);
  1023. log.info("退款结果:{}", refund);
  1024. JSONObject jsonObject = JSON.parseObject(refund);
  1025. String resultCode = jsonObject.getString("result_code");
  1026. log.info("下单结果码:{}", resultCode);
  1027. if (resultCode.equals("200")) {
  1028. String bizResultCode = jsonObject.getJSONObject("biz_response").getString("result_code");
  1029. log.info("下单业务结果码:{}", bizResultCode);
  1030. if (bizResultCode.equals(ShouQianBaConstant.REFUND_SUCCESS)) {
  1031. String orderStatus = jsonObject.getJSONObject("biz_response").getJSONObject("data").getString("order_status");
  1032. log.info("订单状态:{}", orderStatus);
  1033. if (orderStatus.equals(ShouQianBaConstant.REFUNDED) || orderStatus.equals(ShouQianBaConstant.PARTIAL_REFUNDED)) {
  1034. // 退款序列号
  1035. String refundRequestNo = jsonObject.getJSONObject("biz_response").getJSONObject("data").getString("refund_request_no");
  1036. // 退款成功
  1037. // 已退款
  1038. if (order.getRefundQuantity() < order.getProductNumber()) {
  1039. order.setStatus(1);
  1040. } else {
  1041. order.setStatus(3);
  1042. }
  1043. orderService.updateById(order);
  1044. // 修改订单明细
  1045. for (TOrderDetails orderDetail : orderDetails) {
  1046. String orderDetailId = orderDetail.getId();
  1047. Integer productNumber = refundMap.get(orderDetailId);
  1048. if (productNumber != null) {
  1049. // 退款数量
  1050. orderDetail.setRefundQuantity(productNumber);
  1051. // 退款状态
  1052. if (productNumber < orderDetail.getProductNumber()) {
  1053. // 部分退款
  1054. orderDetail.setRefundStatus("2");
  1055. } else {
  1056. // 全部退款
  1057. orderDetail.setRefundStatus("3");
  1058. }
  1059. // 退款金额
  1060. orderDetail.setRefundAmount(orderDetail.getPrice().multiply(new BigDecimal(productNumber)));
  1061. orderDetailsService.updateById(orderDetail);
  1062. }
  1063. }
  1064. // 已退款金额
  1065. BigDecimal refundAmount = order.getRefundAmount();
  1066. BigDecimal price = order.getPrice();
  1067. if (refundAmount != null) {
  1068. if (price.compareTo(refundAmount) == 0) {
  1069. order.setRefundAmount(refundAmount);
  1070. } else {
  1071. order.setRefundAmount(refundAmount.add(refusePrice));
  1072. }
  1073. } else {
  1074. order.setRefundAmount(refusePrice);
  1075. }
  1076. // 退款时间
  1077. order.setRefundDate(new Date());
  1078. order.setModifyDate(new Date());
  1079. order.setRefundTrxNo(refundRequestNo);
  1080. try {
  1081. orderFeign.saveToEs(order);
  1082. } catch (Exception e) {
  1083. e.printStackTrace();
  1084. } finally {
  1085. orderService.updateById(order);
  1086. }
  1087. return R.ok("申请退款已成功");
  1088. }
  1089. }
  1090. }
  1091. } catch (Exception e) {
  1092. e.printStackTrace();
  1093. }
  1094. return R.fail(ResponseCodesEnum.B0001, "申请退款失败,请联系管理员");
  1095. }
  1096. @Override
  1097. public JsonMessage scanpay(String code, String clientId, String productName, String frpCode, String pri) {
  1098. TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(clientId));
  1099. if (equipment == null || equipment.getId() == null) {
  1100. return JsonMessage.error("找不到设备");
  1101. }
  1102. // 验证优惠码,code为空则不选用优惠码
  1103. TPromoCode promoCode = new TPromoCode();
  1104. if (StringUtils.isNotEmpty(code)) {
  1105. //有优惠码,需要对优惠码进行验证
  1106. ResponseModel<TPromoCode> tPromoCodeResponseModel = szwlFeign.selectTPromoCode(code, equipment.getAdminId().toString());
  1107. promoCode = tPromoCodeResponseModel.getData();
  1108. String checkCode = checkCode(promoCode, equipment);
  1109. if (StringUtils.isNotEmpty(checkCode)) {
  1110. return JsonMessage.success(checkCode);
  1111. }
  1112. }
  1113. // 支付方式
  1114. if (!ConfigConsts.ALIPAY_NATIVE.equals(frpCode) && !ConfigConsts.WECHAT_NATIVE.equals(frpCode)) {
  1115. return JsonMessage.error("参数错误");
  1116. }
  1117. Long equipmentId = equipment.getId();
  1118. // 查找商品
  1119. ResponseModel<TProduct> product1 = szwlFeign.getProduct(String.valueOf(equipmentId), productName);
  1120. TProduct product = product1.getData();
  1121. if (product == null) {
  1122. return JsonMessage.error("找不到商品");
  1123. }
  1124. BigDecimal price = product.getRmbPrice();
  1125. if (StringUtils.isNotEmpty(pri)) {
  1126. price = new BigDecimal(pri);
  1127. }
  1128. // 计算折扣后的价格
  1129. if (StringUtils.isNotEmpty(code)) {
  1130. BigDecimal discount = BigDecimal.valueOf(promoCode.getDiscount());
  1131. if (StringUtils.isNotEmpty(promoCode.getType()) && promoCode.getType().equals("1")) {
  1132. if (price.compareTo(discount) > 0) {
  1133. // 如果 price 大于 discount,从 price 中减去 discount
  1134. price = price.subtract(discount).setScale(2, RoundingMode.HALF_DOWN);
  1135. } else {
  1136. // 如果 price 小于等于 discount,将 price 设置为 0
  1137. return JsonMessage.success("0");
  1138. }
  1139. } else {
  1140. price = product.getRmbPrice().multiply(discount).divide(new BigDecimal(10)).setScale(2, RoundingMode.HALF_DOWN);
  1141. }
  1142. }
  1143. // 判断价格是否小于等于0
  1144. if (BigDecimal.ZERO.compareTo(price) >= 0) {
  1145. return JsonMessage.error("商品价格异常");
  1146. }
  1147. // 生成订单编号
  1148. Long client6 = Long.parseLong(clientId.substring(clientId.length() - 6));
  1149. String sn = orderService.initSn(client6);
  1150. // 获取关联设备的分销
  1151. TProportion proportion = R.getDataIfSuccess(szwlFeign.getProportion(String.valueOf(equipmentId)));
  1152. if (proportion == null || proportion.getId() == null) {
  1153. return JsonMessage.error("设备商家未完成分销设置");
  1154. }
  1155. TAdmin admin = R.getDataIfSuccess(szwlFeign.getAdmin(String.valueOf(equipment.getAdminId())));
  1156. if (admin == null) {
  1157. return JsonMessage.error("找不到设备商家");
  1158. }
  1159. // 支付方式:0或null为汇聚,1为汇付支付
  1160. String payPlatform = admin.getPayPlatform();
  1161. String companyType = admin.getCompanyType();
  1162. // 汇聚分账参数
  1163. JSONArray altInfo = new JSONArray();
  1164. // 汇付分账明细参数
  1165. JSONObject acctSplitBunch = new JSONObject();
  1166. if (StringUtils.isNotEmpty(payPlatform) && payPlatform.equals("1")) {
  1167. acctSplitBunch = getAcctSplitBunch(proportion, price, companyType);
  1168. if (!(acctSplitBunch.size() > 0)) {
  1169. return JsonMessage.error("设备商家未注册结算账号");
  1170. }
  1171. } else {
  1172. altInfo = getAltInfo(proportion, price);
  1173. if (!(altInfo.size() > 0)) {
  1174. return JsonMessage.error("设备商家未注册结算账号");
  1175. }
  1176. }
  1177. BigDecimal amount = price.setScale(2, RoundingMode.HALF_DOWN);
  1178. String productDesc = "";
  1179. String commonParameter = "";
  1180. String returnUrl = null;
  1181. String notifyUrl = JoinpayConstant.Notify_Url;
  1182. String isShowPic = "1";
  1183. String openId = null;
  1184. String authCode = null;
  1185. String appid = null;
  1186. String transactionModel = null;
  1187. String tradeMerchantNo = admin.getTradeMerchantNo();
  1188. String buyerId = null;
  1189. String isAlt = "1";
  1190. String altType = "11";
  1191. String altUrl = null;
  1192. BigDecimal marketingAmount = null;
  1193. if (StringUtils.isNotEmpty(pri)) {
  1194. productName = "棉花糖";
  1195. }
  1196. Integer productNumber = 1;
  1197. TOrder order = new TOrder();
  1198. order.setId(IDGenerator.orderID());
  1199. order.setCreateDate(new Date());
  1200. order.setModifyDate(new Date());
  1201. order.setAdminId(admin.getId());
  1202. order.setSn(sn);
  1203. order.setProductId(product.getId());
  1204. order.setProductNo(product.getNo());
  1205. order.setProductName(productName);
  1206. order.setPrice(price);
  1207. order.setClientId(equipment.getClientId());
  1208. order.setEquipmentId(equipmentId);
  1209. order.setFrpCode(frpCode);
  1210. order.setAltInfo(altInfo.toString());
  1211. order.setStatus(0);
  1212. order.setType(admin.getType());
  1213. order.setProductNumber(productNumber);
  1214. order.setCompanyType(admin.getCompanyType());
  1215. order.setMachineType(equipment.getMachineType());
  1216. if (admin.getType() == 0) {
  1217. order.setAdminProportion(proportion.getAdminProportion());
  1218. order.setAgencyProportion(proportion.getAgencyProportion());
  1219. order.setAgencyId(proportion.getAgencyId());
  1220. }
  1221. if (admin.getType() == 1) {
  1222. order.setAdminProportion(proportion.getAdminProportion());
  1223. order.setAgencyProportion(proportion.getAgencyProportion());
  1224. order.setAgencyId(proportion.getAgencyId());
  1225. order.setMerchantProportion(proportion.getMerchantProportion());
  1226. order.setMerchantId(proportion.getMerchantId());
  1227. }
  1228. if (admin.getType() == 2) {
  1229. order.setAdminProportion(proportion.getAdminProportion());
  1230. order.setAgencyProportion(proportion.getAgencyProportion());
  1231. order.setAgencyId(proportion.getAgencyId());
  1232. order.setMerchantProportion(proportion.getMerchantProportion());
  1233. order.setMerchantId(proportion.getMerchantId());
  1234. order.setPersonageProportion(proportion.getPersonageProportion());
  1235. order.setPersonageId(proportion.getPersonageId());
  1236. }
  1237. order.setPayPlatform(payPlatform);
  1238. // 订单明细表
  1239. TOrderDetails orderDetails = new TOrderDetails();
  1240. orderDetails.setId(HuifuUtils.initDetailsId());
  1241. orderDetails.setAdminId(admin.getId());
  1242. orderDetails.setEquipmentId(equipmentId);
  1243. orderDetails.setCreateDate(new Date());
  1244. orderDetails.setOrderSn(sn);
  1245. orderDetails.setPrice(price);
  1246. orderDetails.setProductName(productName);
  1247. orderDetails.setProductNo(product.getNo());
  1248. orderDetails.setProductNumber(productNumber);
  1249. orderDetails.setAmount(price);
  1250. orderDetails.setRefundStatus("0");
  1251. orderDetails.setCompanyType(companyType);
  1252. orderDetails.setMachineType(equipment.getMachineType());
  1253. String productName1 = productName + "-" + equipment.getName() + "-" + client6;
  1254. String result = null;
  1255. if (StringUtils.isNotEmpty(payPlatform) && payPlatform.equals("1")) {
  1256. // 汇付分账参数
  1257. order.setAcctSplitBunch(acctSplitBunch.toString());
  1258. if (frpCode.equals(ConfigConsts.WECHAT_NATIVE)) {
  1259. //添加到汇付临时表
  1260. if (StrUtil.isNotEmpty(companyType) && companyType.equals("1")) {
  1261. result = HuifuConstant.SC_WECHAT_URL + "?price=" + price + "&sn=" + sn;
  1262. } else {
  1263. result = HuifuConstant.SZ_WECHAT_URL + "?price=" + price + "&sn=" + sn;
  1264. }
  1265. log.info("返回链接:{}", result);
  1266. String qrcode = CodeUtil.toQrcode(result);
  1267. JSONObject kindData = new JSONObject();
  1268. kindData.put("sn", sn);
  1269. kindData.put("rd_Pic", qrcode);
  1270. orderService.save(order);
  1271. orderDetailsService.save(orderDetails);
  1272. return JsonMessage.success(kindData.toString());
  1273. }
  1274. // 汇付支付
  1275. try {
  1276. result = huifuMchService.uniPay(
  1277. sn, amount, productName1, productDesc,
  1278. notifyUrl, frpCode, openId, appid, acctSplitBunch, companyType
  1279. );
  1280. } catch (Exception e) {
  1281. e.printStackTrace();
  1282. return JsonMessage.error("申请支付失败");
  1283. }
  1284. if (StrUtil.isEmpty(result)) {
  1285. return JsonMessage.error("找不到支付图片");
  1286. }
  1287. String qrcode = CodeUtil.toQrcode(result);
  1288. JSONObject kindData = new JSONObject();
  1289. kindData.put("sn", sn);
  1290. kindData.put("rd_Pic", qrcode);
  1291. orderService.save(order);
  1292. orderDetailsService.save(orderDetails);
  1293. return JsonMessage.success(kindData.toString());
  1294. } else {
  1295. try {
  1296. result = joinpayMchService.uniPay(
  1297. sn, amount, productName1, productDesc,
  1298. commonParameter, returnUrl, notifyUrl, frpCode,
  1299. isShowPic, openId, authCode, appid, transactionModel, tradeMerchantNo,
  1300. buyerId, isAlt, altType, altInfo, altUrl, marketingAmount
  1301. );
  1302. } catch (UnsupportedEncodingException e) {
  1303. e.printStackTrace();
  1304. return JsonMessage.error("申请支付失败");
  1305. }
  1306. JSONObject resultJson = JSONObject.parseObject(result);
  1307. // 汇聚支付支付申请返回支付二维码图片
  1308. String rdPic = resultJson.getString("rd_Pic");
  1309. if (StringUtils.isBlank(rdPic)) {
  1310. return JsonMessage.error("找不到支付图片");
  1311. }
  1312. JSONObject kindData = new JSONObject();
  1313. kindData.put("sn", sn);
  1314. kindData.put("rd_Pic", rdPic);
  1315. orderService.save(order);
  1316. orderDetailsService.save(orderDetails);
  1317. return JsonMessage.success(kindData.toString());
  1318. }
  1319. }
  1320. @Override
  1321. public JSONObject huifuPayCreate(String sn, String openid) {
  1322. // 查到指定订单
  1323. LambdaQueryWrapper<TOrder> wrapper = new LambdaQueryWrapper<>();
  1324. wrapper.eq(TOrder::getSn, sn);
  1325. wrapper.eq(TOrder::getStatus, 0);
  1326. TOrder order = orderService.getOne(wrapper);
  1327. JSONObject reslut = new JSONObject();
  1328. try {
  1329. reslut = huifuMchService.payWechat(order, openid);
  1330. } catch (Exception e) {
  1331. e.printStackTrace();
  1332. }
  1333. return reslut;
  1334. }
  1335. /**
  1336. * 发送微信消息
  1337. */
  1338. private void sendMessage(String accessToken, RestTemplate restTemplate, Map<String, Object> sendBody) {
  1339. String sendUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken;
  1340. ResponseEntity<String> forEntity = restTemplate.postForEntity(sendUrl, sendBody, String.class);
  1341. JSONObject jsonObject = JSONObject.parseObject(forEntity.getBody());
  1342. String messageCode = jsonObject.getString("errcode");
  1343. String msgId = jsonObject.getString("msgid");
  1344. System.out.println("messageCode : " + messageCode + ", msgId: " + msgId);
  1345. log.info("微信推送结果:{}", "messageCode : " + messageCode + ", msgId: " + msgId);
  1346. }
  1347. public void processRefund(Map<String, Object> bodyMap) {
  1348. String decrypt = wechatPayConfigService.decryptFromResource(bodyMap);
  1349. Gson gson = new Gson();
  1350. Map<String, Object> map = gson.fromJson(decrypt, HashMap.class);
  1351. String sn = map.get("out_trade_no").toString();
  1352. String refundNo = map.get("out_refund_no").toString();
  1353. String amount = map.get("amount").toString();
  1354. Map<String, Object> amountMap = gson.fromJson(amount, HashMap.class);
  1355. String refundPrice = amountMap.get("refund").toString();
  1356. if (StringUtils.isNotEmpty(sn)) {
  1357. LambdaQueryWrapper<TOrder> query = Wrappers.lambdaQuery();
  1358. query.eq(TOrder::getSn, sn);
  1359. TOrder order = getOne(query);
  1360. // 已退款
  1361. if (order.getRefundQuantity() < order.getProductNumber()) {
  1362. order.setStatus(1);
  1363. } else {
  1364. order.setStatus(3);
  1365. }
  1366. // 更改订单明细表
  1367. LambdaQueryWrapper<TOrderDetails> queryWrapper = new LambdaQueryWrapper<>();
  1368. queryWrapper.eq(TOrderDetails::getOrderSn, sn);
  1369. // 处理退款中状态的明细
  1370. queryWrapper.eq(TOrderDetails::getRefundStatus, "4");
  1371. List<TOrderDetails> tOrderDetails = orderDetailsService.list(queryWrapper);
  1372. for (TOrderDetails tOrderDetail : tOrderDetails) {
  1373. Integer refundQuantity = tOrderDetail.getRefundQuantity();
  1374. Integer productNumber = tOrderDetail.getProductNumber();
  1375. if (refundQuantity < productNumber) {
  1376. // 部分退款
  1377. tOrderDetail.setRefundStatus("2");
  1378. orderDetailsService.updateById(tOrderDetail);
  1379. } else {
  1380. // 全部退款
  1381. tOrderDetail.setRefundStatus("3");
  1382. orderDetailsService.updateById(tOrderDetail);
  1383. }
  1384. }
  1385. //退款金额要除以100
  1386. BigDecimal r4_refundAmount = new BigDecimal(refundPrice).divide(new BigDecimal(100), 2, BigDecimal.ROUND_HALF_UP).setScale(2, RoundingMode.HALF_DOWN);
  1387. // if(order.getRefundMarketingAmount()!=null){
  1388. // r4_refundAmount =r4_refundAmount.add(order.getRefundMarketingAmount());
  1389. // }
  1390. BigDecimal refundAmount = order.getRefundAmount();
  1391. BigDecimal price = order.getPrice();
  1392. if (refundAmount != null) {
  1393. if (price.compareTo(refundAmount) == 0) {
  1394. order.setRefundAmount(refundAmount);
  1395. } else {
  1396. order.setRefundAmount(refundAmount.add(r4_refundAmount));
  1397. }
  1398. } else {
  1399. order.setRefundAmount(r4_refundAmount);
  1400. }
  1401. order.setRefundDate(new Date());
  1402. order.setModifyDate(new Date());
  1403. order.setRefundTrxNo(refundNo);
  1404. try {
  1405. orderFeign.saveToEs(order);
  1406. } catch (Exception e) {
  1407. e.printStackTrace();
  1408. } finally {
  1409. updateById(order);
  1410. }
  1411. }
  1412. }
  1413. /**
  1414. * 验证优惠码
  1415. */
  1416. public String checkCode(TPromoCode promoCode, TEquipment equipment) {
  1417. //有优惠码,需要对优惠码进行验证
  1418. if (promoCode == null || promoCode.getId() == null) {
  1419. //不存在
  1420. return "1";
  1421. }
  1422. Date lastUseDate = promoCode.getLastUseDate();
  1423. if (lastUseDate != null && lastUseDate.getTime() < ((new Date()).getTime())) {
  1424. promoCode.setIsUse("2");
  1425. szwlFeign.updatePromoCode(String.valueOf(promoCode.getId()), "2");
  1426. //过期
  1427. return "4";
  1428. }
  1429. if (promoCode.getIsUse().equals("1")) {
  1430. //被使用
  1431. return "2";
  1432. }
  1433. if (!promoCode.getAdminId().equals("1")) {
  1434. if (!String.valueOf(equipment.getAdminId()).equals(promoCode.getAdminId())) {
  1435. //不是本机
  1436. return "3";
  1437. }
  1438. }
  1439. if (promoCode.getDiscount() == null) {
  1440. //旧优惠码
  1441. return "0";
  1442. }
  1443. if (promoCode.getDiscount() == 0) {
  1444. //0折
  1445. return "0";
  1446. }
  1447. return null;
  1448. }
  1449. /**
  1450. * 汇聚分销明细
  1451. */
  1452. public JSONArray getAltInfo(TProportion proportion, BigDecimal price) {
  1453. // 获取分账有几方:0:分账方2个,1:分账方3个,2:分账方4个,3:分账方超4个
  1454. Integer type = proportion.getType();
  1455. // 汇聚分账参数
  1456. JSONArray altInfo = new JSONArray();
  1457. BigDecimal agencyProportion = null,
  1458. merchantProportion = null,
  1459. selfProportion = null;
  1460. BigDecimal agencyAmount = null;
  1461. BigDecimal merchantAmount = null;
  1462. BigDecimal selfAmount = null;
  1463. TJoinpayMch agencyMch = null;
  1464. TJoinpayMch merchantMch = null;
  1465. TJoinpayMch selfMch = null;
  1466. JSONObject agencyJson = null;
  1467. JSONObject merchantJson = null;
  1468. JSONObject selfJson = null;
  1469. //取消平台扣手续费
  1470. BigDecimal cutPrice = price.setScale(2, RoundingMode.HALF_UP);
  1471. BigDecimal refuseAmount = new BigDecimal(0.00);
  1472. switch (type) {
  1473. case 0:
  1474. // 商家自己的分销
  1475. selfProportion = proportion.getProportion();
  1476. // 商家分销获得利润
  1477. selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1478. // 汇聚平台
  1479. selfMch = R.getDataIfSuccess(szwlFeign.getMch(String.valueOf(proportion.getAdminId())));
  1480. if (selfMch == null) {
  1481. return altInfo;
  1482. }
  1483. selfJson = new JSONObject();
  1484. selfJson.put("altMchNo", selfMch.getAltMchNo());
  1485. selfJson.put("altAmount", selfAmount.toString());
  1486. selfJson.put("isGuar", "12");
  1487. altInfo.add(selfJson);
  1488. break;
  1489. case 1:
  1490. // 商家自己的分销
  1491. selfProportion = proportion.getProportion();
  1492. // 一级分销
  1493. agencyProportion = proportion.getAgencyProportion();
  1494. // 商家分销获得利润
  1495. selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1496. // 汇聚平台
  1497. agencyMch = R.getDataIfSuccess(szwlFeign.getMch(String.valueOf(proportion.getAgencyId())));
  1498. selfMch = R.getDataIfSuccess(szwlFeign.getMch(String.valueOf(proportion.getAdminId())));
  1499. if (selfMch == null || agencyMch == null) {
  1500. return altInfo;
  1501. }
  1502. if (!(agencyProportion.compareTo(refuseAmount) == 0 || agencyProportion == null)) {
  1503. // 一级分销获得利润
  1504. agencyAmount = cutPrice.multiply(agencyProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1505. agencyJson = new JSONObject();
  1506. agencyJson.put("altMchNo", agencyMch.getAltMchNo());
  1507. agencyJson.put("altAmount", agencyAmount.toString());
  1508. agencyJson.put("isGuar", "12");
  1509. altInfo.add(agencyJson);
  1510. }
  1511. // 商家自己分销获得利润
  1512. selfJson = new JSONObject();
  1513. selfJson.put("altMchNo", selfMch.getAltMchNo());
  1514. selfJson.put("altAmount", selfAmount.toString());
  1515. selfJson.put("isGuar", "12");
  1516. altInfo.add(selfJson);
  1517. break;
  1518. case 2:
  1519. // 商家自己的分销
  1520. selfProportion = proportion.getProportion();
  1521. // 一级分销
  1522. agencyProportion = proportion.getAgencyProportion();
  1523. // 二级分销
  1524. merchantProportion = proportion.getMerchantProportion();
  1525. // 三级分销
  1526. // personageProportion = proportion.getPersonageProportion();
  1527. // 商家分销获得利润
  1528. selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1529. // 汇聚
  1530. agencyMch = R.getDataIfSuccess(szwlFeign.getMch(String.valueOf(proportion.getAgencyId())));
  1531. merchantMch = R.getDataIfSuccess(szwlFeign.getMch(String.valueOf(proportion.getMerchantId())));
  1532. selfMch = R.getDataIfSuccess(szwlFeign.getMch(String.valueOf(proportion.getAdminId())));
  1533. if (selfMch == null || agencyMch == null || merchantMch == null) {
  1534. return altInfo;
  1535. }
  1536. if (!(agencyProportion.compareTo(refuseAmount) == 0 || agencyProportion == null)) {
  1537. // 代理分销获得利润
  1538. agencyAmount = cutPrice.multiply(agencyProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1539. agencyJson = new JSONObject();
  1540. agencyJson.put("altMchNo", agencyMch.getAltMchNo());
  1541. agencyJson.put("altAmount", agencyAmount.toString());
  1542. agencyJson.put("isGuar", "12");
  1543. altInfo.add(agencyJson);
  1544. }
  1545. if (!(merchantProportion.compareTo(refuseAmount) == 0 || merchantProportion == null)) {
  1546. // 经销商分销获得利润
  1547. merchantAmount = cutPrice.multiply(merchantProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1548. merchantJson = new JSONObject();
  1549. merchantJson.put("altMchNo", merchantMch.getAltMchNo());
  1550. merchantJson.put("altAmount", merchantAmount.toString());
  1551. merchantJson.put("isGuar", "12");
  1552. altInfo.add(merchantJson);
  1553. }
  1554. // 商家自己分销获得利润
  1555. merchantJson = new JSONObject();
  1556. merchantJson.put("altMchNo", selfMch.getAltMchNo());
  1557. merchantJson.put("altAmount", selfAmount.toString());
  1558. merchantJson.put("isGuar", "12");
  1559. altInfo.add(merchantJson);
  1560. break;
  1561. }
  1562. Iterator<Object> iterator = altInfo.iterator();
  1563. while (iterator.hasNext()) {
  1564. JSONObject jsonObject = (JSONObject) iterator.next();
  1565. String altAmount = jsonObject.getString("altAmount");
  1566. if (altAmount.equals("0.00")) {
  1567. iterator.remove();
  1568. }
  1569. }
  1570. return altInfo;
  1571. }
  1572. /**
  1573. * 汇付分销明细
  1574. */
  1575. public JSONObject getAcctSplitBunch(TProportion proportion, BigDecimal price, String companyType) {
  1576. // 获取分账有几方:0:分账方2个,1:分账方3个,2:分账方4个,3:分账方超4个
  1577. Integer type = proportion.getType();
  1578. // 汇付分账明细参数
  1579. JSONObject acctSplitBunch = new JSONObject();
  1580. JSONArray acctInfos = new JSONArray();
  1581. BigDecimal adminProportion = null,
  1582. agencyProportion = null,
  1583. merchantProportion = null,
  1584. selfProportion = null;
  1585. BigDecimal agencyAmount = null;
  1586. BigDecimal merchantAmount = null;
  1587. BigDecimal selfAmount = null;
  1588. BigDecimal adminAmount = null;
  1589. THuifuMch agencyHuifu = null;
  1590. THuifuMch merchantHuifu = null;
  1591. THuifuMch selfHuifu = null;
  1592. JSONObject agencyJson = null;
  1593. JSONObject merchantJson = null;
  1594. JSONObject selfJson = null;
  1595. JSONObject adminJson = null;
  1596. //取消平台扣手续费
  1597. BigDecimal cutPrice = price.setScale(2, RoundingMode.HALF_UP);
  1598. BigDecimal refuseAmount = new BigDecimal(0.00);
  1599. switch (type) {
  1600. case 0:
  1601. // 公司平台分销
  1602. adminProportion = proportion.getAdminProportion();
  1603. // 商家自己的分销
  1604. selfProportion = proportion.getProportion();
  1605. // 平台分销获得利润
  1606. adminAmount = cutPrice.multiply(adminProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_UP);
  1607. // 商家分销获得利润
  1608. selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1609. // 汇付平台
  1610. // 商家汇付信息:agencyHuifu
  1611. selfHuifu = R.getDataIfSuccess(szwlFeign.getHuifuId(proportion.getAdminId()));
  1612. if (selfHuifu == null) {
  1613. return acctSplitBunch;
  1614. }
  1615. // 公司平台分销
  1616. adminJson = new JSONObject();
  1617. adminJson.put("div_amt", adminAmount.toString());
  1618. // 判断为申泽还是七云
  1619. if (StrUtil.isNotEmpty(companyType) && companyType.equals("1")) {
  1620. adminJson.put("huifu_id", HuifuConstant.SC_DIV_HUIFU_ID);
  1621. } else {
  1622. adminJson.put("huifu_id", HuifuConstant.SZ_DIV_HUIFU_ID);
  1623. }
  1624. acctInfos.add(adminJson);
  1625. // 商家分销获得利润
  1626. selfJson = new JSONObject();
  1627. selfJson.put("div_amt", selfAmount.toString());
  1628. selfJson.put("huifu_id", selfHuifu.getHuifuId());
  1629. acctInfos.add(selfJson);
  1630. break;
  1631. case 1:
  1632. // 公司平台分销
  1633. adminProportion = proportion.getAdminProportion();
  1634. // 商家自己的分销
  1635. selfProportion = proportion.getProportion();
  1636. // 一级分销
  1637. agencyProportion = proportion.getAgencyProportion();
  1638. // 平台分销获得利润
  1639. adminAmount = cutPrice.multiply(adminProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_UP);
  1640. // 商家分销获得利润
  1641. selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1642. // 汇付平台
  1643. selfHuifu = R.getDataIfSuccess(szwlFeign.getHuifuId(proportion.getAdminId()));
  1644. agencyHuifu = R.getDataIfSuccess(szwlFeign.getHuifuId(proportion.getAgencyId()));
  1645. if (selfHuifu == null || agencyHuifu == null) {
  1646. return acctSplitBunch;
  1647. }
  1648. // 公司平台分销
  1649. adminJson = new JSONObject();
  1650. adminJson.put("div_amt", adminAmount.toString());
  1651. // 判断为申泽还是七云
  1652. if (StrUtil.isNotEmpty(companyType) && companyType.equals("1")) {
  1653. adminJson.put("huifu_id", HuifuConstant.SC_DIV_HUIFU_ID);
  1654. } else {
  1655. adminJson.put("huifu_id", HuifuConstant.SZ_DIV_HUIFU_ID);
  1656. }
  1657. acctInfos.add(adminJson);
  1658. // 商家分销获得利润
  1659. selfJson = new JSONObject();
  1660. selfJson.put("div_amt", selfAmount.toString());
  1661. selfJson.put("huifu_id", selfHuifu.getHuifuId());
  1662. acctInfos.add(selfJson);
  1663. if (!(agencyProportion.compareTo(refuseAmount) == 0 || agencyProportion == null)) {
  1664. // 一级分销获得利润
  1665. agencyAmount = cutPrice.multiply(agencyProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1666. agencyJson = new JSONObject();
  1667. agencyJson.put("div_amt", agencyAmount.toString());
  1668. agencyJson.put("huifu_id", agencyHuifu.getHuifuId());
  1669. acctInfos.add(agencyJson);
  1670. }
  1671. break;
  1672. case 2:
  1673. // 公司平台分销
  1674. adminProportion = proportion.getAdminProportion();
  1675. // 商家自己的分销
  1676. selfProportion = proportion.getProportion();
  1677. // 一级分销
  1678. agencyProportion = proportion.getAgencyProportion();
  1679. // 二级分销
  1680. merchantProportion = proportion.getMerchantProportion();
  1681. // 平台分销获得利润
  1682. adminAmount = cutPrice.multiply(adminProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_UP);
  1683. // 商家分销获得利润
  1684. selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1685. selfHuifu = R.getDataIfSuccess(szwlFeign.getHuifuId(proportion.getAdminId()));
  1686. agencyHuifu = R.getDataIfSuccess(szwlFeign.getHuifuId(proportion.getAgencyId()));
  1687. merchantHuifu = R.getDataIfSuccess(szwlFeign.getHuifuId(proportion.getMerchantId()));
  1688. if (selfHuifu == null || agencyHuifu == null || merchantHuifu == null) {
  1689. return acctSplitBunch;
  1690. }
  1691. // 公司平台分销
  1692. adminJson = new JSONObject();
  1693. adminJson.put("div_amt", adminAmount.toString());
  1694. // 判断为申泽还是七云
  1695. if (StrUtil.isNotEmpty(companyType) && companyType.equals("1")) {
  1696. adminJson.put("huifu_id", HuifuConstant.SC_DIV_HUIFU_ID);
  1697. } else {
  1698. adminJson.put("huifu_id", HuifuConstant.SZ_DIV_HUIFU_ID);
  1699. }
  1700. acctInfos.add(adminJson);
  1701. // 商家分销获得利润
  1702. selfJson = new JSONObject();
  1703. selfJson.put("div_amt", selfAmount.toString());
  1704. selfJson.put("huifu_id", selfHuifu.getHuifuId());
  1705. acctInfos.add(selfJson);
  1706. if (!(agencyProportion.compareTo(refuseAmount) == 0 || agencyProportion == null)) {
  1707. // 一级分销获得利润
  1708. agencyAmount = cutPrice.multiply(agencyProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1709. agencyJson = new JSONObject();
  1710. agencyJson.put("div_amt", agencyAmount.toString());
  1711. agencyJson.put("huifu_id", agencyHuifu.getHuifuId());
  1712. acctInfos.add(agencyJson);
  1713. }
  1714. if (!(merchantProportion.compareTo(refuseAmount) == 0 || merchantProportion == null)) {
  1715. // 二级分销获得利润
  1716. merchantAmount = cutPrice.multiply(merchantProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN);
  1717. merchantJson = new JSONObject();
  1718. merchantJson.put("div_amt", merchantAmount.toString());
  1719. merchantJson.put("huifu_id", merchantHuifu.getHuifuId());
  1720. acctInfos.add(merchantJson);
  1721. }
  1722. break;
  1723. }
  1724. // 计算div_amt的总和
  1725. BigDecimal totalAmount = BigDecimal.ZERO;
  1726. for (int i = 0; i < acctInfos.size(); i++) {
  1727. JSONObject jsonObject = acctInfos.getJSONObject(i);
  1728. BigDecimal divAmt = new BigDecimal(jsonObject.getString("div_amt"));
  1729. totalAmount = totalAmount.add(divAmt);
  1730. }
  1731. // 如果总和超过原本金额,调整div_amt
  1732. if (totalAmount.compareTo(price) > 0) {
  1733. BigDecimal diffAmount = totalAmount.subtract(price);
  1734. for (int i = 0; i < acctInfos.size(); i++) {
  1735. JSONObject jsonObject = acctInfos.getJSONObject(i);
  1736. String huifuId = jsonObject.getString("huifu_id");
  1737. if (huifuId.equals(HuifuConstant.SZ_DIV_HUIFU_ID) || huifuId.equals(HuifuConstant.SC_DIV_HUIFU_ID)) {
  1738. BigDecimal currentDivAmt = new BigDecimal(jsonObject.getString("div_amt"));
  1739. BigDecimal adjustedDivAmt = currentDivAmt.subtract(diffAmount).max(BigDecimal.ZERO);
  1740. jsonObject.put("div_amt", adjustedDivAmt.toString());
  1741. break;
  1742. }
  1743. }
  1744. }
  1745. acctSplitBunch.put("acct_infos", acctInfos);
  1746. return acctSplitBunch;
  1747. }
  1748. /**
  1749. * 判断支付方式
  1750. */
  1751. public String checkPayType(String payType) {
  1752. if (StrUtil.isNotEmpty(payType)) {
  1753. if (payType.contains("ALIPAY")) {
  1754. return "支付宝";
  1755. } else if (payType.contains("WEIXIN")) {
  1756. return "微信";
  1757. } else if (payType.equals("ECNY_CARD")) {
  1758. return "数字人民币";
  1759. } else {
  1760. return "微信";
  1761. }
  1762. }
  1763. return "微信";
  1764. }
  1765. }