Skip to content

G
gdtel-gztel-school-center
Commit a8a1648e by 陈浩建
Options

融合下单

parent 0bebf3ae
Showing with 269 additions and 224 deletions
apply-net/src/main/java/com/winsun/controller/DankuanController.java
......@@ -7,8 +7,10 @@ import com.baomidou.mybatisplus.mapper.Wrapper;
import com.winsun.auth.core.common.model.ResponseData;
import com.winsun.bean.*;
import com.winsun.constant.Constant;
import com.winsun.constant.FilePath;
import com.winsun.constant.OrderStatus;
import com.winsun.mapper.*;
import com.winsun.outSideSystem.IntelligenceSendOrder;
import com.winsun.utils.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
......@@ -25,8 +27,10 @@ import org.apache.http.util.EntityUtils;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.net.URLEncoder;
......@@ -63,6 +67,17 @@ public class DankuanController {
@Autowired
private SysUserMapper sysUserMapper;
@Resource
private RedisTemplate<String, String> redisTemplate;
@Resource
private RedisLockUtil redisLockUtil;
@Autowired
private Base64ToImgUtils base64ToImgUtils;
@Autowired
private IntelligenceSendOrder intelligenceSendOrder;
/**
* 查询单宽办理接口
*
......@@ -93,158 +108,157 @@ public class DankuanController {
/**
* 创建单宽order_view
*
* @param orderName
* @param orderPhone
* @param orderNumber
* @param orderCustomerStudentId
* @param orderCustomerAccount
* @param orderCustomerPwd
* @param orderSetMeal
* @param productId
* @param webOrderAmount
* @param partner
* @return
* @throws Exception
*/
@RequestMapping("/createProductOrder")
public ResponseData<Object> createProductOrder(@RequestParam("orderName") String orderName, @RequestParam("orderPhone") String orderPhone,
@RequestParam("orderNumber") String orderNumber, @RequestParam("orderCustomerStudentId") String orderCustomerStudentId,
@RequestParam("orderCustomerAccount") String orderCustomerAccount, @RequestParam("orderCustomerPwd") String orderCustomerPwd,
@RequestParam("orderSetMeal") String orderSetMeal, @RequestParam("productId") String productId,
@RequestParam("webOrderAmount") String webOrderAmount, @RequestParam("partner") String partner, @RequestParam(value = "setMealIndex") String setMealIndex) throws Exception {
OrderView orderV = new OrderView();
String orderSeq = RandomUtil.RandomNumber(20);
Product product = productMapper.selectById(productId);
OrderView orderView = new OrderView();
orderView.setOrderName(orderName);
orderView.setOrderPhone(orderPhone);
orderView.setOrderNumber(orderNumber);
orderView.setOrderCustomerStudentId(orderCustomerStudentId);
orderView.setOrderCustomerAccount(orderCustomerAccount);
orderView.setOrderCustomerPwd(orderCustomerPwd);
orderView.setOrderSetMeal(orderSetMeal);
orderView.setOrderSeq(orderSeq);
orderView.setProductName(product.getProductTitle());
orderView.setOrderDate(new Date());
orderView.setOrderUniversityName(product.getProductUniversity());
orderView.setStatus(OrderStatus.NOTPAID.getId());
orderView.setHehuorenId(partner);
orderView.setOrderRegion(product.getProductRegion());
orderView.setPayType("1");
orderView.setWebOrderAmount(webOrderAmount);
if (webOrderAmount.equals("0")) {
orderView.setIPay("0");
} else {
orderView.setIPay("1");
}
orderView.setCustomerId("xyzxyql");
orderView.setOrderCustomerType("学生");
if (webOrderAmount.equals("0")) {
ResponseData<Object> res = createOrder(orderView, partner, orderSeq);
@PostMapping("/createProductOrder")
public ResponseData<Object> createProductOrder(HttpServletRequest request,HttpServletRequest response){
String orderName = request.getParameter("orderName");
String orderPhone = request.getParameter("orderPhone");
String orderNumber = request.getParameter("orderNumber");
String banLiPhone = request.getParameter("banLiPhone");
String orderCustomerStudentId = request.getParameter("orderCustomerStudentId");
String orderCustomerAccount = request.getParameter("orderCustomerAccountInfo");
String orderCustomerPwd = request.getParameter("orderCustomerPwd");
String orderSetMeal = request.getParameter("orderSetMeal");
String productId = request.getParameter("productId");
String webOrderAmount = request.getParameter("webOrderAmount");
String partner = request.getParameter("partner");
String setMealIndex = request.getParameter("setMealIndex");
String imgUrl = request.getParameter("imgUrl");
String filePath = "";
try{
String uuid = UUID.randomUUID().toString();
boolean boo1 = redisLockUtil.redisLock(orderNumber,uuid,10);
boolean boo2 = redisLockUtil.redisLock(orderCustomerAccount,uuid,10);
if(!boo1 || !boo2){
return ResponseData.error("重复下单！");
}
if(StringUtils.isBlank(imgUrl)){
return ResponseData.error("签名失败！");
}
if(StringUtils.isNotBlank(imgUrl)){
filePath = base64ToImgUtils.base64ToImg(imgUrl, FilePath.PATH.getValue()+FilePath.IMGURLPATH.getValue());
}
OrderView orderV = new OrderView();
String orderSeq = RandomUtil.RandomNumber(20);
Product product = productMapper.selectById(productId);
OrderView orderView = new OrderView();
orderView.setOrderName(orderName);
orderView.setOrderPhone(orderPhone);
orderView.setOrderNumber(orderNumber);
orderView.setOrderCustomerStudentId(orderCustomerStudentId);
orderView.setOrderCustomerAccount(orderCustomerAccount);
orderView.setOrderCustomerPwd(orderCustomerPwd);
orderView.setOrderSetMeal(orderSetMeal);
orderView.setOrderSeq(orderSeq);
orderView.setProductName(product.getProductTitle());
orderView.setOrderDate(new Date());
orderView.setOrderUniversityName(product.getProductUniversity());
orderView.setStatus(OrderStatus.NOTPAID.getId());
orderView.setHehuorenId(partner);
orderView.setOrderRegion(product.getProductRegion());
orderView.setPayType("1");
orderView.setWebOrderAmount(webOrderAmount);
if (webOrderAmount.equals("0")) {
orderView.setIPay("0");
} else {
orderView.setIPay("1");
}
orderView.setCustomerId("xyzxyql");
orderView.setOrderCustomerType("学生");
ResponseData<Object> res = null;
orderView.setSetMealIndex(setMealIndex);
Integer insert = orderViewMapper.insert(orderView);
if (webOrderAmount.equals("0")) {
res = createOrder(productId,orderView, partner,filePath,"未下单");
Map<String,Object> map = orderMapper.selectKdOrder(orderSeq);
intelligenceSendOrder.singleBroadSendOrder(map);
Order order =(Order) res.getData();
orderV.setOrderRf2(order.getId());
}else {
res = createOrder(productId,orderView, partner,filePath,"未支付");
}
if (!res.isSuccess()) {
return res;
return ResponseData.error("网络超时，请重试!");
}
Order order =(Order) res.getData();
orderV.setOrderRf2(order.getId());
}
orderView.setSetMealIndex(setMealIndex);
Integer insert = orderViewMapper.insert(orderView);
if (insert == 1) {
orderV.setOrderId(orderView.getOrderId());
orderV.setOrderSeq(orderView.getOrderSeq());
orderV.setWebOrderAmount(webOrderAmount);
return ResponseData.success(orderV, "订单提交完成！");
if (insert == 1) {
orderV.setOrderId(orderView.getOrderId());
orderV.setOrderSeq(orderView.getOrderSeq());
orderV.setWebOrderAmount(webOrderAmount);
return ResponseData.success(orderV, "订单提交完成！");
}
return ResponseData.error("提交失败！");
}catch (Exception e){
return ResponseData.error("网络超时，请重试!");
}finally {
redisTemplate.delete(orderNumber);
redisTemplate.delete(orderCustomerAccount);
}
return ResponseData.error("提交失败！");
}
/**
* 0元调用 创建order
* @param orderView
* @param userId
* @param orderseq
* @return
* @throws Exception
*/
public ResponseData<Object> createOrder(OrderView orderView, String userId, String orderseq) throws Exception {
String uuid = UUID.randomUUID().toString();
String id = uuid.split("-")[0] + uuid.split("-")[1];
public ResponseData<Object> createOrder(String productId, OrderView orderView, String userId,String filePath,String orderStatus){
Order order = new Order();
order.setId(id);
order.setOrderNumber(orderView.getOrderSeq());
order.setOrderStatus(OrderStatus.NOTPAID.getName());
order.setHehuorenId(userId);
order.setCustomerName(orderView.getOrderName());
order.setContactNumber(orderView.getOrderPhone());
order.setIdCard(orderView.getOrderNumber());
order.setCreateTime(new Date());
order.setUserType("5");
order.setNetNumber(orderView.getOrderCustomerAccount());
order.setNetPassword(orderView.getOrderCustomerPwd());
order.setUserSchool(orderView.getOrderUniversityName());
order.setExpenses(orderView.getOrderSetMeal());
order.setKdOrderId(orderView.getOrderSeq());
SysUser sysUser = sysUserMapper.selectById(userId);
order.setHehuorenPhone(sysUser.getPhone());
String schoolId = appMapper.selectSchoolId(userId);
School school = schoolMapper.selectById(schoolId);
order.setHehuorenSchool(school.getSchoolName());
order.setHehuorenName(sysUser.getName());
order.setHehuorenArea(sysUser.getSubstName());
List<String> userId1 = appMapper.selectsupervisorBySchool(schoolId);
SysUser user = sysUserMapper.selectById(userId1.get(0));
order.setSupervisorName(user.getName());
order.setLzgh(school.getLzgh());
// 根据学校名称，获取该学校信息
Wrapper<UniversityInfo> wrapper1 = new EntityWrapper<>();
wrapper1.eq("university_name", orderView.getOrderUniversityName());
wrapper1.eq("university_region", orderView.getOrderRegion());
Map<String, Object> schoolMap = universityInfoMapper.selectMaps(wrapper1).get(0);
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
String currentTimeStr = simpleDateFormat.format(new Date());
String productId = "519";
if (StringUtils.isBlank(orderView.getOrderseqThd())) {
JSONObject productJsonObject = getProductId(currentTimeStr);
if (productJsonObject.toString().indexOf("list") == -1) {
return ResponseData.error("未找到产品信息，如有疑问请联系客服！");
}
JSONArray list = productJsonObject.getJSONArray("list");
String productName = "校园宽带0元";
for (int i = 0; i < list.size(); i++) {
JSONObject itmeJson = JSONObject.parseObject(list.get(i).toString());
// 判断获取的全部产品与订单产品符合的拿取对应的ID
if (itmeJson.getString("name").indexOf(productName) != -1) {
productId = itmeJson.getString("id"); // 获取对应产品ID
break;
}
}
}
String saleId = "1475"; // 销售id
JSONObject saleJsonObject = getSaleId(productId, currentTimeStr); // 获取销售ID
log.info("----------调用智能平台的获取销售品接口返回值：" + saleJsonObject);
JSONArray saleList = saleJsonObject.getJSONArray("list");
JSONObject itmeJson = JSONObject.parseObject(saleList.get(0).toString());
saleId = itmeJson.getString("saleId");
JSONObject submitOrderJsonObject = getOrderInfo(schoolMap, orderView, currentTimeStr, productId, saleId, "", "00000", "0元", "00000");
String orderNum = (String) submitOrderJsonObject.get("orderNumber");
if (StringUtils.isNotBlank(orderNum)) {
Wrapper<OrderView> wrapper = new EntityWrapper<>();
wrapper.eq("orderSeq", orderseq);
Map<String, Object> dataMapping1 = new HashMap<>();
dataMapping1.put("orderSeqTHD", orderNum);
dataMapping1.put("status", "已支付");
orderViewMapper.updateForSet(MyBatisPlusUpdateUtils.toUpdateSet(dataMapping1), wrapper);
order.setOrderStatus("审核中");
order.setOrderId(orderNum);
order.setThStatus(submitOrderJsonObject.get("status").toString());
try{
String uuid = UUID.randomUUID().toString();
String id = uuid.split("-")[0] + uuid.split("-")[1];
order.setId(id);
order.setOrderNumber(orderView.getOrderSeq().toString());
order.setOrderStatus(OrderStatus.NOTPAID.getName().toString());
order.setHehuorenId(userId);
order.setCustomerName(orderView.getOrderName());
order.setContactNumber(orderView.getOrderPhone());
order.setIdCard(orderView.getOrderNumber().toString());
order.setCreateTime(new Date());
order.setUserType("5");
order.setKapin("单宽业务");
order.setStudenCard(orderView.getOrderCustomerStudentId().toString());
order.setNetNumber(orderView.getOrderCustomerAccount().toString());
order.setNetPassword(orderView.getOrderCustomerPwd().toString());
order.setUserSchool(orderView.getOrderUniversityName().toString());
order.setExpenses(orderView.getOrderSetMeal().toString());
order.setKdOrderId(orderView.getOrderSeq().toString());
SysUser sysUser = sysUserMapper.selectById(userId);
order.setHehuorenPhone(sysUser.getPhone());
String schoolId = appMapper.selectSchoolId(userId);
School school = schoolMapper.selectById(schoolId);
order.setHehuorenSchool(school.getSchoolName());
order.setHehuorenName(sysUser.getName());
order.setHehuorenArea(sysUser.getSubstName());
order.setSignImg(filePath);
List<String> userId1 = appMapper.selectsupervisorBySchool(schoolId);
SysUser user = sysUserMapper.selectById(userId1.get(0));
order.setSupervisorName(user.getName());
order.setLzgh(school.getLzgh());
order.setOrderStatus(orderStatus);
// 根据订单号，获取该订单信息
// 根据学校名称，获取该学校信息
Product product = productMapper.selectById(productId);
Wrapper<UniversityInfo> uiWrapper = new EntityWrapper<>();
uiWrapper.eq("university_id", product.getUniversityId());
Map<String, Object> schoolMap = universityInfoMapper.selectMaps(uiWrapper).get(0);
orderMapper.insert(order);
appMapper.inserOrderHis(id, "待审核！", new Date(), orderView.getOrderName());
} else {
return ResponseData.error("智能平台订单创建失败，如有疑问请联系客服！");
}catch (Exception e){
e.getMessage();
Wrapper<OrderView> wrapper = new EntityWrapper<>();
wrapper.eq(StringUtils.isNotBlank(orderView.getOrderSeq().toString()), "orderSeq", orderView.getOrderSeq().toString());
orderViewMapper.delete(wrapper);
return ResponseData.error("订单创建失败");
}
return ResponseData.success(order, "智能平台订单创建成功");
return ResponseData.success(order, "订单创建成功");
}
/**
......
apply-net/src/main/java/com/winsun/controller/RongHeController.java
......@@ -125,12 +125,12 @@ public class RongHeController {
* 支付平台异步更新后台地址，主要对订单进去保存和提交订单到智能平台上
*
* @return
* @throws Exception
*/
@PostMapping("/createRongHeOrder")
public ResponseData<Object> createRongHeOrder(HttpServletRequest request,HttpServletRequest response){
String orderName = request.getParameter("orderName");
String orderPhone = request.getParameter("orderPhone");
String banLiPhone = request.getParameter("banLiPhone");
String orderNumber = request.getParameter("orderNumber");
String orderCustomerStudentId = request.getParameter("orderCustomerStudentId");
String orderCustomerAccount = request.getParameter("orderCustomerAccountInfo");
......@@ -139,7 +139,6 @@ public class RongHeController {
String productId = request.getParameter("productId");
String webOrderAmount = request.getParameter("webOrderAmount");
String partner = request.getParameter("partner");
String banLiPhone = request.getParameter("banLiPhone");
String rhTime = request.getParameter("rhTime");
String setMealIndex = request.getParameter("setMealIndex");
String imgUrl = request.getParameter("imgUrl");
......@@ -204,6 +203,9 @@ public class RongHeController {
prices = priceArry[index] + "元";
}
if(StringUtils.isBlank(expenses)){
expenses = "";
}
orderView.setExpenses(expenses+byStr);
orderView.setProductName(product.getProductTitle());// 产品名称
orderView.setOrderDate(new Date()); // 提交时间
......@@ -227,6 +229,8 @@ public class RongHeController {
ResponseData<Object> res = null;
if (webOrderAmount.equals("0")) {
res = createOrder(productId, orderView, partner, rhTime,filePath,"未下单");
Order order =(Order) res.getData();
orderV.setOrderRf2(order.getId());
}else {
res = createOrder(productId, orderView, partner, rhTime,filePath,"未支付");
}
......@@ -234,8 +238,7 @@ public class RongHeController {
if (!res.isSuccess()) {
return ResponseData.error("网络超时，请重试!");
}
Order order =(Order) res.getData();
orderV.setOrderRf2(order.getId());
orderView.setSetMealIndex(setMealIndex);
Integer insert = 0;
......@@ -258,61 +261,67 @@ public class RongHeController {
}
public ResponseData<Object> createOrder(String productId, OrderView orderView, String userId, String rhTime,String filePath,String orderStatus){
String uuid = UUID.randomUUID().toString();
String id = uuid.split("-")[0] + uuid.split("-")[1];
Order order = new Order();
order.setId(id);
SimpleDateFormat sd = new SimpleDateFormat("yyyyMMdd");
SimpleDateFormat sd2 = new SimpleDateFormat("yyyyMM");
String orderNumber = "YRYM" + sd.format(new Date()) + uuid.substring(1, 12);
SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd");
Date parse = null;
try {
parse = simpleDateFormat1.parse(rhTime);
} catch (ParseException e) {
e.printStackTrace();
String uuid = UUID.randomUUID().toString();
String id = uuid.split("-")[0] + uuid.split("-")[1];
order.setId(id);
SimpleDateFormat sd = new SimpleDateFormat("yyyyMMdd");
SimpleDateFormat sd2 = new SimpleDateFormat("yyyyMM");
String orderNumber = "YRYM" + sd.format(new Date()) + uuid.substring(1, 12);
SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd");
Date parse = null;
try {
parse = simpleDateFormat1.parse(rhTime);
} catch (ParseException e) {
e.printStackTrace();
}
order.setRhTime(parse);
order.setOrderNumber(orderNumber);
order.setOrderStatus(OrderStatus.NOTPAID.getName());
order.setHehuorenId(userId);
order.setCustomerName(orderView.getOrderName());
order.setContactNumber(orderView.getOrderPhone());
order.setBusinessNumber(orderView.getOrderCustomerRemarks());
order.setIdCard(orderView.getOrderNumber());
order.setCreateTime(new Date());
order.setUpdateTime(new Date());
order.setUserType("3");
order.setKapin("融合办理");
order.setStudenCard(orderView.getOrderCustomerStudentId().toString());
order.setNetNumber(orderView.getOrderCustomerAccount().toString());
order.setNetPassword(orderView.getOrderCustomerPwd().toString());
order.setUserSchool(orderView.getOrderUniversityName().toString());
order.setExpenses(orderView.getOrderSetMeal().toString());
order.setKdOrderId(orderView.getOrderSeq().toString());
SysUser sysUser = sysUserMapper.selectById(userId);
order.setHehuorenPhone(sysUser.getPhone().toString());
String schoolId = appMapper.selectSchoolId(userId);
School school = schoolMapper.selectById(schoolId);
order.setHehuorenSchool(school.getSchoolName());
order.setHehuorenName(sysUser.getName());
order.setPackageId(productId);
order.setHehuorenArea(sysUser.getSubstName());
order.setSignImg(filePath);
List<String> userId1 = appMapper.selectsupervisorBySchool(schoolId);
SysUser user = sysUserMapper.selectById(userId1.get(0));
order.setSupervisorName(user.getName());
order.setLzgh(school.getLzgh());
// 根据订单号，获取该订单信息
// 根据学校名称，获取该学校信息
Product product = productMapper.selectById(productId);
Wrapper<UniversityInfo> uiWrapper = new EntityWrapper<>();
uiWrapper.eq("university_id", product.getUniversityId());
List<Map<String, Object>> list1 = universityInfoMapper.selectMaps(uiWrapper);
order.setOrderStatus(orderStatus);
orderMapper.insert(order);
appMapper.inserOrderHis(id, "待下单！", new Date(), orderView.getOrderName());
}catch (Exception e){
e.getMessage();
}
order.setRhTime(parse);
order.setOrderNumber(orderNumber);
order.setOrderStatus(OrderStatus.NOTPAID.getName());
order.setHehuorenId(userId);
order.setCustomerName(orderView.getOrderName());
order.setContactNumber(orderView.getOrderPhone());
order.setBusinessNumber(orderView.getOrderPhone());
order.setIdCard(orderView.getOrderNumber());
order.setCreateTime(new Date());
order.setUpdateTime(new Date());
order.setUserType("3");
order.setKapin("融合办理");
order.setStudenCard(orderView.getOrderCustomerStudentId());
order.setNetNumber(orderView.getOrderCustomerAccount().toString());
order.setNetPassword(orderView.getOrderCustomerPwd().toString());
order.setUserSchool(orderView.getOrderUniversityName().toString());
order.setExpenses(orderView.getOrderSetMeal().toString());
order.setKdOrderId(orderView.getOrderSeq().toString());
SysUser sysUser = sysUserMapper.selectById(userId);
order.setHehuorenPhone(sysUser.getPhone().toString());
String schoolId = appMapper.selectSchoolId(userId);
School school = schoolMapper.selectById(schoolId);
order.setHehuorenSchool(school.getSchoolName());
order.setHehuorenName(sysUser.getName());
order.setPackageId(productId);
order.setHehuorenArea(sysUser.getSubstName());
order.setSignImg(filePath);
List<String> userId1 = appMapper.selectsupervisorBySchool(schoolId);
SysUser user = sysUserMapper.selectById(userId1.get(0));
order.setSupervisorName(user.getName());
order.setLzgh(school.getLzgh());
// 根据订单号，获取该订单信息
// 根据学校名称，获取该学校信息
Product product = productMapper.selectById(productId);
Wrapper<UniversityInfo> uiWrapper = new EntityWrapper<>();
uiWrapper.eq("university_id", product.getUniversityId());
List<Map<String, Object>> list1 = universityInfoMapper.selectMaps(uiWrapper);
order.setOrderStatus(orderStatus);
orderMapper.insert(order);
appMapper.inserOrderHis(id, "待下单！", new Date(), orderView.getOrderName());
return ResponseData.success(order, "订单创建成功");
}
......
apply-net/src/main/java/com/winsun/controller/codeManagerController.java
......@@ -327,43 +327,53 @@ public class codeManagerController {
@PostMapping("selectOrder")
public ResponseData<Object> selectOrder(HttpServletRequest request, HttpServletResponse response){
Map<String, Object> mapData = new HashMap<>();
String idCard = request.getParameter("idCard"); // 身份证号
String accountNumber = request.getParameter("accountNumber");// 多媒体账号
// 判断身份证号是否在清单中
List<Order> list = orderMapper.selectRepeatOrder(idCard);
if(list.size()>0){
List<OrderView> list1 = orderMapper.selectReportOrder(list.get(0).getKdOrderId());
if (StringUtils.isBlank(list1.get(0).getUptranseq())) {
mapData.put("orderId", list1.get(0).getOrderId());
mapData.put("orderSeq", list1.get(0).getOrderSeq());
mapData.put("userType", list.get(0).getUserType());
mapData.put("kapin", list.get(0).getKapin());
mapData.put("code", 2);//"你已存在未支付的订单，请前往支付页面"
return ResponseData.error(mapData,"你已存在未支付的订单，请前往支付页面");
} else {
mapData.put("orderSeq", list1.get(0).getOrderSeq());
mapData.put("uptranseq", list1.get(0).getUptranseq());
mapData.put("userType", list.get(0).getUserType());
mapData.put("kapin", list.get(0).getKapin());
mapData.put("code", 0); //不可重复下单"你已存在正在处理的订单，请勿重复下单"
return ResponseData.error(mapData,"你已存在正在处理的订单，请勿重复下单");
try{
Map<String, Object> mapData = new HashMap<>();
String idCard = request.getParameter("idCard"); // 身份证号
String accountNumber = request.getParameter("accountNumber");// 多媒体账号
// 判断身份证号是否在清单中
Wrapper<Order> orderWrapper = new EntityWrapper<>();
orderWrapper.eq(StringUtils.isNotBlank(idCard), "id_card", idCard);
orderWrapper.in("user_type","3,5,9,10");
orderWrapper.ne("order_status","异常单");
List<Order> order = orderMapper.selectList(orderWrapper);
if(order.size()>0){
Wrapper<OrderView> wrapper = new EntityWrapper<>();
wrapper.eq(StringUtils.isNotBlank(order.get(0).getKdOrderId()), "orderSeq", order.get(0).getKdOrderId());
List<OrderView> orderViews = orderViewMapper.selectList(wrapper);
if (orderViews.get(0).getUptranseq()==null || StringUtils.isBlank(orderViews.get(0).getUptranseq())) {
mapData.put("orderId", orderViews.get(0).getOrderId());
mapData.put("orderSeq", orderViews.get(0).getOrderSeq());
mapData.put("userType", order.get(0).getUserType());
mapData.put("kapin", order.get(0).getKapin());
mapData.put("code", 2);//"你已存在未支付的订单，请前往支付页面"
return ResponseData.error(mapData,"你已存在未支付的订单，请前往支付页面");
} else {
mapData.put("orderSeq", orderViews.get(0).getOrderSeq());
mapData.put("uptranseq", orderViews.get(0).getUptranseq());
mapData.put("userType", order.get(0).getUserType());
mapData.put("kapin", order.get(0).getKapin());
mapData.put("code", 0); //不可重复下单"你已存在正在处理的订单，请勿重复下单"
return ResponseData.error(mapData,"你已存在正在处理的订单，请勿重复下单");
}
}
}
// 判断是否在宽带清单中
List<Map<String, Object>> accountNumberList = orderMapper.checkOldKdUser(accountNumber);
// 查询多媒体账号在甲方提供清单中是否存在
if(!accountNumberList.isEmpty() && accountNumberList.size() > 0) { //已存在纪录
mapData.put("code", 1);
return ResponseData.error(mapData,"该账号已存在");
} else {
// 查询多媒体账号在订单表是否存在
List<Map<String, Object>> maps = orderMapper.checkOldhhrOrder(accountNumber);
if(!maps.isEmpty() && maps.size()>0){
// 判断是否在宽带清单中
List<Map<String, Object>> accountNumberList = orderMapper.checkOldKdUser(accountNumber);
// 查询多媒体账号在甲方提供清单中是否存在
if(!accountNumberList.isEmpty() && accountNumberList.size() > 0) { //已存在纪录
mapData.put("code", 1);
return ResponseData.error(mapData,"该账号已存在");
} else {
// 查询多媒体账号在订单表是否存在
List<Map<String, Object>> maps = orderMapper.checkOldhhrOrder(accountNumber);
if(!maps.isEmpty() && maps.size()>0){
mapData.put("code", 1);
return ResponseData.error(mapData,"该账号已存在");
}
}
}catch (Exception e){
return ResponseData.error("连接超时，请重试");
}
return ResponseData.success();
}
......
common/src/main/java/com/winsun/mapper/OrderMapper.java
......@@ -109,6 +109,12 @@ public interface OrderMapper extends BaseMapper<Order> {
*/
List<Map<String, Object>> selectBroadList(String accountNumber);
/**
* 查询宽带订单
* @param KdOrderID
* @return
*/
Map<String, Object> selectKdOrder(String KdOrderID);
/**
* 查询多媒体账号在甲方提供清单中是否存在
......
common/src/main/java/com/winsun/outSideSystem/IntelligenceSendOrder.java
......@@ -250,7 +250,7 @@ public class IntelligenceSendOrder {
private JSONObject getQueryOrderInfo(
String orderNum, String currentTimeStr, int count) throws Exception {
List<NameValuePair> qParams = new ArrayList<NameValuePair>();
// HttpHost proxy = new HttpHost("172.18.101.170", 3128);
HttpHost proxy = new HttpHost("172.18.101.170", 3128);
RequestConfig defaultRequestConfig =
RequestConfig.custom()
.setSocketTimeout(50000)
......@@ -344,7 +344,7 @@ public class IntelligenceSendOrder {
int count)
throws Exception {
List<NameValuePair> qParams = new ArrayList<NameValuePair>();
// HttpHost proxy = new HttpHost("172.18.101.170", 3128);
HttpHost proxy = new HttpHost("172.18.101.170", 3128);
RequestConfig defaultRequestConfig =
RequestConfig.custom()
.setSocketTimeout(50000)
......@@ -360,6 +360,7 @@ public class IntelligenceSendOrder {
httpPost.setConfig(requestConfig);
Map<String, String> signMap = new HashMap<String, String>(); // 待签名参数
qParams.add(new BasicNameValuePair("service", "order.broadband.create")); // api标识，必填
signMap.put("service", "order.broadband.create"); // api标识，必填
qParams.add(new BasicNameValuePair("userName", Constant.ZHENGSHIAUCCON)); // 用户名，必填
......
common/src/main/resources/com/winsun/mapper/mapping/OrderMapper.xml
......@@ -189,4 +189,8 @@
UPDATE hhr_order SET order_status = '已完成' WHERE id IN (SELECT id FROM(SELECT id FROM hhr_order WHERE order_status='已发货' AND TO_DAYS(NOW()) - TO_DAYS(create_time) > 7) t1)
</update>
<select id="selectKdOrder" parameterType="String" resultType="HashMap">
select * from hhr_order where order_status !='异常单' and kd_order_id = #{KdOrderID}
</select>
</mapper>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment