parent
d1facad8e6
commit
d781ef71b7
@ -0,0 +1,141 @@ |
||||
package com.bweb.controller; |
||||
|
||||
import com.bweb.controller.goods.GoodsController; |
||||
import com.hfkj.common.exception.ErrorCode; |
||||
import com.hfkj.common.exception.ErrorHelp; |
||||
import com.hfkj.common.exception.SysCode; |
||||
import com.hfkj.common.security.SessionObject; |
||||
import com.hfkj.common.security.UserCenter; |
||||
import com.hfkj.common.utils.ResponseMsgUtil; |
||||
import com.hfkj.entity.BsProductConfig; |
||||
import com.hfkj.model.ResponseData; |
||||
import com.hfkj.model.SecUserSessionObject; |
||||
import com.hfkj.service.BsProductConfigService; |
||||
import com.hfkj.sysenum.order.OrderChildProductTypeEnum; |
||||
import io.swagger.annotations.Api; |
||||
import io.swagger.annotations.ApiOperation; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.stereotype.Controller; |
||||
import org.springframework.web.bind.annotation.*; |
||||
|
||||
import javax.annotation.Resource; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import java.util.Date; |
||||
|
||||
|
||||
@Controller |
||||
@RequestMapping(value="/productConfig") |
||||
@Api(value="商户产品折扣配置") |
||||
public class BsProductConfigController { |
||||
|
||||
private static final Logger log = LoggerFactory.getLogger(GoodsController.class); |
||||
|
||||
@Resource |
||||
private UserCenter userCenter; |
||||
|
||||
@Resource |
||||
private BsProductConfigService bsProductConfigService; |
||||
|
||||
|
||||
@RequestMapping(value="/editProductConfig",method = RequestMethod.POST) |
||||
@ResponseBody |
||||
@ApiOperation(value = "编辑产品配置") |
||||
public ResponseData editProductConfig(@RequestBody BsProductConfig body, HttpServletRequest request) { |
||||
try { |
||||
|
||||
SessionObject sessionObject = userCenter.getSessionObject(request); |
||||
SecUserSessionObject userModel = (SecUserSessionObject) sessionObject.getObject(); |
||||
|
||||
if (body == null |
||||
|| body.getMerId() == null |
||||
|| body.getProductType() == null |
||||
) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); |
||||
} |
||||
|
||||
BsProductConfig productConfig = bsProductConfigService.queryDetail(body.getProductType()); |
||||
|
||||
if (productConfig != null && !productConfig.getMerId().equals(body.getMerId())) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "当前产品已有商户配置，不可配置！"); |
||||
} |
||||
|
||||
if (productConfig != null) { |
||||
body.setId(productConfig.getId()); |
||||
} |
||||
|
||||
BsProductConfig bsProductConfig; |
||||
|
||||
if (body.getId() != null) { |
||||
// 查询
|
||||
bsProductConfig = bsProductConfigService.queryDetail(body.getId()); |
||||
if (bsProductConfig == null) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.CONTENT_NOT_FOUND, ""); |
||||
} |
||||
} else { |
||||
bsProductConfig = new BsProductConfig(); |
||||
bsProductConfig.setCreateTime(new Date()); |
||||
|
||||
} |
||||
bsProductConfig.setProductType(body.getProductType()); |
||||
bsProductConfig.setDiscount(body.getDiscount()); |
||||
bsProductConfig.setMerId(body.getMerId()); |
||||
bsProductConfig.setUpdateTime(new Date()); |
||||
bsProductConfig.setStatus(1); |
||||
|
||||
OrderChildProductTypeEnum typeEnum = OrderChildProductTypeEnum.getData(body.getProductType()); |
||||
if (typeEnum == null) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "当前产品类型未配置！"); |
||||
} |
||||
|
||||
bsProductConfig.setProductName(typeEnum.getName()); |
||||
bsProductConfig.setOpId(userModel.getAccount().getId()); |
||||
bsProductConfig.setOpName(userModel.getAccount().getUserName()); |
||||
|
||||
if (body.getId() != null) { |
||||
bsProductConfigService.update(bsProductConfig); |
||||
} else { |
||||
bsProductConfigService.create(bsProductConfig); |
||||
} |
||||
|
||||
return ResponseMsgUtil.success("操作成功"); |
||||
|
||||
} catch (Exception e) { |
||||
log.error("error!",e); |
||||
return ResponseMsgUtil.exception(e); |
||||
} |
||||
|
||||
} |
||||
|
||||
@RequestMapping(value="/getList",method = RequestMethod.GET) |
||||
@ResponseBody |
||||
@ApiOperation(value = "查询列表") |
||||
public ResponseData getList(@RequestParam(value = "merId" , required = false) Long merId) { |
||||
try { |
||||
|
||||
return ResponseMsgUtil.success(bsProductConfigService.getList(merId)); |
||||
|
||||
} catch (Exception e) { |
||||
log.error("error!",e); |
||||
return ResponseMsgUtil.exception(e); |
||||
} |
||||
} |
||||
|
||||
@RequestMapping(value="/delete",method = RequestMethod.GET) |
||||
@ResponseBody |
||||
@ApiOperation(value = "删除") |
||||
public ResponseData delete(@RequestParam(value = "id" , required = false) Long id) { |
||||
try { |
||||
|
||||
|
||||
bsProductConfigService.delete(id , false); |
||||
|
||||
return ResponseMsgUtil.success("删除成功"); |
||||
|
||||
} catch (Exception e) { |
||||
log.error("error!",e); |
||||
return ResponseMsgUtil.exception(e); |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,85 @@ |
||||
package com.order.controller.business; |
||||
|
||||
import com.github.pagehelper.PageHelper; |
||||
import com.github.pagehelper.PageInfo; |
||||
import com.hfkj.common.security.SessionObject; |
||||
import com.hfkj.common.security.UserCenter; |
||||
import com.hfkj.common.utils.ResponseMsgUtil; |
||||
import com.hfkj.model.ResponseData; |
||||
import com.hfkj.model.SecUserSessionObject; |
||||
import com.hfkj.service.goods.BsOrderCinemaService; |
||||
import com.hfkj.sysenum.SecUserObjectTypeEnum; |
||||
import io.swagger.annotations.Api; |
||||
import io.swagger.annotations.ApiOperation; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.stereotype.Controller; |
||||
import org.springframework.web.bind.annotation.RequestMapping; |
||||
import org.springframework.web.bind.annotation.RequestMethod; |
||||
import org.springframework.web.bind.annotation.RequestParam; |
||||
import org.springframework.web.bind.annotation.ResponseBody; |
||||
|
||||
import javax.annotation.Resource; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
|
||||
@Controller |
||||
@RequestMapping(value="/orderCinema") |
||||
@Api(value="电影票订单管理") |
||||
public class BsOrderCinemaController { |
||||
private static final Logger log = LoggerFactory.getLogger(BsOrderCinemaController.class); |
||||
|
||||
@Resource |
||||
private UserCenter userCenter; |
||||
|
||||
@Resource |
||||
private BsOrderCinemaService bsOrderCinemaService; |
||||
|
||||
|
||||
@RequestMapping(value="/getListCinema",method = RequestMethod.GET) |
||||
@ResponseBody |
||||
@ApiOperation(value = "查询列表") |
||||
public ResponseData getListCinema( |
||||
@RequestParam(value = "orderNo" , required = false) String orderNo, |
||||
@RequestParam(value = "childOrderNo" , required = false) String childOrderNo, |
||||
@RequestParam(value = "userPhone" , required = false) String userPhone, |
||||
@RequestParam(value = "goodsSpecsName" , required = false) String goodsSpecsName, |
||||
@RequestParam(value = "goodsName" , required = false) String goodsName, |
||||
@RequestParam(value = "payType" , required = false) Integer payType, |
||||
@RequestParam(value = "status" , required = false) Integer status, |
||||
@RequestParam(value = "createTimeS" , required = false) Long createTimeS, |
||||
@RequestParam(value = "createTimeE" , required = false) Long createTimeE, |
||||
@RequestParam(value = "pageNum" , required = true) Integer pageNum, |
||||
@RequestParam(value = "pageSize" , required = true) Integer pageSize, HttpServletRequest request) { |
||||
try { |
||||
|
||||
SessionObject sessionObject = userCenter.getSessionObject(request); |
||||
SecUserSessionObject userModel = (SecUserSessionObject) sessionObject.getObject(); |
||||
|
||||
Map<String , Object> map = new HashMap<>(); |
||||
|
||||
if (userModel.getAccount().getObjectType().equals(SecUserObjectTypeEnum.type2.getCode())) { |
||||
map.put("merId", userModel.getAccount().getObjectId()); |
||||
} |
||||
|
||||
map.put("orderNo", orderNo); |
||||
map.put("childOrderNo", childOrderNo); |
||||
map.put("userPhone", userPhone); |
||||
map.put("goodsSpecsName", goodsSpecsName); |
||||
map.put("goodsName", goodsName); |
||||
map.put("payType", payType); |
||||
map.put("createTimeS", createTimeS); |
||||
map.put("createTimeE", createTimeE); |
||||
map.put("status", status); |
||||
PageHelper.startPage(pageNum, pageSize); |
||||
|
||||
return ResponseMsgUtil.success(new PageInfo<>(bsOrderCinemaService.getList(map))); |
||||
|
||||
} catch (Exception e) { |
||||
log.error("error!",e); |
||||
return ResponseMsgUtil.exception(e); |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,49 @@ |
||||
package com.order.controller.notify; |
||||
|
||||
import com.alibaba.fastjson.JSONObject; |
||||
import io.swagger.annotations.Api; |
||||
import io.swagger.annotations.ApiOperation; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.stereotype.Controller; |
||||
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.ResponseBody; |
||||
|
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.io.PrintWriter; |
||||
|
||||
@Controller |
||||
@RequestMapping(value = "/cinemaNotify") |
||||
@Api(value = "千猪电影票通知") |
||||
public class QzCinemaNotify { |
||||
|
||||
private static final Logger log = LoggerFactory.getLogger(QzCinemaNotify.class); |
||||
|
||||
@RequestMapping(value = "/notify", method = RequestMethod.POST) |
||||
@ApiOperation(value = "回调") |
||||
@ResponseBody |
||||
public void notify(@RequestBody String reqBodyStr, HttpServletRequest request, HttpServletResponse response) { |
||||
try { |
||||
|
||||
JSONObject dataObject = JSONObject.parseObject(reqBodyStr, JSONObject.class); |
||||
|
||||
log.info("============回调任务Start============="); |
||||
log.info("尖椒订单充值-回调参数: " + dataObject); |
||||
log.info("============回调任务End============="); |
||||
|
||||
|
||||
response.setCharacterEncoding("UTF-8"); |
||||
response.setContentType("text/html;charset=utf-8"); |
||||
PrintWriter writer= response.getWriter(); |
||||
writer.write("SUCCESS"); |
||||
|
||||
|
||||
} catch (Exception e) { |
||||
log.error("WechatPayController --> wechatNotify() error!", e); |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,78 @@ |
||||
package com.hfkj.service; |
||||
|
||||
import com.hfkj.entity.BsProductConfig; |
||||
|
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
public interface BsProductConfigService { |
||||
|
||||
/** |
||||
* @MethodName create |
||||
* @Description:创建 |
||||
* @param productConfig |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/3 下午5:20 |
||||
*/ |
||||
void create(BsProductConfig productConfig); |
||||
|
||||
/** |
||||
* @MethodName update |
||||
* @Description:更新 |
||||
* @param productConfig |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/3 下午5:20 |
||||
*/ |
||||
void update(BsProductConfig productConfig); |
||||
|
||||
/** |
||||
* @MethodName delete |
||||
* @Description:删除 |
||||
* @param id |
||||
* @param fullDelete |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/3 下午5:20 |
||||
*/ |
||||
void delete(Long id , Boolean fullDelete); |
||||
|
||||
/** |
||||
* @MethodName queryDetail |
||||
* @Description:根据id查询 |
||||
* @param id |
||||
* @return: com.hfkj.entity.BsProductConfig |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/3 下午5:20 |
||||
*/ |
||||
BsProductConfig queryDetail(Long id); |
||||
|
||||
/** |
||||
* @MethodName queryDetailByProductType |
||||
* @Description:根据产品类型查询 |
||||
* @param productType |
||||
* @return: com.hfkj.entity.BsProductConfig |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/3 下午5:20 |
||||
*/ |
||||
BsProductConfig queryDetail(Integer productType); |
||||
|
||||
/** |
||||
* @MethodName queryDetailByMap |
||||
* @Description:根据map查询 |
||||
* @param map |
||||
* @return: com.hfkj.entity.BsProductConfig |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/3 下午5:20 |
||||
*/ |
||||
BsProductConfig queryDetailByMap(Map<String , Object> map); |
||||
|
||||
/** |
||||
* @MethodName getList |
||||
* @Description:根据map查询列表 |
||||
* @param merId |
||||
* @return: java.util.List<com.hfkj.entity.BsProductConfig> |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/3 下午5:20 |
||||
*/ |
||||
List<BsProductConfig> getList(Long merId); |
||||
|
||||
} |
||||
@ -0,0 +1,77 @@ |
||||
package com.hfkj.service.goods; |
||||
|
||||
import com.hfkj.entity.BsOrderCinema; |
||||
|
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
public interface BsOrderCinemaService { |
||||
|
||||
/** |
||||
* @MethodName create |
||||
* @Description: 创建 |
||||
* @param orderCinema |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/4 下午2:30 |
||||
*/ |
||||
void create(BsOrderCinema orderCinema); |
||||
|
||||
/** |
||||
* @MethodName update |
||||
* @Description: 更新 |
||||
* @param orderCinema |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/4 下午2:30 |
||||
*/ |
||||
void update(BsOrderCinema orderCinema); |
||||
|
||||
/** |
||||
* @MethodName delete |
||||
* @Description: 删除 |
||||
* @param id |
||||
* @param fullDelete |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/4 下午2:30 |
||||
*/ |
||||
void delete(Long id , Boolean fullDelete); |
||||
|
||||
/** |
||||
* @MethodName queryDetail |
||||
* @Description:查询详情 |
||||
* @param id |
||||
* @return: com.hfkj.entity.BsOrderCinema |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/4 下午2:30 |
||||
*/ |
||||
BsOrderCinema queryDetail(Long id); |
||||
|
||||
/** |
||||
* @MethodName findGoodsOrder |
||||
* @Description: |
||||
* @param orderNo |
||||
* @return: com.hfkj.entity.BsOrderCinema |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/4 下午2:30 |
||||
*/ |
||||
BsOrderCinema findGoodsOrder(String orderNo); |
||||
|
||||
/** |
||||
* @MethodName queryDetailByMap |
||||
* @Description: 查询 |
||||
* @param map |
||||
* @return: com.hfkj.entity.BsOrderCinema |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/4 下午2:34 |
||||
*/ |
||||
BsOrderCinema queryDetailByMap(Map<String , Object> map); |
||||
|
||||
/** |
||||
* @MethodName getList |
||||
* @Description: 查询列表 |
||||
* @param map |
||||
* @return: java.util.List<com.hfkj.entity.BsOrderCinema> |
||||
* @Author: Sum1Dream |
||||
* @Date: 2024/7/4 下午2:35 |
||||
*/ |
||||
List<BsOrderCinema> getList(Map<String , Object> map); |
||||
} |
||||
@ -0,0 +1,109 @@ |
||||
package com.hfkj.service.goods.impl; |
||||
|
||||
import com.hfkj.dao.BsOrderCinemaMapper; |
||||
import com.hfkj.entity.BsOrderCinema; |
||||
import com.hfkj.entity.BsOrderCinemaExample; |
||||
import com.hfkj.entity.BsOrderGoods; |
||||
import com.hfkj.entity.BsOrderGoodsExample; |
||||
import com.hfkj.service.goods.BsOrderCinemaService; |
||||
import org.apache.commons.collections4.MapUtils; |
||||
import org.apache.commons.lang3.StringUtils; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import javax.annotation.Resource; |
||||
import java.util.Collections; |
||||
import java.util.Date; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
@Service("bsOrderCinemaService") |
||||
public class BsOrderCinemaServiceImpl implements BsOrderCinemaService { |
||||
|
||||
@Resource |
||||
private BsOrderCinemaMapper bsOrderCinemaMapper; |
||||
|
||||
@Override |
||||
public void create(BsOrderCinema orderCinema) { |
||||
bsOrderCinemaMapper.insert(orderCinema); |
||||
} |
||||
|
||||
@Override |
||||
public void update(BsOrderCinema orderCinema) { |
||||
bsOrderCinemaMapper.updateByPrimaryKeySelective(orderCinema); |
||||
} |
||||
|
||||
@Override |
||||
public void delete(Long id, Boolean fullDelete) { |
||||
bsOrderCinemaMapper.deleteByPrimaryKey(id); |
||||
} |
||||
|
||||
@Override |
||||
public BsOrderCinema queryDetail(Long id) { |
||||
return bsOrderCinemaMapper.selectByPrimaryKey(id); |
||||
} |
||||
|
||||
@Override |
||||
public BsOrderCinema findGoodsOrder(String orderNo) { |
||||
BsOrderCinemaExample example = new BsOrderCinemaExample(); |
||||
example.createCriteria().andOrderNoEqualTo(orderNo); |
||||
|
||||
List<BsOrderCinema> list = bsOrderCinemaMapper.selectByExample(example); |
||||
|
||||
if (!list.isEmpty()) { |
||||
return list.get(0); |
||||
} |
||||
|
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public BsOrderCinema queryDetailByMap(Map<String, Object> map) { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public List<BsOrderCinema> getList(Map<String, Object> map) { |
||||
BsOrderCinemaExample example = new BsOrderCinemaExample(); |
||||
BsOrderCinemaExample.Criteria criteria = example.createCriteria(); |
||||
|
||||
|
||||
if (MapUtils.getLong(map, "merId") != null) { |
||||
criteria.andMerIdEqualTo(MapUtils.getLong(map, "merId")); |
||||
} |
||||
|
||||
if (StringUtils.isNotBlank(MapUtils.getString(map, "orderNo"))) { |
||||
criteria.andOrderNoEqualTo(MapUtils.getString(map, "orderNo")); |
||||
} |
||||
if (StringUtils.isNotBlank(MapUtils.getString(map, "childOrderNo"))) { |
||||
criteria.andChildOrderNoEqualTo(MapUtils.getString(map, "childOrderNo")); |
||||
} |
||||
if (StringUtils.isNotBlank(MapUtils.getString(map, "userPhone"))) { |
||||
criteria.andUserPhoneEqualTo(MapUtils.getString(map, "userPhone")); |
||||
} |
||||
|
||||
if (StringUtils.isNotBlank(MapUtils.getString(map, "goodsSpecsName"))) { |
||||
criteria.andGoodsSpecsNameEqualTo(MapUtils.getString(map, "goodsSpecsName")); |
||||
} |
||||
|
||||
if (StringUtils.isNotBlank(MapUtils.getString(map, "goodsName"))) { |
||||
criteria.andGoodsNameLike("%"+MapUtils.getString(map, "goodsName")+"%"); |
||||
} |
||||
|
||||
if (MapUtils.getInteger(map, "payType") != null) { |
||||
criteria.andPayTypeEqualTo(MapUtils.getInteger(map, "payType")); |
||||
} |
||||
if (MapUtils.getLong(map, "createTimeS") != null) { |
||||
criteria.andCreateTimeGreaterThanOrEqualTo(new Date(MapUtils.getLong(map, "createTimeS"))); |
||||
} |
||||
if (MapUtils.getLong(map, "createTimeE") != null) { |
||||
criteria.andCreateTimeLessThan(new Date(MapUtils.getLong(map, "createTimeE"))); |
||||
} |
||||
if (MapUtils.getInteger(map, "status") != null) { |
||||
criteria.andStatusEqualTo(MapUtils.getInteger(map, "status")); |
||||
} else { |
||||
criteria.andStatusNotEqualTo(0); |
||||
} |
||||
example.setOrderByClause("create_time desc"); |
||||
return bsOrderCinemaMapper.selectByExample(example); |
||||
} |
||||
} |
||||
@ -0,0 +1,73 @@ |
||||
package com.hfkj.service.impl; |
||||
|
||||
import com.hfkj.dao.BsProductConfigMapper; |
||||
import com.hfkj.entity.BsProductConfig; |
||||
import com.hfkj.entity.BsProductConfigExample; |
||||
import com.hfkj.service.BsProductConfigService; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import javax.annotation.Resource; |
||||
import java.util.Date; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
@Service("bsProductConfigService") |
||||
public class BsProductConfigServiceImpl implements BsProductConfigService { |
||||
|
||||
@Resource |
||||
private BsProductConfigMapper bsProductConfigMapper; |
||||
|
||||
@Override |
||||
public void create(BsProductConfig productConfig) { |
||||
bsProductConfigMapper.insert(productConfig); |
||||
} |
||||
|
||||
@Override |
||||
public void update(BsProductConfig productConfig) { |
||||
bsProductConfigMapper.updateByPrimaryKeySelective(productConfig); |
||||
} |
||||
|
||||
@Override |
||||
public void delete(Long id, Boolean fullDelete) { |
||||
if (fullDelete) { |
||||
bsProductConfigMapper.deleteByPrimaryKey(id); |
||||
} else { |
||||
BsProductConfig productConfig = queryDetail(id); |
||||
productConfig.setStatus(0); |
||||
productConfig.setUpdateTime(new Date()); |
||||
update(productConfig); |
||||
} |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public BsProductConfig queryDetail(Long id) { |
||||
return bsProductConfigMapper.selectByPrimaryKey(id); |
||||
} |
||||
|
||||
@Override |
||||
public BsProductConfig queryDetail(Integer productType) { |
||||
BsProductConfigExample example = new BsProductConfigExample(); |
||||
example.createCriteria().andProductTypeEqualTo(productType).andStatusEqualTo(1); |
||||
|
||||
List<BsProductConfig> list = bsProductConfigMapper.selectByExample(example); |
||||
|
||||
if (!list.isEmpty()) { |
||||
return list.get(0); |
||||
} |
||||
|
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public BsProductConfig queryDetailByMap(Map<String, Object> map) { |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public List<BsProductConfig> getList(Long merId) { |
||||
BsProductConfigExample example = new BsProductConfigExample(); |
||||
example.createCriteria().andMerIdEqualTo(merId).andStatusEqualTo(1); |
||||
return bsProductConfigMapper.selectByExample(example); |
||||
} |
||||
} |
||||
@ -0,0 +1,74 @@ |
||||
package com.hfkj.service.order; |
||||
|
||||
import com.alibaba.fastjson.JSONObject; |
||||
import com.hfkj.common.exception.ErrorCode; |
||||
import com.hfkj.common.exception.ErrorHelp; |
||||
import com.hfkj.common.exception.SysCode; |
||||
import com.hfkj.config.CommonSysConst; |
||||
import com.hfkj.entity.BsOrderChild; |
||||
import com.hfkj.entity.BsOrderCinema; |
||||
import com.hfkj.model.order.OrderChildModel; |
||||
import com.hfkj.model.order.OrderModel; |
||||
import com.hfkj.qianzhu.channel.CinemaService; |
||||
import com.hfkj.service.goods.BsOrderCinemaService; |
||||
import com.hfkj.sysenum.order.OrderChildProductTypeEnum; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import javax.annotation.Resource; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
|
||||
|
||||
/** |
||||
* @ClassName OrderRefundSuccessService |
||||
* @Author Sum1Dream |
||||
* @Description 退款成功业务处理 |
||||
* @Date 2024/7/4 下午5:31 |
||||
**/ |
||||
@Component |
||||
public class OrderRefundSuccessService { |
||||
|
||||
@Resource |
||||
private BsOrderCinemaService bsOrderCinemaService; |
||||
|
||||
/** |
||||
* 订单业务处理 |
||||
* @param orderChild |
||||
* @throws Exception |
||||
*/ |
||||
public void orderRefundHandle(OrderChildModel orderChild) { |
||||
try { |
||||
if (orderChild.getProductType().equals(OrderChildProductTypeEnum.type1.getCode())) { |
||||
// todo 实物产品退款业务
|
||||
} else if (orderChild.getProductType().equals(OrderChildProductTypeEnum.type2.getCode())) { |
||||
// todo 虚拟产品退款业务
|
||||
} else if (orderChild.getProductType().equals(OrderChildProductTypeEnum.type3.getCode())) { |
||||
// 电影票退款业务
|
||||
cinema(orderChild); |
||||
} |
||||
} catch (Exception e) { |
||||
|
||||
} |
||||
} |
||||
|
||||
public void cinema(BsOrderChild childOrder) { |
||||
// 查询电影票订单
|
||||
BsOrderCinema orderCinema = bsOrderCinemaService.findGoodsOrder(childOrder.getOrderNo()); |
||||
|
||||
try { |
||||
|
||||
if (orderCinema != null) { |
||||
Map<String , Object> map = new HashMap<>(); |
||||
map.put("orderNo", childOrder.getOrderNo()); |
||||
CinemaService.refundMovieOrder(map); |
||||
orderCinema.setStatus(-5); |
||||
bsOrderCinemaService.update(orderCinema); |
||||
} |
||||
} catch (Exception e) { |
||||
orderCinema.setExceptionStatus(true); |
||||
orderCinema.setExceptionMsg(e.getMessage()); |
||||
bsOrderCinemaService.update(orderCinema); |
||||
} |
||||
|
||||
} |
||||
} |
||||
@ -0,0 +1,50 @@ |
||||
package com.hfkj.sysenum.order; |
||||
|
||||
import lombok.Getter; |
||||
|
||||
/** |
||||
* @ClassName OrderCinemaStatusEnum |
||||
* @Author Sum1Dream |
||||
* @Description 电影票状态枚举 |
||||
* @Date 2024/7/4 下午3:32 |
||||
**/ |
||||
@Getter |
||||
public enum OrderCinemaStatusEnum { |
||||
|
||||
/** |
||||
* 待付款 |
||||
*/ |
||||
status0(0, "待付款"), |
||||
|
||||
/** |
||||
* 待出票 |
||||
*/ |
||||
status5(5, "待出票"), |
||||
|
||||
/** |
||||
* 已出票 |
||||
*/ |
||||
status10(10, "已出票"), |
||||
|
||||
/** |
||||
* 已退款 |
||||
*/ |
||||
status15(15, "交易成功"), |
||||
|
||||
/** |
||||
* 已取消 |
||||
*/ |
||||
statusNegative5(-5, "已取消"), |
||||
|
||||
; |
||||
|
||||
private final int code; |
||||
|
||||
private final String name; |
||||
|
||||
|
||||
OrderCinemaStatusEnum(int code, String name) { |
||||
this.code = code; |
||||
this.name = name; |
||||
} |
||||
} |
||||
Loading…
Reference in new issue