Merge remote-tracking branch 'origin/dev' into dev

src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java

@@ -43,10 +43,7 @@ import com.glxp.api.service.inout.*;
 import com.glxp.api.service.inv.*;
 import com.glxp.api.service.purchase.SupProductService;
 import com.glxp.api.service.system.SystemParamConfigService;
-import com.glxp.api.util.CustomUtil;
-import com.glxp.api.util.DateUtil;
-import com.glxp.api.util.GennerOrderUtils;
-import com.glxp.api.util.OrderNoTypeBean;
+import com.glxp.api.util.*;
 import com.glxp.api.util.udi.FilterUdiUtils;
 import com.glxp.api.util.udi.UdiCalCountUtil;
 import org.apache.commons.lang3.StringUtils;
@@ -495,7 +492,7 @@ public class IoCodeTempController extends BaseController {
 
         //校验预验收库存是否已存在
         if (bussinessTypeEntity.isScanPreIn()) {
-            if (bussinessTypeEntity.getBackPreinType() == 1) {//按单出库&& bussinessTypeEntity.isPreInBack()
+            if (bussinessTypeEntity.getBackPreinType() == 1 && bussinessTypeEntity.isPreInBack()) {//按单出库&& bussinessTypeEntity.isPreInBack()
                 String orderIds = addOrderRequest.getCheckPreInOrders();
                 if (StrUtil.isNotEmpty(orderIds)) {
                     String[] orderIdArray = orderIds.split(",");
@@ -1097,8 +1094,8 @@ public class IoCodeTempController extends BaseController {
         IoOrderDetailCodeEntity orderDetailCodeEntity = ioOrderDetailCodeService.findByUnique(orderEntity.getBillNo(), codeTempEntity.getRelId(), codeTempEntity.getBatchNo());
         if (orderDetailCodeEntity != null) {
             //扫码数量-1
-            int orderCount = orderDetailCodeEntity.getCount();
-            int orderReCount = orderDetailCodeEntity.getReCount();
+            int orderCount = IntUtil.value(orderDetailCodeEntity.getCount());
+            int orderReCount = IntUtil.value(orderDetailCodeEntity.getReCount());
             if (orderCount > 1) {
                 orderDetailCodeEntity.setCount(orderCount - 1);
                 orderDetailCodeEntity.setReCount(orderReCount - udiCalCountUtil.getActCount(codeTempEntity.getNameCode()));

src/main/java/com/glxp/api/controller/inout/IoOrderDetailBizController.java

@@ -555,7 +555,8 @@ public class IoOrderDetailBizController extends BaseController {
     @Log(title = "发票管理", businessType = BusinessType.DELETE)
     public BaseResponse deleteById(@RequestBody IoOrderInvoiceEntity ioOrderInvoiceEntity) {
 
-        ioOrderInvoiceService.deleteByInvId(ioOrderInvoiceEntity.getId()+"");
+        IoOrderInvoiceResponse ioOrderInvoiceResponse = orderDetailBizService.selectByinvoiceId(ioOrderInvoiceEntity.getId());
+
         //更改 登记状态
         IoOrderDetailCodeEntity ioOrderDetailBizEntity = new IoOrderDetailCodeEntity();
 
@@ -565,16 +566,16 @@ public class IoOrderDetailBizController extends BaseController {
 
         ioOrderDetailBizEntity.setOrderIdFk(ioOrderInvoiceEntity.getOrderIdFk());
 
-        ioOrderDetailBizEntity.setId(ioOrderInvoiceEntity.getRegId());
+        ioOrderDetailBizEntity.setId(ioOrderInvoiceResponse.getBizIdFk().intValue());
 
+        ioOrderInvoiceService.deleteByInvId(ioOrderInvoiceEntity.getId()+"");
         List<IoOrderInvoiceResponse> list = orderDetailBizService.filterListInv(filterOrderDetailBizRequest);
-        if (list == null && list.size() == 0) {
+        if(list.size()==0){
             ioOrderDetailBizEntity.setRegStatus(false);
         }
         orderDetailCodeService.updateOrderDetailBiz(ioOrderDetailBizEntity);
         return ResultVOUtils.success();
 
-
     }
 
     /**

src/main/java/com/glxp/api/controller/inout/IoOrderReviewController.java

@@ -139,7 +139,7 @@ public class IoOrderReviewController extends BaseController {
             }
 
             if (orderEntity.getFromType() == ConstantStatus.FROM_UDISP)
-                spGetHttp.reviewOrder(updateExportStatusRequest);
+                spGetHttp.reviewOrder(updateExportStatusRequest, getUserId() + "");
             return updateReview(getUser(), orderEntity);
         } else if (orderEntity.getStatus() == ConstantStatus.ORDER_STATUS_CHECK_SUCCESS) {
             return thirdUpdateReview(getUser(), orderEntity);
@@ -224,7 +224,6 @@ public class IoOrderReviewController extends BaseController {
                     acceptOrderEntity.setFinishAccept(true);
                     return ResultVOUtils.success(acceptOrderEntity);
                 }
-
                 return ResultVOUtils.success(acceptOrderEntity);
             }
 
@@ -269,14 +268,17 @@ public class IoOrderReviewController extends BaseController {
                     redisUtil.del(ConstantStatus.REDIS_BILLNO + orderEntity.getBillNo());
                     redisUtil.del(ConstantStatus.REDIS_BILLNO_CODES + orderEntity.getBillNo());
                     return ResultVOUtils.success("验收成功！");
-                } else
-
+                } else {
                     return updateReview(authAdmin, orderEntity);
                 }
-        } else
+            }
+        } else {
+
             return updateReview(authAdmin, orderEntity);
         }
 
+    }
+
     @Resource
     IBasicBussinessTypeService basicBussinessTypeService;
     @Resource

src/main/java/com/glxp/api/dao/inout/IoOrderDetailBizDao.java

@@ -24,6 +24,8 @@ public interface IoOrderDetailBizDao extends BaseMapperPlus<IoOrderDetailBizDao,
     List<IoOrderDetailCodeResponse> getfilterList(FilterOrderDetailCodeRequest orderDetailBizRequest);
 
     List<IoOrderInvoiceResponse> filterListInv(FilterOrderDetailBizRequest orderDetailBizRequest);
+    IoOrderInvoiceResponse selectByinvoiceId(Long id);
+
 
     /**
      * 查询单条单据业务详情

src/main/java/com/glxp/api/entity/basic/BasicBussinessTypeEntity.java

@@ -407,4 +407,9 @@ public class BasicBussinessTypeEntity {
     private boolean advancePreIn;
     @TableField(value = "sortNum")
     private Integer sortNum;
+
+    //是否按货位出库    0：不按货位出库，1:按货位出库
+    @TableField(value = "spaceOut")
+    private int spaceOut;
+
 }

src/main/java/com/glxp/api/entity/inout/IoCodeEntity.java

@@ -148,6 +148,7 @@ public class IoCodeEntity implements Serializable {
             return 0;
         return count;
     }
+
     @JsonIgnore
     public int getMyReCount() {
         if (reCount == null) {

src/main/java/com/glxp/api/entity/inout/IoOrderDetailCodeEntity.java

@@ -138,13 +138,13 @@ public class IoOrderDetailCodeEntity {
      * 单据数量
      */
     @TableField(value = "`count`")
-    private int count;
+    private Integer count;
 
     /**
      * 扫码数量
      */
     @TableField(value = "reCount")
-    private int reCount;
+    private Integer reCount;
 
     /**
      * 备注

src/main/java/com/glxp/api/entity/system/SyncDataBustypeEntity.java

@@ -24,4 +24,8 @@ public class SyncDataBustypeEntity {
     private Integer orderStatus;        //单据状态
     @TableField(value = "`direct`")
     private int direct;         //1:UDI管理系统->SPMS  2:SPMS->UDI管理系统
+    @TableField(value = "`syncStatus`")
+    private Integer syncStatus;       //同步后单据状态
+    @TableField(value = "`syncChange`")
+    private boolean syncChange;       //同步后是否自动补单
 }

src/main/java/com/glxp/api/http/sync/SpGetHttpClient.java

@@ -146,9 +146,15 @@ public class SpGetHttpClient {
     }
 
     //验收自助平台单据--直连接口
-    public BaseResponse<String> reviewOrder(ReviewFinishRequest reviewFinishRequest) {
+    public BaseResponse<String> reviewOrder(ReviewFinishRequest reviewFinishRequest, String userId) {
+
+
+        List<String> header = (List<String>) Convert.toList(buildHeader());
+        header.add("ADMIN_ID");
+        header.add(userId);
+
         String json = JSONUtil.toJsonStr(reviewFinishRequest);
-        String result = okHttpCli.doPostJson(getIpUrl() + "/directToSpms" + "/spms/inout/order/web/updateStatus", json, buildHeader());
+        String result = okHttpCli.doPostJson(getIpUrl() + "/directToSpms" + "/spms/inout/order/web/updateStatus", json,  Convert.toStrArray(header));
         BaseResponse<String> response =
                 JSONObject.parseObject(result, new TypeReference<BaseResponse<String>>() {
                 });
@@ -158,6 +164,8 @@ public class SpGetHttpClient {
 
     //    最小销售标识获取国家库信息
     public BaseResponse<PageSimpleResponse<ProductInfoEntity>> getSyncDi(ProductInfoFilterRequest productInfoFilterRequest) {
+
+
         Map<String, String> paramMap = new HashMap<>(16);
         paramMap.put("nameCode", productInfoFilterRequest.getNameCode());
         paramMap.put("page", productInfoFilterRequest.getPage() + "");

src/main/java/com/glxp/api/res/basic/BasicBussinessTypeResponse.java

@@ -1,6 +1,5 @@
 package com.glxp.api.res.basic;
 
-import com.baomidou.mybatisplus.annotation.TableField;
 import lombok.Data;
 
 /**
@@ -151,4 +150,6 @@ public class BasicBussinessTypeResponse {
     private Integer backPreinType;
     private Boolean advancePreIn;
     private Integer sortNum;
+
+    private int spaceOut;
 }

src/main/java/com/glxp/api/res/inout/IoOrderInvoiceResponse.java

@@ -83,6 +83,8 @@ public class IoOrderInvoiceResponse {
 
     private String ggxh;
     private String licenseUrl;
+    private Long bizIdFk;
+
 
 
     public static final String COL_ID = "id";

src/main/java/com/glxp/api/service/auth/impl/InvSpaceServiceImpl.java

@@ -71,7 +71,7 @@ public class InvSpaceServiceImpl extends ServiceImpl<InvSpaceDao, InvSpace> impl
         //获取当前仓库下的最大货位编码
         String maxSpaceCode = invSpaceDao.getMaxSpaceCode(null);
         if (StrUtil.isBlank(maxSpaceCode)) {
-            maxSpaceCode = "0000";
+            maxSpaceCode = "1000";
         }
         String spaceCode = getSpaceCode(maxSpaceCode);
         invSpace.setCode(spaceCode);

src/main/java/com/glxp/api/service/inout/IoChangeInoutService.java

@@ -86,6 +86,9 @@ public class IoChangeInoutService {
     //普通出入库单据流转
     public void genNewOrder(IoOrderEntity orderEntity, List<InvProductDetailEntity> invProductDetailEntities) {
 
+        if (orderEntity.getFromType() == ConstantStatus.FROM_UDISP && (orderEntity.getOutChangeEnable() != null && !orderEntity.getOutChangeEnable())) {
+            return;
+        }
         BasicBusTypePreEntity basicBusTypePreEntity = basicBusTypePreService.findByOriginAction(orderEntity.getAction());
         List<IoCodeEntity> codeEnttities = codeService.findByOrderId(orderEntity.getBillNo());
         if (basicBusTypePreEntity.getSupplementAll()) {//全量补单

src/main/java/com/glxp/api/service/inout/IoOrderDetailBizService.java

@@ -44,6 +44,7 @@ public interface IoOrderDetailBizService {
     List<IoOrderDetailBizEntity> checkOrderList(String orderId);
 
     List<IoOrderInvoiceResponse> filterListInv(FilterOrderDetailBizRequest orderDetailBizRequest);
+    IoOrderInvoiceResponse selectByinvoiceId(Long id);
 
     Boolean updateOrderDetailBiz(IoOrderDetailBizEntity ioOrderDetailBizEntity);
 

src/main/java/com/glxp/api/service/inout/impl/IoOrderDetailBizServiceImpl.java

@@ -175,6 +175,11 @@ public class IoOrderDetailBizServiceImpl implements IoOrderDetailBizService {
         return ioOrderDetailBizDao.filterListInv(orderDetailBizRequest);
     }
 
+    @Override
+    public IoOrderInvoiceResponse selectByinvoiceId(Long id) {
+        return ioOrderDetailBizDao.selectByinvoiceId(id);
+    }
+
     @Override
     public Boolean updateOrderDetailBiz(IoOrderDetailBizEntity ioOrderDetailBizEntity) {
         return ioOrderDetailBizDao.updateById(ioOrderDetailBizEntity) > 0;

src/main/java/com/glxp/api/service/inout/impl/IoOrderServiceImpl.java

@@ -739,6 +739,7 @@ public class IoOrderServiceImpl implements IoOrderService {
             //查询往来单位名称
             if (StrUtil.isNotBlank(order.getFromCorp())) {
                 BasicCorpEntity corpEntity = basicCorpDao.selectByErpId(order.getFromCorp());
+                if (corpEntity != null)
                     response.setFromCorpName(corpEntity.getName());
             } else if (StrUtil.isNotBlank(order.getFromInvCode())) {
                 String fromInvName = invWarehouseDao.selectNameByCode(order.getFromInvCode());

src/main/java/com/glxp/api/service/sync/HeartService.java

@@ -1309,6 +1309,8 @@ public class HeartService {
         return ResultVOUtils.success();
     }
 
+    @Resource
+    SyncDataBustypeService syncDataBustypeService;
 
     //下载最近更新扫码单据--上级服务
     @Transactional(propagation = Propagation.NESTED)
@@ -1344,22 +1346,36 @@ public class HeartService {
                             try {
                                 List<IoOrderEntity> orderEntities = syncDataResponse.getOrderEntities();
                                 for (IoOrderEntity orderEntity : orderEntities) {
+
+                                    SyncDataBustypeEntity syncDataBustypeEntity = syncDataBustypeService.findByAction(orderEntity.getAction(), 2);
                                     orderEntity.setUpdateTime(null);
                                     orderEntity.setFromType(ConstantStatus.FROM_UDISP);
                                     orderEntity.setProcessStatus(ConstantStatus.ORDER_DEAL_POST);
                                     orderEntity.setStatus(ConstantStatus.ORDER_STATUS_PROCESS);
+                                    if (syncDataBustypeEntity != null) {
+                                        if (syncDataBustypeEntity.getSyncStatus() == 1) {
+                                            orderEntity.setProcessStatus(ConstantStatus.ORDER_DEAL_DRAFT);
+                                            orderEntity.setStatus(ConstantStatus.ORDER_STATUS_TEMP_SAVE);
+                                        }
+                                        if (syncDataBustypeEntity.isSyncChange()) {
+                                            orderEntity.setOutChangeEnable(syncDataBustypeEntity.isSyncChange());
+                                        }
+                                    }
                                     IoOrderEntity temp = orderService.findByBillNo(orderEntity.getBillNo());
                                     if (temp == null) {
                                         orderEntity.setId(null);
                                         orderService.insertOrder(orderEntity);
                                         insetOrderDb(syncDataResponse, orderEntity);
                                         orderEntity = orderService.findByBillNo(orderEntity.getBillNo());
+                                        if (orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_TEMP_SAVE) {
                                             addInoutService.dealProcess(orderEntity);
                                             orderEntity = orderService.findByBillNo(orderEntity.getBillNo());
                                             if (orderEntity.getStatus() != ConstantStatus.ORDER_STATS_ERROR && !ioCheckInoutService.checkManual(orderEntity.getBillNo())) {
                                                 ioCheckInoutService.check(orderEntity.getBillNo());
                                             }
                                         }
+
+                                    }
                                 }
                                 if (fileJson != null && fileJson.size() > 0) {
                                     List<String> syncFiles = fileJson.toList(String.class);

src/main/java/com/glxp/api/service/sync/SyncDataBustypeService.java

@@ -10,6 +10,9 @@ public interface SyncDataBustypeService extends IService<SyncDataBustypeEntity>
 
     List<SyncDataBustypeEntity> findAll(Integer direct);
 
+    SyncDataBustypeEntity findByAction(String action, Integer direct);
+
+
     boolean deleteAll(Integer direct);
 
     void inserts(List<SyncDataBustypeEntity> syncDataBustypeEntities);

src/main/java/com/glxp/api/service/sync/impl/SyncDataBustypeServiceImpl.java

@@ -1,5 +1,6 @@
 package com.glxp.api.service.sync.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.glxp.api.dao.sync.SyncDataBustypeDao;
@@ -23,6 +24,17 @@ public class SyncDataBustypeServiceImpl extends ServiceImpl<SyncDataBustypeDao,
         return syncDataBustypeDao.selectList(new QueryWrapper<SyncDataBustypeEntity>().eq("direct", direct));
     }
 
+    @Override
+    public SyncDataBustypeEntity findByAction(String action, Integer direct) {
+
+
+        List<SyncDataBustypeEntity> syncDataBustypeEntities = syncDataBustypeDao.selectList(new QueryWrapper<SyncDataBustypeEntity>().eq(direct != null, "direct", direct).eq("action", action));
+        if (CollUtil.isNotEmpty(syncDataBustypeEntities)) {
+            return syncDataBustypeEntities.get(0);
+        }
+        return null;
+    }
+
     @Override
     public boolean deleteAll(Integer direct) {
         return syncDataBustypeDao.delete(new QueryWrapper<SyncDataBustypeEntity>().eq("direct", direct)) > 0 ? true : false;

src/main/java/com/glxp/api/util/IntUtil.java

@@ -0,0 +1,18 @@
+package com.glxp.api.util;
+
+public class IntUtil {
+
+    public static int value(Integer value) {
+        if (value == null)
+            return 0;
+        else return value.intValue();
+
+    }
+
+    public static long value(Long value) {
+        if (value == null)
+            return 0l;
+        else return value.longValue();
+
+    }
+}

src/main/resources/mybatis/mapper/auth/InvSpaceDao.xml

@@ -390,11 +390,12 @@
     </select>
 
     <select id="getMaxSpaceCode" resultType="java.lang.String">
-        select max(code)
-        from auth_space
+        select max(CONVERT(code, signed))
+        from auth_space;
         <where>
             <if test="invCode != null and invCode != ''">
-                and invWarehouseCode = #{invCode}
+                and invWarehouseCode =
+                    #{invCode}
             </if>
         </where>
     </select>

src/main/resources/mybatis/mapper/basic/BasicBussinessTypeDao.xml

@@ -73,7 +73,7 @@
                                    thrCheckPdaUn, thrCheckPdaEd, thrCheckUdims, thrCheckPc, thrCheckSp,
                                    thrCheckChange, thrCheckBalance, thrCheckCopy, fillCodeRel, checkVailDate,
                                    checkExpire, checkCertExpire, preInBackAction, backPreinType,
-                                   sortNum)
+                                   sortNum, spaceOut)
         values (#{mainAction}, #{action}, #{name}, #{enable}, #{remark}, #{thirdSysFk}, #{genUnit}, #{innerOrder},
                 #{secCheckEnable}, #{checkEnable}, #{checkUdims}, #{checkPdaEd}, #{checkPdaUn}, #{checkPc},
                 #{checkWebNew}, #{checkSp}, #{checkChange}, #{secCheckUdims}, #{secCheckPdaEd}, #{secCheckPdaUn},
@@ -86,7 +86,7 @@
                 #{thrCheckPdaUn}, #{thrCheckPdaEd}, #{thrCheckUdims}, #{thrCheckPc}, #{thrCheckSp},
                 #{thrCheckChange}, #{thrCheckBalance}, #{thrCheckCopy}, #{fillCodeRel}, #{checkVailDate},
                 #{checkExpire}, #{checkCertExpire}, #{preInBackAction}, #{backPreinType},
-                #{sortNum})
+                #{sortNum}, #{spaceOut})
     </insert>
 
     <select id="selectBusList" resultType="com.glxp.api.entity.basic.BasicBussinessTypeEntity">

src/main/resources/mybatis/mapper/inout/IoOrderDetailBizDao.xml

@@ -23,6 +23,11 @@
         group by io_order_detail_biz.id
     </select>
 
+    <select id="selectByinvoiceId" parameterType="java.lang.Long"  resultType="com.glxp.api.res.inout.IoOrderInvoiceResponse">
+        select * from io_order_invoice where id= #{id}
+    </select>
+
+
 
     <select id="getfilterList" resultType="com.glxp.api.res.inout.IoOrderDetailCodeResponse">
         select io_order_detail_code.*,

src/main/resources/mybatis/mapper/system/SyncDataBustypeDao.xml

@@ -11,13 +11,13 @@
 
     <insert id="inserts" parameterType="com.glxp.api.entity.system.SyncDataBustypeEntity" useGeneratedKeys="true">
         replace INTO sync_data_bustypes
-                (id, `action`, `name`, outChange, orderStatus, direct)
+                (id, `action`, `name`, outChange, orderStatus, direct, syncStatus, syncChange)
                 values
 
         <foreach collection="syncDataBustypeEntities" item="item" index="index"
                  separator=",">
             (#{item.id}, #{item.action}, #{item.name},
-             #{item.outChange}, #{item.orderStatus}, #{item.direct})
+             #{item.outChange}, #{item.orderStatus}, #{item.direct}, #{item.syncStatus}, #{item.syncChange})
         </foreach>
     </insert>
 </mapper>

src/main/resources/schemas/schema_v2.1.sql

@@ -409,3 +409,6 @@ CALL Pro_Temp_ColumnWork('inv_place_order_detail', 'supId', 'varchar(255)', 1);
 CALL Pro_Temp_ColumnWork('inv_place_order_detail', 'expireDate', 'varchar(255)', 1);
 CALL Pro_Temp_ColumnWork('inv_place_order_detail', 'produceDate', 'varchar(255)', 1);
 CALL Pro_Temp_ColumnWork('inv_place_order_detail', 'serialNo', 'varchar(255)', 1);
+CALL Pro_Temp_ColumnWork('sync_data_bustypes', 'syncStatus', 'tinyint', 1);
+CALL Pro_Temp_ColumnWork('sync_data_bustypes', 'syncChange', 'tinyint', 1);
+CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'spaceOut', 'tinyint', 1);