基于springboot二手物品交易系统微信小程序

演示视频：

package com.oyhp.esyu.web;import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.oyhp.esyu.pojo.*;
import com.oyhp.esyu.service.*;
import com.oyhp.esyu.util.Result;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;@RestController
public class DiscussController {@AutowiredOrderItemService orderItemService;@AutowiredDiscussService discussService;@AutowiredDiscussItemService discussItemService;@AutowiredOrderService orderService;@AutowiredUserService userService;/**创建聊天窗口*/@PutMapping("/wx/discuss/create/{oid}")public Object onCreate(@PathVariable("oid")int oid,@RequestBody String type){System.out.println("type-"+type);JSONObject typeObj = JSONUtil.parseObj(type);//根据订单id获取订单项OrderItem orderItem = orderItemService.getByOrderId(oid);Discuss discuss = new Discuss();//买家、卖家、订单号、类型discuss.setBuser(orderItem.getUser());discuss.setSuser(orderItem.getProduct().getUser());discuss.setOrder(orderItem.getOrder());discuss.setType((String) typeObj.get("type"));//创建聊天窗口discussService.add(discuss);System.out.println(orderItem);return Result.success(discuss.getId());}/**添加聊天项*/@GetMapping("/wx/discuss/{id}/user/{uid}")public Object addDiscussItem(@PathVariable("id")int id, @PathVariable("uid")int uid,@RequestParam("content")String content){User user = userService.getById(uid);Discuss discuss = discussService.get(id);DiscussItem discussItem = new DiscussItem();discussItem.setDiscuss(discuss);discussItem.setContent(content);discussItem.setCreateDate(new Date());discussItem.setUser(user);discussItemService.add(discussItem);return Result.success("发送成功");}/**根据窗口id获取聊天窗口*/@GetMapping("/wx/discuss/{id}")public Object getDiscuss(@PathVariable("id")int id){Discuss discuss = discussService.get(id);//填充订单的订单项 -- 考虑要不要orderItemService.wxFill(discuss.getOrder());orderService.removeOrderFromOrderItem(discuss.getOrder());List<DiscussItem> discussItems = discussItemService.listByDiscuss(discuss);for (DiscussItem discussItem: discussItems) {discussItem.setDiscuss(null);}discuss.setDiscussItemList(discussItems);return Result.success(discuss);}/*** 判断是否存在聊天窗口*/@GetMapping("/wx/discuss/order/{oid}/buser/{buid}/suser/{suid}")public Object isHasDicuss(@PathVariable("oid")int oid,@PathVariable("buid")int buid,@PathVariable("suid")int suid){Order order = orderService.get(oid);User buser = userService.getById(buid);User suser = userService.getById(suid);Discuss discuss = discussService.getDiscussByOrderAndBuserAndSuser(order,buser,suser);//不存在聊天项if(discuss == null){return Result.fail("不存在聊天窗");}else{return Result.success(discuss);}}/**获取用户的聊天窗口和系统信息*/@GetMapping("/wx/discuss/user/{uid}")public Object getDiscussByUser(@PathVariable("uid")int uid){User user = userService.getById(uid);//聊天信息List<Discuss> discusses = discussService.listByUser(user);//系统信息Discuss systemDiscuss = discussService.get(1);List<DiscussItem> systemNews = discussItemService.listByDiscuss(systemDiscuss);for (DiscussItem d:systemNews) {d.setDiscuss(null);}//填充聊天窗中聊天项discussItemService.fill(discusses);//移除聊天项中的聊天discussItemService.removeDiscussFromDiscussItems(discusses);//产品名称和交易方式ArrayList<String> productName = new ArrayList<>();
//        ArrayList<String> tradeWays = new ArrayList<>();for (Discuss d:discusses) {orderItemService.wxFill(d.getOrder());orderService.removeOrderFromOrderItem(d.getOrder());productName.add(d.getOrder().getOrderItems().get(0).getProduct().getName());
//            tradeWays.add(d.getOrder().getTradeWay());}//移除discuss中的orderdiscussService.removeOrderFromDiscuss(discusses);HashMap<Object,Object> maps = new HashMap<>();maps.put("discusses",discusses);maps.put("productName",productName);maps.put("systemNews",systemNews);
//        maps.put("tradeWays",tradeWays);return Result.success(maps);}
}

package com.oyhp.esyu.web;
import java.awt.image.BufferedImage;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;import javax.imageio.ImageIO;
import javax.servlet.http.HttpServletRequest;import com.oyhp.esyu.pojo.Product;
import com.oyhp.esyu.pojo.ProductImage;
import com.oyhp.esyu.service.CategoryService;
import com.oyhp.esyu.service.ProductImageService;
import com.oyhp.esyu.service.ProductService;
import com.oyhp.esyu.util.ImageUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;@RestController
public class ProductImageController {@AutowiredProductService productService;@AutowiredProductImageService productImageService;@AutowiredCategoryService categoryService;/*** 1. 首先访问路径，admin_productImage_list?pid=2， 通过AdminPageController 中的映射，返回 listProductImage.html* 2. 在listProductImage.html 加载后就获取了参数上的 pid* 3. 然后自动调用 listSingles 函数* 4. listSingles 函数用过 axios.js 调用 products/2/productImages?type=single 这个地址* 5. 步骤4的地址，导致 ProductImageController 的 list 方法被调用* 6. list 方法里根据参数调用 ProductService的 listSingleProductImages 方法，返回当前产品的单个图片集合* 7. 这个图片集合返回 json数组* 8. axios拿到这个json数组就放在 vue的singleProductImages对象上* 9. vue 把 singleProductImages 通过v-for 遍历在视图上* 以上就是单个图片的查询，详情图片的查询同理可得就是参数不一样。*/@GetMapping("/products/{pid}/productImages")public List<ProductImage> list(@RequestParam("type") String type, @PathVariable("pid") int pid) throws Exception {Product product = productService.get(pid);if(ProductImageService.type_single.equals(type)) {List<ProductImage> singles =  productImageService.listSingleProductImages(product);return singles;}else if(ProductImageService.type_detail.equals(type)) {List<ProductImage> details =  productImageService.listDetailProductImages(product);return details;}else {return new ArrayList<>();}}/*** 增加产品图片分单个和详情两种，其区别在于增加所提交的type类型不一样。* 这里就对单个的进行讲解，详情图片的处理同理。* 1. 选中图片后，会导致 getSingleFile 函数被调用，vue就拿到了文件* 2. 点击提交按钮会导致addSingle函数被调用* 3. 与分类上传图片类似， axios,js 上传图片要用 FormData 的方式* 4. 上传到路径 productImages，并带上type和pid参数* 5. ProductImageController 的add方法被调用* 6. 首先根据pid 和 type 创建 ProductImage 对象，并插入数据库* 7. 然后根据类型指定保存文件的路径：productSingle* 8. 接着根据产品图片对象的id，作为文件名，把图片保存到对应的位置* 9. 像分类上传图片一样，要通过 ImageUtil.change2jpg进行类型强制转换,以确保一定是jpg图片* 10. 如果是单个图片，还要创建 small 和 middle 两种不同大小的图片，用的是 ImageUtil.resizeImage 函数* 以上就是单个图片的处理。*/@PostMapping("/productImages")public Object add(@RequestParam("pid") int pid, @RequestParam("type") String type, MultipartFile image, HttpServletRequest request) throws Exception {ProductImage bean = new ProductImage();Product product = productService.get(pid);bean.setProduct(product);bean.setType(type);productImageService.add(bean);String folder = "img/";if(ProductImageService.type_single.equals(bean.getType())){folder +="productSingle";}else{folder +="productDetail";}File  imageFolder= new File(request.getServletContext().getRealPath(folder));File file = new File(imageFolder,bean.getId()+".jpg");String fileName = file.getName();if(!file.getParentFile().exists())file.getParentFile().mkdirs();try {image.transferTo(file);BufferedImage img = ImageUtil.change2jpg(file);ImageIO.write(img, "jpg", file);           } catch (IOException e) {e.printStackTrace();}if(ProductImageService.type_single.equals(bean.getType())){String imageFolder_small= request.getServletContext().getRealPath("img/productSingle_small");String imageFolder_middle= request.getServletContext().getRealPath("img/productSingle_middle");    File f_small = new File(imageFolder_small, fileName);File f_middle = new File(imageFolder_middle, fileName);f_small.getParentFile().mkdirs();f_middle.getParentFile().mkdirs();ImageUtil.resizeImage(file, 56, 56, f_small);ImageUtil.resizeImage(file, 217, 190, f_middle);}      return bean;}/*** 1. 点击删除超链* 2. vue 上的 deleteBean 函数被调用，访问 productImages/id 路径* 3. ProductImageController的delete方法被调用* 4. 根据id获取ProductImage 对象* 5. 借助productImageService，删除数据* 6. 如果是单个图片，那么删除3张正常，中等，小号图片* 7. 如果是详情图片，那么删除一张图片*/@DeleteMapping("/productImages/{id}")public String delete(@PathVariable("id") int id, HttpServletRequest request)  throws Exception {ProductImage bean = productImageService.get(id);productImageService.delete(id);String folder = "img/";if(ProductImageService.type_single.equals(bean.getType()))folder +="productSingle";elsefolder +="productDetail";File  imageFolder= new File(request.getServletContext().getRealPath(folder));File file = new File(imageFolder,bean.getId()+".jpg");String fileName = file.getName();file.delete();if(ProductImageService.type_single.equals(bean.getType())){String imageFolder_small= request.getServletContext().getRealPath("img/productSingle_small");String imageFolder_middle= request.getServletContext().getRealPath("img/productSingle_middle");File f_small = new File(imageFolder_small, fileName);File f_middle = new File(imageFolder_middle, fileName);f_small.delete();f_middle.delete();}return null;}}

package com.oyhp.esyu.web;import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.oyhp.esyu.comparator.*;
import com.oyhp.esyu.pojo.*;
import com.oyhp.esyu.quartz.manager.QuartzJobManager;
import com.oyhp.esyu.quartz.service.QuartzJobService;
import com.oyhp.esyu.service.*;
import com.oyhp.esyu.util.Result;
import com.oyhp.esyu.util.WXProduct;
import com.oyhp.esyu.util.WXUtil;
import org.apache.commons.lang.math.RandomUtils;
import org.quartz.JobKey;
import org.quartz.SchedulerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.text.SimpleDateFormat;
import java.util.*;/*** 微信小程序控制器*/
@RestController
public class WXForeController {@AutowiredUserService userService;@AutowiredSchoolService schoolService;@AutowiredThemeService themeService;@AutowiredCategoryService categoryService;@AutowiredProductService productService;@AutowiredProductImageService productImageService;@AutowiredReviewService reviewService;@AutowiredPropertyValueService propertyValueService;@AutowiredPropertyService propertyService;@AutowiredAddressService addressService;@AutowiredOrderItemService orderItemService;@AutowiredOrderService orderService;@AutowiredSecondaryCategoryService secondaryCategoryService;@AutowiredEvaluationService evaluationService;@Resourceprivate QuartzJobService quartzJobService;/*** 微信小程序登录* 需要判断用户是否是新用户，根据用户的openid去查是否有这个用户* 1、有，不做任何动作* 2、没有，新建用户* @param userInfo  用户信息，微信传过来的code country province name gender city* @return 登录成功，返回openid*/@PostMapping("/wxlogin")public Object wx_login(@RequestBody User userInfo,HttpServletRequest request){Map<String,Object> userKeyMap =  WXUtil.getOpenidSessionKeyAndToken(userInfo.getCode());String openid = (String)userKeyMap.get("openid");//获取了openid保存到userInfo中userInfo.setOpenid(openid);System.out.println(userInfo);//判断拿到数据是否正确if(openid==null)return Result.fail("error");//微信小程序用户是否为第一次登录if(userService.isLoginFirst(userInfo)){//随便设置一下院校,默认城市学院School school = schoolService.get(1);userInfo.setSchool(school);userInfo.setCreateDate(new Date());userInfo.setUpdateDate(new Date());userService.add(userInfo);//保存用户头像到服务器，以后不再保存到数据库String localUrl = request.getServletContext().getRealPath("img/user/")+userInfo.getId()+".jpg";WXUtil.downloadPicture(userInfo.getAvatarUrl(),localUrl);}//返回openid要求小程序端加入到缓存，用户小程序的其它业务,比如发布return Result.success(openid);}/*** 根据openid获取User信息* @param user* @return*/@PostMapping("/wxUser")public Object wx_user(@RequestBody User user){String openid = user.getOpenid();//判断openid是否有效if(openid != null){User my = userService.getUserByOpenid(openid);//在售商品my.setOnSellProduct(productService.onSellProduct(my));//累计交易，我卖出的List<Product> products = productService.getProductsByUser(my);my.setOnOrderProduct(orderItemService.onOrderTraded(products));//我买到的my.setOnMyBought(orderService.OnOrderProduct(my));return Result.success(my);}elsereturn Result.fail("用户未登录");}/*** 获取Token访问* @return*/@GetMapping("wxAccessToken")public Object getAccessToken(){return Result.success(WXUtil.getAccessToken());}/*** wx小程序首页* 7个分类，一个全部* 所有分类下的产品*/@GetMapping("/wx/home")public Object home(School school){/*** 1、获取所有一级分类* 2、填充一级分类中的所有产品* 4、移除产品中的分类，因为在fill(cs)中，根据分类查找产品，将product中的category属性填充* 导致json死循环，即category实例中有product，而product实例有category*/List<Category> cs = categoryService.list();productService.wxFillBySchool(cs,school);categoryService.removeCategoryFromProduct(cs);categoryService.removeCategoryFromSC(cs);for (Category c: cs) {c.setSecondaryCategories(null);}return cs;}/*** 首页* 获取所有主题,并将产品放入到首页中*/@GetMapping("/wx/themes")public Object wxThemes(School school){System.out.println(school);//获取所有主题List<Theme> themes = themeService.list();//设置主题中产品themeService.wxFill(themes,school);return themes;}/*** 1. 获取参数pid* 2. 根据pid获取Product 对象product* 3. 判断改产品是否下架或这库存不足 isOfflineOrLackStock* 4. 根据对象product，获取这个产品对应的详情图片集合* 5. 获取产品的所有属性值* 6. 获取产品对应的所有的评价* 8. 把上述取值放在 map 中* 9. 通过 Result 把这个 map 返回到浏览器去* 为什么要用Map呢？ 因为返回出去的数据是多个集合，而非一个集合，所以通过 map返回给浏览器，浏览器更容易识别* @param pid* @return*/@GetMapping("/wx/product/{pid}")public Object product(@PathVariable("pid") int pid) {Product product = productService.get(pid);//在售商品product.getUser().setOnSellProduct(productService.onSellProduct(product.getUser()));//累计交易，我卖出的List<Product> products = productService.getProductsByUser(product.getUser());product.getUser().setOnOrderProduct(orderItemService.onOrderTraded(products));//我买到的
//        product.getUser().setOnOrderProduct(orderService.OnOrderProduct(product.getUser()));List<ProductImage> productDetailImages = productImageService.listDetailProductImages(product);List<PropertyValue> pvs = propertyValueService.list(product);for (PropertyValue p:pvs) {p.setProduct(null);}Map<String,Object> map= new HashMap<>();map.put("onSellProduct",product.getUser().getOnSellProduct());map.put("onOrderProduct",product.getUser().getOnOrderProduct());map.put("productDetailImages", productDetailImages);map.put("pvs", pvs);map.put("isOfflineOrLackStock", productService.isOfflineOrLackStock(product));return Result.success(map);}/*** 商品搜索模糊查询* @param key 关键字* @return*/@GetMapping("/wx/search")public Object search(@RequestParam("key") String key,@RequestParam(name = "sort",defaultValue = "none")String sort){List<Product> products = productService.search(key,0,5);for (Product p: products) {p.setCategory(null);p.setSecondaryCategory(null);}productImageService.setWXFirstProductImages(products);//防止不支持异常products = new ArrayList<>(products);if(null!=sort){switch(sort){case "price":Collections.sort(products,new ProductPriceComparator());break;}}return Result.success(products);}/*** 预搜索*/@PutMapping("/wx/preSearch")public Object preSearch(@RequestParam("key") String key){List<String> strings = new ArrayList<>();List<Product> products = productService.search(key,0,5);for (Product p: products) {strings.add(p.getName());}return strings;}/*** 首页中的全部分类* 获取所有分类* @return*/@GetMapping("/wx/category/all")public Object getAllCategories(){List<Category> categories = categoryService.list();secondaryCategoryService.fill(categories);secondaryCategoryService.removeCategoryFromSecondCategory(categories);return Result.success(categories);}/*** 发布页面* 获取所有一级分类和所有主题*/@GetMapping("/wx/categoriesAndThemes")public Object listCategory(){List<Category> categories = categoryService.list();List<Theme> themes = themeService.list();Map<String,Object> map = new HashMap<>();map.put("categories",categories);map.put("themes",themes);return Result.success(map);}/*** 筛选页面* 获取一级分类下的所有产品* 1. 获取参数cid* 2. 根据cid获取分类Category对象 c* 3. 为c填充二级分类和产品* 4. 为产品填充销量和评价数据* 5. 获取参数sort*  5.1 如果sort==null，即不排序*  5.2 如果sort!=null，则根据sort的值，从5个Comparator比较器中选择一个对应的排序器进行排序6. 返回对象 c*/@GetMapping("/wx/secondaryCategory/{scid}")public Object category(@PathVariable("scid")int scid,School school,@RequestParam(name = "sort",defaultValue = "none") String sort){//二级分类SecondaryCategory sc = secondaryCategoryService.get(scid);//填充二级级分类productService.wxFillSCBySchool(sc,school);secondaryCategoryService.removeSecondCategoryFromProduct(sc);productImageService.setWXFirstProductImages(sc.getProductList());if(null!=sort){switch(sort){case "review":Collections.sort(sc.getProductList(),new ProductReviewComparator());break;case "date" :Collections.sort(sc.getProductList(),new ProductDateComparator());break;case "saleCount" :Collections.sort(sc.getProductList(),new ProductSaleCountComparator());break;case "price":Collections.sort(sc.getProductList(),new ProductPriceComparator());break;case "all":Collections.sort(sc.getProductList(),new ProductAllComparator());break;}}return sc;}/*** 获取主题中的商品*/@GetMapping("/wx/theme/{tid}/products")public Object wxProductByTheme(@PathVariable("tid")int tid,School school,@RequestParam(name = "sort",defaultValue = "none") String sort){Theme theme = themeService.get(tid);themeService.wxFill(theme,school);if(null!=sort){switch(sort){case "price":Collections.sort(theme.getProducts(),new ProductPriceComparator());break;}}return theme.getProducts();}/*** 发布页面* 根据分类id获取所有属性*/@GetMapping("/wx/categories/{cid}/properties")public Object getPropertiesByCid(@PathVariable("cid")int cid){Category category = categoryService.get(cid);List<Property> properties = propertyService.listByCategory(category);/**防止浪费空间*/for (Property p: properties) {p.setCategory(null);}return properties;}/*** 发布产品-必须使用post传送而且要@RequestBody不然数组内容接受不正确* 1、openid用户、分类cid、内容content、imgs产品图片、price价格、pvs属性参数、title标题* 2、工具类创建了一个wxproduct，在赋值给product* 3、找到数据中最大的pid，是指pid* 注意对三个表同时操作要进行回滚 !!!还没有实现回滚* 4、发布产品* 5、设置产品属性值* 6、设置产品详细图片* 7、设置产品主题* */@Transactional(propagation= Propagation.REQUIRED,rollbackForClassName="Exception")@PostMapping("/wx/issueProduct/{scid}/theme/{tid}")public Object getProduct(@PathVariable("scid")int scid,@RequestBody WXProduct wxproduct,@PathVariable("tid")int tid){System.out.println(wxproduct);Product product = new Product();User u = userService.getUserByOpenid(wxproduct.getOpenid());SecondaryCategory secondaryCategory = secondaryCategoryService.get(scid);Category c = secondaryCategory.getCategory();/** 用户、分类、创建时间 */product.setUser(u);product.setCategory(c);product.setSecondaryCategory(secondaryCategory);product.setCreateDate(new Date());/** 库存 在线 标题、内容、原价、二手价、运费、属性值、图片集合 */product.setStock(1);product.setOnline("T");product.setName(wxproduct.getName());product.setSubTitle(wxproduct.getSubTitle());product.setPromotePrice(wxproduct.getPromotePrice());product.setOriginalPrice(wxproduct.getOriginalPrice());product.setCarriagePrice(wxproduct.getCarriagePrice());String[] pvs = wxproduct.getPvs();/**设置产品可以交易的方式*/String[] selects = wxproduct.getSelect();for (String s:selects) {if(s.equals("school"))product.setIsSchool("T");if(s.equals("change"))product.setIsChange("T");if(s.equals("express"))product.setIsExpress("T");}//发布产品productService.add(product);//添加主题产品表Theme theme = themeService.get(tid);ThemeProduct themeProduct = new ThemeProduct();themeProduct.setProduct(product);themeProduct.setTheme(theme);themeService.addThemeProduct(themeProduct);
//        System.out.println(product);                      //打印//初始化属性值,即写入属性值到数据库propertyValueService.init(product,pvs);return Result.success(product.getId());              //返回产品id,让前端继续上传图片}/*** pid 产品id、imgs用户上传的图片，有以下两种方案* 1、只要存储detail 2、两种都要存储比如single 这样就不会报错了 修改多一个WXFill了* 选择了方案一*/@PostMapping("/wx/productImgs")public Object add(@RequestParam("pid") int pid, @RequestParam(value = "imgs") MultipartFile image,HttpServletRequest request){ProductImage bean = new ProductImage();Product product = productService.get(pid);bean.setProduct(product);bean.setType("detail");             //锁定详细//添加图片productImageService.add(bean);//上传图片WXUtil.upFile(bean.getId(),"productDetail",image,request);return Result.success("图片上传成功");}/*** 商品库存是否足够，是否下架?true继续，否则错误* order订单生成* pid:产品id, uid:用户id,address:收货地址,post:邮政编号,receiver:收货人,mobile:移动电话, number:1 数量* 订单项生成(id,uid,oid,pid,number)* 定时任务: 10分钟未支付取消订单*/@PutMapping("/wx/order/{pid}")public Object createWxOrder(@PathVariable("pid")int pid,@RequestParam(value = "uid")String uid,@RequestBody Order order){User user = userService.getById(Integer.parseInt(uid));Product product = productService.get(pid);//用户是否登录if(null == user)return Result.fail("未登录");//商品未下架且库存>0if(!(product.getOnline().equals("T") && (product.getStock()>0))){return Result.fail("无效商品");}//商品库存-1product.setStock(product.getStock() - 1);productService.update(product);//先创建订单项OrderItem oi = new OrderItem();oi.setUser(user);oi.setProduct(product);oi.setNumber(1);orderItemService.add(oi);//后生成订单String orderCode = new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date()) + RandomUtils.nextInt(10000);order.setOrderCode(orderCode);order.setCreateDate(new Date());order.setUser(user);order.setStatus(OrderService.waitPay);//设置订单项中的订单 这里价格没有用到orderService.wxAdd(order,oi);//设置订单定时任务JobKey jobKey = JobKey.jobKey(String.valueOf(order.getId()),"waitPayOrder");String desc = "待支付订单，超过十分钟取消订单";Map<String,String> jobMap = new HashMap<>();jobMap.put("oid",String.valueOf(order.getId()));jobMap.put("pid",String.valueOf(product.getId()));jobMap.put("status","waitPayOrder");try {QuartzJobManager.startQuartzJob(quartzJobService,jobKey,jobMap,desc);} catch (SchedulerException e) {e.printStackTrace();}//返回数据Map<String,Object> map = new HashMap<>();map.put("oid", order.getId());map.put("orderCode",order.getOrderCode());map.put("tradeWay",order.getTradeWay());map.put("total", order.getTotalPrice());return Result.success(map);}/*** 获取订单详细信息*/@GetMapping("/wx/order/{oid}/orderDetail")public Object onOrderDetail(@PathVariable("oid") int oid){Order order = orderService.get(oid);//填充orderorderItemService.wxFill(order);orderService.removeOrderFromOrderItem(order);return Result.success(order);}/*** 立即支付* 1 获取参数oid* 2 根据oid获取到订单对象order* 3 修改订单对象的状态和支付时间* 4 取消待支付订单计时* 5 更新这个订单对象到数据库* 6 返回订单*/@PutMapping("/wx/payed/{oid}")public Object payed(@PathVariable("oid") int oid) {Order order = orderService.get(oid);//买家账号User user = order.getUser();//余额不足if(user.getMoney() < Float.parseFloat(order.getTotalPrice())){return Result.fail("余额不足");}//扣除买家金额user.setMoney(user.getMoney() - Float.parseFloat(order.getTotalPrice()));//更新用户账号userService.update(user);//取消待支付定时10分钟JobKey jobKey = JobKey.jobKey(String.valueOf(order.getId()),"waitPayOrder");try {QuartzJobManager.pauseQuartzJob(quartzJobService,jobKey);} catch (SchedulerException e) {e.printStackTrace();}order.setStatus(OrderService.waitDelivery);order.setPayDate(new Date());//更新订单orderService.update(order);return Result.success("支付成功");}/*** 确认发货* 1 获取参数oid* 2 根据oid获取到订单对象order* 3 修改订单对象的状态和发货时间* 4 更新这个订单对象到数据库* 5 返回订单*/@GetMapping("/wx/delivery/{oid}")public Object waitDelivery(@PathVariable("oid") int oid){Order order = orderService.get(oid);System.out.println(order);order.setStatus(OrderService.waitConfirm);order.setDeliveryDate(new Date());orderService.update(order);return Result.success("发货成功");}/*** 确认收货* 1 获取参数oid* 2 根据oid获取到订单对象order* 3 修改订单对象的状态和收货时间* 4 更新卖家账号金额* 5 更新这个订单对象到数据库* 6 返回订单*/@GetMapping("/wx/receive/{oid}")public Object waitConfirmReceive(@PathVariable("oid") int oid){Order order = orderService.get(oid);System.out.println(order);//找到卖家,更新账户OrderItem orderItem = orderItemService.getByOrderId(order.getId());Product product = orderItem.getProduct();User user = product.getUser();user.setMoney(user.getMoney() + Float.parseFloat(order.getTotalPrice()));userService.update(user);order.setStatus(OrderService.waitReview);order.setConfirmDate(new Date());orderService.update(order);return Result.success("收货成功");}/**获取order订单*/@GetMapping("/wx/getOrder/{oid}")public Object getOrder(@PathVariable("oid") int oid){Order order = orderService.get(oid);orderItemService.wxFill(order);orderService.removeOrderFromOrderItem(order);order.setUser(null);return Result.success(order);}/*** 获取全部我的订单  微信小程序我买到的* 1、订单里面的uid是下单者的（我），并不是商家uid,应该用product中的uid* 1. 通过openid获取用户user* 2. 查询user所有的状态不是"delete" 的订单集合os* 3. 为这些订单填充订单项* 4. 返回 订单集合*/@GetMapping("/wx/order/bought")public Object bought(@RequestParam(value = "openid")String openid) {User user = userService.getUserByOpenid(openid);System.out.println(user);if(null==user)return Result.fail("未登录");//微信小程序的获取，由于图片问题没有处理好List<Order> os= orderService.wxListByUserWithoutDelete(user);orderService.removeOrderFromOrderItem(os);return os;}/*** 微信小程序我卖出* 1. 通过openid获取用户user* 2. 通过user查找到我发布的产品Product* 3. 通过我发布的产品找到对应的orderItem* 4. 返回 订单项orderItems集合*/@GetMapping("/wx/order/sell")public Object mySell(@RequestParam(value = "openid")String openid){User user = userService.getUserByOpenid(openid);List<Product> products = productService.getProductsByUser(user);for(Product p : products){//设置为空，防止数据冗余p.setCategory(null);
//            System.out.println(p);}List<List<OrderItem>> listOrderItems = orderItemService.listByProduct(products);List<OrderItem> goalOrderItems = new ArrayList<>();for (List<OrderItem> orderItems: listOrderItems) {for (OrderItem oi: orderItems) {goalOrderItems.add(oi);}}//设置第一张图片productImageService.setWXFirstProductImages(products);return Result.success(goalOrderItems);}/*** 我发布的* @param openid* @return 产品*/@GetMapping("/wx/order/release")public Object myRelease(@RequestParam(value = "openid")String openid){User user = userService.getUserByOpenid(openid);List<Product> products = productService.getProductsByUser(user);for (Product p: products) {//设置为空，防止数据冗余p.setCategory(null);p.setSecondaryCategory(null);}//设置第一张图片productImageService.setWXFirstProductImages(products);//设置详细图片return Result.success(products);}/*** 下架商品* 该商品是否处于交易中，是下架失败，否下架成功*/@PutMapping("/wx/my/product/{pid}/offline")public Object offline(@PathVariable("pid") int pid){Product product = productService.get(pid);boolean isTrading = productService.isTrading(product);if(isTrading){return Result.fail("无法下架，商品正处于交易");}product.setOnline("F");productService.update(product);return Result.success();}/*** 重新上架商品* 该商品是否处于交易中，是下架失败，否下架成功*/@PutMapping("/wx/my/product/{pid}/reOnline")public Object reOnline(@PathVariable("pid") int pid){Product product = productService.get(pid);product.setOnline("T");productService.update(product);return Result.success();}/*** 取消订单-买家*/@GetMapping("/wx/order/{id}/cancel")public Object orderCancel(@PathVariable("id") int id){Order order = orderService.get(id);order.setStatus("waitCancel");//更新订单orderService.update(order);return Result.success("待卖家同意");}/*** 同意取消-卖家*/@GetMapping("/wx/order/{id}/agreeCancel/{pid}")public Object agreeOrderCancel(@PathVariable("id") int id,@PathVariable("pid") int pid){Order order = orderService.get(id);User user = order.getUser();Product product = productService.get(pid);//更新订单order.setStatus("cancel");order.setCancelDate(new Date());//更新库存+1 买家金额退还product.setStock(product.getStock()+1);user.setMoney(user.getMoney() + Float.parseFloat(order.getTotalPrice()));userService.update(user);orderService.update(order);productService.update(product);return Result.success("同意取消");}/*** 拒绝取消-卖家* 少了确认收货后*/@GetMapping("/wx/order/{id}/refuseCancel")public Object refuseOrderCancel(@PathVariable("id")int id){Order order = orderService.get(id);if(order.getPayDate() == null)order.setStatus("waitPay");else if(order.getDeliveryDate() == null)order.setStatus("waitDelivery");else if(order.getConfirmDate() == null)order.setStatus("waitConfirm");elsereturn Result.success("拒绝失败");orderService.update(order);return Result.success("拒绝取消");}/*** 充值recharge 提现 withdraw*/@PutMapping("/wx/my/{id}/wallet")public Object rechargeOrWithdraw(@PathVariable("id")int id,@RequestBody String data){JSONObject wallet = JSONUtil.parseObj(data);User user = userService.getById(id);float charge = Float.parseFloat((String)wallet.get("charge"));String type = (String) wallet.get("type");if(type.equals("recharge")){user.setMoney(user.getMoney() + charge);}else if(type.equals("withdraw")){user.setMoney(user.getMoney() - charge);}//更新钱包userService.update(user);return Result.success(user);}/*** 卖家在订单中修改收货地址*/@PutMapping("/wx/order/{id}/updateOrderAddress")public Object updateOrderAddress(@PathVariable("id")int id,@RequestBody String address){JSONObject addrObj = JSONUtil.parseObj(address);String addr = (String)addrObj.get("address");//更新订单收货地址Order order = orderService.get(id);order.setAddress(addr);orderService.update(order);return Result.success();}/*** 订单评价*/@PostMapping("/wx/orderItem/{id}/evaluation")public void orderItemEvaluation(@PathVariable("id")int id,@RequestBody String result){JSONObject resultObj = JSONUtil.parseObj(result);String content = (String) resultObj.get("content");int score = (int) resultObj.get("score");if(content.equals("")){content = "此用户没有填写评价";}//订单项OrderItem orderItem = orderItemService.get(id);Order order = orderItem.getOrder();//订单评价EvaluationOrder evaluationOrder = new EvaluationOrder();evaluationOrder.setContent(content);evaluationOrder.setScore(score);evaluationOrder.setCreateDate(new Date());evaluationOrder.setOrderItem(orderItem);//添加评价evaluationService.add(evaluationOrder);//修改订单状态order.setStatus("finish");orderService.update(order);}/*** 查看评价*/@GetMapping("/wx/orderItem/{id}/evaluation")public Object getEvaluationByOrderItem(@PathVariable("id")int id){EvaluationOrder evaluationOrder = evaluationService.getByOrderItem_Id(id);evaluationOrder.getOrderItem().setOrder(null);//设置商品图片productImageService.setWXFirstProductImage(evaluationOrder.getOrderItem().getProduct());return Result.success(evaluationOrder);}
}

基于springboot高校闲置物品交易系统微信小程序源码和论文相关推荐

1. 基于springboot的健身管理系统微信小程序源码和论文

