7.31 日常开发

sp-service/level-one-server/src/main/java/com/pj/tb_goods_cart/TbGoodsCartService.java

@@ -70,7 +70,7 @@ public class TbGoodsCartService extends ServiceImpl<TbGoodsCartMapper, TbGoodsCa
 		Long id = goodsCartInfoDto.getBuyUserId();
 		//获取购买者对象
 		AppUserDto appUser = adminInterface.getAppUserById(id);
-		if(appUser == null)return AjaxJson.getError("购买者账号异常");
+		if(appUser == null || appUser.getId() == null)return AjaxJson.getError("购买者账号异常");
 		//获取商品对象
 		Long infoId = goodsCartInfoDto.getSaleGoodsInfoId();
 		TbGoodsTransit tbGoodsTransit = tbGoodsTransitMapper.selectById(infoId);
@@ -98,7 +98,7 @@ public class TbGoodsCartService extends ServiceImpl<TbGoodsCartMapper, TbGoodsCa
 		//执行保存
 		int insert = tbGoodsCartMapper.insert(tbGoodsCart);
 		//判断保存结果
-		if(insert != 1)AjaxJson.getError("购物车保存失败!");
+		if(insert != 1)throw new RuntimeException("添加购物车失败!");
 		return AjaxJson.getSuccess("添加购物车成功!");
 	}
 

sp-service/level-one-server/src/main/java/com/pj/tb_goods_transit/TbGoodsTransitService.java

@@ -246,17 +246,18 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
 		String declareOdd = tbGoodsTransit.getDeclareOdd();
 		TbGoods tbGoods = tbGoodsMapper.selectById(declareOdd);
 		if(tbGoods == null)throw new RuntimeException("当前商品已海关不允许销售!");
-		//执行采购,创建一级市场订单表
+		//执行采购,创建一级市场订单表 , 该方法只是设置tbOrder的属性
 		TbOrder tbOrder = methodGoodsTransitService.setTbOrderProperties(tbGoodsTransit, appLoginInfo);
 
-		//查询是否已存在该订单
-		List<TbOrder> tbOrderList = tbOrderMapper.selectList(new LambdaQueryWrapper<TbOrder>().eq(TbOrder::getGoodsId, tbGoodsTransit.getId()));
-		if(tbOrderList.size() != 0)throw new RuntimeException("当前商品已存在订单,暂时无法继续下单!");
+//		//查询是否已存在该订单
+//		List<TbOrder> tbOrderList = tbOrderMapper.selectList(new LambdaQueryWrapper<TbOrder>().eq(TbOrder::getGoodsId, tbGoodsTransit.getId()));
+//		if(tbOrderList.size() != 0)throw new RuntimeException("当前商品已存在订单,暂时无法继续下单!");
 
-		//执行保存
+		//执行保存 创建订单
 		int insert = tbOrderMapper.insert(tbOrder);
 		if(insert == 1){
 			// todo: 执行订单完成后的逻辑
+
 			// todo: 发送短信给边民组通知其确认
 			//获取互市组ID
 			Long groupId = list.get(0).getId();
@@ -269,11 +270,13 @@ public class TbGoodsTransitService extends ServiceImpl<TbGoodsTransitMapper, TbG
 							.eq(TbPeople::getDeleteStatus, DeleteStatus.DELETE_STATUS_ON.getCode()));
 
 			if(tbPeopleList.size() == 0)throw new RuntimeException("订单异常,原因是没有关联的边民!!!");
-			int sendSms = methodGoodsTransitService.sendSms(tbPeopleList);
-			if(sendSms != tbPeopleList.size()){
+			int sendSmsCounts = methodGoodsTransitService.sendSms(tbPeopleList);
+			if(sendSmsCounts != tbPeopleList.size()){
 				//todo: 如果短信发送成功次数 与 边民数不一致处理
+
 			}
 
+
 		}
 
 		return false;

