警员调岗接口的修改

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/dto/A.java

-package com.junmp.jyzb.api.bean.dto;
-
-import lombok.Data;
-
-import java.util.List;
-
-@Data
-public class A {
-    private List<Object[]> a;
-}

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/dto/AccountingDto.java

+package com.junmp.jyzb.api.bean.dto;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+//存储记账的信息
+@Data
+public class AccountingDto {
+    //号型id
+    private String sizeId;
+    //类型id
+    private String typeId;
+    //单价
+    private BigDecimal price;
+    //记账数量
+    private Integer modifyQuantity;
+}

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/dto/ReassignmentDto.java

@@ -43,6 +43,7 @@ public class ReassignmentDto  {
      */
     private Long orgId;
 
+    private String orgName;
     /**
      * 警员
      */

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/query/PoliceReassignmentReq.java

-package com.junmp.jyzb.api.bean.query;
-
-import com.junmp.jyzb.api.bean.req.FormEqsReq;
-import com.junmp.v2.common.bean.request.ValidationApi;
-import lombok.Data;
-
-import javax.validation.constraints.NotBlank;
-import javax.validation.constraints.NotNull;
-import java.util.List;
-
-
-//警员调岗
-@Data
-public class PoliceReassignmentReq {
-    //调岗警员id
-    @NotBlank(message = "警员id不能为空",groups = {ValidationApi.edit.class})
-    private String id;
-    //目标组织机构id
-    @NotNull(message = "目标组织机构id不能为空",groups = {ValidationApi.edit.class})
-    private Long goalOrgId;
-    //需要带走的装备信息列表
-    private List<FormEqsReq> eqsReqList;
-
-    //调岗原因
-    private String note;
-    //工作流id
-
-}

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/query/ProcessReq/PoliceEquipmentReq.java

+package com.junmp.jyzb.api.bean.query.ProcessReq;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+@Data
+public class PoliceEquipmentReq {
+    /**
+     * 主键
+     */
+    private String id;
+
+    /**
+     * 警员ID
+     */
+    private String policeId;
+
+    private String policeName;
+
+    /**
+     * 装备号型id
+     */
+    private String sizeId;
+
+    /**
+     *装备号型名称
+     */
+    private String sizeName;
+
+    /**
+     * 装备类型id
+     */
+    private String typeId;
+
+    /**
+     *装备类型名称
+     */
+    private String typeName;
+
+    /**
+     * 装备数量
+     */
+    private Integer num;
+
+    /**
+     * 组织机构ID
+     */
+    private Long orgId;
+
+    //装备单价
+    private BigDecimal price;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    private List<PoliceEquipmentReq> list;
+}

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/query/QueryReassignmentReq.java

+package com.junmp.jyzb.api.bean.query;
+
+import com.junmp.v2.common.bean.request.BaseRequest;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+
+//警员调岗
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class QueryReassignmentReq extends BaseRequest {
+    /**
+     * id
+     */
+    private String id;
+
+    /**
+     * 经办人
+     */
+    private String userId;
+
+    /**
+     * 工作流id
+     */
+    private String processDefinitionId;
+
+    /**
+     * 调岗警员id
+     */
+    private String policeId;
+
+    /**
+     * 调岗警员姓名
+     */
+    private String policeName;
+
+    /**
+     * 警员带走装备
+     */
+    private String eqsList;
+
+    /**
+     * 组织机构id（警员原组织机构id）
+     */
+    private Long orgId;
+
+    private String orgName;
+
+    /**
+     * 警员编号
+     */
+    private String policeCode;
+
+    /**
+     * 调岗原因
+     */
+    private String note;
+
+    /**
+     * 审核状态(none未接入工作流，working审批中，finished审批完成)
+     */
+    private String examineState;
+    /**
+     * 申请时间
+     */
+    private Date applyTime;
+    /**
+     * 开始时间
+     */
+    private Date startTime;
+    /**
+     * 结束时间
+     */
+    private Date endTime;
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 创建人员
+     */
+    private String createUser;
+
+    /**
+     * 更新人员
+     */
+    private String updateUser;
+
+    /**
+     * 排序规则
+     */
+    private String order;
+    /**
+     * 排序字段
+     */
+    private String column;
+
+}

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/req/UpdateOrderReq.java

@@ -38,7 +38,6 @@ public class UpdateOrderReq extends BaseRequest implements Serializable {
     /**
      * 单据业务类型
      */
-//    @IsDateTime(format = "yyyy-MM-dd HH:mm:ss", message = "字段必须是有效的日期或时间")
     private String  bussinessType;
     /**
      * 订单号

jyzb-api/src/main/java/com/junmp/jyzb/api/bean/req/UpdateReassignmentReq.java

@@ -44,6 +44,8 @@ public class UpdateReassignmentReq extends BaseRequest {
      */
     private Long orgId;
 
+    private String orgName;
+
     /**
      * 警员编号
      */
@@ -58,15 +60,11 @@ public class UpdateReassignmentReq extends BaseRequest {
      * 审核状态(none未接入工作流，working审批中，finished审批完成)
      */
     private String examineState;
-
     /**
-     * 开始时间
+     * 申请时间
      */
-    private Date startTime;
-    /**
-     * 结束时间
-     */
-    private Date endTime;
+    private Date applyTime;
+
     /**
      * 创建时间
      */
@@ -87,12 +85,4 @@ public class UpdateReassignmentReq extends BaseRequest {
      */
     private String updateUser;
 
-    /**
-     * 排序规则
-     */
-    private String order;
-    /**
-     * 排序字段
-     */
-    private String column;
 }

jyzb-biz/src/main/java/com/junmp/jyzb/controller/OutAndInboundController.java

@@ -35,8 +35,7 @@ public class OutAndInboundController {
 
     @Resource
     public LogSummaryService logSummaryService;
-    @Resource
-    private InventorySummaryService inventorySummaryService;
+
 
 
     @Resource
@@ -71,8 +70,8 @@ public class OutAndInboundController {
     }
 
     @PostMapping("/OutInRecords")
-    public ApiRes<Boolean> OutInRecords(@RequestBody RabbitMqOrderReq req){
-        return ApiRes.success(inventorySummaryService.processInventoryRecords(req));
+    public ApiRes<Boolean> OutInRecords(@RequestBody OutInLogsReq req){
+        return ApiRes.success(logSummaryService.processInventoryRecords(req));
     }
 
 }

jyzb-biz/src/main/java/com/junmp/jyzb/controller/PoliceController.java

@@ -4,8 +4,8 @@ import cn.hutool.core.util.ObjectUtil;
 import com.junmp.jyzb.api.bean.dto.PolicemanDto;
 import com.junmp.jyzb.api.bean.dto.ReassignmentDto;
 import com.junmp.jyzb.api.bean.query.CabinetReq;
-import com.junmp.jyzb.api.bean.query.PoliceReassignmentReq;
 import com.junmp.jyzb.api.bean.query.PolicemanReq;
+import com.junmp.jyzb.api.bean.query.QueryReassignmentReq;
 import com.junmp.jyzb.api.bean.req.UpdatePolicemanReq;
 import com.junmp.jyzb.api.bean.req.UpdateReassignmentReq;
 import com.junmp.jyzb.entity.EquipmentSize;
@@ -194,13 +194,6 @@ public class PoliceController {
         return ApiRes.success(policemanService.UpdatePoliceInfo(req));
     }
 
-    //获取警员的装备信息
-    @PostMapping("/GetPoliceEquipment")
-    @ApiOperation("获取警员装备信息")
-    public ApiRes<PageResult<PoliceEquipment>> GetPoliceEqs(@RequestBody PolicemanReq req){
-        return ApiRes.success(policemanService.GetPoliceEqs(req));
-    }
-
     //将警员和user一一对应并且关系表也一一对应
     @PostMapping("/UpdatePoliceUser")
     @ApiOperation("将警员关系一一对应")
@@ -217,7 +210,7 @@ public class PoliceController {
 
     @PostMapping("/ShowReassignmentPage")
     @ApiOperation("查看警员调岗申请单")
-    public ApiRes<PageResult<ReassignmentDto>> ShowReassignmentPage(@RequestBody UpdateReassignmentReq req){
+    public ApiRes<PageResult<ReassignmentDto>> ShowReassignmentPage(@RequestBody QueryReassignmentReq req){
         return ApiRes.success(policemanService.ShowReassignmentPage(req));
     }
 
@@ -227,4 +220,12 @@ public class PoliceController {
         return ApiRes.success(policemanService.changePoliceOrg(req));
     }
 
+
+    //获取警员的装备信息
+    @PostMapping("/GetPoliceEquipment")
+    @ApiOperation("获取警员装备信息")
+    public ApiRes<List<PoliceEquipment>> GetPoliceEqs(@RequestBody QueryReassignmentReq req){
+        return ApiRes.success(policemanService.GetPoliceEqs(req));
+    }
+
 }

jyzb-biz/src/main/java/com/junmp/jyzb/controller/TestController.java

 package com.junmp.jyzb.controller;
 
-import com.junmp.jyzb.api.bean.dto.A;
+import com.junmp.jyzb.api.bean.query.ProcessReq.PoliceEquipmentReq;
 import com.junmp.jyzb.api.bean.query.TestReq;
-import com.junmp.jyzb.api.bean.req.RabbitMqOrderReq;
 import com.junmp.jyzb.entity.InventorySummary;
+import com.junmp.jyzb.entity.PoliceEquipment;
 import com.junmp.jyzb.service.InventorySummaryService;
+import com.junmp.jyzb.service.PoliceEquipmentService;
 import com.junmp.jyzb.service.TestService;
 import com.junmp.jyzb.utils.ResponseResult;
 import com.junmp.v2.common.bean.response.ApiRes;
-import io.swagger.annotations.ApiOperation;
-import liquibase.pro.packaged.B;
+import com.junmp.v2.common.util.BeanPlusUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -19,6 +19,7 @@ import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.stream.Collectors;
 
 @RestController
 @Slf4j
@@ -31,6 +32,9 @@ public class TestController {
     private InventorySummaryService inventorySummaryService;
 
     @Resource
+    private PoliceEquipmentService policeEquipmentService;
+
+    @Resource
     private RabbitAdmin rabbitAdmin;
     @RequestMapping("/hello")
     public ResponseResult Hello(){
@@ -42,10 +46,6 @@ public class TestController {
 //        return ApiRes.success(testService.test(req));
 //    }
 
-    @PostMapping("/test")
-    public ApiRes<Boolean> test(@RequestBody RabbitMqOrderReq req){
-        return ApiRes.success(inventorySummaryService.processInventoryRecords(req));
-    }
 
     @PostMapping("/hasConsumers")
     public ApiRes<Boolean> hasConsumers(@RequestBody TestReq req){
@@ -54,9 +54,13 @@ public class TestController {
         return ApiRes.success(execute>0L);
     }
 
-    @PostMapping("/selectByItem")
-    public ApiRes<List<InventorySummary>> selectByItem(@RequestBody A a){
-
-        return ApiRes.success(inventorySummaryService.selectByItems(a.getA()));
+    @PostMapping("addPoliceEqs")
+    public ApiRes<Boolean> addPoliceEqs(@RequestBody PoliceEquipmentReq req){
+        List<PoliceEquipment> collect = req.getList().stream().map(policeEquipmentReq -> {
+            PoliceEquipment policeEquipment = new PoliceEquipment();
+            BeanPlusUtil.copyProperties(policeEquipmentReq, policeEquipment);
+            return policeEquipment;
+        }).collect(Collectors.toList());
+        return ApiRes.success(policeEquipmentService.saveBatch(collect));
     }
 }

jyzb-biz/src/main/java/com/junmp/jyzb/entity/PoliceEquipment.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import java.io.Serializable;
+import java.math.BigDecimal;
 import java.util.Date;
 
 import io.swagger.annotations.ApiModelProperty;
@@ -31,6 +32,9 @@ public class PoliceEquipment implements Serializable {
     @TableField("police_id")
     private String policeId;
 
+    @TableField("police_name")
+    private String policeName;
+
     /**
      * 装备号型id
      */
@@ -67,6 +71,10 @@ public class PoliceEquipment implements Serializable {
     @TableField("org_id")
     private Long orgId;
 
+    //装备单价
+    @TableField("price")
+    private BigDecimal price;
+
     /**
      * 更新时间
      */

jyzb-biz/src/main/java/com/junmp/jyzb/entity/Reassignment.java

@@ -55,6 +55,9 @@ public class Reassignment implements Serializable {
     @TableField(value = "org_id")
     private Long orgId;
 
+    @TableField(value = "org_name")
+    private String orgName;
+
     /**
      * 警员
      */

jyzb-biz/src/main/java/com/junmp/jyzb/listener/GlobalEndListener.java

@@ -102,7 +102,7 @@ import java.util.stream.Collectors;
                     busForm.setExamineState("finished");
                     busFormService.updateById(busForm);
                 }
-                if (Type.equals("reassigment")){//调岗
+                if (Type.equals("reassigment")){//调岗申请单
                     Reassignment one = reassignmentService.getOne(new LambdaQueryWrapper<Reassignment>()
                             .eq(Reassignment::getProcessId, processInstanceId));
                     UpdateReassignmentReq updateReassignmentReq = new UpdateReassignmentReq();

jyzb-biz/src/main/java/com/junmp/jyzb/mapper/InventorySummaryMapper.java

@@ -35,5 +35,7 @@ public interface InventorySummaryMapper  extends BaseMapper<InventorySummary> {
     List<InventorySummary> selectByEqs(@Param("orgId") Long orgId);
 
 
+    //出入库时无单据查询库存汇总并统计更新或者记账时根据单据查询库存汇总并统计更新
     List<InventorySummary> selectByItems(@Param("list") List<Object[]> searchCriteria);
+
 }
\ No newline at end of file

jyzb-biz/src/main/java/com/junmp/jyzb/rabbitmq/OrderMQReceiver.java

-package com.junmp.jyzb.rabbitmq;
-
-import com.junmp.jyzb.api.bean.req.RabbitMqOrderReq;
-import com.junmp.jyzb.service.InventorySummaryService;
-import com.rabbitmq.client.Channel;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.amqp.support.AmqpHeaders;
-import org.springframework.messaging.handler.annotation.Header;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-import java.io.IOException;
-
-/**
- * 装备出入库消息的监听
- */
-@Component
-
-public class OrderMQReceiver {
-
-    @Resource
-    private InventorySummaryService inventorySummaryService;
-
-    @RabbitListener(queues = "11111")//监听队列名
-    private void a(RabbitMqOrderReq req, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag){
-
-        try {
-            System.out.println("req = " + req);
-            //将消息进行消费
-            Boolean result = inventorySummaryService.processInventoryRecords(req);
-            if (result){
-                // 手动确认消息
-                channel.basicAck(deliveryTag, false);
-            }else {
-                channel.basicNack(deliveryTag, false, true);
-            }
-            // 手动确认消息
-            channel.basicAck(deliveryTag, false);
-        } catch (Exception e) {
-            // 处理消息过程中发生异常，拒绝消息并将其重新放回队列
-            try {
-                channel.basicNack(deliveryTag, false, true);
-            } catch (IOException ex) {
-                throw new RuntimeException(ex);
-            }
-        }
-    }
-}

jyzb-biz/src/main/java/com/junmp/jyzb/service/InventorySummaryService.java

@@ -22,8 +22,6 @@ public interface InventorySummaryService extends IService<InventorySummary> {
     //根据条件查询装备汇总信息，用于出库单的选择装备
     List<InventorySumDto> GetInventorySumInfo(InventorySumReq req);
 
-    //处理本地主机返回单据结果
-    Boolean processInventoryRecords(RabbitMqOrderReq req);
     //对summary表中数据进行重新计算装备信息汇总
     Boolean updateSummaryInsByOrder(Long orgId);
 
@@ -36,6 +34,7 @@ public interface InventorySummaryService extends IService<InventorySummary> {
     //计算装备总数（装备数量数据统计）
     List<InventorySummary> EquipmentStatistics(InventorySumReq req);
 
-
+    //出入库时无单据查询库存汇总并统计更新或者记账时根据单据查询库存汇总并统计更新
     List<InventorySummary> selectByItems(List<Object[]> searchCriteria);
+
 }

jyzb-biz/src/main/java/com/junmp/jyzb/service/PolicemanService.java

@@ -4,8 +4,8 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.junmp.jyzb.api.bean.dto.PolicemanDto;
 import com.junmp.jyzb.api.bean.dto.ReassignmentDto;
 import com.junmp.jyzb.api.bean.query.CabinetReq;
-import com.junmp.jyzb.api.bean.query.PoliceReassignmentReq;
 import com.junmp.jyzb.api.bean.query.PolicemanReq;
+import com.junmp.jyzb.api.bean.query.QueryReassignmentReq;
 import com.junmp.jyzb.api.bean.req.UpdatePolicemanReq;
 import com.junmp.jyzb.api.bean.req.UpdateReassignmentReq;
 import com.junmp.jyzb.entity.PoliceEquipment;
@@ -72,11 +72,11 @@ public interface PolicemanService extends IService<Policeman> {
     //删除账号时同时对警员的信息进行更改操作
     boolean UpdatePoliceInfo(UserOrgReq req);
 
-    //警员调岗
+    //警员调岗(业务过程)
     boolean changePoliceOrg(UpdateReassignmentReq req);
 
     //获取警员的装备信息
-    PageResult<PoliceEquipment> GetPoliceEqs(PolicemanReq req);
+    List<PoliceEquipment> GetPoliceEqs(QueryReassignmentReq req);
 
     //警员调岗业务逻辑
     boolean UpdatePoliceUser();
@@ -85,7 +85,7 @@ public interface PolicemanService extends IService<Policeman> {
     String PoliceReassignment(UpdateReassignmentReq req);
 
     //查看警员调岗申请单
-    PageResult<ReassignmentDto> ShowReassignmentPage(UpdateReassignmentReq req);
+    PageResult<ReassignmentDto> ShowReassignmentPage(QueryReassignmentReq req);
 
     ////查询组织机构下的用户以及角色信息(也可以根据别的查询条件查询)
     PageResult<SysUserDto> ShowUserRole(SysUserReq req);

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/CabinetServiceImpl.java

@@ -292,7 +292,6 @@ public class CabinetServiceImpl extends ServiceImpl<CabinetMapper, Cabinet> impl
      * @param req
      * @return
      */
-    @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean updateCabinetInfo(UpdateCabinetReq req) {
         //查询传入的组织机构id是否存在
@@ -371,7 +370,6 @@ public class CabinetServiceImpl extends ServiceImpl<CabinetMapper, Cabinet> impl
      * @return
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public boolean ChangeCabinetState(UpdateCabinetReq req) {
         //查询单警柜是否存在
         CabinetExist(req.getId());
@@ -407,7 +405,6 @@ public class CabinetServiceImpl extends ServiceImpl<CabinetMapper, Cabinet> impl
 
     //设置单警柜库存数量信息
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public boolean SetInventoryInfo(String id) {
         //统计单警柜总数，在库总数，出库总数，装备总价格
         cabinetMapper.SetInventoryInfo(id);

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/DestoryUnitServiceImpl.java

@@ -72,7 +72,6 @@ public class DestoryUnitServiceImpl extends ServiceImpl<DestoryUnitMapper, Desto
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public boolean delDestoryUnit(DestoryUnitReq req) {
         //抛出异常，销毁、报废单位未选中
         if (req.getDeleteList().size()==0){

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/InventoryServiceImpl.java

@@ -126,7 +126,6 @@ public class InventoryServiceImpl extends ServiceImpl<InventoryMapper, Inventory
 
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public boolean setInventoryMsg(){
         //查询字典表中的临近报废天数
         SysDictItem sysDictItem = sysDictItemService.getOne(new LambdaQueryWrapper<SysDictItem>()
@@ -169,7 +168,6 @@ public class InventoryServiceImpl extends ServiceImpl<InventoryMapper, Inventory
 
     //装备绑定箱门
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public boolean InventoryBind(EquipmentBindReq req) {
         //判断箱门是否存在
         CabinetBox cabinetBox = cabinetBoxService.CabinetBoxExist(req.getCabinetBoxId());
@@ -323,7 +321,9 @@ public class InventoryServiceImpl extends ServiceImpl<InventoryMapper, Inventory
                     inventoryDto.setOrgName(orgName);
                     //查询图片并返回
                     String photo = equipmentSizeService.getById(inventory.getSizeId()).getPhoto();
+                    if (photo != null){
                         inventoryDto.setPhoto(photo);
+                    }
                     return inventoryDto;
                 }).collect(Collectors.toList());
         Page<InventoryDto> page1 = PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize());
@@ -572,7 +572,7 @@ public class InventoryServiceImpl extends ServiceImpl<InventoryMapper, Inventory
         String typeName = equipmentTypeService.getOne(new LambdaQueryWrapper<EquipmentType>()
                 .eq(EquipmentType::getId, typeId)).getName();
         //如果有供应商id的前提下，设置supplierName
-        if (ObjectUtil.isNotNull(supplierId)){
+        if (ObjectUtil.isNotNull(supplierId) && !supplierId.trim().isEmpty()){
             String supplierName = supplierService.getOne(new LambdaQueryWrapper<Supplier>()
                     .eq(Supplier::getId, supplierId)).getName();
             map.put("supplierName",supplierName);

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/LogSummaryServiceImpl.java

@@ -112,6 +112,8 @@ public class LogSummaryServiceImpl extends ServiceImpl<LogSummaryMapper, LogSumm
             List<OrderDetail> collect = orderDetailList.stream().map(detailOrderReq -> {
                 OrderDetail orderDetail = new OrderDetail();
                 BeanPlusUtil.copyProperties(detailOrderReq, orderDetail);
+                //记账数量默认时识别数量
+                orderDetail.setModifyQuantity(detailOrderReq.getActualNum());
                 return orderDetail;
             }).collect(Collectors.toList());
             c=orderDetailService.updateBatchById(collect);
@@ -130,7 +132,6 @@ public class LogSummaryServiceImpl extends ServiceImpl<LogSummaryMapper, LogSumm
     }
 
     //对库存汇总表进行更新（只限于日常出入库）
-    @Transactional(rollbackFor = Exception.class)
     public boolean updateNumToSum(String outInState,List<NormalInOutDto> inventorySumDtos,String OutInState) {
 
         List<NormalInOutDto> groupedResult = inventorySumDtos.stream()
@@ -152,7 +153,7 @@ public class LogSummaryServiceImpl extends ServiceImpl<LogSummaryMapper, LogSumm
         List<Object[]> searchCriteria = new ArrayList<>();
         for (NormalInOutDto groupedDto : groupedResult) {
             Object[] criteria = new Object[]{groupedDto.getOrgId(), groupedDto.getLocationId(),
-                    groupedDto.getSizeId(), groupedDto.getTypeId(), groupedDto.getPrice()};
+                    groupedDto.getTypeId(),groupedDto.getSizeId(), groupedDto.getPrice()};
             searchCriteria.add(criteria);
         }
         //满足条件的数据
@@ -194,10 +195,6 @@ public class LogSummaryServiceImpl extends ServiceImpl<LogSummaryMapper, LogSumm
                     inventorySummary.setOutboundNumber(0);
                     inventorySummary.setUseNumber(0);
                     inventorySummary.setStockNumber(outDto.getNumber());
-                }else {
-                    inventorySummary.setOutboundNumber(0);
-                    inventorySummary.setUseNumber(outDto.getNumber());
-                    inventorySummary.setStockNumber(outDto.getNumber());
                 }
                 addList.add(inventorySummary);
             }
@@ -215,7 +212,6 @@ public class LogSummaryServiceImpl extends ServiceImpl<LogSummaryMapper, LogSumm
     }
 
     //对出入库记录进行存储
-   @Transactional(rollbackFor = Exception.class)
     public List<NormalInOutDto> saveInOutRecords(OutInLogsReq req) {
         //返回结果，用于日常出入库时计算更新库存汇总表
         List<NormalInOutDto> returnList=new ArrayList<>();

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/ManufacturerServiceImpl.java

@@ -69,7 +69,6 @@ public class ManufacturerServiceImpl extends ServiceImpl<ManufacturerMapper, Man
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public boolean delManufacturer(ManufacturerReq req) {
         //抛出异常，生产厂商未选中
         if (req.getDeleteList().size()==0){

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/PolicemanServiceImpl.java

@@ -18,8 +18,8 @@ import com.junmp.jyzb.api.bean.dto.PolicemanDto;
 import com.junmp.jyzb.api.bean.dto.ReassignmentDto;
 import com.junmp.jyzb.api.bean.dto.UserRoleDto;
 import com.junmp.jyzb.api.bean.query.CabinetReq;
-import com.junmp.jyzb.api.bean.query.PoliceReassignmentReq;
 import com.junmp.jyzb.api.bean.query.PolicemanReq;
+import com.junmp.jyzb.api.bean.query.QueryReassignmentReq;
 import com.junmp.jyzb.api.bean.req.FormEqsReq;
 import com.junmp.jyzb.api.bean.req.UpdatePolicemanReq;
 import com.junmp.jyzb.api.bean.req.UpdateReassignmentReq;
@@ -646,12 +646,10 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
 
     //获取警员下面的装备
     @Override
-    public PageResult<PoliceEquipment> GetPoliceEqs(PolicemanReq req) {
+    public List<PoliceEquipment> GetPoliceEqs(QueryReassignmentReq req) {
         LambdaQueryWrapper<PoliceEquipment> eq = new LambdaQueryWrapper<PoliceEquipment>()
-                .eq(PoliceEquipment::getPoliceId, req.getId());
-        Page<PoliceEquipment> page = policeEquipmentService
-                .page(PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize()), eq);
-        return PageResultFactory.createPageResult(page);
+                .eq(PoliceEquipment::getPoliceId, req.getPoliceId());
+        return policeEquipmentService.list(eq);
     }
 
 
@@ -688,8 +686,22 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
     //警员调岗申请
     @Override
     public String PoliceReassignment(UpdateReassignmentReq req) {
+        //判断是否有工作流id，如果有则将状态进行修改
+        if (ObjectUtil.isEmpty(req.getProcessDefinitionId())) {
+            req.setExamineState("none");
+        } else {
+            req.setExamineState("working");
+        }
         Reassignment reassignment = new Reassignment();
         BeanPlusUtil.copyProperties(req,reassignment);
+
+        //先判断该单据id是否存在，如果存在，进行更新操作即可
+        if (ObjectUtil.isNotNull(req.getId()) && ! req.getId().trim().isEmpty() && ObjectUtil.isEmpty(req.getProcessDefinitionId())){
+            reassignment.setUpdateTime(DateTimeUtil.getCurrentDateTime());
+            reassignmentService.updateById(reassignment);
+            return reassignment.getId();
+        }
+        reassignment.setCreateTime(DateTimeUtil.getCurrentDateTime());
         reassignmentService.save(reassignment);
         //执行工作流
         if (req.getExamineState().equals("working"))
@@ -701,14 +713,15 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
             startProcessInstanceDTO.setUserId(req.getUserId());
             String ProcessInstanceId= FlowInstanceService.startProcessInstanceById(startProcessInstanceDTO);
             reassignment.setProcessId(ProcessInstanceId);
-        }
             reassignmentService.updateById(reassignment);
+        }
         return reassignment.getId();
     }
 
     //查看警员调岗申请单
     @Override
-    public PageResult<ReassignmentDto> ShowReassignmentPage(UpdateReassignmentReq req) {
+    public PageResult<ReassignmentDto> ShowReassignmentPage(QueryReassignmentReq req) {
+
         //(如果传其他不是数据库字段参数或者排序规则不是deac或者asc可能会出现错误)
         if (ObjectUtil.isNotNull(req.getColumn()) && !req.getColumn().trim().isEmpty() &&
                 (req.getOrder().equalsIgnoreCase("asc")|| req.getOrder().equalsIgnoreCase("desc")) &&
@@ -719,8 +732,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
         }
         LambdaQueryWrapper<Reassignment> eq = new LambdaQueryWrapper<Reassignment>()
                 .eq(ObjectUtil.isNotNull(req.getOrgId()), Reassignment::getOrgId, req.getOrgId())
-//                .eq(ObjectUtil.isNotNull(req.getTargetOrgId()), Reassignment::getTargetOrgId, req.getTargetOrgId())
-                .eq(ObjectUtil.isNotNull(req.getExamineState()), Reassignment::getExamineState, req.getExamineState())
+                .eq(!req.getExamineState().equals("all"), Reassignment::getExamineState, req.getExamineState())
                 .like(ObjectUtil.isNotNull(req.getPoliceName()), Reassignment::getPoliceName, req.getPoliceName())
                 .ge(ObjectUtil.isNotNull(req.getStartTime()), Reassignment::getApplyTime, req.getStartTime())
                 .le(ObjectUtil.isNotNull(req.getEndTime()), Reassignment::getApplyTime, req.getEndTime())

jyzb-biz/src/main/resources/mapper/InventorySummaryMapper.xml

@@ -267,7 +267,7 @@
         select * from base_inventory_summary where
         <foreach collection="list" item="item"  separator="or">
             (
-            org_id_int = ${item[0]} AND location_id = '${item[1]}' AND size_id = '${item[2]}' AND type_id = ${item[3]} AND unit_price = ${item[4]}
+            org_id_int = ${item[0]} AND location_id = '${item[1]}' AND type_id = ${item[3]} AND size_id = '${item[2]}' AND unit_price = ${item[4]}
             )
         </foreach>
     </select>