java版Spring Cloud+Mybatis 微服务商城 b2b2c商城直播商城小程序商城多商家入驻商城 APP商城源码聚合支付商城

1. 平台简介

一个全新覆盖全行业，以直播、短视频带货，商家实体VR全景体验，多营销模式，分销分佣，多商家入驻，多端支持的大型新零售电商平台。

2. 平台清单

系统管理平台 + 商家端（PC+手机） + 消费端微服务 + 消费端（小程序/APP/公众号/H5） + 消息提醒

3. 平台模式

B2B2C多商家入驻通用版本：标准多商户入驻+二级分销体系+满减、满送、优惠券、组合销售、平台礼包等营销活动）

B2B2C多商家入驻直播/短视频带货版本：标准多商户入驻+直播、短视频带货+二级分销体系+满减、满送、优惠券、组合销售、平台礼包等营销活动

B2B2C多商家入驻VR全景版本：标准多商户入驻+二级分销体系+满减、满送、优惠券、组合销售、平台礼包等营销活动）

4. 涉及营销方案

一、一县一特（一个县城，一个特色，集本地特产、特色、名胜、小吃、文化为一体的营销方案）

二、短距离配送（外卖、生鲜水果配送，解决1.5公里配送问题，接入第三方代跑腿服务）

三、酒店行业（酒店商家入驻，根据定位，可针对附近酒店，不同城酒店进行线上预定、下线核销等，参考去哪儿网酒店业务）

四、VR全景（商家入驻后，可以进行VR全景拍摄，VR店铺体验，全新购物方式，通过虚拟现实技术，线上线下打通，实现全新O2O，深度场景体验，感受另一个大千世界，让用户足不出户完美购物。通过VR让您的店铺曝光率更高，让天下没有难销的商品）

五、线下套餐体验（针对于实体行业，用户线上消费后生成核销码，用户到实体店铺体验套餐，可凭借核销码进行体验项目）

六、旅游业（周边游、本地游、异地游等，旅游景区和VR全景结合，用户足不出户先感受一下旅游项目、旅游攻略等，可线上订票、预定等）

七、供应求购（简易供应链供应、求购模式）

八、社交资讯（用户发布文章，可进行带货）

九、社交动态（个人信息、动态、视频，如：文字+图片、文字+视频，可进行带货；粉丝、关注、分享等）

十、异业联盟（不同行业的联盟销售，如：在某餐饮店面消费后可送附近健身卡优惠券，凭借优惠券可进行线下体验）

十一、一键代发营销（商家选择平台商品后放入自己店面销售，用户购买后商家可获取特殊分润提成，商家不需要发货，由平台厂家直接发货，并支持本店面自提）

十二、秒杀（通用方案）

十三、拼团（仿拼多多）

十四、限时折扣（通用方案，在活动时间范围内会员享受折扣价格）

十五、积分商城（纯积分兑换、积分+现金兑换）

十六、限时折扣（通用方案，在活动时间范围内会员享受折扣价格）

十七、活动商品（平台发布活动商品，如：可以进行0元领取，领取需要进行用户拉新，拉新后可进行现金奖励等）

5. 使用技术

开发工具：Idea、Eclipse

WEB容器：Tomcat、Jboss、Weblogic、webSphere

JDK版本：1.8+

系统支持：Docker、Window、Linux

数据库/数据源：MySQL、Alibaba Druid

服务框架：Spring Cloud、Spring Boot2、Mybatis、前后端分离、分布式、微服务

分布式中间件：RabbitMQ、Redis、ElasticSearch、OSS

前端架构：VUE、Uniapp、H5、CSS3

构建方式：Maven、Jenkins

涉及技术：Eureka、Config、Zuul、OAuth2、Security、OSS、Turbine、Zipkin、Feign、Monitor、Stream、ElasticSearch、Redis、RabbitMQ等

支持终端：小程序、APP（IOS/Android）、公众号、H5

6. 架构设计&思想

分布式、微服务、云架构、模块化、服务化、原子化、持续集成、中间件集成、云服务集成

7. 技术架构图

8. 微服务清单

honghu-activity：活动、honghu-advert：广告、honghu-brand: 品牌

honghu-cms: 内容发布、honghu-collect: 我的收藏、honghu-common: 系统通用服务

honghu-coupon: 优惠券、honghu-distribution: 分销、honghu-file: 文件

honghu-free: 试用、honghu-goodsc-lass: 商品分类、honghu-goods: 商品

honghu-group: 团购、honghu-home: 首页、honghu-integral: 积分商城

honghu-member: 会员、honghu-message: 消息、honghu-operate: 运营

honghu-order: 订单、honghu-pay: 支付、honghu-pin: 拼团

honghu-search: 搜索、honghu-social: 社交电商

honghu-sso: 单点登录、honghu-store: 店铺

@源码地址来源： https://minglisoft.cn/honghu/business.html

8. 演示截图

9. 相关源码

@源码地址来源： https://minglisoft.cn/honghu/business.html