   健身房现在已经不是一个陌生的词汇了,对于广大的人民来说它是一种必然和必要的存在.而计算机的技术也在飞速的发展,在双重推力的促进之下,健身房不能只是单纯的传统企业闭门造车,而是要结合现今的技术和科技.无 ...

2. 七夕节微信表白墙小程序源码/基于Laravel的表白墙微信小程序源码

   七夕节微信表白墙小程序源码/基于Laravel的表白墙微信小程序源码 ☑️ 编号:ym499 ☑️ 品牌:无 ☑️ 语言:小程序 ☑️ 大小:11.2MB ☑️ 类型:微信表白墙小程序 ☑️ 支持:小 ...

3. 基于springboot客运汽车票购票系统微信小程序源码和论文

   如今,由于互联网技术的飞速发展,同时也改变着人们的出行方式,人们会逐渐的选择在线上购买出行的车票,而不是选择去车站大排长龙,与此同时,由于假期时长的缘故,客运汽车出行作为中短途的出行工具也就逐渐流行了 ...

4. java高校学生电器报修系统ssm高校后勤报修系统小程序源码和论文

   随着高校每年的扩大招生,学校人数越来越多,学校后勤报修管理的工作量也越来越繁重.使用传统的管理手段和方法,很难完成大量的信息分析和处理.因此,充分利用网络资源和信息化技术,建设一套基于校园网的学校后勤 ...

5. java线下IT培训机构平台ssm培训课程成绩管理系统微信小程序源码和论文