sp-service/level-one-server/src/main/java/com/pj/tb_people/TbPeopleService.java

@@ -9,6 +9,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.pj.api.client.admin.AdminInterface;
 import com.pj.api.dto.AppUserDto;
+import com.pj.current.dto.PCLoginUserInfo;
 import com.pj.current.satoken.StpUserUtil;
 import com.pj.enummj.DeleteStatus;
 import com.pj.enummj.IsLock;
@@ -89,13 +90,10 @@ public class TbPeopleService extends ServiceImpl<TbPeopleMapper, TbPeople> imple
 	 * 审核
 	 */
 	boolean judge(TbPeople tbPeople){
-		//获取当前登陆人 todo:
-//		String loginUser = "admin";
-		Long id = StpUserUtil.getLoginIdAsLong();
 		//获取登录人
-		AppUserDto appUserById = adminInterface.getAppUserById(id);
+		PCLoginUserInfo appUserById = StpUserUtil.getPCLoginInfo();
 		if(appUserById == null)throw new RuntimeException("当前登录人账号已失效,请重新登录~");
-		String loginUser = appUserById.getName();
+		String loginUser = appUserById.getLoginName();
 		//获取当前被审核人的编号和审核情况
 		Long currId = tbPeople.getId();
 		Integer judgeStatus = tbPeople.getJudgeStatus();
@@ -138,11 +136,10 @@ public class TbPeopleService extends ServiceImpl<TbPeopleMapper, TbPeople> imple
 		int i = tbPeopleMapper.updateById(tbPeople1);
 		//远程调用停用app user表中的边民账号
 		int lock = adminInterface.isLock(id.toString(), People.PEOPLE_TYPE_ONE.getCode(), isLock);
-		//todo: 处理远程调用后的返回结果
-//		if((lock + i) != 2)throw new RuntimeException("停用失败!");
-//
-//		return i == 1 && lock == 1;
-		return true;
+		// 处理远程调用后的返回结果
+		if((lock + i) != 2)throw new RuntimeException("停用失败!");
+
+		return i == 1 && lock == 1;
 	}
 
 	/**

sp-service/level-two-server/src/main/java/com/pj/tb_orders/TbOrdersService.java

@@ -60,8 +60,8 @@ public class TbOrdersService extends ServiceImpl<TbOrdersMapper, TbOrders> imple
 		TbPurchaser tbPurchaser = tbPurchaserMapper.selectById(appLoginInfo.getLoginId());
 		if(tbPurchaser == null)throw new ServiceException("您的身份不是收购商!");
 		//执行查询
-		so.set("create_by",appLoginInfo.getLoginId());
-		so.set("keyword",keyword);
+		so.set("create_by",appLoginInfo.getLoginId()); // 订单创建人为收购商
+		so.set("keyword",keyword); // 后期可根据关键字进行聚合模糊匹配查询
 		so.set("sortType",22);
 		//todo: 管理二级市场收购商的订单
 

sp-service/sp-admin/src/main/java/com/pj/project/app_user/AppUserController.java

@@ -94,12 +94,11 @@ public class AppUserController {
 
 	/** 启/停边民的app账号登陆限制 */
 	@RequestMapping("rpc/isLock")