package com.honghu.cloud.controller;import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;import javax.servlet.http.HttpServletRequest;import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONException;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.honghu.cloud.bean.DaDaAppConfig;
import com.honghu.cloud.bean.DaDaService;
import com.honghu.cloud.bean.DadaApiResponse;
import com.honghu.cloud.bean.ShopAddModel;
import com.honghu.cloud.bean.Store;
import com.honghu.cloud.code.ResponseCode;
import com.honghu.cloud.dto.AreaDto;
import com.honghu.cloud.dto.CouponInfoDto;
import com.honghu.cloud.dto.EvaluateDto;
import com.honghu.cloud.dto.ExpressCompanyCommonDto;
import com.honghu.cloud.dto.ExpressCompanyDto;
import com.honghu.cloud.dto.ExpressInfoDto;
import com.honghu.cloud.dto.GoodsDto;
import com.honghu.cloud.dto.MessageDto;
import com.honghu.cloud.dto.OrderFormDto;
import com.honghu.cloud.dto.OrderFormLogDto;
import com.honghu.cloud.dto.RefundApplyFormDto;
import com.honghu.cloud.dto.ReturnGoodsLogDto;
import com.honghu.cloud.dto.ShipAddressDto;
import com.honghu.cloud.dto.SysConfigDto;
import com.honghu.cloud.dto.TransInfoDto;
import com.honghu.cloud.dto.UserDto;
import com.honghu.cloud.feign.AreaFeignClient;
import com.honghu.cloud.feign.CouponInfoFeignClient;
import com.honghu.cloud.feign.EvaluateFeignClient;
import com.honghu.cloud.feign.ExpressCompanyCommonFeignClient;
import com.honghu.cloud.feign.ExpressCompanyFeignClient;
import com.honghu.cloud.feign.ExpressInfoFeignClient;
import com.honghu.cloud.feign.GoodsFeignClient;
import com.honghu.cloud.feign.MessageFeignClient;
import com.honghu.cloud.feign.ModularClassFeignClient;
import com.honghu.cloud.feign.MsgToolsFeignClient;
import com.honghu.cloud.feign.OrderFormFeignClient;
import com.honghu.cloud.feign.OrderFormLogFeignClient;
import com.honghu.cloud.feign.OrderFormToolsFeignClient;
import com.honghu.cloud.feign.RefundApplyFormFeignClient;
import com.honghu.cloud.feign.ReturnGoodsLogFeignClient;
import com.honghu.cloud.feign.ShipAddressFeignClient;
import com.honghu.cloud.feign.ShipToolsFeignClient;
import com.honghu.cloud.feign.SysConfigFeignClient;
import com.honghu.cloud.feign.UserFeignClient;
import com.honghu.cloud.service.IStoreService;
import com.honghu.cloud.tools.DadaRequestClient;
import com.honghu.cloud.tools.JSONUtil;
import com.honghu.cloud.tools.QueryTools;
import com.honghu.cloud.tools.SecurityUserHolder;
import com.honghu.cloud.utils.CommUtil;
import com.honghu.cloud.utils.StringUtils;
import com.honghu.cloud.utils.tools.Md5Encrypt;import lombok.extern.slf4j.Slf4j;
import net.sf.json.JSONObject;@CrossOrigin(origins = "*", maxAge = 3600)
@Slf4j
@RestController
@RequestMapping(value = "/applet/storeOrder")
public class AppletStoreOrderController {private final Logger logger = LoggerFactory.getLogger(AppletStoreOrderController.class);@Autowiredprivate IStoreService storeService;@Autowiredprivate OrderFormFeignClient orderFormFeignClient;@Autowiredprivate UserFeignClient userFeignClient;@Autowiredprivate GoodsFeignClient goodsFeignClient;@Autowiredprivate QueryTools queryTools;@Autowiredprivate RefundApplyFormFeignClient refundapplyformfeignclient;@Autowiredprivate MessageFeignClient messagefeignclient;@Autowiredprivate ReturnGoodsLogFeignClient returnGoodsLogFeignClient;@Autowiredprivate ShipToolsFeignClient shipToolsFeignClient;@Autowiredprivate OrderFormToolsFeignClient orderFormToolsFeignClient;@Autowiredprivate OrderFormLogFeignClient orderFormLogFeignClient;@Autowiredprivate MsgToolsFeignClient msgToolsFeignClient;@Autowiredprivate ExpressCompanyCommonFeignClient companyCommonFeignClient;@Autowiredprivate ShipAddressFeignClient shipAddressFeignClient;@Autowiredprivate SysConfigFeignClient sysConfigFeignClient;@Autowiredprivate ExpressInfoFeignClient expressInfoFeignClient;@Autowiredprivate EvaluateFeignClient evaluateFeignClient;@Autowiredprivate ExpressCompanyFeignClient expressCompanyFeignClient;@Autowiredprivate ExpressCompanyCommonFeignClient expressCompanyCommonFeignClient;@Autowiredprivate AreaFeignClient areaFeignClient;@Autowiredprivate ModularClassFeignClient modularClassFeignClient;@Autowiredprivate CouponInfoFeignClient couponInfoFeignClient;/*** 卖家订单列表* @param request* @param response* @param currentPage* @param order_status* @param order_id* @param beginTime* @param endTime* @param buyer_userName* @return*/@RequestMapping( value = { "/order" } , method = RequestMethod.POST)public Map<String,Object> order(HttpServletRequest request,@RequestBody JSONObject json) {String currentPage = json.optString("currentPage");String order_status = json.optString("order_status");String order_id = json.optString("order_id");/*String beginTime = json.optString("beginTime");String endTime = json.optString("endTime");*/String order_id_userName = json.optString("order_id_userName");Map<String,Object> maps= this.queryTools.getParams(currentPage,"addTime", "desc");UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store != null){maps.put("store_id", store.getId());}else{return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}/*       maps.put("order_cat_no", 2);
*/      Map<String, Object> map = Maps.newHashMap();if (!CommUtil.null2String(order_status).equals("")) {if (order_status.equals("order_submit")) {//代付款maps.put("order_status1", Integer.valueOf(10));maps.put("order_status2", Integer.valueOf(16));}if (order_status.equals("order_pay")) {     //代发货maps.put("order_status1", Integer.valueOf(20));maps.put("order_status2", Integer.valueOf(14));}if (order_status.equals("order_shipping")) {//待收货   已发货  //maps.put("order_status", Integer.valueOf(30));maps.put("order_status_0", Integer.valueOf(30));maps.put("order_status_1", Integer.valueOf(31));maps.put("order_status_2", Integer.valueOf(32));}if (order_status.equals("order_evaluate")) {// 已收货  待评价maps.put("order_status", Integer.valueOf(40));}if (order_status.equals("order_finish")) { //评论完maps.put("order_status", Integer.valueOf(50));}if (order_status.equals("order_cancel")) {//订单取消maps.put("order_status", Integer.valueOf(0));}if (order_status.equals("order_refund")) {//退款中maps.put("order_status", Integer.valueOf(21));}}if (!CommUtil.null2String(order_id).equals("")) {maps.put("order_id_like", order_id);}/*if (!CommUtil.null2String(beginTime).equals("")) {maps.put("add_Time_more_than_equal", CommUtil.formatDate(beginTime));map.put("beginTime", beginTime);}if (!CommUtil.null2String(endTime).equals("")) {String ends = endTime + " 23:59:59";maps.put("add_Time_less_than_equal", CommUtil.formatDate(ends,"yyyy-MM-dd hh:mm:ss"));map.put("endTime", endTime);}*/if (!CommUtil.null2String(order_id_userName).equals("")) {maps.put("order_id_userName", order_id_userName);}Map<String, Object> list = this.orderFormFeignClient.list(maps);map.putAll(list);/*map.put("list", list);*/map.put("order_id", order_id);map.put("order_status", order_status == null ? "all" : order_status);return ResponseCode.buildSuccessMap(map);}/*** 卖家订单* @param request* @param response* @param currentPage* @param order_status* @param order_id* @param beginTime* @param endTime* @param buyer_userName* @return*/@RequestMapping( value = { "/orderHome" } , method = RequestMethod.POST)public Map<String,Object> orderHome(HttpServletRequest request) {UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}Map<String, Object> map = Maps.newHashMap();map.put("store_id", store.getId());//代付款1map.put("order_status1", Integer.valueOf(10));map.put("order_status2", Integer.valueOf(16));Integer order_submit = this.orderFormFeignClient.selectCount(map);//代发货1map.clear();map.put("store_id", store.getId());map.put("order_status", Integer.valueOf(20));Integer order_pay = this.orderFormFeignClient.selectCount(map);//待收货   已发货  1map.clear();map.put("store_id", store.getId());map.put("order_status", Integer.valueOf(30));Integer order_shipping = this.orderFormFeignClient.selectCount(map);// 已收货  待评价1map.clear();map.put("store_id", store.getId());map.put("order_status", Integer.valueOf(40));Integer order_evaluate = this.orderFormFeignClient.selectCount(map);//退款中1map.clear();map.put("store_id", store.getId());map.put("refundStatus", 1);Integer order_refund = this.orderFormFeignClient.selectCount(map);map.put("selectCount_refund", order_refund);map.clear();map.put("store_id", user.getStore_id());int selectCount = this.returnGoodsLogFeignClient.selectCount(map);if(order_refund == null){order_refund = 0;}order_refund = order_refund + selectCount;map.clear();map.put("order_submit", order_submit);map.put("order_pay", order_pay);map.put("order_shipping", order_shipping);map.put("order_evaluate", order_evaluate);map.put("order_refund", order_refund);return ResponseCode.buildSuccessMap(map);}/**订单详情* @param request* @param json* @return*/@RequestMapping(value = { "/order_view" } , method = RequestMethod.POST)public Map<String , Object> order_view(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}if (user.getStore_id().equals(store.getId())) {Map<String , Object> maps = Maps.newHashMap();if(obj.getOrder_status() == 10){SysConfigDto sys = this.sysConfigFeignClient.getSysConfig();Integer auto_order_cancel = sys.getAuto_order_cancel();Date addTime = obj.getAddTime();Date date = new Date();/*System.out.println(((addTime.getTime() - date.getTime()) / (24 * 60 * 60 * 1000))/ 365 + "年");System.out.println((addTime.getTime() - date.getTime()) / (24 * 60 * 60 * 1000) + "天");System.out.println((((addTime.getTime() - date.getTime()) / (60 * 60 * 1000)) % 24) + "小时");System.out.println((((addTime.getTime() - date.getTime()) / 1000) % 60) + "分钟");System.out.println(((addTime.getTime() - date.getTime()) / (60 * 1000)) % 60 + "秒");*/maps.put("obj", obj);maps.put("second", (((addTime.getTime() - date.getTime()) / 1000)) + auto_order_cancel*60*60);}maps.put("obj", obj);return ResponseCode.buildSuccessMap(maps);} else {return ResponseCode.buildEnumMap(ResponseCode.FAILURE, null);}}/*** 卖家取消订单* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value ={ "/order_cancel" } ,method = RequestMethod.POST)public   Map<String , Object>  order_cancel(HttpServletRequest request , @RequestBody JSONObject jsonv) {String id = jsonv.optString("id");if (SecurityUserHolder.getCurrentUserId(request)==null) {return ResponseCode.buildCodeMap("1111", "userid为空", null);}UserDto seller = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if(seller == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (seller.getParent_id()!=null) {seller = this.userFeignClient.selectByPrimaryKey(seller.getParent_id());}//user = user.getParent_id() == null ? user : user.getParent();    if(seller.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}//System.out.println("---------user--getStore_id-------------"+seller//.getStore_id());Store store = this.storeService.selectByPrimaryKey(seller.getStore_id());//System.out.println("---------user---------------"+seller.getId());//System.out.println("------------obj-------------"+obj.getId());//System.out.println("---------seller---------------"+seller.getStore_id());if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}System.out.println("-----------store--------------"+store.getId());if ((seller.getStore_id() != null)&& (CommUtil.null2String(obj.getStore_id()).equals(seller.getStore_id().toString()))) {return ResponseCode.buildSuccessMap(obj);} else {return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}}/*** 卖家取消订单保存* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value ={ "/order_cancel_save" } ,method = RequestMethod.POST)public Map<String , Object> order_cancel_save(HttpServletRequest request , @RequestBody JSONObject jsonv) {String id = jsonv.optString("id");String state_info = jsonv.optString("state_info");String other_state_info = jsonv.optString("other_state_info");UserDto seller = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if(seller == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (seller.getParent_id()!=null) {seller = this.userFeignClient.selectByPrimaryKey(seller.getParent_id());}//user = user.getParent_id() == null ? user : user.getParent();    if(seller.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(seller.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}Date nowDate = new Date();if ((seller.getStore_id() != null)&& (CommUtil.null2String(obj.getStore_id()).equals(seller.getStore_id().toString()))) {obj.setOrder_status(0);if ((obj.getCoupon_info() != null)&& (!"".equals(obj.getCoupon_info()))) {Map m = JSON.parseObject(obj.getCoupon_info());CouponInfoDto cpInfo = this.couponInfoFeignClient.selectByPrimaryKey(CommUtil.null2Long(m.get("couponinfo_id")));if (cpInfo != null) {if (nowDate.before(cpInfo.getEndDate())) {cpInfo.setStatus(0);} else {cpInfo.setStatus(-1);}}}orderFormFeignClient.updateById(obj);OrderFormLogDto ofl = new OrderFormLogDto();ofl.setAddTime(new Date());ofl.setLog_info("取消订单");ofl.setLog_user_id(seller.getId());ofl.setLog_user_name(seller.getUserName());ofl.setOf_id(obj.getId());if (state_info.equals("其他原因")) {ofl.setState_info(other_state_info);} else {ofl.setState_info(state_info);}this.orderFormLogFeignClient.saveEntity(ofl);/*    UserDto buyer = this.userFeignClient.selectByPrimaryKey(CommUtil.null2Long(obj.getUser_id()));Map<String, Object> map = Maps.newHashMap();map.put("buyer_id", buyer.getId().toString());map.put("seller_id", store.getUser_id());map.put("order_id", obj.getId());String json = JSON.toJSONString(map);*//*if (obj.getOrder_form() == 0) {try {this.msgToolsFeignClient.sendEmailCharge(CommUtil.getURL(request),"email_tobuyer_order_cancel_notify", buyer.getEmail(),json, null, obj.getStore_id());this.msgToolsFeignClient.sendSmsCharge(CommUtil.getURL(request),"sms_tobuyer_order_cancel_notify", buyer.getMobile(),json, null, obj.getStore_id());} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}} else {try {this.msgToolsFeignClient.sendEmailFree(CommUtil.getURL(request),"email_tobuyer_order_cancel_notify", buyer.getEmail(),json, null);this.msgToolsFeignClient.sendSmsFree(CommUtil.getURL(request),"sms_tobuyer_order_cancel_notify", buyer.getMobile(),json, null);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}*/return ResponseCode.buildSuccessMap(null);} else {return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}}/*** 订单退款申请单* @param request* @param response* @param currentPage* @param orderBy* @param orderType* @param status* @return*/@RequestMapping(value = { "/refund_apply_form" } , method = RequestMethod.POST)public Map<String,Object> refund_apply_form(HttpServletRequest request,@RequestBody JSONObject json) {String currentPage = json.optString("currentPage");String orderType = json.optString("orderType");String orderBy = json.optString("orderBy");//状态 0:待审核 5:审核拒绝  10:审核通过待退款 15:已退款String refundStatus = json.optString("refundStatus");   UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));Map<String,Object> maps= this.queryTools.getParams(currentPage, orderBy, orderType);if ((refundStatus == null) || (refundStatus.equals(""))) {maps.put("refundStatus", CommUtil.null2Int(Integer.valueOf(0)));} else {maps.put("refundStatus", CommUtil.null2Int(Integer.valueOf(refundStatus)));}if(store != null){maps.put("store_id", store.getId());}else{return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}Map<String, Object> data = this.orderFormFeignClient.refundApplyFormList(maps);data.put("refundStatus", refundStatus);return ResponseCode.buildSuccessMap(data);}/*** 订单退款申请单详情* @param request* @param response* @param order_id* @return*/@RequestMapping(value = { "/refund_orderform_view" } , method = RequestMethod.POST)public Map<String,Object> refund_orderform_view(HttpServletRequest request, @RequestBody JSONObject json) {Map<Object, Object> map = Maps.newHashMap();map.put("reason","");if (StringUtils.isBlank(json.optString("order_id"))) {return ResponseCode.buildReturnMap(ResponseCode.PARAM_ERROR, null);}String apply_from_id = json.optString("apply_from_id");if (StringUtils.isBlank(apply_from_id)) {return ResponseCode.buildReturnMap(ResponseCode.PARAM_ERROR, null);}OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(json.optString("order_id")));Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}RefundApplyFormDto RefundApplyFormDto = refundapplyformfeignclient.selectByPrimaryKey(CommUtil.null2Long(apply_from_id));if(RefundApplyFormDto!=null){map.put("reason",RefundApplyFormDto.getReturn_content());  //退款原因}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}if(store == null){return ResponseCode.buildReturnMap(ResponseCode.REQUEST_FORBIDDEN, null);}if(!user.getStore_id().equals(store.getId()) ||store.getStore_status()!=15){     //验证是否是当前商家  ， 并且正常营业return ResponseCode.buildReturnMap(ResponseCode.REQUEST_FORBIDDEN, null);}if (obj != null) {String temp = obj.getSpecial_invoice();if ((temp != null) && (!"".equals(temp))) {Map of_va = JSON.parseObject(temp);map.put("of_va", of_va);}}map.put("obj", obj);String queryExInfo = this.queryExInfo(obj.getExpress_info(), "express_company_name");map.put("store", store); map.put("express_company_name", queryExInfo);//map.put("express_company_name", this.orderFormTools.queryExInfo(obj.getExpress_info(), "express_company_name"));ReturnGoodsLogDto returnGoodsLogDto = returnGoodsLogFeignClient.selectByOrderId(obj.getId());map.put("returnGoodsLogDto", returnGoodsLogDto); return ResponseCode.buildSuccessMap(map);}public String queryExInfo(String json, String key) {Map<String, Object> map = Maps.newHashMap();if ((json != null) && (!json.equals(""))) {map = JSON.parseObject(json);}return CommUtil.null2String(map.get(key));}/*** 订单退款申请单审核* @param request* @param result* @param apply_form_id* @param currentPage* @return*/@RequestMapping({ "/refund_audit" })public Map<String, Object> refund_audit(HttpServletRequest request, @RequestBody JSONObject json) {UserDto user = SecurityUserHolder.getCurrentUser(request);Store store = null ;if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}RefundApplyFormDto refundApplyForm = this.refundapplyformfeignclient.selectByPrimaryKey(CommUtil.null2Long(json.optString("apply_from_id")));//TODO//Store store = (user.getParent() == null ? user : user.getParent()).getStore();if ((store != null) && (store.getId().toString().equals(refundApplyForm.getStore_id()))&&refundApplyForm.getOrder_form_id()!=null) {OrderFormDto orderForm = this.orderFormFeignClient.selectByPrimaryKey(refundApplyForm.getOrder_form_id());refundApplyForm.setAudit_date(new Date());refundApplyForm.setAudit_user_name(user.getUserName());if (StringUtils.isNotBlank(json.optString("result"))) {   refundApplyForm.setStatus(10);this.refundapplyformfeignclient.updateById(refundApplyForm);orderForm.setOrder_status(22);this.orderFormFeignClient.updateById(orderForm);MessageDto msg = new MessageDto();String msg_content = "您订单号为：" + orderForm.getOrder_id() + "的订单退款申请已通过，我们会尽快将" + "退款金额打入您的预存款中。";msg.setAddTime(new Date());msg.setStatus(0);msg.setType(0);msg.setContent(msg_content);//msg.setFromu(user);//msg.setToUser(this.userFeignClient.selectByPrimaryKey(CommUtil.null2Long(orderForm.getUser_id())));msg.setFromUser_id(user.getId());msg.setToUser_id(CommUtil.null2Long(orderForm.getUser_id()));this.messagefeignclient.saveEntity(msg);} else {refundApplyForm.setStatus(5);this.refundapplyformfeignclient.updateById(refundApplyForm);orderForm.setOrder_status(20);this.orderFormFeignClient.updateById(orderForm);MessageDto msg = new MessageDto();String msg_content = "您订单号为：" + orderForm.getOrder_id() + "的订单退款申请未通过。";msg.setAddTime(new Date());msg.setStatus(0);msg.setType(0);msg.setContent(msg_content);msg.setFromUser(user);msg.setToUser_id(CommUtil.null2Long(orderForm.getUser_id()));this.messagefeignclient.saveEntity(msg);}}else {//店铺不存在， 或者登录用户不为该订单商铺return ResponseCode.buildReturnMap(ResponseCode.REQUEST_FORBIDDEN, null);}return ResponseCode.buildSuccessMap(null);}/*** 退货列表* @param request* @param response* @param currentPage* @param orderBy* @param orderType* @param name* @param user_name* @param return_service_id* @return*/@RequestMapping(value = { "/return" } , method = RequestMethod.POST)public Map<String, Object> seller_return(HttpServletRequest request,@RequestBody JSONObject json) {String currentPage = json.optString("currentPage");String orderBy = json.optString("orderBy");String orderType = json.optString("orderType");String name = json.optString("name");String user_name = json.optString("user_name");String return_service_id = json.optString("return_service_id");Map<String,Object> maps= this.queryTools.getParams(currentPage, "addTime", "desc");maps.put("goods_type", 1);if ((user_name != null) && (!user_name.equals(""))) {maps.put("user_name", user_name);}if ((name != null) && (!name.equals(""))) {maps.put("goods_name_like", name);}if ((return_service_id != null) && (!return_service_id.equals(""))) {maps.put("return_service_id", return_service_id);}UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store != null){maps.put("store_id", store.getId());}else{return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}maps.put("store_id", user.getStore_id());Map<String , Object> data = this.returnGoodsLogFeignClient.list(maps);data.put("name", name);data.put("user_name", user_name);data.put("return_service_id", return_service_id);data.put("store", store);return ResponseCode.buildSuccessMap(data);}/*** 退货详情数据* @param request* @param response* @param currentPage* @param id* @return*/@RequestMapping(value = { "/return_check" } , method = RequestMethod.POST)public Map<String, Object> return_check(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");ReturnGoodsLogDto obj = this.returnGoodsLogFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));Map<String, Object> map = Maps.newHashMap();if (obj.getGoods_return_status().equals("7")) {TransInfoDto transInfo = this.shipToolsFeignClient.query_Ordership_getData(CommUtil.null2String(obj.getId()));map.put("transInfo", transInfo);Map<String, Object> mapa = JSON.parseObject(obj.getReturn_express_info());//物流名称map.put("express_company_name",mapa.get("express_company_name"));}map.put("obj", obj);return ResponseCode.buildSuccessMap(map);}/*** 退货订单  审核or拒绝* @param request* @param id* @param goods_return_status* @param self_address*/@RequestMapping( value = { "/return_check_save" } , method = RequestMethod.POST)public Map<String , Object> return_check_saveEntity(HttpServletRequest request,@RequestBody JSONObject jsonv) {String id = jsonv.optString("id");/*String currentPage = jsonv.optString("currentPage");*//*String cmd = jsonv.optString("cmd");*/// 退货商品状态 -2为超过退货时间未能输入退货物流 -1为申请被拒绝  1为可以退货 5为退货申请中 6为审核通过可进行退货 7为退货中  10为退货完成,等待退款，11为平台退款完成String goods_return_status = jsonv.optString("goods_return_status");// 收货时向买家发送的收货地址，买家通过此将货物发送给卖家String self_address = jsonv.optString("self_address");UserDto seller = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());
//      UserDto seller = this.userFeignClient.selectByPrimaryKey(445L);if(seller == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (seller.getParent_id()!=null) {seller = this.userFeignClient.selectByPrimaryKey(seller.getParent_id());}//user = user.getParent_id() == null ? user : user.getParent();    if(seller.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(seller.getStore_id()));//     Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(62));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}ReturnGoodsLogDto obj = this.returnGoodsLogFeignClient.selectByPrimaryKey(Long.valueOf(Long.parseLong(id)));String message = "审核为未通过";String code = "10001";if ((seller.getStore_id() != null)&& (CommUtil.null2String(obj.getStore_id()).equals(seller.getStore_id().toString()))) {obj.setGoods_return_status(goods_return_status);obj.setSelf_address(self_address);obj.setRefund_time(new Date()); //审核时间this.returnGoodsLogFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getUser_id());String msg_content =null; if (goods_return_status.equals("6")) {message = "审核通过";code = "10000";msg_content = "退货申请审核通过，请在'退货/退款'-'查看返修/退换记录'中提交退货物流信息。";} else {/*   OrderFormDto of = this.orderFormFeignClient.selectByPrimaryKey(Long.valueOf(obj.getReturn_order_id()));of.setOrder_status(18);        //申请未通过, 用户取消退款确认收货/人工仲裁this.orderFormFeignClient.updateById(of);*/message = "提交成功";code = "10000";msg_content = "订单号：" + obj.getReturn_service_id()+ "退货申请审核未通过，请在'退货/退款'-'查看返修/退换记录'中提交退货物流信息。";}MessageDto msg = new MessageDto();msg.setAddTime(new Date());msg.setStatus(0);msg.setType(0);msg.setContent(msg_content);msg.setFromUser(SecurityUserHolder.getCurrentUser(request));msg.setToUser(user);this.messagefeignclient.saveEntity(msg);} else {message = "信息有误";code = "10001";}return ResponseCode.buildCodeMap(code,message, null);}/*** 确认退货收货* @param request* @param response* @param id* @return*/@RequestMapping( value = { "/return_confirm" } , method = RequestMethod.POST)public Map<String , Object> return_confirm(HttpServletRequest request , @RequestBody JSONObject jsonv) {String id = jsonv.optString("id");UserDto seller = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());ReturnGoodsLogDto obj = this.returnGoodsLogFeignClient.selectByPrimaryKey(Long.valueOf(Long.parseLong(id)));if(seller == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (seller.getParent_id()!=null) {seller = this.userFeignClient.selectByPrimaryKey(seller.getParent_id());}//user = user.getParent_id() == null ? user : user.getParent();    if(seller.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}
//      Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(seller
//              .getStore_id()));Store store = this.storeService.selectByPrimaryKey(seller.getStore_id());if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}if ((seller.getStore_id() != null)&& (CommUtil.null2String(obj.getStore_id()).equals(seller.getStore_id().toString()))) {obj.setGoods_return_status("10");this.returnGoodsLogFeignClient.updateById(obj);}return ResponseCode.buildSuccessMap(null);}/*** 卖家调整订单费用* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/order_fee" } , method = RequestMethod.POST)public Map<String , Object> order_fee(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}if (user.getStore_id().equals(store.getId())) {return ResponseCode.buildSuccessMap(obj);} else {return ResponseCode.buildEnumMap(ResponseCode.FAILURE, null);}}/*** 卖家调整订单费用保存* @param request* @param response* @param id* @param currentPage* @param goods_amount* @param ship_price* @param totalPrice* @return* @throws Exception*/@RequestMapping( value = { "/order_fee_save" } , method = RequestMethod.POST)public Map<String, Object> order_fee_saveEntity(HttpServletRequest request,@RequestBody JSONObject jsonv){String id = jsonv.optString("id");String goods_amount = jsonv.optString("goods_amount"); //商品总价格String ship_price = jsonv.optString("ship_price"); // 配送价格String totalPrice = jsonv.optString("totalPrice"); // 订单总价格OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (CommUtil.null2Double(obj.getCommission_amount()) <= CommUtil.null2Double(goods_amount)) {UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE,null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE,null);}//user = user.getParent_id() == null ? user : user.getParent();    if (user.getStore_id().toString().equals(store.getId().toString())) {obj.setGoods_amount(BigDecimal.valueOf(CommUtil.null2Double(goods_amount)));obj.setShip_price(BigDecimal.valueOf(CommUtil.null2Double(ship_price)));obj.setTotalPrice(BigDecimal.valueOf(CommUtil.null2Double(totalPrice)));obj.setOperation_price_count(obj.getOperation_price_count() + 1);this.orderFormFeignClient.updateById(obj);OrderFormLogDto ofl = new OrderFormLogDto();ofl.setAddTime(new Date());ofl.setLog_info("调整订单费用");ofl.setState_info("调整订单总金额为:" + totalPrice + ",调整运费金额为:"+ ship_price);ofl.setLog_user_id(SecurityUserHolder.getCurrentUser(request).getId());ofl.setLog_user_name(SecurityUserHolder.getCurrentUser(request).getUserName());ofl.setOf_id(obj.getId());this.orderFormLogFeignClient.saveEntity(ofl);/*   UserDto buyer = this.userFeignClient.selectByPrimaryKey(CommUtil.null2Long(obj.getUser_id()));Map<String, Object> map = Maps.newHashMap();map.put("buyer_id", buyer.getId().toString());map.put("seller_id", store.getUser_id());map.put("order_id", obj.getId());String json = JSON.toJSONString(map);if (obj.getOrder_form() == 0) {this.msgToolsFeignClient.sendEmailCharge(CommUtil.getURL(request),"email_tobuyer_order_update_fee_notify",buyer.getEmail(), json, null, obj.getStore_id());this.msgToolsFeignClient.sendSmsCharge(CommUtil.getURL(request),"sms_tobuyer_order_fee_notify", buyer.getMobile(),json, null, obj.getStore_id());} else {this.msgToolsFeignClient.sendEmailFree(CommUtil.getURL(request),"email_tobuyer_order_update_fee_notify",buyer.getEmail(), json, null);this.msgToolsFeignClient.sendSmsFree(CommUtil.getURL(request),"sms_tobuyer_order_fee_notify", buyer.getMobile(),json, null);}*/}else{return ResponseCode.buildReturnMap(ResponseCode.FAILURE,null);}}else{return ResponseCode.buildReturnMap(ResponseCode.FAILURE,null);}return ResponseCode.buildSuccessMap(null);}/*** 卖家发货* @param request* @param response* @param id* @param currentPage* @param page_status* @return*/@RequestMapping(value = { "/order_shipping" } , method = RequestMethod.POST)public Map<String, Object> order_shipping(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");String page_status = json.optString("page_status");OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store1 = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store1 == null ||store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Map<String, Object> map = Maps.newHashMap();if (user.getStore_id().equals(store.getId())) {map.put("obj", obj);List<GoodsDto> list_goods = queryOfGoods(obj);List<GoodsDto> deliveryGoods = Lists.newArrayList();boolean physicalGoods = false;for (GoodsDto g : list_goods) {if (g.getGoods_choice_type() == 1) {deliveryGoods.add(g);} else {physicalGoods = true;}}Map<String, Object> params = Maps.newHashMap();params.put("ecc_type", Integer.valueOf(0));params.put("ecc_store_id", store.getId());List<ExpressCompanyCommonDto> eccs = this.companyCommonFeignClient.queryPages(params);params.clear();params.put("sa_type", Integer.valueOf(0));params.put("sa_user_id", user.getId());params.put("orderBy", "obj.sa_default desc,obj.sa_sequence");params.put("orderType", "asc");List<ShipAddressDto> shipAddrs = this.shipAddressFeignClient.queryPages(params);map.put("eccs", eccs);map.put("shipAddrs", shipAddrs);map.put("physicalGoods", Boolean.valueOf(physicalGoods));map.put("deliveryGoods", deliveryGoods);map.put("page_status", page_status);//用改方法查询虚拟商品的数量/*map.put("queryOfGoodsCount", this.queryOfGoodsCount);*/} else {return ResponseCode.buildEnumMap(ResponseCode.PARAM_ERROR, null);}return ResponseCode.buildSuccessMap(map);}/*** 根据订单id和商品id查询该商品在该订单中的数量          * @param order_id* @param goods_id* @return*/public int queryOfGoodsCount(String order_id, String goods_id) {int count = 0;OrderFormDto of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));List<Map> map_list = this.orderFormToolsFeignClient.queryGoodsInfo(of.getGoods_info());for (Map map : map_list) {if (CommUtil.null2String(map.get("goods_id")).equals(goods_id)) {count = CommUtil.null2Int(map.get("goods_count"));break;}}if ((count == 0)&& (!CommUtil.null2String(of.getChild_order_detail()).equals(""))) { // 主订单无数量信息，继续从子订单中查询List<Map> maps = this.orderFormToolsFeignClient.queryGoodsInfo(of.getChild_order_detail());for (Map map : maps) {OrderFormDto child_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("order_id")));map_list.clear();map_list = this.orderFormToolsFeignClient.queryGoodsInfo(child_order.getGoods_info());for (Map map1 : map_list) {if (CommUtil.null2String(map1.get("goods_id")).equals(goods_id)) {count = CommUtil.null2Int(map1.get("goods_count"));break;}}}}return count;}/*** 根据订单id查询该订单中所有商品,包括子订单中的商品* @param main_order* @return*/public List<GoodsDto> queryOfGoods(OrderFormDto main_order) {List<Map> map_list =this.orderFormToolsFeignClient.queryGoodsInfo(main_order.getGoods_info());List<GoodsDto> goods_list = Lists.newArrayList();for (Map map : map_list) {GoodsDto goods = this.goodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("goods_id")));if(goods != null){goods_list.add(goods);}}if (!CommUtil.null2String(main_order.getChild_order_detail()).equals("")) {List<Map> maps = this.orderFormToolsFeignClient.queryGoodsInfo(main_order.getChild_order_detail());for (Map<String, Object> map : maps) {OrderFormDto child_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("order_id")));map_list.clear();map_list =this.orderFormToolsFeignClient.queryGoodsInfo(child_order.getGoods_info());for (Map map1 : map_list) {GoodsDto good = this.goodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map1.get("goods_id")));goods_list.add(good);}}}return goods_list;}/*** 卖家修改物流* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/order_shipping_code" } , method = RequestMethod.POST)public Map<String , Object> order_shipping_code(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Store store1 = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store1 == null || store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}if (user.getStore_id().equals(store.getId())) {return ResponseCode.buildSuccessMap(obj);} else {return ResponseCode.buildEnumMap(ResponseCode.FAILURE, null);}}/*** 卖家修改物流保存* @param request* @param response* @param id* @param currentPage* @param shipCode* @param state_info* @return*/@RequestMapping(value = { "/order_shipping_code_save" } , method = RequestMethod.POST)public Map<String , Object> order_shipping_code_saveEntity(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");String shipCode = json.optString("shipCode");String state_info = json.optString("state_info");OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store1 = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store1 == null || store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Map<String, Object> map = Maps.newHashMap();if (user.getStore_id().equals(store.getId())) {obj.setShipCode(shipCode);this.orderFormFeignClient.updateById(obj);OrderFormLogDto ofl = new OrderFormLogDto();ofl.setAddTime(new Date());ofl.setLog_info("修改物流信息");ofl.setState_info(state_info);ofl.setLog_user_id(SecurityUserHolder.getCurrentUser(request).getId());ofl.setLog_user_name(SecurityUserHolder.getCurrentUser(request).getUserName());ofl.setOf(obj);this.orderFormLogFeignClient.saveEntity(ofl);if (this.sysConfigFeignClient.getSysConfig().getKuaidi_type() == 1) {JSONObject info = new JSONObject();Map express_map = JSON.parseObject(obj.getExpress_info());info.put("company", CommUtil.null2String(express_map.get("express_company_mark")));info.put("number", obj.getShipCode());info.put("from", CommUtil.null2String(obj.getShip_addr()));info.put("to", obj.getReceiver_area());info.put("key", this.sysConfigFeignClient.getSysConfig().getKuaidi_id2());JSONObject param_info = new JSONObject();param_info.put("callbackurl", CommUtil.getURL(request)+ "/kuaidi_callback?order_id=" + obj.getId()+ "&orderType=0");param_info.put("salt",Md5Encrypt.md5(CommUtil.null2String(obj.getId())).substring(0, 16));info.put("parameters", param_info);try {String result = Post("http://highapi.kuaidi.com/openapi-receive.html",info.toString());Map remap = JSON.parseObject(result);if ("success".equals(CommUtil.null2String(remap.get("message")))) {ExpressInfoDto ei = new ExpressInfoDto();ei.setAddTime(new Date());ei.setOrder_id(obj.getId());ei.setOrder_express_id(obj.getShipCode());ei.setOrder_type(0);Map ec_map = JSON.parseObject(CommUtil.null2String(obj.getExpress_info()));if (ec_map != null) {ei.setOrder_express_name(CommUtil.null2String(ec_map.get("express_company_name")));}this.expressInfoFeignClient.saveEntity(ei);System.out.println("订阅成功");} else {System.out.println("订阅失败");}} catch (JSONException e) {e.printStackTrace(); }}}return ResponseCode.buildSuccessMap(null);}/*** 快递Post请求* @param url* @param param* @return*/@SuppressWarnings("resource")public static String Post(String url, String param) {try {DefaultHttpClient httpClient = new DefaultHttpClient();HttpPost method = new HttpPost(url);StringEntity entity = new StringEntity(param, "utf-8");// 解决中文乱码问题entity.setContentEncoding("UTF-8");entity.setContentType("application/json");method.setEntity(entity);HttpResponse result = httpClient.execute(method);// 请求结束，返回结果return EntityUtils.toString(result.getEntity());} catch (Exception e) {e.printStackTrace();throw new RuntimeException(e.getMessage());}}/*** 卖家物流详情* @param request* @param response* @param id* @return*/@RequestMapping( value = { "/ship_view" } , method = RequestMethod.POST)public Map<String , Object> order_ship_view(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store1 = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store1 == null || store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}Map<String, Object> map = Maps.newHashMap();if (user.getStore_id().equals(store.getId())) {map.put("obj", obj);TransInfoDto transInfo = this.shipToolsFeignClient.query_Ordership_getData(CommUtil.null2String(obj.getId()));map.put("transInfo", transInfo);return ResponseCode.buildSuccessMap(map);} else {return ResponseCode.buildEnumMap(ResponseCode.FAILURE, null);}}/*** 商品评价列表* @param request* @param response* @param currentPage* @param orderBy* @param orderType* @param status* @return*/@RequestMapping({ "/evaluate_list" })public Map<String ,  Object> evaluate_list(HttpServletRequest request,@RequestBody JSONObject json) {String currentPage = json.getString("currentPage");String orderBy = json.getString("orderBy");String orderType = json.getString("orderType");String status = json.getString("status");String evaluate_buyer_val = json.getString("evaluate_buyer_val");Map<String,Object> maps= this.queryTools.getParams(currentPage, orderBy, orderType);UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}maps.put("evaluate_goods_goods_store_id", store.getId());maps.put("evaluate_status", 0);maps.put("evaluate_type", "goods");if ("yes".equals(status)) {maps.put("reply_status", 1);maps.put("status", status);}if ("no".equals(status)) {maps.put("reply_status", 0);maps.put("status", status);}//买家评价，评价类型，1为好评，0为中评，-1为差评if(StringUtils.isNotBlank(evaluate_buyer_val)){maps.put("evaluate_buyer_val", evaluate_buyer_val);}Map<String, Object> map = this.evaluateFeignClient.list(maps);map.put("status", status);return ResponseCode.buildSuccessMap(map);}/*** 商品评价内容查看* @param request* @param response* @param id* @return*/@RequestMapping( value = { "/evaluate_info" } ,method = RequestMethod.POST)public Map<String , Object> evaluate_info(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}EvaluateDto evl = this.evaluateFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));//TODOif (evl != null){OrderFormDto of = this.orderFormFeignClient.selectByPrimaryKey(evl.getOf_id());UserDto euser = userFeignClient.selectByPrimaryKey(evl.getEvaluate_user_id());if((of.getStore_id().equals(user.getStore_id()+""))) {/*mv.addObject("evl", evl);*//*mv.addObject("imageTools", this.imageTools);*/Map<String , Object> maps = Maps.newHashMap();maps.put("evl", evl);maps.put("euser", euser);return ResponseCode.buildSuccessMap(maps);} else {return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}}else{return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}}/*** 商品评价内容回复* @param request* @param response* @param id* @param reply*/@RequestMapping( value = { "/evaluate_reply_save" } , method = RequestMethod.POST)public Map<String, Object> evaluate_reply_saveEntity(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");String reply = json.optString("reply");UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}EvaluateDto evl = this.evaluateFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (evl != null){OrderFormDto of = this.orderFormFeignClient.selectByPrimaryKey(evl.getOf_id());if((of.getStore_id().equals(user.getStore_id()+""))) {/*mv.addObject("evl", evl);*//*mv.addObject("imageTools", this.imageTools);*/evl.setReply(reply);evl.setReply_status(1);this.evaluateFeignClient.updateById(evl);return ResponseCode.buildSuccessMap(evl);} else {return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}}else{return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}}/*** 常用快递公司* @param request* @param response* @param currentPage* @param orderBy* @param orderType* @return*/@RequestMapping(value = { "/ecc_set" } ,method = RequestMethod.POST)public Map<String , Object> ecc_set(HttpServletRequest request) {Map<String, Object> params = Maps.newHashMap();/*List<ExpressCompanyDto> ecs = this.expressCompanyFeignClient.queryPageList(params);*/UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildEnumMap(ResponseCode.TOKEN_EXPIRE, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildEnumMap(ResponseCode.NOTSTORE, null);}List<ExpressCompanyCommonDto> eccs = Lists.newArrayList();if ((store != null) && (user.getUserRole().indexOf("SELLER") >= 0)) {params.put("ecc_type", Integer.valueOf(0));params.put("ecc_store_id", store.getId());eccs = this.expressCompanyCommonFeignClient.queryPages(params);}/*mv.addObject("ecs", ecs);mv.addObject("transportTools", this.transportTools);*/return ResponseCode.buildSuccessMap(eccs);}
//  public int query_common_ec(HttpServletRequest request,String id) {
//      int ret = 0;
//      if (!CommUtil.null2String(id).equals("")) {
//          Map<String, Object> params = Maps.newHashMap();
//          UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder
//                  .getCurrentUser(request).getId());
//          if(user == null){
//              return ret;
//          }
//          if (user.getParent_id()!=null) {
//              user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());
//          }
//          Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user
//                  .getStore_id()));
//          if(store == null){
//              return ret;
//          }
//          List<ExpressCompanyCommonDto> eccs = Lists.newArrayList();
//          if ((store != null) && (user.getUserRole().indexOf("SELLER") >= 0)) {
//              params.put("ecc_type", Integer.valueOf(0));
//              params.put("ecc_store_id", store.getId());
//              eccs = this.expressCompanyCommon.queryPageList(params);
//
//              for (ExpressCompanyCommonDto ecc : eccs) {
//                  if (ecc.getEcc_ec_id().equals(CommUtil.null2Long(id))) {
//                      ret = 1;
//                  }
//              }
//          } else {
//              params.put("ecc_type", Integer.valueOf(1));
//              eccs = this.expressCompanyCommon.queryPageList(params);
//
//              for (ExpressCompanyCommonDto ecc : eccs) {
//                  if (ecc.getEcc_ec_id().equals(CommUtil.null2Long(id))) {
//                      ret = 1;
//                  }
//              }
//          }
//      }
//      return ret;
//  }/*** 常用快递公司删除* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/ecc_delete" } , method = RequestMethod.POST)public Map<String, Object> ecc_deleteById(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");ExpressCompanyCommonDto ecc = this.expressCompanyCommonFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.TOKEN_EXPIRE, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}if (ecc.getEcc_store_id().equals(store.getId())) {this.expressCompanyCommonFeignClient.deleteById(CommUtil.null2Long(id));return ResponseCode.buildSuccessMap(null);}else{return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}}/*** 所有未选择的常用快递公司* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/ecc_saveEntityView" } , method = RequestMethod.POST)public Map<String, Object> ecc_saveEntityView(HttpServletRequest request,@RequestBody JSONObject json) {UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildEnumMap( ResponseCode.TOKEN_EXPIRE, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildEnumMap(ResponseCode.NOTSTORE,null);}Map<String, Object> params = Maps.newHashMap();params.put("company_status", Integer.valueOf(0));params.put("orderBy", "company_sequence");params.put("orderType", "asc");List<ExpressCompanyDto> excs = this.expressCompanyFeignClient.queryPages(params);List<ExpressCompanyCommonDto> eccs = Lists.newArrayList();List<ExpressCompanyDto> execs = Lists.newArrayList();if ((store != null) && (user.getUserRole().indexOf("SELLER") >= 0)) {params.clear();params.put("ecc_type", Integer.valueOf(0));params.put("ecc_store_id", store.getId());eccs = this.expressCompanyCommonFeignClient.queryPages(params);for (ExpressCompanyDto exc : excs) {int i= 0;for (ExpressCompanyCommonDto ecc : eccs) {if (ecc.getEcc_ec_id().equals(CommUtil.null2Long(exc.getId()))) {i=1;break;}}if(i == 0){execs.add(exc);}}} return ResponseCode.buildSuccessMap(execs);}/*** 常用快递公司添加* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/ecc_saveEntity" } , method = RequestMethod.POST)public Map<String, Object> ecc_saveEntity(HttpServletRequest request,@RequestBody JSONObject json) {String ids = json.optString("ids");String[] ec_ids= null;if(ids != null){ec_ids = ids.split(",");}UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.TOKEN_EXPIRE, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}for (String ec_id : ec_ids) {if (!CommUtil.null2String(ec_id).equals("")) {ExpressCompanyDto ec = this.expressCompanyFeignClient.selectByPrimaryKey(CommUtil.null2Long(ec_id));ExpressCompanyCommonDto ecc = new ExpressCompanyCommonDto();ecc.setAddTime(new Date());ecc.setEcc_code(ec.getCompany_mark());ecc.setEcc_ec_id(ec.getId());ecc.setEcc_name(ec.getCompany_name());ecc.setEcc_store_id(store.getId());ecc.setEcc_template(ec.getCompany_template());ecc.setEcc_template_heigh(ec.getCompany_template_heigh());ecc.setEcc_template_width(ec.getCompany_template_width());ecc.setEcc_template_offset(ec.getCompany_template_offset());ecc.setEcc_type(0);ecc.setEcc_ec_type(ec.getCompany_type());this.expressCompanyCommonFeignClient.saveEntity(ecc);}}return ResponseCode.buildSuccessMap(null);}/*** 发货地址列表* @param request* @param response* @param currentPage* @param orderBy* @param orderType* @return*/@RequestMapping(value = { "/ship_address" } ,method = RequestMethod.POST)public Map<String,Object> ship_address(HttpServletRequest request,@RequestBody JSONObject json) {String currentPage = json.optString("currentPage");String orderBy = json.optString("orderBy");String orderType = json.optString("orderType");Map<String,Object> maps= this.queryTools.getParams(currentPage, orderBy, orderType);UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());List<Long> sa_user_ids = Lists.newArrayList();sa_user_ids.add(user.getId());if(user!=null && user.getParent_id()!=null){UserDto userParent = this.userFeignClient.selectByPrimaryKey(user.getParent().getId());sa_user_ids.add(userParent.getId());List<UserDto> childs = userParent.getChilds();for (UserDto uc : childs) {sa_user_ids.add(uc.getId());}}if(user!=null && user.getChilds()!=null && user.getChilds().size()>0){List<UserDto> childs = user.getChilds();for (UserDto uc : childs) {sa_user_ids.add(uc.getId());}}maps.put("sa_type", 0);maps.put("sa_user_ids", sa_user_ids);Map<String, Object> data = this.shipAddressFeignClient.list(maps);HashMap<Object, Object> result = new HashMap<>();result.put("data", data);Store store = storeService.selectByPrimaryKey(user.getStore_id());if (store!=null) {List<Map> ms_list = Lists.newArrayList();if (store.getStore_service_info() != null) {ms_list = JSON.parseArray(store.getStore_service_info(),Map.class);}result.put("ms_list", ms_list);if (store.getMc_id()!=null&&store.getMc_id()==22) {result.put("scenic", 1); //为景点商品}else{result.put("scenic", 0); //普通商品}}return ResponseCode.buildSuccessMap(result);}/*** 新增发货地址的地区* @param request* @param response* @param currentPage* @return*/@RequestMapping(value = { "/ship_address_add" } , method = RequestMethod.POST)public Map<String , Object> ship_address_add(HttpServletRequest request, @RequestBody JSONObject json) {String parent_id = json.optString("parent_id");Map<String, Object> maps = Maps.newHashMap();if(StringUtils.isNotBlank(parent_id)){maps.put("parent_id", parent_id);}else{maps.put("parent_id", -1);}/*List<AreaDto> areas = this.areaFeignClient.queryPageList(maps);*/List<AreaDto> areas = this.areaFeignClient.queryPages(maps);return ResponseCode.buildSuccessMap(areas);}/*** 编辑发货地址* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/ship_address_edit" } , method = RequestMethod.POST)public Map<String , Object> ship_address_edit(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");ShipAddressDto obj = this.shipAddressFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildEnumMap(ResponseCode.TOKEN_EXPIRE,null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildEnumMap(ResponseCode.NOTSTORE,null);}if ((obj != null) && (obj.getSa_user_id().equals(user.getId()))) {Map<String, Object> maps = Maps.newHashMap();AreaDto sa_area = this.areaFeignClient.selectByPrimaryKeyFullParent(obj.getSa_area_id());obj.setSa_area_name(sa_area.getParent().getParent().getAreaName()+sa_area.getParent().getAreaName()+sa_area.getAreaName());maps.put("obj", obj);return ResponseCode.buildSuccessMap(maps);} else {return ResponseCode.buildEnumMap(ResponseCode.PARAM_ERROR, null);}}/*** 保存发货地址* @param request* @param response* @param id* @param currentPage*/@RequestMapping( value = { "/ship_address_save" } ,method = RequestMethod.POST)public Map<String , Object> ship_address_saveEntity(HttpServletRequest request,@RequestBody ShipAddressDto shipaddress) {UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildEnumMap(ResponseCode.TOKEN_EXPIRE,null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildEnumMap(ResponseCode.NOTSTORE,null);}if(shipaddress == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}if (StringUtils.isBlank(shipaddress.getId()+"")) {shipaddress.setAddTime(new Date());shipaddress.setDeleteStatus(0);} else {ShipAddressDto obj = this.shipAddressFeignClient.selectByPrimaryKey(shipaddress.getId());shipaddress.setAddTime(obj.getAddTime());shipaddress.setDeleteStatus(obj.getDeleteStatus());}//判断是不是第一个发货地址   如果是则设置成默认的Map< String , Object> maps = Maps.newHashMap();List<Long> sa_user_ids = Lists.newArrayList();sa_user_ids.add(user.getId());if(user!=null && user.getParent_id()!=null){UserDto userParent = this.userFeignClient.selectByPrimaryKey(user.getParent().getId());sa_user_ids.add(userParent.getId());List<UserDto> childs = userParent.getChilds();for (UserDto uc : childs) {sa_user_ids.add(uc.getId());}}if(user!=null && user.getChilds()!=null && user.getChilds().size()>0){List<UserDto> childs = user.getChilds();for (UserDto uc : childs) {sa_user_ids.add(uc.getId());}}maps.put("sa_type", 0);maps.put("sa_user_ids", sa_user_ids);List<ShipAddressDto> queryPages = this.shipAddressFeignClient.queryPages(maps);if(queryPages.size()>0){shipaddress.setSa_default(0);}else{shipaddress.setSa_default(1);}shipaddress.setStore_id(store.getId());shipaddress.setSa_type(0);shipaddress.setSa_user_id(SecurityUserHolder.getCurrentUser(request).getId());shipaddress.setSa_user_name(SecurityUserHolder.getCurrentUser(request).getUsername());//  根据行业 决定是否需要创建达达门店if (modularClassFeignClient.selectByPrimaryKey(store.getMc_id()).isTimely()) {  // 若为附近配送,SysConfigDto sysConfig = sysConfigFeignClient.getSysConfig();if (sysConfig.getDada_appkey()!=null&& sysConfig.getDada_appsecret()!=null) {// 1.初始化配置(isOnline表示是否测试环境)DaDaAppConfig appConfig = new DaDaAppConfig(store.getSource_id() + "", sysConfig.getDada_appkey(), sysConfig.getDada_appsecret());// 2.初始化modelShopAddModel shopAddModel = new ShopAddModel();if (StringUtils.isBlank(shipaddress.getId()+"")) {    //不存在走更新// 根据实际信息来填写门店地址String order_suffix = CommUtil.formatTime("yyyyMMddHHmmss", new Date());shopAddModel.setOriginShopId(order_suffix + store.getId()); // 门店编码,可自定义,但必须唯一;若不填写,则系统自动生成shipaddress.setShop_no(order_suffix + store.getId()); // 保存门店编码}else{shopAddModel.setOriginShopId(shipaddress.getShop_no());}shopAddModel.setStationName(shipaddress.getSa_name()); // 门店名称shopAddModel.setBusiness(13); // 业务类型, 13 水果生鲜AreaDto area = areaFeignClient.selectByPrimaryKeyFullParent(shipaddress.getSa_area_id());// shipaddressshopAddModel.setCityName(area.getParent().getAreaName()); // 城市名称shopAddModel.setAreaName(area.getAreaName()); // 区域名称shopAddModel.setStationAddress(shipaddress.getSa_addr()); // 详细地址shopAddModel.setLng(BigDecimal.valueOf(shipaddress.getSa_lng())); // 经纬度shopAddModel.setLat(BigDecimal.valueOf(shipaddress.getSa_lat()));shopAddModel.setContactName(shipaddress.getSa_user());shopAddModel.setPhone(shipaddress.getSa_telephone());// 3.初始化service (门店新增比较特殊,是一个批量新增接口)List<ShopAddModel> shopAddList = new ArrayList<ShopAddModel>();shopAddList.add(shopAddModel);String dadaUrl = null;if (StringUtils.isBlank(shipaddress.getId()+"")) {dadaUrl = "/api/shop/add";} else {// 更新门店信息dadaUrl = "/api/shop/update";}DaDaService shopAddService = new DaDaService(dadaUrl, JSONUtil.toJson(shopAddList));// 4.初始化客户端DadaRequestClient dadaClient = new DadaRequestClient(shopAddService, appConfig);DadaApiResponse callRpc = dadaClient.callRpc();if (callRpc.getCode() != 0) { // 不成功 ,返回错误信息return ResponseCode.buildCodeMap("100", callRpc.getMsg(), null);}}}if (StringUtils.isBlank(shipaddress.getId()+"")) {this.shipAddressFeignClient.saveEntity(shipaddress);} else {this.shipAddressFeignClient.updateById(shipaddress);}return ResponseCode.buildSuccessMap(null);}/*** 发货地址删除* @param request* @param response* @param mulitId* @param currentPage* @return*/@RequestMapping(value = { "/ship_address_del" } , method = RequestMethod.POST)public Map<String , Object> ship_address_del(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.TOKEN_EXPIRE, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}if (StringUtils.isNotBlank(id)) {ShipAddressDto obj = this.shipAddressFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if ((obj != null) && (obj.getSa_type() == 0)&& (obj.getSa_user_id().equals(user.getId()))) {this.shipAddressFeignClient.deleteById(obj.getId());}}return ResponseCode.buildSuccessMap(null);}/*** 设置默认发货地址* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping( value = { "/ship_address_default" } , method = RequestMethod.POST)public Map<String , Object> ship_address_default(HttpServletRequest request, @RequestBody JSONObject json) {UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.TOKEN_EXPIRE, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(user.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}Map<String, Object> params = Maps.newHashMap();params.put("sa_default", Integer.valueOf(1));params.put("sa_user_id", user.getId());List<ShipAddressDto> sa_list = this.shipAddressFeignClient.queryPages(params);for (ShipAddressDto sa : sa_list) {sa.setSa_default(0);this.shipAddressFeignClient.updateById(sa);}String id = json.optString("id");ShipAddressDto obj = this.shipAddressFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (obj.getSa_user_id().equals(user.getId())) {obj.setSa_default(1);this.shipAddressFeignClient.updateById(obj);}return ResponseCode.buildSuccessMap(null);}/*** 设置修改收货地址* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/upShippingAddress" } , method = RequestMethod.POST)public Map<String , Object> upShippingAddress(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}if (user.getStore_id().equals(store.getId())) {return ResponseCode.buildSuccessMap(obj);} else {return ResponseCode.buildEnumMap(ResponseCode.FAILURE, null);}}/*** 设置修改收货地址保存* @param request* @param response* @param id* @param currentPage* @return*/@RequestMapping(value = { "/upShippingAddress_save" } , method = RequestMethod.POST)public Map<String , Object> upShippingAddress_save(HttpServletRequest request,@RequestBody JSONObject json) {String id = json.optString("id");String receiver_name = json.optString("receiver_name");// 收货人姓名,确认订单后，将买家的收货地址所有信息添加到订单中，该订单与买家收货地址没有任何关联String receiver_area = json.optString("receiver_area");// 收货人地区,例如：福建省厦门市海沧区String receiver_area_info = json.optString("receiver_area_info");// 收货人详细地址，例如：凌空二街56-1号，4单元2楼1号//String receiver_zip = json.optString("receiver_zip");// 收货人邮政编码String receiver_telephone = json.optString("receiver_telephone");// 收货人联系电话String receiver_mobile = json.optString("receiver_mobile");// 收货人手机号码String lat = json.optString("lat");// 经纬度String lng = json.optString("lng");// OrderFormDto obj = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if(obj == null){return ResponseCode.buildReturnMap(ResponseCode.PARAM_ERROR, null);}UserDto user = this.userFeignClient.selectByPrimaryKey(SecurityUserHolder.getCurrentUser(request).getId());if(user == null){return ResponseCode.buildReturnMap(ResponseCode.USER_DOES_NOT_EXIST, null);}if (user.getParent_id()!=null) {user = this.userFeignClient.selectByPrimaryKey(user.getParent_id());}Store store = this.storeService.selectByPrimaryKey(CommUtil.null2Long(obj.getStore_id()));if(store == null){return ResponseCode.buildReturnMap(ResponseCode.NOTSTORE, null);}//user = user.getParent_id() == null ? user : user.getParent();    if(user.getStore_id() == null){return ResponseCode.buildReturnMap(ResponseCode.FAILURE, null);}if (CommUtil.null2String(user.getStore_id()).equals(CommUtil.null2String(store.getId()))) {obj.setReceiver_Name(receiver_name);obj.setReceiver_area(receiver_area);obj.setReceiver_area_info(receiver_area_info);//obj.setReceiver_zip(receiver_zip);obj.setReceiver_telephone(receiver_telephone);obj.setReceiver_mobile(receiver_mobile);if (StringUtils.isNotBlank(lat)&&StringUtils.isNotBlank(lng)) {obj.setUser_lat(CommUtil.null2Double(lat));obj.setUser_lng(CommUtil.null2Double(lng));}orderFormFeignClient.updateById(obj);return ResponseCode.buildSuccessMap(obj);} else {return ResponseCode.buildEnumMap(ResponseCode.FAILURE, null);}}}

package com.honghu.cloud.controller;import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import org.apache.commons.lang.StringUtils;
import org.jdom.Document;
import org.jdom.Element;
import org.jdom.JDOMException;
import org.jdom.input.SAXBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;import com.alibaba.fastjson.JSON;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.honghu.cloud.bean.GoldLog;
import com.honghu.cloud.bean.GoldRecord;
import com.honghu.cloud.bean.Payment;
import com.honghu.cloud.bean.PlatformPay;
import com.honghu.cloud.bean.PlatformPayFlow;
import com.honghu.cloud.code.ResponseCode;
import com.honghu.cloud.dto.CloudPurchaseOrderDto;
import com.honghu.cloud.dto.DistributionSettingDto;
import com.honghu.cloud.dto.IntegralGoodsDto;
import com.honghu.cloud.dto.IntegralGoodsOrderDto;
import com.honghu.cloud.dto.MessageDto;
import com.honghu.cloud.dto.OrderFormDto;
import com.honghu.cloud.dto.PredepositDto;
import com.honghu.cloud.dto.PredepositLogDto;
import com.honghu.cloud.dto.RushOrderformDto;
import com.honghu.cloud.dto.StoreDto;
import com.honghu.cloud.dto.SysConfigDto;
import com.honghu.cloud.dto.SysConfigExtendDto;
import com.honghu.cloud.dto.UserDto;
import com.honghu.cloud.feign.AgentProfitFeignClient;
import com.honghu.cloud.feign.CloudPurchaseOrderFeignClient;
import com.honghu.cloud.feign.DistributionOrderFeignClient;
import com.honghu.cloud.feign.DistributionProfitFeignClient;
import com.honghu.cloud.feign.DistributionSettingFeignClient;
import com.honghu.cloud.feign.HandleOrderFormFeignClient;
import com.honghu.cloud.feign.IntegralGoodsFeignClient;
import com.honghu.cloud.feign.IntegralGoodsOrderFeignClient;
import com.honghu.cloud.feign.JiguangPushFeignClient;
import com.honghu.cloud.feign.LiveOrderFeignClient;
import com.honghu.cloud.feign.MessageFeignClient;
import com.honghu.cloud.feign.OrderFormFeignClient;
import com.honghu.cloud.feign.OrderFormToolsFeignClient;
import com.honghu.cloud.feign.PinPayRecordFeignClient;
import com.honghu.cloud.feign.PredepositFeignClient;
import com.honghu.cloud.feign.PredepositLogFeignClient;
import com.honghu.cloud.feign.RushOrderFormFeignClient;
import com.honghu.cloud.feign.StoreFeignClient;
import com.honghu.cloud.feign.SysConfigFeignClient;
import com.honghu.cloud.feign.SysconrigExtendFeignClient;
import com.honghu.cloud.feign.TXTemplateFeignClient;
import com.honghu.cloud.feign.UserFeignClient;
import com.honghu.cloud.pay.alipay.services.AlipayService;
import com.honghu.cloud.pay.alipay.util.AlipayUtil;
import com.honghu.cloud.pay.bill.util.MD5Util;
import com.honghu.cloud.pay.tenpay.RequestHandler;
import com.honghu.cloud.pay.tenpay.ResponseHandler;
import com.honghu.cloud.pay.tenpay.util.Sha1Util;
import com.honghu.cloud.pay.tenpay.util.TenpayUtil;
import com.honghu.cloud.pay.unionpay.acp.sdk.SDKUtil;
import com.honghu.cloud.service.IGoldLogService;
import com.honghu.cloud.service.IGoldRecordService;
import com.honghu.cloud.service.IPaymentService;
import com.honghu.cloud.service.IPlatformPayFlowService;
import com.honghu.cloud.service.IPlatformPayService;
import com.honghu.cloud.tools.AccessTokenTools;
import com.honghu.cloud.tools.SecurityUserHolder;
import com.honghu.cloud.tools.qrcode.QRCodeUtil;
import com.honghu.cloud.utils.CommUtil;
import com.honghu.cloud.utils.tools.Md5Encrypt;import lombok.extern.log4j.Log4j;
import net.sf.json.JSONObject;/*** * <p>* Title: HongHuPayViewAction.java* </p>* * <p>* Description:在线支付回调控制器,处理系统支持的所有支付方式回调业务处理，包括支付宝、财付通、快钱、paypal、网银在线* </p>* * <p>* Copyright: Copyright (c) 2015* </p>* * <p>* Company: www.minglisoft.cn* </p>* * @author honghu* * @date 2014-5-25* * @version honghu_b2b2c v8.0 2016版*/
@SuppressWarnings({ "unchecked", "rawtypes", "unused" })
@RestController
@Log4j
@RequestMapping(value = "/pay")
public class PayController {private static final Logger logger = LoggerFactory.getLogger(PayController.class);@Autowiredprivate SysConfigFeignClient sysConfigFeignClient;@Autowiredprivate OrderFormFeignClient orderFormFeignClient;@Autowiredprivate PredepositLogFeignClient predepositLogFeignClient;@Autowiredprivate PredepositFeignClient predepositFeignClient;@Autowiredprivate IPaymentService paymentService;@Autowiredprivate CloudPurchaseOrderFeignClient cloudPurchaseOrderFeignClient;@Autowiredprivate IntegralGoodsOrderFeignClient integralGoodsOrderFeignClient;@Autowiredprivate RushOrderFormFeignClient rushOrderFormFeignClient;@Autowiredprivate UserFeignClient userFeignClient;@Autowiredprivate IGoldRecordService goldRecordService;@Autowiredprivate IGoldLogService goldLogService;@Autowiredprivate HandleOrderFormFeignClient handleOrderFormFeignClient;@Autowiredprivate OrderFormToolsFeignClient orderFormToolsFeignClient;@Autowiredprivate IntegralGoodsFeignClient integralGoodsFeignClient;@Autowiredprivate PinPayRecordFeignClient pinPayRecordFeignClient;@Autowiredprivate DistributionOrderFeignClient distributionOrderFeignClient;@Autowiredprivate SysconrigExtendFeignClient sysconrigExtendFeignClient;@Autowiredprivate IPlatformPayService platformPayService;@Autowiredprivate IPlatformPayFlowService platformPayFlowService;@Autowiredprivate StoreFeignClient storeFeignClient;@Autowiredprivate LiveOrderFeignClient liveOrderFeignClient;@Autowiredprivate MessageFeignClient messageFeignClient;@Autowiredprivate DistributionProfitFeignClient distributionProfitFeignClient;@Autowiredprivate DistributionSettingFeignClient distributionSettingFeignClient;@Autowiredprivate AgentProfitFeignClient agentProfitFeignClient;@Autowiredprivate TXTemplateFeignClient tXTemplateFeignClient;@Autowiredprivate JiguangPushFeignClient jiguangPushFeignClient;@Autowiredprivate AccessTokenTools accessTokenTools;@Autowiredprivate AlipayService alipayService;/* @Value("${notify.url}")private String notify_url;*//*** 移动端订单支付详情* * @param request* @param response* @param payType* @param order_id* @param order_type* @param pay_password* @return*/@RequestMapping(value = "/order_pay", method = RequestMethod.POST)public Map<String, Object> order_pay(HttpServletRequest request, HttpServletResponse response,@RequestBody JSONObject json) {String order_type = json.optString("order_type");String payType = json.optString("payType");Long order_id = json.optLong("order_id");UserDto user = SecurityUserHolder.getCurrentUser(request);Map<String, Object> result = new HashMap<String, Object>();if ("cloudpurchase".equals(order_type)) {CloudPurchaseOrderDto order = cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));if (order != null) {if ((order.getUser_id().equals(user.getId())) && (order.getStatus() == 0)) {if ("wx_pay".equals(payType)) {try {// TODO// 微信支付return ResponseCode.buildSuccessMap(wx_pay1(request, response, order_id, payType, order_type));} catch (Exception e) {log.error(e.toString());return ResponseCode.buildCodeMap("20008", "支付方式错误！", null);}}if ("wxh5_pay".equals(payType)) {try {// TODO// 微信支付return ResponseCode.buildSuccessMap(wxh5_pay(request, response, order_id, payType, order_type));} catch (Exception e) {log.error(e.toString());return ResponseCode.buildCodeMap("20008", "支付方式错误！", null);}}if (payType.equals("balance")) {double order_total_price = CommUtil.null2Double(Integer.valueOf(order.getPrice()));result.put("order_total_price", Double.valueOf(order_total_price));result.put("type", order_type);result.put("order_id", order_id);return ResponseCode.buildCodeMap("20009", "余额支付！", null);}result.put("type", "cloudpurchase");result.put("order_id", order.getId());result.put("url", CommUtil.getURL(request));Map<String, Object> params = Maps.newHashMap();params.put("mark", payType);List<Payment> payments = paymentService.queryPageList(params);if (payments.size() > 0) {Payment payment = payments.get(0);result.put("payment_id", payment.getId());}return ResponseCode.buildSuccessMap(result);}}return ResponseCode.buildCodeMap("20010", "订单中商品已被删除，请重新下单", null);}OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));Map<Boolean, Object> map_verify = orderFormToolsFeignClient.orderForm_verify(order, user.getId());Iterator iterator = map_verify.keySet().iterator();while (iterator.hasNext()) {Boolean verify_result = (Boolean) iterator.next();if (!verify_result.booleanValue()) {return ResponseCode.buildFailMap("", map_verify.get(verify_result));}}int order_status = orderFormToolsFeignClient.query_order_status(CommUtil.null2String(order_id));if (order_status == 10) {if ((payType == null) || ("".equals(CommUtil.null2String(payType)))) {return ResponseCode.buildCodeMap("20011", "支付方式错误", null);}Map<String, Object> params = Maps.newHashMap();params.put("mark", payType);List<Payment> payments = paymentService.queryPageList(params);if (payments.size() > 0) {Payment payment = payments.get(0);order.setPayment_id(payment.getId());order.setPayment_mark(payment.getMark());order.setPayment_name(payment.getName());}order.setPayType("online");orderFormFeignClient.updateById(order);if (payType.equals("balance")) {double order_total_price = orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(order_id));result.put("order_total_price", order_total_price);result.put("user", user);} else {result.put("payType", payType);result.put("url", CommUtil.getURL(request));// mv.addObject("payTools", this.payTools);String type = "goods";if (order.getOrder_cat() == 2) {type = "group";}result.put("type", type);result.put("payment_id", order.getPayment_id());if ("wx_pay".equals(payType)) {try {// TODO// 微信支付return ResponseCode.buildSuccessMap(wx_pay1(request, response, order_id, payType, order_type));} catch (Exception e) {log.error(e.toString());return ResponseCode.buildCodeMap("20011", "支付方式错误", null);}}}result.put("order", order);result.put("order_id", order.getId());result.put("user", user);}if (order_status == 11) {if (payType.equals("balance")) {double order_total_price = orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(order_id));result.put("order_total_price", order_total_price);result.put("user", user);} else {result.put("payType", payType);result.put("url", CommUtil.getURL(request));// mv.addObject("payTools", this.payTools);String type = "goods";result.put("type", type);result.put("payment_id", order.getPayment_id());if ("wx_pay".equals(payType)) {try {// TODO// 微信支付return ResponseCode.buildSuccessMap(wx_pay1(request, response, order_id, payType, order_type));} catch (Exception e) {log.error(e.toString());return ResponseCode.buildCodeMap("20011", "支付方式错误", null);}}}result.put("order", order);result.put("order_id", order.getId());result.put("user", user);}return ResponseCode.buildSuccessMap(result);}/*** 手机订单货到付款* * @param request* @param response* @param order_id* @param pay_msg* @param pay_session* @return* @throws Exception*/@RequestMapping({ "/order_pay_payafter" })public Map<String, Object> order_pay_payafter(HttpServletRequest request, HttpServletResponse response,@RequestBody JSONObject json) throws Exception {String pay_session = json.optString("pay_session");String pay_msg = json.optString("pay_msg");String order_id = json.optString("order_id");Map<String, Object> result = new HashMap<String, Object>();String pay_session1 = CommUtil.null2String(request.getSession(false).getAttribute("pay_session"));if (pay_session1.equals(pay_session)) {OrderFormDto order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));boolean exist = orderFormToolsFeignClient.verify_goods_exist(order);if (!exist) {return ResponseCode.buildFailMap("订单中商品已被删除，请重新下单", null);}boolean inventory_very = orderFormToolsFeignClient.verify_goods_Inventory(order);if (!inventory_very) {return ResponseCode.buildFailMap("订单中商品库存不足，请重新下单", null);}boolean ret = handleOrderFormFeignClient.payByPayafter(order, CommUtil.getURL(request), pay_msg);if (ret) {orderFormToolsFeignClient.updateGoodsInventory(order);}request.getSession(false).removeAttribute("pay_session");result.put("op_title", "货到付款提交成功，等待发货");result.put("url", CommUtil.getURL(request) + "/buyer/order_list");} else {return ResponseCode.buildFailMap("订单已经支付，禁止重复支付", null);}return ResponseCode.buildSuccessMap(result);}/*** 支付宝在线支付成功回调控制* * @param request* @param response* @return* @throws Exception*//*@RequestMapping({ "/aplipay_return" })public Map<String, Object> aplipay_return(HttpServletRequest request, HttpServletResponse response)throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();System.out.println("pc_alipay_return");String trade_no = request.getParameter("trade_no");String[] order_nos = request.getParameter("out_trade_no").split("-");String total_fee = request.getParameter("price");String subject = request.getParameter("subject");String order_no = order_nos[2];String type = CommUtil.null2String(request.getParameter("body")).trim();String trade_status = request.getParameter("trade_status");OrderFormDto main_order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if (type.equals("goods")) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("cash")) {obj = predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("group")) {main_order = orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}Map<String, String> params = Maps.newHashMap();Map requestParams = request.getParameterMap();for (Iterator iter = requestParams.keySet().iterator(); iter.hasNext();) {String name = (String) iter.next();String[] values = (String[]) requestParams.get(name);String valueStr = "";for (int i = 0; i < values.length; i++) {valueStr = valueStr + values[i] + ",";}params.put(name, valueStr);}AlipayConfig config = new AlipayConfig();Payment payment = null;if ((type.equals("goods")) || (type.equals("group"))) {payment = this.paymentService.selectByPrimaryKey(main_order.getPayment_id());config.setKey(payment.getSafeKey());config.setPartner(payment.getPartner());config.setSeller_email(payment.getSeller_email());}if ((type.equals("cash")) || (type.equals("gold")) || (type.equals("integral"))|| (type.equals("cloudpurchase"))) {Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));if (type.equals("cash")) {q_params.put("mark", obj.getPd_payment());}if (type.equals("gold")) {q_params.put("mark", gold.getGold_payment());}if (type.equals("integral")) {q_params.put("mark", ig_order.getIgo_payment());}if (type.equals("cloudpurchase")) {q_params.put("mark", cp_order.getPayment());}List<Payment> payments = this.paymentService.queryPageList(q_params);config.setKey(((Payment) payments.get(0)).getSafeKey());config.setPartner(((Payment) payments.get(0)).getPartner());config.setSeller_email(((Payment) payments.get(0)).getSeller_email());}config.setNotify_url(CommUtil.getURL(request) + "/alipay_notify");config.setReturn_url(CommUtil.getURL(request) + "/aplipay_return");boolean verify_result = AlipayNotify.verify(config, params);if (verify_result) {if (((type.equals("goods")) || (type.equals("group"))) && ((trade_status.equals("WAIT_SELLER_SEND_GOODS"))|| (trade_status.equals("TRADE_FINISHED")) || (trade_status.equals("TRADE_SUCCESS")))) {boolean flag = this.handleOrderFormFeignClient.payByOnline(main_order, trade_no,CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(main_order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");resultMap.put("all_price", Double.valueOf(this.orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(main_order.getId()))));resultMap.put("obj", main_order);}if ((type.equals("cash")) && ((trade_status.equals("WAIT_SELLER_SEND_GOODS"))|| (trade_status.equals("TRADE_FINISHED")) || (trade_status.equals("TRADE_SUCCESS")))) {if (obj.getPd_pay_status() != 2) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("支付宝在线支付");this.predepositLogFeignClient.saveEntity(log);}resultMap.put("op_title", "恭喜您，成功充值" + obj.getPd_amount() + "元");resultMap.put("url", CommUtil.getURL(request) + "/buyer/predeposit_list");}if ((type.equals("gold")) && ((trade_status.equals("WAIT_SELLER_SEND_GOODS"))|| (trade_status.equals("TRADE_FINISHED")) || (trade_status.equals("TRADE_SUCCESS")))) {if (gold.getGold_pay_status() != 2) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("支付宝在线支付");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}resultMap.put("op_title", "兑换" + gold.getGold_count() + "金币成功");resultMap.put("url", CommUtil.getURL(request) + "/seller/gold_record_list");}if ((type.equals("integral")) && ((trade_status.equals("WAIT_SELLER_SEND_GOODS"))|| (trade_status.equals("TRADE_FINISHED")) || (trade_status.equals("TRADE_SUCCESS")))) {if (ig_order.getIgo_status() < 20) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("alipay");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}resultMap.put("obj", ig_order);}if (type.equals("cloudpurchase")) {if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}resultMap.put("op_title", "预付款支付成功！");resultMap.put("url", CommUtil.getURL(request) + "/buyer/cloudbuy_order");}} else {resultMap.put("op_title", "支付回调失败");resultMap.put("url", CommUtil.getURL(request) + "/index");}return resultMap;}*//*** 支付宝异步通知* * @param request* @param response* @throws Exception*/@RequestMapping({ "/alipay_notify" })public void alipay_notify(HttpServletRequest request, HttpServletResponse response) throws Exception {/*https://xx/receive_notify.htm?notify_type=trade_status_sync&notify_id=91722adff935e8cfa58b3aabf4dead6ibe&notify_time=2017-02-16 21:46:15&sign_type=RSA2&sign=xxxxxxxxxxxxxxx&app_id=2088102146225135&trade_no=2013112011001004330000121536&out_trade_no=6823789339978248&out_biz_no=85478536823789339978248&buyer_logon_id=159****5620&seller_id=2088102146225135&trans_currency=USD&seller_email=aa@mail.sa.com&total_amount=120.88&buyer_id=2088202954065786&settle_currency=USD&settle_amount=88.88&pay_currency=CNY&pay_amount=580.04&settle_trans_rate=1&trans_pay_rate=6.5261&trade_status=TRADE_SUCCESS&invoice_amount=88.88&receipt_amount=88.88&point_amount=88.88&refund_fee=10.23&buyer_pay_amount=88.88&subject=Iphone6 16G&body=Iphone6 16G&gmt_create=2014-11-27 15:45:57&gmt_payment=2014-11-27 15:45:57&gmt_refund=2014-11-27 14:15:57&gmt_close=2014-11-27 17:45:57&fund_bill_list="[{\"amount\":\"10000.00\",\"fundChannel\":\"ALIPAYACCOUNT\"}]"&voucher_detail_list="[{\"id\":\"20170307000730026487005X1M6V\",\"name\":\"全仓5折优惠券\"}]"&discount_goods_detail="[{\"goodsId\":\"STANDARD1026181538\",\"goodsName\":\"雪碧\",\"discountAmount\":\"10.00\"}]"&refund_preset_paytool_list=[{"amount":"1.00","assert_type_code":"HEMA"}]&charge_amount=8.88&charge_flags=bluesea_1&settlement_id=2018101610032004620239146945&advance_amount=11.11&current_seller_received_amount=88.88&seller_received_total_amount=88.88&total_from_seller_fee=88.88&ff_current_period=1&notify_action_type=payByAccountAction/closeTradeAction/reverseAction/finishFPAction/confirmDisburseAction/financingReceiptAction&discount_amount=88.88&mdiscount_amount=88.88&unfreeze_amount=18.18&auth_trade_pay_mode=CREDIT_PREAUTH_PAY&passback_params=merchantBizType%3d3C%26merchantBizNo%3d2016010101111&hb_fq_pay_info={"USER_INSTALL_NUM":"3"}&receipt_currency_type=DC*///获取支付宝POST过来反馈信息Map<String, String> params = new HashMap<String, String>();Map requestParams = request.getParameterMap();for (Iterator iter = requestParams.keySet().iterator(); iter.hasNext(); ) {String name = (String) iter.next();String[] values = (String[]) requestParams.get(name);String valueStr = "";for (int i = 0; i < values.length; i++) {valueStr = (i == values.length - 1) ? valueStr + values[i] : valueStr + values[i] + ",";}//乱码解决，这段代码在出现乱码时使用。//valueStr = new String(valueStr.getBytes("ISO-8859-1"), "utf-8");params.put(name, valueStr);}//String sign = request.getParameter("sign");String passbackParamsUnCode = request.getParameter("passback_params");String passbackParams = java.net.URLDecoder.decode(passbackParamsUnCode);String[] attachs = passbackParams.split("_");String type = attachs[3];//支付方式  因为付方式是"alipay_app" 形式 故pay_type为attachs[4]+"_"+attachs[5]String pay_type = attachs[4] + "_" + attachs[5];System.out.println("返回的pay_type:" + pay_type);Map<String, Object> pay_type_params = Maps.newHashMap();pay_type_params.put("mark", pay_type);List<Payment> payments =   this.paymentService.queryPageList(pay_type_params);log.info("----异步通知参数 开始 ------");log.info(params.toString());log.info("----异步通知参数 结束 ------");if (null == payments || payments.size() < 1) {log.error("支付异步通知失败");response.setContentType("text/plain");response.setHeader("Cache-Control", "no-cache");response.setCharacterEncoding("UTF-8");try {PrintWriter writer = response.getWriter();writer.print("fail");} catch (IOException e) {log.error(e.toString());}return;}Payment payment = payments.get(0);//if (AlipayUtil.validateSign(params, payment.getApp_public_key())) {log.info("回調验签成功");afterNotifyOrderHandling_alipay(request, payment, type, attachs);response.setContentType("text/plain");response.setHeader("Cache-Control", "no-cache");response.setCharacterEncoding("UTF-8");try {PrintWriter writer = response.getWriter();writer.print("success");} catch (IOException e) {log.error(e.toString());}} else {log.info("回調验签失败");response.setContentType("text/plain");response.setHeader("Cache-Control", "no-cache");response.setCharacterEncoding("UTF-8");try {PrintWriter writer = response.getWriter();writer.print("fail");} catch (IOException e) {log.error(e.toString());}}}/*** 快钱在线支付回调处理控制* * @param request* @param response* @return* @throws Exception*/@RequestMapping({ "/bill_return" })public Map<String, Object> bill_return(HttpServletRequest request, HttpServletResponse response) throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();String ext1 = request.getParameter("ext1").trim();String ext2 = CommUtil.null2String(request.getParameter("ext2").trim());OrderFormDto order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if ((ext2.equals("goods")) || (ext2.equals("group"))) {order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}String merchantAcctId = request.getParameter("merchantAcctId").trim();String key = "";Payment payment = null;if ((ext2.equals("goods")) || (ext2.equals("group"))) {payment = this.paymentService.selectByPrimaryKey(order.getPayment_id());key = payment.getRmbKey();}if ((ext2.equals("cash")) || (ext2.equals("gold")) || (ext2.equals("integral"))|| (ext2.equals("cloudpurchase"))) {Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));if (ext2.equals("cash")) {q_params.put("mark", obj.getPd_payment());}if (ext2.equals("gold")) {q_params.put("mark", gold.getGold_payment());}if (ext2.equals("integral")) {q_params.put("mark", ig_order.getIgo_payment());}if (ext2.equals("cloudpurchase")) {q_params.put("mark", cp_order.getPayment());}List<Payment> payments = this.paymentService.queryPageList(q_params);key = ((Payment) payments.get(0)).getRmbKey();}String version = request.getParameter("version").trim();String language = request.getParameter("language").trim();String signType = request.getParameter("signType").trim();String payType = request.getParameter("payType").trim();String bankId = request.getParameter("bankId").trim();String orderId = request.getParameter("orderId").trim();String orderTime = request.getParameter("orderTime").trim();String orderAmount = request.getParameter("orderAmount").trim();String dealId = request.getParameter("dealId").trim();String bankDealId = request.getParameter("bankDealId").trim();String dealTime = request.getParameter("dealTime").trim();String payAmount = request.getParameter("payAmount").trim();String fee = request.getParameter("fee").trim();String payResult = request.getParameter("payResult").trim();String errCode = request.getParameter("errCode").trim();String signMsg = request.getParameter("signMsg").trim();String merchantSignMsgVal = "";merchantSignMsgVal = appendParam(merchantSignMsgVal, "merchantAcctId", merchantAcctId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "version", version);merchantSignMsgVal = appendParam(merchantSignMsgVal, "language", language);merchantSignMsgVal = appendParam(merchantSignMsgVal, "signType", signType);merchantSignMsgVal = appendParam(merchantSignMsgVal, "payType", payType);merchantSignMsgVal = appendParam(merchantSignMsgVal, "bankId", bankId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "orderId", orderId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "orderTime", orderTime);merchantSignMsgVal = appendParam(merchantSignMsgVal, "orderAmount", orderAmount);merchantSignMsgVal = appendParam(merchantSignMsgVal, "dealId", dealId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "bankDealId", bankDealId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "dealTime", dealTime);merchantSignMsgVal = appendParam(merchantSignMsgVal, "payAmount", payAmount);merchantSignMsgVal = appendParam(merchantSignMsgVal, "fee", fee);merchantSignMsgVal = appendParam(merchantSignMsgVal, "ext1", ext1);merchantSignMsgVal = appendParam(merchantSignMsgVal, "ext2", ext2);merchantSignMsgVal = appendParam(merchantSignMsgVal, "payResult", payResult);merchantSignMsgVal = appendParam(merchantSignMsgVal, "errCode", errCode);merchantSignMsgVal = appendParam(merchantSignMsgVal, "key", key);String merchantSignMsg = MD5Util.md5Hex(merchantSignMsgVal.getBytes("utf-8")).toUpperCase();if (signMsg.toUpperCase().equals(merchantSignMsg.toUpperCase())) {switch (Integer.parseInt(payResult)) {case 10:if ((ext2.equals("goods")) || (ext2.equals("group"))) {boolean flag = this.handleOrderFormFeignClient.payByOnline(order, "", CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");resultMap.put("all_price", Double.valueOf(this.orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(order.getId()))));resultMap.put("obj", order);}if (ext2.equals("cash")) {if (obj.getPd_pay_status() < 2) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("快钱在线支付");this.predepositLogFeignClient.saveEntity(log);}resultMap.put("op_title", "充值" + obj.getPd_amount() + "成功");resultMap.put("url", CommUtil.getURL(request) + "/buyer/predeposit_list");}if (ext2.equals("gold")) {if (gold.getGold_pay_status() < 2) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("快钱在线支付");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}resultMap.put("op_title", "兑换" + gold.getGold_count() + "金币成功");resultMap.put("url", CommUtil.getURL(request) + "/seller/gold_record_list");}if (ext2.equals("integral")) {if (ig_order.getIgo_status() < 20) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("bill");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}resultMap.put("obj", ig_order);}if (!ext2.equals("cloudpurchase")) {break;}if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}resultMap.put("op_title", "预付款支付成功！");resultMap.put("url", CommUtil.getURL(request) + "/buyer/cloudbuy_order");break;default:resultMap.put("op_title", "快钱支付失败！");resultMap.put("url", CommUtil.getURL(request) + "/index");break;}} else {resultMap.put("op_title", "快钱支付失败！");resultMap.put("url", CommUtil.getURL(request) + "/index");}return resultMap;}public String appendParam(String returnStr, String paramId, String paramValue) {if (!returnStr.equals("")) {if (!paramValue.equals("")) {returnStr = returnStr + "&" + paramId + "=" + paramValue;}} else if (!paramValue.equals("")) {returnStr = paramId + "=" + paramValue;}return returnStr;}/*** 快钱异步回调处理，如果同步回调出错，异步回调会弥补该功能* * @param request* @param response* @throws Exception*/@RequestMapping({ "/bill_notify_return" })public void bill_notify_return(HttpServletRequest request, HttpServletResponse response) throws Exception {int rtnOK = 0;String ext1 = request.getParameter("ext1").trim();String ext2 = CommUtil.null2String(request.getParameter("ext2").trim());OrderFormDto order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if ((ext2.equals("goods")) || (ext2.equals("group"))) {order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}if (ext2.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(ext1));}String merchantAcctId = request.getParameter("merchantAcctId").trim();String key = "";Payment payment = null;if ((ext2.equals("goods")) || (ext2.equals("group"))) {payment = this.paymentService.selectByPrimaryKey(order.getPayment_id());key = payment.getRmbKey();}if ((ext2.equals("cash")) || (ext2.equals("gold")) || (ext2.equals("integral"))|| (ext2.equals("cloudpurchase"))) {Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));if (ext2.equals("cash")) {q_params.put("mark", obj.getPd_payment());}if (ext2.equals("gold")) {q_params.put("mark", gold.getGold_payment());}if (ext2.equals("integral")) {q_params.put("mark", ig_order.getIgo_payment());}if (ext2.equals("cloudpurchase")) {q_params.put("mark", cp_order.getPayment());}List<Payment> payments = this.paymentService.queryPageList(q_params);key = ((Payment) payments.get(0)).getRmbKey();}String version = request.getParameter("version").trim();String language = request.getParameter("language").trim();String signType = request.getParameter("signType").trim();String payType = request.getParameter("payType").trim();String bankId = request.getParameter("bankId").trim();String orderId = request.getParameter("orderId").trim();String orderTime = request.getParameter("orderTime").trim();String orderAmount = request.getParameter("orderAmount").trim();String dealId = request.getParameter("dealId").trim();String bankDealId = request.getParameter("bankDealId").trim();String dealTime = request.getParameter("dealTime").trim();String payAmount = request.getParameter("payAmount").trim();String fee = request.getParameter("fee").trim();String payResult = request.getParameter("payResult").trim();String errCode = request.getParameter("errCode").trim();String signMsg = request.getParameter("signMsg").trim();String merchantSignMsgVal = "";merchantSignMsgVal = appendParam(merchantSignMsgVal, "merchantAcctId", merchantAcctId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "version", version);merchantSignMsgVal = appendParam(merchantSignMsgVal, "language", language);merchantSignMsgVal = appendParam(merchantSignMsgVal, "signType", signType);merchantSignMsgVal = appendParam(merchantSignMsgVal, "payType", payType);merchantSignMsgVal = appendParam(merchantSignMsgVal, "bankId", bankId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "orderId", orderId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "orderTime", orderTime);merchantSignMsgVal = appendParam(merchantSignMsgVal, "orderAmount", orderAmount);merchantSignMsgVal = appendParam(merchantSignMsgVal, "dealId", dealId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "bankDealId", bankDealId);merchantSignMsgVal = appendParam(merchantSignMsgVal, "dealTime", dealTime);merchantSignMsgVal = appendParam(merchantSignMsgVal, "payAmount", payAmount);merchantSignMsgVal = appendParam(merchantSignMsgVal, "fee", fee);merchantSignMsgVal = appendParam(merchantSignMsgVal, "ext1", ext1);merchantSignMsgVal = appendParam(merchantSignMsgVal, "ext2", ext2);merchantSignMsgVal = appendParam(merchantSignMsgVal, "payResult", payResult);merchantSignMsgVal = appendParam(merchantSignMsgVal, "errCode", errCode);merchantSignMsgVal = appendParam(merchantSignMsgVal, "key", key);String merchantSignMsg = MD5Util.md5Hex(merchantSignMsgVal.getBytes("utf-8")).toUpperCase();if (signMsg.toUpperCase().equals(merchantSignMsg.toUpperCase())) {switch (Integer.parseInt(payResult)) {case 10:if ((ext2.equals("goods")) || (ext2.equals("group"))) {boolean flag = this.handleOrderFormFeignClient.payByOnline(order, dealId, CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");rtnOK = 1;}if (ext2.equals("cash")) {if (obj.getPd_pay_status() < 2) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("快钱在线支付");this.predepositLogFeignClient.saveEntity(log);}rtnOK = 1;}if (ext2.equals("gold")) {if (gold.getGold_pay_status() < 2) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("快钱在线支付");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}rtnOK = 1;}if (ext2.equals("integral")) {if (ig_order.getIgo_status() < 20) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("bill");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}rtnOK = 1;}if (ext2.equals("cloudpurchase")) {if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}rtnOK = 1;}break;}}response.setContentType("text/plain");response.setHeader("Cache-Control", "no-cache");response.setCharacterEncoding("UTF-8");try {PrintWriter writer = response.getWriter();writer.print(rtnOK);} catch (IOException e) {log.error(e.toString());}}/*** 财付通支付* * @param request* @param response* @param id* @param type* @param payment_id* @throws IOException*/@RequestMapping({ "/tenpay" })public void tenpay(HttpServletRequest request, HttpServletResponse response,@RequestBody JSONObject json) throws IOException {String payment_id = json.optString("payment_id");String type = json.optString("type");String id = json.optString("id");boolean submit = true;OrderFormDto of = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if ((type.equals("goods")) || (type.equals("group"))) {of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (of.getOrder_status() >= 20) {submit = false;}}if (type.equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (obj.getPd_pay_status() >= 2) {submit = false;}}if (type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(id));if (gold.getGold_pay_status() >= 2) {submit = false;}}if (type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (ig_order.getIgo_status() >= 20) {submit = false;}}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));}if (submit) {String order_price = "";if ((type.equals("goods")) || (type.equals("gruop"))) {order_price = CommUtil.null2String(of.getTotalPrice());}if (type.equals("cash")) {order_price = CommUtil.null2String(obj.getPd_amount());}if (type.equals("gold")) {order_price = CommUtil.null2String(Integer.valueOf(gold.getGold_money()));}if (type.equals("integral")) {order_price = CommUtil.null2String(ig_order.getIgo_trans_fee());}if (type.equals("cloudpurchase")) {order_price = CommUtil.null2String(Integer.valueOf(cp_order.getPrice()));}double total_fee = CommUtil.null2Double(order_price) * 100.0D;int fee = (int) total_fee;String product_name = "";if ((type.equals("goods")) || (type.equals("group"))) {product_name = of.getOrder_id();}if (type.equals("cash")) {product_name = obj.getPd_sn();}if (type.equals("gold")) {product_name = gold.getGold_sn();}if (type.equals("integral")) {product_name = ig_order.getIgo_order_sn();}if (type.equals("cloudpurchase")) {product_name = cp_order.getOdrdersn();}String remarkexplain = "";if ((type.equals("goods")) || (type.equals("group"))) {remarkexplain = of.getMsg();}if (type.equals("cash")) {remarkexplain = obj.getPd_remittance_info();}if (type.equals("gold")) {remarkexplain = gold.getGold_exchange_info();}if (type.equals("integral")) {remarkexplain = ig_order.getIgo_msg();}if (type.equals("cloudpurchase")) {product_name = cp_order.getIgo_order_sn();}String attach = "";if ((type.equals("goods")) || (type.equals("group"))) {attach = type + "," + of.getId().toString();}if (type.equals("cash")) {attach = type + "," + obj.getId().toString();}if (type.equals("gold")) {attach = type + "," + gold.getId().toString();}if (type.equals("integral")) {attach = type + "," + ig_order.getId().toString();}if (type.equals("cloudpurchase")) {attach = type + "," + cp_order.getId().toString();}String desc = "商品：" + product_name;String out_trade_no = "";if ((type.equals("goods")) || (type.equals("group"))) {out_trade_no = of.getOrder_id();}if (type.endsWith("cash")) {out_trade_no = obj.getPd_sn();}if (type.endsWith("gold")) {out_trade_no = gold.getGold_sn();}if (type.equals("integral")) {out_trade_no = ig_order.getIgo_order_sn();}if (type.equals("cloudpurchase")) {out_trade_no = cp_order.getOdrdersn();}Payment payment = this.paymentService.selectByPrimaryKey(CommUtil.null2Long(payment_id));if (payment == null) {payment = new Payment();}String trade_mode = CommUtil.null2String(Integer.valueOf(payment.getTrade_mode()));String currTime = TenpayUtil.getCurrTime();RequestHandler reqHandler = new RequestHandler(request, response);reqHandler.init();reqHandler.setKey(payment.getTenpay_key());reqHandler.setGateUrl("https://gw.tenpay.com/gateway/pay");reqHandler.setParameter("partner", payment.getTenpay_partner());reqHandler.setParameter("out_trade_no", out_trade_no);reqHandler.setParameter("total_fee", String.valueOf(fee));reqHandler.setParameter("return_url", CommUtil.getURL(request) + "/tenpay_return");reqHandler.setParameter("notify_url", CommUtil.getURL(request) + "/tenpay_notify");reqHandler.setParameter("body", desc);reqHandler.setParameter("bank_type", "DEFAULT");reqHandler.setParameter("spbill_create_ip", request.getRemoteAddr());reqHandler.setParameter("fee_type", "1");reqHandler.setParameter("subject", desc);reqHandler.setParameter("sign_type", "MD5");reqHandler.setParameter("service_version", "1.0");reqHandler.setParameter("input_charset", "UTF-8");reqHandler.setParameter("sign_key_index", "1");reqHandler.setParameter("attach", attach);reqHandler.setParameter("product_fee", "");reqHandler.setParameter("transport_fee", "0");reqHandler.setParameter("time_start", currTime);reqHandler.setParameter("time_expire", "");reqHandler.setParameter("buyer_id", "");reqHandler.setParameter("goods_tag", "");reqHandler.setParameter("trade_mode", trade_mode);reqHandler.setParameter("transport_desc", "");reqHandler.setParameter("trans_type", "1");reqHandler.setParameter("agentid", "");reqHandler.setParameter("agent_type", "");reqHandler.setParameter("seller_id", "");String requestUrl = reqHandler.getRequestURL();response.sendRedirect(requestUrl);} else {response.getWriter().write("该订单已经完成支付！");}}/*** 财付通在线支付回调控制* * @param request* @param response* @return* @throws Exception*/@RequestMapping({ "/tenpay_return" })public Map<String, Object> tenpay_return(HttpServletRequest request, HttpServletResponse response)throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();ResponseHandler resHandler = new ResponseHandler(request, response);String[] attachs = request.getParameter("attach").split(",");String out_trade_no = resHandler.getParameter("out_trade_no");OrderFormDto order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if (attachs[0].equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[1]));Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));q_params.put("mark", cp_order.getPayment());List<Payment> payments = this.paymentService.queryPageList(q_params);resHandler.setKey(((Payment) payments.get(0)).getTenpay_key());}if (attachs[0].equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[1]));Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));q_params.put("mark", ig_order.getIgo_payment());List<Payment> payments = this.paymentService.queryPageList(q_params);resHandler.setKey(((Payment) payments.get(0)).getTenpay_key());}if (attachs[0].equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[1]));Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));q_params.put("mark", obj.getPd_payment());List<Payment> payments = this.paymentService.queryPageList(q_params);resHandler.setKey(((Payment) payments.get(0)).getTenpay_key());}if (attachs[0].equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(attachs[1]));Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));q_params.put("mark", gold.getGold_payment());List<Payment> payments = this.paymentService.queryPageList(q_params);resHandler.setKey(((Payment) payments.get(0)).getTenpay_key());}Payment payment = null;if ((attachs[0].equals("goods")) || (attachs[0].equals("group"))) {order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[1]));payment = this.paymentService.selectByPrimaryKey(order.getPayment_id());resHandler.setKey(payment.getTenpay_key());}if (resHandler.isTenpaySign()) {String notify_id = resHandler.getParameter("notify_id");String transaction_id = resHandler.getParameter("transaction_id");String total_fee = resHandler.getParameter("total_fee");String discount = resHandler.getParameter("discount");String trade_state = resHandler.getParameter("trade_state");String trade_mode = resHandler.getParameter("trade_mode");if ("1".equals(trade_mode)) {if ("0".equals(trade_state)) {if (attachs[0].equals("cash")) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);resultMap.put("op_title", "充值" + obj.getPd_amount() + "成功");resultMap.put("url", CommUtil.getURL(request) + "/buyer/predeposit_list");}if ((attachs[0].equals("goods")) || (attachs[0].equals("group"))) {boolean flag = this.handleOrderFormFeignClient.payByOnline(order, transaction_id,CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");resultMap.put("all_price", Double.valueOf(this.orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(order.getId()))));resultMap.put("obj", order);}if (attachs[0].equals("gold")) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("财付通及时到账支付");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);resultMap.put("op_title", "兑换" + gold.getGold_count() + "金币成功");resultMap.put("url", CommUtil.getURL(request) + "/seller/gold_record_list");}if (attachs[0].equals("integral")) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("bill");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}resultMap.put("obj", ig_order);}if (attachs[0].equals("cloudpurchase")) {if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}resultMap.put("op_title", "预付款支付成功！");resultMap.put("url", CommUtil.getURL(request) + "/buyer/cloudbuy_order");}} else {resultMap.put("op_title", "财付通支付失败！");resultMap.put("url", CommUtil.getURL(request) + "/index");}} else if ("2".equals(trade_mode)) {if ("0".equals(trade_state)) {if (attachs[0].equals("cash")) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("财付通中介担保付款");this.predepositLogFeignClient.saveEntity(log);resultMap.put("op_title", "充值" + obj.getPd_amount() + "成功");resultMap.put("url", CommUtil.getURL(request) + "/buyer/predeposit_list");}if (attachs[0].equals("goods")) {boolean flag = this.handleOrderFormFeignClient.payByOnline(order, transaction_id,CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");resultMap.put("all_price", Double.valueOf(this.orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(order.getId()))));resultMap.put("obj", order);}if (attachs[0].equals("gold")) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("财付通中介担保付款成功");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);resultMap.put("op_title", "兑换" + gold.getGold_count() + "金币成功");resultMap.put("url", CommUtil.getURL(request) + "/seller/gold_record_list");}if (attachs[0].equals("integral")) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("bill");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}resultMap.put("obj", ig_order);}if (attachs[0].equals("cloudpurchase")) {if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}resultMap.put("op_title", "预付款支付成功！");resultMap.put("url", CommUtil.getURL(request) + "/buyer/cloudbuy_order");}} else {resultMap.put("op_title", "财付通支付失败！");resultMap.put("url", CommUtil.getURL(request) + "/index");}}} else {resultMap.put("op_title", "财付通认证签名失败！");resultMap.put("url", CommUtil.getURL(request) + "/index");}return resultMap;}/*** 网银在线回调函数* * @param request* @param response* @return* @throws Exception*/@RequestMapping({ "/chinabank_return" })public Map<String, Object> chinabank_return(HttpServletRequest request, HttpServletResponse response)throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();String remark1 = request.getParameter("remark1");String remark2 = CommUtil.null2String(request.getParameter("remark2"));OrderFormDto order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if ((remark2.equals("goods")) || (remark2.equals("group"))) {order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1.trim()));}if (remark2.equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1));}if (remark2.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(remark1));}if (remark2.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1));}if (remark2.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1));}String key = "";Payment payment = null;if ((remark2.equals("goods")) || (remark2.equals("group"))) {payment = this.paymentService.selectByPrimaryKey(order.getPayment_id());key = payment.getChinabank_key();}if ((remark2.equals("cash")) || (remark2.equals("gold")) || (remark2.equals("integral"))|| (remark2.equals("cloudpurchase"))) {Map q_params = Maps.newHashMap();q_params.put("install", Boolean.valueOf(true));if (remark2.equals("cash")) {q_params.put("mark", obj.getPd_payment());}if (remark2.equals("gold")) {q_params.put("mark", gold.getGold_payment());}if (remark2.equals("integral")) {q_params.put("mark", ig_order.getIgo_payment());}if (remark2.equals("cloudpurchase")) {q_params.put("mark", cp_order.getPayment());}List<Payment> payments = this.paymentService.queryPageList(q_params);key = ((Payment) payments.get(0)).getChinabank_key();}String v_oid = request.getParameter("v_oid");String v_pmode = request.getParameter("v_pmode");String v_pstatus = request.getParameter("v_pstatus");String v_pstring = request.getParameter("v_pstring");String v_amount = request.getParameter("v_amount");String v_moneytype = request.getParameter("v_moneytype");String v_md5str = request.getParameter("v_md5str");String text = v_oid + v_pstatus + v_amount + v_moneytype + key;String v_md5text = Md5Encrypt.md5(text).toUpperCase();if (v_md5str.equals(v_md5text)) {if ("20".equals(v_pstatus)) {if ((remark2.equals("goods")) || (remark2.equals("group"))) {boolean flag = this.handleOrderFormFeignClient.payByOnline(order, v_oid, CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");resultMap.put("all_price", Double.valueOf(this.orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(order.getId()))));resultMap.put("obj", order);}if (remark2.endsWith("cash")) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("网银在线支付");this.predepositLogFeignClient.saveEntity(log);resultMap.put("op_title", "充值" + obj.getPd_amount() + "成功");resultMap.put("url", CommUtil.getURL(request) + "/buyer/predeposit_list");}if (remark2.equals("gold")) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("网银在线支付");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);resultMap.put("op_title", "兑换" + gold.getGold_count() + "金币成功");resultMap.put("url", CommUtil.getURL(request) + "/seller/gold_record_list");}if (remark2.equals("integral")) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("bill");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}resultMap.put("obj", ig_order);}if (remark2.equals("cloudpurchase")) {if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}resultMap.put("op_title", "预付款支付成功！");resultMap.put("url", CommUtil.getURL(request) + "/buyer/cloudbuy_order");}}} else {resultMap.put("op_title", "网银在线支付失败！");resultMap.put("url", CommUtil.getURL(request) + "/index");}return resultMap;}/*** paypal回调方法,paypal支付成功了后，调用该方法进行后续处理* * @param request* @param response* @return* @throws Exception*/@SuppressWarnings("deprecation")@RequestMapping({ "/paypal_return" })public Map<String, Object> paypal_return(HttpServletRequest request, HttpServletResponse response)throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();Enumeration en = request.getParameterNames();String str = "cmd=_notify-validate";while (en.hasMoreElements()) {String paramName = (String) en.nextElement();String paramValue = request.getParameter(paramName);str = str + "&" + paramName + "=" + URLEncoder.encode(paramValue);}String[] customs = request.getParameter("custom").split(",");String remark1 = customs[0];String remark2 = customs[1];String item_name = request.getParameter("item_name");String txnId = request.getParameter("txn_id");OrderFormDto order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;Payment payment = null;if ((remark2.equals("goods")) || (remark2.equals("group"))) {order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1.trim()));payment = this.paymentService.selectByPrimaryKey(order.getPayment_id());}if (remark2.equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1));}if (remark2.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(remark1));}if (remark2.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1));}if (remark2.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(remark1));}String txn_id = request.getParameter("txn_id");String itemName = request.getParameter("item_name");String paymentStatus = request.getParameter("payment_status");String paymentAmount = request.getParameter("mc_gross");String paymentCurrency = request.getParameter("mc_currency");String receiverEmail = request.getParameter("receiver_email");String payerEmail = request.getParameter("payer_email");if ((paymentStatus.equals("Completed")) || (paymentStatus.equals("Pending"))) {if (((remark2.equals("goods")) || (remark2.equals("group"))) && (order.getOrder_status() < 20)) {if (CommUtil.null2String(order.getTotalPrice()).equals(paymentAmount)) {boolean flag = this.handleOrderFormFeignClient.payByOnline(order, txnId, CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");resultMap.put("all_price", Double.valueOf(this.orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(order.getId()))));resultMap.put("obj", order);}}if (remark2.endsWith("cash")) {if (obj.getPd_pay_status() < 2) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("Paypal在线支付");this.predepositLogFeignClient.saveEntity(log);}resultMap.put("op_title", "成功充值：" + obj.getPd_amount());resultMap.put("url", CommUtil.getURL(request) + "/buyer/predeposit_list");}if (remark2.equals("gold")) {if (gold.getGold_pay_status() < 2) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("Paypal");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}resultMap.put("op_title", "成功充值金币:" + gold.getGold_count());resultMap.put("url", CommUtil.getURL(request) + "/seller/gold_record_list");}if (remark2.equals("integral")) {if (ig_order.getIgo_status() < 20) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("paypal");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}resultMap.put("obj", ig_order);}if (remark2.equals("cloudpurchase")) {if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}resultMap.put("op_title", "预付款支付成功！");resultMap.put("url", CommUtil.getURL(request) + "/buyer/cloudbuy_order");}} else {resultMap.put("op_title", "Paypal支付失败");resultMap.put("url", CommUtil.getURL(request) + "/index");}return resultMap;}public Map<String, Object> wx_pay1(HttpServletRequest request, HttpServletResponse response, Long id,String pay_type, String order_type) throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();RequestHandler reqHandler = new RequestHandler(request, response);List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();//TODOpay_type="wx_miniprogram";params.put("mark", pay_type);payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}String body = "";String attach = "";String out_trade_no = "";double total_fee = 0.0D;boolean submit = true;OrderFormDto of = null;PredepositDto pd = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if ((order_type.equals("goods")) || (order_type.equals("group"))) {of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (of.getOrder_status() >= 20) {submit = false;} else {body = of.getOrder_id();attach = of.getId() + "_" + of.getOrder_id() + "_" + of.getUser_id() + "_" + order_type +"_"+pay_type;out_trade_no = of.getOrder_id();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", of);}}if (order_type.equals("cash")) {pd = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (pd.getPd_pay_status() >= 2) {submit = false;} else {body = pd.getPd_sn();attach = pd.getId() + "_" + pd.getPd_sn() + "_" + pd.getPd_user().getId() + "_" + order_type+"_"+pay_type;out_trade_no = pd.getPd_sn();total_fee = Double.valueOf(pd.getPd_amount().toString()).doubleValue() * 100.0D;resultMap.put("obj", pd);}}if (order_type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(id));if (gold.getGold_pay_status() >= 2) {submit = false;} else {body = gold.getGold_sn();attach = gold.getId() + "_" + gold.getGold_sn() + "_" + gold.getGold_user().getId() + "_" + order_type+"_"+pay_type;out_trade_no = gold.getGold_sn();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", gold);}}if (order_type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (ig_order.getIgo_status() >= 20) {submit = false;} else {body = ig_order.getIgo_order_sn();attach = ig_order.getId() + "_" + ig_order.getIgo_order_sn() + "_" + ig_order.getIgo_user().getId()+ "_" + order_type+"_"+pay_type;out_trade_no = ig_order.getIgo_order_sn();total_fee = Double.valueOf(ig_order.getIgo_trans_fee().toString()).doubleValue() * 100.0D;resultMap.put("obj", ig_order);}}if (order_type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (cp_order.getStatus() == 5) {submit = false;} else {body = cp_order.getIgo_order_sn();attach = cp_order.getId() + "_" + cp_order.getIgo_order_sn() + "_" + cp_order.getUser_id() + "_"+ order_type+"_"+pay_type;out_trade_no = cp_order.getIgo_order_sn();total_fee = Double.valueOf(cp_order.getPrice()).doubleValue() * 100.0D;resultMap.put("obj", cp_order);}}if ((submit) && (payment != null)) {if (payment != null) {String app_id = payment.getWx_appid();String app_key = payment.getWx_paySignKey();String partner = payment.getTenpay_partner();String notify_url = payment.getTenpay_partner();String noncestr = Sha1Util.getNonceStr();String timestamp = Sha1Util.getTimeStamp();String path = request.getContextPath();String basePath = notify_url + "/";reqHandler.setParameter("appid", app_id);reqHandler.setParameter("mch_id", partner);reqHandler.setParameter("nonce_str", noncestr);reqHandler.setParameter("device_info", "wechat_mini_program");reqHandler.setParameter("body", body);reqHandler.setParameter("attach", attach);reqHandler.setParameter("out_trade_no", out_trade_no);BigDecimal total_feeBig = new BigDecimal(total_fee);reqHandler.setParameter("total_fee", total_feeBig.setScale(0, BigDecimal.ROUND_UP)+"");reqHandler.setParameter("spbill_create_ip", CommUtil.getIpAddr(request));reqHandler.setParameter("notify_url", basePath + "weixin_return");reqHandler.setParameter("trade_type", "JSAPI");// trade_type=JSAPI时,必须传入openidUserDto user = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(of.getUser_id()));reqHandler.setParameter("openid", user.getOpenId());String requestUrl = reqHandler.reqToXml(app_key);HttpURLConnection conn = creatConnection(requestUrl);String result = getInput(conn);Map<String, String> map = doXMLParse(result);String return_code = ((String) map.get("return_code")).toString();String prepay_id = "";String code_url = "";if ("SUCCESS".equals(return_code)) {String result_code = ((String) map.get("result_code")).toString();if ("SUCCESS".equals(result_code)) {prepay_id = (String) map.get("prepay_id");code_url = (String) map.get("code_url");} else {// 预下单异常信息显示log.error(map.toString());}} else {// 预下单异常信息显示log.error(map.toString());}reqHandler.getAllParameters().clear();String newPackage = "prepay_id=" + prepay_id;reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);  reqHandler.setParameter("package", newPackage);reqHandler.setParameter("signType", "MD5");reqHandler.setParameter("timeStamp", timestamp+"");reqHandler.genSign(app_key);String order_sign = reqHandler.getParameter("sign");resultMap.put("app_id", app_id);resultMap.put("timestamp", timestamp+"");resultMap.put("noncestr", noncestr);resultMap.put("packageValue", newPackage);resultMap.put("sign", order_sign);resultMap.put("code_url", code_url);resultMap.put("signType", "MD5");System.out.print("返回给前端---------------------------");System.out.print(resultMap.toString());System.out.print("返回给前端---------------------------");reqHandler.getAllParameters().clear();reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);reqHandler.genSign(app_key);order_sign=reqHandler.getParameter("sign");if ((order_type.equals("goods")) || (order_type.equals("group"))) {of.setOrder_sign(order_sign);this.orderFormFeignClient.updateById(of);}if (order_type.equals("cash")) {pd.setOrder_sign(order_sign);this.predepositFeignClient.updateById(pd);}if (order_type.equals("gold")) {gold.setOrder_sign(order_sign);this.goldRecordService.updateById(gold);}if (order_type.equals("integral")) {ig_order.setOrder_sign(order_sign);this.integralGoodsOrderFeignClient.updateById(ig_order);}if (order_type.equals("cloudpurchase")) {cp_order.setOrder_sign(order_sign);this.cloudPurchaseOrderFeignClient.updateById(cp_order);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}return ResponseCode.buildSuccessMap(resultMap) ;}/*** 微信支付* * @param request* @param response* @param id 订单id* @param pay_type  支付方式 小程序端写死为wx_pay* @param order_type  订单类型* @return* @throws Exception*/@RequestMapping({ "/pay/wx_pay" })public Map<String, Object> wx_pay(HttpServletRequest request, HttpServletResponse response,@RequestBody JSONObject json) throws Exception {Long id = json.optLong("id");String pay_type = json.optString("pay_type");String order_type = json.optString("order_type");Map<String, Object> resultMap = new HashMap<String, Object>();RequestHandler reqHandler = new RequestHandler(request, response);List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();if (StringUtils.isEmpty(pay_type)) {pay_type = "wx_miniprogram";}params.put("mark", pay_type);payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}String body = "";String attach = "";String out_trade_no = "";String order_sign = "";double total_fee = 0.0D;boolean submit = true;OrderFormDto of = null;PredepositDto pd = null;GoldRecord gold = null;PlatformPay platformpay = null;RushOrderformDto  rushOrderformDto =null;Date time = new Date();IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;UserDto user = null;if ((order_type.equals("goods")) || (order_type.equals("group"))) {of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (of.getOrder_status() >= 20) {submit = false;} else {body = of.getOrder_id();attach = of.getId() + "_" + of.getOrder_id() + "_" + of.getUser_id() + "_" + order_type + "_"+ pay_type;// out_trade_no = of.getOrder_id();out_trade_no = of.getId() + "" + time.getTime();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", of);}} // 第一次付款, 带上子订单信息if ((order_type.equals("goodsfirst")) || (order_type.equals("groupfirst"))) {of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (of.getOrder_status() >= 20) {submit = false;} else {body = of.getOrder_id();attach = of.getId() + "_" + of.getOrder_id() + "_" + of.getUser_id() + "_" + order_type + "_"+ pay_type;// out_trade_no = of.getOrder_id();out_trade_no = of.getId() + "" + time.getTime();// 第一次付款取子订单总价格total_fee = Double.valueOf(orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(of.getId()))) * 100.0D;resultMap.put("obj", of);}}if (order_type.equals("cash")) {pd = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (pd.getPd_pay_status() >= 2) {submit = false;} else {body = pd.getPd_sn();attach = pd.getId() + "_" + pd.getPd_sn() + "_" + pd.getPd_user().getId() + "_" + order_type + "_"+ pay_type;out_trade_no = pd.getPd_sn();total_fee = Double.valueOf(pd.getPd_amount().toString()).doubleValue() * 100.0D;resultMap.put("obj", pd);}}if (order_type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(id));if (gold.getGold_pay_status() >= 2) {submit = false;} else {body = gold.getGold_sn();attach = gold.getId() + "_" + gold.getGold_sn() + "_" + gold.getGold_user().getId() + "_" + order_type+ "_" + pay_type;out_trade_no = gold.getGold_sn();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", gold);}}if (order_type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (ig_order.getIgo_status() >= 20) {submit = false;} else {body = ig_order.getIgo_order_sn();attach = ig_order.getId() + "_" + ig_order.getIgo_order_sn() + "_" + ig_order.getIgo_user().getId()+ "_" + order_type + "_" + pay_type;out_trade_no = ig_order.getIgo_order_sn();//积分订单  支付金额    =   运费  加   付款金额total_fee = Double.valueOf(ig_order.getIgo_pay_amount().toString()).doubleValue() * 100.0D;resultMap.put("obj", ig_order);}}if (order_type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (cp_order.getStatus() == 5) {submit = false;} else {body = cp_order.getIgo_order_sn();attach = cp_order.getId() + "_" + cp_order.getIgo_order_sn() + "_" + cp_order.getUser_id() + "_"+ order_type + "_" + pay_type;out_trade_no = cp_order.getIgo_order_sn();total_fee = Double.valueOf(cp_order.getPrice()).doubleValue() * 100.0D;resultMap.put("obj", cp_order);}}if (order_type.equals("platformpay")) { // 保证金platformpay = this.platformPayService.selectByPrimaryKey(CommUtil.null2Long(id));if (platformpay.getPay_status() == 1) { // 已支付submit = false;} else {body = platformpay.getPay_no();attach = platformpay.getId() + "_" + platformpay.getPay_no() + "_" + platformpay.getUser_id() + "_"+ order_type + "_" + pay_type;out_trade_no = platformpay.getPay_no();total_fee = platformpay.getAmount().doubleValue() * 100.0D;resultMap.put("obj", platformpay);user = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(platformpay.getUser_id()));}}if (order_type.equals("rushorder")) { // 抢购单rushOrderformDto = rushOrderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (rushOrderformDto.getPay_time()!=null) { // 已支付submit = false;} else {body = rushOrderformDto.getOrder_no(); //订单号idattach = rushOrderformDto.getId() + "_" + rushOrderformDto.getOrder_no() + "_" + rushOrderformDto.getRush_id() + "_"+ order_type + "_" + pay_type;out_trade_no = rushOrderformDto.getId() + "" + time.getTime();  //流水号total_fee = rushOrderformDto.getBond_money().doubleValue() * 100.0D;  //上架费resultMap.put("obj", rushOrderformDto);user = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(rushOrderformDto.getRush_id()));}}if ((submit) && (payment != null)) {if (payment != null) {String app_id = payment.getWx_appid();String app_key = payment.getWx_paySignKey();String partner = payment.getTenpay_partner();String notify_url = payment.getNotify_url();String noncestr = Sha1Util.getNonceStr();String timestamp = Sha1Util.getTimeStamp();String path = request.getContextPath();String basePath = notify_url + "/";if (pay_type.equals("wx_pay")) {reqHandler.setParameter("appid", app_id);reqHandler.setParameter("mch_id", partner);reqHandler.setParameter("nonce_str", noncestr);reqHandler.setParameter("device_info", "WEB");reqHandler.setParameter("body", body);reqHandler.setParameter("attach", attach);reqHandler.setParameter("out_trade_no", out_trade_no);BigDecimal total_feeBig = new BigDecimal(total_fee);reqHandler.setParameter("total_fee", total_feeBig.setScale(0, BigDecimal.ROUND_UP)+"");reqHandler.setParameter("spbill_create_ip", CommUtil.getIpAddr(request));reqHandler.setParameter("notify_url", basePath + "weixin_return");reqHandler.setParameter("scene_info", "'h5_info':{'type':'Wap','wap_url':'http://haiwah5.minglisoft.cn/','wap_name': '海哇'}");reqHandler.setParameter("trade_type", "MWEB");if (of != null) {// trade_type=JSAPI时,必须传入openid// user = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(of.getUser_id()));}/*reqHandler.setParameter("openid", user.getOpenId());*/String requestUrl = reqHandler.reqToXml(app_key);HttpURLConnection conn = creatConnection(requestUrl);String result = getInput(conn);Map<String, String> map = doXMLParse(result);String return_code = ((String) map.get("return_code")).toString();String prepay_id = "";String code_url = "";if ("SUCCESS".equals(return_code)) {System.out.println("mapppp==="+map);String result_code = ((String) map.get("result_code")).toString();if ("SUCCESS".equals(result_code)) {prepay_id = (String) map.get("prepay_id");code_url = (String) map.get("mweb_url");} else {// 预下单异常信息显示log.error(map.toString());}} else {// 预下单异常信息显示log.error(map.toString());}reqHandler.getAllParameters().clear();String newPackage = "prepay_id=" + prepay_id;reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);reqHandler.setParameter("package", newPackage);reqHandler.setParameter("signType", "MD5");reqHandler.setParameter("timeStamp", timestamp + "");reqHandler.genSign(app_key);order_sign = reqHandler.getParameter("sign");resultMap.put("app_id", app_id);resultMap.put("timestamp", timestamp + "");resultMap.put("noncestr", noncestr);resultMap.put("packageValue", newPackage);resultMap.put("sign", order_sign);     //   http://haiwah5.minglisoft.cn/#/pagesA/order/index/index?type=order_nopay resultMap.put("code_url", code_url+"&redirect_url="+"http://haiwah5.minglisoft.cn/%23/pagesA/order/index/index?type=order_nopay");resultMap.put("signType", "MD5");System.out.print("返回给前端-new1--------------------------");System.out.print(resultMap.toString());System.out.print("返回给前端---------------------------");reqHandler.getAllParameters().clear();reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);reqHandler.genSign(app_key);order_sign = reqHandler.getParameter("sign");} else {reqHandler.setParameter("appid", app_id);reqHandler.setParameter("mch_id", partner);reqHandler.setParameter("nonce_str", noncestr);reqHandler.setParameter("device_info", "wechat_mini_program");reqHandler.setParameter("body", body);reqHandler.setParameter("attach", attach);reqHandler.setParameter("out_trade_no", out_trade_no);BigDecimal total_feeBig = new BigDecimal(total_fee);reqHandler.setParameter("total_fee", total_feeBig.setScale(0, BigDecimal.ROUND_UP) + "");reqHandler.setParameter("spbill_create_ip", CommUtil.getIpAddr(request));reqHandler.setParameter("notify_url", basePath + "weixin_return");reqHandler.setParameter("trade_type", "JSAPI");if (of != null) {// trade_type=JSAPI时,必须传入openiduser = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(of.getUser_id()));}reqHandler.setParameter("openid", user.getOpenId());String requestUrl = reqHandler.reqToXml(app_key);HttpURLConnection conn = creatConnection(requestUrl);String result = getInput(conn);Map<String, String> map = doXMLParse(result);String return_code = ((String) map.get("return_code")).toString();String prepay_id = "";String code_url = "";if ("SUCCESS".equals(return_code)) {String result_code = ((String) map.get("result_code")).toString();if ("SUCCESS".equals(result_code)) {prepay_id = (String) map.get("prepay_id");code_url = (String) map.get("code_url");} else {// 预下单异常信息显示log.error(map.toString());}} else {// 预下单异常信息显示log.error(map.toString());}reqHandler.getAllParameters().clear();String newPackage = "prepay_id=" + prepay_id;reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);reqHandler.setParameter("package", newPackage);reqHandler.setParameter("signType", "MD5");reqHandler.setParameter("timeStamp", timestamp + "");reqHandler.genSign(app_key);order_sign = reqHandler.getParameter("sign");resultMap.put("app_id", app_id);resultMap.put("timestamp", timestamp + "");resultMap.put("noncestr", noncestr);resultMap.put("packageValue", newPackage);resultMap.put("sign", order_sign);resultMap.put("code_url", code_url);resultMap.put("signType", "MD5");System.out.print("返回给前端---------------------------");System.out.print(resultMap.toString());System.out.print("返回给前端---------------------------");reqHandler.getAllParameters().clear();reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);reqHandler.genSign(app_key);order_sign = reqHandler.getParameter("sign");}if ((order_type.equals("goods")) || (order_type.equals("group")) || (order_type.equals("goodsfirst"))|| (order_type.equals("goodsfirst"))) {of.setOrder_sign(order_sign);of.setTrade_no(out_trade_no);this.orderFormFeignClient.updateById(of);}if (order_type.equals("cash")) {pd.setOrder_sign(order_sign);this.predepositFeignClient.updateById(pd);}if (order_type.equals("gold")) {gold.setOrder_sign(order_sign);this.goldRecordService.updateById(gold);}if (order_type.equals("integral")) {ig_order.setOrder_sign(order_sign);this.integralGoodsOrderFeignClient.updateById(ig_order);}if (order_type.equals("cloudpurchase")) {cp_order.setOrder_sign(order_sign);this.cloudPurchaseOrderFeignClient.updateById(cp_order);}if (order_type.equals("platformpay")) {platformpay.setTrade_no(order_sign);platformpay.setSign(order_sign);this.platformPayService.updateById(platformpay);}if (order_type.equals("rushorder")) {rushOrderformDto.setSign(order_sign);rushOrderformDto.setTrade_no(out_trade_no);this.rushOrderFormFeignClient.updateById(rushOrderformDto);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}return ResponseCode.buildSuccessMap(resultMap);}public void disAgentProfit(OrderFormDto orderformDto){//分销收益try{// 拓展配置信息DistributionSettingDto distributionSetting = distributionSettingFeignClient.getDistributionSetting();// 下单成功后调用分销的处理逻辑if (null != distributionSetting && "1".equals(distributionSetting.getIsOpen()) && 4 != orderformDto.getOrder_cat()) {distributionProfitFeignClient.profitInsert(orderformDto);agentProfitFeignClient.profitInsert(orderformDto);// 计算分销的佣金//BigDecimal disProfit = distributionProfitFeignClient.totalProfitByOrderId(orderformDto.getId());//BigDecimal agentProfit = agentProfitFeignClient.totalProfitByOrderId(orderformDto.getId());List<Map> goods_list = JSON.parseArray(orderformDto.getGoods_info(), Map.class);BigDecimal goods_distribution_price = BigDecimal.ZERO;for (Map<String, Object> map : goods_list) {goods_distribution_price = goods_distribution_price.add(CommUtil.toBigDecimal(map.get("goods_distribution_price")));}// 平台的分佣+分销的佣金BigDecimal commission_amount = goods_distribution_price.add(orderformDto.getCommission_amount());orderformDto.setCommission_amount(commission_amount);orderFormFeignClient.updateById(orderformDto);}}catch (Exception e) {logger.error("PayController >> disAgentProfit(distribution&agentProfit) >> Exception:"+ e.getMessage());}}public void sendOrderMessage(OrderFormDto orderformDto){//分销收益try{MessageDto msg = new MessageDto();msg.setAddTime(new Date());msg.setDeleteStatus(0);msg.setContent("订单编号："+orderformDto.getOrder_id()+"已付款。下单人："+orderformDto.getUser_name()+"，订单金额："+orderformDto.getTotalPrice()+"。");msg.setMsg_cat(0);msg.setReply_status(0);msg.setStatus(0);msg.setTitle("用户付款");msg.setType(2);msg.setFromUser_id(1L);UserDto seller = userFeignClient.getUserByStoreId(Long.parseLong(orderformDto.getStore_id()));msg.setToUser_id(seller.getId());messageFeignClient.saveEntity(msg);}catch (Exception e) {logger.error("PayController >> sendOrderMessage >> Exception:"+ e.getMessage());}}public void sendTxMessage(OrderFormDto orderformDto){UserDto saler = userFeignClient.getUserByStoreId(Long.parseLong(orderformDto.getStore_id()));try{Map<String, Object> params2 = new HashMap<String, Object>();params2.put("order_id", orderformDto.getOrder_id());params2.put("orderMoney", orderformDto.getTotalPrice()+"");params2.put("nickname", orderformDto.getUser_name());params2.put("user_id", saler.getId().toString());logger.info("params2[{}]",params2);tXTemplateFeignClient.delivereMsg(params2);tXTemplateFeignClient.paySuccessMsg(orderformDto);}catch (Exception e) {logger.error("PayController >> sendTxMessage >> Exception:"+ e.getMessage());}try{jiguangPushFeignClient.deliveryReminder(saler.getId());}catch (Exception e) {logger.error("PayController >> jiGuangMessage >> Exception:"+ e.getMessage());}}//发送酒店消息public void sendHotelMessage(OrderFormDto orderformDto){UserDto saler = userFeignClient.getUserByStoreId(Long.parseLong(orderformDto.getStore_id()));UserDto buyer = userFeignClient.selectByPrimaryKey(Long.parseLong(orderformDto.getUser_id()));try{Map<String, Object> params2 = new HashMap<String, Object>();params2.put("user_id", saler.getId().toString());SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日"); params2.put("check_in_time", sdf.format(orderformDto.getCheck_in_time()));params2.put("departure_time", sdf.format(orderformDto.getDeparture_time()));List<Map> goods_list = JSON.parseArray(orderformDto.getGoods_info(), Map.class);for (Map<String, Object> map : goods_list) {params2.put("days", map.get("days").toString());params2.put("goods_name", map.get("goods_name").toString());params2.put("count", map.get("goods_count").toString());}params2.put("goods_price", orderformDto.getTotalPrice().toString());params2.put("receiver_name", orderformDto.getReceiver_Name());params2.put("receiver_mobile", orderformDto.getReceiver_mobile());logger.info("params2[{}]",params2);tXTemplateFeignClient.shotelOrderMsg(params2);params2.put("store_name", orderformDto.getStore_name());params2.put("wx_open_id", buyer.getWx_open_id());logger.info("params2[{}]",params2);tXTemplateFeignClient.uhotelOrderMsg(params2);}catch (Exception e) {logger.error("PayController >> sendHotelMessage >> Exception:"+ e.getMessage());}}/*** 微信回调* * @param request* @param response* @throws Exception*/@RequestMapping({ "/weixin_return" })public void weixin_return(HttpServletRequest request, HttpServletResponse response) throws Exception {response.setContentType("text/plain");response.setHeader("Cache-Control", "no-cache");response.setCharacterEncoding("UTF-8");BufferedReader in = new BufferedReader(new InputStreamReader(request.getInputStream(), "UTF-8"));String line = "";StringBuffer strBuf = new StringBuffer();while ((line = in.readLine()) != null) {strBuf.append(line).append("\n");}in.close();Map<String, String> xml = doXMLParse(strBuf.toString().trim());//扩展信息表SysConfigExtendDto  sysConfigExtendDto=sysconrigExtendFeignClient.getSysConfigExtend();String appid = ((String) xml.get("appid")).toString();if ("SUCCESS".equals(((String) xml.get("return_code")).toString())) {if ("SUCCESS".equals(((String) xml.get("result_code")).toString())) {String total_fee = (String) xml.get("total_fee");String out_trade_no = (String) xml.get("out_trade_no");String[] attachs = ((String) xml.get("attach")).split("_");String type = attachs[3];//支付方式  因为微信支付方式是"wx_miniprogram" 形式故pay_type为attachs[4]+"_"+attachs[5]String pay_type = attachs[4]+"_"+attachs[5];System.out.println("返回的pay_type:"+pay_type);OrderFormDto main_order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();params.put("mark",pay_type);payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}RequestHandler reqHandler = new RequestHandler(request, response);reqHandler.setParameter("appId", payment.getWx_appid());reqHandler.setParameter("nonceStr", ((String) xml.get("nonce_str")).toString());reqHandler.genSign(payment.getWx_paySignKey());String sign = reqHandler.getParameter("sign");if (("goodsfirst".equals(type)) || ("groupfirst".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (sign.equals(main_order.getOrder_sign())) {main_order.setPayTime(new Date());main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());main_order.setOut_order_id(out_trade_no);boolean flag = false;//查询修改相关子订单main_order.setOrder_first(0);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);//分销收益try{disAgentProfit(main_order);sendOrderMessage(main_order);if(main_order.getChild_order_detail() != null){List<Map> datalist = com.alibaba.fastjson.JSONObject.parseArray(main_order.getChild_order_detail(), Map.class);for (Map map : datalist) {Integer order_id = (Integer) map.get("order_id");OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(order_id.longValue());if(order != null){disAgentProfit(order);sendOrderMessage(order);}}}}catch (Exception e) {logger.error("PayController >> weixin_return(distribution&agentProfit【goods_first】) >> Exception:"+ e.getMessage());}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order);   //该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}  //如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}//如果订单是拉新用户订单  ,  添加if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==5) {main_order.setOrder_status(14);orderFormFeignClient.updateById(main_order);}else{if(main_order.getCheck_in_time() != null){sendHotelMessage(main_order);}else if(main_order.getOrder_offline()==1){//TODO 待修改 , 验证码消息}else{try{sendTxMessage(main_order);if(main_order.getChild_order_detail() != null){List<Map> datalist = com.alibaba.fastjson.JSONObject.parseArray(main_order.getChild_order_detail(), Map.class);for (Map map : datalist) {Integer order_id = (Integer) map.get("order_id");OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(order_id.longValue());if(order != null){sendTxMessage(main_order);}}}}catch (Exception e) {logger.error("PayController >> weixin_return(sendTxMessage【goods_first】) >> Exception:"+ e.getMessage());}}}//发站内消息/*//拓展配置中分销为开启if(null !=sysConfigExtendDto && sysConfigExtendDto.isDistribution_open() && main_order.getOrder_cat()==0){OrderFormDto updateorder=main_order;//更新分销订单状态updateorder.setOrder_status(20);distributionOrderFeignClient.updateOrderStatus(updateorder);}*/}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}}if (("goods".equals(type)) || ("group".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (sign.equals(main_order.getOrder_sign())) {main_order.setPayTime(new Date());main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());main_order.setOut_order_id(out_trade_no);boolean flag = false;//不查询相关子订单main_order.setOrder_first(1);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);try{disAgentProfit(main_order);sendOrderMessage(main_order);}catch (Exception e) {logger.error("PayController >> weixin_return(distribution&agentProfit【goods】) >> Exception:"+ e.getMessage());}if (main_order.getOrder_cat() != null && main_order.getOrder_cat() != 5) {if (main_order.getCheck_in_time() != null) {sendHotelMessage(main_order);} else if(main_order.getOrder_offline()==1){//TODO 待修改 , 验证码消息}else {try {sendTxMessage(main_order);} catch (Exception e) {logger.error("PayController >> weixin_return(sendTxMessage【goods】) >> Exception:"+ e.getMessage());}}}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order);  //该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}  //如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}//如果订单是拉新用户订单  ,  添加if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==5) {main_order.setOrder_status(14);orderFormFeignClient.updateById(main_order);}}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}}if ("integral".equals(type)) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if ((ig_order != null) && (ig_order.getIgo_status() < 20)&& (sign.equals(ig_order.getOrder_sign()))) {ig_order.setIgo_status(20);ig_order.setIgo_order_sn(out_trade_no);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment(payment.getMark()); this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}}if ("cash".equals(type)) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if ((obj != null) && (obj.getPd_pay_status() != 2) && (sign.equals(obj.getOrder_sign()))) {obj.setPd_payment(payment.getMark());obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info(payment.getName());this.predepositLogFeignClient.saveEntity(log);}}if ("gold".equals(type)) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if ((gold != null) && (gold.getGold_pay_status() != 2) && (sign.equals(gold.getOrder_sign()))) {gold.setGold_status(1);gold.setGold_pay_status(2);gold.setGold_payment(payment.getMark());this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content(payment.getName());log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());cp_order.setPayment(payment.getMark());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}}if (type.equals("platformpay")) {PlatformPay pf = this.platformPayService.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (pf.getPay_status() == 0 && StringUtils.equals(sign, pf.getSign())) {pf.setPay_status(1);pf.setUpdate_date(new Date());pf.setPay_type(payment.getMark());this.platformPayService.updateById(pf);PlatformPayFlow platformpayflow = new PlatformPayFlow();platformpayflow.setPlatform_pay_id(pf.getId());platformpayflow.setInfo("编号["+pf.getPay_no()+"]店铺保证金，支付成功");platformpayflow.setCreate_date(new Date());this.platformPayFlowService.saveEntity(platformpayflow);UserDto user = userFeignClient.selectByPrimaryKey(pf.getUser_id());StoreDto store = this.storeFeignClient.selectByPrimaryKey(user.getStore_id());store.setDeposit(pf.getAmount());this.storeFeignClient.updateById(store);}}//支付抢购订单上架费if (type.equals("rushorder")) {RushOrderformDto rushorderformdto = rushOrderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (rushorderformdto.getOrder_status()==5 && StringUtils.equals(sign, rushorderformdto.getSign())) {rushorderformdto.setPay_mark(payment.getMark());rushorderformdto.setPayment_id(payment.getId());rushorderformdto.setPayment_name(payment.getName());rushorderformdto.setOut_order_id(out_trade_no);rushorderformdto.setPay_time(new Date());rushOrderFormFeignClient.completePayment(rushorderformdto);//2022 支付流水待写入/*PlatformPayFlow platformpayflow = new PlatformPayFlow();platformpayflow.setPlatform_pay_id(pf.getId());platformpayflow.setInfo("编号["+pf.getPay_no()+"]店铺保证金，支付成功");platformpayflow.setCreate_date(new Date());this.platformPayFlowService.saveEntity(platformpayflow);UserDto user = userFeignClient.selectByPrimaryKey(pf.getUser_id());*/}}PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>");} else {PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[ERROR]]></return_msg></xml>");}} else {PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[ERROR]]></return_msg></xml>");}}/*** * @param request* @param response* @return* @throws Exception*/@RequestMapping({ "/unionpay_return" })public Map<String, Object> unionpay_return(HttpServletRequest request, HttpServletResponse response)throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();request.setCharacterEncoding("ISO-8859-1");String encoding = request.getParameter("encoding");Map<String, String> reqParam = getAllRequestParam(request);Map<String, String> valideData = null;if ((reqParam != null) && (!reqParam.isEmpty())) {Iterator<Map.Entry<String, String>> it = reqParam.entrySet().iterator();valideData = new HashMap(reqParam.size());while (it.hasNext()) {Map.Entry<String, String> e = (Map.Entry) it.next();String key = (String) e.getKey();String value = (String) e.getValue();value = new String(value.getBytes("ISO-8859-1"), encoding);valideData.put(key, value);}}if (!SDKUtil.validate(valideData, encoding)) {resultMap.put("op_title", "支付回调失败");resultMap.put("url", CommUtil.getURL(request) + "/index");} else {String orderId = (String) valideData.get("orderId");String respCode = (String) valideData.get("respCode");String txtAmt = (String) valideData.get("txtAmt");String reqReserved = (String) valideData.get("reqReserved");String[] infos = reqReserved.split("_");String type = infos[0];String order_no = infos[1];OrderFormDto main_order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if (type.equals("goods")) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("group")) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}Payment payment = null;if ((type.equals("goods")) || (type.equals("group"))) {payment = this.paymentService.selectByPrimaryKey(main_order.getPayment_id());}if ((type.equals("goods")) || (type.equals("group"))) {boolean flag = this.handleOrderFormFeignClient.payByOnline(main_order, main_order.getTrade_no(),CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(main_order);}resultMap.put("all_price", Double.valueOf(this.orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(main_order.getId()))));resultMap.put("obj", main_order);}if (type.equals("cash")) {if (obj.getPd_pay_status() != 2) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("银联在线支付");this.predepositLogFeignClient.saveEntity(log);}resultMap.put("op_title", "恭喜您，成功充值" + obj.getPd_amount() + "元");resultMap.put("url", CommUtil.getURL(request) + "/buyer/predeposit_list");}if (type.equals("gold")) {if (gold.getGold_pay_status() != 2) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("银联支付");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}resultMap.put("op_title", "兑换" + gold.getGold_count() + "金币成功");resultMap.put("url", CommUtil.getURL(request) + "/seller/gold_record_list");}if (type.equals("integral")) {if (ig_order.getIgo_status() < 20) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("unionpay");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}resultMap.put("obj", ig_order);}if (type.equals("cloudpurchase")) {if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}resultMap.put("op_title", "预付款支付成功！");resultMap.put("url", CommUtil.getURL(request) + "/buyer/cloudbuy_order");}}return resultMap;}@RequestMapping({ "/unionpay_notify" })public void unionpay_notify(HttpServletRequest request, HttpServletResponse response) throws Exception {String result = "ok";request.setCharacterEncoding("ISO-8859-1");String encoding = request.getParameter("encoding");Map<String, String> reqParam = getAllRequestParam(request);Map<String, String> valideData = null;if ((reqParam != null) && (!reqParam.isEmpty())) {Iterator<Map.Entry<String, String>> it = reqParam.entrySet().iterator();valideData = new HashMap(reqParam.size());while (it.hasNext()) {Map.Entry<String, String> e = (Map.Entry) it.next();String key = (String) e.getKey();String value = (String) e.getValue();value = new String(value.getBytes("ISO-8859-1"), encoding);valideData.put(key, value);}}if (!SDKUtil.validate(valideData, encoding)) {result = "no";} else {String orderId = (String) valideData.get("orderId");String respCode = (String) valideData.get("respCode");String txtAmt = (String) valideData.get("txtAmt");String reqReserved = (String) valideData.get("reqReserved");String[] infos = reqReserved.split("_");String type = infos[0];String order_no = infos[1];OrderFormDto main_order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if (type.equals("goods")) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("cash")) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("group")) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_no));}Payment payment = null;if ((type.equals("goods")) || (type.equals("group"))) {payment = this.paymentService.selectByPrimaryKey(main_order.getPayment_id());}if ((type.equals("goods")) || (type.equals("group"))) {boolean flag = this.handleOrderFormFeignClient.payByOnline(main_order, main_order.getTrade_no(),CommUtil.getURL(request));if (flag) {this.orderFormToolsFeignClient.updateGoodsInventory(main_order);}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}if ((type.equals("cash")) && (obj.getPd_pay_status() != 2)) {obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info("银联在线支付");this.predepositLogFeignClient.saveEntity(log);}if ((type.equals("gold")) && (gold.getGold_pay_status() != 2)) {gold.setGold_status(1);gold.setGold_pay_status(2);this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content("银联支付");log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}if ((type.equals("integral")) && (ig_order.getIgo_status() < 20)) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment("unionpay");this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}if ((type.equals("cloudpurchase")) && (cp_order.getStatus() < 5)) {cp_order.setStatus(5);cp_order.setPayTime(new Date());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}}response.setContentType("text/plain");response.setHeader("Cache-Control", "no-cache");response.setCharacterEncoding("UTF-8");try {PrintWriter writer = response.getWriter();writer.print(result);} catch (IOException e) {log.error(e.toString());}}public static Map<String, String> getAllRequestParam(HttpServletRequest request) {Map<String, String> res = Maps.newHashMap();Enumeration<?> temp = request.getParameterNames();if (temp != null) {while (temp.hasMoreElements()) {String en = (String) temp.nextElement();String value = request.getParameter(en);res.put(en, value);if ((res.get(en) == null) || ("".equals(res.get(en)))) {res.remove(en);}}}return res;}/*** 移动端订单预付款支付* @param request* @param response* @param order_id* @param pay_msg* @param type* @return* @throws Exception*/@RequestMapping({ "/order_pay_balance" })public Map<String,Object> order_pay_balance(HttpServletRequest request,HttpServletResponse response, @RequestBody JSONObject json) throws Exception {String order_id = json.optString("order_id");String pay_msg = json.optString("pay_msg");String type = json.optString("type");Map<String,Object> result=Maps.newHashMap();OrderFormDto order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));//余额支付信息Payment balance_payment=paymentService.selectByPrimaryKey(1L);order.setPayment_id(balance_payment.getId());order.setPayment_mark(balance_payment.getMark());order.setPayment_name(balance_payment.getName());//扩展信息表SysConfigExtendDto  sysConfigExtendDto=sysconrigExtendFeignClient.getSysConfigExtend();UserDto user = SecurityUserHolder.getCurrentUser(request);user=userFeignClient.selectByPrimaryKey(user.getId());Map<Boolean, Object>  map_verify = this.orderFormToolsFeignClient.orderForm_verify( order, user.getId());Iterator iterator = map_verify.keySet().iterator();while (iterator.hasNext()) {Boolean verify_result = (Boolean) iterator.next();if (!verify_result.booleanValue()) {return ResponseCode.buildFailMap("", map_verify.get(verify_result));}}double order_total_price = this.orderFormToolsFeignClient.query_order_pay_price(order_id);if (CommUtil.null2Double(user.getAvailableBalance()) >= order_total_price) {boolean ret = this.handleOrderFormFeignClient.payByBalance(order,CommUtil.getURL(request), pay_msg);if(ret){//调用拼一拼更新拼团状态服务if(null !=sysConfigExtendDto && sysConfigExtendDto.isPin_open() && order.getOrder_cat()==3){//调用拼一拼更新拼团状态服务pinPayRecordFeignClient.updateStatusByOrderId(order.getId(),0);}if(null !=sysConfigExtendDto && sysConfigExtendDto.isDistribution_open() && order.getOrder_cat()==0){//更新分销订单状态order.setOrder_status(20);distributionOrderFeignClient.updateOrderStatus(order);}result.put("op_title", "预付款支付成功");}else{result.put("op_title", "预付款支付成功");}} else {            result.put("op_title", "可用余额不足，支付失败");}return result;}/*** 移动端订单预付款支付* @param request* @param response* @param order_id* @param pay_msg* @param type* @return* @throws Exception*/@RequestMapping({ "/rushorder_pay_balance" })public Map<String,Object> rushorder_pay_balance(HttpServletRequest request,HttpServletResponse response, @RequestBody JSONObject json) {String id = json.optString("id");String pay_password = json.optString("pay_password");UserDto user = SecurityUserHolder.getCurrentUser(request);// 用户密码是否匹配if (!StringUtils.equals(Md5Encrypt.md5(pay_password), user.getPassword())) {return ResponseCode.buildFailMap("支付密码错误", null);}Map<String, Object> result = Maps.newHashMap();RushOrderformDto rushorder = rushOrderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if(rushorder==null||rushorder.getOrder_status()!=5){return ResponseCode.buildFailMap("订单数据错误", null);}user = userFeignClient.selectByPrimaryKey(user.getId());if (CommUtil.null2Double(user.getAvailableBalance()) >= CommUtil.null2Double(rushorder.getBond_money())) {// 余额// 买家减去余额user.setAvailableBalance(BigDecimal.valueOf(CommUtil.subtract(user.getAvailableBalance(), rushorder.getBond_money())));userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());//log.setPd_log_user(buyer);log.setPd_log_user_id(user.getId());log.setPd_op_type("消费");log.setPd_log_amount(BigDecimal.valueOf(-CommUtil.null2Double(rushorder.getBond_money())));log.setPd_log_info(rushorder.getOrder_no() + "抢购订单支付上架费减少可用预存款");log.setPd_type("可用预存款");predepositLogFeignClient.saveEntity(log);rushorder.setPay_mark("balance");rushorder.setPayment_id(1L);rushorder.setPayment_name("余额支付");rushorder.setPay_time(new Date());rushOrderFormFeignClient.completePayment(rushorder);return ResponseCode.buildSuccessMap(result);//支付成功} else {return ResponseCode.buildFailMap("可用余额不足，支付失败", null);}}@RequestMapping({ "/pay_code/generate" })public void pay_code_generate(HttpServletRequest request, HttpServletResponse response, @RequestBody JSONObject json)throws IOException {String url = json.optString("url");String logoPath = "";SysConfigDto sysconfig = sysConfigFeignClient.getSysConfig();if (sysconfig.getQr_logo() != null) {logoPath =request.getSession().getServletContext().getRealPath("/") + sysconfig.getQr_logo().getPath()+ File.separator + sysconfig.getQr_logo().getName();}QRCodeUtil.encode(url, logoPath, response, true);}private HttpURLConnection creatConnection(String requestUrl) throws IOException {URL url = new URL("https://api.mch.weixin.qq.com/pay/unifiedorder");HttpURLConnection conn = (HttpURLConnection) url.openConnection();conn.setConnectTimeout(30000);conn.setReadTimeout(30000);conn.setDoOutput(true);conn.setDoInput(true);conn.setUseCaches(false);conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");conn.setRequestMethod("POST");conn.setRequestProperty("Content-Length", requestUrl.length() + "");String encode = "utf-8";OutputStreamWriter out = new OutputStreamWriter(conn.getOutputStream(), encode);out.write(requestUrl.toString());out.flush();out.close();return conn;}private String getInput(HttpURLConnection conn) throws IOException {if (conn.getResponseCode() != 200) {return null;}BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));String line = "";StringBuffer strBuf = new StringBuffer();while ((line = in.readLine()) != null) {strBuf.append(line).append("\n");}in.close();return strBuf.toString().trim();}public Map doXMLParse(String strxml) throws JDOMException, IOException {strxml = strxml.replaceFirst("encoding=\".*\"", "encoding=\"UTF-8\"");if ((strxml == null) || ("".equals(strxml))) {return null;}Map m = Maps.newHashMap();InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8"));SAXBuilder builder = new SAXBuilder();Document doc = builder.build(in);Element root = doc.getRootElement();List list = root.getChildren();Iterator it = list.iterator();while (it.hasNext()) {Element e = (Element) it.next();String k = e.getName();String v = "";List children = e.getChildren();if (children.isEmpty()) {v = e.getTextNormalize();} else {v = getChildrenText(children);}m.put(k, v);}in.close();return m;}public String getChildrenText(List children) {StringBuffer sb = new StringBuffer();if (!children.isEmpty()) {Iterator it = children.iterator();while (it.hasNext()) {Element e = (Element) it.next();String name = e.getName();String value = e.getTextNormalize();List list = e.getChildren();sb.append("<" + name + ">");if (!list.isEmpty()) {sb.append(getChildrenText(list));}sb.append(value);sb.append("</" + name + ">");}}return sb.toString();}/*** 微信回调* * @param request* @param response* @throws Exception*/@RequestMapping(value = "/weixin_returntest2636dd", method = RequestMethod.POST)public void weixin_returntest2636dd(HttpServletRequest request, HttpServletResponse response,@RequestBody JSONObject json) throws Exception {String type = json.optString("type");String pay_type = json.optString("pay_type");String order_id = json.optString("order_id");//扩展信息表if (true) {if (true) {//支付方式  因为微信支付方式是"wx_miniprogram" 形式故pay_type为attachs[4]+"_"+attachs[5]OrderFormDto main_order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();params.put("mark",pay_type);payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}if (("goods_first".equals(type)) || ("group_first".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));if (true) {main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());boolean flag = false;//查询修改相关子订单main_order.setOrder_first(0);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);//分销收益try{disAgentProfit(main_order);sendOrderMessage(main_order);if(main_order.getChild_order_detail() != null){List<Map> datalist = com.alibaba.fastjson.JSONObject.parseArray(main_order.getChild_order_detail(), Map.class);for (Map map : datalist) {Integer order_id1 = (Integer) map.get("order_id");OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(order_id1.longValue());if(order != null){disAgentProfit(order);sendOrderMessage(order);}}}}catch (Exception e) {logger.error("PayController >> weixin_returntest2636dd(distribution) >> Exception:"+ e.getMessage());}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order);  //该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}  //如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}//调用拼一拼更新拼团状态服务if(true && main_order.getOrder_cat()==3){//调用拼一拼更新拼团状态服务orderFormToolsFeignClient.updateStatusByOrderId(main_order.getId(),0);}//拓展配置中分销为开启if(true && main_order.getOrder_cat()==0){OrderFormDto updateorder=main_order;//更新分销订单状态updateorder.setOrder_status(20);distributionOrderFeignClient.updateOrderStatus(updateorder);}}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}}if (("goods".equals(type)) || ("group".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));if (true) {main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());boolean flag = false;//不查询相关子订单main_order.setOrder_first(1);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);//分销收益try{disAgentProfit(main_order);sendOrderMessage(main_order);}catch (Exception e) {logger.error("PayController >> weixin_returntest2636dd(distribution) >> Exception:"+ e.getMessage());}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order);  //该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}  //如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}}if ("integral".equals(type)) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));if ((ig_order != null) && (ig_order.getIgo_status() < 20)&& (true)) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment(payment.getMark()); this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}}if ("cash".equals(type)) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));if ((obj != null) && (obj.getPd_pay_status() != 2) && (true)) {obj.setPd_payment(payment.getMark());obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info(payment.getName());this.predepositLogFeignClient.saveEntity(log);}}if ("gold".equals(type)) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(order_id));if ((gold != null) && (gold.getGold_pay_status() != 2) && (true)) {gold.setGold_status(1);gold.setGold_pay_status(2);gold.setGold_payment(payment.getMark());this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content(payment.getName());log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(order_id));if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());cp_order.setPayment(payment.getMark());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}}if (type.equals("platformpay")) {PlatformPay pf = this.platformPayService.selectByPrimaryKey(CommUtil.null2Long(order_id));if (pf.getPay_status() == 0 && true) {pf.setPay_status(1);pf.setUpdate_date(new Date());pf.setPay_type(payment.getMark());this.platformPayService.updateById(pf);PlatformPayFlow platformpayflow = new PlatformPayFlow();platformpayflow.setPlatform_pay_id(pf.getId());platformpayflow.setInfo("编号["+pf.getPay_no()+"]店铺保证金，支付成功");platformpayflow.setCreate_date(new Date());this.platformPayFlowService.saveEntity(platformpayflow);UserDto user = userFeignClient.selectByPrimaryKey(pf.getUser_id());StoreDto store = this.storeFeignClient.selectByPrimaryKey(user.getStore_id());store.setDeposit(pf.getAmount());this.storeFeignClient.updateById(store);}}PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>");} else {PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[ERROR]]></return_msg></xml>");}} else {PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[ERROR]]></return_msg></xml>");}}/*** 移动端订单支付* @param request* @param response* @param payType* @param order_id* @param order_type* @param pay_password* @return* @throws Exception */@RequestMapping({ "/order_unifiedorder" })public Object order_unifiedorder(HttpServletRequest request,HttpServletResponse response,@RequestBody JSONObject json) throws Exception {Long id = json.optLong("id");String pay_type =json.optString("pay_type");String order_type =json.optString("order_type");Map<String,Object> resultMap=new HashMap<String,Object>();//TODO try{//检查支付方式if(pay_type.equals("wx_app")){return this.weixin_unifiedorder(request, response,pay_type,  id,order_type);}else if(pay_type.equals("alipay_app")){return alipayService.app_alipay_unifiedorder(request, response,pay_type,  id,order_type);}else{resultMap.put("60001", "支付方式错误");}    }catch(Exception e){logger.error(e.toString());}return resultMap;}/*** 移动端移动端预下单* @param request* @param response* @param payType* @param order_id 订单id* @param type 订单类型* @return* @throws Exception */private  Map<String,Object> weixin_unifiedorder(HttpServletRequest request,HttpServletResponse response,String  pay_type,Long  id,String order_type) throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();RequestHandler reqHandler = new RequestHandler(request, response);List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();// TODO//pay_type = "wx_app";params.put("mark", pay_type);payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}String body = "";String attach = "";String out_trade_no = "";double total_fee = 0.0D;boolean submit = true;OrderFormDto of = null;PredepositDto pd = null;GoldRecord gold = null;PlatformPay platformpay=null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;UserDto user=null;if ((order_type.equals("goods")) || (order_type.equals("group"))) {of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (of.getOrder_status() >= 20) {submit = false;} else {body = of.getOrder_id();attach = of.getId() + "_" + of.getOrder_id() + "_" + of.getUser_id() + "_" + order_type + "_"+ pay_type;out_trade_no = of.getOrder_id();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", of);}}//第一次付款, 带上子订单信息if ((order_type.equals("goodsfirst")) || (order_type.equals("groupfirst"))) {of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (of.getOrder_status() >= 20) {submit = false;} else {body = of.getOrder_id();attach = of.getId() + "_" + of.getOrder_id() + "_" + of.getUser_id() + "_" + order_type + "_"+ pay_type;out_trade_no = of.getOrder_id();//第一次付款取子订单总价格total_fee = Double.valueOf(orderFormToolsFeignClient.query_order_pay_price(CommUtil.null2String(of.getId())))* 100.0D;resultMap.put("obj", of);}}if (order_type.equals("cash")) {pd = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (pd.getPd_pay_status() >= 2) {submit = false;} else {body = pd.getPd_sn();attach = pd.getId() + "_" + pd.getPd_sn() + "_" + pd.getPd_user().getId() + "_" + order_type + "_"+ pay_type;out_trade_no = pd.getPd_sn();total_fee = Double.valueOf(pd.getPd_amount().toString()).doubleValue() * 100.0D;resultMap.put("obj", pd);}}if (order_type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(id));if (gold.getGold_pay_status() >= 2) {submit = false;} else {body = gold.getGold_sn();attach = gold.getId() + "_" + gold.getGold_sn() + "_" + gold.getGold_user().getId() + "_" + order_type+ "_" + pay_type;out_trade_no = gold.getGold_sn();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", gold);}}if (order_type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (ig_order.getIgo_status() >= 20) {submit = false;} else {body = ig_order.getIgo_order_sn();attach = ig_order.getId() + "_" + ig_order.getIgo_order_sn() + "_" + ig_order.getIgo_user().getId()+ "_" + order_type + "_" + pay_type;out_trade_no = ig_order.getIgo_order_sn();total_fee = Double.valueOf(ig_order.getIgo_trans_fee().toString()).doubleValue() * 100.0D;resultMap.put("obj", ig_order);}}if (order_type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (cp_order.getStatus() == 5) {submit = false;} else {body = cp_order.getIgo_order_sn();attach = cp_order.getId() + "_" + cp_order.getIgo_order_sn() + "_" + cp_order.getUser_id() + "_"+ order_type + "_" + pay_type;out_trade_no = cp_order.getIgo_order_sn();total_fee = Double.valueOf(cp_order.getPrice()).doubleValue() * 100.0D;resultMap.put("obj", cp_order);}}if (order_type.equals("platformpay")) {   //保证金platformpay = this.platformPayService.selectByPrimaryKey(CommUtil.null2Long(id));if (platformpay.getPay_status() == 1) { //已支付 submit = false;} else {body = platformpay.getPay_no();attach = platformpay.getId() + "_" + platformpay.getPay_no() + "_" + platformpay.getUser_id() + "_"+ order_type + "_" + pay_type;out_trade_no = platformpay.getPay_no();total_fee = platformpay.getAmount().doubleValue() * 100.0D;resultMap.put("obj", platformpay);user = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(platformpay.getUser_id()));}}if ((submit) && (payment != null)) {if (payment != null) {String app_id = payment.getWx_appid();String app_key = payment.getWx_paySignKey();String partner = payment.getTenpay_partner();String notify_url = payment.getNotify_url();String noncestr = Sha1Util.getNonceStr();String timestamp = Sha1Util.getTimeStamp();String path = request.getContextPath();String basePath = notify_url+ "/";reqHandler.setParameter("appid", app_id);reqHandler.setParameter("mch_id", partner);reqHandler.setParameter("nonce_str", noncestr);reqHandler.setParameter("body", body);reqHandler.setParameter("attach", attach);reqHandler.setParameter("out_trade_no", out_trade_no);BigDecimal total_feeBig = new BigDecimal(total_fee);reqHandler.setParameter("total_fee", total_feeBig.setScale(0, BigDecimal.ROUND_UP) + "");reqHandler.setParameter("notify_url", basePath + "weixin_return");reqHandler.setParameter("trade_type", "APP");String requestUrl = reqHandler.reqToXml(app_key);HttpURLConnection conn = creatConnection(requestUrl);String result = getInput(conn);Map<String, String> map = doXMLParse(result);String return_code = ((String) map.get("return_code")).toString();String prepay_id = "";String code_url = "";if ("SUCCESS".equals(return_code)) {String result_code = ((String) map.get("result_code")).toString();if ("SUCCESS".equals(result_code)) {prepay_id = (String) map.get("prepay_id");code_url = (String) map.get("code_url");} else {// 预下单异常信息显示log.error(map.toString());}} else {// 预下单异常信息显示log.error(map.toString());}reqHandler.getAllParameters().clear();reqHandler.setParameter("appid", app_id);reqHandler.setParameter("partnerid", payment.getTenpay_partner());    reqHandler.setParameter("prepayid", prepay_id);reqHandler.setParameter("package", "Sign=WXPay");reqHandler.setParameter("noncestr", noncestr);reqHandler.setParameter("timestamp", timestamp);reqHandler.genSign(app_key);resultMap.put("appid", app_id);resultMap.put("partnerid", payment.getTenpay_partner());resultMap.put("prepayid", prepay_id);resultMap.put("package", "Sign=WXPay");resultMap.put("noncestr", noncestr);       resultMap.put("timestamp", timestamp);resultMap.put("sign", reqHandler.getParameter("sign"));System.out.print("返回给前端---------------------------");System.out.print(resultMap.toString());System.out.print("返回给前端---------------------------");reqHandler.getAllParameters().clear();reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);reqHandler.genSign(app_key);String order_sign = reqHandler.getParameter("sign");if ((order_type.equals("goods")) || (order_type.equals("group"))||(order_type.equals("goodsfirst")) || (order_type.equals("goodsfirst"))) {of.setOrder_sign(order_sign);this.orderFormFeignClient.updateById(of);}if (order_type.equals("cash")) {pd.setOrder_sign(order_sign);this.predepositFeignClient.updateById(pd);}if (order_type.equals("gold")) {gold.setOrder_sign(order_sign);this.goldRecordService.updateById(gold);}if (order_type.equals("integral")) {ig_order.setOrder_sign(order_sign);this.integralGoodsOrderFeignClient.updateById(ig_order);}if (order_type.equals("cloudpurchase")) {cp_order.setOrder_sign(order_sign);this.cloudPurchaseOrderFeignClient.updateById(cp_order);}if (order_type.equals("platformpay")) {platformpay.setTrade_no(order_sign);platformpay.setSign(order_sign);this.platformPayService.updateById(platformpay);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}return ResponseCode.buildSuccessMap(resultMap);}/*** 微信app支付回调* @param request* @param response* @throws Exception*/@RequestMapping({ "/weixin_return_app" })public void weixin_return_app(HttpServletRequest request,HttpServletResponse response) throws Exception {response.setContentType("text/plain");response.setHeader("Cache-Control", "no-cache");response.setCharacterEncoding("UTF-8");BufferedReader in = new BufferedReader(new InputStreamReader(request.getInputStream(), "UTF-8"));String line = "";StringBuffer strBuf = new StringBuffer();while ((line = in.readLine()) != null) {strBuf.append(line).append("\n");}in.close();Map<String, String> xml = doXMLParse(strBuf.toString().trim());//扩展信息表SysConfigExtendDto  sysConfigExtendDto=sysconrigExtendFeignClient.getSysConfigExtend();String appid = ((String) xml.get("appid")).toString();if ("SUCCESS".equals(((String) xml.get("return_code")).toString())) {if ("SUCCESS".equals(((String) xml.get("result_code")).toString())) {String total_fee = (String) xml.get("total_fee");String[] attachs = ((String) xml.get("attach")).split("_");String type = attachs[3];//支付方式  因为微信支付方式是"wx_miniprogram" 形式故pay_type为attachs[4]+"_"+attachs[5]String pay_type = attachs[4]+"_"+attachs[5];System.out.println("返回的pay_type:"+pay_type);OrderFormDto main_order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();params.put("mark",pay_type);payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}RequestHandler reqHandler = new RequestHandler(request, response);reqHandler.setParameter("appId", payment.getWx_appid());reqHandler.setParameter("nonceStr", ((String) xml.get("nonce_str")).toString());reqHandler.genSign(payment.getWx_paySignKey());String sign = reqHandler.getParameter("sign");if (("goodsfirst".equals(type)) || ("groupfirst".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (sign.equals(main_order.getOrder_sign())) {main_order.setPayTime(new Date());main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());boolean flag = false;//查询修改相关子订单main_order.setOrder_first(0);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);//分销收益try{disAgentProfit(main_order);sendOrderMessage(main_order);if(main_order.getChild_order_detail() != null){List<Map> datalist = com.alibaba.fastjson.JSONObject.parseArray(main_order.getChild_order_detail(), Map.class);for (Map map : datalist) {Integer order_id = (Integer) map.get("order_id");OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(order_id.longValue());if(order != null){disAgentProfit(order);sendOrderMessage(order);}}}}catch (Exception e) {logger.error("PayController >> weixin_return(distribution&agentProfit【goods_first】) >> Exception:"+ e.getMessage());}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order); //该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}  //如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}try{sendTxMessage(main_order);if(main_order.getChild_order_detail() != null){List<Map> datalist = com.alibaba.fastjson.JSONObject.parseArray(main_order.getChild_order_detail(), Map.class);for (Map map : datalist) {Integer order_id = (Integer) map.get("order_id");OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(order_id.longValue());if(order != null){sendTxMessage(main_order);}}}}catch (Exception e) {logger.error("PayController >> weixin_return(sendTxMessage【goods_first】) >> Exception:"+ e.getMessage());}//发站内消息/*//拓展配置中分销为开启if(null !=sysConfigExtendDto && sysConfigExtendDto.isDistribution_open() && main_order.getOrder_cat()==0){OrderFormDto updateorder=main_order;//更新分销订单状态updateorder.setOrder_status(20);distributionOrderFeignClient.updateOrderStatus(updateorder);}*/}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}}if (("goods".equals(type)) || ("group".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (sign.equals(main_order.getOrder_sign())) {main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());boolean flag = false;//不查询相关子订单main_order.setOrder_first(1);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);try{disAgentProfit(main_order);sendOrderMessage(main_order);}catch (Exception e) {logger.error("PayController >> weixin_return(distribution&agentProfit【goods】) >> Exception:"+ e.getMessage());}try{sendTxMessage(main_order);}catch (Exception e) {logger.error("PayController >> weixin_return(sendTxMessage【goods】) >> Exception:"+ e.getMessage());}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order); //该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}  //如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}}if ("integral".equals(type)) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if ((ig_order != null) && (ig_order.getIgo_status() < 20)&& (sign.equals(ig_order.getOrder_sign()))) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment(payment.getMark()); this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}}if ("cash".equals(type)) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if ((obj != null) && (obj.getPd_pay_status() != 2) && (sign.equals(obj.getOrder_sign()))) {obj.setPd_payment(payment.getMark());obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info(payment.getName());this.predepositLogFeignClient.saveEntity(log);}}if ("gold".equals(type)) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if ((gold != null) && (gold.getGold_pay_status() != 2) && (sign.equals(gold.getOrder_sign()))) {gold.setGold_status(1);gold.setGold_pay_status(2);gold.setGold_payment(payment.getMark());this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content(payment.getName());log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());cp_order.setPayment(payment.getMark());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}}if (type.equals("platformpay")) {PlatformPay pf = this.platformPayService.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (pf.getPay_status() == 0 && StringUtils.equals(sign, pf.getSign())) {pf.setPay_status(1);pf.setUpdate_date(new Date());pf.setPay_type(payment.getMark());this.platformPayService.updateById(pf);PlatformPayFlow platformpayflow = new PlatformPayFlow();platformpayflow.setPlatform_pay_id(pf.getId());platformpayflow.setInfo("编号["+pf.getPay_no()+"]店铺保证金，支付成功");platformpayflow.setCreate_date(new Date());this.platformPayFlowService.saveEntity(platformpayflow);UserDto user = userFeignClient.selectByPrimaryKey(pf.getUser_id());StoreDto store = this.storeFeignClient.selectByPrimaryKey(user.getStore_id());store.setDeposit(pf.getAmount());this.storeFeignClient.updateById(store);}}PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>");} else {PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[ERROR]]></return_msg></xml>");}} else {PrintWriter write = response.getWriter();write.print("<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[ERROR]]></return_msg></xml>");}}public Map<String, Object> wxh5_pay(HttpServletRequest request, HttpServletResponse response, Long id,String pay_type, String order_type) throws Exception {Map<String, Object> resultMap = new HashMap<String, Object>();RequestHandler reqHandler = new RequestHandler(request, response);List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();//TODOpay_type="wx_pay";params.put("mark", pay_type);payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}String body = "";String attach = "";String out_trade_no = "";double total_fee = 0.0D;boolean submit = true;OrderFormDto of = null;PredepositDto pd = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if ((order_type.equals("goods")) || (order_type.equals("group"))) {of = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (of.getOrder_status() >= 20) {submit = false;} else {body = of.getOrder_id();attach = of.getId() + "_" + of.getOrder_id() + "_" + of.getUser_id() + "_" + order_type +"_"+pay_type;out_trade_no = of.getOrder_id();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", of);}}if (order_type.equals("cash")) {pd = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (pd.getPd_pay_status() >= 2) {submit = false;} else {body = pd.getPd_sn();attach = pd.getId() + "_" + pd.getPd_sn() + "_" + pd.getPd_user().getId() + "_" + order_type+"_"+pay_type;out_trade_no = pd.getPd_sn();total_fee = Double.valueOf(pd.getPd_amount().toString()).doubleValue() * 100.0D;resultMap.put("obj", pd);}}if (order_type.equals("gold")) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(id));if (gold.getGold_pay_status() >= 2) {submit = false;} else {body = gold.getGold_sn();attach = gold.getId() + "_" + gold.getGold_sn() + "_" + gold.getGold_user().getId() + "_" + order_type+"_"+pay_type;out_trade_no = gold.getGold_sn();total_fee = Double.valueOf(of.getTotalPrice().toString()).doubleValue() * 100.0D;resultMap.put("obj", gold);}}if (order_type.equals("integral")) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (ig_order.getIgo_status() >= 20) {submit = false;} else {body = ig_order.getIgo_order_sn();attach = ig_order.getId() + "_" + ig_order.getIgo_order_sn() + "_" + ig_order.getIgo_user().getId()+ "_" + order_type+"_"+pay_type;out_trade_no = ig_order.getIgo_order_sn();total_fee = Double.valueOf(ig_order.getIgo_trans_fee().toString()).doubleValue() * 100.0D;resultMap.put("obj", ig_order);}}if (order_type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(id));if (cp_order.getStatus() == 5) {submit = false;} else {body = cp_order.getIgo_order_sn();attach = cp_order.getId() + "_" + cp_order.getIgo_order_sn() + "_" + cp_order.getUser_id() + "_"+ order_type+"_"+pay_type;out_trade_no = cp_order.getIgo_order_sn();total_fee = Double.valueOf(cp_order.getPrice()).doubleValue() * 100.0D;resultMap.put("obj", cp_order);}}if ((submit) && (payment != null)) {if (payment != null) {String app_id = payment.getWx_appid();String app_key = payment.getWx_paySignKey();String partner = payment.getTenpay_partner();String notify_url = payment.getNotify_url();String noncestr = Sha1Util.getNonceStr();String timestamp = Sha1Util.getTimeStamp();String path = request.getContextPath();String basePath = notify_url + "/";reqHandler.setParameter("appid", app_id);reqHandler.setParameter("mch_id", partner);reqHandler.setParameter("nonce_str", noncestr);/*reqHandler.setParameter("device_info", "wechat_mini_program");*/reqHandler.setParameter("body", body);reqHandler.setParameter("attach", attach);reqHandler.setParameter("out_trade_no", out_trade_no);BigDecimal total_feeBig = new BigDecimal(total_fee);reqHandler.setParameter("total_fee", total_feeBig.setScale(0, BigDecimal.ROUND_UP)+"");reqHandler.setParameter("spbill_create_ip", CommUtil.getIpAddr(request));reqHandler.setParameter("notify_url", basePath + "weixin_return");reqHandler.setParameter("scene_info", "'h5_info':{'type':'Wap','wap_url':'http://haiwah5.minglisoft.cn/','wap_name': '海哇'}");reqHandler.setParameter("trade_type", "MWEB");// trade_type=JSAPI时,必须传入openidUserDto user = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(of.getUser_id()));reqHandler.setParameter("openid", user.getOpenId());String requestUrl = reqHandler.reqToXml(app_key);HttpURLConnection conn = creatConnection(requestUrl);String result = getInput(conn);Map<String, String> map = doXMLParse(result);String return_code = ((String) map.get("return_code")).toString();String prepay_id = "";String code_url = "";if ("SUCCESS".equals(return_code)) {String result_code = ((String) map.get("result_code")).toString();if ("SUCCESS".equals(result_code)) {prepay_id = (String) map.get("prepay_id");code_url = (String) map.get("code_url");} else {// 预下单异常信息显示log.error(map.toString());}} else {// 预下单异常信息显示log.error(map.toString());}reqHandler.getAllParameters().clear();String newPackage = "prepay_id=" + prepay_id;reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);  reqHandler.setParameter("package", newPackage);reqHandler.setParameter("signType", "MD5");reqHandler.setParameter("timeStamp", timestamp+"");reqHandler.genSign(app_key);String order_sign = reqHandler.getParameter("sign");resultMap.put("app_id", app_id);resultMap.put("timestamp", timestamp+"");resultMap.put("noncestr", noncestr);resultMap.put("packageValue", newPackage);resultMap.put("sign", order_sign);resultMap.put("code_url", code_url);resultMap.put("signType", "MD5");System.out.print("返回给前端---------------------------");System.out.print(resultMap.toString());System.out.print("返回给前端---------------------------");reqHandler.getAllParameters().clear();reqHandler.setParameter("appId", app_id);reqHandler.setParameter("nonceStr", noncestr);reqHandler.genSign(app_key);order_sign=reqHandler.getParameter("sign");if ((order_type.equals("goods")) || (order_type.equals("group"))) {of.setOrder_sign(order_sign);this.orderFormFeignClient.updateById(of);}if (order_type.equals("cash")) {pd.setOrder_sign(order_sign);this.predepositFeignClient.updateById(pd);}if (order_type.equals("gold")) {gold.setOrder_sign(order_sign);this.goldRecordService.updateById(gold);}if (order_type.equals("integral")) {ig_order.setOrder_sign(order_sign);this.integralGoodsOrderFeignClient.updateById(ig_order);}if (order_type.equals("cloudpurchase")) {cp_order.setOrder_sign(order_sign);this.cloudPurchaseOrderFeignClient.updateById(cp_order);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}} else {return ResponseCode.buildCodeMap("20001", "支付方式错误！", null);}return ResponseCode.buildSuccessMap(resultMap) ;}@RequestMapping({ "/pay/ditu" })public Map<String, Object> ditu(HttpServletRequest request, HttpServletResponse response,@RequestBody JSONObject json) throws Exception {List<Payment> payments = Lists.newArrayList();Map<String, Object> params = Maps.newHashMap();params.put("mark", "wx_pay");payments = this.paymentService.queryPageList(params);Payment payment = null;if (payments.size() > 0) {payment = (Payment) payments.get(0);}String app_id = payment.getWx_appid();String app_key = payment.getWx_paySignKey();String noncestr = Sha1Util.getNonceStr();String timestamp = Sha1Util.getTimeStamp();//String accessToken = accessTokenTools.getAccessTokenOld(app_id, payment.getWx_appSecret());String accessToken = accessTokenTools.getAccessToken(app_id, payment.getWx_appSecret());System.out.println("accessToken===="+accessToken);Map<String, String> jsapiTicket = accessTokenTools.JsapiTicket(accessToken);String str = "jsapi_ticket="+jsapiTicket.get("ticket")+"&noncestr="+noncestr+"&timestamp="+timestamp+"&url="+"http://haiwah5.minglisoft.cn/";String signature = Sha1Util.getSha1(str);//String signature = SHA1.SHA1(str);Map<String, Object> resultMap = new HashMap<String, Object>();resultMap.put("app_id", payment.getWx_appid());resultMap.put("timestamp", timestamp + "");resultMap.put("nonceStr", noncestr);resultMap.put("jsapiTicket", jsapiTicket.get("ticket"));resultMap.put("sign", signature);return ResponseCode.buildSuccessMap(resultMap);}/*** 支付宝app 支付成功 处理订单* @param request* @param payment 支付方式* @param type 类型* @param attachs 附加参数*/private  void afterNotifyOrderHandling_alipay(HttpServletRequest request,Payment payment,String type,String[] attachs ){OrderFormDto main_order = null;PredepositDto obj = null;GoldRecord gold = null;IntegralGoodsOrderDto ig_order = null;CloudPurchaseOrderDto cp_order = null;if (("goodsfirst".equals(type)) || ("groupfirst".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if(main_order==null||main_order.getOrder_status()!=10){return;}main_order.setPayTime(new Date());main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());boolean flag = false;//查询修改相关子订单main_order.setOrder_first(0);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);//分销收益try{disAgentProfit(main_order);sendOrderMessage(main_order);if(main_order.getChild_order_detail() != null){List<Map> datalist = com.alibaba.fastjson.JSONObject.parseArray(main_order.getChild_order_detail(), Map.class);for (Map map : datalist) {Integer order_id = (Integer) map.get("order_id");OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(order_id.longValue());if(order != null){disAgentProfit(order);sendOrderMessage(order);}}}}catch (Exception e) {logger.error("PayController >> weixin_return(distribution&agentProfit【goods_first】) >> Exception:"+ e.getMessage());}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order);//该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}//如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}//如果订单是拉新用户订单  ,  添加if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==5) {main_order.setOrder_status(14);orderFormFeignClient.updateById(main_order);}else{if(main_order.getCheck_in_time() != null){sendHotelMessage(main_order);}else if(main_order.getOrder_offline()==1){//TODO 待修改 , 验证码消息}else{try{sendTxMessage(main_order);if(main_order.getChild_order_detail() != null){List<Map> datalist = com.alibaba.fastjson.JSONObject.parseArray(main_order.getChild_order_detail(), Map.class);for (Map map : datalist) {Integer order_id = (Integer) map.get("order_id");OrderFormDto order = orderFormFeignClient.selectByPrimaryKey(order_id.longValue());if(order != null){sendTxMessage(main_order);}}}}catch (Exception e) {logger.error("PayController >> weixin_return(sendTxMessage【goods_first】) >> Exception:"+ e.getMessage());}}}//发站内消息/*//拓展配置中分销为开启if(null !=sysConfigExtendDto && sysConfigExtendDto.isDistribution_open() && main_order.getOrder_cat()==0){OrderFormDto updateorder=main_order;//更新分销订单状态updateorder.setOrder_status(20);distributionOrderFeignClient.updateOrderStatus(updateorder);}*/}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}if (("goods".equals(type)) || ("group".equals(type))) {main_order = this.orderFormFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if(main_order==null||main_order.getOrder_status()!=10){return;}main_order.setPayTime(new Date());main_order.setPayment_mark(payment.getMark());main_order.setPayment_name(payment.getName());boolean flag = false;//不查询相关子订单main_order.setOrder_first(1);flag = this.handleOrderFormFeignClient.payByOnline(main_order, "", CommUtil.getURL(request));if (flag) {main_order.setOrder_status(20);try{disAgentProfit(main_order);sendOrderMessage(main_order);}catch (Exception e) {logger.error("PayController >> weixin_return(distribution&agentProfit【goods】) >> Exception:"+ e.getMessage());}if (main_order.getOrder_cat() != null && main_order.getOrder_cat() != 5) {if (main_order.getCheck_in_time() != null) {sendHotelMessage(main_order);} else if(main_order.getOrder_offline()==1){//TODO 待修改 , 验证码消息}else {try {sendTxMessage(main_order);} catch (Exception e) {logger.error("PayController >> weixin_return(sendTxMessage【goods】) >> Exception:"+ e.getMessage());}}}//更新库存this.orderFormToolsFeignClient.updateGoodsInventory(main_order);//该订单存在直播商品if (main_order.getLiveorder_type() != null && main_order.getLiveorder_type()==1) {liveOrderFeignClient.updateLiveOrder(main_order);}//如果订单是增值服务,修改用户   审核状态if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==4) {userFeignClient.updateLiveById(CommUtil.null2Long(main_order.getUser_id()));}//如果订单是拉新用户订单  ,  添加if (main_order.getOrder_cat() != null && main_order.getOrder_cat()==5) {main_order.setOrder_status(14);orderFormFeignClient.updateById(main_order);}}this.orderFormToolsFeignClient.sendMsgWhenHandleOrder(CommUtil.getURL(request), main_order,"tobuyer_online_pay_ok_notify", "toseller_online_pay_ok_notify");}if ("integral".equals(type)) {ig_order = this.integralGoodsOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (ig_order != null && ig_order.getIgo_status() < 20) {ig_order.setIgo_status(20);ig_order.setIgo_pay_time(new Date());ig_order.setIgo_payment(payment.getMark());this.integralGoodsOrderFeignClient.updateById(ig_order);List<Map> ig_maps = this.orderFormToolsFeignClient.query_integral_goodsinfo(ig_order.getGoods_info());for (Map map : ig_maps) {IntegralGoodsDto goods = this.integralGoodsFeignClient.selectByPrimaryKey(CommUtil.null2Long(map.get("id")));goods.setIg_goods_count(goods.getIg_goods_count() - CommUtil.null2Int(map.get("ig_goods_count")));goods.setIg_exchange_count(goods.getIg_exchange_count() + CommUtil.null2Int(map.get("ig_goods_count")));this.integralGoodsFeignClient.updateById(goods);}}}if ("cash".equals(type)) {obj = this.predepositFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (obj != null && obj.getPd_pay_status() != 2) {obj.setPd_payment(payment.getMark());obj.setPd_status(1);obj.setPd_pay_status(2);this.predepositFeignClient.updateById(obj);UserDto user = this.userFeignClient.selectByPrimaryKey(obj.getPd_user().getId());user.setAvailableBalance(BigDecimal.valueOf(CommUtil.add(user.getAvailableBalance(), obj.getPd_amount())));this.userFeignClient.updateById(user);PredepositLogDto log = new PredepositLogDto();log.setAddTime(new Date());log.setPd_log_amount(obj.getPd_amount());log.setPd_log_user(obj.getPd_user());log.setPd_op_type("充值");log.setPd_type("可用预存款");log.setPd_log_info(payment.getName());this.predepositLogFeignClient.saveEntity(log);}}if ("gold".equals(type)) {gold = this.goldRecordService.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (gold != null && gold.getGold_pay_status() != 2) {gold.setGold_status(1);gold.setGold_pay_status(2);gold.setGold_payment(payment.getMark());this.goldRecordService.updateById(gold);UserDto user = this.userFeignClient.selectByPrimaryKey(gold.getGold_user().getId());user.setGold(user.getGold() + gold.getGold_count());this.userFeignClient.updateById(user);GoldLog log = new GoldLog();log.setAddTime(new Date());log.setGl_payment(gold.getGold_payment());log.setGl_content(payment.getName());log.setGl_money(gold.getGold_money());log.setGl_count(gold.getGold_count());log.setGl_type(0);log.setGl_user(gold.getGold_user());log.setGr(gold);this.goldLogService.saveEntity(log);}}if (type.equals("cloudpurchase")) {cp_order = this.cloudPurchaseOrderFeignClient.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (cp_order.getStatus() < 5) {cp_order.setStatus(5);cp_order.setPayTime(new Date());cp_order.setPayment(payment.getMark());this.cloudPurchaseOrderFeignClient.updateById(cp_order);this.cloudPurchaseOrderFeignClient.reduce_inventory(cp_order, request);}}if (type.equals("platformpay")) {PlatformPay pf = this.platformPayService.selectByPrimaryKey(CommUtil.null2Long(attachs[0]));if (pf.getPay_status() == 0 ) {pf.setPay_status(1);pf.setUpdate_date(new Date());pf.setPay_type(payment.getMark());this.platformPayService.updateById(pf);PlatformPayFlow platformpayflow = new PlatformPayFlow();platformpayflow.setPlatform_pay_id(pf.getId());platformpayflow.setInfo("编号["+pf.getPay_no()+"]店铺保证金，支付成功");platformpayflow.setCreate_date(new Date());this.platformPayFlowService.saveEntity(platformpayflow);UserDto user = userFeignClient.selectByPrimaryKey(pf.getUser_id());StoreDto store = this.storeFeignClient.selectByPrimaryKey(user.getStore_id());store.setDeposit(pf.getAmount());this.storeFeignClient.updateById(store);}}}
}

java版Spring Cloud+Mybatis 微服务商城 b2b2c商城直播商城小程序商城多商家入驻商城 APP商城源码聚合支付商城相关推荐

java版Spring Cloud+Vue 前后端分离+b2b2c多商家入驻电子商务源码
涉及平台:商家端(PC端.手机端).平台管理(包含自营店面).买家平台(PC端.H5/公众号.小程序.APP端(IOS/Android).微服务核心架构:Mybatis Plus.Spring Cl ...
从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（三） (mini-cloud) 搭建认证服务（认证/资源分离版） oauth2.0 (中)
本文承接上文<从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(三) (mini-cloud) 搭建认证服务(认证/资源分离版) oauth2.0 (上)> ...
Spring Cloud构建微服务架构：分布式服务跟踪（整合zipkin）【Dalston版】
通过上一篇<分布式服务跟踪(整合logstash)>,我们虽然已经能够利用ELK平台提供的收集.存储.搜索等强大功能,对跟踪信息的管理和使用已经变得非常便利.但是,在ELK平台中的数据分析 ...
Spring Cloud构建微服务架构：Hystrix监控数据聚合【Dalston版】
上一篇我们介绍了使用Hystrix Dashboard来展示Hystrix用于熔断的各项度量指标.通过Hystrix Dashboard,我们可以方便的查看服务实例的综合情况,比如:服务调用次数.服务 ...
Spring Cloud构建微服务架构：服务网关（路由配置）【Dalston版】
在上一篇<Spring Cloud构建微服务架构:服务网关(基础)>一文中,我们通过使用Spring Cloud Zuul构建了一个基础的API网关服务,同时也演示了Spring Clou ...
Spring Cloud构建微服务架构：分布式服务跟踪（整合logstash）【Dalston版】
通过之前的<入门示例>,我们已经为两个由SpringCloud构建的微服务项目 trace-1和 trace-2引入了Spring Cloud Sleuth的基础模块 spring-clo ...
Spring Cloud构建微服务架构：服务注册与发现（Eureka、Consul）【Dalston版】
Spring Cloud简介 Spring Cloud是一个基于Spring Boot实现的云应用开发工具,它为基于JVM的云应用开发中涉及的配置管理.服务发现.断路器.智能路由.微代理.控制总线.全 ...
Spring Cloud构建微服务架构：分布式配置中心【Dalston版】
Spring Cloud Config是Spring Cloud团队创建的一个全新项目,用来为分布式系统中的基础设施和微服务应用提供集中化的外部配置支持,它分为服务端与客户端两个部分.其中服务端也称为 ...
Spring Cloud构建微服务架构：服务容错保护（Hystrix服务降级）【Dalston版】
前言在微服务架构中,我们将系统拆分成了一个个的服务单元,各单元应用间通过服务注册与订阅的方式互相依赖.由于每个单元都在不同的进程中运行,依赖通过远程调用的方式执行,这样就有可能因为网络原因或是依赖服 ...

java版Spring Cloud+Mybatis 微服务商城 b2b2c商城直播商城小程序商城多商家入驻商城 APP商城源码聚合支付商城

java版Spring Cloud+Mybatis 微服务商城 b2b2c商城直播商城小程序商城多商家入驻商城 APP商城源码聚合支付商城相关推荐

最新文章

热门文章

java版Spring Cloud+Mybatis 微服务商城 b2b2c商城 直播商城 小程序商城 多商家入驻商城 APP商城源码 聚合支付商城

java版Spring Cloud+Mybatis 微服务商城 b2b2c商城 直播商城 小程序商城 多商家入驻商城 APP商城源码 聚合支付商城相关推荐

最新文章

热门文章

java版Spring Cloud+Mybatis 微服务商城 b2b2c商城直播商城小程序商城多商家入驻商城 APP商城源码聚合支付商城

java版Spring Cloud+Mybatis 微服务商城 b2b2c商城直播商城小程序商城多商家入驻商城 APP商城源码聚合支付商城相关推荐