   随着互联网的不断发展与微信及微信小程序的普遍应用,教育行业发生了重大变化,有关IT方面的线下培训机构也随之增加.如果线下IT培训机构可以利用线上管理取代传统的人工管理,那么将可以大大地降低工作量,提高 ...

6. 基于java springboot的生鲜配送微信小程序源码

   近几年线下生鲜超市得到迅速发展,加上互联网的冲击,很多生鲜超市向上转型,依托于互联网技术来开发线上配送业务,主要功能我列了个框架,近期到了毕业季,所以选择了该题目弄了个生鲜配送小程序,后台选择了jav ...

7. 基于java springboot 社区团购微信小程序源码

   去年火了一整年的社区团购,一直将战火烧到了2021年春节.春节期间,一些菜市场和小店暂停营业,居民置办年货和买菜的需求剧增,各大以买菜为主要卖点的社区团购平台,盯上了这个难得的冲单时机. 后台主要用到 ...

8. 七夕节情人节微信表白墙小程序源码/基于Laravel的表白墙微信小程序源码

   简介: 微信表白墙小程源码,表白墙最大的特色就是地域性,圈子性比较强,在地方县城里这种级别就比较合适,在大学里更是如鱼得水. 功能主要分为:表白墙.卖舍友.步数旅行.情侣脸.我的,大致功能都在图上了. ...

9. 基于spring-boot的社区社交微信小程序，适合做脚手架、二次开发

