package com.zy.third.erp.task;
|
|
import com.zy.common.service.erp.ErpSqlServer;
|
import com.zy.third.erp.entity.ItemTB;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
@Component
|
public class ERPItemScheduler {
|
@Value("${erp.enabled}")
|
private Boolean erpEnabled;
|
|
@Autowired
|
private ERPItemSchedulerMS erpItemSchedulerMS;
|
|
@Autowired
|
private ErpSqlServer erpSqlServer;
|
|
@Scheduled(cron = "${erp.refreshtime}")
|
public void ItemScheduler() {
|
if (!erpEnabled) return;
|
|
// String selectALL = "SELECT AutoId AS autoId,ItemId AS ItemID,ItemCode AS ItemCode,ItemName AS ItemName ,ItemSpc AS ItemSpc,ItemPic AS itemPic,ItemUnit AS ItemUnit,ItemKind AS ItemKind ,Remark AS remark ,Flag AS flag ,MakeDate AS makedate,Temp1 AS temp1,Temp2 AS temp2 ,Temp3 AS temp3 FROM dbo.erp_ItemTB";
|
// List<ItemTB> itemTBS = erpSqlServer.select(selectALL, ItemTB.class);
|
// List<ItemTB> itemTBS = erpSqlServer.selectAll(ItemTB.class);
|
|
String sqlItemTB = "select * from erp_ItemTB where LKName='中扬'";
|
List<ItemTB> itemTBS = erpSqlServer.select(sqlItemTB, ItemTB.class);
|
if (itemTBS != null && itemTBS.size() > 0) {
|
for (ItemTB itemTB : itemTBS) {
|
//00代表新增
|
if (itemTB.getFlag().equals("00")) {
|
erpItemSchedulerMS.addToMainDatabase(itemTB);
|
}
|
//22代表删除
|
if (itemTB.getFlag().equals("22")) {
|
erpItemSchedulerMS.deleteFromMainDatabase(itemTB);
|
}
|
moveToBak(itemTB);
|
}
|
}
|
}
|
|
/**
|
* 数据库里有触发器,当item表的数据被删除时,会自动向item_bak添加,不用卸载代码里
|
*
|
* @param itemTB
|
*/
|
//将数据从主表移动到bak表里
|
private void moveToBak(ItemTB itemTB) {
|
// ItemTBBak itemTBBak = new ItemTBBak();
|
// BeanUtils.copyProperties(itemTB, itemTBBak);
|
// itemTBBak.setDelDate(new Date());
|
// erpItemTBBakMapper.insert(itemTBBak);
|
erpSqlServer.update("delete from erp_ItemTB where LKName='中扬' and ItemId = '" + itemTB.getItemId() + "'");
|
// erpItemTBMapper.delete(new EntityWrapper<ItemTB>()
|
// .eq("ItemId",itemTB.getItemID()));
|
}
|
}
|