-	public AjaxJson isLock(@RequestParam("id") String id,
+	public int isLock(@RequestParam("id") String id,
 						   @RequestParam("type") Integer type,
 						   @RequestParam("status") Integer status) {
 		int lock = appUserService.isLock(id,type,status);
-		if(lock == 1) return AjaxJson.getSuccess(lock + "");
-		return AjaxJson.getError();
+		return lock;
 	}
 
 	/** 查单个app有效用户 - 根据id */

sp-service/transport-server/src/main/java/com/pj/project/tb_orders/TbOrdersUtil.java

@@ -1,91 +1,91 @@
-package com.pj.project.tb_orders;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import com.pj.utils.sg.*;
-
-/**
- * 工具类：tb_orders -- 订单表
- * @author loovi 
- *
- */
-@Component
-public class TbOrdersUtil {
-
-	
-	/** 底层 Mapper 对象 */
-	public static TbOrdersMapper tbOrdersMapper;
-	@Autowired
-	private void setTbOrdersMapper(TbOrdersMapper tbOrdersMapper) {
-		TbOrdersUtil.tbOrdersMapper = tbOrdersMapper;
-	}
-	
-	
-	/** 
-	 * 将一个 TbOrders 对象进行进行数据完整性校验 (方便add/update等接口数据校验) [G] 
-	 */
-	static void check(TbOrders t) {
-		AjaxError.throwByIsNull(t.getId(), "[货运订单管理表主键] 不能为空");		// 验证: 货运订单管理表主键 
-		AjaxError.throwByIsNull(t.getLevelOneOrderId(), "[一级市场订单ID] 不能为空");		// 验证: 一级市场订单ID 
-		AjaxError.throwByIsNull(t.getOrderNo(), "[订单编号] 不能为空");		// 验证: 订单编号 
-		AjaxError.throwByIsNull(t.getGoodsId(), "[商品id] 不能为空");		// 验证: 商品id 
-		AjaxError.throwByIsNull(t.getGoodsName(), "[商品名称] 不能为空");		// 验证: 商品名称 
-		AjaxError.throwByIsNull(t.getGoodsFrom(), "[商品来源] 不能为空");		// 验证: 商品来源(国家) 
-		AjaxError.throwByIsNull(t.getShipperPhone(), "[发货商电话] 不能为空");		// 验证: 发货商电话 
-		AjaxError.throwByIsNull(t.getShipperName(), "[发货商名称] 不能为空");		// 验证: 发货商名称 
-		AjaxError.throwByIsNull(t.getDriverId(), "[司机ID] 不能为空");		// 验证: 司机ID 
-		AjaxError.throwByIsNull(t.getDriverName(), "[司机名称] 不能为空");		// 验证: 司机名称 
-		AjaxError.throwByIsNull(t.getDriverPhone(), "[司机电话] 不能为空");		// 验证: 司机电话 
-		AjaxError.throwByIsNull(t.getCarId(), "[车型ID] 不能为空");		// 验证: 车型ID 
-		AjaxError.throwByIsNull(t.getCarType(), "[车型名称] 不能为空");		// 验证: 车型名称 
-		AjaxError.throwByIsNull(t.getConsigneeName(), "[收货人名称] 不能为空");		// 验证: 收货人名称 
-		AjaxError.throwByIsNull(t.getConsigneePhone(), "[收货人电话号码] 不能为空");		// 验证: 收货人电话号码 
-		AjaxError.throwByIsNull(t.getDeclarationNumber(), "[申报订单号] 不能为空");		// 验证: (预留字段) 申报订单号 
-		AjaxError.throwByIsNull(t.getOrderFinish(), "[订单状态已完成] 不能为空");		// 验证: 订单状态已完成 (0=禁用,1=启用) 
-		AjaxError.throwByIsNull(t.getCreateTime(), "[创建时间] 不能为空");		// 验证: 创建时间 
-		AjaxError.throwByIsNull(t.getCreateBy(), "[创建人编号] 不能为空");		// 验证: 创建人编号 
-		AjaxError.throwByIsNull(t.getCreateName(), "[创建人名称] 不能为空");		// 验证: 创建人名称 
-		AjaxError.throwByIsNull(t.getUpdateTime(), "[更新时间] 不能为空");		// 验证: 更新时间 
-		AjaxError.throwByIsNull(t.getUpdateBy(), "[更新人编号] 不能为空");		// 验证: 更新人编号 
-		AjaxError.throwByIsNull(t.getUpdateName(), "[更新人名称] 不能为空");		// 验证: 更新人名称 
-		AjaxError.throwByIsNull(t.getDeleteStatus(), "[删除状态] 不能为空");		// 验证: 删除状态(0=禁用,1=启用) 
-	}
-
-	/** 
-	 * 获取一个TbOrders (方便复制代码用) [G] 
-	 */ 
-	static TbOrders getTbOrders() {
-		TbOrders t = new TbOrders();	// 声明对象 
-		t.setId(0L);		// 货运订单管理表主键 
-		t.setLevelOneOrderId(0L);		// 一级市场订单ID 
-		t.setOrderNo("");		// 订单编号 
-		t.setGoodsId(0L);		// 商品id 
-		t.setGoodsName("");		// 商品名称 
-		t.setGoodsFrom("");		// 商品来源(国家) 
-		t.setShipperPhone("");		// 发货商电话 
-		t.setShipperName("");		// 发货商名称 
-		t.setDriverId(0L);		// 司机ID 
-		t.setDriverName("");		// 司机名称 
-		t.setDriverPhone("");		// 司机电话 
-		t.setCarId(0L);		// 车型ID 
-		t.setCarType("");		// 车型名称 
-		t.setConsigneeName("");		// 收货人名称 
-		t.setConsigneePhone("");		// 收货人电话号码 
-		t.setDeclarationNumber("");		// (预留字段) 申报订单号 
-		t.setOrderFinish(0);		// 订单状态已完成 (0=禁用,1=启用) 
-		t.setCreateTime("");		// 创建时间 
-		t.setCreateBy("");		// 创建人编号 
-		t.setCreateName("");		// 创建人名称 
-		t.setUpdateTime("");		// 更新时间 
-		t.setUpdateBy("");		// 更新人编号 
-		t.setUpdateName("");		// 更新人名称 
-		t.setDeleteStatus(0);		// 删除状态(0=禁用,1=启用) 
-		return t;
-	}
-	
-	
-	
-	
-	
-}
+//package com.pj.project.tb_orders;
+//
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.stereotype.Component;
+//
+//import com.pj.utils.sg.*;
+//
+///**
+// * 工具类：tb_orders -- 订单表
+// * @author loovi
+// *
+// */
+//@Component
+//public class TbOrdersUtil {
+//
+//
+//	/** 底层 Mapper 对象 */
+//	public static TbOrdersMapper tbOrdersMapper;
+//	@Autowired
+//	private void setTbOrdersMapper(TbOrdersMapper tbOrdersMapper) {
+//		TbOrdersUtil.tbOrdersMapper = tbOrdersMapper;
+//	}
+//
+//
+//	/**
+//	 * 将一个 TbOrders 对象进行进行数据完整性校验 (方便add/update等接口数据校验) [G]
+//	 */
+//	static void check(TbOrders t) {
+//		AjaxError.throwByIsNull(t.getId(), "[货运订单管理表主键] 不能为空");		// 验证: 货运订单管理表主键
+//		AjaxError.throwByIsNull(t.getLevelOneOrderId(), "[一级市场订单ID] 不能为空");		// 验证: 一级市场订单ID
+//		AjaxError.throwByIsNull(t.getOrderNo(), "[订单编号] 不能为空");		// 验证: 订单编号
+//		AjaxError.throwByIsNull(t.getGoodsId(), "[商品id] 不能为空");		// 验证: 商品id
+//		AjaxError.throwByIsNull(t.getGoodsName(), "[商品名称] 不能为空");		// 验证: 商品名称
+//		AjaxError.throwByIsNull(t.getGoodsFrom(), "[商品来源] 不能为空");		// 验证: 商品来源(国家)
+//		AjaxError.throwByIsNull(t.getShipperPhone(), "[发货商电话] 不能为空");		// 验证: 发货商电话
+//		AjaxError.throwByIsNull(t.getShipperName(), "[发货商名称] 不能为空");		// 验证: 发货商名称
+//		AjaxError.throwByIsNull(t.getDriverId(), "[司机ID] 不能为空");		// 验证: 司机ID
+//		AjaxError.throwByIsNull(t.getDriverName(), "[司机名称] 不能为空");		// 验证: 司机名称
+//		AjaxError.throwByIsNull(t.getDriverPhone(), "[司机电话] 不能为空");		// 验证: 司机电话
+//		AjaxError.throwByIsNull(t.getCarId(), "[车型ID] 不能为空");		// 验证: 车型ID
+//		AjaxError.throwByIsNull(t.getCarType(), "[车型名称] 不能为空");		// 验证: 车型名称
+//		AjaxError.throwByIsNull(t.getConsigneeName(), "[收货人名称] 不能为空");		// 验证: 收货人名称
+//		AjaxError.throwByIsNull(t.getConsigneePhone(), "[收货人电话号码] 不能为空");		// 验证: 收货人电话号码
+//		AjaxError.throwByIsNull(t.getDeclarationNumber(), "[申报订单号] 不能为空");		// 验证: (预留字段) 申报订单号
+//		AjaxError.throwByIsNull(t.getOrderFinish(), "[订单状态已完成] 不能为空");		// 验证: 订单状态已完成 (0=禁用,1=启用)
+//		AjaxError.throwByIsNull(t.getCreateTime(), "[创建时间] 不能为空");		// 验证: 创建时间
+//		AjaxError.throwByIsNull(t.getCreateBy(), "[创建人编号] 不能为空");		// 验证: 创建人编号
+//		AjaxError.throwByIsNull(t.getCreateName(), "[创建人名称] 不能为空");		// 验证: 创建人名称
+//		AjaxError.throwByIsNull(t.getUpdateTime(), "[更新时间] 不能为空");		// 验证: 更新时间
+//		AjaxError.throwByIsNull(t.getUpdateBy(), "[更新人编号] 不能为空");		// 验证: 更新人编号
+//		AjaxError.throwByIsNull(t.getUpdateName(), "[更新人名称] 不能为空");		// 验证: 更新人名称
+//		AjaxError.throwByIsNull(t.getDeleteStatus(), "[删除状态] 不能为空");		// 验证: 删除状态(0=禁用,1=启用)
+//	}
+//
+//	/**
+//	 * 获取一个TbOrders (方便复制代码用) [G]
+//	 */
+//	static TbOrders getTbOrders() {
+//		TbOrders t = new TbOrders();	// 声明对象
+//		t.setId(0L);		// 货运订单管理表主键
+//		t.setLevelOneOrderId(0L);		// 一级市场订单ID
+//		t.setOrderNo("");		// 订单编号
+//		t.setGoodsId(0L);		// 商品id
+//		t.setGoodsName("");		// 商品名称
+//		t.setGoodsFrom("");		// 商品来源(国家)
+//		t.setShipperPhone("");		// 发货商电话
+//		t.setShipperName("");		// 发货商名称
+//		t.setDriverId(0L);		// 司机ID
+//		t.setDriverName("");		// 司机名称
+//		t.setDriverPhone("");		// 司机电话
+//		t.setCarId(0L);		// 车型ID
+//		t.setCarType("");		// 车型名称
+//		t.setConsigneeName("");		// 收货人名称
+//		t.setConsigneePhone("");		// 收货人电话号码
+//		t.setDeclarationNumber("");		// (预留字段) 申报订单号
+//		t.setOrderFinish(0);		// 订单状态已完成 (0=禁用,1=启用)
+//		t.setCreateTime("");		// 创建时间
+//		t.setCreateBy("");		// 创建人编号
+//		t.setCreateName("");		// 创建人名称
+//		t.setUpdateTime("");		// 更新时间
+//		t.setUpdateBy("");		// 更新人编号
+//		t.setUpdateName("");		// 更新人名称
+//		t.setDeleteStatus(0);		// 删除状态(0=禁用,1=启用)
+//		return t;
+//	}
+//
+//
+//
+//
+//
+//}