   代码地址如下: http://www.demodashi.com/demo/13867.html 1 概述 笔者做的一个后端基于spring-boot的社区社交微信小程序,可以作为开发的脚手架,开发速 ...

最新文章

1. 正在进行时 Order 1
2. Java JDBC中，MySQL字段类型到JAVA类型的转换
3. libzbar.a armv7
4. python网络爬虫系列（0）——爬虫概述 http协议复习
5. 开题报告方案论证_观点讨论研究方案、立项申报书、开题报告的联系和区别
6. 隐藏我的电脑中的多余图标
7. Centos6.6系统root用户密码恢复案例(转)
8. 用GO语言开发editplus编辑器插件(附源码)
9. 自动格式化SQL工具推荐
10. 用vs2008编写和调试linux程序 ----VisualGDB 使用教程
11. 华为手机计算器程序员模式_华为手机的普通拍照模式，你真的会用吗？
12. 设计一个对向车道的左转待转区提高十字路口的并行通行率
13. python的就业方向有哪些城市_【行业分析|听说你选择python后就业迷茫？Python就业方向都有哪些】- 环球网校...
14. ins服务器未响应,Ins注册及登陆问题简明教程
15. php绑定银行卡实现,php网站如何绑定银行卡
16. 做外贸十大不能接的订单！
17. B2B商业模式以及交易模式
18. java 安卓客户端开发_《安卓网络编程》之第一篇 java环境下模拟客户端、服务器端...
19. Android源码解析之日志系统Logcat
20. 如何扩展VMware xp虚拟机磁盘

热门文章

1. 基带传输与宽带传输的区别
2. 华硕笔记本电池0%充不进电_笔记本电量一直显示0%无法充电该怎么办?
3. 数据解读：中国铁路百年发展史，从“追赶者”到领先世界
4. 一般四边形的面积公式
5. jquery异形轮播
6. Vue封装一个瀑布流图片容器组件
7. iOS开发——组件化及去Mode化方案
8. 第十二届江苏省园艺博览会设计征集大赛获奖信息公示
9. 大学计算机科学的内容,本科读宾夕法尼亚大学计算机科学专业学什么内容？
10. android+中国+比例,2015年中国智能手机屏幕DPI区间关注比例、手机屏幕占比及手机操作系统情况分析【图】...