|
|
@@ -3,10 +3,14 @@ package com.pj.tb_goods_transit;
|
|
|
import java.io.FileOutputStream;
|
|
|
import java.io.IOException;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
+import java.time.LocalDate;
|
|
|
import java.time.LocalDateTime;
|
|
|
+import java.time.LocalTime;
|
|
|
import java.time.format.DateTimeFormatter;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
+import java.util.concurrent.locks.Lock;
|
|
|
+import java.util.concurrent.locks.ReentrantLock;
|
|
|
|
|
|
import cn.dev33.satoken.stp.StpUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
@@ -44,6 +48,7 @@ import org.apache.poi.hssf.usermodel.HSSFSheet;
|
|
|
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import com.baomidou.mybatisplus.extension.service.IService;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
@@ -53,6 +58,8 @@ import org.springframework.web.multipart.MultipartFile;
|
|
|
|
|
|
import javax.swing.filechooser.FileSystemView;
|
|
|
|
|
|
+import static com.pj.api.consts.FeignFactory.adminInterface;
|
|
|
+
|
|
|
/**
|
|
|
* Service: tb_goods_transit -- 审核商户在APP端发布的商品
|
|
|
* @author qzy
|
|
|
@@ -70,40 +77,19 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
|
|
|
/** 监管产品mapper */
|
|
|
@Autowired
|
|
|
private TbGoodsMapper tbGoodsMapper;
|
|
|
-
|
|
|
@Autowired
|
|
|
- private SmsRetryService smsRetryService;
|
|
|
-
|
|
|
+ private TbOrderService tbOrderService;
|
|
|
@Autowired
|
|
|
- private TbGoodsCartService tbGoodsCartService;
|
|
|
-
|
|
|
+ private TbOrderMapper tbOrderMapper;
|
|
|
/** 互市区mapper */
|
|
|
@Autowired
|
|
|
private TbTradeAreaMapper tbTradeAreaMapper;
|
|
|
- /** 订单保存 */
|
|
|
- @Autowired
|
|
|
- private TbOrderMapper tbOrderMapper;
|
|
|
- /** 边民 */
|
|
|
- @Autowired
|
|
|
- private TbPeopleMapper tbPeopleMapper;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private TbEnterpriseMapper tbEnterpriseMapper;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private TbGoodsCartMapper tbGoodsCartMapper;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private TbOrderService orderService;
|
|
|
+ /** 锁 */
|
|
|
+ private Lock lock = new ReentrantLock();
|
|
|
|
|
|
- @Autowired
|
|
|
- private MethodOrderService methodOrderService;
|
|
|
-
|
|
|
- /**
|
|
|
- * 远程调用
|
|
|
- */
|
|
|
- @Autowired
|
|
|
- private AdminInterface adminInterface;
|
|
|
+ //边民的授信额度
|
|
|
+ //todo: @Value("${quota}")
|
|
|
+ public static final Double QUOTA = 8000.0;
|
|
|
|
|
|
/** 增 */
|
|
|
void add(TbGoodsTransit t){
|
|
|
@@ -154,7 +140,7 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
|
|
|
//添加互市区条件
|
|
|
so.put("tradeAreaId",appLoginInfo.getTradeAreaId()); // 根据边民的所在互市区匹配其能查看的商品
|
|
|
so.put("merchantId", appLoginInfo.getFk()); // 外键
|
|
|
- so.put("isOrders",0); // 未被下单
|
|
|
+ so.put("isOrders",IsOrders.IS_ORDERS_ZERO.getCode()); // 未被下单
|
|
|
so.set("auditStatus",AuditStatus.AUDIT_STATUS_ON.getCode()); // 审核通过
|
|
|
so.put("deleteStatus", DeleteStatus.DELETE_STATUS_ON.getCode()); // 未被逻辑删除
|
|
|
return tbGoodsTransitMapper.getList(so);
|
|
|
@@ -204,8 +190,6 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
|
|
|
|
|
|
/** app端 - 添加需要交易的商品 */
|
|
|
public boolean transactionGoods(TransactionGoodsParam transactionGoodsParam){
|
|
|
- //检查登录
|
|
|
-// StpUtil.checkLogin();
|
|
|
//判断商品的净重毛重
|
|
|
Double netWeight = transactionGoodsParam.getNetWeight();
|
|
|
Double grossWeight = transactionGoodsParam.getGrossWeight();
|
|
|
@@ -228,28 +212,28 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
|
|
|
TbGoodsTransit tbGoodsTransit = new TbGoodsTransit();
|
|
|
BeanUtils.copyProperties(transactionGoodsParam,tbGoodsTransit);
|
|
|
//获取并保存当前商品基本信息
|
|
|
- tbGoodsTransit.setTradeAreaName(tbTradeArea.getName());
|
|
|
- tbGoodsTransit.setGoodsName(tbGoods.getName());
|
|
|
- tbGoodsTransit.setDescription(tbGoods.getRemark());
|
|
|
- tbGoodsTransit.setPlaceOrigin(tbGoods.getSource());
|
|
|
- tbGoodsTransit.setGoodsUnits(tbGoods.getUnit());
|
|
|
- tbGoodsTransit.setGoodsType(tbGoods.getTypeNames());
|
|
|
- tbGoodsTransit.setGoodsImg(tbGoods.getAvatar());
|
|
|
+ tbGoodsTransit.setTradeAreaName(tbTradeArea.getName()); // 交易地区(互市区)
|
|
|
+ tbGoodsTransit.setGoodsName(tbGoods.getName()); // 商品名称
|
|
|
+ tbGoodsTransit.setDescription(tbGoods.getRemark()); // 商品描述
|
|
|
+ tbGoodsTransit.setPlaceOrigin(tbGoods.getSource()); // 商品产地
|
|
|
+ tbGoodsTransit.setGoodsUnits(tbGoods.getUnit()); // 商品单位
|
|
|
+ tbGoodsTransit.setGoodsType(tbGoods.getTypeNames()); // 商品类型名称
|
|
|
+ tbGoodsTransit.setGoodsImg(tbGoods.getAvatar()); // 商品图片
|
|
|
tbGoodsTransit.setGoodsId(tbGoods.getId());//保存监管商品表id
|
|
|
- tbGoodsTransit.setShopId(transactionGoodsParam.getShopId());
|
|
|
- tbGoodsTransit.setShopName(transactionGoodsParam.getShopName());
|
|
|
-
|
|
|
+ tbGoodsTransit.setShopId(transactionGoodsParam.getShopId()); // 商铺ID
|
|
|
+ tbGoodsTransit.setShopName(transactionGoodsParam.getShopName()); // 商铺名称
|
|
|
+ tbGoodsTransit.setSellOut(SellOut.SELL_OUT_ZERO.getCode());//默认商品未售罄
|
|
|
//商户编号
|
|
|
- tbGoodsTransit.setMerchantId(appLoginInfo.getFk() + "");
|
|
|
+ tbGoodsTransit.setMerchantId(appLoginInfo.getFk() + ""); // appUser表的外键
|
|
|
//商户名称
|
|
|
- tbGoodsTransit.setMerchantName(appLoginInfo.getLoginName());
|
|
|
+ tbGoodsTransit.setMerchantName(appLoginInfo.getLoginName()); // appUser表昵称
|
|
|
|
|
|
//保存海关商品表的主键到商品审核表上 todo:原计划是保存[海关申报单号],临时修改成保存海关商品表的主键
|
|
|
tbGoodsTransit.setDeclareOdd(String.valueOf(tbGoods.getId()));
|
|
|
//设置默认信息
|
|
|
tbGoodsTransit.setAuditStatus(AuditStatus.AUDIT_STATUS_ON.getCode());//默认已过审
|
|
|
- tbGoodsTransit.setIsOrders(0);//默认未被下单
|
|
|
- tbGoodsTransit.setEnterpriseConfirm(EnterpriseConfirm.ENTERPRISE_CONFIRM_ZERO.getCode());//商铺确认情况[0=待确认,1=已确认,2=拒绝]
|
|
|
+ tbGoodsTransit.setIsOrders(IsOrders.IS_ORDERS_ZERO.getCode());//默认未被下单
|
|
|
+ tbGoodsTransit.setEnterpriseConfirm(ConfirmStatus.CONFIRM_STATUS_ZERO.getCode());//商铺确认情况[0=待确认,1=已确认,2=拒绝]
|
|
|
//设置基本信息
|
|
|
tbGoodsTransit.setCreateTime(new Date());
|
|
|
tbGoodsTransit.setCreateBy(appLoginInfo.getLoginId() + "");
|
|
|
@@ -284,78 +268,95 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
+ * 一级市场边民的购买操作
|
|
|
* 采购一级市场的商品，
|
|
|
* 包括加入购物车、购买、支付（暂时不做），
|
|
|
* 下单后会向组内边民发送短信，
|
|
|
* 通知其登录APP进行交易确认。
|
|
|
*/
|
|
|
public boolean purchaseLevelOntGoodsTransit(PurchaseLevelOneGoodsTransitParam purchaseLevelOntGoodsTransitParam) throws Exception {
|
|
|
- //检查登录
|
|
|
-// StpUtil.checkLogin();
|
|
|
//获取当前登陆人
|
|
|
APPLoginUserInfo appLoginInfo = StpAPPUserUtil.getAPPLoginInfo();
|
|
|
if(appLoginInfo == null || appLoginInfo.getLoginId() == null)
|
|
|
throw new RuntimeException("当前登陆用户信息已失效!");
|
|
|
- //判断当前登陆人是否为互市组组长
|
|
|
- List<TbPeople> list = tbPeopleMapper.selectList
|
|
|
- (new LambdaQueryWrapper<TbPeople>().eq(TbPeople::getId,appLoginInfo.getFk())
|
|
|
- .eq(TbPeople::getRole, 2) // 1 边民 2组长
|
|
|
- .eq(TbPeople::getIsLock, IsLock.IS_LOCK_ON.getCode())
|
|
|
- .eq(TbPeople::getDeleteStatus, DeleteStatus.DELETE_STATUS_ON.getCode()));
|
|
|
- if(list.size() != 1)throw new RuntimeException("您当前不属于互市组组长~");
|
|
|
//获取商品ID
|
|
|
String goodsTransitId = purchaseLevelOntGoodsTransitParam.getGoodsTransitId();
|
|
|
//查询商品
|
|
|
TbGoodsTransit tbGoodsTransit = tbGoodsTransitMapper.selectById(goodsTransitId);
|
|
|
if(tbGoodsTransit == null || tbGoodsTransit.getId() == null)
|
|
|
throw new RuntimeException("当前商品信息已失效!");
|
|
|
- if(tbGoodsTransit.getGoodsStatus() == GoodsStatus.GOODS_STATUS_OFF.getCode())throw new ServiceException("该商品已下架,无法进行购买!");
|
|
|
+ if(tbGoodsTransit.getGoodsStatus().equals(GoodsStatus.GOODS_STATUS_OFF.getCode()))
|
|
|
+ throw new ServiceException("该商品已下架,无法进行购买!");
|
|
|
+ if(tbGoodsTransit.getSellOut().equals(SellOut.SELL_OUT_ONE.getCode()))
|
|
|
+ throw new ServiceException("该商品已售罄!");
|
|
|
+ //计算价格
|
|
|
+ double totalPrice = tbGoodsTransit.getPrice() * purchaseLevelOntGoodsTransitParam.getNumber();
|
|
|
+ //判断物价是否大于8000
|
|
|
+ if(totalPrice > QUOTA)
|
|
|
+ throw new ServiceException("您当前购物已大于授信额度,请检查购买信息。");
|
|
|
+ //查询当天是否已存在该订单
|
|
|
+ LocalDate today = LocalDate.now();
|
|
|
+ LocalDateTime startTime = LocalDateTime.of(today, LocalTime.MIN);
|
|
|
+ LocalDateTime endTime = LocalDateTime.of(today, LocalTime.MAX);
|
|
|
+ List<TbOrder> tbOrderList = tbOrderMapper.selectList(
|
|
|
+ new LambdaQueryWrapper<TbOrder>()
|
|
|
+ .eq(TbOrder::getCreateBy, appLoginInfo.getLoginId())
|
|
|
+ .between(TbOrder::getCreateTime,startTime,endTime)
|
|
|
+ .eq(TbOrder::getDeleteStatus,DeleteStatus.DELETE_STATUS_ON.getCode()));
|
|
|
+ if(tbOrderList.size() != 0)throw new RuntimeException("当天已下订单,暂时无法继续下单!");
|
|
|
//检查是否属于海关允许销售商品
|
|
|
Long goodsId = tbGoodsTransit.getGoodsId();
|
|
|
TbGoods tbGoods = tbGoodsMapper.selectById(goodsId);
|
|
|
if(tbGoods == null)throw new RuntimeException("当前商品海关已不允许销售!");
|
|
|
- //一天只能下一单
|
|
|
- //1.查询数据库内是否有订单
|
|
|
- LambdaQueryWrapper<TbOrder> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
- queryWrapper.eq(TbOrder::getBuyUserId,appLoginInfo.getFk()); //边民表主键匹配
|
|
|
- queryWrapper.apply("DATE(create_time) = DATE({0})", new Date()); // 匹配当天的数据
|
|
|
- queryWrapper.ne(TbOrder::getEnterpriseConfirm,2); // 商户拒绝情况
|
|
|
- queryWrapper.eq(TbOrder::getCancelPeople,0); // 组长或者边民未取消取消订单
|
|
|
- List<TbOrder> orderList = tbOrderMapper.selectList(queryWrapper);
|
|
|
- if(orderList.size() != 0){
|
|
|
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
- TbOrder tbOrder = orderList.get(0);
|
|
|
- throw new ServiceException("您在 " + sdf.format(tbOrder.getCreateTime()) + " 已下单,请勿重复下单。");
|
|
|
- }
|
|
|
- //执行采购,创建一级市场订单表 , 该方法只是设置tbOrder的属性
|
|
|
- TbOrder tbOrder = methodGoodsTransitService.setTbOrderProperties(tbGoodsTransit, appLoginInfo);
|
|
|
- //执行保存 todo:创建订单
|
|
|
- int insert = tbOrderMapper.insert(tbOrder);
|
|
|
- if(insert == 1){
|
|
|
- //删除购物车
|
|
|
- tbGoodsCartMapper.deleteById(purchaseLevelOntGoodsTransitParam.getGoodsCartId());
|
|
|
- //将商品信息改成已被下单
|
|
|
- tbGoodsTransit.setIsOrders(1);
|
|
|
+ //查询该商品库存是否有库存
|
|
|
+ if(tbGoodsTransit.getStock() == 0.0)throw new ServiceException("当前商品已售罄!");
|
|
|
+ //判断数量是否足够
|
|
|
+ if(purchaseLevelOntGoodsTransitParam.getNumber() > tbGoodsTransit.getStock())
|
|
|
+ throw new ServiceException("购买数量已超上限!");
|
|
|
+ try{
|
|
|
+ //上锁
|
|
|
+ lock.lock();
|
|
|
+ // todo: 调用银行接口,判断当前边民是否有足够的额度
|
|
|
+ //执行购买
|
|
|
+ tbGoodsTransit.setStock(tbGoodsTransit.getStock() - purchaseLevelOntGoodsTransitParam.getNumber());
|
|
|
+ //如果商品的数量已售罄
|
|
|
+ if(tbGoodsTransit.getStock() < 0.0)
|
|
|
+ throw new ServiceException("购买异常!");
|
|
|
+ if(tbGoodsTransit.getStock() == 0.0)
|
|
|
+ tbGoodsTransit.setSellOut(SellOut.SELL_OUT_ONE.getCode());
|
|
|
+ //保存结果
|
|
|
int updateById = tbGoodsTransitMapper.updateById(tbGoodsTransit);
|
|
|
- //执行给商家发送信息
|
|
|
if(updateById == 1){
|
|
|
- //获取商家信息
|
|
|
- TbEnterprise tbEnterprise = tbEnterpriseMapper.selectById(tbGoodsTransit.getMerchantId());
|
|
|
- if(tbEnterprise == null)throw new RuntimeException("商家不存在!");
|
|
|
-
|
|
|
- //todo:给商家发一条接单消息
|
|
|
- MessageDto dto = new MessageDto();
|
|
|
- dto.setUrl("/pages/market/one/merchant/order/list");
|
|
|
- dto.setUserId(tbEnterprise.getId());
|
|
|
- dto.setContents("你的发布的《" + tbGoodsTransit.getGoodsName() + "》已有人接单,请及时确认。");
|
|
|
- adminInterface.messageSave(dto);
|
|
|
- // 给组长旗下的所有边民发送message
|
|
|
- methodOrderService.sendGroupMessage(list.get(0).getGroupId(),list.get(0).getName(),true);
|
|
|
- //todo:通知短信
|
|
|
-// return smsRetryService.sendSmsMsg(tbEnterprise.getContact());
|
|
|
- return true;
|
|
|
+ //生成小订单
|
|
|
+ tbGoodsTransit.setPrice(totalPrice);
|
|
|
+ TbOrder tbOrder = methodGoodsTransitService.setTbOrderProperties(tbGoodsTransit, appLoginInfo);
|
|
|
+ boolean save = tbOrderService.save(tbOrder);
|
|
|
+ if(save){
|
|
|
+ //todo: 将交易成功信息推送给航通
|
|
|
+ //发送message给商家和买家
|
|
|
+ MessageDto dto = new MessageDto();
|
|
|
+ dto.setUrl("/pages/market/one/merchant/order/list");
|
|
|
+ dto.setUserId(Long.valueOf(tbGoodsTransit.getCreateBy()));
|
|
|
+ dto.setContents("你的商品 <<" + tbGoodsTransit.getGoodsName() + ">> " +
|
|
|
+ "已出售"+ purchaseLevelOntGoodsTransitParam.getNumber() +
|
|
|
+ tbGoodsTransit.getGoodsUnits() + "还剩 "+ tbGoodsTransit.getStock() +
|
|
|
+ tbGoodsTransit.getGoodsUnits() +",请前往查看。");
|
|
|
+ //执行message发送
|
|
|
+ adminInterface.messageSave(dto);
|
|
|
+ //执行发送买家
|
|
|
+ dto.setUrl("/pages/market/one/merchant/order/list");
|
|
|
+ dto.setUserId(appLoginInfo.getLoginId());
|
|
|
+ dto.setContents("购买商品 <<" + tbGoodsTransit.getGoodsName() + ">>成功!");
|
|
|
+ adminInterface.messageSave(dto);
|
|
|
+ }
|
|
|
}
|
|
|
+ }catch (Exception e){
|
|
|
+ e.printStackTrace();
|
|
|
+ }finally {
|
|
|
+ //解锁
|
|
|
+ lock.unlock();
|
|
|
}
|
|
|
+
|
|
|
throw new RuntimeException("订单预创建异常!");
|
|
|
}
|
|
|
|
Mechrevo